package com.xiaopeng.automaticPilot.util; //import io.growing.sdk.java.GrowingAPI; //import io.growing.sdk.java.dto.GIOMessage; //import io.growing.sdk.java.dto.GioCdpEventMessage; import java.util.Arrays; import java.util.HashMap; import java.util.Map; public class KafkaSendUtils { // private static final GrowingAPI project = new GrowingAPI.Builder().setProjectKey("89a922449121f7c2").setDataSourceId("9365c3d2f397f172").build(); /** * * 车辆状态变更 触发时机:车辆主状态或子状态发生变化的瞬间。 * 发送数据到GrowingIO * * @param map */ // public static void sendVehicleStatusChanged(Map map) { // // Config GrowingIO // // 参数需要从CDP增长平台上,创建新应用,或从已创建的数据源中获取, 如不清楚请联系您的专属项目经理 // // YourAccountId eg: 89a922449121f7c2 // // YourDatasourceId eg: 9365c3d2f397f172 // //事件行为消息体,anonymousId 和 loginUserId 参数,不能同时为空 // GioCdpEventMessage eventMessage = new GioCdpEventMessage.Builder() // .eventTime(System.currentTimeMillis()) // 默认为系统当前时间 (选填) // .eventKey("RT_web_vehicle_status_changed") // 事件标识 (必填) //// .domain("com.growingio.app") // App包名或H5域名(选填) //// .urlScheme("growing.123c12fb12f123cc") // 链接协议(选填) //// .deviceBrand("google") // 设备品牌(选填) //// .deviceModel("Nexus 5") // 设备型号(选填) //// .deviceType("PHONE") // 设备类型(选填) //// .appVersion("1.2.4") // App版本(选填) //// .appName("看数助手") // App名称(选填) // .language("zh_CN") // 语言(选填) // .anonymousId("device_id") // 访问用户ID (选填) //// .loginUserKey("account") // 登录用户KEY (选填,需有规划并在平台配置后再上报) // .loginUserId("417abcabcabcbac") // 登录用户ID (选填) //// .addEventVariable("product_name", "cdp苹果") // 事件属性 (选填) //// .addEventVariable("product_classify", Arrays.asList("苹果", "香蕉")) // 事件属性 (选填) // .addEventVariables(map) // 事件属性集合 (选填) //// .addItem("itemId", "itemKey") // 物品模型ID, KEY (选填) // .build(); // // //上传事件行为消息到服务器 // project.send(eventMessage); // } /** * * 订单状态变更 * 开始接单,上报一次 * 订单结束,上报一次 * 发送数据到GrowingIO * */ // public static void sendVehicleTraceUpload(Map map) { // //事件行为消息体,anonymousId 和 loginUserId 参数,不能同时为空 // GioCdpEventMessage eventMessage = new GioCdpEventMessage.Builder() // .eventTime(System.currentTimeMillis()) // 默认为系统当前时间 (选填) // .eventKey("RT_xpu_vehicle_trace_upload") // 事件标识 (必填) // .language("zh_CN") // 语言(选填) // .addEventVariables(map) // 事件属性集合 (选填) // .build(); // //上传事件行为消息到服务器 // project.send(eventMessage); // } public static void main(String[] args) { Map map = new HashMap<>(); map.put("vin", "L1NSPGHB7SB018421"); map.put("order_id", ""); map.put("timestamp", System.currentTimeMillis()); map.put("sub_status", ""); map.put("prev_sub_status", ""); // sendVehicleStatusChanged(map); } }