Java生鲜电商平台-帐单模块的设计与架构算法
补充说明：生鲜电商平台-帐单模块的设计与架构，即用户的帐单造成过程。架构
因为系统存在一个押帐功能的需求，（何为押帐，就是造成公司的资金池，相似摩拜单车，ofo单车等等）。目前B2B平台也是采用押帐的这种功能策略。ide
这里有个特别说明的押帐方式：就是好比有个卖家张三，他是5月1日跟咱们平台签约开始入住平台卖菜，咱们约定好押帐7天，那么他5月1日的金额会在5月2日存入设计
他本身的余额里面，可是这个钱不能立刻提取出来，须要等一个星期，也就是5月8日能够提现5月1日的金额，5月9日能够提现5月2日之前的全部金额。code
这个算法的最大好处就是永远的压住客户7天的金额。blog
这个算法采用的是Spring quartz定时器天天晚上23:00点处理的。ci
相关核心的代码以下：get
/**
* 任务工做
* @author wangfucai
*/
@Component
public class TasksQuartz{
private static final Logger logger=LoggerFactory.getLogger(TasksQuartz.class);
@Autowired
private BillService billService;
@Autowired
private SellerService sellerService;
@Autowired
private DeliveryIncomeService deliveryIncomeService;
@Autowired
private BuyerService buyerService;
@Autowired
private OrderInfoService orderInfoService;
@Autowired
private GroupsBuyerService groupsBuyerService;
/**
* 计算天天帐单
* 天天23点执行
*/
@Scheduled(cron="0 0 23 * * ?")
protected void makeBill(){
try
{
logger.info("TasksQuartz.execute.start");
//统计当天的交易完成的订单生成帐单
billService.addBills();
logger.info("帐单数据更新完成");
//根据卖家抽点金额更新帐单实际金额
billService.updateRealAmountByPercentage();
logger.info("根据卖家抽点金额更新帐单实际金额完成");
//更新卖家余额
sellerService.updateBalanceByBill();
logger.info("卖家余额数据更新完成");
logger.info("TasksQuartz.execute.end");
}catch(Exception ex)
{
logger.error("TasksQuartz.execute.exception",ex);
}
}
补充说明：1.须要统计每一个卖家今天的收入。it
2.并行的须要把订单的数据存入帐单表。io
3.余额来源于帐单表。造成一个数据的流转体现。
帐单表的表结构以下：
补充说明：天天定时器会根据卖家的帐期造成帐单，最终更新到用卖家的余额里面。
实际运营状况来说是每一个卖家的帐期是不同的，有的两天，有的三天，有的一周，有的是一个月。
相关核心算法与代码以下：
/**
* 统计10天前的帐单更新卖家余额和帐单金额
*/
@Override
public void updateMoney() {
// 获取10天前的日期d
String day = DateUtil.dateToString(DateUtil.addDay(new Date(), -9), DateUtil.FMT_DATE);
// 查询十天前的全部账单信息
List<Map<String, Object>> list = billDao.getBillsByDay(day);
if (CollectionUtils.isEmpty(list)) {
logger.info("TasksQuartz.updateMoney.isEmpty-->day:" + day);
return;
}
for (Map<String, Object> map : list) {
// 卖家ID
Long sellerId = (Long) map.get("sellerId");
if (sellerId == null) {
continue;
}
// 获取提现的金额即最终帐单的金额
BigDecimal realityMoney = (BigDecimal) map.get("realIncome");
if (realityMoney == null) {
continue;
}
// 获取卖家的余额
BigDecimal balanceMoney = (BigDecimal) map.get("balanceMoney");
if (balanceMoney == null) {
balanceMoney = BigDecimal.ZERO;
}
// 获取卖家的帐单金额
BigDecimal billMoney = (BigDecimal) map.get("billMoney");
if (billMoney == null) {
billMoney = BigDecimal.ZERO;
}
// 金额相加
BigDecimal resultBalanceMoney = realityMoney.add(balanceMoney);
BigDecimal resultBillMoney = realityMoney.add(billMoney);
logger.info("当前用户sellerId:" + sellerId + " 当前的余额为：balanceMoney=" + balanceMoney
+ " 最终金额：resultBalanceMoney=" + resultBalanceMoney);
logger.info("当前的余额为：billMoney=" + billMoney + " 最终金额：resultBillMoney=" + resultBillMoney);
// 更新卖家余额和帐单金额
int result = sellerDao.updateMoney(sellerId, resultBalanceMoney, resultBillMoney);
logger.info("当前用户sellerId:" + sellerId + " 更新结果为：" + (result > 0));
}
// 更新十天前的全部帐单的状态
int count = billDao.updateStatus(day);
logger.info(" 更新" + count + "条帐单，状态变为已结算");
}
业务说明：
1. 无外乎天天须要统计卖家的今日收益状况。
2. 更新卖家的最终余额。
3. 根据卖家的所设置的帐单周期，造成用户的帐单金额。
4. 最终根据帐单金额，造成用户的可提现余额的过程。
业务有点绕口，可是总体是很是地清晰的，思路就是押用户所配置的帐期金额。配置10天就压10天，配置15天就压15天。
如下是帐单跟卖家的核心关联表，就是配置所属的卖家对应的所属帐期时间。
总结：整个技术方面其实都不算复杂，主要是业务逻辑以及统计的一些概念，但愿这些定时器计算，帐单思路造成，架构方面能给你们一些帮助。