group_manage/ruoyi_system/mapper/sys_price_conf_mapper.py

# # -*- coding: utf-8 -*-
# # @Author  : YY
# # @FileName: sys_stuff_info_conf_mapper.py
# # @Time    : 2025-12-22 04:49:51
#
# from typing import List
# from datetime import datetime
#
# from flask import g
# from sqlalchemy import select, update, delete
#
# from ruoyi_admin.ext import db
# from ruoyi_common.domain.entity import SysPriceConf
# from ruoyi_system.domain.po import SysPriceConfPo
#
#
# class SysPriceConfMapper:
#     """价目配置表Mapper"""
#
#     @staticmethod
#     def select_sys_stuff_info_conf_list(sys: SysPriceConf) -> List[SysPriceConf]:
#         """
#         查询价目配置表列表
#
#         Args:
#             sys (sys_stuff_info_conf): 价目配置表对象
#
#         Returns:
#             List[sys_stuff_info_conf]: 价目配置表列表
#         """
#         try:
#             # 构建查询条件
#             stmt = select(SysPriceConfPo)
#
#
#             if sys.conf_id is not None:
#                 stmt = stmt.where(SysPriceConfPo.conf_id == sys.conf_id)
#
#
#
#             if sys.module_index is not None:
#                 stmt = stmt.where(SysPriceConfPo.module_index == sys.module_index)
#
#
#
#             if sys.category is not None:
#                 stmt = stmt.where(SysPriceConfPo.category == sys.category)
#
#
#
#             if sys.attributes is not None:
#                 stmt = stmt.where(SysPriceConfPo.attributes == sys.attributes)
#
#
#             if "criterian_meta" in g and g.criterian_meta.page:
#                 g.criterian_meta.page.stmt = stmt
#
#             result = db.session.execute(stmt).scalars().all()
#             return [SysPriceConf.model_validate(item) for item in result] if result else []
#         except Exception as e:
#             print(f"查询价目配置表列表出错: {e}")
#             return []
#
#
#     @staticmethod
#     def select_sys_stuff_info_conf_by_id(conf_id: int) -> SysPriceConf:
#         """
#         根据ID查询价目配置表
#
#         Args:
#             conf_id (int): conf_id
#
#         Returns:
#             sys_stuff_info_conf: 价目配置表对象
#         """
#         try:
#             result = db.session.get(SysPriceConfPo, conf_id)
#             return SysPriceConf.model_validate(result) if result else None
#         except Exception as e:
#             print(f"根据ID查询价目配置表出错: {e}")
#             return None
#
#
#     @staticmethod
#     def insert_sys_stuff_info_conf(sys: SysPriceConf) -> int:
#         """
#         新增价目配置表
#
#         Args:
#             sys (sys_stuff_info_conf): 价目配置表对象
#
#         Returns:
#             int: 插入的记录数
#         """
#         try:
#             now = datetime.now()
#             new_po = SysPriceConfPo()
#             new_po.conf_id = sys.conf_id
#             new_po.module_index = sys.module_index
#             new_po.category = sys.category
#             new_po.attributes = sys.attributes
#             db.session.add(new_po)
#             db.session.commit()
#             sys.conf_id = new_po.conf_id
#             return 1
#         except Exception as e:
#             db.session.rollback()
#             print(f"新增价目配置表出错: {e}")
#             return 0
#
#
#     @staticmethod
#     def update_sys_stuff_info_conf(sys: SysPriceConf) -> int:
#         """
#         修改价目配置表
#
#         Args:
#             sys (sys_stuff_info_conf): 价目配置表对象
#
#         Returns:
#             int: 更新的记录数
#         """
#         try:
#
#             existing = db.session.get(SysPriceConfPo, sys.conf_id)
#             if not existing:
#                 return 0
#             now = datetime.now()
#             # 主键不参与更新
#             existing.module_index = sys.module_index
#             existing.category = sys.category
#             existing.attributes = sys.attributes
#             db.session.commit()
#             return 1
#
#         except Exception as e:
#             db.session.rollback()
#             print(f"修改价目配置表出错: {e}")
#             return 0
#
#     @staticmethod
#     def delete_sys_stuff_info_conf_by_ids(ids: List[int]) -> int:
#         """
#         批量删除价目配置表
#
#         Args:
#             ids (List[int]): ID列表
#
#         Returns:
#             int: 删除的记录数
#         """
#         try:
#             stmt = delete(SysPriceConfPo).where(SysPriceConfPo.conf_id.in_(ids))
#             result = db.session.execute(stmt)
#             db.session.commit()
#             return result.rowcount
#         except Exception as e:
#             db.session.rollback()
#             print(f"批量删除价目配置表出错: {e}")
#             return 0
#