package com.yeshi.fanli.service.manger;
|
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLDecoder;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.HttpUtil;
|
import org.yeshi.utils.NumberUtil;
|
|
import com.yeshi.fanli.dto.douyin.DouYinGoods;
|
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
|
import com.yeshi.fanli.entity.goods.CommonGoods;
|
import com.yeshi.fanli.entity.jd.JDGoods;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.exception.taobao.TaoBaoTokenParseException;
|
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
|
import com.yeshi.fanli.exception.user.TokenRecordException;
|
import com.yeshi.fanli.service.inter.user.TokenRecordService;
|
import com.yeshi.fanli.service.manger.goods.jd.JDGoodsLinkParseManager;
|
import com.yeshi.fanli.service.manger.goods.tb.TaoBaoTokenAuctionIdMapManager;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.DouYinUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TokenUtil;
|
import com.yeshi.fanli.util.Utils;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
|
import com.yeshi.fanli.util.jd.JDApiUtil;
|
import com.yeshi.fanli.util.jd.JDUtil;
|
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
|
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.vo.msg.TokenVO;
|
import com.yeshi.fanli.vo.search.GoodsDocParseResultVO;
|
|
import net.sf.json.JSONObject;
|
|
/**
|
* 粘贴板解析
|
*
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class ClipboardAnalysisManager {
|
|
@Resource
|
private JDGoodsLinkParseManager jdGoodsLinkParseManager;
|
|
@Resource
|
private TokenRecordService tokenRecordService;
|
|
@Resource
|
private TaoBaoTokenAuctionIdMapManager taoBaoTokenAuctionIdMapManager;
|
|
@Resource
|
private RedisManager redisManager;
|
|
/**
|
* @Title: parseContentType @Description: 解析文本的类型 @param text @return Set
|
* <ClipboardContentType> 返回类型 @throws
|
*/
|
public static Set<ClipboardContentType> parseContentType(String originText, String platform, String version) {
|
Set<ClipboardContentType> typeSet = new HashSet<>();
|
StringBuffer textBuffer = new StringBuffer(originText);
|
String text = textBuffer.toString();
|
// 自有口令
|
String parseToken = TokenUtil.parseToken(text);
|
if (!StringUtil.isNullOrEmpty(parseToken)) {
|
typeSet.add(ClipboardContentType.systemToken);
|
text = text.replace(parseToken, "");
|
}
|
|
// 链接
|
String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?";
|
Pattern p = Pattern.compile(URL_REGEX);
|
Matcher matcher = p.matcher(text);
|
while (matcher.find()) {
|
String url = matcher.group();
|
if (!StringUtil.isNullOrEmpty(url)) {
|
typeSet.add(ClipboardContentType.link);
|
text = text.replace(url, "");
|
}
|
}
|
|
// 淘口令
|
List<String> taoBaoTokenList = null;
|
if (VersionUtil.greaterThan_2_0_7(platform, version))
|
taoBaoTokenList = TaoBaoUtil.getTokenListFromTextWithKuoHao(text);
|
else
|
taoBaoTokenList = TaoBaoUtil.getTokenListFromText(text);
|
if (taoBaoTokenList != null && taoBaoTokenList.size() > 0) {
|
typeSet.add(ClipboardContentType.taoBaoToken);
|
for (String token : taoBaoTokenList) {
|
text = text.replace(token, "");
|
}
|
}
|
// 文本
|
if (text != null && text.trim().length() > 0) {
|
typeSet.add(ClipboardContentType.text);
|
}
|
|
return typeSet;
|
}
|
|
/**
|
*
|
* @Title: parse @Description: 解析 @param text @param typeSet void
|
* 返回类型 @throws
|
*/
|
public void parse(String platform, String version, String text, Long uid, IClipboardAnalysisResult resultListener) {
|
if (text == null)
|
return;
|
text = text.trim();
|
|
Set<ClipboardContentType> typeSet = parseContentType(text, platform, version);
|
|
// 系统口令
|
if (typeSet.contains(ClipboardContentType.systemToken)) {
|
try {
|
TokenVO tokenVO = tokenRecordService.discernToken(text, uid, platform, version);
|
resultListener.onResult(tokenVO);
|
} catch (TokenRecordException e) {
|
if (e.getCode() == 1001) { // 需要用户登录
|
resultListener.needLogin(e.getMsg());
|
} else {
|
resultListener.none();
|
}
|
}
|
return;
|
}
|
|
// 只有链接 淘宝链接/京东链接/拼多多链接
|
if (typeSet.size() == 1) {
|
if (typeSet.contains(ClipboardContentType.link)) {// 纯链接
|
// 解析商品
|
CommonGoods goods = parseLink(text);
|
if (goods == null) {
|
// 判断链接之中是否包含口令
|
try {
|
String newText = URLDecoder.decode(text, "UTF-8");
|
List<String> tokenList = TaoBaoUtil.getTokenListFromTextWithKuoHao(newText);
|
if (tokenList != null && tokenList.size() > 0) {
|
try {
|
goods = parseTaoBaoToken(tokenList.get(0));
|
} catch (TaoBaoTokenParseException e) {
|
}
|
if (goods != null && goods.getGoodsId() != null) {
|
resultListener.onResult(goods);
|
return;
|
}
|
}
|
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
resultListener.none();
|
} else {
|
resultListener.onResult(goods);
|
}
|
|
} else if (typeSet.contains(ClipboardContentType.taoBaoToken)) {// 纯淘口令
|
|
try {
|
CommonGoods commonGoods = parseTaoBaoToken(text);
|
if (commonGoods != null)
|
resultListener.onResult(commonGoods);
|
else
|
resultListener.onResult(text);
|
|
} catch (TaoBaoTokenParseException e1) {
|
resultListener.onResult(text);
|
}
|
|
} else {// 纯文本
|
// 文本推荐
|
if (text.length() > 256)
|
resultListener.none();
|
else
|
resultListener.onResult(text);
|
}
|
} else if (typeSet.size() == 2) {
|
List<String> urlList = HttpUtil.getUrlListFromText(text);
|
List<String> tokenList = null;
|
if (VersionUtil.greaterThan_2_0_7(platform, version))
|
tokenList = TaoBaoUtil.getTokenListFromTextWithKuoHao(text);
|
else
|
tokenList = TaoBaoUtil.getTokenListFromText(text);
|
|
String link = null;
|
String token = null;
|
|
if (typeSet.contains(ClipboardContentType.link) && typeSet.contains(ClipboardContentType.taoBaoToken)) {// 链接+口令
|
if (text.indexOf(urlList.get(0)) < text.indexOf(tokenList.get(0)))// 第一个链接在第一个口令前面
|
link = urlList.get(0);
|
else// 第一个口令在第一个链接前面
|
token = tokenList.get(0);
|
|
} else if (typeSet.contains(ClipboardContentType.link) && typeSet.contains(ClipboardContentType.text)) {// 链接+文本
|
link = urlList.get(0);
|
|
} else {// 口令+文本
|
token = tokenList.get(0);
|
}
|
|
if (!StringUtil.isNullOrEmpty(link)) {
|
CommonGoods goods = parseLink(urlList.get(0));
|
if (goods == null || goods.getGoodsId() == null) {
|
if (urlList.size() > 1)
|
resultListener.onResult(new GoodsDocParseResultVO(text, urlList.get(0)));
|
else {// 单链接
|
// 判断是否包含可转链的链接
|
if (!isContainsLinkConvert(link))
|
resultListener.none();
|
else
|
resultListener.onResult(new GoodsDocParseResultVO(text, link));
|
}
|
} else {
|
if (VersionUtil.greaterThan_2_0_7(platform, version)) {
|
if (urlList.size() == 1)// 单链接+文本
|
resultListener.onResult(goods);
|
else
|
resultListener.onResult(new GoodsDocParseResultVO(text, goods));
|
} else {
|
resultListener.onResult(goods);
|
}
|
}
|
} else {
|
CommonGoods goods = null;
|
try {
|
goods = parseTaoBaoToken(token);
|
} catch (TaoBaoTokenParseException e) {
|
resultListener.onResult(new GoodsDocParseResultVO(text));
|
return;
|
}
|
if (goods != null && goods.getGoodsId() != null) {
|
if (tokenList.size() == 1) {// 单个口令
|
resultListener.onResult(goods);
|
} else
|
resultListener.onResult(new GoodsDocParseResultVO(text, goods));
|
} else {
|
resultListener.onResult(new GoodsDocParseResultVO(text));
|
}
|
}
|
|
} else if (typeSet.size() == 3) {// 口令+链接+文本
|
// 淘口令
|
List<String> tokenList = null;
|
if (VersionUtil.greaterThan_2_0_7(platform, version))
|
tokenList = TaoBaoUtil.getTokenListFromTextWithKuoHao(text);
|
else
|
tokenList = TaoBaoUtil.getTokenListFromText(text);
|
|
List<String> urlList = HttpUtil.getUrlListFromText(text);
|
if (text.contains("【") && tokenList != null && tokenList.size() == 1 && urlList != null
|
&& urlList.size() == 1) {// Android淘宝链接复制
|
CommonGoods goods = null;
|
try {
|
goods = parseTaoBaoToken(tokenList.get(0));
|
} catch (TaoBaoTokenParseException e1) {
|
e1.printStackTrace();
|
}
|
if (goods == null) {
|
if (text.trim().indexOf("【") > -1 && text.trim().indexOf("】") > 0) {
|
// 截取标题
|
String title = text.trim().substring(text.trim().indexOf("【") + 1,
|
text.trim().lastIndexOf("】"));
|
goods = new CommonGoods();
|
goods.setTitle(title);
|
goods.setPicture("http://");
|
}
|
}
|
|
if (goods != null) {
|
resultListener.onResult(goods);
|
}
|
|
} else {// 文案
|
|
String token = null;
|
token = tokenList.get(0);
|
|
if (!StringUtil.isNullOrEmpty(token)) {
|
CommonGoods goods = null;
|
try {
|
goods = parseTaoBaoToken(token);
|
if (goods != null && goods.getGoodsId() != null) {
|
// 如:http://rd.wechat.com/qrcode/confirm?block_type=101&content=%E3%80%90%E5%8E%9F%E4%BB%B7%E3%80%9120%E5%85%83%0A%E3%80%90%E5%88%B8%E5%90%8E%E4%BB%B7%E3%80%9120%E5%85%83%0A-----------------%0A%E5%BE%A9%E8%A3%BD%E8%BF%99%E6%9D%A1%EF%BC%8C(psNX1UPRJNe)%EF%BC%8C%E8%BF%9B%E5%85%A5%E3%80%90Tao%E5%AE%9D%E3%80%91%E5%8D%B3%E5%8F%AF%E6%8A%A2%E8%B4%AD&lang=zh_CN&scene=37
|
if (text.contains("//rd.wechat.com/qrcode/")) {// 微信复制过来的
|
resultListener.onResult(goods);
|
} else
|
resultListener.onResult(new GoodsDocParseResultVO(text, goods));
|
} else {
|
resultListener.onResult(new GoodsDocParseResultVO(text));
|
}
|
} catch (TaoBaoTokenParseException e) {
|
resultListener.onResult(new GoodsDocParseResultVO(text));
|
}
|
} else {
|
CommonGoods goods = parseLink(urlList.get(0));
|
if (goods == null || goods.getGoodsId() == null) {
|
resultListener.onResult(new GoodsDocParseResultVO(text, urlList.get(0)));
|
} else {
|
resultListener.onResult(new GoodsDocParseResultVO(text, goods));
|
}
|
}
|
}
|
return;
|
}
|
}
|
|
/**
|
*
|
* @Title: parseLink @Description: 解析单链接 @param link @return CommonGoods
|
* 返回类型 @throws
|
*/
|
public CommonGoods parseLink(String link) {
|
|
SimpleCommonGoods simpleGoods = parseGoodsIdFromLink(link);
|
if (simpleGoods == null) {
|
return null;
|
}
|
|
CommonGoods commonGoods = null;
|
if (simpleGoods.getGoodsType() == Constant.SOURCE_TYPE_TAOBAO) {
|
TaoBaoGoodsBrief goods = null;
|
try {
|
goods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(simpleGoods.getGoodsId()));
|
} catch (NumberFormatException e) {
|
e.printStackTrace();
|
} catch (TaobaoGoodsDownException e) {
|
e.printStackTrace();
|
}
|
|
if (goods != null) {
|
commonGoods = CommonGoodsFactory.create(goods);
|
} else {
|
goods = TaoBaoUtil.getTmallGoodsInfo(simpleGoods.getGoodsId());
|
if (goods != null) {
|
commonGoods = new CommonGoods();
|
commonGoods.setTitle(goods.getTitle());
|
commonGoods.setPicture(goods.getPictUrl());
|
} else {
|
// TODO 根据淘宝商品ID解析标题与图片
|
}
|
}
|
|
} else if (simpleGoods.getGoodsType() == Constant.SOURCE_TYPE_JD) {
|
// 优先采用高级接口请求数据
|
JDGoods jdGoods = null;
|
try {
|
// 防止高级接口被收回
|
jdGoods = JDApiUtil.queryGoodsDetail(Long.parseLong(simpleGoods.getGoodsId()));
|
} catch (Exception e) {
|
}
|
if (jdGoods == null) {
|
jdGoods = JDApiUtil.getGoodsDetail(Long.parseLong(simpleGoods.getGoodsId()));
|
}
|
if (jdGoods != null) {
|
commonGoods = CommonGoodsFactory.create(jdGoods);
|
} else {// 商品并未参与推广
|
jdGoods = JDUtil.getSimpleGoodsInfo(simpleGoods.getGoodsId());
|
if (jdGoods != null) {
|
commonGoods = new CommonGoods();
|
commonGoods.setTitle(jdGoods.getSkuName());
|
commonGoods.setPicture(jdGoods.getPicUrl());
|
}
|
}
|
} else if (simpleGoods.getGoodsType() == Constant.SOURCE_TYPE_PDD) {
|
PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(Long.parseLong(simpleGoods.getGoodsId()));
|
if (goods != null) {
|
commonGoods = CommonGoodsFactory.create(goods);
|
} else {
|
goods = PinDuoDuoUtil.getPDDGoodsInfo(simpleGoods.getGoodsId());
|
if (goods != null) {
|
commonGoods = new CommonGoods();
|
commonGoods.setTitle(goods.getGoodsName());
|
commonGoods.setPicture(goods.getGoodsThumbnailUrl());
|
}
|
}
|
}
|
|
return commonGoods;
|
}
|
|
/**
|
* 从链接中解析商品ID
|
*
|
* @return
|
*/
|
public SimpleCommonGoods parseGoodsIdFromLink(String link) {
|
|
String jdId = parseJDSkuIdFromLink(link);
|
|
if (!StringUtil.isNullOrEmpty(jdId)) {
|
return new SimpleCommonGoods(jdId, Constant.SOURCE_TYPE_JD);
|
}
|
|
// 解析拼多多
|
String pddId = PinDuoDuoUtil.getPDDGoodsId(link);
|
if (!StringUtil.isNullOrEmpty(pddId)) {
|
return new SimpleCommonGoods(pddId, Constant.SOURCE_TYPE_PDD);
|
}
|
// 解析淘宝
|
String auctionId = parseTBAuctionIdFromLink(link);
|
if (!StringUtil.isNullOrEmpty(auctionId)) {
|
return new SimpleCommonGoods(auctionId, Constant.SOURCE_TYPE_TAOBAO);
|
}
|
|
return null;
|
}
|
|
/**
|
* 从链接中解析京东商品的SKUID
|
*
|
* @param link
|
* @return
|
*/
|
public String parseJDSkuIdFromLink(String link) {
|
// 解析其他商品
|
String jdId = JDUtil.getJDGoodsId(link);
|
|
// 微信链接
|
if (StringUtil.isNullOrEmpty(jdId)) {
|
jdId = JDUtil.getJDGoodsIdByWeiXin(link);
|
}
|
|
// 领券短连接
|
if (StringUtil.isNullOrEmpty(jdId) && link.contains("u.jd.com")) {
|
jdId = jdGoodsLinkParseManager.parseGoodsIdByJDShortUrl(link);
|
}
|
|
return jdId;
|
}
|
|
public String parseTBAuctionIdFromLink(String link) {
|
TaoBaoGoodsBrief tb = null;
|
String auctionId = null;
|
if (link.startsWith("https://a.m.taobao.com/i"))// 淘宝账号未登录状态
|
{
|
link = link.substring("https://a.m.taobao.com/i".length(), link.indexOf(".htm"));
|
if (NumberUtil.isNumeric(link)) {
|
auctionId = link + "";
|
}
|
} else if (link.contains("ju.taobao.com") || link.contains(".juhuasuan.com")) {// 聚划算
|
int index = link.indexOf("item_id");
|
if (index >= 0) {
|
link = link.substring(index);
|
int last = link.indexOf("&");
|
String id = "";
|
if (last > 0)
|
id = link.substring(link.indexOf("=") + 1, link.indexOf("&"));
|
else {
|
id = link.substring(link.indexOf("=" + 1));
|
}
|
auctionId = id;
|
}
|
} else if (link.contains("http://zmnxbc.com")) { // 手机端天猫APP分享
|
tb = TaoBaoUtil.parsePhoneShareUrlByTM(link);
|
if (tb != null)
|
auctionId = tb.getAuctionId() + "";
|
} else if (link.contains("h5.m.taobao") || link.contains("detail.m.tmall") || link.contains("item.taobao")
|
|| link.contains("detail.tmall")) { // 手机页面和电脑页面
|
Map<String, String> map = Utils.parseURL(link);
|
String id = "";
|
id = map.get("id").replace("}", "");
|
auctionId = id;
|
} else if (link.contains("v.douyin.com")) { // 抖音
|
tb = analysisDouYin(link);
|
if (tb != null) {
|
if (!StringUtil.isNullOrEmpty(tb.getAuctionUrl())) {// 抖音解析到淘宝商品链接
|
CommonGoods goods = parseLink(tb.getAuctionUrl());
|
if (goods != null) {
|
auctionId = goods.getGoodsId() + "";
|
}
|
}
|
}
|
} else {
|
tb = TaoBaoUtil.parsePhoneShareUrlByTB(link);
|
if (tb != null)
|
auctionId = tb.getAuctionId() + "";
|
}
|
|
return auctionId;
|
|
}
|
|
private CommonGoods parseTaoBaoToken(String token) throws TaoBaoTokenParseException {
|
Long auctionId = taoBaoTokenAuctionIdMapManager.getAuctionIdByToken(token);
|
if (auctionId != null) {//
|
TaoBaoGoodsBrief goods = TaoBaoUtil.isAlimama(auctionId + "");
|
if (goods == null) {
|
goods = TaoBaoUtil.getTaoBaoGoodsBriefNotInPub(auctionId);
|
}
|
if (goods != null) {
|
CommonGoods commonGoods = CommonGoodsFactory.create(goods);
|
return commonGoods;
|
} else
|
return null;
|
} else {
|
return null;
|
}
|
}
|
|
/**
|
*
|
* @Title: analysisDouYin @Description: 抖音解析 @param link @return CommonGoods
|
* 返回类型 @throws
|
*/
|
private TaoBaoGoodsBrief analysisDouYin(String link) {
|
String location = HttpUtil.getLocation(link);
|
if (!StringUtil.isNullOrEmpty(location)) {
|
if (location.contains("taobao.com")) { // 淘宝商品
|
String realUrl = TaoBaoUtil.getRealUrl(location);
|
if (!StringUtil.isNullOrEmpty(realUrl)) {
|
TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
|
goods.setAuctionUrl(realUrl);
|
return goods;
|
}
|
} else if (location.contains("haohuo.jinritemai.com")) { // 抖音商品
|
DouYinGoods goods = DouYinUtil.getGoodsInfo(location);
|
JSONObject goodsJSON = new JSONObject();
|
goodsJSON.put("title", goods.getName());
|
goodsJSON.put("pictUrl", goods.getImg());
|
|
TaoBaoGoodsBrief commonGoods = new TaoBaoGoodsBrief();
|
commonGoods.setPictUrl(goods.getImg());
|
commonGoods.setTitle(goods.getName());
|
return commonGoods;
|
}
|
}
|
return null;
|
}
|
|
private boolean isContainsLinkConvert(String link) {
|
if (link.contains(".jd.com"))
|
return true;
|
else if (link.contains(".taobao.com") || link.contains(".tmall"))
|
return true;
|
else if (link.contains(".pinduoduo.com") || link.contains(".yangkeduo.com"))
|
return true;
|
return false;
|
}
|
|
class SimpleCommonGoods {
|
private String goodsId;
|
private int goodsType;
|
|
public SimpleCommonGoods(String goodsId, int goodsType) {
|
this.goodsId = goodsId;
|
this.goodsType = goodsType;
|
}
|
|
public String getGoodsId() {
|
return goodsId;
|
}
|
|
public void setGoodsId(String goodsId) {
|
this.goodsId = goodsId;
|
}
|
|
public int getGoodsType() {
|
return goodsType;
|
}
|
|
public void setGoodsType(int goodsType) {
|
this.goodsType = goodsType;
|
}
|
}
|
}
|
|
/**
|
* 粘贴板解析结果
|
*
|
* @author Administrator
|
*
|
*/
|
