From b334b473f36f8565dd2b10515b797aa2a9c77a7c Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期六, 04 十一月 2023 08:11:06 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/kingdee/handler/InboundOrderHandler.java |   59 ++++++++++++++++++++++++++++++++---------------------------
 1 files changed, 32 insertions(+), 27 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/kingdee/handler/InboundOrderHandler.java b/src/main/java/com/zy/asrs/task/kingdee/handler/InboundOrderHandler.java
index 0bc7bd1..c98e298 100644
--- a/src/main/java/com/zy/asrs/task/kingdee/handler/InboundOrderHandler.java
+++ b/src/main/java/com/zy/asrs/task/kingdee/handler/InboundOrderHandler.java
@@ -69,7 +69,7 @@
         for(KingDeeUtilType kingDeeUtilType : KingDeeUtilType.values()) {
             InFormIdParam inFormIdParam = new InFormIdParam();
             DocType docType = docTypeService.selectOne(new EntityWrapper<DocType>().eq("doc_name", kingDeeUtilType.desc));
-            if (Cools.isEmpty(docType)){
+            if (Cools.isEmpty(docType) && !kingDeeUtilType.formId.equals("BD_MATERIAL")){
                 docType = docTypeService.selectOrAdd(kingDeeUtilType.desc, kingDeeUtilType.pakIn.equals(1));
             }
             inFormIdParam.setFormId(kingDeeUtilType.formId);
@@ -83,11 +83,11 @@
             jsonObject.put("Limit", inFormIdParam.getLimit());
             jsonObject.put("StartRow", inFormIdParam.getStartRow());
             //鐗╂枡妗f鏌ヨ
-            if(inFormIdParam.getFormId().equals("BD_MATERIAL")){
+            if(kingDeeUtilType.formId.equals("BD_MATERIAL")){
                 Tag tag = tagService.selectByName("鍏ㄩ儴", 1);
                 //鐗╂枡鐘舵�� FUseOrgId .FNumber
                 FDocumentStatus="C";
-                jsonObject.put("FilterString", "FCreateDate>'"+sdf.format(tag.getUpdateTime())+"' and FDocumentStatus='"+FDocumentStatus+"' and FUseOrgId .FNumber='201'");
+                jsonObject.put("FilterString", "FCreateDate>'"+sdf.format(tag.getUpdateTime())+"' and FDocumentStatus='"+FDocumentStatus+"' and FUseOrgId .FNumber='100'");
                 jsonObject.put("FieldKeys", "FName,FNumber,FCreateDate,FSpecification,FDocumentStatus");
                 // FName : 鐗╂枡鍚嶇О 锛�
                 // FNumber 锛氱墿鏂欑紪鍙凤紱
@@ -98,7 +98,7 @@
                 //鑾峰彇鏈�鏂版椂闂�
                 //鍗曟嵁鐘舵��
                 FDocumentStatus="B";
-                jsonObject.put("FilterString", "FCreateDate>'"+sdf.format(docType.getCreateTime())+"' and FStockId.Fname='绔嬪簱'"+" and FDocumentStatus='"+FDocumentStatus+"'");
+                jsonObject.put("FilterString", "FCreateDate>'"+sdf.format(docType.getCreateTime())+"'"+" and FStockId.Fname='绔嬪簱'"+" and FDocumentStatus='"+FDocumentStatus+"'");
                 jsonObject.put("FieldKeys", "FBillNo,FCreateDate,FMaterialId.FNumber,FMaterialId.FName,FMaterialId.FSpecification,"+kingDeeUtilType.anfme+",FDocumentStatus");
                 // FBillNo :鍗曟嵁缂栧彿锛�
                 // FCreateDate 锛氬崟鎹垱寤烘椂闂达紱
@@ -134,7 +134,7 @@
                     for (int j = 0; j < data.size(); j++) {
                         JSONArray jsonArray = data.getJSONArray(j);
                         //瀵圭編鍥芥椂闂磋繘琛岃浆鎹�
-                        Date date = KingDeeUtil.KingDeeDate(jsonArray.get(2).toString());
+                        Date jsonDate = KingDeeUtil.KingDeeDate(jsonArray.get(2).toString());
                         //鐢熸垚鍟嗗搧妗f
                         //鍟嗗搧缂栧彿
                         Mat mat = matService.selectByMatnr(jsonArray.get(1).toString());
@@ -144,7 +144,7 @@
                             mat.setMaktx(jsonArray.get(0).toString());
                             mat.setSpecs(jsonArray.get(3).toString());//瑙勬牸
                             mat.setTagId(tag.getId());
-                            mat.setCreateTime(date);//鍟嗗搧鍒涘缓鏃堕棿
+                            mat.setCreateTime(jsonDate);//鍟嗗搧鍒涘缓鏃堕棿
                             mat.setUpdateTime(new Date());
                             mat.setStatus(1);
                             //鏈�鏂版姄鍙栧晢鍝佹椂闂�
@@ -157,17 +157,19 @@
 //                                log.info("鍚屾鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}]", mat.getMatnr());
                             }
                         }else {
-                            callApiLogSaveMat(mat,kingDeeUtilType, "鍟嗗搧缂栧彿閲嶅:"+mat.getMatnr(), false);
-                            log.info("鍚屾鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}],鍟嗗搧缂栧彿閲嶅锛侊紒锛�", mat.getMatnr());
+                            if (!jsonDate.equals(tag.getUpdateTime())){
+                                callApiLogSaveMat(mat,kingDeeUtilType, "鍟嗗搧缂栧彿閲嶅:"+mat.getMatnr(), false);
+                                log.info("鍚屾鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}],鍟嗗搧缂栧彿閲嶅锛侊紒锛�", mat.getMatnr());
+                            }
                         }
-                        tag.setUpdateTime(date);
+                        tag.setUpdateTime(jsonDate);
                     }
                     tagService.updateById(tag);
                 } else {
                     for (int j = 0; j < data.size(); j++) {
                         JSONArray jsonArray = data.getJSONArray(j);
                         //鏈�鏂版姄鍙栨椂闂�
-                        Date jsonDate = KingDeeUtil.KingDeeDate(jsonArray.get(2).toString());
+                        Date jsonDate = KingDeeUtil.KingDeeDate(jsonArray.get(1).toString());
                         docType.setCreateTime(jsonDate);
                         Order order = orderService.selectByNo(jsonArray.get(0).toString());
                         if (Cools.isEmpty(order)) {
@@ -211,7 +213,9 @@
                             );
 
                             if (!orderService.insert(order)) {
-                                callApiLogSaveOrder(order,kingDeeUtilType, "鐢熸垚鍗曟嵁涓绘。澶辫触锛岃鑱旂郴绠$悊鍛�"+order, false);
+                                if (!jsonDate.equals(docType.getCreateTime())){
+                                    callApiLogSaveOrder(order,kingDeeUtilType, "鐢熸垚鍗曟嵁涓绘。澶辫触锛岃鑱旂郴绠$悊鍛�"+order, false);
+                                }
                                 continue;
 //                                throw new CoolException("鐢熸垚鍗曟嵁涓绘。澶辫触锛岃鑱旂郴绠$悊鍛�");
                             }
@@ -219,9 +223,10 @@
                         //鐗╂枡缂栫爜
                         Mat mat = matService.selectByMatnr(jsonArray.get(2).toString());
                         if (Cools.isEmpty(mat)) {
-                            callApiLogSaveOrder(order,kingDeeUtilType, "缂栧彿鍟嗗搧妫�绱㈠け璐ワ紝璇峰厛娣诲姞鍟嗗搧"+jsonArray.get(2).toString(), false);
+                            if (!jsonDate.equals(docType.getCreateTime())){
+                                callApiLogSaveOrder(order,kingDeeUtilType, "缂栧彿鍟嗗搧妫�绱㈠け璐ワ紝璇峰厛娣诲姞鍟嗗搧"+jsonArray.get(2).toString(), false);
+                            }
                             continue;
-//                            throw new CoolException(jsonArray.get(2).toString() + "缂栧彿鍟嗗搧妫�绱㈠け璐ワ紝璇峰厛娣诲姞鍟嗗搧");
                         }
                         OrderDetl orderDetl1 = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", jsonArray.get(0).toString()).eq("matnr", jsonArray.get(2).toString()));
                         if (!Cools.isEmpty(orderDetl1)) {
@@ -251,20 +256,20 @@
 //            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                 return FAIL.setMsg(e.getMessage());
             } finally {
-                try {
-                    // 淇濆瓨鎺ュ彛鏃ュ織
-                    apiLogService.save(
-                            "杞鏁版嵁",
-                            URL + inaddress,
-                            null,
-                            "127.0.0.1",
-                            add,
-                            response,
-                            success
-                    );
-                } catch (Exception e) {
-                    log.error("", e);
-                }
+//                try {
+//                    // 淇濆瓨鎺ュ彛鏃ュ織
+//                    apiLogService.save(
+//                            "杞鏁版嵁",
+//                            URL + inaddress,
+//                            null,
+//                            "127.0.0.1",
+//                            add,
+//                            response,
+//                            success
+//                    );
+//                } catch (Exception e) {
+//                    log.error("", e);
+//                }
             }
         }
         return SUCCESS;

--
Gitblit v1.9.1