大数据全系列 教程
1869个小节阅读:464.9k
目录
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
/**
* 保存订单信息到HBase中
* @param data
*/
public void saveOrderInfo(JSONObject data) throws IOException {
// 1、表不存在创建表
if (!HBaseUtils.tableExists(Constants.HTAB_ORDER)){
HBaseUtils.createTable(Constants.HTAB_ORDER,Constants.HTAB_ORDER_FAMILY);
}
// 2、获取表
Table table = HBaseUtils.getTable(Constants.HTAB_ORDER);
// 3、rowkey设计 订单id_创建时间
String rowkey = "";
// 4、 订单map是否有数据
if (orderMap.size() > 0 ){
orderMap.clear();
}
// 5、组装rowkey
rowkey = data.getString("id_").concat("_").concat(data.getString("create_time").replaceAll("-",
"").replaceAll(" ","").replaceAll(":",""));
// 6、订单所有数据拿出来
//id , create_time, pay_all, open_lng , open_lat , begin_address_code ,charge_mileage ,
// city_name ,vehicle_license , driver_id driver_name, cancel , close_gps_time
// 订单创建时间
orderMap.put("create_time", StrUtil.isEmpty(data.getString("create_time"))?"":data.getString("create_time"));
// 支付费用
orderMap.put("pay_all", StrUtil.isEmpty(data.getString("pay_all"))?"":data.getString("pay_all"));
// 订单起始经度。
orderMap.put("open_lng", StrUtil.isEmpty(data.getString("open_lng"))?"":data.getString("open_lng"));
// 订单起始纬度
orderMap.put("open_lat", StrUtil.isEmpty(data.getString("open_lat"))?"":data.getString("open_lat"));
// 发起行政区域代码
orderMap.put("begin_address_code", StrUtil.isEmpty(data.getString("begin_address_code"))?"":data.getString("begin_address_code"));
// 订单里程
orderMap.put("charge_mileage", StrUtil.isEmpty(data.getString("charge_mileage"))?"":data.getString("charge_mileage"));
//下单所属城市名字
orderMap.put("city_name", StrUtil.isEmpty(data.getString("city_name"))?"":data.getString("city_name"));
// 车牌号
orderMap.put("vehicle_license", StrUtil.isEmpty(data.getString("vehicle_license"))?"":data.getString("vehicle_license"));
// 司机id
orderMap.put("driver_id", StrUtil.isEmpty(data.getString("driver_id"))?"":data.getString("driver_id"));
// 司机名字
orderMap.put("driver_name", StrUtil.isEmpty(data.getString("driver_name"))?"":data.getString("driver_name"));
// 状态 0取消 1 用户取消 2 司机取消 3 超时没有接单 系统自动取消
orderMap.put("cancel", StrUtil.isEmpty(data.getString("cancel"))?"":data.getString("cancel"));
//结束上传gps时间
orderMap.put("close_gps_time", StrUtil.isEmpty(data.getString("close_gps_time"))?"":data.getString("close_gps_time"));
table.put(HBaseUtils.createPut(rowkey,Constants.HTAB_ORDER_FAMILY.getBytes(),orderMap));
}