| | |
|---|
| | | this.task.forceOver(); |
|---|
| | | } |
|---|
| | | this.task = new UpgradeTask(); |
|---|
| | | this.task.initOption(this.lastOpenMaxGoOn, this.failTryTimes, this.ugMaxRtuSameTime); |
|---|
| | | this.task.initOption(this.openNoUpgrade, this.lastOpenMaxGoOn, this.failTryTimes, this.ugMaxRtuSameTime); |
|---|
| | | this.task.setTask(vo); |
|---|
| | | this.nowNotifyTimesAfterOver = 0 ; |
|---|
| | | this.monitorFirst = true ; |
|---|
| | |
|---|
| | | * @param protocolVersion 上行数据对应的协议版本号 |
|---|
| | | * @param callbackCom 回调函数，处理下行命令 |
|---|
| | | */ |
|---|
| | | public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callbackCom){ |
|---|
| | | public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callbackCom, Object ...objects){ |
|---|
| | | if(task != null && !task.taskIsOver){ |
|---|
| | | this.task.trigger(rtuAddr, code, protocolName, protocolVersion, callbackCom); |
|---|
| | | this.task.trigger(rtuAddr, code, protocolName, protocolVersion, callbackCom, objects); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
