diff options
| author | default <default@DESKTOP-7FEGRP2> | 2018-11-09 16:14:54 +0800 |
|---|---|---|
| committer | default <default@DESKTOP-7FEGRP2> | 2018-11-09 16:14:54 +0800 |
| commit | 8e46841e918cabd2afe6bce114a0444cb8fcd026 (patch) | |
| tree | 15c00d26dc5b503b19489f7802189424d5cd0b79 | |
| parent | 0a5c6f53b7710a76d0ff1ed70a6387d5c557b8ee (diff) | |
update
| -rw-r--r-- | nms_sync/src/com/nms/interceptor/SyncMissionResultStatisticalInterceptor.java | 70 |
1 files changed, 34 insertions, 36 deletions
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) {
|