ChannelsTable.js 65 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133
  1. import React, { useEffect, useState, useMemo, useRef } from 'react';
  2. import {
  3. API,
  4. showError,
  5. showInfo,
  6. showSuccess,
  7. timestamp2string,
  8. renderGroup,
  9. renderQuota,
  10. getChannelIcon,
  11. renderQuotaWithAmount
  12. } from '../../helpers/index.js';
  13. import { CHANNEL_OPTIONS, ITEMS_PER_PAGE, MODEL_TABLE_PAGE_SIZE } from '../../constants/index.js';
  14. import {
  15. Button,
  16. Divider,
  17. Dropdown,
  18. Empty,
  19. Input,
  20. InputNumber,
  21. Modal,
  22. Space,
  23. SplitButtonGroup,
  24. Switch,
  25. Table,
  26. Tag,
  27. Tooltip,
  28. Typography,
  29. Checkbox,
  30. Card,
  31. Form,
  32. Tabs,
  33. TabPane,
  34. Select
  35. } from '@douyinfe/semi-ui';
  36. import {
  37. IllustrationNoResult,
  38. IllustrationNoResultDark
  39. } from '@douyinfe/semi-illustrations';
  40. import EditChannel from '../../pages/Channel/EditChannel.js';
  41. import {
  42. IconTreeTriangleDown,
  43. IconSearch,
  44. IconMore,
  45. } from '@douyinfe/semi-icons';
  46. import { loadChannelModels, isMobile, copy } from '../../helpers';
  47. import EditTagModal from '../../pages/Channel/EditTagModal.js';
  48. import { useTranslation } from 'react-i18next';
  49. import { useTableCompactMode } from '../../hooks/useTableCompactMode';
  50. const ChannelsTable = () => {
  51. const { t } = useTranslation();
  52. let type2label = undefined;
  53. const renderType = (type) => {
  54. if (!type2label) {
  55. type2label = new Map();
  56. for (let i = 0; i < CHANNEL_OPTIONS.length; i++) {
  57. type2label[CHANNEL_OPTIONS[i].value] = CHANNEL_OPTIONS[i];
  58. }
  59. type2label[0] = { value: 0, label: t('未知类型'), color: 'grey' };
  60. }
  61. return (
  62. <Tag
  63. color={type2label[type]?.color}
  64. shape='circle'
  65. prefixIcon={getChannelIcon(type)}
  66. >
  67. {type2label[type]?.label}
  68. </Tag>
  69. );
  70. };
  71. const renderTagType = () => {
  72. return (
  73. <Tag
  74. color='light-blue'
  75. shape='circle'
  76. type='light'
  77. >
  78. {t('标签聚合')}
  79. </Tag>
  80. );
  81. };
  82. const renderStatus = (status) => {
  83. switch (status) {
  84. case 1:
  85. return (
  86. <Tag color='green' shape='circle'>
  87. {t('已启用')}
  88. </Tag>
  89. );
  90. case 2:
  91. return (
  92. <Tag color='red' shape='circle'>
  93. {t('已禁用')}
  94. </Tag>
  95. );
  96. case 3:
  97. return (
  98. <Tag color='yellow' shape='circle'>
  99. {t('自动禁用')}
  100. </Tag>
  101. );
  102. default:
  103. return (
  104. <Tag color='grey' shape='circle'>
  105. {t('未知状态')}
  106. </Tag>
  107. );
  108. }
  109. };
  110. const renderResponseTime = (responseTime) => {
  111. let time = responseTime / 1000;
  112. time = time.toFixed(2) + t(' 秒');
  113. if (responseTime === 0) {
  114. return (
  115. <Tag color='grey' shape='circle'>
  116. {t('未测试')}
  117. </Tag>
  118. );
  119. } else if (responseTime <= 1000) {
  120. return (
  121. <Tag color='green' shape='circle'>
  122. {time}
  123. </Tag>
  124. );
  125. } else if (responseTime <= 3000) {
  126. return (
  127. <Tag color='lime' shape='circle'>
  128. {time}
  129. </Tag>
  130. );
  131. } else if (responseTime <= 5000) {
  132. return (
  133. <Tag color='yellow' shape='circle'>
  134. {time}
  135. </Tag>
  136. );
  137. } else {
  138. return (
  139. <Tag color='red' shape='circle'>
  140. {time}
  141. </Tag>
  142. );
  143. }
  144. };
  145. // Define column keys for selection
  146. const COLUMN_KEYS = {
  147. ID: 'id',
  148. NAME: 'name',
  149. GROUP: 'group',
  150. TYPE: 'type',
  151. STATUS: 'status',
  152. RESPONSE_TIME: 'response_time',
  153. BALANCE: 'balance',
  154. PRIORITY: 'priority',
  155. WEIGHT: 'weight',
  156. OPERATE: 'operate',
  157. };
  158. // State for column visibility
  159. const [visibleColumns, setVisibleColumns] = useState({});
  160. const [showColumnSelector, setShowColumnSelector] = useState(false);
  161. // 状态筛选 all / enabled / disabled
  162. const [statusFilter, setStatusFilter] = useState(
  163. localStorage.getItem('channel-status-filter') || 'all'
  164. );
  165. // Load saved column preferences from localStorage
  166. useEffect(() => {
  167. const savedColumns = localStorage.getItem('channels-table-columns');
  168. if (savedColumns) {
  169. try {
  170. const parsed = JSON.parse(savedColumns);
  171. // Make sure all columns are accounted for
  172. const defaults = getDefaultColumnVisibility();
  173. const merged = { ...defaults, ...parsed };
  174. setVisibleColumns(merged);
  175. } catch (e) {
  176. console.error('Failed to parse saved column preferences', e);
  177. initDefaultColumns();
  178. }
  179. } else {
  180. initDefaultColumns();
  181. }
  182. }, []);
  183. // Update table when column visibility changes
  184. useEffect(() => {
  185. if (Object.keys(visibleColumns).length > 0) {
  186. // Save to localStorage
  187. localStorage.setItem(
  188. 'channels-table-columns',
  189. JSON.stringify(visibleColumns),
  190. );
  191. }
  192. }, [visibleColumns]);
  193. // Get default column visibility
  194. const getDefaultColumnVisibility = () => {
  195. return {
  196. [COLUMN_KEYS.ID]: true,
  197. [COLUMN_KEYS.NAME]: true,
  198. [COLUMN_KEYS.GROUP]: true,
  199. [COLUMN_KEYS.TYPE]: true,
  200. [COLUMN_KEYS.STATUS]: true,
  201. [COLUMN_KEYS.RESPONSE_TIME]: true,
  202. [COLUMN_KEYS.BALANCE]: true,
  203. [COLUMN_KEYS.PRIORITY]: true,
  204. [COLUMN_KEYS.WEIGHT]: true,
  205. [COLUMN_KEYS.OPERATE]: true,
  206. };
  207. };
  208. // Initialize default column visibility
  209. const initDefaultColumns = () => {
  210. const defaults = getDefaultColumnVisibility();
  211. setVisibleColumns(defaults);
  212. };
  213. // Handle column visibility change
  214. const handleColumnVisibilityChange = (columnKey, checked) => {
  215. const updatedColumns = { ...visibleColumns, [columnKey]: checked };
  216. setVisibleColumns(updatedColumns);
  217. };
  218. // Handle "Select All" checkbox
  219. const handleSelectAll = (checked) => {
  220. const allKeys = Object.keys(COLUMN_KEYS).map((key) => COLUMN_KEYS[key]);
  221. const updatedColumns = {};
  222. allKeys.forEach((key) => {
  223. updatedColumns[key] = checked;
  224. });
  225. setVisibleColumns(updatedColumns);
  226. };
  227. // Define all columns with keys
  228. const allColumns = [
  229. {
  230. key: COLUMN_KEYS.ID,
  231. title: t('ID'),
  232. dataIndex: 'id',
  233. },
  234. {
  235. key: COLUMN_KEYS.NAME,
  236. title: t('名称'),
  237. dataIndex: 'name',
  238. },
  239. {
  240. key: COLUMN_KEYS.GROUP,
  241. title: t('分组'),
  242. dataIndex: 'group',
  243. render: (text, record, index) => (
  244. <div>
  245. <Space spacing={2}>
  246. {text
  247. ?.split(',')
  248. .sort((a, b) => {
  249. if (a === 'default') return -1;
  250. if (b === 'default') return 1;
  251. return a.localeCompare(b);
  252. })
  253. .map((item, index) => renderGroup(item))}
  254. </Space>
  255. </div>
  256. ),
  257. },
  258. {
  259. key: COLUMN_KEYS.TYPE,
  260. title: t('类型'),
  261. dataIndex: 'type',
  262. render: (text, record, index) => {
  263. if (record.children === undefined) {
  264. return <>{renderType(text)}</>;
  265. } else {
  266. return <>{renderTagType()}</>;
  267. }
  268. },
  269. },
  270. {
  271. key: COLUMN_KEYS.STATUS,
  272. title: t('状态'),
  273. dataIndex: 'status',
  274. render: (text, record, index) => {
  275. if (text === 3) {
  276. if (record.other_info === '') {
  277. record.other_info = '{}';
  278. }
  279. let otherInfo = JSON.parse(record.other_info);
  280. let reason = otherInfo['status_reason'];
  281. let time = otherInfo['status_time'];
  282. return (
  283. <div>
  284. <Tooltip
  285. content={t('原因:') + reason + t(',时间:') + timestamp2string(time)}
  286. >
  287. {renderStatus(text)}
  288. </Tooltip>
  289. </div>
  290. );
  291. } else {
  292. return renderStatus(text);
  293. }
  294. },
  295. },
  296. {
  297. key: COLUMN_KEYS.RESPONSE_TIME,
  298. title: t('响应时间'),
  299. dataIndex: 'response_time',
  300. render: (text, record, index) => (
  301. <div>{renderResponseTime(text)}</div>
  302. ),
  303. },
  304. {
  305. key: COLUMN_KEYS.BALANCE,
  306. title: t('已用/剩余'),
  307. dataIndex: 'expired_time',
  308. render: (text, record, index) => {
  309. if (record.children === undefined) {
  310. return (
  311. <div>
  312. <Space spacing={1}>
  313. <Tooltip content={t('已用额度')}>
  314. <Tag color='white' type='ghost' shape='circle'>
  315. {renderQuota(record.used_quota)}
  316. </Tag>
  317. </Tooltip>
  318. <Tooltip content={t('剩余额度$') + record.balance + t(',点击更新')}>
  319. <Tag
  320. color='white'
  321. type='ghost'
  322. shape='circle'
  323. onClick={() => updateChannelBalance(record)}
  324. >
  325. {renderQuotaWithAmount(record.balance)}
  326. </Tag>
  327. </Tooltip>
  328. </Space>
  329. </div>
  330. );
  331. } else {
  332. return (
  333. <Tooltip content={t('已用额度')}>
  334. <Tag color='white' type='ghost' shape='circle'>
  335. {renderQuota(record.used_quota)}
  336. </Tag>
  337. </Tooltip>
  338. );
  339. }
  340. },
  341. },
  342. {
  343. key: COLUMN_KEYS.PRIORITY,
  344. title: t('优先级'),
  345. dataIndex: 'priority',
  346. render: (text, record, index) => {
  347. if (record.children === undefined) {
  348. return (
  349. <div>
  350. <InputNumber
  351. style={{ width: 70 }}
  352. name='priority'
  353. onBlur={(e) => {
  354. manageChannel(record.id, 'priority', record, e.target.value);
  355. }}
  356. keepFocus={true}
  357. innerButtons
  358. defaultValue={record.priority}
  359. min={-999}
  360. size="small"
  361. />
  362. </div>
  363. );
  364. } else {
  365. return (
  366. <InputNumber
  367. style={{ width: 70 }}
  368. name='priority'
  369. keepFocus={true}
  370. onBlur={(e) => {
  371. Modal.warning({
  372. title: t('修改子渠道优先级'),
  373. content: t('确定要修改所有子渠道优先级为 ') + e.target.value + t(' 吗?'),
  374. onOk: () => {
  375. if (e.target.value === '') {
  376. return;
  377. }
  378. submitTagEdit('priority', {
  379. tag: record.key,
  380. priority: e.target.value,
  381. });
  382. },
  383. });
  384. }}
  385. innerButtons
  386. defaultValue={record.priority}
  387. min={-999}
  388. size="small"
  389. />
  390. );
  391. }
  392. },
  393. },
  394. {
  395. key: COLUMN_KEYS.WEIGHT,
  396. title: t('权重'),
  397. dataIndex: 'weight',
  398. render: (text, record, index) => {
  399. if (record.children === undefined) {
  400. return (
  401. <div>
  402. <InputNumber
  403. style={{ width: 70 }}
  404. name='weight'
  405. onBlur={(e) => {
  406. manageChannel(record.id, 'weight', record, e.target.value);
  407. }}
  408. keepFocus={true}
  409. innerButtons
  410. defaultValue={record.weight}
  411. min={0}
  412. size="small"
  413. />
  414. </div>
  415. );
  416. } else {
  417. return (
  418. <InputNumber
  419. style={{ width: 70 }}
  420. name='weight'
  421. keepFocus={true}
  422. onBlur={(e) => {
  423. Modal.warning({
  424. title: t('修改子渠道权重'),
  425. content: t('确定要修改所有子渠道权重为 ') + e.target.value + t(' 吗?'),
  426. onOk: () => {
  427. if (e.target.value === '') {
  428. return;
  429. }
  430. submitTagEdit('weight', {
  431. tag: record.key,
  432. weight: e.target.value,
  433. });
  434. },
  435. });
  436. }}
  437. innerButtons
  438. defaultValue={record.weight}
  439. min={-999}
  440. size="small"
  441. />
  442. );
  443. }
  444. },
  445. },
  446. {
  447. key: COLUMN_KEYS.OPERATE,
  448. title: '',
  449. dataIndex: 'operate',
  450. fixed: 'right',
  451. render: (text, record, index) => {
  452. if (record.children === undefined) {
  453. // 创建更多操作的下拉菜单项
  454. const moreMenuItems = [
  455. {
  456. node: 'item',
  457. name: t('删除'),
  458. type: 'danger',
  459. onClick: () => {
  460. Modal.confirm({
  461. title: t('确定是否要删除此渠道?'),
  462. content: t('此修改将不可逆'),
  463. onOk: () => {
  464. manageChannel(record.id, 'delete', record).then(() => {
  465. removeRecord(record);
  466. });
  467. },
  468. });
  469. },
  470. },
  471. {
  472. node: 'item',
  473. name: t('复制'),
  474. type: 'primary',
  475. onClick: () => {
  476. Modal.confirm({
  477. title: t('确定是否要复制此渠道?'),
  478. content: t('复制渠道的所有信息'),
  479. onOk: () => copySelectedChannel(record),
  480. });
  481. },
  482. },
  483. ];
  484. return (
  485. <Space wrap>
  486. <SplitButtonGroup
  487. className="overflow-hidden"
  488. aria-label={t('测试单个渠道操作项目组')}
  489. >
  490. <Button
  491. theme='light'
  492. size="small"
  493. onClick={() => testChannel(record, '')}
  494. >
  495. {t('测试')}
  496. </Button>
  497. <Button
  498. theme='light'
  499. size="small"
  500. icon={<IconTreeTriangleDown />}
  501. onClick={() => {
  502. setCurrentTestChannel(record);
  503. setShowModelTestModal(true);
  504. }}
  505. />
  506. </SplitButtonGroup>
  507. {record.status === 1 ? (
  508. <Button
  509. theme='light'
  510. type='warning'
  511. size="small"
  512. onClick={() => manageChannel(record.id, 'disable', record)}
  513. >
  514. {t('禁用')}
  515. </Button>
  516. ) : (
  517. <Button
  518. theme='light'
  519. type='secondary'
  520. size="small"
  521. onClick={() => manageChannel(record.id, 'enable', record)}
  522. >
  523. {t('启用')}
  524. </Button>
  525. )}
  526. <Button
  527. theme='light'
  528. type='tertiary'
  529. size="small"
  530. onClick={() => {
  531. setEditingChannel(record);
  532. setShowEdit(true);
  533. }}
  534. >
  535. {t('编辑')}
  536. </Button>
  537. <Dropdown
  538. trigger='click'
  539. position='bottomRight'
  540. menu={moreMenuItems}
  541. >
  542. <Button
  543. icon={<IconMore />}
  544. theme='light'
  545. type='tertiary'
  546. size="small"
  547. />
  548. </Dropdown>
  549. </Space>
  550. );
  551. } else {
  552. // 标签操作按钮
  553. return (
  554. <Space wrap>
  555. <Button
  556. theme='light'
  557. type='secondary'
  558. size="small"
  559. onClick={() => manageTag(record.key, 'enable')}
  560. >
  561. {t('启用全部')}
  562. </Button>
  563. <Button
  564. theme='light'
  565. type='warning'
  566. size="small"
  567. onClick={() => manageTag(record.key, 'disable')}
  568. >
  569. {t('禁用全部')}
  570. </Button>
  571. <Button
  572. theme='light'
  573. type='tertiary'
  574. size="small"
  575. onClick={() => {
  576. setShowEditTag(true);
  577. setEditingTag(record.key);
  578. }}
  579. >
  580. {t('编辑')}
  581. </Button>
  582. </Space>
  583. );
  584. }
  585. },
  586. },
  587. ];
  588. const [channels, setChannels] = useState([]);
  589. const [loading, setLoading] = useState(true);
  590. const [activePage, setActivePage] = useState(1);
  591. const [idSort, setIdSort] = useState(false);
  592. const [searching, setSearching] = useState(false);
  593. const [pageSize, setPageSize] = useState(ITEMS_PER_PAGE);
  594. const [channelCount, setChannelCount] = useState(pageSize);
  595. const [groupOptions, setGroupOptions] = useState([]);
  596. const [showEdit, setShowEdit] = useState(false);
  597. const [enableBatchDelete, setEnableBatchDelete] = useState(false);
  598. const [editingChannel, setEditingChannel] = useState({
  599. id: undefined,
  600. });
  601. const [showEditTag, setShowEditTag] = useState(false);
  602. const [editingTag, setEditingTag] = useState('');
  603. const [selectedChannels, setSelectedChannels] = useState([]);
  604. const [enableTagMode, setEnableTagMode] = useState(false);
  605. const [showBatchSetTag, setShowBatchSetTag] = useState(false);
  606. const [batchSetTagValue, setBatchSetTagValue] = useState('');
  607. const [showModelTestModal, setShowModelTestModal] = useState(false);
  608. const [currentTestChannel, setCurrentTestChannel] = useState(null);
  609. const [modelSearchKeyword, setModelSearchKeyword] = useState('');
  610. const [modelTestResults, setModelTestResults] = useState({});
  611. const [testingModels, setTestingModels] = useState(new Set());
  612. const [selectedModelKeys, setSelectedModelKeys] = useState([]);
  613. const [isBatchTesting, setIsBatchTesting] = useState(false);
  614. const [testQueue, setTestQueue] = useState([]);
  615. const [isProcessingQueue, setIsProcessingQueue] = useState(false);
  616. const [modelTablePage, setModelTablePage] = useState(1);
  617. const [activeTypeKey, setActiveTypeKey] = useState('all');
  618. const [typeCounts, setTypeCounts] = useState({});
  619. const requestCounter = useRef(0);
  620. const [formApi, setFormApi] = useState(null);
  621. const [compactMode, setCompactMode] = useTableCompactMode('channels');
  622. const formInitValues = {
  623. searchKeyword: '',
  624. searchGroup: '',
  625. searchModel: '',
  626. };
  627. const allSelectingRef = useRef(false);
  628. // Filter columns based on visibility settings
  629. const getVisibleColumns = () => {
  630. return allColumns.filter((column) => visibleColumns[column.key]);
  631. };
  632. // Column selector modal
  633. const renderColumnSelector = () => {
  634. return (
  635. <Modal
  636. title={t('列设置')}
  637. visible={showColumnSelector}
  638. onCancel={() => setShowColumnSelector(false)}
  639. footer={
  640. <div className="flex justify-end">
  641. <Button
  642. theme="light"
  643. onClick={() => initDefaultColumns()}
  644. >
  645. {t('重置')}
  646. </Button>
  647. <Button
  648. theme="light"
  649. onClick={() => setShowColumnSelector(false)}
  650. >
  651. {t('取消')}
  652. </Button>
  653. <Button
  654. type='primary'
  655. onClick={() => setShowColumnSelector(false)}
  656. >
  657. {t('确定')}
  658. </Button>
  659. </div>
  660. }
  661. >
  662. <div style={{ marginBottom: 20 }}>
  663. <Checkbox
  664. checked={Object.values(visibleColumns).every((v) => v === true)}
  665. indeterminate={
  666. Object.values(visibleColumns).some((v) => v === true) &&
  667. !Object.values(visibleColumns).every((v) => v === true)
  668. }
  669. onChange={(e) => handleSelectAll(e.target.checked)}
  670. >
  671. {t('全选')}
  672. </Checkbox>
  673. </div>
  674. <div
  675. className="flex flex-wrap max-h-96 overflow-y-auto rounded-lg p-4"
  676. style={{ border: '1px solid var(--semi-color-border)' }}
  677. >
  678. {allColumns.map((column) => {
  679. // Skip columns without title
  680. if (!column.title) {
  681. return null;
  682. }
  683. return (
  684. <div
  685. key={column.key}
  686. className="w-1/2 mb-4 pr-2"
  687. >
  688. <Checkbox
  689. checked={!!visibleColumns[column.key]}
  690. onChange={(e) =>
  691. handleColumnVisibilityChange(column.key, e.target.checked)
  692. }
  693. >
  694. {column.title}
  695. </Checkbox>
  696. </div>
  697. );
  698. })}
  699. </div>
  700. </Modal>
  701. );
  702. };
  703. const removeRecord = (record) => {
  704. let newDataSource = [...channels];
  705. if (record.id != null) {
  706. let idx = newDataSource.findIndex((data) => {
  707. if (data.children !== undefined) {
  708. for (let i = 0; i < data.children.length; i++) {
  709. if (data.children[i].id === record.id) {
  710. data.children.splice(i, 1);
  711. return false;
  712. }
  713. }
  714. } else {
  715. return data.id === record.id;
  716. }
  717. });
  718. if (idx > -1) {
  719. newDataSource.splice(idx, 1);
  720. setChannels(newDataSource);
  721. }
  722. }
  723. };
  724. const setChannelFormat = (channels, enableTagMode) => {
  725. let channelDates = [];
  726. let channelTags = {};
  727. for (let i = 0; i < channels.length; i++) {
  728. channels[i].key = '' + channels[i].id;
  729. if (!enableTagMode) {
  730. channelDates.push(channels[i]);
  731. } else {
  732. let tag = channels[i].tag ? channels[i].tag : '';
  733. // find from channelTags
  734. let tagIndex = channelTags[tag];
  735. let tagChannelDates = undefined;
  736. if (tagIndex === undefined) {
  737. // not found, create a new tag
  738. channelTags[tag] = 1;
  739. tagChannelDates = {
  740. key: tag,
  741. id: tag,
  742. tag: tag,
  743. name: '标签:' + tag,
  744. group: '',
  745. used_quota: 0,
  746. response_time: 0,
  747. priority: -1,
  748. weight: -1,
  749. };
  750. tagChannelDates.children = [];
  751. channelDates.push(tagChannelDates);
  752. } else {
  753. // found, add to the tag
  754. tagChannelDates = channelDates.find((item) => item.key === tag);
  755. }
  756. if (tagChannelDates.priority === -1) {
  757. tagChannelDates.priority = channels[i].priority;
  758. } else {
  759. if (tagChannelDates.priority !== channels[i].priority) {
  760. tagChannelDates.priority = '';
  761. }
  762. }
  763. if (tagChannelDates.weight === -1) {
  764. tagChannelDates.weight = channels[i].weight;
  765. } else {
  766. if (tagChannelDates.weight !== channels[i].weight) {
  767. tagChannelDates.weight = '';
  768. }
  769. }
  770. if (tagChannelDates.group === '') {
  771. tagChannelDates.group = channels[i].group;
  772. } else {
  773. let channelGroupsStr = channels[i].group;
  774. channelGroupsStr.split(',').forEach((item, index) => {
  775. if (tagChannelDates.group.indexOf(item) === -1) {
  776. // join
  777. tagChannelDates.group += ',' + item;
  778. }
  779. });
  780. }
  781. tagChannelDates.children.push(channels[i]);
  782. if (channels[i].status === 1) {
  783. tagChannelDates.status = 1;
  784. }
  785. tagChannelDates.used_quota += channels[i].used_quota;
  786. tagChannelDates.response_time += channels[i].response_time;
  787. tagChannelDates.response_time = tagChannelDates.response_time / 2;
  788. }
  789. }
  790. setChannels(channelDates);
  791. };
  792. const loadChannels = async (
  793. page,
  794. pageSize,
  795. idSort,
  796. enableTagMode,
  797. typeKey = activeTypeKey,
  798. statusF,
  799. ) => {
  800. if (statusF === undefined) statusF = statusFilter;
  801. const { searchKeyword, searchGroup, searchModel } = getFormValues();
  802. if (searchKeyword !== '' || searchGroup !== '' || searchModel !== '') {
  803. setLoading(true);
  804. await searchChannels(enableTagMode, typeKey, statusF, page, pageSize, idSort);
  805. setLoading(false);
  806. return;
  807. }
  808. const reqId = ++requestCounter.current; // 记录当前请求序号
  809. setLoading(true);
  810. const typeParam = (typeKey !== 'all') ? `&type=${typeKey}` : '';
  811. const statusParam = statusF !== 'all' ? `&status=${statusF}` : '';
  812. const res = await API.get(
  813. `/api/channel/?p=${page}&page_size=${pageSize}&id_sort=${idSort}&tag_mode=${enableTagMode}${typeParam}${statusParam}`,
  814. );
  815. if (res === undefined || reqId !== requestCounter.current) {
  816. return;
  817. }
  818. const { success, message, data } = res.data;
  819. if (success) {
  820. const { items, total, type_counts } = data;
  821. if (type_counts) {
  822. const sumAll = Object.values(type_counts).reduce((acc, v) => acc + v, 0);
  823. setTypeCounts({ ...type_counts, all: sumAll });
  824. }
  825. setChannelFormat(items, enableTagMode);
  826. setChannelCount(total);
  827. } else {
  828. showError(message);
  829. }
  830. setLoading(false);
  831. };
  832. const copySelectedChannel = async (record) => {
  833. const channelToCopy = { ...record };
  834. channelToCopy.name += t('_复制');
  835. channelToCopy.created_time = null;
  836. channelToCopy.balance = 0;
  837. channelToCopy.used_quota = 0;
  838. delete channelToCopy.test_time;
  839. delete channelToCopy.response_time;
  840. if (!channelToCopy) {
  841. showError(t('渠道未找到,请刷新页面后重试。'));
  842. return;
  843. }
  844. try {
  845. const newChannel = { ...channelToCopy, id: undefined };
  846. const response = await API.post('/api/channel/', newChannel);
  847. if (response.data.success) {
  848. showSuccess(t('渠道复制成功'));
  849. await refresh();
  850. } else {
  851. showError(response.data.message);
  852. }
  853. } catch (error) {
  854. showError(t('渠道复制失败: ') + error.message);
  855. }
  856. };
  857. const refresh = async () => {
  858. const { searchKeyword, searchGroup, searchModel } = getFormValues();
  859. if (searchKeyword === '' && searchGroup === '' && searchModel === '') {
  860. await loadChannels(activePage, pageSize, idSort, enableTagMode);
  861. } else {
  862. await searchChannels(enableTagMode, activeTypeKey, statusFilter, activePage, pageSize, idSort);
  863. }
  864. };
  865. useEffect(() => {
  866. // console.log('default effect')
  867. const localIdSort = localStorage.getItem('id-sort') === 'true';
  868. const localPageSize =
  869. parseInt(localStorage.getItem('page-size')) || ITEMS_PER_PAGE;
  870. const localEnableTagMode = localStorage.getItem('enable-tag-mode') === 'true';
  871. const localEnableBatchDelete = localStorage.getItem('enable-batch-delete') === 'true';
  872. setIdSort(localIdSort);
  873. setPageSize(localPageSize);
  874. setEnableTagMode(localEnableTagMode);
  875. setEnableBatchDelete(localEnableBatchDelete);
  876. loadChannels(1, localPageSize, localIdSort, localEnableTagMode)
  877. .then()
  878. .catch((reason) => {
  879. showError(reason);
  880. });
  881. fetchGroups().then();
  882. loadChannelModels().then();
  883. }, []);
  884. const manageChannel = async (id, action, record, value) => {
  885. let data = { id };
  886. let res;
  887. switch (action) {
  888. case 'delete':
  889. res = await API.delete(`/api/channel/${id}/`);
  890. break;
  891. case 'enable':
  892. data.status = 1;
  893. res = await API.put('/api/channel/', data);
  894. break;
  895. case 'disable':
  896. data.status = 2;
  897. res = await API.put('/api/channel/', data);
  898. break;
  899. case 'priority':
  900. if (value === '') {
  901. return;
  902. }
  903. data.priority = parseInt(value);
  904. res = await API.put('/api/channel/', data);
  905. break;
  906. case 'weight':
  907. if (value === '') {
  908. return;
  909. }
  910. data.weight = parseInt(value);
  911. if (data.weight < 0) {
  912. data.weight = 0;
  913. }
  914. res = await API.put('/api/channel/', data);
  915. break;
  916. }
  917. const { success, message } = res.data;
  918. if (success) {
  919. showSuccess(t('操作成功完成!'));
  920. let channel = res.data.data;
  921. let newChannels = [...channels];
  922. if (action === 'delete') {
  923. } else {
  924. record.status = channel.status;
  925. }
  926. setChannels(newChannels);
  927. } else {
  928. showError(message);
  929. }
  930. };
  931. const manageTag = async (tag, action) => {
  932. console.log(tag, action);
  933. let res;
  934. switch (action) {
  935. case 'enable':
  936. res = await API.post('/api/channel/tag/enabled', {
  937. tag: tag,
  938. });
  939. break;
  940. case 'disable':
  941. res = await API.post('/api/channel/tag/disabled', {
  942. tag: tag,
  943. });
  944. break;
  945. }
  946. const { success, message } = res.data;
  947. if (success) {
  948. showSuccess('操作成功完成!');
  949. let newChannels = [...channels];
  950. for (let i = 0; i < newChannels.length; i++) {
  951. if (newChannels[i].tag === tag) {
  952. let status = action === 'enable' ? 1 : 2;
  953. newChannels[i]?.children?.forEach((channel) => {
  954. channel.status = status;
  955. });
  956. newChannels[i].status = status;
  957. }
  958. }
  959. setChannels(newChannels);
  960. } else {
  961. showError(message);
  962. }
  963. };
  964. // 获取表单值的辅助函数
  965. const getFormValues = () => {
  966. const formValues = formApi ? formApi.getValues() : {};
  967. return {
  968. searchKeyword: formValues.searchKeyword || '',
  969. searchGroup: formValues.searchGroup || '',
  970. searchModel: formValues.searchModel || '',
  971. };
  972. };
  973. const searchChannels = async (
  974. enableTagMode,
  975. typeKey = activeTypeKey,
  976. statusF = statusFilter,
  977. page = 1,
  978. pageSz = pageSize,
  979. sortFlag = idSort,
  980. ) => {
  981. const { searchKeyword, searchGroup, searchModel } = getFormValues();
  982. setSearching(true);
  983. try {
  984. if (searchKeyword === '' && searchGroup === '' && searchModel === '') {
  985. await loadChannels(page, pageSz, sortFlag, enableTagMode, typeKey, statusF);
  986. return;
  987. }
  988. const typeParam = (typeKey !== 'all') ? `&type=${typeKey}` : '';
  989. const statusParam = statusF !== 'all' ? `&status=${statusF}` : '';
  990. const res = await API.get(
  991. `/api/channel/search?keyword=${searchKeyword}&group=${searchGroup}&model=${searchModel}&id_sort=${sortFlag}&tag_mode=${enableTagMode}&p=${page}&page_size=${pageSz}${typeParam}${statusParam}`,
  992. );
  993. const { success, message, data } = res.data;
  994. if (success) {
  995. const { items = [], total = 0, type_counts = {} } = data;
  996. const sumAll = Object.values(type_counts).reduce((acc, v) => acc + v, 0);
  997. setTypeCounts({ ...type_counts, all: sumAll });
  998. setChannelFormat(items, enableTagMode);
  999. setChannelCount(total);
  1000. setActivePage(page);
  1001. } else {
  1002. showError(message);
  1003. }
  1004. } finally {
  1005. setSearching(false);
  1006. }
  1007. };
  1008. const updateChannelProperty = (channelId, updateFn) => {
  1009. // Create a new copy of channels array
  1010. const newChannels = [...channels];
  1011. let updated = false;
  1012. // Find and update the correct channel
  1013. newChannels.forEach((channel) => {
  1014. if (channel.children !== undefined) {
  1015. // If this is a tag group, search in its children
  1016. channel.children.forEach((child) => {
  1017. if (child.id === channelId) {
  1018. updateFn(child);
  1019. updated = true;
  1020. }
  1021. });
  1022. } else if (channel.id === channelId) {
  1023. // Direct channel match
  1024. updateFn(channel);
  1025. updated = true;
  1026. }
  1027. });
  1028. // Only update state if we actually modified a channel
  1029. if (updated) {
  1030. setChannels(newChannels);
  1031. }
  1032. };
  1033. const processTestQueue = async () => {
  1034. if (!isProcessingQueue || testQueue.length === 0) return;
  1035. const { channel, model, indexInFiltered } = testQueue[0];
  1036. // 自动翻页到正在测试的模型所在页
  1037. if (currentTestChannel && currentTestChannel.id === channel.id) {
  1038. let pageNo;
  1039. if (indexInFiltered !== undefined) {
  1040. pageNo = Math.floor(indexInFiltered / MODEL_TABLE_PAGE_SIZE) + 1;
  1041. } else {
  1042. const filteredModelsList = currentTestChannel.models
  1043. .split(',')
  1044. .filter((m) => m.toLowerCase().includes(modelSearchKeyword.toLowerCase()));
  1045. const modelIdx = filteredModelsList.indexOf(model);
  1046. pageNo = modelIdx !== -1 ? Math.floor(modelIdx / MODEL_TABLE_PAGE_SIZE) + 1 : 1;
  1047. }
  1048. setModelTablePage(pageNo);
  1049. }
  1050. try {
  1051. setTestingModels(prev => new Set([...prev, model]));
  1052. const res = await API.get(`/api/channel/test/${channel.id}?model=${model}`);
  1053. const { success, message, time } = res.data;
  1054. setModelTestResults(prev => ({
  1055. ...prev,
  1056. [`${channel.id}-${model}`]: { success, time }
  1057. }));
  1058. if (success) {
  1059. updateChannelProperty(channel.id, (ch) => {
  1060. ch.response_time = time * 1000;
  1061. ch.test_time = Date.now() / 1000;
  1062. });
  1063. if (!model) {
  1064. showInfo(
  1065. t('通道 ${name} 测试成功,耗时 ${time.toFixed(2)} 秒。')
  1066. .replace('${name}', channel.name)
  1067. .replace('${time.toFixed(2)}', time.toFixed(2)),
  1068. );
  1069. }
  1070. } else {
  1071. showError(message);
  1072. }
  1073. } catch (error) {
  1074. showError(error.message);
  1075. } finally {
  1076. setTestingModels(prev => {
  1077. const newSet = new Set(prev);
  1078. newSet.delete(model);
  1079. return newSet;
  1080. });
  1081. }
  1082. // 移除已处理的测试
  1083. setTestQueue(prev => prev.slice(1));
  1084. };
  1085. // 监听队列变化
  1086. useEffect(() => {
  1087. if (testQueue.length > 0 && isProcessingQueue) {
  1088. processTestQueue();
  1089. } else if (testQueue.length === 0 && isProcessingQueue) {
  1090. setIsProcessingQueue(false);
  1091. setIsBatchTesting(false);
  1092. }
  1093. }, [testQueue, isProcessingQueue]);
  1094. const testChannel = async (record, model) => {
  1095. setTestQueue(prev => [...prev, { channel: record, model }]);
  1096. if (!isProcessingQueue) {
  1097. setIsProcessingQueue(true);
  1098. }
  1099. };
  1100. const batchTestModels = async () => {
  1101. if (!currentTestChannel) return;
  1102. setIsBatchTesting(true);
  1103. // 重置分页到第一页
  1104. setModelTablePage(1);
  1105. const filteredModels = currentTestChannel.models
  1106. .split(',')
  1107. .filter((model) =>
  1108. model.toLowerCase().includes(modelSearchKeyword.toLowerCase()),
  1109. );
  1110. setTestQueue(
  1111. filteredModels.map((model, idx) => ({
  1112. channel: currentTestChannel,
  1113. model,
  1114. indexInFiltered: idx, // 记录在过滤列表中的顺序
  1115. })),
  1116. );
  1117. setIsProcessingQueue(true);
  1118. };
  1119. const handleCloseModal = () => {
  1120. if (isBatchTesting) {
  1121. // 清空测试队列来停止测试
  1122. setTestQueue([]);
  1123. setIsProcessingQueue(false);
  1124. setIsBatchTesting(false);
  1125. showSuccess(t('已停止测试'));
  1126. } else {
  1127. setShowModelTestModal(false);
  1128. setModelSearchKeyword('');
  1129. setSelectedModelKeys([]);
  1130. setModelTablePage(1);
  1131. }
  1132. };
  1133. const channelTypeCounts = useMemo(() => {
  1134. if (Object.keys(typeCounts).length > 0) return typeCounts;
  1135. // fallback 本地计算
  1136. const counts = { all: channels.length };
  1137. channels.forEach((channel) => {
  1138. const collect = (ch) => {
  1139. const type = ch.type;
  1140. counts[type] = (counts[type] || 0) + 1;
  1141. };
  1142. if (channel.children !== undefined) {
  1143. channel.children.forEach(collect);
  1144. } else {
  1145. collect(channel);
  1146. }
  1147. });
  1148. return counts;
  1149. }, [typeCounts, channels]);
  1150. const availableTypeKeys = useMemo(() => {
  1151. const keys = ['all'];
  1152. Object.entries(channelTypeCounts).forEach(([k, v]) => {
  1153. if (k !== 'all' && v > 0) keys.push(String(k));
  1154. });
  1155. return keys;
  1156. }, [channelTypeCounts]);
  1157. const renderTypeTabs = () => {
  1158. if (enableTagMode) return null;
  1159. return (
  1160. <Tabs
  1161. activeKey={activeTypeKey}
  1162. type="card"
  1163. collapsible
  1164. onChange={(key) => {
  1165. setActiveTypeKey(key);
  1166. setActivePage(1);
  1167. loadChannels(1, pageSize, idSort, enableTagMode, key);
  1168. }}
  1169. className="mb-4"
  1170. >
  1171. <TabPane
  1172. itemKey="all"
  1173. tab={
  1174. <span className="flex items-center gap-2">
  1175. {t('全部')}
  1176. <Tag color={activeTypeKey === 'all' ? 'red' : 'grey'} shape='circle'>
  1177. {channelTypeCounts['all'] || 0}
  1178. </Tag>
  1179. </span>
  1180. }
  1181. />
  1182. {CHANNEL_OPTIONS.filter((opt) => availableTypeKeys.includes(String(opt.value))).map((option) => {
  1183. const key = String(option.value);
  1184. const count = channelTypeCounts[option.value] || 0;
  1185. return (
  1186. <TabPane
  1187. key={key}
  1188. itemKey={key}
  1189. tab={
  1190. <span className="flex items-center gap-2">
  1191. {getChannelIcon(option.value)}
  1192. {option.label}
  1193. <Tag color={activeTypeKey === key ? 'red' : 'grey'} shape='circle'>
  1194. {count}
  1195. </Tag>
  1196. </span>
  1197. }
  1198. />
  1199. );
  1200. })}
  1201. </Tabs>
  1202. );
  1203. };
  1204. let pageData = channels;
  1205. const handlePageChange = (page) => {
  1206. const { searchKeyword, searchGroup, searchModel } = getFormValues();
  1207. setActivePage(page);
  1208. if (searchKeyword === '' && searchGroup === '' && searchModel === '') {
  1209. loadChannels(page, pageSize, idSort, enableTagMode).then(() => { });
  1210. } else {
  1211. searchChannels(enableTagMode, activeTypeKey, statusFilter, page, pageSize, idSort);
  1212. }
  1213. };
  1214. const handlePageSizeChange = async (size) => {
  1215. localStorage.setItem('page-size', size + '');
  1216. setPageSize(size);
  1217. setActivePage(1);
  1218. const { searchKeyword, searchGroup, searchModel } = getFormValues();
  1219. if (searchKeyword === '' && searchGroup === '' && searchModel === '') {
  1220. loadChannels(1, size, idSort, enableTagMode)
  1221. .then()
  1222. .catch((reason) => {
  1223. showError(reason);
  1224. });
  1225. } else {
  1226. searchChannels(enableTagMode, activeTypeKey, statusFilter, 1, size, idSort);
  1227. }
  1228. };
  1229. const fetchGroups = async () => {
  1230. try {
  1231. let res = await API.get(`/api/group/`);
  1232. if (res === undefined) {
  1233. return;
  1234. }
  1235. setGroupOptions(
  1236. res.data.data.map((group) => ({
  1237. label: group,
  1238. value: group,
  1239. })),
  1240. );
  1241. } catch (error) {
  1242. showError(error.message);
  1243. }
  1244. };
  1245. const submitTagEdit = async (type, data) => {
  1246. switch (type) {
  1247. case 'priority':
  1248. if (data.priority === undefined || data.priority === '') {
  1249. showInfo('优先级必须是整数!');
  1250. return;
  1251. }
  1252. data.priority = parseInt(data.priority);
  1253. break;
  1254. case 'weight':
  1255. if (
  1256. data.weight === undefined ||
  1257. data.weight < 0 ||
  1258. data.weight === ''
  1259. ) {
  1260. showInfo('权重必须是非负整数!');
  1261. return;
  1262. }
  1263. data.weight = parseInt(data.weight);
  1264. break;
  1265. }
  1266. try {
  1267. const res = await API.put('/api/channel/tag', data);
  1268. if (res?.data?.success) {
  1269. showSuccess('更新成功!');
  1270. await refresh();
  1271. }
  1272. } catch (error) {
  1273. showError(error);
  1274. }
  1275. };
  1276. const closeEdit = () => {
  1277. setShowEdit(false);
  1278. };
  1279. const handleRow = (record, index) => {
  1280. if (record.status !== 1) {
  1281. return {
  1282. style: {
  1283. background: 'var(--semi-color-disabled-border)',
  1284. },
  1285. };
  1286. } else {
  1287. return {};
  1288. }
  1289. };
  1290. const batchSetChannelTag = async () => {
  1291. if (selectedChannels.length === 0) {
  1292. showError(t('请先选择要设置标签的渠道!'));
  1293. return;
  1294. }
  1295. if (batchSetTagValue === '') {
  1296. showError(t('标签不能为空!'));
  1297. return;
  1298. }
  1299. let ids = selectedChannels.map((channel) => channel.id);
  1300. const res = await API.post('/api/channel/batch/tag', {
  1301. ids: ids,
  1302. tag: batchSetTagValue === '' ? null : batchSetTagValue,
  1303. });
  1304. if (res.data.success) {
  1305. showSuccess(
  1306. t('已为 ${count} 个渠道设置标签!').replace('${count}', res.data.data),
  1307. );
  1308. await refresh();
  1309. setShowBatchSetTag(false);
  1310. } else {
  1311. showError(res.data.message);
  1312. }
  1313. };
  1314. const testAllChannels = async () => {
  1315. const res = await API.get(`/api/channel/test`);
  1316. const { success, message } = res.data;
  1317. if (success) {
  1318. showInfo(t('已成功开始测试所有已启用通道,请刷新页面查看结果。'));
  1319. } else {
  1320. showError(message);
  1321. }
  1322. };
  1323. const deleteAllDisabledChannels = async () => {
  1324. const res = await API.delete(`/api/channel/disabled`);
  1325. const { success, message, data } = res.data;
  1326. if (success) {
  1327. showSuccess(
  1328. t('已删除所有禁用渠道,共计 ${data} 个').replace('${data}', data),
  1329. );
  1330. await refresh();
  1331. } else {
  1332. showError(message);
  1333. }
  1334. };
  1335. const updateAllChannelsBalance = async () => {
  1336. const res = await API.get(`/api/channel/update_balance`);
  1337. const { success, message } = res.data;
  1338. if (success) {
  1339. showInfo(t('已更新完毕所有已启用通道余额!'));
  1340. } else {
  1341. showError(message);
  1342. }
  1343. };
  1344. const updateChannelBalance = async (record) => {
  1345. const res = await API.get(`/api/channel/update_balance/${record.id}/`);
  1346. const { success, message, balance } = res.data;
  1347. if (success) {
  1348. updateChannelProperty(record.id, (channel) => {
  1349. channel.balance = balance;
  1350. channel.balance_updated_time = Date.now() / 1000;
  1351. });
  1352. showInfo(
  1353. t('通道 ${name} 余额更新成功!').replace('${name}', record.name),
  1354. );
  1355. } else {
  1356. showError(message);
  1357. }
  1358. };
  1359. const batchDeleteChannels = async () => {
  1360. if (selectedChannels.length === 0) {
  1361. showError(t('请先选择要删除的通道!'));
  1362. return;
  1363. }
  1364. setLoading(true);
  1365. let ids = [];
  1366. selectedChannels.forEach((channel) => {
  1367. ids.push(channel.id);
  1368. });
  1369. const res = await API.post(`/api/channel/batch`, { ids: ids });
  1370. const { success, message, data } = res.data;
  1371. if (success) {
  1372. showSuccess(t('已删除 ${data} 个通道!').replace('${data}', data));
  1373. await refresh();
  1374. } else {
  1375. showError(message);
  1376. }
  1377. setLoading(false);
  1378. };
  1379. const fixChannelsAbilities = async () => {
  1380. const res = await API.post(`/api/channel/fix`);
  1381. const { success, message, data } = res.data;
  1382. if (success) {
  1383. showSuccess(t('已修复 ${success} 个通道,失败 ${fails} 个通道。').replace('${success}', data.success).replace('${fails}', data.fails));
  1384. await refresh();
  1385. } else {
  1386. showError(message);
  1387. }
  1388. };
  1389. const renderHeader = () => (
  1390. <div className="flex flex-col w-full">
  1391. {renderTypeTabs()}
  1392. <div className="flex flex-col md:flex-row justify-between gap-4">
  1393. <div className="flex flex-wrap md:flex-nowrap items-center gap-2 w-full md:w-auto order-2 md:order-1">
  1394. <Button
  1395. size='small'
  1396. disabled={!enableBatchDelete}
  1397. theme='light'
  1398. type='danger'
  1399. className="w-full md:w-auto"
  1400. onClick={() => {
  1401. Modal.confirm({
  1402. title: t('确定是否要删除所选通道?'),
  1403. content: t('此修改将不可逆'),
  1404. onOk: () => batchDeleteChannels(),
  1405. });
  1406. }}
  1407. >
  1408. {t('删除所选通道')}
  1409. </Button>
  1410. <Button
  1411. size='small'
  1412. disabled={!enableBatchDelete}
  1413. theme='light'
  1414. type='primary'
  1415. onClick={() => setShowBatchSetTag(true)}
  1416. className="w-full md:w-auto"
  1417. >
  1418. {t('批量设置标签')}
  1419. </Button>
  1420. <Dropdown
  1421. size='small'
  1422. trigger='click'
  1423. render={
  1424. <Dropdown.Menu>
  1425. <Dropdown.Item>
  1426. <Button
  1427. size='small'
  1428. theme='light'
  1429. type='warning'
  1430. className="w-full"
  1431. onClick={() => {
  1432. Modal.confirm({
  1433. title: t('确定?'),
  1434. content: t('确定要测试所有通道吗?'),
  1435. onOk: () => testAllChannels(),
  1436. size: 'small',
  1437. centered: true,
  1438. });
  1439. }}
  1440. >
  1441. {t('测试所有通道')}
  1442. </Button>
  1443. </Dropdown.Item>
  1444. <Dropdown.Item>
  1445. <Button
  1446. size='small'
  1447. theme='light'
  1448. type='secondary'
  1449. className="w-full"
  1450. onClick={() => {
  1451. Modal.confirm({
  1452. title: t('确定?'),
  1453. content: t('确定要更新所有已启用通道余额吗?'),
  1454. onOk: () => updateAllChannelsBalance(),
  1455. size: 'sm',
  1456. centered: true,
  1457. });
  1458. }}
  1459. >
  1460. {t('更新所有已启用通道余额')}
  1461. </Button>
  1462. </Dropdown.Item>
  1463. <Dropdown.Item>
  1464. <Button
  1465. size='small'
  1466. theme='light'
  1467. type='danger'
  1468. className="w-full"
  1469. onClick={() => {
  1470. Modal.confirm({
  1471. title: t('确定是否要删除禁用通道?'),
  1472. content: t('此修改将不可逆'),
  1473. onOk: () => deleteAllDisabledChannels(),
  1474. size: 'sm',
  1475. centered: true,
  1476. });
  1477. }}
  1478. >
  1479. {t('删除禁用通道')}
  1480. </Button>
  1481. </Dropdown.Item>
  1482. <Dropdown.Item>
  1483. <Button
  1484. size='small'
  1485. theme='light'
  1486. type='tertiary'
  1487. className="w-full"
  1488. onClick={() => {
  1489. Modal.confirm({
  1490. title: t('确定是否要修复数据库一致性?'),
  1491. content: t('进行该操作时,可能导致渠道访问错误,请仅在数据库出现问题时使用'),
  1492. onOk: () => fixChannelsAbilities(),
  1493. size: 'sm',
  1494. centered: true,
  1495. });
  1496. }}
  1497. >
  1498. {t('修复数据库一致性')}
  1499. </Button>
  1500. </Dropdown.Item>
  1501. </Dropdown.Menu>
  1502. }
  1503. >
  1504. <Button size='small' theme='light' type='tertiary' className="w-full md:w-auto">
  1505. {t('批量操作')}
  1506. </Button>
  1507. </Dropdown>
  1508. <Button
  1509. size='small'
  1510. theme='light'
  1511. type='secondary'
  1512. className="w-full md:w-auto"
  1513. onClick={() => setCompactMode(!compactMode)}
  1514. >
  1515. {compactMode ? t('自适应列表') : t('紧凑列表')}
  1516. </Button>
  1517. </div>
  1518. <div className="flex flex-col md:flex-row items-start md:items-center gap-4 w-full md:w-auto order-1 md:order-2">
  1519. <div className="flex items-center justify-between w-full md:w-auto">
  1520. <Typography.Text strong className="mr-2">
  1521. {t('使用ID排序')}
  1522. </Typography.Text>
  1523. <Switch
  1524. size='small'
  1525. checked={idSort}
  1526. onChange={(v) => {
  1527. localStorage.setItem('id-sort', v + '');
  1528. setIdSort(v);
  1529. const { searchKeyword, searchGroup, searchModel } = getFormValues();
  1530. if (searchKeyword === '' && searchGroup === '' && searchModel === '') {
  1531. loadChannels(activePage, pageSize, v, enableTagMode);
  1532. } else {
  1533. searchChannels(enableTagMode, activeTypeKey, statusFilter, activePage, pageSize, v);
  1534. }
  1535. }}
  1536. />
  1537. </div>
  1538. <div className="flex items-center justify-between w-full md:w-auto">
  1539. <Typography.Text strong className="mr-2">
  1540. {t('开启批量操作')}
  1541. </Typography.Text>
  1542. <Switch
  1543. size='small'
  1544. checked={enableBatchDelete}
  1545. onChange={(v) => {
  1546. localStorage.setItem('enable-batch-delete', v + '');
  1547. setEnableBatchDelete(v);
  1548. }}
  1549. />
  1550. </div>
  1551. <div className="flex items-center justify-between w-full md:w-auto">
  1552. <Typography.Text strong className="mr-2">
  1553. {t('标签聚合模式')}
  1554. </Typography.Text>
  1555. <Switch
  1556. size='small'
  1557. checked={enableTagMode}
  1558. onChange={(v) => {
  1559. localStorage.setItem('enable-tag-mode', v + '');
  1560. setEnableTagMode(v);
  1561. setActivePage(1);
  1562. loadChannels(1, pageSize, idSort, v);
  1563. }}
  1564. />
  1565. </div>
  1566. {/* 状态筛选器 */}
  1567. <div className="flex items-center justify-between w-full md:w-auto">
  1568. <Typography.Text strong className="mr-2">
  1569. {t('状态筛选')}
  1570. </Typography.Text>
  1571. <Select
  1572. size='small'
  1573. value={statusFilter}
  1574. onChange={(v) => {
  1575. localStorage.setItem('channel-status-filter', v);
  1576. setStatusFilter(v);
  1577. setActivePage(1);
  1578. loadChannels(1, pageSize, idSort, enableTagMode, activeTypeKey, v);
  1579. }}
  1580. >
  1581. <Select.Option value="all">{t('全部')}</Select.Option>
  1582. <Select.Option value="enabled">{t('已启用')}</Select.Option>
  1583. <Select.Option value="disabled">{t('已禁用')}</Select.Option>
  1584. </Select>
  1585. </div>
  1586. </div>
  1587. </div>
  1588. <Divider margin="12px" />
  1589. <div className="flex flex-col md:flex-row justify-between items-center gap-4 w-full">
  1590. <div className="flex gap-2 w-full md:w-auto order-2 md:order-1">
  1591. <Button
  1592. size='small'
  1593. theme='light'
  1594. type='primary'
  1595. className="w-full md:w-auto"
  1596. onClick={() => {
  1597. setEditingChannel({
  1598. id: undefined,
  1599. });
  1600. setShowEdit(true);
  1601. }}
  1602. >
  1603. {t('添加渠道')}
  1604. </Button>
  1605. <Button
  1606. size='small'
  1607. theme='light'
  1608. type='primary'
  1609. className="w-full md:w-auto"
  1610. onClick={refresh}
  1611. >
  1612. {t('刷新')}
  1613. </Button>
  1614. <Button
  1615. size='small'
  1616. theme='light'
  1617. type='tertiary'
  1618. onClick={() => setShowColumnSelector(true)}
  1619. className="w-full md:w-auto"
  1620. >
  1621. {t('列设置')}
  1622. </Button>
  1623. </div>
  1624. <div className="flex flex-col md:flex-row items-center gap-4 w-full md:w-auto order-1 md:order-2">
  1625. <Form
  1626. initValues={formInitValues}
  1627. getFormApi={(api) => setFormApi(api)}
  1628. onSubmit={() => searchChannels(enableTagMode)}
  1629. allowEmpty={true}
  1630. autoComplete="off"
  1631. layout="horizontal"
  1632. trigger="change"
  1633. stopValidateWithError={false}
  1634. className="flex flex-col md:flex-row items-center gap-4 w-full"
  1635. >
  1636. <div className="relative w-full md:w-64">
  1637. <Form.Input
  1638. size='small'
  1639. field="searchKeyword"
  1640. prefix={<IconSearch />}
  1641. placeholder={t('渠道ID,名称,密钥,API地址')}
  1642. showClear
  1643. pure
  1644. />
  1645. </div>
  1646. <div className="w-full md:w-48">
  1647. <Form.Input
  1648. size='small'
  1649. field="searchModel"
  1650. prefix={<IconSearch />}
  1651. placeholder={t('模型关键字')}
  1652. showClear
  1653. pure
  1654. />
  1655. </div>
  1656. <div className="w-full md:w-32">
  1657. <Form.Select
  1658. size='small'
  1659. field="searchGroup"
  1660. placeholder={t('选择分组')}
  1661. optionList={[
  1662. { label: t('选择分组'), value: null },
  1663. ...groupOptions,
  1664. ]}
  1665. className="w-full"
  1666. showClear
  1667. pure
  1668. onChange={() => {
  1669. // 延迟执行搜索,让表单值先更新
  1670. setTimeout(() => {
  1671. searchChannels(enableTagMode);
  1672. }, 0);
  1673. }}
  1674. />
  1675. </div>
  1676. <Button
  1677. size='small'
  1678. type="primary"
  1679. htmlType="submit"
  1680. loading={loading || searching}
  1681. className="w-full md:w-auto"
  1682. >
  1683. {t('查询')}
  1684. </Button>
  1685. <Button
  1686. size='small'
  1687. theme='light'
  1688. onClick={() => {
  1689. if (formApi) {
  1690. formApi.reset();
  1691. // 重置后立即查询,使用setTimeout确保表单重置完成
  1692. setTimeout(() => {
  1693. refresh();
  1694. }, 100);
  1695. }
  1696. }}
  1697. className="w-full md:w-auto"
  1698. >
  1699. {t('重置')}
  1700. </Button>
  1701. </Form>
  1702. </div>
  1703. </div>
  1704. </div>
  1705. );
  1706. return (
  1707. <>
  1708. {renderColumnSelector()}
  1709. <EditTagModal
  1710. visible={showEditTag}
  1711. tag={editingTag}
  1712. handleClose={() => setShowEditTag(false)}
  1713. refresh={refresh}
  1714. />
  1715. <EditChannel
  1716. refresh={refresh}
  1717. visible={showEdit}
  1718. handleClose={closeEdit}
  1719. editingChannel={editingChannel}
  1720. />
  1721. <Card
  1722. className="!rounded-2xl"
  1723. title={renderHeader()}
  1724. shadows='always'
  1725. bordered={false}
  1726. >
  1727. <Table
  1728. columns={compactMode ? getVisibleColumns().map(({ fixed, ...rest }) => rest) : getVisibleColumns()}
  1729. dataSource={pageData}
  1730. scroll={compactMode ? undefined : { x: 'max-content' }}
  1731. pagination={{
  1732. currentPage: activePage,
  1733. pageSize: pageSize,
  1734. total: channelCount,
  1735. pageSizeOpts: [10, 20, 50, 100],
  1736. showSizeChanger: true,
  1737. formatPageText: (page) => t('第 {{start}} - {{end}} 条,共 {{total}} 条', {
  1738. start: page.currentStart,
  1739. end: page.currentEnd,
  1740. total: channelCount,
  1741. }),
  1742. onPageSizeChange: (size) => {
  1743. handlePageSizeChange(size);
  1744. },
  1745. onPageChange: handlePageChange,
  1746. }}
  1747. expandAllRows={false}
  1748. onRow={handleRow}
  1749. rowSelection={
  1750. enableBatchDelete
  1751. ? {
  1752. onChange: (selectedRowKeys, selectedRows) => {
  1753. setSelectedChannels(selectedRows);
  1754. },
  1755. }
  1756. : null
  1757. }
  1758. empty={
  1759. <Empty
  1760. image={<IllustrationNoResult style={{ width: 150, height: 150 }} />}
  1761. darkModeImage={<IllustrationNoResultDark style={{ width: 150, height: 150 }} />}
  1762. description={t('搜索无结果')}
  1763. style={{ padding: 30 }}
  1764. />
  1765. }
  1766. className="rounded-xl overflow-hidden"
  1767. size="middle"
  1768. loading={loading || searching}
  1769. />
  1770. </Card>
  1771. {/* 批量设置标签模态框 */}
  1772. <Modal
  1773. title={t('批量设置标签')}
  1774. visible={showBatchSetTag}
  1775. onOk={batchSetChannelTag}
  1776. onCancel={() => setShowBatchSetTag(false)}
  1777. maskClosable={false}
  1778. centered={true}
  1779. size="small"
  1780. className="!rounded-lg"
  1781. >
  1782. <div className="mb-5">
  1783. <Typography.Text>{t('请输入要设置的标签名称')}</Typography.Text>
  1784. </div>
  1785. <Input
  1786. placeholder={t('请输入标签名称')}
  1787. value={batchSetTagValue}
  1788. onChange={(v) => setBatchSetTagValue(v)}
  1789. size='large'
  1790. />
  1791. <div className="mt-4">
  1792. <Typography.Text type='secondary'>
  1793. {t('已选择 ${count} 个渠道').replace('${count}', selectedChannels.length)}
  1794. </Typography.Text>
  1795. </div>
  1796. </Modal>
  1797. {/* 模型测试弹窗 */}
  1798. <Modal
  1799. title={
  1800. currentTestChannel && (
  1801. <div className="flex flex-col gap-2 w-full">
  1802. <div className="flex items-center gap-2">
  1803. <Typography.Text strong className="!text-[var(--semi-color-text-0)] !text-base">
  1804. {currentTestChannel.name} {t('渠道的模型测试')}
  1805. </Typography.Text>
  1806. <Typography.Text type="tertiary" className="!text-xs flex items-center">
  1807. {t('共')} {currentTestChannel.models.split(',').length} {t('个模型')}
  1808. </Typography.Text>
  1809. </div>
  1810. {/* 搜索与操作按钮 */}
  1811. <div className="flex items-center justify-end gap-2 w-full">
  1812. <Input
  1813. placeholder={t('搜索模型...')}
  1814. value={modelSearchKeyword}
  1815. onChange={(v) => {
  1816. setModelSearchKeyword(v);
  1817. setModelTablePage(1);
  1818. }}
  1819. className="!w-full"
  1820. prefix={<IconSearch />}
  1821. showClear
  1822. />
  1823. <Button
  1824. theme='light'
  1825. onClick={() => {
  1826. if (selectedModelKeys.length === 0) {
  1827. showError(t('请先选择模型!'));
  1828. return;
  1829. }
  1830. copy(selectedModelKeys.join(',')).then((ok) => {
  1831. if (ok) {
  1832. showSuccess(t('已复制 ${count} 个模型').replace('${count}', selectedModelKeys.length));
  1833. } else {
  1834. showError(t('复制失败,请手动复制'));
  1835. }
  1836. });
  1837. }}
  1838. >
  1839. {t('复制已选')}
  1840. </Button>
  1841. <Button
  1842. theme='light'
  1843. type='primary'
  1844. onClick={() => {
  1845. if (!currentTestChannel) return;
  1846. const successKeys = currentTestChannel.models
  1847. .split(',')
  1848. .filter((m) => m.toLowerCase().includes(modelSearchKeyword.toLowerCase()))
  1849. .filter((m) => {
  1850. const result = modelTestResults[`${currentTestChannel.id}-${m}`];
  1851. return result && result.success;
  1852. });
  1853. if (successKeys.length === 0) {
  1854. showInfo(t('暂无成功模型'));
  1855. }
  1856. setSelectedModelKeys(successKeys);
  1857. }}
  1858. >
  1859. {t('选择成功')}
  1860. </Button>
  1861. </div>
  1862. </div>
  1863. )
  1864. }
  1865. visible={showModelTestModal && currentTestChannel !== null}
  1866. onCancel={handleCloseModal}
  1867. footer={
  1868. <div className="flex justify-end">
  1869. {isBatchTesting ? (
  1870. <Button
  1871. theme='light'
  1872. type='warning'
  1873. onClick={handleCloseModal}
  1874. >
  1875. {t('停止测试')}
  1876. </Button>
  1877. ) : (
  1878. <Button
  1879. theme='light'
  1880. type='tertiary'
  1881. onClick={handleCloseModal}
  1882. >
  1883. {t('取消')}
  1884. </Button>
  1885. )}
  1886. <Button
  1887. theme='light'
  1888. type='primary'
  1889. onClick={batchTestModels}
  1890. loading={isBatchTesting}
  1891. disabled={isBatchTesting}
  1892. >
  1893. {isBatchTesting ? t('测试中...') : t('批量测试${count}个模型').replace(
  1894. '${count}',
  1895. currentTestChannel
  1896. ? currentTestChannel.models
  1897. .split(',')
  1898. .filter((model) =>
  1899. model.toLowerCase().includes(modelSearchKeyword.toLowerCase())
  1900. ).length
  1901. : 0
  1902. )}
  1903. </Button>
  1904. </div>
  1905. }
  1906. maskClosable={!isBatchTesting}
  1907. className="!rounded-lg"
  1908. size={isMobile() ? 'full-width' : 'large'}
  1909. >
  1910. <div className="model-test-scroll">
  1911. {currentTestChannel && (
  1912. <div>
  1913. <Table
  1914. columns={[
  1915. {
  1916. title: t('模型名称'),
  1917. dataIndex: 'model',
  1918. render: (text) => (
  1919. <div className="flex items-center">
  1920. <Typography.Text strong>{text}</Typography.Text>
  1921. </div>
  1922. )
  1923. },
  1924. {
  1925. title: t('状态'),
  1926. dataIndex: 'status',
  1927. render: (text, record) => {
  1928. const testResult = modelTestResults[`${currentTestChannel.id}-${record.model}`];
  1929. const isTesting = testingModels.has(record.model);
  1930. if (isTesting) {
  1931. return (
  1932. <Tag color='blue' shape='circle'>
  1933. {t('测试中')}
  1934. </Tag>
  1935. );
  1936. }
  1937. if (!testResult) {
  1938. return (
  1939. <Tag color='grey' shape='circle'>
  1940. {t('未开始')}
  1941. </Tag>
  1942. );
  1943. }
  1944. return (
  1945. <div className="flex items-center gap-2">
  1946. <Tag
  1947. color={testResult.success ? 'green' : 'red'}
  1948. shape='circle'
  1949. >
  1950. {testResult.success ? t('成功') : t('失败')}
  1951. </Tag>
  1952. {testResult.success && (
  1953. <Typography.Text type="tertiary">
  1954. {t('请求时长: ${time}s').replace('${time}', testResult.time.toFixed(2))}
  1955. </Typography.Text>
  1956. )}
  1957. </div>
  1958. );
  1959. }
  1960. },
  1961. {
  1962. title: '',
  1963. dataIndex: 'operate',
  1964. render: (text, record) => {
  1965. const isTesting = testingModels.has(record.model);
  1966. return (
  1967. <Button
  1968. theme='light'
  1969. type='primary'
  1970. onClick={() => testChannel(currentTestChannel, record.model)}
  1971. loading={isTesting}
  1972. size='small'
  1973. >
  1974. {t('测试')}
  1975. </Button>
  1976. );
  1977. }
  1978. }
  1979. ]}
  1980. dataSource={(() => {
  1981. const filtered = currentTestChannel.models
  1982. .split(',')
  1983. .filter((model) =>
  1984. model.toLowerCase().includes(modelSearchKeyword.toLowerCase()),
  1985. );
  1986. const start = (modelTablePage - 1) * MODEL_TABLE_PAGE_SIZE;
  1987. const end = start + MODEL_TABLE_PAGE_SIZE;
  1988. return filtered.slice(start, end).map((model) => ({
  1989. model,
  1990. key: model,
  1991. }));
  1992. })()}
  1993. rowSelection={{
  1994. selectedRowKeys: selectedModelKeys,
  1995. onChange: (keys) => {
  1996. if (allSelectingRef.current) {
  1997. allSelectingRef.current = false;
  1998. return;
  1999. }
  2000. setSelectedModelKeys(keys);
  2001. },
  2002. onSelectAll: (checked) => {
  2003. const filtered = currentTestChannel.models
  2004. .split(',')
  2005. .filter((m) => m.toLowerCase().includes(modelSearchKeyword.toLowerCase()));
  2006. allSelectingRef.current = true;
  2007. setSelectedModelKeys(checked ? filtered : []);
  2008. },
  2009. }}
  2010. pagination={{
  2011. currentPage: modelTablePage,
  2012. pageSize: MODEL_TABLE_PAGE_SIZE,
  2013. total: currentTestChannel.models
  2014. .split(',')
  2015. .filter((model) =>
  2016. model.toLowerCase().includes(modelSearchKeyword.toLowerCase()),
  2017. ).length,
  2018. showSizeChanger: false,
  2019. onPageChange: (page) => setModelTablePage(page),
  2020. }}
  2021. />
  2022. </div>
  2023. )}
  2024. </div>
  2025. </Modal>
  2026. </>
  2027. );
  2028. };
  2029. export default ChannelsTable;