Browse Source

推送消息

姜永辉 1 year ago
parent
commit
bd8b376675

+ 10 - 2
src/main/java/com/dk/mdm/model/pojo/mst/Customer.java

@@ -172,13 +172,21 @@ public class Customer extends PageInfo<Customer> implements Serializable {
     private String staffId;
 
     /**
-     * 员工名称
+     * 业务员编码
      */
     @Excel(name = "业务员编码")
-    @ApiModelProperty(value = "员工名称")
+    @ApiModelProperty(value = "业务员编码")
     @TableField(exist = false)
     private String staffCode;
 
+    /**
+     * 员工名称
+     */
+    @Excel(name = "员工名称")
+    @ApiModelProperty(value = "员工名称")
+    @TableField(exist = false)
+    private String staffName;
+
 
     /**
      * 报备人

+ 6 - 1
src/main/java/com/dk/mdm/service/xxl/XxlService.java

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