| | |
| | |
|
| | | @Resource(name = "taskExecutor")
|
| | | private TaskExecutor executor;
|
| | | |
| | |
|
| | | @Resource
|
| | | private ConfigService configService;
|
| | | |
| | |
|
| | | @Resource
|
| | | private RedisManager redisManager;
|
| | | |
| | |
|
| | | @Resource
|
| | | private UserInfoMapper userInfoMapper;
|
| | | |
| | |
|
| | | @Resource
|
| | | private UserAccountService userAccountService;
|
| | | |
| | |
|
| | | @Resource
|
| | | private UserShareGoodsRecordMapper userShareGoodsRecordMapper;
|
| | | |
| | |
|
| | | @Resource
|
| | | private CommonGoodsService commonGoodsService;
|
| | | |
| | |
|
| | | @Resource
|
| | | private UserShareGoodsGroupService userShareGoodsGroupService;
|
| | | |
| | |
|
| | | @Resource
|
| | | private HongBaoManageService hongBaoManageService;
|
| | | |
| | |
|
| | | @Resource
|
| | | private UserGoodsStorageService userGoodsStorageService;
|
| | |
|
| | |
| | | return userShareGoodsRecordMapper.updateByPrimaryKeySelective(record);
|
| | | }
|
| | |
|
| | |
|
| | | @Override
|
| | | public List<UserShareGoodsRecord> listQueryByUid(long start, int count, Long uid, String source) {
|
| | | return userShareGoodsRecordMapper.listQueryByUid(start, count, uid, source);
|
| | |
| | | public long countQueryByUid(Long uid, String source) {
|
| | | return userShareGoodsRecordMapper.countQueryByUid(uid, source);
|
| | | }
|
| | | |
| | | |
| | |
|
| | | @Override
|
| | | public List<UserShareGoodsRecord> listCountRecord(List<Long> list) {
|
| | | return userShareGoodsRecordMapper.listCountRecord(list);
|
| | | }
|
| | | |
| | |
|
| | | @Override
|
| | | public List<UserShareGoodsRecord> getMyShareGoodsRecords(long start, int count, Long uid, String source) {
|
| | | |
| | |
|
| | | List<UserShareGoodsRecord> list = listQueryByUid(start, count, uid, source);
|
| | | if (list == null) {
|
| | | list = new ArrayList<UserShareGoodsRecord>();
|
| | | }
|
| | | |
| | |
|
| | | if (list.size() > 0) {
|
| | | List<Long> listId = new ArrayList<Long>();
|
| | | |
| | | for (UserShareGoodsRecord userShareGoodsRecord: list) {
|
| | |
|
| | | for (UserShareGoodsRecord userShareGoodsRecord : list) {
|
| | | userShareGoodsRecord.setShareTime(userShareGoodsRecord.getUpdateTime().getTime());
|
| | | userShareGoodsRecord.setCreateTime(null);
|
| | | userShareGoodsRecord.setUpdateTime(null);
|
| | | listId.add(userShareGoodsRecord.getId());
|
| | | |
| | |
|
| | | // 改变图片尺寸
|
| | | String pictUrl = userShareGoodsRecord.getPicture();
|
| | | if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) {
|
| | | userShareGoodsRecord.setPicture(TbImgUtil.getTBSize320Img(pictUrl));
|
| | | }
|
| | | |
| | | |
| | |
|
| | | }
|
| | | |
| | |
|
| | | // 今日浏览统计
|
| | | List<UserShareGoodsRecord> listTodayBrowse= userShareGoodsRecordMapper.listCountTodayBrowse(listId);
|
| | | |
| | | List<UserShareGoodsRecord> listTodayBrowse = userShareGoodsRecordMapper.listCountTodayBrowse(listId);
|
| | |
|
| | | // 订单、浏览数量、金额统计
|
| | | List<UserShareGoodsRecord> listCountRecord = listCountRecord(listId);
|
| | | |
| | |
|
| | | if ((listCountRecord != null && listCountRecord.size() > 0)
|
| | | || (listTodayBrowse != null && listTodayBrowse.size() > 0)) {
|
| | | |
| | | for (UserShareGoodsRecord shareRecord: list) {
|
| | | Long id = shareRecord.getId() ;
|
| | | |
| | | if (listTodayBrowse != null && listTodayBrowse.size() > 0){
|
| | | for (UserShareGoodsRecord goodsRecord: listTodayBrowse) {
|
| | | || (listTodayBrowse != null && listTodayBrowse.size() > 0)) {
|
| | |
|
| | | for (UserShareGoodsRecord shareRecord : list) {
|
| | | Long id = shareRecord.getId();
|
| | |
|
| | | if (listTodayBrowse != null && listTodayBrowse.size() > 0) {
|
| | | for (UserShareGoodsRecord goodsRecord : listTodayBrowse) {
|
| | | Long recordId = goodsRecord.getId();
|
| | | if (id == recordId || id.equals(recordId)) {
|
| | | shareRecord.setTodayBrowse(goodsRecord.getTodayBrowse());
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | | |
| | |
|
| | | if (listCountRecord != null && listCountRecord.size() > 0) {
|
| | | for (UserShareGoodsRecord goodsRecord: listCountRecord) {
|
| | | for (UserShareGoodsRecord goodsRecord : listCountRecord) {
|
| | | Long recordId = goodsRecord.getId();
|
| | | if (id == recordId || id.equals(recordId)) {
|
| | | shareRecord.setTotalBrowse(goodsRecord.getTotalBrowse());
|
| | | shareRecord.setTotalOrder(goodsRecord.getTotalOrder());
|
| | | |
| | |
|
| | | BigDecimal totalMoney = goodsRecord.getTotalMoney();
|
| | | if (totalMoney != null && totalMoney.compareTo(new BigDecimal(0))>0 ) {
|
| | | if (totalMoney != null && totalMoney.compareTo(new BigDecimal(0)) > 0) {
|
| | | shareRecord.setTotalMoney(goodsRecord.getTotalMoney());
|
| | | } else {
|
| | | shareRecord.setTotalMoney(goodsRecord.getRevenueMoney());
|
| | | }
|
| | | shareRecord.setRevenueMoney(null);
|
| | | |
| | | |
| | |
|
| | | Integer totalGoods = goodsRecord.getTotalGoods();
|
| | | shareRecord.setTotalGoods(totalGoods);
|
| | | if (totalGoods > 1) {
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | | |
| | |
|
| | | return list;
|
| | | }
|
| | | |
| | |
|
| | | @Override
|
| | | public void saveDetail(Long uid, Long auctionId, String type) throws UserShareGoodsRecordException {
|
| | | |
| | |
|
| | | if (auctionId == null) {
|
| | | throw new UserShareGoodsRecordException(1, "分享商品不能为空");
|
| | | }
|
| | | |
| | |
|
| | | if (uid == null) {
|
| | | throw new UserShareGoodsRecordException(1, "用户ID不能为空");
|
| | | }
|
| | | |
| | |
|
| | | TaoBaoGoodsBrief goodsBrief = null;
|
| | | try {
|
| | | goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
|
| | | } catch (TaobaoGoodsDownException e) {
|
| | | throw new UserShareGoodsRecordException(1, "商品已下架");
|
| | | }
|
| | | |
| | |
|
| | | UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
|
| | | userShareGoodsRecord.setUid(uid);
|
| | | userShareGoodsRecord.setSource(ShareSourceTypeEnum.goodsDetail);
|
| | |
| | | // 单个商品分享
|
| | | singleGoodsShare(userShareGoodsRecord, goodsBrief);
|
| | | }
|
| | | |
| | |
|
| | | @Override
|
| | | public void save(Long uid, ShareSourceTypeEnum source, String title, TaoBaoGoodsBrief taoBaoGoodsBrief) throws UserShareGoodsRecordException {
|
| | | |
| | | public void save(Long uid, ShareSourceTypeEnum source, String title, TaoBaoGoodsBrief taoBaoGoodsBrief)
|
| | | throws UserShareGoodsRecordException {
|
| | |
|
| | | if (taoBaoGoodsBrief == null) {
|
| | | throw new UserShareGoodsRecordException(1, "分享商品不能为空");
|
| | | }
|
| | | |
| | |
|
| | | if (uid == null) {
|
| | | throw new UserShareGoodsRecordException(1, "用户ID不能为空");
|
| | | }
|
| | | |
| | |
|
| | | if (source == null) {
|
| | | throw new UserShareGoodsRecordException(1, "分享来源不能为空");
|
| | | }
|
| | | |
| | |
|
| | | UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
|
| | | userShareGoodsRecord.setUid(uid);
|
| | | userShareGoodsRecord.setSource(source);
|
| | |
| | | // 单个商品分享
|
| | | singleGoodsShare(userShareGoodsRecord, taoBaoGoodsBrief);
|
| | | }
|
| | | |
| | | |
| | |
|
| | | /**
|
| | | * 保存分享记录
|
| | | * @param userShareGoodsRecord 分享记录: uid、picture、source 为必输入
|
| | | * |
| | | * @param userShareGoodsRecord
|
| | | * 分享记录: uid、picture、source 为必输入
|
| | | * @throws UserShareGoodsRecordException
|
| | | */
|
| | | @Override
|
| | | public Map<String,Object> save(Long uid, ShareSourceTypeEnum source, String title, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
|
| | | |
| | | public Map<String, Object> save(Long uid, ShareSourceTypeEnum source, String title,
|
| | | List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
|
| | |
|
| | | if (listGoods == null || listGoods.size() < 0) {
|
| | | throw new UserShareGoodsRecordException(1, "分享商品数量不足");
|
| | | }
|
| | | |
| | |
|
| | | if (uid == null) {
|
| | | throw new UserShareGoodsRecordException(1, "用户ID不能为空");
|
| | | }
|
| | | |
| | |
|
| | | if (source == null) {
|
| | | throw new UserShareGoodsRecordException(1, "分享来源不能为空");
|
| | | }
|
| | | |
| | |
|
| | | UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
|
| | | userShareGoodsRecord.setUid(uid);
|
| | | userShareGoodsRecord.setSource(source);
|
| | | userShareGoodsRecord.setTitle(title);
|
| | | // 取一个商品图片作为主图
|
| | | userShareGoodsRecord.setPicture(listGoods.get(0).getPictUrl());
|
| | | |
| | |
|
| | | Date date = new Date();
|
| | | userShareGoodsRecord.setShareState(0); // 初始未分享
|
| | | userShareGoodsRecord.setCreateTime(date);
|
| | | userShareGoodsRecord.setUpdateTime(date);
|
| | | userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);
|
| | | |
| | | |
| | | Map<String,Object> map = new HashMap<String,Object>();
|
| | |
|
| | | Map<String, Object> map = new HashMap<String, Object>();
|
| | | // 多个商品分享
|
| | | FileUploadResult loadResult = multipleGoodsShare(userShareGoodsRecord, listGoods);
|
| | | map.put("loadResult", loadResult);
|
| | | map.put("shareId", userShareGoodsRecord.getId());
|
| | | |
| | |
|
| | | return map;
|
| | | }
|
| | | |
| | |
|
| | | /**
|
| | | * 单个商品分享生成记录
|
| | | * |
| | | * @param userShareGoodsRecord
|
| | | * @param taoBaoGoodsBrief
|
| | | */
|
| | | @Transactional
|
| | | public void singleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, TaoBaoGoodsBrief taoBaoGoodsBrief) {
|
| | | |
| | |
|
| | | CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);
|
| | | commonGoods.setState(taoBaoGoodsBrief.getState());
|
| | | try {
|
| | | CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
|
| | | |
| | |
|
| | | if (resultCommonGoods == null) {
|
| | | return;
|
| | | }
|
| | | |
| | | |
| | |
|
| | | UserShareGoodsGroup singleGoods = userShareGoodsGroupService.getSingleGoods(resultCommonGoods.getId(),
|
| | | userShareGoodsRecord.getUid());
|
| | | |
| | |
|
| | | if (singleGoods != null) {
|
| | | // 单个商品多次分享
|
| | | userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());
|
| | | userShareGoodsRecord.setId(singleGoods.getRecordId());
|
| | | userShareGoodsRecord.setUpdateTime(new Date());
|
| | | userShareGoodsRecordMapper.updateByPrimaryKeySelective(userShareGoodsRecord);
|
| | | |
| | |
|
| | | // 最新商品
|
| | | singleGoods.setUpdateTime(new Date());
|
| | | userShareGoodsGroupService.updateByPrimaryKeySelective(singleGoods);
|
| | | |
| | | } else |
| | | {
|
| | |
|
| | | } else {
|
| | | // 单个商品第一次分享
|
| | | Date date = new Date();
|
| | | userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());
|
| | | userShareGoodsRecord.setCreateTime(date);
|
| | | userShareGoodsRecord.setUpdateTime(date);
|
| | | userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);
|
| | | |
| | |
|
| | | singleGoods = new UserShareGoodsGroup();
|
| | | singleGoods.setTotalOrder(0);
|
| | | singleGoods.setTotalBrowse(0);
|
| | |
| | | singleGoods.setUpdateTime(date);
|
| | | singleGoods.setCommonGoods(resultCommonGoods);
|
| | | singleGoods.setRecordId(userShareGoodsRecord.getId());
|
| | | |
| | |
|
| | | userShareGoodsGroupService.insertSelective(singleGoods);
|
| | | }
|
| | | |
| | |
|
| | | } catch (CommonGoodsException e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | |
| | |
|
| | | }
|
| | | |
| | | |
| | |
|
| | | /**
|
| | | * 多个商品分享生成记录
|
| | | * |
| | | * @param userShareGoodsRecord
|
| | | * @param listGoods
|
| | | */
|
| | | @Transactional
|
| | | public FileUploadResult multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
|
| | | |
| | | public FileUploadResult multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord,
|
| | | List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
|
| | |
|
| | | // 分享记录
|
| | | Date date = new Date();
|
| | | |
| | |
|
| | | List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();
|
| | | List<UserShareGoodsGroup> listGroup = new ArrayList<UserShareGoodsGroup>();
|
| | | |
| | | for (TaoBaoGoodsBrief taoBaoGoodsBrief: listGoods) {
|
| | |
|
| | | 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);
|
| | | TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(resultCommonGoods);
|
| | | listGoodsBrief.add(goodsBrief);
|
| | | }
|
| | | |
| | |
|
| | | UserShareGoodsGroup shareGoodsGroup = new UserShareGoodsGroup();
|
| | | shareGoodsGroup.setTotalOrder(0);
|
| | | shareGoodsGroup.setTotalBrowse(0);
|
| | |
| | | shareGoodsGroup.setUpdateTime(date);
|
| | | shareGoodsGroup.setCommonGoods(resultCommonGoods);
|
| | | shareGoodsGroup.setRecordId(userShareGoodsRecord.getId());
|
| | | |
| | | |
| | |
|
| | | listGroup.add(shareGoodsGroup);
|
| | | |
| | |
|
| | | } catch (CommonGoodsException e) {
|
| | | e.printStackTrace();
|
| | | continue;
|
| | | }
|
| | | }
|
| | | |
| | |
|
| | | FileUploadResult shareImg = createShareImg(userShareGoodsRecord, listGoodsBrief);
|
| | | |
| | |
|
| | | if (listGroup.size() > 0) {
|
| | | userShareGoodsGroupService.insertBatch(listGroup);
|
| | | }
|
| | | |
| | |
|
| | | return shareImg;
|
| | | }
|
| | | |
| | |
|
| | | /**
|
| | | * 生成分享图
|
| | | * @param uid 用户id
|
| | | * @param shareId 分享记录id
|
| | | * @param source 来源
|
| | | * |
| | | * @param uid
|
| | | * 用户id
|
| | | * @param shareId
|
| | | * 分享记录id
|
| | | * @param source
|
| | | * 来源
|
| | | * @param listGoods
|
| | | * @return
|
| | | * @throws UserShareGoodsRecordException
|
| | | */
|
| | | public FileUploadResult createShareImg (UserShareGoodsRecord shareRecord, List<TaoBaoGoodsBrief> listGoods) |
| | | throws UserShareGoodsRecordException{
|
| | | |
| | | public FileUploadResult createShareImg(UserShareGoodsRecord shareRecord, List<TaoBaoGoodsBrief> listGoods)
|
| | | throws UserShareGoodsRecordException {
|
| | |
|
| | | Long uid = shareRecord.getUid();
|
| | | Long shareId = shareRecord.getId();
|
| | | String source = shareRecord.getSource().name();
|
| | | |
| | | 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 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);
|
| | | if (!StringUtil.isNullOrEmpty(shortLink)) {
|
| | | url = shortLink;
|
| | |
| | | } catch (Exception e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | |
| | |
|
| | | // 获取到用户的头像
|
| | | UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
|
| | | if (user == null) {
|
| | | throw new UserShareGoodsRecordException(1, "用户信息不存在");
|
| | | }
|
| | | |
| | |
|
| | | InputStream portrait = null;
|
| | | |
| | |
|
| | | if (!StringUtil.isNullOrEmpty(user.getPortrait())) {
|
| | | try {
|
| | | portrait = HttpUtil.downLoadImg(user.getPortrait());
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | | |
| | |
|
| | | InputStream inputStream = ImageUtil.drawGoodsShareBigImg(erCodeInputStream, portrait, listGoods);
|
| | | |
| | |
|
| | | FileUploadResult shareImg = COSManager.getInstance().uploadInputStream(inputStream,
|
| | | "sharegoods/share_" + uid + "_" + shareId + "_" + System.currentTimeMillis() + ".png");
|
| | | |
| | |
|
| | | return shareImg;
|
| | | }
|
| | | |
| | | |
| | |
|
| | | @Override
|
| | | public JSONObject getGoodsGroup(Long recordId) throws UserShareGoodsRecordException {
|
| | | |
| | |
|
| | | JSONArray array = new JSONArray();
|
| | |
|
| | | List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId);
|
| | | |
| | |
|
| | | List<Long> listGid = new ArrayList<Long>();
|
| | | for (UserShareGoodsGroup goodsGroup : list) {
|
| | | CommonGoods commonGoods = goodsGroup.getCommonGoods();
|
| | |
| | | }
|
| | | listGid.add(commonGoods.getGoodsId());
|
| | | }
|
| | | |
| | |
|
| | | // API网络接口验证是否在售
|
| | | List<TaoBaoGoodsBrief> listTaoKeGoods = null;
|
| | | try {
|
| | |
| | | } catch (Exception e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | |
| | |
|
| | | Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
|
| | | .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
|
| | |
|
| | | BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis());
|
| | | |
| | |
|
| | | for (UserShareGoodsGroup goodsGroup : list) {
|
| | | CommonGoods commonGoods = goodsGroup.getCommonGoods();
|
| | | if (commonGoods == null) {
|
| | | continue;
|
| | | }
|
| | | |
| | | if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 ) {
|
| | | int state = 1; // 默认停售
|
| | |
|
| | | if (listTaoKeGoods != null && listTaoKeGoods.size() > 0) {
|
| | | int state = 1; // 默认停售
|
| | | Long goodsId = commonGoods.getGoodsId();
|
| | | for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {
|
| | | for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {
|
| | | Long auctionId = taoKeGoods.getAuctionId();
|
| | | if (goodsId == auctionId || goodsId.equals(auctionId)) {
|
| | | state = 0; // 在售
|
| | |
| | | }
|
| | | commonGoods.setState(state);
|
| | | }
|
| | | |
| | |
|
| | | TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
|
| | | |
| | |
|
| | | // 今日浏览记录处理
|
| | | Date date = new Date();
|
| | | Date browseTime = goodsGroup.getBrowseTime();
|
| | | if (!DateUtil.isSameDay(browseTime, date)) {
|
| | | goodsGroup.setTodayBrowse(0); // 不是同一天浏览记录设置0
|
| | | }
|
| | | |
| | | |
| | |
|
| | | JSONObject dataObject = new JSONObject();
|
| | | dataObject.put("todayBrowse",goodsGroup.getTodayBrowse() );
|
| | | dataObject.put("totalBrowse",goodsGroup.getTotalBrowse() );
|
| | | dataObject.put("todayBrowse", goodsGroup.getTodayBrowse());
|
| | | dataObject.put("totalBrowse", goodsGroup.getTotalBrowse());
|
| | | dataObject.put("totalOrder", goodsGroup.getTotalOrder());
|
| | | dataObject.put("totalMoney", "¥"+goodsGroup.getTotalMoney());
|
| | | dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate+"", null)));
|
| | | dataObject.put("totalMoney", "¥" + goodsGroup.getTotalMoney());
|
| | | dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate + "", null)));
|
| | | array.add(dataObject);
|
| | | }
|
| | | |
| | |
|
| | | String title = "";
|
| | | UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);
|
| | | if(userShareGoodsRecord != null) {
|
| | | if (userShareGoodsRecord != null) {
|
| | | title = userShareGoodsRecord.getTitle();
|
| | | }
|
| | | |
| | |
|
| | | JSONObject data = new JSONObject();
|
| | | data.put("title", title);
|
| | | data.put("count", list.size());
|
| | |
| | | return data;
|
| | | }
|
| | |
|
| | | |
| | | @Override
|
| | | public JSONObject getGoodsGroupDetail(Long recordId) throws UserShareGoodsRecordException {
|
| | | |
| | |
|
| | | JSONArray array = new JSONArray();
|
| | | |
| | |
|
| | | List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId);
|
| | | |
| | |
|
| | | if (list != null && list.size() > 0) {
|
| | |
|
| | | List<Long> listGid = new ArrayList<Long>();
|
| | |
| | | }
|
| | | listGid.add(commonGoods.getGoodsId());
|
| | | }
|
| | | |
| | |
|
| | | // API网络接口验证是否在售
|
| | | List<TaoBaoGoodsBrief> listTaoKeGoods = null;
|
| | | try {
|
| | |
| | | } catch (Exception e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | |
| | | |
| | |
|
| | | Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
|
| | | .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
|
| | | |
| | |
|
| | | BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis());
|
| | | |
| | |
|
| | | for (UserShareGoodsGroup goodsGroup : list) {
|
| | | CommonGoods commonGoods = goodsGroup.getCommonGoods();
|
| | | if (commonGoods == null) {
|
| | | continue;
|
| | | }
|
| | | |
| | | if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 ) {
|
| | | int state = 1; // 默认停售
|
| | |
|
| | | if (listTaoKeGoods != null && listTaoKeGoods.size() > 0) {
|
| | | int state = 1; // 默认停售
|
| | | Long goodsId = commonGoods.getGoodsId();
|
| | | for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {
|
| | | for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {
|
| | | Long auctionId = taoKeGoods.getAuctionId();
|
| | | if (goodsId == auctionId || goodsId.equals(auctionId)) {
|
| | | state = 0; // 在售
|
| | |
| | | }
|
| | | commonGoods.setState(state);
|
| | | }
|
| | | |
| | |
|
| | | TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
|
| | | |
| | |
|
| | | if (goodsBrief.getCouponLeftCount() < 1 || StringUtil.isNullOrEmpty(goodsBrief.getCouponInfo())) {
|
| | | goodsBrief.setState(1); // 已抢光
|
| | | }
|
| | | |
| | | TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate +"", null);
|
| | | goodsBrief.setState(1); // 已抢光
|
| | | }
|
| | |
|
| | | TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,
|
| | | shareRate + "", null);
|
| | | array.add(gson.toJson(taoBaoGoodsBriefExtra));
|
| | | }
|
| | |
|
| | | }
|
| | | |
| | |
|
| | | String title = "";
|
| | | UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);
|
| | | if(userShareGoodsRecord != null) {
|
| | | if (userShareGoodsRecord != null) {
|
| | | title = userShareGoodsRecord.getTitle();
|
| | | }
|
| | | |
| | |
|
| | | JSONObject data = new JSONObject();
|
| | | data.put("title", title);
|
| | | data.put("count", list.size());
|
| | | data.put("result_list", array);
|
| | | |
| | |
|
| | | return data;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public void updateShareRecord (Long shareId) throws UserShareGoodsRecordException {
|
| | | public void updateShareRecord(Long shareId) throws UserShareGoodsRecordException {
|
| | | UserShareGoodsRecord shareRecord = userShareGoodsRecordMapper.selectByPrimaryKey(shareId);
|
| | | if (shareRecord == null) {
|
| | | throw new UserShareGoodsRecordException(1, "分享记录不存在");
|
| | | }
|
| | | |
| | |
|
| | | shareRecord.setShareState(1);// 分享生效
|
| | | updateByPrimaryKeySelective(shareRecord);
|
| | | // 更新商品为已分享
|
| | | userGoodsStorageService.updateShareState(shareId);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public long countShareRecordByUid(Long uid) {
|
| | |
|
| | | return userShareGoodsRecordMapper.countQueryByUid(uid, null);
|
| | |
|
| | | }
|
| | | }
|