mirror of
				https://github.com/songquanpeng/one-api.git
				synced 2025-11-04 15:53:42 +08:00 
			
		
		
		
	feat: save response time & test time (#59)
This commit is contained in:
		@@ -89,7 +89,6 @@ func AddChannel(c *gin.Context) {
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
	channel.CreatedTime = common.GetTimestamp()
 | 
			
		||||
	channel.AccessedTime = common.GetTimestamp()
 | 
			
		||||
	keys := strings.Split(channel.Key, "\n")
 | 
			
		||||
	channels := make([]model.Channel, 0)
 | 
			
		||||
	for _, key := range keys {
 | 
			
		||||
@@ -236,7 +235,9 @@ func TestChannel(c *gin.Context) {
 | 
			
		||||
	tik := time.Now()
 | 
			
		||||
	err = testChannel(channel, chatRequest)
 | 
			
		||||
	tok := time.Now()
 | 
			
		||||
	consumedTime := float64(tok.Sub(tik).Milliseconds()) / 1000.0
 | 
			
		||||
	milliseconds := tok.Sub(tik).Milliseconds()
 | 
			
		||||
	go channel.UpdateResponseTime(milliseconds)
 | 
			
		||||
	consumedTime := float64(milliseconds) / 1000.0
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		c.JSON(http.StatusOK, gin.H{
 | 
			
		||||
			"success": false,
 | 
			
		||||
 
 | 
			
		||||
@@ -13,7 +13,8 @@ type Channel struct {
 | 
			
		||||
	Name         string `json:"name" gorm:"index"`
 | 
			
		||||
	Weight       int    `json:"weight"`
 | 
			
		||||
	CreatedTime  int64  `json:"created_time" gorm:"bigint"`
 | 
			
		||||
	AccessedTime int64  `json:"accessed_time" gorm:"bigint"`
 | 
			
		||||
	TestTime     int64  `json:"test_time" gorm:"bigint"`
 | 
			
		||||
	ResponseTime int    `json:"response_time"` // in milliseconds
 | 
			
		||||
	BaseURL      string `json:"base_url" gorm:"column:base_url"`
 | 
			
		||||
	Other        string `json:"other"`
 | 
			
		||||
}
 | 
			
		||||
@@ -71,6 +72,16 @@ func (channel *Channel) Update() error {
 | 
			
		||||
	return err
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (channel *Channel) UpdateResponseTime(responseTime int64) {
 | 
			
		||||
	err := DB.Model(channel).Select("response_time", "test_time").Updates(Channel{
 | 
			
		||||
		TestTime:     common.GetTimestamp(),
 | 
			
		||||
		ResponseTime: int(responseTime),
 | 
			
		||||
	}).Error
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		common.SysError("failed to update response time: " + err.Error())
 | 
			
		||||
	}
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (channel *Channel) Delete() error {
 | 
			
		||||
	var err error
 | 
			
		||||
	err = DB.Delete(channel).Error
 | 
			
		||||
 
 | 
			
		||||
@@ -1,7 +1,7 @@
 | 
			
		||||
import React, { useEffect, useState } from 'react';
 | 
			
		||||
import { Button, Form, Label, Pagination, Popup, Table } from 'semantic-ui-react';
 | 
			
		||||
import { Link } from 'react-router-dom';
 | 
			
		||||
import { API, copy, showError, showInfo, showSuccess, timestamp2string } from '../helpers';
 | 
			
		||||
import { API, showError, showInfo, showSuccess, timestamp2string } from '../helpers';
 | 
			
		||||
 | 
			
		||||
import { CHANNEL_OPTIONS, ITEMS_PER_PAGE } from '../constants';
 | 
			
		||||
 | 
			
		||||
@@ -120,6 +120,22 @@ const ChannelsTable = () => {
 | 
			
		||||
    }
 | 
			
		||||
  };
 | 
			
		||||
 | 
			
		||||
  const renderResponseTime = (responseTime) => {
 | 
			
		||||
    let time = responseTime / 1000;
 | 
			
		||||
    time = time.toFixed(2) + " 秒";
 | 
			
		||||
    if (responseTime === 0) {
 | 
			
		||||
      return <Label basic color='grey'>未测试</Label>;
 | 
			
		||||
    } else if (responseTime <= 1000) {
 | 
			
		||||
      return <Label basic color='green'>{time}</Label>;
 | 
			
		||||
    } else if (responseTime <= 3000) {
 | 
			
		||||
      return <Label basic color='olive'>{time}</Label>;
 | 
			
		||||
    } else if (responseTime <= 5000) {
 | 
			
		||||
      return <Label basic color='yellow'>{time}</Label>;
 | 
			
		||||
    } else {
 | 
			
		||||
      return <Label basic color='red'>{time}</Label>;
 | 
			
		||||
    }
 | 
			
		||||
  };
 | 
			
		||||
 | 
			
		||||
  const searchChannels = async () => {
 | 
			
		||||
    if (searchKeyword === '') {
 | 
			
		||||
      // if keyword is blank, load files instead.
 | 
			
		||||
@@ -139,15 +155,20 @@ const ChannelsTable = () => {
 | 
			
		||||
    setSearching(false);
 | 
			
		||||
  };
 | 
			
		||||
 | 
			
		||||
  const testChannel = async (id, name) => {
 | 
			
		||||
  const testChannel = async (id, name, idx) => {
 | 
			
		||||
    const res = await API.get(`/api/channel/test/${id}/`);
 | 
			
		||||
    const { success, message, time } = res.data;
 | 
			
		||||
    if (success) {
 | 
			
		||||
      let newChannels = [...channels];
 | 
			
		||||
      let realIdx = (activePage - 1) * ITEMS_PER_PAGE + idx;
 | 
			
		||||
      newChannels[realIdx].response_time = time * 1000;
 | 
			
		||||
      newChannels[realIdx].test_time = Date.now() / 1000;
 | 
			
		||||
      setChannels(newChannels);
 | 
			
		||||
      showInfo(`通道 ${name} 测试成功,耗时 ${time} 秒。`);
 | 
			
		||||
    } else {
 | 
			
		||||
      showError(message);
 | 
			
		||||
    }
 | 
			
		||||
  }
 | 
			
		||||
  };
 | 
			
		||||
 | 
			
		||||
  const handleKeywordChange = async (e, { value }) => {
 | 
			
		||||
    setSearchKeyword(value.trim());
 | 
			
		||||
@@ -219,18 +240,18 @@ const ChannelsTable = () => {
 | 
			
		||||
            <Table.HeaderCell
 | 
			
		||||
              style={{ cursor: 'pointer' }}
 | 
			
		||||
              onClick={() => {
 | 
			
		||||
                sortChannel('created_time');
 | 
			
		||||
                sortChannel('response_time');
 | 
			
		||||
              }}
 | 
			
		||||
            >
 | 
			
		||||
              创建时间
 | 
			
		||||
              响应时间
 | 
			
		||||
            </Table.HeaderCell>
 | 
			
		||||
            <Table.HeaderCell
 | 
			
		||||
              style={{ cursor: 'pointer' }}
 | 
			
		||||
              onClick={() => {
 | 
			
		||||
                sortChannel('accessed_time');
 | 
			
		||||
                sortChannel('test_time');
 | 
			
		||||
              }}
 | 
			
		||||
            >
 | 
			
		||||
              访问时间
 | 
			
		||||
              测试时间
 | 
			
		||||
            </Table.HeaderCell>
 | 
			
		||||
            <Table.HeaderCell>操作</Table.HeaderCell>
 | 
			
		||||
          </Table.Row>
 | 
			
		||||
@@ -250,15 +271,15 @@ const ChannelsTable = () => {
 | 
			
		||||
                  <Table.Cell>{channel.name ? channel.name : '无'}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>{renderType(channel.type)}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>{renderStatus(channel.status)}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>{renderTimestamp(channel.created_time)}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>{renderTimestamp(channel.accessed_time)}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>{renderResponseTime(channel.response_time)}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>{channel.test_time ? renderTimestamp(channel.test_time) : "未测试"}</Table.Cell>
 | 
			
		||||
                  <Table.Cell>
 | 
			
		||||
                    <div>
 | 
			
		||||
                      <Button
 | 
			
		||||
                        size={'small'}
 | 
			
		||||
                        positive
 | 
			
		||||
                        onClick={() => {
 | 
			
		||||
                          testChannel(channel.id, channel.name);
 | 
			
		||||
                          testChannel(channel.id, channel.name, idx);
 | 
			
		||||
                        }}
 | 
			
		||||
                      >
 | 
			
		||||
                        测试
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user