zhaoqingang
2025-02-24 f13239560d9a6888d3bf95699ed5fc10395b50ff
app/service/v2/app_register.py
@@ -16,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": datetime.now()})
            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()
@@ -39,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):