自动任务日志输出调整

src/custom/common/crm/bean/core/CrmBase.java

@@ -134,7 +134,9 @@ public abstract class CrmBase extends BaseClass {
         for (Row row : rows) {
             list.add(new crm_datasync(title, row.getLong("id"), ownertable, row.getLong("ownerid")));
         }
-        logger.info("监测到有【" + list.size() + "】个【" + title + "】 待同步至CRM");
+        if (!list.isEmpty()) {
+            logger.info("监测到有【" + list.size() + "】个【" + title + "】 待同步至CRM");
+        }
         return list;
     }
 

src/custom/common/crm/bean/customer.java

@@ -16,6 +16,9 @@ public class customer extends CrmBase {
     @Override
     public void autoAction() throws YosException {
         Rows rows = crmDBConnect.runSqlQuery("select t1.id as syncid,t1.ownerid,t2.* from (select max(id) id,ownerid from e_order_sync where ownertable='st_customer' group by ownerid) t1 left join st_customer t2 on t1.ownerid=t2.cid");
+        if (rows.isEmpty()) {
+            return;
+        }
         logger.info(" 监测到有【{}】个【客户档案】 待同步至E-订单", rows.size());
         ArrayList<String> agentnums = rows.toArrayList("fagent_num_created");
         agentnums.addAll(rows.toArrayList("fagent_num"));

src/custom/common/crm/bean/sku_crm.java

@@ -18,6 +18,9 @@ public class sku_crm extends CrmBase {
         JSONObject resultObject = JSONObject.parseObject(result);
         if (resultObject.containsKey("data")) {
             JSONArray dataArray = resultObject.getJSONArray("data");
+            if (dataArray.isEmpty()) {
+                return;
+            }
             logger.info(" 监测到有【{}】个【序列号】 待同步至E-订单", dataArray.size());
 
             for (int i = 0; i < dataArray.size(); i++) {

src/custom/service/GetBasicDataFromU8.java

@@ -54,14 +54,17 @@ public class GetBasicDataFromU8 extends ServiceController {
      * 商品档案
      */
     public void getItem() throws YosException {
-        RowsMap unitMap = SQLFactory.createQuerySQL(dbConnect, "plm_unit", "unitid,unitname").setWhere("siteid", "MD").query().toRowsMap("unitname");
         Rows cInvCodeRows = YUNl_DB.runSqlQuery("select " + "cInvCode," +//--存货编码
                 "cInvName," +//存货名称
                 "cInvStd," +//规格型号
                 "cComUnitName," +//主计量单位名称
                 "isnull(bSerial,0)as bSerial " +//是否序列号管理
                 "from Inventory where status=0 and accid in('666','888')");
+        if (cInvCodeRows.isEmpty()) {
+            return;
+        }
         logger.info("监测到有【{}】个u8商品档案待同步", cInvCodeRows.size());
+        RowsMap unitMap = SQLFactory.createQuerySQL(dbConnect, "plm_unit", "unitid,unitname").setWhere("siteid", "MD").query().toRowsMap("unitname");
 
         ArrayList<String> itemnoList = SQLFactory.createQuerySQL(dbConnect, "plm_item", "itemno").setWhere("siteid", "MD").setWhere("itemno", cInvCodeRows.toArrayList("cInvCode")).query().toArrayList("itemno");
         for (Row cInvCodeRow : cInvCodeRows) {
@@ -111,6 +114,9 @@ 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')");
+        if (codeRows.isEmpty()) {
+            return;
+        }
         logger.info("监测到有【{}】个u8序列号待同步", codeRows.size());
         Rows itemrows = SQLFactory.createQuerySQL(dbConnect, "plm_item", "itemid", "itemno").setWhere("siteid", "MD").setWhere("itemno", codeRows.toArrayList("cInvCode")).query();