我寫的代碼，又被CTO罵了......

public?boolean?canConsume(String?uid,String?shopId,String?supplierId){
????//獲取用戶信息，用戶信息包含類型（student：學(xué)生，teacher：老師，unknown：未知用戶）、名族（han：漢族，mg：蒙古族）
????UserInfo?userInfo?=?getUserInfo(uid);
????//獲取消費(fèi)限制信息，限制信息包含是否允許非清真消費(fèi)、每種類型的用戶是否允許消費(fèi)以及允許消費(fèi)的次數(shù)
???ConsumeConfigInfo?consumeConfigInfo?=?getConsumeConfigInfo(shopId,supplierId)?


????//?構(gòu)造消費(fèi)限制過濾器鏈條
????ConsumeLimitFilterChain?filterChain?=?new?ConsumeLimitFilterChain();
????filterChain.addFilter(new?SpecificCardUserConsumeLimitFilter());
????filterChain.addFilter(new?DayConsumeTimesConsumeLimitFilter());
????filterChain.addFilter(new?MuslimConsumeLimitFilter());
????boolean?checkResult?=?filterChain.doFilter(filterChain,?schoolMemberInfo,?consumeConfigInfo);

????//filterChain.doFilter方法
???public?boolean?doFilter(ConsumeLimitFilterChain?filterChain,UserInfo?userInfo,
?????????????ConsumeConfigInfo?consumeConfigInfo?){
????????//迭代調(diào)用過濾器
????????if(index????????????return?filters.get(index++).doFilter(filterChain,?userInfo,?consumeConfigInfo);
????????}
????}

????//SpecificCardUserConsumeLimitFilter.doFilter方法
?????public?boolean?doFilter(ConsumeLimitFilterChain?filterChain,UserInfo?userInfo,
?????????????ConsumeConfigInfo?consumeConfigInfo?){
????????????????//獲取某一類型的消費(fèi)限制，比如student允許消費(fèi)，unknown不允許消費(fèi)
????????CardConsumeConfig?cardConsumeConfig?=?findSuitCardConfig(userInfo,?consumeConfigInfo);

????????//?判斷當(dāng)前卡用戶是否允許消費(fèi)
????????if?(consumeCardConfig?!=?null)?{
????????????if?((!CAN_PAY.equals(cardConsumeConfig?.getEnabledPay())))?{
????????????????return?false;
????????????}
????????}

????????????????//其余情況，繼續(xù)往后傳遞
????????????return?filterChain.doFilter(filterChain,?memberInfo,?consumeConfig);
????????}

????//DayConsumeTimesConsumeLimitFilter.doFilter方法
?????public?boolean?doFilter(ConsumeLimitFilterChain?filterChain,UserInfo?userInfo,
?????????????ConsumeConfigInfo?consumeConfigInfo?){
????????????????//獲取某一類型的消費(fèi)限制，比如student可以消費(fèi)2次
????????CardConsumeConfig?cardConsumeConfig?=?findSuitCardConfig(userInfo,?consumeConfigInfo);

????????????????//獲取當(dāng)前用戶今天的消費(fèi)次數(shù)
????????????????int?consumeCnt?=?getConsumeCnt(userInfo)????????
????????if(consumeCnt?>=?cardConsumeConfig.getDayConsumeTimesLimit()){
????????????????????return?false;
????????????????}

????????????????//其余情況，繼續(xù)往后傳遞
????????????????return?filterChain.doFilter(filterChain,?memberInfo,?consumeConfig);
????????}

/**
?*?推送策略
?*?/
public?interface?PushStrategy?{
????/**
?????????@param?deviceVO設(shè)備對(duì)象，包扣設(shè)備sn，信鴿pushid
?????????@param?content，推送內(nèi)容，一般為json
????????*/
????public?CallResult?push(AppDeviceVO?deviceVO,?Object?content);
}

IotPushStrategy?implements?PushStrategy{
????????/**
?????????@param?deviceVO設(shè)備對(duì)象，包扣設(shè)備sn，信鴿pushid
?????????@param?content，推送內(nèi)容，一般為json
????????*/
????public?CallResult?push(AppDeviceVO?deviceVO,?Object?content){
????????????//創(chuàng)建自研推送平臺(tái)需要的推送報(bào)文
????????????Message?message?=?createPushMsg(deviceVO，content);

????????????//調(diào)用推送平臺(tái)推送接口
????????????IotMessageService.pushMsg(message);
????????}
}

XingePushStrategy?implements?PushStrategy{
????????/**
?????????@param?deviceVO設(shè)備對(duì)象，包扣設(shè)備sn，信鴿pushid
?????????@param?content，推送內(nèi)容，一般為json
????????*/
????public?CallResult?push(AppDeviceVO?deviceVO,?Object?content){
????????????//創(chuàng)建信鴿平臺(tái)需要的推送報(bào)文
????????????JSONObject?jsonObject?=?createPushMsg(content);

????????????//調(diào)用推送平臺(tái)推送接口
????????????if(!XinggePush.pushMsg(message)){
????????????????//降級(jí)到長(zhǎng)輪詢
????????????????...
????????????}
????????}
}

/**
消息推送Service
*/
MessagePushService{
????pushMsg(AppDeviceVO?deviceVO,?Object?content){
????????if(A設(shè)備){
????????????XingePushStrategy.push(deviceVO,content);
????????}?else?if(B設(shè)備）{
????????????IotPushStrategy.push(deviceVO,content);
????????}
????}
}

abstract?class?AbstractPushStrategy?implements?PushStrategy{
????@Override
????public?CallResult?push(AppDeviceVO?deviceVO,?Object?content)?{
????????//1.構(gòu)造span
????????Span?span?=?buildSpan();
????????//2.具體通道推送邏輯由子類實(shí)現(xiàn)
????????CallResult?callResult?=?doPush(deviceVO,?content);

????????//3.是否允許重試邏輯由子類實(shí)現(xiàn)，如果允許執(zhí)行重試邏輯
????????if(!callResult.isSuccess()?&&?canRetry()){
????????????doPush(deviceVO,?content);
????????}

????????//4.trace結(jié)束
????????span.finish()?
????}

????//具體推送邏輯由子類實(shí)現(xiàn)
????protected?abstract?CallResult?doPush(AppDeviceVO?deviceDO,?Object?content)?;

????//是否允許重試由子類實(shí)現(xiàn)，有些通道之前沒有做消息排重，所有不能重試
????protected?abstract?boolean?canRetry(CallResult?callResult);

}

XingePushStrategy?extends?AbstractPushStrategy{
????@Override
????protected?CallResult?doPush(AppDeviceVO?deviceDO,?Object?content)?{
????????//執(zhí)行推送邏輯
????}

????@Override
????protected?boolean?canRetry(CallResult?callResult){
????????return?false
????}
}

/**
支付回調(diào)處理者
*/
PayCallBackController?implements?ApplicationContextAware?{
?????private?ApplicationContext?applicationContext;

????//如果想獲取applicationContext需要實(shí)現(xiàn)ApplicationContextAware接口，Spring容器會(huì)回調(diào)setApplicationContext方法將applicationContext注入進(jìn)來
????@Override
????public?void?setApplicationContext(ApplicationContext?applicationContext)
????????????throws?BeansException?{
????????this.applicationContext?=?applicationContext;
????}
?????@RequestMapping(value?=?"/pay/callback.do")
?????public?View?callback(HttpServletRequest?request){
????????if(paySuccess(request){
????????????//構(gòu)造支付成功事件
????????????PaySuccessEvent?event?=?buildPaySuccessEvent(...);
????????????//通過applicationContext發(fā)布事件，從而達(dá)到通知觀察者的目的
????????????this.applicationContext.publishEvent(event);
????????}?
????}
}
/**
?*?語(yǔ)音播報(bào)處理者
?*
?*/
public?class?VoiceBroadcastHandler?implements?ApplicationListener<PaySuccessEvent>{
????@Override
????public?void?onApplicationEvent(PaySuccessEvent?event)?{
????????//語(yǔ)音播報(bào)邏輯
????}
}

//其他處理者的邏輯類似

/**
可以自動(dòng)攜帶trace上下文的Runnable裝飾器
*/
public?class?TraceRunnableWrapper?implements?Runnable{
????//被包裝的目標(biāo)對(duì)象
????private?Runnable?task;
????private?Span?parentSpan?=?null;

????public?TraceRunnableWrapper(Runnable?task)?{
????????//1.獲取當(dāng)前線程的上下文（因?yàn)閚ew的時(shí)候還沒有發(fā)生線程切換，所以需要在這里將上下文獲?。?/span>
????????//對(duì)這塊代碼感興趣的可以查看opentracing?API
????????io.opentracing.Scope?currentScope?=?GlobalTracer.get().scopeManager().active();
????????//2.保存父上下文
????????parentSpan?=?currentScope.span();
????????this.task?=?task;
????}

????@Override
????public?void?run()?{
????????//run的時(shí)候?qū)⒏妇€程的上下文綁定到當(dāng)前線程
????????io.opentracing.Scope?scope?=?GlobalTracer.get().scopeManager().activate(parentSpan,false);
????????task.run();
????}
}

//使用者
new?Thread(new?Runnable(){run(...)}).start()替換為new?TraceRunnableWrapper(new?Runnable(){run(...)}).start()

使用者：
HttpClient.doPost("/gateway.do","{'method':'trade.create','sign':'wxxaaa','timestamp':'15311111111'},'bizContent':'業(yè)務(wù)參數(shù)'")

GatewayController:
@RequestMapping("/gateway.do")
JSON?gateway(HttpServletRequest?req){
???//1.組裝開放請(qǐng)求
???OpenRequest?openRequest?=?buildOpenRequest(req);

???OpenResponse?openResponse?=?null;
???//2.請(qǐng)求路由
???if("trade.create".equals(openRequest.getMethod()){
???????//proxy?to?trade?service?by?dubbo
???????openResponse?=?TradeFacade.execute(genericParam);
???}?else?if("iot.message.push".equals(openRequest.getMethod()){
???????//proxy?to?iot?service?by?httpclient
????????openResponse?=?HttpClient.doPost('http://iot.service/generic/execute'genericParam);
???}

???if(openResponse.isSuccess()){
????????return?{"code":"10000","bizContent":openResponse.getResult()};
???}else{
????????return?{"code":"20000","bizCode":openResponse.getCode()};
???}


}