diff --git a/ms-biz/src/main/java/com/ms/api/service/impl/DoudianMsgServiceImpl.java b/ms-biz/src/main/java/com/ms/api/service/impl/DoudianMsgServiceImpl.java index 5bbefeff..ad1504b3 100644 --- a/ms-biz/src/main/java/com/ms/api/service/impl/DoudianMsgServiceImpl.java +++ b/ms-biz/src/main/java/com/ms/api/service/impl/DoudianMsgServiceImpl.java @@ -495,12 +495,14 @@ public class DoudianMsgServiceImpl implements DoudianMsgService { return null; } - row.setLocked(1L); + DoudianTradeMsgQueue updateData = new DoudianTradeMsgQueue(); + updateData.setDoudianTradeMsgQueueId(row.getDoudianTradeMsgQueueId()); + updateData.setLocked(1L); // row.setHostname(""); - row.setGmtLastHeartbeat(new Date()); - row.setGmtLocked(new Date()); - row.setGmtModified(new Date()); - int affRow = doudianTradeMsgQueueMapper.updateByPrimaryKeySelective(row); + updateData.setGmtLastHeartbeat(new Date()); + updateData.setGmtLocked(new Date()); + updateData.setGmtModified(new Date()); + int affRow = doudianTradeMsgQueueMapper.updateByPrimaryKeySelective(updateData); if (affRow == 1) { // todo: 心跳后面想想怎么搞 return row; @@ -531,12 +533,14 @@ public class DoudianMsgServiceImpl implements DoudianMsgService { return null; } - row.setLocked(1); + DoudianAftersaleMsgQueue updateData = new DoudianAftersaleMsgQueue(); + updateData.setDoudianAftersaleMsgQueueId(row.getDoudianAftersaleMsgQueueId()); + updateData.setLocked(1); // row.setHostname(""); - row.setGmtLastHeartbeat(new Date()); - row.setGmtLocked(new Date()); - row.setGmtModified(new Date()); - int affRow = doudianAftersaleMsgQueueMapper.updateByPrimaryKeySelective(row); + updateData.setGmtLastHeartbeat(new Date()); + updateData.setGmtLocked(new Date()); + updateData.setGmtModified(new Date()); + int affRow = doudianAftersaleMsgQueueMapper.updateByPrimaryKeySelective(updateData); if (affRow == 1) { // todo: 心跳后面想想怎么搞 return row; diff --git a/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncPageQueueServiceImpl.java b/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncPageQueueServiceImpl.java index af36e59f..4fc372ae 100644 --- a/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncPageQueueServiceImpl.java +++ b/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncPageQueueServiceImpl.java @@ -68,13 +68,16 @@ public class OpOrderRsyncPageQueueServiceImpl implements OpOrderRsyncPageQueueSe if (ObjectUtil.isEmpty(row)) { return null; } + + OpOrderRsyncPageQueue updateData = new OpOrderRsyncPageQueue(); + updateData.setOpOrderRsyncPageQueueId(row.getOpOrderRsyncPageQueueId()); Date date = new Date(); - row.setLocked(timerLockId); - row.setHostname(""); - row.setGmtLastHeartbeat(date); - row.setGmtModified(date); - row.setGmtLocked(date); - int affectRows = opOrderRsyncPageQueueMapper.updateByPrimaryKey(row); + updateData.setLocked(timerLockId); + updateData.setHostname(""); + updateData.setGmtLastHeartbeat(date); + updateData.setGmtModified(date); + updateData.setGmtLocked(date); + int affectRows = opOrderRsyncPageQueueMapper.updateByPrimaryKeySelective(updateData); if (affectRows == 1) { return row; } diff --git a/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncQueueServiceImpl.java b/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncQueueServiceImpl.java index 526e88ae..c6c9d98d 100644 --- a/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncQueueServiceImpl.java +++ b/ms-biz/src/main/java/com/ms/api/service/impl/OpOrderRsyncQueueServiceImpl.java @@ -65,13 +65,16 @@ public class OpOrderRsyncQueueServiceImpl implements OpOrderRsyncQueueService { if (ObjectUtil.isEmpty(row)) { return null; } + + OpOrderRsyncQueue updateData = new OpOrderRsyncQueue(); + updateData.setOpOrderRsyncQueueId(row.getOpOrderRsyncQueueId()); Date date = new Date(); - row.setLocked(timerLockId); - row.setHostname(""); - row.setGmtLastHeartbeat(date); - row.setGmtModified(date); - row.setGmtLocked(date); - int affectRows = opOrderRsyncQueueMapper.updateByPrimaryKey(row); + updateData.setLocked(timerLockId); + updateData.setHostname(""); + updateData.setGmtLastHeartbeat(date); + updateData.setGmtModified(date); + updateData.setGmtLocked(date); + int affectRows = opOrderRsyncQueueMapper.updateByPrimaryKeySelective(updateData); if (affectRows == 1) { return row; }