|
@@ -126,11 +126,13 @@ func (d *DeviceSceneService) monitorTask(config DeviceSceneConfig) {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
server.Log.Errorf("compare weather condition error :%s", err.Error())
|
|
server.Log.Errorf("compare weather condition error :%s", err.Error())
|
|
|
}
|
|
}
|
|
|
- taskExecutor := NewTaskExecutor(config.Actions)
|
|
|
|
|
- if err = taskExecutor.Do(config.SceneId); err != nil {
|
|
|
|
|
- server.Log.Errorf("device_status do taskid :%s error:%s", config.SceneId, err.Error())
|
|
|
|
|
|
|
+ if result.Result {
|
|
|
|
|
+ taskExecutor := NewTaskExecutor(config.Actions)
|
|
|
|
|
+ if err = taskExecutor.Do(config.SceneId); err != nil {
|
|
|
|
|
+ server.Log.Errorf("device_status do taskid :%s error:%s", config.SceneId, err.Error())
|
|
|
|
|
+ }
|
|
|
|
|
+ _ = taskExecutor.saveHis(config.SceneId, result.ConditionId)
|
|
|
}
|
|
}
|
|
|
- _ = taskExecutor.saveHis(config.SceneId, result.ConditionId)
|
|
|
|
|
|
|
|
|
|
case <-config.stopChan: // 收到停止信号
|
|
case <-config.stopChan: // 收到停止信号
|
|
|
config.ticker.Stop()
|
|
config.ticker.Stop()
|