GTsoft/mps-platform
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

表19-27 更新 批量导入

Browse Source
This commit is contained in:
zhuangdashia 2025-08-27 14:08:20 +08:00
parent 2da956c1b4
commit b9fa6eb66f
27 changed files with 663 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalDianfeiMapper.java
View File

@ -10,6 +10,8 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
/**
* 代收电费Mapper接口
*
@ -33,4 +35,6 @@ public interface OriginalDianfeiMapper extends BaseMapperPlus<OriginalDianfei, O
//})
// List<SysUserExportVo> selectOriginalDianfeiExportList(@Param(Constants.WRAPPER) Wrapper<OriginalDianfei> queryWrapper);
// 批量插入
void batchInsert(@Param("list") Collection<OriginalDianfei> list);
}

5
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalEMBankingMapper.java
View File

@ -10,6 +10,9 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
import java.util.List;
/**
* 企业手机银行Mapper接口
*
@ -26,6 +29,8 @@ public interface OriginalEMBankingMapper extends BaseMapperPlus<OriginalEMBankin
return this.selectVoPage(page, queryWrapper);
}
// 批量插入
void batchInsert(@Param("list") Collection<OriginalEMBanking> list);
//@DataPermission({
// @DataColumn(key = "deptName", value = "create_dept"),

5
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalGjjPaymentMapper.java
View File

@ -10,6 +10,9 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
import java.util.List;
/**
* 公积金缴纳明细Mapper接口
*
@ -26,6 +29,8 @@ public interface OriginalGjjPaymentMapper extends BaseMapperPlus<OriginalGjjPaym
return this.selectVoPage(page, queryWrapper);
}
// 批量插入
void batchInsert(@Param("list") Collection<OriginalGjjPayment> list);
//@DataPermission({
// @DataColumn(key = "deptName", value = "create_dept"),

4
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalHeatMapper.java
View File

@ -10,6 +10,8 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
/**
* 取暖费信息Mapper接口
*
@ -32,5 +34,7 @@ public interface OriginalHeatMapper extends BaseMapperPlus<OriginalHeat, Origina
// @DataColumn(key = "userName", value = "create_by")
//})
// List<SysUserExportVo> selectOriginalHeatExportList(@Param(Constants.WRAPPER) Wrapper<OriginalHeat> queryWrapper);
// 批量插入
void batchInsert(@Param("list") Collection<OriginalHeat> list);
}

4
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalHntSgmxMapper.java
View File

@ -10,6 +10,8 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
/**
* 惠农通收购商交易明细Mapper接口
*
@ -32,5 +34,7 @@ public interface OriginalHntSgmxMapper extends BaseMapperPlus<OriginalHntSgmx, O
// @DataColumn(key = "userName", value = "create_by")
//})
// List<SysUserExportVo> selectOriginalHntSgmxExportList(@Param(Constants.WRAPPER) Wrapper<OriginalHntSgmx> queryWrapper);
// 批量插入
void batchInsert(@Param("list") Collection<OriginalHntSgmx> list);
}

6
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalHntSgsInfoMapper.java
View File

@ -10,6 +10,9 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
import java.util.List;
/**
* 惠农通收购商签约信息Mapper接口
*
@ -26,6 +29,9 @@ public interface OriginalHntSgsInfoMapper extends BaseMapperPlus<OriginalHntSgsI
return this.selectVoPage(page, queryWrapper);
}
// 批量插入
void batchInsert(@Param("list") Collection<OriginalHntSgsInfo> list);
//@DataPermission({
// @DataColumn(key = "deptName", value = "create_dept"),

5
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalOnlinePaymentMapper.java
View File

@ -10,6 +10,9 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
import java.util.List;
/**
* 网上支付Mapper接口
*
@ -26,6 +29,8 @@ public interface OriginalOnlinePaymentMapper extends BaseMapperPlus<OriginalOnli
return this.selectVoPage(page, queryWrapper);
}
// 批量插入
void batchInsert(@Param("list") Collection<OriginalOnlinePayment> list);
//@DataPermission({
// @DataColumn(key = "deptName", value = "create_dept"),

6
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalTrafficMapper.java
View File

@ -10,6 +10,9 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
import java.util.List;
/**
* 代收交警罚没款明细Mapper接口
*
@ -26,6 +29,9 @@ public interface OriginalTrafficMapper extends BaseMapperPlus<OriginalTraffic, O
return this.selectVoPage(page, queryWrapper);
}
// 批量插入
void batchInsert(@Param("list") Collection<OriginalTraffic> list);
//@DataPermission({
// @DataColumn(key = "deptName", value = "create_dept"),

5
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/mapper/OriginalWaterMapper.java
View File

@ -10,6 +10,8 @@ import org.apache.ibatis.annotations.Param;
import org.dromara.common.mybatis.annotation.DataColumn;
import org.dromara.common.mybatis.annotation.DataPermission;
import java.util.Collection;
/**
* 代收水费Mapper接口
*
@ -32,5 +34,6 @@ public interface OriginalWaterMapper extends BaseMapperPlus<OriginalWater, Origi
// @DataColumn(key = "userName", value = "create_by")
//})
// List<SysUserExportVo> selectOriginalWaterExportList(@Param(Constants.WRAPPER) Wrapper<OriginalWater> queryWrapper);
// 批量插入
void batchInsert(@Param("list") Collection<OriginalWater> list);
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalDianfeiServiceImpl.java
View File

@ -48,7 +48,30 @@ public class OriginalDianfeiServiceImpl implements IOriginalDianfeiService {
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalDianfei> batchList = new ArrayList<>(batchSize);
for (OriginalDianfei item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalEMBankingServiceImpl.java
View File

@ -48,7 +48,30 @@ public class OriginalEMBankingServiceImpl implements IOriginalEMBankingService {
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalEMBanking> batchList = new ArrayList<>(batchSize);
for (OriginalEMBanking item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalGjjPaymentServiceImpl.java
View File

@ -48,7 +48,30 @@ public class OriginalGjjPaymentServiceImpl implements IOriginalGjjPaymentService
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalGjjPayment> batchList = new ArrayList<>(batchSize);
for (OriginalGjjPayment item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalHeatServiceImpl.java
View File

@ -48,7 +48,30 @@ public class OriginalHeatServiceImpl implements IOriginalHeatService {
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalHeat> batchList = new ArrayList<>(batchSize);
for (OriginalHeat item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalHntSgmxServiceImpl.java
View File

@ -49,7 +49,30 @@ public class OriginalHntSgmxServiceImpl implements IOriginalHntSgmxService {
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalHntSgmx> batchList = new ArrayList<>(batchSize);
for (OriginalHntSgmx item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalHntSgsInfoServiceImpl.java
View File

@ -49,7 +49,30 @@ public class OriginalHntSgsInfoServiceImpl implements IOriginalHntSgsInfoService
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalHntSgsInfo> batchList = new ArrayList<>(batchSize);
for (OriginalHntSgsInfo item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalOnlinePaymentServiceImpl.java
View File

@ -48,7 +48,30 @@ public class OriginalOnlinePaymentServiceImpl implements IOriginalOnlinePaymentS
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalOnlinePayment> batchList = new ArrayList<>(batchSize);
for (OriginalOnlinePayment item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalTrafficServiceImpl.java
View File

@ -49,7 +49,30 @@ public class OriginalTrafficServiceImpl implements IOriginalTrafficService {
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalTraffic> batchList = new ArrayList<>(batchSize);
for (OriginalTraffic item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

25
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/original/service/impl/OriginalWaterServiceImpl.java
View File

@ -48,7 +48,30 @@ public class OriginalWaterServiceImpl implements IOriginalWaterService {
if (isUpdateSupport) {
baseMapper.insertOrUpdateBatch(list);
} else {
baseMapper.insertBatch(list);
//baseMapper.insertBatch(list);
/**
* 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式
* 经对比验证,foreach方式效率最高
*
* **/
//由于mybatis的批量方法为伪批量,以下优化为真批量
//SqlHelper与service的注解事务管理冲突,所以此处自行写分批
int batchSize = 1000;//每批1000条
List<OriginalWater> batchList = new ArrayList<>(batchSize);
for (OriginalWater item : list) {
batchList.add(item);
if (batchList.size() == batchSize) {
baseMapper.batchInsert(batchList);
batchList.clear();
}
}
// 处理最后一批不满batchSize的数据
if (!batchList.isEmpty()) {
baseMapper.batchInsert(batchList);
}
}
}

37
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalDianfeiMapper.xml
View File

@ -1,7 +1,40 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalDianfeiMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_dianfei
(
id,
branch_id,
branch_name,
quantity,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.branchId},
#{item.branchName},
#{item.quantity},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

37
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalEMBankingMapper.xml
View File

@ -1,7 +1,40 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalEMBankingMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_enterprise_mobile_banking
(
id,
branch_id,
branch_name,
quantity,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.branchId},
#{item.branchName},
#{item.quantity},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

37
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalGjjPaymentMapper.xml
View File

@ -1,7 +1,40 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalGjjPaymentMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_gjj_payment
(
id,
payment_date,
counterparty_name,
payment_amount,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.paymentDate},
#{item.counterpartyName},
#{item.paymentAmount},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

47
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalHeatMapper.xml
View File

@ -1,7 +1,50 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalHeatMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_heat
(
id,
user_code,
user_address,
fee_type,
payment_amount,
heater_amount,
payment_date,
transaction_id,
order_status,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.userCode},
#{item.userAddress},
#{item.feeType},
#{item.paymentAmount},
#{item.heaterAmount},
#{item.paymentDate},
#{item.transactionId},
#{item.orderStatus},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

58
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalHntSgmxMapper.xml
View File

@ -4,4 +4,62 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalHntSgmxMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_hnt_sgmx
(
id,
order_id,
farmer_name,
buyer_name,
order_status,
settlement_status,
actual_amount,
order_time,
payment_time,
farmer_legal_entity,
farmer_branch,
farmer_branch_name,
buyer_legal_entity,
buyer_branch,
buyer_branch_name,
transaction_no,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.orderId},
#{item.farmerName},
#{item.buyerName},
#{item.orderStatus},
#{item.settlementStatus},
#{item.actualAmount},
#{item.orderTime},
#{item.paymentTime},
#{item.farmerLegalEntity},
#{item.farmerBranch},
#{item.farmerBranchName},
#{item.buyerLegalEntity},
#{item.buyerBranch},
#{item.buyerBranchName},
#{item.transactionNo},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

49
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalHntSgsInfoMapper.xml
View File

@ -1,7 +1,52 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalHntSgsInfoMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_hnt_sgs_info
(
id,
contract_id,
name,
id_card,
account_number,
phone,
status,
legal_entity,
branch_affiliation,
branch_code,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.contractId},
#{item.name},
#{item.idCard},
#{item.accountNumber},
#{item.phone},
#{item.status},
#{item.legalEntity},
#{item.branchAffiliation},
#{item.branchCode},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

37
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalOnlinePaymentMapper.xml
View File

@ -1,7 +1,40 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalOnlinePaymentMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_online_payment
(
id,
branch_id,
branch_name,
quantity,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.branchId},
#{item.branchName},
#{item.quantity},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

45
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalTrafficMapper.xml
View File

@ -1,7 +1,48 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalTrafficMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_traffic
(
id,
branch_name,
payer_name,
payer_account,
penalty_decision_no,
payment_method,
payment_amount,
payment_channel,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.branchName},
#{item.payerName},
#{item.payerAccount},
#{item.penaltyDecisionNo},
#{item.paymentMethod},
#{item.paymentAmount},
#{item.paymentChannel},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>

73
cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/original/OriginalWaterMapper.xml
View File

@ -1,7 +1,76 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.original.mapper.OriginalWaterMapper">
<!--mysql写法,达梦兼容-->
<insert id="batchInsert">
INSERT INTO mps_import_water
(
id,
customer_code,
name,
address,
water_meter_number,
bank_transaction_id,
payment_count,
current_payment_amount,
payment_amount,
water_unit_price,
water_fee,
sewage_unit_price,
sewage_fee,
surcharge_unit_price,
surcharge,
penalty,
total_receivable,
previous_balance,
current_balance,
payment_date,
payment_status,
accounting_status,
import_time,
tenant_id,
create_dept,
create_by,
create_time,
update_by,
update_time
)
VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.customerCode},
#{item.name},
#{item.address},
#{item.waterMeterNumber},
#{item.bankTransactionId},
#{item.paymentCount},
#{item.currentPaymentAmount},
#{item.paymentAmount},
#{item.waterUnitPrice},
#{item.waterFee},
#{item.sewageUnitPrice},
#{item.sewageFee},
#{item.surchargeUnitPrice},
#{item.surcharge},
#{item.penalty},
#{item.totalReceivable},
#{item.previousBalance},
#{item.currentBalance},
#{item.paymentDate},
#{item.paymentStatus},
#{item.accountingStatus},
#{item.importTime},
#{item.tenantId},
#{item.createDept},
#{item.createBy},
#{item.createTime},
#{item.updateBy},
#{item.updateTime}
)
</foreach>
</insert>
</mapper>