diff --git a/internal/core/batch_send.go b/internal/core/batch_send.go index aa02291..483e47e 100644 --- a/internal/core/batch_send.go +++ b/internal/core/batch_send.go @@ -52,6 +52,7 @@ func SendBatchWrite(deviceId string, points []plugin.PointData) (err error) { // 批量读取多个点位值 func SendBatchRead(deviceId string, points []plugin.PointData) (err error) { + logger.Logger.Info("send batch read", zap.String("deviceId", deviceId), zap.Any("points", points)) readPoints := make([]plugin.PointData, 0) for _, p := range points { point, ok := helper.CoreCache.GetPointByDevice(deviceId, p.PointName) diff --git a/internal/core/single_send.go b/internal/core/single_send.go index d61c9f5..96e13e6 100644 --- a/internal/core/single_send.go +++ b/internal/core/single_send.go @@ -6,12 +6,14 @@ import ( "github.com/ibuilding-x/driver-box/driverbox/config" "github.com/ibuilding-x/driver-box/driverbox/helper" "github.com/ibuilding-x/driver-box/driverbox/plugin" + "github.com/ibuilding-x/driver-box/internal/logger" "go.uber.org/zap" "time" ) // 单点操作 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)) if !checkMode(mode) { return errors.New("invalid mode") }