diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.java index 0adec1b570..b726ee1f6d 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.java @@ -45,4 +45,6 @@ public interface BusVehicleApplyMapper extends BaseMapper { int abandonApply(@Param("sidsList") List sidsList); int selectByNodeState(String join); + + int selectCountBySids(String join); } \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.xml b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.xml index ed118cd389..be49b046c9 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.xml +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyMapper.xml @@ -94,4 +94,11 @@ where nodeState <> '已办结' and find_in_set(sid, #{join}) + + \ No newline at end of file diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java index 632fb0a95f..394e843905 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java @@ -831,7 +831,12 @@ public class BusVehicleApplyService extends MybatisBaseService 0) { - return rb.setMsg("作废的数据中包含流程未完结的数据,不允许作废"); + return rb.setMsg("选择作废的数据中包含流程未完结的数据,不允许作废"); + } + //查询需要作废的数据中是否包含已认款的 + int counts = baseMapper.selectCountBySids(StringUtils.join(sids, ",")); + if(counts>0){ + return rb.setMsg("选择作废的数据中包含已认款的数据,不允许作废"); } List sidsList = Arrays.asList(sids); int i = baseMapper.abandonApply(sidsList); diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationRest.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationRest.java index ae3f0e87ab..7ecd5563b7 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationRest.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationRest.java @@ -5,6 +5,8 @@ import com.yxt.anrui.portal.api.sysorganization.*; import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgVo; import com.yxt.anrui.portal.biz.sysstaffinfo.SysStaffinfoService; import com.yxt.anrui.portal.biz.sysstafforg.SysStaffOrgService; +import com.yxt.anrui.portal.biz.sysuser.SysUserService; +import com.yxt.common.base.config.RedisUtil; import com.yxt.common.base.config.component.FileUploadComponent; import com.yxt.common.base.utils.QRCodeUtil; import com.yxt.common.base.utils.StringUtils; @@ -19,10 +21,9 @@ import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.io.File; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; + +import static java.util.stream.Collectors.toList; /** * Project: anrui_portal(门户建设)
@@ -50,6 +51,10 @@ public class SysOrganizationRest implements SysOrganizationFeign { private SysStaffinfoService sysStaffinfoService; @Autowired private FileUploadComponent fileUploadComponent; + @Autowired + private SysUserService sysUserService; + @Autowired + private RedisUtil redisUtil; @Override public ResultBean> listPage(@RequestBody PagerQuery pq) { @@ -98,6 +103,8 @@ public class SysOrganizationRest implements SysOrganizationFeign { @Transactional(rollbackFor = Exception.class) public ResultBean update(SysOrganizationDto dto, String sid) { ResultBean rb = ResultBean.fireFail(); + //查询该机构下的所有分管人员 + List stringList = sysStaffOrgService.selectByOrgSid(sid); //根据组织sid查询组织信息 SysOrganization sysOrganization = sysOrganizationService.fetchBySid(sid); if (sysOrganization == null) { @@ -131,6 +138,42 @@ public class SysOrganizationRest implements SysOrganizationFeign { } } sysOrganizationService.updateBySid(dto.toMap(), sid); + //==========================添加清空变化的用户的token + //查询分管人员 + List stringList1 = new ArrayList<>(); + List reduce1 = new ArrayList<>(); + if(StringUtils.isNotBlank(fgStaffSid)){ + stringList1 = Arrays.asList(fgStaffSid.split(",")); + reduce1 = stringList1.stream().filter(item -> !stringList.contains(item)).collect(toList()); + }else{ + reduce1 = stringList; + } + String orgSid1 = sysStaffOrgService.getOrgByOrgSid(sid); + if(reduce1.size()>0){ + for (String s : reduce1){ + //查询该人员的组织机构list + List sysStaffOrgVos = sysStaffOrgService.selectByStaffS(s); + List orgList = new ArrayList<>(); + if (sysStaffOrgVos.size() > 0) { + for (SysStaffOrgVo vv : sysStaffOrgVos) { + String orgSid = sysStaffOrgService.getOrgByOrgSid(vv.getOrgSid()); + SysOrganization ss = sysOrganizationService.fetchBySid(orgSid); + if (ss != null) { + orgList.add(orgSid); + } else { + continue; + } + } + } + if(!orgList.contains(orgSid1)){ + //根据staffSid查询token + String token = sysUserService.selectByStaffsid(s).getToken(); + //清空该token + redisUtil.remove(token); + } + } + + } return rb.success(); } diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationService.java index cfce32800f..ca0e262de6 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationService.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysorganization/SysOrganizationService.java @@ -14,6 +14,7 @@ import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgVo; import com.yxt.anrui.portal.biz.sysstaffinfo.SysStaffinfoService; import com.yxt.anrui.portal.biz.sysstafforg.SysStaffOrgService; import com.yxt.anrui.portal.biz.sysuser.SysUserService; +import com.yxt.common.base.config.RedisUtil; import com.yxt.common.base.config.component.FileUploadComponent; import com.yxt.common.base.service.MybatisBaseService; import com.yxt.common.base.utils.PagerUtil; @@ -27,6 +28,8 @@ import org.springframework.transaction.annotation.Transactional; import java.util.*; +import static java.util.stream.Collectors.toList; + /** * Project: anrui_portal(门户建设)
* File: SysOrganizationService.java
@@ -52,6 +55,8 @@ public class SysOrganizationService extends MybatisBaseService listPage(PagerQuery pq) { SysOrganizationQuery query = pq.getParams(); @@ -163,14 +168,28 @@ public class SysOrganizationService extends MybatisBaseService0){ - return rb.setMsg(sysStaffinfo.getName()+"已在本部门,不能设置分管"); + if (count > 0) { + return rb.setMsg(sysStaffinfo.getName() + "已在本部门,不能设置分管"); } } + //查询该人员的组织机构list + List sysStaffOrgVos = sysStaffOrgService.selectByStaffS(sid); + List orgList = new ArrayList<>(); + if (sysStaffOrgVos.size() > 0) { + for (SysStaffOrgVo vv : sysStaffOrgVos) { + String orgSid = sysStaffOrgService.getOrgByOrgSid(vv.getOrgSid()); + SysOrganization sysOrganization = fetchBySid(orgSid); + if (sysOrganization != null) { + orgList.add(orgSid); + } else { + continue; + } + } + } //添加员工与组织的关联关系 SysStaffOrg sysStaffOrg = new SysStaffOrg(); sysStaffOrg.setManageType(manageType); @@ -193,7 +212,31 @@ public class SysOrganizationService extends MybatisBaseService sysStaffOrgVos1 = sysStaffOrgService.selectByStaffS(sid); + List orgList1 = new ArrayList<>(); + if (sysStaffOrgVos1.size() > 0) { + for (SysStaffOrgVo vv : sysStaffOrgVos1) { + String orgSid = sysStaffOrgService.getOrgByOrgSid(vv.getOrgSid()); + SysOrganization sysOrganization = fetchBySid(orgSid); + if (sysOrganization != null) { + orgList1.add(orgSid); + } else { + continue; + } + } + } + List reduce1 = orgList1.stream().filter(item -> !orgList.contains(item)).collect(toList()); + if (reduce1.size() > 0) { + //根据staffSid查询token + String token = sysUserService.selectByStaffsid(sid).getToken(); + //清空该token + redisUtil.remove(token); + } + + } + return rb.success(); } diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstaffinfo/SysStaffinfoService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstaffinfo/SysStaffinfoService.java index 770f90ecaa..884a898e69 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstaffinfo/SysStaffinfoService.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstaffinfo/SysStaffinfoService.java @@ -12,6 +12,7 @@ import com.yxt.anrui.portal.api.sysstaffinfo.app.AppSysStaffVo; import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg; import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgDetailsVo; import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgDto; +import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgVo; import com.yxt.anrui.portal.api.sysstaffpost.SysStaffPost; import com.yxt.anrui.portal.api.sysstaffpost.SysStaffPostDetailsVo; import com.yxt.anrui.portal.api.sysstaffpost.SysStaffPostDto; @@ -24,6 +25,7 @@ import com.yxt.anrui.portal.biz.sysstafforg.SysStaffOrgService; import com.yxt.anrui.portal.biz.sysstaffpost.SysStaffPostService; import com.yxt.anrui.portal.biz.sysuser.SysUserService; import com.yxt.anrui.portal.biz.sysuserrole.SysUserRoleService; +import com.yxt.common.base.config.RedisUtil; import com.yxt.common.base.config.component.FileUploadComponent; import com.yxt.common.base.service.MybatisBaseService; import com.yxt.common.base.utils.Encodes; @@ -39,6 +41,8 @@ import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; import java.util.*; +import static java.util.stream.Collectors.toList; + /** * Project: anrui_portal(门户建设)
* File: SysStaffinfoService.java
@@ -71,6 +75,8 @@ public class SysStaffinfoService extends MybatisBaseService selectAppContactsList() { List list = baseMapper.selectAppContactsList(); @@ -413,6 +419,20 @@ public class SysStaffinfoService extends MybatisBaseService sysStaffOrgVos = sysStaffOrgService.selectByStaffS(sid); + List orgList = new ArrayList<>(); + if (sysStaffOrgVos.size() > 0) { + for (SysStaffOrgVo vv : sysStaffOrgVos) { + String orgSid = sysStaffOrgService.getOrgByOrgSid(vv.getOrgSid()); + SysOrganization sysOrganization = sysOrganizationService.fetchBySid(orgSid); + if (sysOrganization != null) { + orgList.add(orgSid); + } else { + continue; + } + } + } //根据员工sid查询员工的信息 SysStaffinfo sysStaffinfo = fetchBySid(sid); if (sysStaffinfo == null) { @@ -519,6 +539,26 @@ public class SysStaffinfoService extends MybatisBaseService sysStaffOrgVos1 = sysStaffOrgService.selectByStaffS(sid); + List orgList1 = new ArrayList<>(); + if (sysStaffOrgVos1.size() > 0) { + for (SysStaffOrgVo vv : sysStaffOrgVos1) { + String orgSid = sysStaffOrgService.getOrgByOrgSid(vv.getOrgSid()); + SysOrganization sysOrganization = sysOrganizationService.fetchBySid(orgSid); + if (sysOrganization != null) { + orgList1.add(orgSid); + } else { + continue; + } + } + } + List reduce1 = orgList.stream().filter(item -> !orgList1.contains(item)).collect(toList()); + if (reduce1.size() > 0) { + //根据staffSid查询token + String token = sysUserService.selectByStaffsid(sid).getToken(); + //清空该token + redisUtil.remove(token); + } return rb.success().setMsg("更新员工信息成功"); } diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.java index a34444600b..9384ef8d24 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.java @@ -100,4 +100,6 @@ public interface SysStaffOrgMapper extends BaseMapper { int deleteByStaffSidAndType(@Param("sid") String sid, @Param("staffSid") String zgStaffSid, @Param("type") String type); List selectByStaffS(String staffSid); + + List selectByOrgSid(String sid); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.xml b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.xml index 7032f68f00..1cbe120b0e 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.xml +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgMapper.xml @@ -88,4 +88,8 @@ from sys_staff_org where staffSid = #{staffSid} + + \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgService.java index 75eaa7bed1..79cdc7715c 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgService.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysstafforg/SysStaffOrgService.java @@ -277,4 +277,8 @@ public class SysStaffOrgService extends MybatisBaseService selectByStaffS(String staffSid) { return baseMapper.selectByStaffS(staffSid); } + + public List selectByOrgSid(String sid) { + return baseMapper.selectByOrgSid(sid); + } } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java index b0bb9808c7..692a819b4b 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java @@ -347,10 +347,11 @@ public class SysUserService extends MybatisBaseService { //根据orgSidPath查询分公司sid===== String orgSid = sysStaffOrgService.getOrgByOrgSid(sysStaffOrgVo.getOrgSid()); SysOrganization sysOrganization = sysOrganizationService.fetchBySid(orgSid); - if(sysOrganization != null){ + if (sysOrganization != null) { userInfoOneVo.setDefaultOrgPathName(sysOrganization.getName()); - userInfoOneVo.setDefaultOrgPath(sysStaffOrgVo.getOrgSidPath()); - }else{ +// userInfoOneVo.setDefaultOrgPath(sysStaffOrgVo.getOrgSidPath()); + userInfoOneVo.setDefaultOrgPath(sysOrganization.getSid()); + } else { userInfoOneVo.setDefaultOrgPathName("暂无组织机构"); } } @@ -368,9 +369,12 @@ public class SysUserService extends MybatisBaseService { OrgList orgList1 = new OrgList(); String orgSid = sysStaffOrgService.getOrgByOrgSid(vv.getOrgSid()); SysOrganization sysOrganization = sysOrganizationService.fetchBySid(orgSid); - if(sysOrganization != null){ + if (sysOrganization != null) { orgList1.setOrgName(sysOrganization.getName()); - orgList1.setOrgPath(vv.getOrgSidPath()); +// orgList1.setOrgPath(vv.getOrgSidPath()); + orgList1.setOrgPath(sysOrganization.getSid()); + }else{ + continue; } orgList.add(orgList1); }