scene.go 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161
  1. package service
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. "github.com/gogf/gf/container/gmap"
  7. "github.com/gogf/gf/encoding/gjson"
  8. "sparrow/pkg/rpcs"
  9. "sparrow/pkg/server"
  10. service2 "sparrow/services/scene-service/internal/service/manager"
  11. )
  12. type SceneInfo struct {
  13. Id string `json:"id"`
  14. Name string `json:"name"`
  15. Status int `json:"status"`
  16. SceneType string `json:"scene_type"`
  17. Config string `json:"config"`
  18. Action string `json:"action"`
  19. Time string `json:"time"`
  20. }
  21. type SceneService struct {
  22. scenes *gmap.HashMap // 场景ID到场景实例的映射
  23. timer TaskManager
  24. weather TaskManager
  25. deviceStatus TaskManager
  26. }
  27. func NewSceneService() *SceneService {
  28. return &SceneService{
  29. scenes: gmap.New(true),
  30. timer: service2.NewTimerSceneService(),
  31. weather: service2.NewWeatherSceneService(),
  32. deviceStatus: service2.NewDeviceSceneService(),
  33. }
  34. }
  35. type TaskManager interface {
  36. Add(config string) error
  37. Update(config string) error
  38. Remove(id string) error
  39. Start(id string) error
  40. Stop(id string) error
  41. }
  42. // getServiceByType 根据场景类型获取对应的服务实例
  43. func (m *SceneService) getServiceByType(sceneType string) (TaskManager, error) {
  44. switch sceneType {
  45. case "oneKey":
  46. return nil, nil
  47. case "timer":
  48. return m.timer, nil
  49. case "weather":
  50. return m.weather, nil
  51. case "device_status":
  52. return m.deviceStatus, nil
  53. default:
  54. return nil, errors.New("不支持的场景类型: " + sceneType)
  55. }
  56. }
  57. func (m *SceneService) SubmitAction(args rpcs.ArgsSubmitSceneAction, reply *rpcs.ReplySubmitSceneAction) error {
  58. scene := SceneInfo{
  59. Id: args.Id,
  60. Name: args.Name,
  61. Status: args.Status,
  62. SceneType: args.SceneType,
  63. Config: args.Config,
  64. Action: args.Action,
  65. }
  66. srv, err := m.getServiceByType(scene.SceneType)
  67. if err != nil {
  68. server.Log.Errorf("不支持的场景类型: %s, 场景ID: %s", scene.SceneType, scene.Id)
  69. return err
  70. }
  71. fmt.Printf("提交场景任务:%s", gjson.New(scene).MustToJsonString())
  72. switch scene.Action {
  73. case "add":
  74. err = srv.Add(scene.Config)
  75. if err != nil {
  76. return err
  77. }
  78. m.scenes.Set(scene.Id, scene)
  79. return m.saveSceneRedis(scene)
  80. case "remove":
  81. err = srv.Remove(scene.Id)
  82. if err != nil {
  83. server.Log.Errorf("delete scene error: Id: %s, error: %v", scene.Id, err)
  84. }
  85. m.scenes.Remove(scene.Id)
  86. return m.delSceneRedis(scene)
  87. case "update":
  88. err = srv.Update(scene.Config)
  89. if err != nil {
  90. server.Log.Errorf("update scene error: Id: %s, error: %v", scene.Id, err)
  91. return err
  92. }
  93. m.scenes.Set(scene.Id, scene)
  94. return m.saveSceneRedis(scene)
  95. case "start":
  96. err = srv.Start(scene.Config)
  97. if err != nil {
  98. server.Log.Errorf("start scene error: Id: %s, error: %v", scene.Id, err)
  99. return err
  100. }
  101. scene.Status = 1
  102. m.scenes.Set(scene.Id, scene)
  103. return m.saveSceneRedis(scene)
  104. case "stop":
  105. err = srv.Stop(scene.Config)
  106. if err != nil {
  107. server.Log.Errorf("stop scene error: Id: %s, error: %v", scene.Id, err)
  108. return err
  109. }
  110. scene.Status = 0
  111. m.scenes.Set(scene.Id, scene)
  112. return m.saveSceneRedis(scene)
  113. case "do":
  114. err = m.doAction(gjson.New(scene.Action).MustToJsonString())
  115. }
  116. return nil
  117. }
  118. func (m *SceneService) doAction(action string) error {
  119. var actions []*service2.Action
  120. err := json.Unmarshal([]byte(action), &actions)
  121. if err != nil {
  122. server.Log.Errorf("unmarshal actions error :%v", err)
  123. return err
  124. }
  125. return service2.NewTaskExecutor(actions).Do()
  126. }
  127. func (m *SceneService) saveSceneRedis(scene SceneInfo) error {
  128. sceneArgs := rpcs.ArgsScene{
  129. Key: fmt.Sprintf("scene:%s:%s", scene.SceneType, scene.Id),
  130. SceneId: scene.Id,
  131. Config: scene.Config,
  132. }
  133. sceneReply := rpcs.ReplyEmptyResult{}
  134. err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.SaveScene", sceneArgs, &sceneReply)
  135. if err != nil {
  136. server.Log.Errorf("save scene error: Id: %s, error: %v", scene.Id, err)
  137. }
  138. return err
  139. }
  140. func (m *SceneService) delSceneRedis(scene SceneInfo) error {
  141. sceneArgs := rpcs.ArgsScene{
  142. Key: fmt.Sprintf("scene:%s:%s", scene.SceneType, scene.Id),
  143. Config: scene.Config,
  144. }
  145. sceneReply := rpcs.ReplyEmptyResult{}
  146. err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.DeleteScene", sceneArgs, &sceneReply)
  147. if err != nil {
  148. server.Log.Errorf("del scene error: Id: %s, error: %v", scene.Id, err)
  149. }
  150. return err
  151. }