完善代码

liurunyu

2024-07-30 f79e169e0f00b253e3df4f9e1f3535c8dcad61f9

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationScan.java

@@ -65,9 +65,9 @@
               int onLineDataMinLength;
               int headMinLength ;

               HashMap<String, AnnotationDriverVo> driverMap = ProtocolCach.getDriverMap() ;
               HashMap<String, AnnotationPrefixedDataAvailableVo> prefixedDataAvailableMap = ProtocolCach.getPrefixedDataAvailableMap() ;
               HashMap<String, AnnotationOnLineVo> onLineMap = ProtocolCach.getOnLineMap() ;
               HashMap<String, AnnotationDriverVo> driverMap = ProtocolCache.getDriverMap() ;
               HashMap<String, AnnotationPrefixedDataAvailableVo> prefixedDataAvailableMap = ProtocolCache.getPrefixedDataAvailableMap() ;
               HashMap<String, AnnotationOnLineVo> onLineMap = ProtocolCache.getOnLineMap() ;

               for(String cName : classNames){
                  String className = cName.substring(0,  cName.lastIndexOf('.')) ;
@@ -75,14 +75,16 @@
                  if(clazz.isAnnotationPresent(AnnotationDriver.class)){
                     AnnotationDriver ann = clazz.getAnnotation(AnnotationDriver.class) ;
                     if(ann != null){
                        protocolName = ann.name() ;
                        if(!(protocolName.trim().equals(""))){
                           if(driverMap.containsKey(protocolName)){
                              throw new Exception("严重错误，协议驱动名称" + protocolName + "出现了重复注解！") ;
                        if(ann.enable()){
                           protocolName = ann.name() ;
                           if(!(protocolName.trim().equals(""))){
                              if(driverMap.containsKey(protocolName)){
                                 throw new Exception("严重错误，协议驱动名称" + protocolName + "出现了重复注解！") ;
                              }
                              driverMap.put(protocolName, new AnnotationDriverVo(clazz)) ;
                           }else{
                              throw new Exception("严重错误，协议驱动名称注解值为空字符串") ;
                           }
                           driverMap.put(protocolName, new AnnotationDriverVo(clazz)) ;
                        }else{
                           throw new Exception("严重错误，协议驱动名称注解值为空字符串") ;
                        }
                     }
                  }
@@ -91,61 +93,64 @@
                  if(clazz.isAnnotationPresent(AnnotationPrefixedDataAvailable.class)){
                     AnnotationPrefixedDataAvailable ann = clazz.getAnnotation(AnnotationPrefixedDataAvailable.class) ;
                     if(ann != null){
                        protocolName = ann.protocolName() ;
                        if(!(protocolName.trim().equals(""))){
                           if(prefixedDataAvailableMap.containsKey(protocolName)){
                              throw new Exception("严重错误， 上行数据完整性检查所配协议驱动" + protocolName + "出现了重复注解！") ;
                        if(ann.enable()){
                           protocolName = ann.protocolName() ;
                           if(!(protocolName.trim().equals(""))){
                              if(prefixedDataAvailableMap.containsKey(protocolName)){
                                 throw new Exception("严重错误， 上行数据完整性检查所配协议驱动" + protocolName + "出现了重复注解！") ;
                              }
                           }else{
                              throw new Exception("严重错误，上行数据完整性检查所配协议驱动注解值为空字符串") ;
                           }
                        }else{
                           throw new Exception("严重错误，上行数据完整性检查所配协议驱动注解值为空字符串") ;
                        }

                        priority = ann.priority() ;
                        if(priority == 0){
                           throw new Exception("严重错误， 上行数据完整性检查所配优先级注解不能为0") ;
                        }
                        if(isRepeatPrefixedDataAvailablePriority(priority, prefixedDataAvailableMap)){
                           throw new Exception("严重错误， 上行数据完整性检查所配优先级注解(priority)数值" + priority + "重复") ;
                        }
                           priority = ann.priority() ;
                           if(priority == 0){
                              throw new Exception("严重错误， 上行数据完整性检查所配优先级注解不能为0") ;
                           }
                           if(isRepeatPrefixedDataAvailablePriority(priority, prefixedDataAvailableMap)){
                              throw new Exception("严重错误， 上行数据完整性检查所配优先级注解(priority)数值" + priority + "重复") ;
                           }

                        onLineDataMinLength = ann.onLineDataMinLength() ;
                  /*气象协议为0
                  if(onLineDataMinLength == 0){
                     throw new Exception("严重错误， 上行数据完整性检查所配上线数据最小长度注解不能为0") ;
                  }
                  */
                        headMinLength = ann.headMinLength() ;
                  /*气象协议为0
                  if(headMinLength == 0){
                     throw new Exception("严重错误， 上行数据完整性检查所配上报数据的头部最小长度注解不能为0") ;
                  }
                  */

                        prefixedDataAvailableMap.put(protocolName, new AnnotationPrefixedDataAvailableVo(clazz, protocolName, priority, onLineDataMinLength, headMinLength, ProtocolConstant.errorMaxLength)) ;
                           onLineDataMinLength = ann.onLineDataMinLength() ;
                           /*气象协议为0
                           if(onLineDataMinLength == 0){
                              throw new Exception("严重错误， 上行数据完整性检查所配上线数据最小长度注解不能为0") ;
                           }
                           */
                                    headMinLength = ann.headMinLength() ;
                           /*气象协议为0
                           if(headMinLength == 0){
                              throw new Exception("严重错误， 上行数据完整性检查所配上报数据的头部最小长度注解不能为0") ;
                           }
                           */
                           prefixedDataAvailableMap.put(protocolName, new AnnotationPrefixedDataAvailableVo(clazz, protocolName, priority, onLineDataMinLength, headMinLength, ProtocolConstant.errorMaxLength)) ;
                        }
                     }
                  }

                  if(clazz.isAnnotationPresent(AnnotationOnLine.class)){
                     AnnotationOnLine ann = clazz.getAnnotation(AnnotationOnLine.class) ;
                     if(ann != null){
                        protocolName = ann.protocolName() ;
                        if(!(protocolName.trim().equals(""))){
                           if(onLineMap.containsKey(protocolName)){
                              throw new Exception("严重错误， 上线数据分析所配协议驱动" + protocolName + "出现了重复注解！") ;
                        if(ann.enable()){
                           protocolName = ann.protocolName() ;
                           if(!(protocolName.trim().equals(""))){
                              if(onLineMap.containsKey(protocolName)){
                                 throw new Exception("严重错误， 上线数据分析所配协议驱动" + protocolName + "出现了重复注解！") ;
                              }
                           }else{
                              throw new Exception("严重错误，上线数据分析所配协议驱动注解值为空字符串") ;
                           }
                        }else{
                           throw new Exception("严重错误，上线数据分析所配协议驱动注解值为空字符串") ;
                        }

                        priority = ann.priority() ;
                        if(priority == 0){
                           throw new Exception("严重错误， 上线数据分析所配优先级注解不能为0") ;
                        }
                        if(isRepeatOnLinePriority(priority, onLineMap)){
                           throw new Exception("严重错误， 上线数据分析所配优先级注解(priority)数值" + priority + "重复") ;
                        }
                           priority = ann.priority() ;
                           if(priority == 0){
                              throw new Exception("严重错误， 上线数据分析所配优先级注解不能为0") ;
                           }
                           if(isRepeatOnLinePriority(priority, onLineMap)){
                              throw new Exception("严重错误， 上线数据分析所配优先级注解(priority)数值" + priority + "重复") ;
                           }

                        onLineMap.put(protocolName, new AnnotationOnLineVo(clazz, protocolName, priority)) ;
                           onLineMap.put(protocolName, new AnnotationOnLineVo(clazz, protocolName, priority)) ;
                        }
                     }
                  }
               }