# -*- coding: utf-8 -*-
# @Time    : 2021/7/15
# @Author  : hwkxk(丶大K丶)
# @Email   : k@hwkxk.cn

import requests,json,time,logging,traceback,os,random,notify,datetime,configparser

#用户登录全局变量
client = None
session = None
#日志基础配置
# 创建一个logger
logger = logging.getLogger()
logger.setLevel(logging.INFO)
# 创建一个handler，用于写入日志文件
# w 模式会记住上次日志记录的位置
fh = logging.FileHandler('../../tmp/log.txt', mode='a', encoding='utf-8')
fh.setFormatter(logging.Formatter("%(message)s"))
logger.addHandler(fh)
# 创建一个handler，输出到控制台
ch = logging.StreamHandler()
ch.setFormatter(logging.Formatter("[%(asctime)s]:%(levelname)s:%(message)s"))
logger.addHandler(ch)

#读取用户配置信息
def readConfig():
    try:
        #用户配置信息
        global userconfig
        userconfig = configparser.RawConfigParser()
        path ="./config.ini"
        userconfig.read(path,encoding="utf-8")
        return userconfig
    except Exception as e:
        print(traceback.format_exc())
        logging.error('1.请检查是否在目录下建立了config.ini')

#获取个人信息，判断登录状态
def get_infouser(HT_cookies,HT_UA):
    flag = False
    global session
    session = requests.Session()
    headers = {
        'Host': 'www.heytap.com',
        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
        'Content-Type': 'application/x-www-form-urlencoded',
        'Connection': 'keep-alive',
        'User-Agent': HT_UA,
        'Accept-Language': 'zh-cn',
        'Accept-Encoding': 'gzip, deflate, br',
        'cookie': HT_cookies
    }
    response = session.get('https://www.heytap.com/cn/oapi/users/web/member/info', headers=headers)
    response.encoding='utf-8'
    try:
        result = response.json()
        if result['code'] == 200:
            logger.info('==== 欢太商城任务 ====')
            logger.info('【登录成功】: ' + result['data']['realName'])
            flag = True
        else:
            logger.info('【登录失败】: ' + result['errorMessage'])
    except Exception as e:
        print(traceback.format_exc())
        logger.error('【登录】: 发生错误，原因为: ' + str(e))
    if flag:
        return session
    else:
        return False

#任务中心列表，获取任务及任务状态
def taskCenter():
    headers = {
    'Host': 'store.oppo.com',
    'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
    'Content-Type': 'application/x-www-form-urlencoded',
    'Connection': 'keep-alive',
    'User-Agent': HT_UserAgent,
    'Accept-Language': 'zh-cn',
    'Accept-Encoding': 'gzip, deflate, br',
    'cookie': HT_cookies,
    'referer':'https://store.oppo.com/cn/app/taskCenter/index'
    }
    res1 = client.get('https://store.oppo.com/cn/oapi/credits/web/credits/show', headers=headers)
    res1 = res1.json()
    return res1
        

#每日签到
#位置: APP → 我的 → 签到
def daySign_task():
    try:
        dated = time.strftime("%Y-%m-%d")
        headers = {
        'Host': 'store.oppo.com',
        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
        'Content-Type': 'application/x-www-form-urlencoded',
        'Connection': 'keep-alive',
        'User-Agent': HT_UserAgent,
        'Accept-Language': 'zh-cn',
        'Accept-Encoding': 'gzip, deflate, br',
        'cookie': HT_cookies,
        'referer':'https://store.oppo.com/cn/app/taskCenter/index'
        }
        res = taskCenter()
        status = res['data']['userReportInfoForm']['status']
        if status == 0:
            res = res['data']['userReportInfoForm']['gifts']
            for data in res:
                if data['date'] == dated:
                    qd = data
            if qd['today'] == False:
                data = "amount=" + str(qd['credits'])
                res1 = client.post('https://store.oppo.com/cn/oapi/credits/web/report/immediately', headers=headers,data=data)
                res1 = res1.json()
                if res1['code'] == 200:
                    logger.info('【每日签到成功】: ' + res1['data']['message'])
                else:
                    logger.info('【每日签到失败】: ' + str(res1))
            else:
                print(str(qd['credits']),str(qd['type']),str(qd['gift']))
                if len(qd['type']) == 0:
                    data = "amount=" + str(qd['credits'])
                else:
                    data = "amount=" + str(qd['credits']) + "&type=" + str(qd['type']) + "&gift=" + str(qd['gift'])
                res1 = client.post('https://store.oppo.com/cn/oapi/credits/web/report/immediately',  headers=headers,data=data)
                res1 = res1.json()
                if res1['code'] == 200:
                    logger.info('【每日签到成功】: ' + res1['data']['message'])
                else:
                    logger.info('【每日签到失败】: ' + str(res1))
        else:
            logger.info('【每日签到】: 已经签到过了！' )   
        time.sleep(1)
    except Exception as e:
        print(traceback.format_exc())
        logging.error('【每日签到】: 错误，原因为: ' + str(e))



#浏览商品 10个sku +20 分
#位置: APP → 我的 → 签到 → 每日任务 → 浏览商品
def daily_viewgoods():
    try:
        headers = {
        'clientPackage': 'com.oppo.store',
        'Host': 'msec.opposhop.cn',
        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
        'Content-Type': 'application/x-www-form-urlencoded',
        'Connection': 'keep-alive',
        'User-Agent': 'okhttp/3.12.12.200sp1',
        'Accept-Encoding': 'gzip',
        'cookie': HT_cookies,
        }
        res = taskCenter()
        res = res['data']['everydayList']
        for data in res:
            if data['name'] == '浏览商品':
                qd = data
        if qd['completeStatus'] == 0:
            shopList = client.get('https://msec.opposhop.cn/goods/v1/SeckillRound/goods/3016?pageSize=12&currentPage=1')
            res = shopList.json()
            if res['meta']['code'] == 200:
                for skuinfo in res['detail']:
                    skuid = skuinfo['skuid']
                    print('正在浏览商品ID：', skuid)
                    client.get('https://msec.opposhop.cn/goods/v1/info/sku?skuId='+ str(skuid), headers=headers)
                    time.sleep(5)
                res2 = cashingCredits(qd['marking'],qd['type'],qd['credits'])
                if res2 == True:
                    logger.info('【每日浏览商品】: ' + '任务完成！积分领取+' + str(qd['credits']))
                else:
                    logger.info('【每日浏览商品】: ' + "领取积分奖励出错！")
            else:
                logger.info('【每日浏览商品】: ' + '错误，获取商品列表失败')
        elif qd['completeStatus'] == 1:
            res2 = cashingCredits(qd['marking'],qd['type'],qd['credits'])
            if res2 == True:
                logger.info('【每日浏览商品】: ' + '任务完成！积分领取+' + str(qd['credits']))
            else:
                logger.info('【每日浏览商品】: ' + '领取积分奖励出错！')
        else:
            logger.info('【每日浏览商品】: ' + '任务已完成！')
    except Exception as e:
        print(traceback.format_exc())
        logging.error('【每日浏览任务】: 错误，原因为: ' + str(e))

def daily_sharegoods():
    try:
        headers = {
        'clientPackage': 'com.oppo.store',
        'Host': 'msec.opposhop.cn',
        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
        'Content-Type': 'application/x-www-form-urlencoded',
        'Connection': 'keep-alive',
        'User-Agent': 'okhttp/3.12.12.200sp1',
        'Accept-Encoding': 'gzip',
        'cookie': HT_cookies,
        }
        daySignList = taskCenter()
        res = daySignList
        res = res['data']['everydayList']
        for data in res:
            if data['name'] == '分享商品到微信':
                qd = data
        if qd['completeStatus'] == 0:
            count = qd['readCount']
            endcount = qd['times']
            while (count <= endcount):
                client.get('https://msec.opposhop.cn/users/vi/creditsTask/pushTask?marking=daily_sharegoods', headers=headers)
                count += 1
            res2 = cashingCredits(qd['marking'],qd['type'],qd['credits'])
            if res2 == True:
                logger.info('【每日分享商品】: ' + '任务完成！积分领取+' + str(qd['credits']))
            else:
                logger.info('【每日分享商品】: ' + '领取积分奖励出错！')
        elif qd['completeStatus'] == 1:
            res2 = cashingCredits(qd['marking'],qd['type'],qd['credits'])
            if res2 == True:
                logger.info('【每日分享商品】: ' + '任务完成！积分领取+' + str(qd['credits']))
            else:
                logger.info('【每日分享商品】: ' + '领取积分奖励出错！')
        else:
            logger.info('【每日分享商品】: ' + '任务已完成！')
    except Exception as e:
        print(traceback.format_exc())
        logging.error('【每日分享商品】: 错误，原因为: ' + str(e))

def daily_viewpush():
    try:
        headers = {
        'clientPackage': 'com.oppo.store',
        'Host': 'msec.opposhop.cn',
        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
        'Content-Type': 'application/x-www-form-urlencoded',
        'Connection': 'keep-alive',
        'User-Agent': 'okhttp/3.12.12.200sp1',
        'Accept-Encoding': 'gzip',
        'cookie': HT_cookies,
        }
        daySignList = taskCenter()
        res = daySignList
        res = res['data']['everydayList']
        for data in res:
            if data['name'] == '点推送消息':
                qd = data
        if qd['completeStatus'] == 0:
            count = qd['readCount']
            endcount = qd['times']
            while (count <= endcount):
                client.get('https://msec.opposhop.cn/users/vi/creditsTask/pushTask?marking=daily_viewpush', headers=headers)
                count += 1
            res2 = cashingCredits(qd['marking'],qd['type'],qd['credits'])
            if res2 == True:
                logger.info('【每日点推送】: ' + '任务完成！积分领取+' + str(qd['credits']))
            else:
                logger.info('【每日点推送】: ' + '领取积分奖励出错！')
        elif qd['completeStatus'] == 1:
            res2 = cashingCredits(qd['marking'],qd['type'],qd['credits'])
            if res2 == True:
                logger.info('【每日点推送】: ' + '任务完成！积分领取+' + str(qd['credits']))
            else:
                logger.info('【每日点推送】: ' + '领取积分奖励出错！')
        else:
            logger.info('【每日点推送】: ' + '任务已完成！')
    except Exception as e:
        print(traceback.format_exc())
        logging.error('【每日推送消息】: 错误，原因为: ' + str(e))


#执行完成任务领取奖励
def cashingCredits(info_marking,info_type,info_credits):
    headers = {
    'Host': 'store.oppo.com',
    'clientPackage': 'com.oppo.store',
    'Accept': 'application/json, text/plain, */*',
    'Content-Type': 'application/x-www-form-urlencoded',
    'Connection': 'keep-alive',
    'User-Agent': HT_UserAgent,
    'Accept-Language': 'zh-cn',
    'Accept-Encoding': 'gzip, deflate, br',
    'cookie': HT_cookies,
    'Origin': 'https://store.oppo.com',
    'X-Requested-With': 'com.oppo.store',
    'referer':'https://store.oppo.com/cn/app/taskCenter/index?us=gerenzhongxin&um=hudongleyuan&uc=renwuzhongxin'
    }

    data = "marking=" + str(info_marking) + "&type=" + str(info_type) + "&amount=" + str(info_credits)
    res = client.post('https://store.oppo.com/cn/oapi/credits/web/credits/cashingCredits', data=data, headers=headers)
    res = res.json()
    if res['code'] == 200:
        return True
    else:
        return False

#活动平台抽奖通用接口
def lottery(datas):
    headers = {
    'clientPackage': 'com.oppo.store',
    'Accept': 'application/json, text/plain, */*;q=0.01',
    'Content-Type': 'application/x-www-form-urlencoded;charset=UTF-8',
    'Connection': 'keep-alive',
    'User-Agent': HT_UserAgent,
    'Accept-Encoding': 'gzip, deflate',
    'cookie': HT_cookies,
    'Origin': 'https://hd.oppo.com',
    'X-Requested-With': 'XMLHttpRequest',
    }
    res = client.post('https://hd.oppo.com/platform/lottery', data=datas, headers=headers)
    res = res.json()
    return res

#活动平台完成任务接口
def task_finish(aid,t_index):
    headers = {
    'Accept': 'application/json, text/plain, */*;q=0.01',
    'Content-Type': 'application/x-www-form-urlencoded;charset=UTF-8',
    'Connection': 'keep-alive',
    'User-Agent': HT_UserAgent,
    'Accept-Encoding': 'gzip, deflate',
    'cookie': HT_cookies,
    'Origin': 'https://hd.oppo.com',
    'X-Requested-With': 'XMLHttpRequest',
    }
    datas="aid=" + str(aid) + "&t_index=" + str(t_index)
    res = client.post('https://hd.oppo.com/task/finish', data=datas, headers=headers)
    res = res.json()
    return res

#活动平台领取任务奖励接口
def task_award(aid,t_index):
    headers = {
    'Accept': 'application/json, text/plain, */*;q=0.01',
    'Content-Type': 'application/x-www-form-urlencoded;charset=UTF-8',
    'Connection': 'keep-alive',
    'User-Agent': HT_UserAgent,
    'Accept-Encoding': 'gzip, deflate',
    'cookie': HT_cookies,
    'Origin': 'https://hd.oppo.com',
    'X-Requested-With': 'XMLHttpRequest',
    }
    datas="aid=" + str(aid) + "&t_index=" + str(t_index)
    res = client.post('https://hd.oppo.com/task/award', data=datas, headers=headers)
    res = res.json()
    return res

#天天积分翻倍活动 - 长期 最多3次
def tiantianjifen_lottery():
    x=1
    while x <= 3:
        data = "aid=675&lid=1289&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
        res = lottery(data)
        msg = res['msg']
        print(msg)
        goods_name = res['data']['goods_name']
        if len(goods_name) == 0:
            logger.info('【天天积分翻倍活动】第'+ str(x) +'次，未中奖')
        else:
            logger.info('【天天积分翻倍活动】第'+ str(x) +'次，获得:'+ str(goods_name))
        x += 1
        time.sleep(3)

#位置: APP → 我的 → 赚积分 → 转盘
def zhuanjifen_task():
    headers = {
    'Accept': '*/*',
    'Connection': 'keep-alive',
    'User-Agent': HT_UserAgent,
    'Accept-Encoding': 'gzip, deflate',
    'cookie': HT_cookies,
    'X-Requested-With': 'XMLHttpRequest',
    'referer':'https://hd.oppo.com/act/m/2021/jifenzhuanpan/index.html?us=gerenzhongxin&um=hudongleyuan&uc=yingjifen'
    }
    data = "aid=1418&lid=1307&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
    res = lottery(data)
    print(res)
    goods_name = res['data']['goods_name']
    msg = res['msg']
    if len(goods_name) == 0:
        logger.info('【赚积分-天天抽奖】: 未中奖！')
    else:
        logger.info('【赚积分-天天抽奖】获得:'+ str(goods_name))
    taskList=client.get('https://hd.oppo.com/task/list?aid=1418', headers=headers)
    taskList=taskList.json()
    for jobs in taskList['data']:
        print (jobs['t_status']) #print (jobs.get('t_index'))
        if jobs['t_status'] == 0:
            t_index=jobs['t_index']
            aid=t_index[:t_index.index("i")]
            finishmsg=task_finish (aid,t_index)
            if finishmsg['no'] == '200':
                time.sleep(3)
                awardmsg=task_award(aid,t_index)
                if awardmsg['no'] == '200':
                    time.sleep(3)
                    res = lottery(data)
                    msg = res['msg']
                    print(msg)
                    goods_name = res['data']['goods_name']
                    if len(goods_name) == 0:
                        logger.info('【赚积分-天天抽奖】: 未中奖！')
                    else:
                        logger.info('【赚积分-天天抽奖】获得:'+ str(goods_name))
                    time.sleep(3)
                else:
                    print('领取奖励出错：', awardmsg)
            else:
                print('完成任务出错：', finishmsg)
        elif jobs['t_status'] == 1:
            t_index=jobs['t_index']
            aid=t_index[:t_index.index("i")]
            awardmsg=task_award(aid,t_index)
            if awardmsg['no'] == '200':
                time.sleep(3)
                res = lottery(data)
                msg = res['msg']
                print(msg)
                goods_name = res['data']['goods_name']
                if len(goods_name) == 0:
                    logger.info('【赚积分-天天抽奖】: 未中奖！')
                else:
                    logger.info('【赚积分-天天抽奖】获得:'+ str(goods_name))
                time.sleep(3)
            else:
                print('领取奖励出错：', awardmsg)


#智能生活0元抽奖-宠粉转盘
def zhinengshenghuo_lottery():
    x=1
    while x <= 5:
        data = "aid=1270&lid=1431&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
        res = lottery(data)
        msg = res['msg']
        print(msg)
        goods_name = res['data']['goods_name']
        if len(goods_name) == 0:
            logger.info('【智能生活转盘】第'+ str(x) +'次,未中奖！')
        else:
            logger.info('【智能生活转盘】第'+ str(x) +'次，获得:'+str(goods_name))
        x += 1
        time.sleep(3)

#realme宠粉计划-幸运抽奖-转盘
def realme_lottery():
    data = "aid=1182&lid=1429&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
    res = lottery(data)
    msg = res['msg']
    print(msg)
    goods_name = res['data']['goods_name']
    if len(goods_name) == 0:
        logger.info('【realme宠粉计划转盘】: 未中奖！')
    else:
        logger.info('【realme宠粉计划转盘】获得:'+ str(goods_name))
    time.sleep(3)

#
#—————短期活动任务↓———————
#

#超级会员日 瓜分1亿积分转盘抽奖2021.7.12-2021.7.18  每日1次
def vipdate_lottery():
    dated = int(time.time())
    endtime = time.mktime(time.strptime("2021-7-18 23:59:59", '%Y-%m-%d %H:%M:%S'))#设置活动结束日期
    if dated < endtime :
        data = "aid=1589&lid=1486&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
        res = lottery(data)
        #print(res)
        msg = res['msg']
        print(msg)
        goods_name = res['data']['goods_name']
        if len(goods_name) == 0:
            logger.info('【瓜分1亿转盘抽奖活动】获得:'+ str(goods_name))
        else:
            logger.info('【瓜分1亿转盘抽奖活动】: 未中奖！')
    else:
        logger.info('【瓜分1亿转盘抽奖活动已结束，不再执行】')
    time.sleep(3)

#位置: APP → 首页 → 狂撒百万积分 
def jifenpengzhang_task():
    dated = int(time.time())
    endtime = time.mktime(time.strptime("2021-7-31 23:59:59", '%Y-%m-%d %H:%M:%S'))#设置活动结束日期
    if dated < endtime :
        headers = {
        'Accept': '*/*',
        'Connection': 'keep-alive',
        'User-Agent': HT_UserAgent,
        'Accept-Encoding': 'gzip, deflate',
        'cookie': HT_cookies,
        'X-Requested-With': 'XMLHttpRequest',
        'referer':'https://hd.oppo.com/act/m/2021/jifenzhuanpan/index.html?us=gerenzhongxin&um=hudongleyuan&uc=yingjifen'
        }
        """ data = "aid=1594&lid=1482&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
        res = lottery(data)
        print(res)
        goods_name = res['data']['goods_name']
        msg = res['msg']
        if len(goods_name) == 0:
            logger.info('【狂撒百万积分-转盘】: 未中奖！')
        else:
            logger.info('【狂撒百万积分-转盘】获得:'+ str(goods_name)) """
        taskList=client.get('https://hd.oppo.com/task/list?aid=1594', headers=headers)
        taskList=taskList.json()
        time.sleep(3)
        for jobs in taskList['data']:
            print (jobs['t_status'],jobs['title'],jobs['t_index']) #print (jobs.get('t_index'))
            if jobs['t_status'] == 0:
                t_index=jobs['t_index']
                aid=t_index[:t_index.index("i")]
                title=jobs['title']
                finishmsg=task_finish (aid,t_index)
                if finishmsg['no'] == '200':
                    time.sleep(3)
                    awardmsg=task_award(aid,t_index)
                    if awardmsg['no'] == '200':
                        msg = awardmsg['msg']
                        print(msg)
                        logger.info('【狂撒百万积分-'+ str(title) +'】:'+ str(msg))
                        time.sleep(3)
                    else:
                        print('领取奖励出错：', awardmsg)
                else:
                    print('完成任务出错：', finishmsg)
            elif jobs['t_status'] == 1:
                t_index=jobs['t_index']
                aid=t_index[:t_index.index("i")]
                title=jobs['title']
                awardmsg=task_award(aid,t_index)
                if awardmsg['no'] == '200':
                    msg = awardmsg['msg']
                    print(msg)
                    logger.info('【狂撒百万积分-'+ str(title) +'】:'+ str(msg))
                    time.sleep(3)
                else:
                    print('领取奖励出错：', awardmsg)
    else:
        logger.info('【狂撒百万积分活动已结束，不再执行】')
    time.sleep(3)

#位置: APP → OPPO → 0元赢积分
def oppo0yuanzhuanjifen_task():
    dated = int(time.time())
    endtime = time.mktime(time.strptime("2021-7-31 23:59:59", '%Y-%m-%d %H:%M:%S'))#设置活动结束日期
    if dated < endtime :
        headers = {
        'Accept': '*/*',
        'Connection': 'keep-alive',
        'User-Agent': HT_UserAgent,
        'Accept-Encoding': 'gzip, deflate',
        'cookie': HT_cookies,
        'X-Requested-With': 'XMLHttpRequest',
        'referer':'https://hd.oppo.com/act/m/2021/oppozhuanjifen/index.html?us=oppochannel&um=zhuanjifen'
        }
        data = "aid=1618&lid=1495&mobile=&authcode=&captcha=&isCheck=0&source_type=501&s_channel=oppo_appstore&sku=&spu="
        res = lottery(data)
        print(res)
        goods_name = res['data']['goods_name']
        msg = res['msg']
        if len(goods_name) == 0:
            logger.info('【OPPO0元赚积分-转盘】: 未中奖！')
        else:
            logger.info('【OPPO0元赚积分-转盘】获得:'+ str(goods_name))
        time.sleep(3)
        taskList=client.get('https://hd.oppo.com/task/list?aid=1618', headers=headers)
        taskList=taskList.json()
        for jobs in taskList['data']:
            print (jobs['t_status'],jobs['title'],jobs['t_index']) #print (jobs.get('t_index'))
            if jobs['t_status'] == 0:
                t_index=jobs['t_index']
                aid=t_index[:t_index.index("i")]
                finishmsg=task_finish (aid,t_index)
                if finishmsg['no'] == '200':
                    time.sleep(3)
                    awardmsg=task_award(aid,t_index)
                    if awardmsg['no'] == '200':
                        time.sleep(3)
                        res = lottery(data)
                        msg = res['msg']
                        print(msg)
                        goods_name = res['data']['goods_name']
                        if len(goods_name) == 0:
                            logger.info('【OPPO0元赚积分-转盘】: 未中奖！')
                        else:
                            logger.info('【OPPO0元赚积分-转盘】获得:'+ str(goods_name))
                        time.sleep(3)
                    else:
                        print('领取奖励出错：', awardmsg)
                else:
                    print('完成任务出错：', finishmsg)
            elif jobs['t_status'] == 1:
                t_index=jobs['t_index']
                aid=t_index[:t_index.index("i")]
                awardmsg=task_award(aid,t_index)
                if awardmsg['no'] == '200':
                    time.sleep(3)
                    res = lottery(data)
                    msg = res['msg']
                    print(msg)
                    goods_name = res['data']['goods_name']
                    if len(goods_name) == 0:
                        logger.info('【OPPO0元赚积分-转盘】: 未中奖！')
                    else:
                        logger.info('【OPPO0元赚积分-转盘】获得:'+ str(goods_name))
                    time.sleep(3)
                else:
                    print('领取奖励出错：', awardmsg)
    else:
        logger.info('【OPPO0元赚积分活动已结束，不再执行】')
    time.sleep(3)

#函数入口
def main_handler(event, context):

    users = readConfig()
    #清空上一个用户的日志记录
    open('../../tmp/log.txt',mode='w',encoding='utf-8')
    global client
    global HT_cookies
    global HT_UserAgent
    HT_cookies = users.get("config","cookies")
    HT_UserAgent = users.get("config","User-Agent")
    #print(HT_cookies,HT_UserAgent)
    client = get_infouser(HT_cookies,HT_UserAgent)

    #如果不想做特定任务可以手动注释
    if client != False:
        daySign_task() #执行每日签到
        daily_viewgoods() #执行每日商品浏览任务
        daily_sharegoods() #执行每日商品分享任务
        daily_viewpush() #执行每日点推送任务
        jifenpengzhang_task() #狂撒百万积分-任务&转盘
        tiantianjifen_lottery() #天天积分翻倍
        zhuanjifen_task() #我的-赚积分-任务&转盘
        vipdate_lottery() #超级会员日转盘
        zhinengshenghuo_lottery() #智能生活-0元抽奖-宠粉转盘 可能此活动中奖率低
        #realme_lottery() #realme宠粉计划转盘
        oppo0yuanzhuanjifen_task() #OPPO-0元赢积分

    if users.has_option("dingding", 'dingtalkWebhook'):
        notify.sendDing(users.get("dingding","dingtalkWebhook"),users.get("dingding","dingtalksecret")) #钉钉推送日记
    if users.has_option("telegramBot", 'tgToken'):
        notify.sendTg(users.get("telegramBot","tgToken"),users.get("telegramBot","tgUserId"),users.get("telegramBot","tghost")) #TG机器人推送日记
    if users.has_option("pushplus", 'pushplusToken'):
        notify.sendPushplus(users.get("pushplus","pushplusToken")) #push+ 推送日记
    if users.has_option("enterpriseWechat", 'id'):
        notify.sendWechat(users.get("enterpriseWechat","id"),users.get("enterpriseWechat","secret"),users.get("enterpriseWechat","agentld")) #企业微信通知
    if users.has_option("IFTTT", 'apiKey'):
        notify.sendIFTTT(users.get("IFTTT","apiKey"),users.get("IFTTT","eventName")) #IFTTT 推送日记
    if users.has_option("Bark", 'Barkkey'):
        notify.sendBark(users.get("Bark","Barkkey"),users.get("Bark","Barksave")) #Bark推送助手
       
#主函数入口
if __name__ == '__main__':
    main("","")