smart_tunnel_edge/util/task.go

package util

import (
	"encoding/hex"
	"fmt"
	"github.com/robfig/cron"
	"smart_tunnel_edge/protocol/lampControl"
	"smart_tunnel_edge/util/config"
	"smart_tunnel_edge/util/logger"
)

var commandQueue = make(chan []byte, 5)

func TimeTasks() {
	c := cron.New()
	//每3分钟监测状态
	//_ = c.AddFunc("0 0/5 * * * ? ", func() {
	_ = c.AddFunc("0/5 * * * * ?", func() {
		for _, dev := range config.DevConfig.LampDevs {
			pack := lampControl.DataPack{Addr: dev.Address, Data: []byte{0x00}}
			command := pack.GetLampTurnOnOffCommand()
			//dataPack := lampControl.DataPack{Addr: dev.Address}
			//command := dataPack.GetLampSetBrightCommand(10)
			fmt.Println("命令：", hex.EncodeToString(command.Bytes()))
			port, err := GetSerialPort(dev.SerialId)
			if err != nil {
				logger.Logger.Infof(err.Error())
				continue
			}
			write, err := port.Write(command.Bytes())
			fmt.Println("write.....,", write)
			if err != nil {
				fmt.Println(err.Error())
			}
		}
	})
	c.Start()
}