201 lines
8.2 KiB
JavaScript
201 lines
8.2 KiB
JavaScript
const https = require('https');
|
||
const XLSX = require('xlsx');
|
||
const path = require('path');
|
||
|
||
// ======================== 配置 ========================
|
||
const EXCEL_FILE = '新建 XLSX 工作表.xlsx';
|
||
const SHEET_NAME = '2026';
|
||
|
||
const BASE_HOST = 'superstar.geelytravel.com';
|
||
const API_BASE = '/api/tmc/tmc';
|
||
const STEP_DELAY_MS = 3000;
|
||
|
||
const API_HEADERS = {
|
||
'accept': 'application/json, text/plain, */*',
|
||
'accept-language': 'zh-CN,zh;q=0.9',
|
||
'authorization': 'Bearer eyJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJKV1QtRC1TRVFfVVNFUl9UTUNfMDAwMDAxODMiLCJ1c2VyX2NvZGUiOiJTRVFfVVNFUl9UTUNfMDAwMDAxODMiLCJyb2xlcyI6WyLnu5PnrpfkuJPlkZgiLCLnu5PnrpfkuJPlkZgiXSwiZXhwIjoxNzg2NTMzNTUxLCJpYXQiOjE3ODM5NDE1NTF9.1Mcmf5IM07Scrry4FzPs6TAcfUu0Nqtjre_2iJlNd5c',
|
||
'cache-control': 'no-cache',
|
||
'pragma': 'no-cache',
|
||
'requestsource': 'D',
|
||
'usercode': 'SEQ_USER_TMC_00000183',
|
||
'cookie': '_c_WBKFRo=CefecIUfnnuqejh60diYtytjDPwI9Qptslcwakc4; acw_tc=731dc87617839414337367659e81455072769ade5ba31e7a9d3e4d5d817123',
|
||
'Referer': 'https://superstar.geelytravel.com/new-tmc/finance/account/saleBill/list',
|
||
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
|
||
};
|
||
|
||
function sleep(ms) {
|
||
return new Promise(resolve => setTimeout(resolve, ms));
|
||
}
|
||
|
||
function httpRequest(method, path, headers, body) {
|
||
return new Promise((resolve, reject) => {
|
||
const opts = {
|
||
hostname: BASE_HOST,
|
||
path,
|
||
method,
|
||
headers: headers || API_HEADERS,
|
||
rejectUnauthorized: false,
|
||
};
|
||
const req = https.request(opts, (res) => {
|
||
let data = '';
|
||
res.on('data', chunk => data += chunk);
|
||
res.on('end', () => {
|
||
try {
|
||
resolve({ status: res.statusCode, data: JSON.parse(data) });
|
||
} catch {
|
||
resolve({ status: res.statusCode, data });
|
||
}
|
||
});
|
||
});
|
||
req.on('error', reject);
|
||
if (body) req.write(body);
|
||
req.end();
|
||
});
|
||
}
|
||
|
||
// ======================== 1. 读取 Excel ========================
|
||
function readTeamIds() {
|
||
const workbook = XLSX.readFile(path.join(__dirname, EXCEL_FILE));
|
||
const sheet = workbook.Sheets[SHEET_NAME];
|
||
if (!sheet) { console.error('Sheet not found'); process.exit(1); }
|
||
const rows = XLSX.utils.sheet_to_json(sheet, { defval: null });
|
||
const teamIds = [];
|
||
for (const row of rows) {
|
||
const val = row['团号'];
|
||
const kaipiaoStatus = row['开票状态'];
|
||
if (!val || !/^TEAM-\d+$/.test(String(val).trim())) continue;
|
||
if (kaipiaoStatus && String(kaipiaoStatus).trim() !== '未开票') {
|
||
console.log(` ⚠ ${String(val).trim()} 开票状态: "${kaipiaoStatus}"，跳过`);
|
||
continue;
|
||
}
|
||
teamIds.push(String(val).trim());
|
||
}
|
||
return teamIds;
|
||
}
|
||
|
||
// ======================== 2. 获取 settlementAccountIds ========================
|
||
async function querySettlementAccountIds(teamId) {
|
||
const path = `${API_BASE}/customerAccount/settlement/querySettlementAccountIds?customerSettlementAccountName=${encodeURIComponent(teamId)}`;
|
||
console.log(` [GET] ${path}`);
|
||
const res = await httpRequest('GET', path);
|
||
console.log(` [OK]`, JSON.stringify(res.data));
|
||
return (res.data && res.data.code === 'Z000' && Array.isArray(res.data.result)) ? res.data.result : [];
|
||
}
|
||
|
||
// ======================== 3. 获取结算单列表 ========================
|
||
async function listReceiveStatements(settlementAccountId) {
|
||
const path = `${API_BASE}/settlement/receiveStatements/listPageReceiveStatements?settlementAccountId=${settlementAccountId}&sortType=1&pageIndex=1&pageSize=10`;
|
||
console.log(` [GET] ${path}`);
|
||
const res = await httpRequest('GET', path);
|
||
console.log(` [OK]`, JSON.stringify(res.data));
|
||
return (res.data && res.data.code === 'Z000' && res.data.result && res.data.result.list) ? res.data.result.list : [];
|
||
}
|
||
|
||
// ======================== 4. 自动对账：POST ========================
|
||
async function autoReconciliation(statementSeq, id) {
|
||
const path = '/api/tmc/finance/frond/receiveStatements/autoReconciliation';
|
||
const headers = {
|
||
...API_HEADERS,
|
||
'content-type': 'application/json;charset=UTF-8',
|
||
'Referer': `https://superstar.geelytravel.com/new-tmc/finance/account/saleBill/detail/${id}/${statementSeq}`,
|
||
};
|
||
const body = JSON.stringify({ statementSeq });
|
||
console.log(` [POST] ${path} body=${body}`);
|
||
const res = await httpRequest('POST', path, headers, body);
|
||
console.log(` [OK]`, JSON.stringify(res.data));
|
||
return res.data;
|
||
}
|
||
|
||
// ======================== 5. 确认对账：POST ========================
|
||
async function confirmReconciliation(statementSeq, id) {
|
||
const path = `${API_BASE}/settlement/receiveStatementsGroup/confirmCompleteReceiveReconciliation?statementSeq=${statementSeq}`;
|
||
const headers = {
|
||
...API_HEADERS,
|
||
'Referer': `https://superstar.geelytravel.com/new-tmc/finance/account/saleBill/detail/${id}/${statementSeq}`,
|
||
};
|
||
console.log(` [POST] ${path}`);
|
||
const res = await httpRequest('POST', path, headers, null);
|
||
console.log(` [OK]`, JSON.stringify(res.data));
|
||
return res.data;
|
||
}
|
||
|
||
// ======================== 主流程 ========================
|
||
async function main() {
|
||
const teamIds = readTeamIds();
|
||
console.log(`
|
||
TEAM IDs: ${teamIds.join(', ')}
|
||
`);
|
||
|
||
// 预查询所有结算单，计算总任务数
|
||
console.log('预查询结算单列表...');
|
||
const allTasks = [];
|
||
for (const teamId of teamIds) {
|
||
const accounts = await querySettlementAccountIds(teamId);
|
||
if (!accounts.length) continue;
|
||
for (const account of accounts) {
|
||
const statements = await listReceiveStatements(account.id);
|
||
for (const st of statements) {
|
||
allTasks.push({ teamId, accountId: account.id, statement: st });
|
||
}
|
||
}
|
||
}
|
||
|
||
const total = allTasks.length;
|
||
const pendingTasks = allTasks.filter(t => t.statement.statementStatus !== '5');
|
||
const pendingTotal = pendingTasks.length;
|
||
const skipCount = total - pendingTotal;
|
||
console.log(`总任务: ${total} | 跳过(已完成): ${skipCount} | 待处理: ${pendingTotal}
|
||
`);
|
||
|
||
if (pendingTotal === 0) {
|
||
console.log('所有结算单已完成，无需处理。');
|
||
return;
|
||
}
|
||
|
||
const allResults = [];
|
||
let completed = 0;
|
||
|
||
for (const task of allTasks) {
|
||
const { teamId, accountId, statement: st } = task;
|
||
const { id, statementSeq, statementName, receivableTotalPrice, statementStatus } = st;
|
||
|
||
const pct = Math.round((completed / pendingTotal) * 100);
|
||
console.log(`
|
||
${'='.repeat(50)}`);
|
||
console.log(` 进度: ${pct}% (${completed}/${pendingTotal}) | ${teamId} | ${statementSeq}`);
|
||
console.log(`${'='.repeat(50)}`);
|
||
console.log(` 结算单: ${statementName}`);
|
||
console.log(` 应收: \u00a5${receivableTotalPrice} | 状态: ${statementStatus}`);
|
||
|
||
if (statementStatus === '5') {
|
||
console.log(` \u26a0 已完成，跳过`);
|
||
allResults.push({ teamId, settlementAccountId: accountId, statementSeq, statementName, receivableTotalPrice, autoReconResult: { code: 'SKIP' }, confirmResult: { code: 'SKIP' } });
|
||
continue;
|
||
}
|
||
|
||
const autoResult = await autoReconciliation(statementSeq, id);
|
||
console.log(` \u23f3 等待 ${STEP_DELAY_MS / 1000}s...`);
|
||
await sleep(STEP_DELAY_MS);
|
||
const confirmResult = await confirmReconciliation(statementSeq, id);
|
||
|
||
allResults.push({ teamId, settlementAccountId: accountId, statementSeq, statementName, receivableTotalPrice, autoReconResult: autoResult, confirmResult });
|
||
completed++;
|
||
console.log(` >>> 进度: ${Math.round((completed / pendingTotal) * 100)}% (${completed}/${pendingTotal})`);
|
||
}
|
||
// ======================== 汇总 ========================
|
||
console.log('\n\n' + '='.repeat(70));
|
||
console.log(' 最终汇总');
|
||
console.log('='.repeat(70));
|
||
|
||
for (const item of allResults) {
|
||
const aOk = item.autoReconResult && (item.autoReconResult.code === 'Z000' || item.autoReconResult.code === 'SKIP');
|
||
const cOk = item.confirmResult && (item.confirmResult.code === 'Z000' || item.confirmResult.code === 'SKIP');
|
||
console.log(`\n${aOk ? '\u2705' : '\u274c'} 自动 | ${cOk ? '\u2705' : '\u274c'} 确认 | ${item.teamId} | ${item.statementSeq}`);
|
||
console.log(` ${item.statementName} \u00a5${item.receivableTotalPrice}`);
|
||
console.log(` 自动: ${JSON.stringify(item.autoReconResult)}`);
|
||
console.log(` 确认: ${JSON.stringify(item.confirmResult)}`);
|
||
}
|
||
}
|
||
|
||
main().catch(err => { console.error('Error:', err); process.exit(1); });
|