Merge remote-tracking branch 'origin/develop/xp' into develop/xp

# Conflicts:
#	app/api/statement/crud.py
#	app/api/statement/views.py

.idea/financial-system.iml

@@ -6,7 +6,7 @@
       <excludeFolder url="file://$MODULE_DIR$/fs-env" />
       <excludeFolder url="file://$MODULE_DIR$/venv" />
     </content>
-    <orderEntry type="jdk" jdkName="Python 3.8 (financial_system)" jdkType="Python SDK" />
+    <orderEntry type="jdk" jdkName="Python 3.8 (financial-system)" jdkType="Python SDK" />
     <orderEntry type="sourceFolder" forTests="false" />
   </component>
   <component name="PyDocumentationSettings">

app/api/statement/schemas.py

@@ -113,14 +113,12 @@ class UserNumber(BaseModel):
 
 class CreateBill(BaseModel):
     dst_id: Optional[str] = ""
-    dst_name: str = ""
-    amount: float
+    dst_name: Optional[str] = ""
+    amount: Optional[float] = 0.0
     transfer_id: Optional[str] = ""
-    transfer_name: str = ""
     remark: Optional[str] = ""
-    type: int
-    nick_name: Optional[str] = ""
     transfer_type: Optional[str] = ""
+    type: Optional[int] = None
 
     # @validator('transfer_id')
     # def transfer_id_must_contain_space(cls, v):

app/api/statement/views.py

@@ -64,7 +64,7 @@ def guild_payment_list(page: Optional[int] = 1, size: Optional[int] = 10,start_t
 
 
 @router.post('/upload')
-async def uploadFile(a_file: bytes = File(...),token=Depends(login_required),):
+async def uploadFile(a_file: bytes = File(...), token=Depends(login_required), ):
     a_content = a_file
     image_name = random_number()
     cos_path = new_upload_file(a_content, image_name)
@@ -74,40 +74,47 @@ async def uploadFile(a_file: bytes = File(...),token=Depends(login_required),):
 
 
 @router.post("/payment/add")
-def guild_payment_list(data:PaymentAdd,db: Session = Depends(get_db)):
+def guild_payment_list(data: PaymentAdd, db: Session = Depends(get_db)):
     """提交打款"""
     transfer_query(data)
     return HttpResultResponse(code=200,data='')
 
 
 @router.get("/onaccount")
-def outon_account(db: Session = Depends(get_db),token=Depends(login_required)):
+def outon_account(db: Session = Depends(get_db), token=Depends(login_required)):
     """转出和转入账户人员列表"""
     account_list, total = outon_account_data(db, Account, {})
     return HttpResultResponse(total=total, data=account_list)
 
 
-@router.post("/transferlist")
-def outon_account(data: PaymentAccountlList,token=Depends(login_required),db: Session = Depends(get_db)):
+@router.get("/transferlist")
+def out_on_account(page: int,
+                   size: int,
+                   start_time: Optional[str] = "",
+                   end_time: Optional[str] = "",
+                   transfer_name: Optional[str] = "",
+                   dst_name: Optional[str] = "",
+                   token=Depends(login_required)):
     """转账列表"""
-    account_list, total = accout_list_data(db, Fitransferlog, data.dict(exclude_none=True))
+    account_list, total = accout_list_data(page=page, size=size, start_time=start_time, end_time=end_time,
+                                           transfer_name=transfer_name, dst_name=dst_name)
     return HttpResultResponse(total=total, data=account_list)
 
 
-@router.post("/query/consumable")
-def query_account_money(data: UserNumber,token=Depends(login_required),db: Session = Depends(get_db)):
+@router.get("/query/consumable")
+def query_account_money(uuid: str, token=Depends(login_required)):
     """查询账户余额"""
-    consumable = account_money(db, data)
-    return HttpResultResponse(data=int(consumable))
+    if not uuid:
+        return HttpResultResponse(code=500, msg='请输入uuid')
+    consumable = account_money(uuid)
+    return HttpResultResponse(data=consumable)
 
 
 @router.post("/query/uuid")
-def query_uuid_account(data: UserNumber, token=Depends(login_required), db: Session = Depends(get_db)):
+def query_uuid_account(data: UserNumber, token=Depends(login_required)):
     """uuid user_number查询"""
-    user_info = query_uuid_or_user_number(db, data)
-    if user_info=={}:
-        return HttpResultResponse(code=500,data=user_info,msg="未查询到")
-    return HttpResultResponse(code=200,data=user_info)
+    user_info = query_uuid_or_user_number(data)
+    return HttpResultResponse(data=user_info)
 
 
 @router.post("/transfer/money")
@@ -124,7 +131,7 @@ def account_transfer_money(data: CreateBill, request: Request,
 
 
 @router.post("/guild/update")
-def guild_update_list(data: schemas.GuildUpdate,token=Depends(login_required)):
+def guild_update_list(data: schemas.GuildUpdate, token=Depends(login_required)):
     """公会结算"""
     GuildSet().update_guild_info(data)
     return HttpResultResponse()
@@ -160,7 +167,8 @@ def recovery_fix(page: int,
                  end_time: Optional[str] = "",
                  token=Depends(login_required)):
     """异常数据修复列表"""
-    recovery_list, total = guild.recovery_fix_data(page=page, size=size, uuid=uuid, start_time=start_time, end_time=end_time)
+    recovery_list, total = guild.recovery_fix_data(page=page, size=size, uuid=uuid, start_time=start_time,
+                                                   end_time=end_time)
     return HttpResultResponse(total=total, data=recovery_list)
 
 
@@ -173,3 +181,10 @@ def finance_fix(data: acc_schemas.RecoveryTable, token=Depends(login_required),
     return HttpResultResponse()
 
 
+@router.post("/recovery/fix")
+def recovery_fix(data: acc_schemas.RecoveryupdateTable, token=Depends(login_required)):
+    """修改异常数据"""
+    res = guild.update_recovery_table(data)
+    if res:
+        return HttpResultResponse(code=500, msg=res)
+    return HttpResultResponse()

core/config/env.py

@@ -12,23 +12,22 @@ from qcloud_cos import CosS3Client
 SITE_ROOT = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
 FILE_PATH = os.path.join(SITE_ROOT, "runtime", "images")
 
-
-region ='ap-guangzhou'
+region = 'ap-guangzhou'
 token = None
-scheme ='https'
+scheme = 'https'
 # Bucket ="3yakj-center-1256890024"  #正式桶
-Bucket="fj-dc-test-1256890024"  #测试桶
+Bucket = "fj-dc-test-1256890024"  # 测试桶
 
 # Bucket="3yakj"  #测试桶
 
 # secret_id='LTAI5t6JyitXaGoGdU7mga7o'
 # secret_key='Qg69gRB0vTThX5Ur6tlqgbmvqRaUjE'
-secret_id='AKIDra5Ur292g4FCzYrwmMhAOQFsHSP9wb3S'
-secret_key='JRKyzpSr1wc5OXXUFsGPKtKfsvqcEcqw'
+secret_id = 'AKIDra5Ur292g4FCzYrwmMhAOQFsHSP9wb3S'
+secret_key = 'JRKyzpSr1wc5OXXUFsGPKtKfsvqcEcqw'
 config = CosConfig(Region=region, SecretId=secret_id, SecretKey=secret_key, Token=token, Scheme=scheme)
 client = CosS3Client(config)
-COS_PATH ='https://fj-dc-test-1256890024.cos.ap-guangzhou.myqcloud.com'  #测试
-COS_RERURN_PATH='/images/'
+COS_PATH = 'https://fj-dc-test-1256890024.cos.ap-guangzhou.myqcloud.com'  # 测试
+COS_RERURN_PATH = '/images/'
 
 
 class Env(BaseSettings):

libs/functions.py

@@ -98,9 +98,9 @@ def search(params, method):
     }
     response = requests.post(url=url, headers=header, json=params)
     if response.status_code != 200:
-        return {"status": 0}
+        return {}
     text = json.loads(response.text)
-    return {"status": 1, 'data': text.get('data').get("result")}
+    return text
 
 
 def get_ip():