Просмотр исходного кода

新增、编辑、修改代码

niujiuru 3 недель назад
Родитель
Сommit
aa3bbcae9e
3 измененных файлов с 30 добавлено и 1 удалено
  1. 19 0
      reporter/envdata.go
  2. 0 1
      reporter/sensor_data.go
  3. 11 0
      reporter/takephoto.go

+ 19 - 0
reporter/envdata.go

@@ -0,0 +1,19 @@
+package reporter
+
+import (
+	"context"
+
+	"hnyfkj.com.cn/rtu/linux/baseapp"
+	mcu "hnyfkj.com.cn/rtu/xy_v/mcu_ctrl_board"
+)
+
+func LoopRecvOneEnvData(ctx context.Context) {
+	for {
+		select {
+		case envData := <-mcu.Board.OneEnvDataCh:
+			baseapp.Logger.Infof("[%s] 收到一条环境数据: %s", MODULE_NAME, envData.String())
+		case <-ctx.Done():
+			return
+		}
+	}
+}

+ 0 - 1
reporter/sensor_data.go

@@ -1 +0,0 @@
-package reporter

+ 11 - 0
reporter/takephoto.go

@@ -17,6 +17,17 @@ const (
 	PhotoTimeout = 5 * 60 // 拍照超时时间, 单位: 秒
 )
 
+func LoopTakePhoto(ctx context.Context) {
+	for {
+		select {
+		case <-mcu.Board.ReqTakePhoCh:
+			TakePhotoAndUpToFtp(ctx)
+		case <-ctx.Done():
+			return
+		}
+	}
+}
+
 func TakePhotoAndUpToFtp(ctx context.Context) (string, error) {
 	// 1, 开始执行拍照任务
 	mcu.GlobalWorkState.Add(mcu.PhotoCapturing)