tasks.py 文件源码

def retrieve_channel_users(slack_auth_id):
    slack_auth = SlackAuth.objects.get(pk=slack_auth_id)
    sc = SlackClient(slack_auth.bot_access_token)
    channels = sc.api_call("channels.list")
    for channel in channels["channels"]:
        if channel["is_general"]:
            slack_auth.general_channel_id = channel['id']
            slack_auth.save()
            break
    users = sc.api_call("users.list")
    for user in users["members"]:
        if user["is_bot"] or user["id"] == "USLACKBOT":
            continue
        if not TalkUser.objects.filter(slack_id=user["id"], slack_auth=slack_auth).exists():
            talk_user = TalkUser.objects.create(email=user["profile"]["email"],
                                                name=user["profile"]["real_name"],
                                                slack_id=user["id"],
                                                slack_auth=slack_auth)
            # sm = SlackMessage(slack_auth.bot_access_token, talk_user.slack_id)
            # sm.send_text("Hi, my name is TickerBot. I am a conversational game on slack. You compete with your team"
            #              " for the best portfolio! To learn how to play, just ask :)",
            #              actions=[{"text": "how to play", "value": "how to play"}])
            # sc = SlackClient(slack_auth.access_token)
            # result = sc.api_call("channels.join", name=slack_auth.general_channel_id)