11、生鮮電商平臺-賬單模組的設計與架構
補充說明：生鮮電商平臺-賬單模組的設計與架構，即使用者的賬單形成過程。
由於系統存在一個押賬功能的需求，（何為押賬，就是形成公司的資金池，類似摩拜單車，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天。
以下是賬單跟賣家的核心關聯表，就是配置所屬的賣家對應的所屬賬期時間。
總結：整個技術方面其實都不算複雜，主要是業務邏輯以及統計的一些概念，希望這些定時器計算，賬單思路形成，架構方面能給大家一些幫助。
轉子自-- https://www.cnblogs.com/jurendage/p/9053417.html