并发修改司机结算单导致状态错误

performance-web/src/main/java/com/clx/performance/dao/impl/settle/SettlementDriverDaoImpl.java

@@ -67,4 +67,18 @@ public class SettlementDriverDaoImpl extends BaseDaoImpl<SettlementDriverMapper,
                 .set(SettlementDriver::getLoanFlag, OwnerLoanRecordEnum.LoanFlag.RE_PAY.getCode())
         );
     }
+
+    @Override
+    public void updateStatus(Integer id,Integer status) {
+        update(lUdWrapper().eq(SettlementDriver::getId, id)
+                .set(SettlementDriver::getStatus, status)
+        );
+    }
+
+    @Override
+    public void updatePayErrorMsg(Integer id,String payErrorMsg) {
+        update(lUdWrapper().eq(SettlementDriver::getId, id)
+                .set(SettlementDriver::getPayErrorMsg, payErrorMsg)
+        );
+    }
 }

performance-web/src/main/java/com/clx/performance/dao/settle/SettlementDriverDao.java

@@ -23,4 +23,8 @@ public interface SettlementDriverDao extends BaseDao<SettlementDriverMapper, Set
     Optional<SettlementDriver> getByChildNo(String childNo);
 
     void updateLoanFlagByChildNoList(List<String> childNoList);
+
+    void updateStatus(Integer id,Integer status);
+
+    void updatePayErrorMsg(Integer id,String payErrorMsg);
 }

performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementMqHandlerServiceImpl.java

@@ -230,15 +230,13 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
             orderChild.setFinishTime(orderChild.getSettleTime());
             orderChildDao.updateSettlement(orderChild);
 
-            settlementDriver.setStatus(SettlementDriverEnum.Status.SETTLED.getCode());
-            settlementDriverDao.updateEntityByKey(settlementDriver);
+            settlementDriverDao.updateStatus(settlementDriver.getId(),SettlementDriverEnum.Status.SETTLED.getCode());
 
             // 日志
             orderChildLogService.saveDriverOrderChildLog(childNo, OrderChildLogEnum.Type.COMPLETE.getCode(),
                     OrderChildLogEnum.Type.COMPLETE.getMsg(), 0L, "系统");
         }else{
-            settlementDriver.setPayErrorMsg(payErrorMsg);
-            settlementDriverDao.updateEntityByKey(settlementDriver);
+            settlementDriverDao.updatePayErrorMsg(settlementDriver.getId(),payErrorMsg);
         }
 
     }