diff --git a/sdk/service/protocol/lightProtocol.go b/sdk/service/protocol/lightProtocol.go index 40fbc7a36..17fea3e87 100644 --- a/sdk/service/protocol/lightProtocol.go +++ b/sdk/service/protocol/lightProtocol.go @@ -97,7 +97,7 @@ func NewLightProtocol(c conf.EventConf, pi *dm.ProtocolInfo, pc *LightProtocolCo } func (p *LightProtocol) Start() error { - ctx := context.Background() + ctx := ctxs.WithRoot(context.Background()) _, err := p.ProtocolM.ProtocolInfoCreate(ctx, p.Pi) //初始化协议 if err != nil && !errors.Cmp(errors.Fmt(err), errors.Duplicate) { logx.Must(err) diff --git a/service/dmsvr/internal/logic/otamanage/sendMessageToDevicesLogic.go b/service/dmsvr/internal/logic/otamanage/sendMessageToDevicesLogic.go index 670599ce6..04ebaf815 100644 --- a/service/dmsvr/internal/logic/otamanage/sendMessageToDevicesLogic.go +++ b/service/dmsvr/internal/logic/otamanage/sendMessageToDevicesLogic.go @@ -374,7 +374,7 @@ func (l *SendMessageToDevicesLogic) PushMessageToDevices(jobInfo *relationDB.DmO return nil } - deviceList, err := relationDB.NewOtaFirmwareDeviceRepo(l.ctx).FindByFilter(l.ctx, relationDB.OtaFirmwareDeviceFilter{ + deviceList, err := stores.WithNoDebug(l.ctx, relationDB.NewOtaFirmwareDeviceRepo).FindByFilter(l.ctx, relationDB.OtaFirmwareDeviceFilter{ FirmwareID: jobInfo.FirmwareID, JobID: jobInfo.ID, ProductID: firmware.ProductID,