更换实体

app/src/main/java/com/mogo/cloud/SPIRealTimeTestClass.java

@@ -38,7 +38,8 @@ class SPIRealTimeTestClass implements IRealTimeProvider {
                         .setSn(MoGoAiCloudClientConfig.getInstance().getSn())
                         .build();
 
-        SocketReceiveDataProto3.MyLocationReq myLocationReq = SocketReceiveDataProto3.MyLocationReq.newBuilder()
+        SocketReceiveDataProto3.MyLocationReq myLocationReq =
+                SocketReceiveDataProto3.MyLocationReq.newBuilder()
                         .setLastCoordinate(locationInfoProto)
                         .setDataAccuracy(1)
                         .setMortonCode(mortonCode)
@@ -46,11 +47,16 @@ class SPIRealTimeTestClass implements IRealTimeProvider {
                         .setSn(MoGoAiCloudClientConfig.getInstance().getSn())
                         .build();
 
-        SocketReceiveDataProto3.OnePerSecondSendReqProto self = SocketReceiveDataProto3.OnePerSecondSendReqProto.newBuilder()
-                .setSelf(myLocationReq).build();
+        SocketReceiveDataProto3.OnePerSecondSendReqProto self =
+                SocketReceiveDataProto3.OnePerSecondSendReqProto.newBuilder()
+                        .setSelf(myLocationReq)
+                        .build();
 
-        DataCollectMsgDataProto.DataCollectMsgData msgData = DataCollectMsgDataProto.DataCollectMsgData.newBuilder()
-                .setPayload(self.toByteString()).build();
+        DataCollectMsgDataProto.DataCollectMsgData msgData =
+                DataCollectMsgDataProto.DataCollectMsgData.newBuilder()
+                        .setPayload(self.toByteString())
+                        .setMsgType(MSG_TYPE_UPLINK_CAR_DATA.getMsgType())
+                        .build();
 
         return DataCollectWrapper.DataCollectMsg.newBuilder()
                 .setData(msgData.toByteString())