饿了么绘图，添加口碑

admin

2020-05-19 744594ef1a2f530fc3e86ea9dc48b62247f79420

 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareStorageControllerV2.java

@@ -1,7 +1,6 @@
package com.yeshi.fanli.controller.client.v2;



import java.io.PrintWriter;

import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.HashSet;

import java.util.List;

@@ -17,17 +16,23 @@
import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.google.gson.reflect.TypeToken;

import com.yeshi.fanli.dto.ConfigParamsDTO;

import com.yeshi.fanli.entity.accept.AcceptData;

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

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

import com.yeshi.fanli.entity.system.ConfigKeyEnum;

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

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.exception.user.UserGoodsStorageException;

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

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

import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.VersionUtil;

import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;

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

import com.yeshi.fanli.vo.goods.GoodsDetailVO;

@@ -50,11 +55,56 @@


   @Resource

   private HongBaoManageService hongBaoManageService;

	
   @Resource

   private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;



   @Resource

   private UserGoodsStorageService userGoodsStorageService;



	
   /**

    * 单个商品加入选品库

    * 
    * @param callback

    * @param storageIds

    *            id数组

    * @param out

    */

   @RequestMapping(value = "accordtorage", method = RequestMethod.POST)

   public void accordtorage(AcceptData acceptData, Long uid, long id, Integer goodsType, PrintWriter out) {



      if (uid == null) {

         out.print(JsonUtil.loadFalseResult("用户未登录"));

         return;

      }



      if (goodsType == null) {

         goodsType = Constant.SOURCE_TYPE_TAOBAO;

      }



      try {

         UserGoodsStorage userGoodsStorage = userGoodsStorageService.getByUidAndAuctionId(uid, id, goodsType);

         boolean storageState = false;

         if (userGoodsStorage != null) {

            // 取消加入选品库

            userGoodsStorageService.deleteByPrimaryKey(userGoodsStorage.getId());

         } else {

            // 加入选品库

            Set<Long> set = new HashSet<Long>();

            set.add(id);

            userGoodsStorageService.save(uid, set, goodsType);

            storageState = true;

         }



         JSONObject data = new JSONObject();

         data.put("storageState", storageState);

         out.print(JsonUtil.loadTrueResult(data));

      } catch (Exception e) {

         out.print(JsonUtil.loadFalseResult("操作失败"));

         e.printStackTrace();

      }

   }



   /**

    * 批量添加选品库

    * 

@@ -69,7 +119,8 @@
   public void addStorage(AcceptData acceptData, Long uid, String ids, PrintWriter out) {

      try {

         Gson gson = new Gson();

         Set<Long> set = gson.fromJson(ids, new TypeToken<HashSet<Long>>() {}.getType());

         Set<Long> set = gson.fromJson(ids, new TypeToken<HashSet<Long>>() {

         }.getType());

         if (set == null || set.size() == 0) {

            out.print(JsonUtil.loadFalseResult("未选择商品"));

            return;

@@ -79,17 +130,17 @@
         out.print(JsonUtil.loadTrueResult("添加成功"));

      } catch (UserGoodsStorageException e) {

         out.print(JsonUtil.loadFalseResult(e.getMsg()));

      } 
      }

   }



	
	
   /**

    * 查询用户选品库数据

    * 

    * @param acceptData

    * @param page       页码 初始值 1

    * @param uid        用户id

    * @param page

    *            页码 初始值 1

    * @param uid

    *            用户id

    * @param out

    */

   @RequestMapping(value = "getlist", method = RequestMethod.POST)

@@ -104,113 +155,163 @@
         out.print(JsonUtil.loadFalseResult("平台类型不能为空"));

         return;

      }

		


      if (page == null || page < 1) {

         page = 1;

      }



      try {

         int pageSize = Constant.PAGE_SIZE;

         JSONArray array = new JSONArray();

         JSONObject data = new JSONObject();

			
         if (goodsType == Constant.SOURCE_TYPE_JD) {

            String open = configService.get("share_jd_open");

            if (!"1".equals(open.trim())) {

               data.put("count", 0);

               data.put("result_list", array);

               out.print(JsonUtil.loadTrueResult(data));

               return;

            }

         }

			
         List<UserGoodsStorage> listStorage = userGoodsStorageService.listQueryByUid((page - 1) * pageSize, pageSize,

               uid, goodsType);

         if (listStorage == null || listStorage.size() == 0) {

      int pageSize = Constant.PAGE_SIZE;

      JSONArray array = new JSONArray();

      JSONObject data = new JSONObject();



      if (goodsType == Constant.SOURCE_TYPE_JD) {

         String open = configService.get(ConfigKeyEnum.shareOpenJD.getKey());

         if (!"1".equals(open.trim())) {

            data.put("count", 0);

            data.put("result_list", array);

            out.print(JsonUtil.loadTrueResult(data));

            return;

         }

      }



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

         List<TaoBaoGoodsBrief> listTaoKeGoods = null;

         if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {

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

            for (UserGoodsStorage userGoodsStorage : listStorage) {

               CommonGoods commonGoods = userGoodsStorage.getCommonGoods();

               if (commonGoods == null) {

                  continue;

               }

               listGid.add(commonGoods.getGoodsId());

            }

      List<UserGoodsStorage> listStorage = userGoodsStorageService.listQueryByUid((page - 1) * pageSize, pageSize,

            uid, goodsType);

      if (listStorage == null || listStorage.size() == 0) {

         data.put("count", 0);

         data.put("result_list", array);

         out.print(JsonUtil.loadTrueResult(data));

         return;

      }



            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 fanLiRate = hongBaoManageService.getFanLiRate();

         BigDecimal shareRate = hongBaoManageService.getShareRate();

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

      List<TaoBaoGoodsBrief> listTaoKeGoods = null;

      if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {

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

         for (UserGoodsStorage userGoodsStorage : listStorage) {

            CommonGoods commonGoods = userGoodsStorage.getCommonGoods();

            if (commonGoods == null) {

               continue;

            }



            // 淘宝商品验证在售

            if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {

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

               }

            }



            // 判断是否已分享， 已分享显示已下架

            Integer storageState = userGoodsStorage.getState();

            if (storageState != null && storageState == UserGoodsStorage.STATE_SHARED) {

               Integer goodsState = commonGoods.getState();

               if (goodsState != null && goodsState != 1) {

                  commonGoods.setState(2);

               }

            }



            GoodsDetailVO detailVO = GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate);

            detailVO.setId(commonGoods.getId());

				
				
            JSONObject dataObject = new JSONObject();

            dataObject.put("storageId", userGoodsStorage.getId());

            dataObject.put("goods", gson.toJson(detailVO));

            array.add(dataObject);

            listGid.add(commonGoods.getGoodsId());

         }



         long count = userGoodsStorageService.countQueryByUid(uid, goodsType);

         data.put("count", count);

         data.put("result_list", array);

         out.print(JsonUtil.loadTrueResult(data));

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



      ConfigParamsDTO paramsDTO =  orderHongBaoMoneyComputeService.getShowComputeRate(acceptData.getPlatform(),

            acceptData.getVersion());



      for (UserGoodsStorage userGoodsStorage : listStorage) {

         CommonGoods commonGoods = userGoodsStorage.getCommonGoods();

         if (commonGoods == null) {

            continue;

         }



         // 淘宝商品验证在售

         if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {

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

            }

         }



         // 判断是否已分享， 已分享显示已下架

         Integer storageState = userGoodsStorage.getState();

         if (storageState != null && storageState == UserGoodsStorage.STATE_SHARED) {

            Integer goodsState = commonGoods.getState();

            if (goodsState != null && goodsState != 1) {

               commonGoods.setState(2);

            }

         }



         GoodsDetailVO detailVO = GoodsDetailVOFactory.convertCommonGoods(commonGoods, paramsDTO);

         detailVO.setId(commonGoods.getId());



         JSONObject dataObject = new JSONObject();

         dataObject.put("storageId", userGoodsStorage.getId());

         dataObject.put("goods", gson.toJson(detailVO));

         array.add(dataObject);

      }



      long count = userGoodsStorageService.countQueryByUid(uid, goodsType);

      data.put("count", count);

      data.put("result_list", array);

      out.print(JsonUtil.loadTrueResult(data));

   }



   /**

    * 分享商品返回二维码图片

    * 
    * @param callback

    * @param storageIds

    *            id数组

    * @param out

    */

   @RequestMapping(value = "createShare", method = RequestMethod.POST)

   public void createShare(AcceptData acceptData, Long uid, String storageIds, PrintWriter out) {



      if (StringUtil.isNullOrEmpty(storageIds)) {

         out.print(JsonUtil.loadFalseResult("分享商品不能为空"));

         return;

      }



      if (uid == null) {

         out.print(JsonUtil.loadFalseResult("用户未登录"));

         return;

      }



      try {

         Gson gson = new Gson();

         List<Long> listStorageID = gson.fromJson(storageIds, new TypeToken<ArrayList<Long>>() {

         }.getType());



         if (!VersionUtil.greaterThan_2_0_5(acceptData.getPlatform(), acceptData.getVersion())) {



            if (listStorageID == null || listStorageID.size() < 9) {

               out.print(JsonUtil.loadFalseResult("分享商品数量不足"));

               return;

            }



            if (listStorageID.size() != 9) {

               out.print(JsonUtil.loadFalseResult("分享商品数量只能是9个"));

               return;

            }



            JSONObject data = userGoodsStorageService.createShareV2(uid, listStorageID, true);

            out.print(JsonUtil.loadTrueResult(data));

         } else {

            JSONObject data = userGoodsStorageService.createShareV2(uid, listStorageID, false);

            out.print(JsonUtil.loadTrueResult(data));

         }



      } catch (UserGoodsStorageException e) {

         out.print(JsonUtil.loadFalseResult("分享失败"));

         e.printStackTrace();

      } catch (UserShareGoodsRecordException e) {

         out.print(JsonUtil.loadFalseResult("分享失败"));

         e.printStackTrace();

      } catch (Exception e) {

         out.print(JsonUtil.loadFalseResult("加载列表失败"));

         out.print(JsonUtil.loadFalseResult("分享失败"));

         e.printStackTrace();

      }

   }

	
}