Java开源生鲜电商平台-推荐系统模块的设计与架构…

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='订单的子项目';

    /**
     * 买家注册,第二步完善资料
     * @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, "系统错误,请稍后重试", "");
        }
    }

    /**
     * 我的常用清单
     */
    @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, "系统错误,请稍后重试", "");
        }
    }

/**
     * 到新增页面;
     */
    @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";
    }