一、项目概述

建立医药电商大数据分析平台采集医药电商的数据、分析电商平台数据、可视化电商平台数据。可以根据医药产品销售和库存管理来提高销售率等等。

二、功能概述

1.流量分析：根据每日、每月、年度分析用户的行为数据，如浏览量、访客数、访问次数、平均访问深度等等
2.经营状态分析。根据月度或年度对销售状态进行统计，统计指标包括下单金额，下单客户，下单量等等
3.大数据可视化系统

三、关键技术

1.Hadoop：分布式计算平台
2.HBase：分布式数据存储数据库
3.Bootstrap：页面搭建框架
4.IQuery：后台交互
5.Echarts:数据可视化

四、系统架构设计

4.1 大数据采集子系统

4.1.1定义

系统以离线批处理方式，推送采集结果数据给大数据分析平台。

4.1.2接口

采集大数据接受的格式、大数据接口定义

五、数据存储设计

5.2数据采集子系统

5.2.1采集用户流量数据

WsSysAgentAccessVo.java采集用户流量数据，实现了Serializable接口。它包含以下属性：
sessionId（String类型）：会话ID
userId（Integer类型）：登录用户的ID
trackUid（String类型）：用户标识
userAgent（String类型）：用户UA
referer（String类型）：访问的页面地址
数据格式

“WsSysAgentAccessVo [sessionId=xxx, userId=xxx, trackUid=xxx,
userAgent=xxx, referer=xxx]”

package receiveVo;
import java.io.Serializable;
public class WsSysAgentAccessVo implements Serializable {private static final long serialVersionUID = 1L;
private String sessionId;  //会话IDprivate Integer userId;    //登录用户的IDprivate String trackUid;   //用户标识private String userAgent;  //用户UAprivate String referer;    //访问的页面地址public String getSessionId() {return sessionId;}public void setSessionId(String sessionId) {this.sessionId = sessionId;}public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId = userId;}public String getTrackUid() {return trackUid;}public void setTrackUid(String trackUid) {this.trackUid = trackUid;}public String getUserAgent() {return userAgent;}public void setUserAgent(String userAgent) {this.userAgent = userAgent;}public String getReferer() {return referer;}@Overridepublic String toString() {return "WsSysAgentAccessVo [sessionId=" + sessionId + ", userId=" + userId + ", trackUid=" + trackUid+ ", userAgent=" + userAgent + ", referer=" + referer + "]";}public void setReferer(String referer) {this.referer = referer;}
}

5.2.2采集用户订单数据

WsOrderVo.java采集用户订单数据，实现了Serializable接口。它包含了以下属性：
orderId（int类型）：订单ID
userId（int类型）：下单的用户ID
orderNum（String类型）：订单编号
payment（Double类型）：支付总金额
productTotalAmount（Double类型）：订单商品总金额
isCod（String类型）：是否货到付款
orderStatus（String类型）：订单状态

package receiveVo;
import java.io.Serializable;
public class WsOrderVo implements Serializable{private static final long serialVersionUID = 1L;private int orderId;               //订单IDprivate int userId;                //下单的用户IDprivate String orderNum;           //订单编号private Double payment;            //支付总金额private Double productTotalAmount; //订单商品总金额private String isCod;              //是否货到付款private String orderStatus;        //订单状态public WsOrderVo(){}public int getOrderId(){return orderId;}public void setOrderId(int orderId){this.orderId = orderId;}public int getUserId(){return userId;}public void setUserId(int userId){this.userId = userId;}public String getOrderNum(){return orderNum;}public void setOrderNum(String orderNum){this.orderNum = orderNum;}public Double getPayment(){return payment;}public void setPayment(Double payment){this.payment = payment;}public Double getProductTotalAmount(){return productTotalAmount;}public void setProductTotalAmount(Double productTotalAmount){this.productTotalAmount = productTotalAmount;}public String getIsCod(){return isCod;}public void setIsCod(String isCod