Procházet zdrojové kódy

河南郸城调度计划 定时任务逻辑修改,方案库代码和定时任务部分计算成功数逻辑未提交 下周提

1037015548@qq.com před 11 měsíci
rodič
revize
bea5c8d37e

+ 5 - 2
src/main/java/com/shkpr/service/aimodelpower/bizmgr/WODispatchPlanTmDoBizFun.java

@@ -155,8 +155,9 @@ public class WODispatchPlanTmDoBizFun {
                         jsonParam.put("data",jsonArray);
                         ResponseRes res = ServiceMgrProxy.getInstance().applyTaskServiceApi().postPlanCommand(jsonParam);
                         JSONObject resDataObj = JSONObject.parseObject(res.getResdata().toString());
-                        if (ResponseCode.RESULT_NORMAL.equals(res.getRescode())
-                                &&resDataObj.getJSONArray("data").size()>0
+                        System.out.println("0".equals(resDataObj.getJSONArray("data").getJSONObject(0).getString("code")));
+                        if (ResponseCode.RESULT_NORMAL.toStrCode().equals(res.getRescode())
+                                &&!resDataObj.getJSONArray("data").isEmpty()
                                 &&"0".equals(resDataObj.getJSONArray("data").getJSONObject(0).getString("code"))) {
                             //TODO 再计算下一次的时间,并且更新至调度计划的数据库
                             Map<String, Object> upPlanUpWhere = new HashMap<>();//修改计划的条件
@@ -180,6 +181,8 @@ public class WODispatchPlanTmDoBizFun {
                             } else {
                                 upPlan.put("next_take_time", returnNextTakeTime(nextTimeModel));
                             }
+                            //TODO 计算成功数
+
                             upPlan.put("last_take_time",resDataObj.getJSONArray("data").getJSONObject(0).getLong("okTime"));
                             getThisDBService().updateWiths(upPlan, upPlanUpWhere);
 

+ 14 - 1
src/main/java/com/shkpr/service/aimodelpower/dbdao/services/WODispatchPlanDBServiceImpl.java

@@ -181,7 +181,20 @@ public class WODispatchPlanDBServiceImpl implements WODispatchPlanDBService,WODi
 
     @Override
     public int updateWiths(Map<String, Object> datas, Map<String, Object> andWheres) {
-        return 0;
+        int nCode = 0;
+        String strMsg = "Success";
+        try {
+            return woDispatchPlanMapper.updateWiths(datas, andWheres, null, "");
+        }catch (Exception e){
+            nCode = LogLevelFlag.LOG_ERROR.ordinal();
+            strMsg = e.getLocalizedMessage();
+            return -1;
+        }finally {
+            LogPrintMgr.getInstance().printLogMsg(LogLevelFlag.valueFromInt(nCode)
+                    , mBusinessType
+                    , mStrClassName
+                    , String.format("Update %s to database, code:{%d} msg:{%s} ...", logTag, nCode, strMsg));
+        }
     }
 
     @Override