Merge remote-tracking branch 'origin/master'

admin

2018-12-12 dc73adfa9d92d11d1a8512778deacc34fa877eef

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

@@ -5,17 +5,26 @@
import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.Map;



import javax.annotation.Resource;

import javax.transaction.Transactional;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.QRCodeUtil;

import org.yeshi.utils.entity.FileUploadResult;

import org.yeshi.utils.exception.HttpException;

import org.yeshi.utils.taobao.TbImgUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

import com.yeshi.fanli.dao.mybatis.share.UserShareGoodsRecordMapper;

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

@@ -26,6 +35,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

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

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

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;

@@ -35,6 +45,7 @@
import com.yeshi.fanli.util.AESUtil;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.ImageUtil;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

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

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

@@ -42,8 +53,14 @@
@Service

public class UserShareGoodsRecordServiceImpl implements UserShareGoodsRecordService {



   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	
   @Resource

   private ConfigService configService;

	
   @Resource

   private RedisManager redisManager;

   

   @Resource

   private UserInfoMapper userInfoMapper;

@@ -179,13 +196,9 @@
      return list;

   }

   

   /**

    * 保存分享记录

    * @param userShareGoodsRecord 分享记录： uid、picture、source 为必输入

    * @throws UserShareGoodsRecordException

    */

	
   @Override

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

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

      

      if (taoBaoGoodsBrief == null) {

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

@@ -202,6 +215,7 @@
      UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();

      userShareGoodsRecord.setUid(uid);

      userShareGoodsRecord.setSource(source);

      userShareGoodsRecord.setTitle(title);

      // 单个商品分享

      singleGoodsShare(userShareGoodsRecord, taoBaoGoodsBrief);

   }

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

    */

   @Override

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

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

      }

      

@@ -230,6 +244,7 @@
      UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();

      userShareGoodsRecord.setUid(uid);

      userShareGoodsRecord.setSource(source);

      userShareGoodsRecord.setTitle(title);

      // 取一个商品图片作为主图

      userShareGoodsRecord.setPicture(listGoods.get(0).getPictUrl());

      

@@ -238,12 +253,8 @@
      userShareGoodsRecord.setUpdateTime(date);

      userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);

      

      FileUploadResult shareImg = createShareImg(userShareGoodsRecord, listGoods);

		
      // 多个商品分享

      multipleGoodsShare(userShareGoodsRecord, listGoods);

		
      return shareImg;

      return multipleGoodsShare(userShareGoodsRecord, listGoods);

      

   }

   

@@ -256,6 +267,7 @@
   public void singleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, TaoBaoGoodsBrief taoBaoGoodsBrief) {

   

      CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);

      commonGoods.setState(taoBaoGoodsBrief.getState());

      try {

         CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);

         

@@ -327,17 +339,26 @@
    * @param listGoods

    */

   @Transactional

   public void multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, List<TaoBaoGoodsBrief> listGoods) {

   public FileUploadResult multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {

      

      // 分享记录

      Date date = new Date();

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

      

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

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

		
      for (TaoBaoGoodsBrief taoBaoGoodsBrief: listGoods) {

         CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);

         commonGoods.setState(taoBaoGoodsBrief.getState());

         try {

            CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);

			
            if (resultCommonGoods != null) {

               TaoBaoGoodsBrief goodsBrief =  TaoBaoUtil.convert(resultCommonGoods);

               listGoodsBrief.add(goodsBrief);

            }

				
            UserShareGoodsGroup shareGoodsGroup = new UserShareGoodsGroup();

            shareGoodsGroup.setTotalOrder(0);

            shareGoodsGroup.setTotalBrowse(0);

@@ -359,15 +380,14 @@
         }

      }

      

      FileUploadResult shareImg = createShareImg(userShareGoodsRecord, listGoodsBrief);

		
      if (listGroup.size() > 0) {

         userShareGoodsGroupService.insertBatch(listGroup);

      }

      

      return shareImg;

   }

	
	
	
	
   

   /**

    * 生成分享图

@@ -385,7 +405,7 @@
      Long shareId = shareRecord.getId();

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

      

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

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

      

      String shortLink = HttpUtil.getShortLink(url);

@@ -435,4 +455,115 @@
      return shareImg;

   }

   

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



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



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

                     }

                  }

               }

            }



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

         }

      }

		
      String title = "";

      if(userShareGoodsRecord != null) {

         title = userShareGoodsRecord.getTitle();

      }

		
      JSONObject data = new JSONObject();

      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;

   }



}