-
中欧 · 英国物流服务
+
中美物流服务
物流问题，随时为您解答
@@ -51,8 +55,8 @@
@@ -64,6 +68,7 @@
+
@@ -99,6 +104,7 @@
+
diff --git a/tests/frontend/chat.test.cjs b/tests/frontend/chat.test.cjs
index 64339b2..367d8c0 100644
--- a/tests/frontend/chat.test.cjs
+++ b/tests/frontend/chat.test.cjs
@@ -76,6 +76,7 @@ async function customerPage(pageOptions = {}){
};
class TestDate extends Date { constructor(...args){ super(...(args.length ? args : [2026, 9, 29, pageOptions.hour ?? 12])); } }
let state = {status:'active', messages:[]};
+ let customerState=pageOptions.customer || null;
const context = vm.createContext({
document, console, Date:TestDate, navigator:{language:'zh-CN',clipboard:pageOptions.clipboard}, AbortController, TextDecoder, confirm:() => true,
FormData:class { append(){} },
@@ -93,7 +94,14 @@ async function customerPage(pageOptions = {}){
clearTimeout:id => timers.delete(id),
fetch: async (url, options) => {
calls.push({url, body:options && options.body && (typeof options.body === 'string' ? JSON.parse(options.body) : options.body)});
- if(hooks[url]) return hooks[url](options);
+ if(hooks[url]){
+ const result=await hooks[url](options);
+ if(url==='/api/customer/login' || url==='/api/customer/logout'){
+ const data=await result.json();
+ if(result.ok && data.ok) customerState=url==='/api/customer/login' ? data.user : null;
+ }
+ return result;
+ }
if(url === '/api/get_history' && pageOptions.historyFetch) return pageOptions.historyFetch();
if(url.startsWith('/api/visitor/human/poll') && hooks.poll) return hooks.poll(url);
if(url.startsWith('/api/get_messages') && hooks.messages) return hooks.messages(url);
@@ -107,7 +115,8 @@ async function customerPage(pageOptions = {}){
}
const data = url === '/api/new_chat' ? {id:nextConvId++, welcome:'welcome'}
: url === '/api/visitor/session' ? {ok:true,key:'1'.repeat(64)}
- : url === '/api/customer/session' ? {ok:true,authenticated:Boolean(pageOptions.customer),user:pageOptions.customer || null}
+ : url === '/api/customer/session' ? {ok:true,authenticated:Boolean(customerState),user:customerState}
+ : url === '/api/customer/session?overview=1' ? {ok:true,authenticated:Boolean(customerState),user:customerState,overview:pageOptions.overview || {total:0,processing:0,exceptions:0,stages:[],orders:[]}}
: url === '/api/visitor/human/request' ? (pageOptions.serviceClosed ? {ok:false,closed:true} : {ok:true, session_id:7})
: url.startsWith('/api/visitor/human/poll') ? state
: ['/api/rate', '/api/feedback', '/api/visitor/human/send', '/api/visitor/human/close', '/api/ticket'].includes(url) || url.startsWith('/api/del_history') ? {ok:true}
@@ -115,7 +124,7 @@ async function customerPage(pageOptions = {}){
return {ok:true, json:async () => data};
},
});
- for(const file of ['support.js', 'visitor.js', 'customer.js', 'order_lookup.js', 'drafts.js', 'voice.js', 'chat.js']){
+ for(const file of ['support.js', 'visitor.js', 'customer.js', 'overview.js', 'order_lookup.js', 'drafts.js', 'voice.js', 'chat.js']){
vm.runInContext(fs.readFileSync(path.join(__dirname, '../../static/js', file), 'utf8'), context, {filename:file});
if(file === 'voice.js'){
const createVoice=context.ChatVoice.create;
@@ -193,7 +202,90 @@ test('switching to a quick topic discards the previous topic attachment', async
app.context.window.__pendingImg='/uploads/20261029100145_6787.txt';
app.context.window.__pendingTag='[文件]';
await app.click(app.quickButtons[1]);
- assert.equal(app.calls.find(call => call.url === '/stream_chat').body.msg, '欧洲海运专线报价');
+ assert.equal(app.calls.find(call => call.url === '/stream_chat').body.msg, '美国海运专线报价');
+});
+
+test('the homepage and exception shortcut match the US service in both languages', async () => {
+ for(const language of ['zh','en']){
+ const app=await customerPage({human:false,storage:{'wuliu-lang':language}});
+ await app.click(app.element('.new-chat-btn'));
+ const html=app.element('chatDom').innerHTML;
+ assert.doesNotMatch(html,/欧洲|中欧|英国物流|EUROPE|Europe|理赔|file a claim/);
+ assert.match(html,language==='zh'?/中美物流服务/:/CHINA–US LOGISTICS/);
+ assert.match(html,language==='zh'?/美国海运专线报价/:/US sea freight quote/);
+ assert.match(html,language==='zh'?/查询异常订单/:/View exception orders/);
+ const question=language==='zh'?'我有多少个异常订单？':'How many exception orders do I have?';
+ assert.ok(html.includes('data-question="'+question+'"'));
+ await app.click(app.quickButtons[2]);
+ assert.equal(app.calls.find(call=>call.url==='/stream_chat').body.msg,question);
+ }
+});
+
+test('authenticated entry loads one overview with actionable counts and safe exception text', async () => {
+ const overview={total:9,processing:3,exceptions:2,stages:[{code:'IN_TRANSIT',count:3}],orders:[
+ {order_no:'ORDER20260001',inbound_code:'INB20260001',stage:'IN_TRANSIT',exception_reason:'
'}
+ ]};
+ const app=await customerPage({human:false,customer:{id:1,name:'admin'},overview});
+ const panel=app.element('customer-overview');
+ assert.equal(panel.hidden,false);assert.equal(panel.open,true);
+ assert.match(app.element('customer-overview-summary').textContent,/履约中 3 · 异常订单 2/);
+ assert.equal(app.calls.filter(call=>call.url==='/api/customer/session?overview=1').length,1);
+ const body=app.element('customer-overview-body');
+ assert.equal(body.querySelector('.overview-reason').innerHTML,'');
+ assert.equal(body.querySelector('.overview-reason').textContent,'
');
+ await app.click(body.querySelector('.overview-order'));
+ assert.equal(app.element('order-lookup').hidden,false);
+ assert.equal(app.element('order-reference').value,'INB20260001');
+ await app.click(app.element('order-lookup-cancel'));
+ await app.click(body.querySelectorAll('.overview-metric')[1]);
+ assert.equal(app.calls.find(call=>call.url==='/stream_chat').body.msg,'列出履约中的订单');
+ assert.equal(panel.open,false);
+});
+
+test('guest entry skips private overview and a late refresh cannot restore it after logout', async () => {
+ const guest=await customerPage({human:false});
+ assert.equal(guest.element('customer-overview').hidden,true);
+ assert.equal(guest.calls.filter(call=>call.url==='/api/customer/session?overview=1').length,0);
+ const app=await customerPage({human:false,customer:{id:1,name:'admin'}});
+ let resolve;
+ app.hooks['/api/customer/session?overview=1']=()=>new Promise(done=>{resolve=done;});
+ app.element('customer-overview-body').querySelector('.overview-refresh').click();
+ app.hooks['/api/customer/logout']=()=>response({ok:true,authenticated:false,user:null});
+ await app.click(app.element('customer-account'));
+ resolve(response({ok:true,authenticated:true,user:{id:1,name:'admin'},overview:{total:99,processing:99,exceptions:99,stages:[],orders:[]}}));
+ await flush();
+ assert.equal(app.element('customer-overview').hidden,true);
+ assert.equal(app.element('customer-overview-body').textContent,'');
+ assert.doesNotMatch(app.element('customer-overview-summary').textContent,/99/);
+});
+
+test('overview failure can retry and account data stays out of its error state', async () => {
+ const app=await customerPage({human:false,customer:{id:1,name:'admin'}});
+ app.hooks['/api/customer/session?overview=1']=()=>response({ok:false},503);
+ await app.element('customer-overview-body').querySelector('.overview-refresh').click();
+ assert.match(app.element('customer-overview-summary').textContent,/暂时无法加载/);
+ assert.equal(app.element('customer-overview-body').querySelector('.overview-metric'),null);
+ delete app.hooks['/api/customer/session?overview=1'];
+ await app.element('customer-overview-body').querySelector('.overview-refresh').click();
+ assert.match(app.element('customer-overview-summary').textContent,/履约中 0/);
+});
+
+test('voice errors use a floating notice without changing the composer status', async () => {
+ const app=await customerPage({human:false,width:390});
+ const status=app.element('composer-status');
+ app.voiceOptions.status('语音输入失败，请重试。',true);
+ const feedback=app.element('voice-feedback');
+ assert.equal(feedback.hidden,false);
+ assert.equal(feedback.textContent,'语音输入失败，请重试。');
+ assert.ok(feedback.classList.contains('is-error'));
+ assert.equal(status.textContent,'');
+ app.voiceOptions.status('语音输入失败，请重试。',true);
+ assert.equal(feedback.hidden,false);
+ await app.runTimers(4000);
+ assert.equal(feedback.hidden,true);
+ app.voiceOptions.status('语音输入失败，请重试。',true);
+ await app.click(app.element('.new-chat-btn'));
+ assert.equal(feedback.hidden,true);
});
test('fragmented CRLF event streams preserve UTF-8 text and complete normally', async () => {
@@ -390,7 +482,7 @@ test('tracking does not interrupt human support while quote and exception shortc
const requests = app.calls.filter(call => call.url === '/stream_chat');
assert.equal(requests.length, 2);
assert.equal(new Set(requests.map(call => call.body.conv_id)).size, 2);
- assert.deepEqual(requests.map(call => call.body.msg), ['欧洲海运专线报价', '包裹异常处理']);
+ assert.deepEqual(requests.map(call => call.body.msg), ['美国海运专线报价', '我有多少个异常订单？']);
assert.equal(app.calls.filter(call => call.url === '/api/visitor/human/send').length, 0);
assert.equal(app.context.window.humanSid, 0);
assert.equal(app.element('human-session').hidden, true);
@@ -398,14 +490,14 @@ test('tracking does not interrupt human support while quote and exception shortc
test('welcome and hot question buttons use the same AI routing as the footer', async () => {
const app = await customerPage();
- for(const question of ['欧洲海运专线报价', '如何申请理赔？']){
+ for(const question of ['美国海运专线报价', '各个轨迹节点分别有多少订单？']){
const button = app.element('question-'+question);
button.dataset.question = question;
app.element('chatDom').listeners.click({target:button});
await flush();
}
const requests = app.calls.filter(call => call.url === '/stream_chat');
- assert.deepEqual(requests.map(call => call.body.msg), ['欧洲海运专线报价', '如何申请理赔？']);
+ assert.deepEqual(requests.map(call => call.body.msg), ['美国海运专线报价', '各个轨迹节点分别有多少订单？']);
assert.equal(app.calls.filter(call => call.url === '/api/visitor/human/send').length, 0);
});
@@ -464,7 +556,7 @@ test('a late conversation creation cannot replace the newest quick question', as
const requests = app.calls.filter(call => call.url === '/stream_chat');
assert.equal(requests.length, 1);
assert.equal(requests[0].body.conv_id, 22);
- assert.equal(requests[0].body.msg, '包裹异常处理');
+ assert.equal(requests[0].body.msg, '我有多少个异常订单？');
assert.equal(app.context.window.__busy, false);
});
diff --git a/tests/frontend/voice.test.cjs b/tests/frontend/voice.test.cjs
index cbb2ef8..dc25460 100644
--- a/tests/frontend/voice.test.cjs
+++ b/tests/frontend/voice.test.cjs
@@ -97,6 +97,26 @@ test('short presses and unavailable service do not upload recordings',async()=>{
assert.equal(disabled.statuses.at(-1)[0],'voiceUnavailable');
});
+test('a failed physical hold cannot restart until it has been released',async()=>{
+ for(const touch of [false,true]){
+ const app=voicePage({enabled:false,touch});
+ app.open();
+ const point={identifier:7,clientY:300};
+ const down=async()=>{
+ if(touch) app.elements.hold.listeners.touchstart({touches:[point],preventDefault(){}});
+ else app.elements.hold.listeners.pointerdown(app.event());
+ await flush();
+ };
+ await down();await down();
+ assert.equal(app.calls.filter(call=>call.url==='/api/speech/config').length,1);
+ if(touch) app.elements.hold.listeners.touchend({changedTouches:[point],preventDefault(){}});
+ else app.elements.hold.listeners.pointerup(app.event());
+ await down();
+ assert.equal(app.calls.filter(call=>call.url==='/api/speech/config').length,2);
+ assert.equal(app.permissionCalls,0);
+ }
+});
+
test('late microphone permission after cancellation immediately stops its tracks',async()=>{
let grant;const app=voicePage({permission:()=>new Promise(resolve=>{grant=resolve;})});
app.open();await app.down();await app.up();grant(app.stream);await flush();
diff --git a/tests/test_order_statistics.py b/tests/test_order_statistics.py
index c570453..4161e2d 100644
--- a/tests/test_order_statistics.py
+++ b/tests/test_order_statistics.py
@@ -57,6 +57,51 @@ class OrderStatisticsTests(unittest.TestCase):
self.assertTrue(self.ask(q)['login_required'])
read.assert_not_called()
+ def test_session_overview_is_opt_in_scoped_prioritized_and_not_cached(self):
+ with patch('logistics_chat.order_listing.read_overview') as read:
+ guest=self.client.get('/api/customer/session?overview=1&tenant_id=b',headers={'X-Tenant-Id':'b'})
+ self.assertFalse(guest.json['authenticated'])
+ self.assertNotIn('overview',guest.json)
+ read.assert_not_called()
+ self.login()
+ self.assertNotIn('overview',self.client.get('/api/customer/session').json)
+ response=self.client.get('/api/customer/session?overview=1&tenant_id=b',headers={'X-Tenant-Id':'b'})
+ overview=response.json['overview']
+ self.assertIn('no-store',response.headers['Cache-Control'])
+ self.assertEqual((overview['total'],overview['processing'],overview['exceptions']),(16,12,7))
+ self.assertEqual(sum(stage['count'] for stage in overview['stages']),12)
+ self.assertEqual(len(overview['orders']),5)
+ self.assertTrue(all(order['exception_reason'] for order in overview['orders']))
+ self.assertNotIn('SECRET',response.get_data(as_text=True))
+ self.assertNotIn('tenant_id',response.get_data(as_text=True))
+ self.client.post('/api/customer/logout')
+ self.assertNotIn('overview',self.client.get('/api/customer/session?overview=1').json)
+
+ def test_overview_keeps_old_exception_ahead_of_new_processing_orders_and_refreshes(self):
+ self.login()
+ with self.app.app_context():
+ c=db.connect()
+ c.execute("UPDATE order_test_data SET exception_reason=NULL WHERE tenant_id='a' AND order_no<>'STAT20260000'")
+ c.commit();c.close()
+ overview=self.client.get('/api/customer/session?overview=1').json['overview']
+ self.assertEqual(overview['orders'][0]['order_no'],'STAT20260000')
+ self.assertEqual(len({order['order_no'] for order in overview['orders']}),5)
+ with self.app.app_context():
+ c=db.connect()
+ order_data.import_records(c,[{'tenant_id':'a','order_no':'NEW20260001','status':'PROCESSING','exception_reason':'资料待核实'}])
+ c.commit();c.close()
+ refreshed=self.client.get('/api/customer/session?overview=1').json['overview']
+ self.assertEqual((refreshed['total'],refreshed['processing'],refreshed['exceptions']),(17,13,2))
+
+ def test_overview_read_failure_keeps_login_available_and_no_facts_leak(self):
+ self.login()
+ with patch('logistics_chat.order_listing.read_overview',side_effect=sqlite3.OperationalError('private details')):
+ result=self.client.get('/api/customer/session?overview=1').json
+ self.assertTrue(result['authenticated'])
+ self.assertEqual(result['overview_error'],'unavailable')
+ self.assertNotIn('overview',result)
+ self.assertNotIn('private details',str(result))
+
def test_summaries_show_at_most_five_recent_rows_and_keep_intersecting_filters(self):
self.login()
total=self.ask('我有多少个订单')['t']
@@ -79,6 +124,14 @@ class OrderStatisticsTests(unittest.TestCase):
self.assertIn(token,text)
self.assertNotIn('已还柜：',text);self.assertNotIn('已签收：',text)
+ def test_english_homepage_questions_apply_their_intended_filters(self):
+ self.assertTrue(self.ask('How many exception orders do I have?')['login_required'])
+ self.login()
+ self.assertIn('7 票明确标记异常',self.ask('How many exception orders do I have?')['t'])
+ text=self.ask('How many orders are at each tracking stage?')['t']
+ self.assertIn('船舶已到目的港：10票',text)
+ self.assertIn('暂无实际节点：3票',text)
+
def test_expand_and_pages_keep_filters_and_refresh_counts(self):
self.login();cid=self.client.post('/api/new_chat').json['id']
self.ask('我有多少异常订单',cid)