wanzb_v3_api/src/utils/aliyunpush.py

#-*-coding:utf-8 -*-
from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkpush.request.v20160801.PushRequest import PushRequest
from aliyunsdkpush.request.v20160801.PushNoticeToAndroidRequest import PushNoticeToAndroidRequest

class AliyunPush(object):
    def __init__(self):
        self.ACCESSKEYID = "LTAI5t8bioQxGXB1jtVugJcU"
        self.ACCESSKEYSECRET = "OdGWSBRjkJxaPjgmE38eQ8nzkI6nRk"
        self.REGIONID = "cn-shenzhen"
        self.client = AcsClient(self.ACCESSKEYID,self.ACCESSKEYSECRET,self.REGIONID)

    def push_notice_by_userid(self,user_id,title,body,params,platform):
        if platform == "ios":
            self.request = PushRequest()
            self.request.set_AppKey("333793060")
            self.request.set_iOSApnsEnv('DEV')
            self.request.set_iOSExtParameters(params)
            self.request.set_PushType("NOTICE")

            self.request.set_DeviceType("ALL")
        else:
            self.request = PushNoticeToAndroidRequest()
            self.request.set_AppKey("333793063")
            self.request.set_ExtParameters(params)

        if user_id == "ALL":
            self.request.set_Target("ALL")
            self.request.set_TargetValue("ALL")
        else:
            self.request.set_Target("ACCOUNT")
            self.request.set_TargetValue(str(user_id))

        self.request.set_accept_format("json")
        self.request.set_Body(body)
        self.request.set_Title(title)

        response = self.client.do_action_with_exception(self.request)
        return response

aliyunpush = AliyunPush()


if __name__ == "__main__":
    user_id = 15103
    user_id = 6209
    title = "测试"
    body = "测试"
    params = {"type":"message","id":user_id}
    res = aliyunpush.push_notice_by_userid(user_id,title,body,params,"ios")
    print(params,res)