网站开发 学习步骤,网站wap版,手机网站如何建立,免费网站 推广网站目录
1.创建主程序——DwdOrderRelevantApp类
2.创建DWD层的事实表——来源于订单表和订单明细表
(1)创建订单表实体类
(2)创建订单明细表实体类
(3)创建交易域#xff1a;下单事务事实表实体类#xff0c;并整合(1)与(2)#xff0c;采用下单时间
(4)创建交易域#…目录
1.创建主程序——DwdOrderRelevantApp类
2.创建DWD层的事实表——来源于订单表和订单明细表
(1)创建订单表实体类
(2)创建订单明细表实体类
(3)创建交易域下单事务事实表实体类并整合(1)与(2)采用下单时间
(4)创建交易域支付成功事务事实表实体类并整合(1)与(2)采用支付时间和支付状态
(5)创建物流域揽收接单事务事实表实体类并整合(1)与(2)采用揽收时间
(6)创建物流域发单事务事实表实体类并整合(1)与(2)采用发货时间
(7)创建物流域转运完成事务事实表实体类并整合(1)与(2)采用转运完成时间
(8)创建物流域派送成功事务事实表实体类并整合(1)与(2)采用派送成功时间
(9)创建物流域签收事务事实表实体类并整合(1)与(2)采用签收时间
(10)创建交易域取消运单事务事实表实体类并整合(1)与(2)采用取消时间 1.创建主程序——DwdOrderRelevantApp类
package com.atguigu.tms.realtime.app.dwd;/*** 订单相关事实表准备* 需要启动的进程* zk、kafka、hdfs、OdsApp、DwdOrderRelevantApp**/public class DwdOrderRelevantApp {public static void main(String[] args) throws Exception {// TODO 1.环境准备// 1.1 指定流处理环境以及检查点相关的设置// 1.2 设置并行度和kafka主题的分区数保持一致// TODO 2.从kafka的tms_ods主题中读取// 2.1 声明消费的主题 // 2.2 创建消费者对象 // 2.3 消费数据 封装为流// TODO 3.筛选订单和订单明细数据// TODO 4.对流中的数据类型进行转换 jsonStr - jsonObj// TODO 5.按照order_id进行分组// TODO 6.定义侧输出流标签匿名内部类// 主流下单// 侧输出流支付成功、取消订单、揽收(接单)、发单、转运完成、派送成功、签署// TODO 7.分流// TODO 8.从主流中提取侧输出流// TODO 9.将不同流的数据写到kafka的不同主题中}
}2.创建DWD层的事实表——来源于订单表和订单明细表
(1)创建订单表实体类
package com.atguigu.tms.realtime.beans;import lombok.Data;import java.math.BigDecimal;/*** 订单实体类*/
Data
public class DwdOrderInfoOriginBean {// 编号主键String id;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间Long estimateArriveTime;// 距离单位公里BigDecimal distance;// 创建时间String createTime;// 更新时间String updateTime;// 是否删除String isDeleted;
}(2)创建订单明细表实体类
package com.atguigu.tms.realtime.beans;import lombok.Data;import java.math.BigDecimal;/***订单货物明细实体类*/
Data
public class DwdOrderDetailOriginBean {// 编号主键String id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumnLength;// 宽cmInteger volumnWidth;// 高cmInteger volumnHeight;// 重量 kgBigDecimal weight;// 创建时间String createTime;// 更新时间String updateTime;// 是否删除String isDeleted;
}
(3)创建交易域下单事务事实表实体类并整合(1)与(2)采用下单时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***交易域:下单事务事实表实体类*/
Data
public class DwdTradeOrderDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 下单时间String orderTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;this.orderTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(detailOriginBean.createTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(detailOriginBean.createTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;}
}
(4)创建交易域支付成功事务事实表实体类并整合(1)与(2)采用支付时间和支付状态
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***交易域:支付成功事务事实表实体类*/
Data
public class DwdTradePaySucDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 支付时间String payTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.payTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}
(5)创建物流域揽收接单事务事实表实体类并整合(1)与(2)采用揽收时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***物流域:揽收接单事务事实表实体类*/
Data
public class DwdTransReceiveDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 揽收时间String receiveTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.receiveTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}
(6)创建物流域发单事务事实表实体类并整合(1)与(2)采用发货时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***物流域:发单事务事实表实体类*/
Data
public class DwdTransDispatchDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 发单时间String dispatchTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.dispatchTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}(7)创建物流域转运完成事务事实表实体类并整合(1)与(2)采用转运完成时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***物流域:转运完成事务事实表实体类*/
Data
public class DwdTransBoundFinishDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 转运完成时间String boundFinishTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.boundFinishTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}(8)创建物流域派送成功事务事实表实体类并整合(1)与(2)采用派送成功时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***物流域:派送成功事务事实表实体类*/
Data
public class DwdTransDeliverSucDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 派送成功时间String deliverTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.deliverTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}
(9)创建物流域签收事务事实表实体类并整合(1)与(2)采用签收时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/*** 物流域:签收事务事实表实体类*/
Data
public class DwdTransSignDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 签收时间String signTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.signTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}(10)创建交易域取消运单事务事实表实体类并整合(1)与(2)采用取消时间
package com.atguigu.tms.realtime.beans;import com.atguigu.tms.realtime.utils.DateFormatUtil;
import lombok.Data;import java.math.BigDecimal;/***交易域:取消运单事务事实表实体类*/
Data
public class DwdTradeCancelDetailBean {// 运单明细IDString id;// 运单idString orderId;// 货物类型String cargoType;// 长cmInteger volumeLength;// 宽cmInteger volumeWidth;// 高cmInteger volumeHeight;// 重量 kgBigDecimal weight;// 取消时间String cancelTime;// 运单号String orderNo;// 运单状态String status;// 取件类型1为网点自寄2为上门取件String collectType;// 客户idString userId;// 收件人小区idString receiverComplexId;// 收件人省份idString receiverProvinceId;// 收件人城市idString receiverCityId;// 收件人区县idString receiverDistrictId;// 收件人姓名String receiverName;// 发件人小区idString senderComplexId;// 发件人省份idString senderProvinceId;// 发件人城市idString senderCityId;// 发件人区县idString senderDistrictId;// 发件人姓名String senderName;// 支付方式String paymentType;// 货物个数Integer cargoNum;// 金额BigDecimal amount;// 预计到达时间String estimateArriveTime;// 距离单位公里BigDecimal distance;// 时间戳Long ts;public void mergeBean(DwdOrderDetailOriginBean detailOriginBean, DwdOrderInfoOriginBean infoOriginBean) {// 合并原始明细字段this.id detailOriginBean.id;this.orderId detailOriginBean.orderId;this.cargoType detailOriginBean.cargoType;this.volumeLength detailOriginBean.volumnLength;this.volumeWidth detailOriginBean.volumnWidth;this.volumeHeight detailOriginBean.volumnHeight;this.weight detailOriginBean.weight;// 合并原始订单字段this.orderNo infoOriginBean.orderNo;this.status infoOriginBean.status;this.collectType infoOriginBean.collectType;this.userId infoOriginBean.userId;this.receiverComplexId infoOriginBean.receiverComplexId;this.receiverProvinceId infoOriginBean.receiverProvinceId;this.receiverCityId infoOriginBean.receiverCityId;this.receiverDistrictId infoOriginBean.receiverDistrictId;this.receiverName infoOriginBean.receiverName;this.senderComplexId infoOriginBean.senderComplexId;this.senderProvinceId infoOriginBean.senderProvinceId;this.senderCityId infoOriginBean.senderCityId;this.senderDistrictId infoOriginBean.senderDistrictId;this.senderName infoOriginBean.senderName;this.paymentType infoOriginBean.paymentType;this.cargoNum infoOriginBean.cargoNum;this.amount infoOriginBean.amount;this.estimateArriveTime DateFormatUtil.toYmdHms(infoOriginBean.estimateArriveTime - 8 * 60 * 60 * 1000);this.distance infoOriginBean.distance;this.cancelTime DateFormatUtil.toYmdHms(DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000);this.ts DateFormatUtil.toTs(infoOriginBean.updateTime.replaceAll(T, ).replaceAll(Z, ), true) 8 * 60 * 60 * 1000;}
}
