|
|
@@ -185,10 +185,10 @@ func processReportStatus(topicInfo *protocol.TopicInfo, vendorId string, message
|
|
|
func (a *Access) processDeviceUpgrade(deviceId string, message *gjson.Json) error {
|
|
|
var reply rpcs.ReplyEmptyResult
|
|
|
data := gjson.New(message.GetJson("data").MustToJson())
|
|
|
+ server.Log.Infof("收到指令：%s", data.MustToJsonString())
|
|
|
switch data.GetString("cmd") {
|
|
|
case "download":
|
|
|
params := gjson.New(data.GetJson("params").MustToJson())
|
|
|
-
|
|
|
args := &rpcs.ChunkUpgrade{
|
|
|
DeviceId: deviceId,
|
|
|
FileId: params.GetInt("fileId"),
|
|
|
@@ -341,7 +341,7 @@ func (a *Access) chunkUpgrade(params rpcs.ChunkUpgrade) error {
|
|
|
lockDevice.Locked = true
|
|
|
lockDevice.LastSeen = time.Now()
|
|
|
|
|
|
- server.Log.Infof("4G模组OTA升级：%s", params.DeviceId)
|
|
|
+ server.Log.Infof("正在进行OTA升级：%s", params.DeviceId)
|
|
|
|
|
|
buf := bytes.NewBuffer(gbinary.BeEncodeUint16(gconv.Uint16(params.Offset)))
|
|
|
|
liuxiulin