| | |
| | | daParamCollectionService.insertBatch(collectionList); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 获取SNCode |
| | | */ |
| | | public String getSNCode(){ |
| | | String SNCode = ""; |
| | | return SNCode; |
| | | } |
| | | |
| | | /** |
| | | * 出站保存数据 |
| | | */ |
| | | public String outSaveDate(String thoroughfare,String device) { |
| | | String snCode = ""; |
| | | String result = ""; |
| | | String read = thoroughfare + "." + device + "."; |
| | | |
| | | try { |
| | | if(nullList.stream().noneMatch(s -> s.equals(device))){ |
| | | if(moduleCodeList.stream().anyMatch(s -> s.equals(device))){ |
| | | read = read + "ModuleCode"; |
| | | }else { |
| | | read = read + "PACKCode"; |
| | | } |
| | | } |
| | | snCode = miloService.readFromOpcUa(read).getValue().toString(); |
| | | |
| | | if(null == snCode || "".equals(snCode)){ |
| | | result = "22"; |
| | | }else{ |
| | | |
| | | String workOrderNo = ""; |
| | | String productCode = ""; |
| | | //2、保存过站采集数据 |
| | | Object orderNumberObject = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "WorkOrderNumber").getValue(); |
| | | if(orderNumberObject!=null){ |
| | | workOrderNo = orderNumberObject.toString(); |
| | | } |
| | | |
| | | Object productCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "ProductType").getValue(); |
| | | if(productCodeObject!=null){ |
| | | productCode = productCodeObject.toString(); |
| | | } |
| | | |
| | | saveStationInfo(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | //3、保存参数采集数据 |
| | | SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | |
| | | //如果是末尾工站要报工 |
| | | if(device.equals("OP500")){ |
| | | RestfulService.getWorkReportResultFeedback(snCode,device,format.format(new Date())); |
| | | //1、更新工单信息 |
| | | updateOrderInfo(snCode); |
| | | } |
| | | |
| | | result = "21"; |
| | | |
| | | } |
| | | |
| | | }catch (Exception e) { |
| | | System.out.println(e.getMessage()); |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | |
| | | // /** |
| | | // * 出站保存数据 |
| | | // */ |
| | | // public String outSaveDate(String thoroughfare,String device) { |
| | | // String result = ""; |
| | | // try { |
| | | // //读取SNCode |
| | | // String PACKCode = thoroughfare + "." + device + ".PACKCode"; |
| | | // Object PACKCodeObject = miloService.readFromOpcUa(PACKCode).getValue(); |
| | | // if(null == PACKCodeObject || "".equals(PACKCodeObject)){ |
| | | // result = "22"; |
| | | // }else{ |
| | | // String PACKCodeParam = PACKCodeObject.toString(); |
| | | // //1、更新工单信息 |
| | | // //updateOrderInfo(); |
| | | // //2、保存过站采集数据 |
| | | // saveStationInfo(PACKCodeParam,thoroughfare,device); |
| | | // //3、保存参数采集数据 |
| | | // SaveParamData(PACKCodeParam,thoroughfare,device,"",""); |
| | | // |
| | | // result = "21"; |
| | | // |
| | | // } |
| | | // |
| | | // }catch (Exception e) { |
| | | // |
| | | // } |
| | | // return result; |
| | | // } |
| | | |
| | | /** |
| | | * 保存过站采集 |
| | | */ |
| | | public void saveStationInfo(String packCode,String thoroughfare,String device,String workOrderNo,String productCode) throws Exception { |
| | | SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", Locale.US); |
| | | sdf.setTimeZone(TimeZone.getTimeZone("GMT+8")); // CST通常表示中国标准时间,即东八区 |
| | | String prefix = thoroughfare+"."+device+"."; |
| | | String startTime = miloService.readFromOpcUa(prefix + "StartTime").getValue().toString(); |
| | | String stopTime = miloService.readFromOpcUa(prefix + "StopTime").getValue().toString(); |
| | | String stationStatus = miloService.readFromOpcUa(prefix + "StationStatus").getValue().toString(); |
| | | |
| | | DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection(); |
| | | daPassingStationCollection.setSfcCode(packCode); |
| | | daPassingStationCollection.setWorkOrderNo(workOrderNo); |
| | | daPassingStationCollection.setProductCode(productCode); |
| | | daPassingStationCollection.setLocationCode(device); |
| | | String strt = TimeUtil.stringProcessing(startTime); |
| | | String end = TimeUtil.stringProcessing(stopTime); |
| | | daPassingStationCollection.setInboundTime(sdf.parse(strt));//入站时间 |
| | | daPassingStationCollection.setOutboundTime(sdf.parse(end));//出站时间 |
| | | daPassingStationCollection.setOutRsSign(stationStatus);//出站是否合格 |
| | | daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection); |
| | | } |
| | | |
| | | public static void SaveParamData(String packCode,String thoroughfare,String device,String workOrderNo,String productType) throws Exception { |
| | | List<DaCollectionParamConf> list; |
| | | DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf(); |
| | | daCollectionParamConf.setGatherAddress(thoroughfare+ "." + device); |
| | | list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf); |
| | | |
| | | List<String> nodeIdList = list.stream().map(info -> { |
| | | String nodeid = info.getGatherAddress(); |
| | | return nodeid; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | if(!nodeIdList.isEmpty()){ |
| | | List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList); |
| | | for (int i = 0; i < readWriteEntityList.size(); i++) { |
| | | if(readWriteEntityList.get(i).getValue() == null){ |
| | | readWriteEntityList.get(i).setValue(" "); |
| | | } |
| | | } |
| | | List<DaParamCollection> daParamCollectionlist = new ArrayList<>(); |
| | | for(int i=0;i<nodeIdList.size();i++){ |
| | | if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){ |
| | | String tt = readWriteEntityList.get(i).getValue().toString(); |
| | | DaParamCollection ParamCollection = new DaParamCollection(); |
| | | ParamCollection.setParamCode(list.get(i).getCollectParameterId()); |
| | | ParamCollection.setLocationCode(device); |
| | | if(tt.contains("Time")){ |
| | | // String str = TimeUtil.getTimestamp(TimeUtil.stringProcessing(tt)); |
| | | // ParamCollection.setParamValue(str); |
| | | ParamCollection.setParamValue(TimeUtil.getYyyyDdMm(TimeUtil.stringProcessing(tt))); |
| | | }else { |
| | | ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString()); |
| | | } |
| | | ParamCollection.setSfcCode(packCode); |
| | | if(device.contains("OP360")){ |
| | | String node = nodeIdList.get(i); |
| | | Object value = miloService.readFromOpcUa("PACK.OP360.ModuleSNCode"+node.charAt(node.length()-1)).getValue(); |
| | | if(value!=null){ |
| | | ParamCollection.setModuleCode(value.toString()); |
| | | } |
| | | } |
| | | ParamCollection.setParamName(list.get(i).getCollectParameterName()); |
| | | ParamCollection.setParamUpper(list.get(i).getParamUpper()); |
| | | ParamCollection.setParamLower(list.get(i).getParamLower()); |
| | | ParamCollection.setUnit(list.get(i).getCollectParameterUnit()); |
| | | //ParamCollection.setState("合格"); |
| | | ParamCollection.setType(list.get(i).getCollectParameterType()); |
| | | ParamCollection.setCollectionTime(new Date()); |
| | | ParamCollection.setWorkOrderNo(workOrderNo); |
| | | ParamCollection.setProductCode(productType); |
| | | daParamCollectionlist.add(ParamCollection); |
| | | // daParamCollectionService.insertDaParamCollection(ParamCollection); |
| | | } |
| | | } |
| | | daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist); |
| | | } |
| | | addBaseData(workOrderNo,productType,device,packCode); |
| | | |
| | | } |
| | | |
| | | public static void addBaseData(String workOrderNo,String productCode,String locationCode,String packCode){ |
| | | Map<String, String> map = new HashMap<>(); |
| | | map.put("GC", "南浔工厂"); |
| | | map.put("CXBH", "Pack线"); |
| | | map.put("SBBH", "设备001"); |
| | | map.put("YGBH", "员工001"); |
| | | List<DaParamCollection> confList = new ArrayList<>(); |
| | | map.forEach((key, value) -> { |
| | | List<DaCollectionParamConf> daCollectionParamConfs = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>() |
| | | .eq(DaCollectionParamConf::getProcessesCode,locationCode) |
| | | .like(DaCollectionParamConf::getCollectParameterId,key) |
| | | .eq(DaCollectionParamConf::getRemarks,Constants.ONE)); |
| | | DaParamCollection saveData = new DaParamCollection(); |
| | | saveData.setWorkOrderNo(workOrderNo); |
| | | saveData.setProductCode(productCode); |
| | | saveData.setLocationCode(locationCode); |
| | | saveData.setSfcCode(packCode); |
| | | saveData.setParamCode(daCollectionParamConfs.get(0).getCollectParameterId()); |
| | | saveData.setParamName(daCollectionParamConfs.get(0).getCollectParameterName()); |
| | | saveData.setCollectionTime(new Date()); |
| | | saveData.setParamValue(value); |
| | | confList.add(saveData); |
| | | }); |
| | | daParamCollectionService.insertBatch(confList); |
| | | } |
| | | |
| | | public static void getFactoryOrder(String locationCode){ |
| | | String productionWorkOrder = RestfulService.getProductionWorkOrderRequest("", locationCode); |
| | | JSONObject jsonObject = new JSONObject(productionWorkOrder); |
| | | JSONObject dataObject = jsonObject.getJSONObject("data"); |
| | | |
| | | String productNum = dataObject.getStr("productNum"); |
| | | String stationCode = dataObject.getStr("stationCode"); |
| | | String materialCode = dataObject.getStr("materialCode"); |
| | | String productionOrderNum = dataObject.getStr("productionOrderNum"); |
| | | |
| | | OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo(); |
| | | omProductionOrdeInfo.setProductNum(productNum); |
| | | omProductionOrdeInfo.setWorkOrderNo(productionOrderNum); |
| | | omProductionOrdeInfo.setStationCode(stationCode); |
| | | omProductionOrdeInfo.setProductCode(materialCode); |
| | | omProductionOrdeInfoService.save(omProductionOrdeInfo); |
| | | } |
| | | |
| | | public static void updateOrderInfo(String packCode){ |
| | | OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, packCode)); |
| | | one.setOrderStatus("5"); |
| | | omProductionOrdeInfoService.saveOrUpdate(one); |
| | | } |
| | | |
| | | public static void avgFunction(){ |
| | | |
| | | } |
| | | |
| | | public static String TightenTheConversionOkNg(String param){ |
| | | // 去除首尾的方括号,然后按照逗号分割字符串 |
| | | String[] parts = param.substring(1, param.length() - 1).split(","); |
| | | |
| | | // 创建一个新的StringBuilder来构建替换后的字符串 |
| | | StringBuilder sb = new StringBuilder(); |
| | | sb.append('['); // 添加左方括号 |
| | | |
| | | for (int i = 0; i < parts.length; i++) { |
| | | String part = parts[i].trim(); // 去除可能的空格 |
| | | float value; |
| | | try { |
| | | value = Float.parseFloat(part); // 尝试将字符串转换为浮点数 |
| | | String replacement; |
| | | if (value == 1f) { |
| | | replacement = "OK"; |
| | | } else if (value == 2f) { |
| | | replacement = "NG"; |
| | | } else { |
| | | replacement = part; // 如果不是1或2,则保持不变 |
| | | } |
| | | sb.append(replacement); |
| | | if (i < parts.length - 1) { |
| | | sb.append(','); // 添加逗号(除了最后一个元素) |
| | | } |
| | | } catch (NumberFormatException e) { |
| | | // 如果转换失败,则保持原样(或进行其他错误处理) |
| | | sb.append(part); |
| | | if (i < parts.length - 1) { |
| | | sb.append(','); |
| | | } |
| | | } |
| | | } |
| | | sb.append(']'); // 添加右方括号 |
| | | return sb.toString(); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 校验是否存在NG |
| | | * @param packCode sfcCode |
| | | * @return boolean |
| | | */ |
| | | public boolean checkIsNG(String packCode,String modelCode){ |
| | | List<DaPassingStationCollection> list = daPassingStationCollectionService.list(new LambdaQueryWrapper<DaPassingStationCollection>() |
| | | .eq(StrUtil.isNotBlank(packCode),DaPassingStationCollection::getSfcCode, packCode) |
| | | .eq(DaPassingStationCollection::getOutRsSign, Constants.UN_PASS)); |
| | | return CollUtil.isEmpty(list); |
| | | } |
| | | |
| | | } |