#上报 打印

cl

7 天以前 6062e826f1b1acde1bfe2887353c1214f2af12d6

#上报 打印

 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/CloudWmsReportServiceImpl.java

@@ -8,6 +8,7 @@
import com.vincent.rsf.server.api.feign.CloudWmsErpFeignClient;
import com.vincent.rsf.server.api.integration.dap.DapIlcwmsResponseNormalizer;
import com.vincent.rsf.server.api.service.CloudWmsReportService;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -31,6 +32,8 @@

    @Autowired
    private CloudWmsErpFeignClient cloudWmsErpFeignClient;
    @Autowired
    private ObjectMapper objectMapper;

    @Override
    public Map<String, Object> syncMatnrsToCloud(Object body) {
@@ -57,6 +60,7 @@
        boolean inbound = param.getInbound() == null || Boolean.TRUE.equals(param.getInbound());
        DapIlcwmsCompletionRequest req = new DapIlcwmsCompletionRequest()
                .setData(Collections.singletonList(buildInOutLine(param, inbound)));
        logOutboundPayload("IN_OUT_RESULT", inbound ? "stockInCompleted" : "stockOutCompleted", req);
        Map<String, Object> raw = inbound
                ? cloudWmsErpFeignClient.cusInventoryCompletionReport(req)
                : cloudWmsErpFeignClient.cusOutboundCompletionReport(req);
@@ -94,6 +98,7 @@
        } else {
            return resultMap(400, "不支持的 changeType：" + changeType, null);
        }
        logOutboundPayload("INVENTORY_ADJUST", changeType == 3 ? "stockTransferCompleted" : "reportInventoryAdjust", req);
        Map<String, Object> raw = changeType == 3
                ? cloudWmsErpFeignClient.stockTransferCompleted(req)
                : cloudWmsErpFeignClient.reportInventoryAdjust(req);
@@ -275,4 +280,14 @@
        map.put("data", data);
        return map;
    }

    private void logOutboundPayload(String reportType, String endpoint, DapIlcwmsCompletionRequest req) {
        try {
            log.info("云仓真实请求报文，reportType={}，endpoint={}，payload={}",
                    reportType, endpoint, objectMapper.writeValueAsString(req));
        } catch (Exception e) {
            log.warn("云仓真实请求报文序列化失败，reportType={}，endpoint={}：{}",
                    reportType, endpoint, e.getMessage());
        }
    }
}

 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CloudWmsNotifySchedule.java

@@ -7,6 +7,9 @@
import com.vincent.rsf.server.api.service.CloudWmsReportService;
import com.vincent.rsf.server.manager.entity.CloudWmsNotifyLog;
import com.vincent.rsf.server.manager.service.CloudWmsNotifyLogService;
import com.vincent.rsf.server.system.constant.GlobalConfigCode;
import com.vincent.rsf.server.system.entity.Config;
import com.vincent.rsf.server.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
@@ -22,6 +25,7 @@
public class CloudWmsNotifySchedule {

    private static final int BATCH_LIMIT = 50;
    private static final int STORE_BODY_MAX_CHARS_DEFAULT = 2000;

    @Autowired
    private CloudWmsNotifyLogService cloudWmsNotifyLogService;
@@ -29,6 +33,8 @@
    private CloudWmsReportService cloudWmsReportService;
    @Autowired
    private ObjectMapper objectMapper;
    @Autowired
    private ConfigService configService;

    @Scheduled(cron = "0/30 * * * * ?")
    public void syncCloudWmsNotify() {
@@ -58,8 +64,8 @@
                if (logRecord.getLastNotifyTime() != null) {
                    long elapsed = (nowMs - logRecord.getLastNotifyTime().getTime()) / 1000;
                    if (elapsed < intervalSeconds) {
                        log.info("云仓上报待办跳过：未到重试间隔，id={}，bizRef={}，elapsed={}s，interval={}s",
                                logRecord.getId(), logRecord.getBizRef(), elapsed, intervalSeconds);
//                        log.info("云仓上报待办跳过：未到重试间隔，id={}，bizRef={}，elapsed={}s，interval={}s",
//                                logRecord.getId(), logRecord.getBizRef(), elapsed, intervalSeconds);
                        continue;
                    }
                }
@@ -112,8 +118,8 @@
        Object statusObj = res != null ? res.get("status") : null;
        boolean success = Integer.valueOf(200).equals(codeObj) || Integer.valueOf(200).equals(statusObj);
        int status = success ? cloudWmsNotifyLogService.getNotifyStatusSuccess() : cloudWmsNotifyLogService.getNotifyStatusFail();
        logRecord.setLastRequestBody(requestBody);
        logRecord.setLastResponseBody(responseJson);
        logRecord.setLastRequestBody(truncateForStore(requestBody));
        logRecord.setLastResponseBody(truncateForStore(responseJson));
        logRecord.setLastNotifyTime(now);
        logRecord.setRetryCount(nextRetry);
        logRecord.setNotifyStatus(status);
@@ -124,8 +130,8 @@
    }

    private void setFailResult(CloudWmsNotifyLog logRecord, String requestBody, String errorMsg, int nextRetry, Date now, int effectiveMaxRetry) {
        logRecord.setLastRequestBody(requestBody);
        logRecord.setLastResponseBody(errorMsg);
        logRecord.setLastRequestBody(truncateForStore(requestBody));
        logRecord.setLastResponseBody(truncateForStore(errorMsg));
        logRecord.setLastNotifyTime(now);
        logRecord.setRetryCount(nextRetry);
        // logRecord.setNotifyStatus(nextRetry >= effectiveMaxRetry ? cloudWmsNotifyLogService.getNotifyStatusFail() : cloudWmsNotifyLogService.getNotifyStatusPending());
@@ -143,4 +149,25 @@
    private boolean isInfiniteRetry(Integer maxRetry) {
        return maxRetry != null && maxRetry == -1;
    }

    private String truncateForStore(String body) {
        int maxChars = resolveStoreBodyMaxChars();
        if (body == null || body.length() <= maxChars) {
            return body;
        }
        return body.substring(0, maxChars);
    }

    private int resolveStoreBodyMaxChars() {
        try {
            Config cfg = configService.getCachedOrLoad(GlobalConfigCode.CLOUD_WMS_NOTIFY_STORE_BODY_MAX_CHARS);
            if (cfg == null || cfg.getVal() == null || cfg.getVal().trim().isEmpty()) {
                return STORE_BODY_MAX_CHARS_DEFAULT;
            }
            int parsed = Integer.parseInt(cfg.getVal().trim());
            return parsed > 0 ? parsed : STORE_BODY_MAX_CHARS_DEFAULT;
        } catch (Exception e) {
            return STORE_BODY_MAX_CHARS_DEFAULT;
        }
    }
}

 rsf-server/src/main/java/com/vincent/rsf/server/system/constant/GlobalConfigCode.java

@@ -44,6 +44,8 @@
    public final static String CLOUD_WMS_NOTIFY_STATUS_SUCCESS = "CLOUD_WMS_NOTIFY_STATUS_SUCCESS";
    /** 云仓通知状态：失败 */
    public final static String CLOUD_WMS_NOTIFY_STATUS_FAIL = "CLOUD_WMS_NOTIFY_STATUS_FAIL";
    /** 云仓通知入库体最大长度（last_request_body / last_response_body，默认 2000） */
    public final static String CLOUD_WMS_NOTIFY_STORE_BODY_MAX_CHARS = "CLOUD_WMS_NOTIFY_STORE_BODY_MAX_CHARS";

    /** 指定物料自动全板出库：物料编码（val=物料编码时启用按物料自动生成全板出库单） */
    public final static String AUTO_FULL_OUT_MATNR_CODE = "AUTO_FULL_OUT_MATNR_CODE";

 version/db/backfill_cloud_notify_inbound_tasks_8767_8770.sql

New file
@@ -0,0 +1,82 @@
-- 补历史入库任务（8767~8770）云仓上报来源字段，并生成待上报记录
-- 执行后会在 man_cloud_wms_notify_log 产生 notify_status=0 的待办，按现有定时任务自动补发到云仓

-- 1) 回填任务明细 plat_order_code / plat_work_code（优先取组托明细）
UPDATE man_task_item ti
LEFT JOIN man_wait_pakin_item wpi ON wpi.id = ti.source
SET ti.plat_order_code = COALESCE(NULLIF(ti.plat_order_code, ''), NULLIF(wpi.plat_order_code, '')),
    ti.plat_work_code = COALESCE(NULLIF(ti.plat_work_code, ''), NULLIF(wpi.plat_work_code, '')),
    ti.update_time = NOW()
WHERE ti.task_id IN (8767, 8768, 8769, 8770)
  AND (ti.deleted = 0 OR ti.deleted = 1);

-- 2) 组托明细仍为空时，按订单明细兜底回填（订单明细表：man_asn_order_item）
UPDATE man_task_item ti
LEFT JOIN man_asn_order_item oi ON oi.id = ti.order_item_id
SET ti.plat_order_code = COALESCE(NULLIF(ti.plat_order_code, ''), NULLIF(oi.plat_order_code, '')),
    ti.plat_work_code = COALESCE(NULLIF(ti.plat_work_code, ''), NULLIF(oi.plat_work_code, '')),
    ti.update_time = NOW()
WHERE ti.task_id IN (8767, 8768, 8769, 8770)
  AND (ti.deleted = 0 OR ti.deleted = 1);

-- 3) 生成云仓上报待办（去重：同 taskId + orderNo + lineId 不重复插入）
INSERT INTO man_cloud_wms_notify_log
(report_type, request_body, notify_status, retry_count, biz_ref, tenant_id, deleted, create_time, update_time)
SELECT
    'IN_OUT_RESULT' AS report_type,
    JSON_OBJECT(
        'orderNo', src.order_no,
        'planNo', src.plan_no,
        'lineId', src.line_id,
        'wareHouseId', src.warehouse_code,
        'locId', src.loc_code,
        'matNr', src.matnr_code,
        'qty', src.qty_txt,
        'batch', src.batch_val,
        'inbound', true,
        'barcode', src.barcode
    ) AS request_body,
    CAST(COALESCE(
            (SELECT val FROM sys_config WHERE flag = 'CLOUD_WMS_NOTIFY_STATUS_PENDING' AND (deleted = 0 OR deleted IS NULL) ORDER BY id DESC LIMIT 1),
            '0'
         ) AS SIGNED) AS notify_status,
    0 AS retry_count,
    CONCAT('taskId=', src.task_id, ',orderNo=', src.order_no, ',lineId=', COALESCE(src.line_id, '')) AS biz_ref,
    src.tenant_id,
    0 AS deleted,
    NOW() AS create_time,
    NOW() AS update_time
FROM (
    SELECT
        t.id AS task_id,
        t.barcode,
        t.targ_loc AS loc_code,
        wh.code AS warehouse_code,
        COALESCE(NULLIF(ti.plat_order_code, ''), NULLIF(ti.plat_work_code, ''), NULLIF(wpi.asn_code, '')) AS order_no,
        NULLIF(ti.plat_work_code, '') AS plan_no,
        ti.plat_item_id AS line_id,
        ti.matnr_code,
        CAST(IFNULL(ti.anfme, 0) AS CHAR) AS qty_txt,
        ti.batch AS batch_val,
        IFNULL(ti.tenant_id, 1) AS tenant_id
    FROM man_task t
    JOIN man_task_item ti ON ti.task_id = t.id
    LEFT JOIN man_wait_pakin_item wpi ON wpi.id = ti.source
    LEFT JOIN man_loc l ON l.code = t.targ_loc
    LEFT JOIN man_warehouse wh ON wh.id = l.warehouse_id
    WHERE t.id IN (8767, 8768, 8769, 8770)
      AND t.task_type = 1
      AND t.task_status = 100
      AND (ti.deleted = 0 OR ti.deleted = 1)
) src
LEFT JOIN man_cloud_wms_notify_log exist_log
       ON exist_log.report_type = 'IN_OUT_RESULT'
      AND exist_log.deleted = 0
      AND exist_log.biz_ref = CONCAT('taskId=', src.task_id, ',orderNo=', src.order_no, ',lineId=', COALESCE(src.line_id, ''))
WHERE src.order_no IS NOT NULL
  AND src.order_no <> ''
  AND src.matnr_code IS NOT NULL
  AND src.matnr_code <> ''
  AND src.warehouse_code IS NOT NULL
  AND src.warehouse_code <> ''
  AND exist_log.id IS NULL;