| | |
|---|
| | | import org.springframework.core.task.TaskExecutor;
|
|---|
| | | import org.springframework.stereotype.Service;
|
|---|
| | | import org.yeshi.utils.JsonUtil;
|
|---|
| | | import org.yeshi.utils.entity.FileUploadResult;
|
|---|
| | | import org.yeshi.utils.taobao.TbImgUtil;
|
|---|
| | |
|
|---|
| | | import com.google.gson.Gson;
|
|---|
| | | import com.google.gson.GsonBuilder;
|
|---|
| | |
|---|
| | | 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.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.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;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class UserGoodsStorageServiceImpl implements UserGoodsStorageService {
|
|---|
| | |
|---|
| | | 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 {
|
|---|
| | |
|---|
| | | return array;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | Date nowDate = new Date();
|
|---|
| | | long nh = 1000 * 60 * 60;
|
|---|
| | | long nd = 1000 * 24 * 60 * 60;
|
|---|
| | | List<CommonGoods> listUpadteCommonGoods = new ArrayList<CommonGoods>();
|
|---|
| | | |
|---|
| | | List<Long> listGid = new ArrayList<Long>();
|
|---|
| | | for (UserGoodsStorage userGoodsStorage : listStorage) {
|
|---|
| | | CommonGoods commonGoods = userGoodsStorage.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();
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | BigDecimal rate = manageService.getFanLiRate();
|
|---|
| | | Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
|
|---|
| | | .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
|
|---|
| | |
|
|---|
| | | Map<String, String> map = manageService.convertMap();
|
|---|
| | | BigDecimal rate = manageService.getFanLiRate();
|
|---|
| | | |
|---|
| | |
|
|---|
| | | for (UserGoodsStorage userGoodsStorage : listStorage) {
|
|---|
| | | CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
|
|---|
| | |
|---|
| | | 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 hour = diff % nd / nh;
|
|---|
| | | if (hour > 1 ) {
|
|---|
| | | try {
|
|---|
| | | if (commonGoods.getGoodsType() == CommonGoods.GOODS_TYPE_TB) {
|
|---|
| | | goodsBrief = redisManager.getTaoBaoGoodsBrief(commonGoods.getGoodsId());
|
|---|
| | | goodsBrief.setState(0);
|
|---|
| | | goodsState = 0;
|
|---|
| | | }
|
|---|
| | | } catch (TaobaoGoodsDownException e) {
|
|---|
| | | // 已下架
|
|---|
| | | goodsState = 1;
|
|---|
| | | commonGoods.setState(1);
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (goodsBrief == null) {
|
|---|
| | | goodsBrief = TaoBaoUtil.convert(commonGoods);
|
|---|
| | | } else {
|
|---|
| | | CommonGoods upadeteCommonGoods = CommonGoodsFactory.create(goodsBrief);
|
|---|
| | | upadeteCommonGoods.setState(goodsState);
|
|---|
| | | listUpadteCommonGoods.add(upadeteCommonGoods);
|
|---|
| | | }
|
|---|
| | | TaoBaoGoodsBrief 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); // 已分享状态
|
|---|
| | | Integer storageState = userGoodsStorage.getState();
|
|---|
| | | if (storageState != null && storageState == UserGoodsStorage.STATE_SHARED) {
|
|---|
| | | Integer goodsState = goodsBrief.getState();
|
|---|
| | | if (goodsState != null && goodsState != 1) {
|
|---|
| | | goodsBrief.setState(2); // 已分享状态 优先显示已下架
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 改变图片尺寸
|
|---|
| | | String pictUrl = commonGoods.getPicture();
|
|---|
| | | if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) {
|
|---|
| | | commonGoods.setPicture(TbImgUtil.getTBSize320Img(pictUrl));
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | if (listUpadteCommonGoods.size() > 0) {
|
|---|
| | | executor.execute(new Runnable() {
|
|---|
| | | @Override
|
|---|
| | | public void run() {
|
|---|
| | | try {
|
|---|
| | | // 更新简版信息
|
|---|
| | | commonGoodsService.updateBatchCommonGoods(listUpadteCommonGoods);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return array;
|
|---|
| | |
|---|
| | | 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>();
|
|---|
| | |
|
|---|
| | | for (UserGoodsStorage userGoodsStorage: listStorage) {
|
|---|
| | | String rateStr = hongBaoManageService.get("hongbao_goods_proportion");
|
|---|
| | | |
|---|
| | | for (UserGoodsStorage userGoodsStorage: listResult) {
|
|---|
| | | CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
|
|---|
| | | TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
|
|---|
| | | listGoodsBrief.add(goodsBrief);
|
|---|
| | | // 已分享
|
|---|
| | | userGoodsStorage.setState(1);
|
|---|
| | | userGoodsStorage.setUpdateTime(new Date());
|
|---|
| | |
|
|---|
| | | String rateStr = hongBaoManageService.get("hongbao_goods_proportion");
|
|---|
| | | BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(goodsBrief, new BigDecimal(rateStr));
|
|---|
| | | totalMoney = MoneyBigDecimalUtil.add(totalMoney, money);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String revenue = listGoodsBrief.size() + "个商品预估分享奖金：¥"+totalMoney;
|
|---|
| | | FileUploadResult loadResult = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.storage, listGoodsBrief);
|
|---|
| | |
|
|---|
| | | // 更新为已分享
|
|---|
| | | userGoodsStorageMapper.updateBatchSelective(listStorage);
|
|---|
| | | |
|---|
| | | Map<String,Object> map = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.storage, |
|---|
| | | null, listGoodsBrief);
|
|---|
| | |
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | data.put("shareImg", loadResult);
|
|---|
| | | data.put("revenue", revenue);
|
|---|
| | | data.put("notifyDesc", configService.get("goods_share_notify"));
|
|---|
| | | data.put("shareId", map.get("shareId"));
|
|---|
| | | data.put("shareImg", map.get("loadResult"));
|
|---|
| | | data.put("notifyDesc", configService.get("goods_share_multiple_notify"));
|
|---|
| | |
|
|---|
| | | return data;
|
|---|
| | | |
|---|
| | | }
|
|---|
| | | }
|
|---|
