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();
|
}
|
}
|
}
|
