From 453b36e7753f6df5bb6c648465fc751c9e0122f9 Mon Sep 17 00:00:00 2001 From: xjm Date: Wed, 17 Apr 2024 11:48:34 +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 --- .../service/ssjygl/synctask/SyncTaskService.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) 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 b10f9af..ca0b529 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 @@ -640,6 +640,20 @@ public class SyncTaskService { } } + if ("modify_log".equals(tablename)) { + // id + for (Record o : list) { + String id = o.getStr("id"); + 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, JSONObject.toJSONString(o)); + + removeList.add(o); + } + } + } + if (CollectionUtils.isNotEmpty(removeList)) { list.removeAll(removeList); }