| New file |
| | |
| | | package com.java110.user.cmd.user; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.core.annotation.Java110Cmd; |
| | | import com.java110.core.context.Environment; |
| | | import com.java110.core.context.ICmdDataFlowContext; |
| | | import com.java110.core.event.cmd.Cmd; |
| | | import com.java110.core.event.cmd.CmdEvent; |
| | | import com.java110.dto.attendance.AttendanceClassesStaffDto; |
| | | import com.java110.dto.classes.ScheduleClassesStaffDto; |
| | | import com.java110.dto.data.DataPrivilegeStaffDto; |
| | | import com.java110.dto.inspection.InspectionPlanStaffDto; |
| | | import com.java110.dto.maintainance.MaintainancePlanStaffDto; |
| | | import com.java110.dto.owner.OwnerAppUserDto; |
| | | import com.java110.dto.privilege.PrivilegeUserDto; |
| | | import com.java110.dto.repair.RepairTypeUserDto; |
| | | import com.java110.dto.store.StoreUserDto; |
| | | import com.java110.dto.user.StaffAppAuthDto; |
| | | import com.java110.intf.community.IInspectionPlanStaffV1InnerServiceSMO; |
| | | import com.java110.intf.community.IMaintainancePlanStaffV1InnerServiceSMO; |
| | | import com.java110.intf.community.IRepairTypeUserInnerServiceSMO; |
| | | import com.java110.intf.community.IRepairTypeUserV1InnerServiceSMO; |
| | | import com.java110.intf.store.IScheduleClassesStaffV1InnerServiceSMO; |
| | | import com.java110.intf.store.IStoreUserV1InnerServiceSMO; |
| | | import com.java110.intf.user.*; |
| | | import com.java110.po.attendance.AttendanceClassesStaffPo; |
| | | import com.java110.po.classes.ScheduleClassesStaffPo; |
| | | import com.java110.po.inspection.InspectionPlanStaffPo; |
| | | import com.java110.po.maintainance.MaintainancePlanStaffPo; |
| | | import com.java110.po.owner.OwnerAppUserPo; |
| | | import com.java110.po.privilege.DataPrivilegeStaffPo; |
| | | import com.java110.po.privilege.PrivilegeUserPo; |
| | | import com.java110.po.repair.RepairTypeUserPo; |
| | | import com.java110.po.store.StoreUserPo; |
| | | import com.java110.po.user.StaffAppAuthPo; |
| | | import com.java110.po.user.UserPo; |
| | | import com.java110.utils.exception.CmdException; |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.utils.util.BeanConvertUtil; |
| | | import com.java110.utils.util.ListUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | |
| | | import java.text.ParseException; |
| | | import java.util.List; |
| | | |
| | | @Java110Cmd(serviceCode = "user.deleteSystemUser") |
| | | public class DeleteSystemUserCmd extends Cmd { |
| | | |
| | | |
| | | @Autowired |
| | | private IRepairTypeUserInnerServiceSMO repairTypeUserInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IStoreUserV1InnerServiceSMO storeUserV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IPrivilegeUserV1InnerServiceSMO privilegeUserV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IRepairTypeUserV1InnerServiceSMO repairTypeUserV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IScheduleClassesStaffV1InnerServiceSMO scheduleClassesStaffV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IAttendanceClassesStaffV1InnerServiceSMO attendanceClassesStaffV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IInspectionPlanStaffV1InnerServiceSMO inspectionPlanStaffV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IStaffAppAuthInnerServiceSMO staffAppAuthInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IDataPrivilegeStaffV1InnerServiceSMO dataPrivilegeStaffV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IMaintainancePlanStaffV1InnerServiceSMO maintainancePlanStaffV1InnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl; |
| | | |
| | | @Override |
| | | public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { |
| | | super.validateAdmin(context); |
| | | Environment.isDevEnv(); |
| | | Assert.hasKeyAndValue(reqJson, "staffId", "未包含用户ID"); |
| | | } |
| | | |
| | | @Override |
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { |
| | | |
| | | // 删除员工信息 |
| | | deleteStaff(reqJson); |
| | | |
| | | //todo 删除用户 |
| | | deleteUser(reqJson); |
| | | |
| | | // 解绑业主 |
| | | OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto(); |
| | | ownerAppUserDto.setUserId(reqJson.getString("staffId")); |
| | | List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserV1InnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto); |
| | | if (ListUtil.isNull(ownerAppUserDtos)) { |
| | | return; |
| | | } |
| | | OwnerAppUserPo ownerAppUserPo = null; |
| | | for (OwnerAppUserDto tmpOwnerAppUserDto : ownerAppUserDtos) { |
| | | ownerAppUserPo = BeanConvertUtil.covertBean(tmpOwnerAppUserDto, OwnerAppUserPo.class); |
| | | ownerAppUserV1InnerServiceSMOImpl.deleteOwnerAppUser(ownerAppUserPo); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 删除商户 |
| | | * |
| | | * @param paramInJson |
| | | * @return |
| | | */ |
| | | public void deleteUser(JSONObject paramInJson) { |
| | | UserPo userPo = new UserPo(); |
| | | userPo.setUserId(paramInJson.getString("staffId")); |
| | | int flag = userV1InnerServiceSMOImpl.deleteUser(userPo); |
| | | |
| | | if (flag < 1) { |
| | | throw new CmdException("删除员工失败"); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 删除商户 |
| | | * |
| | | * @param reqJson |
| | | * @return |
| | | */ |
| | | public void deleteStaff(JSONObject reqJson) { |
| | | |
| | | StoreUserDto storeUserDto = new StoreUserDto(); |
| | | storeUserDto.setUserId(reqJson.getString("staffId")); |
| | | List<StoreUserDto> storeUserDtos = storeUserV1InnerServiceSMOImpl.queryStoreUsers(storeUserDto); |
| | | if (ListUtil.isNull(storeUserDtos)) { |
| | | return; |
| | | } |
| | | StoreUserPo storeUserPo = null; |
| | | for (StoreUserDto tmpStoreUserDto : storeUserDtos) { |
| | | storeUserPo = new StoreUserPo(); |
| | | storeUserPo.setStoreUserId(tmpStoreUserDto.getStoreUserId()); |
| | | storeUserPo.setUserId(tmpStoreUserDto.getUserId()); |
| | | storeUserPo.setStoreId(tmpStoreUserDto.getStoreId()); |
| | | storeUserV1InnerServiceSMOImpl.deleteStoreUser(storeUserPo); |
| | | } |
| | | |
| | | //todo 删除报修设置 |
| | | RepairTypeUserDto repairTypeUserDto = new RepairTypeUserDto(); |
| | | repairTypeUserDto.setStaffId(reqJson.getString("staffId")); |
| | | repairTypeUserDto.setStatusCd("0"); |
| | | List<RepairTypeUserDto> repairTypeUserDtoList = repairTypeUserInnerServiceSMOImpl.queryRepairTypeUsers(repairTypeUserDto); |
| | | if (!ListUtil.isNull(repairTypeUserDtoList)) { |
| | | for (RepairTypeUserDto tmpRepairTypeUserDto : repairTypeUserDtoList) { |
| | | JSONObject typeUserJson1 = (JSONObject) JSONObject.toJSON(tmpRepairTypeUserDto); |
| | | deleteRepairTypeUser(typeUserJson1); |
| | | } |
| | | } |
| | | //todo 删除员工排班数据 |
| | | deleteScheduleClassesStaff(reqJson); |
| | | |
| | | //todo 删除员工考勤组 |
| | | deleteAttendanceClassesStaff(reqJson); |
| | | |
| | | // todo 删除巡检员工 |
| | | deleteInspectionPlanStaff(reqJson); |
| | | |
| | | //todo 赋权 |
| | | deleteUserPrivilege(reqJson); |
| | | |
| | | // todo 删除员工认证 |
| | | deleteStaffAppAuth(reqJson); |
| | | |
| | | // todo 删除数据权限 |
| | | deleteStaffDataPri(reqJson); |
| | | |
| | | //todo 删除保养员工 |
| | | deleteMaintainanceStaff(reqJson); |
| | | } |
| | | |
| | | /** |
| | | * 删除数据权限 |
| | | * |
| | | * @param reqJson |
| | | */ |
| | | private void deleteStaffDataPri(JSONObject reqJson) { |
| | | |
| | | DataPrivilegeStaffDto dataPrivilegeStaffDto = new DataPrivilegeStaffDto(); |
| | | dataPrivilegeStaffDto.setStaffId(reqJson.getString("staffId")); |
| | | List<DataPrivilegeStaffDto> dataPrivilegeStaffDtos |
| | | = dataPrivilegeStaffV1InnerServiceSMOImpl.queryDataPrivilegeStaffs(dataPrivilegeStaffDto); |
| | | if (ListUtil.isNull(dataPrivilegeStaffDtos)) { |
| | | return; |
| | | } |
| | | for (DataPrivilegeStaffDto tmpDataPrivilegeStaffDto : dataPrivilegeStaffDtos) { |
| | | |
| | | DataPrivilegeStaffPo dataPrivilegeStaffPo = new DataPrivilegeStaffPo(); |
| | | dataPrivilegeStaffPo.setDpsId(tmpDataPrivilegeStaffDto.getDpsId()); |
| | | dataPrivilegeStaffV1InnerServiceSMOImpl.deleteDataPrivilegeStaff(dataPrivilegeStaffPo); |
| | | } |
| | | } |
| | | |
| | | private void deleteStaffAppAuth(JSONObject reqJson) { |
| | | |
| | | StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto(); |
| | | staffAppAuthDto.setStaffId(reqJson.getString("staffId")); |
| | | List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMOImpl.queryStaffAppAuths(staffAppAuthDto); |
| | | if (ListUtil.isNull(staffAppAuthDtos)) { |
| | | return; |
| | | } |
| | | for (StaffAppAuthDto tmpStaffAppAuthDto : staffAppAuthDtos) { |
| | | StaffAppAuthPo staffAppAuthPo = new StaffAppAuthPo(); |
| | | staffAppAuthPo.setAuId(tmpStaffAppAuthDto.getAuId()); |
| | | staffAppAuthInnerServiceSMOImpl.deleteStaffAppAuth(staffAppAuthPo); |
| | | } |
| | | } |
| | | |
| | | private void deleteInspectionPlanStaff(JSONObject reqJson) { |
| | | |
| | | InspectionPlanStaffDto inspectionPlanStaffDto = new InspectionPlanStaffDto(); |
| | | inspectionPlanStaffDto.setStaffId(reqJson.getString("staffId")); |
| | | List<InspectionPlanStaffDto> inspectionPlanStaffDtos |
| | | = inspectionPlanStaffV1InnerServiceSMOImpl.queryInspectionPlanStaffs(inspectionPlanStaffDto); |
| | | if (ListUtil.isNull(inspectionPlanStaffDtos)) { |
| | | return; |
| | | } |
| | | |
| | | for (InspectionPlanStaffDto tmpInspectionPlanStaffDto : inspectionPlanStaffDtos) { |
| | | InspectionPlanStaffPo inspectionPlanStaffPo = new InspectionPlanStaffPo(); |
| | | inspectionPlanStaffPo.setIpStaffId(tmpInspectionPlanStaffDto.getIpStaffId()); |
| | | inspectionPlanStaffV1InnerServiceSMOImpl.deleteInspectionPlanStaff(inspectionPlanStaffPo); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 删除保养员工 |
| | | * |
| | | * @param reqJson |
| | | */ |
| | | private void deleteMaintainanceStaff(JSONObject reqJson) { |
| | | MaintainancePlanStaffDto maintainancePlanStaffDto = new MaintainancePlanStaffDto(); |
| | | maintainancePlanStaffDto.setStaffId(reqJson.getString("staffId")); |
| | | List<MaintainancePlanStaffDto> maintainancePlanStaffDtos |
| | | = maintainancePlanStaffV1InnerServiceSMOImpl.queryMaintainancePlanStaffs(maintainancePlanStaffDto); |
| | | if (ListUtil.isNull(maintainancePlanStaffDtos)) { |
| | | return; |
| | | } |
| | | |
| | | for (MaintainancePlanStaffDto tmpMaintainancePlanStaffDto : maintainancePlanStaffDtos) { |
| | | MaintainancePlanStaffPo maintainancePlanStaffPo = new MaintainancePlanStaffPo(); |
| | | maintainancePlanStaffPo.setMpsId(tmpMaintainancePlanStaffDto.getMpsId()); |
| | | maintainancePlanStaffV1InnerServiceSMOImpl.deleteMaintainancePlanStaff(maintainancePlanStaffPo); |
| | | } |
| | | } |
| | | |
| | | private void deleteAttendanceClassesStaff(JSONObject reqJson) { |
| | | |
| | | AttendanceClassesStaffDto attendanceClassesStaffDto = new AttendanceClassesStaffDto(); |
| | | attendanceClassesStaffDto.setStaffId(reqJson.getString("staffId")); |
| | | List<AttendanceClassesStaffDto> attendanceClassesStaffDtos |
| | | = attendanceClassesStaffV1InnerServiceSMOImpl.queryAttendanceClassesStaffs(attendanceClassesStaffDto); |
| | | if (ListUtil.isNull(attendanceClassesStaffDtos)) { |
| | | return; |
| | | } |
| | | for (AttendanceClassesStaffDto tmpAttendanceClassesStaffDto : attendanceClassesStaffDtos) { |
| | | AttendanceClassesStaffPo attendanceClassesStaffPo = new AttendanceClassesStaffPo(); |
| | | attendanceClassesStaffPo.setCsId(tmpAttendanceClassesStaffDto.getCsId()); |
| | | attendanceClassesStaffV1InnerServiceSMOImpl.deleteAttendanceClassesStaff(attendanceClassesStaffPo); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 删除考勤员工 |
| | | * |
| | | * @param reqJson |
| | | */ |
| | | private void deleteScheduleClassesStaff(JSONObject reqJson) { |
| | | ScheduleClassesStaffDto scheduleClassesStaffDto = new ScheduleClassesStaffDto(); |
| | | scheduleClassesStaffDto.setStaffId(reqJson.getString("staffId")); |
| | | List<ScheduleClassesStaffDto> scheduleClassesStaffDtos |
| | | = scheduleClassesStaffV1InnerServiceSMOImpl.queryScheduleClassesStaffs(scheduleClassesStaffDto); |
| | | if (ListUtil.isNull(scheduleClassesStaffDtos)) { |
| | | return; |
| | | } |
| | | for (ScheduleClassesStaffDto tmpScheduleClassesStaffDto : scheduleClassesStaffDtos) { |
| | | ScheduleClassesStaffPo scheduleClassesStaffPo = new ScheduleClassesStaffPo(); |
| | | scheduleClassesStaffPo.setScsId(tmpScheduleClassesStaffDto.getScsId()); |
| | | scheduleClassesStaffV1InnerServiceSMOImpl.deleteScheduleClassesStaff(scheduleClassesStaffPo); |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 删除用户权限 |
| | | * |
| | | * @param paramInJson |
| | | */ |
| | | private void deleteUserPrivilege(JSONObject paramInJson) { |
| | | |
| | | PrivilegeUserDto privilegeUserDto = new PrivilegeUserDto(); |
| | | privilegeUserDto.setUserId(paramInJson.getString("staffId")); |
| | | List<PrivilegeUserDto> privilegeUserDtos = privilegeUserV1InnerServiceSMOImpl.queryPrivilegeUsers(privilegeUserDto); |
| | | |
| | | if (ListUtil.isNull(privilegeUserDtos)) { |
| | | return; |
| | | } |
| | | |
| | | for (PrivilegeUserDto tmpPrivilegeUserDto : privilegeUserDtos) { |
| | | PrivilegeUserPo privilegeUserPo = new PrivilegeUserPo(); |
| | | privilegeUserPo.setPuId(tmpPrivilegeUserDto.getPuId()); |
| | | int flag = privilegeUserV1InnerServiceSMOImpl.deletePrivilegeUser(privilegeUserPo); |
| | | if (flag < 1) { |
| | | throw new CmdException("删除员工失败"); |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 添加小区信息 |
| | | * |
| | | * @param paramInJson 接口调用放传入入参 |
| | | * @return 订单服务能够接受的报文 |
| | | */ |
| | | public void deleteRepairTypeUser(JSONObject paramInJson) { |
| | | |
| | | RepairTypeUserPo repairTypeUserPo = BeanConvertUtil.covertBean(paramInJson, RepairTypeUserPo.class); |
| | | //super.update(dataFlowContext, repairTypeUserPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_REPAIR_TYPE_USER); |
| | | int flag = repairTypeUserV1InnerServiceSMOImpl.deleteRepairTypeUser(repairTypeUserPo); |
| | | if (flag < 1) { |
| | | throw new CmdException("删除员工失败"); |
| | | } |
| | | } |
| | | |
| | | } |