ansteel.git - Gitblit

liriming

2025-05-20 72cf3d00cb99e8c0d671bdb47a0ef0ccbc6f2290

模型调用

已修改4个文件

	ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java	21 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java	18 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelHCTask.java	10 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelLJTask.java	10 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java

@@ -98,19 +98,18 @@
            String clock = DateUtils.format(startDate);

            // 调用模型
            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
            dto.setScheduleTime(calendar.getTime());
            dto.setScheduleCode(params);
            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
            Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
//            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
//            dto.setScheduleTime(calendar.getTime());
//            dto.setScheduleCode(params);
//            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
//            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
//
//            Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
//            JSONObject result = new JSONObject(tResult);
//            logger.info("result===" +  JSONObject.toJSONString(result));

            JSONObject jsonObject = new JSONObject(tResult);
            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));
            logger.info("result===" +  JSONObject.toJSONString(result));

//            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
//            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));

            if (Objects.isNull(result)) {
                logger.info("模型结果为空");

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java

@@ -94,15 +94,15 @@
            String clock = DateUtils.format(startDate);

            // 调用模型
/*            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
            dto.setScheduleTime(calendar.getTime());
            dto.setScheduleCode(params);
            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
            Map<String, Object> result = mdkScheduleRespDTO.getResult();

            JSONObject jsonObject = new JSONObject(result);
            JSONObject result2 = (JSONObject) JSON.toJSON(jsonObject.get("result"));*/
//            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
//            dto.setScheduleTime(calendar.getTime());
//            dto.setScheduleCode(params);
//            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
//            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
//
//            Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
//            JSONObject result = new JSONObject(tResult);
//            logger.info("result===" +  JSONObject.toJSONString(result));

            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelHCTask.java

@@ -94,6 +94,16 @@
            String clock = DateUtils.format(startDate);

            // 调用模型
//            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
//            dto.setScheduleTime(calendar.getTime());
//            dto.setScheduleCode(params);
//            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
//            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
//
//            Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
//            JSONObject result = new JSONObject(tResult);
//            logger.info("result===" +  JSONObject.toJSONString(result));

            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));


 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelLJTask.java

@@ -94,6 +94,16 @@
            String clock = DateUtils.format(startDate);

            // 调用模型
//            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
//            dto.setScheduleTime(calendar.getTime());
//            dto.setScheduleCode(params);
//            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
//            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
//
//            Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
//            JSONObject result = new JSONObject(tResult);
//            logger.info("result===" +  JSONObject.toJSONString(result));

            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));

			@@ -98,19 +98,18 @@
			String clock = DateUtils.format(startDate);

			// 调用模型
			MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
			dto.setScheduleTime(calendar.getTime());
			dto.setScheduleCode(params);
			MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
			logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
			Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
			// MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
			// dto.setScheduleTime(calendar.getTime());
			// dto.setScheduleCode(params);
			// MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
			// logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
			//
			// Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
			// JSONObject result = new JSONObject(tResult);
			// logger.info("result===" + JSONObject.toJSONString(result));

			JSONObject jsonObject = new JSONObject(tResult);
			JSONObject jsonObject = JSONObject.parseObject(jsonStr);
			JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));
			logger.info("result===" + JSONObject.toJSONString(result));

			// JSONObject jsonObject = JSONObject.parseObject(jsonStr);
			// JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));

			if (Objects.isNull(result)) {
			logger.info("模型结果为空");

			@@ -94,15 +94,15 @@
			String clock = DateUtils.format(startDate);

			// 调用模型
			/* MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
			dto.setScheduleTime(calendar.getTime());
			dto.setScheduleCode(params);
			MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
			logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
			Map<String, Object> result = mdkScheduleRespDTO.getResult();

			JSONObject jsonObject = new JSONObject(result);
			JSONObject result2 = (JSONObject) JSON.toJSON(jsonObject.get("result"));*/
			// MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
			// dto.setScheduleTime(calendar.getTime());
			// dto.setScheduleCode(params);
			// MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
			// logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
			//
			// Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
			// JSONObject result = new JSONObject(tResult);
			// logger.info("result===" + JSONObject.toJSONString(result));

			JSONObject jsonObject = JSONObject.parseObject(jsonStr);
			JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));

			@@ -94,6 +94,16 @@
			String clock = DateUtils.format(startDate);

			// 调用模型
			// MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
			// dto.setScheduleTime(calendar.getTime());
			// dto.setScheduleCode(params);
			// MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
			// logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
			//
			// Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
			// JSONObject result = new JSONObject(tResult);
			// logger.info("result===" + JSONObject.toJSONString(result));

			JSONObject jsonObject = JSONObject.parseObject(jsonStr);
			JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));