【博思达】【定时任务时间点修改测试】

src/main/java/com/uas/eis/task/SyncProductStockTask.java

@@ -36,11 +36,10 @@ public class SyncProductStockTask {
     public void SyncProductStock() {
         SqlRowList rs2 = baseDao.queryForRowSet("select TO_CHAR(SYSDATE,'HH24') v_hour,TO_CHAR(SYSDATE,'MI') v_mi from dual");
         while(rs2.next()) {
-            Object V_HOUR = rs2.getResultList().get(0).get("V_HOUR");
-            Object V_MI = rs2.getResultList().get(0).get("V_MI");
-            if (("02".equals(V_HOUR.toString()) || "15".equals(V_HOUR.toString())
-                    || "16".equals(V_HOUR.toString()) || "20".equals(V_HOUR.toString()))
-                    && ("14".equals(V_MI.toString()) || "16".equals(V_MI.toString()))) {
+            String V_HOUR = rs2.getGeneralString("v_hour");
+            String V_MI = rs2.getGeneralString("v_mi");
+            if (("08".equals(V_HOUR) || "20".equals(V_HOUR) || "17".equals(V_HOUR) || "20".equals(V_HOUR))
+                    && ("00".equals(V_MI) || "03".equals(V_MI))) {
                 X5JsonHttpClient x5JsonHttpClient = new X5JsonHttpClient(configuration.getX5appid(), configuration.getX5appkey(), configuration.getX5ProductStockUrl());
                 Map<String, Object> data = new HashMap<>();
                 SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -52,8 +51,6 @@ public class SyncProductStockTask {
                         "                 (select ct_id from (select ct_id from CUSTOMTABLE where ct_caller='XiaoMiProduct' and trunc(ct_recorddate)=trunc(sysdate) and ct_statuscode='AUDITED' and nvl(CT_SENDSTATUS,' ')<>'已上传' order by ct_id desc) where rownum=1)" +
                         "                 order by cd_detno) A) where rn<=1000";
                 SqlRowList rs = baseDao.queryForRowSet(Sql);
-                baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
-                        "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'1上传失败！',to_char(sysdate,'yyyy-mm-dd HH24:mi:ss'),''）");
                 while (rs.next()) {
                     Map<String, Object> map = new HashMap<>();
                     map.put("factory_code", configuration.getX5vendercode());
@@ -70,8 +67,6 @@ public class SyncProductStockTask {
                 }
                 data.put("data", list);
                 if (list.size() > 0) {
-                    baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
-                            "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'2上传失败！',to_char(sysdate,'yyyy-mm-dd HH24:mi:ss'),''）");
                     x5JsonHttpClient.post(data, configuration, baseDao, "ProductStock");
                 }
             }

src/main/java/com/uas/eis/task/SyncProductWIPTask.java

@@ -38,11 +38,10 @@ public class SyncProductWIPTask {
     public void SyncProductWIP() {
         SqlRowList rs2 = baseDao.queryForRowSet("select TO_CHAR(SYSDATE,'HH24') v_hour,TO_CHAR(SYSDATE,'MI') v_mi from dual");
         while(rs2.next()){
-            Object V_HOUR = rs2.getResultList().get(0).get("V_HOUR");
-            Object V_MI = rs2.getResultList().get(0).get("V_MI");
-            if(("02".equals(V_HOUR.toString()) || "16".equals(V_HOUR.toString())
-                    || "08".equals(V_HOUR.toString()) || "20".equals(V_HOUR.toString()))
-              && ("10".equals(V_MI.toString()) || "12".equals(V_MI.toString()))){
+            String V_HOUR = rs2.getGeneralString("v_hour");
+            String V_MI = rs2.getGeneralString("v_mi");
+            if(("02".equals(V_HOUR) || "16".equals(V_HOUR) || "08".equals(V_HOUR) || "20".equals(V_HOUR))
+              && ("00".equals(V_MI) || "03".equals(V_MI))){
                 X5JsonHttpClient x5JsonHttpClient = new X5JsonHttpClient(configuration.getX5appid(),configuration.getX5appkey(),configuration.getX5ProductWIPUrl());
                 Map<String,Object> data = new HashMap<>();
                 SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -54,8 +53,7 @@ public class SyncProductWIPTask {
                         " (select ct_id from (select ct_id from CUSTOMTABLE where ct_caller='XiaoMiProductWIP' and trunc(ct_recorddate)=trunc(sysdate) and ct_statuscode='AUDITED' and nvl(CT_SENDSTATUS,' ')<>'已上传' order by ct_id desc) where rownum=1)" +
                         " order by cd_detno) A) where rn<=1000";
                 SqlRowList rs = baseDao.queryForRowSet(Sql);
-                baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
-                        "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'11上传失败！',to_char(sysdate,'yyyy-mm-dd HH24:mi:ss'),''）");
+
                 while (rs.next()){
                     Map<String,Object> map = new HashMap<>();
                     map.put("factory_code",configuration.getX5vendercode());
@@ -72,8 +70,6 @@ public class SyncProductWIPTask {
                 }
                 data.put("data",list);
                 if(list.size()>0){
-                    baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
-                            "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'22上传失败！',to_char(sysdate,'yyyy-mm-dd HH24:mi:ss'),''）");
                     x5JsonHttpClient.post(data, configuration, baseDao, "ProductWIP");
                 }
             }

src/main/java/com/uas/eis/task/httpclient/X5JsonHttpClient.java

@@ -42,8 +42,6 @@ public class X5JsonHttpClient extends X5HttpClient {
         }else if("ProductWIP".equals(type)){
             kind="物料WIP同步";
         }
-        baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
-                "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'3上传失败！',to_char(sysdate,'yyyy-mm-dd HH24:mi:ss'),'"+kind+"'）");
         X5Response<T> x5Response;
         if (X5StringUtils.isEmpty(appid) || X5StringUtils.isEmpty(appkey) || X5StringUtils.isEmpty(url)) {
             throw new X5Exception("1016", "The request at least contains appid appkey and url.");
@@ -68,8 +66,6 @@ public class X5JsonHttpClient extends X5HttpClient {
         String data = X5StringUtils.encodeBase64(JSON.toJSONString(x5Request));
         String encoding = null;
         String account=configuration.getX5username()+":"+configuration.getX5password();
-        baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,ML_RESULT,ML_TYPE)" +
-                "values(XIAOMIDOCKINGLOG_seq.nextval,sysdate,'4上传失败！',to_char(sysdate,'yyyy-mm-dd HH24:mi:ss'),'"+kind+"'）");
         try {
             encoding = DatatypeConverter.printBase64Binary(account.getBytes("UTF-8"));  //username  password 自行修改  中间":"不可少
         } catch (UnsupportedEncodingException e) {