package cn.stylefeng.guns.plcserver.callback;
|
|
|
import cn.stylefeng.guns.modular.bs.collectionParamConf.model.params.CollectionParamConfParam;
|
import cn.stylefeng.guns.modular.bs.collectionParamConf.model.result.CollectionParamConfResult;
|
import cn.stylefeng.guns.modular.bs.collectionParamConf.service.CollectionParamConfService;
|
import cn.stylefeng.guns.modular.bs.equipmentInfo.model.params.EquipmentInfoParam;
|
import cn.stylefeng.guns.modular.bs.equipmentInfo.model.result.EquipmentInfoResult;
|
import cn.stylefeng.guns.modular.bs.equipmentInfo.service.EquipmentInfoService;
|
import cn.stylefeng.guns.modular.bs.locationInfo.model.params.LocationInfoParam;
|
import cn.stylefeng.guns.modular.bs.locationInfo.model.result.LocationInfoResult;
|
import cn.stylefeng.guns.modular.bs.locationInfo.service.LocationInfoService;
|
import cn.stylefeng.guns.modular.cm.paramCollection.model.params.ParamCollectionParam;
|
import cn.stylefeng.guns.modular.cm.paramCollection.service.ParamCollectionService;
|
import cn.stylefeng.guns.modular.cm.passingStationCollection.model.params.PassingStationCollectionParam;
|
import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService;
|
import cn.stylefeng.guns.modular.dq.materialTraceability.model.params.MaterialTraceabilityParam;
|
import cn.stylefeng.guns.modular.dq.materialTraceability.service.MaterialTraceabilityService;
|
import cn.stylefeng.guns.modular.em.equipmentAlarm.model.params.EquipmentAlarmParam;
|
import cn.stylefeng.guns.modular.em.equipmentAlarm.service.EquipmentAlarmService;
|
import cn.stylefeng.guns.modular.em.equipmentStatus.model.params.EquipmentStatusParam;
|
import cn.stylefeng.guns.modular.em.equipmentStatus.model.result.EquipmentStatusResult;
|
import cn.stylefeng.guns.modular.em.equipmentStatus.service.EquipmentStatusService;
|
import cn.stylefeng.guns.modular.gm.greaseManage.model.params.GreaseManageParam;
|
import cn.stylefeng.guns.modular.gm.greaseManage.model.result.GreaseManageResult;
|
import cn.stylefeng.guns.modular.gm.greaseManage.service.GreaseManageService;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.params.ProductionOrdeInfoParam;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.result.ProductionOrdeInfoResult;
|
import cn.stylefeng.guns.modular.om.productionOrdeInfo.service.ProductionOrdeInfoService;
|
import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.model.params.ProductionOrderBatchInfoParam;
|
import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.model.result.ProductionOrderBatchInfoResult;
|
import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.service.ProductionOrderBatchInfoService;
|
import cn.stylefeng.guns.modular.om.productionOrderRecords.service.ProductionOrderRecordsService;
|
import cn.stylefeng.guns.modular.sc.repairManageInfo.model.params.RepairManageInfoParam;
|
import cn.stylefeng.guns.modular.sc.repairManageInfo.model.result.RepairManageInfoResult;
|
import cn.stylefeng.guns.modular.sc.repairManageInfo.service.RepairManageInfoService;
|
import cn.stylefeng.guns.modular.sc.serialNumbersConf.service.SerialNumbersConfService;
|
import cn.stylefeng.guns.plcserver.opc.GlobalVariable;
|
import cn.stylefeng.guns.plcserver.opc.OPCElement;
|
import cn.stylefeng.guns.plcserver.opc.unit.OPCUnit;
|
import cn.stylefeng.guns.plcserver.tool.DateTool;
|
import cn.stylefeng.guns.plcserver.tool.LogUtil;
|
import com.kangaroohy.milo.model.ReadWriteEntity;
|
import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
|
import com.kangaroohy.milo.service.MiloService;
|
import org.apache.log4j.Logger;
|
import org.openscada.opc.lib.da.Item;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.time.format.DateTimeFormatter;
|
import java.time.temporal.ChronoUnit;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Random;
|
|
@Component
|
public class StateCallback implements SubscriptionCallback {
|
|
public MiloService miloService;
|
|
@Autowired
|
public ProductionOrdeInfoService productionOrdeInfoService;
|
@Autowired
|
public PassingStationCollectionService passingStationCollectionService;
|
@Autowired
|
public ParamCollectionService paramCollectionService;
|
@Autowired
|
public CollectionParamConfService collectionParamConfService;
|
@Autowired
|
public SerialNumbersConfService serialNumbersConfService;
|
@Autowired
|
private EquipmentStatusService equipmentStatusService;
|
|
@Autowired
|
private EquipmentAlarmService equipmentAlarmService;
|
@Autowired
|
private MaterialTraceabilityService materialTraceabilityService;
|
@Autowired
|
private EquipmentInfoService equipmentInfoService;
|
@Autowired
|
private RepairManageInfoService repairManageInfoService;
|
|
@Autowired
|
private LocationInfoService locationInfoService;
|
|
@Autowired
|
private GreaseManageService greaseManageService;
|
|
@Autowired
|
private ProductionOrderRecordsService productionOrderRecordsService;
|
|
@Autowired
|
private ProductionOrderBatchInfoService productionOrderBatchInfoService;
|
|
private static Logger logger;
|
LogUtil logUtil = new LogUtil();
|
static {
|
logger = Logger.getLogger(StateCallback.class);
|
}
|
private static Date IN_TIME = null;
|
private static String S_ORDER_CODE = "";//工单编号
|
private static String S_PRODUCT_CODE = "";//产品编号
|
private static String S_PRODUCT_TYPE= "";//产品类型
|
private static String S_SFC_CODE = "";//总成编码
|
private static String PRODUCTION_LINE = "BOP";//产线号
|
private static String LOCATION_CODE = "BOP010";//工位号
|
private static List list = null;
|
|
public StateCallback(MiloService miloService,
|
ProductionOrdeInfoService productionOrdeInfoService,
|
PassingStationCollectionService passingStationCollectionService,
|
ParamCollectionService paramCollectionService,
|
CollectionParamConfService collectionParamConfService,
|
SerialNumbersConfService serialNumbersConfService,
|
EquipmentStatusService equipmentStatusService,
|
EquipmentAlarmService equipmentAlarmService,
|
MaterialTraceabilityService materialTraceabilityService,
|
EquipmentInfoService equipmentInfoService,
|
RepairManageInfoService repairManageInfoService,
|
LocationInfoService locationInfoService,
|
GreaseManageService greaseManageService,
|
ProductionOrderRecordsService productionOrderRecordsService,
|
ProductionOrderBatchInfoService productionOrderBatchInfoService) {
|
this.miloService = miloService;
|
this.productionOrdeInfoService = productionOrdeInfoService;
|
this.passingStationCollectionService = passingStationCollectionService;
|
this.paramCollectionService = paramCollectionService;
|
this.collectionParamConfService = collectionParamConfService;
|
this.serialNumbersConfService = serialNumbersConfService;
|
this.equipmentStatusService = equipmentStatusService;
|
this.equipmentAlarmService = equipmentAlarmService;
|
this.materialTraceabilityService = materialTraceabilityService;
|
this.equipmentInfoService = equipmentInfoService;
|
this.repairManageInfoService = repairManageInfoService;
|
this.locationInfoService = locationInfoService;
|
this.greaseManageService = greaseManageService;
|
this.productionOrderRecordsService = productionOrderRecordsService;
|
this.productionOrderBatchInfoService = productionOrderBatchInfoService;
|
}
|
@Override
|
public void onSubscribe(String identifier, Object value) {
|
String ecpStr = "";//异常记录标记
|
try {
|
handleInfo();
|
} catch (Exception e) {
|
ecpStr ="出现异常：" + logUtil.getTrace(e);
|
}finally {
|
if(!"".equals(ecpStr)){
|
logger.info(ecpStr+"\r\n");
|
}
|
}
|
}
|
public void handleInfo() throws Exception {
|
logger.info("OP100工位,handleInfo START！");
|
|
if(null == list ){
|
EquipmentInfoParam equipmentInfoParam = new EquipmentInfoParam();
|
list = equipmentInfoService.findListBySpec(equipmentInfoParam);
|
}
|
if(null != list && list.size()>0) {
|
for (int i = 0; i < list.size(); i++) {
|
EquipmentInfoResult result = (EquipmentInfoResult) list.get(i);
|
Item item = result.getItem();
|
String value = OPCUnit.read(item);//读参数值 设备状态
|
String equipmentNo = result.getEquipmentNo();
|
|
EquipmentStatusParam equipmentStatusParam = new EquipmentStatusParam();
|
equipmentStatusParam.setEquipmentNo(equipmentNo);
|
List statuslist = equipmentStatusService.findListBySpec(equipmentStatusParam);
|
if(statuslist.size()>0){
|
EquipmentStatusResult equipmentStatusResult = (EquipmentStatusResult) statuslist.get(0);
|
if(!value.equals(equipmentStatusResult.getStatus())){
|
equipmentStatusParam.setId(equipmentStatusResult.getId());
|
equipmentStatusParam.setStatus(value);
|
equipmentStatusParam.setUpdateTime(DateTool.getLocalTimeForDate());
|
equipmentStatusService.update(equipmentStatusParam);//更新设备状态
|
|
//添加设备报警
|
if("3".equals(value)){
|
EquipmentAlarmParam equipmentAlarmParam = new EquipmentAlarmParam();
|
equipmentAlarmParam.setEquipmentNo(equipmentNo);
|
equipmentAlarmParam.setEquipmentName(result.getEquipmentName());
|
equipmentAlarmParam.setWorkshopCode(result.getWorkshopCode());
|
equipmentAlarmParam.setProductionLineCode(result.getProductionLineCode());
|
equipmentAlarmParam.setLocationCode(result.getLocationCode());
|
equipmentAlarmParam.setErrorDesc(result.getEquipmentName()+"报警！");
|
equipmentAlarmParam.setAlarmTime(DateTool.getLocalTimeForDate());
|
equipmentAlarmService.add(equipmentAlarmParam);
|
}
|
}
|
|
}else{
|
equipmentStatusParam.setEquipmentName(result.getEquipmentName());
|
equipmentStatusParam.setWorkshopCode(result.getWorkshopCode());
|
equipmentStatusParam.setProductionLineCode(result.getProductionLineCode());
|
equipmentStatusParam.setLocationCode(result.getLocationCode());
|
equipmentStatusParam.setStatus(value);
|
equipmentStatusParam.setUpdateTime(DateTool.getLocalTimeForDate());
|
equipmentStatusService.add(equipmentStatusParam);
|
|
//添加设备报警
|
if("3".equals(value)){
|
EquipmentAlarmParam equipmentAlarmParam = new EquipmentAlarmParam();
|
equipmentAlarmParam.setEquipmentNo(equipmentNo);
|
equipmentAlarmParam.setEquipmentName(result.getEquipmentName());
|
equipmentAlarmParam.setWorkshopCode(result.getWorkshopCode());
|
equipmentAlarmParam.setProductionLineCode(result.getProductionLineCode());
|
equipmentAlarmParam.setLocationCode(result.getLocationCode());
|
equipmentAlarmParam.setErrorDesc(result.getEquipmentName()+"报警！");
|
equipmentAlarmParam.setAlarmTime(DateTool.getLocalTimeForDate());
|
equipmentAlarmService.add(equipmentAlarmParam);
|
}
|
}
|
|
}
|
}
|
|
|
Thread.sleep(60*1000);
|
}
|
|
public void handleOilStateDOP020(String LOCATION_CODE) throws Exception {
|
GreaseManageParam param = new GreaseManageParam();
|
param.setLocationCode(LOCATION_CODE);
|
List<GreaseManageResult> list = greaseManageService.findListBySpec(param);
|
if(!list.isEmpty()) {
|
String duaDate = list.get(0).getDuaDate();
|
|
SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
|
String currentDate = format.format(new Date());
|
long daysBetween = getRemainder(currentDate,duaDate);
|
if(daysBetween>0){
|
ReadWriteEntity entity = new ReadWriteEntity(OPCElement.DOP020_OIL_STATE,false);
|
miloService.writeToOpcUa(entity);//写PC完成
|
}else{
|
ReadWriteEntity entity = new ReadWriteEntity(OPCElement.DOP020_OIL_STATE,true);
|
miloService.writeToOpcUa(entity);//写PC完成
|
}
|
}
|
}
|
|
public void handleOilStateOP050(String LOCATION_CODE) throws Exception {
|
GreaseManageParam param = new GreaseManageParam();
|
param.setLocationCode(LOCATION_CODE);
|
List<GreaseManageResult> list = greaseManageService.findListBySpec(param);
|
if(!list.isEmpty()) {
|
String duaDate = list.get(0).getDuaDate();
|
|
SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
|
String currentDate = format.format(new Date());
|
long daysBetween = getRemainder(currentDate,duaDate);
|
if(daysBetween>0){
|
ReadWriteEntity entity = new ReadWriteEntity(OPCElement.OP050_OIL_STATE,false);
|
miloService.writeToOpcUa(entity);//写PC完成
|
}else{
|
ReadWriteEntity entity = new ReadWriteEntity(OPCElement.OP050_OIL_STATE,true);
|
miloService.writeToOpcUa(entity);//写PC完成
|
}
|
}
|
}
|
|
public void handleOilStateBOP030(String LOCATION_CODE) throws Exception {
|
GreaseManageParam param = new GreaseManageParam();
|
param.setLocationCode(LOCATION_CODE);
|
List<GreaseManageResult> list = greaseManageService.findListBySpec(param);
|
if(!list.isEmpty()) {
|
String duaDate = list.get(0).getDuaDate();
|
|
SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
|
String currentDate = format.format(new Date());
|
long daysBetween = getRemainder(currentDate,duaDate);
|
if(daysBetween>0){
|
ReadWriteEntity entity = new ReadWriteEntity(OPCElement.BOP030_OIL_STATE,false);
|
miloService.writeToOpcUa(entity);//写PC完成
|
}else{
|
ReadWriteEntity entity = new ReadWriteEntity(OPCElement.BOP030_OIL_STATE,true);
|
miloService.writeToOpcUa(entity);//写PC完成
|
}
|
}
|
}
|
|
public static long getRemainder(String currentDate,String tableDate){
|
DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyyMMdd");
|
LocalDate localDate1 = LocalDate.parse(currentDate, dateFormatter);
|
LocalDate localDate2 = LocalDate.parse(tableDate, dateFormatter);
|
long days = ChronoUnit.DAYS.between(localDate1, localDate2);
|
return days;
|
}
|
}
|
