package com.dy.aceMw.server.tasks;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import com.dy.common.mw.core.CoreTask;
|
import com.dy.common.mw.protocol.MidResult;
|
import com.dy.common.mw.protocol.Command;
|
import com.dy.common.mw.protocol.Driver;
|
import com.dy.common.mw.protocol.ProtocolCache;
|
import com.dy.aceMw.server.ServerProperties;
|
import com.dy.aceMw.server.forTcp.TcpSessionCach;
|
|
/**
|
* 从web业务系统发向RTU的命令任务
|
* @author Administrator
|
*
|
*/
|
public class RtuDownTask extends CoreTask {
|
|
private static Logger log = LogManager.getLogger(RtuDownTask.class.getName());
|
|
@Override
|
public Integer excute() {
|
Command com = (Command)this.data ;
|
try {
|
log.info("下发远程命令" + com.getCode() + "的核心任务开始执行");
|
this.deal(com);
|
} catch (Exception e) {
|
log.error("处理下行命令出错" + (e.getMessage()==null?"!":("，" + e.getMessage())) ,e);
|
}
|
return null ;
|
}
|
|
/**
|
* 处理命令
|
* @param com 命令
|
* @throws Exception
|
*/
|
private void deal(Command com) throws Exception{
|
String rtuAddr = com.getRtuAddr() ;
|
//前面已经判断rtuAddr为空情况，至此其不为空
|
Driver dri = null ;
|
String protocolName = TcpSessionCach.getTcpProtocolName(rtuAddr) ;
|
if(protocolName == null){
|
//RTU未曾上线
|
int count = ProtocolCache.driverCount() ;
|
if(count == 1){
|
//只有一个协议
|
dri = ProtocolCache.getFirstDriver() ;
|
}
|
}else{
|
dri = ProtocolCache.getDriver(protocolName) ;
|
}
|
if(dri == null){
|
log.error("严重错误，未能得到协议" + protocolName + "驱动类实例！");
|
}else{
|
MidResult[] actions = dri.createCommand(ServerProperties.isLowPower, com) ;
|
log.info("下发远程命令" + com.getCode() + "由协议驱动构造完成");
|
if(actions != null){
|
for(MidResult act : actions){
|
act.action();
|
}
|
}
|
}
|
}
|
|
}
|
