From 9dbcd00464ee63eb317feb53479b1c572f8ad17f Mon Sep 17 00:00:00 2001 From: xjm Date: Wed, 17 Apr 2024 11:39:47 +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 --- .../cowr/service/ssjygl/synctask/SyncTaskService.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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); }