| | |
| | | @Slf4j |
| | | public class RunningOverallEquipmentEfficiencyJob implements Job { |
| | | |
| | | /** |
| | | * 若参数变量名修改 QuartzJobController中也需对应修改 时间: yyyyMMdd 例: 20230414 |
| | | */ |
| | | private String parameter; |
| | | |
| | | public void setParameter(String parameter) { |
| | | this.parameter = parameter; |
| | | } |
| | | |
| | | @Resource |
| | | private IQuartzJobService quartzJobService; |
| | | |
| | |
| | | if (byJobClassName != null && !byJobClassName.isEmpty()) { |
| | | quartzLog.setJobId(byJobClassName.get(0).getId()); |
| | | } |
| | | log.info("定时计算设备综合效率OEE任务 RunningOverallEquipmentEfficiencyJob start! 时间:" + DateUtils.now()); |
| | | quartzLog.setParams(this.parameter); |
| | | log.info("定时计算设备综合效率OEE任务 RunningOverallEquipmentEfficiencyJob start! 时间:" + DateUtils.now(), this.parameter); |
| | | long startTime = System.currentTimeMillis(); |
| | | try { |
| | | mdcOverallEquipmentEfficiencyService.runningOverallEquipmentEfficiency(); |
| | | mdcOverallEquipmentEfficiencyService.runningOverallEquipmentEfficiency(this.parameter); |
| | | quartzLog.setIsSuccess(0); |
| | | } catch (Exception e) { |
| | | quartzLog.setIsSuccess(-1); |
| | | quartzLog.setExceptionDetail(ThrowableUtil.getStackTrace(e)); |
| | | // 发送消息通知 |
| | | sysAnnouncementService.jobSendMessage("定时统计段时间任务", quartzLog.getExceptionDetail()); |
| | | sysAnnouncementService.jobSendMessage("定时计算设备综合效率OEE任务", quartzLog.getExceptionDetail()); |
| | | } |
| | | long endTime = System.currentTimeMillis(); |
| | | quartzLog.setExecutionTime(Integer.parseInt(String.valueOf(endTime - startTime))); |