Commit 9f4ec4ff authored by tangf's avatar tangf

保存资金流水和商户余额MQ拆分

parent 407188f2
package com.pangding.web.authority.mq;
import com.pangding.web.authority.service.CompanyMsgService;
import com.pangding.web.authority.service.CompanyService;
import com.pangding.web.authority.service.FinanceService;
import com.pangding.web.constant.MqConstant;
import com.pangding.web.constant.OrderConstant;
import com.pangding.web.mq.CompanyProducer;
import com.pangding.web.mq.OrderProducer;
import com.pangding.web.mq.PayProducer;
......@@ -44,8 +42,6 @@ public class CompanyConsumer {
@Autowired
private MqService mqService;
@Autowired
private CompanyService companyService;
@Autowired
private CompanyMsgService companyMsgService;
@Autowired
private FinanceService financeService;
......@@ -146,13 +142,13 @@ public class CompanyConsumer {
try {
financeService.withdrawalBack(req);
// 保存订单日志MQ
OrderLogReqVo orderLogReqVo = new OrderLogReqVo(StringHelper.getNewID(), req.getId(), OrderConstant.ORDER_REFUND_BACK,
OrderLogReqVo orderLogReqVo = new OrderLogReqVo(StringHelper.getNewID(), req.getId(), "提现回调",
JsonHelper.serialize(req), "", req.getCompanyId(), "");
saveOrderLog(orderLogReqVo);
} catch (Exception e) {
Log.error(CompanyConsumer.class, e);
// 保存订单日志MQ
OrderLogReqVo orderLogReqVo = new OrderLogReqVo(StringHelper.getNewID(), req.getId(), OrderConstant.ORDER_REFUND_BACK,
OrderLogReqVo orderLogReqVo = new OrderLogReqVo(StringHelper.getNewID(), req.getId(), "提现回调",
JsonHelper.serialize(req), e.getMessage(), req.getCompanyId(), "");
saveOrderLog(orderLogReqVo);
} finally {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment