//发送心跳. 填自身的产品id和设备id
err = client.SendHeart("productId", "deviceId")
if err != nil {
t.Errorf("err: %s", err.Error())
}
//发送时间校准. 填自身的产品id和设备id
err = client.SendNtp("productId", "deviceId")
if err != nil {
t.Errorf("err: %s", err.Error())
}
//属性上报. 填自身的产品id和设备id和数据
err = client.SendPropertiesUp("productId", "deviceId", &comm.DasDevicePropertiesUp{
DasProjectServiceMqttReq: comm.DasProjectServiceMqttReq{
Id: "", //这边生成唯一id
Version: comm.DAS_PROJECT_AIOT_VERSION,
Method: comm.DAS_DEVICE_PROPERTIES_UP_METHOD,
},
Sys: nil, //这边填自身业务数据
Params: nil, //这边填自身业务数据
})
if err != nil {
t.Errorf("err: %s", err.Error())
}
//属性上报批量. 填自身的产品id和设备id和数据
err = client.SendPropertiesUpBatch("productId", "deviceId", &comm.DasDevicePropertiesUpBatch{
DasProjectServiceMqttReq: comm.DasProjectServiceMqttReq{
Id: "", //这边生成唯一id
Version: comm.DAS_PROJECT_AIOT_VERSION,
Method: comm.DAS_DEVICE_PROPERTIES_UP_BATCH_METHOD,
},
Sys: nil, //这边填自身业务数据
Params: nil, //这边填自身业务数据
})
if err != nil {
t.Errorf("err: %s", err.Error())
}
//属性写值回复. 填自身的产品id和设备id和数据
err = client.SendPropertiesSetResponse("productId", "deviceId", &comm.DasDevicePropertiesSetResponse{DasProjectServiceMqttResponse: comm.DasProjectServiceMqttResponse{
Code: comm.RESPONSE_CODE_SUCCESS,
Data: make(map[string]interface{}),
Id: "", //这边填收到的包中的id
Message: comm.RESPONSE_CODE_SUCCESS_MESSAGE,
Method: comm.DAS_DEVICE_PROPERTIES_SET_METHOD,
Version: comm.DAS_PROJECT_AIOT_VERSION,
}})
if err != nil {
t.Errorf("err: %s", err.Error())
}
//属性查询回复. 填自身的产品id和设备id和数据
err = client.SendPropertiesGetResponse("productId", "deviceId", &comm.DasDevicePropertiesGetResponse{DasProjectServiceMqttResponse: comm.DasProjectServiceMqttResponse{
Code: comm.RESPONSE_CODE_SUCCESS,
Data: nil, //这边填写属性值
Id: "", //这边填收到的包中的id
Message: comm.RESPONSE_CODE_SUCCESS_MESSAGE,
Method: comm.DAS_DEVICE_PROPERTIES_GET_METHOD,
Version: comm.DAS_PROJECT_AIOT_VERSION,
}})
if err != nil {
t.Errorf("err: %s", err.Error())
}
//事件上报. 填自身的产品id和设备id和数据
err = client.SendEventUp("productId", "deviceId", &comm.DasDeviceEventUp{
DasProjectServiceMqttReq: comm.DasProjectServiceMqttReq{
Id: "", //这边生成唯一id
Version: comm.DAS_PROJECT_AIOT_VERSION,
Method: comm.DAS_DEVICE_EVENT_UP_METHOD,
},
Sys: nil, //这边填自身业务数据
Identifier: "", //这边填自身业务数据
Params: nil, //这边填自身业务数据
})
if err != nil {
t.Errorf("err: %s", err.Error())
}
//服务下发回复. 填自身的产品id和设备id和数据
err = client.SendServiceSetResponse("productId", "deviceId", &comm.DasDeviceServiceSetResponse{
DasProjectServiceMqttResponse: comm.DasProjectServiceMqttResponse{
Code: comm.RESPONSE_CODE_SUCCESS,
Data: nil, //这边填写属性值
Id: "", //这边填收到的包中的id
Message: comm.RESPONSE_CODE_SUCCESS_MESSAGE,
Method: comm.DAS_DEVICE_SERVER_SET_METHOD,
Version: comm.DAS_PROJECT_AIOT_VERSION,
},
Identifier: "",
})
if err != nil {
t.Errorf("err: %s", err.Error())
}
//设备在线状态上报. 填自身的产品id和设备id和数据
err = client.SendDeviceStatusUp("productId", "deviceId", &comm.DasDeviceStatusUp{
Id: "",
Time: 0,
Devices: nil,
})
if err != nil {
t.Errorf("err: %s", err.Error())
}