|
|
@ -30,131 +30,127 @@ import java.util.Map; |
|
|
@Service |
|
|
@Service |
|
|
public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoInitial { |
|
|
public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoInitial { |
|
|
|
|
|
|
|
|
private static final Logger log = LoggerFactory.getLogger(OpcServerServiceImpl.class); |
|
|
private static final Logger log = LoggerFactory.getLogger(OpcServerServiceImpl.class); |
|
|
@Autowired |
|
|
@Autowired OpcServerManageService opcServerManageService; |
|
|
OpcServerManageService opcServerManageService; |
|
|
Map<String, OpcServerManageDto> opcServerManageDtos = new HashMap(); |
|
|
Map<String, OpcServerManageDto> opcServerManageDtos = new HashMap(); |
|
|
Map<String, Server> servers = Collections.synchronizedMap(new HashMap()); |
|
|
Map<String, Server> servers = Collections.synchronizedMap(new HashMap()); |
|
|
Map<String, Group> groups = Collections.synchronizedMap(new HashMap()); |
|
|
Map<String, Group> groups = Collections.synchronizedMap(new HashMap()); |
|
|
|
|
|
|
|
|
public OpcServerServiceImpl() {} |
|
|
public OpcServerServiceImpl() { |
|
|
|
|
|
|
|
|
public void autoInitial() throws Exception { |
|
|
|
|
|
this.reload(); |
|
|
|
|
|
if (OpcConfig.auto_start_opc) { |
|
|
|
|
|
Thread t = |
|
|
|
|
|
new Thread() { |
|
|
|
|
|
public void run() { |
|
|
|
|
|
Iterator var1 = OpcServerServiceImpl.this.opcServerManageDtos.values().iterator(); |
|
|
|
|
|
|
|
|
|
|
|
while (var1.hasNext()) { |
|
|
|
|
|
OpcServerManageDto dto = (OpcServerManageDto) var1.next(); |
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
|
OpcServerServiceImpl.this.getServer(dto.getOpc_code()); |
|
|
|
|
|
OpcServerServiceImpl.log.info("加载opc server {}", dto.getOpc_code()); |
|
|
|
|
|
} catch (Exception var4) { |
|
|
|
|
|
OpcServerServiceImpl.log.warn("启动无法载入servers", var4); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
}; |
|
|
|
|
|
t.start(); |
|
|
} |
|
|
} |
|
|
|
|
|
} |
|
|
/** |
|
|
|
|
|
* 加载opc服务，启动opc线程 |
|
|
public synchronized void reload() { |
|
|
* @throws Exception |
|
|
this.opcServerManageDtos = this.opcServerManageService.queryAllServerMap(); |
|
|
*/ |
|
|
this.opcServerManageDtos = Collections.synchronizedMap(this.opcServerManageDtos); |
|
|
public void autoInitial() throws Exception { |
|
|
} |
|
|
this.reload(); // 加载opc服务
|
|
|
|
|
|
if (OpcConfig.auto_start_opc) { |
|
|
public synchronized Group getServer(String code) { |
|
|
Thread t = |
|
|
Group group = null; |
|
|
new Thread(() -> { |
|
|
group = (Group) this.groups.get(code); |
|
|
Iterator var1 = OpcServerServiceImpl.this.opcServerManageDtos.values().iterator(); |
|
|
if (group != null) { |
|
|
|
|
|
try { |
|
|
while (var1.hasNext()) { |
|
|
if (group.isActive()) { |
|
|
OpcServerManageDto dto = (OpcServerManageDto) var1.next(); |
|
|
return group; |
|
|
|
|
|
|
|
|
try { |
|
|
|
|
|
OpcServerServiceImpl.this.getServer(dto.getOpc_code()); |
|
|
|
|
|
OpcServerServiceImpl.log.info("加载opc server {}", dto.getOpc_code()); |
|
|
|
|
|
} catch (Exception var4) { |
|
|
|
|
|
OpcServerServiceImpl.log.warn("启动无法载入servers", var4); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
t.start(); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
} catch (JIException var9) { |
|
|
|
|
|
var9.printStackTrace(); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public synchronized void reload() { |
|
|
Server server = (Server) this.servers.get(code); |
|
|
this.opcServerManageDtos = this.opcServerManageService.queryAllServerMap(); |
|
|
boolean needcreate = false; |
|
|
this.opcServerManageDtos = Collections.synchronizedMap(this.opcServerManageDtos); |
|
|
if (server == null) { |
|
|
|
|
|
needcreate = true; |
|
|
|
|
|
} else { |
|
|
|
|
|
try { |
|
|
|
|
|
group = server.findGroup(OpcConfig.opc_server_default_group); |
|
|
|
|
|
} catch (UnknownHostException |
|
|
|
|
|
| JIException |
|
|
|
|
|
| UnknownGroupException |
|
|
|
|
|
| NotConnectedException |
|
|
|
|
|
| IllegalArgumentException var8) { |
|
|
|
|
|
var8.printStackTrace(); |
|
|
|
|
|
needcreate = true; |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public synchronized Group getServer(String code) { |
|
|
if (needcreate) { |
|
|
Group group = null; |
|
|
OpcServerManageDto dto = (OpcServerManageDto) this.opcServerManageDtos.get(code); |
|
|
group = (Group) this.groups.get(code); |
|
|
if (dto == null) { |
|
|
if (group != null) { |
|
|
throw new BadRequestException("code 不存在"); |
|
|
try { |
|
|
} |
|
|
if (group.isActive()) { |
|
|
|
|
|
return group; |
|
|
|
|
|
} |
|
|
|
|
|
} catch (JIException var9) { |
|
|
|
|
|
var9.printStackTrace(); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
Server server = (Server) this.servers.get(code); |
|
|
server = OpcServerUtl.getServerWithOutException( |
|
|
boolean needcreate = false; |
|
|
dto.getOpc_host(), |
|
|
if (server == null) { |
|
|
dto.getCls_id(), |
|
|
needcreate = true; |
|
|
dto.getUser(), |
|
|
} else { |
|
|
dto.getPassword(), |
|
|
try { |
|
|
dto.getDomain()); |
|
|
group = server.findGroup(OpcConfig.opc_server_default_group); |
|
|
|
|
|
} catch (UnknownHostException |
|
|
|
|
|
| JIException |
|
|
|
|
|
| UnknownGroupException |
|
|
|
|
|
| NotConnectedException |
|
|
|
|
|
| IllegalArgumentException var8) { |
|
|
|
|
|
var8.printStackTrace(); |
|
|
|
|
|
needcreate = true; |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (needcreate) { |
|
|
|
|
|
OpcServerManageDto dto = (OpcServerManageDto) this.opcServerManageDtos.get(code); |
|
|
|
|
|
if (dto == null) { |
|
|
|
|
|
throw new BadRequestException("code 不存在"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
server = OpcServerUtl.getServerWithOutException( |
|
|
|
|
|
dto.getOpc_host(), |
|
|
|
|
|
dto.getCls_id(), |
|
|
|
|
|
dto.getUser(), |
|
|
|
|
|
dto.getPassword(), |
|
|
|
|
|
dto.getDomain()); |
|
|
|
|
|
|
|
|
|
|
|
// server = OpcServerUtl.getServerWithOutException(this.OpcServer.getOpc_host(), this.OpcServer.getCls_id(), this.OpcServer.getUser(), this.OpcServer.getPassword(), this.OpcServer.getDomain());
|
|
|
// server = OpcServerUtl.getServerWithOutException(this.OpcServer.getOpc_host(), this.OpcServer.getCls_id(), this.OpcServer.getUser(), this.OpcServer.getPassword(), this.OpcServer.getDomain());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
try { |
|
|
group = server.addGroup(OpcConfig.opc_server_default_group); |
|
|
group = server.addGroup(OpcConfig.opc_server_default_group); |
|
|
} catch (Exception var7) { |
|
|
} catch (Exception var7) { |
|
|
throw new BadRequestException(var7.toString()); |
|
|
throw new BadRequestException(var7.toString()); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
this.servers.put(code, server); |
|
|
|
|
|
this.groups.put(code, group); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return group; |
|
|
this.servers.put(code, server); |
|
|
|
|
|
this.groups.put(code, group); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public synchronized void clearServer(String code) { |
|
|
return group; |
|
|
try { |
|
|
} |
|
|
Server server = (Server) this.servers.get(code); |
|
|
|
|
|
if (server != null) { |
|
|
|
|
|
server.disconnect(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) { |
|
|
public synchronized void clearServer(String code) { |
|
|
e.printStackTrace(); |
|
|
try { |
|
|
log.error("清理server异常,", e.getMessage()); |
|
|
Server server = (Server) this.servers.get(code); |
|
|
} |
|
|
if (server!=null){ |
|
|
|
|
|
server.disconnect(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
this.servers.remove(code); |
|
|
} catch (Exception e) { |
|
|
this.groups.remove(code); |
|
|
e.printStackTrace(); |
|
|
|
|
|
log.error("清理server异常,",e.getMessage()); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public void writeInteger(String code, ItemValue... values) { |
|
|
this.servers.remove(code); |
|
|
try { |
|
|
this.groups.remove(code); |
|
|
Group group = this.getServer(code); |
|
|
} |
|
|
OpcUtl.writeValue(group, values); |
|
|
|
|
|
} catch (Exception var4) { |
|
|
public void writeInteger(String code, ItemValue... values) { |
|
|
this.clearServer(code); |
|
|
try { |
|
|
log.warn("写入出错opc server {} 重新加载", code, var4); |
|
|
Group group = this.getServer(code); |
|
|
ThreadUtl.sleep(5000L); |
|
|
OpcUtl.writeValue(group, values); |
|
|
throw var4; |
|
|
} catch (Exception var4) { |
|
|
} |
|
|
this.clearServer(code); |
|
|
|
|
|
log.warn("写入出错opc server {} 重新加载", code, var4); |
|
|
|
|
|
ThreadUtl.sleep(5000L); |
|
|
|
|
|
throw var4; |
|
|
} |
|
|
} |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
psh
2 years ago