| | |
| | | package com.iailab.module.shasteel.job.task; |
| | | |
| | | import com.iailab.framework.common.util.date.DateUtils; |
| | | import com.iailab.module.model.api.mdk.MdkApi; |
| | | import com.iailab.module.model.api.mdk.dto.MdkPredictReqDTO; |
| | | import com.iailab.module.shasteel.mq.common.constant.RoutingConstant; |
| | |
| | | logger.info(type + "模块预测完成。"); |
| | | Map<String, Object> msg = new HashMap<>(); |
| | | msg.put("moduleType", type); |
| | | msg.put("predictTime", predictTime); |
| | | msg.put("predictTime", DateUtils.format(predictTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)); |
| | | rabbitTemplate.convertAndSend(RoutingConstant.EXCHANGE, RoutingConstant.Iailab_Model_PredictFinish, msg); |
| | | }); |
| | | } catch (Exception ex) { |