xiejun
2023-09-15 d989fc036d8e3c2261491e2ba89efcfc21939fb7
Source/UBCS/ubcs-service/ubcs-applyjtcodeservice/src/main/java/com/vci/ubcs/code/applyjtcodeservice/service/impl/GroupMdmInterServiceImpl.java
@@ -41,8 +41,10 @@
   private String code="";
   private String msg="";
   @Value("${docking.apply.partCoe:10}")
   public String partCoe;
   @Value("${docking.apply.userFlag:false}")
   public boolean usedFlag;
   @Value("${docking.apply.unitCode:41000}")
   public String dockingApplyUnitCode;
@@ -101,6 +103,7 @@
   @Transactional(rollbackFor = VciBaseException.class)
   @Override
   public R applyGroupCode(String oids, String btmName) throws VciBaseException {
      if(usedFlag) {
      try {
         List<BaseModel> updateCbos = new ArrayList<BaseModel>();
         List<DockingPreApplyForm> dockingPreAttrMappings = new ArrayList<>();
@@ -165,6 +168,7 @@
                  if (isEditDatas) {
                     if (baseModelMap.containsKey(applyId)) {
                        BaseModel baseModel = baseModelMap.get(applyId);
                           baseModel.getData().getOrDefault("codeclassid","");
                        BeanUtilForVCI.copyDeclaredIgnoreCase(baseModel, baseModel);
                        DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
                        DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
@@ -204,6 +208,9 @@
      }catch (VciBaseException e){
         return R.fail("申请接口调用失败"+e);
      }
      }else{
         return R.fail("申请接口开关已关闭,不申请集团码");
      }
   }
   /***
@@ -216,6 +223,10 @@
   @Transactional(rollbackFor = VciBaseException.class)
   @Override
   public R receiveEditApply(String oids, String btmName) throws VciBaseException {
      if(usedFlag) {
         log.info("更新接口功能已关闭!->"+usedFlag);
         R.success("更新接口功能已关闭!");
      }
      List<BaseModel> updateCbos=new ArrayList<BaseModel>();
      List<DockingPreApplyForm> dockingPreAttrMappings=new ArrayList<>();
      VciBaseUtil.alertNotNull(oids,"选择的数据");
@@ -283,7 +294,7 @@
                        //BeanUtilForVCI.copyDeclaredIgnoreCase(baseModelVO, baseModel);
                        DefaultAttrAssimtUtil.updateDefaultAttrAssimt(baseModel);
                     //   baseModel.setId(customCoding);
                        baseModel.getData().getOrDefault("groupCode",customCoding);
                        baseModel.getData().put("groupCode", customCoding);
                        updateCbos.add(baseModel);//更新数据集团code
                     }
                  }
@@ -314,9 +325,9 @@
            dockingPreApplyFormService.saveOrUpdateBatch(dockingPreAttrMappings);
            mdmEngineClient.updateBatchByType(btmName,updateCbos);//保存数据
         }
         return R.success("申请接口调用成功");
         return R.success("更新接口调用成功");
      }catch (VciBaseException e){
         return R.fail("申请接口调用失败"+e.getMessage());
         return R.fail("更新接口调用失败" + e.getMessage());
      }
   }
@@ -330,6 +341,10 @@
   public R queryClassModel(String groupClassifyId) throws Throwable {
      log.info("获取集团模型详细信息执行保存start");
      String message="执行成功!";
      if(usedFlag){
         log.info("获取集团模型详细信息执行保存功能已关闭!->"+usedFlag);
         return R.fail("获取集团模型详细信息接口已关闭!");
      }
      try {
         if (StringUtils.isBlank(groupClassifyId)) {
            message = "参数:集团分类主键,为空!";
@@ -361,12 +376,12 @@
         }
         return R.success(message);
      }catch (Throwable e){
         e.printStackTrace();;
         e.printStackTrace();
         log.error("获取数据模型详细信息失败"+e);
         R.fail(message);
      }
         return R.fail(message);
      }finally {
      log.info("获取集团模型详细信息执行保存end");
      return R.success(message);
      }
   }
   /***
@@ -378,6 +393,10 @@
   public R queryMdmModel() throws Throwable {
      String message="执行成功!";
      log.info("从集团获取主模型信息执行保存接口statr");
      if(usedFlag){
         log.info("从集团获取主模型信息执行保存接口功能已关闭!->"+usedFlag);
         return R.fail("查询模型视图接口已关闭!");
      }
      try {
         if (StringUtils.isBlank(dockingApplySysName)) {
            message = "获取系统标识" + dockingApplySysName + "为空,请查看配置!";
@@ -461,7 +480,10 @@
    */
   @Override
   public R queryApplyState(String dataOids) throws VciBaseException {
      if(usedFlag){
         log.info("查询申请单状态接口开关已关闭");
         return R.fail("查询申请单状态接口开关已关闭");
      }
      String message="执行成功!";
      log.info("查询申请单状态接口statr");
      try {
@@ -524,6 +546,10 @@
    */
   @Override
   public R syncClassifyModel(String classifyId, String operationType) throws VciBaseException {
      if(usedFlag){
         log.info("同步集团模型信息开关已关闭");
         return R.fail("同步集团模型信息开关已关闭");
      }
      VciBaseUtil.alertNotNull(operationType,"集成操作类型");
      try {
         if(operationType.equals("all")){