import org.apache.ibatis.executor.Executor;import org.apache.ibatis.mapping.BoundSql;import org.apache.ibatis.mapping.MappedStatement;import org.apache.ibatis.mapping.ParameterMapping;import org.apache.ibatis.plugin.*;import org.apache.ibatis.session.ResultHandler;import org.apache.ibatis.session.RowBounds;
import java.lang.reflect.InvocationTargetException;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Properties;
/** * MyBatis拦截器，用于拦截SQL查询无入参的场景，避免全表查询 * */@Intercepts({        @Signature(type = Executor.class, method = "query",                args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class})})public class ParameterInterceptor implements Interceptor {
    private final Map<Object, Object> mappedStatementIdMap = new HashMap<Object, Object>();
    @Override    public Object intercept(Invocation invocation) throws InvocationTargetException, IllegalAccessException {        Object[] queryArgs = invocation.getArgs();
        MappedStatement mappedStatement = null;        if (queryArgs[0] instanceof MappedStatement) {            mappedStatement = (MappedStatement) queryArgs[0];        }
        if (null != mappedStatement && mappedStatementIdMap.containsKey(mappedStatement.getId())) {            // 获取SQL            BoundSql boundSql = mappedStatement.getBoundSql(queryArgs[1]);
            List<ParameterMapping> parameterMappingList = boundSql.getParameterMappings();
            if (parameterMappingList.isEmpty()) {                Profiler.businessAlarm(mappedStatement.getId(), "查询参数为空");                throw new BadArgumentException("查询参数为空，请确认入参是否有值");            }
        }
        return invocation.proceed();    }
    @Override    public Object plugin(Object target) {        return Plugin.wrap(target, this);    }
    @Override    public void setProperties(Properties properties) {        for (Object key : properties.keySet()) {            mappedStatementIdMap.put(key, 1);        }    }}

<jsf:filter id="callFilter" ref="jsfInvokeFilter"/>

import com.jd.jsf.gd.filter.AbstractFilter;import com.jd.jsf.gd.msg.RequestMessage;import com.jd.jsf.gd.msg.ResponseMessage;import com.jd.jsf.gd.util.RpcContext;import com.jd.ump.profiler.proxy.Profiler;import org.springframework.stereotype.Component;import java.util.HashMap;import java.util.Map;/** * JSF filter * JSF服务的调用次数统计 */@Componentpublic class JsfInvokeFilter extends AbstractFilter {    /**     * 按API接口统计方法调用量 - 业务监控KEY     */    private static final String API_PROVIDER_METHOD_COUNT_KEY = "api.jsf.provider.method.count.key";    private static final String API_CONSUMER_METHOD_COUNT_KEY = "api.jsf.consumer.method.count.key";    @Override    public ResponseMessage invoke(RequestMessage requestMessage) {        String key;        if (RpcContext.getContext().isProviderSide()) {            key = API_PROVIDER_METHOD_COUNT_KEY;        } else {            key = API_CONSUMER_METHOD_COUNT_KEY;        }        String method = requestMessage.getClassName() + "." + requestMessage.getMethodName();        Map<String, String> tags = new HashMap<String, String>(2);        tags.put("bMark", method);        tags.put("bCount", "1");        Profiler.sourceDataByStr(key, tags);        return getNext().invoke(requestMessage);    }}

import osimport openpyxlimport jsonimport requestsfrom cookies import Cookieimport time
headers = {    'Cookie': Cookie,    'Content-Type': 'application/json',    'token': '******',    'erp': '******'}

def get_jsf(start_time, end_time):    url = 'http://xxx.taishan.jd.com/api/xxx/xxx/xxx/'    body = {}    params = {'startTime': start_time,              'endTime': end_time,              'endPointKey': 'api.jsf.provider.method.count.key',              'quickTime': int((end_time - start_time) / 1000),              'markFlag': 'true',              'markLimit': 500}
    res = requests.post(url=url, data=json.dumps(body), params=params, headers=headers)
    print('url: ', res.request.url)  # 查看发送的url    # print('response: ', res.text)  # 返回请求结果
    res_json = json.loads(res.text)
    title = ['序号', 'jsf key', '次数', '占比%', '峰值', '次/秒', '峰值时间']    i = 0
    keys = {}    marks = res_json['response_data']['marks']    for mark in marks:        keys.setdefault(mark, [0, 0, 0, ''])
    data = []    records = res_json['response_data']['monitorData']    print(len(records))    for key, value in records.items():        count = 0        max_val = 0        max_time = ''        for val in value:            v = val['value']            count += v            if v > max_val:                max_val = v                max_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(int(val['dateTime'] / 1000)))        keys[key] = [count, max_val, int(max_val / 1200), max_time]
    key_list = sorted(keys.items(), key=lambda x: x[1], reverse=True)    # print(key_list)
    all_count = key_list[0][1][0]
    for key in key_list:        values = [i, key[0], key[1][0], str(round(key[1][0] / all_count * 100, 2)) + '%', key[1][1], key[1][2], key[1][3]]        data.append(values)        i += 1    #    # # print(data)    #    path = r"/Users/xxx/Documents/治理/QPS治理/"    os.chdir(path)  # 修改工作路径    workbook = openpyxl.Workbook()    sheet = workbook.active    sheet.title = 'JSF接口调用次数统计'    sheet.append(title)    for record in data:        sheet.append(record)    workbook.save('JSF接口调用次数统计-' + str(start_time / 1000) + '-' + str(end_time / 1000) + '.xlsx')

def change_time(dt):    # 转换成时间数组    time_array = time.strptime(dt, "%Y-%m-%d %H:%M:%S")    # 转换成时间戳    timestamp = time.mktime(time_array)    return int(timestamp * 1000)

if __name__ == '__main__':    start_time = '2024-03-06 12:20:00'    end_time = '2024-03-07 12:20:00'
    get_jsf(change_time(start_time), change_time(end_time))

Cookie = '*****'