代码优化

src/main/java/com/usky/dxtop/service/impl/DeptServiceImpl.java

@@ -22,7 +22,10 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
 
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -124,10 +127,9 @@ public class DeptServiceImpl extends ServiceImpl<DeptMapper, Dept> implements De
         msgLog.setBusinessId(dept.getDId());
         msgLog.setExchange(GroupConsumeConfig.NAME);
         msgLog.setRoutingKey(GroupConsumeConfig.NAME);
+        msgLog.setMsg(JSON.toJSONString(map));
         msgLogService.save(msgLog);
         map.put("seq",msgLog.getId());
-        msgLog.setMsg(JSON.toJSONString(map));
-        msgLogService.updateById(msgLog);
         CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
         groupRabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);
     }

src/main/java/com/usky/dxtop/service/impl/StaffServiceImpl.java

@@ -75,12 +75,11 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
         msgLog.setExchange(CartGetConsumeConfig.NAME);
         msgLog.setRoutingKey(CartGetConsumeConfig.NAME);
         msgLog.setRemark("获取卡余额");
-        msgLogService.save(msgLog);
         Map<String,Object> map = new HashMap<>();
-        map.put("seq",msgLog.getId());
         map.put("card",card);
         msgLog.setMsg(JSON.toJSONString(map));
-        msgLogService.updateById(msgLog);
+        msgLogService.save(msgLog);
+        map.put("seq",msgLog.getId());
         CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
         rabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);
         return msgLog.getId().toString();
@@ -114,10 +113,9 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
         msgLog.setBusinessId(staff.getSId());
         msgLog.setExchange(ProfileConsumeConfig.NAME);
         msgLog.setRoutingKey(ProfileConsumeConfig.NAME);
+        msgLog.setMsg(JSON.toJSONString(map));
         msgLogService.save(msgLog);
         map.put("seq",msgLog.getId());
-        msgLog.setMsg(JSON.toJSONString(map));
-        msgLogService.updateById(msgLog);
         CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
         profileRabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);
     }
@@ -136,11 +134,10 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
         msgLog.setBusinessId(staff.getSId());
         msgLog.setExchange(FaceConsumeConfig.NAME);
         msgLog.setRoutingKey(FaceConsumeConfig.NAME);
-        msgLogService.save(msgLog);
-        map.put("seq",msgLog.getId());
         map.put("img",staff.getFaceId());
         msgLog.setMsg(JSON.toJSONString(map));
-        msgLogService.updateById(msgLog);
+        msgLogService.save(msgLog);
+        map.put("seq",msgLog.getId());
         map.put("img",encode);
         CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
         faceRabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);