refactor: 移除PostgreSQL支持并优化数据库初始化流程

移除PostgreSQL相关配置和代码,简化数据库连接逻辑。优化数据库初始化流程,避免重复创建表和插入数据。改进Redis缓存配置,移除不必要的过期时间设置。
This commit is contained in:
zhangtao
2025-05-23 00:04:13 +08:00
parent 27fa41937b
commit cb138adc9b
16 changed files with 107 additions and 171 deletions
@@ -98,8 +98,7 @@ class LoginService:
os=user_agent.os.family,
browser = user_agent.browser.family,
login_time=user.last_login
).model_dump_json(),
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
).model_dump_json()
)
return user
@@ -42,7 +42,6 @@ class ConfigService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
logger.info(f"更新系统配置成功: {new_obj_dict}")
return True
@@ -78,7 +77,6 @@ class ConfigService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
return value
except Exception as e:
@@ -30,9 +30,11 @@ class DictTypeService:
async def get_obj_list_service(cls, auth: AuthSchema, search: DictTypeQueryParams = None, order_by: List[Dict[str, str]] = None) -> List[Dict]:
if order_by:
order_by = eval(order_by)
obj_list = None
if search:
obj_list = await DictTypeCRUD(auth).get_obj_list_crud(search=search.__dict__, order_by=order_by)
obj_list = await DictTypeCRUD(auth).get_obj_list_crud()
else:
obj_list = await DictTypeCRUD(auth).get_obj_list_crud()
return [DictTypeOutSchema.model_validate(obj).model_dump() for obj in obj_list]
@classmethod
@@ -50,7 +52,6 @@ class DictTypeService:
await RedisCURD(redis).set(
key=redis_key,
value="",
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
logger.info(f"创建字典类型成功: {new_obj_dict}")
except Exception as e:
@@ -105,7 +106,6 @@ class DictTypeService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
logger.info(f"更新字典类型成功并刷新缓存: {new_obj_dict}")
except Exception as e:
@@ -201,7 +201,6 @@ class DictDataService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
except Exception as e:
logger.error(f"初始化字典数据失败: {e}")
@@ -244,7 +243,6 @@ class DictDataService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
logger.info(f"创建字典数据写入缓存成功: {obj}")
except Exception as e:
@@ -283,7 +281,6 @@ class DictDataService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
except Exception as e:
logger.error(f"更新字典数据状态时刷新缓存失败: {e}")
@@ -299,7 +296,6 @@ class DictDataService:
await RedisCURD(redis).set(
key=redis_key,
value=value,
expire=settings.ACCESS_TOKEN_EXPIRE_MINUTES * 60
)
logger.info(f"更新字典数据写入缓存成功: {obj}")
except Exception as e: