Java開源生鮮電商平臺-賬單模塊的設計與架構(源碼可下載) 補充說明:Java開源生鮮電商平臺-賬單模塊的設計與架構,即用戶的賬單形成過程。 由於系統存在一個押賬功能的需求,(何為押賬,就是形成公司的資金池,類似摩拜單車,ofo單車等等)。目前B2B平臺也是採用押賬的這種功能策略。 這裡有個特別說 ...
Java開源生鮮電商平臺-賬單模塊的設計與架構(源碼可下載)
補充說明:Java開源生鮮電商平臺-賬單模塊的設計與架構,即用戶的賬單形成過程。
由於系統存在一個押賬功能的需求,(何為押賬,就是形成公司的資金池,類似摩拜單車,ofo單車等等)。目前B2B平臺也是採用押賬的這種功能策略。
這裡有個特別說明的押賬方式:就是比如有個賣家張三,他是5月1日跟我們平臺簽約開始入住平臺賣菜,我們約定好押賬7天,那麼他5月1日的金額會在5月2日存入
他自己的餘額裡面,但是這個錢不能馬上提取出來,需要等一個星期,也就是5月8日可以提現5月1日的金額,5月9日可以提現5月2日以前的所有金額。
這個演算法的最大好處就是永遠的壓住客戶7天的金額。
這個演算法採用的是Spring quartz定時器每天晚上23:00點處理的。
相關核心的代碼如下:
/** * 任務工作 * @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.需要統計每個賣家今天的收入。
2.並行的需要把訂單的數據存入賬單表。
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天。
以下是賬單跟賣家的核心關聯表,就是配置所屬的賣家對應的所屬賬期時間。
總結:整個技術方面其實都不算複雜,主要是業務邏輯以及統計的一些概念,希望這些定時器計算,賬單思路形成,架構方面能給大家一些幫助。
Java開源生鮮電商平臺-賬單模塊的設計與架構(源碼可下載),如果需要下載的話,可以在我的github下麵進行下載。