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 = '*****'