Przeglądaj źródła

代码优化开发20211218

MSY 3 lat temu
rodzic
commit
a7dc435333

+ 30 - 13
src/main/java/com/jkcredit/invoice/credit/InterfaceCheckServer.java

@@ -28,6 +28,8 @@ public class InterfaceCheckServer {
 
         log.info("[-InterfaceCheckServer.doJumpHandler-] request appKey=" + appKey + " ,api=" + api + " ,data=" +data + " ,requestid=" +requestid);
 
+        long startTime = System.currentTimeMillis();
+
         DataResult resultTimeOut = new DataResult();
         resultTimeOut.setData(3);
         resultTimeOut.setCode(200);
@@ -40,7 +42,7 @@ public class InterfaceCheckServer {
             //----------------------------自有车、无车公共接口---------------------------------//
             case "COMPANY_ADD_V1"://无车、自有车企业注册
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -50,7 +52,7 @@ public class InterfaceCheckServer {
                 break;
             case "PROTOCOL_ADD_V1"://无车、自有车协议上传
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -60,7 +62,7 @@ public class InterfaceCheckServer {
                 break;
             case "COMPANY_QUERY_V1"://无车、自有车企业查询
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -74,7 +76,7 @@ public class InterfaceCheckServer {
                 //----------------------------自有车下游接口---------------------------------//
             case "CARD_BIND_QUERY_LIST_V1"://自有车 用户卡列表查询
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -84,7 +86,7 @@ public class InterfaceCheckServer {
                 break;
             case "CARD_QUERY_CARD_V1"://自有车 卡信息查询
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -94,7 +96,7 @@ public class InterfaceCheckServer {
                 break;
             case "CARD_BINDING_V1"://自有车 下发短信验证码
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -104,7 +106,7 @@ public class InterfaceCheckServer {
                 break;
             case "CARD_VALID_CODE_V1"://自有车 卡绑定接口 渠道调用此接口,上传用户收到的短信验证码
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -114,7 +116,7 @@ public class InterfaceCheckServer {
                 break;
             case "CARD_TRADE_V1"://自有车 交易查询接口 渠道通过此接口可以查询单张卡连续90天内的交易(待开票、开票中、已开票)
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -124,7 +126,7 @@ public class InterfaceCheckServer {
                 break;
             case "B2B_INVOICE_APPLY_V1"://自有车 申请开票接口 渠道通过此接口可以对该公司绑定的单张卡连续90天内的交易进行开票。
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -134,7 +136,7 @@ public class InterfaceCheckServer {
                 break;
             case "B2B_INVOICE_QUERY_V1"://自有车 已开发票查询接口 渠道通过此接口可以根据该公司绑定的单张卡查询此卡在某个月开具的发票。
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -144,7 +146,7 @@ public class InterfaceCheckServer {
                 break;
             case "B2B_INVOICE_PACKAGE_V1"://自有车 发票下载 渠道通过此接口可以下载某公司某个月份开具的发票。
                 if(StatisRequestIdTimeComp.isLimit){
-                    log.info(appKey+"被拒绝");
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -162,6 +164,7 @@ public class InterfaceCheckServer {
             //----------------------------无车下游接口---------------------------------//
             case "VEHICLE_REGISTER"://无车 车辆备案接口
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -170,10 +173,18 @@ public class InterfaceCheckServer {
                 }
                 break;
             case "VEHICLE_REGISTER_QUERY"://无车 车辆备案查询接口
-                result = noCarInterService.customeRecUpperQuery(appKey,api,data,requestid);
+                if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
+                    result = resultTimeOut;
+                }else{
+                    statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
+                    result = noCarInterService.customeRecUpperQuery(appKey,api,data,requestid);
+                    statisRequestIdTimeComp.removeReQuestIdAndTime(requestid);
+                }
                 break;
             case "WAY_BILL_START"://无车 实时运单开始指令
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -183,6 +194,7 @@ public class InterfaceCheckServer {
                 break;
             case "WAY_BILL_END"://无车 实时运单结束指令
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -192,6 +204,7 @@ public class InterfaceCheckServer {
                 break;
             case "WAY_BILL_HISTORY_START"://无车 历史运单开始指令
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -201,6 +214,7 @@ public class InterfaceCheckServer {
                 break;
             case "WAY_BILL_HISTORY_END"://无车 历史运单结束指令
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -210,6 +224,7 @@ public class InterfaceCheckServer {
                 break;
             case "WAY_BILL_NUM_FIND_INVOICE"://无车  运单号查询发票数据
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -219,6 +234,7 @@ public class InterfaceCheckServer {
                 break;
             case "FIND_NO_SEARCH_NUM"://无车  获取未查询过发票的运单编号
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -228,6 +244,7 @@ public class InterfaceCheckServer {
                 break;
             case "BALANCE_QUERY"://无车   账号余额查询接口
                 if(StatisRequestIdTimeComp.isLimit){
+                    log.info("InterfaceCheckServer.doJumpHandler,appKey=" + appKey + " ,api="+api + " ,data=" + data + " ,requestid=" + requestid +"=被拒绝");
                     result = resultTimeOut;
                 }else{
                     statisRequestIdTimeComp.putReQuestIdAndTime(requestid);
@@ -240,7 +257,7 @@ public class InterfaceCheckServer {
                 break;
         }
 
-        log.info("[-InterfaceCheckServer.doJumpHandler-] result appKey=" + appKey + " ,api=" + api + " ,data=" +data + " ,requestid=" +requestid+ " ,result="+result);
+        log.info("[-InterfaceCheckServer.doJumpHandler-] result appKey=" + appKey + " ,api=" + api + " ,data=" +data + " ,requestid=" +requestid+ " ,result="+result + " ,costTime="+(System.currentTimeMillis()-startTime) );
 
         return result;