From ee530992793ed7d0b7f16f1ce07b6c53ae265068 Mon Sep 17 00:00:00 2001 From: zhangherong <571457620@qq.com> Date: 星期二, 22 七月 2025 13:56:40 +0800 Subject: [PATCH] art: 技术状态变更申请-字典转译 --- lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java | 374 ++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 296 insertions(+), 78 deletions(-) diff --git a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java index c2ec226..5dbd7b1 100644 --- a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java +++ b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.apache.commons.lang3.StringUtils; @@ -13,30 +14,30 @@ 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.AssetStatusEnum; -import org.jeecg.modules.eam.constant.EquipmentMaintenanceStatus; -import org.jeecg.modules.eam.constant.EquipmentOperationTagEnum; -import org.jeecg.modules.eam.constant.EquipmentRepairStatus; +import org.jeecg.modules.eam.constant.*; import org.jeecg.modules.eam.entity.EamEquipment; import org.jeecg.modules.eam.entity.EamEquipmentExtend; import org.jeecg.modules.eam.mapper.EamEquipmentMapper; import org.jeecg.modules.eam.request.EamEquipmentQuery; import org.jeecg.modules.eam.service.IEamEquipmentExtendService; import org.jeecg.modules.eam.service.IEamEquipmentService; +import org.jeecg.modules.eam.tree.FindsEquipmentEamCenterUtil; import org.jeecg.modules.eam.tree.FindsEquipmentProductionUtil; import org.jeecg.modules.eam.vo.EamEquipmentTree; import org.jeecg.modules.eam.vo.EquipmentSearchResult; +import org.jeecg.modules.system.entity.BaseFactory; +import org.jeecg.modules.system.entity.BaseFactoryUser; import org.jeecg.modules.system.entity.MdcProduction; +import org.jeecg.modules.system.service.IBaseFactoryService; +import org.jeecg.modules.system.service.IBaseFactoryUserService; import org.jeecg.modules.system.service.IMdcProductionService; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collections; -import java.util.List; +import java.util.*; import java.util.stream.Collectors; /** @@ -54,6 +55,10 @@ private IEamEquipmentExtendService equipmentExtendService; @Autowired private IMdcProductionService mdcProductionService; + @Autowired + private IBaseFactoryUserService baseFactoryUserService; + @Autowired + private IBaseFactoryService baseFactoryService; @Override @Transactional(rollbackFor = Exception.class) @@ -69,13 +74,28 @@ //鎵╁睍琛ㄦ暟鎹悓姝ユ坊鍔� EamEquipmentExtend eamEquipmentExtend = new EamEquipmentExtend(); - eamEquipmentExtend.setId(eamEquipment.getId()); + BeanUtils.copyProperties(eamEquipment, eamEquipmentExtend); eamEquipmentExtend.setMaintenanceStatus(EquipmentMaintenanceStatus.NORMAL.name()); eamEquipmentExtend.setRepairStatus(EquipmentRepairStatus.NORMAL.name()); - equipmentExtendService.save(eamEquipmentExtend); //鎻掑叆璁惧灞ュ巻 @EquipmentHistoryLog + return eamEquipment; + } + + /** + * 鍙拌处璁惧缂栬緫 + * @param eamEquipment + */ + @Override + public EamEquipment updateEquipment(EamEquipment eamEquipment){ + if (eamEquipment == null) { + return null; + } + eamEquipmentMapper.updateById(eamEquipment); + EamEquipmentExtend eamEquipmentExtend = new EamEquipmentExtend(); + BeanUtils.copyProperties(eamEquipment, eamEquipmentExtend); + equipmentExtendService.updateById(eamEquipmentExtend); return eamEquipment; } @@ -100,6 +120,32 @@ return treeList; } + /** + * 鑾峰彇EAM涓績涓嬬殑璁惧淇℃伅 + * @param ids EAM涓績ids + * @return + */ + @Override + public List<EamEquipmentTree> loadTreeListByEamCenterIds(String ids){ + List<String> baseFactoryIds = Arrays.asList(ids.split(",")); + //鑾峰彇鎵�鏈塃AM鏁版嵁 + List<BaseFactory> baseFactoryList = baseFactoryService.list(new LambdaQueryWrapper<BaseFactory>().eq(BaseFactory::getDelFlag, CommonConstant.DEL_FLAG_0.toString()).orderByAsc(BaseFactory::getSorter)); + List<String> allBaseFactoryIds = new ArrayList<>(); + //鎵惧埌鎵�鏈変骇绾縤d鐨勪笂绾d + if (!baseFactoryIds.isEmpty()) { + for (String baseFactoryId : baseFactoryIds) { + this.getAllBaseFactoryIds(baseFactoryList, baseFactoryId, allBaseFactoryIds); + } + } + //杩囨护EAM鏁版嵁 + List<BaseFactory> list = baseFactoryList.stream().filter((BaseFactory baseFactory) -> allBaseFactoryIds.contains(baseFactory.getId())).collect(Collectors.toList()); + //缁勮EAM璁惧鏍� + List<EamEquipmentTree> treeList = FindsEquipmentEamCenterUtil.wrapEquipmentBaseFactoryTreeList(list); + //濉厖璁惧鏁版嵁 + fillEquipmentByBaseFactory(treeList); + return treeList; + } + @Override public IPage<EamEquipment> queryPageList(IPage<EamEquipment> page, EamEquipmentQuery eamEquipment) { QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>(); @@ -109,13 +155,202 @@ if (sysUser == null) { return page; } - if (StringUtils.isNotBlank(sysUser.getEquipmentIds())) { + if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 - List<String> equipArr = Arrays.asList(sysUser.getEquipmentIds().split(",")); + List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); queryWrapper.in("e.equipment_code", equipArr); } else { + //娌℃湁閫夋嫨璁惧锛屾牴鎹腑蹇冭繃婊よ澶� + List<BaseFactoryUser> baseFactoryUserList=baseFactoryUserService. + list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId,sysUser.getId())); + if(!CollectionUtils.isEmpty(baseFactoryUserList)){ + Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet()); + Set<String> factoryCode= baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet()); + queryWrapper.in("e.factory_org_code", factoryCode); + }else { + return page; + } + } + //鏌ヨ鏉′欢杩囨护 + if (eamEquipment != null) { + if (StringUtils.isNotBlank(eamEquipment.getEquipmentCode())) { + queryWrapper.like("e.equipment_code", eamEquipment.getEquipmentCode()); + } + if (StringUtils.isNotBlank(eamEquipment.getEquipmentName())) { + queryWrapper.like("e.equipment_name", eamEquipment.getEquipmentName()); + } + if (StringUtils.isNotBlank(eamEquipment.getEquipmentImportance())) { + queryWrapper.eq("e.equipment_importance", eamEquipment.getEquipmentImportance()); + } + if (StringUtils.isNotBlank(eamEquipment.getAssetStatus())) { + queryWrapper.like("e.asset_status", eamEquipment.getAssetStatus()); + } + if (StringUtils.isNotBlank(eamEquipment.getTechnologyStatus())) { + queryWrapper.like("e.technology_status", eamEquipment.getTechnologyStatus()); + } + if (StringUtils.isNotBlank(eamEquipment.getOperationSystem())) { + queryWrapper.like("e.operation_system", eamEquipment.getOperationSystem()); + } + if (StringUtils.isNotBlank(eamEquipment.getOrgId())) { + //杞﹂棿缂栫爜涓嶄负绌� + List<String> productIds = mdcProductionService.recursionChildren(eamEquipment.getOrgId()); + if (CollectionUtil.isNotEmpty(productIds)) { + //涓嶅仛绛涢�� + queryWrapper.in("e.org_id", productIds); + } + } + if (StringUtils.isNotBlank(eamEquipment.getEquipmentCategory())) { + queryWrapper.like("e.equipment_category", eamEquipment.getEquipmentCategory()); + } + if (StringUtils.isNotBlank(eamEquipment.getFactoryOrgCode())) { + queryWrapper.like("e.factory_org_code", eamEquipment.getFactoryOrgCode()); + } + if (StringUtils.isNotBlank(eamEquipment.getRepairDepartOrgCode())) { + queryWrapper.like("e.repair_depart_org_code", eamEquipment.getRepairDepartOrgCode()); + } + if (StringUtils.isNotBlank(eamEquipment.getId())) { + queryWrapper.eq("e.id", eamEquipment.getId()); + } + //鎺掑簭 + if (StringUtils.isNotBlank(eamEquipment.getColumn()) && StringUtils.isNotBlank(eamEquipment.getOrder())) { + //queryWrapper.like("column", eamEquipment.getColumn()); + String column = eamEquipment.getColumn(); + if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) { + column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX)); + } + if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(eamEquipment.getOrder())) { + queryWrapper.orderByAsc("e." + oConvertUtils.camelToUnderline(column)); + } else { + queryWrapper.orderByDesc("e." + oConvertUtils.camelToUnderline(column)); + } + } else { + queryWrapper.orderByDesc("e.create_time"); + } + } else { + queryWrapper.orderByDesc("e.create_time"); + } + + IPage<EamEquipment> ipage = eamEquipmentMapper.queryPageList(page, queryWrapper); + return ipage; + } + + @Override + public List<EquipmentSearchResult> asyncLoadEquipment(String keyword, Integer pageSize, String id, String factoryOrgCode) { + if (StringUtils.isNotBlank(id)) { + EamEquipment eamEquipment = eamEquipmentMapper.selectById(id); + if (eamEquipment != null) { + List<EquipmentSearchResult> resultList = new ArrayList<>(); + resultList.add(new EquipmentSearchResult(eamEquipment)); + return resultList; + } + } + IPage<EamEquipment> page = new Page<>(1, pageSize); + QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>(); + //鐢ㄦ埛鏁版嵁鏉冮檺 + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + return Collections.emptyList(); + } + if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { + //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 + List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); + queryWrapper.in("e.equipment_code", equipArr); + } else { + //娌℃湁閫夋嫨璁惧锛屾牴鎹腑蹇冭繃婊よ澶� + List<BaseFactoryUser> baseFactoryUserList=baseFactoryUserService. + list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId,sysUser.getId())); + if(!CollectionUtils.isEmpty(baseFactoryUserList)){ + Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet()); + Set<String> factoryCode = baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet()); + queryWrapper.in("e.factory_org_code", factoryCode); + } else { + return Collections.emptyList(); + } + } + + if (StringUtils.isNotBlank(keyword)) { + queryWrapper.like("e.equipment_code", keyword); + queryWrapper.or().like("e.equipment_name", keyword); + } + if(StringUtils.isNotBlank(factoryOrgCode)){ + queryWrapper.likeRight("e.factory_org_code", factoryOrgCode); + } + queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0); + IPage<EamEquipment> pageResult = eamEquipmentMapper.queryPageList(page, queryWrapper); + if (pageResult != null && CollectionUtil.isNotEmpty(pageResult.getRecords())) { + List<EquipmentSearchResult> resultList = new ArrayList<>(); + pageResult.getRecords().forEach((record) -> { + resultList.add(new EquipmentSearchResult(record)); + }); + return resultList; + } + return Collections.emptyList(); + } + + @Override + public EamEquipment selectByEquipmentCode(String equipmentCode) { + if (StringUtils.isBlank(equipmentCode)) { + return null; + } + QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>(); + //鐢ㄦ埛鏁版嵁鏉冮檺 + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + return null; + } + if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { + //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 + List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); + queryWrapper.in("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()); + List<BaseFactoryUser> baseFactoryUserList = baseFactoryUserService. + list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId, sysUser.getId())); + if (!CollectionUtils.isEmpty(baseFactoryUserList)) { + Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet()); + Set<String> factoryCodeList = baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet()); + queryWrapper.in("factory_org_code", factoryCodeList); + } else { + return null; + } + + } + queryWrapper.eq("equipment_code", equipmentCode); + queryWrapper.eq("del_flag", CommonConstant.DEL_FLAG_0); + + return eamEquipmentMapper.selectOne(queryWrapper); + } + + /** + * 璁惧鍙拌处瀵煎嚭 + * @param eamEquipment + * @return + */ + @Override + public List<EamEquipment> exportList(EamEquipmentQuery eamEquipment){ + QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0); + //鐢ㄦ埛鏁版嵁鏉冮檺 + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + return new ArrayList<>(); + } + if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { + //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 + List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); + queryWrapper.in("e.equipment_code", equipArr); + } else { + //娌℃湁閫夋嫨璁惧锛屾牴鎹腑蹇冭繃婊よ澶� + List<BaseFactoryUser> baseFactoryUserList=baseFactoryUserService. + list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId,sysUser.getId())); + if(!CollectionUtils.isEmpty(baseFactoryUserList)){ + Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet()); + Set<String> factoryCode= baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet()); + queryWrapper.in("e.factory_org_code", factoryCode); + }else { + return Collections.emptyList(); + } + } //鏌ヨ鏉′欢杩囨护 if (eamEquipment != null) { @@ -169,75 +404,17 @@ } else { queryWrapper.orderByDesc("e.create_time"); } - - IPage<EamEquipment> ipage = eamEquipmentMapper.queryPageList(page, queryWrapper); - return ipage; + return eamEquipmentMapper.queryList(queryWrapper); } @Override - public List<EquipmentSearchResult> asyncLoadEquipment(String keyword, Integer pageSize, String id) { - if (StringUtils.isNotBlank(id)) { - EamEquipment eamEquipment = eamEquipmentMapper.selectById(id); - if (eamEquipment != null) { - List<EquipmentSearchResult> resultList = new ArrayList<>(); - resultList.add(new EquipmentSearchResult(eamEquipment)); - return resultList; - } - } - IPage<EamEquipment> page = new Page<>(1, pageSize); + public List<EamEquipment> selectTechnicalEquipmentList() { QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>(); - //鐢ㄦ埛鏁版嵁鏉冮檺 - LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); - if (sysUser == null) { - return Collections.emptyList(); - } - if (StringUtils.isNotBlank(sysUser.getEquipmentIds())) { - //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 - List<String> equipArr = Arrays.asList(sysUser.getEquipmentIds().split(",")); - queryWrapper.in("equipment_code", equipArr); - } else { - //娌℃湁閫夋嫨璁惧锛屾牴鎹溅闂磋繃婊よ澶� - queryWrapper.exists("select 1 from mdc_user_production t where t.user_id={0} and t.pro_id=org_id", sysUser.getId()); - } - if (StringUtils.isNotBlank(keyword)) { - queryWrapper.like("equipment_code", keyword); - queryWrapper.or().like("equipment_name", keyword); - } - queryWrapper.eq("del_flag", CommonConstant.DEL_FLAG_0); - IPage<EamEquipment> pageResult = eamEquipmentMapper.queryPageList(page, queryWrapper); - if (pageResult != null && CollectionUtil.isNotEmpty(pageResult.getRecords())) { - List<EquipmentSearchResult> resultList = new ArrayList<>(); - pageResult.getRecords().forEach((record) -> { - resultList.add(new EquipmentSearchResult(record)); - }); - return resultList; - } - return Collections.emptyList(); - } - - @Override - public EamEquipment selectByEquipmentCode(String equipmentCode) { - if (StringUtils.isBlank(equipmentCode)) { - return null; - } - QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>(); - //鐢ㄦ埛鏁版嵁鏉冮檺 - LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); - if (sysUser == null) { - return null; - } - if (StringUtils.isNotBlank(sysUser.getEquipmentIds())) { - //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧 - List<String> equipArr = Arrays.asList(sysUser.getEquipmentIds().split(",")); - queryWrapper.in("equipment_code", equipArr); - } else { - //娌℃湁閫夋嫨璁惧锛屾牴鎹溅闂磋繃婊よ澶� - queryWrapper.exists("select 1 from mdc_user_production t where t.user_id={0} and t.pro_id=org_id", sysUser.getId()); - } - queryWrapper.eq("equipment_code", equipmentCode); - queryWrapper.eq("del_flag", CommonConstant.DEL_FLAG_0); - - return eamEquipmentMapper.selectOne(queryWrapper); + queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0); + queryWrapper.ne("ext.technology_status", TechnologyStatusEnum.PROHIBITED.name()); + queryWrapper.isNotNull("ext.technology_check_period"); + queryWrapper.isNotNull("ext.next_technology_check"); + return this.getBaseMapper().selectTechnicalEquipmentList(queryWrapper); } /** @@ -261,6 +438,26 @@ } /** + * 鑾峰彇鎵�鏈夌殑浜х嚎id锛堝寘鍚墍鏈変笂绾э級 + */ + private void getAllBaseFactoryIds(List<BaseFactory> baseFactoryList, String baseFactoryId, List<String> allBaseFactoryIds) { + if (!allBaseFactoryIds.contains(baseFactoryId)) { + allBaseFactoryIds.add(baseFactoryId); + } + for (BaseFactory baseFactory : baseFactoryList) { + if (StringUtils.isEmpty(baseFactory.getParentId())) { + continue; + } + if (baseFactoryId.equals(baseFactory.getId())) { + if (!allBaseFactoryIds.contains(baseFactory.getParentId())) { + allBaseFactoryIds.add(baseFactory.getParentId()); + getAllBaseFactoryIds(baseFactoryList, baseFactory.getParentId(), allBaseFactoryIds); + } + } + } + } + + /** * 浜х嚎璁惧鏍戝~鍏呰澶囨暟鎹� */ private void fillEquipmentByProduction(List<EamEquipmentTree> treeList) { @@ -281,4 +478,25 @@ } } + /** + * 浜х嚎璁惧鏍戝~鍏呰澶囨暟鎹� + */ + private void fillEquipmentByBaseFactory(List<EamEquipmentTree> treeList) { + for (EamEquipmentTree mdcEquipmentTree : treeList) { + List<EamEquipment> equipmentList = eamEquipmentMapper.queryByEamCenterId(mdcEquipmentTree.getKey()); + if (CollectionUtil.isNotEmpty(equipmentList)) { + for (EamEquipment mdcEquipment : equipmentList) { + EamEquipmentTree tree = new EamEquipmentTree().convert(mdcEquipment); + tree.setParentId(mdcEquipmentTree.getKey()); + tree.setType(2); + mdcEquipmentTree.getChildren().add(tree); + } + mdcEquipmentTree.setLeaf(false); + } + if (CollectionUtil.isNotEmpty(mdcEquipmentTree.getChildren())) { + fillEquipmentByBaseFactory(mdcEquipmentTree.getChildren()); + } + } + } + } -- Gitblit v1.9.3