| | |
| | | import com.jcdm.main.plcserver.conf.OPCElement; |
| | | import com.jcdm.main.plcserver.util.TimeUtil; |
| | | import com.jcdm.main.restful.factoryMes.service.RestfulService; |
| | | import com.jcdm.main.restful.qingYan.doman.ChildVO; |
| | | import com.jcdm.main.restful.qingYan.doman.ParentVO; |
| | | import com.kangaroohy.milo.model.ReadWriteEntity; |
| | | import com.kangaroohy.milo.runner.subscription.SubscriptionCallback; |
| | | import com.kangaroohy.milo.service.MiloService; |
| | |
| | | |
| | | import javax.websocket.Session; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.Instant; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | |
| | | saveStationInfo(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | //3、保存参数采集数据 |
| | | SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | List<DaParamCollection> daParamCollectionList = SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | |
| | | //如果是末尾工站要报工 |
| | | if(device.equals("OP500")){ |
| | |
| | | updateOrderInfo(snCode); |
| | | } |
| | | try{ |
| | | daParamCollectionService.pushGeelycvMesFeedback(snCode,device); |
| | | daParamCollectionService.automaticWorkstationPushGeelycvMesFeedback(snCode,device,daParamCollectionList); |
| | | }catch (Exception e){ |
| | | } |
| | | result = "21"; |
| | |
| | | daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection); |
| | | } |
| | | |
| | | public static void SaveParamData(String packCode,String thoroughfare,String device,String workOrderNo,String productType) throws Exception { |
| | | public static List<DaParamCollection> 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<DaParamCollection> daParamCollectionlist = new ArrayList<>(); |
| | | |
| | | List<String> nodeIdList = list.stream().map(info -> { |
| | | String nodeid = info.getGatherAddress(); |
| | |
| | | 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(); |
| | | ChildVO childVO = new ChildVO(); |
| | | ParamCollection.setParamCode(list.get(i).getCollectParameterId()); |
| | | ParamCollection.setLocationCode(device); |
| | | if(tt.contains("Time")){ |
| | |
| | | } |
| | | } |
| | | daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist); |
| | | } |
| | | addBaseData(workOrderNo,productType,device,packCode); |
| | | |
| | | } |
| | | List<DaParamCollection> baseDataList = addBaseData(workOrderNo,productType,device,packCode); |
| | | for (int i = 0; i < baseDataList.size(); i++){ |
| | | daParamCollectionlist.add(baseDataList.get(i)); |
| | | } |
| | | return daParamCollectionlist; |
| | | } |
| | | |
| | | public static void addBaseData(String workOrderNo,String productCode,String locationCode,String packCode){ |
| | | public static List<DaParamCollection> addBaseData(String workOrderNo,String productCode,String locationCode,String packCode){ |
| | | Map<String, String> map = new HashMap<>(); |
| | | map.put("GC", "南浔工厂"); |
| | | map.put("CXBH", "Pack线"); |
| | |
| | | confList.add(saveData); |
| | | }); |
| | | daParamCollectionService.insertBatch(confList); |
| | | return confList; |
| | | } |
| | | |
| | | public static void getFactoryOrder(String locationCode){ |