读取第二数据源

ZY

2025-05-10 dc84bb47fbc3ffc22a6ba36d30a2852432c2d01d

 src/main/java/com/zy/asrs/service/impl/ReportToThirdServiceImpl.java

@@ -10,14 +10,18 @@
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.OrderService;
import com.zy.asrs.service.ReportToThirdService;
import com.zy.common.utils.HttpHandler;
import com.zy.nc.SendUtil;
import com.zy.nc.util.NcResultMessage;
import com.zy.nc.vo.SaleOutBodyVO;
import com.zy.nc.vo.SaleOutHeadVO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

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

@Service
@Slf4j
@@ -42,62 +46,70 @@
    @Override
    public void report(Order order, List<OrderDetl> orderDetls, DocType docType) {
        Boolean http = false;
        switch (order.getDocType().toString()) {
            case "销售发货":
                http = http("", docType.getDocName(), nyncIp + port, saveRefDelivery);
                if (Cools.isEmpty(order.getShipCode()) || order.getShipCode().equalsIgnoreCase("1")) {

                }
                break;
            case "产成品入库":
                break;
            case "辅料采购入库":
                break;
            case "辅料及成品转库":
                break;
            case "自动包装入库":
                break;
            case "内部调拨":
                break;
            default:
                break;
        }
        if (http) {
            // 修改订单状态 4.完成 ===>> 6.已上报
            if (!orderService.updateSettle(order.getId(), 6L, null)) {
                throw new CoolException("服务器内部错误，请联系管理员");
        NcResultMessage response = null;
        try {
            switch (order.getDocType().toString()) {
                case "销售发货":
                    //组装对象数据
                    Map<String, Object> data = new HashMap<String, Object>();
                    SaleOutHeadVO saleOutHeadVO = new SaleOutHeadVO();
                    saleOutHeadVO.setPk_org("FYT");
                    saleOutHeadVO.setCwarehouseid("6101");
                    SaleOutBodyVO saleOutBodyVO = null;
                    for (OrderDetl orderDetl : orderDetls) {
                        saleOutBodyVO = new SaleOutBodyVO();
                        saleOutBodyVO.setCsourcebillhid("1001A1100000027XNSH2");
                        saleOutBodyVO.setCsourcebillbid("1001A1100000027YFC8U");
                        saleOutBodyVO.setCsourcetype("4331-01");
                    }
                    data.put("saleOutHeadVO", saleOutHeadVO);
                    data.put("saleOutBodyVO", saleOutBodyVO);
                    //发送请求
                    response = SendUtil.sendDataToNc(SendUtil.token, nyncIp + port, saveRefDelivery, JSONObject.toJSONString(data));
                    if (!Cools.isEmpty(response) && response.isSuccess()) {
                        log.info("response:{}", response);
                        http = true;
                    }
                    break;
                case "产成品入库":
                    break;
                case "辅料采购入库":
                    break;
                case "辅料及成品转库":
                    break;
                case "自动包装入库":
                    break;
                case "内部调拨":
                    break;
                default:
                    break;
            }
            if (http) {
                // 修改订单状态 4.完成 ===>> 6.已上报
                if (!orderService.updateSettle(order.getId(), 6L, null)) {
                    throw new CoolException("服务器内部错误，请联系管理员");
                }
            }
        } catch (Exception e) {
            throw new CoolException("调用接口报错，请联系管理员");
        } finally {
            reportApiLog(response, order.getDocType$(), nyncIp, saveRefDelivery);
        }

    }

    private Boolean http(Object data, String docType, String url, String path) {
    private Boolean reportApiLog(Object data, String docType, String url, String path) {
        String response = "";
        boolean success = false;
        try {
            response = new HttpHandler.Builder()
                    .setUri(url)
                    .setPath(path)
                    .setJson(JSON.toJSONString(data))
                    .build()
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if (jsonObject.getInteger("code").equals(1)) {
                return true;
            }
            log.error("请求接口失败！！！url：{}；request：{}；response：{}", url + path, JSON.toJSONString(data), response);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            apiLogService.save(
                    docType,
                    url + path,
                    null,
                    "127.0.0.1",
                    JSON.toJSONString(data),
                    response,
                    success
            );
        }
        apiLogService.save(
                docType,
                url + path,
                null,
                "127.0.0.1",
                JSON.toJSONString(data),
                response,
                success
        );
        return false;
    }
}