huangyujie
/
qihang-ecom-erp-open
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
qihang-ecom-erp-open/jd-api/src/main/java/com/qihang/jd/controller/GoodsApiController.java

188 lines
9.7 KiB
Java
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

package com.qihang.jd.controller;
import com.alibaba.fastjson2.JSON;
import com.jd.open.api.sdk.DefaultJdClient;
import com.jd.open.api.sdk.JdClient;
import com.jd.open.api.sdk.JdException;
import com.jd.open.api.sdk.domain.ware.SkuReadService.response.searchSkuList.Sku;
import com.jd.open.api.sdk.domain.ware.WareReadService.response.searchWare4Valid.Ware;
import com.jd.open.api.sdk.request.order.OrderGetRequest;
import com.jd.open.api.sdk.request.order.PopOrderEnSearchRequest;
import com.jd.open.api.sdk.request.order.PopOrderSearchRequest;
import com.jd.open.api.sdk.request.refundapply.PopAfsRefundapplyQuerybyidRequest;
import com.jd.open.api.sdk.request.refundapply.PopAfsRefundapplyQuerylistRequest;
import com.jd.open.api.sdk.request.ware.SkuReadSearchSkuListRequest;
import com.jd.open.api.sdk.request.ware.WareReadSearchWare4ValidRequest;
import com.jd.open.api.sdk.response.order.OrderGetResponse;
import com.jd.open.api.sdk.response.order.PopOrderEnSearchResponse;
import com.jd.open.api.sdk.response.order.PopOrderSearchResponse;
import com.jd.open.api.sdk.response.refundapply.PopAfsRefundapplyQuerybyidResponse;
import com.jd.open.api.sdk.response.refundapply.PopAfsRefundapplyQuerylistResponse;
import com.jd.open.api.sdk.response.ware.SkuReadSearchSkuListResponse;
import com.jd.open.api.sdk.response.ware.WareReadSearchWare4ValidResponse;
import com.qihang.common.common.ApiResult;
import com.qihang.common.common.ResultVo;
import com.qihang.common.enums.EnumShopType;
import com.qihang.common.enums.HttpStatus;
import com.qihang.jd.domain.JdGoods;
import com.qihang.jd.domain.JdGoodsSku;
import com.qihang.jd.domain.SysShopPullLogs;
import com.qihang.jd.openApi.ApiCommon;
import com.qihang.jd.openApi.PullRequest;
import com.qihang.jd.service.JdGoodsService;
import com.qihang.jd.service.SysShopPullLogsService;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@RequestMapping("/goods")
@RestController
@AllArgsConstructor
public class GoodsApiController {
private final ApiCommon apiCommon;
private final JdGoodsService goodsService;
private final SysShopPullLogsService pullLogsService;
@RequestMapping(value = "/pull_list", method = RequestMethod.POST)
public Object pullList(@RequestBody PullRequest params) throws Exception {
if (params.getShopId() == null || params.getShopId() <= 0) {
// return ApiResul new ApiResult(HttpStatus.PARAMS_ERROR, "参数错误，没有店铺Id");
return ApiResult.build(HttpStatus.PARAMS_ERROR, "参数错误，没有店铺Id");
}
Date currDateTime = new Date();
long startTime = System.currentTimeMillis();
var checkResult = apiCommon.checkBefore(params.getShopId());
if (checkResult.getCode() != HttpStatus.SUCCESS) {
return ApiResult.build(checkResult.getCode(), checkResult.getMsg(), checkResult.getData());
}
String accessToken = checkResult.getData().getAccessToken();
String serverUrl = checkResult.getData().getServerUrl();
String appKey = checkResult.getData().getAppKey();
String appSecret = checkResult.getData().getAppSecret();
// String accessToken = "8abd974c62c34778935b34b5952e6f68izdk";
// String appKey="FB4CC3688E6F9065D4FF510A53BB60FF";
// String appSecret="40e8c8b2427f4e6db8f4a39af27d719e";
JdClient client=new DefaultJdClient(serverUrl,accessToken,appKey,appSecret);
//https://open.jd.com/home/home/#/doc/api?apiCateId=55&apiId=4246&apiName=jingdong.pop.order.search
// PopOrderSearchRequest request=new PopOrderSearchRequest();
// request.setStartDate("2024-2-14 10:00:00");
// request.setEndDate("2024-3-4 12:00:00");
// request.setOrderState("TRADE_CANCELED");
// request.setOptionalFields("itemInfoList,orderId,isShipmenttype,scDT,idSopShipmenttype,orderStartTime,consigneeInfo");
// request.setPage("1");
// request.setPageSize("20");
// request.setSortType(1);
// request.setDateType(0);
// PopOrderSearchResponse response=client.execute(request);
// System.out.println(response);
// PopOrderEnSearchRequest request=new PopOrderEnSearchRequest();
// request.setStartDate("2020-04-04 00:20:35");
// request.setEndDate("2020-04-04 00:20:35");
// request.setOrderState("21");
//// request.setOptionalFields("orderId,venderId");
//// request.setSourceId("JOS");
// request.setOptionalFields("itemInfoList,orderId,isShipmenttype,scDT,idSopShipmenttype,orderStartTime,consigneeInfo");
// request.setPage("1");
// request.setPageSize("10");
// request.setSortType(1);
// request.setDateType(0);
// PopOrderEnSearchResponse response=client.execute(request);
//https://open.jd.com/home/home/#/doc/api?apiCateId=48&apiId=1587&apiName=jingdong.ware.read.searchWare4Valid
WareReadSearchWare4ValidRequest request=new WareReadSearchWare4ValidRequest();
request.setField("jdPrice,wareId,title,spuId,images,itemNum,outerId,logo,weight,width,height,length,modified,created,offlineTime,onlineTime,mobileDesc,afterSales,marketPrice,costPrice,brandName,stockNum,sellPoint,afterSaleDesc,categoryId");
request.setWareStatusValue("8");
request.setPageNo(1);
request.setPageSize(100);
WareReadSearchWare4ValidResponse response=client.execute(request);
int successTotal = 0;
if(response != null && response.getPage()!= null && response.getPage().getData()!=null){
for (var ware: response.getPage().getData()){
JdGoods jdGoods = new JdGoods();
BeanUtils.copyProperties(ware,jdGoods);
List<JdGoodsSku> skuList = new ArrayList<>();
// 获取sku
SkuReadSearchSkuListRequest request1=new SkuReadSearchSkuListRequest();
request1.setWareId(ware.getWareId().toString());
request1.setField("skuId,categoryId,stockNum,wareTitle,status,multiCateProps,outerId,jdPrice,logo,skuName,parentId,modified,created,saleAttrs,imgTag,currencySpuId");
SkuReadSearchSkuListResponse response1=client.execute(request1);
// System.out.println(response1);
if(response1 != null && response1.getPage()!= null && response1.getPage().getData()!=null){
for(var s : response1.getPage().getData()){
JdGoodsSku sku = new JdGoodsSku();
BeanUtils.copyProperties(s,sku);
sku.setSaleAttrs(JSON.toJSONString(s.getSaleAttrs()));
skuList.add(sku);
}
}
jdGoods.setSkuList(skuList);
goodsService.saveGoods(params.getShopId(),jdGoods);
successTotal++;
}
}
SysShopPullLogs logs = new SysShopPullLogs();
logs.setShopId(params.getShopId());
logs.setShopType(EnumShopType.JD.getIndex());
logs.setPullType("GOODS");
logs.setPullWay("主动拉取");
logs.setPullParams("{WareStatusValue:8,PageNo:1,PageSize:100}");
logs.setPullResult("{successTotal:"+successTotal+"}");
logs.setPullTime(currDateTime);
logs.setDuration(System.currentTimeMillis() - startTime);
pullLogsService.save(logs);
//https://open.jd.com/home/home/#/doc/api?apiCateId=48&apiId=1227&apiName=jingdong.sku.read.searchSkuList
// SkuReadSearchSkuListRequest request1=new SkuReadSearchSkuListRequest();
// request1.setWareId("10223753529");
// request1.setField("skuId,categoryId,stockNum,wareTitle,status,multiCateProps,outerId,jdPrice,logo,skuName,parentId,modified,created,saleAttrs,imgTag,currencySpuId");
// SkuReadSearchSkuListResponse response1=client.execute(request1);
// System.out.println(response1);
// SpuGetModelOrItemNumListRequest request=new SpuGetModelOrItemNumListRequest();
// request.setUniqueCodeType(1);
// request.setCategoryId(1233);
// request.setPageNo(1);
// request.setPageSize(10);
// request.setBrandId(1122);
// request.setAppId("1784");
// request.setAppName("app名称");
// request.setBusinessIdentity("JOS");
// request.setIp("192.168.1.1");
// request.setUserAgent("zhangsan");
// SpuGetModelOrItemNumListResponse response=client.execute(request);
// //https://open.jd.com/home/home/#/doc/api?apiCateId=71&apiId=307&apiName=jingdong.pop.afs.refundapply.querylist
// PopAfsRefundapplyQuerylistRequest request2=new PopAfsRefundapplyQuerylistRequest();
//// request2.setStatus("1");
//// request2.setId("111");
//// request2.setOrderId("1234");
//// request2.setBuyerId("abc");
//// request2.setBuyerName("abc");
//// request2.setApplyTimeStart("2023-12-01 16:11:40");
//// request2.setApplyTimeEnd("2023-12-31 16:11:40");
//// request2.setCheckTimeStart("2023-12-01 16:11:40");
//// request2.setCheckTimeEnd("2023-12-31 16:11:40");
// request2.setPageIndex(1);
// request2.setPageSize(10);
// PopAfsRefundapplyQuerylistResponse response2=client.execute(request2);
// System.out.println(request2);
// PopAfsRefundapplyQuerybyidRequest request3=new PopAfsRefundapplyQuerybyidRequest();
// request3.setRaId(23454754437L);
// PopAfsRefundapplyQuerybyidResponse response3=client.execute(request3);
return response;
}
}
Reference in New Issue View Git Blame Copy Permalink