Merge branch 'developer'

935090232@qq.com

2022-02-22 bbe0a2fd03063316e50cf141986bda984599bbda

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

@@ -1,6 +1,7 @@
package com.matrix.system.shopXcx.mqTask;


import com.matrix.component.asyncmessage.MessageHandler;
import com.matrix.core.tools.LogUtil;
import com.matrix.system.hive.bean.SysOrder;
import com.matrix.system.hive.dao.SysOrderDao;
@@ -12,11 +13,12 @@

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

/**
 * 微商城发货后erp出库
 */
public class OrderOutSotoreTask implements DeliverCallback {
public class OrderOutSotoreTask implements MessageHandler {

    @Autowired
    SysOrderDao sysOrderDao;
@@ -25,9 +27,19 @@
    SysOrderService orderService;

    @Override
    public void handle(String consumerTag, Delivery message) throws IOException {
    public String getName() {
        return "微商城发货后erp出库";
    }

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

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

        String orderNo = (String) param.get("orderNo");
        LogUtil.debug("收到出库订单orderNo={}", orderNo);
        //获取订单信息
        SysOrder sourceOrder = new SysOrder();