From 67cbfd8f7c2ed9598eef92470313f3cf31028ea1 Mon Sep 17 00:00:00 2001
From: 严智鑫 <test>
Date: 星期二, 11 三月 2025 08:39:33 +0800
Subject: [PATCH] 2.13-3-7号  现场标注线调试更改

---
 JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/md/service/impl/TaskingServiceImpl.java |  110 +++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 98 insertions(+), 12 deletions(-)

diff --git a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/md/service/impl/TaskingServiceImpl.java b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/md/service/impl/TaskingServiceImpl.java
index c07ef4a..68cd9ce 100644
--- a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/md/service/impl/TaskingServiceImpl.java
+++ b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/md/service/impl/TaskingServiceImpl.java
@@ -7,6 +7,7 @@
 import com.mes.md.entity.*;
 import com.mes.md.mapper.*;
 import com.mes.md.service.*;
+import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -45,6 +46,9 @@
     private MachineMapper machineMapper;
     @Autowired
     private LineConfigurationService lineConfigurationService;
+
+    @Autowired
+    KBBTLensSortingMapper kBBTLensSortingMapper;
 
     /**
      * @param machine
@@ -169,6 +173,10 @@
         List<Tasking> list=this.findMachineWorkStateTask(machine,"绛夊緟");
         if(!list.isEmpty()){
             Tasking tasking=list.get(0);
+            LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(tasking.getLineConfigurationId());
+            tasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+            tasking.setOperationRecordTime(new Date());
+            tasking.setOperationMode("寮�濮�");
             tasking.setWorkState("姝e湪宸ヤ綔");
             if(baseMapper.updateById(tasking)>0){
                 return tasking;
@@ -183,10 +191,24 @@
      */
     @Override
     public Tasking startMachineTask(Machine machine, String scan_id) {
-        List<Tasking> list=this.findMachineWorkStateTask(machine,"绛夊緟");
+        //List<Tasking> list=this.findMachineWorkStateTask(machine,"绛夊緟");
+        List<Tasking> list=baseMapper.selectJoinList(Tasking.class,new MPJLambdaWrapper<Tasking>()
+                .selectAll(Tasking.class)
+                .innerJoin(LineConfiguration.class,LineConfiguration::getId,Tasking::getLineConfigurationId)
+                .innerJoin(Machine.class,Machine::getId,LineConfiguration::getMachineId)
+                .eq(LineConfiguration::getMachineId,machine.getId())
+                .eq(Tasking::getGlassState,"姝e父")
+                .eq(Tasking::getState,"绾夸笂")
+                .eq(Tasking::getScanId,scan_id)
+                .eq(Tasking::getWorkState,"绛夊緟")
+                .orderByAsc(Tasking::getTaskSequence));
         if(!list.isEmpty()){
             Tasking tasking=list.get(0);
             if(scan_id.equals(tasking.getScanId())){
+                LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(tasking.getLineConfigurationId());
+                tasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+                tasking.setOperationRecordTime(new Date());
+                tasking.setOperationMode("寮�濮�");
                 tasking.setWorkState("姝e湪宸ヤ綔");
                 if(baseMapper.updateById(tasking)>0){
                     return tasking;
@@ -216,6 +238,7 @@
                     .eq(Tasking::getScanId,scan_id)
                     .eq(Tasking::getGlassState,"姝e父")
                     .eq(Tasking::getState,"绾夸笂")
+                    .ne(Tasking::getWorkState,"瀹屽伐")
                     .le(LineConfiguration::getProcessSequence,machineLineConfiguration.get(0).getProcessSequence())
                     .orderByAsc(Tasking::getTaskSequence));
             if(!list.isEmpty()){
@@ -229,8 +252,14 @@
                 machine.setTodayCount(taskSequence);
                 machineMapper.updateById(machine);
                 tasking.setTaskSequence(taskSequence);
+
                 tasking.setWorkState("姝e湪宸ヤ綔");
                 tasking.setLineConfigurationId(machineLineConfiguration.get(0).getId());
+                //璁板綍璁惧寮�濮嬫椂闂�
+                tasking.setOperationRecord(machineLineConfiguration.get(0).getRemark()+machineLineConfiguration.get(0).getLineId());
+                tasking.setOperationRecordTime(new Date());
+                tasking.setOperationMode("寮�濮�");
+
                 if(baseMapper.updateById(tasking)>0){
                     finishMachineTask(machine);
                     return tasking;
@@ -273,6 +302,10 @@
             if(!list.isEmpty()){
                 Tasking tasking=list.get(0);
                 if (!listLineConfiguration.isEmpty()){
+                    LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(tasking.getLineConfigurationId());
+                    tasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+                    tasking.setOperationRecordTime(new Date());
+                    tasking.setOperationMode("缁撴潫");
                     tasking.setLineConfigurationId(listLineConfiguration.get(0).getId());
                     tasking.setWorkState("绛夊緟");
                     return baseMapper.updateById(tasking);
@@ -293,11 +326,12 @@
     @Override
     public int finishMachineTask(Machine machine) {
         List<Tasking> list=this.findMachineWorkStateTask(machine,"姝e湪宸ヤ綔");
-        //褰撳墠璁惧鐨勭嚎璺厤缃�
+        //鏌ヨ褰撳墠璁惧绾胯矾閰嶇疆
         List<LineConfiguration> machineLineConfiguration=lineConfigurationMapper.selectJoinList(LineConfiguration.class,new MPJLambdaWrapper<LineConfiguration>()
                 .selectAll(LineConfiguration.class)
                 .eq(LineConfiguration::getMachineId,machine.getId()));
         if(!machineLineConfiguration.isEmpty()){
+            //褰撳墠璁惧瀛樺湪绾胯矾閰嶇疆锛屾煡璇㈠綋鍓嶈澶� 鍦ㄧ嚎璺厤缃〃涓殑涓嬩竴璁惧
             List<LineConfiguration> listLineConfiguration=lineConfigurationMapper.selectJoinList(LineConfiguration.class,new MPJLambdaWrapper<LineConfiguration>()
                     .selectAll(LineConfiguration.class)
                     .eq(LineConfiguration::getLineId,machineLineConfiguration.get(0).getLineId())
@@ -306,14 +340,24 @@
                     .orderByAsc(LineConfiguration::getProcessSequence)
                     .orderByAsc(LineConfiguration::getPrioritySequence)
             );
+
             if(!list.isEmpty()){
+                //鏍囪浠诲姟鐘舵��
                 Tasking tasking=list.get(0);
+                LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(tasking.getLineConfigurationId());
+                tasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+                tasking.setOperationRecordTime(new Date());
+                tasking.setOperationMode("缁撴潫");
+                //listLineConfiguration涓嶆槸绌�,琛ㄧず褰撳墠璁惧閰嶇疆鍏崇郴涓湁涓嬩竴璁惧
+                // 鍚﹀垯琛ㄧず鏃犱笅涓�宸ュ簭锛屽嵆褰撳墠宸ュ簭涓烘渶鍚庝竴宸ュ簭 鏍囪鐘舵�佸畬宸�
                 if (!listLineConfiguration.isEmpty()){
                     tasking.setLineConfigurationId(listLineConfiguration.get(0).getId());
                     tasking.setWorkState("绛夊緟");
                     return baseMapper.updateById(tasking);
-                }else{
-                    return this.stopTasking(tasking);
+                }
+                else{
+                    tasking.setWorkState("瀹屽伐");
+                    return baseMapper.updateById(tasking);
                 }
 
             }
@@ -338,6 +382,10 @@
                 .orderByDesc(Tasking::getTaskSequence));
         if(!list.isEmpty()){
             Tasking tasking=list.get(0);
+            LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(tasking.getLineConfigurationId());
+            tasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+            tasking.setOperationRecordTime(new Date());
+            tasking.setOperationMode("浜哄伐");
             tasking.setWorkState("绛夊緟");
             return baseMapper.updateById(tasking);
         }
@@ -356,6 +404,10 @@
                 .orderByDesc(Tasking::getTaskSequence));
         if(!list.isEmpty()){
             Tasking tasking=list.get(0);
+            LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(tasking.getLineConfigurationId());
+            tasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+            tasking.setOperationRecordTime(new Date());
+            tasking.setOperationMode("鑷姩");
             tasking.setState("绾夸笅");
             return baseMapper.updateById(tasking);
         }
@@ -370,6 +422,10 @@
     public int damagedTask(Tasking tasking) {
         Tasking oldTasking=baseMapper.selectById(tasking);
         if(!Objects.isNull(oldTasking)){
+            LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(oldTasking.getLineConfigurationId());
+            oldTasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+            oldTasking.setOperationRecordTime(new Date());
+            oldTasking.setOperationMode("浜哄伐");
             oldTasking.setGlassState("鐮存崯");
             return baseMapper.updateById(oldTasking);
         }
@@ -384,6 +440,10 @@
     public int glassDownLine(Tasking tasking) {
         Tasking oldTasking=baseMapper.selectById(tasking);
         if (!Objects.isNull(oldTasking)){
+            LineConfiguration thisLineConfiguration=lineConfigurationMapper.selectById(oldTasking.getLineConfigurationId());
+            oldTasking.setOperationRecord(thisLineConfiguration.getRemark()+thisLineConfiguration.getLineId());
+            oldTasking.setOperationRecordTime(new Date());
+            oldTasking.setOperationMode("浜哄伐");
             oldTasking.setState("绾夸笅");
             return baseMapper.updateById(oldTasking);
         }
@@ -449,14 +509,29 @@
         if(!Objects.isNull(scanId)){
             List<PrimitiveTask> primitiveTaskList=primitiveTaskMapper.selectList(new QueryWrapper<PrimitiveTask>().lambda()
                     .eq(PrimitiveTask::getScanId,scanId));
+            if(primitiveTaskList.isEmpty()){
+                int insertCount=projectService.insertProjectCustomization(scanId);
+                errorStr="鎵爜ID锛�"+scanId+" 涔濈墽IT鏁版嵁搴撴湭涓嬪彂";
+                if (insertCount<1&&!errorStr.equals(machine.getRemark())){
+                    machine.setRemark(errorStr);
+                    machineMapper.updateById(machine);
+                    return 0;
+                }
+            }
+            primitiveTaskList=primitiveTaskMapper.selectList(new QueryWrapper<PrimitiveTask>().lambda()
+                    .eq(PrimitiveTask::getScanId,scanId));
+
             if(!primitiveTaskList.isEmpty()){
                 PrimitiveTask primitiveTask=primitiveTaskList.get(0);
                 LineConfiguration lineConfiguration=lineConfigurationService.machineLineConfiguration(machine);
                 List<Tasking> listTasking=baseMapper.selectList(new QueryWrapper<Tasking>().lambda()
                         .eq(Tasking::getScanId,scanId)
+                        .ne(Tasking::getLineConfigurationId,113)
+                        .ne(Tasking::getWorkState,"瀹屽伐")
                         .ne(Tasking::getState,"绾夸笅")
                         .ne(Tasking::getGlassState,"鐮存崯"));
-                if(listTasking.size()<primitiveTaskList.get(0).getTaskQuantity()){
+                Machine oneMachine=machineMapper.selectById(1L);
+                if((listTasking.size()<primitiveTaskList.get(0).getTaskQuantity())||oneMachine.getMode()==3){
                     Tasking tasking=primitiveTaskService.convertListTasking(primitiveTask,lineConfiguration.getId());
                     Integer taskSequence=1;
                     if (machine.getTodayCount()>0&&machine.getTodayCount()<5000){
@@ -465,6 +540,22 @@
                         taskSequence=1;
                     }
                     machine.setTodayCount(taskSequence);
+                    String Warehouse="";
+                    if (machine.getId()==24){
+                        List<KBBTLensSorting> list=kBBTLensSortingMapper.selectList(new QueryWrapper<KBBTLensSorting>().lambda()
+                                .eq(KBBTLensSorting::getBarcode,scanId)
+                                .notLike(KBBTLensSorting::getProductionName,"闃茬鑶�")
+                                .notLike(KBBTLensSorting::getProductionName,"纾ㄧ爞")
+                                .notLike(KBBTLensSorting::getProductionName,"鍊掕"));
+                        if (list.size()>0){
+                            Warehouse=list.get(0).getWarehouse();
+                        }
+                    }
+                    tasking.setWarehouse(Warehouse);
+                    tasking.setOperationRecord(lineConfiguration.getRemark()+lineConfiguration.getLineId());
+                    tasking.setOperationRecordTime(new Date());
+                    tasking.setOperationMode("鎻掑叆鏁版嵁");
+
                     tasking.setTaskSequence(taskSequence);
                     machineMapper.updateById(machine);
                     return baseMapper.insert(tasking);
@@ -474,19 +565,14 @@
                     machine.setRemark(errorStr);
                     machineMapper.updateById(machine);
                 }
-            }else{
-                int insertCount=projectService.insertProjectCustomization(scanId);
-                errorStr="鎵爜ID锛�"+scanId+" 涔濈墽IT鏁版嵁搴撴湭涓嬪彂";
-                if (insertCount<1&&!errorStr.equals(machine.getRemark())){
-                    machine.setRemark(errorStr);
-                    machineMapper.updateById(machine);
-                }
             }
 
         }
         return 0;
     }
 
+
+
     @Override
     public Boolean insertTasking(String status) {
         Tasking tasking = new Tasking();

--
Gitblit v1.8.0