Browse Source

农行银企直连查询日志输出调整

shenjingwei 4 months ago
parent
commit
f79d60decb
1 changed files with 6 additions and 8 deletions
  1. 6 8
      src/custom/service/AutoQueryBoclnfosForNH.java

+ 6 - 8
src/custom/service/AutoQueryBoclnfosForNH.java

@@ -21,22 +21,21 @@ public class AutoQueryBoclnfosForNH extends ServiceController {
         if (HOUR_OF_DAY <= 6) {
             return;
         }
+        logger.info("开始进行农行银企直连流水查询");
         String StartDate = "";
         String StartTime = "";
         String EndDate = "";
         String siteid = "MD";
         Rows rows = dbConnect.runSqlQuery("select tranflow from sa_bankstatement where siteid='" + siteid + "' and banktype='农行' order by tranflow desc");
         if (rows.isEmpty()) {
-            StartDate = new SimpleDateFormat("yyyyMMdd").format(Calendar
-                    .getInstance().getTime());
+            StartDate = new SimpleDateFormat("yyyyMMdd").format(Calendar.getInstance().getTime());
             EndDate = StartDate;
             StartTime = "0";
         } else {
             String tranflow = rows.get(0).getString("tranflow");
             StartTime = tranflow;
             StartDate = tranflow.substring(0, 8);
-            EndDate = new SimpleDateFormat("yyyyMMdd").format(Calendar
-                    .getInstance().getTime());
+            EndDate = new SimpleDateFormat("yyyyMMdd").format(Calendar.getInstance().getTime());
         }
 
         JSONObject object = new JSONObject();
@@ -52,13 +51,11 @@ public class AutoQueryBoclnfosForNH extends ServiceController {
 //			content.put("EndDate", "20211203");
 
         object.put("content", content);
-
+        logger.info("查询范围从{} {} 到{}", StartDate, StartTime, EndDate);
         String data = new qyzl().query(object.toString());
-        System.err.println("object:"+object.toString());
-        System.err.println("data:"+data);
         JSONArray jsonArray = JSONArray.parseArray(data);
-        System.err.println("jsonArray:"+jsonArray.toJSONString());
         if (!(jsonArray == null || jsonArray.isEmpty())) {
+            logger.info("查询到{}条流水信息", jsonArray.size());
             JSONObject jsonObject = CreateBankstatement.createBankstatement(this, jsonArray, siteid);
             dbConnect.runSqlUpdate((ArrayList<String>) jsonObject.get("sqlList"));
 //            ArrayList<Long> idList = (ArrayList<Long>) jsonObject.get("idList");
@@ -69,6 +66,7 @@ public class AutoQueryBoclnfosForNH extends ServiceController {
 //                }
 //            }
         }
+        logger.info("结束进行农行银企直连流水查询");
     }
 
 }