推送消息

src/main/java/com/dk/mdm/service/xxl/XxlService.java

@@ -44,7 +44,8 @@ public class XxlService extends BaseService<CusFollow> {
     public BaseMapper<CusFollow> getRepository() {
         return cusFollowMapper;
     }
-     @Autowired
+
+    @Autowired
     private CustomerMapper customerMapper;
     @Autowired
     private StaffMapper staffMapper;
@@ -179,11 +180,15 @@ public class XxlService extends BaseService<CusFollow> {
         if (followStaff != null) {
             log.info("sendFollowMessage:{}", JSONObject.toJSONString(followStaff));
             Customer customer = customerMapper.selectById(follow.getCusId());
+            log.info("customer:{}", JSONObject.toJSONString(customer));
+            Map<String, Object> otherParamMap = new HashMap<>();
             if (customer != null) {
                 if (follow.getFollowStatus().equals("跟进状态-约尺")) {
-                    customer.setStaffName(followStaff.getStaffName());
-                    // 暂时用最后一次 跟进id传过去
-                    customer.setLastFollowId(follow.getFollowId());
+//                    customer.setStaffName(followStaff.getStaffName());
+//                    // 暂时用最后一次 跟进id传过去
+//                    customer.setLastFollowId(follow.getFollowId());
+                    otherParamMap.put("staffName", followStaff.getStaffName());
+                    otherParamMap.put("followId", follow.getFollowId());
                 }
                 String loginType = "4";
 //                List<String> list = new ArrayList<>();
@@ -230,7 +235,8 @@ public class XxlService extends BaseService<CusFollow> {
                         // 发送消息
                         Map<String, Object> mapMessage = new HashMap<>();
                         mapMessage.put("loginType", loginType);
-                        mapMessage.put("otherParam", JSONObject.toJSONString(customer));
+                        otherParamMap.put("cusId", customer.getCusId());
+                        mapMessage.put("otherParam", JSONObject.toJSONString(otherParamMap));
 //                        mapMessage.put("publicOpenId", user.get("publicOpenId"));
                         mapMessage.put("userWxId", user.get("userWxId"));
                         mapMessage.put("first", "客户跟进提醒");