Merge branch 'developer'

姜友瑶

2022-08-09 c423224dbe37ea69c1a36c696f85490343e68c4c

 zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/SalesOrderRefundTask.java

@@ -2,6 +2,7 @@


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.matrix.component.asyncmessage.MessageHandler;
import com.matrix.core.tools.LogUtil;
import com.matrix.system.fenxiao.dao.ShopSalesmanOrderDao;
import com.matrix.system.fenxiao.entity.ShopSalesmanOrder;
@@ -17,12 +18,13 @@

import java.io.IOException;
import java.util.List;
import java.util.Map;

/**
 * 分销订单退款
 */
@Component
public class SalesOrderRefundTask implements DeliverCallback {
public class SalesOrderRefundTask implements MessageHandler {


    @Autowired
@@ -39,9 +41,19 @@


    @Override
    public void handle(String consumerTag, Delivery message) throws IOException {
    public String getName() {
        return "分销订单退款";
    }

        String orderId = new String(message.getBody(), "UTF-8");
    @Override
    public String getRouteKey() {
        return AsyncMessageRouting.SHOP_ORDER_REFUND;
    }

    @Override
    public void handle(Map<String,Object> param){

        String orderId = (String) param.get("orderId");
        LogUtil.debug("收到分销订单退款任务orderId={}", orderId);
        QueryWrapper queryWrapper=new QueryWrapper();
        queryWrapper.eq("order_id",orderId);