替换原来老的资金详情

admin

2018-12-25 4cb15e222cd7d099d533ccbeb7f9a8cd99bf180c

 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;



@@ -15,6 +16,7 @@


import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

import org.yeshi.utils.DateUtil;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.QRCodeUtil;

@@ -33,13 +35,16 @@
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,7 +265,7 @@
    * @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() < 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,88 +485,78 @@
   

   @Override

   public JSONObject getGoodsGroup(Long recordId) throws UserShareGoodsRecordException {

      UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);

      

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



      JSONArray array = new JSONArray();



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

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

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

      }

		


         Date nowDate = new Date();

         long nh = 1000 * 60 * 60;

         long nd = 1000 * 24 * 60 * 60;

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

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



         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 userShareGoodsGroup : list) {

            CommonGoods commonGoods = userShareGoodsGroup.getCommonGoods();

            if (commonGoods == null) {

               continue;

            }



            TaoBaoGoodsBrief goodsBrief = null;

            JSONObject dataObject = new JSONObject();



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

            Integer goodsState = commonGoods.getState();

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

            if (goodsState != null && (goodsState != 1 || !goodsState.equals(1))) {

               Date updateTime = commonGoods.getUpdateTime();

               if (updateTime != null) {

						
                  // 计算差多少小时

                  long diff = nowDate.getTime() - updateTime.getTime();

                  long day = diff / nd;

                   long hour = diff % nd / nh;

                   if (hour > 1 || day > 0 ) {

                      try {

                         if (commonGoods.getGoodsType() == CommonGoods.GOODS_TYPE_TB) {

                            goodsBrief = redisManager.getTaoBaoGoodsBrief(commonGoods.getGoodsId());

					    		
                            goodsState = 0;

                            goodsBrief.setState(goodsState);

					    			
                            CommonGoods upadeteCommonGoods = CommonGoodsFactory.create(goodsBrief);

                            upadeteCommonGoods.setState(goodsState);

                           upadeteCommonGoods.setId(commonGoods.getId());

                           listUpadteCommonGoods.add(upadeteCommonGoods);

                         }

                     } catch (TaobaoGoodsDownException e) {

                        // 已下架

                        goodsState = 1;

                        commonGoods.setState(goodsState);

                        listUpadteCommonGoods.add(commonGoods);

                        e.printStackTrace();

                     }

                  }

      BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis());

		
      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;

               }

            }



            if (goodsBrief == null) {

               goodsBrief = TaoBaoUtil.convert(commonGoods);

            } 


            // 改变图片尺寸

            String pictUrl = commonGoods.getPicture();

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

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

            }



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



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

            dataObject.put("goods", json);

            array.add(dataObject);

            commonGoods.setState(state);

         }

			
         TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

			
         // 今日浏览记录处理

         Date date = new Date();

         Date browseTime = goodsGroup.getBrowseTime();

         if (!DateUtil.isSameDay(browseTime, date)) {

            goodsGroup.setTodayBrowse(0); // 不是同一天浏览记录设置0

         }

			
			
         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, shareRate+"", null)));

         array.add(dataObject);

      }

      

      String title = "";

      UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);

      if(userShareGoodsRecord != null) {

         title = userShareGoodsRecord.getTitle();

      }

@@ -548,22 +565,101 @@
      data.put("title", title);

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

      data.put("result_list", array);

      return data;

   }



      if (listUpadteCommonGoods.size() > 0) {

         executor.execute(new Runnable() {

            @Override

            public void run() {

               try {

                  // 更新简版信息

                  commonGoodsService.updateBatchCommonGoods(listUpadteCommonGoods);

               } catch (Exception e) {

                  e.printStackTrace();

               }

	
   @Override

   public JSONObject getGoodsGroupDetail(Long recordId) throws UserShareGoodsRecordException {

		
      JSONArray array = new JSONArray();

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

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



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

			
         BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis());

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

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

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

             }

				
            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate +"", null);

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

         }



      }

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

   }

}