yacloud/hummingbird
1
0
Fork 0
mirror of https://gitee.com/winc-link/hummingbird.git synced 2025-04-20 00:12:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

修复device sn为空 bug

Browse Source
This commit is contained in:
winc-link 2024-08-30 19:57:00 +08:00
parent 620b1b6af6
commit 01a1231a07
4 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/dtos/device.go
View File

@ -171,6 +171,7 @@ type DeviceReportPropertiesValueSearchResponse struct {
type DeviceAddRequest struct {
DeviceId string `json:"device_id"`
Name string `json:"name"`
DeviceSn string `json:"device_sn"`
ProductId string `json:"product_id"`
Description string `json:"description"`
Platform constants.IotPlatform `json:"platform"`

1
internal/hummingbird/core/application/deviceapp/deviceapp.go
View File

@ -152,6 +152,7 @@ func (p *deviceApp) AddDevice(ctx context.Context, req dtos.DeviceAddRequest) (s
var insertDevice models.Device
insertDevice.Id = deviceId
insertDevice.Name = req.Name
insertDevice.DeviceSn = req.DeviceSn
insertDevice.ProductId = req.ProductId
insertDevice.Platform = constants.IotPlatform_LocalIot
insertDevice.DriveInstanceId = req.DriverInstanceId

10
internal/hummingbird/core/controller/rpcserver/driverserver/device.go
View File

@ -52,7 +52,7 @@ func (s *DriverDeviceServer) GetDeviceConnectStatus(ctx context.Context, request
func (s *DriverDeviceServer) QueryDeviceList(ctx context.Context, request *device.QueryDeviceListRequest) (*device.QueryDeviceListResponse, error) {
deviceItf := container.DeviceItfFrom(s.dic.Get)
var platform string
if request.BaseRequest.UseCloudPlatform {
platform = string(constants.TransformEdgePlatformToDbPlatform(request.BaseRequest.GetCloudInstanceInfo().GetIotPlatform()))
@ -81,7 +81,7 @@ func (s *DriverDeviceServer) QueryDeviceList(ctx context.Context, request *devic
func (s *DriverDeviceServer) QueryDeviceById(ctx context.Context, request *device.QueryDeviceByIdRequest) (*device.QueryDeviceByIdResponse, error) {
deviceItf := container.DeviceItfFrom(s.dic.Get)
deviceInfo, err := deviceItf.DeviceModelById(ctx, request.Id)
response := new(device.QueryDeviceByIdResponse)
response.BaseResponse = new(drivercommon.CommonResponse)
@ -110,13 +110,15 @@ func (s *DriverDeviceServer) CreateDevice(ctx context.Context, request *device.C
response.BaseResponse.ErrorMessage = errWrapper.Message()
return response, nil
}
var insertDevice dtos.DeviceAddRequest
insertDevice.ProductId = productInfo.Id
insertDevice.Platform = constants.IotPlatform_LocalIot
insertDevice.Name = request.Device.Name
insertDevice.DeviceSn = request.Device.DeviceSn
//insertDevice.d
insertDevice.DriverInstanceId = request.BaseRequest.GetDriverInstanceId()
deviceId, err := deviceItf.AddDevice(ctx, insertDevice)
if err != nil {
errWrapper := errort.NewCommonEdgeXWrapper(err)

1
internal/models/device.go
View File

@ -32,6 +32,7 @@ type Device struct {
CloudInstanceId string `gorm:"index;type:string;size:255;comment:云实例ID"`
DriveInstanceId string `gorm:"index;type:string;size:255;comment:驱动实例ID"`
Name string `gorm:"type:string;size:255;comment:名字"`
DeviceSn string `gorm:"type:string;size:255;comment:设备唯一编码"`
Status constants.DeviceStatus `gorm:"type:string;size:50;comment:设备状态"`
Description string `gorm:"type:text;comment:描述"`
ProductId string `gorm:"type:string;size:255;comment:产品ID"`