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