| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| from mod.base.msg import SenderManager, WeChatAccountMsg, update_mod_push_msg |
| from mod.base.push_mod import SenderConfig |
| from mod.base import json_response |
|
|
| import public |
|
|
|
|
| |
|
|
|
|
| class main(SenderManager): |
|
|
| @staticmethod |
| def wx_account_auth(get=None): |
| return WeChatAccountMsg.get_auth_url() |
|
|
| @staticmethod |
| def unbind_wx_account(get): |
| try: |
| sender_id = get.sender_id.strip() |
| except AttributeError: |
| return json_response(status=False, msg="参数错误") |
|
|
| conf = SenderConfig().get_by_id(sender_id) |
| if not conf: |
| return json_response(status=False, msg="未查询到对应绑定信息") |
|
|
| res = WeChatAccountMsg.unbind(conf["data"]["id"]) |
| public.WriteFile(WeChatAccountMsg.need_refresh_file, "") |
| return res |
|
|
| def set_default_sender(self, get): |
| try: |
|
|
| try: |
| sender_id = get.sender_id.strip() |
| sender_type = get.sender_type.strip() |
| except AttributeError: |
| return json_response(status=False, msg="参数错误") |
|
|
| sc = SenderConfig() |
| change = False |
| for conf in sc.config: |
| if conf["sender_type"] == sender_type: |
| is_original = conf.get("original", False) |
| if conf["id"] == sender_id: |
| change = True |
| conf["original"] = True |
| else: |
| conf["original"] = False |
|
|
| sc.save_config() |
| if change: |
| self.set_default_for_compatible(sc.get_by_id(sender_id)) |
| return json_response(status=True, msg="设置成功") |
| except Exception as e: |
| return json_response(status=False, msg=e) |
|
|
|
|
