shop--10.商品--商品添加（后端）

商品添加dao层

    /**
     * 插入商品
     * 
     * @param product
     * @return
     */
    int insertProduct(Product product);

商品添加映射文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper 
  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ryanxu.o2o.dao.ProductDao">
    <insert id="insertProduct"
        parameterType="com.ryanxu.o2o.entity.Product" useGeneratedKeys="true"
        keyProperty="productId" keyColumn="product_id">
        INSERT INTO
        tb_product(product_name,product_desc,img_addr,
        normal_price,promotion_price,priority,create_time,
        last_edit_time,enable_status,product_category_id,
        shop_id)
        VALUES
        (#{productName},#{productDesc},#{imgAddr},
        #{normalPrice},#{promotionPrice},#{priority},#{createTime},
        #{lastEditTime},#{enableStatus},#{productCategory.productCategoryId},
        #{shop.shopId})
    </insert>
</mapper>

批量添加商品图片dao层

    /**
     * 批量添加商品详情图片
     * @param productImgList
     * @return
     */
    int batchInsertProductImg(List<ProductImg> productImgList);

批量添加商品图片映射文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper 
  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  <mapper namespace="com.ryanxu.o2o.dao.ProductImgDao">
      <insert id="batchInsertProductImg" parameterType="java.util.List">
          INSERT INTO
          tb_product_img(img_addr,img_desc,priority,
          create_time,product_id)
          VALUES
          <foreach collection="list" item="productImg" index="index"
              separator=",">
              (
               #{productImg.imgAddr},
               #{productImg.imgDesc},
               #{productImg.priority},
               #{productImg.createTime},
               #{productImg.productId}
              )    
          </foreach>
      </insert>
  </mapper>

在做单元测试的时候需要继承BaseTest

Service层

步骤如下：

• 1.处理商品的缩略图，获取相对路径，为了调用dao层的时候写入 tb_product中的 img_addr字段有值

• 2.写入tb_product ，得到product_id（Mybatis自动映射进去的）

• 3.集合product_id 批量处理商品详情图片

• 4.将商品详情图片 批量更新到 tb_proudct_img表

    /**
     * 添加商品信息以及图片处理
     * 
     * @param product
     * @param thumbnail 缩略图
     * @param productImgs 详情图
     * @return
     * @throws ProductCategoryOperationException
     */
    ProductExecution addProduct(Product product,ImageHolder thumbanil,List<ImageHolder> productImgList) throws ProductCategoryOperationException;

因为每次都需要传入文件流和文件名 所以使用ImageHolder来专门包装这两个属性
public class ImageHolder {
    private String imageName;
    private InputStream image;
    
    public ImageHolder(String imageName, InputStream image) {
        this.imageName = imageName;
        this.image = image;
    }

    public String getImageName() {
        return imageName;
    }

    public void setImageName(String imageName) {
        this.imageName = imageName;
    }

    public InputStream getImage() {
        return image;
    }

    public void setImage(InputStream image) {
        this.image = image;
    }
    
    
}

Service层的实现类

@Service
public class ProductServiceImpl implements ProductService{
    @Autowired
    private ProductDao productDao;
    @Autowired
    private ProductImgDao productImgDao;
    
    @Override
    @Transactional
    //1.处理缩略图，获取缩略图相对路径并赋值给product
    //2.往tb_product写入商品信息，获取productId
    //3.结合productId批量处理商品详情图
    //4.将商品详情图列表批量插入tb_product_img中
    public ProductExecution addProduct(Product product, ImageHolder thumbanil, List<ImageHolder> productImgList)
            throws ProductCategoryOperationException {
        //空值判断
        if(product!=null&&product.getShop()!=null&&product.getShop().getShopId()!=null) {
            //给商品设置默认属性
            product.setCreateTime(new Date());
            product.setLastEditTime(new Date());
            //默认为上架的状态
            product.setEnableStatus(1);
            //若商品缩略图不为空则添加
            if(thumbanil!=null) {
                addThumbnail(product,thumbanil);
            }
            try {
                //创建商品信息
                int effectedNum = productDao.insertProduct(product);
                if(effectedNum<=0) {
                    throw new ProductOperationException("创建商品失败");
                }
            }catch (Exception e) {
                throw new ProductOperationException("创建商品失败 ：" +e.toString());
            }
            //若商品详情图不为空则添加
            if(productImgList != null && productImgList.size() >0) {
                addProductImgList(product,productImgList);
            }
            return new ProductExecution(ProductStateEnum.SUCCESS,product);
        }else {
            //传参为空则返回空值错误信息
            return new ProductExecution(ProductStateEnum.NULL_PRODUCT);
        }
    }
    

    /**
     * 将商品缩略图添加到用户相对的文件夹下，并将店铺信息中的商品图片信息更新
     * 
     * @param product
     * @param imageHolder
     */
    private void addThumbnail(Product product,ImageHolder imageHolder) {
        //获取缩略图的存储途径，直接存储在店铺的文件夹下
        String dest = PathUtil.getShopImagePath(product.getShop().getShopId());
        //返回相对路径
        String thumbnailAddr = ImageUtil.generateThumbnail(imageHolder, dest);
        product.setImgAddr(thumbnailAddr);
    }
    
    /**
     * 批量添加商品详情图片到用户相对的文件夹下，并将其批量插入到数据库中
     * 
     * @param product
     * @param productImgHolderList
     */
    private void addProductImgList(Product product, List<ImageHolder> productImgHolderList) {
        //获取图片存储路径，这里直接存放到相应店铺的文件夹底下
        String dest = PathUtil.getShopImagePath(product.getShop().getShopId());
        List<ProductImg> productImgList = new ArrayList<>();
        //遍历图片一次去处理，并添加进productImg实体类里
        for(ImageHolder productImgHolder:productImgHolderList) {
            String imgAddr = ImageUtil.generateNormalImg(productImgHolder,dest);
            ProductImg productImg  = new ProductImg();
            productImg.setImgAddr(imgAddr);
            productImg.setProductId(product.getProductId());
            productImg.setCreateTime(new Date());
            productImgList.add(productImg);
        }
        //如果确实是有图片需要添加的，就执行批量添加操作
        if(productImgList.size() > 0) {
            try {
                int effectedNum = productImgDao.batchInsertProductImg(productImgList);
                if(effectedNum <= 0) {
                    throw new ProductOperationException("创建商品详情图片失败");
                }
            }catch (Exception e) {
                throw new ProductOperationException("创建商品详情图片失败: "+e.toString());
            }
        }
    }
}

Controller层

步骤如下：

• 获取前端传递过来的Product对象，通过FastJson提供的api将其转换为Product对象

• 获取前端传递过来的商品缩略图以及商品详情图片，通过CommonsMultipartResolver来处理

• 调用Service层的服务来持久化数据及图片的操作

@Controller
@RequestMapping("/shopadmin")
public class ProductManagementController {
    @Autowired
    private ProductService productService;
    
    //支持上传商品详情图的最大数量
    private static final int IMAGEMAXCOUNT=6;
    
    /**
     *     前端页面通过post方式传递一个包含文件上传的Form会以multipart/form-data请求发送给服务器，
     * 
     *  需要告诉DispatcherServlet如何处理MultipartRequest，我们在spring-web.
     *  xml中定义了multipartResolver。
     * 
     *  如果某个Request是一个MultipartRequest，它就会首先被MultipartResolver处理，
     *  然后再转发相应的Controller。
     * 
     *  在Controller中，
     *  将HttpServletRequest转型为MultipartHttpServletRequest
     *  ，可以非常方便的得到文件名和文件内容
     * @param request
     * @return    
     * @throws IOException
     */
    @RequestMapping(value="/addproduct",method=RequestMethod.POST)
    @ResponseBody
    private Map<String, Object> addproduct(HttpServletRequest request) throws IOException{
        Map<String, Object> modelMap = new HashMap<>();
        
        //初始化各种参数！！！！
        //接收前端传递过来的product
        Product product = null;
        String productStr = HttpServletRequestUtil.getString(request, "productStr");
        //处理文件流
        MultipartHttpServletRequest multipartHttpServletRequest = null;
        //接收前端传递过来的product
        ImageHolder thumbnail = null;
        // 接收商品详情图片
        List<ImageHolder> productImgList = new ArrayList<>();
        //在本次会话的上下文获取上传的文件
        CommonsMultipartResolver commonsMultipartResolver = new CommonsMultipartResolver(request.getSession().getServletContext());
        
        //步骤1：验证码校验
        if(!CodeUtil.checkVerifyCode(request)) {
            modelMap.put("success", false);
            modelMap.put("errMsg", "验证码错误");
            return modelMap;
        }
        //步骤2：使用FastJson提供的api,实例化Product 构造调用service层的第一个参数
        //接受前端参数变量的初始化，商品，缩略图，详情图列表实体类
        ObjectMapper objectMapper = new ObjectMapper();
        // 获取前端传递过来的product,约定好使用productStr
        try {
            product = objectMapper.readValue(productStr, Product.class);
        } catch (Exception e) {
            modelMap.put("success", false);
            modelMap.put("errMsg", e.toString());
            return modelMap;
        }
        //步骤3: 商品缩略图 和 商品详情图 构造调用service层的第二个参数和第三个参数
        try {
            //若请求中存在文件流，则取出相关的文件（包括缩略图和详情图）
            if(commonsMultipartResolver.isMultipart(request)) {
                // 将HttpServletRequest转型为MultipartHttpServletRequest，可以很方便地得到文件名和文件内容
                multipartHttpServletRequest = (MultipartHttpServletRequest) request;
                
                //1.接收商品缩略图  取出缩略图并构建ImageHolder对象 
                CommonsMultipartFile thumbnailFile = (CommonsMultipartFile) multipartHttpServletRequest.getFile("thumbnail");
                //2.转化为ImageHolder，使用service层的参数类型要求
                thumbnail = new ImageHolder(thumbnailFile.getOriginalFilename(), thumbnailFile.getInputStream());
                //3.取出详情图列表并构建List<ImageHolder>列表对象，最多支持六张图上传
                for(int i = 0; i < IMAGEMAXCOUNT; i++){
                    CommonsMultipartFile commonsMultipartFile = (CommonsMultipartFile) multipartHttpServletRequest.getFile("productImg" + i);
                    if(commonsMultipartFile != null){
                        //若取出的第i个详情图片文件流不为空，则将其加入详情图列表
                        ImageHolder productImg = new ImageHolder(commonsMultipartFile.getOriginalFilename(), commonsMultipartFile.getInputStream());
                        productImgList.add(productImg);
                    } else {
                        //若取出的第i个详情图片文件流为空，则终止循环
                        break;
                    }
                }
 
            } else{
                modelMap.put( "success", false );
                modelMap.put( "errMsg", "上传图片不能为空" );
            }
        } catch (Exception e){
            modelMap.put( "success", false );
            modelMap.put( "errMsg", e.toString() );
            return modelMap;
        }

        //步骤4：调用service层
        //若product，thumbnail（缩略图），productImgList（商品详情图片列表）不为空，则进行商品添加
        if(product != null && thumbnail != null && productImgList.size() > 0){
            try{
                //从session中获取当前shop的id赋值给product，减少对前端数据的依赖
                Shop currentShop = (Shop) request.getSession().getAttribute( "currentShop" );
               
/*                Shop currentShop = new Shop();
                currentShop.setShopId( 1L );*/
                Shop shop = new Shop();
                shop.setShopId(currentShop.getShopId());
                product.setShop(shop);
                //执行添加操作
                ProductExecution productExecution = productService.addProduct( product, thumbnail, productImgList );
                if(productExecution.getState() == ProductStateEnum.SUCCESS.getState()){
                    modelMap.put( "success", true );
                }else{
                    modelMap.put( "success", false );
                    modelMap.put( "errMsg", productExecution.getStateInfo() );
                }
            } catch(ProductOperationException e){
                modelMap.put( "success", false );
                modelMap.put( "errMsg", e.toString() );
                return modelMap;
            }
        }else{
            modelMap.put( "success", false );
            modelMap.put( "errMsg", "请输入商品信息" );
        }
        return modelMap;
    }
}