| | |
| | | import com.vci.ubcs.starter.web.util.BeanUtilForVCI; |
| | | import com.vci.ubcs.starter.web.util.VciBaseUtil; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.collections4.map.CaseInsensitiveMap; |
| | | import org.springblade.core.secure.utils.AuthUtil; |
| | | import org.springblade.core.tool.api.R; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | private String msg=""; |
| | | @Value("${docking.apply.partCoe:10}") |
| | | public String partCoe; |
| | | @Value("${docking.apply.userFlag:false}") |
| | | @Value("${docking.apply.usedFlag:false}") |
| | | public boolean usedFlag; |
| | | @Value("${docking.apply.unitCode:41000}") |
| | | public String dockingApplyUnitCode; |
| | |
| | | @Transactional(rollbackFor = VciBaseException.class) |
| | | @Override |
| | | public R receiveEditApply(String oids, String btmName) throws VciBaseException { |
| | | if(usedFlag) { |
| | | if(!usedFlag) { |
| | | log.info("更新接口功能已关闭!->"+usedFlag); |
| | | R.success("更新接口功能已关闭!"); |
| | | } |
| | |
| | | //List<BaseModelVO> codeWupins=mdmEngineService.listByIds(VciBaseUtil.str2List(oids)); |
| | | List<BaseModel> dataModelList = new ArrayList<>(); |
| | | try { |
| | | R<List<BaseModel>> listR = mdmEngineClient.selectByTypeAndOid(btmName, oids); |
| | | if(listR.getData().size() == 0){ |
| | | return R.fail("为查询到相关业务数据!"); |
| | | } |
| | | dataModelList = listR.getData(); |
| | | if (!CollectionUtils.isEmpty(dataModelList)) { |
| | | DockingGroupDataVO dockingGroupDataVO = new DockingGroupDataVO(); |
| | | //申请单和申请单对象关系 |
| | |
| | | public R queryClassModel(String groupClassifyId) throws Throwable { |
| | | log.info("获取集团模型详细信息执行保存start"); |
| | | String message="执行成功!"; |
| | | if(usedFlag){ |
| | | if(!usedFlag){ |
| | | log.info("获取集团模型详细信息执行保存功能已关闭!->"+usedFlag); |
| | | return R.fail("获取集团模型详细信息接口已关闭!"); |
| | | } |
| | |
| | | public R queryMdmModel() throws Throwable { |
| | | String message="执行成功!"; |
| | | log.info("从集团获取主模型信息执行保存接口statr"); |
| | | if(usedFlag){ |
| | | if(!usedFlag){ |
| | | log.info("从集团获取主模型信息执行保存接口功能已关闭!->"+usedFlag); |
| | | return R.fail("查询模型视图接口已关闭!"); |
| | | } |
| | |
| | | } |
| | | return R.success(message); |
| | | }catch (Throwable e){ |
| | | e.printStackTrace();; |
| | | e.printStackTrace(); |
| | | log.error("获取数据模型失败"+e); |
| | | R.fail(message); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R queryApplyState(String dataOids) throws VciBaseException { |
| | | if(usedFlag){ |
| | | if(!usedFlag){ |
| | | log.info("查询申请单状态接口开关已关闭"); |
| | | return R.fail("查询申请单状态接口开关已关闭"); |
| | | } |
| | |
| | | } |
| | | |
| | | }catch (Throwable e){ |
| | | e.printStackTrace();; |
| | | e.printStackTrace(); |
| | | log.error("获取申请单状态失败"+e); |
| | | throw new VciBaseException(message); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public R syncClassifyModel(String classifyId, String operationType) throws VciBaseException { |
| | | if(usedFlag){ |
| | | if(!usedFlag){ |
| | | log.info("同步集团模型信息开关已关闭"); |
| | | return R.fail("同步集团模型信息开关已关闭"); |
| | | } |
| | |
| | | */ |
| | | private boolean saveDatas(DockingQueryClassModelVO dockingQueryClassifyModelVO) throws Throwable { |
| | | try { |
| | | DockingClassifyMainVO mainData = dockingQueryClassifyModelVO.getMainData(); |
| | | List<DockingClassifyVO> classList = mainData.getClassList(); |
| | | Map<String,List<DockingClassifyViewVO>>classInfoMap = mainData.getClassInfos(); |
| | | DockingClassifyMainVO data = dockingQueryClassifyModelVO.getData(); |
| | | List<DockingClassifyVO> classList = data.getClassList(); |
| | | Map<String,List<DockingClassifyViewVO>>classInfoMap = data.getClassInfos(); |
| | | ////initVCIInvocationInfo("1"); |
| | | List<DockingPreClassify> dockingPreClassifyArrayList=new ArrayList<>(); |
| | | for (DockingClassifyVO jclassObject : classList) { |
| | |
| | | Map<String, DockingPreViewModel> jviewmodelMap = new HashMap<String, DockingPreViewModel>(); |
| | | //Map<String, String> condtionMa = new HashMap<String, String>(); |
| | | // condtionMa.put("jsourceclsfid", jclassId); |
| | | List<DockingPreViewModel> dockingPreViewModelList= dockingPreViewModelService.list(Wrappers.<DockingPreViewModel>query().lambda().eq(DockingPreViewModel::getSourceClassifyId,false));// 根据分类查询模型视图对象 |
| | | List<DockingPreViewModel> dockingPreViewModelList= dockingPreViewModelService.list(Wrappers.<DockingPreViewModel>query().lambda().eq(DockingPreViewModel::getSourceClassifyId,jclassId));// 根据分类查询模型视图对象 |
| | | for (DockingPreViewModel dockingPreViewModel : dockingPreViewModelList) { |
| | | jviewmodelMap.put(dockingPreViewModel.getViewName(),dockingPreViewModel); |
| | | } |
| | | |
| | | for (DockingClassifyViewVO viewInfo : list) { |
| | | String viewName = com.alibaba.cloud.commons.lang.StringUtils.isBlank(viewInfo.getViewName())?"":viewInfo.getViewName(); |
| | | String impactList = com.alibaba.cloud.commons.lang.StringUtils.isBlank(viewInfo.getImpactList())?"":viewInfo.getImpactList(); |
| | | String impactList = viewInfo.getImpactList() == null ? "" : viewInfo.getImpactList().get(0).get(0); |
| | | log.info("VilewMode:-------------->视图名称:"+viewName); |
| | | log.info("VilewMode:-------------->影响编码项:"+impactList); |
| | | log.info("VilewMode:--------------> 集团分类主键:"+jclassId); |
| | |
| | | List<DockingClassifyMetaAttrVO> childMetaList = new ArrayList<>(); |
| | | childMetaList.add(compositeMeta); |
| | | getMetaAttrObject(childMetaList, jclassId,jviewModelObject, pid,allDockingPreMetaAttrList); |
| | | }else{ |
| | | allDockingPreMetaAttrList.add(dockingPreMetaAttr); |
| | | } |
| | | |
| | | } |
| | |
| | | List<DockingMainData> mainDataList=new ArrayList<DockingMainData>(); |
| | | for (BaseModel dataBusinessObject : codeWupins) { |
| | | String format = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date()); |
| | | String codeclsfid = dataBusinessObject.getData().getOrDefault("codeclsfid",""); |
| | | Map<String,String> dataValueMap=new CaseInsensitiveMap<>(dataBusinessObject.getData()); |
| | | String codeclsfid =dataValueMap.getOrDefault("codeclsfid",""); |
| | | String btmName = dataBusinessObject.getBtmname(); |
| | | String oid = dataBusinessObject.getOid(); |
| | | |
| | |
| | | //构造模型视图数据 |
| | | List<Map<String, Object>> viewValueList=new ArrayList<Map<String,Object>>(); |
| | | String oid = dockingPreViewModel.getOid(); |
| | | Map<String,String> dataValueMap=dataBusinessObject.getData(); |
| | | Map<String,String> dataValueMap=new CaseInsensitiveMap<>(dataBusinessObject.getData()); |
| | | String codeClassifyId=dataValueMap.get("codeclsfid"); |
| | | Map<String,String>conditionsMap=new HashMap<String, String>(); |
| | | List<DockingPreAttrMapping> dockingPreAttrMappingList = dockingPreAttrMappingMapper.selectList(Wrappers.<DockingPreAttrMapping>query().lambda() |
| | |
| | | Object newVaue=null; |
| | | if(StringUtils.isNotBlank(jtargetattrkey)){ |
| | | getAttrRange(dockingPreMetaAttr);//获取字段取值范围 |
| | | String value=dataValueMap.get(jtargetattrkey)==null?"":dataValueMap.getOrDefault(jtargetattrkey,""); |
| | | String value =""; |
| | | if(jtargetattrkey.toLowerCase(Locale.ROOT).equals("name")){ |
| | | value=dataBusinessObject.getName(); |
| | | }else if(jtargetattrkey.toLowerCase(Locale.ROOT).equals("id")){ |
| | | value=dataBusinessObject.getId(); |
| | | }else if(jtargetattrkey.toLowerCase(Locale.ROOT).equals("description")){ |
| | | value=dataBusinessObject.getDescription(); |
| | | }else { |
| | | value = dataValueMap.get(jtargetattrkey) == null ? "" : dataValueMap.getOrDefault(jtargetattrkey, ""); |
| | | } |
| | | newVaue = getVaue(dockingPreMetaAttr, value); |
| | | }else{ |
| | | newVaue = getVaue(dockingPreMetaAttr, ""); |
| | |
| | | viewValueMap.put(jenglishname, newVaue); |
| | | } |
| | | } |
| | | |
| | | viewValueList.add(viewValueMap); |
| | | return viewValueList; |
| | | } |