|
@@ -445,14 +445,20 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
|
|
String url = "https://openapi.kwaixiaodian.com";
|
|
String url = "https://openapi.kwaixiaodian.com";
|
|
Long beginTime = DateUtils.getStartLongTime(beginDate);
|
|
Long beginTime = DateUtils.getStartLongTime(beginDate);
|
|
Long endTime = DateUtils.getEndLongTime(endDate);
|
|
Long endTime = DateUtils.getEndLongTime(endDate);
|
|
- Map<Long, Long> itemMap = getItemMap();
|
|
|
|
|
|
+// Map<Long, Long> itemMap = getItemMap();
|
|
List<KuaishouAccessToken> tokens = accessTokenService.getTokenInfos();
|
|
List<KuaishouAccessToken> tokens = accessTokenService.getTokenInfos();
|
|
for (KuaishouAccessToken accessToken : tokens) {
|
|
for (KuaishouAccessToken accessToken : tokens) {
|
|
- getInfo(accessToken, beginTime, endTime, url, pcursor, itemMap, 1);
|
|
|
|
|
|
+ getInfo(accessToken, beginTime, endTime, url, pcursor, 1);
|
|
}
|
|
}
|
|
|
|
+ Thread.sleep(600000);
|
|
|
|
+ List<KuaishouAccessToken> mgsTokens = accessTokenService.getMgsTokenInfos();
|
|
|
|
+ for (KuaishouAccessToken accessToken : mgsTokens) {
|
|
|
|
+ getMgsInfo(accessToken, beginTime, endTime, url, pcursor, 1);
|
|
|
|
+ }
|
|
|
|
+
|
|
}
|
|
}
|
|
|
|
|
|
- private void getInfo(KuaishouAccessToken accessToken, Long beginTime, Long endTime, String url, String pcursor, Map<Long, Long> itemMap, Integer counts) throws InterruptedException {
|
|
|
|
|
|
+ private void getInfo(KuaishouAccessToken accessToken, Long beginTime, Long endTime, String url, String pcursor, Integer counts) throws InterruptedException {
|
|
List<Long> list = new ArrayList<>();
|
|
List<Long> list = new ArrayList<>();
|
|
String appKey = accessToken.getAppKey();
|
|
String appKey = accessToken.getAppKey();
|
|
String signSecret = accessToken.getSignSecret();
|
|
String signSecret = accessToken.getSignSecret();
|
|
@@ -500,7 +506,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
|
|
log.error("===查询分销团长订单列表(open.distribution.cps.leader.order.cursor.list)失败,信息:{}", obj.getString("msg"));
|
|
log.error("===查询分销团长订单列表(open.distribution.cps.leader.order.cursor.list)失败,信息:{}", obj.getString("msg"));
|
|
log.error("游标:{},执行次数:{}", pcursor, counts);
|
|
log.error("游标:{},执行次数:{}", pcursor, counts);
|
|
if (counts <= 3) {
|
|
if (counts <= 3) {
|
|
- getInfo(accessToken, beginTime, endTime, url, pcursor, itemMap, counts + 1);
|
|
|
|
|
|
+ getInfo(accessToken, beginTime, endTime, url, pcursor, counts + 1);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (Check.isNotNull(list) && list.size() > 0) {
|
|
if (Check.isNotNull(list) && list.size() > 0) {
|
|
@@ -508,7 +514,67 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
|
|
Thread.sleep(200);
|
|
Thread.sleep(200);
|
|
}
|
|
}
|
|
if (!"nomore".equals(pcursor)) {
|
|
if (!"nomore".equals(pcursor)) {
|
|
- getInfo(accessToken, beginTime, endTime, url, pcursor, itemMap, 1);
|
|
|
|
|
|
+ getInfo(accessToken, beginTime, endTime, url, pcursor, 1);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void getMgsInfo(KuaishouAccessToken accessToken, Long beginTime, Long endTime, String url, String pcursor, Integer counts) throws InterruptedException {
|
|
|
|
+ List<Long> list = new ArrayList<>();
|
|
|
|
+ String appKey = accessToken.getAppKey();
|
|
|
|
+ String signSecret = accessToken.getSignSecret();
|
|
|
|
+ if (Check.isNull(signSecret) || Check.isNull(appKey)) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ AccessTokenKsMerchantClient client = new AccessTokenKsMerchantClient(url, appKey, signSecret);
|
|
|
|
+ OpenDistributionCpsLeaderOrderCursorListRequest request = new OpenDistributionCpsLeaderOrderCursorListRequest();
|
|
|
|
+ request.setAccessToken(accessToken.getAccessToken());
|
|
|
|
+ request.setApiMethodVersion(1L);
|
|
|
|
+
|
|
|
|
+ //排序类型 [1:按指定查询类型降序] [2:按指定查询类型升序]
|
|
|
|
+ request.setSortType(1);
|
|
|
|
+ //查询类型 [1:按分销订单创建时间查询] [2:按分销订单更新时间查询][4:按订单实际创建时间查询]
|
|
|
|
+ request.setQueryType(2);
|
|
|
|
+ //分销订单状态 [0:全部订单] [30:已付款] [50:已收货] [60:已结算] [80:已失效]
|
|
|
|
+ request.setCpsOrderStatus(0);
|
|
|
|
+ request.setDistributorId(0l);
|
|
|
|
+ request.setBeginTime(beginTime);
|
|
|
|
+ request.setEndTime(endTime);
|
|
|
|
+ request.setPcursor(pcursor);
|
|
|
|
+ request.setPageize(100);
|
|
|
|
+ request.setFundType(1);
|
|
|
|
+
|
|
|
|
+ OpenDistributionCpsLeaderOrderCursorListResponse response = null;
|
|
|
|
+ try {
|
|
|
|
+ response = client.execute(request);
|
|
|
|
+ } catch (KsMerchantApiException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ JSONObject obj = JSONObject.parseObject(GsonUtils.toJSON(response));
|
|
|
|
+ String code = obj.getString("code");
|
|
|
|
+ if ("1".equals(code)) {
|
|
|
|
+ JSONObject data = obj.getJSONObject("data");
|
|
|
|
+ pcursor = data.getString("pcursor");
|
|
|
|
+ JSONArray orderView = data.getJSONArray("orderView");
|
|
|
|
+ for (int i = 0; i < orderView.size(); i++) {
|
|
|
|
+ JSONObject info = orderView.getJSONObject(i);
|
|
|
|
+ Integer sendStatus = info.getInteger("sendStatus");
|
|
|
|
+ if (Check.isNotNull(sendStatus) && sendStatus == 1) {
|
|
|
|
+ list.add(info.getLong("oid"));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ log.error("===查询分销团长订单列表(open.distribution.cps.leader.order.cursor.list)失败,信息:{}", obj.getString("error_msg"));
|
|
|
|
+ log.error("游标:{},执行次数:{}", pcursor, counts);
|
|
|
|
+ if (counts <= 3) {
|
|
|
|
+ getMgsInfo(accessToken, beginTime, endTime, url, pcursor, counts + 1);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (Check.isNotNull(list) && list.size() > 0) {
|
|
|
|
+ supplyChainMapper.updateMgsKuaishouSupplyChain(list);
|
|
|
|
+ Thread.sleep(200);
|
|
|
|
+ }
|
|
|
|
+ if (!"nomore".equals(pcursor)) {
|
|
|
|
+ getMgsInfo(accessToken, beginTime, endTime, url, pcursor, 1);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -567,12 +633,18 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
|
|
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void addListKuaishouActivityInfo() {
|
|
|
|
|
|
+ public void addListKuaishouActivityInfo() throws InterruptedException {
|
|
String url = "https://openapi.kwaixiaodian.com";
|
|
String url = "https://openapi.kwaixiaodian.com";
|
|
List<KuaishouAccessToken> tokens = accessTokenService.getTokenInfos();
|
|
List<KuaishouAccessToken> tokens = accessTokenService.getTokenInfos();
|
|
for (KuaishouAccessToken accessToken : tokens) {
|
|
for (KuaishouAccessToken accessToken : tokens) {
|
|
getInfoKuaishouActivityInfo(accessToken, url);
|
|
getInfoKuaishouActivityInfo(accessToken, url);
|
|
}
|
|
}
|
|
|
|
+ Thread.sleep(600000);
|
|
|
|
+ List<KuaishouAccessToken> mgsTokens = accessTokenService.getMgsTokenInfos();
|
|
|
|
+ for (KuaishouAccessToken mgsToken : mgsTokens) {
|
|
|
|
+ getMgsInfoKuaishouActivityInfo(mgsToken, url);
|
|
|
|
+ }
|
|
|
|
+
|
|
}
|
|
}
|
|
|
|
|
|
private void getInfoKuaishouActivityInfo(KuaishouAccessToken accessToken, String url) {
|
|
private void getInfoKuaishouActivityInfo(KuaishouAccessToken accessToken, String url) {
|
|
@@ -634,5 +706,46 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
|
|
return activityInfo;
|
|
return activityInfo;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+
|
|
|
|
+ private void getMgsInfoKuaishouActivityInfo(KuaishouAccessToken accessToken, String url) {
|
|
|
|
+ List<KuaiShouActivityInfo> list = new ArrayList<>();
|
|
|
|
+ String appKey = accessToken.getAppKey();
|
|
|
|
+ String signSecret = accessToken.getSignSecret();
|
|
|
|
+ if (Check.isNull(signSecret) || Check.isNull(appKey)) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ AccessTokenKsMerchantClient client = new AccessTokenKsMerchantClient(url, appKey, signSecret);
|
|
|
|
+ OpenDistributionInvestmentActivityOpenListRequest request = new OpenDistributionInvestmentActivityOpenListRequest();
|
|
|
|
+
|
|
|
|
+ request.setAccessToken(accessToken.getAccessToken());
|
|
|
|
+ request.setApiMethodVersion(1L);
|
|
|
|
+
|
|
|
|
+ //每页活动数量
|
|
|
|
+ request.setLimit(5000);
|
|
|
|
+ OpenDistributionInvestmentActivityOpenListResponse response = null;
|
|
|
|
+ try {
|
|
|
|
+ response = client.execute(request);
|
|
|
|
+ } catch (KsMerchantApiException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ JSONObject obj = JSONObject.parseObject(GsonUtils.toJSON(response));
|
|
|
|
+ String code = obj.getString("code");
|
|
|
|
+ if ("1".equals(code)) {
|
|
|
|
+ JSONObject data = obj.getJSONObject("data");
|
|
|
|
+ JSONArray result = data.getJSONArray("result");
|
|
|
|
+ for (int i = 0; i < result.size(); i++) {
|
|
|
|
+ JSONObject info = result.getJSONObject(i);
|
|
|
|
+ KuaiShouActivityInfo activityInfo = organizeKuaishouActivityInfo(info);
|
|
|
|
+ list.add(activityInfo);
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ log.error("===团长查询招商活动列表(open.distribution.investment.activity.open.list)失败,信息:{}" + obj.getString("msg"));
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if (Check.isNotNull(list) && list.size() > 0) {
|
|
|
|
+ supplyChainMapper.replaceMgsKuaishouActivityInfo(list);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|