1、优化知识图谱职位数据的同步逻辑

2、将pay模块改为雪花算法填充

citu-module-pay/citu-module-pay-biz/src/main/resources/application.yaml

@@ -47,7 +47,7 @@ mybatis-plus:
     map-underscore-to-camel-case: true # 虽然默认为 true ，但是还是显示去指定下。
   global-config:
     db-config:
-      id-type: NONE # “智能”模式，基于 IdTypeEnvironmentPostProcessor + 数据源的类型，自动适配成 AUTO、INPUT 模式。
+      id-type: ASSIGN_ID # “智能”模式，基于 IdTypeEnvironmentPostProcessor + 数据源的类型，自动适配成 AUTO、INPUT 模式。
       #      id-type: AUTO # 自增 ID，适合 MySQL 等直接自增的数据库
       #      id-type: INPUT # 用户输入 ID，适合 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库
       #      id-type: ASSIGN_ID # 分配 ID，默认使用雪花算法。注意，Oracle、PostgreSQL、Kingbase、DB2、H2 数据库时，需要去除实体类上的 @KeySequence 注解

menduner/menduner-system-api/src/main/java/com/citu/module/menduner/system/api/python/GraphApi.java

@@ -32,7 +32,7 @@ public interface GraphApi {
     @Operation(summary = "推荐人才")
     CommonResult<Long[]> queryRecommendPerson(@RequestBody GraphQueryPageDTO queryDTO);
 
-    @PostMapping("/rocket/receive/data")
+    @PostMapping("/rocket/delete/data")
     @Operation(summary = "删除图谱数据")
     CommonResult<Boolean> receiveData(@RequestBody GraphQueryPageDTO queryDTO);
 }

menduner/menduner-system-api/src/main/java/com/citu/module/menduner/system/enums/DictTypeConstants.java

@@ -20,10 +20,11 @@ public interface DictTypeConstants {
     String MENDUNER_EDUCATION_TYPE = "menduner_education_type"; // 学历
     String MENDUNER_EDUCATION_SYSTEM_TYPE = "menduner_education_system_type"; // 学制类型
     String MENDUNER_VISITS_TYPE = "menduner_visits_type"; // 业务类型
+    String MENDUNER_JOB_SEEK_STATUS = "menduner_job_seek_status"; // 求职状态
 
     String MENDUNER_EXP_TYPE = "menduner_exp_type"; // 工作经验
 
-    String MENDUNER_JOB_STATUS = "menduner_job_status"; // 求职状态
+    String MENDUNER_JOB_STATUS = "menduner_job_status"; // 招聘职位状态
     String MENDUNER_SEX = "menduner_sex";
 
 

menduner/menduner-system-api/src/main/java/com/citu/module/menduner/system/enums/job/JobSeekStatusEnum.java

@@ -0,0 +1,25 @@
+package com.citu.module.menduner.system.enums.job;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 求职状态（0离职-随时到岗 1在职-月内到岗 2在职-考虑机会 3在职-暂不考虑）
+ **/
+@Getter
+@AllArgsConstructor
+public enum JobSeekStatusEnum {
+    LEAVE("0","离职"),
+    IN_MONTH("1","月内到岗"),
+    CONSIDER("2","考虑机会"),
+    NOT_CONSIDER("3","暂不考虑");
+
+    /**
+     * 状态值
+     */
+    private final String status;
+    /**
+     * 状态名
+     */
+    private final String name;
+}

menduner/menduner-system-biz/src/main/java/com/citu/module/menduner/system/service/job/JobAdvertisedServiceImpl.java

@@ -1,6 +1,8 @@
 package com.citu.module.menduner.system.service.job;
 
 
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.http.HtmlUtil;
 import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.citu.framework.common.pojo.PageParam;
 import com.citu.framework.common.pojo.PageResult;
@@ -68,9 +70,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
     @Resource
     private JobAdvertisedMapper mapper;
 
-    @Resource
-    private JobInterestedMapper jobInterestedMapper;
-
     @Resource
     private EnterpriseService enterpriseService;
 
@@ -227,7 +226,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
         return mapper.selectPage(pageReqVO);
     }
 
-
     @Override
     public PageResult<AppJobAdvertisedHomeRespVO> getAcquaintedPage(AppJobAdvertisedPageReqVO pageReqVO) {
         try {
@@ -285,7 +283,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
         return result;
     }
 
-
     @Override
     public AppJobAdvertisedDetailRespVO detail(Long id) {
         JobAdvertisedDO job = mapper.selectById(id);
@@ -309,7 +306,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
         return respVO;
     }
 
-
     @Override
     public List<CommonRespVO> getJobPositionCountByEnterpriseId(Long enterpriseId) {
         List<CommonRespVO> list = new ArrayList<>();
@@ -355,9 +351,12 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
     public void syncGraph() {
 
         List<JobAdvertisedDO> list = mapper.list(
-                JobAdvertisedReqVO.builder().build()
+                JobAdvertisedReqVO.builder().status(JobStatusEnum.ENABLE.getStatus()).build()
         );
         List<JobAdvertisedRespVO> respList = JobAdvertisedConvert.INSTANCE.convertList7(list);
+        if(CollUtil.isNotEmpty(respList)) {
+            graphApi.receiveData(GraphQueryPageDTO.builder().type(SyncConstants.JOB).build()).getCheckedData();
+        }
         for (JobAdvertisedRespVO resp : respList) {
             // 设置字典真实值
             resp.setType(DictFrameworkUtils.getDictDataLabel(MENDUNER_JOB_TYPE, resp.getType()));
@@ -369,15 +368,20 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
             resp.setStatus(DictFrameworkUtils.getDictDataLabel(MENDUNER_JOB_STATUS, resp.getStatus()));
             // TODO 暂时不要
             resp.setContent(null);
-        }
+            // 瘦身
+            String requirement = HtmlUtil.cleanHtmlTag(resp.getRequirement())
+                    .replaceAll("[\r\n]+", "")
+                    .trim();
+            resp.setRequirement(requirement);
 
-        producer.send(
-                new GraphSendDTO(
-                        SyncConstants.SYNC_ALL,
-                        SyncConstants.JOB,
-                        respList
-                )
-        );
+            producer.send(
+                    new GraphSendDTO(
+                            SyncConstants.ADD,
+                            SyncConstants.JOB,
+                            resp
+                    )
+            );
+        }
 
     }
 
@@ -417,7 +421,6 @@ public class JobAdvertisedServiceImpl implements JobAdvertisedService {
         return job.getId();
     }
 
-
     /**
      * 效验职位发布的编辑
      *