基于Java、JavaScript、CSS、HTML的果蔬商城开源设计源码

package com.spy.mall.shop.product.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.spy.mall.common.constant.Constants; import com.spy.mall.common.domain.ExecuteResult; import com.spy.mall.common.domain.PageBean; import com.spy.mall.shop.api.domain.entity.ShopProduct; import com.spy.mall.shop.api.domain.entity.ShopProductPicture; import com.spy.mall.shop.api.domain.entity.ShopSellType; import com.spy.mall.shop.api.domain.vo.ShopDetailProductVo; import com.spy.mall.shop.api.domain.vo.ShopIndexProductVo; import com.spy.mall.shop.api.domain.vo.ShopProductPictureVo; import com.spy.mall.shop.api.domain.vo.ShopProductVo; import com.spy.mall.shop.product.mapper.ShopProductMapper; import com.spy.mall.shop.product.mapper.ShopProductPictureMapper; import com.spy.mall.shop.product.mapper.ShopSellTypeMapper; import com.spy.mall.shop.product.repository.IndexProductElasticRepository; import com.spy.mall.shop.product.service.ShopProductService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; /** * @Author: spy * @Date: 2019/2/7 17:22 * @Version 1.0 */ @Transactional @Service public class ShopProductServiceImpl implements ShopProductService { @Autowired private ShopProductMapper productMapper; @Autowired private ShopProductPictureMapper productPictureMapper; @Autowired private ShopSellTypeMapper sellTypeMapper; @Autowired private IndexProductElasticRepository indexProductElasticRepository; private static final Logger LOGGER = LoggerFactory.getLogger(ShopProductServiceImpl.class); @Override public ExecuteResult<ShopProductVo> insert(ShopProduct entity) { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { int insert = productMapper.insert(entity); if (insert > 0) { // 成功 successed(result, "添加成功!"); // 封装传输对象 ShopProductVo productVo = new ShopProductVo(); BeanUtils.copyProperties(entity, productVo); result.setEntityVo(productVo); } else { executed(result, "添加失败!"); } } catch (Exception e) { LOGGER.error("系统运行时错误！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductVo> updateById(ShopProduct entity) { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { int insert = productMapper.updateById(entity); if (insert > 0) { // 更新es中的数据 List<ShopIndexProductVo> productVos = productMapper.selectIndexProductsByProductId(entity.getProductId()); indexProductElasticRepository.save(productVos); // 封装传输对象 ShopProductVo productVo = new ShopProductVo(); BeanUtils.copyProperties(entity, productVo); result.setEntityVo(productVo); successed(result, "更新成功!"); } else { executed(result, "更新失败!"); } } catch (Exception e) { LOGGER.error("系统运行时错误！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductVo> selectById(Long id) { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { ShopProductVo productVo = productMapper.selectDetailById(id); if (productVo != null) { // 成功 successed(result, "查询成功!"); result.setEntityVo(productVo); } else { // 失败 executed(result, "查询失败!"); } } catch (Exception e) { LOGGER.error("系统运行时错误！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductVo> deleteById(Long id) { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { int delete = productMapper.deleteById(id); if (delete > 0) { List<ShopIndexProductVo> productVos = productMapper.selectIndexProductsByProductId(id); indexProductElasticRepository.delete(productVos); // 删除成功 successed(result, "删除成功!"); } else { // 删除失败 executed(result, "删除失败!"); } } catch (Exception e) { LOGGER.error("有相关数据存在，不能删除！！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductVo> deleteBatchIds(String ids) { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { String[] idStrs = ids.split(Constants.ID_SPLIT_SIGN); int deleteBatchIds = productMapper.deleteBatchIds(Arrays.asList(idStrs)); if (deleteBatchIds > 0) { successed(result, "删除成功!"); for (String idStr : idStrs) { List<ShopIndexProductVo> productVos = productMapper.selectIndexProductsByProductId(Long.valueOf(idStr)); indexProductElasticRepository.delete(productVos); } } else { executed(result, "删除失败!"); } } catch (Exception e) { LOGGER.error("有相关数据存在，不能删除！", e); throw e; } return result; } @Override public ExecuteResult<PageBean<ShopProductVo>> selectByPage(PageBean<ShopProductVo> pageBean) { ExecuteResult<PageBean<ShopProductVo>> result = new ExecuteResult<>(); try { List<ShopProductVo> productVos = productMapper.selectByPage(pageBean); long total = productMapper.selectTotal(pageBean); pageBean.setRecords(productVos); pageBean.setTotal(total); result.setEntityVo(pageBean); successed(result, "查询成功!"); } catch (Exception e) { LOGGER.error("系统运行时错误！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductVo> selectAllIdAndName() { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { List<ShopProductVo> productVos = productMapper.selectAllIdAndName(); result.setEntityVos(productVos); successed(result, "查询成功!"); } catch (Exception e) { LOGGER.error("系统运行时错误！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductVo> selectOneIdAndName(Long id) { ExecuteResult<ShopProductVo> result = new ExecuteResult<>(); try { ShopProductVo productVo = productMapper.selectOneIdAndName(id); result.setEntityVo(productVo); successed(result, "查询成功!"); } catch (Exception e) { LOGGER.error("系统运行时错误！", e); throw e; } return result; } @Override public ExecuteResult<ShopProductPictureVo> saveProductPicture(ShopProductPicture productPicture) { ExecuteResult<ShopProductPictureVo> result = new ExecuteResult<>(); try { int insert = productPictureMapper.insert(productPicture); if (insert > 0) { successed(result, "商�