<!--參數(shù)校驗(yàn)-->
<dependency>
 <groupId>javax.validation</groupId>
 <artifactId>validation-api</artifactId>
 <version>2.0.1.Final</version>
</dependency>


<!--提供一些字符串操作-->
<dependency>
 <groupId>org.apache.commons</groupId>
 <artifactId>commons-lang3</artifactId>
 <version>3.3.2</version>
</dependency>


<!--lombok-->
<dependency>
 <groupId>org.projectlombok</groupId>
 <artifactId>lombok</artifactId>
 <version>1.18.2</version>
 <optional>true</optional>
</dependency>


<!--knife4j接口-->
<dependency>
 <groupId>com.github.xiaoymin</groupId>
 <artifactId>knife4j-spring-boot-starter</artifactId>
 <version>2.0.4</version>
</dependency>

/**
* 用于實(shí)現(xiàn)枚舉類的校驗(yàn)
*/
public interface EnumValidate<T> {

 /**
 * 校驗(yàn)枚舉值是否存在
 */
 boolean existValidate(T value);
}

@Target({ElementType.FIELD, ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Constraint(validatedBy = {ActionTypeEnumValidator.class})
@Documented
public @interface ActionTypeEnumValid {

 String message() default "";


 Class<?>[] groups() default {};


 Class<? extends Payload>[] payload() default {};


 Class<?>[] target() default {};

 /**
 * 允許的枚舉
 *
 * @return
 */
 Class<? extends Enum<?>> enumClass();
}

/**
* 用于校驗(yàn)ActionTypeEnumValidator
*/
public class ActionTypeEnumValidator implements ConstraintValidator<ActionTypeEnumValid,String> {


 private Class<? extends Enum> enumClass;


 @Override
 public void initialize(ActionTypeEnumValid actionTypeEnumValid) {
 enumClass = actionTypeEnumValid.enumClass();
 }


 @Override
 public boolean isValid(String value, ConstraintValidatorContext context) {
 if (value == null || "".equals(value)) {
 return true;
 }


 EnumValidate[] enums = (EnumValidate[]) enumClass.getEnumConstants();
 if(enums ==null || enums.length == 0){
 return false;
 }


 return enums[0].existValidate(value);
 }

}

@Getter
public enum ActionTypeEnum implements EnumValidate<String> {


 ACTION_INVOKR("invoke", "invoke"),
 UNKNOWN_ERROR("no", "no");

 /**
 * 狀態(tài)值
 */
 private String couponType;

 /**
 * 狀態(tài)描述
 */
 private String couponTypeDesc;

 ActionTypeEnum(String couponType, String couponTypeDesc) {
 this.couponType = couponType;
 this.couponTypeDesc = couponTypeDesc;
 }


 public static String getDescByType(String couponType) {
 for (ActionTypeEnum type : ActionTypeEnum.values()) {
 if (type.couponType.equals(couponType) ) {
 return type.couponTypeDesc;
 }
 }
 return null;
 }

 /**
 * 判斷是否在枚舉類當(dāng)中
 * @param value
 * @return
 */
 @Override
 public boolean existValidate(String value) {
 if (value == null || "".equals(value)) {
 return false;
 }
 for (ActionTypeEnum testEnum : ActionTypeEnum.values()) {
 if (testEnum.getCouponType().equalsIgnoreCase(value)) {
 return true;
 }
 }
 return false;
 }

 public String getcouponTypeStr() {
 return String.valueOf(this.couponType);
 }
}

@RestControllerAdvice
@Slf4j
public class GlobalExceptionHandler {

 /**
 * 忽略參數(shù)異常處理器
 *
 * @param e 忽略參數(shù)異常
 * @return Response
 */
 @ResponseStatus(HttpStatus.BAD_REQUEST)
 @ExceptionHandler(MissingServletRequestParameterException.class)
 public ResponseResult parameterMissingExceptionHandler(MissingServletRequestParameterException e) {
 log.error("參數(shù)異常", e);
 return new ResponseResult(CouponTypeEnum.PARAMETER_ERROR.getcouponTypeStr(), "請求參數(shù) " + e.getParameterName() + " 不能為空");
 }


 /**
 * 缺少請求體異常處理器
 *
 * @param e 缺少請求體異常
 * @return Response
 */
 @ResponseStatus(HttpStatus.BAD_REQUEST)
 @ExceptionHandler(HttpMessageNotReadableException.class)
 public ResponseResult parameterBodyMissingExceptionHandler(HttpMessageNotReadableException e) {
 log.error("缺少請求體異常", e);
 return new ResponseResult(CouponTypeEnum.PARAMETER_ERROR.getcouponTypeStr(), "參數(shù)體不能為空");
 }


 /**
 * 參數(shù)效驗(yàn)異常處理器
 *
 * @param e 參數(shù)驗(yàn)證異常
 * @return ResponseInfo
 */
 @ResponseStatus(HttpStatus.BAD_REQUEST)
 @ExceptionHandler(MethodArgumentNotValidException.class)
 public ResponseResult parameterExceptionHandler(MethodArgumentNotValidException e) {
 log.error("參數(shù)驗(yàn)證異常", e);
 // 獲取異常信息
 BindingResult exceptions = e.getBindingResult();
 // 判斷異常中是否有錯誤信息，如果存在就使用異常中的消息，否則使用默認(rèn)消息
 if (exceptions.hasErrors()) {
 List<ObjectError> errors = exceptions.getAllErrors();
 if (!errors.isEmpty()) {
 // 這里列出了全部錯誤參數(shù)，按正常邏輯，只需要第一條錯誤即可
 FieldError fieldError = (FieldError) errors.get(0);
 return new ResponseResult(CouponTypeEnum.PARAMETER_ERROR.getcouponTypeStr(), fieldError.getDefaultMessage());
 }
 }
 return new ResponseResult(CouponTypeEnum.PARAMETER_ERROR);
 }


 /**
 * 自定義參數(shù)錯誤異常處理器
 *
 * @param e 自定義參數(shù)
 * @return ResponseInfo
 */
 @ResponseStatus(HttpStatus.BAD_REQUEST)
 @ExceptionHandler({BusinessException.class})
 public ResponseResult paramExceptionHandler(BusinessException e) {
 log.error("業(yè)務(wù)異常", e);
 // 判斷異常中是否有錯誤信息，如果存在就使用異常中的消息，否則使用默認(rèn)消息
 if (!StringUtils.isEmpty(e.getMessage())) {
 return new ResponseResult(CouponTypeEnum.PARAMETER_ERROR.getcouponTypeStr(), e.getMessage());
 }
 return new ResponseResult(CouponTypeEnum.PARAMETER_ERROR);
 }


 /**
 * 其他異常
 *
 * @param e
 * @return
 */
 @ResponseStatus(HttpStatus.BAD_REQUEST)
 @ExceptionHandler({Exception.class})
 public ResponseResult otherExceptionHandler(Exception e) {
 log.error("其他異常", e);
 // 判斷異常中是否有錯誤信息，如果存在就使用異常中的消息，否則使用默認(rèn)消息
 if (!StringUtils.isEmpty(e.getMessage())) {
 return new ResponseResult(CouponTypeEnum.UNKNOWN_ERROR.getcouponTypeStr(), e.getMessage());
 }
 return new ResponseResult(CouponTypeEnum.UNKNOWN_ERROR);
 }
}

/**
* 指令的封裝類
*/
@Getter
@Setter
@ToString
public class CommandPOJO implements Serializable {
 private static final long serialVersionUID = -8497328408069586664L;

 //指令
 @NotNull(message = "指令為必填項(xiàng)，不得為空")
 @ActionTypeEnumValid(message = "該指令暫不支持,暫時(shí)只支持invoke", enumClass = ActionTypeEnum.class)
 private String action ="invoke";

}

@RestController
@Slf4j
@Api(value = "遠(yuǎn)程調(diào)用模塊")
@RequestMapping("/xiyuanrpc")
public class RPCController {

 @PostMapping("/rpcNettybyInvoke")
 @ApiOperation(value = "rpc遠(yuǎn)程調(diào)用")
 @InvokeParameterCheck
 @MethodLogPrint
 public ResponseResult rpcNettybyInvoke(@Valid @RequestBody CommandPOJO pojo) {
 return NettyClientUtil.rpcNetty(pojo);
 }

}