From c4674749ceefae571c83d614eb3679bf05eb1b36 Mon Sep 17 00:00:00 2001
From: Cxx0822 <1556464090@qq.com>
Date: Sun, 21 Sep 2025 22:47:06 +0800
Subject: [PATCH] =?UTF-8?q?feat:=E5=88=9D=E5=A7=8B=E5=8C=96=E5=B7=A5?=
=?UTF-8?q?=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.env | 9 +
.idea/.gitignore | 8 +
.idea/blog-service.iml | 10 +
.../inspectionProfiles/profiles_settings.xml | 6 +
.idea/misc.xml | 7 +
.idea/modules.xml | 8 +
Dockerfile | 8 +
__pycache__/main.cpython-312.pyc | Bin 0 -> 615 bytes
api/__init__.py | 6 +
api/__pycache__/__init__.cpython-312.pyc | Bin 0 -> 472 bytes
api/__pycache__/blog.cpython-312.pyc | Bin 0 -> 4029 bytes
api/blog.py | 59 +++++
config/__pycache__/auth.cpython-312.pyc | Bin 0 -> 3130 bytes
config/__pycache__/database.cpython-312.pyc | Bin 0 -> 1123 bytes
config/__pycache__/logging.cpython-312.pyc | Bin 0 -> 1477 bytes
config/__pycache__/setting.cpython-312.pyc | Bin 0 -> 808 bytes
config/auth.py | 85 ++++++++
config/database.py | 23 ++
config/logging.py | 65 ++++++
config/setting.py | 19 ++
id_generator/__init__.py | 0
.../__pycache__/__init__.cpython-312.pyc | Bin 0 -> 161 bytes
.../__pycache__/generator.cpython-312.pyc | Bin 0 -> 1528 bytes
.../__pycache__/options.cpython-312.pyc | Bin 0 -> 1137 bytes
.../__pycache__/snowflake.cpython-312.pyc | Bin 0 -> 730 bytes
.../__pycache__/snowflake_m1.cpython-312.pyc | Bin 0 -> 6924 bytes
id_generator/generator.py | 38 ++++
id_generator/idregister.py | 134 ++++++++++++
id_generator/options.py | 43 ++++
id_generator/snowflake.py | 20 ++
id_generator/snowflake_m1.py | 147 +++++++++++++
main.py | 14 ++
.../blog_visit_middleware.cpython-312.pyc | Bin 0 -> 1971 bytes
.../__pycache__/exceptions.cpython-312.pyc | Bin 0 -> 3207 bytes
middleware/blog_visit_middleware.py | 41 ++++
middleware/exceptions.py | 54 +++++
models/__pycache__/base.cpython-312.pyc | Bin 0 -> 2771 bytes
models/__pycache__/blog.cpython-312.pyc | Bin 0 -> 3913 bytes
models/base.py | 57 +++++
models/blog.py | 99 +++++++++
packages/PyJWT-2.10.1-py3-none-any.whl | Bin 0 -> 22997 bytes
.../annotated_types-0.7.0-py3-none-any.whl | Bin 0 -> 13643 bytes
packages/anyio-4.10.0-py3-none-any.whl | Bin 0 -> 107213 bytes
packages/click-8.3.0-py3-none-any.whl | Bin 0 -> 107295 bytes
packages/colorama-0.4.6-py2.py3-none-any.whl | Bin 0 -> 25335 bytes
packages/fastapi-0.115.14-py3-none-any.whl | Bin 0 -> 95514 bytes
...linux2014_x86_64.manylinux_2_17_x86_64.whl | Bin 0 -> 651839 bytes
packages/h11-0.16.0-py3-none-any.whl | Bin 0 -> 37515 bytes
packages/idna-3.10-py3-none-any.whl | Bin 0 -> 70442 bytes
packages/loguru-0.7.3-py3-none-any.whl | Bin 0 -> 61595 bytes
packages/passlib-1.7.4-py2.py3-none-any.whl | Bin 0 -> 525554 bytes
packages/pydantic-2.11.9-py3-none-any.whl | Bin 0 -> 444855 bytes
...linux_2_17_x86_64.manylinux2014_x86_64.whl | Bin 0 -> 2002028 bytes
.../pydantic_settings-2.9.1-py3-none-any.whl | Bin 0 -> 44356 bytes
packages/pymysql-1.1.2-py3-none-any.whl | Bin 0 -> 45300 bytes
packages/python_dotenv-1.1.1-py3-none-any.whl | Bin 0 -> 20556 bytes
packages/sniffio-1.3.1-py3-none-any.whl | Bin 0 -> 10235 bytes
...linux_2_17_x86_64.manylinux2014_x86_64.whl | Bin 0 -> 3329648 bytes
packages/starlette-0.46.2-py3-none-any.whl | Bin 0 -> 72037 bytes
.../typing_extensions-4.15.0-py3-none-any.whl | Bin 0 -> 44614 bytes
.../typing_inspection-0.4.1-py3-none-any.whl | Bin 0 -> 14552 bytes
packages/uvicorn-0.23.2-py3-none-any.whl | Bin 0 -> 59544 bytes
.../win32_setctime-1.2.0-py3-none-any.whl | Bin 0 -> 4083 bytes
requirements.txt | 9 +
schemas/__pycache__/blog.cpython-312.pyc | Bin 0 -> 3761 bytes
.../paginate_query.cpython-312.pyc | Bin 0 -> 1526 bytes
.../__pycache__/pagination.cpython-312.pyc | Bin 0 -> 2211 bytes
schemas/blog.py | 79 +++++++
schemas/paginate_query.py | 27 +++
schemas/pagination.py | 42 ++++
.../__pycache__/blog_service.cpython-312.pyc | Bin 0 -> 12941 bytes
service/blog_service.py | 197 +++++++++++++++++
sys.stdout | 203 ++++++++++++++++++
test_main.http | 11 +
utils/__pycache__/blog_utils.cpython-312.pyc | Bin 0 -> 2002 bytes
utils/__pycache__/common.cpython-312.pyc | Bin 0 -> 1166 bytes
utils/blog_utils.py | 58 +++++
utils/common.py | 13 ++
78 files changed, 1599 insertions(+)
create mode 100644 .env
create mode 100644 .idea/.gitignore
create mode 100644 .idea/blog-service.iml
create mode 100644 .idea/inspectionProfiles/profiles_settings.xml
create mode 100644 .idea/misc.xml
create mode 100644 .idea/modules.xml
create mode 100644 Dockerfile
create mode 100644 __pycache__/main.cpython-312.pyc
create mode 100644 api/__init__.py
create mode 100644 api/__pycache__/__init__.cpython-312.pyc
create mode 100644 api/__pycache__/blog.cpython-312.pyc
create mode 100644 api/blog.py
create mode 100644 config/__pycache__/auth.cpython-312.pyc
create mode 100644 config/__pycache__/database.cpython-312.pyc
create mode 100644 config/__pycache__/logging.cpython-312.pyc
create mode 100644 config/__pycache__/setting.cpython-312.pyc
create mode 100644 config/auth.py
create mode 100644 config/database.py
create mode 100644 config/logging.py
create mode 100644 config/setting.py
create mode 100644 id_generator/__init__.py
create mode 100644 id_generator/__pycache__/__init__.cpython-312.pyc
create mode 100644 id_generator/__pycache__/generator.cpython-312.pyc
create mode 100644 id_generator/__pycache__/options.cpython-312.pyc
create mode 100644 id_generator/__pycache__/snowflake.cpython-312.pyc
create mode 100644 id_generator/__pycache__/snowflake_m1.cpython-312.pyc
create mode 100644 id_generator/generator.py
create mode 100644 id_generator/idregister.py
create mode 100644 id_generator/options.py
create mode 100644 id_generator/snowflake.py
create mode 100644 id_generator/snowflake_m1.py
create mode 100644 main.py
create mode 100644 middleware/__pycache__/blog_visit_middleware.cpython-312.pyc
create mode 100644 middleware/__pycache__/exceptions.cpython-312.pyc
create mode 100644 middleware/blog_visit_middleware.py
create mode 100644 middleware/exceptions.py
create mode 100644 models/__pycache__/base.cpython-312.pyc
create mode 100644 models/__pycache__/blog.cpython-312.pyc
create mode 100644 models/base.py
create mode 100644 models/blog.py
create mode 100644 packages/PyJWT-2.10.1-py3-none-any.whl
create mode 100644 packages/annotated_types-0.7.0-py3-none-any.whl
create mode 100644 packages/anyio-4.10.0-py3-none-any.whl
create mode 100644 packages/click-8.3.0-py3-none-any.whl
create mode 100644 packages/colorama-0.4.6-py2.py3-none-any.whl
create mode 100644 packages/fastapi-0.115.14-py3-none-any.whl
create mode 100644 packages/greenlet-3.2.4-cp312-cp312-manylinux2014_x86_64.manylinux_2_17_x86_64.whl
create mode 100644 packages/h11-0.16.0-py3-none-any.whl
create mode 100644 packages/idna-3.10-py3-none-any.whl
create mode 100644 packages/loguru-0.7.3-py3-none-any.whl
create mode 100644 packages/passlib-1.7.4-py2.py3-none-any.whl
create mode 100644 packages/pydantic-2.11.9-py3-none-any.whl
create mode 100644 packages/pydantic_core-2.33.2-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl
create mode 100644 packages/pydantic_settings-2.9.1-py3-none-any.whl
create mode 100644 packages/pymysql-1.1.2-py3-none-any.whl
create mode 100644 packages/python_dotenv-1.1.1-py3-none-any.whl
create mode 100644 packages/sniffio-1.3.1-py3-none-any.whl
create mode 100644 packages/sqlalchemy-2.0.43-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl
create mode 100644 packages/starlette-0.46.2-py3-none-any.whl
create mode 100644 packages/typing_extensions-4.15.0-py3-none-any.whl
create mode 100644 packages/typing_inspection-0.4.1-py3-none-any.whl
create mode 100644 packages/uvicorn-0.23.2-py3-none-any.whl
create mode 100644 packages/win32_setctime-1.2.0-py3-none-any.whl
create mode 100644 requirements.txt
create mode 100644 schemas/__pycache__/blog.cpython-312.pyc
create mode 100644 schemas/__pycache__/paginate_query.cpython-312.pyc
create mode 100644 schemas/__pycache__/pagination.cpython-312.pyc
create mode 100644 schemas/blog.py
create mode 100644 schemas/paginate_query.py
create mode 100644 schemas/pagination.py
create mode 100644 service/__pycache__/blog_service.cpython-312.pyc
create mode 100644 service/blog_service.py
create mode 100644 sys.stdout
create mode 100644 test_main.http
create mode 100644 utils/__pycache__/blog_utils.cpython-312.pyc
create mode 100644 utils/__pycache__/common.cpython-312.pyc
create mode 100644 utils/blog_utils.py
create mode 100644 utils/common.py
diff --git a/.env b/.env
new file mode 100644
index 0000000..060fafa
--- /dev/null
+++ b/.env
@@ -0,0 +1,9 @@
+LOG_LEVEL=DEBUG
+
+DB_USER=root
+DB_PASSWORD=123456
+#DB_PASSWORD=19940822Cxx%401213
+DB_HOST=localhost
+#DB_HOST=host.docker.internal
+DB_PORT=3306
+DB_NAME=blog
diff --git a/.idea/.gitignore b/.idea/.gitignore
new file mode 100644
index 0000000..13566b8
--- /dev/null
+++ b/.idea/.gitignore
@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
diff --git a/.idea/blog-service.iml b/.idea/blog-service.iml
new file mode 100644
index 0000000..74d515a
--- /dev/null
+++ b/.idea/blog-service.iml
@@ -0,0 +1,10 @@
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/inspectionProfiles/profiles_settings.xml b/.idea/inspectionProfiles/profiles_settings.xml
new file mode 100644
index 0000000..105ce2d
--- /dev/null
+++ b/.idea/inspectionProfiles/profiles_settings.xml
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/misc.xml b/.idea/misc.xml
new file mode 100644
index 0000000..f62dc0d
--- /dev/null
+++ b/.idea/misc.xml
@@ -0,0 +1,7 @@
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/modules.xml b/.idea/modules.xml
new file mode 100644
index 0000000..90c2e3f
--- /dev/null
+++ b/.idea/modules.xml
@@ -0,0 +1,8 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..19295d7
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,8 @@
+FROM python:3.12-slim
+WORKDIR /app
+COPY ./packages /app/packages
+COPY requirements.txt /app/
+RUN pip install --no-cache-dir --no-index --find-links=/app/packages -r requirements.txt
+COPY . /app/
+EXPOSE 8082
+CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "8082"]
\ No newline at end of file
diff --git a/__pycache__/main.cpython-312.pyc b/__pycache__/main.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..d04da1430b59fd50d90ebeec2399480957edb4f9
GIT binary patch
literal 615
zcmX@j%ge<81ksgeGnyC~7#@Q-Fu($3eBK0POlL@8NMX!j$YqRTWCXF9a+q?NqnN>L
z<{Xw>)+kmmn3Wi>~4w0C5{1}K&C)ZYIP1B{`|LSTagV3j8#=Zn38UZA>i4EMf+_;1)B81q#hu3JCM{u-aP03Q{JD
zqzrC(aSXn6S204U>#iCY6dHG5kv$*6qiyE97-Ux$+f+bHsO*Kiw+L{1feeO
ziv9(Efr}2J9CUK(R;ZJc?=%%3+;`u1@80*`-BT_%4;YWfC+!>DKa`k-mXhf@k|B8D
z5g)pwMhJMCr~6u0uTkWbk*4NlE@>?@Ff4Pd$}A$ygL)M2RgcExR~sToVkV?s4?|a-
z&4MD)aZSqzLpX=d|7?0Io=t;OJZSf+A}|0;uSnI;2nB2MQ%jS1-gEuLV@}#J+wg-{
zDl8%lw2V}XwXd!HZM!Oh4s+wkKICybY5Yl5v=K4U=PtABA-5fe_jv3$rEnk@1#9sL
zpOe}~B8P?<<-Ck=0q@j&qlFh*xH`KnKhwf1Eln{270Zxj6MqIBg?hE5s*zBoBC9|d
t-GRs}zJMU-cDjL=_-t1!p;UuMD+m*v5Hf<*5fmo|A)D95Pr&V`@EeJ|ZSw#C
literal 0
HcmV?d00001
diff --git a/api/__pycache__/blog.cpython-312.pyc b/api/__pycache__/blog.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..f8d81e646411e9528095db2c027f6a76531cfdec
GIT binary patch
literal 4029
zcmcInYitzP6`t9hea`x|HW3mRaCls$?!>Sbd=_9_0TUlF6C5{L$rvS^u79xYcYq7_PI
zw36*{$yG`)8f0U)T&>hZYuMN$Z&9{JxAL5W!%pNyz66i_NJIgNm-yRdvot1nqP4ho
zywe=pB`QZ1IEek*sq%JZX*b1kp(^?>h^lYb%nGIj({7>Kt*91lyS;tZwXPR%%`9)u
z#+;}QZ$~@m-%jiubE91!x@OHKE?T!q6uZ$L%>S1tgpwuoZTI0oAuKX{0qwQn@7M&t
z9yMV927Y!l9__QD6;PuMZRaLv`_Ta!ZQ!|_ZNvoj4%B4B+qDT^7&YUv7er?wwb+n$
zZ-Uf{+VCD+{y#<5Zo>;vygsW)wik+^4qX3&$U1QaI*8p?rMqm14Vy%G2py&oR=y;{
zr}gNzVeZQu3HPi)d|}=Yj!UW*77X8aP98gzOlz1Jo_?Id6G$~&@1`-y7@kx3LK@Ru
zyx|$bswyQX!X6`VR8A&NVKtSUP_f~InYq0NhJ7&&Cz2$yzM%@VLt0Ez*HuAK9j6;r
zZC%H<^(7SrPiTDv(?z42;hCz^J{pSuWGsQ{JS{_D?gZ9G&?p@RMk(ruiplq-IG%Jx
zV44n4vP&QTYH9Aq%G}J#r&pw()6dKh5mw_wN@i5+$r9yP5fF`BgUlFf*cL|9&f&)N{<
zX+kJ72;Ge7FF#xQ$;T9CW%@F8>qub36_cfyN~-DpHRzUW2rRwec1W5u&6e+c04nTL1(XfK%IVo}HKRG~|=gtXJaOB2FR
zakG~75JwuRNhu+<8xyh~3SAG=ZDvBiG!!BSK+#eXb#$QCQbGB-8NWzQjLbXcznd3(
zb)lCu(Y47Su+!*aiu{lzT|z%HS=tWd(v=@C&Hc&nSQ}mm&&rKFC3MR{T7e3yxSb#*
zlz<4)KXnTgm$-*w?N?$`PHf5sv){{$hjrnwNzWIFTP@^yR#&gA{Qhoy{iISLC>Sdm
zcz$WoxY8y2Ov$QkR7&1&@g@=QW)%wVe*yx^t-@)vc(mlimh92I7}14@$-*5`q2;Bw
z(M|S)w{rLT>fFr3FJ_i6-+2W@>@{Hlkb@Aajl&^2Cm@<(!N$R?MP6*xg;tY;CnB>R
zZL7oT7e8J8^>wr9y@K$oY;`bwKNo*D#1A6!O#I=T7|zz`#Wr1NGvoKt4~5+)CV^kh
zFWva98T#s-4_D{@Y~2{vCc{I_+wTABlF%05JksZxGgcWx$n27qL)s;e&~2m#1p8*d
zkakJ4EA)aI1Qg5a3L8F}c{wlk=|Z1L7P`+}}u(tah)zK22@bQ)OP5C1pb>r;9eyn2>4+@%0QHZsG!0KmJH~vDNV%S{vegGP(eHH
zn3QNoF)cP4qjyvlXg$_tW!{5sV*ZG7(jO#-Q<~7sdy6%9)&N=efMObgOn-W@Lu@!x
zY0VHulS!G?nq}t}$1=cCnqNzxD`z$0c{MoO5_T
zs=HiwbwJi-DYSIVSIu8oEYr_OU$%@Fn%c6X^Y1QnEspEw$?}Vd&hGF
z?}M{wA<{jYDKvM^@1Ko4ays~LO}|#;=<9yyz+;#K${C76hef{yq6b2H^Bec30ARS#
z*|V_q^F2Vm`&zsRujz}A;RU8=sVN;6y(RyH`rgBfNFN-@z4-yy#|rz~vST-sVBc|V
z01P|8aFiK#JT-hv-`%4hvoh4sobA5J65e*L7Hrx|Z0Yc+%`tsX*J8hZ>`bnI7@VCg
z>}$!sdGj4`)_&~(7`B7qIp(bWso~pt=+NSOVDfh1^jZBJ%Adwy)X(b;hk#>0zi`of
z-(xZN^MEtRaQgXmAS+Xv{$3*Y&UwI-3SGSm-Ji4Ad#0U$(UWBqdH`XZe?;@u!_MJ<
E025;1xBvhE
literal 0
HcmV?d00001
diff --git a/api/blog.py b/api/blog.py
new file mode 100644
index 0000000..c377216
--- /dev/null
+++ b/api/blog.py
@@ -0,0 +1,59 @@
+from typing import List
+
+from fastapi import APIRouter, Depends, Query, Request
+from sqlalchemy.orm import Session
+
+from schemas.blog import BlogResponse, BlogQuery, BlogCategoryResponse, BlogStatsResponse, \
+ BlogLatestResponse, BlogCommentCreate, BlogCommentResponse
+from schemas.pagination import PageResult
+from config.database import get_db
+from service import blog_service
+
+router = APIRouter(
+ prefix="/blog",
+ tags=["博客管理"],
+ responses={404: {"description": "Not found"}}
+)
+
+
+@router.get("/page", summary="分页查询博客", response_model=PageResult[BlogResponse])
+def query_blog_by_page(current_page: int = Query(1, ge=1, alias="currentPage", description="当前页码"),
+ page_size: int = Query(10, ge=1, le=100, alias="pageSize", description="每页数量"),
+ db: Session = Depends(get_db)):
+ return blog_service.query_blog_by_page(db, current_page, page_size)
+
+
+@router.get("/condition", summary="条件查询博客", response_model=List[BlogResponse])
+def query_blog_by_condition(query: BlogQuery = Depends(),
+ db: Session = Depends(get_db)):
+ return blog_service.query_blog_by_condition(db, query)
+
+
+@router.get("/content/{blog_id}", summary="查询博客内容", response_model=BlogResponse)
+def query_blog_by_id(blog_id: int, db: Session = Depends(get_db)):
+ return blog_service.query_blog_by_id(db, blog_id)
+
+
+@router.get("/category", summary="查询博客分类", response_model=List[BlogCategoryResponse])
+def query_blog_category(db: Session = Depends(get_db)):
+ return blog_service.query_blog_category(db)
+
+
+@router.get("/stats", summary="查询博客统计信息", response_model=BlogStatsResponse)
+def query_blog_stats(db: Session = Depends(get_db)):
+ return blog_service.query_blog_stats(db)
+
+
+@router.get("/latest", summary="查询近期博客", response_model=list[BlogLatestResponse])
+def query_blog_latest(db: Session = Depends(get_db)):
+ return blog_service.query_blog_latest(db)
+
+
+@router.put("/comment", summary="新增博客评论", response_model=bool)
+def add_blog_comment(blog_comment: BlogCommentCreate, request: Request, db: Session = Depends(get_db)):
+ return blog_service.add_blog_comment(db, request, blog_comment)
+
+
+@router.get("/comment/{blog_id}", summary="查询博客评论", response_model=list[BlogCommentResponse])
+def query_blog_comment(blog_id: int, db: Session = Depends(get_db)):
+ return blog_service.query_blog_comment(db, blog_id)
\ No newline at end of file
diff --git a/config/__pycache__/auth.cpython-312.pyc b/config/__pycache__/auth.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..f003779b6338e05bd5fa02a2901f9dc2fb26e716
GIT binary patch
literal 3130
zcma)8O-vlg6|U;;>G|pTVSq7)0gQiOJ$PZgcgBQcd5U&9l9A!tAM#FRgGu!i{
z>gH!wV`;SU0Zz8H2j<9O4_J2YKIF2wMv*`e+3MgVQoK@p8^Rt|Q4V>pyJxVil{O`H
z)q7R1-h1`xtM~d(fq;)dyIlJ7Qq)VxKar_7*&&XGDIuHWE>Vd}HIkzVN|6>cAtxk+
zoR|cz`tn95rRhnwmS&d9uOfO@&3tzH?4>XD?9eZ+UewvgLsu`Eu8G;9%U9lX
zgOjE_pGI}2lv*|l;G|nmFR>icO`pn&oTb5K6(*UkgO6a%V-&t*`MX>*MSXeRRMPed
zlgN0Aj3sYi8|JfTzIkWyS#la3WrT1x3lG0G#b
zO-Ca=|G6?gd~b#qvMg=r_ikp4rRDhsJFgWM2Xw|)GHG@XbSz{R@4-2j28$&#jA5%g
zoJ74m3JSYWa|?78a-f`ep+t9;Xmw&w>D`ffk6@aZ!J?MR5f{Bn+m!!gyw(1S~qp@#=K6)6>H{a6M$NH=N+7VfGA4
zVW^z5bnPl#)%k0-v3YDaMyJio;vl6)?cHot1M)d`r7fR3S}|V
zkfg-Gs9P-?tW(EhSumRFoY7pTo{3MLQ_Yf?glW#5%jB00NJJt84|s1%TP$#R-?^C2
zl+uM_iR0-_F<)5a7)3KWIyM%colVY7--=Hq6iLI=oi>DavX_}VukmCp}l;)xuD+c!HOcYf2oHLx50XhVKo=f92Z
ze=@y)W@a}$vo61snqEk4yHZ;j0T*H`mX?4qyPfvYVK15ei`frnaa_o
z`-}!C>frmD9)sXm^1fg+0FlMK@Lnqmb)A%y$l13`MFS|uTe7Xkbe%d!xB>wD34d0}
zn)n4-rN0+fX-q(X`5J)IV+y|lDoj~rhzpL_$A5_(W)hBR(0bw=O+w*ghUsfmS=|gz
z=2uc$MxDdb80WmeVa_5br2@@f_>{E;KSScFtib>ihuER
z{&=7SAC7E{yihLeDi{7usH^`V_`zNg
z5XC==BG7gL>S@&Yl@!-Gp2K>0_M4N9QZbWXW8~PiOErymt7HujCWdVimdef@a?^=5Ooaa=Z+y%vev$e&3#Jxq`Z^
zu@OE4s|b7j4RjDkO8-XA{GFVCMWWx6=qvK^Uy1J(IsZNRv?h~aZ^if0-%|0u?C#ki
zQF#5K=+?y6@bkX?;AllT^pJ4xc4oinY9#<`J^kCgd#5f|l=Vba+(_<`i!~3WeOuxY
zfuZK3^!nCV4e0C7&*Ieenop#1Rjd&hwxlB*YC%dntK%ruxiyDUow%{1I)_soTWOr?
tIQ02xoL0}(2#(up&%L`J-8izC!yeN6;r8vlbHj%uK>MrdA8@cj@jqL@y~_Xq
literal 0
HcmV?d00001
diff --git a/config/__pycache__/database.cpython-312.pyc b/config/__pycache__/database.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..48e6e5f881d5dde40c8de57c09ed840b453c2322
GIT binary patch
literal 1123
zcmah|U1$?Q5Z=8@Esm^uQF3p^X@c0
z1b}hMUfD|mb4{~+jco>&pRFBE1ZCe1lxQjXLxCR_7sAXhQ6icoMY0(sOMnQqvJu!x4rLGu#bfe4eUD
zLp<|}c~h5kO;b$fvGAmtH>Q{)tz>1XR-3IHAiH3%njnS{hUu8K`yo`n#WmzXSJ6Z6
z5zOl@7uRNd|ZC#Mao
znjOC*u}E^1>eECrjpQ-KoXV&FnQ2we>@^6zq(~$w>DfsolaxhMv|1U?6`7DBW=c-e
zHptWh+X#X9j@C-(t7qe#?WKWbj(4_w3LVRSj=XRkHpW|V02`x3Qk8)4KiOWdL}v$jSr^Ijtw)R
z`o3thmCG>zy|5eb0<8jpsP)q@cfY2~d6gWZonTs>HXeXj<}t=gXy+0-xP*3nLtUR*
zI-c#WboMNC_LMvJzuNcee5LoqLhp(4fs^wc^T#X0$%Wx$d1$;mK2c6(Dk*&-rI#mi
z<=jk}Uik%C@eyvNs+Qr~IL3hr4ss>mXHWa%{zcF3lCUD6;I?P^H_o?57n_H`MH&>???OGNr^n>gcqGFVn+a-2hdNBdIhvWd$ezouk$EG|oR2ee
zvzc(A%{4Rq#lq5GtXP2~qV2WY2vaS2-wclEF8e45EVu2GB#rrd%!M9VeqeaV;g6Lz
zM#$Y51eSx!52+M)cZ=0({_fqf0+9UJ9K-(k;f1(xUj*Kb?y6q_$j%R9*T%{GfniieH=?~syTYl&HL6Xn5_
zw>*fcD97Ncc&Pe)zvKtd>jedoBz?<0CPGX|#6u4|WQ+CoGzwgGrxq~FM6m)NqvMZ)295Pf-v@QOeSpB>$Q3)eQ+!0!91;cuaJ!|
zzlVFVO{6Zpf7?31NyeFOdG4XrE?qtbEX0i%#-U{+!ysbU#IzA2?bPlV)$KYFoMUKV
zqA+`B^TFm05qjM&!bETERcoK`8C$jb?x%YswY9yod1Z(gIo=5(ya^$Z48yc-!}tk2
zr(EFW?P_`dKK44O75Mvitl+43Ff|Y85fW
z6+b{fgXA;#2|RiU1A^emo0@{qlW%5|)eh`$esAW@d%u0}eJ&Jo2-YWS|L6oG^j#Q>
zrO(Oi0gwyiArJS_0NWTN1=W$KoFPx8c%mkLwxS@aOy-Ylb*!2C4`G>@=XV`OEgHvu
z&|~i0MQ+;Mn7ssYfhe-EhiqjJQI%>Q-iA}E15+duXKKo{l<6tU2qxuaL7p*DlK6IJ
zykzFMvCzP?)m`$mWj&Xq-RdM{&#HC!GF-KHEbB$9Q8v~rlq2H&x=t3C@qXF|{e?&i`naF+hu)5W4N8u~##;jZSD)k
zN4!Lc69i%G#C{ksP_OzyEMG)x!czvgDVP{238Lxj9>6;^Ev%e2{)5%>7p*MqZ>1Zj
z%|Du=Z~jIANgNTPX=;4+c#ZU4{sj$b! dict:
+ return {
+ "sub": sub
+ }
+
+
+# 验证payload
+def verify_payload(payload: dict) -> bool:
+ return "sub" in payload
+
+
+# 从payload中获取用户
+def get_payload_sub(payload: dict) -> str:
+ return payload["sub"]
+
+
+# 创建token
+def create_token(payload: dict, expires_delta: Optional[timedelta] = None):
+ # 复制一份
+ payload_copy = payload.copy()
+
+ # 加上有效时间
+ if expires_delta:
+ expire = datetime.now() + expires_delta
+ else:
+ expire = datetime.now() + timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES)
+ payload_copy.update({"exp": expire})
+
+ # 生成jwt Token
+ return jwt.encode(payload_copy, SECRET_KEY, algorithm=ALGORITHM)
+
+
+# 验证token
+async def verify_token(token: str = Depends(oauth2_scheme)):
+ try:
+ # 1. 检验token信息
+ payload = jwt.decode(token, SECRET_KEY, algorithms=[ALGORITHM])
+ # 2. 校验payload信息
+ if not verify_payload(payload):
+ raise get_credentials_exception()
+ # 3. 校验数据库中是否存在 payload中的账户信息
+ sub = get_payload_sub(payload)
+
+ # 4. 存储账户信息
+ context_sub.set(sub)
+ except jwt.exceptions.InvalidTokenError:
+ raise get_credentials_exception()
diff --git a/config/database.py b/config/database.py
new file mode 100644
index 0000000..e600cb2
--- /dev/null
+++ b/config/database.py
@@ -0,0 +1,23 @@
+from sqlalchemy import create_engine
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker
+
+from config.setting import settings
+
+DATABASE_URL = f"mysql+pymysql://{settings.DB_USER}:{settings.DB_PASSWORD}@{settings.DB_HOST}:{settings.DB_PORT}/{settings.DB_NAME}"
+
+engine = create_engine(url=DATABASE_URL)
+
+# 会话工厂
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+# ORM基类
+Base = declarative_base()
+
+
+def get_db():
+ # 创建数据库会话实例
+ db = SessionLocal()
+ try:
+ yield db
+ finally:
+ db.close()
diff --git a/config/logging.py b/config/logging.py
new file mode 100644
index 0000000..4f834d9
--- /dev/null
+++ b/config/logging.py
@@ -0,0 +1,65 @@
+from loguru import logger
+from pathlib import Path
+
+from config.setting import settings
+
+# 日志目录
+LOG_DIR = Path(__file__).parent.parent.parent / "logs"
+LOG_DIR.mkdir(exist_ok=True)
+
+# 日志级别
+LOG_LEVEL = settings.LOG_LEVEL.upper()
+
+# 日志格式
+STDOUT_FORMAT = (
+ "{time:YYYY-MM-DD HH:mm:ss.SSS} | "
+ "{level: <8} | "
+ "{name}:{function}:{line} - "
+ "{message}"
+)
+
+FILE_FORMAT = (
+ "{time:YYYY-MM-DD HH:mm:ss.SSS} | "
+ "{level: <8} | "
+ "{name}:{function}:{line} - {message}"
+)
+
+# 移除默认处理器
+logger.remove()
+
+# 添加控制台处理器
+logger.add(
+ sink="sys.stdout",
+ level=LOG_LEVEL,
+ format=STDOUT_FORMAT,
+ colorize=True,
+ backtrace=True, # 显示完整异常堆栈
+ diagnose=True, # 显示详细异常信息
+)
+
+# 添加文件处理器 - 常规日志
+logger.add(
+ sink=LOG_DIR / "app.log",
+ level="INFO",
+ format=FILE_FORMAT,
+ rotation="10 MB", # 日志文件大小达到10MB时自动分割
+ retention="7 days", # 保留7天的日志
+ compression="zip", # 归档时压缩为zip
+ enqueue=True, # 异步写入
+ serialize=False, # 不使用JSON格式
+)
+
+# 添加文件处理器 - 错误日志
+logger.add(
+ sink=LOG_DIR / "error.log",
+ level="ERROR",
+ format=FILE_FORMAT,
+ rotation="10 MB",
+ retention="30 days",
+ compression="zip",
+ enqueue=True,
+ serialize=False,
+)
+
+# 导出配置好的logger
+__all__ = ["logger"]
\ No newline at end of file
diff --git a/config/setting.py b/config/setting.py
new file mode 100644
index 0000000..6f53870
--- /dev/null
+++ b/config/setting.py
@@ -0,0 +1,19 @@
+from pydantic_settings import BaseSettings
+
+
+class Settings(BaseSettings):
+ DB_HOST: str
+ DB_PORT: int
+ DB_USER: str
+ DB_PASSWORD: str
+ DB_NAME: str
+
+ LOG_LEVEL: str
+
+ class Config:
+ env_file = ".env" # 指定.env文件路径
+ case_sensitive = False # 忽略变量名大小写
+
+
+# 全局配置实例
+settings = Settings()
diff --git a/id_generator/__init__.py b/id_generator/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/id_generator/__pycache__/__init__.cpython-312.pyc b/id_generator/__pycache__/__init__.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..11d9d6ea53ac5f4b282ac994504e7cafa554bfe3
GIT binary patch
literal 161
zcmX@j%ge<81bc(SGC=fW5P=Rpvj9b=GgLBYGWxA#C}INgK7-W!a&WPV2`I|XN=+^)
zj&aW{$tX>NbCYuN({+nei^?*SQ)4ny;?q;}Qi~Ex@{3~P<1_OzOXB183My}L*yQG?
bl;)(`6|n*hWCY@35aS~=BO_xGGmr%U#a}4p
literal 0
HcmV?d00001
diff --git a/id_generator/__pycache__/generator.cpython-312.pyc b/id_generator/__pycache__/generator.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..46918d52e0d87a549415522c40768c6b4eb7d775
GIT binary patch
literal 1528
zcmZux&2Jl35PxsiYp*}j1P3ZPX<%CjsSyo{#Dxk)7zLsn2uM+Tup&J<-sg7RwKu$7
zQ*1?5s4SEsK{!Cu!hv#v5-Ba>z^U*D^x}|1sui4QK6*>*R+Tt0v+LcOk~z$qnK$#^
z%x~ts+dVxA0(5Kk^x3#f$ls_06zK@<*Fjh%I>{5A>XJz-QeL7c%OJ~nnG%Ui5k1l*
zy0RwuQTa$cnvKvGd8tq{ovxH>&p}K=1Dc);Q}*;C<{A*@0QK@QloAh1xlY}P&CQaHXK4TACQr_NAgnSkI`-U@;he3_hw8j(ojGB1@sUyF
zbB4~&1YpgD(&$3nRT(p?hQnB6@c%`O2Ai0j9S62V?qr6RBcC5?W0r2z$GaFnibgEQ
zE6D_5l`PUSTAw1Fo`V>XbkNfyU0Uk^bCEhqU@b=j>B+iC15W@em@!h9vys}X;N^jg
z!0)a9wtH*c(0%y#erRqlU%mVL_dB252wjY8pHkB3n=ja0bBqetxDb{YoyjV09E}W(
zZsK&otnqhnOW=KOau#OmU7W4=#)S%&tR(Omh(o|^1VhtA5*D}5<__ydzwzP$FhA{t
zvty3|TO#`jl1gtS2RD*~S4w{*U-~nBq&4)~W_qlZ8oQer-pY(`WX5m4yqS3eyCQn<
z(x~80O;rCgXkk}$@PMw6gSxWR-H#CEi}Yaca@Zv}vO{Z~brvA;-!66nY43|)w^uIj
zT)w&cP4m>L>B+DMjiU=D#|8ijnxSjqcxnYlD;dIeMzgYqvUmngcVkulF=8rk9{q>l
zVJ!}W-WWIl-cG;^=zjv3k80n_#HEQ=@~DUCTbt=zE0w#`+rM(*(uJ+w;f>zm&EAog
zI^sb(lTF}DsTL}nF*m_j#nNjg$|=S^tQE}8PK+_#Dl#VU_YjD=o9_A)-uHhe(T^Ll
zQFXkWuM_VMzX+UnfebrozXGgD?n{!QK2WLh{C-qbPF_2|HImyH$+Zb6`_IOd<5&70
z5?K6WFc=0{48ZF8NqAH1ohpXF`s6xSebcXGLLfT$0PQ2d_GL;bTuUR5`UpMz7a4dQ
M&Cufy2rw`DUuLv#hX4Qo
literal 0
HcmV?d00001
diff --git a/id_generator/__pycache__/options.cpython-312.pyc b/id_generator/__pycache__/options.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..6787315c6ef484709a2a4c61f3a64b9ce2497afa
GIT binary patch
literal 1137
zcmaJ=O-vI}5PrMemQtWmAQ8cY6*baCxNH2mkPt3FV&b7Td1?Dry4vo-+g%jXLl4E&
zNCO89(StuXj1l!Dl3?P+ix&@i*~F7wn!SNFG4bR~x4S_!PO`J#_vU>wZ|BW^?COdU
zuu$FtM%;-w{+Ki`ZktrWo*7$2}q+4=o(Q-Qh*X76Oth&F|jNpB}g5%yZ2?A
znl)8jGpw&zP6nG83yOM`nyVx7O`YFRI8~YKEUr7ROU~-c+Ga^*XJlt-%c|uFwf?Y-y4vQ8pomj_QeRz%KyACabN^K|)eKz4{4uCZcwvpqM$G+3lIMp-@vT
zD0X|$A-gw#`+8!>|Ll<+FQji#T+^&VM&ZC!Z9nfZ^;xRV!_8)O!vtq(W$_m;7VjSLXPxRq@@l3{igxM5u9j&Q)esE=jd@*8XQ41
zup1?V@<9|KCxjy;&?qSI^GKo{tP&mmM$oi+A&HCIhY)?@3QII0T|e_GT9Tu;pmTee|Xs2h^^&8-=R^0#q
literal 0
HcmV?d00001
diff --git a/id_generator/__pycache__/snowflake.cpython-312.pyc b/id_generator/__pycache__/snowflake.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..8fbb8ffcf7298bed5365305b9fdc8f2264ea6dc5
GIT binary patch
literal 730
zcmY*X&ubG=5T3U`l5|P5X$3D*Lp|-m{sAI_P%K`8Q0gHB9_j8&yPEFSx4Y_=9(u^3
z2&NviTlL_f2>t-6c<|(3;6EUHm2BEuYy`oRGub54f&Jb$Z)UzX^WJ_hl?*`pwtRPe
zo&o$MXKdPt3@#yw!G;i^fx%Vkfzr5%@f0OP$
z>%M%KcHVaP4!eg(=|RV^Mv}v2qyU3CbYl=uV|a!_`Zd*7gw|ASwXN0kNHg_hYT5N3
z-D)-N3u|0RD#TU%1~UjTY_o0P$TEw-WL1+Td2cgtJl8jsMDs*iDnVS=fw{0_TqF1e|Zp
zOuAec?-l8+DTE#PadB=}ds-Zz14&MbAe63!*M7!^)6m_=5HV8;=aCwfksWuwcK7zv
z{iEKi_R7lb#Yy0VG~VO9GKa(`(TdC?CV5vp4!C1)mH+oP+B#3El(YkV1E$N8+N_#6
z8pv&I2+k9O^9|1qTf~c;KL{JGEFudet~zcY&mof~0;(ULDrt%#(EsJnBDCRDWBTQO
zPS?u^v%dkCET2-V_%wOWZO`I7t39ii6s~7&+>jSAoyPNt^i{^#FHK?EpJ{`YPXS@5
F`VV1ivN-?%
literal 0
HcmV?d00001
diff --git a/id_generator/__pycache__/snowflake_m1.cpython-312.pyc b/id_generator/__pycache__/snowflake_m1.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..787690c1ec1989e2ac18ad9effd89d76678c0a69
GIT binary patch
literal 6924
zcmd5>UrZZE8lUw)3^ukC(*uLSe{c*7fdoPh3L#t)3Q5$^v_vPB%VlM}8{%N>bZwdh
zaaDCnrSz^*s9Gt_Q+YV)h$8j!a1VW{)IQ$}YbRREmr6)?y=PuQIlOEwkCkMLwGVnc!sy6
znHh$bmKh6gs+jdTHTqx
zZ$JL@Z#P%Ixw}^P1iPo6Fp#rMxpq2}y*iOj%nMN2dy1bFGJ=@MXT{g92IyLab^=|e(6vCj
z6uJ&*w?eysuD|YP>&q@p*)x5M?Vv+l7}A-(zyJQmH#hH|8rK&2EF`@|-U>Bsei&z~
z@aS_>`6hfi`Fe>Cy{rlib85O$4K!(>fpaInsRkx|It?_52CL9LZj`SZqwaG8T9|Nx
z7R_MiM&7ne%(PsBHSxA37zyjsWEtjn8|TKFZhp;DhB2OJj;T?5K__j^Y8z@|swpsl
zj+zC5%S1Eas8uEL7N}`9p*5GGPaDtMffLU*O_WnxK|Z9mUk2vwS!WAxeDRnVl4ja3Zi=rrG@_MO3BS$&`qHz(BCFjc#V{d*@%y6@btP_E5i5`_ex%FLB*uVz8DmyCnK%xP$5
zEoECyNM96jQ{~W0;qVXRUoYktc>FiujP7vQtC57`KWKPBR
z^Em+iiwOMOLSOHd>t!bg3V|oNr3RhNd(~DyPWT33+q+~V5Wi{rz*BPVm0dx}66aq?#nwYN$3K|bbdY_(_|O@loE?&@W38{?+W)w-du>wQe^T0ivegf#W&(F!DXC?SW&SFn-B^#7;vE&PwstIAN{0rp?0y`G
ze%f}otr%c$+HQHaz_g_75Czz;57whyCROb~=e^aMN>LyDa+zFX%sj+fm%yG$%YWq`xFDjNfk(S3?)Be(=lyp+;pMhN
zQrn@TcVOK)AcnzW2E;?W!H{FC@M4Guqs0`QL=C?{rjmGO9(%{2*90qhMhPvoK6UM=iX$J0R4MB^%g=3Of9E^D*iSM&yKsIK5y_rjqa
z_ktE=s&mmWRv!YJV6wS2tC~Z<3Cct3ZdeJ}zYA8XcGur!|3PPbOy~k@yxH`Ye7^NO
z$0)!E0Tz5}GR2FB~8f5l_#Gd%__2Rxs8eVPu7*yRAMV}Mxo{7%8gPe94!KUbZ3UUvC
zz_1QBI#An_1~6L3ZUG*?iOm54T1_Ac`IkT{^lGxJ1oq@LaN;fMAzlJW)8wADvW4fq
z|L52f>uW=2SbOD`#utK!XI%7Rh9^?JZ0i@5w^ue
zN{t7f+AU3eu$3AbSMndd{Iu5QYuzNa+SbY~^n4D2vkFlgXje)90|#lJ57ap-uB+Yz
z+Z`kx08Z8+QY_i#6oeM)8Sx-c21h`|vjb$dM?5Rku(SkF&nvk3wkDSpT@0=c~
zu?L;gyQ_0FsE7Hq(*rLAI6Zl-ulha5?Ali!4RERe`gb`O5J0QDeVVYAsX3T}ynCbf
z7;B?uE8FN7kQy4QW^y84A}m8A${gwuu0)TG96Yp50^6l_;}$n%`ZdVOMQ~p7*t_@R
z@jI`6`07VftJ6|L=i2xmrtVEi{^6o`WZgNkGkii+p~&(X5HIjx#4m7%^V*Za3`2NE
zwG@Na)Vu%_D@nEZGajZm5A(s{Wu{{7f8BdpI5T^846NM_LMnISPk}1ib7?`i!YaYL
zFE7A1Anm;%h=!fqP_e!-_+JX|G`*4IJ(wr=24nyDr?a*xalOm@VYa!(@_Y@)KR|!
zf;tMy?ddR~rqv^p!XoYglWXp&j;oqH;{y&YW;5ehW|9^j{>{J>HD+W0-rGqZ$uU$&}C^mhNJvgDzjQz-(e~Un|
z>2TP?t4VARBTw@u{_lWpu4sV@uukz6)B_G65$Or5&8Z&*MH@Eay;E5!Rd@ocVa(|J
z*m int:
+ """
+ 获取新的UUID
+ """
+
+ if self.snowflake is None:
+ raise ValueError("please set id generator at first.")
+ return self.snowflake.next_id()
diff --git a/id_generator/idregister.py b/id_generator/idregister.py
new file mode 100644
index 0000000..787faac
--- /dev/null
+++ b/id_generator/idregister.py
@@ -0,0 +1,134 @@
+"""
+worker id generator
+"""
+
+# !/usr/bin/python
+# coding=UTF-8
+
+
+from threading import Thread
+import time
+import logging
+import redis
+
+
+class Register:
+ """
+ redis封装
+ - host 代表redis ip
+ - port 代表redis端口
+ - max_worker_id worker_id的最大值, 默认为100
+ - password redis的密码, 默认为空
+ """
+
+ def __init__(self, host, port, max_worker_id=100, password=None):
+ self.redis_impl = redis.StrictRedis(host=host, port=port, db=0, password=password)
+ self.loop_count = 0
+ self.max_loop_count = 10
+ self.worker_id_expire_time = 15
+ self.max_worker_id = max_worker_id
+ self.worker_id = -1
+ self.is_stop = False
+
+ def get_lock(self, key):
+ """
+ 获取分布式全局锁,并设置过期时间为30秒
+ """
+
+ if self.redis_impl.setnx(key, 1):
+ self.redis_impl.expire(key, 30)
+ return True
+ if self.redis_impl.ttl(key) < 0:
+ self.redis_impl.expire(key, 30)
+ return False
+
+ def stop(self):
+ """
+ 退出注册器的线程
+ """
+
+ self.is_stop = True
+
+ def get_worker_id(self):
+ """
+ 获取全局唯一worker_id, 会创建一个线程给worker id续期
+ 失败返回-1
+ """
+
+ self.loop_count = 0
+
+ def extern_life(my_id):
+ while 1:
+ time.sleep(self.worker_id_expire_time / 3)
+ # 是否关闭了
+ if self.is_stop:
+ return
+ # 更新生命周期
+ if self.worker_id != my_id:
+ break
+ try:
+ self.redis_impl.expire(
+ f"IdGen:WorkerId:Value:{my_id}",
+ self.worker_id_expire_time)
+ except Exception as exe:
+ logging.error(exe)
+ continue
+
+ self.worker_id = self.__get_next_worker_id()
+ if self.worker_id > -1:
+ Thread(target=extern_life, args=[self.worker_id]).start()
+ return self.worker_id
+
+ def __get_next_worker_id(self):
+ """
+ 获取全局唯一worker id内部实现
+ """
+
+ cur = self.redis_impl.incrby("IdGen:WorkerId:Index", 1)
+
+ def can_reset():
+ try:
+ reset_value = self.redis_impl.incr("IdGen:WorkerId:Value:Edit")
+ return reset_value != 1
+ except Exception as ept:
+ logging.error(ept)
+ return False
+
+ def end_reset():
+ try:
+ self.redis_impl.set("IdGen:WorkerId:Value:Edit", 0)
+ except Exception as ept:
+ logging.error(ept)
+
+ def is_available(worker_id: int):
+ try:
+ rst = self.redis_impl.get(f"IdGen:WorkerId:Value:{worker_id}")
+ return rst != "Y"
+ except Exception as ept:
+ logging.error(ept)
+ return False
+
+ if cur > self.max_worker_id:
+ if can_reset():
+ self.redis_impl.set("IdGen:WorkerId:Index", -1)
+ end_reset()
+ self.loop_count += 1
+
+ if self.loop_count > self.max_loop_count:
+ self.loop_count = 0
+ return -1
+
+ time.sleep(0.2 * self.loop_count)
+ return self.__get_next_worker_id()
+ time.sleep(0.2)
+ return self.__get_next_worker_id()
+ if is_available(cur):
+ self.redis_impl.setex(
+ f"IdGen:WorkerId:Value:{cur}",
+ self.worker_id_expire_time,
+ "Y"
+ )
+ self.loop_count = 0
+ return cur
+
+ return self.__get_next_worker_id()
diff --git a/id_generator/options.py b/id_generator/options.py
new file mode 100644
index 0000000..8558381
--- /dev/null
+++ b/id_generator/options.py
@@ -0,0 +1,43 @@
+"""
+生成器IdGenerator配置选项
+"""
+
+# !/usr/bin/python
+# coding=UTF-8
+
+
+class IdGeneratorOptions:
+ """
+ ID生成器配置
+ - worker_id 全局唯一id, 区分不同uuid生成器实例
+ - worker_id_bit_length 生成的uuid中worker_id占用的位数
+ - seq_bit_length 生成的uuid中序列号占用的位数
+ """
+
+ def __init__(self, worker_id=0, worker_id_bit_length=6, seq_bit_length=6):
+
+ # 雪花计算方法,（1-漂移算法|2-传统算法）, 默认1。目前只实现了1。
+ self.method = 1
+
+ # 基础时间（ms单位）, 不能超过当前系统时间
+ self.base_time = 1582136402000
+
+ # 机器码, 必须由外部设定, 最大值 2^worker_id_bit_length-1
+ self.worker_id = worker_id
+
+ # 机器码位长, 默认值6, 取值范围 [1, 15]（要求：序列数位长+机器码位长不超过22）
+ self.worker_id_bit_length = worker_id_bit_length
+
+ # 序列数位长, 默认值6, 取值范围 [3, 21]（要求：序列数位长+机器码位长不超过22）
+ self.seq_bit_length = seq_bit_length
+
+ # 最大序列数（含）, 设置范围 [max_seq_number, 2^seq_bit_length-1]
+ # 默认值0, 表示最大序列数取最大值（2^seq_bit_length-1]）
+ self.max_seq_number = 0
+
+ # 最小序列数（含）, 默认值5, 取值范围 [5, max_seq_number], 每毫秒的前5个序列数对应编号0-4是保留位
+ # 其中1-4是时间回拨相应预留位, 0是手工新值预留位
+ self.min_seq_number = 5
+
+ # 最大漂移次数（含）, 默认2000, 推荐范围500-10000（与计算能力有关）
+ self.top_over_cost_count = 2000
diff --git a/id_generator/snowflake.py b/id_generator/snowflake.py
new file mode 100644
index 0000000..ea36cfa
--- /dev/null
+++ b/id_generator/snowflake.py
@@ -0,0 +1,20 @@
+
+"""
+雪花算法生成器接口声明
+"""
+
+# !/usr/bin/python
+# coding=UTF-8
+
+
+class SnowFlake():
+
+ def __init__(self, options):
+ self.options = options
+
+ def next_id(self) -> int:
+ """
+ 获取新的UUID
+ """
+
+ return 0
diff --git a/id_generator/snowflake_m1.py b/id_generator/snowflake_m1.py
new file mode 100644
index 0000000..596b76d
--- /dev/null
+++ b/id_generator/snowflake_m1.py
@@ -0,0 +1,147 @@
+"""
+M1生成器
+"""
+
+# !/usr/bin/python
+# coding=UTF-8
+
+import threading
+import time
+from .snowflake import SnowFlake
+from .options import IdGeneratorOptions
+
+
+class SnowFlakeM1(SnowFlake):
+ """
+ M1规则ID生成器配置
+ """
+
+ def __init__(self, options: IdGeneratorOptions):
+ # 1.base_time
+ self.base_time = 1582136402000
+ if options.base_time != 0:
+ self.base_time = int(options.base_time)
+
+ # 2.worker_id_bit_length
+ self.worker_id_bit_length = 6
+ if options.worker_id_bit_length != 0:
+ self.worker_id_bit_length = int(options.worker_id_bit_length)
+
+ # 3.worker_id
+ self.worker_id = options.worker_id
+
+ # 4.seq_bit_length
+ self.seq_bit_length = 6
+ if options.seq_bit_length != 0:
+ self.seq_bit_length = int(options.seq_bit_length)
+
+ # 5.max_seq_number
+ self.max_seq_number = int(options.max_seq_number)
+ if options.max_seq_number <= 0:
+ self.max_seq_number = (1 << self.seq_bit_length) - 1
+
+ # 6.min_seq_number
+ self.min_seq_number = int(options.min_seq_number)
+
+ # 7.top_over_cost_count
+ self.top_over_cost_count = int(options.top_over_cost_count)
+
+ # 8.Others
+ self.__timestamp_shift = self.worker_id_bit_length + self.seq_bit_length
+ self.__current_seq_number = self.min_seq_number
+ self.__last_time_tick: int = 0
+ self.__turn_back_time_tick: int = 0
+ self.__turn_back_index: int = 0
+ self.__is_over_cost = False
+ self.___over_cost_count_in_one_term: int = 0
+ self.__id_lock = threading.Lock()
+
+ def __next_over_cost_id(self) -> int:
+ current_time_tick = self.__get_current_time_tick()
+ if current_time_tick > self.__last_time_tick:
+ self.__last_time_tick = current_time_tick
+ self.__current_seq_number = self.min_seq_number
+ self.__is_over_cost = False
+ self.___over_cost_count_in_one_term = 0
+ return self.__calc_id(self.__last_time_tick)
+
+ if self.___over_cost_count_in_one_term >= self.top_over_cost_count:
+ self.__last_time_tick = self.__get_next_time_tick()
+ self.__current_seq_number = self.min_seq_number
+ self.__is_over_cost = False
+ self.___over_cost_count_in_one_term = 0
+ return self.__calc_id(self.__last_time_tick)
+
+ if self.__current_seq_number > self.max_seq_number:
+ self.__last_time_tick += 1
+ self.__current_seq_number = self.min_seq_number
+ self.__is_over_cost = True
+ self.___over_cost_count_in_one_term += 1
+ return self.__calc_id(self.__last_time_tick)
+
+ return self.__calc_id(self.__last_time_tick)
+
+ def __next_normal_id(self) -> int:
+ current_time_tick = self.__get_current_time_tick()
+ if current_time_tick < self.__last_time_tick:
+ if self.__turn_back_time_tick < 1:
+ self.__turn_back_time_tick = self.__last_time_tick - 1
+ self.__turn_back_index += 1
+ # 每毫秒序列数的前5位是预留位, 0用于手工新值, 1-4是时间回拨次序
+ # 支持4次回拨次序（避免回拨重叠导致ID重复）, 可无限次回拨（次序循环使用）。
+ if self.__turn_back_index > 4:
+ self.__turn_back_index = 1
+
+ return self.__calc_turn_back_id(self.__turn_back_time_tick)
+
+ # 时间追平时, _TurnBackTimeTick清零
+ self.__turn_back_time_tick = min(self.__turn_back_time_tick, 0)
+
+ if current_time_tick > self.__last_time_tick:
+ self.__last_time_tick = current_time_tick
+ self.__current_seq_number = self.min_seq_number
+ return self.__calc_id(self.__last_time_tick)
+
+ if self.__current_seq_number > self.max_seq_number:
+ self.__last_time_tick += 1
+ self.__current_seq_number = self.min_seq_number
+ self.__is_over_cost = True
+ self.___over_cost_count_in_one_term = 1
+ return self.__calc_id(self.__last_time_tick)
+
+ return self.__calc_id(self.__last_time_tick)
+
+ def __calc_id(self, use_time_tick) -> int:
+ self.__current_seq_number += 1
+ return (
+ (use_time_tick << self.__timestamp_shift) +
+ (self.worker_id << self.seq_bit_length) +
+ self.__current_seq_number
+ ) % int(1e64)
+
+ def __calc_turn_back_id(self, use_time_tick) -> int:
+ self.__turn_back_time_tick -= 1
+ return (
+ (use_time_tick << self.__timestamp_shift) +
+ (self.worker_id << self.seq_bit_length) +
+ self.__turn_back_index
+ ) % int(1e64)
+
+ def __get_current_time_tick(self) -> int:
+ return int((time.time_ns() / 1e6) - self.base_time)
+
+ def __get_next_time_tick(self) -> int:
+ temp_time_ticker = self.__get_current_time_tick()
+ while temp_time_ticker <= self.__last_time_tick:
+ # 0.001 = 1 mili sec
+ time.sleep(0.001)
+ temp_time_ticker = self.__get_current_time_tick()
+ return temp_time_ticker
+
+ def next_id(self) -> int:
+ with self.__id_lock:
+ if self.__is_over_cost:
+ nextid = self.__next_over_cost_id()
+ else:
+ nextid = self.__next_normal_id()
+ return nextid
diff --git a/main.py b/main.py
new file mode 100644
index 0000000..e01f3bb
--- /dev/null
+++ b/main.py
@@ -0,0 +1,14 @@
+from fastapi import FastAPI
+
+from api import register_routers
+from middleware.blog_visit_middleware import blog_visit_middleware
+from middleware.exceptions import global_exception_handler
+
+app = FastAPI(title="Blog Service")
+
+# 加载中间件
+app.middleware("http")(global_exception_handler)
+app.middleware("http")(blog_visit_middleware)
+
+# 挂载API
+register_routers(app)
\ No newline at end of file
diff --git a/middleware/__pycache__/blog_visit_middleware.cpython-312.pyc b/middleware/__pycache__/blog_visit_middleware.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..26d66126df24bceadd6f97441c271087e6a7c7bd
GIT binary patch
literal 1971
zcma)7Z)g)|7=Q0B_cuwKrcJx5)0A49IBXS}g}P1D47HtBCL0)v;hMX)7caT&y^E>t
zGK!9oGR2iKBg%%z1{vK-g^hh0gS8)oF=)x4Jwr<$f_q~0*%vQG4)>GbPkaW!pWBjVvkt+=ycvIrhO*YNY?Dz^3m3Lk()5eFHG
zt&tlhd^k2pxT?w)k>Iu{RXA0hKSt$f_^l;65jL2r*2pn9TjgpT--b+h|EUvAp%uo-
zm~&b6PK51pvJK*TIX1^x4VykX(dgisR5oWgGjqHZaQrr7vo`ntcWLuqu~V2-WaI>^
zWdi{)RRuXw1XinKO>A>eP1>R@I6I?&Ehb*9`5feAqku>vIvjgV)*@(N<6Cm}b`8__
zT?T+#bbL(|x(hztJj<(;
z0&>!OQkKesG3GqTQtkh_QYW$pTtEFalcmDKnJa+{-Gu$!aU*46YIlbQm6yW1uSjoU
z`tLhR=#Ri-!k;jUXf2Is!$kZLG_u%_m<-ggM!H8+G9DcD$E}&w`=71exU)KaKhuN_
zYtuhGE=;dY&#Zp`$?E41*1q|oHyCb2G*l6rl&$zENuncHTDC?Z=?}z@sq)gQ$ClK5+
zp7lq12hTzyp~fw9@PuZKW`;IZl4xJ`qcfP)6h&9FGE@g^1!6U8SNbvv{Hq6c;-YT+
zn63Dl*1*$o@W|&c2$RBm>w%e`?+!mWym;{V!olMuUu2$-jA!uck$2neo|3mcPcH>_
z6k?OH#Xx8w5GwANfu%riURrJr7x$K$U!HL1>HLXhf8ZmvaB=eDy|#~2C4WbrU*|yc
zuBG}0@@v|@sJbEajzjAE?{*;e|Y1rg^bt+4I7pr*py6S)_}7
zzj%6Zn%&P4d`OIRFtbP6B0**@$YMO#!9+q}F658&
zGIPBy922gGzb=;~{5KUPVzn#5ja
mD2n
literal 0
HcmV?d00001
diff --git a/middleware/__pycache__/exceptions.cpython-312.pyc b/middleware/__pycache__/exceptions.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..279b97a65fdcdab7326abde88ba7073df0f31306
GIT binary patch
literal 3207
zcmbtWZ){W76~FgA|BanEfK!sNC0@x8hQ=flemG=8gR@2H|Xi%_Yyz%*$($T
zH-rU*fL3H80*P*cHWleKwy0KBsG>kzBD}!
z2dh^^^0pKeI}(y0$YKvq#17H$lj7^{)odImB_);PPE`~h#b+$rsk(CL&Z6nHH5W~n
zocb`}T!1x1N}&Tc07{Zih#aSta9koKq-9DwIqpQ7m-8G}Q3+WM^0yFKL-($t9lc(9
z2e%6;Wzbzfe`OeR?J&EDV91G5Da}f9pF2t&YBXx!dH65<3VgB;VQ{b=sY?!x7s}@M
z2=D>oCIeu3`~WU1a4gF!2K52@&@`II#0X@lu`3$c{3Tjhm3~#d6-O{MfHuaUX?V~J
zW6aM(NPQbl`aO1#eb;P8rjad8w?Dv`p}nJT~mV
z#QQVf`Do@B=Vm4*V2OsBr`|I+{=?bx?=*P`#qlzlBUc%?Xi5+@Yc!Qq#iW|1i3qS~
z2Yx#9@l^vN47I@qxf0T2XDVG$C^CC>;OQ@iW`1yI?q@f177qRRFE?%)JEcWxp}u2i
zfEsmuWaiy>o}C|g_TKfm@o}2Yss813?sXG-Zp}nhX_kbj#!`aDrirXMp}>(|uA3)(
zLeWfu6jccg0nG}zJSio+^xUbLMOw|45eZFVgcfMcO=}~!wV{D)_P27Oz`;X-_As$h
zmMuyoRf_U5Sxcuiy5u&H+#3uBLP7uQTzeq&tw4wighKm6ntiFzc};}Ire=q|GM5xj
zs+x`DtE`4ag(g=hPaZwRYn5Gc>NqcRONEDv@kyvgg!n*CuVA)tC46@4Mz3
zbB}aQ`I@u7=EvTa%*NJCWnj|z+MlYPAKw1BYV*{Z%@=L+7UXopwydLe_@z%B8|dC(
zfAHFo;n>uMrtF5M%-45j*1bCE-1SG-+KaCFQsjQ&pNr+lS@}0)GKX}toc+!#XNLJ7
zNgqkWZ{BuH_&?eE^Su*0GZk%&7fo8(Xp)Tc#Tt@7nL!f6YIV?n&9Y1B)y!
z58=NfY!Bhj7r~Hq6!Vyl>FRf7syC0d+{UA?jl7bn+&ZCtW^2uZy^-Dc#&kp5WcYCA
z$kE5)NVe`xigirKI+nw#pjbJ#0T%dT&B(#g=SFOq%EpP-&usoesQQM?uJ9x;WW>(L
zd{?$EM$zIrS{#2qZ>2#0R!+f}IfvW6iZA#Zo425Q+i-Ke>E6pP1AYGmx_-YNQ+kWN
zt(v|6ir>>(!#=3QFnLgA2KIv*C#5&}?SUQa!M{Rj`j-l<}yX
zG9Fc!DP7G1tyzeurb#jiRxCAorJ?enh278%7Swoksm2$p>H-$v!6xA`lkvE0hZjrm
zR831NEeoDxO7*Xs5r|Xx!=+t~`+K
z)!gH6H)#S9`eIUcLO0K1jQ@aM%%T^6k2dMQuPxeGTzh55B7$MQtQN=dNZSIU<9sVN
OW6SWaMFfL>uKxf?q3YcL
literal 0
HcmV?d00001
diff --git a/middleware/blog_visit_middleware.py b/middleware/blog_visit_middleware.py
new file mode 100644
index 0000000..64a671e
--- /dev/null
+++ b/middleware/blog_visit_middleware.py
@@ -0,0 +1,41 @@
+import re
+from fastapi import Request
+
+from models.blog import BlogVisit
+from service import blog_service
+from utils.blog_utils import get_user_agent_info, get_client_ip
+from config.database import SessionLocal
+from middleware.exceptions import AppException
+
+
+async def blog_visit_middleware(request: Request, call_next):
+ # 检查路径是否匹配 /blog/content/{blog_id}
+ if match := re.match(r"^/blog/content/(\d+)$", request.url.path):
+ # 获取客户端信息
+ ip = get_client_ip(request)
+ user_agent = request.headers.get("User-Agent", "")
+ os, browser = get_user_agent_info(user_agent)
+ blog_id = int(match.group(1))
+
+ # 创建访问记录
+ blog_visit = BlogVisit(
+ ip=ip,
+ os=os,
+ browser=browser,
+ uri=request.url.path,
+ blog_id=blog_id
+ )
+
+ db = SessionLocal()
+ try:
+ blog_service.add_blog_visit(db, blog_visit)
+ db.commit()
+ except Exception as e:
+ db.rollback()
+ raise AppException(f"新增博客{blog_id}访问记录失败: {e}")
+ finally:
+ db.close()
+
+ # 继续处理请求
+ response = await call_next(request)
+ return response
diff --git a/middleware/exceptions.py b/middleware/exceptions.py
new file mode 100644
index 0000000..8013846
--- /dev/null
+++ b/middleware/exceptions.py
@@ -0,0 +1,54 @@
+from fastapi import Request, HTTPException, status
+from fastapi.responses import JSONResponse
+from sqlalchemy.exc import SQLAlchemyError
+from config.logging import logger
+
+
+# 自定义异常类
+class AppException(Exception):
+ def __init__(self, message: str, details=None):
+ self.message = message
+ self.details = details
+
+
+# 全局异常处理中间件
+async def global_exception_handler(request: Request, call_next):
+ try:
+ # 记录请求信息（可选）
+ logger.info(f"请求: {request.method} {request.url}")
+ if request.query_params:
+ logger.info(f"查询参数: {dict(request.query_params)}")
+
+ response = await call_next(request)
+
+ # 记录响应信息（可选）
+ if response.status_code >= 400:
+ logger.warning(f"响应: {response.status_code}")
+
+ return response
+
+ except AppException as e:
+ # 记录业务异常
+ logger.error(f"业务异常: {e.message} - 详情: {e.details}")
+ return JSONResponse(status_code=status.HTTP_400_BAD_REQUEST,
+ content={"message": e.message, "details": e.details})
+
+ except SQLAlchemyError as e:
+ # 记录数据库异常
+ logger.critical(f"数据库异常: {str(e)}", exc_info=True)
+ return JSONResponse(status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+ content={"message": "数据库操作失败", "details": str(e)})
+
+ except Exception as e:
+ # 记录未知异常（带堆栈信息）
+ logger.critical(f"未知异常: {str(e)}", exc_info=True)
+ return JSONResponse(status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+ content={"code": 500, "message": "服务器内部错误", "details": str(e)})
+
+
+def get_credentials_exception() -> HTTPException:
+ return HTTPException(
+ status_code=status.HTTP_401_UNAUTHORIZED,
+ detail="Could not validate credentials",
+ headers={"WWW-Authenticate": "Bearer"},
+ )
diff --git a/models/__pycache__/base.cpython-312.pyc b/models/__pycache__/base.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..d86d7a79467c5c163af7332b4568a350f38d0198
GIT binary patch
literal 2771
zcmcgu&2Q9J5P!DUUhh}3*@PttP=W{_tE4$lN(+rZP1B|kB|#!5E0X11KN2tYIy`#=
z+osYYAvHZz4dRgW)C-58aNr0h{(!0y5la)SBB)vp+!iILUfLNu-fR%iTP=Csyf^d4
z^XC0##=oReaRN{F>aWvcl#oAh5OZwZQEMU;poDk6t6
z-juAU67_k(l&zQ&^ZAGww-QRi=S4GVC6%PlOJ>SyQCfUHYPMQwC2h4SZ5-hVO&5DZ
zC$>jjz7tykPw-LFpw(799L$>O%GN~bpdH1&W=X))bZ7&=G(zMzf)Y()CtbU9Z{7G}-EY$FBAr9&|MA+Edw;
z%f3XnbD}4GW}9WJ4rzrEJ3obKCQ=UAmxpcy?s3+1{T5@xom(pp$)EL!O
z&2W~Ey(!a#Y@I_qu>9a+mOwXBJXSLAR$yP
zklWl?j%P`bda|mP;OMFf=MoC0Fu9Nll-PN!Dh_x=nmm_zFYq68nq32@e70-+P8v>EqeJ-$pyS!AMUbGoi
zjS?K+oj@qeFndOu0w5L8iSWVb`!{nQm_;(j7eh(YSnYNjw^R(l(p(1>Tr0gqVfIiL7izONoc+^cG8EBgGQ`VJTUWa#1h#X<0Yi
zFze(}*)$QuUR0+SwX*5H{0F?uaSYQ8@&*S_woBz1EFfdKln++67na#RBp9~FjA<@S1U=d!7pg=uP4wkw3Uh
zQqUlhhORa`AWNYtX0MkS)kng{IKI^?Gs8i`G>KR*DyJQa)v3vlUr!T3&2dzys(#t=
zfgN12ADABeTm$=_JQ%ct)9ecnV5f3^15y__j(bLi9+RP`z|+4
zBrw!F3Ey7bwZ>&uxy-_er89T+8utnG1+Eu51V30uZZj!yA1p|l1crL1dBe#i`(8(l
YJN=3mxC6N1OdYv;^4&_lx_|C}0Ua4%!~g&Q
literal 0
HcmV?d00001
diff --git a/models/__pycache__/blog.cpython-312.pyc b/models/__pycache__/blog.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..95125572e4684bfc000460b801b92decac23ce97
GIT binary patch
literal 3913
zcmb7HU2Gf25kCIik$2?rN3^8KP9mdC9Xbx1rm0;ymfA?NW%)-)YSnESqXeb9%9oHl
zdXHz9dMK#EX`BK^r3!)RI6>v0uxUt@)D&@DySDRQ6wt#JknYW>DT!|_EF(Z)+L=9(
zI$Cmo61chDZ+B;JXJ@_{{w)yT8Td8-{O_ml`5ES)*s1+I>y1aBLE{o5F_I(AWE=@c
z#+h(tTnSgkop5J72~UPiuo*7FWxNTm1Lrx@z6_t>Y1@?+GX8|$!8n;dMslBLB#-Q$
zc3HX;0gAGKayC??s25P54GmJ12UM`3A&U9|4cO3dL5u~fxJk@w^4-cve>N|V$i(Ej
zRW&WAvL@T3ru9tL-}pX8KW
zGw!-gJUByU0rl8Wj-p;bSsUu3C=V!SLj^?PY23qWo8hmo^Vv|ijrE;*8w$5UwFMbfm@Knk|+hG&`h{~k_bg3Qj-+5p-mLs257SljZ(A)&{i9|t?*2&&2)FC
z)sgCdVdp^|yp*Y2{HQYf>GIV3)lW+|oTfLcr_-sSv}|(2Y9=FR^ZGL|Yvt~2_3F(^
z@vrTxH-BCE{dJJlPo^p#T+~}(bh$KF8NUW{<+FR0$+7lVp!Y54+BR7EEMpCW(ql?WWYt=QI)JI(D^F3eKv2paf8v_jry&z2K5#M+D#uWKdER+e)I)w0)`)9
z*FZ<(s2O$CHl+3+-Sw0;J=XoyR}I9PO>Z)pO=aX{(&UrLj4J7AZ2ObRGkPj*jS%D_
z;sarN@=87}6AUiXmsfMiv#GQ$6F2s~ik2K9aw<=dUrfPfLX*?<3>wGehwBG7`Ex3f
zlEbQ=%@Yon1Yot4lypMln+Q~EO%1x2Wl#1jT1GRy>;9(QU>?C#=0AIT_n&%`sPD+b
zdF@o6l0U5v)w^h^mo=H3RfgqLa85a`okA?0D-aPDQxSrO_74!}nI(T@VsGhdldqSf
z^S?0shl&T6Le1mn%F%^=KQKZkiv3H$ZQ~Q?imrVuAgEw5(HlaMAbAYLyySUQ(vD&$iVY8Sqt8;;AuTu(
zM?nw%3bydWsQ5NCv|S+Js)g{xH%gJo-BbDbpBh4MvG;+$bw(PWQA7IB0S~_s~
z*2dclBaOzx1Tf>QQFa0o3oE%KHzXF;W-bm+vmF+bCJ;9q1PRYF&r8r6-A&C?r-mnK
zAifb#v9B}^(jh^OmTh)m>j~S?uRzfWkA`*y+lbNex65%u>?rm<5L&2J+AZhvvtzxM
zRdCJLR`~)(8m$6WXiSWolJBM&_C(CW=;q{VPs%h^Z_;5;&|cIb`yg%GlQIveAo(O-
z5@t3^B!3|g6Uno13=#w}sCz*wxyr}$l~0P)m1%lep1k<*?#C;Cx&z5aN2Xl<{5PxD
zFH|mzy`KhIU}oqvpLt?a2t))nsoWb}on^Lj1yKwPZfZs6&z?^JT8Q`Jmvh^Xg)
z>P(kT6pM^Gq&i3xPrrP6L==7SXzzl6%l8E**l}%An3Cp?7{2cnyY0w;;p+ipgXwN<
zH^hTLbbM%{x#XJM4&n4;gYPQ#pc5s4?07@$*>I!h7o$j58*YTVZ|z3zO*PyW!Q}$X
zWed2Pt8kLLUh8>mT4jz)HN0?a*n^9UFBBwi&f*kb~;2R&fSw
zUt!gP0ZFuBSn~z3nv=pakvdg`3Qe&nc@B(3_M!L=2px0e%7vS&bLUrQZ^Qkflj4mAexw)0ZtOezm5jzC_8l0;-pGkG22AekD0*%tX>2$}*^DydwKsAuJ`hzM$F6hDMV`z;8I4in`zLwpVV
z9O{A5a;FjMfMS5AkfzC(7IuBt5ITyzwy;>}IAVxLX#sGVEs-l&1aunVep&u%~sI
zl^cjXA{h92o;0WI#MZ@i@vjUaT-X*VuLkd!b{Ef!Eq02j^hNp#!hA
ZD7ItkZ2{W8H3nX5J4D1EGw`Ab=zmMK9)th@
literal 0
HcmV?d00001
diff --git a/models/base.py b/models/base.py
new file mode 100644
index 0000000..af5136a
--- /dev/null
+++ b/models/base.py
@@ -0,0 +1,57 @@
+from sqlalchemy import Column, BigInteger, String, DateTime, event
+from sqlalchemy.ext.declarative import declared_attr
+
+from config.auth import context_sub
+from config.database import Base
+from datetime import datetime
+
+from utils.common import camel_to_snake
+from id_generator import options, generator
+
+# https://github.com/yitter/IdGenerator/tree/master/Python
+options = options.IdGeneratorOptions(worker_id=23)
+idgen = generator.DefaultIdGenerator()
+idgen.set_id_generator(options)
+
+
+# 第二层基类：包含ID
+class IdBase(Base):
+ __abstract__ = True
+
+ id = Column(BigInteger, primary_key=True, index=True)
+
+ @declared_attr
+ def __tablename__(cls):
+ # 自动把数据库实体类名驼峰转为数据库表名下划线
+ return camel_to_snake(cls.__name__)
+
+
+# 自动填充id
+@event.listens_for(IdBase, 'before_insert', propagate=True)
+def before_insert_listener(mapper, connection, target):
+ if target.id is None:
+ target.id = idgen.next_id()
+
+
+# 第二层基类：包含ID和审计字段
+class AuditBase(IdBase):
+ __abstract__ = True
+
+ create_time = Column(DateTime, nullable=True, default=datetime.now)
+ create_by = Column(String(255), nullable=True)
+ update_time = Column(DateTime, nullable=True, onupdate=datetime.now)
+ update_by = Column(String(255), nullable=True)
+
+
+@event.listens_for(AuditBase, 'before_insert', propagate=True)
+def before_insert(mapper, connection, target):
+ value = context_sub.get(None)
+ if value is not None:
+ target.create_by = value
+
+
+@event.listens_for(AuditBase, 'before_update', propagate=True)
+def before_update(mapper, connection, target):
+ value = context_sub.get(None)
+ if value is not None:
+ target.update_by = value
diff --git a/models/blog.py b/models/blog.py
new file mode 100644
index 0000000..bcd2957
--- /dev/null
+++ b/models/blog.py
@@ -0,0 +1,99 @@
+from sqlalchemy import (
+ BigInteger,
+ Boolean,
+ Column,
+ Integer,
+ DECIMAL,
+ SMALLINT,
+ String,
+ LargeBinary
+)
+from sqlalchemy.orm import relationship
+
+from models.base import AuditBase
+
+
+class Blog(AuditBase):
+ title = Column(String(255), nullable=True, comment="博客标题")
+ top_value = Column(Integer, nullable=True, comment="置顶值 越大越靠前")
+ is_great = Column(Boolean, nullable=True, comment="是否是精品 0否1是")
+ category_id = Column(BigInteger, nullable=True, comment="博客类别")
+ summary = Column(String(255), nullable=True, comment="博客内容概要")
+ content_id = Column(BigInteger, nullable=True, comment="博客内容")
+ word_count = Column(Integer, nullable=True, comment="字数统计")
+ read_duration = Column(DECIMAL(10, 2), nullable=True, comment="阅读时长")
+
+ category = relationship(
+ "BlogCategory",
+ back_populates="blogs",
+ primaryjoin="foreign(Blog.category_id) == BlogCategory.id"
+ )
+
+ content = relationship(
+ "BlogContent",
+ back_populates="blog",
+ primaryjoin="foreign(Blog.content_id) == BlogContent.id"
+ )
+
+ visits = relationship(
+ "BlogVisit",
+ back_populates="blog",
+ primaryjoin="Blog.id == foreign(BlogVisit.blog_id)"
+ )
+
+ comments = relationship(
+ "BlogComment",
+ back_populates="blog",
+ primaryjoin="Blog.id == foreign(BlogComment.blog_id)"
+ )
+
+
+class BlogCategory(AuditBase):
+ name = Column(String(45), nullable=True, comment="类别名称")
+
+ blogs = relationship(
+ "Blog",
+ back_populates="category",
+ primaryjoin="BlogCategory.id == foreign(Blog.category_id)"
+ )
+
+
+class BlogContent(AuditBase):
+ content = Column(LargeBinary, comment="博客内容")
+
+ blog = relationship(
+ "Blog",
+ back_populates="content",
+ primaryjoin="BlogContent.id == foreign(Blog.content_id)"
+ )
+
+
+class BlogVisit(AuditBase):
+ ip = Column(String(255), nullable=True, comment="ip地址")
+ os = Column(String(255), nullable=True, comment="操作系统")
+ browser = Column(String(255), nullable=True, comment="浏览器")
+ uri = Column(String(255), nullable=True, comment="路径")
+ blog_id = Column(BigInteger, nullable=True, comment="博客id")
+
+ blog = relationship(
+ "Blog",
+ back_populates="visits",
+ primaryjoin="foreign(BlogVisit.blog_id) == Blog.id"
+ )
+
+
+class BlogComment(AuditBase):
+ blog_id = Column(BigInteger, comment="博客id")
+ parent_id = Column(BigInteger, comment="父评论id")
+ name = Column(String(255), comment="评论人昵称")
+ website = Column(String(255), nullable=True, comment="评论人网站")
+ ip_address = Column(String(45), nullable=True, comment="评论人ip")
+ user_agent = Column(String(255), nullable=True, comment="评论人浏览器信息")
+ content = Column(String(512), comment="评论内容")
+ is_approved = Column(SMALLINT, comment="是否通过")
+
+ blog = relationship(
+ "Blog",
+ back_populates="comments",
+ primaryjoin="foreign(BlogComment.blog_id) == Blog.id"
+ )
diff --git a/packages/PyJWT-2.10.1-py3-none-any.whl b/packages/PyJWT-2.10.1-py3-none-any.whl
new file mode 100644
index 0000000000000000000000000000000000000000..6195c57682405cded6020754dbf8111489923b9a
GIT binary patch
literal 22997
zcmZ6y1B@4Mp|7WOQ}R&&LS3%IPUg1B9&lN1&OME
zn6svfFm`mAOe@(>UEJz-1C^Sh5~_1GQ_EoX-3ZLQ=8_1I@Z=|cUOBWeyS7IN{hccv
zQc8I?l?$WRA5byGOSwsG(gc(maGxBA*9`1J`Q%P#G#QqQv4Gx{lK`ibA^1A4l8O##
z42%RnyWB4flOjk3q5XDTF`b-P-P9NcgKmO53C`Snu5{4=P)J67i8gk{Q4ufW5~iV2
zYFh3HyKl3^
z=8C=|gU`3c4byHWEwen&d=i^`$&;aMCM~W8k{W}~pidg&(Uig6%-`EpTyeLmhXYj1
zZZ(-tv-5W+S+@~i!)2m#B)2eGD?!0@rc)JLSXmGG$QsI&@Z%GzdvV)EGz3}0jG9!S
zCi5Zd8fnkd(kO>rmd1g?%O5@%Yu`N%jhQv;Dm0%Lf4|7oXoO}rma-ezZYTEF5-S<*Aq!-}gBl1P0R8Yw#RZYK*$$ws62)b=v*i*zJBO}CRJ
zEktw8xNQA8kv@-by6U=fH_-~FT}GiwO15Ra`|<6BMFJD>FZ@h6{;NLSge-Y!RKKcw
z2?-_N2nD**@-`Re%L;k3A;_!T5apoq`$_#XHjSnj
za*~8H^8EtI+cpzLn~esmH#slSM72D@(N3A=^PYDwaM!mn5LDzw=zCuOWwK=q`M@~i
z2i-{Up{{dFoBgsH_DBkelSGge>@jD2#yWFsiFE~)?c>Y6Cr#2O@=4#0aN-CUTnW=m
zHEX~JOsgif8cDp$$9+Al6cO%A5^q#Ty4S3`xMJy?7*6Z==$Jk@4pLYSdMzvGs>qY(
z#zXf$E?t#Xb0N_3xY8
z#6M@@pUqrAXIE^Jq>_xw_=uAb`dvC*aP40{846ZB%7r@V-k_M?ZU=y8_%DKKGX{ivF$_#Vr^0^mthEdp;S-`vExeMi>c`f>d3n
zc;n(4U%6;s6{!%qAqdr?oO6%5#VQ{>cq|2kZs75@yqFk0-|l0A!d_Q7Q9KP%+-73+
zyF8m;5Y<;6`?uQNpP;tPJv46K4=i?;Y@gcL%wH?`l+P`zc>&zHCPN%rv@bgHwRrLe
zl|%F1nE~aX%G|>RcXwzq9vy#?4tb*bl0W5WB8_oo9Rk(Vc>N^yu=j(Xmz2jc2w8(9
z;w(R(m38n&ed)nfOj)K{!7kk+T$g>JG0=X1X;?5w&4iz+wD0f@dDcEyw5Hy|nqHZ7
z$&u-}gSZCc_IOUX>uThthU8g%hWYwXhWvF6x}A0CSIJ~+JWvMS`!%zBX)HaRf2FFH
z+Vn8Sd^~t~4v-?jBc$ZI0NA>D*1OK3O4c||dD-;qzo$Bu~A6KP2>e@zX
zLh;!R&!J7d1ybzJ);+MYg8DJSHoENeD*q91jL#&u><4S}{M6
zOR5HjaS;vkRVHkJpb6cEvPRGeLWi>mt`4>DC6LNQWL?H*lTC#70LUvatwKo5D1>yg
z3VA|Orxyz^Ywf9ut6MK$?R7lyzCN-WV)S`7YXk=F%|Bg&zv?c$wru}6lH-jOB{0dq
z`+%;*(jcz|_YM3#kWyeXymd^NT=MVh-&gVOx?aqAB>deVg)jt?#ojmD+F*_!Uf5YG
z`@tg20Mu{fFwDWkx#$hjGTxUOkQcxQ+!cZ4ZhwbnqYVSBu9wj~Uo&S@-OJy8%}8Abf#{KE0uZ6h2*Xwp@@T;?vEG!G*@>l%@^^9N#RepPi|Dp
zxuBnTffu_dWz!s|v{I!mBFPTcRuPho-Ca$?{-N_z&Lb~q5B*;qI&6d*`66&{izk0r
zM-V`P{g7RMvj!o?#ZjiLf9vjefU$1yZ=E4&K}5#@m?)AYTG(-R!8o;`8W7}V)#r?b
zi2&kXEF>!qt^mB!SheSM_vi%z(1V0i=$quPXU3<(1QpgP^%F98EoEe@7bf$yYJb^AMULhQ2F+5i8tmfiK7BH{5677!~xivqJv!%#LxK1wuYo`
zw67YK`JWagbrFKHiQfm(4)~0e@y-Z65b3QX-~oPH=Z%z3vwkeES=o}z;y
z9Po$7=A0!4yU6Eo`K9WCk2=IOJHVmnLtw84870!WObHAm1O9A4Iwj*UfR0i-me}O{
zAtcPVkS3622i!}+Gp`ViN=M}BO2&|IX4`%c52rr#rU|<;WP2tkPP-pQPl;5+{dvGO
z!5l+4&GEb+i)CdTa&q=BjQ}r5S=3^Pv`(=<^ErStV>{Qvm__z?68s-m=QZHXgU8QS
z0#N4wxrhA8%3Om-PpN^_vl-xvmk$ftG)?zCd
zY}+FBF-WMgI=?@7(I#9$%Xv{)M$VbM8p+D;Ku~z7tC>ntkfhbOJ3y8|Qe?7I5XX?Y
zoo9t`@cBffI!X}?{;1wc>4Q>`gV81x;JpCR*puDB$$1a5NrZQTOEZYAU;RG<=%FLU
zL3hEl_jpJV3}_Pb@)Q8hu9Y)6m*K9^^sPZWxXr0
zQQ%N%=@x~#YlqaY)$K%2#~%Jzqhx?rKobB!om|q$Y2)x>KYLvIYv2ZLrYf
zk(jqGAX*#jz&X!iaFtsmHB{|=mh-N*V&30iz`TXZcR-#pt%W3)eBB`v&+T6J7b-y1
zq;V3;zSwY9qDQgho2wp}LKqdo8*ibz4H}@aL^)`JPsh`q8i_gB#eA_p0T=v`b89e*~WVD|jd08`XVAhphtYZ}kkRU#p{Mne(`I
zKaR?;zWqcn91O)^SZVde>qi~V0@Ux|1VGCcbXT@yz_Ohvx?bF~c+uC^K~d1$_0#sN
zDmQx(S$?FcjT@-42u01|%$a4%4zdCl$^x)uR53uD3}u1bGD?J#vP8u_2aR7WY$i~>
zaYyO-L>hWcRB|JO36}+%S1BU4-MqI9-4)+;0)dTX(L%xMRN4i2GJjVtLC;EX7A6Ty=~e9sAj`1H7p>=BnG<8
zvdZ`}-$C__^`};Q;F#^zm2euuT{G!qJy*eH$5>h+FpDKB)C@zjrwYB=BjC=d1w3ie
z2W3hIMFl|pd$V)cyK!lHhQ4-JfO90@ABbupf5j2Zh*AP${?shr8lN>s(NpQc>eh*~
z#9h^}zF;e+yMd^*x#!bm4A3?kxjkhEpc!XFU05y}j$*X*0!@4>m%&&{E)b7svM;#QFq2o(i-H`ld_3o$e}-~{y|l~_u1o^L
zkKA2cU<~-x3}1*Zsi9xt>5=ui4;K<^9~5gZg2`GK#n#V|HMR!jw*=+aobhc2;=sRc
zhBqa$d;NFnARO0mSFh(6o?EH6(x8eu+FpRyqcHX^+qq%*7^-zx@w@N)okEDkqCa=k
z**DPwet$}(US_?iX|9d^WEwEhWj{8MT`O@(Dtzyx2<}2p{q)=}-iOYht0hR6iOfzs
zF_N)e9{FsYRt5p4L#XZ)nI38F$)3u+J8mkzNbylz0mNFi$jY?0b5
z<^da(eXA}2*+pyebJzF&i?8&!dw!Rt8K>@M6;@2U2)t5NI&R>M(W-6CG`hr#C6uDh
z{mB9ReD3#rQAoac>1Pv!l)wR%9jll^7u^~M`BU19DxwRXVFN*y`>v$8*FF(;Oc;3R
zLg)eFi8JV{qnSWtGG*n^m`Qh}1NRAD&Nq?_EInBuB{hW*NA3gI!x85oFz178sJuW#
z>#!ABtHQ;{<<=or_Ytz?Z-Q)33|Izb|{|Vgi6FoHE;MblwVx-Q(Q36svqLJF{eBE8&M__!e0w5SI=|m>h)(f=&>D8%!eK
zfchdx4MwkL;q7IveHZ!qm`oApH8NjyToIX{y3(Ma4KlTNc6KO-X36Bo8Aq-OGk>p$
zxS2R*!Nk;LCp5VV^mVPC)@Tru+MQ_ID{D=9uhqDlaC_=>ENo%*JrQH#U+optA)n**
zaYF%rFaD~xfi6gxR_ex*<4=X4F;lE+$oEa0<&uV&GH7U6%3H)-7>z#er7(&2Yqs!f
zKS9u~i(x8uaN4Xw1+I{)+MO27$sXYpDZ4zFHy@W*vYtmV$=8c@?dVkA`TV(fE57(q
z_&UbkfTV?;9V97v2i`O8al$AWdkED1bp~Hw<({kUPmC*R%Z1WuB2<6kN=MkYtK>Q`
z*Q*gs^Huds!u5vyWpxP}a=bsl25jsLtO^&v=(jGO2u3
zcqC!I>pSKS!p8z@omXX{_jsvFZLg{TK*04qAq!!lkP3o#FO|~9IGr{T@g81AaOFw5
z)o}f%ZDE`94(Y~O`4AeNWT(=DTEu%q@4i#+x30MrfXt|{f?v?6<=zIa(pP__6es(F
zCpK0#7h(NZpZbFuPDJ@+@SS13FEO2-d}|k8RHprO&aK6Eww&Kz4^ine;tEY$G!(=?
z1Pe@q7xmKBC3QX<;D!t-egeF0ViRmfyO~5$<0DJ1@mFZd-N{EPfE{i~?VQII1Bc0mja|=1T
zEDHgx*OybAA|cMXI%tgrOf7udM|U@yDSdb9YC%tbp>_B<1Kj8yt#Pwd&D;!QwGq}j
zWkq=l?6Y$HQGc|h7iv^`^HMBvzb&a3402oOWYWe-;f{}So@|Nwr4mj;pOE0fpAV@z
zdqUcsY+EsP+Tdw-+_qM|@mKGX^9?la(5F0Gw?$qJLg&isCHIxAJCxu1SO9jNt1y1m
zXDd7U?umq^GXnYdWOz*DzuLFVP%Se>J>E)|I3edn;3yGx3W2%sQt#)@=g4M_5OdV#
zQ+XM7nv4x}Xr1IA4w;CgQxc!@`)#v^f5gNW5{UnG
z2XpKgfu2P$r|8N(+6*+|2Vv$@)+&5k`ChmwVR@(R=!p=WWj?UW(+!13aJC+*)fzx@
zA7+Iy1>s^2^PZ-V2{6Q^zp7%*m26t|_uRi_^^8z7ZEK?jDp?xqzEOVwf{}iU!iXvXH)o
zlAlSRSITwe%KR2-9KOvjxsKPkm0?bz(~l`oMZivb?*w~~th0~Y9Wza_RIvSnp7ZMee?OP-xm$R
zv0H+=IqwqewFcN`X`3Da{6%%m1Vq-v#ZbwteHfzKzdu{`%DWF^O^pBeDtLVP->(avFGut~
z7d~B~Hx$K$*!(#;uF=M&Yi?fUs25Id(9YeFL38IJ-0C`DEnHw<0=73dpJmrLI9K6j
z(x@H;vEBVKH;2dszH$)H?16d^7ItT-A6MqnMQUc+S~ItX?VN;YiiDefXAN(}`7n%a
zI)>{{Q!KJLqKnl|GJb9wgbpF2jKdAs7ByDHcW$*m
z-<#B!&W|i)YWAx*zg;Ru`N*D2v?`_cMn
z@F!IH*4u7iO0RdPr^c-6B`r&J)}>NaWTLZYhM-SO^b;S<`EQCQSHG{t^6o)P4Q$(I
zi~XVaDMOJ>#8!vedw~ev4@V6_viqCY&odN?^3q`@(`=jtsfW0(Tj;)MoH@VYpjG8R
z-OHVARQfH2&ue74MwMw(DkQ
z3&_rRoA7wUC|5hW@HbtG;hVVXJK+HC%nEYTo?F?^8=Biehux?ToD*e$b7MNIjHM9>
zj*S94bBw;*jvW{3)v^~(WX!0BND(&M80p$cj;%G>zeo$_|S==c4IkL4>eNQQ6T
zFN+++Sne`kxIY%lv!SBTmdh;0Uen7dBaq`*PC}r(qV^;S;`nGI?78Lf$6$w}dDL3C
zo8&}AF@bp$Av}JDsBqx8(4+qK5ImKqiZ*^=nyiqnM{Yp7q20Z;er>}C9_B;cUaob=
zUV^x3sE#XzAk5I&F@_73GgGr|=lgaG?gc%TC^xhuUR~6YTb9ViWI@DPH4al-YYGrKUUWY<-D)^wrxw
zi>65W??ldOmR&CV5T>wz9wN3LD&ui3imqs5^sfN?!vIvSW(dYZ#n`V=T8(Y3ni#L7
ztCVftEVN_2&t;x%>>%Y5Dv#@IVE^a2Q|i%*U}?NepICKzup
zbc}o9K<|QTA`t-Gu#+knT6ObF8c{{10xM%&FwVg@$r0tomx6TnZnjvwU4yX|<~oy@
zf~sp~j4%n6vDz1KfLH0>ClvGPJ`{AZllbpnOSWDO*QvuIXdx=w+p;jp5SkroTVR)V
zcF$;W3<2or4T+^5XgZ<}YovPC=^6Lz=}QXzE6bkZx6R}$4*flm2+->r(L-kEfhbQ+
zsaXPGikeEfZBs6R==O^+k6uFtyA%mzXoO}Tr@i8IhYZWsHwruR9Z6s6B7F6UDqV>k
z4FzAQ#4=z9=*|6kiq|-4yf)oCRU0Vl{(UvihC?iM!7HG0
z0;@}F`$=?S6ZNy{4?fzuS9I7y*aE+Pr+|9ibXw{>_%o)8>}(^fxwVkp
zmVX*y0s3ZLwvffc{Vq2X(T$8lmm;<``1*^Qdqb=02oT6C-XVB)XJF$hJ{X36qV`j_
zp8Ntw)iQooh~cVdG8#%ZkYRDo577VRjU3VM16*N&fbQx3JBs}eX@p~Kzae(t={pqo
zWiW3LVZ9Cu13axeTZ~B|fHPHb}T-<)*=l?6~=l=2>hL}e9gPgRo
zMa%BI^t7c@tuK@rq-Vv7_c#uBxr9@Dq5D!PhUB@WNw)F0?Z)bE)1OFmU~#{+;NyxZ
zS2XgVTf!cpHFE3E!3P83A;t%tv6nBSb~-z4rSo%(<+)g0Th+CN=3!9$^|ESxIi=Os
zR!5D!CV5(lf{%JK=mNU!+QiL!X)r12!Kwx@{6OTOlB;5P-dat!@tf(>nY;68_ZLY^
z-=Osdh%^0kGO%8nsgJ?ipVGD>{EyyPTb`qkbz5kWocP!jx`SO~
zPL@^+w$HZ|mMY2W4W;mdP*rpMavFD&!#X-HH4IyJqMD1)%?45`>c9(xRxq}`;JHmM
zi0~K*N?M{=dD{V)htya;Oaa4kc_1=tbd9S~v`{9&q8G%L?wFhh=e{A9)0JK`)O1
zwtVyO06|op6DBQsx_i#O$GZZ(tx1=}2X_l3uz{UC^0ib2rTU=Z1B`3!Cf-VkWkwDr
z6J4z%5vVA6{NpUPJ0%Qym_kcs+yslYvI20%_mI@Tqn3vGL;2)&({bsMf`fFo44O$`
z2}i)21?z<%odOPFO0e|>;DiGg2YPoOmM)+#u`tD+F==q5JqWKonQ-`VXeT;>6q3_P
z0Xefgh~VzUwj1j5_1C1SpB_XYkrlpa#E@Dm8>M_rU=2(waVd7miD>Mp{APYMoAMw2
z`&eA%L~Wrwi`SZJRj{eJ`z9{>Fa$IZLU-2G4s(X=MP;Fd581t9j5b$O0`uDoY8Xas
zp~G;7IzZtg)sa-m`jX0mk(MA|gurvW8@_Rv)Rg-OMWsh#!!kY)hclzOY-kOrV3BFL
zGTdVO%MJ39Sv9ei;3DungW^{iK?83yx1>-KW2J4N6kuq8e{5O`BjsnT>l%hz)59_k
zBdTqDYtP(Px5@4t05pNIs>kywauZK0x_gkp{r2sANM9c!LA|SnGxk$4{HU2XabX#=
zBnJUQLS?f3d3FcDI#wjF*uQ#085u{4#fPYJ6d
zwXOg4cvr2FJ4m;#LV!#i8Ed8;Y96u=OypOrux~kw!IF+pD2YW&5dBZfzzVwvzYYeQ
zH#AQRUO-M+aGjLWiysoLBpe@jguuh|mNSY9{|)@xw6)hc`Syu?Z`laQaC6?EQX`$*
ziB~s_AsjlsBV(7(rq6in11e+}KkjRdB@&#EC;j|wv5wU`8MAB<)_h%fH&94X`=WdQ
zs&cwl%mpleTn@v!JzNvQeS$*9$Ph?ctiK_G=#z9LH6B)Oq^^0)<>|hYNnIoJIP%s&
z_d0~$EABwbjYah>b^!-G6;)j!9dg%70rr8m%Bwg17IZ3RfNzpOwb5}wP)mUrb=;3M
z&MDD1E+5B4$2l?vJk80{d7!^Bb@nS))q^9~JUFyW@sWr0ay=%{
zUwOPo?hpxgJ3+)wG^qjiRV~h!e2<0XF+zc&M6~&a+XS6V&`B9nwM+u%wSfYdkpTF6
zU!qo|C6YjXWpyqJ5B_KBQgw_w01cYHceX`>vO%t&TMra#Md%`&X-`6){at{q0qw1H
zxB%iDu1F|@y0Sp1yiVLQD*KL3@E4{}!fAGL6wgFZa(ZZ&vJQ+uE1BUNlXai1j
z0t(XrY*4qh-d`Gkpds;6HBSrdP`T)^aF^zkhCNOY+yY(iOd*hkozcQ
zi+!#fx>t~}VyYN_l%{W7kh;y9b`?XnEKk|R?unFJ=soRW_eFpkCBc%;bzfcj`Zen
zf~gFyG@^pQZGzr(;1ue2Q%d9}L{j3y@X9sI*1hLbded8dL}j**V6AB^*L^er#MdK-
zSr&I`rd95=MM(%()j{Hn2e2!5(7uo(Vlr(j3x9_w6f$!WW6f`1G3w|%);f=Abzqr#
zd7|w*fApP}$sreiqO-32j)hQ1rc}+ctLkncC$lXg#vCGIV!W6#2n!v9C8;okZRoBX
zZT0Wk=>1cns5xu!A^XO-D4{@D9rXf?+)=!Ljbt5{9mco{k
zhI-MUYD73}g=k>!*EA4%4TCg+d=_+8bef6aP1nhR{y6PNW0_H=e#B1OM_E;MhBSkwyUtFGn(
z3$ai%%`+s!{X18wJDBTivb#R6>134QM#*cLprGHiQEu)l}Znyjng3pJOB-C-4m-jGx5fF=?{!p(gR$3HUpXoA~m+6
z;fDcFux}#xAsA*ee_bEt&(I#+q?_
zZTgkwDw=Mc2Afs}nz8*tN>kd#2Bf5jZ&%XsejdX8iqXiJ^eRVRl#?!rgYn7KwOD&s
z&#Fo1T%=M;J#vUcoqKA%Bk$quJAErXGM#`w^@ki=y%{gq#Ihdr#!s&Ww2x>Wo1j!?
z{X>4+-5Pu!BT?qH)A~O?!?_qE5g<`G+s|wF$N7?RuOGoT5j@NUa#)|dCz2WWn5wF3
z%1H2P%%{{WO9&c5c?H4UHej;whxpQ+d?c>-X-v(x^uxJgoQZBMF
z6gc+1mDMsfuW@MQAG&yMA8k{%0-p8miqctk&Q){CU&n?8VA@$1b_n#pKdpXeka^I8
z{nagdQtF0Ko{E&APb=7c^Bk5c>EM)Z6w!mxOc<_R^;@&9Lu|><)I6rm@QuhT
zOuO0c@-5&)oJQXbnK0x1-4a4B|67bGpS45$axImjRmRR(0zNwcx-lK986V*{42QOw
z|C%rnTr-C`82eR+KDv2eBW!*qh}tSPnXVAaa21H7KHZ=cj2|-wECg^+im0zi;kK~|
zGVLj;fZ(Yl2!*AS$YMy294-A0HP#A=0M|Q})c6-uHXG1IL!n8t4C8AbV8Zs^xB-l-JGCsNiJu@~^rXnT=z-Kj~
zbGmb#Z~FrKQ3BowH9x1M4wi87LqD}u(!143h$H?y&n;u_Hu&5f@-=_pKR*=zDi^KW
zqvT$&DtK4h+(=}hD>nshykp|lWq}8Gsc+Yw8O}g6&6sw_V&&pdA0kteNOcUj#VC{X
zsOT%GDzBiG1wMlT9f+)e9Smiv+yz_RRmz^r3YG_rIoG=VN5q1Oov>cmq?5vmS)GmUv&C9ln*dvr%Gv+
zCgVGCVmuK<=Xf!%mTR!C;PR^hMTG*9?+0~eUgBS35?+4Jr>+I}1KSLcLV>cRimIG~
zBa3sPJ9m%|u?4M=3T-bhgP0{Z&G};?+AI*AP8%G*QBlRN9XUnqI|)>Wgk2^;hjo&R
zu1tSmGO=KKkSHY*6t!Uu%>0Bf8JBG!>B7(04(R_bN{#iQqml%{*9x!30EinsT5~lh
z%9<=Drc)s*%)
zYGQf?&8v@-rUm>a`0bJSB#VQy!8+ui1TA)0!BAjA+;OY;HN%`w}+6tI;SvRGLeud9`mk{DKlL^&T_dzo_+QR+kN
zy3e3C9FDy}a0^oqD#MBtTcMv@Y1`e|*HMTT18xBkM-|Mgj0LS!Xy~CqU9TYlCCW%t
z>Kix=a1KfO3<@7+Z}y)zKfFVK)EiYE8FIdw0Q%BIICvI7RND&YFZ&fp#^!U1XTvI&
zQ`C{XaBSe`ch5EZkjDl20xXvk)$UmM*p3W%^dKNc+zCUqO!!o&AmPF+;>j=p5EefT)T3}m6BCfKFm;}AK%7F5V
z0;_kwW+t75YL;bTy|k`^2eRVN`@&_Hw0MBJaJk;lYjAxXaLI3-%K{g)L^>;I+0P3s
zR|5Mf+@ker?^|+hjxWneUtRi8?ptIPHqMdbe(}Qm&mB*HO-#3D4)E0PjJgmRw_oY_
z+5yCsIZpDoYW1gQhUf^lDcFADLyuP}5!p}u@eJvUxhA`
zi!U}Q+D9+c+mu;g47sjl0+)V|q!PO|{bgAW2kcsKeA`zgO&D2bW+@zZOLyO!M
zdOy&wW712SWEpJVyJ~kM5i}i1xp`^@Oupxu0Cn&fhtLc(rvwEy+4L)Ws7|)ao@u5$
zr4dVj$Asz9_(mJfa2OLb9Flf93F|TYMM6e{OLdwx7DaoDz#io{Z#^vgZKm*AD4nx#
z?;bQqE27*|M)}V^)OWcBv-_9W%!?!_Yd+T~acCA8yF>kuUFoTUUflqOr$8AAXcG|3
zx@c<^h@sZ9Ra-6&UJ%+;0(7g=`i9&aPJC75f8v=oR$#0`?Sldfku!
z-;1N<{0os#Dw@`qOx(HOL$dlw|kM0Ss^s6knfj`9px_VCYZh15y)F-EDXkpP+<>R&r1i0jebQh9?Ya
zKCx#5F_XFW?^Da&MGmhDhSoZy<$qiujfKAT0L{yG?0SQs8rKu`>^CWFJVA_TZMz_nuJ5P;_XU9lY0?&1By=q@jwO#95!M{1;Cz9Ca(btYq5L50HC%?oim!gcZN
za@skxy^LW-{%7`0C$ux0D)#qggNu7VsdsaE6qfp?pb#(2bdXMtLzJm=ehhBa?^0*D
zeeQckKAj=dBaDGimaVZSbBWB6>6j3qEX<97jp^HI+TdCAaFiQBCCp4=zK)Kd&@S(Kd9N7~LDH_q;5@q^Z^B76k)jfc(x8Q&UX43lQ
zd17}y7vz;C;_+*L{tdvYr2B#)0Et~$EuYZpQWuIsA6wAqS%{_72@cp_BR`=*afo>GM1&jR*Wtr`Oa@-jX<#Y&aE%<8&cKb&?E(M~khkbiv
z3v&;7Am8kfDo~uk_QzL}vS!wt)$5?f>MO2x*=SK_LXA^}m!Z+y_M-=lsl8+E4ame9?L|_d!>;viOl^xCP2ZlkZd<7Rf<`MahAxm
zlTvzBJx{V%DhVdx?9aB;E#R7$rYMcmM6>hySv>)1)s3}XLC=*IHPd~R0LW@3jo#e0
zSIm&@M}N;MPZGsS#z!0!h~?%iCP@xqH7SyE{PoABnr(clNMIK4ZKnuQ!@FQH%(mix
zDHYma1zzi20xB-J{U>B44X*tdwJ(U{d0kcCsuNAyW`z%5Y+?DWUZvBj)%~jI?3ZTI
zQS4wdcs2MuL`ntr>xs^OX)*F~Bc+OfpnBc!__$IN@(lm~nqI)&*4OS|`x+7?5YRt{
z=zrSREKF@2{uw>ypEPit5vlt_z3m#DY_vd}%=1*aLIuNeV*y5#KEt25UUy`zx_Q6H
z?UKgwI2l$KXT3S}(f4N1Eqd9xgBdr|dk(yG?H4p|PZ
zY+j#=&=^ZeSK&Ioo(%=bAWkb0S{}w+Xw3TJg`$Z7jtFn0*G6#LGq;o_
z@T%mmLaPiPHnEH$Ij#a-kNOy9u^Dy}eWHL+Xp7i;Ud
z)wx<@YOct=BrU1}J;)C`y)QGs(Uz@Bn(jtuTOV@(goIk&{F;&kPn@2)?&Fg`^Czhc
z-H1ZEaNAkW0T6OC3C9PAoo7_L*f8%96Cr1JBo!-Dc-YbiQlo|y-yS%U-?rwi=w955
z_0wiVXJUnc+{YDpH)eA1tLvi{qMGdPbL%1T(~5Nkj$nE=ZHFcLCB&CT?Hl1@b&dsc
z2`A|!fB&5$S)Zd-LI3KX!cq2s=V`UjaXxd^T}ervM!3YFH`>+2#Iwbhn9rx{-$~zJ
z-5I6;7O~<{f5xO5Iu@6T3mnO8$aWr~YP7x?Stn;DLPa(H6%Qdu**h#xE`#<-`j;$E
zcg2?6Rk99;4FA_HHRq4i#Q#Nv9#9~l|MXh^r>pXx=0e}u6rgWxXl!Bn&p%U?bfpIv
z(R^lV+jgacwEI>9z3yZM!6Cikk&V*q)ECIeu$_OlA8FWJY?$R+Iscp-v}oYk^14@n
zmsi#F5yDr{8Myrz@mLL!pY>+rn&gGm0{imv)#Ppm=QS_-clJ&
zza()kJM2W3XayMpg(VC+nB9En{53_M$Q=z`5 {H|6bO-iLuvIGgk4h!GQSi9AC{
zQMH9MXkPQfZTJj!XwNO#c9Kun;M69So&bbD#ITyKEKbv3*(`>B6JNio!oo
z7TaTcijqqH{4c6_HKU4+85{_x2nh%X<^MOlv%ay7rK#P2z^D>+ZTk&2G~bt6qNXqj
ze>3wfc*asg;SP|CKvxT;%RWXhEv|-)(d1uBwp~O&K4EB735nT&bOM`%liSU1=YrMx
z8XU=g6$ECLmwi@)NvA2OUn|jJp+yBLl~(Rp1vNO6jOjut_7uYGTnHuI(ed$n#Xbtb
zq@qU!_Kx;>?I&8&3T+ZoyBUbz&Pt+cb}D}39K5VD>+|Rc;!02XQ=zfud}fJT-VNQ`
z%)&;`cX($HZahI!lMJVcDuSgN{sjsd67^+j)pbCY@NIkmo49*_trUb#p)%fY(WT`<
z`s&77)WFgb5ED#%nm>(KQjj+Fqf*qtUcP^cUJn)GSxmFXSm2*xJ;9PiH*42Jt0Us4
z>WZF^HQFj_a
zk#EJOD*gv$A$p&Q#RY|521@*U!ScLAL(S-}HX&r(L>~}k!J(s|c6!6FaW2Ewa1@zX
zJX%NceM2HfhgUMh!xr4Lp=yf`aCHsK46t+1OhZy>JCxH}sK_=ms#z*{#$+#DR{nVM
zPZ7b8RMz!+)z9Iko!Umi+DjB3Wv^0m>M~F^>y_#|f8QO4mw2@-(5RGWr@LdqR>{CV
zAQKfE!%NF1Bkt2lOj%oeXt7Fd^&hXQfim#tv!!sTnULS!&6fy5(;w-e+(tskvyuqA
z#L}v`t5XR(evn#GwO8w_`v&P``T087#2OqlmwNvo_vV_7vpH6B{wkG9azu{n4_f%s
z*VWGny0FiPEU>bupqGk1B|LF;SU{jk)-=HMt2GDNvqUx8L_X4vWwz7~1Jj<8CZdXK
zH9Rl|z>Lp~QG|+$w`fhviM67&c-P15vfyunYqxbJ2|nxdKMj!f!Oy=l?DA*o#t?8wBP7&`CNycZCI
z2@N~ic7o0!kB>7=+NmR_#Rai#IMlS6LaSVBNwY{sngwJFWfXI+MiDhpi>0|Oy(x#}
zg8$mXQ2`+~M;3Xtnxn|9(P1^SZ@$}U-rhZopxVrb`P1%5+OOG0`;t)MEskH{C1#y-
z+%xdIU6=}?u!O1y|0j&CtXl*rgO7Ae79L-YPUr^ab#q|e+2OP_RWM!cRJlI9e7!SMvfF0Te`fSK9(2jXkE;~bz<1*dF
z7?F`y&?N8{*41RJfpm9?{zf-X-2JMhOVRR)koF+-^d!ztSM~4YW8FhFn6rh27@1_#
z_8HpqVsuuir>lELj~~XHAMpRpZU3Sw(7%f7f3AO!|NrDR2M>CHhl8mJ=zoP{RLPk?
z^8eNt|9k#-?SB^jrzn=D8J|(5ET|q#I?RR&vs_^9HopeZ$x3g|hXF33YTJ`>_*eN{*#}^Uve|E95MI+S;Nu
zOpx2+6ewP#K!M^kK+xh4yto91P^7p!6pDKb1PT-{PKy<2aV@UF-Q6itc=XES-n{9&
zWX_z)Ouql@$>glP*1z`Ic2Ei3Pj2C@!Wn~PW+N#Q1E6Ljlo`o=>0#8VXdo&T{dT$c
z<3;Y4E~xFReK;$TM)P_C#s$m{^XR9G9BNj*45ZeNDk#X^*Lz=lE5Zk&*tY}m)GfZ2&r
zY`jVUpTca8><3N9zR*eXl(eK~8_x<&wvFY_+jI(I%zHo#Is_Nwp!U9?d_;?<6iC=F
zE6#nKs>R*!q>3I}HWqex7?CO;9gk10syN_~j`uD#LqG}r01X{40RWzU_Y|Zste^|+
z5aTT_5zR7XsHZn)N*qIvWL8(DC`*4+hh`)5IE&6U6aKOA(NhM=*-V#M@rlDO688%&
zY1^1VNd=}9at&vhmTGFBC`~+(23Kt_z<>)~HcQ~!eu+fL;dUiNd+r{g^XDF8*
z9Y)*ehN-QP$ahXMV}Tpm6Z1(XxjuS)$u>j=d?oe=@Saby{yjz%(S={$S#RMg?NsT%
zR?oSXzMrqP`CVf!vQhEdJuSnH<1dNP&G9MxLO;lfCEF-U^b}y%h^>zmIJ7RJ$gzZ?IA5rDudtmf=|Mg=epVHeM0w|C
zGO?>6$}xlt)(r}Ip#l;`A*j?@FB)f
zXRCNFL%b~MO{Wf<$E~pKIJW;tn>m|Ivvmzn^c)w^J3+?1mp5*J#{6Rwo5RL_m6;VD
zP5LSBXJP&;*A&${bF1BA$8UbtK1yrgbkNbt=*sA_*T#BeMAiE_)`UK^f~A?hQsG9@
zpUYk>FJ1TYG~+S4U<#{LwmGr%r|<7
z`J7j;R1}GNQ`7g}w{fjCw7wSHu0bJ4hBhDLgD;N8`w27;xAnJl
zl$ov{hC6HFwO_Q;l=855%5WH6Gg2X66c=DKet;4|V4J;`HxxM_*385{0M-!8KR2+~
zHQP~qXeBmzmbQmIX)YwNj{V2%MuC8J>168c#(WReu@^3GZA*E*5QSU89`ojgu2i90
z_e=X`MwY-*tyvA$K3+?~+MU&kDL4eF7cFqQJLUZ3T&1rI0En@UYur8IZ=rY&Hlfh$
z<5)X~{Qz_*)Hk_2%Y@Lml-{uH9T#1)l$yI9W01^u28CVI;x|^$I|ra&qlH;hj;1D5)_IvIM%T#UFf8(q||JWz$`wPEfft;cL7X@a#veW|G&D7wz+#nyOjK
z%zIU4MHdX7@xCbkorhg)9yyJI%S45f9#Ef2DbHmL+4N&;h{(dOm7uYa2_a#o}pg8f}gB+uGWljtPd_
zuSMB%xEDkzjR=lwTP=Ly*Y3(>zdl2TrqhT
znI*A+Y4R|tr|+i1Bw>r-OgMA25Y5AH__AySauYvs^akvktW??vr
zJ|rjC(dT{_a)2BiHS!X)PJE2wv=vB?QL|hT1G=?orP>yTo%qq$$p9Us{_1^&)g#o_
zGqLc`s5vmmLm1(BynAx-8kcVX>7qlBL3wLG378p;&Mhl0lkW4ofem~);doe46}oQc
zQ-;2vp~j5)+PDq=C9<$eHZ>+?pQwtO9%3@}R@voIlmcVi)@MY@Z0-rMgiBUVrCn6n
z1>=_I6-9>mpKBUdU1JZ;@z&@sIqjvY$pCPV
z@GZz8H`DJrv$PslB%!iu-|`-3{Y$mvP$ui1O=2
zYL(U$nOxIn9aJm(fng*sR2)Is{vjq9rL>eChdb^X-|FO_keeECq*)5ynB*zpyc1mO
z0d+`U3V%&R?|<33g-051F?S?pl<8$?KPwTM_;8I@TzKD@PW^*72+mc!q@w4Tz-$y&
zOJwwPsLY1t;35RKQ$xOzNWAGC?$lLW2UmHn2ySr~_YdKUMgSeba!>NwLOb=U>K8>z
zH?n;so+FX{xAvIi%;HpvT~V(p@MrYz@s!JV$pv2IjK=RUbpp6v0N;2gzv1I=`o5cO
z#Nq^`52h2Bj7P{Q198ZeP+
zLThY<3SSQK?G9R;%r_Lat|-1&RRfhZ)>bB*fmN
zp}f*@U<#%^Be>hJM|lEaj*eiL^fTXqkV<+R7Ia2@%_?K9fE8t0Xsc;)G21NR&JzK4
zct#3#CQ-})4PGD6QM5BO>&alPzLis~)e9xl@Svp0_Z`pw=puCG*ds7Xd&`0aUp*ni
zw;17_EId79is*YBt1qPV{lybI`M|b4rgN(z)RM+B{3iA2xiT4wy2b<#cVV*
z&@>CmkkudUe4mT1PbQfZh}Li;NEBdh`%HIFGHp7)o|r0Lp)f8+
z|4kFkL;HffV>ou(Lf%3v*IVA_m~e>Win0k~I1A~H(dGP)mh+3kl}hJbyZWllBCPR7
zZ3FFG90SWw4;3|EuTIKt^v8;HoDV==nQ8`pb;?bH!EYvx;-=;2TCknoD0foWl1mHH
z0>U5EgVrwF*
zWa>FZ<(Df;|F#W?W;tJ!tuE!43O?Fq>w&t?E0@FH0W7?me4-8t=No$
z)#?J1T0zbNOFfuq?~6;*;Qv0*aDJAx)Iedtj=qttWwuBn&F@g{Q-?(>uc`&n&rm_h3#`cgRbWm8-^ZkLbClD
z1mo1En%k|K()$xRGql1==iVZ}kXz;FbMSX)*=feqb~;fUcYTr1E_8-KD06#X&P}da
z$Ji5FhYNbh=s9!Ezj~wDc6=GY?b#F@^l1X~`TdCmmWJX5(@hU_z6V~YNsSym2eQ^y
z0NA3LV~StD>%7J^_6KKa9Lmd)9)$s*PUEg9&iW+gWV{thUVe{wDMrZN1+;sbIgP3&g1SZJ@Xva
zBJh%FuBU@9JXtI(O~UuTqY_(Mi@x335a~8aLZbWqsGMx=46Myu%&gg*+?=|fvM(Sb
z%v4I*`u(oAZoc#FZ1w2(Ix3RlN-7f0!(E>b
z-y5xH71Swg1$c2iE_^8y-P~t_?_%oTA_sxsrz(GZgH#$C5}VFvpePt@|IF06GR^7i
zbPV8&F0RkJ`(W|=sDpT|GIZ7Y+2vH@!*8KLk%EBNu_JS17FX69?Q)?#uDc_~N%&LY
z))4X%(hj^^sotbJJ9XsrtE^uf;=3oA<`Fw693|B?(=Ca86_
zst#t6?^jLzJoh!qDHY#*=meG=f%IHw!W1B{%UvM=5H;=X-VS?B5v}O;RJI+M+;W~f
z#6u
zgjotaiiFsU%=PTR)*9l>#Q$!eX
zv&z3vB&2MA>)WF17yO^CD-m(TC$I1DS>nI(|9uV{kwtvo@s7>D4Xl4&`cL*(Ese+`
zuEf4$r5OLs{%VCGvWV*#?pTT2YW~-C|FfzA5l8IB-{B2Bf8l?3<`F@}Zs{GU!S@%4
z*gHj3Ky3TnDfILIufo5YfQbCB@BiD=zT>$>{^I{}xDiQ2hx?Ay|C{{B??xmME$TZG
z{x|uLVU0*4+ADXYy3}8z{g>H-2qQWtcX0JB{QvtXh}}P?%ikq`<~c4E3zuGqSg}`
zk(sq3-nEvz6bL9P004me+keW-wT7)`A_4&KtN;Mc-!}%fwsy`2&L+ls&K~wAPV{kXzeMkC>9Q6yYE(W(&s6Jm%#K6TzQKoZsA
zAd-M6BBqae_1q2^G5JUwb54aOfv{t)MSBBAMSf`xpl?n>%zrIYU-@OK5I^d#SAbEs
z?}-dGqi43SF`yCzC&28LPGM-srR0DJH{`x$T;%chOzD2FY^?ZodVde3>nv6>dQDYE
z%26?zrinIfmbp&yv4~b=su?|7tnEsE)+lZ|=cTz&;tgM7kACRE!}wMJ`7*>S854D*
zREOTcj_K2{oz56N>o~IM-(n!8L_iQ*g2G1oSf?n21o~{4#L$=wX`{A^Zwn}ETJNr!
z?GY<~j_4}uEH*O{95_zakc^jkW~bBM#?9XDFCyKwR2cs%7AivU7=Jy!`&Zpzk_GQe^PI>-FI?SU!!qU|}qpVXMYIfP76UjO#q(k{@U{gQdB%fXb
z+=)1l=TENH-7f~*lzVgQ5nuDA2Bf3mI;h^@Zx^)Tn%}D?aEhG=Dc@fX8dz(}`vWY|
zqkkk9_oDcP_2y=*W`pS~;KTV_3X{QbW&BlM3Vq;kUjyg9b-g~M_voMz-q*Pw>?395T$Nfw*)Cyrkk$Dmr0Hu!3nO~&5yn#s_q4Z|?
zzkXd1`{VK$b>+}v6tZPza6+URah#5Hvp9iQdQhtaMbb+F1p=RnT3GM`384ib(Sl~-
zESxqbC5f_d*{GV$}!WC&802uw^G
zuZc%lLT9pv+L;^|hU`Fb`wo#ws-R4iL7LNqU}D0npot)E|%eJZ4E
z+|en&LGE9S)b}K~ZPcgUU)xvJztkZP>>)yA
z#xhn{Ne0bSf>PmNg7u?!nHC$iFE)Vt)WR?VLl1XXCuMKVn2@GhaB85qKa``YjJ3HO
zVelw;mXr%;qN<3`Ct4
z77T~=-czg_Qp90HvR;O^H=vbWx$KuXoJah{(7jmLL^gGS1_o?)aSebn%IzI@D#6CM
zg9@pNveY2DcyeR}qKu|&p7k#^##A;C$U+C)hB4ggWdrpGft*g5nobj;@C&dRrdbb~
zlfkFJoyNYJKuu4S)y6Np;Zso{K}lZHmsRRWf}$+(Nh(8C_bLYIekBB!6Tx+G2?W)+
zS|Ca*znjaGr|*dP=zbNPD~X&tiJUiPd~;2lml|Kt;WFs@-vMCfi%SULvz!=N-@+*3
zLnXJN)6Poxm*D7abENNCH~Z|S2uuvm@xGQ|am{ac2FJ1w2%_(>6Oa;N?CsKo1^dn9UBjG@E5y1)yLyXT9w1c5o!qZ5RNwturFlOxk{HRz58PS=(
zT&~saHq03gBlJqWVPJ|`es+e4klzN8t2a0L9@!Rxh82YVKI>2ZiBVmoc>~L83qvt{
z{)G(t6w4X?gt}So7_9VaopMwn2mJ$XkspvV9lZj%X@~;bGAe-(D-}DBmZ!wXs
z*Sk-v3zyP~j=HC0mdbqiWwpY4-d%=M3Uj2Yv%Nrjl68ed+eA@i7f{k}69N(f-dDz^
z8XdkGIqn>^Gy?o8-kp|eOR<3!`R`1E-!9St1^UjIK|Fs98VCiy3#lL2UsBH--*GjrNhCqxVPx5nW4
z;h&EQN4eY7&5|H!Z$OL55x$HHQ(ek)CiK;NgJ-u)=(;F`K?I*vtFBeFM5p|D@-lev
z4|;!pY0a^_=b@}Z@L6C^cBiATS)+*;)%F7<5@IZR5HE9UFL~jpG{h|~0`sBcW-9>cBI_(bZz<+(IPU3b
z1n1=BH7ciX%9SXCEmH+vpeJ`
zQfDYM%qcN}#6Ixg=1aPFcjAe|VPT}Bcxu^Pn$aN1&{DFSx>DG3(dssj7mKMz$Hyx?xH6-b(
zTA1WkE1k3xHS&4%%&4Vv>YHJqCXZM+gE7vf`NyL|!rk`}Anxw(anmjjNu_;Q>BWzy
z)kVIau?jZXX1Fbg%Hxn^Im&?S2C$@S<=dBjVza0~3!h5o7lP-cG+!MVnd{C|wZhTz
zJxcdq6FJORX6u6?NW3`|N}_f#g>QMr%yKGx5_^p
z6G92!I5MbQG`OSY1CfE`|IH)TcEM_2uG~SwrxBGU9bn!XVguvN*|I34YOx^>&mWn0
z4zIuk@2e`+01>NV8H60%Hy{2}wm=?o!g>SJWkeUa6BSX>?)FH#)`9W
z<^Xx2Qp9KxSV-fSKW^FWk#+ZlNzbc2$Vcpt%7bmz(ut$z6|uh7%3{wm+$qrsM1%;|
z2ed`Y`0dYzL5iDm<}82~CnU`uljJbs4aC$7WYfB+x<$+x3k|sbR*^A-oXdw0+Y#0L
z%dO8G`!7rI(X?WO?|@hqTWSMIJxQ-mB(J{m?iKRuICL>{(BKpnpi_(^+fx*o+uT~+
z!o3K=;cnH!knnQBA4E~{*qv5L49k$Ce%Mfw^k&Qj<%9ABH1iDpodZ-zS`G{&=_)g=4|PsFf&*0FEV`JkQc)NPpgsjKw&m@;Wm-9?g{|^afwAZ=jledr
z1laeZ&PHL8T5Wvd#p@}X)zzOKx?xuVTkq`Gpi2wd2=;(x3^akf}C*BY!G%X
z?+1n(+;87N$*(>ZF@Tg6CT@w`f5isU4DW$$4Y6q
zrP{fPzec4ySsu`^sH4Z{Gk-mEN^RbQprrq#E1ZKD80(`Q$Ce9><$UxRaaKiioAX%y
ztumV)h%yYmLn@!iH*`HMtlBfMAWM=wcQwxM-2a*F6_`FasyEA6T3~Fh=@O=6IbE`!
zyE~+8h|#4bncW`QuVJNJm)G9rP=3}8TEv@!2t<~GO{|i&I^AE~!nsL?YGM&_K@FPy
z>@$RZi%bsSaRC;EgFBLw*NH#XHn<>uB-3Vg0SD@85e2mHh0)fVSllSS<|LA4U}A!_
z6Pz~+8cty(AxlFn(vg;kO5ED#p@w%p(6nS{KX4t9hB^?q(vk^Z2|LC6A-GU@8~2Mv{=zc
zktXJ5Rxk>L-XC<6qwRUDQ?V-LD=w6t^+dT9IF%;{eoeJUp38wf1S62bm?v5yLXh@h
zSMxI5kd!ygd9LAO`!lzJwom3(xPsgutE8cDuC>+|pm`DPjA3=ZifIFa7}2-9<+o3h
z9wlPlSA{q($*VlBpWz-{vBylq&OjY7JEUdRXwRe$K9Cq&-Gg)So-rdYU1dA`=zBm$
z_k*Ejq!`40)?|B^(iBru#>&ZdkkfR4rtSxu9&e9g4Z>MIYY8`L$RZ0eBv2C0i^Nbb#oVB-
zu03O%V
zx46yeNT`w4KwgkF5F5`t$m+C^`>qVTLD1Y30PfbW!-|+kYZ&)d2Q%0$(rbJ$blb;Ral>>R=;zt)3x;Itu^VdS1nDzsL=;&N1;`yF
zfOh>ED`*|Xi{W-lIo?$nb%QLPL}&?~6JonZ(766=EuAhd&*%Nb2Q`juN2$l>l;Ch=
zP)jowFX4(%v0LDzrBu0^c(cM>PSNM??CI!8)nZq;E488Kr=a2ng(vxbd~;W*ylHud1U}pjWWuE1+9+&Ni`3
zhVyC^$kKIgUmR#30a0S=Vk-+}$2zz_q%%x;48?HO?OhyP{5LVnA~myE^>4##2FH(}
z8=*s>KwoLR=cVRutQxSxiq{SNX_P|F@N98D@p(M1_nCP%|77pHZ;^rS1pI@irO=nJ
zXsDz5zq1EtlQBzcO1%Es8rn&s1*cl0Fmim)vAI^MG@`1r+ehcWKyJ07!V*_*DTV+C
z6^;|o*c39|SSmRQLHSTjxiP$3Uj?rc5cHO{nfp;CM_F$RP4dSv5=P6wr{2M|3
zKS>&YRSW>|KexXP^KbvRq+#zt_m8$=3;zk3|7{4X`>@=l`zAKil-?v
zP7I4Kf>UpGDwnx!*AFP_cvTRl`7!E^H&1}$R#Mp^vt8rvoWUAXsFjuNptpYbvmt#N
zBsH}t+=l5Gs;R3a|K!Ru#HN=SvCOe_AkDneX=*<>%6#}&F+nfl!zvm1a=y^6+B}C5
zd!ooHBW1GK&p`Glco<|=EQPC7Mq%bLSkH!F`PT{A(gO$=@Mxk)y_y@Lt<#Nko1*tGuv;I^`A4AQ<
zyT(GSt6WPX`~;``H{4ge0k6sA+tfz=g6;{*j9W-9`Lk@PMl%^3!)KfOL9*P74)jG&
zHV2#g)y68*a1#P^_8cjh}_D+2w
zOlUtCmSbY_C3v06@IOC2y=N$DdB(XpIe`=~LOs^ngsSbDyDVL@hE%M2Gm6g&+2LmH
zI!1;|inC&JfyQBwo^7wY=2lptQQX26QimyoO^{01&dO)kiKR6trBwu$M=Wm)>c@M$
zs(x$pZ?UT0l)7aX17u8o%y7?f)0qXp!D~V8WNqK^mFov3dX;fm8@dv;q4si)6nl5#
zbf)ZX>A&D0ddYA4>S^L9L_xN2uA<+Vab8&Hj_(y{Y0{?30CPTW;xd6fY+CzVCImw3
zvnelN))lDbE~3a#))3I(CHjvKugGCiR3Ci3+m*IAwa)zUXoe>VLs`oz#wr=gP=}9e
zEGmYNl^4cwn^uL(f5RRaJGDX(NIqiWCA6>xr|C#mlZb+dh;C-Wi_tK)j9QYlK=FRM
z^)ZUaCrp$ND>&?!Gk+ik`D!V1w-#G2Rry7pxoJdUCX%nYRMK7;QB$f@(pl+Qm;0l{
ze>)#N2P-<8lDfENg+8f;_@M^=5Mqy#2;i*Qtk`ZL51RRI|A$@D#rt(wxgLneuZNmJ&SJXo>JlX9~FA1bLNq(KqHyxr=T
zsLz~b9_~o_oN);hpG;vLR=zxpq+yEg1L!MTC-16T)Hrx%?Op*#^#%v_AzK3e-L!tX
zjxLAQnbyKUkGrFke=08;o5rVrP)l;tb+t_DRWG4h!Q@BgXczJY2NqvF&BZLj#3uK_
z5EnZ2^MblC3=)(3AcS{zSLE;8XiewXuR=Ph%u+!j8hd1vrn{
zi!VC(?VqEVc+U6vRDx?{d?XGuG4ZZcbS|ivVRq%a5Mi&KS1bnrg5pA|R(HRw2wV3m
z7}^uTVX;-j%#0){V$iJt)^Jop%OKjq6I=)_;0GQZYaoO;@{tK9o8D8eYLk9)$P%9~
z)(TbmMO(8SPn!6IGYlLpI-c6nb`dl(@|G(*GQwLmJig%{gM#gemiTcIBNeDX&*lz{(Y5y`*!dVv!xXNrX2DaRaX
zY%gP0Tyb^A=+VYHy-F1=`mo}&-8s@>O-bfl_`h;(0S`YlQm-N_4V8#y%~?9~d^-ZV
z6jG#(Nk_gFizQt6P~P_hZ&hoSq(^yHQmT}hYS==U1euMozffg^7CgICk4(vY)tVC?
zq$AW%N~laS)dJ1JC8O3U9CB2t|Hx$051i