From 1bc65f9830ae5403b94f0c29f5b806d2da249c36 Mon Sep 17 00:00:00 2001
From: wkc <978997012@qq.com>
Date: Tue, 3 Mar 2026 09:27:50 +0800
Subject: [PATCH] feat(routers): implement all 6 API endpoints

---
 lsfx-mock-server/requirements.txt             |   1 +
 lsfx-mock-server/routers/__init__.py          |   1 +
 .../__pycache__/__init__.cpython-313.pyc      | Bin 0 -> 181 bytes
 .../routers/__pycache__/api.cpython-313.pyc   | Bin 0 -> 4154 bytes
 lsfx-mock-server/routers/api.py               |  99 ++++++++++++++++++
 5 files changed, 101 insertions(+)
 create mode 100644 lsfx-mock-server/routers/__init__.py
 create mode 100644 lsfx-mock-server/routers/__pycache__/__init__.cpython-313.pyc
 create mode 100644 lsfx-mock-server/routers/__pycache__/api.cpython-313.pyc
 create mode 100644 lsfx-mock-server/routers/api.py

diff --git a/lsfx-mock-server/requirements.txt b/lsfx-mock-server/requirements.txt
index ca3203e..75b7aa5 100644
--- a/lsfx-mock-server/requirements.txt
+++ b/lsfx-mock-server/requirements.txt
@@ -1,6 +1,7 @@
 fastapi==0.104.1
 uvicorn[standard]==0.24.0
 pydantic==2.5.0
+pydantic-settings==2.1.0
 python-multipart==0.0.6
 pytest>=7.0.0
 pytest-cov>=4.0.0
diff --git a/lsfx-mock-server/routers/__init__.py b/lsfx-mock-server/routers/__init__.py
new file mode 100644
index 0000000..873f7bb
--- /dev/null
+++ b/lsfx-mock-server/routers/__init__.py
@@ -0,0 +1 @@
+# Routers package
diff --git a/lsfx-mock-server/routers/__pycache__/__init__.cpython-313.pyc b/lsfx-mock-server/routers/__pycache__/__init__.cpython-313.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..c1ef67c6da37078bb5d45fab6a128470502c8081
GIT binary patch
literal 181
zcmey&%ge<81jj6vWeNl7#~=<2FhUuhS%8eG4CxG-jD9N_ikN`B&mgH=Aud)i$;m01
z5JE3GC$TgoHKshjD7&O6HMKY<r#P)bH#a{yTemp1s4TSzQ=llnv?R5tI3_+mGcU6w
lK3=b&@)n0pZhlH>PO4oIE6@^<BZ@(ckIamWj77{q761#YF%$p*

literal 0
HcmV?d00001

diff --git a/lsfx-mock-server/routers/__pycache__/api.cpython-313.pyc b/lsfx-mock-server/routers/__pycache__/api.cpython-313.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..a1e8c8f11705d67b4110786879adf63ee8374c75
GIT binary patch
literal 4154
zcmdrPZERE5^}grN_}Ous?+-!^1c=)vE@>zU>X@Jql$R=0akEv$t7q&NV`BSx_dS;p
zX;PpogaQQ>DCuA{v>gOhO)_nyO<`jDwZC?)DdlNwlg2a2FO1AI@o(qeXB(#>Qh)T<
zp7f5-J?EZt-#y>X*=!aB&)u%8;pc4#{hKTbk2#Oz>RE)&BM<U0eTZi;!?T#>by&yi
zv7R?zgOl*sJ|l0!Cf<zAd>Jm|E!e_yn4>&hpOv>^8^!f~<-8r+DQ@Vi;2qdOabsU4
zUxlkEZtAP%YjBMdd6~6nbN(}Mt=Cqvs`J`QR`p&-$*RFyJ5UfS+y;I<=FN<@^ptr`
zovg>whz{rr8*$SLQd~jGYgmgsR*%h7-pzXT6t@!`G*x(6kHfplQ|Z-p8a-7+?*XQ$
zxp@W6)dkJ)J!a5Sv*deLuOL-hB2@-bbxWk4SwX74M2Z8ch9y$Y6{H$Vq%0uSv_xu6
zXqBsZk(ktFP|CKy);l03WC1Jo9sa;@2#bkW@O8g5EGd@3ctrFEd%_Vx(dVIvqabD9
zEy%Bn!$NF8_(ejHWTmD@kOTXBV=)2uM8tyya@{NYg~0G@ek=(d*)J!gA_Elc@W+M;
zRfq~PxxlF0DMSQWAg2{JyBNhv5Az84?QlSVHAnbQmK8-cPiW=4Fcz^V98E<0vWP)Q
z|7uv0N9x`FKmhJ2y8~i0D#qNQ{8bba)-DsshZ_w#9l&?s%}oJVhn$d7dnto}0Z6g$
zK5Nk+8qj~2icrBNF=miy&9nWrs8pMAxfEz)3X&~oZy~wS0JnVaVDXF=v_&_>xR^u~
zcBx|*)tg^0UYWapaY~(=U3mXX_4J1eQ@0l{Oi`;^Eb7%Gnah`)aV#DX0&>6TR8PLE
zp84D<5DWU=fXA7cIJPh~^WfG=b>`^8?Q`nI%j)!;`t`Z{zxnmzxsMj6r`5BkU}<p~
zaRr>IR0Y9_0okXii2Cs`1Xx+|1f_akA{+_k*;tU`VoVYgn@nQLCux3GtN|=Qc=#yw
zI*TibW{ajWAO;1AnBVDC_Uzp14FrN=4YUU${zOpl9u)Dgj0HjRMx>!%wnfFja2wGq
z;N=7eddL9D>yL-q<A;<ohzadfyb6wJfLGcHU=fX?N9Cx}Iq!J!8^?<?yXQN1r8;+|
z9X+G`KTM9l+neX@9pBhHX11p7+mhyOkBrFLFwd<|aqA~SX|6q~Z-1O4UOuwDYI_Yc
z;&LDK%M!#Ooa@dT$Bl)kC<|KZdE$|<Ok%w~L0qpnv3DoQ0JwethvRZsj3unV%iK7e
znfYVp!(;bu&MFoAimB|AX)c>cV#j-fihc;x1xQ#I9s?jW#CbrLg?Q=Cyu=%o5NdgP
zFZ7rFfWOV0*Yz8$s0Eo(zn+F4o7e*a_r7}X-mQt!ud`URuY^##|M>~^)E~5fBEdB`
zt6rK^&%Cdmo>6bkF5LdO^ZvCD)Txu1u`>(TKFwS{W9fIXij`cU7$sbSRw*ALx^(y%
zI1@VwSOY*JpXqcuaTB4m6o8Ac2%mbi8da{Iceqjx*W|`zcW>Ik&vSfI&!;&4u|#Zp
zq;VZ{iCLrntzjKA()u)~LBQ~D5=ZU9Zyvyb1VR6g>d4Q*2$>VdN#VG1Qa$>v=FVc}
z2qYv~j0*UNC>^*O&QdH-RAMNS2(Kg5iXqZvd|}dNd_&M@FilOZ3}`OiNH!C&1>TjC
zwkOrulXmQ0Ice+Xxz-fdI$4+IHYN3&9^+=vHnQPqp4Xy}bdk6a3x;DMX^G!SCwK?m
z+*<&?PjWrIdjRz*-C=XS{}k&zNx00XqnVF?r=^&dH22?|&5RzlShPITIGOQj^~}|U
z+vAXM+OB(FeevMdSR8saTtfZgLT2j5gImWfF1=>^$^dEQKEj9Gqs^SAnNl8(LFo!X
z5tm4Vz0S}&Es-XgPdk!rn1J2zN(7;4XGK=9^Rp@L*>BDE)Ar-`@w)j2cdEgi)3H`#
z7O@87V~N=B$a8Hg)XIH+hzD(AcrvRjv463+$)M<mwm*2K*pWef{wb8kqF4HWkvTrM
zc<i(~HnI58XIe>w)~UGy>fyv(=G0U~4D|*jb?m~zl}T-5vB&1UIW?pH>Ab~d&^%%d
z(ou;PK1uV1QPZIq6VT~;gZMc(xzrPFu*L*<2!o6vC7x(WaV--+z2>{(n+bgx`+e-s
zp})rd5=(P~N&R5n5ifNyBhIH~0fhe!&yGW{k}E8+KdHYo{yPEre)fMd@8qYLogk`>
zEsJMop#W*sM>7-{@7#3e<Y9H}=;D<d5cmtzpU^N43H{>1=bdqXNbrP51RBb$;vkVr
z2hL*us3gsPAIzdOswr=o-8$e4FabY<SE>h4uv_yy=T33%8B?0;O6t4vcB-vs`dw=k
z(~uv|i-$3>0w$r1Njzeb%Gd-zDUZS&6Or2UqbDZegv$sZ|L`!G@-XQ@N^O29lG>Nd
zNErV9A*H6sEbWZAobVcpyk%F%b}F2Z!|(;#SS1zaWo?Wz%7@}m4X}f3G-^{4u7d@Q
zK)i{N^>I;>>71nK!ZBHEva}4-yr&^YOm`jS03uqZ74yq*@kB(}hJOq+QY)mr0JA!V
zVg8AF{)T$~%NiN>KZt;G#Jq49wcSNq?jk_y9vYFQ>O|A15fDf7+451_9ed-6UyWMt
zRJWw7HzbiGYeua3SkvLAq-|rGY0a`6;~w|r5d7qHh;>myc6D)6SDNVtW!3fLy2-{=
zRp*_$rtw!M-%8cJ{Loa!^fBMouFvWS@-JIO)<BS~5pgw-D3fU1nq?`qv8ZxOn&~3P
zbR=84$-y0DTQ{YY9K1Qryp&~4j4`?4M>zz)WY-o-$<`Kik<ZJr2IePB(%F$i1j!#t
c&}?OKqdU#KKsI($b?{5JZF)#3cpDh`e}+Y3YXATM

literal 0
HcmV?d00001

diff --git a/lsfx-mock-server/routers/api.py b/lsfx-mock-server/routers/api.py
new file mode 100644
index 0000000..7f68495
--- /dev/null
+++ b/lsfx-mock-server/routers/api.py
@@ -0,0 +1,99 @@
+from fastapi import APIRouter, BackgroundTasks, UploadFile, File, Form
+from models.request import (
+    GetTokenRequest,
+    FetchInnerFlowRequest,
+    CheckParseStatusRequest,
+    GetBankStatementRequest,
+    DeleteFilesRequest,
+)
+from services.token_service import TokenService
+from services.file_service import FileService
+from services.statement_service import StatementService
+from utils.error_simulator import ErrorSimulator
+from typing import List
+
+# 创建路由器
+router = APIRouter()
+
+# 初始化服务实例
+token_service = TokenService()
+file_service = FileService()
+statement_service = StatementService()
+
+
+# ==================== 接口1：获取Token ====================
+@router.post("/account/common/getToken")
+async def get_token(request: GetTokenRequest):
+    """创建项目并获取访问Token
+
+    如果 projectNo 包含 error_XXXX 标记，将返回对应的错误响应
+    """
+    # 检测错误标记
+    error_code = ErrorSimulator.detect_error_marker(request.projectNo)
+    if error_code:
+        return ErrorSimulator.build_error_response(error_code)
+
+    # 正常流程
+    return token_service.create_token(request)
+
+
+# ==================== 接口2：上传文件 ====================
+@router.post("/watson/api/project/remoteUploadSplitFile")
+async def upload_file(
+    background_tasks: BackgroundTasks,
+    groupId: int = Form(..., description="项目ID"),
+    file: UploadFile = File(..., description="流水文件"),
+):
+    """上传流水文件
+
+    文件将立即返回，并在后台延迟4秒完成解析
+    """
+    return await file_service.upload_file(groupId, file, background_tasks)
+
+
+# ==================== 接口3：拉取行内流水 ====================
+@router.post("/watson/api/project/getJZFileOrZjrcuFile")
+async def fetch_inner_flow(request: FetchInnerFlowRequest):
+    """拉取行内流水
+
+    如果 customerNo 包含 error_XXXX 标记，将返回对应的错误响应
+    """
+    # 检测错误标记
+    error_code = ErrorSimulator.detect_error_marker(request.customerNo)
+    if error_code:
+        return ErrorSimulator.build_error_response(error_code)
+
+    # 正常流程
+    return file_service.fetch_inner_flow(request)
+
+
+# ==================== 接口4：检查文件解析状态 ====================
+@router.post("/watson/api/project/upload/getpendings")
+async def check_parse_status(request: CheckParseStatusRequest):
+    """检查文件解析状态
+
+    返回文件是否还在解析中（parsing字段）
+    """
+    return file_service.check_parse_status(
+        request.groupId, request.inprogressList
+    )
+
+
+# ==================== 接口5：删除文件 ====================
+@router.post("/watson/api/project/batchDeleteUploadFile")
+async def delete_files(request: DeleteFilesRequest):
+    """批量删除上传的文件
+
+    根据logIds列表删除对应的文件记录
+    """
+    return file_service.delete_files(request.groupId, request.logIds, request.userId)
+
+
+# ==================== 接口6：获取银行流水 ====================
+@router.post("/watson/api/project/getBSByLogId")
+async def get_bank_statement(request: GetBankStatementRequest):
+    """获取银行流水列表
+
+    支持分页查询（pageNow, pageSize）
+    """
+    return statement_service.get_bank_statement(request)