足迹、收藏订单兼容新需求

yujian

2020-05-23 28cf328a098334b51a3e9d2d56f983fb8c862211

 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/ScanHistoryV2ServiceImpl.java

@@ -1,15 +1,18 @@
package com.yeshi.fanli.service.impl.goods;



import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Service;



import com.yeshi.fanli.dao.mybatis.goods.ScanHistoryV2Mapper;

import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.goods.CommonGoods;

import com.yeshi.fanli.entity.goods.ScanHistoryV2;

import com.yeshi.fanli.entity.jd.JDGoods;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.exception.goods.CommonGoodsException;

import com.yeshi.fanli.exception.goods.ScanHistoryException;

@@ -32,21 +35,73 @@
         throws CommonGoodsException, ScanHistoryException {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         throw new ScanHistoryException(1, "设备或用户信息缺失");

		
      CommonGoods commonGoods = CommonGoodsFactory.create(goods);

      commonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);

      if (commonGoods == null)

         throw new CommonGoodsException(2, "商品信息不完整");

		
      // 添加浏览记录

      ScanHistoryV2 scanHistoryV2 = new ScanHistoryV2();

      scanHistoryV2.setCommonGoods(commonGoods);

      scanHistoryV2.setCreateTime(new Date());

      scanHistoryV2.setDevice(device);

		
      if (uid != null)

         scanHistoryV2.setUserInfo(new UserInfo(uid));

		
      scanHistoryV2.setUpdateTime(new Date());

      scanHistoryV2Mapper.insertSelective(scanHistoryV2);

   }



	
   @Override

   public void addJDScanHistory(Long uid, String device, JDGoods goods) throws CommonGoodsException, ScanHistoryException {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         throw new ScanHistoryException(1, "设备或用户信息缺失");

		
      CommonGoods commonGoods = CommonGoodsFactory.create(goods);

      commonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);

      if (commonGoods == null)

         throw new CommonGoodsException(2, "商品信息不完整");

		
      // 添加浏览记录

      ScanHistoryV2 scanHistoryV2 = new ScanHistoryV2();

      scanHistoryV2.setCommonGoods(commonGoods);

      scanHistoryV2.setCreateTime(new Date());

      scanHistoryV2.setDevice(device);

		
      if (uid != null)

         scanHistoryV2.setUserInfo(new UserInfo(uid));

		
      scanHistoryV2.setUpdateTime(new Date());

      scanHistoryV2Mapper.insertSelective(scanHistoryV2);

   }

	
	
   @Override

   public void addPDDScanHistory(Long uid, String device, PDDGoodsDetail pddGoods) throws CommonGoodsException, ScanHistoryException {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         throw new ScanHistoryException(1, "设备或用户信息缺失");

		
      CommonGoods commonGoods = CommonGoodsFactory.create(pddGoods);

      commonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);

      if (commonGoods == null)

         throw new CommonGoodsException(2, "商品信息不完整");

		
      // 添加浏览记录

      ScanHistoryV2 scanHistoryV2 = new ScanHistoryV2();

      scanHistoryV2.setCommonGoods(commonGoods);

      scanHistoryV2.setCreateTime(new Date());

      scanHistoryV2.setDevice(device);

		
      if (uid != null)

         scanHistoryV2.setUserInfo(new UserInfo(uid));

		
      scanHistoryV2.setUpdateTime(new Date());

      scanHistoryV2Mapper.insertSelective(scanHistoryV2);

   }

	
   @Override

   public void addScanHistory(ScanHistoryV2 history) throws CommonGoodsException, ScanHistoryException {

      if (history == null)

@@ -54,11 +109,62 @@
      if (history.getUserInfo() == null && StringUtil.isNullOrEmpty(history.getDevice()))

         throw new ScanHistoryException(1, "设备或用户信息缺失");



      CommonGoods commonGoods = commonGoodsService.addOrUpdateCommonGoods(history.getCommonGoods());

      CommonGoods commonGoods = commonGoodsService.addCommonGoods(history.getCommonGoods());

      if (commonGoods == null)

         throw new CommonGoodsException(2, "商品信息不完整");

      history.setCommonGoods(commonGoods);

      scanHistoryV2Mapper.insertSelective(history);

   }



   @Override

   public List<ScanHistoryV2> getScanHistoryByDeviceOrUid(Long uid, String device, int page, int pageSize,

         Integer source, boolean notBackSuVip) {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         return null;

      return scanHistoryV2Mapper.selectByDeviceOrUid(uid, device, (page - 1) * pageSize, pageSize, source, notBackSuVip);

   }



   @Override

   public long getCountByDeviceOrUid(Long uid, String device, Integer source, boolean notBackSuVip) {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         return 0;

      Long count = scanHistoryV2Mapper.selectCountByDeviceOrUid(uid, device, source, notBackSuVip);

      return count == null ? 0 : count;

   }



   @Override

   public void deleteByDeviceOrUid(Long uid, String device) {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         return;

      List<ScanHistoryV2> list = scanHistoryV2Mapper.listDeviceOrUid(uid, device);

      if (list != null)

         for (ScanHistoryV2 sv : list)

            scanHistoryV2Mapper.deleteByPrimaryKey(sv.getId());

   }



   @Override

   public void deleteByAuctionIdAndDeviceOrUid(Long uid, String device, Long auctionId) {

      if (uid == null && StringUtil.isNullOrEmpty(device))

         return;

      List<ScanHistoryV2> list = scanHistoryV2Mapper.selectByDeviceOrUidAndGoodsIdAndGoodsType(uid, device, auctionId);

      if (list != null)

         for (ScanHistoryV2 sv : list)

            scanHistoryV2Mapper.deleteByPrimaryKey(sv.getId());

   }



	
   @Override

   public void deleteByCommonIdAndDeviceOrUid(Long uid, String device, Long commonId) {

      if (uid == null && StringUtil.isNullOrEmpty(device)) {

         return;

      }

		
      List<ScanHistoryV2> list = scanHistoryV2Mapper.getByCommonGoodsId(uid, device, commonId);

      if (list != null && list.size() > 0) {

         for (ScanHistoryV2 sv : list) {

            scanHistoryV2Mapper.deleteByPrimaryKey(sv.getId());

         }

      }

   }



}