• 调用电商集成平台 聚水潭 api接口示例

    先上工具类

    1. package com.zuodou.utlis;
    2.  
    3. import org.springframework.beans.factory.annotation.Value;
    4. import org.springframework.stereotype.Component;
    5.  
    6. import javax.xml.crypto.Data;
    7. import java.io.*;
    8. import java.net.HttpURLConnection;
    9. import java.net.URL;
    10. import java.net.URLEncoder;
    11. import java.security.MessageDigest;
    12. import java.util.*;
    13. import java.util.Map.Entry;
    14. import java.util.zip.GZIPInputStream;
    15. @Component
    16. public class ApiUtils {
    17.  
    18.     private static final String SIGN_METHOD_MD5 = "md5";
    19.     private static final String CHARSET_UTF8 = "utf-8";
    20.     private static final String CONTENT_ENCODING_GZIP = "gzip";
    21.  
    22.     // TOP服务地址，正式环境需要设置为https://openapi.jushuitan.com
    23. //    @Value("${erp.serverUrl}")
    24. //    public   String serverUrl;
    25. //
    26. //    @Value("${erp.appKey}")
    27. //    public  String appKey; // 可替换为您的应用的appKey
    28. //
    29. //    @Value("${erp.appSecret}")
    30. //    public  String appSecret; // 可替换为您的应用的appSecret
    31. //
    32. //    @Value("${erp.accessToken}")
    33. //    public  String accessToken; // 必须替换为授权得到的真实有效accessToken
    34.  
    35.     public static String serverUrl;
    36.     public static String appKey;
    37.     public static String appSecret;
    38.     public static String accessToken;
    39.  
    40.     @Value("${erp.serverUrl}")
    41.     public void setServerUrl(String serverUrl) {
    42.         ApiUtils.serverUrl = serverUrl;
    43.     }
    44.  
    45.     @Value("${erp.appKey}")
    46.     public void setAppKey(String appKey) {
    47.         ApiUtils.appKey = appKey;
    48.     }
    49.  
    50.     @Value("${erp.appSecret}")
    51.     public void setAppSecret(String appSecret) {
    52.         ApiUtils.appSecret = appSecret;
    53.     }
    54.  
    55.     @Value("${erp.accessToken}")
    56.     public void setAccessToken(String accessToken) {
    57.         ApiUtils.accessToken = accessToken;
    58.     }
    59.  
    60.  
    61.     /**
    62.      *
    63.      * @param fangfa
    64.      * @return
    65.      * @throws IOException
    66.      */
    67.     public static String getSellerItem(String fangfa, String biz) throws IOException {
    68.         Map params = new HashMap();
    69.  
    70.         // 公共参数
    71.         params.put("app_key",appKey);
    72.         params.put("access_token", accessToken);
    73.         params.put("timestamp", String.valueOf(System.currentTimeMillis() / 1000));
    74.         params.put("version", "2");
    75.         params.put("charset", "utf-8");
    76.         // 业务参数
    77.         params.put("biz", biz);
    78.         // 签名参数
    79.         params.put("sign", signTopRequest(params, appSecret, SIGN_METHOD_MD5));
    80.         // 调用API
    81.         return callApi(new URL(serverUrl+fangfa), params);
    82.     }
    83.  
    84.     /**
    85.      * 对TOP请求进行签名。
    86.      */
    87.     private static String signTopRequest(Map params, String secret, String signMethod) throws IOException {
    88.         // 第一步：检查参数是否已经排序
    89.         String[] keys = params.keySet().toArray(new String[0]);
    90.         Arrays.sort(keys);
    91.  
    92.         // 第二步：把所有参数名和参数值串在一起
    93.         StringBuilder query = new StringBuilder();
    94.         if (SIGN_METHOD_MD5.equals(signMethod)) {
    95.             query.append(secret);
    96.         }
    97.         for (String key : keys) {
    98.             String value = params.get(key);
    99.             if (isNotEmpty(key) && isNotEmpty(value)) {
    100.                 query.append(key).append(value);
    101.             }
    102.         }
    103.         return createSign(query.toString());
    104.     }
    105.  
    106.     /**
    107.      * 生成新sign
    108.      *
    109.      * @param str 字符串
    110.      * @return String
    111.      */
    112.     private static String createSign(String str) {
    113.         if (str == null || str.length() == 0) {
    114.             return null;
    115.         }
    116.         char[] hexDigits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
    117.         try {
    118.             MessageDigest mdTemp = MessageDigest.getInstance(SIGN_METHOD_MD5);
    119.             mdTemp.update(str.getBytes("UTF-8"));
    120.  
    121.             byte[] md = mdTemp.digest();
    122.             int j = md.length;
    123.             char[] buf = new char[j * 2];
    124.             int k = 0;
    125.             int i = 0;
    126.             while (i < j) {
    127.                 byte byte0 = md[i];
    128.                 buf[k++] = hexDigits[byte0 >>> 4 & 0xf];
    129.                 buf[k++] = hexDigits[byte0 & 0xf];
    130.                 i++;
    131.             }
    132.             return new String(buf);
    133.         } catch (Exception e) {
    134.             return null;
    135.         }
    136.     }
    137.  
    138.  
    139.     private static String callApi(URL url, Map params) throws IOException {
    140.         String query = buildQuery(params, CHARSET_UTF8);
    141.         byte[] content = {};
    142.         if (query != null) {
    143.             content = query.getBytes(CHARSET_UTF8);
    144.         }
    145.  
    146.         HttpURLConnection conn = null;
    147.         OutputStream out = null;
    148.         String rsp = null;
    149.         try {
    150.             conn = (HttpURLConnection) url.openConnection();
    151.             conn.setRequestMethod("POST");
    152.             conn.setDoInput(true);
    153.             conn.setDoOutput(true);
    154.             conn.setRequestProperty("Host", url.getHost());
    155.             conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=" + CHARSET_UTF8);
    156.             out = conn.getOutputStream();
    157.             out.write(content);
    158.             rsp = getResponseAsString(conn);
    159.         } finally {
    160.             if (out != null) {
    161.                 out.close();
    162.             }
    163.             if (conn != null) {
    164.                 conn.disconnect();
    165.             }
    166.         }
    167.  
    168.         return rsp;
    169.     }
    170.  
    171.     private static String buildQuery(Map params, String charset) throws IOException {
    172.         if (params == null || params.isEmpty()) {
    173.             return null;
    174.         }
    175.  
    176.         StringBuilder query = new StringBuilder();
    177.         Set> entries = params.entrySet();
    178.         boolean hasParam = false;
    179.  
    180.         for (Entry entry : entries) {
    181.             String name = entry.getKey();
    182.             String value = entry.getValue();
    183.             // 忽略参数名或参数值为空的参数
    184.             if (isNotEmpty(name) && isNotEmpty(value)) {
    185.                 if (hasParam) {
    186.                     query.append("&");
    187.                 } else {
    188.                     hasParam = true;
    189.                 }
    190.  
    191.                 query.append(name).append("=").append(URLEncoder.encode(value, charset));
    192.             }
    193.         }
    194.  
    195.         return query.toString();
    196.     }
    197.  
    198.     private static String getResponseAsString(HttpURLConnection conn) throws IOException {
    199.         String charset = getResponseCharset(conn.getContentType());
    200.         if (conn.getResponseCode() < 400) {
    201.             String contentEncoding = conn.getContentEncoding();
    202.             if (CONTENT_ENCODING_GZIP.equalsIgnoreCase(contentEncoding)) {
    203.                 return getStreamAsString(new GZIPInputStream(conn.getInputStream()), charset);
    204.             } else {
    205.                 return getStreamAsString(conn.getInputStream(), charset);
    206.             }
    207.         } else {// Client Error 4xx and Server Error 5xx
    208.             throw new IOException(conn.getResponseCode() + " " + conn.getResponseMessage());
    209.         }
    210.     }
    211.  
    212.     private static String getStreamAsString(InputStream stream, String charset) throws IOException {
    213.         try {
    214.             Reader reader = new InputStreamReader(stream, charset);
    215.             StringBuilder response = new StringBuilder();
    216.  
    217.             final char[] buff = new char[1024];
    218.             int read = 0;
    219.             while ((read = reader.read(buff)) > 0) {
    220.                 response.append(buff, 0, read);
    221.             }
    222.  
    223.             return response.toString();
    224.         } finally {
    225.             if (stream != null) {
    226.                 stream.close();
    227.             }
    228.         }
    229.     }
    230.  
    231.     private static String getResponseCharset(String ctype) {
    232.         String charset = CHARSET_UTF8;
    233.  
    234.         if (isNotEmpty(ctype)) {
    235.             String[] params = ctype.split(";");
    236.             for (String param : params) {
    237.                 param = param.trim();
    238.                 if (param.startsWith("charset")) {
    239.                     String[] pair = param.split("=", 2);
    240.                     if (pair.length == 2) {
    241.                         if (isNotEmpty(pair[1])) {
    242.                             charset = pair[1].trim();
    243.                         }
    244.                     }
    245.                     break;
    246.                 }
    247.             }
    248.         }
    249.  
    250.         return charset;
    251.     }
    252.  
    253.     private static boolean isNotEmpty(String value) {
    254.         int strLen;
    255.         if (value == null || (strLen = value.length()) == 0) {
    256.             return false;
    257.         }
    258.         for (int i = 0; i < strLen; i++) {
    259.             if ((Character.isWhitespace(value.charAt(i)) == false)) {
    260.                 return true;
    261.             }
    262.         }
    263.         return false;
    264.     }
    265.  
    266.  
    267.     public static void main(String[] args) {
    268.         int pageNo = 1;
    269.         int pageSize = 100;
    270.         boolean hasMoreData = true;
    271.         List allData = new ArrayList<>();
    272.  
    273.         while (hasMoreData) {
    274.             List currentPageData = callThirdPartyApi(pageNo, pageSize); // 调用第三方API获取当前页数据
    275.             allData.addAll(currentPageData); // 将当前页数据加入总数据集合
    276.  
    277.             if (currentPageData.size() < pageSize) {
    278.                 hasMoreData = false; // 当前页数据不足pageSize，表示已获取所有数据
    279.             } else {
    280.                 pageNo++; // 继续获取下一页数据
    281.             }
    282.         }
    283.  
    284.         // 所有数据已获取完成
    285.         System.out.println("Total data count: " + allData.size());
    286.         // 进一步处理allData集合...
    287.     }
    288.  
    289.     // 调用第三方API获取指定页数据的示例方法
    290.     private static List callThirdPartyApi(int pageNo, int pageSize) {
    291.         // 调用第三方API获取指定页的数据
    292.         // 返回数据列表
    293.         return new ArrayList<>(); // 这里仅作示例，实际应调用API并返回数据
    294.     }
    295.  
    296. }

    需求说明，需要把聚水潭所有的售后数据拉取到自研平台进行进一步操作。

    调用接口的限制：分页，每页数量50，请求限制，一秒钟不能超过5次，一分钟不能超过一百次。

    注意代码待完善：accessToken是有过期时间的，但可以在主账号设置，如果超过限制我不会进行记录会漏掉这条数据。有一些注入的地方可以删掉。我定义了一个erpDatas和erpItems类来接收数据，由于返回值是下划线的，而我项目架构是驼峰命名，会导致映射值失败，最下面是处理方法（可以不用的自行删除）。

    1. package com.zuodou.job;
    2.  
    3.  
    4. import com.zuodou.mapper.ZuodouTaskDatasMapper;
    5.  
    6.  
    7. import com.zuodou.utlis.DataUtil;
    8. import com.zuodou.utlis.TimeUtils;
    9. import lombok.extern.slf4j.Slf4j;
    10. import org.apache.commons.lang3.StringUtils;
    11. import org.quartz.DisallowConcurrentExecution;
    12. import org.quartz.Job;
    13. import org.quartz.JobExecutionContext;
    14. import org.quartz.JobExecutionException;
    15. import org.springframework.beans.factory.annotation.Autowired;
    16.  
    17. import java.util.*;
    18.  
    19. /**
    20.  * 售后
    21.  */
    22.  
    23. @Slf4j
    24. //禁止并发执行
    25. @DisallowConcurrentExecution
    26. public class TaskDatas implements Job {
    27.  
    28.  
    29.     @Autowired
    30.     private ZuodouTaskDatasMapper zuodouTaskDatasMapper;
    31.  
    32.  
    33.     @Autowired
    34.     private  threadService threadService;
    35.  
    36.     /**
    37.      * 若参数变量名修改 QuartzJobController中也需对应修改
    38.      */
    39.     private String parameter;
    40.  
    41.     public void setParameter(String parameter) {
    42.         this.parameter = parameter;
    43.     }
    44.  
    45.     private String parameterstartime;
    46.  
    47.     public void setParameterstartime(String parameterstartime) {
    48.         this.parameterstartime = parameterstartime;
    49.     }
    50.  
    51.  
    52.  
    53.     /**
    54.      * 拿售后数据
    55.      * @param jobExecutionContext
    56.      * @throws JobExecutionException
    57.      *
    58.      * token过期
    59.      * 1.请求状态
    60.      * 2.时间间隔七天
    61.      * 3.分页数据
    62.      * /open/refund/single/query
    63.      *
    64.      */
    65.  
    66.     @Override
    67.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    68.         
    69.         try {
    70.             //1.拿到数据库中最大时间  如果没有，默认多少，如果有生成一个七天时间lsit
    71.             //1.1 先判断数据库时间和当前时间是否相差七天，相差七天就减，没有相差就用当前时间当作结束时间
    72.             //2.在每个七天里面分页拿取数据，data_count 总数，page_count 有多少页
    73.             //3.把分页数据整合到list中
    74.  
    75. //            for (String shopId : Shop_id) {
    76.  
    77.                 String start = zuodouTaskDatasMapper.maxOrdersDate(null);
    78.                 String end = TimeUtils.getStringDate();//比当前时间少一分钟，防止数据重复
    79.                 if (StringUtils.isBlank(start)) {
    80.                     start = this.parameterstartime;
    81.                 }
    82.                 log.info("聚水潭售后数据拉取开始-------"+TimeUtils.date2Str(new Date()));
    83.  
    84.                 Date CalendarstartTime = TimeUtils.DateSwitch(start);
    85.                 Date CalendarendTime = TimeUtils.DateSwitch(end);
    86.                 Calendar startCal = Calendar.getInstance();
    87.                 startCal.setTime(CalendarstartTime) ;
    88.                 Calendar endCal = Calendar.getInstance();
    89.                 endCal.setTime(CalendarendTime);
    90.                 String startTime =start;
    91.                 String endTime =null;
    92.                 while (!start.equals(end)) { //当开始时间大于或者等于结束时间
    93.                     Integer day = DataUtil.countDaynew(start,end );
    94.                     if (day>7) {
    95.                         startCal.add(Calendar.DAY_OF_MONTH, 7);
    96.                         endTime = TimeUtils.date2Str(startCal.getTime());
    97.                         Integer  daya = DataUtil.countDaynew(endTime, end); //判断结束时间加上七天跟当前时间的间隔
    98.                         if (daya <1) { //如果加上七天大于当前时间或者等于
    99.                             endTime=end;
    100.                         }
    101.                     }
    102.  
    103.                     if (StringUtils.isBlank(endTime)){
    104.                         endTime=end;
    105.                     }
    106.  
    107.                     System.out.println(startTime+"-----3---"+endTime);
    108.                     String finalStartTime = startTime;
    109.                     String finalEndTime = endTime;
    110.  
    111.                     threadService.apithread(finalStartTime, finalEndTime);
    112.                     Integer     days = DataUtil.countDaynew(startTime,endTime );
    113.                     Integer  daya = DataUtil.countDaynew(endTime, end);
    114.  
    115.                     if (days==7){ //超过七天
    116.                         startTime = endTime;
    117.                     } else if (days>0&&daya==0){
    118.                         startTime = endTime;//累计七天的结束时间
    119.                         endTime = end; //结束时间为当前时间
    120.                         start = end; //设置停止循环
    121.                     }else if(daya<7){
    122.                         endTime=end;
    123.                         start=end;//用于结束循环
    124.                     }
    125.  
    126.                 }
    127.  
    128. //            }
    129.  
    130.  
    131.  
    132.         } catch (Exception  e) {
    133.             e.printStackTrace();
    134.         }
    135.     }
    136.  
    137.     public static void main(String[] args)  {
    138.  
    139.         String start = "2023-10-09 13:41:20";
    140.         String end = TimeUtils.getStringDate();//比当前时间少一分钟，防止数据重复
    141.         if (StringUtils.isBlank(start)) {
    142.             start = "2023-08-01 00:00:00";
    143.         }
    144.  
    145.         Date CalendarstartTime = TimeUtils.DateSwitch(start);
    146.         Date CalendarendTime = TimeUtils.DateSwitch(end);
    147.         Calendar startCal = Calendar.getInstance();
    148.         startCal.setTime(CalendarstartTime) ;
    149.         Calendar endCal = Calendar.getInstance();
    150.         endCal.setTime(CalendarendTime);
    151.         String startTime =start;
    152.         String endTime =null;
    153.         while (!start.equals(end)) { //当开始时间大于或者等于结束时间
    154.             Integer day = DataUtil.countDaynew(start,end );
    155.             if (day>7) {
    156.                 startCal.add(Calendar.DAY_OF_MONTH, 7);
    157.                 endTime = TimeUtils.date2Str(startCal.getTime());
    158.                 Integer  daya = DataUtil.countDaynew(endTime, end); //判断结束时间加上七天跟当前时间的间隔
    159.                 if (daya <1) { //如果加上七天大于当前时间或者等于
    160.                     endTime=end;
    161.                 }
    162.             }
    163.             if (StringUtils.isBlank(endTime)){
    164.                 endTime=end;
    165.             }
    166.             System.out.println(startTime+"-----3---"+endTime);
    167.  
    168.             Integer     days = DataUtil.countDaynew(startTime,endTime );
    169.             Integer  daya = DataUtil.countDaynew(endTime, end);
    170.  
    171.             if (days==7){ //超过七天
    172.                 startTime = endTime;
    173.             } else if (days>0&&daya==0){
    174.                 startTime = endTime;//累计七天的结束时间
    175.                 endTime = end; //结束时间为当前时间
    176.                 start = end; //设置停止循环
    177.             }else if(daya<7){
    178.                 endTime=end;
    179.                 start=end;//用于结束循环
    180.             }
    181.  
    182.            }
    183.  
    184.         }
    185.  
    186.  
    187.  
    188.  
    189.  
    190.  
    191.  
    192. }
    1. package com.zuodou.job;
    2.  
    3. import com.fasterxml.jackson.core.JsonProcessingException;
    4. import com.fasterxml.jackson.databind.JsonNode;
    5. import com.fasterxml.jackson.databind.ObjectMapper;
    6. import com.fasterxml.jackson.databind.node.ArrayNode;
    7. import com.zuodou.entity.ZuodouTaskDatas;
    8. import com.zuodou.entity.ZuodouTaskItem;
    9. import com.zuodou.enums.CommonConstant;
    10. import com.zuodou.enums.ErpStatusEnum;
    11. import com.zuodou.erpmodel.erpData;
    12. import com.zuodou.erpmodel.erpDatas;
    13. import com.zuodou.erpmodel.erpItems;
    14. import com.zuodou.mapper.ZuodouTaskDatasMapper;
    15. import com.zuodou.model.*;
    16. import com.zuodou.service.IZuodouTaskDatasService;
    17. import com.zuodou.service.IZuodouTaskItemService;
    18. import com.zuodou.utlis.BaseUtlis;
    19. import com.zuodou.utlis.TimeUtils;
    20. import lombok.extern.slf4j.Slf4j;
    21. import org.apache.commons.lang3.StringUtils;
    22. import org.springframework.beans.factory.annotation.Autowired;
    23. import org.springframework.stereotype.Service;
    24. import org.springframework.util.CollectionUtils;
    25.  
    26. import java.io.IOException;
    27. import java.util.*;
    28.  
    29. import static com.zuodou.utlis.ApiUtils.getSellerItem;
    30.  
    31. @Service
    32. @Slf4j
    33. public class threadService {
    34.  
    35.     @Autowired
    36.     private IZuodouTaskItemService zuodouTaskItemService;
    37.  
    38.     @Autowired
    39.     private IZuodouTaskDatasService iZuodouTaskDatasService;
    40.  
    41.     @Autowired
    42.     private ZuodouTaskDatasMapper zuodouTaskDatasMapper;
    43.  
    44.  
    45.  
    46.     public void apithread(String finalStartTime, String finalEndTime) {
    47.         log.info("执行售后任务时间"+finalStartTime+"----"+finalEndTime);
    48.  
    49.         List zuodouTaskDatas = new ArrayList<>();
    50.         List updatezuodouTaskDatas = new ArrayList<>();
    51.         List zuodouTaskItemList = new ArrayList<>();
    52.         List updatezuodouTaskItemList = new ArrayList<>();
    53.         List orders = new ArrayList<>();
    54.          ObjectMapper objectMapper=new ObjectMapper();
    55.         OrderQueryParams queryParams = new OrderQueryParams();
    56.         queryParams.setModified_begin(finalStartTime).setModified_end(finalEndTime).setPage_index(1).setPage_size(50);
    57.         try {
    58.             String valueAsString = objectMapper.writeValueAsString(queryParams);
    59.             JsonNode jsonNode = objectMapper.readTree(getSellerItem("/open/refund/single/query", valueAsString));
    60.             String msg = jsonNode.get("msg").asText();
    61.             String code = jsonNode.get("code").asText();
    62.             if (StringUtils.equals(msg, "执行成功") && StringUtils.equals(code, "0")) {
    63.                 Integer page_count = 0;//有多少页
    64.                 JsonNode dataNode = jsonNode.get("data");
    65.                 erpData erpData = null;
    66.  
    67.                 erpData = objectMapper.treeToValue(dataNode, erpData.class);
    68.  
    69.                 page_count += erpData.getPage_count();
    70.                 if (page_count > 0) {
    71.                     for (int j = 1; j <= page_count; j++) {
    72.                         OrderQueryParams queryParamsdata_count = new OrderQueryParams();
    73.                         queryParamsdata_count.setModified_begin(finalStartTime).setModified_end(finalEndTime).setPage_index(j).setPage_size(50);
    74.                         String valueAsStrings = null;
    75.                         valueAsStrings = objectMapper.writeValueAsString(queryParamsdata_count);
    76.                         JsonNode    jsonNodes = objectMapper.readTree(getSellerItem("/open/refund/single/query", valueAsStrings));
    77.                         String msgs = jsonNodes.get("msg").asText();
    78.                         String codes = jsonNodes.get("code").asText();
    79.                         JsonNode dataNodea = jsonNodes.get("data");
    80.                         if (StringUtils.equals(msgs, "执行成功") && StringUtils.equals(codes, "0")) {
    81.                             log.info("售后数据执行成功"+msgs);
    82.                             JsonNode dataNodes = dataNodea.get("datas");//拿到数据结构
    83.                             if (dataNodes instanceof ArrayNode) {
    84.                                 ArrayNode ordersArrayNode = (ArrayNode) dataNodes;
    85.                                 for (JsonNode orderNode : ordersArrayNode) {
    86.                                     erpDatas    order = objectMapper.treeToValue(orderNode, erpDatas.class);
    87.                                     orders.add(order);
    88.                                 }
    89.                             }
    90.                         } else {
    91.                             log.info("售后数据执行失败"+msgs);
    92.                         }
    93.                         try {
    94.                             // 在apithread方法中休息两秒
    95.                             Thread.sleep(1000);
    96.                         } catch (InterruptedException e) {
    97.                             e.printStackTrace();
    98.                         }
    99.                     }
    100.                 }
    101.                 log.info("聚水潭售后数据拉取结束-----"+ TimeUtils.date2Str(new Date()));
    102.  
    103.             } else {
    104.                 log.info("外层分页售后"+msg);
    105.             }
    106.             try {
    107.                 // 在apithread方法中休息两秒
    108.                 Thread.sleep(1000);
    109.             } catch (InterruptedException e) {
    110.                 e.printStackTrace();
    111.             }
    112.             insertOrdersData(orders, zuodouTaskDatas,updatezuodouTaskDatas, zuodouTaskItemList,updatezuodouTaskItemList);
    113.  
    114.             log.info("开始插入售后数据----"+zuodouTaskDatas.size() + "商品数据---"+zuodouTaskItemList.size()+"需要修改售后数据--"+updatezuodouTaskDatas.size());
    115.             iZuodouTaskDatasService.saveBatch(zuodouTaskDatas);
    116.             zuodouTaskItemService.saveBatch(zuodouTaskItemList);
    117.             iZuodouTaskDatasService.updateBatchById(updatezuodouTaskDatas);
    118.             zuodouTaskItemService.updateBatchById(updatezuodouTaskItemList);
    119.         } catch (JsonProcessingException e) {
    120.             e.printStackTrace();
    121.         } catch (IOException e) {
    122.             e.printStackTrace();
    123.         } catch (IllegalAccessException e) {
    124.             e.printStackTrace();
    125.         } catch (InterruptedException e) {
    126.             e.printStackTrace();
    127.         }catch (Exception e){
    128.             e.printStackTrace();
    129.         }
    130.     }
    131.  
    132.  
    133.  
    134.     private  void insertOrdersData(List orders, List zuodouTaskOrdersList, List updatezuodouTaskOrdersList, List zuodouTaskItemList,List updatezuodouTaskItemList ) throws IllegalAccessException, IOException, InterruptedException {
    135.         if (!CollectionUtils.isEmpty(orders)){
    136.             for (erpDatas order : orders) {
    137.                 ZuodouTaskDatas zuodouTaskDatas=new ZuodouTaskDatas();
    138.                 BaseUtlis.copyProperties(order,zuodouTaskDatas);
    139.                 String asId = zuodouTaskDatasMapper.oIdasIddatas(order.getO_id(), order.getAs_id());
    140. //                boolean exists = zuodouTaskOrdersList.stream()
    141. //                        .anyMatch(obj -> obj.getOId().equals(order.getO_id()) && obj.getAsId() .equals(order.getAs_id()));
    142.  
    143.                 boolean exists = zuodouTaskOrdersList.stream()
    144.                         .anyMatch(obj -> obj.getAsId() .equals(order.getAs_id()));
    145.                 if (exists) {//如果插入的list中有那个值就直接跳过
    146.                     continue;
    147.                 }else if (StringUtils.isNotBlank(asId)) {
    148.                     zuodouTaskDatas.setAsId(asId);
    149.                     zuodouTaskDatas.setStatusName(ErpStatusEnum.getValueName(order.getStatus(), CommonConstant.STATUS));
    150.                     zuodouTaskDatas.setShopStatusName(ErpStatusEnum.getValueName(order.getShop_status(),CommonConstant.SHOP_STATUS));
    151.                     zuodouTaskDatas.setGoodStatusName(ErpStatusEnum.getValueName(order.getGood_status(),CommonConstant.GOOD_STATUS));
    152.                     zuodouTaskDatas.setOrderStatusName(ErpStatusEnum.getValueName(order.getOrder_status(),CommonConstant.ORDER_STATUS));
    153.                     zuodouTaskDatas.setOrderlabels(String.join(",",order.getOrder_labels()));
    154.                     updatezuodouTaskOrdersList.add(zuodouTaskDatas);
    155.                     for (erpItems item : order.getItems()) {
    156.                         ZuodouTaskItem zuodouTaskItem=new ZuodouTaskItem();
    157.                         BaseUtlis.copyProperties(item,zuodouTaskItem);
    158.                         zuodouTaskItem.setSkuTypeName(ErpStatusEnum.getValueName(item.getSku_type(),CommonConstant.SKU_TYPE));
    159.                         zuodouTaskItem.setSkuType(item.getSku_type());
    160.                         updatezuodouTaskItemList.add(zuodouTaskItem);
    161.                     }
    162.                 }else{
    163.                     zuodouTaskDatas.setStatusName(ErpStatusEnum.getValueName(order.getStatus(),CommonConstant.STATUS));
    164.                     zuodouTaskDatas.setShopStatusName(ErpStatusEnum.getValueName(order.getShop_status(),CommonConstant.SHOP_STATUS));
    165.                     zuodouTaskDatas.setGoodStatusName(ErpStatusEnum.getValueName(order.getGood_status(),CommonConstant.GOOD_STATUS));
    166.                     zuodouTaskDatas.setOrderStatusName(ErpStatusEnum.getValueName(order.getOrder_status(),CommonConstant.ORDER_STATUS));
    167.                     zuodouTaskDatas.setOrderlabels(String.join(",",order.getOrder_labels()));
    168.                     if (!CollectionUtils.isEmpty(order.getItems())){
    169.                         for (erpItems item : order.getItems()) {
    170.                             ZuodouTaskItem zuodouTaskItem=new ZuodouTaskItem();
    171.                             BaseUtlis.copyProperties(item,zuodouTaskItem);
    172.                             zuodouTaskItem.setSkuTypeName(ErpStatusEnum.getValueName(item.getSku_type(),CommonConstant.SKU_TYPE));
    173.                             zuodouTaskItem.setSkuType(item.getSku_type());
    174.                             zuodouTaskItemList.add(zuodouTaskItem);
    175.                         }
    176.                     }
    177.                     zuodouTaskOrdersList.add(zuodouTaskDatas);
    178.                 }
    179.  
    180.  
    181.  
    182.             }
    183.         }
    184.     }
    185.  
    186.  
    187.  
    188.  
    189. }

    public static void copyProperties(Object source, Object destination) throws IllegalAccessException {
    Field[] sourceFields = source.getClass().getDeclaredFields();
    Field[] destinationFields = destination.getClass().getDeclaredFields();

    for (Field sourceField : sourceFields) {
        sourceField.setAccessible(true);
        String sourceFieldName = sourceField.getName();
        String destinationFieldName = convertToCamelCase(sourceFieldName); // 将下划线命名转换为驼峰命名

        for (Field destinationField : destinationFields) {
            if (destinationField.getName().equals(destinationFieldName)) {
                destinationField.setAccessible(true);
                destinationField.set(destination, sourceField.get(source));
                break;
            }
        }
    }
}

  • 相关阅读:
    k8s系列-kubectl 命令快速参考
    复盘：智能座舱系列文三- 它背后的5种交互技术之触觉
    实验室（检验科）信息系统源码，医学检验LIS系统源码，云LIS源码
    Golang goroutine MPG模式浅析
    高维前缀和和子集dp(状压dp的一种)
    MySQL 1055报错 -this is incompatible with sql_mode=only_full_group_by
    考研数据结构与算法（五）数组
    高等数学（第七版）同济大学 总习题三（后10题） 个人解答
    核心交换机、汇聚层交换机、接入层交换机的区别和特点
    Potplayer通过公网访问群晖WebDav，快速搭建远程办公环境
  • 原文地址：https://blog.csdn.net/andrew_dear/article/details/134439563