mirror of
https://gitee.com/XM-GO/PandaX.git
synced 2026-04-23 10:58:35 +08:00
55 lines
1.6 KiB
Go
55 lines
1.6 KiB
Go
package util
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"errors"
|
|
"pandax/apps/device/services"
|
|
ruleEntity "pandax/apps/rule/entity"
|
|
ruleService "pandax/apps/rule/services"
|
|
"pandax/pkg/global"
|
|
"pandax/pkg/rule_engine"
|
|
"pandax/pkg/rule_engine/message"
|
|
"pandax/pkg/tool"
|
|
)
|
|
|
|
func BuildRunDeviceRpc(deviceId, mode string, msgData map[string]interface{}) error {
|
|
device, err := services.DeviceModelDao.FindOne(deviceId)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if device.LinkStatus != global.ONLINE {
|
|
return errors.New("设备不在线无法设置属性")
|
|
}
|
|
findOne := ruleService.RuleChainModelDao.FindOne(device.Product.RuleChainId)
|
|
ruleData := ruleEntity.RuleDataJson{}
|
|
err = tool.StringToStruct(findOne.RuleDataJson, &ruleData)
|
|
if err != nil {
|
|
global.Log.Error("规则链数据转化失败", err)
|
|
return errors.New("规则链数据转化失败")
|
|
}
|
|
dataCode := ruleData.LfData.DataCode
|
|
code, _ := json.Marshal(dataCode)
|
|
//新建规则链实体
|
|
instance, errs := rule_engine.NewRuleChainInstance(findOne.Id, code)
|
|
if err != nil {
|
|
return errs
|
|
}
|
|
metadataVals := map[string]interface{}{
|
|
"deviceId": device.Id,
|
|
"mode": mode,
|
|
"deviceName": device.Name,
|
|
"deviceType": device.DeviceType,
|
|
"deviceProtocol": device.Product.ProtocolName,
|
|
"productId": device.Pid,
|
|
"orgId": device.OrgId,
|
|
"owner": device.Owner,
|
|
}
|
|
msg := message.NewMessage(device.Owner, message.RpcRequestToDevice, msgData, metadataVals)
|
|
err = instance.StartRuleChain(context.Background(), msg)
|
|
if err != nil {
|
|
global.Log.Error("规则链执行失败", errs)
|
|
}
|
|
return err
|
|
}
|