Changes

src/main/java/top/lvzhiqiang/mapper/CoinMapper.java

@@ -220,7 +220,7 @@ public interface CoinMapper {
 
     @Insert({"<script>" +
             "INSERT ignore INTO coin_binance_order_history(orderId,symbol,status,price,avgPrice,origQty,executedQty,cumQuote,timeInForce,type" +
-            ",side,positionSide,stopPrice,workingType,origType,time,updateTime,commission,realizedPnl,modifyTime)" +
+            ",side,positionSide,stopPrice,workingType,origType,time,updateTime,commission,realizedPnl,modify_time)" +
             " VALUES " +
             "<foreach collection='list' item='p' index=\"index\" separator=\",\">" +
             "   ( #{p.orderId}, #{p.symbol}, #{p.status}, #{p.price}, #{p.avgPrice}, #{p.origQty}, #{p.executedQty}, #{p.cumQuote}, #{p.timeInForce}, #{p.type}" +

src/main/java/top/lvzhiqiang/service/impl/CoinService2Impl.java

@@ -100,6 +100,8 @@ public class CoinService2Impl implements CoinService2 {
                 paramMap.clear();
                 String timestamp = String.valueOf(System.currentTimeMillis());
                 paramMap.put("symbol", coinBinanceSymbol.getSymbol());
+                paramMap.put("startTime", startTime);
+                paramMap.put("endTime", endTime);
                 paramMap.put("timestamp", timestamp);
                 String queryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
                 String sign = generate("", "", "", queryString, null, secretKey);
@@ -119,6 +121,8 @@ public class CoinService2Impl implements CoinService2 {
                             timestamp = String.valueOf(System.currentTimeMillis());
                             paramMap.put("symbol", coinBinanceSymbol.getSymbol());
                             paramMap.put("orderId", coinBinanceOrderHistory.getOrderId());
+                            paramMap.put("startTime", startTime);
+                            paramMap.put("endTime", endTime);
                             paramMap.put("timestamp", timestamp);
                             queryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
                             sign = generate("", "", "", queryString, null, secretKey);

src/test/java/top/lvzhiqiang/TestCoin.java

@@ -54,10 +54,12 @@ public class TestCoin {
     @Test
     public void testSyncData4Binance() {
         LocalDateTime now = LocalDateTime.now();
-        String startTime = String.valueOf(DateUtils.localDateTimeToMilliseconds(now.minusMonths(8)));
-        String endTime = String.valueOf(DateUtils.localDateTimeToMilliseconds(now.minusMonths(3)));
-        String pageSize = "100";
-        coinService2.syncData4Binance(startTime, endTime, pageSize);
+        for (int i = 0; i < 100; i++) {
+            String startTime = String.valueOf(DateUtils.localDateTimeToMilliseconds(now.minusDays(6 + (6 * i))));
+            String endTime = String.valueOf(DateUtils.localDateTimeToMilliseconds(now.minusDays((6 * i))));
+            String pageSize = "100";
+            coinService2.syncData4Binance(startTime, endTime, pageSize);
+        }
     }
 
     @Test