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

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)
        self.request = PushRequest()
        self.request.set_accept_format("json")
        self.request.set_iOSApnsEnv('DEV')
        self.request.set_AppKey("333793060")

    def push_notice_by_userid(self,user_id,title,body,params):
        self.request.set_PushType("NOTICE")
        self.request.set_DeviceType("ALL")
        self.request.set_Target("ACCOUNT")
        self.request.set_TargetValue(str(user_id))
        self.request.set_Body(title)
        self.request.set_Title(body)
        self.request.set_iOSExtParameters(params)
        response = self.client.do_action_with_exception(self.request)
        return response

aliyunpush = AliyunPush()


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