编写财务报表的增删改查
This commit is contained in:
parent
8307a1e74f
commit
4f795bf100
|
@ -21,19 +21,15 @@ host = 127.0.0.1
|
||||||
port = 27017
|
port = 27017
|
||||||
db = 城投调研
|
db = 城投调研
|
||||||
|
|
||||||
[hw_msg]
|
[hw_msg] # 华为短信配置
|
||||||
# 华为短信配置
|
|
||||||
# APP接入地址(在控制台"应用管理"页面获取)+接口访问URI
|
|
||||||
url = https://smsapi.cn-north-4.myhuaweicloud.com:443/sms/batchSendSms/v1
|
url = https://smsapi.cn-north-4.myhuaweicloud.com:443/sms/batchSendSms/v1
|
||||||
app_key = 3h499M186sTF8046f9J9I28J1L9m
|
app_key = 3h499M186sTF8046f9J9I28J1L9m
|
||||||
app_secret = TMCaZWxoMbuW55l27zdxoDfsiKAH
|
app_secret = TMCaZWxoMbuW55l27zdxoDfsiKAH
|
||||||
# 国内短信签名通道号或国际/港澳台短信通道号
|
# 通道号
|
||||||
sender = 8823032033987
|
sender = 8823032033987
|
||||||
# 模板ID
|
|
||||||
template_id = 2e129e3ad70d4ccaa8cbadf528d69c3a
|
template_id = 2e129e3ad70d4ccaa8cbadf528d69c3a
|
||||||
# 签名名称
|
# 签名名称
|
||||||
signature = 远东资信
|
signature = 远东资信
|
||||||
# 选填,短信状态报告接收地址,推荐使用域名,为空或者不填表示不接收状态报告
|
|
||||||
status_call_back = ""
|
status_call_back = ""
|
||||||
|
|
||||||
[app]
|
[app]
|
||||||
|
|
|
@ -7,6 +7,11 @@ from Utils.MongoUtils import pydantic_to_mg_dict
|
||||||
from . import Schemas
|
from . import Schemas
|
||||||
|
|
||||||
|
|
||||||
|
# 财务报表数据结构验证
|
||||||
|
def finance_data_check(type_name: str, data: dict):
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
def format_id(obj: dict):
|
def format_id(obj: dict):
|
||||||
obj["_id"] = str(obj["_id"])
|
obj["_id"] = str(obj["_id"])
|
||||||
obj["id"] = obj["_id"]
|
obj["id"] = obj["_id"]
|
||||||
|
@ -15,8 +20,8 @@ def format_id(obj: dict):
|
||||||
|
|
||||||
def company_finance_add(db: Database, type_name, data):
|
def company_finance_add(db: Database, type_name, data):
|
||||||
col = db[type_name]
|
col = db[type_name]
|
||||||
new_item = col.insert_one(data)
|
col.insert_one(data)
|
||||||
data['id'] = str(new_item.inserted_id)
|
format_id(data)
|
||||||
return data
|
return data
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -10,7 +10,7 @@ router = APIRouter(tags=["财务报表"])
|
||||||
|
|
||||||
@router.post("/company_finance/add", summary="添加财务报表")
|
@router.post("/company_finance/add", summary="添加财务报表")
|
||||||
def company_finance_query(req: Schemas.CompanyFinanceAddReq, db: Session = Depends(mg_db.get_db)):
|
def company_finance_query(req: Schemas.CompanyFinanceAddReq, db: Session = Depends(mg_db.get_db)):
|
||||||
item = Crud.company_finance_add(db, req)
|
item = Crud.company_finance_add(db, req.type,req.data)
|
||||||
return item
|
return item
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -5,6 +5,7 @@ from Context.common import common_db
|
||||||
class User(common_db.Base):
|
class User(common_db.Base):
|
||||||
__tablename__ = "user"
|
__tablename__ = "user"
|
||||||
email = Column(String(128), primary_key=True, comment="邮箱")
|
email = Column(String(128), primary_key=True, comment="邮箱")
|
||||||
|
phone = Column(String(255), comment="手机号")
|
||||||
name = Column(String(32), comment="用户名")
|
name = Column(String(32), comment="用户名")
|
||||||
department = Column(Text, comment="部门")
|
department = Column(Text, comment="部门")
|
||||||
post = Column(Text, comment="职务")
|
post = Column(Text, comment="职务")
|
||||||
|
|
|
@ -81,11 +81,10 @@ def login_by_phone(req: Schemas.LoginByPhoneReq,
|
||||||
checked = phone_verify_code.check_code(phone, req.code, PhoneVerifyType.login)
|
checked = phone_verify_code.check_code(phone, req.code, PhoneVerifyType.login)
|
||||||
if not checked:
|
if not checked:
|
||||||
raise HTTPException(detail="验证码错误", status_code=303)
|
raise HTTPException(detail="验证码错误", status_code=303)
|
||||||
user = Crud.get_user_info_by_phone(db, phone)
|
user_data = Crud.get_user_info_by_phone(db, phone)
|
||||||
if not user:
|
if not user_data:
|
||||||
raise HTTPException(detail="手机号未录入系统", status_code=303)
|
raise HTTPException(detail="手机号未录入系统", status_code=303)
|
||||||
auth_data = Crud.get_user_auth(db, user.email)
|
auth_data = Crud.get_user_auth(db, user_data['email'])
|
||||||
user_data = user.to_dict()
|
|
||||||
user_data["auth_data"] = auth_data
|
user_data["auth_data"] = auth_data
|
||||||
token_data = auth_util.tokenDataModel(**user_data).dict()
|
token_data = auth_util.tokenDataModel(**user_data).dict()
|
||||||
token = auth_util.create_token(token_data)
|
token = auth_util.create_token(token_data)
|
||||||
|
|
1
main.py
1
main.py
|
@ -31,5 +31,6 @@ app.include_router(UserRouter.router)
|
||||||
app.include_router(BasicInformationRouter.router)
|
app.include_router(BasicInformationRouter.router)
|
||||||
app.include_router(OtherInformationRouter.router)
|
app.include_router(OtherInformationRouter.router)
|
||||||
app.include_router(CommonInformationRouter.router)
|
app.include_router(CommonInformationRouter.router)
|
||||||
|
print(f"http://127.0.0.1:{conf['app']['port']}/docs")
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
uvicorn.run(app, log_config=uvicorn_log_config, port=int(conf['app']['port']))
|
uvicorn.run(app, log_config=uvicorn_log_config, port=int(conf['app']['port']))
|
||||||
|
|
Loading…
Reference in New Issue