#26-03-10-00

zzgtfwq

1 天以前 253f9cb5ab38c88c231de6e84ab962460853e37d

 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java

@@ -5,6 +5,7 @@
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.exception.CoolException;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkDetl;
import com.zy.asrs.entity.WrkLastno;
import com.zy.asrs.entity.WrkMast;
@@ -56,7 +57,8 @@
    
    @Autowired
    private WrkDetlService wrkDetlService;
    
    @Autowired
    private LocMastService locMastService;
    @Autowired
    private SlaveProperties slaveProperties;

@@ -231,10 +233,10 @@
                wrkMast.setWrkSts(11L);
            }
            String locNo = null;
            if(param.getSourceLocNo() != null){
            if (param.getSourceLocNo() != null && !param.getSourceLocNo().isEmpty()) {
                locNo = param.getSourceLocNo();
            }
            if(param.getTargetLocNo() !=null){
            if (param.getTargetLocNo() != null && !param.getTargetLocNo().isEmpty()) {
                locNo = param.getTargetLocNo();
            }
// 取前两位
@@ -255,6 +257,7 @@
            }

            wrkMast.setCrnNo(crnNo);
            wrkMast.setIoTime(new Date());
            wrkMast.setModiTime(new Date());
            wrkMast.setAppeTime(new Date());
            wrkMast.setWrkDate(new Date());
@@ -278,7 +281,19 @@
                    wrkDetlService.insert(wrkDetl);
                }
            }
            
            if(param.getIoType() == 2 || param.getIoType() == 12){
                locMastService.updateLocMast(param.getTargetLocNo(),"S");
            }else if(param.getIoType() == 3){
                locMastService.updateLocMast(param.getSourceLocNo(),"R");
                locMastService.updateLocMast(param.getTargetLocNo(),"S");
            }else if(param.getIoType() == 22 || param.getIoType() == 32){
                locMastService.updateLocMast(param.getTargetLocNo(),"Q");
            }else if(param.getIoType() == 1 || param.getIoType() == 11){
                locMastService.updateLocMast(param.getSourceLocNo(),"R" );
            }else{
                locMastService.updateLocMast(param.getSourceLocNo(),"P" );
            }

            // 4. 下发给PLC
            if(Inbound){
                writeToPlc(wrkMast);
@@ -329,7 +344,12 @@
             // 检查该PLC是否管理该站点
             if (devpThread.getStation().containsKey(sourceStaNo.shortValue())) {
                 StaProtocol staProtocol = devpThread.getStation().get(sourceStaNo.shortValue());
                 if (staProtocol != null && staProtocol.getWorkNo() == 9998) {
                 if (staProtocol == null) {
                     continue;
                 } else {
                     staProtocol = staProtocol.clone();
                 }
                 if (staProtocol != null && staProtocol.getWorkNo() == 9999) {

                     staProtocol.setWorkNo(wrkMast.getWrkNo());
                     if (wrkMast.getStaNo() != null) {
@@ -337,7 +357,7 @@
                     }
                     
                     // 下发PLC指令
                     devpThread.setPakMk(staProtocol.getSiteId(), false, 283);
                     devpThread.setPakMk(staProtocol.getSiteId(), false, 9999);
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     
                     if (result) {