libs.registry.member

  1"""
  2lib/registry/member_manager.py
  3"""
  4
  5import logging
  6
  7import libs.global_value as g
  8from libs.data import modify
  9from libs.functions import configuration
 10from libs.utils import dbutil, textutil, validator
 11
 12
 13def append(argument: list) -> str:
 14    """メンバー追加
 15
 16    Args:
 17        argument (list): 登録情報
 18            - argument[0]: 登録するメンバー名
 19            - argument[1]: 登録する別名
 20
 21    Returns:
 22        str: slackにpostする内容(処理結果)
 23    """
 24
 25    resultdb = dbutil.get_connection()
 26
 27    ret = False
 28    dbupdate_flg = False
 29    msg = "使い方が間違っています。"
 30
 31    if len(argument) == 1:  # 新規追加
 32        new_name = textutil.str_conv(argument[0], "h2z")
 33        rows = resultdb.execute("select count() from member")
 34        count = rows.fetchone()[0]
 35        if count > g.cfg.member.registration_limit:
 36            msg = "登録上限を超えています。"
 37        else:  # 登録処理
 38            ret, msg = validator.check_namepattern(new_name, "member")
 39            if ret:
 40                resultdb.execute(
 41                    "insert into member(name) values (?)",
 42                    (new_name,)
 43                )
 44                resultdb.execute(
 45                    "insert into alias(name, member) values (?,?)",
 46                    (new_name, new_name)
 47                )
 48                msg = f"「{new_name}」を登録しました。"
 49                logging.notice(f"add new member: {new_name}")  # type: ignore
 50
 51    if len(argument) == 2:  # 別名登録
 52        new_name = textutil.str_conv(argument[0], "h2z")
 53        nic_name = textutil.str_conv(argument[1], "h2z")
 54        registration_flg = True
 55        rows = resultdb.execute("select count() from alias where member=?", (new_name,))
 56        count = rows.fetchone()[0]
 57        if count == 0:
 58            msg = f"「{new_name}」はまだ登録されていません。"
 59            registration_flg = False
 60        if count > g.cfg.member.alias_limit:
 61            msg = "登録上限を超えています。"
 62            registration_flg = False
 63
 64        if registration_flg:  # 登録処理
 65            ret, msg = validator.check_namepattern(nic_name, "member")
 66            if ret:
 67                resultdb.execute("insert into alias(name, member) values (?,?)", (nic_name, new_name))
 68                msg = f"「{new_name}」に「{nic_name}」を追加しました。"
 69                logging.notice(f"add alias: {new_name} -> {nic_name}")  # type: ignore
 70                dbupdate_flg = True
 71
 72        if dbupdate_flg:
 73            rows = resultdb.execute(
 74                """
 75                select distinct name from (
 76                    select p1_name as name from result
 77                    union all select p2_name from result
 78                    union all select p3_name from result
 79                    union all select p4_name from result
 80                    union all select name from remarks
 81                );
 82                """
 83            )
 84            name_list = [row["name"] for row in rows.fetchall()]
 85
 86            if {nic_name, textutil.str_conv(nic_name, "k2h"), textutil.str_conv(nic_name, "h2k")} & set(name_list):
 87                msg += modify.db_backup()
 88                for tbl, col in [("result", f"p{x}_name") for x in range(1, 5)] + [("remarks", "name")]:
 89                    resultdb.execute(f"update {tbl} set {col}=? where {col}=?", (new_name, nic_name))
 90                    resultdb.execute(f"update {tbl} set {col}=? where {col}=?", (new_name, textutil.str_conv(nic_name, "k2h")))
 91                    resultdb.execute(f"update {tbl} set {col}=? where {col}=?", (new_name, textutil.str_conv(nic_name, "h2k")))
 92                msg += "\nデータベースを更新しました。"
 93
 94    resultdb.commit()
 95    resultdb.close()
 96    configuration.read_memberslist()
 97
 98    return msg
 99
100
101def remove(argument: list) -> str:
102    """メンバー削除
103
104    Args:
105        argument (list): 削除情報
106            - argument[0]: 削除するメンバー名
107            - argument[1]: 削除する別名
108
109    Returns:
110        str: slackにpostする内容(処理結果)
111    """
112
113    resultdb = dbutil.get_connection()
114    msg = "使い方が間違っています。"
115
116    if len(argument) == 1:  # メンバー削除
117        new_name = textutil.str_conv(argument[0], "h2z")
118        if new_name in g.member_list:
119            resultdb.execute("delete from member where name=?", (new_name,))
120            resultdb.execute("delete from alias where member=?", (new_name,))
121            msg = f"「{new_name}」を削除しました。"
122            logging.notice(f"remove member: {new_name}")  # type: ignore
123        else:
124            msg = f"「{new_name}」は登録されていません。"
125
126    if len(argument) == 2:  # 別名削除
127        new_name = textutil.str_conv(argument[0], "h2z")
128        nic_name = textutil.str_conv(argument[1], "h2z")
129        if nic_name in g.member_list:
130            resultdb.execute(
131                "delete from alias where name=? and member=?",
132                (nic_name, new_name)
133            )
134            msg = f"「{new_name}」から「{nic_name}」を削除しました。"
135            logging.notice(f"alias remove: {new_name} -> {nic_name}")  # type: ignore
136        else:
137            msg = f"「{new_name}」に「{nic_name}」は登録されていません。"
138
139    resultdb.commit()
140    resultdb.close()
141    configuration.read_memberslist()
142
143    return msg