更新马桥商品档案错误修复

src/custom/service/UpdateBasicDataToWms.java

@@ -68,7 +68,10 @@ public class UpdateBasicDataToWms extends ServiceController {
     }
 
     public void getMcode() throws YosException {
-        Rows skuRows = SQLFactory.createQuerySQL(dbConnect, "sa_itemsku", "itemno", "sku").setWhere("siteid", "MD").setWhere("wmsuploadflag<2").query();
+        QuerySQL skuQuery = SQLFactory.createQuerySQL(dbConnect, "sa_itemsku", "sku").setTableAlias("t1");
+        skuQuery.addJoinTable(JOINTYPE.inner, "plm_item", "t2", "itemid=:itemid", "itemno");
+        skuQuery.setWhere("t1.siteid", "MD").setWhere("wmsuploadflag<2");
+        Rows skuRows = skuQuery.query();
         if (skuRows.isNotEmpty()) {
             logger.info("监测到有{}个序列号待更新至wms", skuRows.size());
             ArrayList<String> tqskus = SQLFactory.createQuerySQL(TQWMS, "TMaterialsSerialNo", "SerialNo").setWhere("SerialNo", skuRows.toArrayList("sku")).query().toArrayList("SerialNo");
@@ -96,7 +99,7 @@ public class UpdateBasicDataToWms extends ServiceController {
 
             TQWMS.runSqlUpdate(TQSqlist);
             YUNl_DB.runSqlUpdate(MQSqlist);
-            SQLFactory.createUpdateSQL(dbConnect, "sa_itemsku").setValue("WMSUPLOADFLAG", 2).setWhere("siteid", "MD").setWhere("sku", skuRows.toArrayList("sku")).update();
+            SQLFactory.createUpdateSQL(dbConnect, "sa_itemsku").setValue("wmsuploadflag", 2).setWhere("siteid", "MD").setWhere("sku", skuRows.toArrayList("sku")).update();
         }
     }