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); }