1、修复数据统计分析模块统计错误问题

2、优化就平台发布职位数据同于逻辑

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/controller/app/recruit/analysis/AppRecruitAnalysisController.java

@@ -65,6 +65,7 @@ public class AppRecruitAnalysisController {
     @Operation(summary = "获取投递简历的性别分布")
     @PreAuthenticated
     public CommonResult<List<CommonRespVO>> getJobCvSexCount(@Valid RecruitAnalysisReqVO reqVO) {
+        setCommonCondition(reqVO);
         return success(jobCvcRelService.getJobCvSexCount(reqVO));
     }
 
@@ -72,6 +73,7 @@ public class AppRecruitAnalysisController {
     @Operation(summary = "获取投递简历的年龄分布")
     @PreAuthenticated
     public CommonResult<Map<String, Object[]>> getJobCvAgeCount(@Valid RecruitAnalysisReqVO reqVO) {
+        setCommonCondition(reqVO);
         return success(jobCvcRelService.getJobCvAgeCount(reqVO));
     }
 
@@ -79,6 +81,7 @@ public class AppRecruitAnalysisController {
     @Operation(summary = "获取投递简历的学历分布")
     @PreAuthenticated
     public CommonResult<Map<String, Object[]>> getJobCvEduCount(@Valid RecruitAnalysisReqVO reqVO) {
+        setCommonCondition(reqVO);
         return success(jobCvcRelService.getJobCvEduCount(reqVO));
     }
 
@@ -86,6 +89,7 @@ public class AppRecruitAnalysisController {
     @Operation(summary = "获取投递简历的工作经验分布")
     @PreAuthenticated
     public CommonResult<Map<String, Object[]>> getJobCvExpCount(@Valid RecruitAnalysisReqVO reqVO) {
+        setCommonCondition(reqVO);
         return success(jobCvcRelService.getJobCvExpCount(reqVO));
     }
 

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/dal/mysql/job/JobCvRelMapper.java

@@ -225,8 +225,7 @@ public interface JobCvRelMapper extends BaseMapperX<JobCvRelDO> {
     /**
      * 投递简历的性别比例
      **/
-    default List<CommonRespVO> getJobCvSexCount
-    (RecruitAnalysisReqVO reqVO, LocalDateTime startTime, LocalDateTime endTime) {
+    default List<CommonRespVO> getJobCvSexCount(RecruitAnalysisReqVO reqVO, LocalDateTime startTime, LocalDateTime endTime) {
         MPJLambdaWrapperX<JobCvRelDO> wrapper = new MPJLambdaWrapperX<>();
         wrapper.selectAs(PersonInfoDO::getSex, "`key`");
         wrapper.selectCount(JobCvRelDO::getId, CommonRespVO::getValue);

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/old/MdeOldSyncService.java

@@ -323,10 +323,11 @@ public class MdeOldSyncService {
 
     public void syncJob() {
         // 职位信息
-        List<OldMdeJobAdvertised> jobList = oldJobAdvertisedMapper.selectList(OldMdeJobAdvertised::getDelFlag, 0);
+        List<OldMdeJobAdvertised> jobList = oldJobAdvertisedMapper.selectList();
         jobList.forEach(oldMdeJobAdvertised -> {
             JobAdvertisedDO jobAdvertisedDO = jobAdvertisedMapper.selectOne(JobAdvertisedDO::getId, oldMdeJobAdvertised.getJobId());
 
+
             JobAdvertisedDO insertionDO = JobAdvertisedDO.builder()
                     .id(null == jobAdvertisedDO ? oldMdeJobAdvertised.getJobId() : jobAdvertisedDO.getId())
                     .type(JobTypeEnum.FULL_TIME.getType())

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/old/mysql/OldMdeJobAdvertisedMapper.java

@@ -2,10 +2,28 @@ package com.citu.module.menduner.system.old.mysql;
 
 import com.baomidou.dynamic.datasource.annotation.Slave;
 import com.citu.framework.mybatis.core.mapper.BaseMapperX;
+import com.citu.framework.mybatis.core.query.MPJLambdaWrapperX;
 import com.citu.module.menduner.system.old.dataobject.OldMdeJobAdvertised;
+import com.citu.module.menduner.system.old.dataobject.OldMdeUser;
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.List;
+
 @Slave
 @Mapper
 public interface OldMdeJobAdvertisedMapper extends BaseMapperX<OldMdeJobAdvertised> {
+
+
+    default List<OldMdeJobAdvertised> selectList() {
+        MPJLambdaWrapperX<OldMdeJobAdvertised> query = new MPJLambdaWrapperX<>();
+        query.selectAll(OldMdeJobAdvertised.class);
+        query.innerJoin(OldMdeUser.class, on -> on
+                .eq(OldMdeUser::getUserCode, OldMdeJobAdvertised::getPublisher)
+        );
+        query.eq(OldMdeJobAdvertised::getDelFlag, 0);
+        query.eq(OldMdeUser::getDelFlag, 0);
+        // 企业用户
+        query.eq(OldMdeUser::getIdentityFlag, 1);
+        return selectJoinList(OldMdeJobAdvertised.class, query);
+    }
 }

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/service/person/PersonIntegrationServiceImpl.java

@@ -182,16 +182,25 @@ public class PersonIntegrationServiceImpl implements PersonIntegrationService {
 
             list.add(resp);
 
+            graphApi.send(
+                    new GraphSendDTO<PersonDetailRespVO>
+                            (
+                                    SyncConstants.ADD,
+                                    SyncConstants.PERSON,
+                                    resp
+                            )
+            ).getCheckedData();
+
         }
 
-        graphApi.send(
-                new GraphSendDTO<PersonDetailRespVO>
-                        (
-                                SyncConstants.SYNC_ALL,
-                                SyncConstants.PERSON,
-                                list
-                        )
-        ).getCheckedData();
+//        graphApi.send(
+//                new GraphSendDTO<PersonDetailRespVO>
+//                        (
+//                                SyncConstants.SYNC_ALL,
+//                                SyncConstants.PERSON,
+//                                list
+//                        )
+//        ).getCheckedData();
     }
 
     @Override