package com.yeshi.fanli.service.impl.goods;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import com.yeshi.fanli.entity.SystemEnum;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import org.springframework.stereotype.Service;
|
import org.yeshi.utils.HttpUtil;
|
import org.yeshi.utils.JsonUtil;
|
import org.yeshi.utils.QRCodeUtil;
|
import org.yeshi.utils.entity.FileUploadResult;
|
import org.yeshi.utils.exception.HttpException;
|
import org.yeshi.utils.tencentcloud.COSManager;
|
|
import com.yeshi.fanli.dao.mybatis.UserShareGoodsHistoryMapper;
|
import com.yeshi.fanli.dto.taobao.TaoLiJinDTO;
|
import com.yeshi.fanli.entity.bus.share.UserShareGoodsHistory;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.taobao.PidUser;
|
import com.yeshi.fanli.entity.taobao.TBPid;
|
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.entity.taobao.TaoBaoLink;
|
import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
|
import com.yeshi.common.entity.taobao.TaoKeAppInfo;
|
import com.yeshi.fanli.entity.taobao.UserTLJBuyHistory;
|
import com.yeshi.fanli.exception.share.ShareGoodsException;
|
import com.yeshi.fanli.exception.taobao.TaoKeApiException;
|
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
|
import com.yeshi.fanli.exception.tlj.TaoLiJinCreateException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.goods.ShareGoodsService;
|
import com.yeshi.fanli.service.inter.monitor.BusinessEmergent110Service;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.redpack.UserTaoLiJinNewbiesService;
|
import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
|
import com.yeshi.fanli.service.inter.taobao.UserTLJBuyHistoryService;
|
import com.yeshi.goods.facade.service.DaTaoKeGoodsDetailV2Service;
|
import com.yeshi.fanli.service.inter.user.TBPidService;
|
import com.yeshi.fanli.service.inter.user.UserAccountService;
|
import com.yeshi.fanli.service.manger.goods.ConvertLinkManager;
|
import com.yeshi.fanli.util.AESUtil;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.FilePathEnum;
|
import com.yeshi.fanli.util.FileUtil;
|
import com.yeshi.fanli.util.ImageUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import org.yeshi.utils.TimeUtil;
|
import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|
@Service
|
public class ShareGoodsServiceImpl implements ShareGoodsService {
|
|
@Resource
|
private TBPidService tbPidService;
|
|
@Resource
|
private UserShareGoodsHistoryMapper userShareGoodsHistoryMapper;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private TaoBaoUnionConfigService taoBaoUnionConfigService;
|
|
@Resource
|
private UserAccountService userAccountService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private UserTLJBuyHistoryService userTLJBuyHistoryService;
|
|
@Resource
|
private TLJBuyGoodsService tljBuyGoodsService;
|
|
@Resource
|
private BusinessEmergent110Service businessEmergent110Service;
|
|
@Resource
|
private ConvertLinkManager convertLinkManager;
|
|
@Override
|
public void addShareGoodsHistory(UserShareGoodsHistory history) {
|
UserShareGoodsHistory userShareGoodsHistory = userShareGoodsHistoryMapper
|
.selectByUidAndAuctionId(history.getUser().getId(), history.getGoodsId());
|
if (userShareGoodsHistory != null && !StringUtil.isNullOrEmpty(history.getTkCode())) {
|
UserShareGoodsHistory update = new UserShareGoodsHistory();
|
update.setId(userShareGoodsHistory.getId());
|
userShareGoodsHistory.setTkCode(history.getTkCode());
|
userShareGoodsHistory.setCreateTime(new Date());
|
userShareGoodsHistoryMapper.updateByPrimaryKeySelective(userShareGoodsHistory);
|
} else
|
userShareGoodsHistoryMapper.insertSelective(history);
|
}
|
|
@Override
|
public UserShareGoodsHistory addShareGoodsHistory(Long uid, String auctionId) throws ShareGoodsException {
|
TBPid tbPid = tbPidService.getTBPid(uid, PidUser.TYPE_SHARE_GOODS);
|
if (tbPid == null) {
|
throw new ShareGoodsException(1, "获取PID失败");
|
}
|
String appId = tbPid.getPid().split("_")[2];
|
String adzoneId = tbPid.getPid().split("_")[3];
|
TaoBaoUnionConfig taoBaoUnionConfig = taoBaoUnionConfigService.getConfigByAppIdCache(appId);
|
|
TaoKeAppInfo info = new TaoKeAppInfo();
|
info.setAdzoneId(adzoneId);
|
info.setAppKey(taoBaoUnionConfig.getAppKey());
|
info.setAppSecret(taoBaoUnionConfig.getAppSecret());
|
info.setPid(tbPid.getPid());
|
TaoBaoGoodsBrief goods = null;
|
long startTime = System.currentTimeMillis();
|
try {
|
goods = TaoKeApiUtil.searchGoodsDetail(auctionId, info);
|
} catch (TaobaoGoodsDownException e) {
|
throw new ShareGoodsException(3, "商品已下架");
|
} finally {
|
LogHelper.test(auctionId + "-获取商品详情耗时为:" + (System.currentTimeMillis() - startTime));
|
}
|
if (goods == null) {
|
throw new ShareGoodsException(3, "商品已下架");
|
}
|
|
// 没有获取到转过链的商品详情
|
if (StringUtil.isNullOrEmpty(goods.getCouponLink()) && !goods.getAuctionUrl().contains("s.click.taobao.com")) {
|
TaoBaoGoodsBrief taoBaoLink = TaoKeApiUtil.specialConvertCouponV2(auctionId, info, null, null); // TaoBaoUtil.getTbLinkForShare(auctionId,
|
// tbPid.getPid(),
|
// taoBaoUnionConfig);
|
if (taoBaoLink == null) {
|
throw new ShareGoodsException(201, "转链失败");
|
}
|
goods.setCouponLink(taoBaoLink.getCouponLink());
|
goods.setAuctionUrl(taoBaoLink.getAuctionUrl());
|
}
|
return addShareGoodsHistory(uid, goods);
|
}
|
|
@Override
|
public UserShareGoodsHistory addShareGoodsHistory(Long uid, TaoBaoGoodsBrief goods) throws ShareGoodsException {
|
if (StringUtil.isNullOrEmpty(goods.getCouponLink()) && StringUtil.isNullOrEmpty(goods.getAuctionUrl())) {
|
throw new ShareGoodsException(10, "转链失败");
|
}
|
|
SystemEnum system = userInfoService.getUserSystem(uid);
|
BigDecimal rate = hongBaoManageService.getShareRate(system);
|
|
// 创建淘口令
|
TaoBaoLink tbLink = new TaoBaoLink(); // TaoBaoUtil.getTbLinkForShare(goods.getAuctionId(),
|
// tbPid.getPid(),
|
// config.get(0));
|
tbLink.setAuctionId(goods.getAuctionId());
|
tbLink.setClickUrl(goods.getAuctionUrl());
|
tbLink.setCouponLink(goods.getCouponLink());
|
|
if (!StringUtil.isNullOrEmpty(tbLink.getCouponLink())) {// 通过立即推广方式获取淘口令成功
|
String quanToken = TaoKeApiUtil.getTKToken(goods.getPictUrl(), goods.getTitle(), tbLink.getCouponLink());
|
if (!StringUtil.isNullOrEmpty(quanToken)) {
|
tbLink.setTaoToken(quanToken);
|
}
|
} else if (!StringUtil.isNullOrEmpty(tbLink.getClickUrl())) {
|
String quanToken = TaoKeApiUtil.getTKToken(goods.getPictUrl(), goods.getTitle(), tbLink.getClickUrl());
|
if (!StringUtil.isNullOrEmpty(quanToken)) {
|
tbLink.setTaoToken(quanToken);
|
}
|
}
|
|
UserShareGoodsHistory history = new UserShareGoodsHistory();
|
history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));
|
history.setLink(tbLink.getClickUrl());
|
history.setQuanLink(tbLink.getCouponLink());
|
history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));
|
|
history.setCreateTime(new Date());
|
history.setGoodsId(goods.getAuctionId());
|
history.setGoodsType(UserShareGoodsHistory.TYPE_TAOBAO);
|
history.setHongbao(TaoBaoUtil.getShareGoodsHongBaoInfo(goods, rate));
|
List<String> imgList = goods.getImgList();
|
if (imgList == null) {
|
imgList = new ArrayList<>();
|
}
|
history.setPictures(JsonUtil.getGson().toJson(imgList));
|
history.setUser(new UserInfo(uid));
|
history.setPostPicture(goods.getPictUrl());
|
// 生成二维码信息
|
// 包含用户ID与商品ID
|
// 新版商品分享
|
|
String url = String.format("http://%s%s?uid=%s&id=%s", configService.getH5Host(system),
|
Constant.systemCommonConfig.getShareGoodsPagePath(), AESUtil.encrypt(uid + "", Constant.UIDAESKEY),
|
goods.getAuctionId() + "");
|
|
String shortLink = HttpUtil.getShortLink(url);
|
if (!StringUtil.isNullOrEmpty(shortLink)) {
|
url = shortLink;
|
}
|
String destPath = FileUtil.getCacheDir() + "/ercode_" + uid + "_" + goods.getAuctionId() + ".jpg";
|
String shareImgPath = FileUtil.getCacheDir() + "/share_" + uid + "_" + goods.getAuctionId() + ".png";
|
InputStream erCodeInputStream = null;
|
|
try {
|
try {
|
erCodeInputStream = QRCodeUtil.getInstance(500).encode(url);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
// if (!new File(destPath).exists()) {
|
// throw new ShareGoodsException(4, "生成二维码失败");
|
// }
|
// 获取到用户的头像
|
UserInfo user = userInfoService.selectAvailableByPrimaryKey(uid);
|
InputStream portrait = null;
|
if (!StringUtil.isNullOrEmpty(user.getPortrait())) {
|
try {
|
portrait = HttpUtil.downLoadImg(user.getPortrait());
|
} catch (HttpException e) {
|
String portraitUrl = userAccountService.repairPortrait(uid);
|
if (StringUtil.isNullOrEmpty(portraitUrl))
|
throw new ShareGoodsException(11, "获取头像出错");
|
else {
|
// 再次获取头像
|
try {
|
portrait = HttpUtil.downLoadImg(portraitUrl);
|
} catch (HttpException e1) {
|
throw new ShareGoodsException(11, "获取头像出错");
|
}
|
}
|
}
|
}
|
|
InputStream shareImgInputStream = null;
|
|
try {
|
// 海草街的分享二维码不一样
|
if (Constant.systemCommonConfig.getProjectChineseName().contains("海草街")) {
|
try {
|
shareImgInputStream = ImageUtil.drawGoodsShareImgHCJ(new FileInputStream(new File(destPath)),
|
portrait, goods);
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
throw new ShareGoodsException(5, "分享图绘制失败");
|
}
|
} else {
|
shareImgInputStream = ImageUtil.drawGoodsShareImg(erCodeInputStream, portrait, goods);
|
}
|
} catch (Exception e) {
|
try {
|
LogHelper.errorDetailInfo(e, "", "分享图无法找到");
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
try {
|
if (shareImgInputStream != null && shareImgInputStream.available() <= 0) {
|
throw new ShareGoodsException(5, "生成分享图失败");
|
}
|
} catch (IOException e) {
|
throw new ShareGoodsException(5, "读取分享图失败");
|
}
|
|
FileUploadResult shareImgResult = COSManager.getInstance().uploadInputStream(shareImgInputStream,
|
FilePathEnum.shareGoods.getPath() + "share_" + uid + "_" + goods.getAuctionId() + "_"
|
+ System.currentTimeMillis() + ".png");
|
|
if (shareImgResult == null || StringUtil.isNullOrEmpty(shareImgResult.getUrl())) {
|
throw new ShareGoodsException(6, "分享图片保存失败");
|
}
|
|
history.setShareImg(shareImgResult.getUrl());
|
history.setShareImgMD5(shareImgResult.getMd5());
|
|
// 查询之前是否存在，存在就替换掉
|
|
UserShareGoodsHistory old = userShareGoodsHistoryMapper.selectByUidAndAuctionId(uid, history.getGoodsId());
|
if (old != null) {
|
history.setId(old.getId());
|
userShareGoodsHistoryMapper.updateByPrimaryKeySelective(history);
|
// 删除原来的图片
|
COSManager.getInstance().deleteFile(old.getShareImg());
|
} else {
|
userShareGoodsHistoryMapper.insertSelective(history);
|
}
|
history.setLink(url);
|
return history;
|
} finally {
|
if (new File(destPath).exists()) {
|
new File(destPath).delete();
|
}
|
if (new File(shareImgPath).exists()) {
|
new File(shareImgPath).delete();
|
}
|
}
|
}
|
|
@Override
|
public UserShareGoodsHistory getShareGoodsHistoryDetail(Long uid, String auctionId) throws ShareGoodsException {
|
UserShareGoodsHistory userShareGoodsHistory = userShareGoodsHistoryMapper.selectByUidAndAuctionId(uid,
|
auctionId);
|
if (userShareGoodsHistory == null)
|
throw new ShareGoodsException(10, "分享不存在");
|
|
// 淘口令不存在
|
if (StringUtil.isNullOrEmpty(userShareGoodsHistory.getTkCode())) {
|
TBPid tbPid = tbPidService.getTBPid(uid, PidUser.TYPE_SHARE_GOODS);
|
if (tbPid == null)
|
throw new ShareGoodsException(1, "获取PID失败");
|
|
List<TaoBaoUnionConfig> config = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_SHARE_GOODS);
|
// 创建淘口令
|
TaoBaoLink tbLink = TaoBaoUtil.getTbLink(auctionId, tbPid.getPid(), config.get(0));
|
if (tbLink == null) {
|
TaoBaoGoodsBrief goods = null;
|
try {
|
goods = TaoKeApiUtil.searchGoodsDetail(auctionId);
|
} catch (TaobaoGoodsDownException e) {
|
throw new ShareGoodsException(4, "商品已下架");
|
}
|
tbLink = TaoBaoUtil.getTbLinkWithCoupon(goods.getPictUrl(), goods.getTitle(),
|
goods.getCouponActivityId(), auctionId, tbPid.getPid());
|
if (tbLink == null || StringUtil.isNullOrEmpty(tbLink.getTaoToken()))
|
throw new ShareGoodsException(2, "获取淘口令失败，请稍后重试");
|
}
|
// 更新淘口令
|
|
UserShareGoodsHistory history = new UserShareGoodsHistory();
|
history.setId(userShareGoodsHistory.getId());
|
history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));
|
history.setLink(tbLink.getClickUrl());
|
history.setQuanLink(tbLink.getCouponLink());
|
history.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));
|
userShareGoodsHistoryMapper.updateByPrimaryKeySelective(history);
|
|
userShareGoodsHistory.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));
|
userShareGoodsHistory.setLink(tbLink.getClickUrl());
|
userShareGoodsHistory.setQuanLink(tbLink.getCouponLink());
|
userShareGoodsHistory.setTkCode(TaoBaoUtil.filterTaoToken(tbLink.getTaoToken()));
|
}
|
|
return userShareGoodsHistory;
|
}
|
|
@Override
|
public String createTaoBaoToken(Long uid, TaoBaoGoodsBrief goods) {
|
String quanToken = "";
|
if (!StringUtil.isNullOrEmpty(goods.getCouponLink())) {// 通过立即推广方式获取淘口令成功
|
quanToken = convertLinkManager.createTaoBaoToken(uid, goods.getPictUrl(), goods.getTitle(),
|
goods.getCouponLink(), false);
|
} else if (!StringUtil.isNullOrEmpty(goods.getAuctionUrl())) {
|
quanToken = convertLinkManager.createTaoBaoToken(uid, goods.getPictUrl(), goods.getTitle(),
|
goods.getAuctionUrl(), false);
|
}
|
return quanToken;
|
}
|
|
@Override
|
public TaoBaoLink getTaoBaoLink(Long uid, String auctionId, String pid) throws ShareGoodsException {
|
|
if (uid == null || uid <= 0) {
|
throw new ShareGoodsException(1, "用户ID不能为空");
|
}
|
|
if (StringUtil.isNullOrEmpty(auctionId)) {
|
throw new ShareGoodsException(2, "商品ID不能为空");
|
}
|
|
if (StringUtil.isNullOrEmpty(pid)) {
|
throw new ShareGoodsException(3, "无推广位");
|
}
|
|
String appId = pid.split("_")[2];
|
String adzoneId = pid.split("_")[3];
|
TaoBaoUnionConfig taoBaoUnionConfig = taoBaoUnionConfigService.getConfigByAppIdCache(appId);
|
|
TaoKeAppInfo info = new TaoKeAppInfo();
|
info.setAdzoneId(adzoneId);
|
info.setAppKey(taoBaoUnionConfig.getAppKey());
|
info.setAppSecret(taoBaoUnionConfig.getAppSecret());
|
info.setPid(pid);
|
TaoBaoGoodsBrief goods = null;
|
try {
|
goods = TaoKeApiUtil.searchGoodsDetailForConvert(auctionId, info, null, null);
|
} catch (TaobaoGoodsDownException e) {
|
throw new ShareGoodsException(4, "商品已下架");
|
} finally {
|
|
}
|
if (goods == null) {
|
throw new ShareGoodsException(5, "获取商品详情失败");
|
}
|
|
if (StringUtil.isNullOrEmpty(goods.getCouponLink()) && !goods.getAuctionUrl().contains("s.click.taobao.com")) {
|
TaoBaoGoodsBrief taoBaoLink = TaoKeApiUtil.specialConvertCouponV2(auctionId, info, null, null);
|
if (taoBaoLink == null) {
|
throw new ShareGoodsException(201, "商品转链失败");
|
}
|
goods.setCouponLink(taoBaoLink.getCouponLink());
|
goods.setAuctionUrl(taoBaoLink.getAuctionUrl());
|
}
|
|
// 创建淘口令
|
TaoBaoLink tbLink = new TaoBaoLink();
|
tbLink.setAuctionId(goods.getAuctionId());
|
tbLink.setClickUrl(goods.getAuctionUrl());
|
tbLink.setCouponLink(goods.getCouponLink());
|
return tbLink;
|
}
|
|
@Override
|
public UserShareGoodsHistory getShareGoodsHistory(Long uid, String auctionId) {
|
return userShareGoodsHistoryMapper.selectByUidAndAuctionId(uid, auctionId);
|
}
|
|
@Override
|
public TaoBaoLink getTaoLiJinLinkForBuyWithOutFanLi(Long uid, String auctionId, TaoKeAppInfo app)
|
throws ShareGoodsException, TaoLiJinCreateException {
|
if (uid == null || uid <= 0) {
|
throw new ShareGoodsException(1, "用户ID不能为空");
|
}
|
|
if (StringUtil.isNullOrEmpty(auctionId)) {
|
throw new ShareGoodsException(2, "商品ID不能为空");
|
}
|
|
boolean canBuy = userTLJBuyHistoryService.canBuy(uid, auctionId);
|
if (!canBuy) {
|
throw new ShareGoodsException(3, "立减红包已抢光，请稍后再试");
|
}
|
|
SystemEnum system = userInfoService.getUserSystem(uid);
|
|
long currentTime = System.currentTimeMillis();
|
Date sendEndTime = new Date(TimeUtil.convertToTimeTemp(
|
TimeUtil.getGernalTime(currentTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));
|
TaoBaoGoodsBrief goods = null;
|
try {
|
goods = TaoKeApiUtil.searchGoodsDetail(auctionId);
|
} catch (TaobaoGoodsDownException e) {
|
throw new ShareGoodsException(4, "商品已下架");
|
}
|
|
BigDecimal perface = TaoBaoUtil.getGoodsHongBaoMoney(goods, new BigDecimal(70), false);
|
TaoLiJinDTO taoLiJinDTO = null;
|
try {
|
taoLiJinDTO = TaoKeApiUtil.createTaoLiJin(auctionId, "自购立减", perface, 1,
|
new Date(currentTime - 1000 * 60 * 10L), sendEndTime, new Date(currentTime - 1000 * 60 * 10L),
|
sendEndTime, app);
|
} catch (TaoLiJinCreateException e1) {
|
if (e1.getCode() == TaoLiJinCreateException.CODE_TLJ_NO_MONEY) {// 资金不足
|
TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppKeyCache(app.getAppKey());
|
businessEmergent110Service.tljNoMoney(config.getAccount(), system);
|
} else if (e1.getCode() == TaoLiJinCreateException.CODE_TLJ_FORBIDDEN) {// 商品不允许创建淘礼金
|
tljBuyGoodsService.removeGoods(auctionId);
|
}
|
LogHelper.errorDetailInfo(e1, e1.getMessage(), null);
|
} catch (TaoKeApiException e) {
|
LogHelper.errorDetailInfo(e, e.getMessage(), null);
|
throw new ShareGoodsException(5, "生成推广链接失败");
|
}
|
|
if (taoLiJinDTO == null)
|
throw new ShareGoodsException(5, "生成推广链接失败");
|
|
// 减去剩余个数(随机减去8到10个)
|
tljBuyGoodsService.subHongBaoLeftCount(auctionId, TimeUtil.getGernalTime(currentTime, "yyyy-MM-dd"),
|
8 + (int) (3 * Math.random()));
|
|
// 插入记录
|
try {
|
userTLJBuyHistoryService.addHistory(new UserTLJBuyHistory(null, uid, auctionId,
|
TimeUtil.getGernalTime(currentTime, "yyyy-MM-dd"), taoLiJinDTO.getRightsId(), new Date()));
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
TaoBaoLink taoBaoLink = new TaoBaoLink();
|
taoBaoLink.setAuctionId(auctionId);
|
taoBaoLink.setClickUrl(goods.getAuctionUrl());
|
taoBaoLink.setCouponLink(taoLiJinDTO.getSendUrl());
|
taoBaoLink.setGoods(goods);
|
return taoBaoLink;
|
}
|
}
|
