From dc9b3f8cb8f35f18699cab2262d4d03e24635234 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Fri, 24 Sep 2021 13:47:32 +0800 Subject: [PATCH] screen-api 更改获取国控站数据接口,添加参数因子code --- screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java | 31 +++++++++++++++---------------- 1 files changed, 15 insertions(+), 16 deletions(-) diff --git a/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java b/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java index 5ef990c..79bcfe9 100644 --- a/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java +++ b/screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java @@ -37,23 +37,10 @@ historyFiveMinutelyService.insertHistoryFiveMinutely(); } catch (Exception e) { XxlJobHelper.log(e.getMessage()); - return ReturnT.FAIL; + return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); } return ReturnT.SUCCESS; } - - //��������������������������������������� - @XxlJob("insertHistoryHourly") - public ReturnT insertHistoryHourly() { - try { - historyHourlyService.insertHistoryHourly(); - } catch (Exception e) { - XxlJobHelper.log(e.getMessage()); - return ReturnT.FAIL; - } - return ReturnT.SUCCESS; - } - //��������������� @XxlJob("insertHistoryDaily") @@ -74,7 +61,7 @@ historyWeeklyService.insertHistoryWeekly(); } catch (Exception e) { XxlJobHelper.log(e.getMessage()); - return ReturnT.FAIL; + return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); } return ReturnT.SUCCESS; } @@ -86,7 +73,19 @@ historyMonthlyService.insertHistoryMonthly(); } catch (Exception e) { XxlJobHelper.log(e.getMessage()); - return ReturnT.FAIL; + return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); + } + return ReturnT.SUCCESS; + } + + //������������������������ + @XxlJob("historyHourlySupplement") + public ReturnT historyHourlySupplement() { + try { + historyHourlyService.insertHistoryHourly(); + } catch (Exception e) { + XxlJobHelper.log(e.getMessage()); + return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); } return ReturnT.SUCCESS; } -- Gitblit v1.8.0