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,12 +31,14 @@
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;

@@ -51,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 {

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

   public int updateByPrimaryKeySelective(UserShareGoodsRecord record) {

      return userShareGoodsRecordMapper.updateByPrimaryKeySelective(record);

   }



   @Override

   public int updateByPrimaryKey(UserShareGoodsRecord record) {

      return userShareGoodsRecordMapper.updateByPrimaryKey(record);

   }





@@ -266,7 +265,7 @@
    * @throws UserShareGoodsRecordException

    */

   @Override

   public JSONObject 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, "分享商品数量不足");

@@ -294,13 +293,13 @@
      userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);

      

      

      JSONObject data = new JSONObject();

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

      // 多个商品分享

      FileUploadResult loadResult = multipleGoodsShare(userShareGoodsRecord, listGoods);

      data.put("loadResult", loadResult);

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

      map.put("loadResult", loadResult);

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

      

      return data;

      return map;

   }

   

   /**

@@ -320,25 +319,20 @@
            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);

            

            // 最新商品

            shareGoodsGroup.setUpdateTime(new Date());

            userShareGoodsGroupService.updateByPrimaryKeySelective(shareGoodsGroup);

            singleGoods.setUpdateTime(new Date());

            userShareGoodsGroupService.updateByPrimaryKeySelective(singleGoods);

            

         } else 

         {

@@ -349,18 +343,17 @@
            userShareGoodsRecord.setUpdateTime(date);

            userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);

            

            shareGoodsGroup = new UserShareGoodsGroup();

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

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

            

				
            userShareGoodsGroupService.insertSelective(shareGoodsGroup);

            userShareGoodsGroupService.insertSelective(singleGoods);

         }

         

      } catch (CommonGoodsException e) {

@@ -437,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 +"");

@@ -494,88 +487,65 @@
   public JSONObject getGoodsGroup(Long recordId) throws UserShareGoodsRecordException {

      

      JSONArray array = new JSONArray();

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



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

                     }

                  }

      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;

               }

            }



            if (goodsBrief == null) {

               goodsBrief = TaoBaoUtil.convert(commonGoods);

            } 


            // 改变图片尺寸

            String pictUrl = goodsBrief.getPictUrl();

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

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

            }

				
            userShareGoodsGroup.setId(null);

            userShareGoodsGroup.setBrowseTime(null);

            userShareGoodsGroup.setCreateTime(null);

            userShareGoodsGroup.setUpdateTime(null);

            userShareGoodsGroup.setRecordId(null);

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

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

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

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

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

            array.add(dataObject);

            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 = "";

@@ -588,21 +558,6 @@
      data.put("title", title);

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

      data.put("result_list", array);



      if (listUpadteCommonGoods.size() > 0) {

         executor.execute(new Runnable() {

            @Override

            public void run() {

               try {

                  // 更新简版信息

                  commonGoodsService.updateBatchCommonGoods(listUpadteCommonGoods);

               } catch (Exception e) {

                  e.printStackTrace();

               }

            }

         });

      }

		
      return data;

   }



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

                         

                            goodsState = 0;

                            goodsBrief.setState(goodsState); // 在售

                            

                            CommonGoods upadeteCommonGoods = CommonGoodsFactory.create(goodsBrief);

                            upadeteCommonGoods.setState(goodsState);