From f64b33aacfd8ae0e0e1ca6a19bcb0a156f888989 Mon Sep 17 00:00:00 2001 From: xjm Date: Wed, 17 Apr 2024 11:31:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=A1=E6=A0=B8=E8=AE=A2=E5=8D=95=E5=8F=96?= =?UTF-8?q?=E6=B6=88=E7=94=B3=E8=AF=B7=E6=8E=A5=E5=8F=A3=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ssjygl/synctask/SyncTaskService.java | 25 ++++--------------- 1 file changed, 5 insertions(+), 20 deletions(-) diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java index 442a9b8..68be982 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java @@ -16,6 +16,7 @@ import com.jfinal.log.Log; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.IAtom; import com.jfinal.plugin.activerecord.Record; +import com.jfinal.plugin.redis.Redis; import org.apache.commons.collections4.CollectionUtils; import java.math.BigDecimal; @@ -587,11 +588,7 @@ public class SyncTaskService { Record first = Db.findFirst("select * from " + tablename + " where sn = ?", sn); if (first != null ) { - log.info("==============================================="); - log.info("主键冲突"); - log.info(tablename); - log.info(JSONObject.toJSONString(o)); - log.info("==============================================="); + Redis.use().set("主键冲突:" + tablename + ":" + sn, 0); removeList.add(o); } @@ -606,11 +603,7 @@ public class SyncTaskService { if (first != null ) { - log.info("==============================================="); - log.info("主键冲突"); - log.info(tablename); - log.info(JSONObject.toJSONString(o)); - log.info("==============================================="); + Redis.use().set("主键冲突:" + tablename + ":" + id, 0); removeList.add(o); } @@ -625,11 +618,7 @@ public class SyncTaskService { if (first != null ) { - log.info("==============================================="); - log.info("主键冲突"); - log.info(tablename); - log.info(JSONObject.toJSONString(o)); - log.info("==============================================="); + Redis.use().set("主键冲突:" + tablename + ":" + id, 0); removeList.add(o); } @@ -643,11 +632,7 @@ public class SyncTaskService { Record first = Db.findFirst("select * from " + tablename + " where id = ?", id); if (first != null ) { - log.info("==============================================="); - log.info("主键冲突"); - log.info(tablename); - log.info(JSONObject.toJSONString(o)); - log.info("==============================================="); + Redis.use().set("主键冲突:" + tablename + ":" + id, 0); removeList.add(o); }