| | |
| | | import org.apache.shiro.SecurityUtils; |
| | | import org.jeecg.common.api.vo.FileUploadResult; |
| | | import org.jeecg.common.constant.CommonConstant; |
| | | import org.jeecg.common.constant.DataBaseConstant; |
| | | import org.jeecg.common.system.vo.LoginUser; |
| | | import org.jeecg.common.util.oConvertUtils; |
| | | import org.jeecg.modules.eam.aspect.annotation.EquipmentHistoryLog; |
| | | import org.jeecg.modules.eam.constant.*; |
| | | import org.jeecg.modules.eam.entity.*; |
| | |
| | | * 分页列表 |
| | | * |
| | | * @param page |
| | | * @param eamReportRepairQuery |
| | | * @param query |
| | | * @return |
| | | */ |
| | | @Override |
| | | public IPage<EamReportRepair> pageList(Page<EamReportRepair> page, EamReportRepairQuery eamReportRepairQuery) { |
| | | public IPage<EamReportRepair> pageList(Page<EamReportRepair> page, EamReportRepairQuery query) { |
| | | QueryWrapper<EamReportRepair> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("wmo.del_flag", CommonConstant.DEL_FLAG_0); |
| | | //用户数据权限 |
| | | LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); |
| | | if (sysUser == null) { |
| | | return page; |
| | | } |
| | | List<String> equipmentIds = new ArrayList<>(); |
| | | if (StringUtils.isNotBlank(sysUser.getEquipmentIds())) { |
| | | //选择了设备,根据设备id过滤设备 |
| | | equipmentIds = Arrays.asList(sysUser.getEquipmentIds().split(",")); |
| | | List<String> equipArr = Arrays.asList(sysUser.getEquipmentIds().split(",")); |
| | | queryWrapper.in("e.equipment_code", equipArr); |
| | | } else { |
| | | //没有选择设备,根据车间过滤设备 |
| | | queryWrapper.exists("select 1 from mdc_user_production t where t.user_id={0} and t.pro_id=e.org_id ", sysUser.getId()); |
| | | } |
| | | return this.baseMapper.pageList(page, eamReportRepairQuery, sysUser.getId(), equipmentIds); |
| | | //查询条件过滤 |
| | | if (query != null) { |
| | | if (StringUtils.isNotBlank(query.getEquipmentId())) { |
| | | queryWrapper.eq("wmo.equipment_id", query.getEquipmentId()); |
| | | } |
| | | if (StringUtils.isNotBlank(query.getEquipmentCode())) { |
| | | queryWrapper.like("e.equipment_code", query.getEquipmentCode()); |
| | | } |
| | | if (StringUtils.isNotBlank(query.getEquipmentName())) { |
| | | queryWrapper.like("e.equipment_name", query.getEquipmentName()); |
| | | } |
| | | if (StringUtils.isNotBlank(query.getBreakdownFlag())) { |
| | | queryWrapper.eq("wmo.breakdown_flag", query.getBreakdownFlag()); |
| | | } |
| | | if (StringUtils.isNotBlank(query.getReportStatus())) { |
| | | queryWrapper.eq("wmo.report_status", query.getReportStatus()); |
| | | } |
| | | if (StringUtils.isNotBlank(query.getFaultDescription())) { |
| | | queryWrapper.like("wmo.fault_description", query.getFaultDescription()); |
| | | } |
| | | if(query.getStartTime() != null && query.getEndTime() != null) { |
| | | queryWrapper.between("wmo.fault_start_time", query.getStartTime(), query.getEndTime()); |
| | | } |
| | | //排序 |
| | | if (StringUtils.isNotBlank(query.getColumn()) && StringUtils.isNotBlank(query.getOrder())) { |
| | | String column = query.getColumn(); |
| | | if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) { |
| | | column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX)); |
| | | } |
| | | if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(query.getOrder())) { |
| | | queryWrapper.orderByAsc("wmo." + oConvertUtils.camelToUnderline(column)); |
| | | } else { |
| | | queryWrapper.orderByDesc("wmo." + oConvertUtils.camelToUnderline(column)); |
| | | } |
| | | } else { |
| | | queryWrapper.orderByDesc("wmo.create_time"); |
| | | } |
| | | } else { |
| | | queryWrapper.orderByDesc("wmo.create_time"); |
| | | } |
| | | |
| | | return baseMapper.queryPageList(page, queryWrapper); |
| | | } |
| | | |
| | | @Override |