package cn.stylefeng.guns.plcserver;


import cn.stylefeng.guns.modular.bs.collectionParamConf.service.CollectionParamConfService;
import cn.stylefeng.guns.modular.bs.equipmentInfo.service.EquipmentInfoService;
import cn.stylefeng.guns.modular.bs.locationInfo.service.LocationInfoService;
import cn.stylefeng.guns.modular.cm.paramCollection.service.ParamCollectionService;
import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService;
import cn.stylefeng.guns.modular.dq.materialTraceability.service.MaterialTraceabilityService;
import cn.stylefeng.guns.modular.em.equipmentAlarm.service.EquipmentAlarmService;
import cn.stylefeng.guns.modular.em.equipmentStatus.service.EquipmentStatusService;
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.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.OPCComm;
import cn.stylefeng.guns.plcserver.server.BOP010.BOP010ServerInterface;
import cn.stylefeng.guns.plcserver.server.BOP010.impl.BOP010ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.BOP020.BOP020ServerInterface;
import cn.stylefeng.guns.plcserver.server.BOP020.impl.BOP020ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.BOP030.BOP030ServerInterface;
import cn.stylefeng.guns.plcserver.server.BOP030.impl.BOP030ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.BOP030B.BOP030BServerInterface;
import cn.stylefeng.guns.plcserver.server.BOP030B.impl.BOP030BServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.BOP040.BOP040ServerInterface;
import cn.stylefeng.guns.plcserver.server.BOP040.impl.BOP040ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.BOP040B.BOP040BServerInterface;
import cn.stylefeng.guns.plcserver.server.BOP040B.impl.BOP040BServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.COP010.COP010ServerInterface;
import cn.stylefeng.guns.plcserver.server.COP010.impl.COP010ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.COP020.COP020ServerInterface;
import cn.stylefeng.guns.plcserver.server.COP020.impl.COP020ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.COP030.COP030ServerInterface;
import cn.stylefeng.guns.plcserver.server.COP030.impl.COP030ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.DOP010.DOP010ServerInterface;
import cn.stylefeng.guns.plcserver.server.DOP010.impl.DOP010ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.DOP020.DOP020ServerInterface;
import cn.stylefeng.guns.plcserver.server.DOP020.impl.DOP020ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP010.EOP010ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP010.impl.EOP010ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP020.EOP020ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP020.impl.EOP020ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP030.EOP030ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP030.impl.EOP030ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP040.EOP040ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP040.impl.EOP040ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP050.EOP050ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP050.impl.EOP050ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP060.EOP060ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP060.impl.EOP060ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP070.EOP070ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP070.impl.EOP070ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP070B.EOP070BServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP070B.impl.EOP070BServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP080.EOP080ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP080.impl.EOP080ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP090.EOP090ServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP090.impl.EOP090ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.EOP090B.EOP090BServerInterface;
import cn.stylefeng.guns.plcserver.server.EOP090B.impl.EOP090BServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP010.OP010ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP010.impl.OP010ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP020.OP020ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP020.impl.OP020ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP030.OP030ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP030.impl.OP030ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP040.OP040ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP040.impl.OP040ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP050.OP050ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP050.impl.OP050ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP070.OP070ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP070.impl.OP070ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP080.OP080ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP080.impl.OP080ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP090.OP090ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP090.impl.OP090ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP100.OP100ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP100.impl.OP100ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP110.OP110ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP110.impl.OP110ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP120.OP120ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP120.impl.OP120ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP120B.OP120BServerInterface;
import cn.stylefeng.guns.plcserver.server.OP120B.impl.OP120BServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP130.OP130ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP130.impl.OP130ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP130B.OP130BServerInterface;
import cn.stylefeng.guns.plcserver.server.OP130B.impl.OP130BServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP140.OP140ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP140.impl.OP140ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP150.OP150ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP150.impl.OP150ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP160.OP160ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP160.impl.OP160ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.OP170.OP170ServerInterface;
import cn.stylefeng.guns.plcserver.server.OP170.impl.OP170ServerInterfaceImpl;
import cn.stylefeng.guns.plcserver.server.state.StateServerInterface;
import cn.stylefeng.guns.plcserver.server.state.impl.StateServerInterfaceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@Component
@Order(1)
public class OpcServiceMain  implements CommandLineRunner {
    private OPCComm opc = OPCComm.getInstance();

    @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;

    @Override
    public void run(String... args) throws Exception {
        if(GlobalVariable.TERMINATED) {
            opc.init(productionOrdeInfoService,passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService,
                    equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService,
                    repairManageInfoService,locationInfoService);

            GlobalVariable.PRODUCT_TYPE_MAP.put("191.220001-01","1");
            GlobalVariable.PRODUCT_TYPE_MAP.put("191.220003-01","2");
            GlobalVariable.PRODUCT_TYPE_MAP.put("191.220002-01","3");
            GlobalVariable.PRODUCT_TYPE_MAP.put("191.220004-01","4");

            GlobalVariable.PRODUCT_CODE_MAP.put("1","191.220001-01");
            GlobalVariable.PRODUCT_CODE_MAP.put("2","191.220003-01");
            GlobalVariable.PRODUCT_CODE_MAP.put("3","191.220002-01");
            GlobalVariable.PRODUCT_CODE_MAP.put("4","191.220004-01");

            ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
            cachedThreadPool.execute(new OP010TaskThreadPool());
            cachedThreadPool.execute(new OP020TaskThreadPool());
            cachedThreadPool.execute(new OP030TaskThreadPool());
            cachedThreadPool.execute(new OP040TaskThreadPool());
            cachedThreadPool.execute(new OP050TaskThreadPool());
            cachedThreadPool.execute(new OP070TaskThreadPool());
            cachedThreadPool.execute(new OP080TaskThreadPool());
            cachedThreadPool.execute(new OP090TaskThreadPool());
            cachedThreadPool.execute(new OP100TaskThreadPool());
            cachedThreadPool.execute(new OP110TaskThreadPool());
     /*      cachedThreadPool.execute(new OP120TaskThreadPool());
            cachedThreadPool.execute(new OP120BTaskThreadPool());*/
            cachedThreadPool.execute(new OP130TaskThreadPool());
            cachedThreadPool.execute(new OP130BTaskThreadPool());
            cachedThreadPool.execute(new OP140TaskThreadPool());
            cachedThreadPool.execute(new OP150TaskThreadPool());
            cachedThreadPool.execute(new OP160TaskThreadPool());
            cachedThreadPool.execute(new OP170TaskThreadPool());

            //COP
            cachedThreadPool.execute(new COP010TaskThreadPool());
            cachedThreadPool.execute(new COP020TaskThreadPool());
            cachedThreadPool.execute(new COP030TaskThreadPool());

            //BOP
            cachedThreadPool.execute(new BOP010TaskThreadPool());
            cachedThreadPool.execute(new BOP020TaskThreadPool());
            cachedThreadPool.execute(new BOP030TaskThreadPool());
            cachedThreadPool.execute(new BOP030BTaskThreadPool());
            cachedThreadPool.execute(new BOP040TaskThreadPool());
            cachedThreadPool.execute(new BOP040BTaskThreadPool());

            //DOP
            cachedThreadPool.execute(new DOP010TaskThreadPool());
            cachedThreadPool.execute(new DOP020TaskThreadPool());

            //EOP
            cachedThreadPool.execute(new EOP010TaskThreadPool());
            cachedThreadPool.execute(new EOP020TaskThreadPool());
            cachedThreadPool.execute(new EOP030TaskThreadPool());
            cachedThreadPool.execute(new EOP040TaskThreadPool());
            cachedThreadPool.execute(new EOP050TaskThreadPool());
            cachedThreadPool.execute(new EOP060TaskThreadPool());
            cachedThreadPool.execute(new EOP070TaskThreadPool());
            //cachedThreadPool.execute(new EOP070BTaskThreadPool());

            cachedThreadPool.execute(new EOP080TaskThreadPool());
            cachedThreadPool.execute(new EOP090TaskThreadPool());
            cachedThreadPool.execute(new EOP090BTaskThreadPool());

            cachedThreadPool.execute(new StateTaskThreadPool());
        }
    }

}

class OP010TaskThreadPool implements Runnable {

    private OP010ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP010ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP020TaskThreadPool implements Runnable {

    private OP020ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP020ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}


class OP030TaskThreadPool implements Runnable {

    private OP030ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP030ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP040TaskThreadPool implements Runnable {

    private OP040ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP040ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP050TaskThreadPool implements Runnable {

    private OP050ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP050ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP070TaskThreadPool implements Runnable {

    private OP070ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP070ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP080TaskThreadPool implements Runnable {

    private OP080ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP080ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP090TaskThreadPool implements Runnable {

    private OP090ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP090ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP100TaskThreadPool implements Runnable {

    private OP100ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP100ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP110TaskThreadPool implements Runnable {

    private OP110ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP110ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
class OP120TaskThreadPool implements Runnable {

    private OP120ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP120ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
class OP120BTaskThreadPool implements Runnable {

    private OP120BServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP120BServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP130TaskThreadPool implements Runnable {

    private OP130ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP130ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP130BTaskThreadPool implements Runnable {

    private OP130BServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP130BServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP140TaskThreadPool implements Runnable {

    private OP140ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP140ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP150TaskThreadPool implements Runnable {

    private OP150ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP150ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP160TaskThreadPool implements Runnable {

    private OP160ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP160ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class OP170TaskThreadPool implements Runnable {

    private OP170ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new OP170ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}


class COP010TaskThreadPool implements Runnable {

    private COP010ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new COP010ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}class COP020TaskThreadPool implements Runnable {

    private COP020ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new COP020ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class COP030TaskThreadPool implements Runnable {

    private COP030ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new COP030ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class BOP010TaskThreadPool implements Runnable {

    private BOP010ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new BOP010ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class BOP020TaskThreadPool implements Runnable {

    private BOP020ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new BOP020ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class BOP030TaskThreadPool implements Runnable {

    private BOP030ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new BOP030ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class BOP030BTaskThreadPool implements Runnable {

    private BOP030BServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new BOP030BServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class BOP040TaskThreadPool implements Runnable {

    private BOP040ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new BOP040ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class BOP040BTaskThreadPool implements Runnable {

    private BOP040BServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new BOP040BServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

//EOP
class EOP010TaskThreadPool implements Runnable {

    private EOP010ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP010ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
class EOP020TaskThreadPool implements Runnable {

    private EOP020ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP020ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP030TaskThreadPool implements Runnable {

    private EOP030ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP030ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
class EOP040TaskThreadPool implements Runnable {

    private EOP040ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP040ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
class EOP050TaskThreadPool implements Runnable {

    private EOP050ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP050ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP060TaskThreadPool implements Runnable {

    private EOP060ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP060ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP070TaskThreadPool implements Runnable {

    private EOP070ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP070ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP070BTaskThreadPool implements Runnable {

    private EOP070BServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP070BServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP080TaskThreadPool implements Runnable {

    private EOP080ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP080ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP090TaskThreadPool implements Runnable {

    private EOP090ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP090ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class EOP090BTaskThreadPool implements Runnable {

    private EOP090BServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new EOP090BServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class DOP010TaskThreadPool implements Runnable {

    private DOP010ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new DOP010ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class DOP020TaskThreadPool implements Runnable {

    private DOP020ServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new DOP020ServerInterfaceImpl();
                server.monitor();
                Thread.sleep(GlobalVariable.SLEEP_TIME);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

class StateTaskThreadPool implements Runnable {

    private StateServerInterface server;

    public void run() {
        try {
            while (GlobalVariable.TERMINATED) {
                server = new StateServerInterfaceImpl();
                server.monitor();
                Thread.sleep(30*1000);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}