|
@@ -13,14 +13,15 @@ import (
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
type SceneInfo struct {
|
|
type SceneInfo struct {
|
|
|
- Id string `json:"id"`
|
|
|
|
|
- Name string `json:"name"`
|
|
|
|
|
- Desc string `json:"desc"`
|
|
|
|
|
- Status int `json:"status"`
|
|
|
|
|
- SceneType string `json:"scene_type"`
|
|
|
|
|
- Config string `json:"config"`
|
|
|
|
|
- Action string `json:"action"`
|
|
|
|
|
- Time time.Time `json:"time"`
|
|
|
|
|
|
|
+ Id string `json:"id"`
|
|
|
|
|
+ Name string `json:"name"`
|
|
|
|
|
+ ConditionDesc string `json:"condition_desc"`
|
|
|
|
|
+ ActionDesc string `json:"action_desc"`
|
|
|
|
|
+ Status int `json:"status"`
|
|
|
|
|
+ SceneType string `json:"scene_type"`
|
|
|
|
|
+ Config string `json:"config"`
|
|
|
|
|
+ Action string `json:"action"`
|
|
|
|
|
+ Time time.Time `json:"time"`
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
type SceneService struct {
|
|
type SceneService struct {
|
|
@@ -65,14 +66,15 @@ func (m *SceneService) getServiceByType(sceneType string) (TaskManager, error) {
|
|
|
|
|
|
|
|
func (m *SceneService) SubmitAction(args rpcs.ArgsSubmitSceneAction, reply *rpcs.ReplySubmitSceneAction) error {
|
|
func (m *SceneService) SubmitAction(args rpcs.ArgsSubmitSceneAction, reply *rpcs.ReplySubmitSceneAction) error {
|
|
|
scene := SceneInfo{
|
|
scene := SceneInfo{
|
|
|
- Id: args.Id,
|
|
|
|
|
- Name: args.Name,
|
|
|
|
|
- Status: args.Status,
|
|
|
|
|
- Desc: args.Desc,
|
|
|
|
|
- SceneType: args.SceneType,
|
|
|
|
|
- Config: args.Config,
|
|
|
|
|
- Action: args.Action,
|
|
|
|
|
- Time: args.Time,
|
|
|
|
|
|
|
+ Id: args.Id,
|
|
|
|
|
+ Name: args.Name,
|
|
|
|
|
+ Status: args.Status,
|
|
|
|
|
+ ConditionDesc: args.ConditionDesc,
|
|
|
|
|
+ ActionDesc: args.ActionDesc,
|
|
|
|
|
+ SceneType: args.SceneType,
|
|
|
|
|
+ Config: args.Config,
|
|
|
|
|
+ Action: args.Action,
|
|
|
|
|
+ Time: args.Time,
|
|
|
}
|
|
}
|
|
|
srv, err := m.getServiceByType(scene.SceneType)
|
|
srv, err := m.getServiceByType(scene.SceneType)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -139,12 +141,13 @@ func (m *SceneService) doAction(action string) error {
|
|
|
|
|
|
|
|
func (m *SceneService) saveSceneRedis(scene SceneInfo) error {
|
|
func (m *SceneService) saveSceneRedis(scene SceneInfo) error {
|
|
|
sceneArgs := rpcs.ArgsScene{
|
|
sceneArgs := rpcs.ArgsScene{
|
|
|
- Key: fmt.Sprintf("scene:%s:%s", scene.SceneType, scene.Id),
|
|
|
|
|
- Name: scene.Name,
|
|
|
|
|
- Desc: scene.Desc,
|
|
|
|
|
- SceneId: scene.Id,
|
|
|
|
|
- Config: scene.Config,
|
|
|
|
|
- Time: scene.Time,
|
|
|
|
|
|
|
+ Key: fmt.Sprintf("scene:%s:%s", scene.SceneType, scene.Id),
|
|
|
|
|
+ Name: scene.Name,
|
|
|
|
|
+ ConditionDesc: scene.ConditionDesc,
|
|
|
|
|
+ ActionDesc: scene.ActionDesc,
|
|
|
|
|
+ SceneId: scene.Id,
|
|
|
|
|
+ Config: scene.Config,
|
|
|
|
|
+ Time: scene.Time,
|
|
|
}
|
|
}
|
|
|
sceneReply := rpcs.ReplyEmptyResult{}
|
|
sceneReply := rpcs.ReplyEmptyResult{}
|
|
|
err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.SaveScene", sceneArgs, &sceneReply)
|
|
err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.SaveScene", sceneArgs, &sceneReply)
|