#

1

4 小时以前 e0300cb5c16e9487d118361141e59f1d7a284b7a

#

 src/main/java/com/zy/asrs/task/kingdee/ReviewOrderSyncScheduler.java

@@ -42,10 +42,12 @@
        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
//            List<Order> orders = OrderInAndOutUtil.selectComplete9(null);//查询9提交完成的
            List<Order> orders = orderService.selectComplete9();
            for (Order order : orders) {
                ReturnT<String> result = reviewOrderSyncHandler.start(order);
                if (!result.isSuccess()) {
                    log.error("单据[orderNo={}]向erp审核失败", order.getOrderNo());
            if(orders.size() > 0){
                for (Order order : orders) {
                    ReturnT<String> result = reviewOrderSyncHandler.start(order);
                    if (!result.isSuccess()) {
                        log.error("单据[orderNo={}]向erp审核失败", order.getOrderNo());
                    }
                }
            }
        }

 src/main/java/com/zy/asrs/task/kingdee/SaveOrderSyncScheduler.java

@@ -42,11 +42,12 @@
        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
//            List<Order> orders = OrderInAndOutUtil.selectComplete(null);
            List<Order> orders = orderService.selectComplete();

            for (Order order : orders) {
                ReturnT<String> result = saveOrderSyncHandler.start(order);//4已完成
                if (!result.isSuccess()) {
                    log.error("单据[orderNo={}]新增保存至erp失败", order.getOrderNo());
            if(orders.size() > 0){
                for (Order order : orders) {
                    ReturnT<String> result = saveOrderSyncHandler.start(order);//4已完成
                    if (!result.isSuccess()) {
                        log.error("单据[orderNo={}]新增保存至erp失败", order.getOrderNo());
                    }
                }
            }
        }

 src/main/java/com/zy/asrs/task/kingdee/SubmitOrderSyncScheduler.java

@@ -44,11 +44,12 @@
        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
//            List<Order> orders = OrderInAndOutUtil.selectComplete10(null); //查询10新增上报完成
            List<Order> orders = orderService.selectComplete10();

            for (Order order : orders) {
                ReturnT<String> result = submitOrderSyncHandler.start(order);
                if (!result.isSuccess()) {
                    log.error("单据[orderNo={}]保存至erp失败", order.getOrderNo());
            if(orders.size() > 0){
                for (Order order : orders) {
                    ReturnT<String> result = submitOrderSyncHandler.start(order);
                    if (!result.isSuccess()) {
                        log.error("单据[orderNo={}]提交至erp失败", order.getOrderNo());
                    }
                }
            }
        }

 src/main/java/com/zy/asrs/task/kingdee/handler/SaveOrderSyncHandler.java

@@ -98,10 +98,11 @@
                    if (orderDetl.getQty() == 0) {
                        continue;
                    }

                    JSONArray idArr = new JSONArray();
                    idArr.add(0L);   // ✅ 注意必须是 Long 类型的 0L
                    // 创建 billentry_lk 对象
                    JSONObject billentryLk = new JSONObject()
                            .fluentPut("id", Long.parseLong(orderDetl.getThreeCode()))
                            .fluentPut("id", idArr)
                            .fluentPut("seq", orderDetl.getLineNumber())
                            .fluentPut("billentry_lk_stableid", 677270092232273922L)
                            .fluentPut("billentry_lk_sbillid", Long.parseLong(order.getItemName()))  // 主单ID
@@ -111,7 +112,7 @@
                    billentryLkArray.add(billentryLk);
                    // 创建 billentry 对象，填充缺失的字段
                    JSONObject billentry = new JSONObject()
                            .fluentPut("id", Long.parseLong(orderDetl.getThreeCode()))
                            .fluentPut("id", idArr)
                            .fluentPut("warehouse_number", orderDetl.getManu())  // 仓库编号
                            .fluentPut("invstatus_number", "110")  // 库存状态
                            .fluentPut("invtype_number", "110")  // 库存类型
@@ -119,16 +120,15 @@
                            .fluentPut("linetype_number", "010")  // 行号类型
                            .fluentPut("qty", orderDetl.getQty())  // 数量
                            .fluentPut("material_number", orderDetl.getMatnr())  // 物料编号
                            .fluentPut("billentry_lk", billentryLkArray);  // 将 billentry_lk 添加到 billentry
                            .fluentPut("billentry_lk", billentryLkArray);

                    billentryArray.add(billentry);
                }
                Date now = new Date();
                // 生成 INR 相关请求参数
                return new JSONObject()
                        .fluentPut("data", new JSONArray(Arrays.asList(
                                new JSONObject()
                                        .fluentPut("billno", UUID.randomUUID().toString().replace("-", ""))
                                        .fluentPut("billno", UUID.randomUUID().toString().replace("-", "").substring(0, 16))
                                        .fluentPut("trdbillno", UUID.randomUUID().toString().replace("-", ""))
                                        .fluentPut("billtype_number", "im_PurInBill_STD_BT_S")
                                        .fluentPut("biztime", sdf1.format(now))
@@ -140,7 +140,6 @@
                                        .fluentPut("invscheme_number", "110")
                                        .fluentPut("billtype_number", "im_PurInBill_STD_BT_S")
                                        .fluentPut("supplier_number", suppCode)  // 供应商编号
                                        .fluentPut("billno", order.getOrderNo())
                                        .fluentPut("billentry", billentryArray)  // 将 billentry 数组添加到请求参数
                        )));