Ver código fonte

同步人员修复

yq 3 anos atrás
pai
commit
e70607110b

+ 3 - 3
src/main/java/com/usky/dxtop/service/impl/StaffServiceImpl.java

@@ -131,17 +131,17 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
     public void faceSendMessage(Staff staff){
         String encode = Base64.encode(ImageUtils.getImage(staff.getFaceId()));
         Map<String,Object> map = new HashMap<>();
-        map.put("mob",staff.getSId());
-        map.put("image",encode);
-        faceRabbitTemplate.convertAndSend(FaceConsumeConfig.NAME, FaceConsumeConfig.NAME, map);
+        map.put("mob",staff.getId());
         MsgLog msgLog = new MsgLog();
         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);
+        map.put("img",encode);
         CorrelationData correlationData = new CorrelationData(msgLog.getId().toString());
         faceRabbitTemplate.convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);
     }