yangys
2025-09-18 0d61b9bfca526e9c3da2209de8f9f367e76fd013
blade-service/blade-mdm/src/main/java/org/springblade/mdm/thirdpart/controller/MesController.java
@@ -6,7 +6,9 @@
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.mdm.flow.constants.FlowContants;
import org.springblade.mdm.basesetting.producedivision.entity.QinzheFgb;
import org.springblade.mdm.basesetting.producedivision.service.QinzheFgbService;
import org.springblade.mdm.flow.constants.FlowConstant;
import org.springblade.mdm.flow.entity.TaskDispatch;
import org.springblade.mdm.flow.excution.StartDispatcher;
import org.springblade.mdm.flow.service.TaskDispatchService;
@@ -15,7 +17,6 @@
import org.springblade.mdm.thirdpart.service.MesTaskService;
import org.springblade.mdm.thirdpart.vo.MesTaskFinishVO;
import org.springblade.mdm.thirdpart.vo.MesTaskVO;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -34,6 +35,8 @@
   private StartDispatcher dispatcher;
   @Autowired
   private TaskDispatchService taskDispatchService;
   @Autowired
   private QinzheFgbService qinzheFgbService;
   /**
    * 新增
    */
@@ -41,6 +44,7 @@
   @Operation(summary = "接收MES任务", description = "接收MES任务")
   public R<Void> newTask(@RequestBody MesTaskVO mesTaskVO) {
      try {
         log.info("接收MES任务,参数:{}", mesTaskVO);
         TaskAssignVO startVO = this.toTaskAssignVO(mesTaskVO);
         List<String> errors = checkTaskData(startVO);
@@ -71,7 +75,7 @@
         }
         return R.success();
      }catch (Exception e) {
         log.error("接收mes任务失败", e);;
         log.error("接收mes任务失败", e);
         return R.fail(e.getMessage());
      }
@@ -129,7 +133,11 @@
      taskAssignVO.setMachineCode(mesTaskVO.getEquipmentCode());
      taskAssignVO.setMachineMode(mesTaskVO.getEquipmentModel());
      taskAssignVO.setDispatchBy(mesTaskVO.getDspatchBy());
      if (mesTaskVO.getProductModel() != null) {
         taskAssignVO.setProductModel(mesTaskVO.getProductModel());
      }else{
         taskAssignVO.setProductModel(this.queryProductModel(mesTaskVO.getDrawingCode()));
      }
      try {
         taskAssignVO.setPlanStartTime(DateUtil.fromDate(DateUtil.parse(mesTaskVO.getPlanStartTime(),"yyyy-MM-dd HH:mm:ss")).toLocalDate());
      }catch(Exception e){
@@ -137,8 +145,22 @@
      }
      taskAssignVO.setTitle(taskAssignVO.getDrawingNo()+"-"+taskAssignVO.getProcessNo()+"-"+taskAssignVO.getProcessEdition()+"计划任务");
      taskAssignVO.setIsTempFlow(FlowContants.N);
      taskAssignVO.setIsTempFlow(FlowConstant.N);
      return taskAssignVO;
   }
   /**
    * 查询产品型号
    * @param drawingNo 图号
    * @return 产品型号
    */
   String queryProductModel(String drawingNo){
      QinzheFgb fgb = qinzheFgbService.getByLjh(drawingNo);
      if(fgb!= null){
         return fgb.getCph();
      }else{
         return null;
      }
   }
   @PostMapping("/mes-finish-task")
@@ -155,7 +177,7 @@
         mesTaskService.finishTask(finishTaskVO);
         return R.success();
      }catch(Exception e){
         log.error("接收MES工序完成信息失败", e);;
         log.error("接收MES工序完成信息失败", e);
         return R.fail("内部错误");
      }