更新ota升级下发指令格式

services/apiprovider/actions.go

@@ -94,7 +94,7 @@ func GetDeviceInfoByIdentifier(urlparams martini.Params, r render.Render) {
 	server.Log.Printf("ACTION GetDeviceInfoByIdentifier, identifier:: %v", identifier)
 	device := &models.Device{}
 
-	err := server.RPCCallByName(context.Background(), rpcs.RegistryServerName, "Registry.FindDeviceByIdentifier", identifier, device)
+	err := server.RPCCallByName(context.Background(), rpcs.RegistryServerName, "Registry.FindDeviceByIdentifier2", identifier, device)
 	if err != nil {
 		r.JSON(http.StatusOK, renderError(ErrDeviceNotFound, err))
 		return

services/mqttaccess/access.go

@@ -80,16 +80,24 @@ func (a *Access) SendCommand(args rpcs.ArgsSendCommand, reply *rpcs.ReplySendCom
 // Upgrade 设备OTA升级指令
 func (a *Access) Upgrade(args rpcs.ArgsDeviceUpgrade, reply *rpcs.ReplyEmptyResult) error {
 	server.Log.Infof("设备OTA升级：%s, %s", args.DeviceId, args.Version)
-	cmd := &klink.DevUpgrade{
-		Action:      "devUpgrade",
-		MsgId:       0,
-		DeviceCode:  args.DeviceId,
+
+	cmd := &klink.CloudSend{
+		Action:     "cloudSend",
+		MsgId:      0,
+		DeviceCode: args.DeviceId,
+		Timestamp:  time.Now().Unix(),
+		Data: &klink.CloudSendData{
+			Cmd: "devUpgrade",
+			Params: map[string]interface{}{
+				"md5":     args.Md5,
+				"url":     args.Url,
+				"version": args.Version,
+			},
+		},
+
 		SubDeviceId: args.SudDeviceId,
-		Timestamp:   time.Now().Unix(),
-		Version:     args.Version,
-		Url:         args.Url,
-		Md5:         args.Md5,
 	}
+
 	msg, err := cmd.Marshal()
 	if err != nil {
 		return err

services/registry/registry.go

@@ -383,6 +383,23 @@ func (r *Registry) FindDeviceByIdentifier(identifier string, reply *models.Devic
 	return nil
 }
 
+// FindDeviceByIdentifier2 will find the device by indentifier
+func (r *Registry) FindDeviceByIdentifier2(identifier string, reply *models.Device) error {
+	db, err := getDB()
+	if err != nil {
+		return err
+	}
+
+	err = db.Where(&models.Device{
+		DeviceIdentifier: identifier,
+	}).First(reply).Error
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
 func (r *Registry) FindDeviceById(args uint64, reply *models.Device) error {
 	db, err := getDB()
 	if err != nil {