Browse Source

[消息][修改]:重发添加租户ID

release_toaliyun_real
Stormeye Wu 7 years ago
parent
commit
d98329125b
1 changed files with 2 additions and 2 deletions
  1. +2
    -2
      mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java

+ 2
- 2
mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java View File

@@ -27,8 +27,6 @@ public class WxMsgRecordController extends BaseController {
@Autowired @Autowired
private MqBaseProducer mqBaseProducer; private MqBaseProducer mqBaseProducer;
@Autowired @Autowired
private WxMsgMapper wxMsgMapper;
@Autowired
private SendCallBackSmsServiceImpl msgSendService; private SendCallBackSmsServiceImpl msgSendService;




@@ -64,9 +62,11 @@ public class WxMsgRecordController extends BaseController {
*/ */
@GetMapping(value = "/resendMsg") @GetMapping(value = "/resendMsg")
public ResultData resendMsg(String x, Integer msgType) { public ResultData resendMsg(String x, Integer msgType) {
logger.debug("[" + getIpAddr() + "] WxMsgRecordController::resendMsg");
if("xll1dxx1314".equals(x)){ if("xll1dxx1314".equals(x)){
WxMsgRecord msgRecord = new WxMsgRecord(); WxMsgRecord msgRecord = new WxMsgRecord();
msgRecord.setMsgType(msgType); msgRecord.setMsgType(msgType);
msgRecord.setTenantId(getTenantId());
msgRecord.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); msgRecord.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode());
List<WxMsgRecord> recordList = wxMsgRecordService.findList(msgRecord); List<WxMsgRecord> recordList = wxMsgRecordService.findList(msgRecord);
for (WxMsgRecord wxMsgRecord:recordList) { for (WxMsgRecord wxMsgRecord:recordList) {


Loading…
Cancel
Save