修改update写法

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;

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

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