CC/Jarvis_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
cc
2024-12-06 11:48:50 +08:00
parent 6ecd8963b7
commit c9c8b9850b
1 changed files with 45 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

94
src/main/java/cn/van/business/util/JDUtils.java
View File

@@ -8,15 +8,11 @@ import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.util.DateUtils; import com.alibaba.fastjson2.util.DateUtils;
import com.jd.open.api.sdk.DefaultJdClient; import com.jd.open.api.sdk.DefaultJdClient;
import com.jd.open.api.sdk.JdClient; import com.jd.open.api.sdk.JdClient;
import com.jd.open.api.sdk.domain.kplunion.GoodsService.request.query.BigFieldGoodsReq;
import com.jd.open.api.sdk.domain.kplunion.OrderService.request.query.OrderRowReq; import com.jd.open.api.sdk.domain.kplunion.OrderService.request.query.OrderRowReq;
import com.jd.open.api.sdk.domain.kplunion.OrderService.response.query.GoodsInfo; import com.jd.open.api.sdk.domain.kplunion.OrderService.response.query.GoodsInfo;
import com.jd.open.api.sdk.domain.kplunion.OrderService.response.query.OrderRowResp; import com.jd.open.api.sdk.domain.kplunion.OrderService.response.query.OrderRowResp;
import com.jd.open.api.sdk.domain.kplunion.promotioncommon.PromotionService.request.get.PromotionCodeReq;
import com.jd.open.api.sdk.request.kplunion.UnionOpenGoodsBigfieldQueryRequest;
import com.jd.open.api.sdk.request.kplunion.UnionOpenOrderRowQueryRequest; import com.jd.open.api.sdk.request.kplunion.UnionOpenOrderRowQueryRequest;
import com.jd.open.api.sdk.request.kplunion.UnionOpenPromotionCommonGetRequest; import com.jd.open.api.sdk.request.kplunion.UnionOpenPromotionBysubunionidGetRequest;
import com.jd.open.api.sdk.response.kplunion.UnionOpenGoodsBigfieldQueryResponse;
import com.jd.open.api.sdk.response.kplunion.UnionOpenOrderRowQueryResponse; import com.jd.open.api.sdk.response.kplunion.UnionOpenOrderRowQueryResponse;
import com.jd.open.api.sdk.response.kplunion.UnionOpenPromotionCommonGetResponse; import com.jd.open.api.sdk.response.kplunion.UnionOpenPromotionCommonGetResponse;
import org.slf4j.Logger; import org.slf4j.Logger;
@@ -50,14 +46,14 @@ import java.util.stream.Stream;
public class JDUtils { public class JDUtils {
private static final String SERVER_URL = "https://api.jd.com/routerjson"; private static final String SERVER_URL = "https://api.jd.com/routerjson";
// van论坛 // van论坛
private static final String APP_KEY = "98e21c89ae5610240ec3f5f575f86a59"; private static final String APP_KEY_WZ = "98e21c89ae5610240ec3f5f575f86a59";
private static final String SECRET_KEY = "3dcb6b23a1104639ac433fd07adb6dfb"; private static final String SECRET_KEY_WZ = "3dcb6b23a1104639ac433fd07adb6dfb";
// 标记是否拉取过小时的订单，空订单会set 一个 tag，避免重复拉取 // 标记是否拉取过小时的订单，空订单会set 一个 tag，避免重复拉取
private static final String JD_REFRESH_TAG = "jd:refresh:tag:"; private static final String JD_REFRESH_TAG = "jd:refresh:tag:";
// 导购的 // 导购的
//private static final String APP_KEY = "faf410cb9587dc80dc7b31e321d7d322"; private static final String APP_KEY_DG = "faf410cb9587dc80dc7b31e321d7d322";
//private static final String SECRET_KEY = private static final String SECRET_KEY_DG =
// "a4fb15d7bedd4316b97b4e96e4effc1c"; "a4fb15d7bedd4316b97b4e96e4effc1c";
//accessToken //accessToken
private static final String ACCESS_TOKEN = ""; private static final String ACCESS_TOKEN = "";
@@ -392,7 +388,7 @@ public class JDUtils {
} }
// 打印方法调用和开始结束时间 // 打印方法调用和开始结束时间
logger.info("拉取订单---> ,类型 {} , 开始时间：{} --- 结束时间：{}", hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER)); //logger.info("拉取订单---> ,类型 {} , 开始时间：{} --- 结束时间：{}", hourMinuteTag, startTime.format(DATE_TIME_FORMATTER), endTime.format(DATE_TIME_FORMATTER));
return unionOpenOrderRowQueryResponse; return unionOpenOrderRowQueryResponse;
} }
@@ -759,22 +755,22 @@ public class JDUtils {
wxUtil.sendTextMessage(WXUtil.super_admin_wxid, content.toString(), 1, WXUtil.super_admin_wxid); wxUtil.sendTextMessage(WXUtil.super_admin_wxid, content.toString(), 1, WXUtil.super_admin_wxid);
} }
} }
public UnionOpenGoodsBigfieldQueryResponse getUnionOpenGoodsBigfieldQueryResponse(){ //public UnionOpenGoodsBigfieldQueryResponse getUnionOpenGoodsBigfieldQueryResponse(){
JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY, SECRET_KEY); // JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY, SECRET_KEY);
//
UnionOpenGoodsBigfieldQueryRequest request=new UnionOpenGoodsBigfieldQueryRequest(); // UnionOpenGoodsBigfieldQueryRequest request=new UnionOpenGoodsBigfieldQueryRequest();
BigFieldGoodsReq goodsReq=new BigFieldGoodsReq(); // BigFieldGoodsReq goodsReq=new BigFieldGoodsReq();
goodsReq.setSkuIds(); // goodsReq.setSkuIds();
request.setGoodsReq(goodsReq); // request.setGoodsReq(goodsReq);
request.setVersion("1.0"); // request.setVersion("1.0");
UnionOpenGoodsBigfieldQueryResponse response= null; // UnionOpenGoodsBigfieldQueryResponse response= null;
try { // try {
response = client.execute(request); // response = client.execute(request);
} catch (Exception e) { // } catch (Exception e) {
throw new RuntimeException(e); // throw new RuntimeException(e);
} // }
return response; // return response;
} //}
/** /**
@@ -792,7 +788,7 @@ public class JDUtils {
//System.out.println("调用API - 从 " + startTime //System.out.println("调用API - 从 " + startTime
// + " 到 " + endTime); // + " 到 " + endTime);
// 实际的 API 调用逻辑应在这里进行 // 实际的 API 调用逻辑应在这里进行
JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY, SECRET_KEY); JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY_WZ, SECRET_KEY_WZ);
UnionOpenOrderRowQueryRequest request = new UnionOpenOrderRowQueryRequest(); UnionOpenOrderRowQueryRequest request = new UnionOpenOrderRowQueryRequest();
OrderRowReq orderReq = new OrderRowReq(); OrderRowReq orderReq = new OrderRowReq();
orderReq.setPageIndex(pageIndex); orderReq.setPageIndex(pageIndex);
@@ -817,25 +813,25 @@ public class JDUtils {
/** /**
* 转链 * 转链
*/ */
String transfer(String url) throws Exception { //String transfer(String url) throws Exception {
JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY, SECRET_KEY); // JdClient client = new DefaultJdClient(SERVER_URL, ACCESS_TOKEN, APP_KEY_DG, SECRET_KEY_DG);
UnionOpenPromotionCommonGetRequest request = new UnionOpenPromotionCommonGetRequest(); // UnionOpenPromotionBysubunionidGetRequest getRequest = new UnionOpenPromotionBysubunionidGetRequest();
request.setVersion("1.0"); // getRequest.setVersion("1.0");
request.setSignmethod("md5"); // getRequest.setSignmethod("md5");
//
PromotionCodeReq promotionCodeReq = new PromotionCodeReq(); // PromotionCodeReq promotionCodeReq = new PromotionCodeReq();
promotionCodeReq.setMaterialId(url); // promotionCodeReq.setMaterialId(url);
promotionCodeReq.setSiteId("4101253066"); // promotionCodeReq.setSiteId("4101191512");
promotionCodeReq.setSceneId(1); // promotionCodeReq.setSceneId(2);
promotionCodeReq.setCommand(1); // promotionCodeReq.setCommand(1);
promotionCodeReq.setProType(5); // promotionCodeReq.setProType(5);
//
//
request.setPromotionCodeReq(promotionCodeReq); // getRequest.setPromotionCodeReq(promotionCodeReq);
UnionOpenPromotionCommonGetResponse response = client.execute(request); // UnionOpenPromotionCommonGetResponse response = client.execute(request);
//
String jsonString = JSON.toJSONString(response); // String jsonString = JSON.toJSONString(response);
System.out.println(jsonString); // System.out.println(jsonString);
// //
//System.out.println(request.getAppJsonParams()); //System.out.println(request.getAppJsonParams());
//System.out.println(request.getPromotionCodeReq()); //System.out.println(request.getPromotionCodeReq());
@@ -845,7 +841,7 @@ public class JDUtils {
//System.out.println(response.getGetResult().getMessage()); //System.out.println(response.getGetResult().getMessage());
//System.out.println(response.getGetResult().getData().getClickURL()); //System.out.println(response.getGetResult().getData().getClickURL());
//System.out.println(response.getGetResult().getData().getJCommand()); //System.out.println(response.getGetResult().getData().getJCommand());
return response.getGetResult().getData().getClickURL(); // return response.getGetResult().getData().getClickURL();
} //}
} }