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;