居民信息对比功能调整

epmet-user/epmet-user-server/src/main/java/com/epmet/constant/EpidemicConstant.java

@@ -21,7 +21,8 @@ public interface EpidemicConstant {
      */
     String JOB_TYPE_NAT = "nat";
     String JOB_TYPE_VACCINE = "vaccine";
-    String JOB_TYPE_COMPARISON = "comparison";
+    // 居民信息对比
+    String JOB_TYPE_COMPARISON_RESI = "comparison_resi";
 
     String OPERATION_STATUS_WAITING = "waiting";
     String OPERATION_STATUS_PROCESSING = "processing";

epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiComparisonSyncProcessor.java → epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiResiComparisonSyncProcessor.java

@@ -7,7 +7,6 @@ import com.epmet.commons.tools.redis.RedisUtils;
 import com.epmet.constant.EpidemicConstant;
 import com.epmet.dao.IcSyncJobDao;
 import com.epmet.entity.IcSyncJobEntity;
-import com.epmet.service.DataSyncConfigService;
 import com.epmet.service.IcResiComparisonRecordService;
 import lombok.extern.slf4j.Slf4j;
 import org.redisson.api.RLock;
@@ -20,12 +19,14 @@ import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.TimeUnit;
 
-import static com.epmet.constant.EpidemicConstant.JOB_TYPE_NAT;
+/**
-
+  * @Description 居民一致性对比任务处理器
-// 烟台数据比对
+  * @Author wxz
+  * @Date 2022/11/15 下午5:54
+ */
 @Component
 @Slf4j
-public class YanTaiComparisonSyncProcessor {
+public class YanTaiResiComparisonSyncProcessor {
 
     public static final int MAX_EXECUTING_COUNT = 3;
 
@@ -67,10 +68,10 @@ public class YanTaiComparisonSyncProcessor {
 
         RLock lock = null;
         try {
-            lock = distributedLock.getLock("data:sync:" + "comparison", 60L, 60L, TimeUnit.SECONDS);
+            lock = distributedLock.getLock("data:sync:comparison:resi", 60L, 60L, TimeUnit.SECONDS);
             // 查询可执行的任务列表，并且异步执行
             List<IcSyncJobEntity> icSyncJobToExec = icSyncJobDao.selectExecutableJobList(
-                    EpidemicConstant.JOB_TYPE_COMPARISON,
+                    EpidemicConstant.JOB_TYPE_COMPARISON_RESI,
                     leftCount);
 
             if (!CollectionUtils.isEmpty(icSyncJobToExec)) {

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiComparisonRecordServiceImpl.java

@@ -251,7 +251,7 @@ public class IcResiComparisonRecordServiceImpl extends BaseServiceImpl<IcResiCom
         // 查询该组织是否存在等待中或者进行中的任务
         LambdaQueryWrapper<IcSyncJobEntity> qw = new LambdaQueryWrapper<>();
         qw.eq(IcSyncJobEntity::getOrgId, formDTO.getAgencyId())
-                .eq(IcSyncJobEntity::getJobType, EpidemicConstant.JOB_TYPE_COMPARISON)
+                .eq(IcSyncJobEntity::getJobType, EpidemicConstant.JOB_TYPE_COMPARISON_RESI)
                 .in(IcSyncJobEntity::getOperationStatus, OPERATION_STATUS_WAITING, OPERATION_STATUS_PROCESSING);
         List<IcSyncJobEntity> icSyncJobEntities = icSyncJobDao.selectList(qw);
         // 当前组织下存在同步任务
@@ -265,7 +265,7 @@ public class IcResiComparisonRecordServiceImpl extends BaseServiceImpl<IcResiCom
         e.setOrgId(formDTO.getAgencyId());
         e.setPid(agencyInfo.getPid());
         e.setOrgIdPath(StringUtils.isBlank(agencyInfo.getPids()) ? agencyInfo.getId() : agencyInfo.getPids() + ":" + agencyInfo.getId());
-        e.setJobType(EpidemicConstant.JOB_TYPE_COMPARISON);
+        e.setJobType(EpidemicConstant.JOB_TYPE_COMPARISON_RESI);
         e.setOperatorId(formDTO.getUserId());
         e.setOperationStatus(OPERATION_STATUS_WAITING);
         icSyncJobDao.insert(e);