u8基础资料同步优化

src/custom/service/GetBasicDataFromU8.java

@@ -42,6 +42,7 @@ public class GetBasicDataFromU8 extends ServiceController {
                     unitInsert.setWhere("not exists(select * from plm_unit where siteid='MD' and unitname='" + cComUnitName + "')");
                     unitInsert.insert();
                     YUNl_DB.runSqlUpdate("update ComputationUnit set status=1 where cComUnitName='" + cComUnitName + "' and accid in('666','888')");
+                    logger.info("计量单位【{}】同步E-订单成功", cComUnitName);
                 } catch (Exception e) {
                     logger.error("U8计量单位同步DRP失败", row.toJsonObject(), e);
                 }
@@ -60,15 +61,17 @@ public class GetBasicDataFromU8 extends ServiceController {
                 "cComUnitName," +//主计量单位名称
                 "isnull(bSerial,0)as bSerial " +//是否序列号管理
                 "from Inventory where status=0 and accid in('666','888')");
+        logger.info("监测到有【{}】个u8商品档案待同步", cInvCodeRows.size());
 
         ArrayList<String> itemnoList = SQLFactory.createQuerySQL(dbConnect, "plm_item", "itemno").setWhere("siteid", "MD").setWhere("itemno", cInvCodeRows.toArrayList("cInvCode")).query().toArrayList("itemno");
         for (Row cInvCodeRow : cInvCodeRows) {
             try {
+                String cInvCode = cInvCodeRow.getString("cInvCode");
                 String cComUnitName = cInvCodeRow.getString("cComUnitName");
                 if (!unitMap.containsKey(cComUnitName)) {
+                    logger.error("商品{}同步E-订单失败，计量单位【{}】不存在", cInvCode, cComUnitName);
                     continue;//计量单位不存在
                 }
-                String cInvCode = cInvCodeRow.getString("cInvCode");
                 String cInvName = cInvCodeRow.getString("cInvName");
                 String cInvStd = cInvCodeRow.getString("cInvStd");
                 boolean bSerial = cInvCodeRow.getBoolean("bSerial");
@@ -94,6 +97,7 @@ public class GetBasicDataFromU8 extends ServiceController {
                     plmItem.setValue("siteid", "MD");
                     plmItem.insert();
                 }
+                logger.info("商品【{}】同步E-订单成功", cInvCode);
                 YUNl_DB.runSqlUpdate("update Inventory set status=1 where cInvCode='" + cInvCode + "' and accid in('666','888')");
             } catch (Exception e) {
                 logger.error("U8货品档案同步DRP失败", cInvCodeRow.toJsonObject(), e);
@@ -106,6 +110,7 @@ public class GetBasicDataFromU8 extends ServiceController {
      */
     public void getMcode() throws YosException {
         Rows codeRows = YUNl_DB.runSqlQuery("SELECT cInvCode,cInvSN FROM ST_SNState where status=0 and accid in('666','888')");
+        logger.info("监测到有【{}】个u8序列号待同步", codeRows.size());
         Rows itemrows = SQLFactory.createQuerySQL(dbConnect, "plm_item", "itemid", "itemno").setWhere("siteid", "MD").setWhere("itemno", codeRows.toArrayList("cInvCode")).query();
 
         RowsMap itemMap = itemrows.toRowsMap("itemno");
@@ -134,8 +139,10 @@ public class GetBasicDataFromU8 extends ServiceController {
                     sku.setValue("WMSUPLOADFLAG", 2);
                     sku.insert();
                 }
+                logger.info("序列号【{}】同步E-订单成功", cInvSN);
                 YUNl_DB.runSqlUpdate("update ST_SNState set status=1 where cInvCode='" + cInvCode + "' and cInvSN='" + cInvSN + "' and accid in('666','888')");
             } else {
+                logger.error("序列号【{}】同步E-订单失败，商品【{}】不存在", cInvSN, cInvCode);
                 YUNl_DB.runSqlUpdate("update ST_SNState set status=2 where cInvCode='" + cInvCode + "' and cInvSN='" + cInvSN + "' and accid in('666','888')");
             }
         }