erp上传记录优化

src/custom/beans/uploaderpdata/SQL/erp上传日志更新.sql

@@ -0,0 +1,10 @@
+update sys_erpupdatelog
+  set
+  erpbillno=$erpbillno$,
+  response=$response$,
+  request=$request$,
+  errmsg=$errmsg$,
+  status=$status$
+where ownerid=$ownerid$ and ownertable=$ownertable$ and type =$type$ and siteid=$siteid$
+
+     

src/custom/service/AftersalesmagAutoRecheckService.java

@@ -49,8 +49,16 @@ public class AftersalesmagAutoRecheckService extends ServiceController {
 
             JSONObject resultobject = JSONObject.parseObject(result);
             try {
-                SQLFactory sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志新增");
-                sqlFactory.addParameter("sys_erpupdatelogid", createTableID("sys_erpupdatelog"));
+                Rows erpupdatelogRows = dbConnect.runSqlQuery(
+                        "select * from sys_erpupdatelog where ownertable='sa_aftersalesmag' and type='复核erp退/换货单' and ownerid=" + sa_aftersalesmagid);
+                SQLFactory sqlFactory;
+                if (!rows.isEmpty()) {
+                    sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志更新");
+                    sqlFactory.addParameter("sys_erpupdatelogid", erpupdatelogRows.get(0).getLong("sys_erpupdatelogid"));
+                } else {
+                    sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志新增");
+                    sqlFactory.addParameter("sys_erpupdatelogid", createTableID("sys_erpupdatelog"));
+                }
                 sqlFactory.addParameter("siteid", "ZZYOS");
                 sqlFactory.addParameter("userid", 1);
                 sqlFactory.addParameter("username","admin");

src/custom/service/DispatchAutoCloseService.java

@@ -53,8 +53,16 @@ public class DispatchAutoCloseService extends ServiceController {
             JSONObject resultobject = JSONObject.parseObject(result);
 
             try {
-                SQLFactory sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志新增");
-                sqlFactory.addParameter("sys_erpupdatelogid", createTableID("sys_erpupdatelog"));
+                Rows erpupdatelogRows = dbConnect.runSqlQuery(
+                        "select * from sys_erpupdatelog where ownertable='sa_dispatch' and type='关闭发货单' and ownerid=" + sa_dispatchid);
+                SQLFactory sqlFactory;
+                if (!rows.isEmpty()) {
+                    sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志更新");
+                    sqlFactory.addParameter("sys_erpupdatelogid", erpupdatelogRows.get(0).getLong("sys_erpupdatelogid"));
+                } else {
+                    sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志新增");
+                    sqlFactory.addParameter("sys_erpupdatelogid", createTableID("sys_erpupdatelog"));
+                }
                 sqlFactory.addParameter("siteid", "ZZYOS");
                 sqlFactory.addParameter("userid", 1);
                 sqlFactory.addParameter("username","admin");

src/custom/utility/ERPDocking.java

@@ -385,8 +385,16 @@ public class ERPDocking {
                                   JSONObject response,String billno) {
         boolean issuccess = false;
         try {
-            SQLFactory sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志新增");
-            sqlFactory.addParameter("sys_erpupdatelogid", controller.createTableID("sys_erpupdatelog"));
+            Rows rows = controller.dbConnect.runSqlQuery(
+                    "select * from sys_erpupdatelog where ownertable='" + ownertable + "' and ownerid=" + ownerid);
+            SQLFactory sqlFactory;
+            if (!rows.isEmpty()) {
+                sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志更新");
+                sqlFactory.addParameter("sys_erpupdatelogid", rows.get(0).getLong("sys_erpupdatelogid"));
+            } else {
+                sqlFactory = new SQLFactory(new UploadDataToERP_HY(), "erp上传日志新增");
+                sqlFactory.addParameter("sys_erpupdatelogid", controller.createTableID("sys_erpupdatelog"));
+            }
             sqlFactory.addParameter("siteid", controller.siteid);
             sqlFactory.addParameter("userid", controller.userid);
             sqlFactory.addParameter("username", controller.username);