调整代码

basic/pom.xml

@@ -125,6 +125,21 @@
                     <testFailureIgnore>true</testFailureIgnore>
                 </configuration>
             </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <addClasspath>true</addClasspath>
+                            <useUniqueVersions>false</useUniqueVersions>
+                            <classpathPrefix>lib/</classpathPrefix>
+                            <mainClass>cn.mymaven.test.TestMain</mainClass>
+                        </manifest>
+                    </archive>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

basic/src/main/java/com/liangjiang/basic/controller/BasicController.java

@@ -23,11 +23,11 @@ public class BasicController {
 
     /**
      * 保存成交单信息
-     * @param dealRecords 成交单信息
+     * @param list 成交单信息数组
      */
     @RequestMapping(value = "/saveDealRecords", method = RequestMethod.POST)
-    public void saveDealRecords(@RequestBody DealRecords dealRecords) {
-        this.basicService.saveDealRecords(dealRecords);
+    public void saveDealRecords(@RequestBody List<DealRecords> list) {
+        this.basicService.saveDealRecords(list);
     }
 
     /**

basic/src/main/java/com/liangjiang/basic/mapper/DealRecordsMapper.java

@@ -16,4 +16,6 @@ import java.util.List;
 public interface DealRecordsMapper extends BaseMapper<DealRecords> {
 
     List<DealRecords> queryDealRecords(QueryDealRecordsParams params);
+
+
 }

basic/src/main/java/com/liangjiang/basic/service/IBasicService.java

@@ -13,9 +13,9 @@ import java.util.List;
 public interface IBasicService {
     /**
      * 写入交易记录
-     * @param records 记录信息
+     * @param list 记录信息数组
      */
-    void saveDealRecords(DealRecords records);
+    void saveDealRecords(List<DealRecords> list);
 
     /**
      * 根据条件参数查询交易记录

basic/src/main/java/com/liangjiang/basic/service/IDealRecordsService.java

@@ -0,0 +1,11 @@
+package com.liangjiang.basic.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.liangjiang.basic.domain.bo.QueryDealRecordsParams;
+import com.liangjiang.basic.domain.entity.DealRecords;
+
+import java.util.List;
+
+public interface IDealRecordsService extends IService<DealRecords> {
+    List<DealRecords> queryDealRecords(QueryDealRecordsParams params);
+}

basic/src/main/java/com/liangjiang/basic/service/impl/BasicServiceImpl.java

@@ -4,6 +4,7 @@ import com.liangjiang.basic.domain.bo.QueryDealRecordsParams;
 import com.liangjiang.basic.domain.entity.DealRecords;
 import com.liangjiang.basic.mapper.DealRecordsMapper;
 import com.liangjiang.basic.service.IBasicService;
+import com.liangjiang.basic.service.IDealRecordsService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -17,17 +18,18 @@ import java.util.List;
 @Service(value = "basicServiceImpl")
 @RequiredArgsConstructor
 public class BasicServiceImpl implements IBasicService {
-    private final DealRecordsMapper dealRecordsMapper;
+    private final IDealRecordsService dealRecordsService;
 
     @Override
-    public void saveDealRecords(DealRecords records){
-        records.setId(null);
-        dealRecordsMapper.insert(records);
+    public void saveDealRecords(List<DealRecords> list) {
+        list.forEach(d ->{
+            d.setId(null);
+        });
+        dealRecordsService.saveBatch(list);
     }
 
     @Override
     public List<DealRecords> getDealRecordsByParams(QueryDealRecordsParams params){
-        List<DealRecords> records = dealRecordsMapper.queryDealRecords(params);
-        return records;
+        return dealRecordsService.queryDealRecords(params);
     }
 }

basic/src/main/java/com/liangjiang/basic/service/impl/DealRecordsServiceImpl.java

@@ -0,0 +1,23 @@
+package com.liangjiang.basic.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liangjiang.basic.domain.bo.QueryDealRecordsParams;
+import com.liangjiang.basic.domain.entity.DealRecords;
+import com.liangjiang.basic.mapper.DealRecordsMapper;
+import com.liangjiang.basic.service.IDealRecordsService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class DealRecordsServiceImpl extends ServiceImpl<DealRecordsMapper, DealRecords> implements IDealRecordsService {
+    private final DealRecordsMapper dealRecordsMapper;
+
+    @Override
+    public List<DealRecords> queryDealRecords(QueryDealRecordsParams params) {
+        List<DealRecords> records = dealRecordsMapper.queryDealRecords(params);
+        return records;
+    }
+}

basic/src/main/resources/application.yml

@@ -15,8 +15,8 @@ spring:
     time-zone: GMT+8
   datasource:
     username: root
-    password: 43626546
-    url: jdbc:mysql://localhost:3306/market_warehouse?characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true
+    password: zxc123...
+    url: jdbc:mysql://as.skyfffire.com:3306/market_warehouse?characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true
     driver-class-name: com.mysql.cj.jdbc.Driver
     type: com.alibaba.druid.pool.DruidDataSource
     druid:

basic/src/test/java/com/liangjiang/basic/BasicTest.java

@@ -13,6 +13,7 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
@@ -30,9 +31,11 @@ public class BasicTest {
     public void save() throws ParseException {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSSS");
         Date date = sdf.parse("2023-12-07 12:12:12.1585");
-        DealRecords dealRecords = new DealRecords(null, new BigDecimal(123.5156),
-                new BigDecimal(123.5056), new BigDecimal(1.5754), date, "rust1", "kk");
-        basicService.saveDealRecords(dealRecords);
+        DealRecords dealRecords = new DealRecords(null, new BigDecimal("123.5156"),
+                new BigDecimal("123.5056"), new BigDecimal("1.5754"), date, "rust1", "kk");
+        List<DealRecords> list= new ArrayList<>();
+        list.add(dealRecords);
+        basicService.saveDealRecords(list);
     }
 
     @Test