zhanghumingxi

admin

2018-12-24 16da7b547decb88029b267fa7c68bd7c3396e734

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java

@@ -4,6 +4,7 @@
import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



@@ -30,16 +31,20 @@
import com.yeshi.fanli.entity.bus.share.UserShareGoodsGroup;

import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord;

import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord.ShareSourceTypeEnum;

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

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

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

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

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

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

import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;

import com.yeshi.fanli.exception.taobao.TaoKeApiException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.user.UserAccountService;

import com.yeshi.fanli.service.inter.user.UserGoodsStorageService;

import com.yeshi.fanli.service.inter.user.UserShareGoodsGroupService;

import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;

import com.yeshi.fanli.util.AESUtil;

@@ -49,6 +54,7 @@
import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.factory.CommonGoodsFactory;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;



@Service

public class UserShareGoodsRecordServiceImpl implements UserShareGoodsRecordService {

@@ -79,6 +85,9 @@
   

   @Resource

   private HongBaoManageService hongBaoManageService;

	
   @Resource

   private UserGoodsStorageService userGoodsStorageService;



   @Override

   public int insert(UserShareGoodsRecord record) {

@@ -98,11 +107,6 @@
   @Override

   public int updateByPrimaryKeySelective(UserShareGoodsRecord record) {

      return userShareGoodsRecordMapper.updateByPrimaryKeySelective(record);

   }



   @Override

   public int updateByPrimaryKey(UserShareGoodsRecord record) {

      return userShareGoodsRecordMapper.updateByPrimaryKey(record);

   }





@@ -138,6 +142,14 @@
            userShareGoodsRecord.setCreateTime(null);

            userShareGoodsRecord.setUpdateTime(null);

            listId.add(userShareGoodsRecord.getId());

				
            // 改变图片尺寸

            String pictUrl = userShareGoodsRecord.getPicture();

            if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) {

               userShareGoodsRecord.setPicture(TbImgUtil.getTBSize320Img(pictUrl));

            }

				
				
         }

         

         // 今日浏览统计

@@ -196,6 +208,32 @@
      return list;

   }

   



   @Override

   public void saveDetail(Long uid, Long auctionId, String type) throws UserShareGoodsRecordException {

		
      if (auctionId == null) {

         throw new UserShareGoodsRecordException(1, "分享商品不能为空");

      }

		
      if (uid == null) {

         throw new UserShareGoodsRecordException(1, "用户ID不能为空");

      }

		
      TaoBaoGoodsBrief goodsBrief = null;

      try {

         goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);

      } catch (TaobaoGoodsDownException e) {

         throw new UserShareGoodsRecordException(1, "商品已下架");

      }

		
      UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();

      userShareGoodsRecord.setUid(uid);

      userShareGoodsRecord.setSource(ShareSourceTypeEnum.goodsDetail);

      userShareGoodsRecord.setShareState(1);// 已分享成功

      // 单个商品分享

      singleGoodsShare(userShareGoodsRecord, goodsBrief);

   }

   

   @Override

   public void save(Long uid, ShareSourceTypeEnum source, String title, TaoBaoGoodsBrief taoBaoGoodsBrief) throws UserShareGoodsRecordException {

@@ -227,9 +265,9 @@
    * @throws UserShareGoodsRecordException

    */

   @Override

   public FileUploadResult save(Long uid, ShareSourceTypeEnum source, String title, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {

   public Map<String,Object> save(Long uid, ShareSourceTypeEnum source, String title, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {

      

      if (listGoods == null || listGoods.size() <= 1) {

      if (listGoods == null || listGoods.size() < 0) {

         throw new UserShareGoodsRecordException(1, "分享商品数量不足");

      }

      

@@ -249,13 +287,19 @@
      userShareGoodsRecord.setPicture(listGoods.get(0).getPictUrl());

      

      Date date = new Date();

      userShareGoodsRecord.setShareState(0); // 初始未分享

      userShareGoodsRecord.setCreateTime(date);

      userShareGoodsRecord.setUpdateTime(date);

      userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);

      

      // 多个商品分享

      return multipleGoodsShare(userShareGoodsRecord, listGoods);

      

      Map<String,Object> map = new HashMap<String,Object>();

      // 多个商品分享

      FileUploadResult loadResult = multipleGoodsShare(userShareGoodsRecord, listGoods);

      map.put("loadResult", loadResult);

      map.put("shareId", userShareGoodsRecord.getId());

		
      return map;

   }

   

   /**

@@ -275,33 +319,23 @@
            return;

         }

         

         UserShareGoodsGroup shareGoodsGroup = null;

         

         UserShareGoodsGroup singleGoods = userShareGoodsGroupService.getSingleGoods(resultCommonGoods.getId(),

               userShareGoodsRecord.getUid());

         if (singleGoods != null && singleGoods.getTotalGoods() == 1) {

            // 同一个商品多次分享

            shareGoodsGroup = singleGoods;

         }	
         

         if (shareGoodsGroup != null) {

         if (singleGoods != null) {

            // 单个商品多次分享

            userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());

            userShareGoodsRecord.setId(shareGoodsGroup.getRecordId());

            userShareGoodsRecord.setId(singleGoods.getRecordId());

            userShareGoodsRecord.setUpdateTime(new Date());

            userShareGoodsRecordMapper.updateByPrimaryKey(userShareGoodsRecord);

            userShareGoodsRecordMapper.updateByPrimaryKeySelective(userShareGoodsRecord);

            

            Integer totalOrder = shareGoodsGroup.getTotalOrder();

            if (totalOrder == null ||totalOrder == 0 || totalOrder.equals(0)) {

               // 预计金额

               String rateStr = hongBaoManageService.get("hongbao_goods_proportion");

               shareGoodsGroup.setUpdateTime(new Date());

               BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(taoBaoGoodsBrief, new BigDecimal(rateStr));

               shareGoodsGroup.setTotalMoney(money);

					
               userShareGoodsGroupService.updateByPrimaryKeySelective(shareGoodsGroup);

            }

         } else {

            // 最新商品

            singleGoods.setUpdateTime(new Date());

            userShareGoodsGroupService.updateByPrimaryKeySelective(singleGoods);

				
         } else 
         {

            // 单个商品第一次分享

            Date date = new Date();

            userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());

@@ -309,21 +343,17 @@
            userShareGoodsRecord.setUpdateTime(date);

            userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);

            

            shareGoodsGroup = new UserShareGoodsGroup();

            shareGoodsGroup.setTotalOrder(0);

            shareGoodsGroup.setTotalBrowse(0);

            shareGoodsGroup.setTodayBrowse(0);

            shareGoodsGroup.setCreateTime(date);

            shareGoodsGroup.setUpdateTime(date);

            shareGoodsGroup.setCommonGoods(resultCommonGoods);

            shareGoodsGroup.setRecordId(userShareGoodsRecord.getId());

            singleGoods = new UserShareGoodsGroup();

            singleGoods.setTotalOrder(0);

            singleGoods.setTotalBrowse(0);

            singleGoods.setTodayBrowse(0);

            singleGoods.setTotalMoney(new BigDecimal(0));

            singleGoods.setCreateTime(date);

            singleGoods.setUpdateTime(date);

            singleGoods.setCommonGoods(resultCommonGoods);

            singleGoods.setRecordId(userShareGoodsRecord.getId());

            

            // 预计金额

            String rateStr = hongBaoManageService.get("hongbao_goods_proportion");

            BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(taoBaoGoodsBrief, new BigDecimal(rateStr));

            shareGoodsGroup.setTotalMoney(money);

				
            userShareGoodsGroupService.insertSelective(shareGoodsGroup);

            userShareGoodsGroupService.insertSelective(singleGoods);

         }

         

      } catch (CommonGoodsException e) {

@@ -343,7 +373,6 @@
      

      // 分享记录

      Date date = new Date();

      String rateStr = hongBaoManageService.get("hongbao_goods_proportion");

      

      List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();

      List<UserShareGoodsGroup> listGroup = new ArrayList<UserShareGoodsGroup>();

@@ -363,14 +392,12 @@
            shareGoodsGroup.setTotalOrder(0);

            shareGoodsGroup.setTotalBrowse(0);

            shareGoodsGroup.setTodayBrowse(0);

            shareGoodsGroup.setTotalMoney(new BigDecimal(0));

            shareGoodsGroup.setCreateTime(date);

            shareGoodsGroup.setUpdateTime(date);

            shareGoodsGroup.setCommonGoods(resultCommonGoods);

            shareGoodsGroup.setRecordId(userShareGoodsRecord.getId());

            

            // 预计金额

            BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(taoBaoGoodsBrief, new BigDecimal(rateStr));

            shareGoodsGroup.setTotalMoney(money);

            

            listGroup.add(shareGoodsGroup);

            

@@ -403,7 +430,7 @@
      

      Long uid = shareRecord.getUid();

      Long shareId = shareRecord.getId();

      String source = shareRecord.getSource().getDesc();

      String source = shareRecord.getSource().name();

      

      String url = String.format("http://%s/share_mushGoods.html?uid=%s&shareId=%s&source=%s", configService.getH5Host(),

            AESUtil.encrypt(uid + "", Constant.UIDAESKEY), shareRecord.getId() + "", source +"");

@@ -458,12 +485,90 @@
   

   @Override

   public JSONObject getGoodsGroup(Long recordId) throws UserShareGoodsRecordException {

		
      JSONArray array = new JSONArray();



      List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId);

		
      List<Long> listGid = new ArrayList<Long>();

      for (UserShareGoodsGroup goodsGroup : list) {

         CommonGoods commonGoods = goodsGroup.getCommonGoods();

         if (commonGoods == null) {

            continue;

         }

         listGid.add(commonGoods.getGoodsId());

      }

		
      // API网络接口验证是否在售

      List<TaoBaoGoodsBrief> listTaoKeGoods = null;

      try {

         listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);

      } catch (TaoKeApiException e) {

         e.printStackTrace();

      } catch (TaobaoGoodsDownException e) {

         e.printStackTrace();

      } catch (Exception e) {

         e.printStackTrace();

      }

		


      Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

            .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



      Map<String, String> map = hongBaoManageService.convertMap();

      String proportion = map.get("hongbao_goods_proportion");

		
      for (UserShareGoodsGroup goodsGroup : list) {

         CommonGoods commonGoods = goodsGroup.getCommonGoods();

         if (commonGoods == null) {

            continue;

         }

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

            int state = 1;  // 默认停售

            Long goodsId = commonGoods.getGoodsId();

            for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {

               Long auctionId = taoKeGoods.getAuctionId();

               if (goodsId == auctionId || goodsId.equals(auctionId)) {

                  state = 0; // 在售

                  break;

               }

            }

            commonGoods.setState(state);

         }

			
         TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

			
         JSONObject dataObject = new JSONObject();

         dataObject.put("todayBrowse",goodsGroup.getTodayBrowse() );

         dataObject.put("totalBrowse",goodsGroup.getTotalBrowse() );

         dataObject.put("totalOrder", goodsGroup.getTotalOrder());

         dataObject.put("totalMoney", "¥"+goodsGroup.getTotalMoney());

         dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, null)));

         array.add(dataObject);

      }

		
      String title = "";

      UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);

      if(userShareGoodsRecord != null) {

         title = userShareGoodsRecord.getTitle();

      }

		
      JSONObject data = new JSONObject();

      data.put("title", title);

      data.put("count", list.size());

      data.put("result_list", array);

      return data;

   }



	
   @Override

   public JSONObject getGoodsGroupDetail(Long recordId) throws UserShareGoodsRecordException {

      

      List<CommonGoods> listUpadteCommonGoods = new ArrayList<CommonGoods>();



      JSONArray array = new JSONArray();



		
      List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId);

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



@@ -473,7 +578,8 @@


         Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

               .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



		
			
         Map<String, String> map = hongBaoManageService.convertMap();

         String proportion = map.get("hongbao_goods_proportion");



@@ -484,8 +590,6 @@
            }



            TaoBaoGoodsBrief goodsBrief = null;

            JSONObject dataObject = new JSONObject();



            // 更新一个小时之内的商品不再更新

            Integer goodsState = commonGoods.getState();

            // 状态未下架时进行更新

@@ -503,7 +607,7 @@
                            goodsBrief = redisManager.getTaoBaoGoodsBrief(commonGoods.getGoodsId());

                         

                            goodsState = 0;

                            goodsBrief.setState(goodsState);

                            goodsBrief.setState(goodsState); // 在售

                            

                            CommonGoods upadeteCommonGoods = CommonGoodsFactory.create(goodsBrief);

                            upadeteCommonGoods.setState(goodsState);

@@ -524,22 +628,24 @@
            if (goodsBrief == null) {

               goodsBrief = TaoBaoUtil.convert(commonGoods);

            } 



				
            if (goodsBrief.getCouponLeftCount() < 1 || StringUtil.isNullOrEmpty(goodsBrief.getCouponInfo())) {

                goodsBrief.setState(1); // 已抢光

             }

				
            // 改变图片尺寸

            String pictUrl = commonGoods.getPicture();

            String pictUrl = goodsBrief.getPictUrl();

            if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) {

               commonGoods.setPicture(TbImgUtil.getTBSize320Img(pictUrl));

               goodsBrief.setPictUrl(TbImgUtil.getTBSize320Img(pictUrl));

            }



            String json = gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, null));



            dataObject.put("groupId", userShareGoodsGroup.getId());

            dataObject.put("goods", json);

            array.add(dataObject);

				
            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, null);

            array.add(gson.toJson(taoBaoGoodsBriefExtra));

         }

      }

      

      String title = "";

      UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);

      if(userShareGoodsRecord != null) {

         title = userShareGoodsRecord.getTitle();

      }

@@ -566,4 +672,16 @@
      return data;

   }



   @Override

   public void updateShareRecord (Long shareId) throws UserShareGoodsRecordException {

      UserShareGoodsRecord shareRecord = userShareGoodsRecordMapper.selectByPrimaryKey(shareId);

      if (shareRecord == null) {

         throw new UserShareGoodsRecordException(1, "分享记录不存在");

      }

		
      shareRecord.setShareState(1);// 分享生效

      updateByPrimaryKeySelective(shareRecord);

      // 更新商品为已分享

      userGoodsStorageService.updateShareState(shareId);

   }

}