package cn.stylefeng.guns.plcserver.server.state.impl;


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.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.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.plcserver.opc.GlobalVariable;
import cn.stylefeng.guns.plcserver.opc.OPCComm;
import cn.stylefeng.guns.plcserver.opc.unit.OPCUnit;
import cn.stylefeng.guns.plcserver.server.OP100.OP100ServerInterface;
import cn.stylefeng.guns.plcserver.server.state.StateServerInterface;
import cn.stylefeng.guns.plcserver.tool.DateTool;
import cn.stylefeng.guns.plcserver.tool.LogUtil;
import org.apache.log4j.Logger;
import org.openscada.opc.lib.da.Group;
import org.openscada.opc.lib.da.Item;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


public class StateServerInterfaceImpl implements StateServerInterface {

    private static Logger logger;
    LogUtil logUtil = new LogUtil();
    static {
        logger = Logger.getLogger(StateServerInterfaceImpl.class);
    }

    private OPCComm opc = OPCComm.getInstance();

    private static String GROUP_NAME  = "STATE_GROUP";//组
    private static List list = null;
    private static Group group = null;

    @Override
    public void monitor() {
        String ecpStr = "";//异常记录标记
        try{
            handleInfo();

        }catch (Exception e) {
            ecpStr ="出现异常：" + logUtil.getTrace(e);
        }finally {
            if(!"".equals(ecpStr)){
                logger.info(ecpStr+"\r\n");
            }
        }
    }


    //PC读参数信息
    public void handleInfo() throws Exception {
        logger.info("OP100工位,handleInfo START！");

        if(null == list /*|| !S_PRODUCT_CODE_OLD.equals(S_PRODUCT_CODE)*/){
            if(group != null){
                opc.getServer().removeGroup(group,true);
            }
            group = opc.getServer().addGroup(GROUP_NAME);

            EquipmentInfoParam equipmentInfoParam = new EquipmentInfoParam();
            EquipmentInfoService equipmentInfoService = opc.equipmentInfoService;
            list = equipmentInfoService.findListBySpec(equipmentInfoParam);

            for(int i=0;i<list.size();i++){
                EquipmentInfoResult result = (EquipmentInfoResult) list.get(i);
                Item item = group.addItem(result.getSpareField1());
                result.setItem(item);
                list.set(i,result);
            }
        }
        if(null != list && list.size()>0) {
            EquipmentStatusService equipmentStatusService = opc.equipmentStatusService;

            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 equipmentAlarmService = opc.equipmentAlarmService;
                            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 equipmentAlarmService = opc.equipmentAlarmService;
                        equipmentAlarmService.add(equipmentAlarmParam);
                    }
                }

            }
        }

    }


}