|
@@ -1,6 +1,9 @@
|
|
|
package com.ruoyi.business.service.impl;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
+import com.baomidou.mybatisplus.extension.service.IService;
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.ruoyi.business.domain.ZwywBtglLrbtgl;
|
|
|
import com.ruoyi.business.domain.ZwywBtglXmgl;
|
|
|
import com.ruoyi.business.mapper.ZwywBtglLrbtglMapper;
|
|
@@ -8,18 +11,18 @@ import com.ruoyi.business.mapper.ZwywBtglXmglMapper;
|
|
|
import com.ruoyi.business.service.IZwywBtglLrbtglService;
|
|
|
import com.ruoyi.common.core.exception.ServiceException;
|
|
|
import com.ruoyi.common.core.utils.DateUtils;
|
|
|
+import com.ruoyi.common.core.utils.uuid.IdUtils;
|
|
|
import com.ruoyi.common.security.utils.AmountUtils;
|
|
|
import com.ruoyi.common.security.utils.SecurityUtils;
|
|
|
import com.ruoyi.system.api.enums.DataStatus;
|
|
|
import com.ruoyi.system.utils.SubCodeUtil;
|
|
|
import org.apache.commons.lang3.ObjectUtils;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
+import sun.nio.cs.ext.MacArabic;
|
|
|
|
|
|
-import java.util.Arrays;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.Objects;
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
|
* 老人补贴资金受理Service业务层处理
|
|
@@ -28,7 +31,7 @@ import java.util.Objects;
|
|
|
* @date 2022-05-24
|
|
|
*/
|
|
|
@Service
|
|
|
-public class ZwywBtglLrbtglServiceImpl implements IZwywBtglLrbtglService
|
|
|
+public class ZwywBtglLrbtglServiceImpl implements IZwywBtglLrbtglService
|
|
|
{
|
|
|
@Autowired
|
|
|
private ZwywBtglLrbtglMapper zwywBtglLrbtglMapper;
|
|
@@ -177,4 +180,102 @@ public class ZwywBtglLrbtglServiceImpl implements IZwywBtglLrbtglService
|
|
|
return zwywBtglLrbtglMapper.deleteBatchIds(Arrays.asList(ids));
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public String importZwywBtglLrbtgl(List<ZwywBtglLrbtgl> zwywBtglLrbtglList) {
|
|
|
+
|
|
|
+ if (com.ruoyi.common.core.utils.StringUtils.isNull(zwywBtglLrbtglList) || zwywBtglLrbtglList.size() == 0) {
|
|
|
+ throw new ServiceException("导入数据不能为空!");
|
|
|
+ }
|
|
|
+ for (ZwywBtglLrbtgl n:zwywBtglLrbtglList){
|
|
|
+ if (StringUtils.isEmpty(n.getZjhm())) {
|
|
|
+ throw new ServiceException("证件号码不能为空");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //list数据去重
|
|
|
+ Long count = zwywBtglLrbtglList.stream().distinct().count();
|
|
|
+ boolean isRepeat = count < zwywBtglLrbtglList.size();
|
|
|
+ if (isRepeat) {
|
|
|
+ throw new ServiceException("导入的Excel有重复信息,请检查。");
|
|
|
+ }
|
|
|
+ int successNum = 0;
|
|
|
+ int failureNum= 0;
|
|
|
+ StringBuilder successMsg = new StringBuilder();
|
|
|
+ StringBuilder failureMsg = new StringBuilder();
|
|
|
+ for (ZwywBtglLrbtgl z:zwywBtglLrbtglList){
|
|
|
+ //证件号码 证件类型 数据状态 status DataStatus.NORMAL.getCode
|
|
|
+ ZwywBtglLrbtgl one = zwywBtglLrbtglMapper.getZwywBtglLrbtgl(z.getZjlx(),z.getZjhm(),DataStatus.NORMAL.getCode());
|
|
|
+ if (one != null){
|
|
|
+ failureNum++;
|
|
|
+ failureMsg.append("<br/>" + failureNum + "<" + "证件号码:" +z.getZjhm()+ " >已存在,请修改。");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ List<ZwywBtglLrbtgl> insertList = new ArrayList<>();
|
|
|
+ for (int i=0;i<zwywBtglLrbtglList.size();i++){
|
|
|
+ //开始导入
|
|
|
+ ZwywBtglLrbtgl zwywBtglLrbtgl = new ZwywBtglLrbtgl();
|
|
|
+
|
|
|
+ zwywBtglLrbtgl.setId(IdUtils.simpleUUID());
|
|
|
+ zwywBtglLrbtgl.setXm(zwywBtglLrbtglList.get(i).getXm());
|
|
|
+ zwywBtglLrbtgl.setZjlx(zwywBtglLrbtglList.get(i).getZjlx());
|
|
|
+ zwywBtglLrbtgl.setZjhm(zwywBtglLrbtglList.get(i).getZjhm());
|
|
|
+ zwywBtglLrbtgl.setCsrq(zwywBtglLrbtglList.get(i).getCsrq());
|
|
|
+ zwywBtglLrbtgl.setXb(zwywBtglLrbtglList.get(i).getXb());
|
|
|
+ zwywBtglLrbtgl.setGj(zwywBtglLrbtglList.get(i).getGj());
|
|
|
+ zwywBtglLrbtgl.setMz(zwywBtglLrbtglList.get(i).getMz());
|
|
|
+ zwywBtglLrbtgl.setWhcd(zwywBtglLrbtglList.get(i).getWhcd());
|
|
|
+ zwywBtglLrbtgl.setHyzk(zwywBtglLrbtglList.get(i).getHyzk());
|
|
|
+ zwywBtglLrbtgl.setZzmm(zwywBtglLrbtglList.get(i).getZzmm());
|
|
|
+ zwywBtglLrbtgl.setRjsr(zwywBtglLrbtglList.get(i).getRjsr());
|
|
|
+ zwywBtglLrbtgl.setSjhm(zwywBtglLrbtglList.get(i).getSjhm());
|
|
|
+ zwywBtglLrbtgl.setGddh(zwywBtglLrbtglList.get(i).getGddh());
|
|
|
+ zwywBtglLrbtgl.setSxsfbq(zwywBtglLrbtglList.get(i).getSxsfbq());
|
|
|
+ zwywBtglLrbtgl.setBtlx(zwywBtglLrbtglList.get(i).getBtlx());
|
|
|
+ zwywBtglLrbtgl.setFfzq(zwywBtglLrbtglList.get(i).getFfzq());
|
|
|
+ zwywBtglLrbtgl.setXqpglx(zwywBtglLrbtglList.get(i).getXqpglx());
|
|
|
+ zwywBtglLrbtgl.setHjlb(zwywBtglLrbtglList.get(i).getHjlb());
|
|
|
+ zwywBtglLrbtgl.setHjszd(zwywBtglLrbtglList.get(i).getHjszd());
|
|
|
+ zwywBtglLrbtgl.setHjdzms(zwywBtglLrbtglList.get(i).getHjdzms());
|
|
|
+ zwywBtglLrbtgl.setJg(zwywBtglLrbtglList.get(i).getJg());
|
|
|
+ zwywBtglLrbtgl.setXjd(zwywBtglLrbtglList.get(i).getXjd());
|
|
|
+ zwywBtglLrbtgl.setJzdzms(zwywBtglLrbtglList.get(i).getJzdzms());
|
|
|
+ zwywBtglLrbtgl.setCjlb(zwywBtglLrbtglList.get(i).getCjlb());
|
|
|
+ zwywBtglLrbtgl.setCjdj(zwywBtglLrbtglList.get(i).getCjdj());
|
|
|
+ zwywBtglLrbtgl.setCjzh(zwywBtglLrbtglList.get(i).getCjzh());
|
|
|
+ zwywBtglLrbtgl.setSfxschx(zwywBtglLrbtglList.get(i).getSfxschx());
|
|
|
+ zwywBtglLrbtgl.setSfcjsb(zwywBtglLrbtglList.get(i).getSfcjsb());
|
|
|
+ zwywBtglLrbtgl.setSbkh(zwywBtglLrbtglList.get(i).getSbkh());
|
|
|
+ zwywBtglLrbtgl.setYblb(zwywBtglLrbtglList.get(i).getYblb());
|
|
|
+ zwywBtglLrbtgl.setPgdj(zwywBtglLrbtglList.get(i).getPgdj());
|
|
|
+ zwywBtglLrbtgl.setJhrxm(zwywBtglLrbtglList.get(i).getJhrxm());
|
|
|
+ zwywBtglLrbtgl.setJhrsjhm(zwywBtglLrbtglList.get(i).getJhrsjhm());
|
|
|
+ zwywBtglLrbtgl.setJhrgx(zwywBtglLrbtglList.get(i).getJhrgx());
|
|
|
+ zwywBtglLrbtgl.setKhyh(zwywBtglLrbtglList.get(i).getKhyh());
|
|
|
+ zwywBtglLrbtgl.setYhzh(zwywBtglLrbtglList.get(i).getYhzh());
|
|
|
+ zwywBtglLrbtgl.setKhmc(zwywBtglLrbtglList.get(i).getKhmc());
|
|
|
+ zwywBtglLrbtgl.setDbrxm(zwywBtglLrbtglList.get(i).getDbrxm());
|
|
|
+ zwywBtglLrbtgl.setDbrdh(zwywBtglLrbtglList.get(i).getDbrdh());
|
|
|
+ zwywBtglLrbtgl.setSljg(zwywBtglLrbtglList.get(i).getSljg());
|
|
|
+ zwywBtglLrbtgl.setSlyj(zwywBtglLrbtglList.get(i).getSlyj());
|
|
|
+ zwywBtglLrbtgl.setShjg(zwywBtglLrbtglList.get(i).getShjg());
|
|
|
+ zwywBtglLrbtgl.setShyj(zwywBtglLrbtglList.get(i).getShyj());
|
|
|
+ zwywBtglLrbtgl.setSpjg(zwywBtglLrbtglList.get(i).getSpjg());
|
|
|
+ zwywBtglLrbtgl.setShyj(zwywBtglLrbtglList.get(i).getShyj());
|
|
|
+ insertList.add(zwywBtglLrbtgl);
|
|
|
+ successNum++;
|
|
|
+ successMsg.append("<br/>"+ successNum + "、姓名: " + zwywBtglLrbtglList.get(i).getXm() + " 导入成功");
|
|
|
+ }
|
|
|
+ if (failureNum > 0) {
|
|
|
+ failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
|
|
|
+ throw new ServiceException(failureMsg.toString());
|
|
|
+ }else
|
|
|
+ {
|
|
|
+ successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
|
|
|
+ }
|
|
|
+ if (insertList.size()>0){
|
|
|
+ zwywBtglLrbtglMapper.saveBaths(insertList);
|
|
|
+ }
|
|
|
+ return successMsg.toString();
|
|
|
+ }
|
|
|
+
|
|
|
}
|