feat(设备影子): 记录指令下发事件

ibuilding-X · Jun 20, 2024 · 1ec1b91 · 1ec1b91
1 parent 0d32cd9
commit 1ec1b91
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/internal/core/batch_send.go b/internal/core/batch_send.go
@@ -14,6 +14,9 @@ import (
 // SendBatchWrite 发送多个点位写命令
 func SendBatchWrite(deviceId string, points []plugin.PointData) (err error) {
 	logger.Logger.Info("send batch write", zap.String("deviceId", deviceId), zap.Any("points", points))
+	for _, point := range points {
+		_ = helper.DeviceShadow.SetWritePointValue(deviceId, point.PointName, point.Value)
+	}
 	//设备驱动层加工
 	result, err := deviceDriverProcess(deviceId, plugin.WriteMode, points...)
 	if err != nil {
@@ -104,8 +107,6 @@ func tryReadNewValues(deviceId string, points []plugin.PointData) {
 			continue
 		}
 		readPoints = append(readPoints, p)
-		//更新点位写时间
-		_ = helper.DeviceShadow.SetWritePointValue(deviceId, p.PointName, p.Value)
 	}
 	if len(readPoints) == 0 {
 		return

diff --git a/internal/core/single_send.go b/internal/core/single_send.go
@@ -13,6 +13,7 @@ import (
 // 单点操作
 func SendSinglePoint(deviceId string, mode plugin.EncodeMode, pointData plugin.PointData) error {
 	logger.Logger.Info("send single point", zap.String("deviceId", deviceId), zap.Any("mode", mode), zap.Any("pointData", pointData))
+	_ = helper.DeviceShadow.SetWritePointValue(deviceId, pointData.PointName, pointData.Value)
 	if !checkMode(mode) {
 		return errors.New("invalid mode")
 	}