main
hshansha 2 months ago
parent fb33cb788c
commit 6a78222dea

@ -32,6 +32,10 @@
<artifactId>json</artifactId>
<version>20210307</version>
</dependency>
<dependency>
<groupId>com.ruoyi</groupId>
<artifactId>ruoyi-system</artifactId>
</dependency>
</dependencies>
</project>

@ -26,9 +26,9 @@ public class KhEmployee extends BaseEntity {
private Long userId;
/**
*
* ID
*/
@Excel(name = "职工所属部门")
@Excel(name = "部门ID")
private Long deptId;
/**

@ -2,12 +2,14 @@ package com.ruoyi.kaohe.service.impl;
import java.util.List;
import com.ruoyi.common.core.domain.entity.SysDept;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.bean.BeanValidators;
import com.ruoyi.system.mapper.SysDeptMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@ -20,145 +22,130 @@ import javax.annotation.Resource;
/**
* Service
*
*
* @author hs
* @date 2025-06-17
*/
@Service
public class KhEmployeeServiceImpl implements IKhEmployeeService
{
public class KhEmployeeServiceImpl implements IKhEmployeeService {
@Resource
private KhEmployeeMapper khEmployeeMapper;
@Resource
private SysDeptMapper deptMapper;
private static final Logger log = LoggerFactory.getLogger(KhEmployeeServiceImpl.class);
/**
*
*
*
* @param id
* @return
*/
@Override
public KhEmployee selectKhEmployeeById(Long id)
{
public KhEmployee selectKhEmployeeById(Long id) {
return khEmployeeMapper.selectKhEmployeeById(id);
}
/**
*
*
*
* @param khEmployee
* @return
*/
@Override
public List<KhEmployee> selectKhEmployeeList(KhEmployee khEmployee)
{
public List<KhEmployee> selectKhEmployeeList(KhEmployee khEmployee) {
return khEmployeeMapper.selectKhEmployeeList(khEmployee);
}
/**
*
*
*
* @param khEmployee
* @return
*/
@Override
public int insertKhEmployee(KhEmployee khEmployee)
{
public int insertKhEmployee(KhEmployee khEmployee) {
khEmployee.setCreateTime(DateUtils.getNowDate());
return khEmployeeMapper.insertKhEmployee(khEmployee);
}
/**
*
*
*
* @param khEmployee
* @return
*/
@Override
public int updateKhEmployee(KhEmployee khEmployee)
{
public int updateKhEmployee(KhEmployee khEmployee) {
khEmployee.setUpdateTime(DateUtils.getNowDate());
return khEmployeeMapper.updateKhEmployee(khEmployee);
}
/**
*
*
*
* @param ids
* @return
*/
@Override
public int deleteKhEmployeeByIds(Long[] ids)
{
public int deleteKhEmployeeByIds(Long[] ids) {
return khEmployeeMapper.deleteKhEmployeeByIds(ids);
}
/**
*
*
*
* @param id
* @return
*/
@Override
public int deleteKhEmployeeById(Long id)
{
public int deleteKhEmployeeById(Long id) {
return khEmployeeMapper.deleteKhEmployeeById(id);
}
@Override
public String importEmp(List<KhEmployee> empList, boolean updateSupport, String operName) {
if (StringUtils.isNull(empList) || empList.size() == 0)
{
if (StringUtils.isNull(empList) || empList.size() == 0) {
throw new ServiceException("导入职工数据不能为空!");
}
int successNum = 0;
int failureNum = 0;
StringBuilder successMsg = new StringBuilder();
StringBuilder failureMsg = new StringBuilder();
for (KhEmployee employee : empList)
{
try
{
for (KhEmployee employee : empList) {
try {
//根据deptId查询deptName
SysDept sysDept = deptMapper.selectDeptById(employee.getDeptId());
employee.setDeptName(sysDept.getDeptName());
// 验证是否存在这个职工
KhEmployee param = new KhEmployee();
param.setEmpName(employee.getEmpName());
param.setDeptId(employee.getDeptId());
List<KhEmployee> e = khEmployeeMapper.selectKhEmployeeList(param);
if (StringUtils.isNull(e)||e.size()==0)
{
if (StringUtils.isNull(e) || e.size() == 0) {
khEmployeeMapper.insertKhEmployee(employee);
successNum++;
successMsg.append("<br/>" + successNum + "、账号 " + employee.getEmpName() + " 导入成功");
}
else if (updateSupport)
{
} else if (updateSupport) {
employee.setId(e.get(0).getId());
khEmployeeMapper.updateKhEmployee(employee);
successNum++;
successMsg.append("<br/>" + successNum + "、账号 " + employee.getEmpName() + " 更新成功");
}
else
{
} else {
failureNum++;
failureMsg.append("<br/>" + failureNum + "、账号 " + employee.getEmpName() + " 已存在");
}
}
catch (Exception e)
{
} catch (Exception e) {
failureNum++;
String msg = "<br/>" + failureNum + "、账号 " + employee.getEmpName() + " 导入失败:";
failureMsg.append(msg + e.getMessage());
log.error(msg, e);
}
}
if (failureNum > 0)
{
if (failureNum > 0) {
failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
throw new ServiceException(failureMsg.toString());
}
else
{
} else {
successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
}
return successMsg.toString();

@ -256,7 +256,7 @@ public class KhKhrwResultServiceImpl implements IKhKhrwResultService
return AjaxResult.success("更新成功");
}else{
this.insertKhKhrwResult(pcResult);
return AjaxResult.success();
return AjaxResult.success("生成成功");
}
}
}

Loading…
Cancel
Save