首页模型

zhaoqingang

2025-04-11 fb4beedd7ee92777711a854c1c264db460a38d49

 app/service/v2/app_register.py

@@ -1,6 +1,8 @@
from datetime import datetime

from app.models.public_api_model import AppRegisterModel
from Log import logger
from app.models import current_time
# from app.models import current_time
from sqlalchemy.orm import Session
from typing import Type

@@ -14,22 +16,23 @@

        return session

    def update_app(self, app_id: str, status: int):
    def update_app(self, app_id: str, status: int, name):

        logger.error("更新数据: app register---------------------------")
        try:
            self.db.query(AppRegisterModel).filter(AppRegisterModel.id==app_id).update({"status":status, "updated_at": current_time()})
            self.db.query(AppRegisterModel).filter(AppRegisterModel.id==app_id).update({"status":status, "updated_at": datetime.now(), "name": name})
            self.db.commit()
        except Exception as e:
            logger.error(e)
            self.db.rollback()
            raise Exception("更新失败！")

    def insert_app(self, app_id: str, status: int):
    def insert_app(self, app_id: str, status: int, name: str):
        logger.error("新增数据: app register---------------------------")
        new_session = AppRegisterModel(
            id=app_id,
            status=status
            status=status,
            name=name
        )
        self.db.add(new_session)
        self.db.commit()
@@ -37,14 +40,14 @@
        return new_session


    def update_and_insert_app(self, app_id: str, status: int):
    def update_and_insert_app(self, app_id: str, status: int, name=""):

        logger.error("更新或者添加数据: app register---------------------------")
        token_boj = self.get_app_by_id(app_id)
        if token_boj:
            self.update_app(app_id, status)
            self.update_app(app_id, status, name)
        else:
            self.insert_app(app_id, status)
            self.insert_app(app_id, status, name)


    def get_apps(self):