diff --git a/nms_sync/src/com/nms/interceptor/SyncMissionResultStatisticalInterceptor.java b/nms_sync/src/com/nms/interceptor/SyncMissionResultStatisticalInterceptor.java index b6a6e7b..a6d74ff 100644 --- a/nms_sync/src/com/nms/interceptor/SyncMissionResultStatisticalInterceptor.java +++ b/nms_sync/src/com/nms/interceptor/SyncMissionResultStatisticalInterceptor.java @@ -186,10 +186,8 @@ public class SyncMissionResultStatisticalInterceptor implements Interceptor{ } Db.update("mission_state_table", missionTableInfo); } - } - - // 修改周期任务的执行状态 - if(null!=loopmissionStateTableInfo) { + + // 修改周期任务的执行状态 Record result = Db.use().findFirst("select lmst.mission_id missionId, t.ok, t.fail, t.total\r\n" + "from (select mrt.mission_id, \r\n" + "ifnull(sum(case mrt.result when 0 then 1 else 0 end), 0) ok, \r\n" + @@ -215,39 +213,39 @@ public class SyncMissionResultStatisticalInterceptor implements Interceptor{ } } - } - if(null!=loopmissionStateTableInfo&&!isInsert) { - missionState = loopmissionStateTableInfo.getInt("mission_state"); - Integer missionTableInfoState = missionTableInfo.getInt("mission_state"); - switch(missionState) { - case(3): - Record findFirst = Db.use().findFirst("select COUNT(*) count from loopmission_state_table where mission_id = ? and mission_state=0",loopmissionStateTableInfo.getLong("mission_id")); - if(findFirst.getInt("count").equals(0)&&missionTableInfoState!=3) { - status=3; - autoDesc=format.format(System.currentTimeMillis())+"i18n_server.UpgradeService.sql.revoke_n81i"; - } - break; - case(4): - if(missionTableInfoState!=4) { - status=4; - autoDesc=format.format(System.currentTimeMillis())+" Task execution failure "; - } - break; - case(6): - if(missionTableInfoState!=6) { - status=6; - autoDesc=format.format(System.currentTimeMillis())+"Task revocation start execute"; - } - break; - case(7): - if(missionTableInfoState!=7) { - status=7; - autoDesc=format.format(System.currentTimeMillis())+"i18n_server.UpgradeService.sql.revoke_n81i"; - } - break; + + if(isInsert) { + missionState = loopmissionStateTableInfo.getInt("mission_state"); + Integer missionTableInfoState = missionTableInfo.getInt("mission_state"); + switch(missionState) { + case(3): + Record findFirst = Db.use().findFirst("select COUNT(*) count from loopmission_state_table where mission_id = ? and mission_state=0",loopmissionStateTableInfo.getLong("mission_id")); + if(findFirst.getInt("count").equals(0)&&missionTableInfoState!=3) { + status=3; + autoDesc=format.format(System.currentTimeMillis())+"i18n_server.UpgradeService.sql.revoke_n81i"; + } + break; + case(4): + if(missionTableInfoState!=4) { + status=4; + autoDesc=format.format(System.currentTimeMillis())+" Task execution failure "; + } + break; + case(6): + if(missionTableInfoState!=6) { + status=6; + autoDesc=format.format(System.currentTimeMillis())+"Task revocation start execute"; + } + break; + case(7): + if(missionTableInfoState!=7) { + status=7; + autoDesc=format.format(System.currentTimeMillis())+"i18n_server.UpgradeService.sql.revoke_n81i"; + } + break; + } } - } - if(null!=loopmissionStateTableInfo) { + Record missionStateTableResult =new Record(); missionStateTableResult.set("mission_id", loopmissionStateTableInfo.get("mission_id")); if(status!=null) {