|
@@ -113,10 +113,10 @@ func (t *TimerSceneService) Remove(id string) error {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func (t *TimerSceneService) Start(id string) error {
|
|
func (t *TimerSceneService) Start(id string) error {
|
|
|
- fmt.Printf("task-------:%s\n", t.task.String())
|
|
|
|
|
- if !t.task.Contains(id) {
|
|
|
|
|
- return errors.New("场景不存在")
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ //fmt.Printf("task-------:%s\n", t.task.String())
|
|
|
|
|
+ //if !t.task.Contains(id) {
|
|
|
|
|
+ // return errors.New("场景不存在")
|
|
|
|
|
+ //}
|
|
|
scene := t.task.Get(id).(TimerSceneConfig)
|
|
scene := t.task.Get(id).(TimerSceneConfig)
|
|
|
for _, v := range scene.Conditions {
|
|
for _, v := range scene.Conditions {
|
|
|
t.cron.Start(v.TaskId)
|
|
t.cron.Start(v.TaskId)
|
|
@@ -126,9 +126,9 @@ func (t *TimerSceneService) Start(id string) error {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func (t *TimerSceneService) Stop(id string) error {
|
|
func (t *TimerSceneService) Stop(id string) error {
|
|
|
- if !t.task.Contains(id) {
|
|
|
|
|
- return errors.New("场景不存在")
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ //if !t.task.Contains(id) {
|
|
|
|
|
+ // return errors.New("场景不存在")
|
|
|
|
|
+ //}
|
|
|
scene := t.task.Get(id).(TimerSceneConfig)
|
|
scene := t.task.Get(id).(TimerSceneConfig)
|
|
|
for _, v := range scene.Conditions {
|
|
for _, v := range scene.Conditions {
|
|
|
t.cron.Stop(v.TaskId)
|
|
t.cron.Stop(v.TaskId)
|