midea.git - Gitblit

cheng

2023-12-12 c64c9f6fb38f65be99b827c1af8d3c3852f68ba4

提交 \| 用户 \| 时间
71e81e	1	package cn.stylefeng.guns.plcserver.server.DOP020.impl;
懒	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.cm.paramCollection.model.params.ParamCollectionParam;
	8	import cn.stylefeng.guns.modular.cm.paramCollection.service.ParamCollectionService;
	9	import cn.stylefeng.guns.modular.cm.passingStationCollection.model.params.PassingStationCollectionParam;
	10	import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService;
c64c9f	11	import cn.stylefeng.guns.modular.gm.greaseManage.model.params.GreaseManageParam;
C	12	import cn.stylefeng.guns.modular.gm.greaseManage.model.result.GreaseManageResult;
	13	import cn.stylefeng.guns.modular.gm.greaseManage.service.GreaseManageService;
71e81e	14	import cn.stylefeng.guns.plcserver.opc.GlobalVariable;
懒	15	import cn.stylefeng.guns.plcserver.opc.OPCComm;
	16	import cn.stylefeng.guns.plcserver.opc.unit.OPCUnit;
	17
	18	import cn.stylefeng.guns.plcserver.server.DOP020.DOP020ServerInterface;
	19	import cn.stylefeng.guns.plcserver.tool.DateTool;
	20	import cn.stylefeng.guns.plcserver.tool.LogUtil;
	21	import org.apache.log4j.Logger;
	22	import org.openscada.opc.lib.da.Group;
	23	import org.openscada.opc.lib.da.Item;
	24
c64c9f	25	import java.time.LocalDate;
C	26	import java.time.temporal.ChronoUnit;
71e81e	27	import java.util.Date;
懒	28	import java.util.List;
	29
	30
	31	public class DOP020ServerInterfaceImpl implements DOP020ServerInterface {
	32
	33	private static Logger logger;
	34	LogUtil logUtil = new LogUtil();
	35	static {
	36	logger = Logger.getLogger(DOP020ServerInterfaceImpl.class);
	37	}
	38
	39	private OPCComm opc = OPCComm.getInstance();
	40	private static Date IN_TIME = null;
	41	private static String S_ORDER_CODE = "";//工单编号
	42	private static String S_PRODUCT_CODE = "";//产品编号
	43	private static String S_PRODUCT_TYPE= "";//产品类型
	44	private static String S_PRODUCT_CODE_OLD = "";//产品编号
	45	private static String S_SFC_CODE = "";//总成编码
	46	private static String S_RIGHT_CODE = "";//右壳体编码
	47	private static String PRODUCTION_LINE = "EOP";//产线号
	48	private static String LOCATION_CODE = "DOP020";//工位号
	49	private static String GROUP_NAME = "DOP020_P";//组名
	50	private static List list = null;
	51	private static Group group = null;
	52	@Override
	53	public synchronized void monitor() {
	54	String ecpStr = "";//异常记录标记
	55	try{
	56	if(GlobalVariable.DOP020_F_HEART_BEAT) {
	57	//PC读工单
	58	String isPLCStart = OPCUnit.read(opc.getDOP020_J_PLC_START());//PLC开始
	59	if(isPLCStart.equals("true")){
	60	String isFinish = OPCUnit.read(opc.getDOP020_J_PC_WRITE_ORDER());//PC下发工单完成
	61	if(isFinish.equals("false")){
	62	handleOrder();
	63	}
	64	}
	65
	66
	67	//PC完成
	68	String isPLCFinish = OPCUnit.read(opc.getDOP020_J_PLC_FINISH());//PLC完成
	69	if(isPLCFinish.equals("true")){
	70	String isFinish = OPCUnit.read(opc.getDOP020_J_PC_FINISH());//PC操作完成
	71	if(isFinish.equals("false")){
	72	handleInfo();
	73	handleFinsh();
	74	}
	75	}
c64c9f	76	handleOilState();
71e81e	77	}else{
懒	78	logger.info("DOP020工位与PLC断开,请检查PLC或网络是否异常！");
	79	}
	80
	81	}catch (Exception e) {
	82	ecpStr ="出现异常：" + logUtil.getTrace(e);
	83	}finally {
	84	if(!"".equals(ecpStr)){
	85	logger.info(ecpStr+"\r\n");
	86	}
	87	}
	88	}
	89
c64c9f	90	public void handleOilState(){
C	91	GreaseManageParam param = new GreaseManageParam();
	92	GreaseManageService greaseManageService = opc.greaseManageService;
	93	param.setLocationCode(LOCATION_CODE);
	94	List<GreaseManageResult> list = greaseManageService.findListBySpec(param);
	95	if(list.size()>0) {
	96	String duaDate = list.get(0).getDuaDate();
	97	LocalDate date1 = LocalDate.parse(duaDate); // 第一个日期
	98	LocalDate date2 = LocalDate.now(); // 当前日期（或者指定其他日期）
	99
	100	long daysBetween = ChronoUnit.DAYS.between(date1, date2);
	101
	102	if(daysBetween>0){
	103	OPCUnit.write(opc.getOP050_OIL_STATE(), "false"); //写油脂状态
	104	}else{
	105	OPCUnit.write(opc.getOP050_OIL_STATE(), "true"); //写油脂状态
	106	}
	107	logger.info("到期日期："+date1+"当前日期："+date1+"剩余天数：："+daysBetween);
	108	}
	109	}
	110
71e81e	111	//PC读工单
懒	112	public void handleOrder() {
	113	IN_TIME = DateTool.getLocalTimeForDate();
	114	S_ORDER_CODE = OPCUnit.read(opc.getDOP020_S_ORDER_CODE());//工单编号
	115	S_PRODUCT_TYPE = OPCUnit.read(opc.getDOP020_S_PRODUCT_CODE());//产品编号
	116	S_PRODUCT_CODE = GlobalVariable.PRODUCT_CODE_MAP.get(S_PRODUCT_TYPE);
	117	S_SFC_CODE = OPCUnit.read(opc.getDOP020_S_SFC_CODE());//总成编码
	118	OPCUnit.write(opc.getDOP020_J_PC_WRITE_ORDER(), "true"); //PC读工单完成
	119	logger.info("DOP020工位,handleOrder PC处理完成！");
	120	}
	121
	122	//PC读参数信息
	123	public void handleInfo() throws Exception {
	124	logger.info("DOP020工位,handleInfo START！");
	125
	126	if(null == list /\|\| !S_PRODUCT_CODE_OLD.equals(S_PRODUCT_CODE)/){
	127	if(group != null){
	128	opc.getServer().removeGroup(group,true);
	129	}
	130	group = opc.getServer().addGroup(GROUP_NAME);
	131
	132	CollectionParamConfParam collectionParamConfParam = new CollectionParamConfParam();
	133	//collectionParamConfParam.setProductCode(S_PRODUCT_CODE);
	134	collectionParamConfParam.setLocationCode(LOCATION_CODE);
	135	CollectionParamConfService collectionParamConfService = opc.collectionParamConfService;
	136	list = collectionParamConfService.findListBySpec(collectionParamConfParam);
	137
	138
	139	for(int i=0;i<list.size();i++){
	140	CollectionParamConfResult result = (CollectionParamConfResult) list.get(i);
	141	Item item = group.addItem(result.getGatherAddress());
	142	result.setItem(item);
	143	list.set(i,result);
	144	}
	145	//S_PRODUCT_CODE_OLD = S_PRODUCT_CODE;
	146	}
	147
	148	if(null != list && list.size()>0) {
	149	ParamCollectionService paramCollectionService = opc.paramCollectionService;
	150	for (int i = 0; i < list.size(); i++) {
	151	CollectionParamConfResult result = (CollectionParamConfResult) list.get(i);
	152	Item item = result.getItem();
	153	String value = OPCUnit.read(item);//读参数值
	154	ParamCollectionParam paramCollectionParam = new ParamCollectionParam();
	155	paramCollectionParam.setParamCode(result.getParamCode());
	156	paramCollectionParam.setParamName(result.getParamName());
	157	paramCollectionParam.setWorkOrderNo(S_ORDER_CODE);
	158	paramCollectionParam.setSfcCode(S_SFC_CODE);
	159	paramCollectionParam.setProductCode(S_PRODUCT_CODE);
	160	paramCollectionParam.setProductionLine(result.getProductionLine());
	161	paramCollectionParam.setLocationCode(result.getLocationCode());
	162	paramCollectionParam.setParamValue(value);
	163	paramCollectionParam.setParamLower(result.getParamLower());
	164	paramCollectionParam.setParamUpper(result.getParamUpper());
	165	paramCollectionParam.setParamStandard(result.getParamCentral());
	166	paramCollectionParam.setCollectionTime(DateTool.getLocalTimeForDate());
	167	paramCollectionParam.setUnit(result.getUnit());
	168	paramCollectionService.add(paramCollectionParam);
	169	}
	170	}
	171
	172	logger.info("DOP020工位,handleInfo END！");
	173	}
	174
	175	//PC完成
	176	public void handleFinsh() {
	177	if("".equals(S_ORDER_CODE)){
	178	IN_TIME = DateTool.getLocalTimeForDate();
	179	S_ORDER_CODE = OPCUnit.read(opc.getDOP020_S_ORDER_CODE());//工单编号
	180	S_PRODUCT_TYPE = OPCUnit.read(opc.getDOP020_S_PRODUCT_CODE());//产品编号
	181	S_PRODUCT_CODE = GlobalVariable.PRODUCT_CODE_MAP.get(S_PRODUCT_TYPE);
	182	S_SFC_CODE = OPCUnit.read(opc.getDOP020_S_SFC_CODE());//总成编码
	183	}
	184	//处理过站信息
	185	String S_PRODUCT_STATE_CODE = OPCUnit.read(opc.getDOP020_S_PRODUCT_STATE_CODE());
	186	PassingStationCollectionParam param = new PassingStationCollectionParam();
	187	param.setWorkOrderNo(S_ORDER_CODE);
	188	param.setProductCode(S_PRODUCT_CODE);
	189	param.setSfcCode(S_SFC_CODE);
	190	param.setProductionLine(PRODUCTION_LINE);
	191	param.setLocationCode(LOCATION_CODE);
	192	param.setInboundTime(IN_TIME);
	193	param.setOutboundTime(DateTool.getLocalTimeForDate());
	194	param.setOutRsSign(S_PRODUCT_STATE_CODE);//出站是否合格
	195	PassingStationCollectionService passingStationCollectionService = opc.passingStationCollectionService;
	196	passingStationCollectionService.add(param);
	197
	198	OPCUnit.write(opc.getDOP020_J_PC_FINISH(), "true"); //PC完成
	199
	200	logger.info("DOP020工位,handleFinsh PC处理完成！");
	201	}
	202
	203	}