zh

src/main/java/com/zh/project0512/controller/manage/TaskController.java

@@ -82,6 +82,7 @@ public class TaskController {
         if (LocalDateTime.now().isAfter(task.getStart())) {
             task.setStatus(1);
         }
+        task.setCreatAt(LocalDateTime.now());
         taskService.save(task);
         int id = task.getId();
         List tagList = task.getTagList();
@@ -373,6 +374,47 @@ public class TaskController {
         return Result.success(res);
     }
 
+    @Operation(summary = "任务传播数据")
+    @PostMapping("taskEffect")
+    @adminTokenValid
+    public Result taskEffect(@Validated @RequestBody DetTaskParam param) {
+        List<Map> maps = taskService.taskEffectData(new QueryWrapper<>());
+        JSONObject res = (JSONObject) JSONObject.toJSON(maps);
+        if(maps!=null) {
+            QueryWrapper<Task> qw = new QueryWrapper<>();
+            qw.groupBy("t1.userId");
+            res.put("userEffect", taskService.taskEffectData(qw));
+        }
+        return Result.success(res);
+    }
+
+    @Data
+    static class TaskUserParam {
+        @NotNull(message = "id不能为空")
+        @Min(value = 1, message = "id最小值为1")
+        @Schema(title = "任务id")
+        private Integer id;
+        @NotNull(message = "用户id不能为空")
+        @Schema(title = "用户id")
+        private Integer userId;
+    }
+
+    @Operation(summary = "任务内员工传播数据")
+    @PostMapping("taskUserEffect")
+    @adminTokenValid
+    public Result taskUserEffect(@Validated @RequestBody TaskUserParam param) {
+        QueryWrapper<Task> qw = new QueryWrapper<>();
+        qw.eq("userId",param.getUserId()).groupBy("t1.userId");
+        List<Map> maps = taskService.taskEffectData(qw);
+        JSONObject res = (JSONObject) JSONObject.toJSON(maps);
+        if(maps!=null) {
+            QueryWrapper<Video> qw2 = new QueryWrapper<>();
+            qw2.eq("taskId",param.getId()).eq("userId",param.getUserId());
+            res.put("userEffect", videoService.list(qw2));
+        }
+        return Result.success(res);
+    }
+
     @Data
     static class CNListParam {
         @Schema(title = "姓名")

src/main/java/com/zh/project0512/controller/manage/VideoController.java

@@ -142,7 +142,7 @@ public class VideoController {
         up.set(param.getCollectionNum() != null, "collectionNum", param.getCollectionNum());
         up.set(param.getCommentNum() != null, "commentNum", param.getCommentNum());
         up.set(param.getReSendNum() != null, "reSendNum", param.getReSendNum());
-        up.set(param.getRecommendNum() != null, "recommendNum", param.getRecommendNum());
+            up.set(param.getRecommendNum() != null, "recommendNum", param.getRecommendNum());
         up.set("status", 2);
         int a = 0;
         List<VideoEffectSetting> list = videoEffectSettingService.list();

src/main/java/com/zh/project0512/mapper/TaskMapper.java

@@ -57,4 +57,13 @@ public interface TaskMapper extends BaseMapper<Task> {
     IPage<Integer> idList(IPage iPage,String openid, List<Integer> tagIdList, List<Integer> brandIdList, @Param("ew") Wrapper<Reference> queryWrapper);
     List<Map> list(String openid,List<Integer> list, List<Integer> tagIdList, List<Integer> brandIdList, @Param("ew") Wrapper<Reference> queryWrapper);
     Task detailById(String openid,int id);
+
+    @Select("SELECT SUM(t1.playNum) as playNumSum,SUM(t1.commendNum) as commendNumSum,\n" +
+        "SUM(t1.collectionNum) as collectionNumSum,SUM(t1.commentNum) as commentNumSum,\n" +
+        "SUM(t1.reSendNum) as reSendNumSum,SUM(t1.recommendNum) as recommendNumSum,SUM(t1.effectResult) as effectResultSum,t1.userId,\n" +
+        "t2.title as taskTitle,t3.name as userName,t4.name as departmentName from video as t1 INNER JOIN task as t2 on t2.id = 31 and t2.id = t1.taskId\n" +
+        "LEFT JOIN user as t3 on t1.userId = t3.id\n" +
+        "LEFT JOIN qywxDepartment as t4 on t3.main_department = t4.departmentId " +
+        "${ew.customSqlSegment}")
+    List<Map> taskEffectData(@Param("ew") Wrapper<Task> queryWrapper);
 }

src/main/java/com/zh/project0512/service/ITaskService.java

@@ -23,4 +23,5 @@ public interface ITaskService extends IService<Task> {
     IPage<Integer> idList(IPage iPage,String openid, List<Integer> tagIdList, List<Integer> brandIdList, @Param("ew") Wrapper<Reference> queryWrapper);
     List<Map> list(String openid,List<Integer> list, List<Integer> tagIdList, List<Integer> brandIdList, @Param("ew") Wrapper<Reference> queryWrapper);
     Task detailById(String openid,int id);
+    List<Map> taskEffectData(@Param("ew") Wrapper<Task> queryWrapper);
 }

src/main/java/com/zh/project0512/serviceImpl/TaskServiceImpl.java

@@ -39,4 +39,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements IT
     public Task detailById(String openid,int id){
        return taskMapper.detailById(openid,id);
     }
+    public List<Map> taskEffectData(@Param("ew") Wrapper<Task> queryWrapper){
+        return taskMapper.taskEffectData(queryWrapper);
+    }
 }