From 80cb29baa8263cb1c01feb908d4ea3e634a72a3f Mon Sep 17 00:00:00 2001 From: wangxianzhang Date: Tue, 15 Nov 2022 21:04:21 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E5=B1=85=E6=B0=91=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=AF=B9=E6=AF=94=E5=8A=9F=E8=83=BD=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/epmet/constant/EpidemicConstant.java | 3 ++- ...ava => YanTaiResiComparisonSyncProcessor.java} | 15 ++++++++------- .../impl/IcResiComparisonRecordServiceImpl.java | 4 ++-- 3 files changed, 12 insertions(+), 10 deletions(-) rename epmet-user/epmet-user-server/src/main/java/com/epmet/processor/{YanTaiComparisonSyncProcessor.java => YanTaiResiComparisonSyncProcessor.java} (91%) diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/EpidemicConstant.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/EpidemicConstant.java index edd9d1a695..3b843838e4 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/constant/EpidemicConstant.java +++ b/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"; diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiComparisonSyncProcessor.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiResiComparisonSyncProcessor.java similarity index 91% rename from epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiComparisonSyncProcessor.java rename to epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiResiComparisonSyncProcessor.java index cc07aafab2..8e57474606 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/processor/YanTaiComparisonSyncProcessor.java +++ b/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 icSyncJobToExec = icSyncJobDao.selectExecutableJobList( - EpidemicConstant.JOB_TYPE_COMPARISON, + EpidemicConstant.JOB_TYPE_COMPARISON_RESI, leftCount); if (!CollectionUtils.isEmpty(icSyncJobToExec)) { diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiComparisonRecordServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiComparisonRecordServiceImpl.java index 78b76b12f7..9b6dfa7628 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiComparisonRecordServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiComparisonRecordServiceImpl.java @@ -251,7 +251,7 @@ public class IcResiComparisonRecordServiceImpl extends BaseServiceImpl 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 icSyncJobEntities = icSyncJobDao.selectList(qw); // 当前组织下存在同步任务 @@ -265,7 +265,7 @@ public class IcResiComparisonRecordServiceImpl extends BaseServiceImpl Date: Tue, 15 Nov 2022 22:26:55 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E7=96=AB=E8=8B=97=E6=8E=A5=E7=A7=8Dsql?= =?UTF-8?q?=E5=AD=97=E6=AE=B5=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/epmet/service/impl/DataSyncConfigServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java index 438f0d80c7..a10b033255 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java @@ -1103,7 +1103,7 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl vaccineList = JSON.parseArray(json,Map.class); List> vaccineList = yantaiNamedParamLantuJdbcTemplate.queryForList( - "select data, name, card_no, vaccineCount from t_ymjz_info where card_no in (:idcards)", args); + "select data, name, cardno, vaccineCount from t_ymjz_info where cardno in (:idcards)", args); List ytVaccineListDTOS = new ArrayList<>(); if (CollectionUtils.isNotEmpty(vaccineList)) { vaccineList.forEach(v -> { From a211fcdbeb3c66abe193f5cb2d76b9fdbf2fa266 Mon Sep 17 00:00:00 2001 From: wangxianzhang Date: Tue, 15 Nov 2022 23:45:53 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E7=96=AB=E8=8B=97=E6=8E=A5=E7=A7=8D?= =?UTF-8?q?=E9=80=BB=E8=BE=91=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/DataSyncConfigServiceImpl.java | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java index a10b033255..d77a248ffd 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java @@ -2,6 +2,7 @@ package com.epmet.service.impl; import java.util.Date; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; @@ -1108,14 +1109,24 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl { if (v.containsKey("data")){ - Map data = (Map) v.get("data"); - if (data.containsKey("vaccineList")){ - List vaccineList1 = JSON.parseArray(data.get("vaccineList").toString(), YTVaccineListDTO.class); + JSONObject jo = JSON.parseObject((String) v.get("data")); + if (jo.containsKey("vaccineList")) { + JSONArray vaccineListJA = jo.getJSONArray("vaccineList"); + List vaccineList1 = vaccineListJA.toJavaList(YTVaccineListDTO.class); vaccineList1.forEach(v1 -> { v1.setCardno(v.get("cardno").toString()); }); ytVaccineListDTOS.addAll(vaccineList1); } + + //Map data = (Map) v.get("data"); + //if (data.containsKey("vaccineList")){ + // List vaccineList1 = JSON.parseArray(data.get("vaccineList").toString(), YTVaccineListDTO.class); + // vaccineList1.forEach(v1 -> { + // v1.setCardno(v.get("cardno").toString()); + // }); + // ytVaccineListDTOS.addAll(vaccineList1); + //} } }); List entities = new ArrayList<>(); From 829e1c4e2dcd3a8c174d186c2f7e7d3af4d5f47d Mon Sep 17 00:00:00 2001 From: zxc <1272811460@qq.com> Date: Wed, 16 Nov 2022 08:44:02 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E5=AD=97=E6=AE=B5=E8=B5=8B=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/epmet/service/impl/DataSyncConfigServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java index d77a248ffd..f8136ef9c5 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java @@ -1164,7 +1164,7 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl relationEntities = new ArrayList<>(); entities.forEach(e -> { IcVaccineRelationEntity re = new IcVaccineRelationEntity(); - re.setIcVaccineId(e.getAgencyId()); + re.setIcVaccineId(e.getId()); re.setPids(e.getPids()); re.setCustomerId(customerId); re.setUserType("ytPull");