From cefb7219a98e56019269a0dffa5493075cc23cba Mon Sep 17 00:00:00 2001 From: xjm Date: Wed, 17 Apr 2024 11:42:19 +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 --- .../cowr/service/ssjygl/synctask/SyncTaskService.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 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 38f0d69..b10f9af 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 @@ -589,7 +589,7 @@ public class SyncTaskService { Record first = Db.findFirst("select * from " + tablename + " where sn = ?", sn); if (first != null ) { - Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + sn, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + sn, JSONObject.toJSONString(o)); removeList.add(o); } @@ -604,7 +604,7 @@ public class SyncTaskService { if (first != null ) { - Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, JSONObject.toJSONString(o)); removeList.add(o); } @@ -619,7 +619,7 @@ public class SyncTaskService { if (first != null ) { - Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, JSONObject.toJSONString(o)); removeList.add(o); } @@ -633,7 +633,7 @@ public class SyncTaskService { Record first = Db.findFirst("select * from " + tablename + " where id = ?", id); if (first != null ) { - Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, JSONObject.toJSONString(o)); removeList.add(o); } @@ -641,7 +641,7 @@ public class SyncTaskService { } if (CollectionUtils.isNotEmpty(removeList)) { -// list.removeAll(removeList); + list.removeAll(removeList); } return list;