|
@@ -1,6 +1,7 @@
|
|
|
package manager
|
|
|
|
|
|
import (
|
|
|
+ "fmt"
|
|
|
"sparrow/pkg/rpcs"
|
|
|
"sparrow/pkg/server"
|
|
|
"time"
|
|
@@ -62,6 +63,7 @@ func (a *TaskExecutor) doTask(action *Action) error {
|
|
|
return err
|
|
|
}
|
|
|
reply := &rpcs.ReplyEmptyResult{}
|
|
|
+ fmt.Printf("rpchost:%s-----------", rpchost)
|
|
|
if rpchost != "" {
|
|
|
args := rpcs.ArgsSendCommand{
|
|
|
DeviceId: action.DeviceID,
|
|
@@ -80,7 +82,7 @@ func (a *TaskExecutor) doTask(action *Action) error {
|
|
|
if err != nil {
|
|
|
server.Log.Errorf("plc设备发送消息失败:%v", err)
|
|
|
}
|
|
|
-
|
|
|
+ fmt.Printf("plc设备发送消息成功:topic:%s,payload:%s", publishArgs.Topic, publishArgs.Payload)
|
|
|
return nil
|
|
|
}
|
|
|
|