Преглед изворни кода

[核销异常][修改]:核销失败消息重发

release_toaliyun_real
Stormeye Wu пре 6 година
родитељ
комит
83c1ce85e7
1 измењених фајлова са 7 додато и 0 уклоњено
  1. +7
    -0
      mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java

+ 7
- 0
mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java Прегледај датотеку

@@ -103,6 +103,13 @@ public class WxMsgRecordController extends BaseController {
msg.setReceiver(wxMsgRecord.getReceiver()); msg.setReceiver(wxMsgRecord.getReceiver());
msg.updateTenantInfo(tenantEntity); msg.updateTenantInfo(tenantEntity);
mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode());
}else if(EnumMsgRecordType.INSIDE_COUPON_VERIFY.getCode().equals(wxMsgRecord.getMsgType())){
//内部消息 - 券核销
FmInsideCouponVerifyMsg msg = (FmInsideCouponVerifyMsg) JsonUtil.readValue(wxMsgRecord.getMsgJson(),FmInsideCouponVerifyMsg.class);
msg.setMsgType(wxMsgRecord.getMsgType());
msg.setReceiver(wxMsgRecord.getReceiver());
msg.setTenantId(wxMsgRecord.getTenantId());
mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode());
} }
} }
return new ResultData(); return new ResultData();


Loading…
Откажи
Сачувај