qt
/
weaver-hrm-salary
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'remotes/origin/feature/230702-非系统人员导入功能' into release/2.9.3.2308.01

This commit is contained in:
sy 2023-08-04 15:26:24 +08:00
parent 4048d0998c 07eb966c18
commit 8c9049f1f7
8 changed files with 476 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/com/engine/salary/entity/extemp/param/ExtEmpImportParam.java Normal file
View File

@ -0,0 +1,22 @@
package com.engine.salary.entity.extemp.param;
import com.engine.salary.util.valid.DataCheck;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @Author: sy
* @Description: 非系统人员导入参数
* @Date: 2023/7/26
**/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ExtEmpImportParam {
//上传文件id
@DataCheck(require = true,message = "imageId为空")
String imageId;
}

5
src/com/engine/salary/entity/hrm/DeptInfo.java
View File

@ -25,4 +25,9 @@ public class DeptInfo {
* 名称
*/
private String name;
/**
* 所属分部id
*/
private Long subcompanyid1;
}

15
src/com/engine/salary/mapper/datacollection/EmployMapper.java
View File

@ -87,4 +87,19 @@ public interface EmployMapper {
List<HrmInfoDTO> listHrmInfoByIdAndName(@Param("param") HrmQueryParam param);
/**
* 根据部门名称查询部门
*/
List<DeptInfo> getDeptInfosByName(String name);
/**
* 根据分部名称查询分部
*/
List<SubCompanyInfo> getSubCompanyInfosByName(String name);
/**
* 根据部门id查询部门
*/
DeptInfo getDeptInfoById(Long id);
}

22
src/com/engine/salary/mapper/datacollection/EmployMapper.xml
View File

@ -350,4 +350,26 @@
</if>
</select>
<select id="getDeptInfosByName" resultType="com.engine.salary.entity.hrm.DeptInfo">
select d.departmentname as name,
d.id as id,
d.subcompanyid1 as subcompanyid1
from hrmdepartment d
where d.departmentname = #{name}
</select>
<select id="getSubCompanyInfosByName" resultType="com.engine.salary.entity.hrm.SubCompanyInfo">
select d.subcompanyname as name,
d.id as id
from hrmsubcompany d
where d.subcompanyname = #{name}
</select>
<select id="getDeptInfoById" resultType="com.engine.salary.entity.hrm.DeptInfo">
select d.departmentname as name,
d.id as id,
d.subcompanyid1 as subcompanyid1
from hrmdepartment d
where d.id = #{id}
</select>
</mapper>

9
src/com/engine/salary/service/ExtEmpService.java
View File

@ -1,14 +1,17 @@
package com.engine.salary.service;
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
import com.engine.salary.entity.extemp.param.ExtEmpImportParam;
import com.engine.salary.entity.extemp.param.ExtEmpQueryParam;
import com.engine.salary.entity.extemp.param.ExtEmpSaveParam;
import com.engine.salary.entity.extemp.po.ExtEmpPO;
import com.engine.salary.entity.salarysob.param.SalarySobRangeEmpQueryParam;
import com.engine.salary.util.page.PageInfo;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import java.util.Collection;
import java.util.List;
import java.util.Map;
public interface ExtEmpService {
@ -45,4 +48,10 @@ public interface ExtEmpService {
Collection<DataCollectionEmployee> listAllForReport();
ExtEmpPO getById(Long id);
XSSFWorkbook exportImportTemplate();
Map<String, Object> previewImportExtEmp(ExtEmpImportParam param);
Map<String, Object> importExtEmp(ExtEmpImportParam param);
}

332
src/com/engine/salary/service/impl/ExtEmpServiceImpl.java
View File

@ -3,6 +3,7 @@ package com.engine.salary.service.impl;
import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
import com.engine.salary.entity.extemp.param.ExtEmpImportParam;
import com.engine.salary.entity.extemp.param.ExtEmpQueryParam;
import com.engine.salary.entity.extemp.param.ExtEmpSaveParam;
import com.engine.salary.entity.extemp.po.ExtEmpPO;
@ -10,22 +11,40 @@ import com.engine.salary.entity.hrm.DeptInfo;
import com.engine.salary.entity.hrm.SubCompanyInfo;
import com.engine.salary.entity.salarysob.param.SalarySobRangeEmpQueryParam;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.mapper.datacollection.EmployMapper;
import com.engine.salary.mapper.extemp.ExternalEmployeeMapper;
import com.engine.salary.service.ExtEmpService;
import com.engine.salary.service.SalaryEmployeeService;
import com.engine.salary.util.SalaryDateUtil;
import com.engine.salary.util.SalaryI18nUtil;
import com.engine.salary.util.db.MapperProxyFactory;
import com.engine.salary.util.excel.ExcelComment;
import com.engine.salary.util.excel.ExcelParseHelper;
import com.engine.salary.util.excel.ExcelSupport;
import com.engine.salary.util.excel.ExcelUtilPlus;
import com.engine.salary.util.page.PageInfo;
import com.engine.salary.util.page.SalaryPageUtil;
import com.engine.salary.util.valid.ValidUtil;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import dm.jdbc.util.IdGenerator;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.Validate;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.util.IOUtils;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.beans.BeanUtils;
import weaver.file.ImageFileManager;
import weaver.general.Util;
import weaver.hrm.User;
import java.io.InputStream;
import java.util.*;
import java.util.stream.Collectors;
import static com.engine.salary.util.excel.ExcelSupport.EXCEL_TYPE_XLSX;
/**
* 累计专项
* <p>Copyright: Copyright (c) 2022</p>
@ -45,6 +64,9 @@ public class ExtEmpServiceImpl extends Service implements ExtEmpService {
return ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
}
private EmployMapper getEmployMapper() {
return MapperProxyFactory.getProxy(EmployMapper.class);
}
@Override
public List<ExtEmpPO> list(ExtEmpQueryParam param) {
@ -203,4 +225,314 @@ public class ExtEmpServiceImpl extends Service implements ExtEmpService {
return employee;
}).collect(Collectors.toList());
}
@Override
public XSSFWorkbook exportImportTemplate() {
// 模板表头
List<Object> headerList = Lists.newArrayList(
SalaryI18nUtil.getI18nLabel(25034, "姓名"),
SalaryI18nUtil.getI18nLabel(27511, "部门"),
SalaryI18nUtil.getI18nLabel(33553, "分部"),
SalaryI18nUtil.getI18nLabel(1516, "入职日期"),
SalaryI18nUtil.getI18nLabel(125238, "手机号"),
SalaryI18nUtil.getI18nLabel(1933, "工号"),
SalaryI18nUtil.getI18nLabel(1887, "身份证号码"),
SalaryI18nUtil.getI18nLabel(0, "本人开户的银行卡卡号"),
SalaryI18nUtil.getI18nLabel(0, "本人开户的银行卡开户支行全称"));
List<String> dataIndexList = Lists.newArrayList("username", "departmentName", "subcompanyName", "companystartdate", "mobile", "workcode", "idNo", "bankCardNum", "bankName");
// excel导出的数据
List<List<Object>> rows = new ArrayList<>();
rows.add(headerList);
// 注释
List<ExcelComment> excelComments = Lists.newArrayList();
excelComments.add(new ExcelComment(0, 0, 1, 2, SalaryI18nUtil.getI18nLabel(30036, "必填")));
excelComments.add(new ExcelComment(3, 0, 4, 2, SalaryI18nUtil.getI18nLabel(542348, "格式样例为'2022-01-01'、'2022/1/1'")));
String sheetName = "非系统人员导入模板";
return ExcelUtilPlus.genWorkbookV2(rows, sheetName, excelComments);
}
@Override
public Map<String, Object> previewImportExtEmp(ExtEmpImportParam param) {
//参数校验
ValidUtil.doValidator(param);
Map<String, Object> map = new HashMap<>();
InputStream fileInputStream = null;
try {
fileInputStream = ImageFileManager.getInputStreamById(Integer.parseInt(param.getImageId()));
Sheet sheet = ExcelSupport.parseFile(fileInputStream, 0, EXCEL_TYPE_XLSX);
map.put("headers", ExcelSupport.getSheetHeader(sheet, 0));
map.put("list", ExcelParseHelper.parse2List(sheet, 1));
return map;
} finally {
IOUtils.closeQuietly(fileInputStream);
}
}
@Override
public Map<String, Object> importExtEmp(ExtEmpImportParam param){
Map<String, Object> apidatas = new HashMap<String, Object>();
//excel文件id
String imageId = Util.null2String(param.getImageId());
Validate.notBlank(imageId, SalaryI18nUtil.getI18nLabel(542127, "imageId为空"));
// 失败的数量
int failCount = 0;
// 成功的数量
int successCount = 0;
InputStream fileInputStream = null;
try {
fileInputStream = ImageFileManager.getInputStreamById(Integer.parseInt(param.getImageId()));
Sheet sheet = ExcelSupport.parseFile(fileInputStream, 0, EXCEL_TYPE_XLSX);
//数据库中现有非系统人员集合
List<ExtEmpPO> allExtEmpInfo= getExternalEmployeeMapper().listAll();
// 错误提示信息
List<Map> excelComments = Lists.newArrayList();
// 存在错误的那行数据
List<Map<String, Object>> errorDatas = Lists.newArrayList();
// 表头
List<String> headers = ExcelSupport.getSheetHeader(sheet, 0);
// 处理数值
List<Map<String, Object>> data = ExcelParseHelper.parse2Map(sheet, 1);
if (CollectionUtils.isEmpty(headers)) {
throw new SalaryRunTimeException("表头为空");
}
if (CollectionUtils.isEmpty(data)) {
throw new SalaryRunTimeException("无数据");
}
//存储待新增和待更新的ExtEmpPO数据
List<ExtEmpPO> updateExtEmpPOList = new ArrayList<>();
List<ExtEmpPO> insertExtEmpPOList = new ArrayList<>();
//遍历excel表具体数据
for (int i = 0; i < data.size(); i++) {
String row = "第" + (i + 1) + "行";
boolean isError = false;
Map<String, Object> map = data.get(i);
Long employeeId = 0L;
String username = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(25034, "姓名"), "");
String departmentName = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(27511, "部门"), "");
String subcompanyName = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(33553, "分部"), "");
String companystartdate = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(1516, "入职日期"), "");
//校验姓名
if (StringUtils.isBlank(username)) {
//姓名是必填项
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(102838, "姓名不能为空"));
excelComments.add(errorMessageMap);
}
long usernameNum = updateExtEmpPOList.stream().filter(f -> f.getUsername().equals(username)).count() + insertExtEmpPOList.stream().filter(f -> f.getUsername().equals(username)).count();
if (usernameNum > 0) {
//excel中姓名相同时，只会录入第一次出现的数据
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(102838, "本次excel文件中已存在该姓名相关数据，本行数据无法录入"));
excelComments.add(errorMessageMap);
}
//校验部门、分部
List<SubCompanyInfo> subCompanyInfos = new ArrayList<>();
List<DeptInfo> deptInfos = new ArrayList<>();
if (StringUtils.isNotBlank(subcompanyName)) {
subCompanyInfos = getEmployMapper().getSubCompanyInfosByName(subcompanyName);
if (subCompanyInfos.size() == 0) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "分部信息不存在，请检查分部数据是否正确"));
excelComments.add(errorMessageMap);
}
}
if (StringUtils.isNotBlank(departmentName)) {
deptInfos = getEmployMapper().getDeptInfosByName(departmentName);
if (deptInfos.size() == 0) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "部门信息不存在，请检查部门数据是否正确"));
excelComments.add(errorMessageMap);
}
}
if (StringUtils.isNotBlank(companystartdate) && (companystartdate.length() < 10 || !SalaryDateUtil.checkDay(companystartdate.substring(0, 10)))) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "入职日期格式错误，正确格式为YYYY-MM或者yyyy-MM-dd"));
excelComments.add(errorMessageMap);
}
if (!isError){
//校验当前数据是否有相关数据（姓名相同）存在数据库中，有则更新，无则新建
List<ExtEmpPO> targetExtEmpInfoList = allExtEmpInfo.stream().filter(f -> f.getUsername().equals(username)).collect(Collectors.toList());
//校验部门和分部关系
List<DeptInfo> targetDeptInfos = new ArrayList<>();
List<SubCompanyInfo> targetSubCompanyInfos = new ArrayList<>();
if (targetExtEmpInfoList.size() == 1) {
ExtEmpPO targetExtEmpInfo = targetExtEmpInfoList.get(0);
//将库中已有的部门和分布信息取出（excel行未设置对应字段数据时）
if (targetExtEmpInfo.getSubcompanyId() != null && subCompanyInfos.size() == 0) {
subCompanyInfos.add(SubCompanyInfo.builder().id(targetExtEmpInfo.getSubcompanyId()).name(targetExtEmpInfo.getSubcompanyName()).build());
}
if (targetExtEmpInfo.getDepartmentId() != null && deptInfos.size() == 0) {
DeptInfo oldDeptInfo = getEmployMapper().getDeptInfoById(targetExtEmpInfo.getDepartmentId());
deptInfos.add(oldDeptInfo);
}
}
//分部结果数为0，部门结果数大于1，则无法匹配
if(subCompanyInfos.size() == 0 && deptInfos.size() > 1) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "系统中存在重复部门信息，无法指定当前人员关联的唯一部门，请通过填写部门所属的分部信息来缩小部门筛选范围"));
excelComments.add(errorMessageMap);
} else if (subCompanyInfos.size() > 1 && deptInfos.size() == 0) {
//部门结果数为0，分部结果数大于1，则无法匹配
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "系统中存在重复分部信息，无法指定当前人员关联的唯一分部，请通过填写人员所属的部门信息来缩小分部筛选范围"));
excelComments.add(errorMessageMap);
} else if (subCompanyInfos.size() >= 1 && deptInfos.size() >= 1) {
//部门结果数大于等于1，分部结果数大于等于1，筛选出可配对的组合，根据部门的所属分部字段进行配对
for (DeptInfo deptInfo : deptInfos) {
if (subCompanyInfos.stream().filter(g -> g.getId().equals(deptInfo.getSubcompanyid1())).count() > 0) {
targetDeptInfos.add(deptInfo);
}
}
if (targetDeptInfos.size() == 0) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "部门与分部无法匹配"));
excelComments.add(errorMessageMap);
} else if (targetDeptInfos.size() > 1) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "该组数据中的部门和分部信息在系统中出现多组匹配的部门和分布组合，无法指定唯一的部门和分部组合"));
excelComments.add(errorMessageMap);
} else {
targetSubCompanyInfos = subCompanyInfos.stream().filter(f -> f.getId().equals(targetDeptInfos.get(0).getSubcompanyid1())).collect(Collectors.toList());
}
} else if (subCompanyInfos.size() == 0 && deptInfos.size() == 1) {
//分部结果数为0，部门结果数为1，可以匹配
targetDeptInfos.add(deptInfos.get(0));
} else if (subCompanyInfos.size() == 1 && deptInfos.size() == 0) {
//部门结果数为0，分部结果数为1，可以匹配
targetSubCompanyInfos.add(subCompanyInfos.get(0));
}
//收集excel有效数据，并区分新增和更新
DeptInfo finalDeptInfo = targetDeptInfos.size() > 0 ? targetDeptInfos.get(0) : null;
SubCompanyInfo finalSubCompanyInfo = targetSubCompanyInfos.size() > 0 ? targetSubCompanyInfos.get(0) : null;
if (targetExtEmpInfoList.isEmpty()) {
if (!isError) {
//添加一条新建数据
insertExtEmpPOList.add(handleExtEmpInfo(null, map, finalDeptInfo, finalSubCompanyInfo));
}
} else if (targetExtEmpInfoList.size() > 1) {
isError = true;
Map<String, String> errorMessageMap = Maps.newHashMap();
errorMessageMap.put("message", row + SalaryI18nUtil.getI18nLabel(0, "数据库中非系统人员信息存在姓名相同数据，请先确保姓名唯一"));
excelComments.add(errorMessageMap);
} else {
if (!isError) {
//添加一条更新数据
updateExtEmpPOList.add(handleExtEmpInfo(targetExtEmpInfoList.get(0), map, finalDeptInfo, finalSubCompanyInfo));
}
}
}
if (isError) {
failCount++;
errorDatas.add(map);
} else {
successCount++;
}
}
//更新
for(ExtEmpPO po : updateExtEmpPOList) {
getExternalEmployeeMapper().updateIgnoreNull(po);
}
//新建
for(ExtEmpPO po : insertExtEmpPOList) {
getExternalEmployeeMapper().insertIgnoreNull(po);
}
apidatas.put("successCount", successCount);
apidatas.put("errorCount", failCount);
apidatas.put("errorData", excelComments);
} finally {
IOUtils.closeQuietly(fileInputStream);
}
return apidatas;
}
public ExtEmpPO handleExtEmpInfo(ExtEmpPO po, Map<String, Object> map, DeptInfo deptInfo, SubCompanyInfo subCompanyInfo) {
ExtEmpPO resultPo = new ExtEmpPO();
if (po == null) {
//新建
resultPo.setId(IdGenerator.generate());
resultPo.setCreateTime(new Date());
resultPo.setUpdateTime(new Date());
resultPo.setDeleteType(0);
resultPo.setCreator((long) user.getUID());
} else {
//更新
BeanUtils.copyProperties(po, resultPo);
resultPo.setUpdateTime(new Date());
}
String username = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(25034, "姓名"), "");
// String departmentName = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(27511, "部门"), "");
// String subcompanyName = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(33553, "分部"), "");
String companystartdate = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(1516, "入职日期"), "");
String mobile = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(125238, "手机号"), "");
String workcode = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(1933, "工号"), "");
String idNo = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(1887, "身份证号码"), "");
String bankCardNum = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(0, "本人开户的银行卡卡号"), "");
String bankName = (String) map.getOrDefault(SalaryI18nUtil.getI18nLabel(0, "本人开户的银行卡开户支行全称"), "");
if (StringUtils.isNotBlank(companystartdate)) {
resultPo.setCompanystartdate(companystartdate.substring(0, 10));
}
if (StringUtils.isNotBlank(username)) {
resultPo.setUsername(username);
}
if (StringUtils.isNotBlank(mobile)) {
resultPo.setMobile(mobile);
}
if (StringUtils.isNotBlank(workcode)) {
resultPo.setWorkcode(workcode);
}
if (StringUtils.isNotBlank(idNo)) {
resultPo.setIdNo(idNo);
}
if (StringUtils.isNotBlank(bankCardNum)) {
resultPo.setBankCardNum(bankCardNum);
}
if (StringUtils.isNotBlank(bankName)) {
resultPo.setBankName(bankName);
}
if (deptInfo != null) {
resultPo.setDepartmentName(deptInfo.getName());
resultPo.setDepartmentId(deptInfo.getId());
}
if (subCompanyInfo != null) {
resultPo.setSubcompanyName(subCompanyInfo.getName());
resultPo.setSubcompanyId(subCompanyInfo.getId());
}
resultPo.setModifier((long) user.getUID());
return resultPo;
}
}

55
src/com/engine/salary/web/ExtEmpController.java
View File

@ -1,13 +1,17 @@
package com.engine.salary.web;
import com.engine.common.util.ServiceUtil;
import com.engine.salary.entity.extemp.param.ExtEmpImportParam;
import com.engine.salary.entity.extemp.param.ExtEmpQueryParam;
import com.engine.salary.entity.extemp.param.ExtEmpSaveParam;
import com.engine.salary.entity.extemp.po.ExtEmpPO;
import com.engine.salary.util.ResponseResult;
import com.engine.salary.util.SalaryI18nUtil;
import com.engine.salary.util.page.PageInfo;
import com.engine.salary.wrapper.ExtEmpWrapper;
import io.swagger.v3.oas.annotations.parameters.RequestBody;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import weaver.hrm.HrmUserVarify;
import weaver.hrm.User;
@ -16,7 +20,13 @@ import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.*;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.StreamingOutput;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.time.LocalDate;
import java.util.Collection;
import java.util.Map;
/**
* 外部人员
@ -26,6 +36,7 @@ import java.util.Collection;
* @author qiantao
* @version 1.0
**/
@Slf4j
public class ExtEmpController {
private ExtEmpWrapper getExtEmpWrapper(User user) {
@ -72,6 +83,50 @@ public class ExtEmpController {
return new ResponseResult<Long, ExtEmpPO>(user).run(getExtEmpWrapper(user)::detail, id);
}
// **********************************非系统人员导入 start*********************************/
//导出导入模板
@GET
@Path("/importtemplate/export")
@Produces(MediaType.APPLICATION_OCTET_STREAM)
public Response exportImportTemplate(@Context HttpServletRequest request, @Context HttpServletResponse response) {
try {
User user = HrmUserVarify.getUser(request, response);
XSSFWorkbook workbook = getExtEmpWrapper(user).exportImportTemplate();
String time = LocalDate.now().toString();
String fileName = SalaryI18nUtil.getI18nLabel(0, "非系统人员导入模板") + time;
try {
fileName = URLEncoder.encode(fileName + ".xlsx", "UTF-8").replaceAll("\\+", "%20");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
StreamingOutput output = outputStream -> {
workbook.write(outputStream);
outputStream.flush();
};
response.setContentType("application/octet-stream");
return Response.ok(output).header("Content-disposition", "attachment;filename=" + fileName).header("Cache-Control", "no-cache").build();
} catch (Exception e) {
log.error("非系统人员导入模板导出异常", e);
throw e;
}
}
//导入非系统人员
@POST
@Path("/importExtEmp")
@Produces(MediaType.APPLICATION_JSON)
public String importExtEmp(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody ExtEmpImportParam param) {
User user = HrmUserVarify.getUser(request, response);
return new ResponseResult<ExtEmpImportParam, Map<String, Object>>(user).run(getExtEmpWrapper(user)::importExtEmp, param);
}
@POST
@Path("/preview")
@Produces(MediaType.APPLICATION_JSON)
public String previewImportExtEmp(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody ExtEmpImportParam param) {
User user = HrmUserVarify.getUser(request, response);
return new ResponseResult<ExtEmpImportParam, Map<String, Object>>(user).run(getExtEmpWrapper(user)::previewImportExtEmp, param);
}
// **********************************非系统人员导入 end*********************************/
}

16
src/com/engine/salary/wrapper/ExtEmpWrapper.java
View File

@ -2,15 +2,18 @@ package com.engine.salary.wrapper;
import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.entity.extemp.param.ExtEmpImportParam;
import com.engine.salary.entity.extemp.param.ExtEmpQueryParam;
import com.engine.salary.entity.extemp.param.ExtEmpSaveParam;
import com.engine.salary.entity.extemp.po.ExtEmpPO;
import com.engine.salary.service.ExtEmpService;
import com.engine.salary.service.impl.ExtEmpServiceImpl;
import com.engine.salary.util.page.PageInfo;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import weaver.hrm.User;
import java.util.Collection;
import java.util.Map;
/**
* 累计专项
@ -46,4 +49,17 @@ public class ExtEmpWrapper extends Service {
public ExtEmpPO detail(Long id) {
return getExtEmpService(user).getById(id);
}
public XSSFWorkbook exportImportTemplate() {
return getExtEmpService(user).exportImportTemplate();
}
public Map<String, Object> previewImportExtEmp(ExtEmpImportParam param) {
return getExtEmpService(user).previewImportExtEmp(param);
}
public Map<String, Object> importExtEmp(ExtEmpImportParam param) {
return getExtEmpService(user).importExtEmp(param);
}
}