|
@@ -3,7 +3,14 @@ package com.zjrs.zwnw.zj.blo.impl;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
+import com.zjrs.appcomm.template.excel.ExcelTemplate;
|
|
|
|
|
+import com.zjrs.appcomm.template.excel.builder.ImportDefinition;
|
|
|
|
|
+import com.zjrs.appcomm.template.excel.mapper.DynamicHeaderMapper;
|
|
|
|
|
+import com.zjrs.appcomm.template.excel.mapper.RowMapper;
|
|
|
|
|
+import com.zjrs.zwnw.jbxxgl.dto.GrjbxxDTO;
|
|
|
|
|
+import com.zjrs.zwnw.jbxxgl.dto.GrxxDTO;
|
|
|
import io.micrometer.core.instrument.util.StringUtils;
|
|
import io.micrometer.core.instrument.util.StringUtils;
|
|
|
|
|
+import org.apache.poi.ss.usermodel.Cell;
|
|
|
import org.mohrss.leaf.core.framework.domain.blo.impl.BLOImpl;
|
|
import org.mohrss.leaf.core.framework.domain.blo.impl.BLOImpl;
|
|
|
import org.mohrss.leaf.core.framework.persistens.PageResult;
|
|
import org.mohrss.leaf.core.framework.persistens.PageResult;
|
|
|
import org.mohrss.leaf.core.framework.persistens.PageUtil;
|
|
import org.mohrss.leaf.core.framework.persistens.PageUtil;
|
|
@@ -21,6 +28,7 @@ import com.zjrs.zwnw.zj.dto.*;
|
|
|
import com.zjrs.zwnw.zj.entity.*;
|
|
import com.zjrs.zwnw.zj.entity.*;
|
|
|
import com.zjrs.zwnw.zj.po.*;
|
|
import com.zjrs.zwnw.zj.po.*;
|
|
|
import com.zjrs.zwnw.zj.util.FileUtil;
|
|
import com.zjrs.zwnw.zj.util.FileUtil;
|
|
|
|
|
+import org.mohrss.leaf.core.framework.util.CurrentUser;
|
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -67,6 +75,9 @@ public class GccrcBLOImpl extends BLOImpl implements GccrcBLO {
|
|
|
@Resource
|
|
@Resource
|
|
|
private GrxxglBLO grxxglBLO;
|
|
private GrxxglBLO grxxglBLO;
|
|
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private ExcelTemplate excelTemplate;
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public GccrcInfoDTO getGccrcInfo(GccrcQueryByIdDTO dto) {
|
|
public GccrcInfoDTO getGccrcInfo(GccrcQueryByIdDTO dto) {
|
|
|
return gccrcMapper.getGccrcInfo(dto);
|
|
return gccrcMapper.getGccrcInfo(dto);
|
|
@@ -281,13 +292,404 @@ public class GccrcBLOImpl extends BLOImpl implements GccrcBLO {
|
|
|
|
|
|
|
|
Map<String, String> fieldsMapper = new HashMap<String, String>();
|
|
Map<String, String> fieldsMapper = new HashMap<String, String>();
|
|
|
fieldsMapper.put("序号", "xh");
|
|
fieldsMapper.put("序号", "xh");
|
|
|
|
|
+ fieldsMapper.put("姓名", "aac003");
|
|
|
|
|
+ fieldsMapper.put("国籍", "aac161");
|
|
|
|
|
+ fieldsMapper.put("证件类型", "aac058");
|
|
|
|
|
+ fieldsMapper.put("证件号码", "aac147");
|
|
|
|
|
+ fieldsMapper.put("性别", "aac004");
|
|
|
|
|
+ fieldsMapper.put("民族", "aac005");
|
|
|
|
|
+ fieldsMapper.put("学历", "aac011");
|
|
|
|
|
+ fieldsMapper.put("认定主要依据", "rdzyyj");
|
|
|
|
|
+ fieldsMapper.put("认定湛江人才卡类型", "rcklx");
|
|
|
|
|
+ fieldsMapper.put("职称专业名称", "zczymc");
|
|
|
|
|
+ fieldsMapper.put("单位名称", "dwmc");
|
|
|
|
|
+ fieldsMapper.put("单位所在县市区", "gwszxsq");
|
|
|
|
|
+ fieldsMapper.put("劳动合同期限", "ldhtqx");
|
|
|
|
|
+ fieldsMapper.put("劳动合同截止期限\n" +
|
|
|
|
|
+ "(精确到日)", "ldhtjzrq");
|
|
|
|
|
+ fieldsMapper.put("签发日期\n" +
|
|
|
|
|
+ "(精确到日)", "qfsj");
|
|
|
|
|
+ fieldsMapper.put("有效日期\n" +
|
|
|
|
|
+ "(精确到日)", "yxrq");
|
|
|
|
|
+ fieldsMapper.put("备注(原认定类别)", "bz");
|
|
|
fieldsMapper.put("手机号码", "aac067");
|
|
fieldsMapper.put("手机号码", "aac067");
|
|
|
fieldsMapper.put("人才卡号码", "rckhm");
|
|
fieldsMapper.put("人才卡号码", "rckhm");
|
|
|
fieldsMapper.put("公示期数", "gsqs");
|
|
fieldsMapper.put("公示期数", "gsqs");
|
|
|
fieldsMapper.put("申请类型", "sqlx");
|
|
fieldsMapper.put("申请类型", "sqlx");
|
|
|
|
|
|
|
|
|
|
+ DynamicHeaderMapper headerMapper = new DynamicHeaderMapper(fieldsMapper);
|
|
|
|
|
+
|
|
|
List<String> rowMapperList = new ArrayList<>();
|
|
List<String> rowMapperList = new ArrayList<>();
|
|
|
-
|
|
|
|
|
|
|
+ RowMapper<GccrcPO> rowMapper = new RowMapper<GccrcPO>() {
|
|
|
|
|
+ //重写mapper方法实现业务校验、保存等操作
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void mapper(GccrcPO gccrcPO, Map<String, Object> valuesMap, Map<String, Cell> cellMap, int dataIndex, int rowIndex) {
|
|
|
|
|
+ StringBuilder builder = new StringBuilder();
|
|
|
|
|
+ //检查导入是否空模板
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac003")))) {
|
|
|
|
|
+ rowMapperList.add(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ }
|
|
|
|
|
+ //字段校验
|
|
|
|
|
+ validationRule(gccrcPO, valuesMap, aa10RowSet, builder);
|
|
|
|
|
+ /*一、人才卡号码已存在,则根据“证件类型+证件号码+人才卡号码”查找是否存在数据:
|
|
|
|
|
+ (1)若存在数据,则允许导入,做覆盖更新处理。
|
|
|
|
|
+ (2)若不存在数据,则不允许导入,导入失败原因:该人才卡号码在系统中已被其他人员使用,不允许导入。
|
|
|
|
|
+ 二、人才卡号码不存在,则根据“证件类型+证件号码”查找是否存在数据:
|
|
|
|
|
+ (1)若存在,则允许导入,做覆盖更新处理。
|
|
|
|
|
+ (2)若不存在,则新增导入数据。*/
|
|
|
|
|
+ if (valuesMap.get("aac058Code") != null) {
|
|
|
|
|
+ QueryWrapper<GccrcQfPO> queryWrapper = new QueryWrapper<>();
|
|
|
|
|
+ queryWrapper.eq("rckhm", objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ int cnt = Math.toIntExact(gccrcQfMapper.selectCount(queryWrapper));
|
|
|
|
|
+ if (cnt > 0) {
|
|
|
|
|
+ queryWrapper.eq("AAC058", valuesMap.get("aac058Code"));
|
|
|
|
|
+ queryWrapper.eq("AAC147", objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ cnt = Math.toIntExact(gccrcQfMapper.selectCount(queryWrapper));
|
|
|
|
|
+ if (cnt == 0) {
|
|
|
|
|
+ builder.append("该人才卡号码在系统中已被其他人员使用,不允许导入。");
|
|
|
|
|
+ }
|
|
|
|
|
+ AC01DTO dto = new AC01DTO();
|
|
|
|
|
+ dto.setAac058(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ dto.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ VSAc01PO vsAc01PO = queryRyxx(dto);
|
|
|
|
|
+ if(vsAc01PO!=null){
|
|
|
|
|
+ QueryWrapper<GccrcPO> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
|
+ queryWrapper1.eq("ztid", vsAc01PO.getZtid());
|
|
|
|
|
+ queryWrapper1.eq("rckhm", objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ cnt = Math.toIntExact(gccrcMapper.selectCount(queryWrapper1));
|
|
|
|
|
+ if (cnt > 1) {
|
|
|
|
|
+ builder.append("高层次人才信息库中同一证件号码存在多条记录;");
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }else{
|
|
|
|
|
+ AC01DTO dto = new AC01DTO();
|
|
|
|
|
+ dto.setAac058(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ dto.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ VSAc01PO vsAc01PO = queryRyxx(dto);
|
|
|
|
|
+ if(vsAc01PO!=null){
|
|
|
|
|
+ QueryWrapper<GccrcPO> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
|
+ queryWrapper1.eq("ztid", vsAc01PO.getZtid());
|
|
|
|
|
+ cnt = Math.toIntExact(gccrcMapper.selectCount(queryWrapper1));
|
|
|
|
|
+ if (cnt > 1) {
|
|
|
|
|
+ builder.append("高层次人才信息库中同一证件号码存在多条记录;");
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ String builderStr = builder.toString();
|
|
|
|
|
+ if (builderStr.length() == 0) {
|
|
|
|
|
+ //导入成功
|
|
|
|
|
+ //1、插入导入成功记录
|
|
|
|
|
+ RsZjGccrcDrlogPO rsZjGccrcDrlogPO = new RsZjGccrcDrlogPO();
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDrph(drph);
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDrjg("1");
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac003(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac161(objToStr(valuesMap.get("aac161")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac058(objToStr(valuesMap.get("aac058")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac004(objToStr(valuesMap.get("aac004")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac005(objToStr(valuesMap.get("aac005")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac011(objToStr(valuesMap.get("aac011")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRdzyyj(objToStr(valuesMap.get("rdzyyj")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRcklx(objToStr(valuesMap.get("rcklx")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setZczymc(objToStr(valuesMap.get("zczymc")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDwmc(objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setGwszxsq(objToStr(valuesMap.get("gwszxsq")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setLdhtqx(objToStr(valuesMap.get("ldhtqx")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setLdhtjzrq(objToStr(valuesMap.get("ldhtjzrq")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setQfsj(objToStr(valuesMap.get("qfsj")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setYxrq(objToStr(valuesMap.get("yxrq")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setBz(objToStr(valuesMap.get("bz")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac067(objToStr(valuesMap.get("aac067")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRckhm(objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setGsqs(objToStr(valuesMap.get("gsqs")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setSqlx(objToStr(valuesMap.get("sqlx")));
|
|
|
|
|
+ //插入日志
|
|
|
|
|
+ rsZjGccrcDrlogMapper.insert(rsZjGccrcDrlogPO);
|
|
|
|
|
+ //创建/最近修改人、创建/最近修改时间、创建/最近修改机构分别取值操作导入的账号姓名、导入时间、操作导入的账号所属组织机构
|
|
|
|
|
+ CurrentUser currentUser = getCurrentUser();
|
|
|
|
|
+ String userid = currentUser.getUserid() == null ? "" : currentUser.getUserid().trim();
|
|
|
|
|
+ //操作时间
|
|
|
|
|
+ Date t = new Date();
|
|
|
|
|
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
+ //2.判断基本信息是否存在,存在进行更新,不存在则插入
|
|
|
|
|
+ AC01DTO dto = new AC01DTO();
|
|
|
|
|
+ dto.setAac058(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ dto.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ VSAc01PO vsAc01PO = queryRyxx(dto);
|
|
|
|
|
+ String ztid = "";
|
|
|
|
|
+ //学历对照
|
|
|
|
|
+ String aac011Code=objToStr(valuesMap.get("aac011Code"));
|
|
|
|
|
+ if(aac011Code.equals("10")){
|
|
|
|
|
+ aac011Code="11";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (vsAc01PO != null) {
|
|
|
|
|
+ //修改
|
|
|
|
|
+ ztid = vsAc01PO.getZtid();
|
|
|
|
|
+ GrjbxxDTO grjbxxDTO = new GrjbxxDTO();
|
|
|
|
|
+ grjbxxDTO.setAac058(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ grjbxxDTO.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ grjbxxDTO.setAac003(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ grjbxxDTO.setAac161(objToStr(valuesMap.get("aac161Code")));
|
|
|
|
|
+ grjbxxDTO.setAac004(objToStr(valuesMap.get("aac004Code")));
|
|
|
|
|
+ grjbxxDTO.setAac005(objToStr(valuesMap.get("aac005Code")));
|
|
|
|
|
+ grjbxxDTO.setAac011(aac011Code);
|
|
|
|
|
+ grjbxxDTO.setAac067(objToStr(valuesMap.get("aac067")));
|
|
|
|
|
+ grjbxxDTO.setZtid(ztid);
|
|
|
|
|
+ ztid = grxxglBLO.saveGrjbxx(grjbxxDTO);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ //新增
|
|
|
|
|
+ GrxxDTO grxxDTO = new GrxxDTO();
|
|
|
|
|
+ grxxDTO.setAac058(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ grxxDTO.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ grxxDTO.setAac003(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ grxxDTO.setAac161(objToStr(valuesMap.get("aac161Code")));
|
|
|
|
|
+ grxxDTO.setAac004(objToStr(valuesMap.get("aac004Code")));
|
|
|
|
|
+ grxxDTO.setAac005(objToStr(valuesMap.get("aac005Code")));
|
|
|
|
|
+ grxxDTO.setAac011(aac011Code);
|
|
|
|
|
+ grxxDTO.setAac067(objToStr(valuesMap.get("aac067")));
|
|
|
|
|
+ ztid = grxxglBLO.saveGrxx(grxxDTO);
|
|
|
|
|
+ }
|
|
|
|
|
+ //3.判断是否存在高层次人才认定表数据,若存在则更新,不存在则插入
|
|
|
|
|
+ String rsZjGccrcLsh = UUID.randomUUID().toString().replaceAll("-", "");
|
|
|
|
|
+ QueryWrapper<GccrcPO> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
|
+ queryWrapper1.eq("rckhm", objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ int cnt = Math.toIntExact(gccrcMapper.selectCount(queryWrapper1));
|
|
|
|
|
+ GccrcPO gccrcPO1 = new GccrcPO();
|
|
|
|
|
+ gccrcPO1.setRsZjGccrcLsh(rsZjGccrcLsh);
|
|
|
|
|
+ gccrcPO1.setZtid(ztid);
|
|
|
|
|
+ gccrcPO1.setBz(objToStr(valuesMap.get("bz")));
|
|
|
|
|
+ gccrcPO1.setRdzyyj(objToStr(valuesMap.get("rdzyyj")));
|
|
|
|
|
+ gccrcPO1.setRcklx(objToStr(valuesMap.get("rcklxCode")));
|
|
|
|
|
+ gccrcPO1.setZczymc(objToStr(valuesMap.get("zczymc")));
|
|
|
|
|
+ gccrcPO1.setDwmc(objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ gccrcPO1.setGwszxsq(objToStr(valuesMap.get("gwszxsqCode")));
|
|
|
|
|
+ gccrcPO1.setLdhtqx(objToStr(valuesMap.get("ldhtqxCode")));
|
|
|
|
|
+ gccrcPO1.setLdhtjzrq(objToStr(valuesMap.get("ldhtjzrqStr")));
|
|
|
|
|
+ gccrcPO1.setQfsj(objToStr(valuesMap.get("qfsjStr")));
|
|
|
|
|
+ gccrcPO1.setYxrq(objToStr(valuesMap.get("yxrqStr")));
|
|
|
|
|
+ gccrcPO1.setRckhm(objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ gccrcPO1.setGsqs(objToStr(valuesMap.get("gsqs")));
|
|
|
|
|
+ gccrcPO1.setSqlx(objToStr(valuesMap.get("sqlxCode")));
|
|
|
|
|
+ gccrcPO1.setXl(objToStr(valuesMap.get("aac011Code")));
|
|
|
|
|
+ gccrcPO1.setQfzt("1");
|
|
|
|
|
+ gccrcPO1.setRckzt("1");
|
|
|
|
|
+ if (cnt == 0) {
|
|
|
|
|
+ queryWrapper1 = new QueryWrapper<>();
|
|
|
|
|
+ queryWrapper1.eq("ztid", ztid);
|
|
|
|
|
+ GccrcPO gccrcPO2=gccrcMapper.selectOne(queryWrapper1);
|
|
|
|
|
+ if(gccrcPO2==null){
|
|
|
|
|
+ //新增
|
|
|
|
|
+ gccrcMapper.insert(gccrcPO1);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ //更新
|
|
|
|
|
+ rsZjGccrcLsh=gccrcPO2.getRsZjGccrcLsh();
|
|
|
|
|
+ UpdateWrapper<GccrcPO> updateWrapper = new UpdateWrapper<>();
|
|
|
|
|
+ updateWrapper.eq("ztid", ztid);
|
|
|
|
|
+ updateWrapper.eq("rs_zj_gccrc_lsh", rsZjGccrcLsh);
|
|
|
|
|
+ gccrcPO1.setRsZjGccrcLsh(rsZjGccrcLsh);
|
|
|
|
|
+ gccrcMapper.update(gccrcPO1, updateWrapper);
|
|
|
|
|
+ }
|
|
|
|
|
+ } else {
|
|
|
|
|
+ queryWrapper1.eq("ztid", ztid);
|
|
|
|
|
+ GccrcPO gccrcPO2=gccrcMapper.selectOne(queryWrapper1);
|
|
|
|
|
+ if(gccrcPO2!=null){
|
|
|
|
|
+ //更新
|
|
|
|
|
+ UpdateWrapper<GccrcPO> updateWrapper = new UpdateWrapper<>();
|
|
|
|
|
+ updateWrapper.eq("ztid", ztid);
|
|
|
|
|
+ updateWrapper.eq("rckhm", objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ rsZjGccrcLsh=gccrcPO2.getRsZjGccrcLsh();
|
|
|
|
|
+ updateWrapper.eq("rs_zj_gccrc_lsh", rsZjGccrcLsh);
|
|
|
|
|
+ gccrcPO1.setRsZjGccrcLsh(rsZjGccrcLsh);
|
|
|
|
|
+ gccrcMapper.update(gccrcPO1, updateWrapper);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ //4.判断签发记录是否存在,若数据一样,则不插入
|
|
|
|
|
+ String yxrq=null;
|
|
|
|
|
+ try{
|
|
|
|
|
+ Date d = new SimpleDateFormat("yyyy-MM-dd").parse(objToStr(valuesMap.get("yxrqStr")));
|
|
|
|
|
+ yxrq=new SimpleDateFormat("yyyy年MM月dd日").format(d.getTime());
|
|
|
|
|
+ }catch(Exception ex){
|
|
|
|
|
+ ex.printStackTrace();
|
|
|
|
|
+ }
|
|
|
|
|
+ QueryWrapper<GccrcQfPO> queryWrapper = new QueryWrapper<>();
|
|
|
|
|
+ queryWrapper.eq("rckhm", objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ queryWrapper.eq("AAC161", objToStr(valuesMap.get("aac161Code")));
|
|
|
|
|
+ queryWrapper.eq("AAC003", objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ queryWrapper.eq("AAC147", objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ queryWrapper.eq("RCKLX", objToStr(valuesMap.get("rcklxCode")));
|
|
|
|
|
+ queryWrapper.eq("DWMC", objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ queryWrapper.eq("YXRQ", yxrq);
|
|
|
|
|
+ queryWrapper.eq("AAC058", valuesMap.get("aac058Code"));
|
|
|
|
|
+ if (StringUtils.isNotBlank(userid)) {
|
|
|
|
|
+ queryWrapper.eq("qfr", userid);
|
|
|
|
|
+ }
|
|
|
|
|
+ queryWrapper.eq("qfsj", objToStr(valuesMap.get("qfsjStr")));
|
|
|
|
|
+ cnt = Math.toIntExact(gccrcQfMapper.selectCount(queryWrapper));
|
|
|
|
|
+ if (cnt == 0) {
|
|
|
|
|
+ GccrcQfPO gccrcQfPO = new GccrcQfPO();
|
|
|
|
|
+ gccrcQfPO.setRsZjGccrcLsh(rsZjGccrcLsh);
|
|
|
|
|
+ gccrcQfPO.setDwmc(objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ gccrcQfPO.setGj(objToStr(valuesMap.get("aac161Code")));
|
|
|
|
|
+ gccrcQfPO.setQfr(userid);
|
|
|
|
|
+ gccrcQfPO.setQfsj(objToStr(valuesMap.get("qfsjStr")));
|
|
|
|
|
+ gccrcQfPO.setRckhm(objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ gccrcQfPO.setRcklx(objToStr(valuesMap.get("rcklxCode")));
|
|
|
|
|
+ gccrcQfPO.setXm(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ gccrcQfPO.setZjlx(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ gccrcQfPO.setZjhm(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ gccrcQfPO.setYxbz("1");
|
|
|
|
|
+ gccrcQfPO.setYxrq(yxrq);
|
|
|
|
|
+ gccrcQfPO.setGsqs(objToStr(valuesMap.get("gsqs")));
|
|
|
|
|
+
|
|
|
|
|
+ //签发时把以前的改成0
|
|
|
|
|
+ UpdateWrapper<GccrcQfPO> updateQfWrapper=new UpdateWrapper<>();
|
|
|
|
|
+ updateQfWrapper.eq("rs_zj_gccrc_lsh",rsZjGccrcLsh);
|
|
|
|
|
+ GccrcQfPO qfPO=new GccrcQfPO();
|
|
|
|
|
+ qfPO.setYxbz("0");
|
|
|
|
|
+ gccrcQfMapper.update(qfPO,updateQfWrapper);
|
|
|
|
|
+
|
|
|
|
|
+ gccrcQfMapper.insert(gccrcQfPO);
|
|
|
|
|
+ }else{
|
|
|
|
|
+ //更新签发信息
|
|
|
|
|
+ GccrcQfPO gccrcQfPO = new GccrcQfPO();
|
|
|
|
|
+ gccrcQfPO.setRsZjGccrcLsh(rsZjGccrcLsh);
|
|
|
|
|
+ gccrcQfPO.setDwmc(objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ gccrcQfPO.setGj(objToStr(valuesMap.get("aac161Code")));
|
|
|
|
|
+ gccrcQfPO.setQfr(userid);
|
|
|
|
|
+ gccrcQfPO.setQfsj(objToStr(valuesMap.get("qfsjStr")));
|
|
|
|
|
+ gccrcQfPO.setRckhm(objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ gccrcQfPO.setRcklx(objToStr(valuesMap.get("rcklxCode")));
|
|
|
|
|
+ gccrcQfPO.setXm(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ gccrcQfPO.setZjlx(objToStr(valuesMap.get("aac058Code")));
|
|
|
|
|
+ gccrcQfPO.setZjhm(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ gccrcQfPO.setYxbz("1");
|
|
|
|
|
+ gccrcQfPO.setYxrq(yxrq);
|
|
|
|
|
+ gccrcQfPO.setGsqs(objToStr(valuesMap.get("gsqs")));
|
|
|
|
|
+ UpdateWrapper<GccrcQfPO> updateWrapper=new UpdateWrapper<>();
|
|
|
|
|
+ updateWrapper.eq("rckhm", objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ updateWrapper.eq("AAC161", objToStr(valuesMap.get("aac161Code")));
|
|
|
|
|
+ updateWrapper.eq("AAC003", objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ updateWrapper.eq("AAC147", objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ updateWrapper.eq("RCKLX", objToStr(valuesMap.get("rcklxCode")));
|
|
|
|
|
+ updateWrapper.eq("DWMC", objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ updateWrapper.eq("YXRQ", yxrq);
|
|
|
|
|
+ updateWrapper.eq("AAC058", valuesMap.get("aac058Code"));
|
|
|
|
|
+ if (StringUtils.isNotBlank(userid)) {
|
|
|
|
|
+ updateWrapper.eq("qfr", userid);
|
|
|
|
|
+ }
|
|
|
|
|
+ updateWrapper.eq("qfsj", objToStr(valuesMap.get("qfsjStr")));
|
|
|
|
|
+ updateWrapper.eq("rs_zj_gccrc_lsh", rsZjGccrcLsh);
|
|
|
|
|
+ gccrcQfMapper.update(gccrcQfPO,updateWrapper);
|
|
|
|
|
+ }
|
|
|
|
|
+ } else {
|
|
|
|
|
+ //导入失败
|
|
|
|
|
+ RsZjGccrcDrlogPO rsZjGccrcDrlogPO = new RsZjGccrcDrlogPO();
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDrph(drph);
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDrjg("0");
|
|
|
|
|
+ rsZjGccrcDrlogPO.setSbyy(builderStr);
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac003(objToStr(valuesMap.get("aac003")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac161(objToStr(valuesMap.get("aac161")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac058(objToStr(valuesMap.get("aac058")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac147(objToStr(valuesMap.get("aac147")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac004(objToStr(valuesMap.get("aac004")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac005(objToStr(valuesMap.get("aac005")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac011(objToStr(valuesMap.get("aac011")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRdzyyj(objToStr(valuesMap.get("rdzyyj")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRcklx(objToStr(valuesMap.get("rcklx")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setZczymc(objToStr(valuesMap.get("zczymc")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDwmc(objToStr(valuesMap.get("dwmc")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setGwszxsq(objToStr(valuesMap.get("gwszxsq")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setLdhtqx(objToStr(valuesMap.get("ldhtqx")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setLdhtjzrq(objToStr(valuesMap.get("ldhtjzrq")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setQfsj(objToStr(valuesMap.get("qfsj")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setYxrq(objToStr(valuesMap.get("yxrq")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setBz(objToStr(valuesMap.get("bz")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac067(objToStr(valuesMap.get("aac067")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRckhm(objToStr(valuesMap.get("rckhm")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setGsqs(objToStr(valuesMap.get("gsqs")));
|
|
|
|
|
+ rsZjGccrcDrlogPO.setSqlx(objToStr(valuesMap.get("sqlx")));
|
|
|
|
|
+
|
|
|
|
|
+ if (StringUtils.isNotBlank(builderStr) && getLength(builderStr) > 4000) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setSbyy(builderStr.substring(0, 2000));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac161"))) && getLength(objToStr(valuesMap.get("aac161"))) > 30) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac161(objToStr(valuesMap.get("aac161")).substring(0, 15));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac058"))) && getLength(objToStr(valuesMap.get("aac058"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac058(objToStr(valuesMap.get("aac058")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac147"))) && getLength(objToStr(valuesMap.get("aac147"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac147(objToStr(valuesMap.get("aac147")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac003"))) && getLength(objToStr(valuesMap.get("aac003"))) > 25) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac003(objToStr(valuesMap.get("aac003")).substring(0, 12));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac004"))) && getLength(objToStr(valuesMap.get("aac004"))) > 10) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac004(objToStr(valuesMap.get("aac004")).substring(0, 5));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac005"))) && getLength(objToStr(valuesMap.get("aac005"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac005(objToStr(valuesMap.get("aac005")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac011"))) && getLength(objToStr(valuesMap.get("aac011"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac011(objToStr(valuesMap.get("aac011")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("rdzyyj"))) && getLength(objToStr(valuesMap.get("rdzyyj"))) > 4000) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRdzyyj(objToStr(valuesMap.get("rdzyyj")).substring(0, 2000));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("rcklx"))) && getLength(objToStr(valuesMap.get("rcklx"))) > 30) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRcklx(objToStr(valuesMap.get("rcklx")).substring(0, 15));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("zczymc"))) && getLength(objToStr(valuesMap.get("zczymc"))) > 200) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setZczymc(objToStr(valuesMap.get("zczymc")).substring(0, 100));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("dwmc"))) && getLength(objToStr(valuesMap.get("dwmc"))) > 100) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setDwmc(objToStr(valuesMap.get("dwmc")).substring(0, 50));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("gwszxsq"))) && getLength(objToStr(valuesMap.get("gwszxsq"))) > 100) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setGwszxsq(objToStr(valuesMap.get("gwszxsq")).substring(0, 50));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("ldhtqx"))) && getLength(objToStr(valuesMap.get("ldhtqx"))) > 30) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setLdhtqx(objToStr(valuesMap.get("ldhtqx")).substring(0, 15));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("bz"))) && getLength(objToStr(valuesMap.get("bz"))) > 4000) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setBz(objToStr(valuesMap.get("bz")).substring(0, 2000));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("ldhtjzrq"))) && getLength(objToStr(valuesMap.get("ldhtjzrq"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setLdhtjzrq(objToStr(valuesMap.get("ldhtjzrq")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("qfsj"))) && getLength(objToStr(valuesMap.get("qfsj"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setQfsj(objToStr(valuesMap.get("qfsj")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("yxrq"))) && getLength(objToStr(valuesMap.get("yxrq"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setYxrq(objToStr(valuesMap.get("yxrq")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("aac067"))) && getLength(objToStr(valuesMap.get("aac067"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setAac067(objToStr(valuesMap.get("aac067")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("rckhm"))) && getLength(objToStr(valuesMap.get("rckhm"))) > 20) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setRckhm(objToStr(valuesMap.get("rckhm")).substring(0, 10));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("gsqs"))) && getLength(objToStr(valuesMap.get("gsqs"))) > 50) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setGsqs(objToStr(valuesMap.get("gsqs")).substring(0, 25));
|
|
|
|
|
+ }
|
|
|
|
|
+ if (StringUtils.isNotBlank(objToStr(valuesMap.get("sqlx"))) && getLength(objToStr(valuesMap.get("sqlx"))) > 30) {
|
|
|
|
|
+ rsZjGccrcDrlogPO.setSqlx(objToStr(valuesMap.get("sqlx")).substring(0, 15));
|
|
|
|
|
+ }
|
|
|
|
|
+ rsZjGccrcDrlogMapper.insert(rsZjGccrcDrlogPO);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ };
|
|
|
|
|
+ ImportDefinition<?, GccrcPO> importDefinition = ImportDefinition.builder(null, GccrcPO.class)
|
|
|
|
|
+ .headerRowIndex(0)
|
|
|
|
|
+ .headerRowCount(1)
|
|
|
|
|
+ .headerMapper(headerMapper)
|
|
|
|
|
+ .dataRowIndex(1)
|
|
|
|
|
+ .sheet(is, "高层次人才数据")
|
|
|
|
|
+ .rowMapper(rowMapper)//实现自己的rowMapper方法
|
|
|
|
|
+ .build();
|
|
|
|
|
+ excelTemplate.importFile(importDefinition);//每行数据都会进入rowMapper
|
|
|
if (rowMapperList == null || rowMapperList.size() == 0) {
|
|
if (rowMapperList == null || rowMapperList.size() == 0) {
|
|
|
resultMap.put("code", "1");
|
|
resultMap.put("code", "1");
|
|
|
resultMap.put("msg", "导入失败,请检查导入内容是否正确。");
|
|
resultMap.put("msg", "导入失败,请检查导入内容是否正确。");
|