midea.git - Gitblit

2024-01-22 314bc7a1733856bd82c9d99bdfa27b34a4a762c3

提交 \| 用户 \| 时间
d43481	1	package cn.stylefeng.guns.plcserver.callback;
C	2
	3
	4	import cn.stylefeng.guns.modular.bs.collectionParamConf.model.params.CollectionParamConfParam;
	5	import cn.stylefeng.guns.modular.bs.collectionParamConf.model.result.CollectionParamConfResult;
	6	import cn.stylefeng.guns.modular.bs.collectionParamConf.service.CollectionParamConfService;
	7	import cn.stylefeng.guns.modular.bs.equipmentInfo.service.EquipmentInfoService;
	8	import cn.stylefeng.guns.modular.bs.locationInfo.model.params.LocationInfoParam;
	9	import cn.stylefeng.guns.modular.bs.locationInfo.model.result.LocationInfoResult;
	10	import cn.stylefeng.guns.modular.bs.locationInfo.service.LocationInfoService;
	11	import cn.stylefeng.guns.modular.cm.paramCollection.model.params.ParamCollectionParam;
	12	import cn.stylefeng.guns.modular.cm.paramCollection.service.ParamCollectionService;
	13	import cn.stylefeng.guns.modular.cm.passingStationCollection.model.params.PassingStationCollectionParam;
	14	import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService;
	15	import cn.stylefeng.guns.modular.dq.materialTraceability.model.params.MaterialTraceabilityParam;
	16	import cn.stylefeng.guns.modular.dq.materialTraceability.service.MaterialTraceabilityService;
	17	import cn.stylefeng.guns.modular.em.equipmentAlarm.service.EquipmentAlarmService;
	18	import cn.stylefeng.guns.modular.em.equipmentStatus.service.EquipmentStatusService;
	19	import cn.stylefeng.guns.modular.gm.greaseManage.service.GreaseManageService;
	20	import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.params.ProductionOrdeInfoParam;
	21	import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.result.ProductionOrdeInfoResult;
	22	import cn.stylefeng.guns.modular.om.productionOrdeInfo.service.ProductionOrdeInfoService;
	23	import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.model.params.ProductionOrderBatchInfoParam;
	24	import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.model.result.ProductionOrderBatchInfoResult;
	25	import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.service.ProductionOrderBatchInfoService;
	26	import cn.stylefeng.guns.modular.om.productionOrderRecords.service.ProductionOrderRecordsService;
	27	import cn.stylefeng.guns.modular.sc.repairManageInfo.model.params.RepairManageInfoParam;
	28	import cn.stylefeng.guns.modular.sc.repairManageInfo.model.result.RepairManageInfoResult;
	29	import cn.stylefeng.guns.modular.sc.repairManageInfo.service.RepairManageInfoService;
	30	import cn.stylefeng.guns.modular.sc.serialNumbersConf.service.SerialNumbersConfService;
	31	import cn.stylefeng.guns.plcserver.opc.GlobalVariable;
	32	import cn.stylefeng.guns.plcserver.opc.OPCElement;
	33	import cn.stylefeng.guns.plcserver.opc.unit.OPCUnit;
	34	import cn.stylefeng.guns.plcserver.tool.DateTool;
	35	import cn.stylefeng.guns.plcserver.tool.LogUtil;
	36	import com.kangaroohy.milo.model.ReadWriteEntity;
	37	import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
	38	import com.kangaroohy.milo.service.MiloService;
	39	import org.apache.log4j.Logger;
	40	import org.springframework.beans.factory.annotation.Autowired;
	41	import org.springframework.stereotype.Component;
	42
	43	import java.util.ArrayList;
	44	import java.util.Date;
	45	import java.util.List;
	46	import java.util.Random;
	47
	48	@Component
	49	public class BOP010Callback implements SubscriptionCallback {
	50
	51	public MiloService miloService;
	52
	53	@Autowired
	54	public ProductionOrdeInfoService productionOrdeInfoService;
	55	@Autowired
	56	public PassingStationCollectionService passingStationCollectionService;
	57	@Autowired
	58	public ParamCollectionService paramCollectionService;
	59	@Autowired
	60	public CollectionParamConfService collectionParamConfService;
	61	@Autowired
	62	public SerialNumbersConfService serialNumbersConfService;
	63	@Autowired
	64	private EquipmentStatusService equipmentStatusService;
	65
	66	@Autowired
	67	private EquipmentAlarmService equipmentAlarmService;
	68	@Autowired
	69	private MaterialTraceabilityService materialTraceabilityService;
	70	@Autowired
	71	private EquipmentInfoService equipmentInfoService;
	72	@Autowired
	73	private RepairManageInfoService repairManageInfoService;
	74
	75	@Autowired
	76	private LocationInfoService locationInfoService;
	77
	78	@Autowired
	79	private GreaseManageService greaseManageService;
	80
	81	@Autowired
	82	private ProductionOrderRecordsService productionOrderRecordsService;
	83
	84	@Autowired
	85	private ProductionOrderBatchInfoService productionOrderBatchInfoService;
	86
	87	private static Logger logger;
	88	LogUtil logUtil = new LogUtil();
	89	static {
	90	logger = Logger.getLogger(BOP010Callback.class);
	91	}
	92	private static Date IN_TIME = null;
	93	private static String S_ORDER_CODE = "";//工单编号
	94	private static String S_PRODUCT_CODE = "";//产品编号
	95	private static String S_PRODUCT_TYPE= "";//产品类型
	96	private static String S_SFC_CODE = "";//总成编码
	97	private static String PRODUCTION_LINE = "BOP";//产线号
	98	private static String LOCATION_CODE = "BOP010";//工位号
	99	private static List list = null;
	100
	101	public BOP010Callback(MiloService miloService,
	102	ProductionOrdeInfoService productionOrdeInfoService,
	103	PassingStationCollectionService passingStationCollectionService,
	104	ParamCollectionService paramCollectionService,
	105	CollectionParamConfService collectionParamConfService,
	106	SerialNumbersConfService serialNumbersConfService,
	107	EquipmentStatusService equipmentStatusService,
	108	EquipmentAlarmService equipmentAlarmService,
	109	MaterialTraceabilityService materialTraceabilityService,
	110	EquipmentInfoService equipmentInfoService,
	111	RepairManageInfoService repairManageInfoService,
	112	LocationInfoService locationInfoService,
	113	GreaseManageService greaseManageService,
	114	ProductionOrderRecordsService productionOrderRecordsService,
	115	ProductionOrderBatchInfoService productionOrderBatchInfoService) {
	116	this.miloService = miloService;
	117	this.productionOrdeInfoService = productionOrdeInfoService;
	118	this.passingStationCollectionService = passingStationCollectionService;
	119	this.paramCollectionService = paramCollectionService;
	120	this.collectionParamConfService = collectionParamConfService;
	121	this.serialNumbersConfService = serialNumbersConfService;
	122	this.equipmentStatusService = equipmentStatusService;
	123	this.equipmentAlarmService = equipmentAlarmService;
	124	this.materialTraceabilityService = materialTraceabilityService;
	125	this.equipmentInfoService = equipmentInfoService;
	126	this.repairManageInfoService = repairManageInfoService;
	127	this.locationInfoService = locationInfoService;
	128	this.greaseManageService = greaseManageService;
	129	this.productionOrderRecordsService = productionOrderRecordsService;
	130	this.productionOrderBatchInfoService = productionOrderBatchInfoService;
	131	}
	132	@Override
	133	public void onSubscribe(String identifier, Object value) {
	134	String ecpStr = "";//异常记录标记
	135	try {
	136	//心跳
	137	if(null != value && identifier.equals(OPCElement.COP010_F_HEART_BEAT)){
	138	if( "false".equals(value.toString()))
	139	{
	140	ReadWriteEntity entity = new ReadWriteEntity(OPCElement.BOP010_F_HEART_BEAT,true);
	141	miloService.writeToOpcUa(entity);
	142	}
	143	}
	144	//PLC进站
	145	else if(null != value && identifier.equals(OPCElement.BOP010_J_PLC_START)){
	146	if("true".equals(value.toString())){
	147	String isRepair = miloService.
	148	readFromOpcUa(OPCElement.BOP010_P_REPAIR)
	149	.getValue().toString();//是否返修
	150	if(isRepair.equals("true")){
	151	handleRepair();
	152	}else{
	153	handleOrder();
	154	}
	155	}
	156	}
	157	//PLC出站
	158	else if(null != value && identifier.equals(OPCElement.BOP010_J_PLC_FINISH)){
	159	if("true".equals(value.toString())){
	160	handleFinsh();
	161	handleInfo();
	162	handleMaterial();
	163	}
	164	}else{
	165	System.out.println("BOP010值没有变");
	166	}
	167	} catch (Exception e) {
	168	ecpStr ="出现异常：" + logUtil.getTrace(e);
	169	}finally {
	170	if(!"".equals(ecpStr)){
	171	logger.info(ecpStr+"\r\n");
	172	}
	173	}
	174	}
	175
	176	public void handleOrder() throws Exception{
	177
	178	IN_TIME = DateTool.getLocalTimeForDate();
	179	ProductionOrdeInfoParam param = new ProductionOrdeInfoParam();
	180	param.setProductionLine("");//产线
	181	param.setOrderStatus("3");//工单状态
	182	List<ProductionOrdeInfoResult> list = productionOrdeInfoService.findListBySpec(param);
	183
	184	if(list.size()>0) {
	185	ProductionOrdeInfoResult result = list.get(0);
	186
	187	S_ORDER_CODE = result.getWorkOrderNo();
	188	S_PRODUCT_CODE = result.getMaterialCode();
	189	S_PRODUCT_TYPE = GlobalVariable.PRODUCT_TYPE_MAP.get(S_PRODUCT_CODE);
	190
	191	//自动生成唯一码
	192	Random random = new Random(System.currentTimeMillis());
	193	S_SFC_CODE = "BOP"+random.nextLong();
	194
	195	List<ReadWriteEntity> lists = new ArrayList<>();
	196	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_ORDER_CODE,S_ORDER_CODE));
314bc7	197	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_PRODUCT_CODE,Short.parseShort(S_PRODUCT_TYPE)));
d43481	198	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_SFC_CODE,S_SFC_CODE));
314bc7	199	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_NUMBER,Short.parseShort(result.getPlanQty().toString())));
d43481	200	lists.add(new ReadWriteEntity(OPCElement.BOP010_J_PC_WRITE_ORDER,true));
C	201	miloService.writeToOpcUa(lists);
	202
	203	logger.info("BOP010工位,handleOrder PC处理完成！2");
	204	}else{
	205	logger.info("BOP010工位没有可执行的工单,请联系工单管理员下发该产线的工单！");
	206	}
	207	}
	208
	209	public void handleFinsh() throws Exception {
	210	logger.info("handleFinsh PC处理开始！");
	211	String S_PRODUCT_STATE_CODE = miloService.
	212	readFromOpcUa(OPCElement.BOP010_S_PRODUCT_STATE_CODE)
	213	.getValue().toString();
	214
	215	//处理过站信息
	216	PassingStationCollectionParam param = new PassingStationCollectionParam();
	217	param.setWorkOrderNo(S_ORDER_CODE);
	218	param.setProductCode(S_PRODUCT_CODE);
	219	param.setSfcCode(S_SFC_CODE);
	220	param.setProductionLine(PRODUCTION_LINE);
	221	param.setLocationCode(LOCATION_CODE);
	222	param.setInboundTime(IN_TIME);
	223	param.setOutboundTime(DateTool.getLocalTimeForDate());
	224	param.setOutRsSign(S_PRODUCT_STATE_CODE);//出站是否合格
	225	passingStationCollectionService.add(param);
	226
	227	ReadWriteEntity entity = new ReadWriteEntity(OPCElement.BOP010_J_PC_FINISH,true);
	228	miloService.writeToOpcUa(entity);//写PC完成
	229	logger.info("handleFinsh PC处理完成！");
	230	}
	231
	232	public void handleMaterial() {
	233
	234	//查询批次上料信息
	235	ProductionOrderBatchInfoParam productionOrderBatchInfoParam = new ProductionOrderBatchInfoParam();
	236	productionOrderBatchInfoParam.setWorkOrderNo(S_ORDER_CODE);
	237	productionOrderBatchInfoParam.setLocationCode(LOCATION_CODE);
	238	List<ProductionOrderBatchInfoResult> list = productionOrderBatchInfoService.findListBySpec(productionOrderBatchInfoParam);
	239	for(int i=0;i<list.size();i++){
	240	ProductionOrderBatchInfoResult productionOrderBatchInfoResult = list.get(i);
	241	int remainingQuantity = productionOrderBatchInfoResult.getResidueQuantity();//剩余数量
	242	if(remainingQuantity>0 ){
	243	//新增物料追溯
	244	MaterialTraceabilityParam materialTraceabilityParam = new MaterialTraceabilityParam();
	245	materialTraceabilityParam.setWorkOrderNo(S_ORDER_CODE);
	246	materialTraceabilityParam.setProductCode(S_PRODUCT_CODE);
	247	materialTraceabilityParam.setProductNo(S_SFC_CODE);
	248	materialTraceabilityParam.setLineCode(PRODUCTION_LINE);
	249	materialTraceabilityParam.setLocationCode(LOCATION_CODE);
	250	materialTraceabilityParam.setAssemblyQty(1);
	251	materialTraceabilityParam.setAssemblyTime(DateTool.getLocalTimeForDate());
	252	materialTraceabilityParam.setMaterialCode(productionOrderBatchInfoResult.getMaterialCode());//物料编码
	253	materialTraceabilityParam.setMaterialBatchNo(productionOrderBatchInfoResult.getBatch());//物料批次
	254
	255	materialTraceabilityService.add(materialTraceabilityParam);
	256	//更新剩余数量
	257	productionOrderBatchInfoParam.setId(productionOrderBatchInfoResult.getId());
	258	productionOrderBatchInfoParam.setResidueQuantity(remainingQuantity-1);//剩余数量
	259	productionOrderBatchInfoService.update(productionOrderBatchInfoParam);
	260	}
	261	}
	262	}
	263
	264	//PC读参数信息
	265	public void handleInfo() throws Exception {
	266	logger.info("handleInfo START！");
	267
	268	if(null == list){
	269	CollectionParamConfParam collectionParamConfParam = new CollectionParamConfParam();
	270	collectionParamConfParam.setLocationCode(LOCATION_CODE);
	271	list = collectionParamConfService.findListBySpec(collectionParamConfParam);
	272	}
	273	if(null != list && !list.isEmpty()) {
	274	for (int i = 0; i < list.size(); i++) {
	275	CollectionParamConfResult result = (CollectionParamConfResult) list.get(i);
	276	String value = miloService.
	277	readFromOpcUa(result.getGatherAddress())
	278	.getValue().toString();//读参数值
	279	ParamCollectionParam paramCollectionParam = new ParamCollectionParam();
	280	paramCollectionParam.setParamCode(result.getParamCode());
	281	paramCollectionParam.setParamName(result.getParamName());
	282	paramCollectionParam.setWorkOrderNo(S_ORDER_CODE);
	283	paramCollectionParam.setSfcCode(S_SFC_CODE);
	284	paramCollectionParam.setProductCode(S_PRODUCT_CODE);
	285	paramCollectionParam.setProductionLine(result.getProductionLine());
	286	paramCollectionParam.setLocationCode(result.getLocationCode());
	287	paramCollectionParam.setParamValue(value);
	288	paramCollectionParam.setParamLower(result.getParamLower());
	289	paramCollectionParam.setParamUpper(result.getParamUpper());
	290	paramCollectionParam.setParamStandard(result.getParamCentral());
	291	paramCollectionParam.setCollectionTime(DateTool.getLocalTimeForDate());
	292	paramCollectionParam.setUnit(result.getUnit());
	293	paramCollectionService.add(paramCollectionParam);
	294	}
	295	}
	296
	297	logger.info("handleInfo END！");
	298	}
	299	public void handleRepair() throws Exception{
	300	RepairManageInfoParam repairManageInfoParam = new RepairManageInfoParam();
	301	repairManageInfoParam.setLocationCode(LOCATION_CODE);
	302	repairManageInfoParam.setManageType("2");
	303	repairManageInfoParam.setUpPlc("0");
	304	List<RepairManageInfoResult> list = repairManageInfoService.findListBySpec(repairManageInfoParam);
	305	if(list.size()>0) {
	306	RepairManageInfoResult result = list.get(0);
	307
	308	//自动生成唯一码
	309	Random random = new Random(System.currentTimeMillis());
	310	S_SFC_CODE = "BOP" + random.nextLong();
	311
	312
	313	S_ORDER_CODE = result.getWorkOrderNo();
	314	S_PRODUCT_CODE = result.getProductCode();
	315	S_PRODUCT_TYPE = GlobalVariable.PRODUCT_TYPE_MAP.get(S_PRODUCT_CODE);
	316	String repairLocation = result.getPoorLocationCode();//
	317
	318	//根据工位编码查询工位表中配置的返修工位号
	319	LocationInfoParam param = new LocationInfoParam();
	320	param.setLocationCode(repairLocation);
	321	List<LocationInfoResult> results = locationInfoService.findListBySpec(param);
	322	if(results.size()>0) {
	323	LocationInfoResult r = results.get(0);
	324	String repairLocationNo = r.getSpareField2();
	325	if(null != repairLocationNo && "" != repairLocationNo){
	326	List<ReadWriteEntity> lists = new ArrayList<>();
	327	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_ORDER_CODE,S_ORDER_CODE));
314bc7	328	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_PRODUCT_CODE,Short.parseShort(S_PRODUCT_TYPE)));
d43481	329	lists.add(new ReadWriteEntity(OPCElement.BOP010_S_SFC_CODE,S_SFC_CODE));
C	330	lists.add(new ReadWriteEntity(OPCElement.BOP010_P_REPAIR_LOCATION,repairLocationNo));
	331	lists.add(new ReadWriteEntity(OPCElement.BOP010_J_PC_WRITE_ORDER,true));
	332	miloService.writeToOpcUa(lists);
	333	//更新为已经返修上线
	334	Long id = result.getId();
	335	repairManageInfoParam.setId(id);
	336	repairManageInfoParam.setUpPlc("1");
	337	repairManageInfoService.update(repairManageInfoParam);
	338
	339	}else{
	340	logger.info("BOP010工位,handleRepair 请查询"+repairLocation+"工位是否配置返修工位号！");
	341	}
	342	}else{
	343	logger.info("BOP010工位,handleRepair 无法查询到"+repairLocation+"工位！");
	344	}
	345	}
	346	}
	347	}