Merge remote-tracking branch 'origin/master'

admin

2018-12-12 263d995ed175dc8260b0f830751db376221e4ac9

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

@@ -4,47 +4,27 @@
import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.Map;



import javax.annotation.Resource;



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.DateUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.taobao.TbImgUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

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

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

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

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

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

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

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

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

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

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

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;



@Service

public class UserShareGoodsGroupServiceImpl implements UserShareGoodsGroupService {



   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	
   @Resource

   private HongBaoManageService hongBaoManageService;

	
   @Resource

   private RedisManager redisManager;

   

   @Resource

   private CommonGoodsService commonGoodsService;

@@ -174,109 +154,4 @@
         updateByPrimaryKeySelective(shareGoodsGroup);

      }

   }

	
   @Override

   public JSONObject getGoodsGroup(Long recordId) throws UserShareGoodsRecordException {

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



      JSONArray array = new JSONArray();



      List<UserShareGoodsGroup> list = 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);

         }



      }

		
      JSONObject data = new JSONObject();

      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;

   }



}