Skip to content

spring-simple-operation
spring-simple-operation
Commit 66a691ef by kk
Options

17443-摄影刷数据

parent 29588cff
Showing with 145 additions and 6 deletions
src/main/java/cn/kk/spring_simple_operation/mapper/PhotoProgressMapper.java
......@@ -24,4 +24,8 @@ public interface PhotoProgressMapper extends BaseMapper<PhotoProgress> {
List<PhotoSkuInfo> getSkuInfo(@Param("developerNumList") List<String> developerNumList);
List<PhotoSkuInfo> getSkuInfo2();
List<PhotoSkuInfo> getPhotoSkuInfo(@Param("skuList") List<String> skuList);
List<PhotoSkuInfo> getPhotoSkuSimpleVideoStatus(@Param("skuList") List<String> l);
}
src/main/java/cn/kk/spring_simple_operation/model/dto/SkuSiteDTO.java
......@@ -16,5 +16,11 @@ public class SkuSiteDTO {
@Excel(name = "站点")
private String site;
@Excel(name = "编号")
private String number;
@Excel(name = "人员")
private String name;
}
src/main/java/cn/kk/spring_simple_operation/model/vo/PhotoSkuInfo.java
package cn.kk.spring_simple_operation.model.vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
......@@ -25,4 +26,12 @@ public class PhotoSkuInfo {
private String dept;
@ApiModelProperty("简易视频摄影名字")
private String simpleVideoPhotographerName;
@ApiModelProperty("简易视频摄影编号")
private String simpleVideoPhotographerNum;
private Integer simpleVideoStatus;
}
src/main/java/cn/kk/spring_simple_operation/service/PhotoProgressService.java
......@@ -21,4 +21,8 @@ public interface PhotoProgressService extends IService<PhotoProgress> {
void getVideoSkuArea();
void brushSimpleVideoData();
void brushSimpleVideoDataPeople(List<SkuSiteDTO> list);
void brushSimpleVideoDataStatus(List<SkuSiteDTO> list);
}
src/main/java/cn/kk/spring_simple_operation/service/impl/PhotoProgressServiceImpl.java
......@@ -262,7 +262,8 @@ public class PhotoProgressServiceImpl extends ServiceImpl<PhotoProgressMapper, P
.setSimpleVideoPhotographerName(visualDesigner.getUserName())
.setSimpleVideoPhotographerNum(visualDesigner.getVisualNumber());
content += "根据开发地区修改简易视频师为：" + visualDesigner.getUserName();
} else {
}
else {
return;
}
......@@ -297,4 +298,79 @@ public class PhotoProgressServiceImpl extends ServiceImpl<PhotoProgressMapper, P
}
log.info("修改简易视频任务状态成功，共修改{}条数据！", updateList.size());
}
@Override
public void brushSimpleVideoDataPeople(List<SkuSiteDTO> list) {
if (CollectionUtils.isEmpty(list)) return;
Integer currentTimeSecond = DateUtils.getCurrentTimeSecond();
list.stream().collect(Collectors.groupingBy(SkuSiteDTO::getNumber))
.forEach((number, ls) -> {
Lists.partition(ls, 500).forEach(l -> {
List<VisualDesignLog> logList = new ArrayList<>();
List<PhotoProgressPerson> photoProgressPersonList = new ArrayList<>();
SkuSiteDTO skuSiteDTO = l.get(0);
List<PhotoSkuInfo> photoSkuInfoList = baseMapper.getPhotoSkuInfo(l.stream().map(SkuSiteDTO::getSku).collect(Collectors.toList()));
photoSkuInfoList.forEach(p -> {
PhotoProgressPerson photoProgressPerson = new PhotoProgressPerson();
photoProgressPerson.setId(p.getId())
.setSimpleVideoPhotographerName(skuSiteDTO.getName())
.setSimpleVideoPhotographerNum(skuSiteDTO.getNumber())
;
photoProgressPersonList.add(photoProgressPerson);
logList.add(new VisualDesignLog()
.setId(IdWorker.getId())
.setOperationKey("photo_progress")
.setOperationContent(String.format("简易视频摄影师由[%s]修改为[%s]", p.getSimpleVideoPhotographerName(), skuSiteDTO.getName()))
.setRelationId(p.getId())
.setOperationType("simple_video_photographer_num")
.setCreateTime(currentTimeSecond)
.setCreateId(0)
.setCreateName("job")
);
});
if (!CollectionUtils.isEmpty(photoProgressPersonList)) {
photoProgressPersonService.updateBatchById(photoProgressPersonList);
visualDesignLogService.saveBatch(logList);
log.info("本次修改简易视频师成功，共修改{}条数据！", photoProgressPersonList.size());
}
});
});
}
@Override
public void brushSimpleVideoDataStatus(List<SkuSiteDTO> list) {
if (CollectionUtils.isEmpty(list)) return;
Integer currentTimeSecond = DateUtils.getCurrentTimeSecond();
List<String> skuList = list.stream().map(SkuSiteDTO::getSku).collect(Collectors.toList());
Lists.partition(skuList, 500).forEach(l -> {
List<VisualDesignLog> logList = new ArrayList<>();
List<PhotoProgressPerson> photoProgressPersonList = new ArrayList<>();
List<PhotoSkuInfo> photoSkuInfoList = baseMapper.getPhotoSkuSimpleVideoStatus(l);
photoSkuInfoList.forEach(p -> {
PhotoProgressPerson photoProgressPerson = new PhotoProgressPerson();
photoProgressPerson.setId(p.getId())
.setSimpleVideoStatus(StatusEnum.PHOTOGRAPHY_NO_NEED_HANDLE.getCode())
;
photoProgressPersonList.add(photoProgressPerson);
logList.add(new VisualDesignLog()
.setId(IdWorker.getId())
.setOperationKey("photo_progress")
.setOperationContent(String.format("简易视频摄影状态由[%s]修改为[%s]", StatusEnum.get(p.getSimpleVideoStatus()), StatusEnum.PHOTOGRAPHY_NO_NEED_HANDLE.getMessage()))
.setRelationId(p.getId())
.setOperationType("simple_video_status")
.setCreateTime(currentTimeSecond)
.setCreateId(0)
.setCreateName("job")
);
});
if (!CollectionUtils.isEmpty(photoProgressPersonList)) {
photoProgressPersonService.updateBatchById(photoProgressPersonList);
visualDesignLogService.saveBatch(logList);
log.info("本次修改简易视频摄影状态成功，共修改{}条数据！", photoProgressPersonList.size());
}
});
}
}
src/main/resources/mapper/PhotoProgressMapper.xml
......@@ -65,4 +65,32 @@
WHERE ppp.is_change_simple_video_status = 1
GROUP BY pp.sku
</select>
<select id="getPhotoSkuInfo" resultType="cn.kk.spring_simple_operation.model.vo.PhotoSkuInfo">
SELECT
pp.id,
pp.sku,
ppp.simple_video_photographer_name,
ppp.simple_video_photographer_num
FROM
photo_progress pp
INNER JOIN photo_progress_person ppp ON ppp.id = pp.id
where pp.sku in
<foreach collection="skuList" item="item" open="(" separator="," close=")">
#{item}
</foreach>
group by pp.sku
</select>
<select id="getPhotoSkuSimpleVideoStatus" resultType="cn.kk.spring_simple_operation.model.vo.PhotoSkuInfo">
SELECT
pp.id,
ppp.simple_video_status
FROM
photo_progress pp
INNER JOIN photo_progress_person ppp ON ppp.id = pp.id
where pp.sku in
<foreach collection="skuList" item="item" open="(" separator="," close=")">
#{item}
</foreach>
group by pp.sku
</select>
</mapper>
src/test/java/cn/kk/spring_simple_operation/ApplicationTest.java
......@@ -3,6 +3,7 @@ package cn.kk.spring_simple_operation;
import cn.kk.spring_simple_operation.mapper.PhotoProgressMapper;
import cn.kk.spring_simple_operation.model.dto.BrandAccountDto;
import cn.kk.spring_simple_operation.model.dto.SkuPeopleNameDto;
import cn.kk.spring_simple_operation.model.dto.SkuSiteDTO;
import cn.kk.spring_simple_operation.model.vo.PhotoSkuInfo;
import cn.kk.spring_simple_operation.model.vo.PublishInfoVo;
import cn.kk.spring_simple_operation.service.*;
......@@ -57,15 +58,26 @@ public class ApplicationTest {
//brushSimpleVideoData();
exportAPlusPublishData();
//exportAPlusPublishData();
brushSimpleVideoData_2();
}
private void exportAPlusPublishData() throws Exception {
List<PublishInfoVo> publishInfoVos = aPlusProductService.exportAPlusPublishData();
ExcelUtil<PublishInfoVo> util = new ExcelUtil<>(PublishInfoVo.class);
util.exportExcelFile(publishInfoVos, "运营导数据-20250618.xlsx");
private void brushSimpleVideoData_2() throws Exception {
File file = new File("2025-06-30_vkai_2025老产品补拍简易视频进度.xlsx");
ExcelUtil<SkuSiteDTO> util = new ExcelUtil<SkuSiteDTO>(SkuSiteDTO.class);
List<SkuSiteDTO> list = util.importExcel("指定人员", Files.newInputStream(file.toPath()));
photoProgressService.brushSimpleVideoDataPeople(list);
list = util.importExcel("前台有视频的 刷成简易视频不需要处理", Files.newInputStream(file.toPath()));
photoProgressService.brushSimpleVideoDataStatus(list);
}
//private void exportAPlusPublishData() throws Exception {
// List<PublishInfoVo> publishInfoVos = aPlusProductService.exportAPlusPublishData();
// ExcelUtil<PublishInfoVo> util = new ExcelUtil<>(PublishInfoVo.class);
// util.exportExcelFile(publishInfoVos, "运营导数据-20250618.xlsx");
//}
//private void brushSimpleVideoData() {
// photoProgressService.brushSimpleVideoData();
//}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment