feature: 埋点数据转换

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/adaptor/MessageConvertHelper.java

@@ -35,25 +35,34 @@ public class MessageConvertHelper {
         String appKey = jsonObject.getString("app_key");
         interactRecordMessageBO.setAppKey(appKey);
 
-        String enterpriseId = jsonObject.getString("merch_id");
+        String gp = jsonObject.getString("gp");
+        JSONObject gpJson = JSON.parseObject(gp);
+
+        String cusp = jsonObject.getString("cusp");
+        JSONObject cuspJson = JSON.parseObject(cusp);
+
+        String sysp = jsonObject.getString("sysp");
+        JSONObject syspJson = JSON.parseObject(sysp);
+
+        String enterpriseId = gpJson.getString("merch_id");
         interactRecordMessageBO.setEnterpriseId(enterpriseId);
 
-        String memberId = jsonObject.getString("member_id");
+        String memberId = gpJson.getString("member_id");
         interactRecordMessageBO.setMemberId(memberId);
 
-        String unionId = jsonObject.getString("union_id");
+        String unionId = gpJson.getString("union_id");
         interactRecordMessageBO.setUnionId(unionId);
 
-        String clerkId = jsonObject.getString("share_id");
+        String clerkId = cuspJson.getString("share_id");
         interactRecordMessageBO.setClerkId(clerkId);
 
-        String storeId = jsonObject.getString("share_shop_id");
+        String storeId = cuspJson.getString("share_shop_id");
         interactRecordMessageBO.setStoreId(storeId);
 
-        String materialId = jsonObject.getString("material_id");
+        String materialId = cuspJson.getString("material_id");
         interactRecordMessageBO.setMaterialId(materialId);
 
-        String shareMaterialChannel = jsonObject.getString("share_material_channel");
+        String shareMaterialChannel = cuspJson.getString("share_material_channel");
         interactRecordMessageBO.setChannelSource(this.convertChannelSource(shareMaterialChannel));
 
         String eventCode = jsonObject.getString("event_code");
@@ -62,10 +71,10 @@ public class MessageConvertHelper {
         Integer duration = jsonObject.getInteger("duration");
         interactRecordMessageBO.setDurationTime(duration);
 
-        String orderNumber = jsonObject.getString("order_number");
+        String orderNumber = cuspJson.getString("order_number");
         interactRecordMessageBO.setOrderNumber(orderNumber);
 
-        String goodsId = jsonObject.getString("goods_id");
+        String goodsId = cuspJson.getString("goods_id");
         interactRecordMessageBO.setGoodsId(goodsId);
 
         String runningUuid = jsonObject.getString("runningUuid");
@@ -74,7 +83,7 @@ public class MessageConvertHelper {
         Long lastAccessTime = jsonObject.getLong("server_timestamp");
         interactRecordMessageBO.setLastAccessTime(lastAccessTime);
 
-        String refUrl = jsonObject.getString("ref_url");
+        String refUrl = syspJson.getString("ref_url");
         interactRecordMessageBO.setRefUrl(refUrl);
 
         return interactRecordMessageBO;