大数据全系列 教程
1869个小节阅读:465.5k
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
else if (tableName.equals("driver_info")) {
// TODO 保存司机信息
saveDriverInfo(data);
}
xxxxxxxxxx
/**
* 保存司机信息数据
* @param data
*/
public void saveDriverInfo(JSONObject data) throws IOException {
// 1、表不存在创建表
if (!HBaseUtils.tableExists(Constants.HTAB_DRIVER_INFO)){
HBaseUtils.createTable(Constants.HTAB_DRIVER_INFO,Constants.HTAB_DRIVER_INFO_FAMILY);
}
// 2、获取表
Table table = HBaseUtils.getTable(Constants.HTAB_DRIVER_INFO);
// 3、rowkey设计 司机id_创建时间
String rowkey = "";
// 4、判断司机map是否为空
if(driverInfoMap.size() > 0){
driverInfoMap.clear();
}
if (StrUtil.isEmpty(data.getString("id_"))){
return ;
}
if (StrUtil.isEmpty(data.getString("create_time"))){
return ;
}
rowkey = data.getString("id_").concat("_").concat(data.getString("create_time").replaceAll("-",
"").replaceAll(" ","").replaceAll(":",""));
// 5、司机信息取出来
/**
* `id_` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
* `mobile` varchar(20) DEFAULT NULL COMMENT '手机号',
* `driver_name` varchar(64) DEFAULT NULL COMMENT '姓名',
* `create_time` varchar(64) DEFAULT NULL COMMENT '创建时间',
* `register_city` varchar(6) DEFAULT NULL COMMENT '注册城市(城市编码字典)',
* `driver_type` int(11) DEFAULT NULL COMMENT '司机所属业务类型, "1":快车 "2":出租车 "3":专车',
* `cancel_count` int(11) DEFAULT NULL COMMENT '司机当天有责取消订单的次数',
* `driver_management_id` int(11) DEFAULT NULL COMMENT '司管方id',
*/
// 创建时间
driverInfoMap.put("create_time",StrUtil.isEmpty(data.getString("create_time")) ? "": data.getString("create_time"));
//注册城市城市编码字典
driverInfoMap.put("register_city", StrUtil.isEmpty(data.getString("register_city")) ? "" : data.getString("register_city"));
//司机名字
driverInfoMap.put("driver_name", StrUtil.isEmpty(data.getString("driver_name")) ? "" : data.getString("driver_name"));
// 手机号
driverInfoMap.put("mobile", StrUtil.isEmpty(data.getString("mobile")) ? "" : data.getString("mobile"));
// 司机所属业务类型, "1":快车 "2":出租车 "3":专车
driverInfoMap.put("driver_type", StrUtil.isEmpty(data.getString("driver_type")) ? "" : data.getString("driver_type"));
// 司机当天有责取消订单的次数
driverInfoMap.put("cancel_count", StrUtil.isEmpty(data.getString("cancel_count")) ? "" : data.getString("cancel_count"));
// 司管方id
driverInfoMap.put("driver_management_id", StrUtil.isEmpty(data.getString("driver_management_id")) ? "" : data.getString("driver_management_id")); table.put(HBaseUtils.createPut(rowkey,Constants.HTAB_DRIVER_INFO_FAMILY.getBytes(),driverInfoMap));
}