Java開源生鮮電商平臺-推薦系統模塊的設計與架構(源碼可下載） 業務需求： 對於一個B2B的生鮮電商平臺，對於買家而言，他需要更加快速的購買到自己的產品，跟自己的餐飲店不相關的東西，他是不關心的，而且過多無用的東西摻雜在一起，反而不便 於買家下單，用戶體驗也很差，嚴重的會因此丟了客戶。（客戶覺得太 ...
Java開源生鮮電商平臺-推薦系統模塊的設計與架構(源碼可下載）
業務需求：
對於一個B2B的生鮮電商平臺，對於買家而言，他需要更加快速的購買到自己的產品，跟自己的餐飲店不相關的東西，他是不關心的，而且過多無用的東西摻雜在一起，反而不便
於買家下單，用戶體驗也很差，嚴重的會因此丟了客戶。（客戶覺得太難用了。一般都就會放棄使用.）
對於賣家而言，他自己就調整下自己的商品的上架與下架，然後就是調整下自己商品的價格。（蔬菜類的商品會隨著市場的供求關係會有相應的波動.）
業務分析：
推薦系統：根據買家的行為習慣以及購買行為來推薦些他可能需要的東西的一套演算法系統。
對於買家而言，數量來源於以下三個維度：
1. 購買記錄。-----買家實際下的訂單。
2. 收藏夾。 -----對於買家而言，收藏了某個商品，但是並沒購買的，我們認為他也會購買，屬於需要推送的數據之一。
3. 常用清單。----用戶最近一段時間購買的記錄，我們業務分析認為他一定會再次購買，因為相對一個餐館而言，它所做的菜從某種程度來說是一定的，所以購買的食材，也相對而言也是類似的。也就是說昨天買的，今天可能也會再次夠買，只是數量有所變化而言。
4. 同類推薦。 ----對於一個餐館而言，比如說小炒類似的餐館，那麼很多類似小炒的餐館的所有菜應該也是類似的，也許存在不需要的，但是也存在可能需要的情況，也屬於我們的推薦系統中的。
5. 系統推薦。 ----對於一個剛註冊的買家而言，我們希望給他更好的業務體驗，那麼在註冊的時候，他就會一定選擇一個所屬類別，根據類別，我們會把相應的類別的系統清單推薦出來，讓客戶一進來就感覺到這些他所需要的菜都好像是系統跟他量身定做的一樣。
根據以上的業務分析，我們理清楚了上述的所有維度，以下是資料庫的設計與思路：
1. 購買記錄。來源於訂單明細記錄表：
CREATE TABLE `order_item` ( `item_id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主鍵', `order_id` bigint(20) DEFAULT NULL COMMENT '訂單主表id,order_info表的order_id', `order_number` varchar(32) DEFAULT NULL COMMENT '唯一訂單號', `order_status` tinyint(4) DEFAULT NULL COMMENT '訂單項狀態，1為已提交訂單，2為取消訂單', `format_id` bigint(20) DEFAULT NULL COMMENT '商品規格的ID', `buyer_id` bigint(20) unsigned DEFAULT '0' COMMENT '買家ID', `seller_id` bigint(20) DEFAULT NULL COMMENT '所屬賣家ID', `delivery_type` tinyint(2) DEFAULT '1' COMMENT '配送類型，1為平臺送,2.賣家自己送', `delivery_status` tinyint(2) DEFAULT '0' COMMENT '配送狀態，0 表示未收貨，1表示已收貨,送貨中，2表示已收貨，已送貨', `seller_status` tinyint(4) DEFAULT '0' COMMENT '賣家備貨狀態，0為備貨中，1為備貨完成,2為缺貨', `buyer_status` tinyint(2) unsigned DEFAULT '0' COMMENT '買家狀態，0待收貨，1為已收貨，2為換貨，3為退貨', `remark` varchar(255) DEFAULT NULL COMMENT '訂單項備註，由用戶提交訂單前填寫', `goods_number_old` decimal(12,2) DEFAULT NULL COMMENT '訂單初始商品數量', `goods_number` decimal(12,2) DEFAULT NULL COMMENT '商品的數量', `goods_price` decimal(12,2) DEFAULT NULL COMMENT '商品的單價', `goods_amount` decimal(12,2) DEFAULT NULL COMMENT '單項總金額', `delivery_money` decimal(12,2) DEFAULT '0.00' COMMENT '配送費用', `create_time` datetime DEFAULT NULL COMMENT '訂單創建時間', `delivery_receive_time` datetime DEFAULT NULL COMMENT '配送人員收貨時間', `delivery_finish_time` datetime DEFAULT NULL COMMENT '配送人員完成時間', `seller_finish_time` datetime DEFAULT NULL COMMENT '賣家完成時間', `buyer_finish_time` datetime DEFAULT NULL COMMENT '買家完成時間', `method_id` bigint(20) DEFAULT NULL COMMENT '加工方式ID', `delivery_id` bigint(20) DEFAULT NULL, PRIMARY KEY (`item_id`) ) ENGINE=InnoDB AUTO_INCREMENT=3424 DEFAULT CHARSET=utf8 COMMENT='訂單的子項目';
2. 收藏夾系統資料庫表：
說明：收藏夾比較簡單，某個商品ID，那個買家，什麼時候收藏的。
3. 常用清單
說明：常用清單，維度也是對於商品而言，不是針對某一個店鋪，因為我們市場反饋給出的結論是買家關註的商品本身，而不是那個賣家。
4. 同類分析。
說明：數據來源於類似的餐館點。我們把餐館店分為幾種類型，在地推團隊來銷售產品的時候，其實是知道那個餐館的所屬類別的。
（客戶的類型，1為火鍋店，2為小餐館，3為中餐館，4,為燒烤）
5. 系統推薦。
說明：系統推薦，跟收藏夾，買家常用清單功能都很類似，不同點就在於業務的範圍與範疇。
剛註冊的用戶的常用清單的數據就來源於系統推薦的數據。
相關業務核心代碼如下：
1.註冊代碼中添加
/** * 買家註冊,第二步完善資料 * @param request * @param response * @return */ @RequestMapping(value = "/register/second/step", method = { RequestMethod.GET, RequestMethod.POST }) public JsonResult secondStepRegister(HttpServletRequest request, HttpServletResponse response,@RequestBody Buyer buyer) { logger.info("UsersController.secondStepRegister.seller:新增買家：" + buyer); if (buyer == null) { return new JsonResult(JsonResultCode.FAILURE, "參數異常", ""); } try { buyerService.updateBuyer(buyer); //添加買家預設的常用清單 buyerService.insertBuyerCommon(buyer.getBuyerId(), buyer.getBuyerType(), buyer.getRegionId()); return new JsonResult(JsonResultCode.SUCCESS, "完善買家信息成功",buyer); } catch (Exception e) { logger.error("[UsersController][secondStepRegister] exception :", e); return new JsonResult(JsonResultCode.FAILURE, "系統錯誤,請稍後重試", ""); } }
2.常用清單方面
/** * 我的常用清單 */ @RequestMapping(value = "/my/commonList", method = { RequestMethod.GET, RequestMethod.POST }) public JsonResult commonList(HttpServletRequest request, HttpServletResponse response, Long userId) { try { List<CommonListVo> list = buyerService.getCommonList(userId); return new JsonResult(JsonResultCode.SUCCESS, "查詢信息成功", list); } catch (Exception ex) { logger.error("[MyController][commonList] exception :", ex); return new JsonResult(JsonResultCode.FAILURE, "系統錯誤,請稍後重試", ""); } }
3。系統常用清單
說明：系統常用清單來源於後臺管理人員人工添加
相應代碼如下；
/** * 到新增頁面; */ @RequestMapping(value = "/toAdd", method = { RequestMethod.GET, RequestMethod.POST }) public String toAdd(HttpServletRequest request, HttpServletResponse response, Model model, SysCommonVo sysCommonVo,@ModelAttribute SearchGoodsVo sgv) { // 獲取分頁當前的頁碼 int currentPageNum = this.getPageNum(request); // 獲取分頁的大小 int currentPageSize = this.getPageSize(request); //區域ID Long areaId = sysCommonVo.getAreaId(); sgv.setAreaId(areaId); sgv.setSearchStatus((short) 1); sgv.setFormatStatus((short)1); sgv.setSellerStatus((short)3); List<SysCommonVo> sysCommon = sysCommonService.getSysCommon(sysCommonVo); StringBuffer sb = new StringBuffer(); if(sysCommon.size()>0){ for (int i = 0; i < sysCommon.size(); i++) { if(i != sysCommon.size()-1){ SysCommonVo sc = sysCommon.get(i); sb.append(sc.getGoodsId()); sb.append(","); }else { SysCommonVo sc = sysCommon.get(i); sb.append(sc.getGoodsId()); } } } sgv.setGoodIds(new String(sb)); PageUtil paginator = goodsService.getPageResultByCommon(sgv, currentPageNum, currentPageSize); model.addAttribute("paginator", paginator); model.addAttribute("sgv", sgv); model.addAttribute("sysCommonVo", sysCommonVo); return "sys/common/addFrom"; }
說明：相對而言，這個代碼都是強依賴於資料庫，畢竟不可能很多時間都有人同時買菜與註冊。很多時候都是聯表查詢即可完成數據的分析與統計。
5.定時器代碼。（數據的系統推薦與個性化推薦都是系統採用定時器進行處理的。spring task）
相關代碼如下；
總結：所有的推薦系統的模型都類似我上面來的幾個維度的思考，需要根據自己的業務實際情況，自己分析與總結，至於是同步還是非同步，還是定時器等等都是處理手段，
我這邊就採用了，同步與非同步，包括定時器同時計算的過程，最終達到用戶的推薦效果。
Java開源生鮮電商平臺-推薦系統模塊的設計與架構(源碼可下載），如果需要下載的話，可以在我的github下麵進行下載。
相應的業務實際運行圖如下：
