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 68be982..38f0d69 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 @@ -2,6 +2,7 @@ package com.cowr.service.ssjygl.synctask; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import com.cowr.common.Const; import com.cowr.common.enums.Enums; import com.cowr.common.enums.OrderStateEnum; import com.cowr.model.*; @@ -588,7 +589,7 @@ public class SyncTaskService { Record first = Db.findFirst("select * from " + tablename + " where sn = ?", sn); if (first != null ) { - Redis.use().set("主键冲突:" + tablename + ":" + sn, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + sn, 0); removeList.add(o); } @@ -603,7 +604,7 @@ public class SyncTaskService { if (first != null ) { - Redis.use().set("主键冲突:" + tablename + ":" + id, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, 0); removeList.add(o); } @@ -618,7 +619,7 @@ public class SyncTaskService { if (first != null ) { - Redis.use().set("主键冲突:" + tablename + ":" + id, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, 0); removeList.add(o); } @@ -632,7 +633,7 @@ public class SyncTaskService { Record first = Db.findFirst("select * from " + tablename + " where id = ?", id); if (first != null ) { - Redis.use().set("主键冲突:" + tablename + ":" + id, 0); + Redis.use().set(Config.dbprop.get("redis.basekey") + Const.REDIS_SEPARATE+"主键冲突:" + tablename + ":" + id, 0); removeList.add(o); }