Source/UBCS/ubcs-service/ubcs-webservice/src/main/java/com/vci/ubcs/code/webservice/service/impl/GroupMdmInterServiceImpl.java

@@ -7,11 +7,11 @@
import com.fasterxml.jackson.databind.ObjectMapper;
import com.vci.ubcs.code.feign.IMdmEngineClient;
import com.vci.ubcs.code.webservice.entity.*;
import com.vci.ubcs.code.webservice.service.IGroupMdmInterService;
import com.vci.ubcs.code.webservice.vo.*;
import com.vci.ubcs.starter.util.MdmBtmTypeConstant;
import com.vci.ubcs.code.webservice.feign.MdmApplyGroupCodeProvider;
import com.vci.ubcs.code.webservice.mapper.DockingPreAttrMappingMapper;
import com.vci.ubcs.code.webservice.service.*;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil;
import com.vci.ubcs.starter.web.util.BeanUtilForVCI;
@@ -55,20 +55,20 @@
    * 集团分类服务
    */
   @Autowired(required = false)
   private IDockingPreClassifyService dockingPreClassifyService;
   private com.vci.ubcs.code.webservice.service.IDockingPreClassifyService dockingPreClassifyService;

   /***
    * 申请单服务
    */
   @Autowired(required = false)
   private IDockingPreApplyFormService dockingPreApplyFormService;
   private com.vci.ubcs.code.webservice.service.IDockingPreApplyFormService dockingPreApplyFormService;


   /***
    * 模型视图单服务
    */
   @Autowired(required = false)
   private IDockingPreViewModelService dockingPreViewModelService;
   private com.vci.ubcs.code.webservice.service.IDockingPreViewModelService dockingPreViewModelService;


   /***
@@ -80,14 +80,14 @@
    * 属性取值范围服务
    */
   @Autowired(required = false)
   private IDockingPreAttrRangeService dockingPreAttrRangeService;
   private com.vci.ubcs.code.webservice.service.IDockingPreAttrRangeService dockingPreAttrRangeService;


   /***
    * 集团属性服务
    */
   @Autowired(required = false)
   private IDockingPreMetaAttrService dockingPreMetaAttrService;
   private com.vci.ubcs.code.webservice.service.IDockingPreMetaAttrService dockingPreMetaAttrService;

   @Autowired(required = false)
   private IMdmEngineClient mdmEngineClient;
@@ -355,7 +355,7 @@
               throw new Throwable(message);
            }
         }else{
            message="未获从集团获取到任何模型信息";
            message="未从集团获取到任何模型信息";
            log.info(message);
            throw new Throwable(message);
         }
@@ -438,7 +438,7 @@
               throw new Throwable(message);
            }
         }else{
            message="未获从集团获取到任何模型信息";
            message="未从集团获取到任何模型信息";
            log.info(message);
            throw new Throwable(message);
         }
@@ -459,24 +459,57 @@
    * @param dataOids
    * @return 执行结果
    */
   public R queryApplyState(String dataOids) {
   @Override
   public R queryApplyState(String dataOids) throws VciBaseException {

      String message="执行成功！";
      log.info("查询申请单状态接口statr");
      try {
         VciBaseUtil.alertNotNull(dataOids,"所查申请单数据主键");
         VciBaseUtil.alertNotNull(dockingApplySysName,"系统标识配置：docking.apply.unitCode");

         List<String> applyIdList=new ArrayList<>();
         List<DockingPreApplyForm> dockingPreApplyFormList=   this.dockingPreApplyFormService.list(Wrappers.<DockingPreApplyForm>query().lambda().in(DockingPreApplyForm::getDataOid, VciBaseUtil.str2List(dataOids)));
         Map<String,DockingPreApplyForm> dockingPreApplyFormMap=new HashMap<>();
         dockingPreApplyFormList.stream().forEach(dockingPreApplyForm -> {
            dockingPreApplyForm.getId();

            applyIdList.add(dockingPreApplyForm.getId());
            dockingPreApplyFormMap.put(dockingPreApplyForm.getId(),dockingPreApplyForm);
         });

         DockingModelQueryVO dockingModelQueryVO=new DockingModelQueryVO();
         dockingModelQueryVO.setApplyNums(VciBaseUtil.array2String(applyIdList.toArray(new String[]{})));
         dockingModelQueryVO.setSysName(dockingApplySysName);
         DockingApplyFormQueryStatusVO dockingApplyFormQueryStatusVO=mdmApplyGroupCodeProvider.queryApplyState(dockingModelQueryVO);

         int code=dockingApplyFormQueryStatusVO.getCode();
         String mesg=dockingApplyFormQueryStatusVO.getMsg();
         if(code==1){
            List<DockingApplyFormStatusVO> dockingApplyFormStatusVOList=dockingApplyFormQueryStatusVO.getData();
            if(CollectionUtils.isEmpty(dockingApplyFormStatusVOList)){
               for (DockingApplyFormStatusVO applyFormDataState : dockingApplyFormStatusVOList) {
                  String applyId=applyFormDataState.getApplyNum();
                  String state= applyFormDataState.getFormState();
                  String examineOpinion=applyFormDataState.getExamineOpinion();
                  String jmsg=getCodeState(state)+"，意见："+examineOpinion;
                  if(dockingPreApplyFormMap.containsKey(applyId)){
                     DockingPreApplyForm applyFormObject=dockingPreApplyFormMap.get(applyId);
                     applyFormObject.setMsg(jmsg);
                  }
               }
               boolean res=this.dockingPreApplyFormService.saveOrUpdateBatch(dockingPreApplyFormList);
               if(res){
                  R.success("申请集团码状态查询成功:"+mesg);
               }
            }else{
               throw new Throwable("没有获取到相关数据信息");
            }
         }else{
            throw new   Throwable(mesg);
         }

      }catch (Throwable e){
         e.printStackTrace();;
         log.error("获取数据模型失败"+e);
         R.fail(message);
         log.error("获取申请单状态失败"+e);
         throw  new VciBaseException(message);
      }
      log.info("查询申请单状态接口end");
      return R.success(message);
@@ -968,4 +1001,28 @@
      }
      return value;
   }

   private String getCodeState(String formState){
      String msg="";
      if("1".equals(formState)){
         msg="集团审核中";
      }else if("2".equals(formState)){
         msg="驳回";
      }else if("3".equals(formState)){
         msg="集团审核中";
      }else if("4".equals(formState)){
         msg="审核结束，赋码失败";
      }else if("5".equals(formState)){
         msg="审核结束，赋码成功";
      }else if("6".equals(formState)){
         msg="待301赋码";
      }else if("7".equals(formState)){
         msg="已赋码";
      }else if("8".equals(formState)){
         msg="已赋码（沿用）";
      }else if("9".equals(formState)){
         msg="审核中";
      }
      return msg;
   }
}