|
|
@@ -22,7 +22,7 @@ import org.springblade.core.secure.utils.SecureUtil;
|
|
|
import org.springblade.core.tool.api.R;
|
|
|
import org.springblade.core.tool.utils.BeanUtil;
|
|
|
import org.springblade.school.entity.SalaryItem;
|
|
|
-import org.springblade.school.excel.SalaryItemExcel;
|
|
|
+import org.springblade.school.excel.*;
|
|
|
import org.springblade.school.vo.SalaryItemVO;
|
|
|
import org.springblade.school.mapper.SalaryItemMapper;
|
|
|
import org.springblade.school.service.ISalaryItemService;
|
|
|
@@ -54,11 +54,11 @@ public class SalaryItemServiceImpl extends ServiceImpl<SalaryItemMapper, SalaryI
|
|
|
throw new SecurityException("导入数据不能为空");
|
|
|
}
|
|
|
StringBuffer errMsg= new StringBuffer();
|
|
|
-
|
|
|
+ int success = 0; //导入成功条数
|
|
|
for(int i=0;i<data.size();i++)
|
|
|
{
|
|
|
SalaryItemExcel salaryItemExcel = data.get(i);
|
|
|
- /*if (StringUtils.isBlank(salaryItemExcel.getIdNumber())){
|
|
|
+ if (StringUtils.isBlank(salaryItemExcel.getIdNumber())){
|
|
|
errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
continue;
|
|
|
}
|
|
|
@@ -66,14 +66,14 @@ public class SalaryItemServiceImpl extends ServiceImpl<SalaryItemMapper, SalaryI
|
|
|
errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
continue;
|
|
|
}
|
|
|
- if (StringUtils.isBlank(salaryItemExcel.getRankStandard())){
|
|
|
+ /*if (StringUtils.isBlank(salaryItemExcel.getRankStandard())){
|
|
|
errMsg.append("第"+(i+2)+"行,职级标准为空,");
|
|
|
continue;
|
|
|
}*/
|
|
|
SalaryItem salaryItem = new SalaryItem();
|
|
|
BeanUtil.copy(salaryItemExcel,salaryItem);
|
|
|
//根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
- SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
.eq("is_deleted", 0).eq("pid",id));
|
|
|
if (item == null){
|
|
|
salaryItem.setPid(id);
|
|
|
@@ -81,19 +81,763 @@ public class SalaryItemServiceImpl extends ServiceImpl<SalaryItemMapper, SalaryI
|
|
|
salaryItem.setCreateUser(SecureUtil.getUserId());
|
|
|
salaryItem.setCreateTime(new Date());
|
|
|
baseMapper.insert(salaryItem);
|
|
|
+ success = ++ success;
|
|
|
}else {
|
|
|
salaryItem.setPid(id);
|
|
|
salaryItem.setId(item.getId());
|
|
|
salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
salaryItem.setUpdateTime(new Date());
|
|
|
baseMapper.updateById(salaryItem);
|
|
|
+ success = ++ success;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (success == 0){
|
|
|
+ return R.success("导入失败");
|
|
|
+ }else if (success >0 && success == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else {
|
|
|
+ return R.success("导入部分成功,成功"+ success +"条,导入失败"+(data.size()-success)+"条");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R importEmploy(List<EmployExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ EmployExcel employExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(employExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(employExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(employExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R importPosition(List<PositionExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PositionExcel positionExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(positionExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(positionExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(positionExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R importPower(List<LearningPower> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ LearningPower learningPower = data.get(i);
|
|
|
+ if (StringUtils.isBlank(learningPower.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(learningPower.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(learningPower,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R importWeChat(List<WeChatExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ WeChatExcel weChatExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(weChatExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(weChatExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(weChatExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R importTeacherSubsidy(List<TeacherSubsidy> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ TeacherSubsidy teacherSubsidy = data.get(i);
|
|
|
+ if (StringUtils.isBlank(teacherSubsidy.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(teacherSubsidy.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(teacherSubsidy,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R importOvertime(List<OvertimeExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ OvertimeExcel overtimeExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(overtimeExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(overtimeExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(overtimeExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
- if (StringUtils.isNotBlank(errMsg)){
|
|
|
- return R.success("导入部分成功,未导入成功的有"+errMsg.toString());
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
}
|
|
|
- return R.success("导入成功");
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importPhoneFine(List<PhoneFineExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PhoneFineExcel phoneFineExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(phoneFineExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(phoneFineExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(phoneFineExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importSanitationFee(List<SanitationFee> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ SanitationFee sanitationFee = data.get(i);
|
|
|
+ if (StringUtils.isBlank(sanitationFee.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(sanitationFee.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(sanitationFee,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importAttendanceExcel(List<AttendanceExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ AttendanceExcel attendanceExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(attendanceExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(attendanceExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(attendanceExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importPersonalInsurance(List<PersonalInsurance> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PersonalInsurance personalInsurance = data.get(i);
|
|
|
+ if (StringUtils.isBlank(personalInsurance.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(personalInsurance.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(personalInsurance,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importReservedFunds(List<ReservedFunds> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ ReservedFunds reservedFunds = data.get(i);
|
|
|
+ if (StringUtils.isBlank(reservedFunds.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(reservedFunds.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(reservedFunds,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importPayTaxes(List<PayTaxes> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PayTaxes payTaxes = data.get(i);
|
|
|
+ if (StringUtils.isBlank(payTaxes.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(payTaxes.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(payTaxes,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importPostTrainExcel(List<PostTrainExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PostTrainExcel postTrainExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(postTrainExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(postTrainExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(postTrainExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importAwardExcel(List<AwardExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ AwardExcel awardExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(awardExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(awardExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(awardExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importVacationExcel(List<VacationExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ VacationExcel vacationExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(vacationExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(vacationExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(vacationExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importPostAllowance(List<PostAllowance> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PostAllowance postAllowance = data.get(i);
|
|
|
+ if (StringUtils.isBlank(postAllowance.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(postAllowance.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(postAllowance,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importPerformanceExcel(List<PerformanceExcel> data, Boolean isCovered, Long id) {
|
|
|
+ if(org.springframework.util.CollectionUtils.isEmpty(data))
|
|
|
+ {
|
|
|
+ throw new SecurityException("导入数据不能为空");
|
|
|
+ }
|
|
|
+ int message = 0; //导入成功条数
|
|
|
+ StringBuffer errMsg= new StringBuffer();
|
|
|
+ for(int i=0;i<data.size();i++)
|
|
|
+ {
|
|
|
+ PerformanceExcel performanceExcel = data.get(i);
|
|
|
+ if (StringUtils.isBlank(performanceExcel.getIdNumber())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,身份证号码为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (StringUtils.isBlank(performanceExcel.getCname())){
|
|
|
+ errMsg.append("第"+(i+2)+"行,姓名为空,");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ SalaryItem salaryItem = new SalaryItem();
|
|
|
+ BeanUtil.copy(performanceExcel,salaryItem);
|
|
|
+ //根据身份证号查询教职工信息是否存在存在更新不存在新增
|
|
|
+ SalaryItem item = baseMapper.selectOne(new QueryWrapper<SalaryItem>().eq("id_number", salaryItem.getIdNumber()).eq("cname",salaryItem.getCname()).eq("tenant_id", SecureUtil.getTenantId())
|
|
|
+ .eq("is_deleted", 0).eq("pid",id));
|
|
|
+ if (item != null){
|
|
|
+ salaryItem.setPid(id);
|
|
|
+ salaryItem.setId(item.getId());
|
|
|
+ salaryItem.setUpdateUser(SecureUtil.getUserId());
|
|
|
+ salaryItem.setUpdateTime(new Date());
|
|
|
+ baseMapper.updateById(salaryItem);
|
|
|
+ message = ++ message;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ if (message >0 && message == data.size()){
|
|
|
+ return R.success("全部导入成功");
|
|
|
+ }else if (message >0 && message != data.size()){
|
|
|
+ return R.success("导入部分成功,成功"+ message +"条,导入失败"+(data.size()-message)+"条");
|
|
|
+ }else {
|
|
|
+ return R.success("导入失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importOvertime6(List<OvertimeExcel> data, Boolean isCovered, Long id) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importOvertime7(List<OvertimeExcel> data, Boolean isCovered, Long id) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importOvertime8(List<OvertimeExcel> data, Boolean isCovered, Long id) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importOvertime9(List<OvertimeExcel> data, Boolean isCovered, Long id) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public R importOvertime10(List<OvertimeExcel> data, Boolean isCovered, Long id) {
|
|
|
+ return null;
|
|
|
}
|
|
|
|
|
|
}
|