cl
2024-07-02 8c5c9cfbe2dfa4b40636ec974feaf48ace0d271f
jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
@@ -8,7 +8,10 @@
import cn.hutool.http.HttpResponse;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.jcdm.common.core.domain.AjaxResult;
import com.jcdm.framework.websocket.WebSocketUsers;
import com.jcdm.main.bs.formulaChild.domain.BsFormulaChildInfo;
import com.jcdm.main.constant.Constants;
import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf;
import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService;
@@ -16,7 +19,9 @@
import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService;
import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection;
import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService;
import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo;
import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService;
import com.jcdm.main.plcserver.util.TimeUtil;
import com.jcdm.main.restful.qingYan.doman.ChildVO;
import com.jcdm.main.restful.qingYan.doman.ParentVO;
import com.kangaroohy.milo.model.ReadWriteEntity;
@@ -37,10 +42,10 @@
@Component
public class OPCUaSubscription implements SubscriptionCallback {
    public SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    public static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    Map<String, Session> map = WebSocketUsers.getUsers();
    public static MiloService miloService;
@@ -99,19 +104,31 @@
                    }
                }else if (Constants.RECORD_SN.equals(tab)){//求下发模组码请9
                    if (Constants.ONE.equals(valueString)){
                        if (Constants.OP100_1.equals(device) || Constants.OP100_2.equals(device) ){
                            /*List<WorkOrder> orderList = workOrderService.list().stream()
                                    .sorted(Comparator.comparing(WorkOrder::getCreateTime).reversed())
                                    .collect(Collectors.toList());
                        /*if (Constants.OP100_1.equals(device) || Constants.OP100_2.equals(device) ){*/
                            //查询要生产的工单
                            List<OmProductionOrdeInfo> orderList = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>()
                                    .eq(OmProductionOrdeInfo::getOrderStatus, Constants.ONE));//工单状态
                            if (CollUtil.isNotEmpty(orderList)){
                                Long id = orderList.get(0).getId();
                                String productNum = orderList.get(0).getProductNum();//模组码
                                //OP070下发产品模组码
                                //下发产品模组码
                                miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ModuleCode").value(productNum).build());
                                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordSNDone").value(1).build());
                                //更新工单状态为执行中
                                OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
                                omProductionOrdeInfo.setId(id);
                                omProductionOrdeInfo.setOrderStatus("3");
                                omProductionOrdeInfoService.updateOmProductionOrdeInfo(omProductionOrdeInfo);
                                //将产品SN发送到前台
                                productNum = "productNum,"+ productNum;
                                WebSocketUsers.sendMessageToUserByText(map.get(device), productNum);
                            }else{
                                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordSNDone").value(2).build());//没有要生产的工单
                            }*/
                        }
                     /*   }*/
                    }
                }else if (Constants.RECORD_DATA.equals(tab)){//出入站
                    if (Constants.ONE.equals(valueString)){//入站
@@ -149,9 +166,8 @@
                            Integer result = 21;
                            //读取电芯码
                            List<String> cellCodeList = readCellCodeList(thoroughfare, device);
                            if(ObjectUtil.isNull(cellCodeList) && cellCodeList.size() != 4){
                            if(ObjectUtil.isNull(cellCodeList) || cellCodeList.size() != 4){
                                result = 23;
                                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(23).build());
                            }else{
                                result = savePassingStation(thoroughfare, device,cellCodeList);//保存过站
                                if(result==21) {
@@ -161,6 +177,9 @@
                            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(result).build());
                            log.info("写入到工位{}的RecordDataDone数据:{}",device,result);
                        } else if (Constants.OP100_1.equals(device) || Constants.OP100_2.equals(device)){
                            //上线报工
                        } else {
                            //2:告知MES工位工作完成,请求记录工位数据
@@ -192,7 +211,7 @@
                            log.info("写入到工位{}的RecordDataDone数据:{}",device,21);
                        }
                    }
                }  else if (Constants.RECORD_CHECK_CODE_1.equals(tab)) {
                }  /*else if (Constants.RECORD_CHECK_CODE_1.equals(tab)) {
                    if (Constants.OP100_1.equals(device)){
                        //钢带条码校验--发送给工厂mes
                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ScanerResult11").value(11).build());
@@ -200,9 +219,10 @@
                        //PET带条码校验--发送给工厂mes
                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ScanerResult12").value(11).build());
                    }
                }
                }*/
            }
        } catch (Exception e) {
            log.error(e.getMessage());
            System.out.println(e.getMessage());
            log.info(e.getMessage());
        }
@@ -229,7 +249,10 @@
            List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(readList);//电芯码
            for (ReadWriteEntity readWriteEntity : readWriteEntityList) {
                if (ObjectUtil.isNotNull(readWriteEntity.getValue())){
                    if(!"".equals(readWriteEntity.getValue().toString().trim())){
                    cellCodeList.add(readWriteEntity.getValue().toString());//封装电芯码
                    }
                }
            }
        } catch (Exception e) {
@@ -254,9 +277,7 @@
            Date startTime = new Date();
            ReadWriteEntity startTimeRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StartTime");//进站时间
            if (ObjectUtil.isNotNull(startTimeRead.getValue())){
                String stringStartTime = startTimeRead.getValue().toString();
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
                startTime = sdf.parse(stringStartTime);
                startTime = format.parse(TimeUtil.test(TimeUtil.stringProcessing(startTimeRead.getValue().toString())));
            }else{
                result = 23;
                log.info("读取到工位{}的StartTime数据:{},返回RecordDataDone的值为{}",device,"IS NULL!",result);
@@ -319,6 +340,7 @@
            //查询参数配置表
            List<DaCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>()
                    .eq(DaCollectionParamConf::getProcessesCode, device)//工位
                    .eq(DaCollectionParamConf::getWhetherToCollect, Constants.ONE)//是否采集
                    .eq(DaCollectionParamConf::getRemarks, Constants.ONE));//类型
            if (CollUtil.isNotEmpty(list)) {
                List<DaParamCollection> saveParamList = new ArrayList<>();//封装参数采集list
@@ -476,6 +498,9 @@
                            if (ObjectUtil.isNotNull(paramCollectionList0.get(j).getValue())) {
                                paramValue = paramCollectionList0.get(j).getValue().toString();//参数值
                            }
                            if(confColl0.get(j).getCollectParameterName().contains("时间") && !"".equals(paramValue)){
                                paramValue = format.parse(TimeUtil.test(TimeUtil.stringProcessing(paramValue))).toString();
                            }
                            daParamCollection.setParamValue(paramValue);//参数值
                            daParamCollection.setLocationCode(device);//工位
                            daParamCollection.setCollectionTime(new Date());//采集时间