Commit 05abc82201aee4bcf15ece246ea072c6a89cb269

Authored by wangqian
1 parent dd855940

所属单位修改

urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/costfee/CostFeeServiceImpl.java
@@ -47,8 +47,7 @@ import java.util.stream.IntStream; @@ -47,8 +47,7 @@ import java.util.stream.IntStream;
47 import static com.zteits.urbanops.framework.common.exception.enums.GlobalErrorCodeConstants.BAD_REQUEST; 47 import static com.zteits.urbanops.framework.common.exception.enums.GlobalErrorCodeConstants.BAD_REQUEST;
48 import static com.zteits.urbanops.framework.common.exception.util.ServiceExceptionUtil.exception; 48 import static com.zteits.urbanops.framework.common.exception.util.ServiceExceptionUtil.exception;
49 import static com.zteits.urbanops.framework.common.exception.util.ServiceExceptionUtil.exception0; 49 import static com.zteits.urbanops.framework.common.exception.util.ServiceExceptionUtil.exception0;
50 -import static com.zteits.urbanops.framework.security.core.util.SecurityFrameworkUtils.getLoginUser;  
51 -import static com.zteits.urbanops.framework.security.core.util.SecurityFrameworkUtils.getLoginUserDeptId; 50 +import static com.zteits.urbanops.framework.security.core.util.SecurityFrameworkUtils.*;
52 import static com.zteits.urbanops.module.garden.enums.ErrorCodeConstants.COST_FEE_NOT_EXISTS_001; 51 import static com.zteits.urbanops.module.garden.enums.ErrorCodeConstants.COST_FEE_NOT_EXISTS_001;
53 52
54 /** 53 /**
@@ -227,8 +226,8 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -227,8 +226,8 @@ public class CostFeeServiceImpl implements CostFeeService {
227 .map(importObj -> { 226 .map(importObj -> {
228 WaterFeeDO fee = new WaterFeeDO(); 227 WaterFeeDO fee = new WaterFeeDO();
229 BeanUtils.copyProperties(importObj, fee); 228 BeanUtils.copyProperties(importObj, fee);
230 - fee.setCompanyId(String.valueOf(getLoginUserDeptId()));  
231 - if (getLoginUserDeptId() == 100) { 229 + fee.setCompanyId(String.valueOf(getCompanyId()));
  230 + if (getCompanyId() == 100) {
232 fee.setCompanyName("蓟城山水"); 231 fee.setCompanyName("蓟城山水");
233 } else { 232 } else {
234 // 设置单位id 233 // 设置单位id
@@ -502,8 +501,8 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -502,8 +501,8 @@ public class CostFeeServiceImpl implements CostFeeService {
502 if (CollectionUtils.isEmpty(dataList)) { 501 if (CollectionUtils.isEmpty(dataList)) {
503 return; // 空列表无需校验 502 return; // 空列表无需校验
504 } 503 }
505 - //登录用户部门  
506 - Long deptId = getLoginUserDeptId(); 504 + //登录用户单位
  505 + Long belongCompanyId = getCompanyId();
507 //单位集合 506 //单位集合
508 List<DeptRespDTO> companyList = deptApi.getSubDeptList(); 507 List<DeptRespDTO> companyList = deptApi.getSubDeptList();
509 List<Long> deptIds = companyList.stream().map(DeptRespDTO::getId).collect(Collectors.toList()); 508 List<Long> deptIds = companyList.stream().map(DeptRespDTO::getId).collect(Collectors.toList());
@@ -577,7 +576,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -577,7 +576,7 @@ public class CostFeeServiceImpl implements CostFeeService {
577 } 576 }
578 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName()); 577 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName());
579 //单位校验 578 //单位校验
580 - validatecompany(rowNum, importBean.getCompanyName(), companyId, deptId); 579 + validatecompany(rowNum, importBean.getCompanyName(), companyId, belongCompanyId);
581 //部门名称校验 580 //部门名称校验
582 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds()); 581 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds());
583 582
@@ -612,7 +611,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -612,7 +611,7 @@ public class CostFeeServiceImpl implements CostFeeService {
612 } 611 }
613 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName()); 612 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName());
614 //单位校验 613 //单位校验
615 - validatecompany(rowNum, importBean.getCompanyName(), companyId, deptId); 614 + validatecompany(rowNum, importBean.getCompanyName(), companyId, belongCompanyId);
616 //部门名称校验 615 //部门名称校验
617 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds()); 616 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds());
618 617
@@ -646,7 +645,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -646,7 +645,7 @@ public class CostFeeServiceImpl implements CostFeeService {
646 } 645 }
647 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName()); 646 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName());
648 //单位校验 647 //单位校验
649 - validatecompany(rowNum, importBean.getCompanyName(), companyId, deptId); 648 + validatecompany(rowNum, importBean.getCompanyName(), companyId, belongCompanyId);
650 //部门名称校验 649 //部门名称校验
651 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds()); 650 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds());
652 651
@@ -716,7 +715,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -716,7 +715,7 @@ public class CostFeeServiceImpl implements CostFeeService {
716 } 715 }
717 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName()); 716 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName());
718 //单位校验 717 //单位校验
719 - validatecompany(rowNum, importBean.getCompanyName(), companyId, deptId); 718 + validatecompany(rowNum, importBean.getCompanyName(), companyId, belongCompanyId);
720 //部门名称校验 719 //部门名称校验
721 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds()); 720 validateTeams(rowNum, deptList.get(companyId), importBean.getTeamIds());
722 721
@@ -752,7 +751,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -752,7 +751,7 @@ public class CostFeeServiceImpl implements CostFeeService {
752 751
753 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName()); 752 Long companyId = nameToCompanyIdMap.get(importBean.getCompanyName());
754 //单位校验 753 //单位校验
755 - validatecompany(rowNum, importBean.getCompanyName(), companyId, deptId); 754 + validatecompany(rowNum, importBean.getCompanyName(), companyId, belongCompanyId);
756 } catch (ConstraintViolationException ex) { 755 } catch (ConstraintViolationException ex) {
757 // 5. 包装异常,明确行号 + 真实校验错误( 756 // 5. 包装异常,明确行号 + 真实校验错误(
758 throw exception0(BAD_REQUEST.getCode(), String.format("第%d条数据校验失败:%s", rowNum, ex.getMessage()), ex); 757 throw exception0(BAD_REQUEST.getCode(), String.format("第%d条数据校验失败:%s", rowNum, ex.getMessage()), ex);
@@ -761,7 +760,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -761,7 +760,7 @@ public class CostFeeServiceImpl implements CostFeeService {
761 } 760 }
762 } 761 }
763 762
764 - private void validatecompany(int rowNum, String companyName, Long companyId, Long deptId){ 763 + private void validatecompany(int rowNum, String companyName, Long companyId, Long belongCompanyId){
765 // 校验数组长度是否一致 764 // 校验数组长度是否一致
766 if (companyId == null) { 765 if (companyId == null) {
767 throw exception0(BAD_REQUEST.getCode(), String.format( 766 throw exception0(BAD_REQUEST.getCode(), String.format(
@@ -770,7 +769,7 @@ public class CostFeeServiceImpl implements CostFeeService { @@ -770,7 +769,7 @@ public class CostFeeServiceImpl implements CostFeeService {
770 )); 769 ));
771 } 770 }
772 // 校验导入单位 771 // 校验导入单位
773 - if (deptId != 100 && !deptId.equals(companyId)) { 772 + if (belongCompanyId != 100 && !belongCompanyId.equals(companyId)) {
774 throw exception0(BAD_REQUEST.getCode(), String.format( 773 throw exception0(BAD_REQUEST.getCode(), String.format(
775 "第%d条数据:导入单位%s与当前操作员单位不一致", 774 "第%d条数据:导入单位%s与当前操作员单位不一致",
776 rowNum, companyName 775 rowNum, companyName