|
|
|
@@ -411,6 +411,12 @@ public class WxFlowServiceImpl implements WxFlowService { |
|
|
|
wxMsgRecord.setModelType(EnumMsgModel.FLOW_ASSIGNEE_NODIFY.getCode()); |
|
|
|
wxMsgRecord.setReceiver(phone); |
|
|
|
wxMsgRecord.setTenantId(tenantId); |
|
|
|
if(1 == flowType.intValue() || 3 == flowType.intValue()){ |
|
|
|
dynamicContentMap.put("bustype","合同"); |
|
|
|
}else if(2 == flowType.intValue()){ |
|
|
|
dynamicContentMap.put("bustype","账单"); |
|
|
|
dynamicContentMap.put("contract", businessId.toString()); |
|
|
|
} |
|
|
|
wxMsgRecord.setDynamicContentMap(dynamicContentMap); |
|
|
|
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
|
|
|
|
@@ -731,6 +737,12 @@ public class WxFlowServiceImpl implements WxFlowService { |
|
|
|
wxMsgRecord.setModelType(EnumMsgModel.FLOW_APPLY_NODIFY.getCode()); |
|
|
|
wxMsgRecord.setReceiver(userMap!=null?(String)userMap.get("phone"):""); |
|
|
|
wxMsgRecord.setTenantId(tenantId); |
|
|
|
if(1 == flowType.intValue() || 3 == flowType.intValue()){ |
|
|
|
msgReplaceMap.put("bustype","合同"); |
|
|
|
}else if(2 == flowType.intValue()){ |
|
|
|
msgReplaceMap.put("bustype","账单"); |
|
|
|
msgReplaceMap.put("contract", businessId.toString()); |
|
|
|
} |
|
|
|
wxMsgRecord.setDynamicContentMap(msgReplaceMap); |
|
|
|
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
|
|
|
|
@@ -770,6 +782,12 @@ public class WxFlowServiceImpl implements WxFlowService { |
|
|
|
wxMsgRecord.setModelType(EnumMsgModel.FLOW_PASS_NODIFY.getCode()); |
|
|
|
wxMsgRecord.setReceiver(userMap!=null?(String)userMap.get("phone"):""); |
|
|
|
wxMsgRecord.setTenantId(tenantId); |
|
|
|
if(1 == flowType.intValue() || 3 == flowType.intValue()){ |
|
|
|
msgReplaceMap.put("bustype","合同"); |
|
|
|
}else if(2 == flowType.intValue()){ |
|
|
|
msgReplaceMap.put("bustype","账单"); |
|
|
|
msgReplaceMap.put("contract", businessId.toString()); |
|
|
|
} |
|
|
|
wxMsgRecord.setDynamicContentMap(msgReplaceMap); |
|
|
|
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
|
|
|
|
@@ -876,6 +894,12 @@ public class WxFlowServiceImpl implements WxFlowService { |
|
|
|
wxMsgRecord.setModelType(EnumMsgModel.FLOW_REJECT_NODIFY.getCode()); |
|
|
|
wxMsgRecord.setReceiver(userMap!=null?(String)userMap.get("phone"):""); |
|
|
|
wxMsgRecord.setTenantId(tenantId); |
|
|
|
if(1 == flowType.intValue() || 3 == flowType.intValue()){ |
|
|
|
msgReplaceMap.put("bustype","合同"); |
|
|
|
}else if(2 == flowType.intValue()){ |
|
|
|
msgReplaceMap.put("bustype","账单"); |
|
|
|
msgReplaceMap.put("contract", businessId.toString()); |
|
|
|
} |
|
|
|
wxMsgRecord.setDynamicContentMap(msgReplaceMap); |
|
|
|
mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode()); |
|
|
|
|
|
|
|
|