Merge branch 'feature' into 'dev'

Feature

See merge request !11

src/main/java/com/zhiwei/brandkbs2/auth/AuthAspect.java

@@ -5,7 +5,7 @@ import com.zhiwei.brandkbs2.common.GenericAttribute;
 import com.zhiwei.brandkbs2.model.CommonCodeEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.UserInfo;
-import com.zhiwei.brandkbs2.service.IUserService;
+import com.zhiwei.brandkbs2.service.UserService;
 import com.zhiwei.middleware.auth.util.JwtUtil;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.Signature;
@@ -40,7 +40,7 @@ public class AuthAspect {
     private String jwtKey;
 
     @Resource(name = "userServiceImpl")
-    private IUserService iUserService;
+    private UserService UserService;
 
     @Pointcut("execution(com.zhiwei.brandkbs2.model.ResponseResult com.zhiwei.brandkbs2.controller..*.*(..))")
 //  @Pointcut("within(com.zhiwei.brandkbs2.controller..*)")
@@ -73,7 +73,7 @@ public class AuthAspect {
             return unAuthenticatedResponse(response, noAuth, joinPoint);
         }
         String uid = tokenInfo.get(GenericAttribute.USER_ID).toString();
-        UserInfo userInfo = iUserService.queryUserInfo(uid, request.getHeader("pid"));
+        UserInfo userInfo = UserService.queryUserInfo(uid, request.getHeader("pid"));
         if (!noAuth && null == userInfo) {
             return unAuthoriseResponse(response);
         }

src/main/java/com/zhiwei/brandkbs2/common/GenericAttribute.java

@@ -7,6 +7,7 @@ package com.zhiwei.brandkbs2.common;
  * @date: 2022-04-21 10:10
  */
 public class GenericAttribute {
+
     private GenericAttribute() {
     }
 
@@ -24,12 +25,22 @@ public class GenericAttribute {
      **/
     public static final String ES_IND_FULL_TEXT = "ind_full_text";
     /**
+     * es followers_num
+     */
+    public static final String ES_FOLLOWERS_NUM = "followers_num";
+    /**
+     * es rootSource
+     **/
+    public static final String ES_ROOT_SOURCE = "root_source";
+    /**
      * es gid
      **/
     public static final String ES_GID = "gid";
     public static final String ES_CNAME = "cname";
     /** es c2 **/
     public static final String ES_C2 = "c2";
+    /** es c4 **/
+    public static final String ES_C4 = "c4";
     /** es c5 **/
     public static final String ES_C5 = "c5";
     /** es foreign **/

src/main/java/com/zhiwei/brandkbs2/common/GlobalPojo.java

 package com.zhiwei.brandkbs2.common;
 
-import com.zhiwei.brandkbs2.service.ISystemInfoService;
+import com.zhiwei.brandkbs2.service.SystemInfoService;
 import com.zhiwei.qbjc.bean.pojo.common.MessagePlatform;
 import com.zhiwei.qbjc.bean.pojo.common.Tag;
 import org.apache.logging.log4j.LogManager;
@@ -26,7 +26,7 @@ public class GlobalPojo {
     public static final Logger log = LogManager.getLogger(GlobalPojo.class);
 
     @Resource(name = "systemInfoServiceImpl")
-    private ISystemInfoService systemInfoService;
+    private SystemInfoService systemInfoService;
 
     /**
      * 监测系统平台

src/main/java/com/zhiwei/brandkbs2/common/RedisKeyPrefix.java

@@ -15,6 +15,8 @@ public class RedisKeyPrefix {
     private RedisKeyPrefix() {
     }
 
+    private static final String SEPARATOR = ":";
+
     public static final String MARK_ANALYZE_SUMMARY = "BRANDKBS:MARK:ANALYZE_SUMMARY:";
     public static final String MARK_PLATFORM_PROPORTION = "BRANDKBS:MARK:PLATFORM_PROPORTION:";
     public static final String MARK_SPREAD = "BRANDKBS:MARK:SPREAD:";
@@ -22,7 +24,12 @@ public class RedisKeyPrefix {
     public static final String MARK_EMOTION_PROPORTION = "BRANDKBS:MARK:EMOTION_PROPORTION:";
     public static final String MARK_HIGH_WORD = "BRANDKBS:MARK:HIGH_WORD:";
 
-    private static final String SEPARATOR = ":";
+    public static final String REDIS_SYSTEM_COPY = "BRANDKBS:SYSTEM:COPY:";
+
+    /**
+     * 项目简报报相关缓存KEY
+     */
+    public static final String REPORT_PC = "BRANDKBS:REPORT:PC:";
 
     /**
      * 稿件数据上传缓存key

src/main/java/com/zhiwei/brandkbs2/config/Constant.java

 package com.zhiwei.brandkbs2.config;
 
+import org.apache.commons.lang3.time.FastDateFormat;
+
 /**
  * @ClassName: Constant
  * @Description 常量
@@ -8,8 +10,12 @@ package com.zhiwei.brandkbs2.config;
  */
 public class Constant {
 
+    public static final String HOUR_PATTERN = "yyyy-MM-dd HH";
     public static final String DAY_PATTERN = "yyyy-MM-dd";
 
+    public static final FastDateFormat HOUR_FORMAT = FastDateFormat.getInstance(HOUR_PATTERN);
+    public static final FastDateFormat DAY_FORMAT = FastDateFormat.getInstance(DAY_PATTERN);
+
     /**
      * 自定义fid分隔符号
      */
@@ -19,6 +25,8 @@ public class Constant {
      * 标签相关
      */
     public static final String EMOTION_LABEL_KEY = "情感倾向";
+    public static final String EMOTION_SENSITIVE = "敏感";
+    public static final String EMOTION_NEGATIVE= "负面";
     public static final String BRAND_LABEL_KEY = "品牌归属";
 
     /**

src/main/java/com/zhiwei/brandkbs2/controller/CommonController.java

@@ -3,8 +3,8 @@ package com.zhiwei.brandkbs2.controller;
 import com.zhiwei.brandkbs2.auth.Auth;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
-import com.zhiwei.brandkbs2.service.ICommonService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.CommonService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import com.zhiwei.middleware.mark.pojo.enums.TagField;
 import com.zhiwei.middleware.mark.vo.MarkerTag;
 import io.swagger.annotations.Api;
@@ -33,10 +33,10 @@ import java.util.stream.Collectors;
 public class CommonController extends BaseController {
 
     @Resource(name = "commonServiceImpl")
-    ICommonService commonService;
+    CommonService commonService;
 
     @Resource(name = "projectServiceImpl")
-    IProjectService projectService;
+    ProjectService projectService;
 
     @ApiOperation("获取情感倾向标签信息")
     @ApiImplicitParam(name = "linkedGroupId", value = "关联项目ID", required = true, paramType = "path", dataType = "string")
@@ -67,4 +67,18 @@ public class CommonController extends BaseController {
         return ResponseResult.success(projectService.getUserAllProjects());
     }
 
+//    @ApiOperation("获取默认月间隔时间节点")
+//    @GetMapping("/time/month")
+//    @Auth(role = RoleEnum.CUSTOMER)
+//    public ResponseResult getTimeRangeMonth() {
+//        return ResponseResult.success(commonService.getTimeRangeMonth());
+//    }
+//
+//    @ApiOperation("获取默认周间隔时间节点")
+//    @GetMapping("/time/week")
+//    @Auth(role = RoleEnum.CUSTOMER)
+//    public ResponseResult getTimeRangeWeek() {
+//        return ResponseResult.success(commonService.getTimeRangeWeek());
+//    }
+
 }

src/main/java/com/zhiwei/brandkbs2/controller/LoginController.java

@@ -5,8 +5,8 @@ import com.zhiwei.brandkbs2.auth.Auth;
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
-import com.zhiwei.brandkbs2.service.IProjectService;
-import com.zhiwei.brandkbs2.service.IUserService;
+import com.zhiwei.brandkbs2.service.ProjectService;
+import com.zhiwei.brandkbs2.service.UserService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -36,15 +36,15 @@ public class LoginController extends BaseController {
     private int jwtHour;
 
     @Resource(name = "userServiceImpl")
-    private IUserService iUserService;
+    private UserService UserService;
 
     @Resource(name = "projectServiceImpl")
-    private IProjectService iProjectService;
+    private ProjectService ProjectService;
 
     @ApiOperation("用户登录")
     @PostMapping("/user/login")
     public ResponseResult login() {
-        return ResponseResult.success(iUserService.login().toMap());
+        return ResponseResult.success(UserService.login().toMap());
     }
 
     @ApiOperation("用户信息获取")
@@ -59,7 +59,7 @@ public class LoginController extends BaseController {
             @ApiImplicitParam(name = "username", value = "用户名", required = false, paramType = "query", dataType = "string"))
     @PostMapping("/user/bind/reset")
     public ResponseResult resetBind(@RequestBody JSONObject json) {
-        iUserService.resetBind(json.getString("username"));
+        UserService.resetBind(json.getString("username"));
         return ResponseResult.success();
     }
 
@@ -71,25 +71,25 @@ public class LoginController extends BaseController {
     public ResponseResult bindUser(@RequestBody JSONObject json) {
         String username = json.getString("username");
         String password = json.getString("password");
-        return ResponseResult.success(iUserService.bindUser(username, password));
+        return ResponseResult.success(UserService.bindUser(username, password));
     }
 
     @ApiOperation("跳过绑定(赋默认权限)")
     @PostMapping("/user/bind/skip")
     public ResponseResult skipBindUser() {
-        return ResponseResult.success(iUserService.skipBindUser());
+        return ResponseResult.success(UserService.skipBindUser());
     }
 
     @ApiOperation("校验用户是否已有绑定关系")
     @GetMapping("/user/login/checkBind")
     public ResponseResult checkBind() {
-        return ResponseResult.success(iUserService.checkUserRoles());
+        return ResponseResult.success(UserService.checkUserRoles());
     }
 
     @ApiOperation("获取当前用户拥有的所有项目(含过期)")
     @GetMapping("/user/login/getUserAllProjects")
     public ResponseResult getLoginUserAllProjects() {
-        return ResponseResult.success(iProjectService.getLoginUserAllProjects());
+        return ResponseResult.success(ProjectService.getLoginUserAllProjects());
     }
 
     @ApiOperation("测试接口")

src/main/java/com/zhiwei/brandkbs2/controller/admin/ArticleController.java

@@ -7,8 +7,8 @@ import com.zhiwei.brandkbs2.controller.BaseController;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.Behavior;
-import com.zhiwei.brandkbs2.service.IBehaviorService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.BehaviorService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import com.zhiwei.brandkbs2.util.Tools;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -55,10 +55,10 @@ public class ArticleController extends BaseController {
     private RestTemplate restTemplate;
 
     @javax.annotation.Resource(name = "behaviorServiceImpl")
-    private IBehaviorService behaviorService;
+    private BehaviorService behaviorService;
 
     @javax.annotation.Resource(name = "projectServiceImpl")
-    private IProjectService projectService;
+    private ProjectService projectService;
 
     private static final Behavior.Operation OPERATION = new Behavior.Operation("稿件上传", true);
 

src/main/java/com/zhiwei/brandkbs2/controller/admin/BaseModuleController.java

@@ -10,9 +10,9 @@ import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.dto.TagFilterDTO;
 import com.zhiwei.brandkbs2.pojo.vo.ProjectVO;
-import com.zhiwei.brandkbs2.service.IHighWordService;
-import com.zhiwei.brandkbs2.service.IProjectService;
-import com.zhiwei.brandkbs2.service.ITagFilterService;
+import com.zhiwei.brandkbs2.service.HighWordService;
+import com.zhiwei.brandkbs2.service.ProjectService;
+import com.zhiwei.brandkbs2.service.TagFilterService;
 import com.zhiwei.brandkbs2.util.Tools;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -37,13 +37,13 @@ import java.util.List;
 public class BaseModuleController extends BaseController {
 
     @Resource(name = "tagFilterServiceImpl")
-    ITagFilterService tagFilterService;
+    TagFilterService tagFilterService;
 
     @Resource(name = "highWordServiceImpl")
-    IHighWordService highWordService;
+    HighWordService highWordService;
 
     @Resource(name = "projectServiceImpl")
-    IProjectService projectService;
+    ProjectService projectService;
 
     @ApiOperation("获取在用筛选器列表")
     @GetMapping("/tagFilter")

src/main/java/com/zhiwei/brandkbs2/controller/admin/BehaviorController.java

@@ -7,8 +7,8 @@ import com.zhiwei.brandkbs2.easyexcel.EasyExcelUtil;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportBehaviorDTO;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
-import com.zhiwei.brandkbs2.service.IBehaviorService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.BehaviorService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -34,10 +34,10 @@ import java.util.List;
 public class BehaviorController extends BaseController {
 
     @Resource(name = "behaviorServiceImpl")
-    private IBehaviorService behaviorService;
+    private BehaviorService behaviorService;
 
     @Resource(name = "projectServiceImpl")
-    private IProjectService iProjectService;
+    private ProjectService ProjectService;
 
     @ApiOperation("分页查询用户行为列表")
     @ApiImplicitParams({
@@ -72,7 +72,7 @@ public class BehaviorController extends BaseController {
                                    @RequestParam(value = "behavior", defaultValue = "true") boolean behavior) {
         List<ExportBehaviorDTO> downloadList = behaviorService.download(startTime, endTime, behavior);
         String behaviorName = behavior ? "后台" : "前台";
-        String sheetName = iProjectService.getProjectVOById(UserThreadLocal.getProjectId()).getProjectName() + "_" + behaviorName;
+        String sheetName = ProjectService.getProjectVOById(UserThreadLocal.getProjectId()).getProjectName() + "_" + behaviorName;
         EasyExcelUtil.download(sheetName + "用户行为", sheetName, ExportBehaviorDTO.class, downloadList, response);
         return ResponseResult.success();
     }

src/main/java/com/zhiwei/brandkbs2/controller/admin/ChannelController.java

@@ -12,8 +12,8 @@ import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.dto.ChannelDTO;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
-import com.zhiwei.brandkbs2.service.IChannelService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.ChannelService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import com.zhiwei.brandkbs2.util.Tools;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -41,10 +41,10 @@ import java.util.stream.Collectors;
 public class ChannelController extends BaseController {
 
     @Resource(name = "channelServiceImpl")
-    IChannelService channelService;
+    ChannelService channelService;
 
     @Resource(name = "projectServiceImpl")
-    IProjectService projectService;
+    ProjectService projectService;
 
     @Value("${brandkbs.img.url}")
     private String brandkbsImgPath;

src/main/java/com/zhiwei/brandkbs2/controller/admin/CustomTagController.java

@@ -6,8 +6,8 @@ import com.zhiwei.brandkbs2.controller.BaseController;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.Behavior;
-import com.zhiwei.brandkbs2.service.IBehaviorService;
-import com.zhiwei.brandkbs2.service.ICustomTagService;
+import com.zhiwei.brandkbs2.service.BehaviorService;
+import com.zhiwei.brandkbs2.service.CustomTagService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -33,10 +33,10 @@ import static com.alibaba.fastjson.JSON.parseArray;
 public class CustomTagController extends BaseController {
 
     @Resource(name = "customTagServiceImpl")
-    private ICustomTagService customTagService;
+    private CustomTagService customTagService;
 
     @Resource(name = "behaviorServiceImpl")
-    private IBehaviorService behaviorService;
+    private BehaviorService behaviorService;
 
     private static final Behavior.Operation OPERATION = new Behavior.Operation("自定义标签管理", true);
 

src/main/java/com/zhiwei/brandkbs2/controller/admin/ProjectController.java

@@ -11,9 +11,9 @@ import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.Behavior;
 import com.zhiwei.brandkbs2.pojo.vo.ProjectVO;
-import com.zhiwei.brandkbs2.service.IBehaviorService;
-import com.zhiwei.brandkbs2.service.ICommonService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.BehaviorService;
+import com.zhiwei.brandkbs2.service.CommonService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import com.zhiwei.brandkbs2.util.Tools;
 import com.zhiwei.middleware.mark.vo.MarkerTag;
 import io.swagger.annotations.Api;
@@ -50,13 +50,13 @@ public class ProjectController extends BaseController {
     private RestTemplate restTemplate;
 
     @Resource(name = "projectServiceImpl")
-    private IProjectService iProjectService;
+    private ProjectService ProjectService;
 
     @Resource(name = "behaviorServiceImpl")
-    private IBehaviorService behaviorService;
+    private BehaviorService behaviorService;
 
     @Resource(name = "commonServiceImpl")
-    private ICommonService commonService;
+    private CommonService commonService;
 
     private static final Behavior.Operation OPERATION = new Behavior.Operation("项目管理", true);
 
@@ -75,7 +75,7 @@ public class ProjectController extends BaseController {
     @ApiOperation("添加项目配置")
     @PostMapping("/add")
     public ResponseResult addProject(@RequestBody ProjectVO projectVO) {
-        iProjectService.addProject(projectVO);
+        ProjectService.addProject(projectVO);
         behaviorService.pushBehavior(OPERATION, "添加项目配置:" + projectVO.getId(), request);
         return ResponseResult.success();
     }
@@ -85,14 +85,14 @@ public class ProjectController extends BaseController {
             @ApiImplicitParam(name = "size", value = "每页记录数", required = false, defaultValue = "10", paramType = "query", dataType = "int"), @ApiImplicitParam(name = "keyword", value = "搜索关键字", required = false, defaultValue = "", paramType = "query", dataType = "string")})
     @GetMapping("/list")
     public ResponseResult findProjectList(@RequestParam(value = "page", defaultValue = "1") int page, @RequestParam(value = "size", defaultValue = "10") int size, @RequestParam(value = "keyword", defaultValue = "") String keyword) {
-        return ResponseResult.success(iProjectService.findProjectList(page, size, keyword));
+        return ResponseResult.success(ProjectService.findProjectList(page, size, keyword));
     }
 
 
     @ApiOperation("修改项目")
     @PutMapping("/update")
     public ResponseResult updateProject(@RequestBody ProjectVO projectVO) {
-        iProjectService.updateProject(projectVO);
+        ProjectService.updateProject(projectVO);
         behaviorService.pushBehavior(OPERATION, "修改项目:" + projectVO.getId(), request);
         return ResponseResult.success();
     }
@@ -101,7 +101,7 @@ public class ProjectController extends BaseController {
     @ApiImplicitParam(name = "pid", value = "项目ID", required = true, paramType = "path", dataType = "string")
     @DeleteMapping("/delete/{pid}")
     public ResponseResult deleteProject(@PathVariable("pid") String pid) {
-        iProjectService.deleteProject(pid, UserThreadLocal.getProjectId());
+        ProjectService.deleteProject(pid, UserThreadLocal.getProjectId());
         behaviorService.pushBehavior(OPERATION, "删除项目:" + pid, request);
         return ResponseResult.success();
     }
@@ -110,7 +110,7 @@ public class ProjectController extends BaseController {
     @ApiImplicitParam(name = "pid", value = "项目ID", required = true, paramType = "path", dataType = "string")
     @PutMapping("/switch/projectShow/{pid}")
     public ResponseResult switchProjectShow(@PathVariable String pid) {
-        boolean result = iProjectService.switchProjectShow(pid);
+        boolean result = ProjectService.switchProjectShow(pid);
         if (result) {
             behaviorService.pushBehavior(OPERATION, "切换项目展示状态:" + pid, request);
             return ResponseResult.success();
@@ -123,7 +123,7 @@ public class ProjectController extends BaseController {
     @ApiImplicitParam(name = "pid", value = "项目ID", required = true, paramType = "path", dataType = "string")
     @PutMapping("/switch/projectStart/{pid}")
     public ResponseResult switchProjectStart(@PathVariable String pid) {
-        iProjectService.switchProjectStart(pid);
+        ProjectService.switchProjectStart(pid);
         behaviorService.pushBehavior(OPERATION, "切换项目状态:" + pid, request);
         return ResponseResult.success();
     }
@@ -132,7 +132,7 @@ public class ProjectController extends BaseController {
     @ApiImplicitParam(name = "pid", value = "项目ID", required = true, paramType = "path", dataType = "string")
     @GetMapping("/get/{pid}")
     public ResponseResult getProjectVOById(@PathVariable("pid") String pid) {
-        return ResponseResult.success(iProjectService.getProjectVOById(pid));
+        return ResponseResult.success(ProjectService.getProjectVOById(pid));
     }
 
     @ApiOperation("图片上传")
@@ -153,7 +153,7 @@ public class ProjectController extends BaseController {
     @ApiImplicitParam(name = "pid", value = "项目ID", required = true, paramType = "path", dataType = "string")
     @GetMapping("/download/keyword/{pid}")
     public ResponseResult downloadArticles(@PathVariable("pid") String pid) {
-        ProjectVO project = iProjectService.getProjectVOById(pid);
+        ProjectVO project = ProjectService.getProjectVOById(pid);
         EasyExcelUtil.download(project.getBrandName() + "_命中关键词", "sheet1", UploadKeywordDTO.class, UploadKeywordDTO.change2This(project.getHitKeywords()), response);
         return ResponseResult.success();
     }
@@ -202,7 +202,7 @@ public class ProjectController extends BaseController {
     @GetMapping("/user/getUserAllProjects")
     @Auth(role = RoleEnum.CUSTOMER)
     public ResponseResult getUserAllProjects() {
-        return ResponseResult.success(iProjectService.getUserAllProjects());
+        return ResponseResult.success(ProjectService.getUserAllProjects());
     }
 
 }

src/main/java/com/zhiwei/brandkbs2/controller/admin/ReportController.java

@@ -4,7 +4,7 @@ import com.zhiwei.brandkbs2.auth.Auth;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.dto.ReportSettingsDTO;
-import com.zhiwei.brandkbs2.service.IReportService;
+import com.zhiwei.brandkbs2.service.ReportService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.web.bind.annotation.*;
@@ -24,7 +24,7 @@ import javax.annotation.Resource;
 public class ReportController {
 
     @Resource(name = "reportServiceImpl")
-    private IReportService reportService;
+    private ReportService reportService;
 
 
     @ApiOperation("获取简报设置")

src/main/java/com/zhiwei/brandkbs2/controller/admin/UserController.java

@@ -6,8 +6,8 @@ import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.Behavior;
 import com.zhiwei.brandkbs2.pojo.dto.UserDTO;
-import com.zhiwei.brandkbs2.service.IBehaviorService;
-import com.zhiwei.brandkbs2.service.IUserService;
+import com.zhiwei.brandkbs2.service.BehaviorService;
+import com.zhiwei.brandkbs2.service.UserService;
 import com.zhiwei.middleware.auth.pojo.CenterUser;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -31,10 +31,10 @@ import javax.annotation.Resource;
 public class UserController extends BaseController {
 
     @Resource(name = "userServiceImpl")
-    private IUserService iUserService;
+    private UserService UserService;
 
     @Resource(name = "behaviorServiceImpl")
-    private IBehaviorService behaviorService;
+    private BehaviorService behaviorService;
 
     private static final Behavior.Operation OPERATION = new Behavior.Operation("用户管理", true);
 
@@ -55,7 +55,7 @@ public class UserController extends BaseController {
                                    @RequestParam(value = "keyword", defaultValue = "") String keyword,
                                    @RequestParam(value = "pid") String pid,
                                    @RequestParam(value = "role", defaultValue = "-1") int role) {
-        return ResponseResult.success(iUserService.findUserList(page, size, keyword, pid, role));
+        return ResponseResult.success(UserService.findUserList(page, size, keyword, pid, role));
     }
 
     @ApiOperation("根据手机号搜索用户信息")
@@ -77,7 +77,7 @@ public class UserController extends BaseController {
     @ApiOperation("添加用户")
     @PostMapping("/add")
     public ResponseResult addUser(@RequestBody UserDTO userDTO) {
-        iUserService.addUser(userDTO);
+        UserService.addUser(userDTO);
         behaviorService.pushBehavior(OPERATION, "添加用户:" + userDTO.getId(), request);
         return ResponseResult.success();
     }
@@ -89,7 +89,7 @@ public class UserController extends BaseController {
     @DeleteMapping("/delete")
     @Auth(role = RoleEnum.ADMIN)
     public ResponseResult deleteUser(@RequestParam(value = "uid") String userId, @RequestParam(value = "pid") String pid) {
-        iUserService.deleteUser(userId, pid);
+        UserService.deleteUser(userId, pid);
         behaviorService.pushBehavior(OPERATION, "删除用户:" + userId, request);
         return ResponseResult.success();
     }
@@ -97,7 +97,7 @@ public class UserController extends BaseController {
     @ApiOperation("编辑用户")
     @PutMapping("/update")
     public ResponseResult updateUser(@RequestBody UserDTO userDTO) {
-        iUserService.updateUser(userDTO);
+        UserService.updateUser(userDTO);
         behaviorService.pushBehavior(OPERATION, "编辑用户:" + userDTO, request);
         return ResponseResult.success();
     }
@@ -113,14 +113,14 @@ public class UserController extends BaseController {
     public ResponseResult findSuperAdminList(@RequestParam(value = "page", defaultValue = "1") int page,
                                              @RequestParam(value = "size", defaultValue = "10") int size,
                                              @RequestParam(value = "keyword", defaultValue = "") String keyword) {
-        return ResponseResult.success(iUserService.findSuperAdminList(page, size, keyword));
+        return ResponseResult.success(UserService.findSuperAdminList(page, size, keyword));
     }
 
     @ApiOperation("添加超级管理员")
     @PostMapping("/add/superAdmin")
     @Auth(role = RoleEnum.SUPER_ADMIN)
     public ResponseResult addSuperAdmin(@RequestBody UserDTO userDTO) {
-        iUserService.addSuperAdmin(userDTO);
+        UserService.addSuperAdmin(userDTO);
         behaviorService.pushBehavior(OPERATION, "添加超级管理员:" + userDTO.getId(), request);
         return ResponseResult.success();
     }
@@ -131,7 +131,7 @@ public class UserController extends BaseController {
     @DeleteMapping("/delete/superAdmin")
     @Auth(role = RoleEnum.SUPER_ADMIN)
     public ResponseResult deleteSuperAdmin(@RequestParam(value = "uid") String userId) {
-        iUserService.deleteSuperAdmin(userId);
+        UserService.deleteSuperAdmin(userId);
         behaviorService.pushBehavior(OPERATION, "删除超级管理员:" + userId, request);
         return ResponseResult.success();
     }

src/main/java/com/zhiwei/brandkbs2/controller/AppArticleController.java → src/main/java/com/zhiwei/brandkbs2/controller/app/AppArticleController.java

-package com.zhiwei.brandkbs2.controller;
+package com.zhiwei.brandkbs2.controller.app;
 
 import com.zhiwei.brandkbs2.auth.Auth;
+import com.zhiwei.brandkbs2.controller.BaseController;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.model.ResponseResult;
 import com.zhiwei.brandkbs2.pojo.dto.MarkSearchDTO;
-import com.zhiwei.brandkbs2.service.IMarkDataService;
-import com.zhiwei.brandkbs2.service.IReportService;
+import com.zhiwei.brandkbs2.pojo.dto.ReportDTO;
+import com.zhiwei.brandkbs2.pojo.dto.ReportSearchDTO;
+import com.zhiwei.brandkbs2.service.CommonService;
+import com.zhiwei.brandkbs2.service.MarkDataService;
+import com.zhiwei.brandkbs2.service.ReportService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -27,10 +31,13 @@ import javax.annotation.Resource;
 public class AppArticleController extends BaseController {
 
     @Resource(name = "markDataServiceImpl")
-    IMarkDataService markDataService;
+    MarkDataService markDataService;
 
     @Resource(name = "reportServiceImpl")
-    IReportService reportService;
+    ReportService reportService;
+
+    @Resource(name = "commonServiceImpl")
+    CommonService commonService;
 
     @ApiOperation("舆情列表")
     @PostMapping("/mark/list")
@@ -38,6 +45,12 @@ public class AppArticleController extends BaseController {
         return ResponseResult.success(markDataService.getYuqingMarkList(markSearchDTO));
     }
 
+    @ApiOperation("舆情列表-生成聚合")
+    @PostMapping("/mark/agree")
+    public ResponseResult generateYuqingMarkAggreeList(@RequestBody MarkSearchDTO markSearchDTO) {
+        return ResponseResult.success(markDataService.generateYuqingMarkAggreeList(markSearchDTO));
+    }
+
     @ApiOperation("舆情列表-搜索条件")
     @GetMapping("/mark/list/criteria")
     public ResponseResult getYuqingMark(@RequestParam(required = false) String linkedGroupId) {
@@ -62,7 +75,7 @@ public class AppArticleController extends BaseController {
         return ResponseResult.success(markDataService.getMarkSpread(startTime, endTime, true));
     }
 
-    @ApiOperation("舆情分析-平台曝光对比")
+    @ApiOperation("舆情分析-品牌曝光对比")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "startTime", value = "开始时间", paramType = "query", dataType = "long"),
             @ApiImplicitParam(name = "endTime", value = "结束时间", paramType = "query", dataType = "long")
@@ -98,16 +111,41 @@ public class AppArticleController extends BaseController {
     })
     @GetMapping("/highWord")
     public ResponseResult getMarkHighWord(@RequestParam(value = "startTime", required = false) Long startTime,
-                                            @RequestParam(value = "endTime", required = false) Long endTime) {
+                                          @RequestParam(value = "endTime", required = false) Long endTime) {
         return ResponseResult.success(markDataService.getMarkHighWord(startTime, endTime));
     }
 
+    @ApiOperation("舆情分析-获取默认时间")
+    @GetMapping("/default/time")
+    public ResponseResult getDefaultTime() {
+        return ResponseResult.success(commonService.getTimeRangeMonth());
+    }
+
     @ApiOperation("舆情简报-分类统计")
-    @GetMapping("/aggCount")
+    @GetMapping("/report/aggCount")
     public ResponseResult getReportsAggCount() {
         return ResponseResult.success(reportService.getReportsAggCount());
     }
 
+    @ApiOperation("舆情简报-全部报告列表")
+    @GetMapping("/report/list")
+    public ResponseResult findReportList(ReportSearchDTO reportSearch) {
+        return ResponseResult.success(reportService.findReportList(reportSearch));
+    }
+
+    @ApiOperation("舆情简报-添加自定义简报")
+    @PostMapping("report/custom/add")
+    public ResponseResult addCustomReport(@RequestBody ReportDTO reportDTO) {
+        reportService.addCustomReport(reportDTO);
+        return ResponseResult.success();
+    }
 
+    @ApiOperation("舆情简报-删除简报")
+    @ApiImplicitParam(name = "id", value = "报告ID", required = true, paramType = "path", dataType = "String")
+    @DeleteMapping("report/{id}")
+    public ResponseResult deleteReportById(@PathVariable String id) {
+        reportService.deleteReportById(id);
+        return ResponseResult.success();
+    }
 
 }

src/main/java/com/zhiwei/brandkbs2/controller/app/GlobalController.java

+package com.zhiwei.brandkbs2.controller.app;
+
+import com.zhiwei.brandkbs2.auth.Auth;
+import com.zhiwei.brandkbs2.controller.BaseController;
+import com.zhiwei.brandkbs2.enmus.RoleEnum;
+import com.zhiwei.brandkbs2.model.ResponseResult;
+import com.zhiwei.brandkbs2.service.MarkFlowService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+
+/**
+ * @ClassName: GlobalController
+ * @Description 全局通用获取Controller
+ * @author: sjj
+ * @date: 2022-07-15 10:33
+ */
+@RestController
+@RequestMapping("/app/global")
+@Api(tags = "全局通用接口")
+@Auth(role = RoleEnum.CUSTOMER)
+public class GlobalController extends BaseController {
+
+    @Resource(name = "markFlowServiceImpl")
+    MarkFlowService markFlowService;
+
+    @ApiOperation("内部快照-组装页面")
+    @PostMapping("/shotPage")
+    public ResponseResult setShotPage(@RequestBody String markFlowEntity) {
+        return ResponseResult.success(markFlowService.setShotPage(markFlowEntity));
+    }
+
+    @ApiOperation("内部快照-获取页面")
+    @GetMapping("/shotPage/{id}")
+    public ResponseResult getShotPage(@PathVariable(name = "id") String id) {
+        return ResponseResult.success(markFlowService.getShotPageFromCache(id));
+    }
+
+}

src/main/java/com/zhiwei/brandkbs2/dao/IBaseMongoDao.java → src/main/java/com/zhiwei/brandkbs2/dao/BaseMongoDao.java

@@ -15,7 +15,7 @@ import java.util.List;
  * @date: 2022-04-29 14:45
  */
 
-public interface IBaseMongoDao<T extends AbstractBaseMongo> {
+public interface BaseMongoDao<T extends AbstractBaseMongo> {
 
     /**
      * 插入一条数据
@@ -54,6 +54,13 @@ public interface IBaseMongoDao<T extends AbstractBaseMongo> {
     void deleteOneById(String id, String... collectionNames);
 
     /**
+     * 通过id删除数据
+     *
+     * @param id 数据库唯一id
+     */
+    void deleteOneByIdWithQuery(String id, Query query, String... collectionNames);
+
+    /**
      * 通过id查找单条数据
      *
      * @param id 数据库唯一id
@@ -95,7 +102,7 @@ public interface IBaseMongoDao<T extends AbstractBaseMongo> {
      * @param preQuery 查询请求
      * @return list<T>
      */
-    List<T> findList(Query preQuery,String... collectionNames);
+    List<T> findList(Query preQuery, String... collectionNames);
 
     /**
      * 量查询
@@ -106,18 +113,26 @@ public interface IBaseMongoDao<T extends AbstractBaseMongo> {
     long count(Query preQuery, String... collectionNames);
 
     /**
+     * 量查询with关键词
+     *
+     * @param preQuery 查询请求
+     * @return long
+     */
+    long count(Query preQuery, String keyword, String[] matchFields, String... collectionNames);
+
+    /**
      * 添加模糊查询条件
      *
-     * @param query query
-     * @param keyword 关键字
+     * @param query    query
+     * @param keyword  关键字
      * @param fuzzKeys 匹配keys
      */
-    void addKeywordFuzz(Query query,String keyword,String... fuzzKeys);
+    void addKeywordFuzz(Query query, String keyword, String... fuzzKeys);
 
     /**
      * 添加排序
      *
-     * @param query query
+     * @param query  query
      * @param sorter 排序字段
      */
     void addSort(Query query, String sorter);
@@ -133,6 +148,7 @@ public interface IBaseMongoDao<T extends AbstractBaseMongo> {
         criteria.and("platform").is(channelIndex.getPlatform());
         criteria.and("realSource").is(channelIndex.getRealSource());
         criteria.and("source").is(channelIndex.getSource());
+        criteria.and("projectId").is(channelIndex.getProjectId());
         criteria.and("linkedGroupId").is(channelIndex.getLinkedGroupId());
         return criteria;
     }

src/main/java/com/zhiwei/brandkbs2/dao/IBehaviorDao.java → src/main/java/com/zhiwei/brandkbs2/dao/BehaviorDao.java

@@ -3,10 +3,10 @@ package com.zhiwei.brandkbs2.dao;
 import com.zhiwei.brandkbs2.pojo.Behavior;
 
 /**
- * @ClassName: IBehaviorDao
- * @Description IBehaviorDao
+ * @ClassName: BehaviorDao
+ * @Description BehaviorDao
  * @author: sjj
  * @date: 2022-05-27 13:46
  */
-public interface IBehaviorDao extends IBaseMongoDao<Behavior>, IShardingMongo {
+public interface BehaviorDao extends BaseMongoDao<Behavior>, ShardingMongo {
 }

src/main/java/com/zhiwei/brandkbs2/dao/IBrandkbsTaskDao.java → src/main/java/com/zhiwei/brandkbs2/dao/BrandkbsTaskDao.java

@@ -3,12 +3,12 @@ package com.zhiwei.brandkbs2.dao;
 import com.zhiwei.brandkbs2.pojo.BrandkbsTask;
 
 /**
- * @ClassName: IBrandkbsTaskDao
- * @Description IBrandkbsTaskDao
+ * @ClassName: BrandkbsTaskDao
+ * @Description BrandkbsTaskDao
  * @author: sjj
  * @date: 2022-07-12 17:25
  */
-public interface IBrandkbsTaskDao extends IBaseMongoDao<BrandkbsTask> {
+public interface BrandkbsTaskDao extends BaseMongoDao<BrandkbsTask> {
 
     /**
      * 根据任务名称获取任务

src/main/java/com/zhiwei/brandkbs2/dao/IChannelDao.java → src/main/java/com/zhiwei/brandkbs2/dao/ChannelDao.java

@@ -4,12 +4,12 @@ import com.zhiwei.brandkbs2.pojo.Channel;
 import com.zhiwei.brandkbs2.pojo.ChannelIndex;
 
 /**
- * @ClassName: IChannelDao
- * @Description IChannelDao
+ * @ClassName: ChannelDao
+ * @Description ChannelDao
  * @author: sjj
  * @date: 2022-06-16 15:30
  */
-public interface IChannelDao extends IBaseMongoDao<Channel>{
+public interface ChannelDao extends BaseMongoDao<Channel>{
 
     Channel queryUnique(ChannelIndex channelIndex);
 

src/main/java/com/zhiwei/brandkbs2/dao/IChannelLabelDao.java → src/main/java/com/zhiwei/brandkbs2/dao/ChannelLabelDao.java

@@ -10,7 +10,7 @@ import java.util.List;
  * @author: sjj
  * @date: 2022-06-20 16:53
  */
-public interface IChannelLabelDao extends IBaseMongoDao<ChannelLabel>{
+public interface ChannelLabelDao extends BaseMongoDao<ChannelLabel>{
 
     List<String> getChannelLabelType();
 

src/main/java/com/zhiwei/brandkbs2/dao/ChannelTagDao.java

+package com.zhiwei.brandkbs2.dao;
+
+import com.zhiwei.brandkbs2.pojo.ChannelTag;
+
+/**
+ * @ClassName: ChannelTagDao
+ * @Description ChannelTagDao
+ * @author: sjj
+ * @date: 2022-07-13 14:28
+ */
+public interface ChannelTagDao extends BaseMongoDao<ChannelTag>{
+
+    String getTagByChannelName(String name);
+}

src/main/java/com/zhiwei/brandkbs2/dao/ICustomTagDao.java → src/main/java/com/zhiwei/brandkbs2/dao/CustomTagDao.java

@@ -5,12 +5,12 @@ import com.zhiwei.brandkbs2.pojo.CustomTag;
 import java.util.List;
 
 /**
- * @ClassName: ICustomTagDao
- * @Description ICustomTagDao
+ * @ClassName: CustomTagDao
+ * @Description CustomTagDao
  * @author: sjj
  * @date: 2022-07-04 13:43
  */
-public interface ICustomTagDao extends IBaseMongoDao<CustomTag> {
+public interface CustomTagDao extends BaseMongoDao<CustomTag> {
 
     /**
      * 查询所有自定义标签（按创建时间降序）

src/main/java/com/zhiwei/brandkbs2/dao/IEventDao.java → src/main/java/com/zhiwei/brandkbs2/dao/EventDao.java

@@ -3,12 +3,12 @@ package com.zhiwei.brandkbs2.dao;
 import com.zhiwei.brandkbs2.pojo.Event;
 
 /**
- * @ClassName: IEventDao
- * @Description IEventDao
+ * @ClassName: EventDao
+ * @Description EventDao
  * @author: sjj
  * @date: 2022-05-18 14:35
  */
-public interface IEventDao extends IBaseMongoDao<Event>{
+public interface EventDao extends BaseMongoDao<Event>{
 
     /**
      * 是否已存在事件

src/main/java/com/zhiwei/brandkbs2/dao/IEventDataDao.java → src/main/java/com/zhiwei/brandkbs2/dao/EventDataDao.java

@@ -8,12 +8,12 @@ import java.util.Date;
 import java.util.List;
 
 /**
- * @ClassName: IEventDataDao
- * @Description IEventDataDao
+ * @ClassName: EventDataDao
+ * @Description EventDataDao
  * @author: sjj
  * @date: 2022-05-19 16:08
  */
-public interface IEventDataDao extends IBaseMongoDao<EventData>, IShardingMongo {
+public interface EventDataDao extends BaseMongoDao<EventData>, ShardingMongo {
 
     /**
      * 获取首发稿件

src/main/java/com/zhiwei/brandkbs2/dao/IHighWordDao.java → src/main/java/com/zhiwei/brandkbs2/dao/HighWordDao.java

@@ -3,10 +3,10 @@ package com.zhiwei.brandkbs2.dao;
 import com.zhiwei.brandkbs2.pojo.HighWord;
 
 /**
- * @ClassName: IHighWordDao
- * @Description IHighWordDao
+ * @ClassName: HighWordDao
+ * @Description HighWordDao
  * @author: sjj
  * @date: 2022-06-06 09:47
  */
-public interface IHighWordDao extends IBaseMongoDao<HighWord>{
+public interface HighWordDao extends BaseMongoDao<HighWord>{
 }

src/main/java/com/zhiwei/brandkbs2/dao/IProjectDao.java → src/main/java/com/zhiwei/brandkbs2/dao/ProjectDao.java

@@ -5,9 +5,9 @@ import com.zhiwei.brandkbs2.pojo.Project;
 /**
  * @author sjj
  * @version 1.0
- * @description IProjectDao
+ * @description ProjectDao
  * @date 2022年4月20日17:38:54
  */
-public interface IProjectDao extends IBaseMongoDao<Project>{
+public interface ProjectDao extends BaseMongoDao<Project>{
 
 }

src/main/java/com/zhiwei/brandkbs2/dao/IQbjcPojoDao.java → src/main/java/com/zhiwei/brandkbs2/dao/QbjcPojoDao.java

@@ -6,14 +6,14 @@ import com.zhiwei.qbjc.bean.pojo.common.Tag;
 import java.util.List;
 
 /**
- * IQbjcPojoDao-interface
+ * QbjcPojoDao-interface
  * 
- * @ClassName: IQbjcPojoDao
- * @Description IQbjcPojoDao-interface
+ * @ClassName: QbjcPojoDao
+ * @Description QbjcPojoDao-interface
  * @author sjj
  * @date 2022年6月16日14:23:36
  */
-public interface IQbjcPojoDao {
+public interface QbjcPojoDao {
 
 	/**
 	 * 获取qbjcPlatform

src/main/java/com/zhiwei/brandkbs2/dao/IReportDao.java → src/main/java/com/zhiwei/brandkbs2/dao/ReportDao.java

 package com.zhiwei.brandkbs2.dao;
 
+import com.alibaba.fastjson.JSONObject;
 import com.zhiwei.brandkbs2.pojo.Report;
 
+import java.util.List;
+
 /**
- * @ClassName: IReportDao
- * @Description IReportDao
+ * @ClassName: ReportDao
+ * @Description ReportDao
  * @author: sjj
  * @date: 2022-05-31 18:13
  */
-public interface IReportDao extends IBaseMongoDao<Report> {
+public interface ReportDao extends BaseMongoDao<Report> {
+
+    List<JSONObject> getReportAggCount(String projectId);
+
 }

src/main/java/com/zhiwei/brandkbs2/dao/IReportSettingsDao.java → src/main/java/com/zhiwei/brandkbs2/dao/ReportSettingsDao.java

@@ -2,11 +2,16 @@ package com.zhiwei.brandkbs2.dao;
 
 import com.zhiwei.brandkbs2.pojo.ReportSettings;
 
+import java.util.List;
+
 /**
- * @ClassName: IReportSettingsDao
- * @Description IReportSettingsDao
+ * @ClassName: ReportSettingsDao
+ * @Description ReportSettingsDao
  * @author: sjj
  * @date: 2022-05-31 18:13
  */
-public interface IReportSettingsDao extends IBaseMongoDao<ReportSettings> {
+public interface ReportSettingsDao extends BaseMongoDao<ReportSettings> {
+
+    List<ReportSettings> getReportSettingByProjectWithUsed(String projectId);
+
 }

src/main/java/com/zhiwei/brandkbs2/dao/IShardingMongo.java → src/main/java/com/zhiwei/brandkbs2/dao/ShardingMongo.java

@@ -5,12 +5,12 @@ import com.zhiwei.brandkbs2.util.IndexUtil;
 import java.util.Date;
 
 /**
- * @ClassName: IShardingMongo
+ * @ClassName: ShardingMongo
  * @Description 分库mongo接口
  * @author: sjj
  * @date: 2022-05-27 11:29
  */
-public interface IShardingMongo {
+public interface ShardingMongo {
 
     String collectionPrefix();
 

src/main/java/com/zhiwei/brandkbs2/dao/ITagFilterDao.java → src/main/java/com/zhiwei/brandkbs2/dao/TagFilterDao.java

@@ -3,10 +3,10 @@ package com.zhiwei.brandkbs2.dao;
 import com.zhiwei.brandkbs2.pojo.TagFilter;
 
 /**
- * @ClassName: ITagFilterDao
- * @Description ITagFilterDao
+ * @ClassName: TagFilterDao
+ * @Description TagFilterDao
  * @author: sjj
  * @date: 2022-06-01 13:52
  */
-public interface ITagFilterDao extends IBaseMongoDao<TagFilter>{
+public interface TagFilterDao extends BaseMongoDao<TagFilter>{
 }

src/main/java/com/zhiwei/brandkbs2/dao/IUserDao.java → src/main/java/com/zhiwei/brandkbs2/dao/UserDao.java

@@ -3,11 +3,11 @@ package com.zhiwei.brandkbs2.dao;
 import com.zhiwei.brandkbs2.pojo.User;
 
 /**
- * @ClassName: IUserDao
+ * @ClassName: UserDao
  * @Description 用户相关接口
  * @author: sjj
  * @date: 2022-04-28 18:10
  */
-public interface IUserDao extends IBaseMongoDao<User>{
+public interface UserDao extends BaseMongoDao<User>{
 
 }

src/main/java/com/zhiwei/brandkbs2/dao/impl/BaseMongoDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zhiwei.brandkbs2.dao.IBaseMongoDao;
+import com.zhiwei.brandkbs2.dao.BaseMongoDao;
 import com.zhiwei.brandkbs2.pojo.AbstractBaseMongo;
 import org.apache.commons.lang3.StringUtils;
 import org.bson.Document;
@@ -24,7 +24,7 @@ import java.util.regex.Pattern;
  * @author: sjj
  * @date: 2022-04-29 15:11
  */
-public class BaseMongoDaoImpl<T extends AbstractBaseMongo> implements IBaseMongoDao<T> {
+public class BaseMongoDaoImpl<T extends AbstractBaseMongo> implements BaseMongoDao<T> {
 
     protected static final String ID = "_id";
     private final String collectionName;
@@ -77,6 +77,11 @@ public class BaseMongoDaoImpl<T extends AbstractBaseMongo> implements IBaseMongo
     }
 
     @Override
+    public void deleteOneByIdWithQuery(String id, Query query, String... collectionNames) {
+        mongoTemplate.remove(query.addCriteria(Criteria.where(ID).is(id)), getCollections(collectionNames)[0]);
+    }
+
+    @Override
     public T findOneById(String id, String... collectionNames) {
         return mongoTemplate.findOne(new Query(Criteria.where(ID).is(id)), clazz, getCollections(collectionNames)[0]);
     }
@@ -119,10 +124,18 @@ public class BaseMongoDaoImpl<T extends AbstractBaseMongo> implements IBaseMongo
 
     @Override
     public long count(Query preQuery, String... collectionNames) {
+        return count(preQuery, null, null, collectionNames);
+    }
+
+    @Override
+    public long count(Query preQuery, String keyword, String[] matchFields, String... collectionNames) {
         Query query = new Query();
         if (null != preQuery) {
             query = preQuery;
         }
+        if (StringUtils.isNotEmpty(keyword)) {
+            addKeywordFuzz(query, keyword, matchFields);
+        }
         long count = 0;
         for (String collection : getCollections(collectionNames)) {
             count += mongoTemplate.count(query, collection);

src/main/java/com/zhiwei/brandkbs2/dao/impl/BehaviorDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IBehaviorDao;
+import com.zhiwei.brandkbs2.dao.BehaviorDao;
 import com.zhiwei.brandkbs2.pojo.Behavior;
 import org.springframework.stereotype.Component;
 
@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-05-27 13:48
  */
 @Component("behaviorDao")
-public class BehaviorDaoImpl extends BaseMongoDaoImpl<Behavior> implements IBehaviorDao {
+public class BehaviorDaoImpl extends BaseMongoDaoImpl<Behavior> implements BehaviorDao {
 
     private static final String COLLECTION_PREFIX = "brandkbs_behavior";
     private static final String TIME_PATTERN = "yyyyMM";

src/main/java/com/zhiwei/brandkbs2/dao/impl/BrandkbsTaskDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IBrandkbsTaskDao;
+import com.zhiwei.brandkbs2.dao.BrandkbsTaskDao;
 import com.zhiwei.brandkbs2.pojo.BrandkbsTask;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-07-12 17:27
  */
 @Component("brandkbsTaskDao")
-public class BrandkbsTaskDaoImpl extends BaseMongoDaoImpl<BrandkbsTask> implements IBrandkbsTaskDao {
+public class BrandkbsTaskDaoImpl extends BaseMongoDaoImpl<BrandkbsTask> implements BrandkbsTaskDao {
     private static final String COLLECTION_PREFIX = "brandkbs_task";
 
     public BrandkbsTaskDaoImpl() {

src/main/java/com/zhiwei/brandkbs2/dao/impl/ChannelDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IChannelDao;
+import com.zhiwei.brandkbs2.dao.ChannelDao;
 import com.zhiwei.brandkbs2.pojo.Channel;
 import com.zhiwei.brandkbs2.pojo.ChannelIndex;
 import org.springframework.data.mongodb.core.query.Criteria;
@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-06-16 15:31
  */
 @Component("channelDao")
-public class ChannelDaoImpl extends BaseMongoDaoImpl<Channel> implements IChannelDao {
+public class ChannelDaoImpl extends BaseMongoDaoImpl<Channel> implements ChannelDao {
 
     private static final String COLLECTION_PREFIX = "brandkbs_channel";
 
@@ -24,11 +24,15 @@ public class ChannelDaoImpl extends BaseMongoDaoImpl<Channel> implements IChanne
 
     @Override
     public Channel queryUnique(ChannelIndex channelIndex) {
-        Query query = Query.query(Criteria.where("linkedGroupId").is(channelIndex.getLinkedGroupId()).
-                and("projectId").is(channelIndex.getProjectId()).
-                and("platform").is(channelIndex.getPlatform()).
-                and("realSource").is(channelIndex.getRealSource()).
-                and("source").is(channelIndex.getSource()));
+        if (null == channelIndex) {
+            return null;
+        }
+//        Query query = Query.query(Criteria.where("linkedGroupId").is(channelIndex.getLinkedGroupId()).
+//                and("projectId").is(channelIndex.getProjectId()).
+//                and("platform").is(channelIndex.getPlatform()).
+//                and("realSource").is(channelIndex.getRealSource()).
+//                and("source").is(channelIndex.getSource()));
+        Query query = Query.query(Criteria.where("fid").is(channelIndex.getFid()));
         return mongoTemplate.findOne(query, clazz, COLLECTION_PREFIX);
     }
 

src/main/java/com/zhiwei/brandkbs2/dao/impl/ChannelLabelDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zhiwei.brandkbs2.dao.IChannelLabelDao;
+import com.zhiwei.brandkbs2.dao.ChannelLabelDao;
 import com.zhiwei.brandkbs2.pojo.ChannelLabel;
 import org.springframework.data.mongodb.core.aggregation.Aggregation;
 import org.springframework.data.mongodb.core.aggregation.AggregationResults;
@@ -17,7 +17,7 @@ import java.util.stream.Collectors;
  * @date: 2022-06-20 16:56
  */
 @Component("channelLabelDao")
-public class ChannelLabelDaoImpl extends BaseMongoDaoImpl<ChannelLabel> implements IChannelLabelDao {
+public class ChannelLabelDaoImpl extends BaseMongoDaoImpl<ChannelLabel> implements ChannelLabelDao {
 
     private static final String COLLECTION_NAME = "brandkbs_channel_label";
 

src/main/java/com/zhiwei/brandkbs2/dao/impl/ChannelTagDaoImpl.java

+package com.zhiwei.brandkbs2.dao.impl;
+
+import com.zhiwei.brandkbs2.dao.ChannelTagDao;
+import com.zhiwei.brandkbs2.pojo.ChannelTag;
+import org.springframework.stereotype.Component;
+
+/**
+ * @ClassName: ChannelTagDaoImpl
+ * @Description ChannelTagDaoImpl
+ * @author: sjj
+ * @date: 2022-07-13 14:29
+ */
+@Component("channelTagDao")
+public class ChannelTagDaoImpl extends BaseMongoDaoImpl<ChannelTag> implements ChannelTagDao {
+    private static final String COLLECTION_PREFIX = "brandkbs_channel_tag";
+
+    public ChannelTagDaoImpl() {
+        super(COLLECTION_PREFIX);
+    }
+
+    @Override
+    public String getTagByChannelName(String name) {
+        ChannelTag channelTag = findOne("channel", name);
+        if (null == channelTag) {
+            return null;
+        }
+        return channelTag.getTag();
+    }
+}

src/main/java/com/zhiwei/brandkbs2/dao/impl/CustomTagDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.ICustomTagDao;
+import com.zhiwei.brandkbs2.dao.CustomTagDao;
 import com.zhiwei.brandkbs2.pojo.CustomTag;
 import org.springframework.stereotype.Component;
 
@@ -14,7 +14,7 @@ import java.util.List;
  * @date: 2022-07-04 13:46
  */
 @Component("customTagDao")
-public class CustomTagDaoImpl extends BaseMongoDaoImpl<CustomTag> implements ICustomTagDao {
+public class CustomTagDaoImpl extends BaseMongoDaoImpl<CustomTag> implements CustomTagDao {
     private static final String COLLECTION_NAME = "brandkbs_custom_tag";
 
     public CustomTagDaoImpl() {

src/main/java/com/zhiwei/brandkbs2/dao/impl/EventDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IEventDao;
+import com.zhiwei.brandkbs2.dao.EventDao;
 import com.zhiwei.brandkbs2.pojo.Event;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
@@ -13,7 +13,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-05-18 14:45
  */
 @Component("eventDao")
-public class EventDaoImpl extends BaseMongoDaoImpl<Event> implements IEventDao {
+public class EventDaoImpl extends BaseMongoDaoImpl<Event> implements EventDao {
 
     private static final String COLLECTION_NAME = "brandkbs_event";
 

src/main/java/com/zhiwei/brandkbs2/dao/impl/EventDataDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zhiwei.brandkbs2.dao.IEventDataDao;
+import com.zhiwei.brandkbs2.dao.EventDataDao;
 import com.zhiwei.brandkbs2.pojo.ChannelIndex;
 import com.zhiwei.brandkbs2.pojo.Event;
 import com.zhiwei.brandkbs2.pojo.EventData;
@@ -12,6 +12,7 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
 
+import java.util.Calendar;
 import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -23,7 +24,7 @@ import java.util.stream.Collectors;
  * @date: 2022-05-19 17:42
  */
 @Component("eventDataDao")
-public class EventDataDaoImpl extends BaseMongoDaoImpl<EventData> implements IEventDataDao {
+public class EventDataDaoImpl extends BaseMongoDaoImpl<EventData> implements EventDataDao {
 
     private static final String COLLECTION_PREFIX = "brandkbs_event_data";
     private static final String TIME_PATTERN = "yyyy";
@@ -57,7 +58,7 @@ public class EventDataDaoImpl extends BaseMongoDaoImpl<EventData> implements IEv
         Criteria criteria = addChannelIndex(channelIndex);
         // 分组
         Aggregation agg = Aggregation.newAggregation(Aggregation.match(criteria), Aggregation.group("eventId").count().as("eventCount"));
-        AggregationResults<JSONObject> aggregate = mongoTemplate.aggregate(agg, "brandkbs_event_data_2022", JSONObject.class);
+        AggregationResults<JSONObject> aggregate = mongoTemplate.aggregate(agg, getAggreeCollection(), JSONObject.class);
         List<JSONObject> mappedResults = aggregate.getMappedResults();
         return mappedResults.stream().map(json -> json.getString("_id")).collect(Collectors.toList());
     }
@@ -90,4 +91,10 @@ public class EventDataDaoImpl extends BaseMongoDaoImpl<EventData> implements IEv
         return mongoTemplate.count(query, EventData.class, collectionName);
     }
 
+    private String getAggreeCollection() {
+        Calendar date = Calendar.getInstance();
+        int year = date.get(Calendar.YEAR);
+        return COLLECTION_PREFIX + "_" + year;
+    }
+
 }

src/main/java/com/zhiwei/brandkbs2/dao/impl/HighWordDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IHighWordDao;
+import com.zhiwei.brandkbs2.dao.HighWordDao;
 import com.zhiwei.brandkbs2.pojo.HighWord;
 import org.springframework.stereotype.Component;
 
@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-06-06 09:48
  */
 @Component("highWordDao")
-public class HighWordDaoImpl extends BaseMongoDaoImpl<HighWord> implements IHighWordDao {
+public class HighWordDaoImpl extends BaseMongoDaoImpl<HighWord> implements HighWordDao {
     private static final String COLLECTION_NAME = "brandkbs_high_word";
 
     public HighWordDaoImpl() {

src/main/java/com/zhiwei/brandkbs2/dao/impl/ProjectDaoImlp.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IProjectDao;
+import com.zhiwei.brandkbs2.dao.ProjectDao;
 import com.zhiwei.brandkbs2.pojo.Project;
 import org.springframework.stereotype.Component;
 
@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-04-21 13:51
  */
 @Component("projectDao")
-public class ProjectDaoImlp extends BaseMongoDaoImpl<Project> implements IProjectDao {
+public class ProjectDaoImlp extends BaseMongoDaoImpl<Project> implements ProjectDao {
 
     private static final String COLLECTION_NAME = "brandkbs_project";
 

src/main/java/com/zhiwei/brandkbs2/dao/impl/QbjcPojoDao.java → src/main/java/com/zhiwei/brandkbs2/dao/impl/QbjcPojoDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IQbjcPojoDao;
+import com.zhiwei.brandkbs2.dao.QbjcPojoDao;
 import com.zhiwei.qbjc.bean.pojo.common.MessagePlatform;
 import com.zhiwei.qbjc.bean.pojo.common.Tag;
 import org.springframework.data.mongodb.core.MongoTemplate;
@@ -17,7 +17,7 @@ import java.util.List;
  * @date: 2022-06-16 14:24
  */
 @Component("qbjcPojoDao")
-public class QbjcPojoDao implements IQbjcPojoDao {
+public class QbjcPojoDaoImpl implements QbjcPojoDao {
 
     @Resource(name = "secondaryMongoTemplate")
     protected MongoTemplate mongoTemplate;

src/main/java/com/zhiwei/brandkbs2/dao/impl/ReportDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IReportDao;
+import com.alibaba.fastjson.JSONObject;
+import com.zhiwei.brandkbs2.dao.ReportDao;
 import com.zhiwei.brandkbs2.pojo.Report;
+import org.springframework.data.mongodb.core.aggregation.Aggregation;
+import org.springframework.data.mongodb.core.aggregation.AggregationResults;
+import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 /**
  * @ClassName: ReportDaoImpl
  * @Description ReportDaoImpl
@@ -11,10 +17,23 @@ import org.springframework.stereotype.Component;
  * @date: 2022-05-31 18:14
  */
 @Component("reportDao")
-public class ReportDaoImpl extends BaseMongoDaoImpl<Report> implements IReportDao {
+public class ReportDaoImpl extends BaseMongoDaoImpl<Report> implements ReportDao {
     private static final String COLLECTION_NAME = "brandkbs_report";
 
     public ReportDaoImpl() {
         super(COLLECTION_NAME);
     }
+
+    @Override
+    public List<JSONObject> getReportAggCount(String projectId) {
+        // 添加渠道唯一标识
+        Criteria criteria = Criteria.where("projectId").is(projectId).and("status").is(true);
+        // 分组
+        Aggregation aggregation = Aggregation.newAggregation(Aggregation.match(criteria),
+                //
+                Aggregation.project("publishTime", "type").andExpression("add(new java.util.Date(0l),publishTime)").substring(0, 4).as("year"),
+                Aggregation.group("type", "year").count().as("count"));
+        AggregationResults<JSONObject> aggregate = mongoTemplate.aggregate(aggregation, COLLECTION_NAME, JSONObject.class);
+        return aggregate.getMappedResults();
+    }
 }

src/main/java/com/zhiwei/brandkbs2/dao/impl/ReportSettingsDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IReportSettingsDao;
+import com.zhiwei.brandkbs2.dao.ReportSettingsDao;
 import com.zhiwei.brandkbs2.pojo.ReportSettings;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 /**
  * @ClassName: ReportSettingsDaoImpl
  * @Description ReportSettingsDaoImpl
@@ -11,10 +15,17 @@ import org.springframework.stereotype.Component;
  * @date: 2022-05-31 18:14
  */
 @Component("reportSettingsDao")
-public class ReportSettingsDaoImpl extends BaseMongoDaoImpl<ReportSettings> implements IReportSettingsDao {
+public class ReportSettingsDaoImpl extends BaseMongoDaoImpl<ReportSettings> implements ReportSettingsDao {
     private static final String COLLECTION_NAME = "brandkbs_report_settings";
 
     public ReportSettingsDaoImpl() {
         super(COLLECTION_NAME);
     }
+
+    @Override
+    public List<ReportSettings> getReportSettingByProjectWithUsed(String projectId) {
+        Query query = Query.query(Criteria.where("projectId").is(projectId).and("used").is(true));
+        return findList(query);
+    }
+
 }

src/main/java/com/zhiwei/brandkbs2/dao/impl/TagFilterDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.ITagFilterDao;
+import com.zhiwei.brandkbs2.dao.TagFilterDao;
 import com.zhiwei.brandkbs2.pojo.TagFilter;
 import org.springframework.stereotype.Component;
 
@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-06-01 14:26
  */
 @Component("tagFilterDao")
-public class TagFilterDaoImpl extends BaseMongoDaoImpl<TagFilter> implements ITagFilterDao {
+public class TagFilterDaoImpl extends BaseMongoDaoImpl<TagFilter> implements TagFilterDao {
     private static final String COLLECTION_NAME = "brandkbs_tag_filter";
 
     public TagFilterDaoImpl() {

src/main/java/com/zhiwei/brandkbs2/dao/impl/UserDaoImpl.java

 package com.zhiwei.brandkbs2.dao.impl;
 
-import com.zhiwei.brandkbs2.dao.IUserDao;
+import com.zhiwei.brandkbs2.dao.UserDao;
 import com.zhiwei.brandkbs2.pojo.User;
 import org.springframework.stereotype.Component;
 
@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
  * @date: 2022-04-28 18:10
  */
 @Component("userDao")
-public class UserDaoImpl extends BaseMongoDaoImpl<User> implements IUserDao {
+public class UserDaoImpl extends BaseMongoDaoImpl<User> implements UserDao {
 
     private static final String COLLECTION_NAME = "brandkbs_user";
 

src/main/java/com/zhiwei/brandkbs2/easyexcel/listener/EventDataListener.java

@@ -2,8 +2,8 @@ package com.zhiwei.brandkbs2.easyexcel.listener;
 
 import com.alibaba.excel.context.AnalysisContext;
 import com.alibaba.excel.event.AnalysisEventListener;
-import com.zhiwei.brandkbs2.dao.IEventDao;
-import com.zhiwei.brandkbs2.dao.IEventDataDao;
+import com.zhiwei.brandkbs2.dao.EventDao;
+import com.zhiwei.brandkbs2.dao.EventDataDao;
 import com.zhiwei.brandkbs2.easyexcel.dto.UploadEventDataDTO;
 import com.zhiwei.brandkbs2.pojo.Event;
 import com.zhiwei.brandkbs2.pojo.EventData;
@@ -20,15 +20,15 @@ import org.springframework.data.redis.core.StringRedisTemplate;
 public class EventDataListener extends AnalysisEventListener<UploadEventDataDTO> {
 
 
-    private final IEventDao eventDao;
-    private final IEventDataDao eventDataDao;
+    private final EventDao eventDao;
+    private final EventDataDao eventDataDao;
 
     private final StringRedisTemplate stringRedisTemplate;
 
     private final String linkedGroupId;
     private final String redisKey;
 
-    public EventDataListener(IEventDao eventDao, IEventDataDao eventDataDao, StringRedisTemplate stringRedisTemplate, String linkedGroupId,
+    public EventDataListener(EventDao eventDao, EventDataDao eventDataDao, StringRedisTemplate stringRedisTemplate, String linkedGroupId,
                              String redisKey) {
         this.eventDao = eventDao;
         this.eventDataDao = eventDataDao;

src/main/java/com/zhiwei/brandkbs2/easyexcel/listener/EventFileListener.java

@@ -3,7 +3,7 @@ package com.zhiwei.brandkbs2.easyexcel.listener;
 import com.alibaba.excel.context.AnalysisContext;
 import com.alibaba.excel.event.AnalysisEventListener;
 import com.zhiwei.brandkbs2.easyexcel.dto.UploadEventDTO;
-import com.zhiwei.brandkbs2.service.IEventService;
+import com.zhiwei.brandkbs2.service.EventService;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.ArrayList;
@@ -25,12 +25,12 @@ public class EventFileListener extends AnalysisEventListener<UploadEventDTO> {
      * 储存解析数据集合
      */
     private final List<UploadEventDTO> datas = new ArrayList<>(BATCH_COUNT);
-    private final IEventService iEventService;
+    private final EventService EventService;
     private final String projectId;
     private final String linkedGroupId;
 
-    public EventFileListener(IEventService iEventService, String projectId, String linkedGroupId) {
-        this.iEventService = iEventService;
+    public EventFileListener(EventService EventService, String projectId, String linkedGroupId) {
+        this.EventService = EventService;
         this.projectId = projectId;
         this.linkedGroupId = linkedGroupId;
     }
@@ -65,6 +65,6 @@ public class EventFileListener extends AnalysisEventListener<UploadEventDTO> {
      * 保存更新事件信息逻辑
      */
     private void addFileEvent() {
-        datas.forEach(eventDTO -> iEventService.addFileEvent(projectId, linkedGroupId, eventDTO));
+        datas.forEach(eventDTO -> EventService.addFileEvent(projectId, linkedGroupId, eventDTO));
     }
 }

src/main/java/com/zhiwei/brandkbs2/enmus/ChannelEmotion.java

+package com.zhiwei.brandkbs2.enmus;
+
+import lombok.Getter;
+
+/**
+ * @ClassName: ChannelEmotion
+ * @Description 渠道倾向枚举类
+ * @author: sjj
+ * @date: 2022-07-14 17:56
+ */
+public enum ChannelEmotion {
+
+    /**
+     * 正面的
+     */
+    POSITIVE(1, "友好渠道"),
+    /**
+     * 中性的
+     */
+    NEUTRAL(2, "不友好渠道"),
+    /**
+     * 负面的
+     */
+    NEGATIVE(3, "中性渠道");
+
+    @Getter
+    private final int state;
+    @Getter
+    private final String name;
+
+    ChannelEmotion(int state, String name) {
+        this.state = state;
+        this.name = name;
+    }
+
+    public static ChannelEmotion getFromState(int state) {
+        for (ChannelEmotion value : ChannelEmotion.values()) {
+            if (value.state == state) {
+                return value;
+            }
+        }
+        throw new IllegalArgumentException("不识别的类型:" + state);
+    }
+
+}

src/main/java/com/zhiwei/brandkbs2/enmus/ImportantChannelEnum.java

@@ -41,7 +41,7 @@ public enum ImportantChannelEnum {
     QITA("其他");
 
 
-    private String state;
+    private final String state;
 
     ImportantChannelEnum(String state) {
         this.state = state;

src/main/java/com/zhiwei/brandkbs2/enmus/ReportTypeEnum.java

+package com.zhiwei.brandkbs2.enmus;
+
+import lombok.Getter;
+
+import java.util.Arrays;
+import java.util.Calendar;
+import java.util.List;
+
+/**
+ * @author lxj
+ * @version 1.0
+ * @description 平台枚举类
+ * @date 2019/9/2 10:51
+ */
+public enum ReportTypeEnum {
+
+    /**
+     * 月报
+     */
+    MONTH("月报", "每月一号", "月"),
+    /**
+     * 周报
+     */
+    WEEK("周报", "每周一", "周"),
+    /**
+     * 自定义简报
+     */
+    CUSTOM("自定义", "自定义", "周期");
+
+    @Getter
+    private final String state;
+    @Getter
+    private final String publishTime;
+    @Getter
+    private final String describe;
+    // 发布最小间隔1天
+    public static final Long PUSH_LIMIT = 24 * 60 * 60 * 1000L;
+
+    public static final List<String> SORT_LIST = Arrays.asList(ReportTypeEnum.MONTH.getState(), ReportTypeEnum.WEEK.getState(),
+            ReportTypeEnum.CUSTOM.getState());
+
+    ReportTypeEnum(String state, String publishTime, String describe) {
+        this.state = state;
+        this.publishTime = publishTime;
+        this.describe = describe;
+    }
+
+    public static boolean canPublishNowByState(String state) {
+        return canPublishNow(getInstanceByState(state));
+    }
+
+    public static ReportTypeEnum getInstanceByState(String state) {
+        for (ReportTypeEnum value : ReportTypeEnum.values()) {
+            if (value.getState().equals(state)) {
+                return value;
+            }
+        }
+        throw new IllegalArgumentException("不识别的类型:" + state);
+    }
+
+    public static boolean canPublishNow(ReportTypeEnum type) {
+        Calendar cal = Calendar.getInstance();
+        switch (type) {
+            case WEEK:
+                return cal.get(Calendar.DAY_OF_WEEK) == Calendar.MONDAY;
+            case MONTH:
+                return cal.get(Calendar.DAY_OF_MONTH) == 1;
+        }
+        // 自定义简报
+        return true;
+    }
+
+}

src/main/java/com/zhiwei/brandkbs2/es/EsClientDao.java

@@ -171,7 +171,7 @@ public class EsClientDao {
     private List<Map<String, Object>> searchScroll(QueryBuilder queryBuilder, int size, String[] fetchSource) throws IOException {
         SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
         sourceBuilder.query(queryBuilder).size(size).fetchSource(fetchSource, null);
-        return searchScroll(sourceBuilder);
+        return retryTemplate.execute(context -> searchScroll(sourceBuilder));
     }
 
     private Map<ChannelIndex, ChannelIndex.ChannelRecord> searchChannelRecord(long startTime, long endTime) {
@@ -180,7 +180,7 @@ public class EsClientDao {
             QueryBuilder queryBuilder = QueryBuilders.rangeQuery("mtime").gte(startTime).lt(endTime);
             List<Map<String, Object>> results = searchScroll(queryBuilder, 10000, CHANNEL_RECORD_FETCH_SOURCE);
             for (Map<String, Object> result : results) {
-                for (ChannelIndex channelIndex : ChannelIndex.getChannelIndexes(result)) {
+                for (ChannelIndex channelIndex : ChannelIndex.createChannelIndexes(result)) {
                     res.compute(channelIndex, (k, v) -> {
                         if (null == v) {
                             v = new ChannelIndex.ChannelRecord();
@@ -189,8 +189,8 @@ public class EsClientDao {
                             return v.mergeRecord(new ChannelIndex.ChannelRecord((long) result.get(GenericAttribute.ES_TIME), String.valueOf(result.get("id"))));
                         } catch (Exception e) {
                             log.error("searchChannelRecord-error-id:{}", result.get("id"), e);
+                            return null;
                         }
-                        return v;
                     });
                 }
             }

src/main/java/com/zhiwei/brandkbs2/pojo/Channel.java

 package com.zhiwei.brandkbs2.pojo;
 
+import com.zhiwei.brandkbs2.enmus.ChannelEmotion;
 import com.zhiwei.brandkbs2.util.Tools;
 import lombok.Getter;
 import lombok.Setter;
@@ -50,7 +51,7 @@ public class Channel extends ChannelIndex {
     /**
      * 渠道倾向
      */
-    private String emotion = "未定义";
+    private int emotion;
 
     /**
      * 渠道指数
@@ -100,6 +101,17 @@ public class Channel extends ChannelIndex {
         channel.setSource(channelIndex.getSource());
         channel.setLastTime(channelRecord.getLastTime());
         channel.setArticleIds(channelRecord.getArticleIds());
+        // fid 用来便捷搜索
+        channel.setFid(channelIndex.getFid());
+        // TODO 调性随机分配
+        double random = Math.random();
+        if (random < 0.3) {
+            channel.setEmotion(ChannelEmotion.POSITIVE.getState());
+        } else if (random < 0.6) {
+            channel.setEmotion(ChannelEmotion.NEGATIVE.getState());
+        } else {
+            channel.setEmotion(ChannelEmotion.NEUTRAL.getState());
+        }
         return channel;
     }
 

src/main/java/com/zhiwei/brandkbs2/pojo/ChannelIndex.java

@@ -2,6 +2,8 @@ package com.zhiwei.brandkbs2.pojo;
 
 import com.zhiwei.brandkbs2.common.GenericAttribute;
 import com.zhiwei.brandkbs2.common.GlobalPojo;
+import com.zhiwei.brandkbs2.util.Tools;
+import com.zhiwei.qbjc.bean.pojo.common.MessagePlatform;
 import com.zhiwei.qbjc.bean.tools.BeanTools;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
@@ -44,18 +46,44 @@ public class ChannelIndex extends AbstractBaseMongo {
      */
     private String source;
 
-    public static List<ChannelIndex> getChannelIndexes(Map<String, Object> sourceAsMap ) {
+    private String fid;
+
+    public ChannelIndex(String projectId, String linkedGroupId, String platform, String realSource, String source) {
+        this.projectId = projectId;
+        this.linkedGroupId = linkedGroupId;
+        this.platform = platform;
+        this.realSource = realSource;
+        this.source = source;
+        this.fid = Tools.concat(projectId, linkedGroupId, platform, realSource, source);
+    }
+
+    public static ChannelIndex createChannelIndex(Map<String, Object> sourceAsMap, String projectId, String linkedGroupId) {
+        String realSource = String.valueOf(sourceAsMap.get(GenericAttribute.ES_REAL_SOURCE));
+        String source = String.valueOf(sourceAsMap.get(GenericAttribute.ES_SOURCE));
+        Integer c5 = Integer.parseInt(String.valueOf(sourceAsMap.get(GenericAttribute.ES_C5)));
+        Integer foreign = Integer.parseInt(String.valueOf(sourceAsMap.get(GenericAttribute.ES_FOREIGN)));
+        MessagePlatform messagePlatform = BeanTools.filterPlatform(GlobalPojo.PLATFORMS, c5, foreign);
+        if (null == messagePlatform) {
+            return null;
+        }
+        return new ChannelIndex(projectId, linkedGroupId, messagePlatform.getName(), realSource, source);
+    }
+
+    public static List<ChannelIndex> createChannelIndexes(Map<String, Object> sourceAsMap) {
         List<ChannelIndex> res = new ArrayList<>();
         String realSource = String.valueOf(sourceAsMap.get(GenericAttribute.ES_REAL_SOURCE));
         String source = String.valueOf(sourceAsMap.get(GenericAttribute.ES_SOURCE));
         Integer c5 = Integer.parseInt(String.valueOf(sourceAsMap.get(GenericAttribute.ES_C5)));
         Integer foreign = Integer.parseInt(String.valueOf(sourceAsMap.get(GenericAttribute.ES_FOREIGN)));
+        MessagePlatform messagePlatform = BeanTools.filterPlatform(GlobalPojo.PLATFORMS, c5, foreign);
+        if (null == messagePlatform) {
+            return res;
+        }
         List<Map<String, Object>> cacheMaps = (List<Map<String, Object>>) sourceAsMap.get(GenericAttribute.ES_BRANDKBS_CACHE_MAPS);
         for (Map<String, Object> cacheMap : cacheMaps) {
             String projectId = String.valueOf(cacheMap.get(GenericAttribute.PROJECT_ID));
             String linkedGroupId = String.valueOf(cacheMap.get(GenericAttribute.LINKED_GROUP_ID));
-            String platform = BeanTools.filterPlatform(GlobalPojo.PLATFORMS, c5, foreign).getName();
-            res.add(new ChannelIndex(projectId,linkedGroupId, platform, realSource, source));
+            res.add(new ChannelIndex(projectId, linkedGroupId, messagePlatform.getName(), realSource, source));
         }
         return res;
     }
@@ -76,7 +104,7 @@ public class ChannelIndex extends AbstractBaseMongo {
         }
 
         private void setLastTime(Long lastTime) {
-            if (null == this.lastTime || this.lastTime<lastTime) {
+            if (null == this.lastTime || this.lastTime < lastTime) {
                 this.lastTime = lastTime;
             }
         }

src/main/java/com/zhiwei/brandkbs2/pojo/ChannelTag.java

+package com.zhiwei.brandkbs2.pojo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @ClassName: ChannelTag
+ * @Description 渠道标签
+ * @author: sjj
+ * @date: 2022-07-13 14:27
+ */
+@Setter
+@Getter
+public class ChannelTag extends AbstractBaseMongo {
+
+    private String channel;
+
+    private String tag;
+
+}

src/main/java/com/zhiwei/brandkbs2/pojo/MarkFlowEntity.java

@@ -2,10 +2,10 @@ package com.zhiwei.brandkbs2.pojo;
 
 import com.alibaba.fastjson.JSONObject;
 import com.zhiwei.base.category.ClassB;
-import com.zhiwei.base.entity.subclass.CompleteText;
-import com.zhiwei.base.entity.subclass.IncompleteText;
-import com.zhiwei.base.entity.subclass.QAText;
-import com.zhiwei.base.entity.subclass.Video;
+import com.zhiwei.base.entity.subclass.mark.CompleteTextMark;
+import com.zhiwei.base.entity.subclass.mark.IncompleteTextMark;
+import com.zhiwei.base.entity.subclass.mark.QATextMark;
+import com.zhiwei.base.entity.subclass.mark.VideoMark;
 import com.zhiwei.brandkbs2.common.GenericAttribute;
 import com.zhiwei.brandkbs2.util.FlowEntityUtil;
 import com.zhiwei.brandkbs2.util.Tools;
@@ -17,7 +17,6 @@ import org.elasticsearch.search.SearchHit;
 
 import java.util.List;
 import java.util.Objects;
-import java.util.stream.Collectors;
 
 /**
  * @ClassName: MarkFlowEntity
@@ -37,17 +36,23 @@ public class MarkFlowEntity {
     private JSONObject type;
 
     /**
+     * 信息字段
+     */
+    private JSONObject info;
+
+    /**
      * 消息内容
      */
     private Object data;
 
-    public static MarkFlowEntity getInstance(List<JSONObject> tJons) {
+    public static MarkFlowEntity getFoldInstance(List<MarkFlowEntity> entities) {
         // 首条数据为主
-        MarkFlowEntity entity = new MarkFlowEntity(tJons.get(0));
-        if (tJons.size() > 1) {
+        MarkFlowEntity entity = entities.get(0);
+        if (entities.size() > 1) {
             entity.getType().put("fold", true);
-            entity.getType().put("size", tJons.size());
-            entity.setData(tJons.stream().map(json -> new MarkFlowEntity(json).getData()).collect(Collectors.toList()));
+            entity.getType().put("size", entities.size());
+            // info内容
+            entity.getInfo().put("foldInfo", entities);
         }
         return entity;
     }
@@ -79,7 +84,7 @@ public class MarkFlowEntity {
                 if (!Tools.isEmpty(tJson.get("ind_title"))) {
                     tJson.put("ind_title", Tools.filterStrHtmlTag(ObjectUtils.defaultIfNull(tJson.getString("ind_title"), "[\"\"]")));
                 }
-                CompleteText completeText = CompleteText.restoreFromEs(tJson);
+                CompleteTextMark completeText = CompleteTextMark.restoreFromEs(tJson);
                 this.type = FlowEntityUtil.getCompleteTextType(completeText);
                 this.data = completeText;
                 break;
@@ -87,7 +92,7 @@ public class MarkFlowEntity {
                 if (!Tools.isEmpty(tJson.get("ind_full_text"))) {
                     tJson.put("ind_full_text", Tools.filterStrHtmlTag(ObjectUtils.defaultIfNull(tJson.getString("ind_full_text"), "[\"\",\"\"]")));
                 }
-                IncompleteText incompleteText = IncompleteText.restoreFromEs(tJson);
+                IncompleteTextMark incompleteText = IncompleteTextMark.restoreFromEs(tJson);
                 this.type = FlowEntityUtil.getIncompleteTextType(incompleteText);
                 this.data = incompleteText;
                 break;
@@ -101,7 +106,7 @@ public class MarkFlowEntity {
                 if (!Tools.isEmpty(tJson.get("ind_content"))) {
                     tJson.put("ind_content", Tools.filterStrHtmlTag(ObjectUtils.defaultIfNull(tJson.getString("ind_content"), "[\"\"]")));
                 }
-                QAText qaText = QAText.restoreFromEs(tJson);
+                QATextMark qaText = QATextMark.restoreFromEs(tJson);
                 this.type = FlowEntityUtil.getQaTextType(qaText);
                 this.data = qaText;
                 break;
@@ -112,7 +117,7 @@ public class MarkFlowEntity {
                 if (!Tools.isEmpty(tJson.get("ind_title"))) {
                     tJson.put("ind_title", Tools.filterStrHtmlTag(ObjectUtils.defaultIfNull(tJson.getString("ind_title"), "[\"\"]")));
                 }
-                Video video = Video.restoreFromEs(tJson);
+                VideoMark video = VideoMark.restoreFromEs(tJson);
                 this.type = FlowEntityUtil.getVideoType(video);
                 this.data = video;
                 break;

src/main/java/com/zhiwei/brandkbs2/pojo/Report.java

 package com.zhiwei.brandkbs2.pojo;
 
+import com.zhiwei.brandkbs2.auth.UserThreadLocal;
+import com.zhiwei.brandkbs2.config.Constant;
+import com.zhiwei.brandkbs2.enmus.ReportTypeEnum;
+import com.zhiwei.brandkbs2.pojo.dto.ReportDTO;
+import com.zhiwei.brandkbs2.util.Tools;
 import lombok.Getter;
 import lombok.Setter;
+import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.data.mongodb.core.mapping.Document;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -15,7 +22,7 @@ import java.util.List;
 @Setter
 @Getter
 @Document("brandkbs_report")
-public class Report extends AbstractBaseMongo{
+public class Report extends AbstractBaseMongo {
 
     /**
      * 简报标题
@@ -38,24 +45,65 @@ public class Report extends AbstractBaseMongo{
      */
     private String type;
     /**
-     * 是否是最新的
-     */
-    private boolean latest;
-    /**
      * 项目ID
      */
     private String projectId;
     /**
-     * 查看用户ID：0为全项目都可查看
-     */
-    private String userId;
-    /**
      * 竞品信息字符串
      */
     @Deprecated
     private List<String> contends;
     /**
-     * 发布状态
+     * 生成状态
      */
-    private boolean release;
+    private boolean status;
+
+    public static Report createFromReportDTO(ReportDTO reportDTO) {
+        Report report = new Report();
+        report.setTitle(reportDTO.getTitle());
+        report.setStartTime(reportDTO.getStartTime());
+        report.setEndTime(reportDTO.getEndTime());
+        report.setPublishTime(reportDTO.getPublishTime());
+        report.setType(ReportTypeEnum.CUSTOM.getState());
+        report.setProjectId(UserThreadLocal.getProjectId());
+        report.setContends(reportDTO.getContends());
+        return report;
+    }
+
+    public static Report createFromReportSettings(ReportSettings reportSettings, AbstractProject project) {
+        Report report = new Report();
+        Date now = new Date();
+        report.setPublishTime(now.getTime());
+        // 枚举简报类型
+        ReportTypeEnum reportType = ReportTypeEnum.getInstanceByState(reportSettings.getType());
+        // 根据简报类型不同设置
+        report.setType(reportType.getState());
+        switch (reportType) {
+            // 周报月报标题按天级别
+            case WEEK:
+                report.setTitle(project.getBrandName() + Constant.DAY_FORMAT.format(now) + reportSettings.getType());
+                now = Tools.truncDate(new Date(), Constant.DAY_PATTERN);
+                report.setStartTime(DateUtils.addDays(now, -7).getTime());
+                report.setEndTime(now.getTime());
+                break;
+            case MONTH:
+                report.setTitle(project.getBrandName() + Constant.DAY_FORMAT.format(now) + reportSettings.getType());
+                now = Tools.truncDate(new Date(), Constant.DAY_PATTERN);
+                report.setStartTime(DateUtils.addMonths(now, 1).getTime());
+                report.setEndTime(now.getTime());
+                break;
+            case CUSTOM:
+                // 自定义简报标题按小时级别
+                report.setTitle(project.getBrandName() + Constant.HOUR_FORMAT.format(now) + reportSettings.getType());
+                report.setStartTime(reportSettings.getStartTime());
+                report.setEndTime(reportSettings.getEndTime());
+                break;
+            default:
+                throw new IllegalArgumentException("不识别的类型:" + reportSettings.getType());
+        }
+        report.setProjectId(reportSettings.getProjectId());
+        report.setContends(reportSettings.getContendIds());
+        return report;
+    }
+
 }

src/main/java/com/zhiwei/brandkbs2/pojo/ReportSettings.java

@@ -23,6 +23,17 @@ public class ReportSettings extends AbstractBaseMongo {
      * 报告类型
      */
     private String type;
+
+    /**
+     * 数据起始时间
+     */
+    private Long startTime;
+
+    /**
+     * 数据截止时间
+     */
+    private Long endTime;
+
     /**
      * 简报后缀标题
      */

src/main/java/com/zhiwei/brandkbs2/pojo/dto/EventSearchDTO.java

@@ -10,7 +10,7 @@ import java.util.Map;
 
 /**
  * @ClassName: EventSearchDto
- * @Description TODO
+ * @Description EventSearchDto
  * @author: sjj
  * @date: 2022-05-20 14:07
  */

src/main/java/com/zhiwei/brandkbs2/pojo/dto/MarkSearchDTO.java

@@ -99,9 +99,9 @@ public class MarkSearchDTO {
     private JSONObject sorter;
 
     /**
-     * 是否聚合
+     * 是否去重
      */
-    @ApiModelProperty(value = "是否聚合")
-    private boolean aggregation;
+    @ApiModelProperty(value = "是否去重")
+    private boolean duplicate;
 
 }

src/main/java/com/zhiwei/brandkbs2/pojo/dto/ReportDTO.java

+package com.zhiwei.brandkbs2.pojo.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.util.List;
+
+/**
+ * @author sjj
+ * @version 1.0
+ * @description 自定义简报传输类
+ * @date 2022年7月15日16:16:39
+ */
+@Data
+@ToString
+@ApiModel("自定义简报传输类")
+public class ReportDTO {
+
+    /**
+     * 简报标题
+     */
+    @ApiModelProperty("简报标题")
+    private String title;
+    /**
+     * 开始时间
+     */
+    @ApiModelProperty("开始时间")
+    private Long startTime;
+    /**
+     * 结束时间
+     */
+    @ApiModelProperty("结束时间")
+    private Long endTime;
+
+    /**
+     * 发布时间
+     */
+    @ApiModelProperty("发布时间")
+    private Long publishTime;
+
+    /**
+     * 竞品信息
+     */
+    @ApiModelProperty("竞品信息")
+    private List<String> contends;
+    /**
+     * 是否是仅个人查看
+     */
+    @ApiModelProperty("是否是仅个人查看")
+    private boolean personal;
+
+}

src/main/java/com/zhiwei/brandkbs2/pojo/dto/ReportSearchDTO.java

+package com.zhiwei.brandkbs2.pojo.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+/**
+ * @author sjj
+ * @version 1.0
+ * @description 简报搜索传输类
+ * @date 2022年7月15日15:55:49
+ */
+@Data
+@ToString
+@ApiModel("简报搜索传输类")
+public class ReportSearchDTO {
+    /**
+     * 页码
+     */
+    @ApiModelProperty("页码")
+    private int page = 1;
+    /**
+     * 大小
+     */
+    @ApiModelProperty("页码大小")
+    private int pageSize = 10;
+    /**
+     * 开始时间
+     */
+    @ApiModelProperty("开始时间")
+    private Long startTime;
+    /**
+     * 结束时间
+     */
+    @ApiModelProperty("结束时间")
+    private Long endTime;
+    /**
+     * 搜索关键字
+     */
+    @ApiModelProperty(value = "搜索关键字")
+    private String keyword;
+
+    /**
+     * 报告类型
+     */
+    @ApiModelProperty(value = "报告类型")
+    private String type;
+
+    /**
+     * 排序字段
+     */
+    @ApiModelProperty(value = "排序字段")
+    private String sorter = "{\"publishTime\":\"descend\"}";
+
+}

src/main/java/com/zhiwei/brandkbs2/pojo/dto/ReportSettingsDTO.java

 package com.zhiwei.brandkbs2.pojo.dto;
 
+import com.zhiwei.brandkbs2.enmus.ReportTypeEnum;
 import com.zhiwei.brandkbs2.pojo.ReportSettings;
 import com.zhiwei.brandkbs2.util.Tools;
 import io.swagger.annotations.ApiModelProperty;
@@ -63,9 +64,9 @@ public class ReportSettingsDTO {
 
     public static ReportSettingsDTO createFromReportSettings(ReportSettings reportSettings) {
         ReportSettingsDTO reportSettingsDTO = Tools.convertMap(reportSettings, ReportSettingsDTO.class);
-        String publishTime = "每周一";
-        if("月报".equals(reportSettingsDTO.getType())){
-            publishTime = "每月1号";
+        String publishTime = ReportTypeEnum.WEEK.getPublishTime();
+        if (ReportTypeEnum.MONTH.name().equals(reportSettingsDTO.getType())) {
+            publishTime = ReportTypeEnum.MONTH.getPublishTime();
         }
         reportSettingsDTO.setPublishTime(publishTime);
         return reportSettingsDTO;

src/main/java/com/zhiwei/brandkbs2/service/IBehaviorService.java → src/main/java/com/zhiwei/brandkbs2/service/BehaviorService.java

@@ -9,12 +9,12 @@ import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 
 /**
- * @ClassName: IBehaviorService
+ * @ClassName: BehaviorService
  * @Description 用户行为业务接口
  * @author: sjj
  * @date: 2022-05-27 11:05
  */
-public interface IBehaviorService {
+public interface BehaviorService {
     /**
      * 添加用户行为
      *

src/main/java/com/zhiwei/brandkbs2/service/IBrandkbsTaskService.java → src/main/java/com/zhiwei/brandkbs2/service/BrandkbsTaskService.java

@@ -9,7 +9,7 @@ import com.zhiwei.brandkbs2.pojo.BrandkbsTask;
  * @description 定时任务业务接口
  * @date 2019/12/12 13:58
  */
-public interface IBrandkbsTaskService {
+public interface BrandkbsTaskService {
     /**
      * 根据任务名称获取任务
      *

src/main/java/com/zhiwei/brandkbs2/service/IChannelService.java → src/main/java/com/zhiwei/brandkbs2/service/ChannelService.java

@@ -4,18 +4,20 @@ import com.alibaba.fastjson.JSONObject;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportAdminChannelArticleDTO;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportAdminChannelEventDTO;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportChannelDTO;
+import com.zhiwei.brandkbs2.pojo.Channel;
+import com.zhiwei.brandkbs2.pojo.ChannelIndex;
 import com.zhiwei.brandkbs2.pojo.dto.ChannelDTO;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 
 import java.util.List;
 
 /**
- * @ClassName: IChannelService
- * @Description IChannelService
+ * @ClassName: ChannelService
+ * @Description ChannelService
  * @author: sjj
  * @date: 2022-06-16 16:00
  */
-public interface IChannelService {
+public interface ChannelService {
 
     /**
      * 根据搜索条件查询渠道列表

src/main/java/com/zhiwei/brandkbs2/service/ICommonService.java → src/main/java/com/zhiwei/brandkbs2/service/CommonService.java

@@ -12,13 +12,13 @@ import java.util.List;
  * @author: sjj
  * @date: 2022-06-02 11:22
  */
-public interface ICommonService {
+public interface CommonService {
 
     /**
      * 获取qbjcTags
      *
      * @param linkedGroupId 项目组id
-     * @param tagSearches 搜索条件
+     * @param tagSearches   搜索条件
      * @return markTags
      */
     List<MarkerTag> getQbjcTags(String linkedGroupId, TagSearch... tagSearches);
@@ -26,7 +26,7 @@ public interface ICommonService {
     /**
      * 获取qbjcTags
      *
-     * @param groupName 项目组名
+     * @param groupName   项目组名
      * @param tagSearches 搜索条件
      * @return markTags
      */
@@ -34,13 +34,20 @@ public interface ICommonService {
 
     /**
      * 获取qbjcPlatform名称
+     *
      * @return 平台名称
      */
     List<String> getQbjcPlatformNames();
 
     /**
      * 获取qbjcPlatform
+     *
      * @return 平台
      */
     List<JSONObject> getQbjcPlatform(String... includeFields);
+
+    Long[] getTimeRangeMonth();
+
+    Long[] getTimeRangeWeek();
+
 }

src/main/java/com/zhiwei/brandkbs2/service/ICustomTagService.java → src/main/java/com/zhiwei/brandkbs2/service/CustomTagService.java

@@ -12,7 +12,7 @@ import java.util.List;
  * @description 自定义标签业务接口
  * @date 2022年3月24日15:20:16
  */
-public interface ICustomTagService {
+public interface CustomTagService {
 
 	/**
 	 * 分页查询该项目所有自定义标签数据

src/main/java/com/zhiwei/brandkbs2/service/IEventDataService.java → src/main/java/com/zhiwei/brandkbs2/service/EventDataService.java

@@ -3,12 +3,12 @@ package com.zhiwei.brandkbs2.service;
 import com.zhiwei.brandkbs2.pojo.Event;
 
 /**
- * @ClassName: IEventDataService
+ * @ClassName: EventDataService
  * @Description 事件数据业务接口抽象类
  * @author: sjj
  * @date: 2022-05-23 17:48
  */
-public interface IEventDataService {
+public interface EventDataService {
 
     /**
      * 更新事件数据

src/main/java/com/zhiwei/brandkbs2/service/IEventService.java → src/main/java/com/zhiwei/brandkbs2/service/EventService.java

@@ -16,12 +16,12 @@ import org.springframework.web.multipart.MultipartFile;
 import java.util.List;
 
 /**
- * @ClassName: IEventService
+ * @ClassName: EventService
  * @Description 事件管理业务接口
  * @author: sjj
  * @date: 2022-05-17 16:32
  */
-public interface IEventService {
+public interface EventService {
 
     /**
      * 根据事件id查询事件

src/main/java/com/zhiwei/brandkbs2/service/IHighWordService.java → src/main/java/com/zhiwei/brandkbs2/service/HighWordService.java

@@ -7,12 +7,12 @@ import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 import java.util.List;
 
 /**
- * @ClassName: IHighWordService
+ * @ClassName: HighWordService
  * @Description 高频词服务接口
  * @author: sjj
  * @date: 2022-06-06 09:59
  */
-public interface IHighWordService {
+public interface HighWordService {
 
     /**
      * 分页查询高频词列表

src/main/java/com/zhiwei/brandkbs2/service/IReportService.java

-package com.zhiwei.brandkbs2.service;
-
-import com.alibaba.fastjson.JSONObject;
-import com.zhiwei.brandkbs2.pojo.dto.ReportSettingsDTO;
-
-import java.util.Map;
-
-/**
- * @ClassName: IReportService
- * @Description 报告业务接口
- * @author: sjj
- * @date: 2022-05-31 18:00
- */
-public interface IReportService {
-
-    /**
-     * 获取项目报告配置信息
-     *
-     * @return 项目报告配置信息
-     */
-    Map<String,ReportSettingsDTO> getReportSettings();
-
-    /**
-     * 保存报告配置
-     *
-     * @param reportSettingsDTO 报告配置传输类
-     */
-    void upsertReportSettings(ReportSettingsDTO reportSettingsDTO);
-
-    /**
-     * 获取简报分类统计
-     *
-     * @return 获取简报分类统计
-     */
-    JSONObject getReportsAggCount();
-}

src/main/java/com/zhiwei/brandkbs2/service/IMarkDataService.java → src/main/java/com/zhiwei/brandkbs2/service/MarkDataService.java

@@ -8,12 +8,12 @@ import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 import java.util.List;
 
 /**
- * @ClassName: IMarkDataService
+ * @ClassName: MarkDataService
  * @Description: 标注数据服务抽象类
  * @author: sjj
  * @date: 2022-06-28 14:04
  */
-public interface IMarkDataService {
+public interface MarkDataService {
 
     /**
      * @param markSearchDTO 标注数据搜索传输类
@@ -22,6 +22,13 @@ public interface IMarkDataService {
     PageVO<MarkFlowEntity> getYuqingMarkList(MarkSearchDTO markSearchDTO);
 
     /**
+     * 生成聚合列表并返回id
+     *
+     * @return 聚合id
+     */
+    String generateYuqingMarkAggreeList(MarkSearchDTO markSearchDTO);
+
+    /**
      * 舆情标注数据搜索条件
      */
     JSONObject getYuqingMarkCriteria(String linkedGroup);

src/main/java/com/zhiwei/brandkbs2/service/MarkFlowService.java

+package com.zhiwei.brandkbs2.service;
+
+import com.alibaba.fastjson.JSONObject;
+import com.zhiwei.brandkbs2.pojo.MarkFlowEntity;
+
+/**
+ * @ClassName: MarkFlowService
+ * @Description 标注消息流服务抽象类
+ * @author: sjj
+ * @date: 2022-07-13 14:00
+ */
+public interface MarkFlowService {
+
+    /**
+     * 创建标注消息流实体
+     *
+     * @param json
+     * @param projectId
+     * @param linkedGroupId
+     * @return
+     */
+    JSONObject createMarkFlowInfo(JSONObject json, String projectId, String linkedGroupId);
+
+    /**
+     * 快照页信息组装
+     *
+     * @param markFlowEntity 消息实体
+     */
+    String setShotPage(String markFlowEntity);
+
+    /**
+     * 获取标注消息实体
+     *
+     * @param id 缓存id
+     * @return markFlowEntity
+     */
+    MarkFlowEntity getShotPageFromCache(String id);
+
+}

src/main/java/com/zhiwei/brandkbs2/service/IProjectService.java → src/main/java/com/zhiwei/brandkbs2/service/ProjectService.java

@@ -2,6 +2,7 @@ package com.zhiwei.brandkbs2.service;
 
 import com.alibaba.fastjson.JSONObject;
 import com.zhiwei.brandkbs2.pojo.AbstractProject;
+import com.zhiwei.brandkbs2.pojo.Project;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 import com.zhiwei.brandkbs2.pojo.vo.ProjectVO;
 
@@ -13,7 +14,7 @@ import java.util.List;
  * @description 项目业务接口
  * @date 2022年4月18日16:49:10
  */
-public interface IProjectService {
+public interface ProjectService {
 
     /**
      * 添加项目
@@ -97,4 +98,10 @@ public interface IProjectService {
      */
     AbstractProject getProjectByLinkedGroupId(String linkedGroupId);
 
+    /**
+     * 获取所有启动状态下的Project
+     * @return
+     */
+    List<Project> getAllProjectsWithStart();
+
 }

src/main/java/com/zhiwei/brandkbs2/service/ReportService.java

+package com.zhiwei.brandkbs2.service;
+
+import com.alibaba.fastjson.JSONObject;
+import com.zhiwei.brandkbs2.pojo.AbstractProject;
+import com.zhiwei.brandkbs2.pojo.Report;
+import com.zhiwei.brandkbs2.pojo.ReportSettings;
+import com.zhiwei.brandkbs2.pojo.dto.ReportDTO;
+import com.zhiwei.brandkbs2.pojo.dto.ReportSearchDTO;
+import com.zhiwei.brandkbs2.pojo.dto.ReportSettingsDTO;
+import com.zhiwei.brandkbs2.pojo.vo.PageVO;
+import org.apache.commons.lang3.tuple.Pair;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName: ReportService
+ * @Description 报告业务接口
+ * @author: sjj
+ * @date: 2022-05-31 18:00
+ */
+public interface ReportService {
+
+    /**
+     * 获取项目报告配置信息
+     *
+     * @return 项目报告配置信息
+     */
+    Map<String, ReportSettingsDTO> getReportSettings();
+
+    List<Report> getCustomReportByStatus(String projectId,boolean status);
+
+    /**
+     * 保存报告配置
+     *
+     * @param reportSettingsDTO 报告配置传输类
+     */
+    void upsertReportSettings(ReportSettingsDTO reportSettingsDTO);
+
+    /**
+     * 开闭简报设置使用
+     *
+     * @param id
+     * @param used
+     */
+    @Deprecated
+    void switchReportSettingsUsed(String id,boolean used);
+
+    /**
+     * 开闭简报生成状态
+     *
+     * @param id
+     * @param status
+     */
+    void switchReportStatus(String id,boolean status);
+
+    /**
+     * 获取简报分类统计
+     *
+     * @return 获取简报分类统计
+     */
+    JSONObject getReportsAggCount();
+
+    /**
+     * 生成简报信息并返回
+     *
+     * @param reportSettings
+     * @param project
+     * @return 新否新简报&&简报
+     */
+    Pair<Boolean,Report> generateReportBySettings(ReportSettings reportSettings, AbstractProject project);
+
+    /**
+     * 获取PC端报告信息
+     *
+     * @param id    报告ID
+     * @param cache 是否优先读取缓存
+     * @return 获取PC端报告信息
+     */
+    JSONObject getPcReportAnalyze(String id, boolean cache);
+
+
+    /**
+     * 获取PC端报告信息
+     *
+     * @param report 报告
+     * @param cache  是否优先读取缓存
+     * @return 获取PC端报告信息
+     */
+    JSONObject getPcReportAnalyze(Report report, boolean cache);
+
+    /**
+     * 分页查询报告列表
+     *
+     * @param reportSearch 报告搜索对象
+     * @return 分页查询报告列表
+     */
+    PageVO<JSONObject> findReportList(ReportSearchDTO reportSearch);
+
+    /**
+     * 添加自定义简报
+     *
+     * @param reportDTO
+     */
+    void addCustomReport(ReportDTO reportDTO);
+
+    /**
+     * 删除简报
+     *
+     * @param id
+     */
+    void deleteReportById(String id);
+
+}

src/main/java/com/zhiwei/brandkbs2/service/ISystemInfoService.java → src/main/java/com/zhiwei/brandkbs2/service/SystemInfoService.java

@@ -6,12 +6,12 @@ import com.zhiwei.qbjc.bean.pojo.common.Tag;
 import java.util.List;
 
 /**
- * @ClassName: ISystemInfoService
+ * @ClassName: SystemInfoService
  * @Description 监测系统相关infoService
  * @author: sjj
  * @date: 2022-06-16 14:19
  */
-public interface ISystemInfoService {
+public interface SystemInfoService {
 
     /**
      * 获取监测系统Platforms

src/main/java/com/zhiwei/brandkbs2/service/ITagFilterService.java → src/main/java/com/zhiwei/brandkbs2/service/TagFilterService.java

@@ -10,7 +10,7 @@ import java.util.List;
  * @author: sjj
  * @date: 2022-06-01 13:40
  */
-public interface ITagFilterService {
+public interface TagFilterService {
 
     /**
      * 获取在用筛选器列表

src/main/java/com/zhiwei/brandkbs2/service/ITaskService.java → src/main/java/com/zhiwei/brandkbs2/service/TaskService.java

 package com.zhiwei.brandkbs2.service;
 
 /**
- * @ClassName: ITaskService
+ * @ClassName: TaskService
  * @Description 定时服务抽象类
  * @author: sjj
  * @date: 2022-06-16 15:27
  */
-public interface ITaskService{
+public interface TaskService{
 
     /**
-     * 渠道记录
+     * 消息进量记录
      */
     void messageFlowCount(int day);
 
     /**
-     * 简报推送
+     * 生成简报任务并推送
      */
-    void reportSend();
+    void generateReportAndSend();
 
 }

src/main/java/com/zhiwei/brandkbs2/service/IUserService.java → src/main/java/com/zhiwei/brandkbs2/service/UserService.java

@@ -8,12 +8,12 @@ import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 import java.util.List;
 
 /**
- * @ClassName: IUserService
+ * @ClassName: UserService
  * @Description 用户管理服务接口
  * @author: sjj
  * @date: 2022-04-28 14:58
  */
-public interface IUserService {
+public interface UserService {
 
     /**
      * 用户登录

src/main/java/com/zhiwei/brandkbs2/service/impl/BehaviorServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
-import com.zhiwei.brandkbs2.dao.IBehaviorDao;
-import com.zhiwei.brandkbs2.dao.IUserDao;
+import com.zhiwei.brandkbs2.dao.BehaviorDao;
+import com.zhiwei.brandkbs2.dao.UserDao;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportBehaviorDTO;
 import com.zhiwei.brandkbs2.enmus.RoleEnum;
 import com.zhiwei.brandkbs2.listener.ApplicationProjectListener;
@@ -11,7 +11,7 @@ import com.zhiwei.brandkbs2.pojo.User;
 import com.zhiwei.brandkbs2.pojo.UserRole;
 import com.zhiwei.brandkbs2.pojo.vo.BehaviorVO;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
-import com.zhiwei.brandkbs2.service.IBehaviorService;
+import com.zhiwei.brandkbs2.service.BehaviorService;
 import com.zhiwei.brandkbs2.util.MongoUtil;
 import com.zhiwei.brandkbs2.util.Tools;
 import org.apache.commons.collections4.CollectionUtils;
@@ -39,14 +39,14 @@ import java.util.stream.Collectors;
  * @date: 2022-05-27 13:41
  */
 @Service("behaviorServiceImpl")
-public class BehaviorServiceImpl implements IBehaviorService {
+public class BehaviorServiceImpl implements BehaviorService {
     public static final Logger log = LogManager.getLogger(BehaviorServiceImpl.class);
 
     @Resource(name = "behaviorDao")
-    private IBehaviorDao behaviorDao;
+    private BehaviorDao behaviorDao;
 
     @Resource(name = "userDao")
-    private IUserDao userDao;
+    private UserDao userDao;
 
     @Resource(name = "mongoUtil")
     private com.zhiwei.brandkbs2.util.MongoUtil mongoUtil;

src/main/java/com/zhiwei/brandkbs2/service/impl/BrandkbsTaskServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
 import com.zhiwei.brandkbs2.config.Constant;
-import com.zhiwei.brandkbs2.dao.IBrandkbsTaskDao;
+import com.zhiwei.brandkbs2.dao.BrandkbsTaskDao;
 import com.zhiwei.brandkbs2.pojo.BrandkbsTask;
-import com.zhiwei.brandkbs2.service.IBrandkbsTaskService;
+import com.zhiwei.brandkbs2.service.BrandkbsTaskService;
 import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
 
@@ -17,10 +17,10 @@ import java.util.Objects;
  * @date: 2022-07-12 17:38
  */
 @Service
-public class BrandkbsTaskServiceImpl implements IBrandkbsTaskService {
+public class BrandkbsTaskServiceImpl implements BrandkbsTaskService {
 
     @Resource(name = "brandkbsTaskDao")
-    private IBrandkbsTaskDao brandkbsTaskDao;
+    private BrandkbsTaskDao brandkbsTaskDao;
 
     /**
      * 根据任务名称获取任务
@@ -59,6 +59,9 @@ public class BrandkbsTaskServiceImpl implements IBrandkbsTaskService {
      */
     @Override
     public void resetTask(BrandkbsTask task, Long nextTime) {
+        if (null == task) {
+            return;
+        }
         Update set = Update.update("version", Constant.INIT_VERSION).set("executableTime", nextTime);
         brandkbsTaskDao.updateOneByIdWithField(task.getId(), set);
     }

src/main/java/com/zhiwei/brandkbs2/service/impl/ChannelServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zhiwei.brandkbs2.dao.IChannelDao;
-import com.zhiwei.brandkbs2.dao.IChannelLabelDao;
-import com.zhiwei.brandkbs2.dao.IEventDao;
-import com.zhiwei.brandkbs2.dao.IEventDataDao;
+import com.zhiwei.brandkbs2.dao.ChannelDao;
+import com.zhiwei.brandkbs2.dao.ChannelLabelDao;
+import com.zhiwei.brandkbs2.dao.EventDao;
+import com.zhiwei.brandkbs2.dao.EventDataDao;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportAdminChannelArticleDTO;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportAdminChannelEventDTO;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportChannelDTO;
@@ -16,7 +16,7 @@ import com.zhiwei.brandkbs2.model.CommonCodeEnum;
 import com.zhiwei.brandkbs2.pojo.*;
 import com.zhiwei.brandkbs2.pojo.dto.ChannelDTO;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
-import com.zhiwei.brandkbs2.service.IChannelService;
+import com.zhiwei.brandkbs2.service.ChannelService;
 import com.zhiwei.brandkbs2.util.MongoUtil;
 import com.zhiwei.brandkbs2.util.Tools;
 import org.apache.commons.collections4.CollectionUtils;
@@ -38,19 +38,19 @@ import java.util.stream.Collectors;
  * @date: 2022-06-16 16:07
  */
 @Service("channelServiceImpl")
-public class ChannelServiceImpl implements IChannelService {
+public class ChannelServiceImpl implements ChannelService {
 
     @Resource(name = "eventDataDao")
-    IEventDataDao eventDataDao;
+    EventDataDao eventDataDao;
 
     @Resource(name = "channelDao")
-    IChannelDao channelDao;
+    ChannelDao channelDao;
 
     @Resource(name = "eventDao")
-    IEventDao eventDao;
+    EventDao eventDao;
 
     @Resource(name = "channelLabelDao")
-    IChannelLabelDao channelLabelDao;
+    ChannelLabelDao channelLabelDao;
 
     @Resource(name = "esClientDao")
     EsClientDao esClientDao;

src/main/java/com/zhiwei/brandkbs2/service/impl/CommonServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zhiwei.brandkbs2.service.ICommonService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.common.GenericAttribute;
+import com.zhiwei.brandkbs2.config.Constant;
+import com.zhiwei.brandkbs2.service.CommonService;
+import com.zhiwei.brandkbs2.service.ProjectService;
+import com.zhiwei.brandkbs2.util.Tools;
 import com.zhiwei.middleware.mark.pojo.enums.TagField;
 import com.zhiwei.middleware.mark.service.MarkerClient;
 import com.zhiwei.middleware.mark.vo.MarkerTag;
 import com.zhiwei.middleware.mark.vo.TagSearch;
+import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpEntity;
@@ -14,10 +18,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.web.client.RestTemplate;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -27,13 +28,13 @@ import java.util.stream.Collectors;
  * @date: 2022-06-02 11:23
  */
 @Service("commonServiceImpl")
-public class CommonServiceImpl implements ICommonService {
+public class CommonServiceImpl implements CommonService {
 
     @Value("${qbjc.platform.url}")
     private String qbjcPlatformUrl;
 
     @Resource(name = "projectServiceImpl")
-    private IProjectService projectService;
+    private ProjectService projectService;
 
     @Autowired
     private MarkerClient markClient;
@@ -71,8 +72,7 @@ public class CommonServiceImpl implements ICommonService {
     @Override
     public List<String> getQbjcPlatformNames() {
         HttpEntity<JSONObject> entity = restTemplate.getForEntity(qbjcPlatformUrl, JSONObject.class);
-        return Objects.requireNonNull(entity.getBody()).getJSONArray("data").toJavaList(JSONObject.class).stream().map(json -> json.getString("name"))
-                .collect(Collectors.toList());
+        return Objects.requireNonNull(entity.getBody()).getJSONArray("data").toJavaList(JSONObject.class).stream().map(json -> json.getString("name")).collect(Collectors.toList());
     }
 
     @Override
@@ -90,4 +90,18 @@ public class CommonServiceImpl implements ICommonService {
         }).collect(Collectors.toList());
     }
 
+    @Override
+    public Long[] getTimeRangeMonth() {
+        long endTime = DateUtils.addDays(Tools.truncDate(new Date(), Constant.DAY_PATTERN), 1).getTime();
+        long startTime = DateUtils.addMonths(new Date(endTime), -1).getTime();
+        return new Long[]{startTime, endTime};
+    }
+
+    @Override
+    public Long[] getTimeRangeWeek() {
+        long endTime = DateUtils.addDays(Tools.truncDate(new Date(), Constant.DAY_PATTERN), 1).getTime();
+        long startTime = DateUtils.addWeeks(new Date(endTime), -1).getTime();
+        return new Long[]{startTime, endTime};
+    }
+
 }

src/main/java/com/zhiwei/brandkbs2/service/impl/CustomTagServiceImpl.java

@@ -2,7 +2,7 @@
 package com.zhiwei.brandkbs2.service.impl;
 
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
-import com.zhiwei.brandkbs2.dao.ICustomTagDao;
+import com.zhiwei.brandkbs2.dao.CustomTagDao;
 import com.zhiwei.brandkbs2.enmus.response.CustomTagCodeEnum;
 import com.zhiwei.brandkbs2.es.EsClientDao;
 import com.zhiwei.brandkbs2.exception.ExceptionCast;
@@ -10,7 +10,7 @@ import com.zhiwei.brandkbs2.model.CommonCodeEnum;
 import com.zhiwei.brandkbs2.pojo.CustomTag;
 import com.zhiwei.brandkbs2.pojo.vo.CustomTagVo;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
-import com.zhiwei.brandkbs2.service.ICustomTagService;
+import com.zhiwei.brandkbs2.service.CustomTagService;
 import org.apache.commons.collections.CollectionUtils;
 import org.elasticsearch.action.DocWriteResponse;
 import org.elasticsearch.action.update.UpdateRequest;
@@ -30,10 +30,10 @@ import java.util.stream.Collectors;
  * @date 2022年3月24日18:22:53
  */
 @Service
-public class CustomTagServiceImpl implements ICustomTagService {
+public class CustomTagServiceImpl implements CustomTagService {
 
     @Resource(name = "customTagDao")
-    private ICustomTagDao customTagDao;
+    private CustomTagDao customTagDao;
 
     @Resource(name = "esClient")
     private RestHighLevelClient esClient;

src/main/java/com/zhiwei/brandkbs2/service/impl/EventDataServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
-import com.zhiwei.brandkbs2.dao.IEventDao;
-import com.zhiwei.brandkbs2.dao.IEventDataDao;
+import com.zhiwei.brandkbs2.dao.EventDao;
+import com.zhiwei.brandkbs2.dao.EventDataDao;
 import com.zhiwei.brandkbs2.es.EsClientDao;
 import com.zhiwei.brandkbs2.pojo.Event;
 import com.zhiwei.brandkbs2.pojo.EventData;
-import com.zhiwei.brandkbs2.service.IEventDataService;
+import com.zhiwei.brandkbs2.service.EventDataService;
 import com.zhiwei.brandkbs2.util.Tools;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -25,14 +25,14 @@ import java.util.stream.Collectors;
  * @date: 2022-05-23 17:49
  */
 @Service("eventDataServiceImpl")
-public class EventDataServiceImpl implements IEventDataService {
+public class EventDataServiceImpl implements EventDataService {
     public static final Logger log = LogManager.getLogger(EventDataServiceImpl.class);
 
     @Resource(name = "eventDao")
-    private IEventDao eventDao;
+    private EventDao eventDao;
 
     @Resource(name = "eventDataDao")
-    private IEventDataDao eventDataDao;
+    private EventDataDao eventDataDao;
 
     @Resource(name = "esClientDao")
     private EsClientDao esClientDao;

src/main/java/com/zhiwei/brandkbs2/service/impl/EventServiceImpl.java

@@ -5,8 +5,8 @@ import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Lists;
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
 import com.zhiwei.brandkbs2.common.RedisKeyPrefix;
-import com.zhiwei.brandkbs2.dao.IEventDao;
-import com.zhiwei.brandkbs2.dao.IEventDataDao;
+import com.zhiwei.brandkbs2.dao.EventDao;
+import com.zhiwei.brandkbs2.dao.EventDataDao;
 import com.zhiwei.brandkbs2.easyexcel.EasyExcelUtil;
 import com.zhiwei.brandkbs2.easyexcel.config.ReadExcelDTO;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportEventDTO;
@@ -26,9 +26,9 @@ import com.zhiwei.brandkbs2.pojo.dto.YqEventDTO;
 import com.zhiwei.brandkbs2.pojo.vo.EventVO;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 import com.zhiwei.brandkbs2.pojo.vo.YqEventSearchVO;
-import com.zhiwei.brandkbs2.service.IEventDataService;
-import com.zhiwei.brandkbs2.service.IEventService;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.EventDataService;
+import com.zhiwei.brandkbs2.service.EventService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import com.zhiwei.brandkbs2.util.MongoUtil;
 import com.zhiwei.brandkbs2.util.Tools;
 import org.apache.commons.collections4.CollectionUtils;
@@ -62,7 +62,7 @@ import java.util.stream.Collectors;
  * @date: 2022-05-17 16:36
  */
 @Service("eventServiceImpl")
-public class EventServiceImpl implements IEventService {
+public class EventServiceImpl implements EventService {
     private static final Logger log = LogManager.getLogger(EventServiceImpl.class);
 
     @Value("${qbjc.event.tag.url}")
@@ -75,16 +75,16 @@ public class EventServiceImpl implements IEventService {
     private String brandkbsFileUrl;
 
     @Resource(name = "eventDao")
-    private IEventDao eventDao;
+    private EventDao eventDao;
 
     @Resource(name = "eventDataDao")
-    private IEventDataDao eventDataDao;
+    private EventDataDao eventDataDao;
 
     @Resource(name = "eventDataServiceImpl")
-    private IEventDataService eventDataService;
+    private EventDataService eventDataService;
 
     @Resource(name = "projectServiceImpl")
-    private IProjectService projectService;
+    private ProjectService projectService;
 
     @Resource(name = "mongoUtil")
     private com.zhiwei.brandkbs2.util.MongoUtil mongoUtil;
@@ -225,7 +225,7 @@ public class EventServiceImpl implements IEventService {
 
     @Override
     public JSONObject uploadEventDatas(String linkedGroupId, MultipartFile file) {
-        String uuid = UUID.randomUUID().toString().replace("-", "");
+        String uuid = Tools.getUUID();
         String redisKey = RedisKeyPrefix.eventDataProgressKey(uuid);
         stringRedisTemplate.opsForValue().set(redisKey, "0");
         ApplicationProjectListener.getThreadPool().execute(() -> {

src/main/java/com/zhiwei/brandkbs2/service/impl/HighWordServiceImpl.java

@@ -2,11 +2,11 @@ package com.zhiwei.brandkbs2.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
-import com.zhiwei.brandkbs2.dao.IHighWordDao;
+import com.zhiwei.brandkbs2.dao.HighWordDao;
 import com.zhiwei.brandkbs2.easyexcel.dto.ExportHighWordDTO;
 import com.zhiwei.brandkbs2.pojo.HighWord;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
-import com.zhiwei.brandkbs2.service.IHighWordService;
+import com.zhiwei.brandkbs2.service.HighWordService;
 import com.zhiwei.brandkbs2.util.MongoUtil;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
@@ -23,10 +23,10 @@ import java.util.stream.Collectors;
  * @date: 2022-06-06 10:02
  */
 @Service("highWordServiceImpl")
-public class HighWordServiceImpl implements IHighWordService {
+public class HighWordServiceImpl implements HighWordService {
 
     @Resource(name = "highWordDao")
-    IHighWordDao highWordDao;
+    HighWordDao highWordDao;
 
     @Resource(name = "mongoUtil")
     private com.zhiwei.brandkbs2.util.MongoUtil mongoUtil;

src/main/java/com/zhiwei/brandkbs2/service/impl/MarkFlowServiceImpl.java

+package com.zhiwei.brandkbs2.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.zhiwei.base.category.ClassD;
+import com.zhiwei.brandkbs2.auth.UserThreadLocal;
+import com.zhiwei.brandkbs2.common.GenericAttribute;
+import com.zhiwei.brandkbs2.config.Constant;
+import com.zhiwei.brandkbs2.dao.ChannelTagDao;
+import com.zhiwei.brandkbs2.dao.ChannelDao;
+import com.zhiwei.brandkbs2.exception.ExceptionCast;
+import com.zhiwei.brandkbs2.model.CommonCodeEnum;
+import com.zhiwei.brandkbs2.pojo.Channel;
+import com.zhiwei.brandkbs2.pojo.ChannelIndex;
+import com.zhiwei.brandkbs2.pojo.MarkFlowEntity;
+import com.zhiwei.brandkbs2.service.MarkFlowService;
+import com.zhiwei.brandkbs2.util.RedisUtil;
+import com.zhiwei.brandkbs2.util.Tools;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * @ClassName: MarkFlowServiceImpl
+ * @Description 标注消息流服务实现类
+ * @author: sjj
+ * @date: 2022-07-13 14:00
+ */
+@Service("markFlowServiceImpl")
+public class MarkFlowServiceImpl implements MarkFlowService {
+
+    @Resource(name = "channelTagDao")
+    ChannelTagDao channelTagDao;
+
+    @Resource(name = "channelDao")
+    ChannelDao channelDao;
+
+    @Resource(name = "redisUtil")
+    RedisUtil redisUtil;
+
+    @Override
+    public JSONObject createMarkFlowInfo(JSONObject json, String projectId, String linkedGroupId) {
+        JSONObject resultInfo = createInfoWithEmotion(json);
+        resultInfo.put("sourceDetails", getSourceDetails(json, projectId, linkedGroupId));
+        return resultInfo;
+    }
+
+    @Override
+    public String setShotPage(String markFlowEntity) {
+        MarkFlowEntity data = JSON.parseObject(markFlowEntity, MarkFlowEntity.class);
+        String id = JSON.parseObject(JSON.toJSONString(data.getData())).getString("id");
+        String key = RedisUtil.getShotPageKey(id, UserThreadLocal.getProjectId());
+        redisUtil.setExpire(key, markFlowEntity);
+        return id;
+    }
+
+    @Override
+    public MarkFlowEntity getShotPageFromCache(String id) {
+        String key = RedisUtil.getShotPageKey(id, UserThreadLocal.getProjectId());
+        String data = redisUtil.get(key);
+        if (null == data) {
+            ExceptionCast.cast(CommonCodeEnum.FAIL.message("缓存不存在或已过期"));
+        }
+        return JSON.parseObject(data, MarkFlowEntity.class);
+//        JSONObject dataJson = JSON.parseObject(data);
+//        FilterInfo filterInfo = null;
+//        JSONObject filterInfoJson = dataJson.getJSONObject("filterInfo");
+//        if (Objects.nonNull(filterInfoJson) && filterInfoJson.containsKey("selectType")
+//                && filterInfoJson.containsKey("filterMap")) {
+//            SelectType selectType = SelectType.valueOf(filterInfoJson.getString("selectType"));
+//            JSONObject filterMap = filterInfoJson.getJSONObject("filterMap");
+//            // 2020/5/27 15:17 论坛回答部分特殊去重解析
+//            if (SelectType.SPEC_FORUM_CONTENT_MARK == selectType) {
+//                filterInfo = FilterInfo.getInstanceWithNoTime(selectType,
+//                        requireNonNull(filterMap.getString("url"), "url 为空"),
+//                        requireNonNull(filterMap.getString("text"), "text 为空"),
+//                        requireNonNull(filterMap.getString("spareText"), "spareText 为空"),
+//                        requireNonNull(filterMap.getString("source"), "source 为空"), filterMap.getString("mgroup"));
+//            } else {
+//                filterInfo = new FilterInfo(selectType, requireNonNull(filterMap.getString("unique"), "unique 为空"),
+//                        requireNonNull(filterMap.getString("url"), "url 为空"),
+//                        requireNonNull(filterMap.getLong("time"), "time 为空"),
+//                        requireNonNull(filterMap.getString("text"), "text 为空"),
+//                        requireNonNull(filterMap.getString("source"), "source 为空"), filterMap.getString("mgroup"));
+//            }
+//        }
+    }
+
+    private JSONObject createInfoWithEmotion(JSONObject json) {
+        JSONObject info = new JSONObject();
+        String emotion = Tools.getEmotion(json);
+        // tag
+        if (null == emotion) {
+            info.put("hasTag", false);
+        } else {
+            info.put("hasTag", true);
+            // 敏感算作负面
+            info.put("showEmotion", Constant.EMOTION_SENSITIVE.equals(emotion) ? Constant.EMOTION_NEGATIVE : emotion);
+        }
+        return info;
+    }
+
+    private JSONObject getSourceDetails(JSONObject tJson, String projectId, String linkedGroupId) {
+        JSONObject sourceDetails = new JSONObject();
+        String source = tJson.getString(GenericAttribute.ES_SOURCE);
+        // 是否原创
+        if (tJson.containsKey(GenericAttribute.ES_ROOT_SOURCE)
+                && isOrigin(source, tJson.getString(GenericAttribute.ES_ROOT_SOURCE))) {
+            sourceDetails.put("rootPublish", "原创");
+        }
+        // C4,realSource提取展示
+        sourceDetails.put("clientFrom", getClientFrom(tJson.getIntValue(GenericAttribute.ES_C4),
+                tJson.getString(GenericAttribute.ES_REAL_SOURCE)));
+        // source
+        sourceDetails.put("source", source);
+        // 粉丝量提取
+        Long followersNum = tJson.getLongValue(GenericAttribute.ES_FOLLOWERS_NUM);
+        sourceDetails.put("followersNum", followersNum);
+        // 渠道标签
+        sourceDetails.put("channelTag", channelTagDao.getTagByChannelName(source));
+        // 渠道倾向及id
+        Channel channel = channelDao.queryUnique(ChannelIndex.createChannelIndex(tJson, projectId, linkedGroupId));
+        if (null != channel) {
+            sourceDetails.put("channelId", channel.getId());
+            sourceDetails.put("channelEmotion", channel.getEmotion());
+        } else {
+            sourceDetails.put("channelId", null);
+            sourceDetails.put("channelEmotion", null);
+        }
+        return sourceDetails;
+    }
+
+    /**
+     * 按c4、origin获取ClientFrom
+     *
+     * @param c4
+     * @param realSource
+     * @return String
+     */
+    public String getClientFrom(int c4, String realSource) {
+        if (Tools.isEmpty(realSource)) {
+            return ClassD.TypeD.fromEncode(c4).title();
+        } else {
+            return realSource;
+        }
+    }
+
+    /**
+     * 网媒来源是否原创
+     *
+     * @param source
+     * @param rootSource
+     * @return boolean
+     */
+    public boolean isOrigin(String source, String rootSource) {
+        // 条件一 泛用
+        return rootSource.contains(source) || source.contains(rootSource);
+    }
+
+
+}

src/main/java/com/zhiwei/brandkbs2/service/impl/ProjectServiceImpl.java

@@ -2,8 +2,8 @@ package com.zhiwei.brandkbs2.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
-import com.zhiwei.brandkbs2.dao.IProjectDao;
-import com.zhiwei.brandkbs2.dao.IUserDao;
+import com.zhiwei.brandkbs2.dao.ProjectDao;
+import com.zhiwei.brandkbs2.dao.UserDao;
 import com.zhiwei.brandkbs2.enmus.response.ProjectCodeEnum;
 import com.zhiwei.brandkbs2.exception.ExceptionCast;
 import com.zhiwei.brandkbs2.model.CommonCodeEnum;
@@ -13,10 +13,11 @@ import com.zhiwei.brandkbs2.pojo.Project;
 import com.zhiwei.brandkbs2.pojo.User;
 import com.zhiwei.brandkbs2.pojo.vo.PageVO;
 import com.zhiwei.brandkbs2.pojo.vo.ProjectVO;
-import com.zhiwei.brandkbs2.service.IProjectService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import com.zhiwei.brandkbs2.util.MongoUtil;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
@@ -32,13 +33,13 @@ import java.util.stream.Collectors;
  * @date 2022年4月18日16:49:10
  */
 @Service("projectServiceImpl")
-public class ProjectServiceImpl implements IProjectService {
+public class ProjectServiceImpl implements ProjectService {
 
     @Resource(name = "userDao")
-    private IUserDao userDao;
+    private UserDao userDao;
 
     @Resource(name = "projectDao")
-    private IProjectDao projectDao;
+    private ProjectDao projectDao;
 
     @Resource(name = "mongoUtil")
     private com.zhiwei.brandkbs2.util.MongoUtil mongoUtil;
@@ -62,7 +63,7 @@ public class ProjectServiceImpl implements IProjectService {
         }
         //给超管添加该项目权限，并且初始化预警推送 TODO
 //            for (Integer SUPER_ADMINUid : userMapper.getAllSUPER_ADMINUids()) {
-//                iUserService.insertAdminRoleAndWarn(SUPER_ADMINUid, project.getId());
+//                UserService.insertAdminRoleAndWarn(SUPER_ADMINUid, project.getId());
 //            }
         projectDao.insertOneWithoutId(projectVO.creatProject(new Date()));
     }
@@ -218,6 +219,11 @@ public class ProjectServiceImpl implements IProjectService {
         return null;
     }
 
+    @Override
+    public List<Project> getAllProjectsWithStart() {
+        return projectDao.findList(Query.query(Criteria.where("isStart").is(true)));
+    }
+
 //    public JSONObject getUserInfoAndProjectConfig(User user) {
 //        long start = System.currentTimeMillis();
 //        JSONObject result = new JSONObject();

src/main/java/com/zhiwei/brandkbs2/service/impl/SystemInfoServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
-import com.zhiwei.brandkbs2.dao.IQbjcPojoDao;
-import com.zhiwei.brandkbs2.service.ISystemInfoService;
+import com.zhiwei.brandkbs2.dao.QbjcPojoDao;
+import com.zhiwei.brandkbs2.service.SystemInfoService;
 import com.zhiwei.qbjc.bean.pojo.common.MessagePlatform;
 import com.zhiwei.qbjc.bean.pojo.common.Tag;
 import org.springframework.stereotype.Service;
@@ -10,16 +10,16 @@ import javax.annotation.Resource;
 import java.util.List;
 
 /**
- * @ClassName: ISystemInfoServiceImpl
- * @Description ISystemInfoServiceImpl
+ * @ClassName: SystemInfoServiceImpl
+ * @Description SystemInfoServiceImpl
  * @author: sjj
  * @date: 2022-06-16 14:21
  */
 @Service("systemInfoServiceImpl")
-public class SystemInfoServiceImpl implements ISystemInfoService {
+public class SystemInfoServiceImpl implements SystemInfoService {
 
     @Resource(name = "qbjcPojoDao")
-    private IQbjcPojoDao qbjcPojoDao;
+    private QbjcPojoDao qbjcPojoDao;
 
     @Override
     public List<MessagePlatform> getPlatforms() {

src/main/java/com/zhiwei/brandkbs2/service/impl/TagFilterServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
 import com.zhiwei.brandkbs2.auth.UserThreadLocal;
-import com.zhiwei.brandkbs2.dao.ITagFilterDao;
+import com.zhiwei.brandkbs2.dao.TagFilterDao;
 import com.zhiwei.brandkbs2.pojo.TagFilter;
 import com.zhiwei.brandkbs2.pojo.dto.TagFilterDTO;
-import com.zhiwei.brandkbs2.service.ICommonService;
-import com.zhiwei.brandkbs2.service.IProjectService;
-import com.zhiwei.brandkbs2.service.ITagFilterService;
+import com.zhiwei.brandkbs2.service.CommonService;
+import com.zhiwei.brandkbs2.service.TagFilterService;
+import com.zhiwei.brandkbs2.service.ProjectService;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
-import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -24,16 +23,16 @@ import java.util.stream.Collectors;
  * @date: 2022-06-01 13:40
  */
 @Service("tagFilterServiceImpl")
-public class TagFilterServiceImpl implements ITagFilterService {
+public class TagFilterServiceImpl implements TagFilterService {
 
     @Resource(name = "tagFilterDao")
-    private ITagFilterDao tagFilterDao;
+    private TagFilterDao tagFilterDao;
 
     @Resource(name = "commonServiceImpl")
-    private ICommonService commonService;
+    private CommonService commonService;
 
     @Resource(name = "projectServiceImpl")
-    private IProjectService projectService;
+    private ProjectService projectService;
 
     @Override
     public List<TagFilterDTO> getTagFilter() {

src/main/java/com/zhiwei/brandkbs2/service/impl/TaskServiceImpl.java

 package com.zhiwei.brandkbs2.service.impl;
 
 import com.zhiwei.brandkbs2.config.Constant;
-import com.zhiwei.brandkbs2.dao.IBrandkbsTaskDao;
-import com.zhiwei.brandkbs2.dao.IChannelDao;
-import com.zhiwei.brandkbs2.dao.IEventDataDao;
+import com.zhiwei.brandkbs2.dao.BrandkbsTaskDao;
+import com.zhiwei.brandkbs2.dao.ChannelDao;
+import com.zhiwei.brandkbs2.dao.EventDataDao;
+import com.zhiwei.brandkbs2.dao.ReportSettingsDao;
+import com.zhiwei.brandkbs2.enmus.ReportTypeEnum;
 import com.zhiwei.brandkbs2.es.EsClientDao;
-import com.zhiwei.brandkbs2.pojo.BrandkbsTask;
-import com.zhiwei.brandkbs2.pojo.Channel;
-import com.zhiwei.brandkbs2.pojo.ChannelIndex;
-import com.zhiwei.brandkbs2.service.ITaskService;
+import com.zhiwei.brandkbs2.listener.ApplicationProjectListener;
+import com.zhiwei.brandkbs2.pojo.*;
+import com.zhiwei.brandkbs2.service.BrandkbsTaskService;
+import com.zhiwei.brandkbs2.service.ProjectService;
+import com.zhiwei.brandkbs2.service.ReportService;
+import com.zhiwei.brandkbs2.service.TaskService;
+import org.apache.commons.lang3.tuple.Pair;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.Date;
+import java.util.ArrayList;
 import java.util.LinkedHashSet;
+import java.util.List;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.atomic.AtomicInteger;
 
 /**
  * @ClassName: TaskServiceImpl
@@ -25,46 +34,119 @@ import java.util.Map;
  * @date: 2022-06-16 15:28
  */
 @Service("taskServiceImpl")
-public class TaskServiceImpl implements ITaskService {
+public class TaskServiceImpl implements TaskService {
     public static final Logger log = LogManager.getLogger(TaskServiceImpl.class);
 
     @Resource(name = "esClientDao")
     EsClientDao esClientDao;
 
     @Resource(name = "channelDao")
-    IChannelDao channelDao;
+    ChannelDao channelDao;
 
     @Resource(name = "eventDataDao")
-    IEventDataDao eventDataDao;
+    EventDataDao eventDataDao;
 
     @Resource(name = "brandkbsTaskDao")
-    IBrandkbsTaskDao brandkbsTaskDao;
+    BrandkbsTaskDao brandkbsTaskDao;
+
+    @Resource(name = "reportSettingsDao")
+    ReportSettingsDao reportSettingsDao;
+
+    @Resource(name = "brandkbsTaskServiceImpl")
+    BrandkbsTaskService brandkbsTaskService;
+
+    @Resource(name = "projectServiceImpl")
+    ProjectService projectService;
+
+    @Resource(name = "reportServiceImpl")
+    ReportService reportService;
 
     @Override
     public void messageFlowCount(int day) {
         Map<ChannelIndex, ChannelIndex.ChannelRecord> channelIndexChannelRecordMap = esClientDao.searchChannelRecordRecentDay(day);
         log.info("渠道信息记录-搜索到近{}天的记录条数{}条", day, channelIndexChannelRecordMap.size());
-        int insertCount = 0;
+        List<Channel> insertList = new ArrayList<>();
         for (Map.Entry<ChannelIndex, ChannelIndex.ChannelRecord> entry : channelIndexChannelRecordMap.entrySet()) {
             // 是否已存在
             Channel channel = channelDao.queryUnique(entry.getKey());
             if (null == channel) {
                 channel = Channel.createFromChannelIndexRecord(entry.getKey(), entry.getValue());
                 channel.setEventIds(new LinkedHashSet<>(eventDataDao.getEventCount(entry.getKey())));
+                insertList.add(channel);
                 channelDao.insertOne(channel);
-                insertCount++;
             } else {
                 channel.setEventIds(new LinkedHashSet<>(eventDataDao.getEventCount(entry.getKey())));
                 channel.setChannelRecord(entry.getValue());
                 channelDao.updateOne(channel);
             }
         }
-        log.info("渠道信息记录-录入完毕,新增渠道{}条,更新渠道{}条", insertCount, channelIndexChannelRecordMap.size() - insertCount);
+//        ListUtils.partition(insertList, 1000).forEach(list -> {
+//            channelDao.insertMany(list);
+//        });
+        log.info("渠道信息记录-录入完毕,新增渠道{}条,更新渠道{}条", insertList.size(), channelIndexChannelRecordMap.size() - insertList.size());
     }
 
     @Override
-    public void reportSend() {
-        Date now = new Date();
-        BrandkbsTask task = brandkbsTaskDao.findTaskByTaskNameAndVersion(Constant.TASK_REPORT_JOB, Constant.INIT_VERSION);
+    public void generateReportAndSend() {
+        long now = System.currentTimeMillis();
+        BrandkbsTask task = null;
+        boolean getTask = false;
+        try {
+            task = brandkbsTaskDao.findTaskByTaskNameAndVersion(Constant.TASK_REPORT_JOB, Constant.INIT_VERSION);
+            if (!(getTask = brandkbsTaskService.getTaskJob(task, now))) {
+                return;
+            }
+            log.info("执行task:{}", task.getTaskName());
+            List<CompletableFuture<Boolean>> futures = new ArrayList<>();
+            for (Project project : projectService.getAllProjectsWithStart()) {
+                ThreadPoolExecutor threadPool = ApplicationProjectListener.getThreadPool();
+                futures.add(CompletableFuture.supplyAsync(() -> reportSendByProject(project), threadPool));
+            }
+            AtomicInteger valid = new AtomicInteger();
+            CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).whenComplete((v, e) -> {
+                if (null != e) {
+                    log.error("reportSendByProject-", e);
+                }
+                futures.forEach(f -> {
+                    if (Boolean.TRUE.equals(f.join())) {
+                        valid.getAndIncrement();
+                    }
+                });
+            }).join();
+            log.info("结束task:{},本次执行有效任务数:{}", task.getTaskName(), valid.get());
+        } finally {
+            if (getTask) {
+                //重置定时任务表
+                brandkbsTaskService.resetTask(task, now);
+                log.info("重置task:{}", task.getTaskName());
+            }
+        }
     }
+
+    private boolean reportSendByProject(Project project) {
+        boolean flag = false;
+        // 扫描setting信息
+        for (ReportSettings reportSettings : reportSettingsDao.getReportSettingByProjectWithUsed(project.getId())) {
+            ReportTypeEnum reportType = ReportTypeEnum.getInstanceByState(reportSettings.getType());
+            if (ReportTypeEnum.canPublishNow(reportType)) {
+                Pair<Boolean, Report> booleanReportPair = reportService.generateReportBySettings(reportSettings, project);
+                // 生成新的简报之后的处理
+                if (booleanReportPair.getLeft()) {
+                    Report report = booleanReportPair.getRight();
+                    // 用作生成缓存
+                    reportService.getPcReportAnalyze(report.getId(), false);
+                    reportService.switchReportStatus(report.getId(), true);
+                }
+                flag = true;
+            }
+        }
+        // 自定义简报不通过setting生效
+        for (Report report : reportService.getCustomReportByStatus(project.getId(), false)) {
+            // 用作生成缓存
+            reportService.getPcReportAnalyze(report.getId(), false);
+            reportService.switchReportStatus(report.getId(), true);
+        }
+        return flag;
+    }
+
 }