From 651f2856e9ae10aacbfb8327d967aacbb6d58333 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 12 四月 2023 18:13:58 +0800
Subject: [PATCH] 大淘客API修复/唯品会订单爬取策略修改
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/PreviewInfoServiceImpl.java | 58 ++++++++++++++++++++++++++++++++++++++++++----------------
1 files changed, 42 insertions(+), 16 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/PreviewInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/PreviewInfoServiceImpl.java
index 3d914b5..3cc68f7 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/PreviewInfoServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/PreviewInfoServiceImpl.java
@@ -1,15 +1,19 @@
package com.yeshi.fanli.service.impl.user;
+import java.io.InputStream;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
+import java.util.UUID;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
+import org.yeshi.utils.entity.FileUploadResult;
+import org.yeshi.utils.tencentcloud.COSManager;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
@@ -23,9 +27,10 @@
import com.yeshi.fanli.service.inter.money.extract.BindingAccountService;
import com.yeshi.fanli.service.inter.user.PreviewInfoService;
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
+import com.yeshi.fanli.util.ImageUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
-import com.yeshi.fanli.util.TimeUtil;
+import org.yeshi.utils.TimeUtil;
import com.yeshi.fanli.vo.money.MoneyStatisticVO;
import com.yeshi.fanli.vo.user.MineInfoVO;
@@ -44,7 +49,6 @@
@Resource
private ThreeSaleDetailService threeSaleDetailService;
-
@Override
@@ -59,16 +63,16 @@
info.setUpdateTime(new Date());
previewInfoDao.save(info);
- if (type == PreviewEnum.extractRecord) {
+ if (type == PreviewEnum.extractRecord || type == PreviewEnum.moneyArrival) {
return;
}
+ // redis缂撳瓨
if (StringUtil.isNullOrEmpty(content)) {
removePreview(preUid, type);
} else {
adddPreview(preUid, type, content);
}
-
}
// 缂撳瓨10鍒嗛挓
@@ -115,9 +119,9 @@
if (StringUtil.isNullOrEmpty(time))
throw new PreviewInfoException(1, "鎻愮幇鏃堕棿涓嶈兘涓虹┖");
- Date parse = TimeUtil.parseDotCommon2(time);
- if (parse == null)
- throw new PreviewInfoException(1, "璇疯緭鍏ユ纭殑鏃堕棿鏍煎紡锛屽锛�2020.01.01 01:01");
+ Date receiveTime = TimeUtil.parseYYYYMMDD_HHMM(time);
+ if (receiveTime == null)
+ throw new PreviewInfoException(1, "璇疯緭鍏ユ纭殑鏃堕棿鏍煎紡");
Gson gson = new Gson();
@@ -127,7 +131,7 @@
extract.setName(alipay.getName());
extract.setAccount(alipay.getAccount());
extract.setMoney(money);
- extract.setReceiveTime(TimeUtil.parseDotCommon2(time));
+ extract.setReceiveTime(receiveTime);
extract.setId(java.lang.System.currentTimeMillis());
String id = StringUtil.Md5(uid + "#" + PreviewEnum.extractRecord.name());
@@ -242,22 +246,44 @@
@Override
- public String saveMoneyArrival(Long uid, BigDecimal money, String time,String orderNo) throws PreviewInfoException {
+ public String saveMoneyArrival(Long uid, BigDecimal money, String time,String orderNo, String platform)
+ throws PreviewInfoException,Exception {
if (uid == null )
throw new PreviewInfoException(1, "璇峰厛鐧诲綍");
if (money == null )
throw new PreviewInfoException(1, "璇疯緭鍏ラ噾棰�");
- if(StringUtil.isNullOrEmpty(time))
+ if(StringUtil.isNullOrEmpty(orderNo))
throw new PreviewInfoException(1, "璇疯緭鍏ヨ鍗曞彿");
if(StringUtil.isNullOrEmpty(time))
throw new PreviewInfoException(1, "璇疯緭鍏ュ垱寤烘椂闂�");
- Date parse = TimeUtil.parseDotCommon2(time);
- if (parse == null)
- throw new PreviewInfoException(1, "璇疯緭鍏ユ纭殑鏃堕棿鏍煎紡锛屽锛�2020.01.01 01:01");
+ Date date = TimeUtil.parseYYYYMMDD_HHMM(time);
+ if (date == null)
+ throw new PreviewInfoException(1, "璇疯緭鍏ユ纭殑鏃堕棿鏍煎紡");
+ InputStream drawStream = null;
+ if ("ios".equalsIgnoreCase(platform)) {
+ drawStream = ImageUtil.drawAlipayIOS(money, orderNo, time);
+ } else {
+ drawStream = ImageUtil.drawAlipayAndroid(money, orderNo, time);
+ }
- String content = ""; // TODO
- // save(uid, PreviewEnum.moneyArrival, gson.toJson(infoVO));
- return content;
+ if (drawStream == null)
+ throw new PreviewInfoException(1, "棰勮鐢熸垚澶辫触");
+
+ // 涓婁紶鏂囦欢
+ String uuid = UUID.randomUUID().toString().replace("-", "");
+ String upPath = "/user/img/preview/" + uuid + "_" + System.currentTimeMillis() + ".png";
+ FileUploadResult result = COSManager.getInstance().uploadInputStream(drawStream, upPath);
+ if (result == null) {
+ throw new PreviewInfoException(1, "棰勮鐢熸垚澶辫触");
+ }
+
+ // 淇濆瓨淇℃伅
+ save(uid, uid, PreviewEnum.moneyArrival, result.getUrl());
+
+ return result.getUrl();
}
}
+
+
+
--
Gitblit v1.8.0