SpringBoot使用反射对业务代码进行统一处理

public interface BlackValidateService {
    /**
     * @Description: 根据手机号判断是否在黑名单中
     * @param phone
     * @return com.p4.risk.entity.RiskRetCode
     * @author Surpass
     * @date 2020/12/2 13:56
     */
    RiskRetCode getPhone(String phone);

    /**
     * @Description: 根据身份证号判断是否在黑名单中
     * @param idCardNum
     * @return com.p4.risk.entity.RiskRetCode
     * @author Surpass
     * @date 2020/12/2 13:56
     */
    RiskRetCode getIdCardNum(String idCardNum);

    /**
     * @Description: 根据终端号判断是否在黑名单中
     * @param termNo
     * @return com.p4.risk.entity.RiskRetCode
     * @author Surpass
     * @date 2020/12/2 13:56
     */
    RiskRetCode getTermNo(String termNo);

    /**
     * @Description: 根据银行卡号判断是否在黑名单中
     * @param cardNum
     * @return com.p4.risk.entity.RiskRetCode
     * @author Surpass
     * @date 2020/12/2 13:57
     */
    RiskRetCode getCardNum(String cardNum);

    /**
     * @Description: 根据营业执照号判断是否在黑名单中
     * @param busLicenseNo
     * @return com.p4.risk.entity.RiskRetCode
     * @author Surpass
     * @date 2020/12/2 13:57
     */
    RiskRetCode getBusLicenseNo(String busLicenseNo);

    /**
     * @Description: 根据基站号，小区号判断是否在黑名单中
     * @param stationNo
     * @param cellId
     * @return com.p4.risk.entity.RiskRetCode
     * @author Surpass
     * @date 2020/12/2 13:57
     */
    RiskRetCode getBaseStation(String stationNo, String cellId);
}

@Slf4j
@RestController
@RequestMapping("/mposDataValidate")
public class MposDataValidateController {

    /**
     * mpos黑名单校验方法
     */
    @Autowired
    private BlackValidateService validate;

    private Gson gson = new Gson();

    /**
     * @Description: 利用反射将黑名单方法和参数进行绑定，根据参数key不同来查询不同的黑名单
     * @param param 需要校验的参数：idCardNum，termNo，cardNum，busLicenseNo，stationNo，cellId，phone
     * @return java.util.Map<java.lang.String , java.lang.Object>
     * @author Surpass
     * @date 2020/12/2 13:22
     */
    @RequestMapping("/dataValidator")
    public Map<String,Object> dataValidator(@RequestBody Map<String,Object> param){
        log.info("mpos外放接口调用，校验黑名单传入参数:"+gson.toJson(param));
        Map<String, Object> resultMap = new HashMap<>(2);
        if (param.size() == 0){
            resultMap.put("rspCode","99");
            resultMap.put("rspMsg","接口数据参数为空");
            log.info("接口数据参数为空");
            return resultMap;
        }
        try {
            //基站号参数key
            String stationNo = "stationNo";
            //小区号参数key
            String cellId = "cellId";
            //基站黑名单方法名
            String baseStationMethodName = "getBaseStation";
            //基站号参数value
            String stationNoVal = null;
            //小区号参数value
            String cellIdVal = null;
            RiskRetCode result = null;
            //获得接口校验的class类对象
            Class<BlackValidateService> cls = BlackValidateService.class;
            //遍历参数
            for (Map.Entry<String, Object> entry : param.entrySet()) {
                String key = entry.getKey();
                String value = (String) entry.getValue();
                if (StringUtils.isBlank(value)){
                    continue;
                }
                //基站信息特殊处理
                if ((stationNo).equals(key)){
                    stationNoVal = value;
                    continue;
                }
                if ((cellId).equals(key)){
                    cellIdVal = value;
                    continue;
                }
                //根据参数key获取方法名   getPhone...
                String methodsName = "get"+key.substring(0,1).toUpperCase()+key.substring(1);
                //根据方法名和方法参数确定某一个方法
                Method method = cls.getMethod(methodsName, String.class);
                //执行，对方法进行访问赋值
                result = (RiskRetCode)method.invoke(validate, value);

                if (Objects.equals(result.getValue(), RiskRetCode.R00.getValue())){
                    //校验通过，进行下一个  00通过
                    resultMap.put("rspCode",RiskRetCode.R00.getValue());
                    resultMap.put("rspMsg",result.getDesc());
                    continue;
                }else {
                    //在黑名单中，直接返回    99不通过
                    resultMap.put("rspCode",RiskRetCode.R99.getValue());
                    resultMap.put("rspMsg",result.getDesc());
                    return resultMap;
                }
            }
            //基站需要基站号和小区号
            if (StringUtils.isNotEmpty(stationNoVal) && StringUtils.isNotEmpty(cellIdVal)){
                //根据方法名和方法参数确定某一个方法
                Method method = cls.getMethod(baseStationMethodName, String.class, String.class);
                //执行，对方法进行访问赋值
                result = (RiskRetCode)method.invoke(validate, stationNoVal,cellIdVal);
            }
            if (Objects.equals(result.getValue(), RiskRetCode.R00.getValue())){
                resultMap.put("rspCode",RiskRetCode.R00.getValue());
                resultMap.put("rspMsg",result.getDesc());
            }else {
                resultMap.put("rspCode",RiskRetCode.R99.getValue());
                resultMap.put("rspMsg",result.getDesc());
                return resultMap;
            }
        }catch (Exception e){
            log.error("mpos外放接口黑名单校验异常",e);
            resultMap.put("rspCode",RiskRetCode.R99.getValue());
            resultMap.put("rspMsg","mpos外放接口黑名单校验异常");
            return resultMap;
        }
        if (resultMap.size() == 0){
            resultMap.put("rspCode", RiskRetCode.R99.getValue());
            resultMap.put("rspMsg", "本次请求没有过任何黑名单接口");
        }
        log.info("mpos外放接口调用，校验黑名单返回参数:"+gson.toJson(resultMap));
        return resultMap;
    }

}