From 02d2603087f1f33aba8c32f4999004ca41fa314b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=A5=8E=E5=85=B4?= <2220574228@qq.com>
Date: Sat, 28 Mar 2026 10:20:10 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E9=80=81nc=E7=8A=B6=E6=80=81=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0=E4=BF=AE=E6=94=B9;=E6=96=B0=E5=AD=97=E6=AE=B5sql?=
 =?UTF-8?q?=E6=95=B4=E7=90=86;?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../persistence/BillManageImpl.java           | 18 ++++++
 .../persistence/ReconciliationImpl.java       | 64 +++++++++++++++++++
 sql/wkx.sql                                   |  6 +-
 3 files changed, 87 insertions(+), 1 deletion(-)

diff --git a/mhd_bms/src/main/java/com/mhd/bms/domain/billManage/repository/persistence/BillManageImpl.java b/mhd_bms/src/main/java/com/mhd/bms/domain/billManage/repository/persistence/BillManageImpl.java
index 7ef870c2d..07727abc7 100644
--- a/mhd_bms/src/main/java/com/mhd/bms/domain/billManage/repository/persistence/BillManageImpl.java
+++ b/mhd_bms/src/main/java/com/mhd/bms/domain/billManage/repository/persistence/BillManageImpl.java
@@ -198,6 +198,8 @@ public class BillManageImpl extends ServiceImpl<BillManageMapper, BillManage> im
                     if (ncUrl!=null&&ncUrl!="") {
                         url = ncUrl;
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        billManageMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
                     String salesmanId = reconciliation.getSalesmanId();
@@ -403,6 +405,8 @@ public class BillManageImpl extends ServiceImpl<BillManageMapper, BillManage> im
                         billManageMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        billManageMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -412,8 +416,13 @@ public class BillManageImpl extends ServiceImpl<BillManageMapper, BillManage> im
                         }
                     }
                 }
+            } else {
+                reconciliation.setSynchronousStatus(2);
+                billManageMapper.updateById(reconciliation);
             }
         } catch (JAXBException e) {
+            reconciliation.setSynchronousStatus(2);
+            billManageMapper.updateById(reconciliation);
             e.printStackTrace();
         }
         return true;
@@ -469,6 +478,8 @@ public class BillManageImpl extends ServiceImpl<BillManageMapper, BillManage> im
                     if (ncUrl!=null&&ncUrl!="") {
                         url = ncUrl;
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        billManageMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
                     List<BmsMakeOutInvoiceItem> bmsMakeOutInvoiceItems = bmsMakeOutInvoiceItemMapper.selectList(new LambdaQueryWrapper<BmsMakeOutInvoiceItem>().eq(BmsMakeOutInvoiceItem::getMakeId, make.getId()));
@@ -674,6 +685,8 @@ public class BillManageImpl extends ServiceImpl<BillManageMapper, BillManage> im
                         billManageMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        billManageMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -684,8 +697,13 @@ public class BillManageImpl extends ServiceImpl<BillManageMapper, BillManage> im
                     }
 
                 }
+            } else {
+                reconciliation.setSynchronousStatus(2);
+                billManageMapper.updateById(reconciliation);
             }
         } catch (JAXBException e) {
+            reconciliation.setSynchronousStatus(2);
+            billManageMapper.updateById(reconciliation);
             e.printStackTrace();
         }
         return true;
diff --git a/mhd_finance/src/main/java/com/linke/finance/domain/reconciliation/repository/persistence/ReconciliationImpl.java b/mhd_finance/src/main/java/com/linke/finance/domain/reconciliation/repository/persistence/ReconciliationImpl.java
index ad4bd7ba4..250bc2904 100644
--- a/mhd_finance/src/main/java/com/linke/finance/domain/reconciliation/repository/persistence/ReconciliationImpl.java
+++ b/mhd_finance/src/main/java/com/linke/finance/domain/reconciliation/repository/persistence/ReconciliationImpl.java
@@ -444,6 +444,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         if (urlList != null && urlList.size() > 0) {
                             url = urlList.get(0).getInterfaceTypeValue();
                         } else {
+                            reconciliation.setSynchronousStatus(2);
+                            reconciliationMapper.updateById(reconciliation);
                             throw new ServiceException("未找到该组织的推送地址!");
                         }
                         String invoiceNumber="";
@@ -625,6 +627,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                                 reconciliationMapper.updateById(reconciliation);
                                 response.close();
                             } catch (Exception e) {
+                                reconciliation.setSynchronousStatus(2);
+                                reconciliationMapper.updateById(reconciliation);
                                 e.printStackTrace();
                             } finally {
                                 try {
@@ -634,6 +638,9 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                                 }
                             }
                         }
+                    } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                     }
                 }//else if(reconciliation.getOrganizationName().contains("通宇")){
                 else if(reconciliation.getOrganizationId()==2830){//通宇
@@ -677,6 +684,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         order = result.getData()!=null && result.getData().size()>0?result.getData().get(0):null;
                     }
                     if (order==null){
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到对应订单信息");
                     }
                     String url = "";
@@ -688,6 +697,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                     if (urlList != null && urlList.size() > 0) {
                         url = urlList.get(0).getInterfaceTypeValue();
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
 
@@ -771,6 +782,9 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                                 ysitemList.add(item);
                             }
                         }
+                    } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                     }
 
                     Ysbodys bodys=new Ysbodys();
@@ -885,6 +899,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         reconciliationMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -896,6 +912,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                 }
             }
         } catch (JAXBException e) {
+            reconciliation.setSynchronousStatus(2);
+            reconciliationMapper.updateById(reconciliation);
             e.printStackTrace();
         }
         return true;
@@ -929,6 +947,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         order = result.getData()!=null && result.getData().size()>0?result.getData().get(0):null;
                     }
                     if (order==null){
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到对应订单信息");
                     }
                     String url = "";
@@ -940,6 +960,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                     if (urlList != null && urlList.size() > 0) {
                         url = urlList.get(0).getInterfaceTypeValue();
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
 
@@ -1023,6 +1045,9 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                                 ysitemList.add(item);
                             }
                         }
+                    } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                     }
 
                     Ysbodys bodys=new Ysbodys();
@@ -1137,6 +1162,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         reconciliationMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -1148,6 +1175,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                 }
             }
         } catch (JAXBException e) {
+            reconciliation.setSynchronousStatus(2);
+            reconciliationMapper.updateById(reconciliation);
             e.printStackTrace();
         }
         return true;
@@ -1195,6 +1224,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                     if (urlList != null && urlList.size() > 0) {
                         url = urlList.get(0).getInterfaceTypeValue();
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
                     if(result.getCode()==200){
@@ -1230,7 +1261,13 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                             }*/
 
                             }
+                        } else {
+                            reconciliation.setSynchronousStatus(2);
+                            reconciliationMapper.updateById(reconciliation);
                         }
+                    } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                     }
                     SKbodys bodys=new SKbodys();
                     bodys.setItem(ysitemList);
@@ -1343,6 +1380,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         reconciliationMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -1393,6 +1432,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         order = result.getData()!=null && result.getData().size()>0?result.getData().get(0):null;
                     }
                     if (order==null){
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到对应订单信息");
                     }
                     String url = "";
@@ -1404,6 +1445,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                     if (urlList != null && urlList.size() > 0) {
                         url = urlList.get(0).getInterfaceTypeValue();
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
                     R<List<TmsMakeOutInvoiceItem>> itemR = wlhyServiceFeign.selectMakeOutInvoiceItemList(make);
@@ -1488,6 +1531,9 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                             item.setMoney_bal(String.valueOf(totalInvoiceValue));
                             ysitemList.add(item);
                         }
+                    } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                     }
                     SKbodys bodys=new SKbodys();
                     bodys.setItem(ysitemList);
@@ -1600,6 +1646,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         reconciliationMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -1612,6 +1660,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                 }
             }
         } catch (JAXBException e) {
+            reconciliation.setSynchronousStatus(2);
+            reconciliationMapper.updateById(reconciliation);
             e.printStackTrace();
         }
         return true;
@@ -1645,6 +1695,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         order = result.getData()!=null && result.getData().size()>0?result.getData().get(0):null;
                     }
                     if (order==null){
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到对应订单信息");
                     }
                     String url = "";
@@ -1656,6 +1708,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                     if (urlList != null && urlList.size() > 0) {
                         url = urlList.get(0).getInterfaceTypeValue();
                     } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         throw new ServiceException("未找到该组织的推送地址!");
                     }
                     R<List<TmsMakeOutInvoiceItem>> itemR = wlhyServiceFeign.selectMakeOutInvoiceItemList(make);
@@ -1739,7 +1793,13 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                             item.setMoney_cr(String.valueOf(totalInvoiceValue));
                             item.setMoney_bal(String.valueOf(totalInvoiceValue));
                             ysitemList.add(item);
+                        } else {
+                            reconciliation.setSynchronousStatus(2);
+                            reconciliationMapper.updateById(reconciliation);
                         }
+                    } else {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                     }
                     SKbodys bodys=new SKbodys();
                     bodys.setItem(ysitemList);
@@ -1852,6 +1912,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                         reconciliationMapper.updateById(reconciliation);
                         response.close();
                     } catch (Exception e) {
+                        reconciliation.setSynchronousStatus(2);
+                        reconciliationMapper.updateById(reconciliation);
                         e.printStackTrace();
                     } finally {
                         try {
@@ -1864,6 +1926,8 @@ public class ReconciliationImpl extends ServiceImpl<ReconciliationMapper, Reconc
                 }
             }
         } catch (JAXBException e) {
+            reconciliation.setSynchronousStatus(2);
+            reconciliationMapper.updateById(reconciliation);
             e.printStackTrace();
         }
         return true;
diff --git a/sql/wkx.sql b/sql/wkx.sql
index f1a21d417..15a2e6c17 100644
--- a/sql/wkx.sql
+++ b/sql/wkx.sql
@@ -4,4 +4,8 @@ COMMENT ON COLUMN "NGWL_TEST_BMS"."NC_LOG"."SEND_TIME" IS '推送时间';
 
 ALTER TABLE "NGWL_TEST_FINANCE"."NC_LOG" ADD COLUMN "SEND_TIME" DATE;
 
-COMMENT ON COLUMN "NGWL_TEST_FINANCE"."NC_LOG"."SEND_TIME" IS '推送时间';
\ No newline at end of file
+COMMENT ON COLUMN "NGWL_TEST_FINANCE"."NC_LOG"."SEND_TIME" IS '推送时间';
+
+ALTER TABLE "NGWL_TEST_PRODUCT"."SYS_ORGANIZATION" ADD COLUMN "NC_CODE" VARCHAR2(128);
+
+COMMENT ON COLUMN "NGWL_TEST_PRODUCT"."SYS_ORGANIZATION"."NC_CODE" IS 'nc编码';
\ No newline at end of file