Procházet zdrojové kódy

[消息组件][添加][优化]

release_toaliyun_real
luozukai před 7 roky
rodič
revize
f08588c89f
4 změnil soubory, kde provedl 53 přidání a 31 odebrání
  1. +5
    -0
      mallinkService/src/main/java/com/iformall/common/ErrorCode.java
  2. +1
    -1
      mallinkService/src/main/java/com/iformall/service/WxFlowService.java
  3. +5
    -5
      mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java
  4. +42
    -25
      mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java

+ 5
- 0
mallinkService/src/main/java/com/iformall/common/ErrorCode.java Zobrazit soubor

@@ -363,6 +363,11 @@ public enum ErrorCode{
DEVICE_NOT_FOUND(26000, "设备未找到"), DEVICE_NOT_FOUND(26000, "设备未找到"),
DEVICE_ALREADY_EXIST(26001, "设备已经存在"), DEVICE_ALREADY_EXIST(26001, "设备已经存在"),
DEVICE_QRCODE_GET_FAILED(26002, "微信二维码生成失败,请重试"), DEVICE_QRCODE_GET_FAILED(26002, "微信二维码生成失败,请重试"),
/**
* 消息组件
*/
MSG_MODEL_NOT_FOUND(27000, "找不到短信模板"),
MSG_CONFIG_NOT_FOUND(27001, "找不到短信配置"),
; ;


private int code; private int code;


+ 1
- 1
mallinkService/src/main/java/com/iformall/service/WxFlowService.java Zobrazit soubor

@@ -65,7 +65,7 @@ public interface WxFlowService {
* @param params * @param params
* @return * @return
*/ */
ResultData setBack(@RequestBody Map<String, Object> params,Long userId,String userName);
ResultData setBack(Map<String, Object> params,Long userId,String userName);


/** /**
* 生成流程图 * 生成流程图


+ 5
- 5
mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java Zobrazit soubor

@@ -197,13 +197,13 @@ public class WxCouponOrderServiceImpl implements WxCouponOrderService {
} }


@Override @Override
public ResultData listCUserVoAsPage(WxCouponOrder record, Integer pageIndex, Integer pageSize) {
public PageInfo<WxCouponOrderCVo> listCUserVoAsPage(WxCouponOrder record, Integer pageIndex, Integer pageSize) {


return new ResultData(PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxCouponOrderMapper.findListOfCUser(record)));
return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxCouponOrderMapper.findListOfCUser(record));
} }


@Override @Override
public ResultData detailCUserVo(Long cUserId, String couponOrderId) {
public WxCouponOrderCVo detailCUserVo(Long cUserId, String couponOrderId) {
WxCUser wxCuser = wxCUserMapper.selectByPrimaryKey(cUserId); WxCUser wxCuser = wxCUserMapper.selectByPrimaryKey(cUserId);
if (wxCuser == null) { if (wxCuser == null) {
logger.error("用户不存在:" + cUserId); logger.error("用户不存在:" + cUserId);
@@ -212,8 +212,8 @@ public class WxCouponOrderServiceImpl implements WxCouponOrderService {


WxCouponOrderCVo wxCouponOrderCVo = wxCouponOrderMapper.findDetailOfCUser(Long.valueOf(couponOrderId)); WxCouponOrderCVo wxCouponOrderCVo = wxCouponOrderMapper.findDetailOfCUser(Long.valueOf(couponOrderId));
if (wxCouponOrderCVo == null) if (wxCouponOrderCVo == null)
return new ResultData(ErrorCode.COUPON_ORDER_IS_NULL);
return new ResultData(wxCouponOrderCVo);
throw new MallinkException(ErrorCode.COUPON_ORDER_IS_NULL);
return wxCouponOrderCVo;
} }






+ 42
- 25
mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java Zobrazit soubor

@@ -10,6 +10,8 @@ import com.iformall.domain.po.*;
import com.iformall.enums.*; import com.iformall.enums.*;
import com.iformall.exception.MallinkException; import com.iformall.exception.MallinkException;
import com.iformall.mapper.*; import com.iformall.mapper.*;
import com.iformall.mq.MqBaseProducer;
import com.iformall.mapper.*;
import com.iformall.service.*; import com.iformall.service.*;
import com.iformall.utils.Constant; import com.iformall.utils.Constant;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
@@ -56,8 +58,6 @@ public class WxFlowServiceImpl implements WxFlowService {
@Autowired @Autowired
private MallUserInfoService mallUserInfoService; private MallUserInfoService mallUserInfoService;
@Autowired @Autowired
private WxMsgValidationcodeService wxMsgValidationcodeService;
@Autowired
private WxRentContractMapper wxRentContractMapper; private WxRentContractMapper wxRentContractMapper;
@Autowired @Autowired
private WxPropertyContractMapper wxPropertyContractMapper; private WxPropertyContractMapper wxPropertyContractMapper;
@@ -71,6 +71,8 @@ public class WxFlowServiceImpl implements WxFlowService {
private WxBillPropertyMapper wxBillPropertyMapper; private WxBillPropertyMapper wxBillPropertyMapper;
@Autowired @Autowired
private WxMerchantService wxMerchantService; private WxMerchantService wxMerchantService;
@Autowired
private MqBaseProducer mqBaseProducer;


/** /**
* 获取流程key,1合同 2账单 * 获取流程key,1合同 2账单
@@ -241,11 +243,13 @@ public class WxFlowServiceImpl implements WxFlowService {
content.put("userName",starterInfo.getName()); content.put("userName",starterInfo.getName());
content.put("page", Constant.adminPage); content.put("page", Constant.adminPage);


WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode();
wxMsgValidationcode.setTenantId(tenantId);
wxMsgValidationcode.setPhone(mallUserInfo.getPhone());
wxMsgValidationcode.setType(EnumMsgModel.FLOW_ASSIGNEE_NODIFY.getCode());
wxMsgValidationcodeService.sendWorkFlowNodify(wxMsgValidationcode,content);
WxMsgRecord wxMsgRecord = new WxMsgRecord();
wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode());
wxMsgRecord.setModelType(EnumMsgModel.FLOW_ASSIGNEE_NODIFY.getCode());
wxMsgRecord.setReceiver(mallUserInfo.getPhone());
wxMsgRecord.setTenantId(tenantId);
wxMsgRecord.setDynamicContentMap(content);
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode());
} }
return new ResultData(); return new ResultData();
} }
@@ -375,8 +379,8 @@ public class WxFlowServiceImpl implements WxFlowService {
assigneeArray = assignee.get("assignee").split(","); assigneeArray = assignee.get("assignee").split(",");
userName = ""; userName = "";
for (String userid:assigneeArray) { for (String userid:assigneeArray) {
MallUserInfo mallUserInfo = this.mallUserInfoService.getById(Long.parseLong(userid));
userName += mallUserInfo.getName()+" ";
MallUserInfo mallUserInfo = this.mallUserInfoService.getById(Long.parseLong(userid));
userName += mallUserInfo.getName()+" ";
} }


wxFlowRecord = new WxFlowRecord(); wxFlowRecord = new WxFlowRecord();
@@ -472,10 +476,13 @@ public class WxFlowServiceImpl implements WxFlowService {
msgReplaceMap.put("userName",userName); msgReplaceMap.put("userName",userName);
msgReplaceMap.put("page",Constant.adminPage); msgReplaceMap.put("page",Constant.adminPage);


assignee += mallUserInfo.getName()+" ";
wxMsgValidationcode.setPhone(mallUserInfo.getPhone());
wxMsgValidationcode.setType(EnumMsgModel.FLOW_ASSIGNEE_NODIFY.getCode());
wxMsgValidationcodeService.sendWorkFlowNodify(wxMsgValidationcode,msgReplaceMap);
WxMsgRecord wxMsgRecord = new WxMsgRecord();
wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode());
wxMsgRecord.setModelType(EnumMsgModel.FLOW_ASSIGNEE_NODIFY.getCode());
wxMsgRecord.setReceiver(mallUserInfo.getPhone());
wxMsgRecord.setTenantId(tenantId);
wxMsgRecord.setDynamicContentMap(msgReplaceMap);
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode());
} }


// 给发起人发送短信 // 给发起人发送短信
@@ -485,10 +492,13 @@ public class WxFlowServiceImpl implements WxFlowService {
msgReplaceMap.put("contract",businessId+""); msgReplaceMap.put("contract",businessId+"");
msgReplaceMap.put("toUserName",assignee.trim()); msgReplaceMap.put("toUserName",assignee.trim());


wxMsgValidationcode = new WxMsgValidationcode();
wxMsgValidationcode.setPhone(userMap!=null?(String)userMap.get("phone"):"");
wxMsgValidationcode.setType(EnumMsgModel.FLOW_APPLY_NODIFY.getCode());
wxMsgValidationcodeService.sendWorkFlowNodify(wxMsgValidationcode,msgReplaceMap);
WxMsgRecord wxMsgRecord = new WxMsgRecord();
wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode());
wxMsgRecord.setModelType(EnumMsgModel.FLOW_APPLY_NODIFY.getCode());
wxMsgRecord.setReceiver(userMap!=null?(String)userMap.get("phone"):"");
wxMsgRecord.setTenantId(tenantId);
wxMsgRecord.setDynamicContentMap(msgReplaceMap);
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode());
return false; return false;
}else{ }else{
//继续递归判断 //继续递归判断
@@ -501,10 +511,14 @@ public class WxFlowServiceImpl implements WxFlowService {
msgReplaceMap = new HashedMap(); msgReplaceMap = new HashedMap();
msgReplaceMap.put("contract",businessId+""); msgReplaceMap.put("contract",businessId+"");
msgReplaceMap.put("page",Constant.adminPage); msgReplaceMap.put("page",Constant.adminPage);
wxMsgValidationcode = new WxMsgValidationcode();
wxMsgValidationcode.setPhone(userMap!=null?(String)userMap.get("phone"):"");
wxMsgValidationcode.setType(EnumMsgModel.FLOW_PASS_NODIFY.getCode());
wxMsgValidationcodeService.sendWorkFlowNodify(wxMsgValidationcode,msgReplaceMap);

WxMsgRecord wxMsgRecord = new WxMsgRecord();
wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode());
wxMsgRecord.setModelType(EnumMsgModel.FLOW_PASS_NODIFY.getCode());
wxMsgRecord.setReceiver(userMap!=null?(String)userMap.get("phone"):"");
wxMsgRecord.setTenantId(tenantId);
wxMsgRecord.setDynamicContentMap(msgReplaceMap);
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode());
return true; return true;
} }
} }
@@ -583,10 +597,13 @@ public class WxFlowServiceImpl implements WxFlowService {
msgReplaceMap.put("contract",businessId+""); msgReplaceMap.put("contract",businessId+"");
msgReplaceMap.put("page",Constant.adminPage); msgReplaceMap.put("page",Constant.adminPage);


wxMsgValidationcode = new WxMsgValidationcode();
wxMsgValidationcode.setPhone(userMap!=null?(String)userMap.get("phone"):"");
wxMsgValidationcode.setType(EnumMsgModel.FLOW_REJECT_NODIFY.getCode());
wxMsgValidationcodeService.sendWorkFlowNodify(wxMsgValidationcode,msgReplaceMap);
WxMsgRecord wxMsgRecord = new WxMsgRecord();
wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode());
wxMsgRecord.setModelType(EnumMsgModel.FLOW_REJECT_NODIFY.getCode());
wxMsgRecord.setReceiver(userMap!=null?(String)userMap.get("phone"):"");
wxMsgRecord.setTenantId(tenantId);
wxMsgRecord.setDynamicContentMap(msgReplaceMap);
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode());
return new ResultData(); return new ResultData();
} }




Načítá se…
Zrušit
Uložit