|
@@ -81,7 +81,7 @@ func (w *WeatherSceneService) monitorTask(task WeatherSceneConfig) {
|
|
|
if err = taskExecutor.Do(task.SceneId); err != nil {
|
|
if err = taskExecutor.Do(task.SceneId); err != nil {
|
|
|
server.Log.Errorf("weather do taskid :%s error:%s", task.SceneId, err.Error())
|
|
server.Log.Errorf("weather do taskid :%s error:%s", task.SceneId, err.Error())
|
|
|
}
|
|
}
|
|
|
- err = taskExecutor.saveHis(task.SceneId, result.ConditionId, task.Actions[0])
|
|
|
|
|
|
|
+ err = taskExecutor.saveHis(task.SceneId, result.ConditionId)
|
|
|
}
|
|
}
|
|
|
case <-task.stopChan: // 收到停止信号
|
|
case <-task.stopChan: // 收到停止信号
|
|
|
task.ticker.Stop()
|
|
task.ticker.Stop()
|