抖音转链修改

admin

2024-01-23 81da61b828e29b7745e1382dfbbaeb685dc083ef

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

@@ -1,371 +1,470 @@
package com.yeshi.fanli.service.impl.user;



import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.Map;

import java.util.Set;



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

import org.yeshi.utils.taobao.TbImgUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.yeshi.fanli.dao.mybatis.user.UserGoodsStorageMapper;

import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord.ShareSourceTypeEnum;

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

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

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

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

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

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 UserGoodsStorageServiceImpl implements UserGoodsStorageService {

	
   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	
   @Resource

   private RedisManager redisManager;

	
   @Resource

   private ConfigService configService;

	
   @Resource

   private CommonGoodsService commonGoodsService;

	
   @Resource

   private HongBaoManageService manageService;



   @Resource

   private UserGoodsStorageMapper userGoodsStorageMapper;

	
   @Resource

   private UserShareGoodsRecordService userShareGoodsRecordService;

   @Resource

   private HongBaoManageService hongBaoManageService;



   @Override

   public int deleteByPrimaryKey(Long id) {

      return userGoodsStorageMapper.deleteByPrimaryKey(id);

   }



   @Override

   public int insert(UserGoodsStorage record) {

      return userGoodsStorageMapper.insert(record);

   }



   @Override

   public int insertSelective(UserGoodsStorage record) {

      return userGoodsStorageMapper.insertSelective(record);

   }



   @Override

   public UserGoodsStorage selectByPrimaryKey(Long id) {

      return userGoodsStorageMapper.selectByPrimaryKey(id);

   }



   @Override

   public int updateByPrimaryKeySelective(UserGoodsStorage record) {

      return userGoodsStorageMapper.updateByPrimaryKeySelective(record);

   }



   @Override

   public int updateByPrimaryKey(UserGoodsStorage record) {

      return userGoodsStorageMapper.updateByPrimaryKey(record);

   }



   /**

    * 根据主键批量删除

    * 
    * @param list

    * @return

    */

   @Override

   public int deleteBatchByPrimaryKey(List<Long> list) {

      return userGoodsStorageMapper.deleteBatchByPrimaryKey(list);

   }

	
   /**

    * 根据主键 、uid 批量删除

    * @param list

    * @return

    */

   @Override

   public int deleteBatchByUidAndPrimaryKey(Long uid, List<Long> list) {

      return userGoodsStorageMapper.deleteBatchByUidAndPrimaryKey(uid, list);

   }



   @Override

   public List<UserGoodsStorage> listQueryByUid(long start, int count, Long uid) {

      return userGoodsStorageMapper.listQueryByUid(start, count, uid);

   }

	
   @Override

   public UserGoodsStorage getByUidAndAuctionId(Long uid, Long auctionId) {

      return userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId);

   }



   @Override

   public long countQueryByUid(Long uid) {

      return userGoodsStorageMapper.countQueryByUid(uid);

   }

	
   @Override

   public void updateShareState(Long shareId) {

      userGoodsStorageMapper.updateShareState(shareId);

   }



   @Override

   public void save(Long uid, Set<Long> auctionIds) throws UserGoodsStorageException {



      if (uid == null) {

         throw new UserGoodsStorageException(1, "用户尚未登录");

      }



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

         throw new UserGoodsStorageException(1, "商品ID为空");

      }



      for (Long auctionId : auctionIds) {



         TaoBaoGoodsBrief goodsBrief = null;



         try {

            // 获取商品详情

            goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);

         } catch (TaobaoGoodsDownException e) {



            // 更新简版 下架状态

            CommonGoods commonGoods = new CommonGoods();

            commonGoods.setGoodsId(auctionId);

            commonGoods.setGoodsType(CommonGoods.GOODS_TYPE_TB);

            commonGoods.setState(CommonGoods.STATE_OFFLINE);



            throw new UserGoodsStorageException(1, "该商品已下架");

         }



         // 转换简版商品信息

         CommonGoods commonGoods = CommonGoodsFactory.create(goodsBrief);

         try {

            commonGoodsService.addOrUpdateCommonGoods(commonGoods);

         } catch (CommonGoodsException e) {

            e.printStackTrace();

            throw new UserGoodsStorageException(1, "商品信息更新失败");

         }



         Long cid = commonGoods.getId();



         UserGoodsStorage goodsStorage = userGoodsStorageMapper.getByUidAndCid(uid, cid);



         if (goodsStorage != null) {

            // 初始话状态

            goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);

            goodsStorage.setUpdateTime(new Date());

            userGoodsStorageMapper.updateByPrimaryKeySelective(goodsStorage);

         } else {

            goodsStorage = new UserGoodsStorage();

            goodsStorage.setUid(uid);;

            goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);

            goodsStorage.setCommonGoods(commonGoods);

            goodsStorage.setCreateTime(new Date());

            goodsStorage.setUpdateTime(new Date());

            userGoodsStorageMapper.insertSelective(goodsStorage);

         }



      }

   }



	
   @Override

   public JSONArray getMyStorage(int page, int pageSize, Long uid) throws UserGoodsStorageException {

		
      JSONArray  array = new JSONArray();



      List<UserGoodsStorage> listStorage = listQueryByUid(page , pageSize, uid);

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

         return array;

      }

		
      Date nowDate = new Date();

      long nh = 1000 * 60 * 60;

      long nd = 1000 * 24 * 60 * 60;

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

		
      BigDecimal  rate = manageService.getFanLiRate();

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

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



		
      for (UserGoodsStorage userGoodsStorage : listStorage) {

         CommonGoods commonGoods = userGoodsStorage.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);

         } 
			
         // 判断是否已分享

         Integer state = userGoodsStorage.getState();

         int shared = UserGoodsStorage.STATE_SHARED;

         if (state != null && (state == shared || state.equals(shared))) {

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

               goodsBrief.setState(2); // 已分享状态

            }

         }



         // 改变图片尺寸

         String pictUrl = goodsBrief.getPictUrl();

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

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

         }

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



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

         dataObject.put("goods", json);

         array.add(dataObject);

      }

		
		
      if (listUpadteCommonGoods.size() > 0) {

         executor.execute(new Runnable() {

            @Override

            public void run() {

               try {

                  // 更新简版信息

                  commonGoodsService.updateBatchCommonGoods(listUpadteCommonGoods);

               } catch (Exception e) {

                  e.printStackTrace();

               }

					
            }

         });

      }

		
      return array;

   }

	
	
   @Override

   public boolean isExistStorage(Long uid, Long auctionId) {

      boolean state = false;

      if (uid != null && auctionId != null) {

         UserGoodsStorage userGoodsStorage = userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId);

         if (userGoodsStorage != null) {

            state = true;

         }

      }

      return state;

   }

	
   @Override

   public JSONObject shareGoods(Long uid, List<Long> listStorageID)  
         throws UserGoodsStorageException, UserShareGoodsRecordException {

		
      List<UserGoodsStorage> listStorage = userGoodsStorageMapper.listQueryByIds(listStorageID);

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

         throw new UserGoodsStorageException(1, "选品库商品不存在");

      }

		
		
      List<UserGoodsStorage> listResult = new ArrayList<UserGoodsStorage>();

      // 还原顺序 用于制图

      for (Long sid: listStorageID) {

         for (UserGoodsStorage torage: listStorage) {

            Long id = torage.getId();

            if (sid == id || sid.equals(id)) {

               listResult.add(torage);

               break;

            }

         }

      }

		
		
      BigDecimal totalMoney = new BigDecimal(0.00);

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

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

		
      for (UserGoodsStorage userGoodsStorage: listResult) {

         CommonGoods commonGoods = userGoodsStorage.getCommonGoods();

         TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

         listGoodsBrief.add(goodsBrief);

			
         BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(goodsBrief, new BigDecimal(rateStr));

         totalMoney = MoneyBigDecimalUtil.add(totalMoney, money);

      }

		
      String revenue = listGoodsBrief.size() + "个商品预估分享奖金：¥"+totalMoney;

		
      Map<String,Object> map = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.storage, 
            null, listGoodsBrief);

		
      JSONObject data = new JSONObject();

      data.put("revenue", revenue);

      data.put("shareId", map.get("shareId"));

      data.put("shareImg", map.get("loadResult"));

      data.put("notifyDesc", configService.get("goods_share_multiple_notify"));



      return data;

   }

}

package com.yeshi.fanli.service.impl.user;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Set;

import javax.annotation.Resource;

import com.yeshi.fanli.entity.SystemEnum;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.util.*;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.MoneyBigDecimalUtil;
import org.yeshi.utils.entity.FileUploadResult;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dao.mybatis.user.UserGoodsStorageMapper;
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
import com.yeshi.fanli.dto.share.ShareGoodsRecordDTO;
import com.yeshi.fanli.entity.bus.user.UserGoodsStorage;
import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
import com.yeshi.fanli.entity.goods.CommonGoods;
import com.yeshi.fanli.entity.jd.JDGoods;
import com.yeshi.fanli.entity.system.ConfigKeyEnum;
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
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.exception.user.UserGoodsStorageException;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
import com.yeshi.fanli.service.inter.user.UserGoodsStorageService;
import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
import com.yeshi.fanli.util.jd.JDApiUtil;
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

@Service
public class UserGoodsStorageServiceImpl implements UserGoodsStorageService {

    @Resource(name = "taskExecutor")
    private TaskExecutor executor;

    @Resource
    private RedisManager redisManager;

    @Resource
    private ConfigService configService;

    @Resource
    private CommonGoodsService commonGoodsService;

    @Resource
    private HongBaoManageService manageService;

    @Resource
    private UserGoodsStorageMapper userGoodsStorageMapper;

    @Resource
    private UserShareGoodsRecordService userShareGoodsRecordService;
    @Resource
    private HongBaoManageService hongBaoManageService;

    @Resource
    private UserInfoService userInfoService;

    @Override
    public int deleteByPrimaryKey(Long id) {
        return userGoodsStorageMapper.deleteByPrimaryKey(id);
    }

    @Override
    public int insert(UserGoodsStorage record) {
        return userGoodsStorageMapper.insert(record);
    }

    @Override
    public int insertSelective(UserGoodsStorage record) {
        return userGoodsStorageMapper.insertSelective(record);
    }

    @Override
    public UserGoodsStorage selectByPrimaryKey(Long id) {
        return userGoodsStorageMapper.selectByPrimaryKey(id);
    }

    @Override
    public int updateByPrimaryKeySelective(UserGoodsStorage record) {
        return userGoodsStorageMapper.updateByPrimaryKeySelective(record);
    }

    @Override
    public int updateByPrimaryKey(UserGoodsStorage record) {
        return userGoodsStorageMapper.updateByPrimaryKey(record);
    }

    /**
     * 根据主键批量删除
     *
     * @param list
     * @return
     */
    @Override
    public int deleteBatchByPrimaryKey(List<Long> list) {
        return userGoodsStorageMapper.deleteBatchByPrimaryKey(list);
    }

    /**
     * 根据主键 、uid 批量删除
     *
     * @param list
     * @return
     */
    @Override
    public int deleteBatchByUidAndPrimaryKey(Long uid, List<Long> list) {
        return userGoodsStorageMapper.deleteBatchByUidAndPrimaryKey(uid, list);
    }

    @Override
    public List<UserGoodsStorage> listQueryByUid(long start, int count, Long uid, Integer source) {
        return userGoodsStorageMapper.listQueryByUid(start, count, uid, source);
    }

    @Override
    public UserGoodsStorage getByUidAndAuctionId(Long uid, String auctionId, Integer goodsType) {
        return userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId, goodsType);
    }

    @Override
    public long countQueryByUid(Long uid, Integer source) {
        return userGoodsStorageMapper.countQueryByUid(uid, source);
    }

    @Override
    public void save(Long uid, Set<String> auctionIds, Integer goodsType) throws UserGoodsStorageException {

        if (uid == null) {
            throw new UserGoodsStorageException(1, "用户尚未登录");
        }

        if (auctionIds == null || auctionIds.size() == 0) {
            throw new UserGoodsStorageException(1, "商品ID为空");
        }

        for (String auctionId : auctionIds) {
            CommonGoods commonGoods = null;
            if (goodsType == null) {
                goodsType = Constant.SOURCE_TYPE_TAOBAO;
            }

            if (goodsType == Constant.SOURCE_TYPE_JD) {
                // 京东
                JDGoods jdGoods = JDApiUtil.queryGoodsDetail(Long.parseLong(auctionId));
                if (jdGoods == null) {
                    jdGoods = JDApiUtil.getGoodsDetail(Long.parseLong( auctionId));
                }
                if (jdGoods == null) {
                    throw new UserGoodsStorageException(1, auctionId + "商品已下架");
                }
                commonGoods = CommonGoodsFactory.create(jdGoods);

            } else if (goodsType == Constant.SOURCE_TYPE_PDD) {
                // 拼多多
                PDDGoodsDetail pddGoods = PinDuoDuoApiUtil.getGoodsDetail(Long.parseLong(auctionId));
                if (pddGoods == null) {
                    throw new UserGoodsStorageException(1, auctionId + "商品已下架");
                }
                commonGoods = CommonGoodsFactory.create(pddGoods);
            } else {
                // 淘宝
                try {
                    // 获取商品详情
                    TaoBaoGoodsBrief goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
                    commonGoods = CommonGoodsFactory.create(goodsBrief);
                } catch (TaobaoGoodsDownException e) {
                    throw new UserGoodsStorageException(1, auctionId + "商品已下架");
                }
            }

            if (commonGoods != null) {
                try {
                    commonGoodsService.addOrUpdateCommonGoods(commonGoods);
                } catch (CommonGoodsException e) {
                    e.printStackTrace();
                    throw new UserGoodsStorageException(1, "商品信息更新失败");
                }

                Long cid = commonGoods.getId();

                UserGoodsStorage goodsStorage = userGoodsStorageMapper.getByUidAndCid(uid, cid);

                if (goodsStorage != null) {
                    // 初始话状态
                    goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
                    goodsStorage.setUpdateTime(new Date());
                    userGoodsStorageMapper.updateByPrimaryKeySelective(goodsStorage);
                } else {
                    goodsStorage = new UserGoodsStorage();
                    goodsStorage.setUid(uid);
                    ;
                    goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
                    goodsStorage.setCommonGoods(commonGoods);
                    goodsStorage.setCreateTime(new Date());
                    goodsStorage.setUpdateTime(new Date());
                    userGoodsStorageMapper.insertSelective(goodsStorage);
                }
            }
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addCommonGoods(Long uid, Set<Long> ids) throws UserGoodsStorageException {

        if (uid == null) {
            throw new UserGoodsStorageException(1, "用户尚未登录");
        }

        if (ids == null || ids.size() == 0) {
            throw new UserGoodsStorageException(1, "商品ID为空");
        }

        for (Long id : ids) {
            CommonGoods commonGoods = commonGoodsService.selectByPrimaryKey(id);
            if (commonGoods != null) {
                UserGoodsStorage goodsStorage = userGoodsStorageMapper.getByUidAndCid(uid, id);

                if (goodsStorage != null) {
                    // 初始话状态
                    goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
                    goodsStorage.setUpdateTime(new Date());
                    userGoodsStorageMapper.updateByPrimaryKeySelective(goodsStorage);
                } else {
                    goodsStorage = new UserGoodsStorage();
                    goodsStorage.setUid(uid);
                    ;
                    goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
                    goodsStorage.setCommonGoods(commonGoods);
                    goodsStorage.setCreateTime(new Date());
                    goodsStorage.setUpdateTime(new Date());
                    userGoodsStorageMapper.insertSelective(goodsStorage);
                }
            }
        }
    }

    @Override
    public JSONArray getMyStorage(int page, int pageSize, Long uid, Integer source) throws UserGoodsStorageException {

        JSONArray array = new JSONArray();

        List<UserGoodsStorage> listStorage = listQueryByUid(page, pageSize, uid, source);
        if (listStorage == null || listStorage.size() == 0) {
            return array;
        }

        if (source == null) {
            source = Constant.SOURCE_TYPE_TAOBAO;
        }

        List<TaoBaoGoodsBrief> listTaoKeGoods = null;
        if (source == Constant.SOURCE_TYPE_TAOBAO) {
            List<String> listGid = new ArrayList<>();
            for (UserGoodsStorage userGoodsStorage : listStorage) {
                CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
                if (commonGoods == null) {
                    continue;
                }
                listGid.add(commonGoods.getGoodsId());
            }

            // API网络接口验证是否在售
            try {
                listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);
            } catch (TaoKeApiException e) {
                e.printStackTrace();
            } catch (TaobaoGoodsDownException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        SystemEnum system = userInfoService.getUserSystem(uid);
        BigDecimal rate = manageService.getFanLiRate(UserLevelEnum.daRen, system);
        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        for (UserGoodsStorage userGoodsStorage : listStorage) {
            CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
            if (commonGoods == null) {
                continue;
            }

            int state = 0;
            Integer goodsType = commonGoods.getGoodsType();

            if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 && goodsType != null
                    && goodsType == Constant.SOURCE_TYPE_TAOBAO) {
                state = 1; // 默认停售
                String goodsId = commonGoods.getGoodsId();
                for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {
                    String auctionId = taoKeGoods.getAuctionId();
                    if (goodsId == auctionId || goodsId.equals(auctionId)) {
                        state = 0; // 在售
                        break;
                    }
                }
            }
            commonGoods.setState(state);
            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

            // 判断是否已分享
            Integer storageState = userGoodsStorage.getState();
            if (storageState != null && storageState == UserGoodsStorage.STATE_SHARED) {
                Integer goodsState = goodsBrief.getState();
                if (goodsState != null && goodsState != 1) {
                    goodsBrief.setState(2); // 已分享状态 优先显示已下架
                }
            }

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

            JSONObject dataObject = new JSONObject();
            dataObject.put("storageId", userGoodsStorage.getId());
            dataObject.put("goods", json);
            array.add(dataObject);
        }

        return array;
    }

    @Override
    public boolean isExistStorage(Long uid, String auctionId, Integer goodType) {
        boolean state = false;
        if (uid != null && auctionId != null) {
            UserGoodsStorage userGoodsStorage = userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId, goodType);
            if (userGoodsStorage != null) {
                state = true;
            }
        }
        return state;
    }

    @Override
    public JSONObject shareGoods(Long uid, List<Long> listStorageID)
            throws UserGoodsStorageException, UserShareGoodsRecordException {
        List<UserGoodsStorage> listStorage = userGoodsStorageMapper.listQueryByIds(listStorageID);
        if (listStorage == null || listStorage.size() == 0) {
            throw new UserGoodsStorageException(1, "选品库商品不存在");
        }

        List<UserGoodsStorage> listResult = new ArrayList<UserGoodsStorage>();
        // 还原顺序 用于制图
        for (Long sid : listStorageID) {
            for (UserGoodsStorage torage : listStorage) {
                Long id = torage.getId();
                if (sid == id || sid.equals(id)) {
                    listResult.add(torage);
                    break;
                }
            }
        }

        BigDecimal totalMoney = new BigDecimal(0.00);
        List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();

        SystemEnum system = userInfoService.getUserSystem(uid);

        BigDecimal rate = hongBaoManageService.getShareRate(UserLevelEnum.daRen,system);
        for (UserGoodsStorage userGoodsStorage : listResult) {
            CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
            listGoodsBrief.add(goodsBrief);

            BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(goodsBrief, rate, true);
            totalMoney = MoneyBigDecimalUtil.add(totalMoney, money);
        }

        ShareGoodsRecordDTO shareRecord = userShareGoodsRecordService.addRecordGoodsStorage(uid, listGoodsBrief,
                listStorageID);
        FileUploadResult uploadResult = new FileUploadResult();
        uploadResult.setUrl(shareRecord.getSharePictureUrl());

        UserInfo user = userInfoService.selectByPKey(uid);

        JSONObject data = new JSONObject();
        data.put("revenue", listGoodsBrief.size() + "个商品预估分享奖金：¥" + totalMoney);
        data.put("shareId", shareRecord.getRedisKey());
        data.put("shareImg", uploadResult);
        data.put("notifyDesc", configService.getValue(ConfigKeyEnum.goodsShareMultipleNotify.getKey(), user.getSystem()));
        return data;
    }

    @Override
    public JSONObject createShareV2(Long uid, List<Long> listStorageID, boolean needDrawPicture)
            throws UserGoodsStorageException, UserShareGoodsRecordException {
        List<UserGoodsStorage> listStorage = userGoodsStorageMapper.listQueryByIds(listStorageID);
        if (listStorage == null || listStorage.size() == 0) {
            throw new UserGoodsStorageException(1, "选品库商品不存在");
        }

        List<UserGoodsStorage> listResult = new ArrayList<UserGoodsStorage>();
        // 还原顺序 用于制图
        for (Long sid : listStorageID) {
            for (UserGoodsStorage torage : listStorage) {
                Long id = torage.getId();
                if (sid == id || sid.equals(id)) {
                    listResult.add(torage);
                    break;
                }
            }
        }

        SystemEnum system = userInfoService.getUserSystem(uid);

        BigDecimal totalMoney = new BigDecimal(0.00);
        List<CommonGoods> listCommonGoods = new ArrayList<CommonGoods>();

        Integer goodsType = null;
        BigDecimal rate = hongBaoManageService.getShareRate(UserLevelEnum.daRen,system);
        for (UserGoodsStorage userGoodsStorage : listResult) {
            CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
            BigDecimal money = CommonGoodsUtil.getCommission(commonGoods, rate);
            totalMoney = MoneyBigDecimalUtil.add(totalMoney, money);
            listCommonGoods.add(commonGoods);

            if (goodsType == null) {
                goodsType = commonGoods.getGoodsType();
            }
        }

        ShareGoodsRecordDTO shareRecord = userShareGoodsRecordService.addRecordGoodsStorageV2(uid, listCommonGoods,
                listStorageID, needDrawPicture);
        FileUploadResult uploadResult = new FileUploadResult();
        uploadResult.setUrl(shareRecord.getSharePictureUrl());

        JSONObject data = new JSONObject();
        data.put("revenue", listCommonGoods.size() + "个商品预估分享奖金：¥" + totalMoney);
        data.put("shareId", shareRecord.getRedisKey());
        data.put("shareImg", uploadResult);


        // 提示语不同
        if (goodsType == Constant.SOURCE_TYPE_JD) {
            // 京东
            data.put("notifyDesc", configService.getValue(ConfigKeyEnum.goodsShareNotifyJD.getKey(), system));
        } else if (goodsType == Constant.SOURCE_TYPE_PDD) {
            // 拼多多
            data.put("notifyDesc", configService.getValue(ConfigKeyEnum.goodsShareNotifyPDD.getKey(), system));
        } else {
            data.put("notifyDesc", configService.getValue(ConfigKeyEnum.goodsShareMultipleNotify.getKey(), system));
        }
        return data;
    }

}