好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

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

@@ -1,15 +1,20 @@
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.dto.suning.SuningGoodsInfo;

import com.yeshi.fanli.dto.vip.goods.VIPGoodsInfo;

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;

@@ -28,23 +33,87 @@
   private ScanHistoryV2Mapper scanHistoryV2Mapper;



   @Override

   public void addScanHistory(Long uid, String device, TaoBaoGoodsBrief goods)

   public void addVIPScanHistory(Long uid, String device, VIPGoodsInfo goods)

         throws CommonGoodsException, ScanHistoryException {



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

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



      CommonGoods commonGoods = CommonGoodsFactory.create(goods);

      addScanHistory(commonGoods, device, uid);

   }



   @Override

   public void addSuningScanHistory(Long uid, String device, SuningGoodsInfo suningGoods)

         throws CommonGoodsException, ScanHistoryException {

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

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

      CommonGoods commonGoods = CommonGoodsFactory.create(goods);



      CommonGoods commonGoods = CommonGoodsFactory.create(suningGoods);

      addScanHistory(commonGoods, device, uid);

   }



   private void addScanHistory(CommonGoods commonGoods, String device, Long uid)

         throws CommonGoodsException, ScanHistoryException {

      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(Long uid, String device, TaoBaoGoodsBrief 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 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);

      addScanHistory(commonGoods, device, uid);

   }



   @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);

      addScanHistory(commonGoods, device, uid);

   }



   @Override

@@ -54,11 +123,63 @@
      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());

         }

      }

   }



}