From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java | 29 +++++++++++++++++++----------
1 files changed, 19 insertions(+), 10 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java
index dee73b4..9581d0d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java
@@ -13,6 +13,8 @@
import com.yeshi.fanli.exception.taobao.TaoBaoConvertLinkException;
import com.yeshi.fanli.service.manger.PIDManager;
import com.yeshi.fanli.service.manger.goods.TaoBaoLinkManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -96,6 +98,8 @@
@Service
public class UserCloudServiceImpl implements UserCloudService {
+
+ Logger logger = LoggerFactory.getLogger(UserCloudService.class);
@Resource
private UserCloudMapper userCloudMapper;
@@ -661,7 +665,7 @@
@Override
@Transactional(rollbackFor = Exception.class)
- public void sendCustomGoods(Long uid, Long goodsId, Integer goodsType, Long sellerId) throws UserCloudException {
+ public void sendCustomGoods(Long uid, String goodsId, Integer goodsType, Long sellerId) throws UserCloudException {
sendCircleByGoods(uid, goodsId, goodsType, null, sellerId, UserCloudSendRecord.SEND_WAY_MANUAL);
}
@@ -696,7 +700,7 @@
}
}
- private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId, Long sellerId, int way)
+ private void sendCircleByGoods(Long uid, String goodsId, Integer goodsType, Long storeId, Long sellerId, int way)
throws UserCloudException {
long begainTime = java.lang.System.currentTimeMillis();
@@ -824,11 +828,11 @@
} else if (goodsType == Constant.SOURCE_TYPE_JD) {
sendJDGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
} else if (goodsType == Constant.SOURCE_TYPE_PDD) {
- sendPDDGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
+ sendPDDGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
} else if (goodsType == Constant.SOURCE_TYPE_VIP) {
- sendVIPGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
+ sendVIPGoods(user, robotId, wxId, Long.parseLong(goodsId), relationId, listOpen, result.getId());
} else if (goodsType == Constant.SOURCE_TYPE_SUNING) {
- sendSuNingGoods(user, robotId, wxId, goodsId, sellerId, relationId, listOpen, result.getId());
+ sendSuNingGoods(user, robotId, wxId, Long.parseLong(goodsId), sellerId, relationId, listOpen, result.getId());
}
// 鏇存柊鍙戝崟璁板綍
if (storeId != null) {
@@ -867,7 +871,7 @@
* @param listOpen
* @throws UserCloudException
*/
- private void sendTaoBaoGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
+ private void sendTaoBaoGoods(UserInfo user, int robotId, String wxId, String goodsId, String relationId,
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
TaoBaoLink taoBaoLink = null;
try {
@@ -924,7 +928,7 @@
* @param listOpen
* @throws UserCloudException
*/
- private void sendJDGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
+ private void sendJDGoods(UserInfo user, int robotId, String wxId, String goodsId, String relationId,
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
JDGoods jdGoods = jdGoodsCacheUtil.getGoodsInfo(goodsId);
if (jdGoods == null)
@@ -936,8 +940,13 @@
couponUrl = couponInfo.getLink();
}
String materialId = "https://item.jd.com/" + goodsId + ".html";
- String jumpLink = JDApiUtil.convertLinkWithSubUnionId(materialId, couponUrl, null, pidManager.getPidCache(user.getSystem(), Constant.SOURCE_TYPE_JD, SystemPIDInfo.PidType.share),
- user.getId() + "");
+ String jumpLink = null;
+ try {
+ jumpLink = JDApiUtil.convertLinkWithSubUnionId(materialId, couponUrl, null, pidManager.getPidCache(user.getSystem(), Constant.SOURCE_TYPE_JD, SystemPIDInfo.PidType.share),
+ user.getId() + "");
+ } catch (Exception e) {
+ logger.warn(String.format("浜笢杞摼鍑洪敊锛歮aterialId-%s couponUrl-%s", materialId, couponUrl), e);
+ }
boolean coupon = false;
if (couponInfo != null) {
@@ -990,7 +999,7 @@
* @param listOpen
* @throws UserCloudException
*/
- private void sendPDDGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
+ private void sendPDDGoods(UserInfo user, int robotId, String wxId, String goodsId, String relationId,
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
PDDGoodsDetail goods = pinDuoDuoCacheUtil.getGoodsInfo(goodsId);
if (goods == null)
--
Gitblit v1.8.0