| | |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.zy.acs.framework.common.Cools; |
| | | import com.zy.acs.manager.core.utils.HttpHandler; |
| | | import com.zy.acs.manager.manager.entity.TaskReport; |
| | | import com.zy.acs.manager.manager.entity.TaskReportLog; |
| | |
| | | private ConfigService configService; |
| | | |
| | | |
| | | @Scheduled(fixedDelay = 1000) |
| | | @Scheduled(fixedDelay = 3000) |
| | | public void execute() { |
| | | Boolean report = configService.getVal("REPORT", Boolean.class, false); |
| | | if (report) { |
| | |
| | | Integer times = configService.getVal("REPORT_TIMES", Integer.class, 3); |
| | | List<TaskReport> list = taskReportService.list(); |
| | | for (TaskReport taskReport : list) { |
| | | if (taskReport.getReportTimes() > times) { |
| | | if ((Cools.isEmpty(taskReport.getReportTimes()) ? 0 : taskReport.getReportTimes()) > times) { |
| | | toLog(taskReport); |
| | | continue; |
| | | } |
| | | if (report(taskReport, wmsUrl, wmsPath)) { |
| | | toLog(taskReport); |
| | | } else { |
| | | taskReport.setReportTimes(taskReport.getReportTimes() + 1); |
| | | taskReport.setReportTimes((Cools.isEmpty(taskReport.getReportTimes()) ? 0 : taskReport.getReportTimes()) + 1); |
| | | taskReport.setUpdateTime(new Date()); |
| | | taskReportService.updateById(taskReport); |
| | | } |
| | |
| | | .setJson(JSON.toJSONString(taskReport)) |
| | | .build() |
| | | .doPost(); |
| | | log.info("返回参数:{}", response); |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | if (jsonObject.getInteger("code").equals(200)) { |
| | | return true; |