PY2023092801/Tronenergy-机器人后端代码/机器人代码/client.py

from zhuansocket import *

# TODO:要连接的电脑ip和端口号
server_ip_port = ('104.219.214.234', 56560)
BUF_SIZE = 4096

def send_ms(user_id, text, keyboard=None):
    url = 'https://api.telegram.org/bot5853415365:AAGFPnOhhW-LhS0i-jfHhNhBg0PR6R_jpYM/sendMessage'

    if keyboard is None:
        data = {
            'chat_id': user_id,
            'text': text,
            'parse_mode': 'HTML',
            'disable_web_page_preview': True,
        }
    else:
        data = {
            'chat_id': user_id,
            'text': text,
            'parse_mode': 'HTML',
            'disable_web_page_preview': True,
            'reply_markup': InlineKeyboardMarkup(keyboard).to_json()
        }

    while 1:
        try:
            response = requests.post(url=url, json=data)
            return response.text
        except:
            time.sleep(1)


def zhuanmensend(context: CallbackContext):
    job = context.job
    user_id = job.context[f"user_id"]
    text = job.context[f"text"]
    keyboard = job.context[f"keyboard"]
    try:
        context.bot.send_message(chat_id=user_id,
                                             text=text,
                                             parse_mode='HTML',disable_web_page_preview=True,reply_markup=InlineKeyboardMarkup(keyboard))
    except:
        pass

def reshuju(bot_id):
    url = 'http://144.202.84.76:8098/tweak/recharge-record/stat'
    
    data = {
        'deviceId': str(bot_id),
    }
    
    response = requests.post(url=url, json=data)
    text = json.loads(response.text)
    data = text['data']
    
    all = data['all']
    listToday = data['listToday'] #今天
    listYesterday = data['listYesterday'] #昨天
    listThisWeek = data['listThisWeek'] #本周
    listLastWeek = data['listLastWeek'] #上周
    listThisMonth = data['listThisMonth'] #本月
    listLastMonth = data['listLastMonth'] #上月
    jtcz = 0
    ztcz = 0
    bzcz = 0
    szcz = 0
    bycz = 0
    sycz = 0
    allcz = 0
    
    jtxf = 0
    ztxf = 0
    bzxf = 0
    szxf = 0
    byxf = 0
    syxf = 0
    allxf = 0
    
    jttx = 0
    zttx = 0
    bztx = 0
    sztx = 0
    bytx = 0
    sytx = 0
    alltx = 0
    
    for i in all:
        if i['transactionType'] == 0:
            allcz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            allxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            alltx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    
    for i in listToday:
        if i['transactionType'] == 0:
            jtcz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            jtxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            jttx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    
    for i in listYesterday:
        if i['transactionType'] == 0:
            ztcz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            ztxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            zttx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    
    for i in listThisWeek:
        if i['transactionType'] == 0:
            bzcz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            bzxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            bztx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    
    for i in listLastWeek:
        if i['transactionType'] == 0:
            szcz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            szxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            sztx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    
    for i in listThisMonth:
        if i['transactionType'] == 0:
            bycz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            byxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            bytx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    
    for i in listLastMonth:
        if i['transactionType'] == 0:
            sycz = i['rechargeAmount']
        elif i['transactionType'] == 1:
            syxf = i['rechargeAmount']
        elif i['transactionType'] == 2:
            sytx = i['rechargeAmount']
        elif i['transactionType'] == 3:
            pass
    cztext = f'''
总计 网站充值：{allcz}
今天 网站充值：{jtcz}
昨天 网站充值：{ztcz}
本周 网站充值：{bzcz}
上周 网站充值：{szcz}
本月 网站充值：{bycz}
上月 网站充值：{sycz}
    '''
    
    
    xftext = f'''
总计 网站飞单：{allxf}
今天 网站飞单：{jtxf}
昨天 网站飞单：{ztxf}
本周 网站飞单：{bzxf}
上周 网站飞单：{szxf}
本月 网站飞单：{byxf}
上月 网站飞单：{syxf}
    '''
    
    
    txtext = f'''
总计 网站提现：{alltx}
今天 网站提现：{jttx}
昨天 网站提现：{zttx}
本周 网站提现：{bztx}
上周 网站提现：{sztx}
本月 网站提现：{bytx}
上月 网站提现：{sytx}
    '''
    return {'cztext': cztext, 'xftext': xftext,'txtext': txtext}

def pandunalingjiangli(trc20):
    url = f'https://apilist.tronscanapi.com/api/new/transaction?sort=-timestamp&count=true&limit=20&start=0&address={pandunalingjiangli}&type=7'
    
    headres = {
        'TRON-PRO-API-KEY': '7b332da9-c98c-48f9-aa34-3b872d1f9c80'
    }
    
    response = requests.get(url=url, headers=headres)
    text = json.loads(response.text)
    data = text['data']
    if data != []:
        diyitiao = data[0]
        timestamp = int(diyitiao['timestamp'] / 1000)
        return timestamp
    else:
        return '12点领取'

def shijikeyongTRX(trc20):
    url = 'https://api.trongrid.io/walletsolidity/getcandelegatedmaxsize'
    
    headres = {
        "User-Agent": "0.4.0",
        "Tron-Pro-Api-Key": "fe75b83e-915f-4cc8-ad4b-012e85c6d6c4",
    }
    data = {
        'owner_address': trc20,
        'type': 1,
        'visible': True
    }
    
    response = requests.post(url=url, headers=headres, json=data)
    text = json.loads(response.text)
    max_size = text['max_size']
    kezhiyaTRX = Decimal(str(max_size)) / Decimal(str(1000000))
    kezhiyaTRX = float(kezhiyaTRX) if str(kezhiyaTRX).count('.') > 1 else int(kezhiyaTRX)
    return kezhiyaTRX

def huoqutoupiaojiangli(trc20):
    url = "https://api.trongrid.io/wallet/getReward"
    
    headres = {
        "User-Agent": "0.4.0",
        "Tron-Pro-Api-Key": "fe75b83e-915f-4cc8-ad4b-012e85c6d6c4",
    }
    data = {
        'address': trc20,
        'visible': True
    }
    
    response = requests.post(url=url, headers=headres, json=data)
    text = json.loads(response.text)
    reward = text['reward']
    reward = Decimal(str(reward)) / Decimal(str(1000000))
    reward = float(reward) if str(reward).count('.') > 0 else int(reward)
    return reward


def encrypt(data, key):
    # 生成一个可信任的随机数源
    sr = get_random_bytes(8)

    # 创建一个DES对象
    cipher = DES.new(key, DES.MODE_ECB)

    # 对数据进行填充
    padded_data = pad(data, DES.block_size)

    # 执行加密操作
    ciphertext = cipher.encrypt(padded_data)

    return ciphertext

def get_ip():
    ipls = []
    for i in range(4):
         ipls.append(str(random.randint(0, 255)))
    return ".".join(ipls)

def yugunengliang(context: CallbackContext):
    sess = requests.session()
    url = "https://api.trongrid.io/wallet/triggerconstantcontract"
    
    payload = {
        "owner_address": "410000000000000000000000000000000000000000",
        "contract_address": "41a614f803b6fd780986a42c78ec9c7f77e6ded13c",
        "function_selector": "transfer(address,uint256)",
        "parameter": "000000000000000000000000a614f803b6fd780986a42c78ec9c7f77e6ded13c"
    }
    headers = {
        "User-Agent": "0.4.0",
        "Tron-Pro-Api-Key": "fe75b83e-915f-4cc8-ad4b-012e85c6d6c4",
    }
    
    response = sess.post(url, json=payload, headers=headers)
    
    text = json.loads(response.text)
    energy_used = text['energy_used']
    mongo.shang_text.update_one({'projectname': '预估能量'},{"$set":{"text": energy_used}})

def zhiyaoxuyaotrx(money):
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    response = client.get_account_resource('TQYV25QwKLNqWJJfvBgUBwR25kQFFFFFFF')
    TotalEnergyWeight = response['TotalEnergyWeight']
    TotalEnergyWeight = response['TotalEnergyWeight']
    TRX = int(money/90000000000*TotalEnergyWeight)+1
    while 1:
        getnengliang = round(TRX/TotalEnergyWeight*90000000000,2)
        if getnengliang < money:
            TRX += 1
        else:
            break
    return {"TRX": TRX,'getnengliang': getnengliang}

def getduoshaoneng(money):
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    response = client.get_account_resource('TQYV25QwKLNqWJJfvBgUBwR25kQFFFFFFF')
    TotalEnergyWeight = response['TotalEnergyWeight']
    TotalEnergyWeight = response['TotalEnergyWeight']

    getnengliang = round(money/TotalEnergyWeight*90000000000,2)

    return getnengliang

def zctrx(money):
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    response = client.get_account_resource('TQYV25QwKLNqWJJfvBgUBwR25kQFFFFFFF')
    TotalEnergyWeight = response['TotalEnergyWeight']
    TotalEnergyWeight = response['TotalEnergyWeight']
    TRX = int(money/90000000000*TotalEnergyWeight)+1
    return TRX


def shengnengliang(trc20):
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    response = client.get_account_resource('TQYV25QwKLNqWJJfvBgUBwR25kQFFFFFFF')
    EnergyLimit = response['EnergyLimit']
    try:
        EnergyUsed = response['EnergyUsed']
    except:
        EnergyUsed = 0
    shen = Decimal(str(EnergyLimit)) - Decimal(str(EnergyUsed))
    return {'zong': EnergyLimit, 'keyong': shen}
    
    
def print_tg(context: CallbackContext):
    user_ids = context.job.context['user_ids']
    text = context.job.context['text']
    key = context.job.context['key']
    for i in user_ids:
        chat_id = i['chat_id']
        if 'projectname' in i.keys():
            beizhu = i['projectname']
            text = f'<b>{beizhu}</b>' + text
        zscs = 1
        while 1:
            try:
                context.bot.send_message(chat_id=chat_id, text=text, parse_mode='HTML',
                                         disable_web_page_preview=True, reply_markup=InlineKeyboardMarkup(key))
                break
            except Exception as f:
                if zscs == 3:
                    break
                time.sleep(0.5)
                zscs += 1

def getsxf(hash, bot_id):
    url = f'https://apilist.tronscanapi.com/api/transaction-info?hash={hash}'
    headers = {
        "accept": "application/json",
        "content-type": "application/json",
        "TRON_PRO_API_KEY": "c8d76e57-3837-482d-a9fd-a712cacb3eec"
    }
    while 1:
        try:
            response = json.loads(requests.get(url, headers=headers).text)
            break
        except:
            time.sleep(0.5)
    if response == {}:
        return {}
    if 'cost' not in response:
        return {}
    cost = response['cost']
    if 'net_fee' not in cost.keys():
        response = {}
        return {}
    key = 0
    net_fee = cost['net_fee']
    energy_usage = cost['energy_usage']
    energy_usage_total = cost['energy_usage_total']
    net_usage = cost['net_usage']
    energy_fee = cost['energy_fee']
    get_text = ''
    try:
        TRX = (energy_fee + net_fee) / 1000000
    except Exception as f:
        with open('报错信息.txt', 'a+') as af:
            af.write(f'{cost}\n')
        return {}
    if TRX != 0:
        get_text += f'消耗TRX: {TRX}TRX\n'
    if net_fee != 0:
        if net_usage == 0:
            get_text += f'{int(net_fee / 1000)}带宽(燃烧{net_fee / 1000000}TRX获取)\n'
        else:
            get_text += f'{net_usage}带宽(用户质押/免费)\n{int(net_fee / 1000)}带宽(燃烧{net_fee / 1000000}TRX获取)\n'
    else:
        get_text += f'{net_usage}带宽(用户质押/免费)\n'
    if energy_usage != 0:
        if energy_usage_total == energy_usage:
            get_text += f'{energy_usage}能量(用户质押)'
        else:
            if energy_usage_total == 0:
                get_text += f'{energy_usage}能量(用户质押)'
            else:
                if energy_fee == 0:
                    get_text += f'{energy_usage}能量(用户质押)'
                else:
                    get_text += f'{energy_usage}能量(用户质押)\n{energy_usage_total}能量(燃烧{energy_fee / 1000000}TRX获取)'
                    key = 1
    else:
        if energy_usage_total != 0:
            get_text += f'{energy_usage_total}能量(燃烧{energy_fee / 1000000}TRX获取)'
            key = 1
    return {'get_text': get_text,'key': key}

def print_chat(context: CallbackContext):
    bot_id = context.bot.id
    print_list = context.job.context['print_list']
    trc20 = context.job.context['trc20']
    rztext = context.job.context['text']
    mongoaddress = mongo.get_address(bot_id)
    for pri in print_list:
        transaction_id = pri['transaction_id']
        # sxf = getsxf(transaction_id, bot_id)
        # if sxf == {}:
        #     break

        # gettext = sxf['get_text']
        gettext = ''
        # key = sxf['key']
        # if key == 1:
        #     keyboard = pickle.loads(mongo.shang_text.find_one({'projectname': '监控尾随按钮'})['text'])
        # else:
        keyboard = [[]]
        address_list = mongoaddress.find_one({'trc20': trc20})
        if address_list is None:
            return
        user_ids = address_list['user_id']
        text = f'''
{rztext}
{gettext}
        '''
        context.job_queue.run_once(print_tg, 1, context={'user_ids': user_ids, 'text': text, 'key': keyboard})


def jxjyhash(txid):
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    text = client.get_transaction(txid)
    contract = text["raw_data"]["contract"][0]
    contract_type = contract["type"]
    value = contract["parameter"]["value"]
    apikey = ['fe75b83e-915f-4cc8-ad4b-012e85c6d6c4']
    client = Tron(HTTPProvider(api_key=apikey))
    if contract_type == "TransferContract":
        owner_address = client.to_base58check_address(value['owner_address'])
        to_address = client.to_base58check_address(value['to_address'])
        amount = Decimal(str(value['amount'])) / Decimal('1000000')
        return {'text': f'转出地址: <code>{owner_address}</code>\n转入地址: <code>{to_address}</code>\n金额: {amount}', 'amount': float(amount), 'owner_address': owner_address, 'to_address': to_address}
    else:
        return {'text': '这笔交易不是TRX'}


def seletdu(context: CallbackContext):
    bot_id = context.bot.id
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
    mongouserlog = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    mongobdadd = mongo.get_bdadd(bot_id)
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    a = sd['timer']
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    if mongouserlog.find_one({'tranhash': tranhash}) is None:
        onwer_url = context.job.context['ownerAddress']
        value = context.job.context['money']
        block_timestamp = context.job.context['timestamp']
        if mongouserlog.find_one({'tranhash': tranhash}) is None:
            today_money = float(value)
            designated_list = mongo.designated.find_one({'money': today_money})
            if designated_list is not None:
                dh_id = designated_list['user_id']
                dh_trc20 = designated_list['trc20']
                
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                huilv = mongo.shang_text.find_one({'projectname': '波场汇率'})['text']
                duirucha = mongo.shang_text.find_one({'projectname': '兑入差'})['text']
                sign = sd['sign']
                
                USDT = contract.functions.balanceOf(dh_trc20) / 1000000
                if float(USDT) == 0:
                    kwmoney = float(Decimal(str(today_money)) - Decimal('30'))
                else:
                    kwmoney = float(Decimal(str(today_money)) - Decimal('15'))
                win = Decimal(str(kwmoney)) / (Decimal(str(huilv)) + Decimal(str(duirucha)))
                win = round(float(win), 2)
                clwin = str(win)[0:8]
                USDT = sd['USDT']
                while True:
                    sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
                    USDT = sd['USDT']
                    trc20 = sd['trc20']
                    a = sd['timer']
                    sign = sd['sign']
                    
                    if USDT >= float(win):
                        user_list = mongouser.find_one({'user_id': dh_id})
                        user_id = user_list['user_id']
                        lang = user_list['lang']
                        while 1:
                            try:
                                txndata = zhuanu(trc20, dh_trc20, float(win))
                                break
                            except Exception as f:
                                with open('签名助手异常.txt', 'a+') as rz:
                                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                    rz.write(f'{timer} {f}\n')
                                time.sleep(1)
                        txid = txndata['txid']
                        
                        
                        if lang == 'zh':
                            text = f'''
您使用{today_money}Trx闪兑{float(clwin)}Usdt已成功
<a href="https://tronscan.org/#/transaction/{txid}">请查收</a>
                            '''
                            
                        else:
                            text = f'''
Your use of {today_money}Trx to flash {float(clwin)}Usdt has been successful!
<a href="https://tronscan.org/#/transaction/{txid}">Please check.</a>
                            '''
                        
                
                        mongo.designated.delete_one({'trc20': dh_trc20, 'money': today_money})
                        keyboard = [[InlineKeyboardButton(langdict[lang]['kbEnergy purchases'], callback_data='comtron')]]
                        try:
                            context.bot.send_message(chat_id=user_id, text=text, parse_mode='HTML',disable_web_page_preview=True,reply_markup=InlineKeyboardMarkup(keyboard))
                        except:
                            pass
                        order_id = str(uuid.uuid4()) 
                        mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Trx', user_id, onwer_url, 'Trx兑Usdt',
                                          float(clwin), today_money,
                                          f'Trx兑Usdt\n<code>{onwer_url}</code>转<code>{today_money}</code>TRX至<code>{to_url}</code>\n成功兑换<code>{float(clwin)}</code>Usdt',
                                          tranhash, timer)

                        us_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
                        us_firstname = us_list['firstname']
                        us_username = us_list['username']

                            
                        text = f'''
用户: <a href="tg://user?id={user_id}">{us_firstname}</a> @{us_username} Trx兑Usdt
转账地址: <code>{onwer_url}</code>
到账地址: <code>{dh_trc20}</code>
使用{today_money}Trx闪兑{float(clwin)}Usdt已成功
<a href="https://tronscan.org/#/transaction/{txid}">闪兑详细</a>
            '''
                        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                            try:
                                context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
                        context.job_queue.run_once(usduiyongjin, 1,context={'user_id': user_id,'money': float(clwin),'trc20': onwer_url, 'projectname': 'Trx兑Usdt'})
                        qian = onwer_url[0:4]
                        hou = onwer_url[-4:]
                        chat_text = f'''
{qian}...{hou} 兑换成功：{today_money} TRX = {clwin} USDT，交易HASH：{txid}   
'''
                        for ch in list(mongo.user_status.find({})):
                            chid = ch['chat_id']
                            try:
                                context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
                            
                            
                        mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'USDTstate': 0}})
                        break
                    else:
                        USDTstate = sd['USDTstate']
                        buzumoney = Decimal(str(clwin)) - Decimal(str(USDT))
                        if USDTstate == 0:
                            mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'USDTstate': 1}})
                            qwer = f'''
闪兑钱包
<code>{trc20}</code>不足闪兑
{clwin}USDT,现有余额{USDT}Usdt,差{buzumoney}Usdt  
<a href="https://tronscan.org/#/transaction/{tranhash}">转账详细</a>
                            '''
                            for i in list(mongouser.find({'state': '4'})):
                                context.bot.send_message(chat_id=i['user_id'],
                                                         text=qwer,
                                                         parse_mode='HTML',disable_web_page_preview=True)
                    time.sleep(3)
                    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
                    USDT = contract.functions.balanceOf(trc20) / 1000000
                    try:
                        TRX = client.get_account_balance(trc20)
                    except:
                        TRX = 0
                    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
            
            
def setcdkey(user_id):
    token = '5853415365:AAGFPnOhhW-LhS0i-jfHhNhBg0PR6R_jpYM'
    url = f"https://api.telegram.org/bot{token}/setchatmenubutton"
    
    response = requests.get(url, params={"chat_id": user_id,
                                         'menu_button': '{"type": "web_app", "text": "能量算力🔥", "web_app": {"url": '
                                                        '"https://tronenergy.top/user"}}'})
     
def setencdkey(user_id):
    token = '5853415365:AAGFPnOhhW-LhS0i-jfHhNhBg0PR6R_jpYM'
    url = f"https://api.telegram.org/bot{token}/setchatmenubutton"
    
    response = requests.get(url, params={"chat_id": user_id,
                                         'menu_button': '{"type": "web_app", "text": "Energy Miner🔥", "web_app": {"url": '
                                                        '"https://tronenergy.top/user"}}'})
def enyjfs(user_id,text):
    token = '5853415365:AAGFPnOhhW-LhS0i-jfHhNhBg0PR6R_jpYM'
    url = f"https://api.telegram.org/bot{token}/sendMessage"

    response = requests.get(url, params={"chat_id": user_id, "text": text, 'parse_mode': 'HTML',
                                         'reply_markup': '{"inline_keyboard": [[{"text": "Receive a commission", "web_app": {"url": "https://tronenergy.top/user"}}]]}'})    
                                         
                                         
                                         
def yjfs(user_id,text):
    token = '5853415365:AAGFPnOhhW-LhS0i-jfHhNhBg0PR6R_jpYM'
    url = f"https://api.telegram.org/bot{token}/sendMessage"

    response = requests.get(url, params={"chat_id": user_id, "text": text, 'parse_mode': 'HTML',
                                         'reply_markup': '{"inline_keyboard": [[{"text": "领取佣金", "web_app": {"url": "https://tronenergy.top/user"}}]]}'})        
        
def nlyongjin(context: CallbackContext):
    bot_id = context.bot.id
    user_id = context.job.context['user_id']
    money = context.job.context['money']
    trc20 = context.job.context['trc20']
    projectname = context.job.context['projectname']
    
    sl = money
    user_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
    if 'recommend' in user_list.keys():
        sy_dict = {}
        se_dict = {}
        ss_dict = {}
        recommend = user_list['recommend']
        for sy in mongo.get_group(bot_id).find({"code": recommend}):
            recommend_id = sy['user_id']
            recommend_code = sy['code']
            recommend_grade = sy['grade']
            now = datetime.datetime.now()
    
            # 计算明天的日期
            tomorrow = now + timedelta(days=1)
    
            # 将时间调整到凌晨0点0分
            midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
    
            # 转换为字符串格式
            if recommend_grade == 'vip':
                midnight_tomorrow_str = '9999-12-1 00:00:00'
            else:
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                dt_plus_24h = dt + timedelta(hours=24)
                midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")

            now_mining_machine_id = str(uuid.uuid4())
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            
            
            ZD = mongo.jlzhidu.find_one({'projectname': '上一代'})
            energy_sales = ZD['energy_sales']
            jl = zzhzcad(Decimal(str(sl)) * Decimal(str(energy_sales)))
                    
            
            data = {
                '_id': now_mining_machine_id,
                'type': '能量销售额奖励',
                'projectname': projectname,
                'mining_machine_id': '无',
                'user_id': user_id,
                'sl': jl,
                'midnight_tomorrow_str': midnight_tomorrow_str,
                'state': 0,
                'timer': timer
            }
            data[str(recommend_id)] = {'state': 0, 'projectname': '上一代'}
            
            try:
                recommend_lang = sy['lang']
                if recommend_lang == 'zh':
                    if recommend_grade == 'vip':
                        fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx        
                        '''
                    else:
                        fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx     
佣金将在24小时内失效
                        '''
                    yjfs(recommend_id,fstext)
                else:
                    if recommend_grade == 'vip':
                        fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx 
                        '''
                    else:
                        fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx   
Commission will expire in 24 hours
                        '''
                    enyjfs(recommend_id,fstext)
            except:
                pass
            mongo.jiangli.insert_one(data)
            if 'recommend' in sy.keys():
                sy_recommend = sy['recommend']
                for se in mongo.get_group(bot_id).find({"code": sy_recommend}):
                    recommend_id = se['user_id']
                    recommend_code = se['code']
                    recommend_grade = se['grade']
                    now = datetime.datetime.now() 
            
                    # 计算明天的日期
                    tomorrow = now + timedelta(days=1)
            
                    # 将时间调整到凌晨0点0分
                    midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
            
                    # 转换为字符串格式
                    if recommend_grade == 'vip':
                        midnight_tomorrow_str = '9999-12-1 00:00:00'
                    else:
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                        dt_plus_24h = dt + timedelta(hours=24)
                        midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                    now_mining_machine_id = str(uuid.uuid4())
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    
                    ZD = mongo.jlzhidu.find_one({'projectname': '上二代'})
                    energy_sales = ZD['energy_sales']
                    jl = zzhzcad(Decimal(str(sl)) * Decimal(str(energy_sales)))
                    
                    data = {
                        '_id': now_mining_machine_id,
                        'type': '能量销售额奖励',
                        'projectname': projectname,
                        'mining_machine_id': '无',
                        'user_id': user_id,
                        'sl': jl,
                        'midnight_tomorrow_str': midnight_tomorrow_str,
                        'state': 0,
                        'timer': timer
                    }
                    data[str(recommend_id)] = {'state': 0, 'projectname': '上二代'}
                    
                    
                    try:
                        recommend_lang = se['lang']
                        if recommend_lang == 'zh':
                            if recommend_grade == 'vip':
                                fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx        
                                '''
                            else:
                                fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx     
佣金将在24小时内失效
                                '''
                            yjfs(recommend_id,fstext)
                        else:
                            if recommend_grade == 'vip':
                                fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx 
                                '''
                            else:
                                fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx   
Commission will expire in 24 hours
                                '''
                            enyjfs(recommend_id,fstext)
                    except:
                        pass
                    
                    
                    mongo.jiangli.insert_one(data)
                    
                    if 'recommend' in se.keys():
                        se_recommend = se['recommend']
                        for ss in mongo.get_group(bot_id).find({"code": se_recommend}):
                            recommend_id = ss['user_id']
                            recommend_code = ss['code']
                            recommend_grade = ss['grade']
                            now = datetime.datetime.now() 
                    
                            # 计算明天的日期
                            tomorrow = now + timedelta(days=1)
                    
                            # 将时间调整到凌晨0点0分
                            midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
                    
                            # 转换为字符串格式
                            if recommend_grade == 'vip':
                                midnight_tomorrow_str = '9999-12-1 00:00:00'
                            else:
                                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                                dt_plus_24h = dt + timedelta(hours=24)
                                midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                            now_mining_machine_id = str(uuid.uuid4())
                            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                            
                            ZD = mongo.jlzhidu.find_one({'projectname': '上三代'})
                            energy_sales = ZD['energy_sales']
                            jl = zzhzcad(Decimal(str(sl)) * Decimal(str(energy_sales)))
                    
                            data = {
                                '_id': now_mining_machine_id,
                                'type': '能量销售额奖励',
                                'projectname': projectname,
                                'mining_machine_id': '无',
                                'user_id': user_id,
                                'sl': jl,
                                'midnight_tomorrow_str': midnight_tomorrow_str,
                                'state': 0,
                                'timer': timer
                            }
                            data[str(recommend_id)] = {'state': 0, 'projectname': '上三代'}
                            
                            try:
                                recommend_lang = ss['lang']
                                if recommend_lang == 'zh':
                                    if recommend_grade == 'vip':
                                        fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx        
                                        '''
                                    else:
                                        fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx     
佣金将在24小时内失效
                                        '''
                                    yjfs(recommend_id,fstext)
                                else:
                                    if recommend_grade == 'vip':
                                        fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx 
                                        '''
                                    else:
                                        fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx   
Commission will expire in 24 hours
                                        '''
                                    enyjfs(recommend_id,fstext)
                            except:
                                pass
                            
                            mongo.jiangli.insert_one(data)
        
    code = user_list['code']
    if list(mongo.get_group(bot_id).find_one({"recommend": code})) != []:
        xyidailist = {}
        xerdailist = {}
        xsandailist = {}
        for xy in mongo.get_group(bot_id).find({"recommend": code}):
            recommend_id = xy['user_id']
            recommend_code = xy['code']
            recommend_grade = xy['grade']
            now = datetime.datetime.now() 
    
            # 计算明天的日期
            tomorrow = now + timedelta(days=1)
    
            # 将时间调整到凌晨0点0分
            midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
    
            # 转换为字符串格式
            if recommend_grade == 'vip':
                midnight_tomorrow_str = '9999-12-1 00:00:00'
            else:
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                dt_plus_24h = dt + timedelta(hours=24)
                midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
            now_mining_machine_id = str(uuid.uuid4())
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            
            ZD = mongo.jlzhidu.find_one({'projectname': '下一代'})
            energy_sales = ZD['energy_sales']
            jl = zzhzcad(Decimal(str(sl)) * Decimal(str(energy_sales)))
                    
            data = {
                '_id': now_mining_machine_id,
                'type': '能量销售额奖励',
                'projectname': projectname,
                'mining_machine_id': '无',
                'user_id': user_id,
                'sl': jl,
                'midnight_tomorrow_str': midnight_tomorrow_str,
                'state': 0,
                'timer': timer
            }
            data[str(recommend_id)] = {'state': 0, 'projectname': '下一代'}
            try:
                recommend_lang = xy['lang']
                if recommend_lang == 'zh':
                    if recommend_grade == 'vip':
                        fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx        
                        '''
                    else:
                        fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx     
佣金将在24小时内失效
                        '''
                    yjfs(recommend_id,fstext)
                else:
                    if recommend_grade == 'vip':
                        fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx 
                        '''
                    else:
                        fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx   
Commission will expire in 24 hours
                        '''
                    enyjfs(recommend_id,fstext)
            except:
                pass
            mongo.jiangli.insert_one(data)
            xy_code = xy['code']
            for xe in mongo.get_group(bot_id).find({"recommend": xy_code}):
                xe_id = xe['user_id']
                recommend_id = xe['user_id']
                recommend_code = xe['code']
                recommend_grade = xe['grade']
                now = datetime.datetime.now() 
        
                # 计算明天的日期
                tomorrow = now + timedelta(days=1)
        
                # 将时间调整到凌晨0点0分
                midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
        
                # 转换为字符串格式
                if recommend_grade == 'vip':
                    midnight_tomorrow_str = '9999-12-1 00:00:00'
                else:
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                    dt_plus_24h = dt + timedelta(hours=24)
                    midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                now_mining_machine_id = str(uuid.uuid4())
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                
                ZD = mongo.jlzhidu.find_one({'projectname': '下二代'})
                energy_sales = ZD['energy_sales']
                jl = zzhzcad(Decimal(str(sl)) * Decimal(str(energy_sales)))
                    
                data = {
                    '_id': now_mining_machine_id,
                    'type': '能量销售额奖励',
                    'projectname': projectname,
                    'mining_machine_id': '无',
                    'user_id': user_id,
                    'sl': jl,
                    'midnight_tomorrow_str': midnight_tomorrow_str,
                    'state': 0,
                    'timer': timer
                }
                data[str(recommend_id)] = {'state': 0, 'projectname': '下二代'}
                try:
                    recommend_lang = xe['lang']
                    if recommend_lang == 'zh':
                        if recommend_grade == 'vip':
                            fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx        
                            '''
                        else:
                            fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx     
佣金将在24小时内失效
                            '''
                        yjfs(recommend_id,fstext)
                    else:
                        if recommend_grade == 'vip':
                            fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx 
                            '''
                        else:
                            fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx   
Commission will expire in 24 hours
                            '''
                        enyjfs(recommend_id,fstext)
                except:
                    pass
                mongo.jiangli.insert_one(data)
                xe_code = xe['code']
                for xs in mongo.get_group(bot_id).find({"recommend": xe_code}):
                    xs_id = xs['user_id']
                    recommend_id = xs['user_id']
                    recommend_code = xs['code']
                    recommend_grade = xs['grade']
                    now = datetime.datetime.now() 
            
                    # 计算明天的日期
                    tomorrow = now + timedelta(days=1)
            
                    # 将时间调整到凌晨0点0分
                    midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
            
                    # 转换为字符串格式
                    if recommend_grade == 'vip':
                        midnight_tomorrow_str = '9999-12-1 00:00:00'
                    else:
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                        dt_plus_24h = dt + timedelta(hours=24)
                        midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                    now_mining_machine_id = str(uuid.uuid4())
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    
                    ZD = mongo.jlzhidu.find_one({'projectname': '下三代'})
                    energy_sales = ZD['energy_sales']
                    jl = zzhzcad(Decimal(str(sl)) * Decimal(str(energy_sales)))
                    
                    data = {
                        '_id': now_mining_machine_id,
                        'type': '能量销售额奖励',
                        'projectname': projectname,
                        'mining_machine_id': '无',
                        'user_id': user_id,
                        'sl': jl,
                        'midnight_tomorrow_str': midnight_tomorrow_str,
                        'state': 0,
                        'timer': timer
                    }
                    data[str(recommend_id)] = {'state': 0, 'projectname': '下三代'}
                    try:
                        recommend_lang = xs['lang']
                        if recommend_lang == 'zh':
                            if recommend_grade == 'vip':
                                fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx        
                                '''
                            else:
                                fstext = f'''
收到{trc20} 能量销售额佣金{jl}Trx     
佣金将在24小时内失效
                                '''
                            yjfs(recommend_id,fstext)
                        else:
                            if recommend_grade == 'vip':
                                fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx 
                                '''
                            else:
                                fstext = f'''
Received {trc20} Energy Sales Commission {jl}Trx   
Commission will expire in 24 hours
                                '''
                            enyjfs(recommend_id,fstext)
                    except:
                        pass
                    mongo.jiangli.insert_one(data)


def usduiyongjin(context: CallbackContext):
    bot_id = context.bot.id
    user_id = context.job.context['user_id']
    money = context.job.context['money']
    trc20 = context.job.context['trc20']
    projectname = context.job.context['projectname']
    if projectname == 'Usdt兑Trx':
        beishu = mongo.shang_text.find_one({'projectname': '兑出差'})['text']
        sl = zzhzcad(Decimal(str(money)) * Decimal(str(beishu)))
    else:
        beishu = mongo.shang_text.find_one({'projectname': '兑入差'})['text']
        sl = zzhzcad(Decimal(str(money)) * Decimal(str(beishu)))
    user_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
    if 'recommend' in user_list.keys():
        sy_dict = {}
        se_dict = {}
        ss_dict = {}
        recommend = user_list['recommend']
        for sy in mongo.get_group(bot_id).find({"code": recommend}):
            recommend_id = sy['user_id']
            recommend_code = sy['code']
            recommend_grade = sy['grade']
            now = datetime.datetime.now()
    
            # 计算明天的日期
            tomorrow = now + timedelta(days=1)
    
            # 将时间调整到凌晨0点0分
            midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
    
            # 转换为字符串格式
            if recommend_grade == 'vip':
                midnight_tomorrow_str = '9999-12-1 00:00:00'
            else:
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                dt_plus_24h = dt + timedelta(hours=24)
                midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
            now_mining_machine_id = str(uuid.uuid4())
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            
            
            ZD = mongo.jlzhidu.find_one({'projectname': '上一代'})
            Computational = ZD['Computational']
            jl = zzhzcad(Decimal(str(sl)) * Decimal(str(Computational)))
            
            data = {
                '_id': now_mining_machine_id,
                'type': '闪兑奖励',
                'projectname': projectname,
                'mining_machine_id': '无',
                'user_id': user_id,
                'sl': jl,
                'midnight_tomorrow_str': midnight_tomorrow_str,
                'state': 0,
                'timer': timer
            }
            data[str(recommend_id)] = {'state': 0, 'projectname': '上一代'}
            try:
                recommend_lang = sy['lang']
                if recommend_lang == 'zh':
                    if recommend_grade == 'vip':
                        fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx        
                            '''
                    else:
                        fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx     
佣金将在24小时内失效
                        '''
                    yjfs(recommend_id,fstext)
                else:
                    if recommend_grade == 'vip':
                        fstext = f'''
Received {trc20} Flash Commission {jl}Trx      
                        '''
                    else:
                        fstext = f'''
Received {trc20} Flash Commission {jl}Trx       
Commission will expire in 24 hours
                        '''
                    enyjfs(recommend_id,fstext)
            except:
                pass
            mongo.jiangli.insert_one(data)
            if 'recommend' in sy.keys():
                sy_recommend = sy['recommend']
                for se in mongo.get_group(bot_id).find({"code": sy_recommend}):
                    recommend_id = se['user_id']
                    recommend_code = se['code']
                    recommend_grade = se['grade']
                    now = datetime.datetime.now() 
            
                    # 计算明天的日期
                    tomorrow = now + timedelta(days=1)
            
                    # 将时间调整到凌晨0点0分
                    midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
            
                    # 转换为字符串格式
                    if recommend_grade == 'vip':
                        midnight_tomorrow_str = '9999-12-1 00:00:00'
                    else:
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                        dt_plus_24h = dt + timedelta(hours=24)
                        midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                    now_mining_machine_id = str(uuid.uuid4())
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    
                    ZD = mongo.jlzhidu.find_one({'projectname': '上二代'})
                    Computational = ZD['Computational']
                    jl = zzhzcad(Decimal(str(sl)) * Decimal(str(Computational)))
                    data = {
                        '_id': now_mining_machine_id,
                        'type': '闪兑奖励',
                        'projectname': projectname,
                        'mining_machine_id': '无',
                        'user_id': user_id,
                        'sl': jl,
                        'midnight_tomorrow_str': midnight_tomorrow_str,
                        'state': 0,
                        'timer': timer
                    }
                    data[str(recommend_id)] = {'state': 0, 'projectname': '上二代'}
                    
                    
                    try:
                        recommend_lang = se['lang']
                        if recommend_lang == 'zh':
                            if recommend_grade == 'vip':
                                fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx        
                                    '''
                            else:
                                fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx     
佣金将在24小时内失效
                                '''
                            yjfs(recommend_id,fstext)
                        else:
                            if recommend_grade == 'vip':
                                fstext = f'''
Received {trc20} Flash Commission {jl}Trx      
                                '''
                            else:
                                fstext = f'''
Received {trc20} Flash Commission {jl}Trx       
Commission will expire in 24 hours
                                '''
                            enyjfs(recommend_id,fstext)
                    except:
                        pass
                    
                    
                    mongo.jiangli.insert_one(data)
                    
                    if 'recommend' in se.keys():
                        se_recommend = se['recommend']
                        for ss in mongo.get_group(bot_id).find({"code": se_recommend}):
                            recommend_id = ss['user_id']
                            recommend_code = ss['code']
                            recommend_grade = ss['grade']
                            now = datetime.datetime.now() 
                    
                            # 计算明天的日期
                            tomorrow = now + timedelta(days=1)
                    
                            # 将时间调整到凌晨0点0分
                            midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
                    
                            # 转换为字符串格式
                            if recommend_grade == 'vip':
                                midnight_tomorrow_str = '9999-12-1 00:00:00'
                            else:
                                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                                dt_plus_24h = dt + timedelta(hours=24)
                                midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                            now_mining_machine_id = str(uuid.uuid4())
                            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                            
                            ZD = mongo.jlzhidu.find_one({'projectname': '上三代'})
                            Computational = ZD['Computational']
                            jl = zzhzcad(Decimal(str(sl)) * Decimal(str(Computational)))
                            data = {
                                '_id': now_mining_machine_id,
                                'type': '闪兑奖励',
                                'projectname': projectname,
                                'mining_machine_id': '无',
                                'user_id': user_id,
                                'sl': jl,
                                'midnight_tomorrow_str': midnight_tomorrow_str,
                                'state': 0,
                                'timer': timer
                            }
                            data[str(recommend_id)] = {'state': 0, 'projectname': '上三代'}
                            
                            try:
                                recommend_lang = ss['lang']
                                if recommend_lang == 'zh':
                                    if recommend_grade == 'vip':
                                        fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx        
                                            '''
                                    else:
                                        fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx     
佣金将在24小时内失效
                                        '''
                                    yjfs(recommend_id,fstext)
                                else:
                                    if recommend_grade == 'vip':
                                        fstext = f'''
Received {trc20} Flash Commission {jl}Trx      
                                        '''
                                    else:
                                        fstext = f'''
Received {trc20} Flash Commission {jl}Trx       
Commission will expire in 24 hours
                                        '''
                                    enyjfs(recommend_id,fstext)
                            except:
                                pass
                            
                            mongo.jiangli.insert_one(data)
        
    code = user_list['code']
    if list(mongo.get_group(bot_id).find_one({"recommend": code})) != []:
        xyidailist = {}
        xerdailist = {}
        xsandailist = {}
        for xy in mongo.get_group(bot_id).find({"recommend": code}):
            recommend_id = xy['user_id']
            recommend_code = xy['code']
            recommend_grade = xy['grade']
            now = datetime.datetime.now() 
    
            # 计算明天的日期
            tomorrow = now + timedelta(days=1)
    
            # 将时间调整到凌晨0点0分
            midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
    
            # 转换为字符串格式
            if recommend_grade == 'vip':
                midnight_tomorrow_str = '9999-12-1 00:00:00'
            else:
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                dt_plus_24h = dt + timedelta(hours=24)
                midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
            now_mining_machine_id = str(uuid.uuid4())
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            
            ZD = mongo.jlzhidu.find_one({'projectname': '下一代'})
            Computational = ZD['Computational']
            jl = zzhzcad(Decimal(str(sl)) * Decimal(str(Computational)))
            data = {
                '_id': now_mining_machine_id,
                'type': '闪兑奖励',
                'projectname': projectname,
                'mining_machine_id': '无',
                'user_id': user_id,
                'sl': jl,
                'midnight_tomorrow_str': midnight_tomorrow_str,
                'state': 0,
                'timer': timer
            }
            data[str(recommend_id)] = {'state': 0, 'projectname': '下一代'}
            try:
                recommend_lang = xy['lang']
                if recommend_lang == 'zh':
                    if recommend_grade == 'vip':
                        fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx        
                            '''
                    else:
                        fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx     
佣金将在24小时内失效
                        '''
                    yjfs(recommend_id,fstext)
                else:
                    if recommend_grade == 'vip':
                        fstext = f'''
Received {trc20} Flash Commission {jl}Trx      
                        '''
                    else:
                        fstext = f'''
Received {trc20} Flash Commission {jl}Trx       
Commission will expire in 24 hours
                        '''
                    enyjfs(recommend_id,fstext)
            except:
                pass
            mongo.jiangli.insert_one(data)
            xy_code = xy['code']
            for xe in mongo.get_group(bot_id).find({"recommend": xy_code}):
                xe_id = xe['user_id']
                recommend_id = xe['user_id']
                recommend_code = xe['code']
                recommend_grade = xe['grade']
                now = datetime.datetime.now() 
        
                # 计算明天的日期
                tomorrow = now + timedelta(days=1)
        
                # 将时间调整到凌晨0点0分
                midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
        
                # 转换为字符串格式
                if recommend_grade == 'vip':
                    midnight_tomorrow_str = '9999-12-1 00:00:00'
                else:
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                    dt_plus_24h = dt + timedelta(hours=24)
                    midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                now_mining_machine_id = str(uuid.uuid4())
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                
                ZD = mongo.jlzhidu.find_one({'projectname': '下二代'})
                Computational = ZD['Computational']
                jl = zzhzcad(Decimal(str(sl)) * Decimal(str(Computational)))
                data = {
                    '_id': now_mining_machine_id,
                    'type': '闪兑奖励',
                    'projectname': projectname,
                    'mining_machine_id': '无',
                    'user_id': user_id,
                    'sl': jl,
                    'midnight_tomorrow_str': midnight_tomorrow_str,
                    'state': 0,
                    'timer': timer
                }
                data[str(recommend_id)] = {'state': 0, 'projectname': '下二代'}
                try:
                    recommend_lang = xe['lang']
                    if recommend_lang == 'zh':
                        if recommend_grade == 'vip':
                            fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx        
                                '''
                        else:
                            fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx     
佣金将在24小时内失效
                            '''
                        yjfs(recommend_id,fstext)
                    else:
                        if recommend_grade == 'vip':
                            fstext = f'''
Received {trc20} Flash Commission {jl}Trx      
                            '''
                        else:
                            fstext = f'''
Received {trc20} Flash Commission {jl}Trx       
Commission will expire in 24 hours
                            '''
                        enyjfs(recommend_id,fstext)
                except:
                    pass
                mongo.jiangli.insert_one(data)
                xe_code = xe['code']
                for xs in mongo.get_group(bot_id).find({"recommend": xe_code}):
                    xs_id = xs['user_id']
                    recommend_id = xs['user_id']
                    recommend_code = xs['code']
                    recommend_grade = xs['grade']
                    now = datetime.datetime.now() 
            
                    # 计算明天的日期
                    tomorrow = now + timedelta(days=1)
            
                    # 将时间调整到凌晨0点0分
                    midnight_tomorrow = datetime.datetime(tomorrow.year, tomorrow.month, tomorrow.day, 0, 0)
            
                    # 转换为字符串格式
                    if recommend_grade == 'vip':
                        midnight_tomorrow_str = '9999-12-1 00:00:00'
                    else:
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        dt = datetime.datetime.strptime(timer, "%Y-%m-%d %H:%M:%S")
                        dt_plus_24h = dt + timedelta(hours=24)
                        midnight_tomorrow_str = dt_plus_24h.strftime("%Y-%m-%d %H:%M:%S")
                    now_mining_machine_id = str(uuid.uuid4())
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    
                    ZD = mongo.jlzhidu.find_one({'projectname': '下三代'})
                    Computational = ZD['Computational']
                    jl = zzhzcad(Decimal(str(sl)) * Decimal(str(Computational)))
                    
                    
                    data = {
                        '_id': now_mining_machine_id,
                        'type': '闪兑奖励',
                        'projectname': projectname,
                        'mining_machine_id': '无',
                        'user_id': user_id,
                        'sl': jl,
                        'midnight_tomorrow_str': midnight_tomorrow_str,
                        'state': 0,
                        'timer': timer
                    }
                    data[str(recommend_id)] = {'state': 0, 'projectname': '下三代'}
                    try:
                        recommend_lang = xs['lang']
                        if recommend_lang == 'zh':
                            if recommend_grade == 'vip':
                                fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx        
                                    '''
                            else:
                                fstext = f'''
收到{trc20} 闪兑佣金{jl}Trx     
佣金将在24小时内失效
                                '''
                            yjfs(recommend_id,fstext)
                        else:
                            if recommend_grade == 'vip':
                                fstext = f'''
Received {trc20} Flash Commission {jl}Trx      
                                '''
                            else:
                                fstext = f'''
Received {trc20} Flash Commission {jl}Trx       
Commission will expire in 24 hours
                                '''
                            enyjfs(recommend_id,fstext)
                    except:
                        pass
                    mongo.jiangli.insert_one(data)






def usdtshandui(context: CallbackContext):
    bot_id = context.bot.id
    
    mongouserlog = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    mongobdadd = mongo.get_bdadd(bot_id)
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    a = sd['timer']
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    if mongouserlog.find_one({'tranhash': tranhash}) is None:
        onwer_url = context.job.context['ownerAddress']
        value = context.job.context['money']
        block_timestamp = context.job.context['timestamp']
        if mongouserlog.find_one({'tranhash': tranhash}) is None:
            today_money = float(value)
            mintrx = mongo.shang_text.find_one({'projectname': '最小TRX闪兑'})['text']
            if today_money >= mintrx:
                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                huilv = mongo.shang_text.find_one({'projectname': '波场汇率'})['text']
                duirucha = mongo.shang_text.find_one({'projectname': '兑入差'})['text']
                sign = sd['sign']
                
                USDT = contract.functions.balanceOf(onwer_url) / 1000000
                if float(USDT) == 0:
                    kwmoney = float(Decimal(str(today_money)) - Decimal('30'))
                else:
                    kwmoney = float(Decimal(str(today_money)) - Decimal('15'))
                win = Decimal(str(kwmoney)) / (Decimal(str(huilv)) + Decimal(str(duirucha)))
                win = round(float(win), 2)
                clwin = str(win)[0:8]
                USDT = sd['USDT']
                while True:
                    sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
                    USDT = sd['USDT']
                    trc20 = sd['trc20']
                    a = sd['timer']
                    sign = sd['sign']
                    
                    if USDT >= float(win):
                        if mongouser.find_one({'trc_url': {"$regex": onwer_url}}) != None:
                            user_list = mongouser.find_one({'trc_url': {"$regex": onwer_url}})
                            user_id = user_list['user_id']
                            lang = user_list['lang']
                            while 1:
                                try:
                                    txndata = zhuanu(trc20, onwer_url, float(win))
                                    break
                                except Exception as f:
                                    with open('签名助手异常.txt', 'a+') as rz:
                                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                        rz.write(f'{timer} {f}\n')
                                    time.sleep(1)
                            txid = txndata['txid']
                            
                            
                            if lang == 'zh':
                                text = f'''
您使用{today_money}Trx闪兑{float(clwin)}Usdt已成功
<a href="https://tronscan.org/#/transaction/{txid}">请查收</a>
                                '''
                                
                            else:
                                text = f'''
Your use of {today_money}Trx to flash {float(clwin)}Usdt has been successful!
<a href="https://tronscan.org/#/transaction/{txid}">Please check.</a>
                                '''
                            
                            keyboard = [[InlineKeyboardButton(langdict[lang]['kbEnergy purchases'], callback_data='comtron')]]
                            try:
                                context.bot.send_message(chat_id=user_id, text=text, parse_mode='HTML',disable_web_page_preview=True,reply_markup=InlineKeyboardMarkup(keyboard))
                            except:
                                pass
                            order_id = str(uuid.uuid4()) 
                            mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Trx', user_id, onwer_url, 'Trx兑Usdt',
                                              float(clwin), today_money,
                                              f'Trx兑Usdt\n<code>{onwer_url}</code>转<code>{today_money}</code>TRX至<code>{to_url}</code>\n成功兑换<code>{float(clwin)}</code>Usdt',
                                              tranhash, timer)
    
                            us_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
                            us_firstname = us_list['firstname']
                            us_username = us_list['username']

                            text = f'''
用户: <a href="tg://user?id={user_id}">{us_firstname}</a> @{us_username} Trx兑Usdt
地址: <code>{onwer_url}</code>
使用{today_money}Trx闪兑{float(clwin)}Usdt已成功
<a href="https://tronscan.org/#/transaction/{txid}">闪兑详细</a>
                '''
                            for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                                try:
                                    context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                             disable_web_page_preview=True)
                                except:
                                    continue
                            context.job_queue.run_once(usduiyongjin, 1,context={'user_id': user_id,'money': float(clwin),'trc20': onwer_url, 'projectname': 'Trx兑Usdt'})
                            qian = onwer_url[0:4]
                            hou = onwer_url[-4:]
                            chat_text = f'''
{qian}...{hou} 兑换成功：{today_money} TRX = {clwin} USDT，交易HASH：{txid}   
'''
                            for ch in list(mongo.user_status.find({})):
                                chid = ch['chat_id']
                                try:
                                    context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                             disable_web_page_preview=True)
                                except:
                                    continue
    
                        else:
                            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())

                            while 1:
                                try:
                                    txndata = zhuanu(trc20, onwer_url, float(win))
                                    break
                                except Exception as f:
                                    with open('签名助手异常.txt', 'a+') as rz:
                                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                        rz.write(f'{timer} {f}\n')
                                    time.sleep(1)
                            txid = txndata['txid']
                            
                            order_id = str(uuid.uuid4()) 
                            mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Trx', '', onwer_url, 'Trx兑Usdt',
                                              float(clwin), today_money,
                                              f'Trx兑Usdt\n<code>{onwer_url}</code>转<code>{today_money}</code>TRX至<code>{to_url}</code>\n成功兑换<code>{float(clwin)}</code>Usdt',
                                              tranhash, timer)
    
                            text = f'''
地址: <code>{onwer_url}</code>
使用{today_money}Trx闪兑{float(clwin)}Usdt已成功
<a href="https://tronscan.org/#/transaction/{txid}">闪兑详细</a>
                    '''
                            for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                                try:
                                    context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                             disable_web_page_preview=True)
                                except:
                                    continue
                            
                            qian = onwer_url[0:4]
                            hou = onwer_url[-4:]
                            chat_text = f'''
{qian}...{hou} 兑换成功：{today_money} TRX = {clwin} USDT，交易HASH：{txid}   
'''
                            for ch in list(mongo.user_status.find({})):
                                chid = ch['chat_id']
                                try:
                                    context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                             disable_web_page_preview=True)
                                except:
                                    continue
                                
                                
                            
                        mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'USDTstate': 0}})
                        break
                    else:
                        USDTstate = sd['USDTstate']
                        buzumoney = Decimal(str(clwin)) - Decimal(str(USDT))
                        if USDTstate == 0:
                            mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'USDTstate': 1}})
                            qwer = f'''
闪兑钱包
<code>{trc20}</code>不足闪兑
{clwin}USDT,现有余额{USDT}Usdt,差{buzumoney}Usdt  
<a href="https://tronscan.org/#/transaction/{tranhash}">转账详细</a>
                            '''
                            for i in list(mongouser.find({'state': '4'})):
                                context.bot.send_message(chat_id=i['user_id'],
                                                         text=qwer,
                                                         parse_mode='HTML',disable_web_page_preview=True)
                    time.sleep(3)
                    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
                    USDT = contract.functions.balanceOf(trc20) / 1000000
                    try:
                        TRX = client.get_account_balance(trc20)
                    except:
                        TRX = 0
                    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
            else:
                for j in list(mongobdadd.find({'today_money': today_money})):
                    if today_money == j['today_money']:
                        user_list = mongouser.find_one({'user_id': j['user_id']})
                        TRX = user_list['TRX']
                        user_money = float((Decimal(str(TRX)) + Decimal(str(today_money))).quantize(Decimal('0.001')))
                        if mongouser.find_one({"trc_url": {"$regex": onwer_url}}) is None:
                            if mongouser.find_one({'trc_url': {'$ne': None}, 'user_id': j['user_id']}) is None:
                                mongouser.update_one({'user_id': j['user_id']},
                                                     {'$set': {"trc_url": onwer_url, "TRX": user_money}})
                                mongobdadd.delete_one({'user_id': j['user_id']})
                                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                try:
                                    context.bot.send_message(chat_id=j['user_id'],
                                                             text=f'恭喜您认证成功啦！\n\n您绑定的地址为：{onwer_url}')
                                    order_id = str(uuid.uuid4()) 
                                    mongo.userlogdata(bot_id, order_id, block_timestamp, '', 'Trx', j['user_id'], onwer_url,
                                                      '绑定地址', 0, j['today_money'],
                                                      f'用户转账{j["today_money"]}TRX绑定地址', tranhash, timer)
                                    user_list = mongouser.find_one({'user_id': j['user_id']})
                                    TRX = user_list['TRX']
                                    trc_list = []
                                    for i in list(mongouser.find({'user_id': j['user_id'], 'trc_url': {'$ne': None}})):
                                        for tc in i['trc_url'].split(','):
                                            trc_list.append(f'<code>{tc}</code>')
                                    if trc_list == []:
                                        trc_list = ''
                                    else:
                                        trc_list = '已绑定地址:\n' + "\n".join(trc_list)
                                    text = f'''
账户ID：
<code>{j["user_id"]}</code>

余额：
<code>{TRX}</code> TRX

{trc_list}
                                            '''
                                    keyboard = [
                                        [InlineKeyboardButton('闪兑报表', callback_data='usershanduibb'),
                                         InlineKeyboardButton('闪兑明细', callback_data='flashexchange')],
                                        [InlineKeyboardButton('能量报表', callback_data='usernengliangbaobiao'),
                                         InlineKeyboardButton('能量明细', callback_data='usernengliangmingxi')]
                                    ]
                                    context.bot.send_message(chat_id=j["user_id"], text=text,
                                                             parse_mode='HTML',
                                                             reply_markup=InlineKeyboardMarkup(keyboard))
                                except:
                                    pass

                            else:
                                trc20 = mongouser.find_one({'user_id': j['user_id']})['trc_url']
                                mongouser.update_one({'user_id': j['user_id']}, {'$set': {"TRX": user_money}})
                                if onwer_url not in trc20:
                                    mongouser.update_one({'user_id': j['user_id']},
                                                         {'$set': {"trc_url": trc20 + f',{onwer_url}'}})
                                    mongobdadd.delete_one({'user_id': j['user_id']})
                                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                    try:
                                        context.bot.send_message(chat_id=j['user_id'],
                                                                 text=f'恭喜您认证成功啦！\n\n您绑定的地址为：{onwer_url}')
                                        order_id = str(uuid.uuid4()) 
                                        mongo.userlogdata(bot_id, order_id, block_timestamp, '', 'Trx', j['user_id'], onwer_url,
                                                          '绑定地址', 0, j['today_money'],
                                                          f'用户转账{j["today_money"]}TRX绑定地址', tranhash, timer)
                                        user_list = mongouser.find_one({'user_id': j['user_id']})
                                        TRX = user_list['TRX']
                                        trc_list = []
                                        for i in list(
                                                mongouser.find({'user_id': j['user_id'], 'trc_url': {'$ne': None}})):
                                            for tc in i['trc_url'].split(','):
                                                trc_list.append(f'<code>{tc}</code>')
                                        if trc_list == []:
                                            trc_list = ''
                                        else:
                                            trc_list = '已绑定地址:\n' + "\n".join(trc_list)
                                        text = f'''
账户ID：
<code>{j["user_id"]}</code>

余额：
<code>{TRX}</code> TRX

{trc_list}
                                                '''
                                        keyboard = [
                                            [InlineKeyboardButton('闪兑报表', callback_data='usershanduibb'),
                                             InlineKeyboardButton('闪兑明细', callback_data='flashexchange')],
                                            [InlineKeyboardButton('能量报表', callback_data='usernengliangbaobiao'),
                                             InlineKeyboardButton('能量明细', callback_data='usernengliangmingxi')]
                                        ]
                                        context.bot.send_message(chat_id=j["user_id"], text=text,
                                                                 parse_mode='HTML',
                                                                 reply_markup=InlineKeyboardMarkup(keyboard))
                                    except:
                                        pass
                                else:
                                    mongobdadd.delete_one({'user_id': j['user_id']})
                        else:
                            mongobdadd.delete_one({'user_id': j['user_id']})

            time.sleep(3)
            contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
            USDT = contract.functions.balanceOf(trc20) / 1000000
            try:
                TRX = client.get_account_balance(trc20)
            except:
                TRX = 0
            mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
def Numberoftransfers(update: Update, context: CallbackContext):
    query = update.callback_query
    user_id = query.from_user.id
    query.answer()
    bot_id = context.bot.id
    user_list = mongo.get_group(bot_id).find_one({'user_id': user_id})
    lang = user_list['lang']
    if lang == 'zh':
        text = f'''
❣️提交格式：
接收能量钱包地址|每天转账笔数|租赁天数
换行另一个地址，可同时提交多个地址
温馨提示：租赁天数最少5天起！
例如:
<code>TQYV25QwKLNqWJJfvBgUBwR25kQFFFFFFF|1|3</code>
<code>TJHiSX3Nn6TLQtabyRN9chX4zkS3333333|10|30</code>
        '''
    else:
        text = f'''
❣️ Submission Format:
Receive Energy Wallet Address | Number of Transfers per Day | Number of Lease Days
Change the line to another address, you can submit more than one address at the same time!
Note: Lease days start at a minimum of 5 days!
Example.
<code>TQYV25QwKLNqWJJfvBgUBwR25kQFFFFFFF|1|3</code>
<code>TJHiSX3Nn6TLQtabyRN9chX4zkS3333333|10|30</code>
        '''
    mongo.get_group(bot_id).update_one({"user_id": user_id}, {"$set": {"sign": 'Numberoftransfers'}})
    keyboard = [[InlineKeyboardButton('取消提交', callback_data=f'close {user_id}')]]
    context.bot.send_message(chat_id=user_id, text=text, reply_markup=InlineKeyboardMarkup(keyboard), parse_mode='HTML')


def close(update: Update, context: CallbackContext):
    query = update.callback_query
    chat = query.message.chat
    yh_id = query.data.replace("close ", '')
    bot_id = context.bot.id
    chat_id = chat.id
    user_id = query.from_user.id
    if yh_id == 'all':
        query.answer()
    elif int(yh_id) != user_id:
        query.answer('这不是你的按钮', show_alert=bool("true"))
        return
    mongo.get_group(bot_id).update_one({'user_id': user_id}, {'$set': {'sign': 0}})
    context.bot.deleteMessage(query.from_user.id, query.message.message_id)


def seleudt(context: CallbackContext):
    bot_id = context.bot.id
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
    mongouserlog = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    a = sd['timer']
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    zdstate = 0
    if mongouserlog.find_one({'tranhash': tranhash}) is None:
        onwer_url = context.job.context['ownerAddress']
        value = context.job.context['money']
        block_timestamp = context.job.context['timestamp']
        today_money = float(value)
        TRX = sd['TRX']
        designated_list = mongo.designated.find_one({'money': today_money})
        if designated_list is not None:
            
            dh_id = designated_list['user_id']
            dh_trc20 = designated_list['trc20']
            
            
            huilv = mongo.shang_text.find_one({'projectname': '波场汇率'})['text']
            zdcg = mongo.caigou.find_one({'state': 0}, sort=[("TRX", 1)])
            if zdcg != None:
                bianhao = zdcg['bianhao']
                zdshuliang = zdcg['shuliang']
                zdcgtrx = zdcg['TRX']
                zdmoney = zdcg['money']
                zdstate = 1
                if huilv > zdcgtrx:
                    huilv = zdcgtrx
            
            duichucha = mongo.shang_text.find_one({'projectname': '兑出差'})['text']
            sign = sd['sign']
            client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
            
            win = Decimal(str(today_money)) * (Decimal(str(huilv)) - Decimal(str(duichucha)))
            if zdstate == 1:
                zdmoneysum = Decimal(str(zdmoney)) + win
                mongo.caigou.update_one({'bianhao': bianhao},{"$set":{"money": float(zdmoneysum)}})
                if zdmoneysum >= zdshuliang:
                    mongo.caigou.update_one({'bianhao': bianhao},{"$set":{"state": 1}})
            win = round(float(win), 2)
            clwin = str(win)[0:8]
            while 1:
                sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
                TRX = sd['TRX']
                trc20 = sd['trc20']
                a = sd['timer']
                sign = sd['sign']
                
                if TRX >= float(win):
                    user_list = mongouser.find_one({'user_id': dh_id})
                    user_id = user_list['user_id']

                    while 1:
                        try:
                            txndata = zhuantrx(trc20, dh_trc20, float(win))
                            break
                        except Exception as f:
                            with open('签名助手异常.txt', 'a+') as rz:
                                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                rz.write(f'{timer} {f}\n')
                            time.sleep(1)
                    txid = txndata['txid']
                    
                    text = f'''
您使用{today_money}Usdt闪兑{float(clwin)}Trx已成功
<a href="https://tronscan.org/#/transaction/{txid}">请查收</a>
                    '''
                    mongo.designated.delete_one({'trc20': dh_trc20, 'money': today_money})
                    keyboard = [[InlineKeyboardButton('能量购买', callback_data='comtron')]]
                    context.bot.send_message(chat_id=user_id, text=text, parse_mode='HTML',disable_web_page_preview=True,reply_markup=InlineKeyboardMarkup(keyboard))
                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                    order_id = str(uuid.uuid4()) 
                    mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Usdt', user_id, onwer_url, 'Usdt兑Trx',
                                      today_money, float(clwin),
                                      f'Usdt兑Trx\n<code>{onwer_url}</code>转<code>{today_money}</code>U至<code>{to_url}</code>\n成功兑换<code>{float(clwin)}</code>TRX',
                                      tranhash, timer)

                        
                    us_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
                    us_firstname = us_list['firstname']
                    us_username = us_list['username']

                        
                    text = f'''
用户: <a href="tg://user?id={user_id}">{us_firstname}</a> @{us_username} Usdt兑Trx
转账地址: <code>{onwer_url}</code>
到账地址: <code>{dh_trc20}</code>
使用{today_money}Usdt闪兑{float(clwin)}Trx已成功
<a href="https://tronscan.org/#/transaction/{txid}">闪兑详细</a>
            '''
                    for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                        try:
                            context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                     disable_web_page_preview=True)
                        except:
                            continue
                    context.job_queue.run_once(usduiyongjin, 1,context={'user_id': user_id,'money': today_money,'trc20': onwer_url, 'projectname': 'Usdt兑Trx'})
                    qian = onwer_url[0:4]
                    hou = onwer_url[-4:]
                    chat_text = f'''
{qian}...{hou} 兑换成功：{today_money} Usdt = {clwin} Trx，交易HASH：{txid}   
'''
                    for ch in list(mongo.user_status.find({})):
                        chid = ch['chat_id']
                        try:
                            context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                     disable_web_page_preview=True)
                        except:
                            continue
    
                    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'TRXstate': 0}})
                    break
                else:
                    TRXstate = sd['TRXstate']
                    if TRXstate == 0:
                        mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'TRXstate': 1}})
                        zlqb = mongo.get_wallet(bot_id).find_one({'projectname': '租赁'})
                        zltrc20 = zlqb['trc20']
                        zltrx = zlqb['TRX']
                        zlsign = zlqb['sign']
                        if zltrx >= float(win):
                            while 1:
                                try:
                                    txndata = zhuantrx(trc20, dh_trc20, float(win))
                                    break
                                except Exception as f:
                                    with open('签名助手异常.txt', 'a+') as rz:
                                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                        rz.write(f'{timer} {f}\n')
                                    time.sleep(1)
                            txid = txndata['txid']
                            time.sleep(3)
                            context.job_queue.run_once(seleudt, 1,context={'transaction_id': tranhash,'transferType': 'USDT','ownerAddress': onwer_url,'toAddress': to_url,'money': value,'timestamp': block_timestamp})
                            return
                        else:
                            buzumoney = Decimal(str(clwin)) - Decimal(str(TRX))
                            qwer = f'''
闪兑钱包
<code>{trc20}</code>不足闪兑
{clwin}Trx,现有余额{TRX}Trx,差{buzumoney}Trx     
<a href="https://tronscan.org/#/transaction/{tranhash}">转账详细</a>
                            '''
                            for i in list(mongouser.find({'state': '4'})):
                                context.bot.send_message(chat_id=i['user_id'],
                                                         text=qwer,
                                                         parse_mode='HTML',disable_web_page_preview=True)
                time.sleep(3)
                contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
                USDT = contract.functions.balanceOf(trc20) / 1000000
                try:
                    TRX = client.get_account_balance(trc20)
                except:
                    TRX = 0
                mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                    {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
            time.sleep(3)
            contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
            USDT = contract.functions.balanceOf(trc20) / 1000000
            try:
                TRX = client.get_account_balance(trc20)
            except:
                TRX = 0
            mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})

def trxshandui(context: CallbackContext):
    bot_id = context.bot.id
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
    mongouserlog = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    a = sd['timer']
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    zdstate = 0
    if mongouserlog.find_one({'tranhash': tranhash}) is None:
        onwer_url = context.job.context['ownerAddress']
        value = context.job.context['money']
        block_timestamp = context.job.context['timestamp']
        today_money = float(value)
        TRX = sd['TRX']
        minusdt = mongo.shang_text.find_one({'projectname': '最小USDT闪兑'})['text']
        if today_money >= minusdt:
            huilv = mongo.shang_text.find_one({'projectname': '波场汇率'})['text']
            zdcg = mongo.caigou.find_one({'state': 0}, sort=[("TRX", 1)])
            if zdcg != None:
                bianhao = zdcg['bianhao']
                zdshuliang = zdcg['shuliang']
                zdcgtrx = zdcg['TRX']
                zdmoney = zdcg['money']
                zdstate = 1
                if huilv > zdcgtrx:
                    huilv = zdcgtrx
            
            duichucha = mongo.shang_text.find_one({'projectname': '兑出差'})['text']
            sign = sd['sign']
            client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
            
            win = Decimal(str(today_money)) * (Decimal(str(huilv)) - Decimal(str(duichucha)))
            if zdstate == 1:
                zdmoneysum = Decimal(str(zdmoney)) + win
                mongo.caigou.update_one({'bianhao': bianhao},{"$set":{"money": float(zdmoneysum)}})
                if zdmoneysum >= zdshuliang:
                    mongo.caigou.update_one({'bianhao': bianhao},{"$set":{"state": 1}})
            win = round(float(win), 2)
            clwin = str(win)[0:8]
            while 1:
                sd = mongo.get_wallet(bot_id).find_one({'projectname': '闪兑'})
                TRX = sd['TRX']
                trc20 = sd['trc20']
                a = sd['timer']
                sign = sd['sign']
                
                if TRX >= float(win):
                    if mongouser.find_one({'trc_url': {"$regex": onwer_url}}) != None:
                        user_list = mongouser.find_one({'trc_url': {"$regex": onwer_url}})
                        user_id = user_list['user_id']
                        lang = user_list['lang']
                        while 1:
                            try:
                                txndata = zhuantrx(trc20, onwer_url, float(win))
                                break
                            except Exception as f:
                                with open('签名助手异常.txt', 'a+') as rz:
                                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                    rz.write(f'{timer} {f}\n')
                                time.sleep(1)
                        txid = txndata['txid']
                        if lang == 'zh':
                            text = f'''
您使用{today_money}Usdt闪兑{float(clwin)}Trx已成功
<a href="https://tronscan.org/#/transaction/{txid}">请查收</a>
                            '''
                            
                        else:
                            text = f'''
Your use of {today_money}Usdt to flash {float(clwin)}Trx has been successful!
<a href="https://tronscan.org/#/transaction/{txid}">Please check.</a>
                            '''
                        keyboard = [[InlineKeyboardButton(langdict[lang]['kbEnergy purchases'], callback_data='comtron')]]
                        context.bot.send_message(chat_id=user_id, text=text, parse_mode='HTML',disable_web_page_preview=True,reply_markup=InlineKeyboardMarkup(keyboard))
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        order_id = str(uuid.uuid4()) 
                        mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Usdt', user_id, onwer_url, 'Usdt兑Trx',
                                          today_money, float(clwin),
                                          f'Usdt兑Trx\n<code>{onwer_url}</code>转<code>{today_money}</code>U至<code>{to_url}</code>\n成功兑换<code>{float(clwin)}</code>TRX',
                                          tranhash, timer)

                            
                        us_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
                        us_firstname = us_list['firstname']
                        us_username = us_list['username']

                        text = f'''
用户: <a href="tg://user?id={user_id}">{us_firstname}</a> @{us_username} Usdt兑Trx
地址: <code>{onwer_url}</code>
使用{today_money}Usdt闪兑{float(clwin)}Trx已成功
<a href="https://tronscan.org/#/transaction/{txid}">闪兑详细</a>
                '''
                        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                            try:
                                context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
                        context.job_queue.run_once(usduiyongjin, 1,context={'user_id': user_id,'money': today_money,'trc20': onwer_url, 'projectname': 'Usdt兑Trx'})
                        qian = onwer_url[0:4]
                        hou = onwer_url[-4:]
                        chat_text = f'''
{qian}...{hou} 兑换成功：{today_money} Usdt = {clwin} Trx，交易HASH：{txid}   
'''
                        for ch in list(mongo.user_status.find({})):
                            chid = ch['chat_id']
                            try:
                                context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
    
    
                    else:

                        while 1:
                            try:
                                txndata = zhuantrx(trc20, onwer_url, float(win))
                                break
                            except Exception as f:
                                with open('签名助手异常.txt', 'a+') as rz:
                                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                    rz.write(f'{timer} {f}\n')
                                time.sleep(1)
                        txid = txndata['txid']
                        
                        
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        order_id = str(uuid.uuid4()) 
                        mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Usdt', '', onwer_url, 'Usdt兑Trx',
                                          today_money, float(clwin),
                                          f'Usdt兑Trx\n<code>{onwer_url}</code>转<code>{today_money}</code>U至<code>{to_url}</code>\n成功兑换<code>{float(clwin)}</code>TRX',
                                          tranhash, timer)
    
                        text = f'''
该地址未绑定机器人
地址: <code>{onwer_url}</code>
使用{today_money}Usdt闪兑{float(clwin)}Trx已成功
<a href="https://tronscan.org/#/transaction/{txid}">闪兑详细</a>
                '''
                        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                            try:
                                context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue

                        qian = onwer_url[0:4]
                        hou = onwer_url[-4:]
                        chat_text = f'''
{qian}...{hou} 兑换成功：{today_money} Usdt = {clwin} Trx，交易HASH：{txid}   
'''
                        for ch in list(mongo.user_status.find({})):
                            chid = ch['chat_id']
                            try:
                                context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
                    
                    mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'TRXstate': 0}})
                    break
                else:
                    TRXstate = sd['TRXstate']
                    if TRXstate == 0:
                        mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'}, {"$set": {'TRXstate': 1}})
                        zlqb = mongo.get_wallet(bot_id).find_one({'projectname': '租赁'})
                        zltrc20 = zlqb['trc20']
                        zltrx = zlqb['TRX']
                        zlsign = zlqb['sign']
                        if zltrx >= float(win):
                            while 1:
                                try:
                                    txndata = zhuantrx(zltrc20, trc20, float(win))
                                    break
                                except Exception as f:
                                    with open('签名助手异常.txt', 'a+') as rz:
                                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                        rz.write(f'{timer} {f}\n')
                                    time.sleep(1)
                            txid = txndata['txid']
                            
                            time.sleep(3)
                            context.job_queue.run_once(trxshandui, 1,context={'transaction_id': tranhash,'transferType': 'USDT','ownerAddress': onwer_url,'toAddress': to_url,'money': value,'timestamp': block_timestamp})
                            return
                        else:
                            buzumoney = Decimal(str(clwin)) - Decimal(str(TRX))
                            qwer = f'''
闪兑钱包
<code>{trc20}</code>不足闪兑
{clwin}Trx,现有余额{TRX}Trx,差{buzumoney}Trx     
<a href="https://tronscan.org/#/transaction/{tranhash}">转账详细</a>
                            '''
                            for i in list(mongouser.find({'state': '4'})):
                                context.bot.send_message(chat_id=i['user_id'],
                                                         text=qwer,
                                                         parse_mode='HTML',disable_web_page_preview=True)
                time.sleep(3)
                contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
                USDT = contract.functions.balanceOf(trc20) / 1000000
                try:
                    TRX = client.get_account_balance(trc20)
                except:
                    TRX = 0
                mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                    {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
            time.sleep(3)
            contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
            USDT = contract.functions.balanceOf(trc20) / 1000000
            try:
                TRX = client.get_account_balance(trc20)
            except:
                TRX = 0
            mongo.get_wallet(bot_id).update_one({'projectname': '闪兑'},
                                                {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
                                                
def twwebyuefeidan(context: CallbackContext):
    bot_id = context.bot.id
    botname = context.bot.username
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '租赁'})
    mongopledge = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    mongolibrary = mongo.get_library(bot_id)
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    mongo.get_wallet(bot_id).update_one({'projectname': '充值'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    ss_trc20 = sd['trc20']
    a = sd['timer'] 
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    onwer_url = context.job.context['ownerAddress']
    value = context.job.context['money']
    transferType = context.job.context['transferType']
    block_timestamp = context.job.context['timestamp']
    today_money = float(value)
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    
    bal = jianceyonghu(bot_id)
    if float(bal) < today_money:
        text = f'''
飞单失败，备用金已不足支付{today_money}Trx
请充值后重试或选择直接用租赁地址代理能量
        '''
        if mongo.lssj.find_one({"transaction_id": tranhash}) is None:
            weiyiid = str(uuid.uuid4())
        else:
            weiyiid = mongo.lssj.find_one({"transaction_id": tranhash})['bianhao']
            mongo.lssj.update_one({"transaction_id": tranhash},{"$set":{"state": 0}})
        datashuju = {'bianhao': weiyiid, 'transaction_id': tranhash,'transferType': transferType,'ownerAddress': onwer_url,'toAddress': to_url,'money': today_money,'timestamp': block_timestamp, 'state': 0}
        
        keyboard = [
            [InlineKeyboardButton('重新飞单', callback_data=f'zxfeidan {weiyiid}'), InlineKeyboardButton('直接代理', callback_data=f'zxzhiya {weiyiid}')]    
        ]
        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
            context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                     disable_web_page_preview=True, reply_markup=InlineKeyboardMarkup(keyboard))


        if mongo.lssj.find_one({"transaction_id": tranhash}) is None:
            mongo.lssj.insert_one(datashuju)

            
        return
    
    if mongopledge.find_one({'tranhash': tranhash}) is None:
        library_list = mongolibrary.find_one({'today_money': today_money})
        if library_list:
            nenglbaifenb = mongo.shang_text.find_one({'projectname': '获利比例'})['text']
            yuanprice = today_money
            today_money = float(Decimal(str(today_money)) - Decimal(str(today_money)) * (Decimal(str(nenglbaifenb)) / Decimal(str(100))))
            zztrc20 = library_list['trc20']
            zzmoney = library_list['zzmoney']
            uid = library_list['user_id']
            xq = []
            zongbishu = 0
            for dz in zztrc20:
                xq.append(
                    {
                        'countNum': int(dz['pencount']),
                        'dayNum': int(dz['days']),
                        'recAddress': dz['trc20']
                    }    
                    )
                zongbishu += Decimal(str(dz['pencount']))*Decimal(str(dz['days']))
            zongbishu = Decimal(str(13.3959))* zongbishu
            rangli = int(round(Decimal(str(today_money))/zongbishu,2)*100)
            data = { 
"amount": today_money,
"equipmentType": 3,
"orderList": xq,
"scale": rangli,
        }
            # print(data)
            data = json.dumps(data).encode('utf-8')
            key = "Longteng".encode('utf-8')
            # 调用加密函数
            encrypted_data = encrypt(data, key)
            
            encrypted_data = base64.b64encode(encrypted_data).decode('utf-8')
            data = {
                "key": encrypted_data
            }
            
            
            url = 'http://144.202.84.76:8098/tweak/purchase-energy/add'
            response = requests.post(url=url,json=data)
            dingdan = json.loads(response.text)['data']
            data = {
'id': int(dingdan),
'paymentAddress': botname,
'status': 1
            }
            url = 'http://144.202.84.76:8098/tweak/purchase-energy/updateStatus'
            response = requests.post(url=url,json=data)
            us_list = mongo.get_group(bot_id).find_one({"user_id": uid})
            us_firstname = us_list['firstname']
            us_username = us_list['username']    
            us_TRX = us_list['TRX']
            us_id = us_list['user_id']
            fullname = us_list['fullname']
            zytrc20 = []
            yuanlist = []
            dzxq = []
            for dz in zztrc20:
                yuanlist.append(dz["trc20"])
                zytrc20.append(f'<code>{dz["trc20"]}</code>')
                dzxq.append(f'地址: {dz["trc20"]} 每天转账{dz["pencount"]}次，{dz["days"]}天，租赁{dz["zuzhimoney"]}Trx，省{dz["shengmoney"]}Trx')
            zytrc20 = ','.join(zytrc20)
            dzxq = '\n'.join(dzxq)
            
            webxiaofei(bot_id, today_money)
            bal = jianceyonghu(bot_id)
            
            text = f'''
<b>本次订单已飞往TWUK网站</b> 
<b>原价格:{yuanprice} 获利比例:{nenglbaifenb}% 提交价格:{today_money} 备用金剩余: {bal}</b>
用户: <a href="tg://user?id={uid}">{us_firstname}</a> @{us_username} 使用余额进行租赁，消耗{value}Trx，剩{us_TRX}Trx
{dzxq}
    '''
            for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                try:
                    context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                             disable_web_page_preview=True)
                except:
                    continue
                
            fs_text = f'''
此订单在30分钟之内完成！
'''
            try:
                context.bot.send_message(chat_id=uid, text=fs_text, parse_mode='HTML',
                                         disable_web_page_preview=True)
            except:
                pass
                
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            order_id = str(uuid.uuid4())
            mongo.pledge_data('网站飞单',bot_id,order_id, block_timestamp, tranhash, '', uid, ss_trc20, 0,
                              0, value, 0, '能量', zztrc20, 0, '', 0, timer,
                              '')
            mongo.get_pledge(bot_id).update_one({"order_id": order_id},{"$set":{"dingdan": int(dingdan)}})
            order_id = str(uuid.uuid4()) 
            mongo.userlogdata(bot_id, order_id, block_timestamp, '', 'Trx', uid, onwer_url, '能量租赁',
                              0, value,
                              f'飞单往网站',
                              tranhash, timer)
            mongo.get_user_log(bot_id).update_one({"tranhash": tranhash},{"$set":{"beizhu": "网站飞单"}})

               
def webxiaofei(bot_id, money):
    data = {
        "deviceId": str(bot_id),
        "transactionType": 1,
        "reserveFund": money,
        'equipmentType': 3,
    }
    # print(data)
    data = json.dumps(data).encode('utf-8')
    key = "Longteng".encode('utf-8')
    # 调用加密函数
    encrypted_data = encrypt(data, key)
    
    encrypted_data = base64.b64encode(encrypted_data).decode('utf-8')
    data = {
        "key": encrypted_data
    }
    
    url = 'http://144.202.84.76:8098/tweak/device-user/UpdateReserveFund'
    response = requests.post(url=url, json=data)
    text = json.loads(response.text)
    return text
     
     
def del_message(message):
    try:
        message.delete()
    except:
        pass           
     
def zxfeidan(update: Update, context: CallbackContext):
    query = update.callback_query
    bot_id = context.bot.id
    text = query.message.text
    user_id = query.from_user.id
    bianhao = query.data.replace('zxfeidan ','')
    bianhao_list = mongo.lssj.find_one({"bianhao": bianhao})
    state = bianhao_list['state']
    if state == 0:
        
        query.answer('操作成功，已重新飞单', show_alert=bool("true"))
        context.job_queue.run_once(twwebfeidan, 1,context=bianhao_list)
        mongo.lssj.update_one({"bianhao": bianhao},{"$set":{"state": 1}})
        del_message(query.message)
    elif state == 1:
        query.answer('操作失败，已重新飞单', show_alert=bool("true"))
        del_message(query.message)
       
    else:
        query.answer('操作失败，已更换为自己地址出售能量', show_alert=bool("true"))
        del_message(query.message)
        
    
def zxzhiya(update: Update, context: CallbackContext):
    query = update.callback_query
    bot_id = context.bot.id
    text = query.message.text
    user_id = query.from_user.id
    bianhao = query.data.replace('zxzhiya ','')
    bianhao_list = mongo.lssj.find_one({"bianhao": bianhao},{"_id": 0})
    state = bianhao_list['state']
    if state == 0:
        query.answer('操作成功，已直接质押', show_alert=bool("true"))
        context.job_queue.run_once(zhiyanengliang, 1,context=bianhao_list)
        mongo.lssj.update_one({"bianhao": bianhao},{"$set":{"state": 2}})
        del_message(query.message)
    elif state == 1:
        query.answer('操作失败，已重新飞单', show_alert=bool("true"))
        del_message(query.message)
       
    else:
        query.answer('操作失败，已更换为自己地址出售能量', show_alert=bool("true"))
        del_message(query.message)
        
                                                
def twwebfeidan(context: CallbackContext):
    bot_id = context.bot.id
    botname = context.bot.username
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '租赁'})
    mongopledge = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    mongolibrary = mongo.get_library(bot_id)
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    mongo.get_wallet(bot_id).update_one({'projectname': '充值'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    ss_trc20 = sd['trc20']
    a = sd['timer'] 
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    onwer_url = context.job.context['ownerAddress']
    transferType = context.job.context['transferType']
    value = context.job.context['money']
    block_timestamp = context.job.context['timestamp']
    today_money = float(value)
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    bal = jianceyonghu(bot_id)
    if float(bal) < today_money:
        text = f'''
飞单失败，备用金已不足支付{today_money}Trx
请充值后重试或选择直接用租赁地址代理能量
        '''
        if mongo.lssj.find_one({"transaction_id": tranhash}) is None:
            weiyiid = str(uuid.uuid4())
        else:
            weiyiid = mongo.lssj.find_one({"transaction_id": tranhash})['bianhao']
            mongo.lssj.update_one({"transaction_id": tranhash},{"$set":{"state": 0}})
        datashuju = {'bianhao': weiyiid, 'transaction_id': tranhash,'transferType': transferType,'ownerAddress': onwer_url,'toAddress': to_url,'money': today_money,'timestamp': block_timestamp, 'state': 0}
        
        keyboard = [
            [InlineKeyboardButton('重新飞单', callback_data=f'zxfeidan {weiyiid}'), InlineKeyboardButton('直接代理', callback_data=f'zxzhiya {weiyiid}')]    
        ]
        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
            try:
                context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                         disable_web_page_preview=True, reply_markup=InlineKeyboardMarkup(keyboard))
            except:
                continue

        if mongo.lssj.find_one({"transaction_id": tranhash}) is None:
            mongo.lssj.insert_one(datashuju)

            
        return
    
    if mongopledge.find_one({'tranhash': tranhash}) is None:
        library_list = mongolibrary.find_one({'today_money': today_money})
        if library_list:
            nenglbaifenb = mongo.shang_text.find_one({'projectname': '获利比例'})['text']
            yuanprice = today_money
            today_money = float(Decimal(str(today_money)) - Decimal(str(today_money)) * (Decimal(str(nenglbaifenb)) / Decimal(str(100))))
            zztrc20 = library_list['trc20']
            zzmoney = library_list['zzmoney']
            uid = library_list['user_id']
            xq = []
            zongbishu = 0
            for dz in zztrc20:
                xq.append(
                    {
                        'countNum': int(dz['pencount']),
                        'dayNum': int(dz['days']),
                        'recAddress': dz['trc20']
                    }    
                    )
                zongbishu += Decimal(str(dz['pencount']))*Decimal(str(dz['days']))
            zongbishu = Decimal(str(13.3959))* zongbishu
            rangli = int(round(Decimal(str(today_money))/zongbishu,2)*100)
            data = { 
"amount": today_money,
"equipmentType": 3,
"orderList": xq,
"scale": rangli,
        }
            # print(data)
            data = json.dumps(data).encode('utf-8')
            key = "Longteng".encode('utf-8')
            # 调用加密函数
            encrypted_data = encrypt(data, key)
            
            encrypted_data = base64.b64encode(encrypted_data).decode('utf-8')
            data = {
                "key": encrypted_data
            }
            
            
            url = 'http://144.202.84.76:8098/tweak/purchase-energy/add'
            response = requests.post(url=url,json=data)
            dingdan = json.loads(response.text)['data']
            data = {
'id': int(dingdan),
'paymentAddress': botname,
'status': 1
            }
            url = 'http://144.202.84.76:8098/tweak/purchase-energy/updateStatus'
            response = requests.post(url=url,json=data)
            us_list = mongo.get_group(bot_id).find_one({"user_id": uid})
            us_firstname = us_list['firstname']
            us_username = us_list['username']    
            us_id = us_list['user_id']
            fullname = us_list['fullname']
            zytrc20 = []
            yuanlist = []
            dzxq = []
            for dz in zztrc20:
                yuanlist.append(dz["trc20"])
                zytrc20.append(f'<code>{dz["trc20"]}</code>')
                dzxq.append(f'地址: {dz["trc20"]} 每天转账{dz["pencount"]}次，{dz["days"]}天，租赁{dz["zuzhimoney"]}Trx，省{dz["shengmoney"]}Trx')
            zytrc20 = ','.join(zytrc20)
            dzxq = '\n'.join(dzxq)
            webxiaofei(bot_id, today_money)
            bal = jianceyonghu(bot_id)
            text = f'''
<b>本次订单已飞往TWUK网站</b> 
<b>原价格:{yuanprice} 获利比例:{nenglbaifenb}% 提交价格:{today_money} 备用金剩余: {bal}</b>
<a href="https://tronscan.org/#/transaction/{tranhash}">用户转账信息</a>
用户: <a href="tg://user?id={uid}">{us_firstname}</a> @{us_username}
{dzxq}
    '''
            for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                try:
                    context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                             disable_web_page_preview=True)
                except:
                    continue
            
            fs_text = f'''
此订单在30分钟之内完成！
'''
            try:
                context.bot.send_message(chat_id=uid, text=fs_text, parse_mode='HTML',
                                         disable_web_page_preview=True)
            except:
                pass
                
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            order_id = str(uuid.uuid4())
            mongo.pledge_data('网站飞单',bot_id,order_id, block_timestamp, tranhash, '', uid, ss_trc20, 0,
                              0, value, 0, '能量', zztrc20, 0, '', 0, timer,
                              '')
            mongo.get_pledge(bot_id).update_one({"order_id": order_id},{"$set":{"dingdan": int(dingdan)}})
            order_id = str(uuid.uuid4()) 
            mongo.userlogdata(bot_id, order_id, block_timestamp, '', 'Trx', uid, onwer_url, '能量租赁',
                              0, value,
                              f'飞单往网站',
                              tranhash, timer)
            mongo.get_user_log(bot_id).update_one({"tranhash": tranhash},{"$set":{"beizhu": "网站飞单"}})
            
def webczrukou(bot_id, money, tranhash):
    data = {
        "deviceId": str(bot_id),
        "transactionType": 0,
        "reserveFund": money,
        "equipmentType": 3,
        "rechargeHashValue": tranhash
    }
    # print(data)
    data = json.dumps(data).encode('utf-8')
    key = "Longteng".encode('utf-8')
    # 调用加密函数
    encrypted_data = encrypt(data, key)
    
    encrypted_data = base64.b64encode(encrypted_data).decode('utf-8')
    data = {
        "key": encrypted_data
    }
    
    url = 'http://144.202.84.76:8098/tweak/device-user/UpdateReserveFund'
    response = requests.post(url=url, json=data)
    text = json.loads(response.text)
    
    
def jianceyonghu(bot_id):
    url = 'http://144.202.84.76:8098/tweak/device-user/page'
    data = {
        "deviceId": str(bot_id),
        'size': 1
    } 
    response = requests.post(url=url, json=data)
    text = json.loads(response.text)
    data = text['data']
    records = data['records']
    if records == []:
        return '没有此用户'
    else:
        records = records[0]
        reserveFund = records['reserveFund']
        return reserveFund
    

def wanzhanczcg(context: CallbackContext):       
    bot_id = context.bot.id
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    onwer_url = context.job.context['ownerAddress']
    value = context.job.context['money']
    block_timestamp = context.job.context['timestamp']
    today_money = float(value)
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    dj_list = mongo.dj.find_one({"money": today_money})
    if dj_list is not None:
        weishu = dj_list['weishu']
        user_id = dj_list['user_id']
        text = f'''
网站充值成功，充值{today_money}TRX
<a href="https://tronscan.org/#/transaction/{tranhash}">充值详细</a>
'''
        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
            try:
                context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                         disable_web_page_preview=True)
            except:
                continue
        webczrukou(bot_id, today_money, tranhash)
        bal = jianceyonghu(bot_id)
        text = f'''
你当前余额: {bal}
        '''
        keyboard = [
            [InlineKeyboardButton('网站充值', callback_data='webchongzhi')],
            [InlineKeyboardButton('网站接单', callback_data='webjiedanlist'),InlineKeyboardButton('网站飞单', callback_data='weburlduijie')],
            [InlineKeyboardButton('返回', callback_data='backstart')]
        ]
        context.bot.send_message(chat_id=user_id, text=text, reply_markup=InlineKeyboardMarkup(keyboard),
                                 disable_web_page_preview=True)
        
def zhiyanengliang(context: CallbackContext):
    bot_id = context.bot.id
    sd = mongo.get_wallet(bot_id).find_one({'projectname': '租赁'})
    mongopledge = mongo.get_user_log(bot_id)
    mongouser = mongo.get_group(bot_id)
    mongolibrary = mongo.get_library(bot_id)
    trc20 = sd['trc20']
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
    USDT = contract.functions.balanceOf(trc20) / 1000000
    try:
        TRX = client.get_account_balance(trc20)
    except:
        TRX = 0
    mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    mongo.get_wallet(bot_id).update_one({'projectname': '充值'},
                                        {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
    ss_trc20 = sd['trc20']
    a = sd['timer'] 
    tranhash = context.job.context['transaction_id']
    to_url = context.job.context['toAddress']
    transferType = context.job.context['transferType']
    onwer_url = context.job.context['ownerAddress']
    value = context.job.context['money']
    block_timestamp = context.job.context['timestamp']
    today_money = float(value)
    client = Tron(HTTPProvider('https://api.tronwallets.vip', 30))
    if mongopledge.find_one({'tranhash': tranhash}) is None:
        library_list = mongolibrary.find_one({'today_money': today_money})
        if library_list:
            zztrc20 = library_list['trc20']
            zzmoney = library_list['zzmoney']
            uid = library_list['user_id']
            mongo.shiyong.update_one({"tranhash": tranhash},{"$set":{"user_id": uid}})
            TRX = sd['TRX']
            try:
                library_list.update({'tranhash': tranhash, 'timestamp': block_timestamp})
                mongo.get_order(bot_id).insert_one(library_list)
            except:
                pass
            while 1:
                sd = mongo.get_wallet(bot_id).find_one({'projectname': '租赁'})
                trc20 = sd['trc20'] 
                sign = sd['sign']
                zhiya = sd['zhiya']
                yiyong = sd['shiyong']
                
                shengyu = shijikeyongTRX(trc20)
                ss_trc20 = sd['trc20']
                a = sd['timer'] 
                TRX = sd['TRX']

                if shengyu >= zzmoney:
                    
                    for zzzh in zztrc20:
                        zcmoney = zzzh['zzmoney']
                        zytrc20 = zzzh['trc20']
                        wusuijishu = zzzh['zuzhimoney']
                        shengmoney = zzzh['shengmoney']
                        pencount = zzzh['pencount']
                        days = zzzh['days']
                        if trc20 == zytrc20:
                            order_id = str(uuid.uuid4())
                            mongo.pledge_data('充值租赁本地址',bot_id,order_id, block_timestamp, tranhash, '', '', '', '', '', '', '', '能量', '',
                                              '', '', '', '', '')
                            order_id = str(uuid.uuid4())
                            mongo.userlogdata(bot_id, order_id, block_timestamp, '', 'Trx', '', '', '能量租赁',
                                              0, float(today_money),
                                              f'',
                                              tranhash, '')
                            mongo.shiyong.update_one({"tranhash": tranhash},{"$set":{"state": 1}})
                            mongolibrary.delete_one({'today_money': today_money})
                            return
                        else:
                            while 1:
                                try:
                                    txndata = dailineg(trc20, zytrc20, float(zcmoney))
                                    break
                                except Exception as f:
                                    with open('签名助手异常.txt', 'a+') as rz:
                                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                        rz.write(f'{timer} {f}\n')
                                    time.sleep(1)
                            txid = txndata['txid']
                            
                            
                            ss_trc20 = trc20
                            jiashiyong = Decimal(str(zcmoney)) + Decimal(str(yiyong))
                            mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},{
                                "$set": {'shiyong': float(jiashiyong)}})

                        getnengliang = getduoshaoneng(zcmoney)
                        us_list = mongo.get_group(bot_id).find_one({"user_id": uid})
                        lang = us_list['lang']
                        
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        tomorrow_str = (date.today() + timedelta(days=+int(days))).strftime(f"%Y-%m-%d {timer[-8:]}")
                        if lang == 'zh':
                            fs_text = f'''
租赁成功
你的账户: <code>{zytrc20}</code>
每天转账{pencount}次，{days}天，租赁{wusuijishu}Trx，省{shengmoney}Trx
过期时间: {tomorrow_str}
<a href="https://tronscan.org/#/transaction/{txid}">租赁详细</a>
    '''
                        else:
                            fs_text = f'''
Rental successful
Your account: <code>{zytrc20}</code>
Transfer {pencount} times per day, {days} day, rent {wusuijishu}Trx, save {shengmoney}Trx
Expires: {tomorrow_str}
<a href="https://tronscan.org/#/transaction/{txid}">Rental details</a>
    '''
    
                        context.job_queue.run_once(nlyongjin, 1,context={'user_id': uid,'money': wusuijishu,'trc20': onwer_url, 'projectname': '能量销售额奖励'})
                        try:
                            context.bot.send_message(chat_id=uid, text=fs_text, parse_mode='HTML',
                                                     disable_web_page_preview=True)
                        except:
                            pass
                        us_list = mongo.get_group(bot_id).find_one({"user_id": uid})
                        us_firstname = us_list['firstname']
                        us_username = us_list['username']    
                        us_id = us_list['user_id']
                        fullname = us_list['fullname']

                        order_id = str(uuid.uuid4())       
                        mongo.pledge_data('转账租赁', bot_id, order_id, block_timestamp, tranhash, txid, uid, ss_trc20, zcmoney,
                                          wusuijishu, today_money, shengmoney, '能量', zytrc20, pencount, '', days, timer,
                                          tomorrow_str)
                 
                        order_id = str(uuid.uuid4())                            
                        mongo.userlogdata(bot_id, order_id, block_timestamp, txid, 'Trx', uid, onwer_url, '能量租赁',
                                          0, float(today_money),
                                          f'能量租赁\n<code>{onwer_url}</code>转<code>{today_money}</code>Trx至<code>{to_url}</code>\n租赁<code>{wusuijishu}</code>TRX',
                                          tranhash, timer)
                        mongo.get_wallet(bot_id).update_one({'projectname': '租赁'}, {"$set": {'TRXstate': 0}})
                        time.sleep(3)
                        liada1 = shengnengliang(trc20)
                        zongnl = liada1['zong']
                        keyong = liada1['keyong']
                        text = f'''
用户: <a href="tg://user?id={uid}">{us_firstname}</a> @{us_username} 租赁成功
地址: <code>{zytrc20}</code>
每天转账{pencount}次，{days}天，租赁{wusuijishu}Trx，省{shengmoney}Trx
过期时间: {tomorrow_str}
<a href="https://tronscan.org/#/transaction/{txid}">租赁详细</a>
本次质押{zcmoney}Trx, 产生{getnengliang}能量
总能量: {zongnl}, 可用能量: {keyong}
                '''

                        for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                            if us['user_id'] == uid:
                                continue
                            try:
                                context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
                            
                            
                        chat_text = f'''
地址: <code>{zytrc20}</code>
每天转账{pencount}次，{days}天，租赁{wusuijishu}Trx，省{shengmoney}Trx
过期时间: {tomorrow_str}
'''
                        for ch in list(mongo.user_status.find({})):
                            chid = ch['chat_id']
                            try:
                                context.bot.send_message(chat_id=chid, text=chat_text, parse_mode='HTML',
                                                         disable_web_page_preview=True)
                            except:
                                continue
                            
                            
                    us_list = mongo.get_group(bot_id).find_one({"user_id": uid})
                    us_firstname = us_list['firstname']
                    us_username = us_list['username']    
                    us_id = us_list['user_id']
                            
                    text = f'''
用户: <a href="tg://user?id={uid}">{us_firstname}</a> @{us_username}
提交了{len(zztrc20)}笔质押，成功{len(zztrc20)}笔
                    '''
                    
                    try:
                        context.bot.send_message(chat_id=uid, text=text, parse_mode='HTML',
                                                 disable_web_page_preview=True)
                    except:
                        pass
                    
                    for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                        if us['user_id'] == uid:
                            continue
                        try:
                            context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                                     disable_web_page_preview=True)
                        except:
                            continue
                    mongo.shiyong.update_one({"tranhash": tranhash},{"$set":{"state": 1}})
                    mongolibrary.delete_one({'today_money': today_money})
                    break
                else:
                    TRXstate = sd['TRXstate']
                    fsdztrc20 = []
                    for zzzh in zztrc20:
                        zytrc20 = zzzh['trc20']
                        fsdztrc20.append(zytrc20)
                    fsdztrc20 = ','.join(fsdztrc20)

                    jiaqilai = float(Decimal(str(TRX)) + Decimal(str(shengyu)))
                    xuyaobuqi = float(Decimal(str(zzmoney)) - (Decimal(str(shengyu)) +  Decimal(str(TRX))))
                    if TRX >= xuyaobuqi:
                        while 1:
                            try:
                                txndata = sockzhiyaneng(trc20, xuyaobuqi)
                                break
                            except Exception as f:
                                with open('签名助手异常.txt', 'a+') as rz:
                                    timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                    rz.write(f'{timer} {f}\n')
                                time.sleep(1)
                        txid = txndata['txid']
                        
                        
                        
                        jiazhiya = Decimal(str(zzmoney)) + Decimal(str(zhiya))
                        mongo.get_wallet(bot_id).update_one({'projectname': '租赁'}, {"$set": {'zhiya': float(jiazhiya)}})
                        time.sleep(3)
                        context.job_queue.run_once(zhiyanengliang, 1,context={'transaction_id': tranhash,'transferType': 'TRX','ownerAddress': onwer_url,'toAddress': to_url,'money': value,'timestamp': block_timestamp})
                        return
                    else:

                        qwer = f'''
租赁钱包
<code>{trc20}</code>不足质押
能量{zzmoney}Trx,剩余可用能量{shengyu}Trx,现有{TRX}TRX,需补齐{xuyaobuqi}Trx质押
<a href="https://tronscan.org/#/transaction/{tranhash}">转账详细</a>
质押地址: {fsdztrc20}
                        '''
                        jisuanhash = tranhash[:-6]
 
                            
                            
                        if mongo.lssj.find_one({"transaction_id": tranhash}) is None:
                            weiyiid = str(uuid.uuid4())
                        else:
                            weiyiid = mongo.lssj.find_one({"transaction_id": tranhash})['bianhao']
                            mongo.lssj.update_one({"transaction_id": tranhash},{"$set":{"state": 0}})
                        datashuju = {'bianhao': weiyiid, 'transaction_id': tranhash,'transferType': transferType,'ownerAddress': onwer_url,'toAddress': to_url,'money': today_money,'timestamp': block_timestamp, 'state': 0}
                        
                        keyboard = [
                            
                        ]
                            
                            
                            
                        if TRXstate == 0:
                            mongo.get_wallet(bot_id).update_one({'projectname': '租赁'}, {"$set": {'TRXstate': 1}})
                            for i in list(mongouser.find({'state': '4'})):
                                # context.user_data[f'{i["user_id"]}yiwai{jisuanhash}'] = {'transaction_id': tranhash,'transferType': 'TRX','ownerAddress': onwer_url,'toAddress': to_url,'money': value,'timestamp': block_timestamp}
                                try:
                                    context.bot.send_message(chat_id=i['user_id'],
                                                             text=qwer,
                                                             parse_mode='HTML',disable_web_page_preview=True,reply_markup=InlineKeyboardMarkup(keyboard))
                                except:
                                    pass

                time.sleep(3)
                contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
                USDT = contract.functions.balanceOf(trc20) / 1000000
                try:
                    TRX = client.get_account_balance(trc20)
                except:
                    TRX = 0
                mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},
                                                    {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
                mongo.get_wallet(bot_id).update_one({'projectname': '充值'},
                                                    {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
        elif mongouser.find_one({'trc_url': {"$regex": onwer_url}}) != None:
            user_list = mongouser.find_one({'trc_url': {"$regex": onwer_url}})
            user_id = user_list['user_id']
            TRX = user_list['TRX']
            dazhe = user_list['dazhe']
            user_money = float((Decimal(str(TRX)) + Decimal(str(today_money))).quantize(Decimal('0.001')))
#             if today_money >= 10000:
#                 mongouser.update_one({'user_id': user_id}, {"$set": {'dazhe': 0.8}})
#                 text = f'''
# 充值金额一次性达到10000Trx以上!
# 能量租赁享受8折优惠
#                 '''
#                 if dazhe != 0.8:
#                     context.bot.send_message(chat_id=user_id, text=text,
#                                              parse_mode='HTML')
                    
                
#             elif today_money >= 5000:
#                 mongouser.update_one({'user_id': user_id}, {"$set": {'dazhe': 0.9}})
#                 text = f'''
# 充值金额一次性达到5000Trx以上!
# 能量租赁享受9折优惠
#                 '''
#                 if dazhe != 0.9:
#                     context.bot.send_message(chat_id=user_id, text=text,
#                                              parse_mode='HTML')
#             else:
#                 pass
            mongouser.update_one({'user_id': user_id}, {"$set": {'TRX': user_money}})
            text = f'''
👏 恭喜！
成功充值 {today_money} Trx
            '''

            context.bot.send_message(chat_id=user_id, text=text, parse_mode='HTML')
            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
            order_id = str(uuid.uuid4())
            mongo.userlogdata(bot_id, order_id, block_timestamp, '', 'Trx', user_id, onwer_url, '充值',
                              0, today_money,
                              f'充值\n<code>{onwer_url}</code>转<code>{today_money}</code>TRX至<code>{to_url}</code>\n成功充值<code>{today_money}</code>Usdt',
                              tranhash, timer)
            
            us_list = mongo.get_group(bot_id).find_one({"user_id": user_id})
            us_firstname = us_list['firstname']
            us_username = us_list['username']
            text = f'''
用户: <a href="tg://user?id={user_id}">{us_firstname}</a> @{us_username} 充值成功
地址: <code>{onwer_url}</code>
充值: {today_money} Trx
<a href="https://tronscan.org/#/transaction/{tranhash}">充值详细</a>
'''
            for us in list(mongo.get_group(bot_id).find({'state': '4'})):
                try:
                    context.bot.send_message(chat_id=us['user_id'], text=text, parse_mode='HTML',
                                             disable_web_page_preview=True)
                except:
                    continue

#             user_list = mongouser.find_one({'user_id': user_id})
#             TRX = user_list['TRX']
#             trc_list = []
#             for i in list(
#                     mongouser.find({'user_id': user_id, 'trc_url': {'$ne': None}})):
#                 for tc in i['trc_url'].split(','):
#                     trc_list.append(f'<code>{tc}</code>')
#             if trc_list == []:
#                 trc_list = ''
#             else:
#                 trc_list = '已绑定地址:\n' + "\n".join(trc_list)
#             text = f'''
# 账户ID：
# <code>{user_id}</code>

# 余额：
# <code>{TRX}</code> TRX

# {trc_list}
#                                     '''
#             keyboard = [
#                 [InlineKeyboardButton('闪兑报表', callback_data='usershanduibb'),
#                  InlineKeyboardButton('闪兑明细', callback_data='flashexchange')],
#                 [InlineKeyboardButton('能量报表', callback_data='usernengliangbaobiao'),
#                  InlineKeyboardButton('能量明细', callback_data='usernengliangmingxi')]
#             ]
#             context.bot.send_message(chat_id=user_id, text=text,
#                                      parse_mode='HTML',
#                                      reply_markup=InlineKeyboardMarkup(keyboard))

        time.sleep(3)
        contract = client.get_contract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t")
        USDT = contract.functions.balanceOf(trc20) / 1000000
        try:
            TRX = client.get_account_balance(trc20)
        except:
            TRX = 0
        mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},
                                            {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})
        mongo.get_wallet(bot_id).update_one({'projectname': '充值'},
                                            {"$set": {"USDT": float(USDT), 'TRX': float(TRX)}})


def djth(update: Update, context: CallbackContext):
    query = update.callback_query
    user_id = query.from_user.id
    bot_id = context.bot.id
    jiaoyihash = query.data.replace('djth ', '')
    log_list = mongo.get_user_log(bot_id).find_one({'tranhash': {'$regex': jiaoyihash}})
    tranhash = log_list['tranhash']
    zlstate = log_list['zlstate']
    TRX = log_list['TRX']
    trc20 = log_list['trc20']
    if zlstate == 0:
        query.answer(text=f'已操作退回{TRX}Trx', show_alert=bool("true"))
        
        mongo.get_user_log(bot_id).update_one({'tranhash': tranhash},{"$set":{"zlstate": 1}})
        
        mongo.get_wallet(bot_id).update_one({'projectname': '租赁'},{"$set":{f"tuihui{tranhash}": tranhash}})
    elif zlstate == 1:
        query.answer(text=f'管理员已操作退回，点击无效', show_alert=bool("true"))
    elif zlstate == 2:
        query.answer(text=f'管理员已操作飞单，操作点击无效无效', show_alert=bool("true"))
    

def djfd(update: Update, context: CallbackContext):
    query = update.callback_query
    user_id = query.from_user.id
    bot_id = context.bot.id
    jiaoyihash = query.data.replace('djfd ', '')
    log_list = context.user_data[f'{user_id}yiwai{jiaoyihash}']
    
    ownerAddress = log_list['ownerAddress']
    toAddress = log_list['toAddress']
    money = log_list['money']
    transaction_id = log_list['transaction_id']
    timestamp = log_list['timestamp']
    nenglbaifenb = mongo.shang_text.find_one({'projectname': '获利比例'})['text']
    if mongo.get_pledge(bot_id).find_one({'tranhash': transaction_id}) is None:
        text = f'''
订单已支付金额：{money}
获利比例：{nenglbaifenb}%
飞单支付金额:
        '''

    else:
        query.answer(text=f'管理员已操作飞单，操作点击无效无效', show_alert=bool("true"))


class SocketClient:

    def __init__(self,bot_id,context):
        self.socket = None
        self.emptyDataCount = 0
        self.cmdstate = 1
        self.bot_id = bot_id
        self.cmdstate = 1
        self.zxstate = 0
        self.context = context
    # 连接服务端

    def connectServer(self) -> bool:
        global server_ip_port
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        try:
            self.socket.connect(('104.219.214.234', 56560))
        except Exception as e:
            print(e)
            self.socket.close()
            return False
        
        try:
            if self.zxstate == 0:
                if mongo.get_kehuduan().find_one({}) == None:
                    self.regirst()
                else:
                    self.souquan()
                self.listenMsg()
                # 发送心跳
                self.sendHeartbeatThread()
        except Exception as f:
            with open('日志.txt', 'a+') as rz:
                rz.write(f'{f}\n')   
                
            self.socket.close()
            return False
        self.zxstate = 1
        return True


    def souquan(self):
        while 1:
            khd_list = mongo.get_kehuduan().find_one({})
            if khd_list != None:
                break
            time.sleep(1)
        api = khd_list['api']
        key = khd_list['key']
        tcid = khd_list['tcid']
        shijiancuo = int(time.time())
        jiaoyanma = hashlib.md5(f'auth{key}{shijiancuo}'.encode()).hexdigest()
        data = {"cmd": "auth", "api": api, "checksum": jiaoyanma, "tm": f"{shijiancuo}", "tcid": tcid}
        with open('授权日记.txt','a+') as f:
            f.write(f"{data}")
        datalen = struct.pack('i', len(json.dumps(data, cls=MyEncoder).encode()))
        self.sendMsg(datalen)
        self.sendMsg(json.dumps(data, cls=MyEncoder).encode())
    #添加监控地址
    def addjiankong(self,trc20):
        data = {"cmd":"addr-add","data":trc20}
        datalen = struct.pack('i', len(json.dumps(data,cls=MyEncoder).encode()))
        self.sendMsg(datalen)
        self.sendMsg(json.dumps(data, cls=MyEncoder).encode())
    #删除监控地址
    def adddel(self,trc20):
        data = {"cmd":"addr-del","data":trc20}
        datalen = struct.pack('i', len(json.dumps(data,cls=MyEncoder).encode()))
        self.sendMsg(datalen)
        self.sendMsg(json.dumps(data, cls=MyEncoder).encode())


    def cszl(self):
        while 1:
            if self.connectServer():
                break

    #注册机器人
    def regirst(self):
        shuju = {"cmd":"reg","rem":"bot", "name": "Tron_energybot"}
        cd = len(str(shuju))
        data = struct.pack('i', cd)
        self.sendMsg(data)
        
        self.sendMsg(json.dumps(shuju,cls=MyEncoder).encode())

    # 监听消息
    def listenMsg(self):
        thread = threading.Thread(target=self.receiveMsg)
        thread.start()

    def receiveMsg(self):
        # packet = ''
        # while True:
        #     try:
        #         data = self.socket.recv(BUF_SIZE)  # 接受信息
        #         if data == b'':
        #             self.socket.close()
        #             self.listenMsg()
        #             break
        #         packet += data
        #         num = struct.unpack('i', data[0:4])
        #         jsondata = json.loads(data[4:num[0] + 4])
        packet = b''
        while True:
            try:
                data = self.socket.recv(BUF_SIZE)  # 接受信息
                if data == b'':
                    self.close()
                    self.zxstate = 0
                    thread = threading.Thread(target=self.cszl)
                    thread.start()
                    return
                    
                packet += data
                while 1:
                    if len(packet) < 4:
                        break
                    num = struct.unpack('i', packet[0:4])
                    if len(packet) < num[0]:
                        break
                    jsondata = json.loads(packet[4:num[0] + 4])
                    with open('日志.txt', 'a+') as rz:
                        timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                        rz.write(f'{timer} {jsondata}\n')
                    if jsondata['cmd'] == 'transcan':
                        quant123 = Decimal(jsondata['data']['quant']) / Decimal('1000000')
                        quant = abs(float(quant123))
                        tcid = jsondata['data']['id']
                        mongo.get_kehuduan().update_one({},{"$set":{"tcid": tcid}})
                        type = jsondata['data']['type']
                        if float(quant) >= 1 and type in ['USDT', 'TRX']:
                            fromaddress = jsondata['data']['from']
                            toaddress = jsondata['data']['to']
                            tran_id = jsondata['data']['tran_id']
                            timestamp = jsondata['data']['time']
                            number = jsondata['data']['number']
                            timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                            create_time = int(timestamp)
                            time_tuple_1 = time.localtime(create_time)
                            create_time = time.strftime("%Y/%m/%d %H:%M:%S", time_tuple_1)
                            starturl = fromaddress[0:3]
                            endurl = fromaddress[-7:]
                            repurl = fromaddress.replace(starturl, '', 1).replace(endurl, '', 1)
                            zqurl = fromaddress.replace(repurl, '**')
                            slownerAddress = zqurl.replace(fromaddress[3:7], '')

                            starturl = toaddress[0:3]
                            endurl = toaddress[-7:]
                            repurl = toaddress.replace(starturl, '', 1).replace(endurl, '', 1)
                            zqurl = toaddress.replace(repurl, '**')
                            sltrc20 = zqurl.replace(toaddress[3:7], '')

                            starturl = tran_id[0:3]
                            endurl = tran_id[-7:]
                            repurl = tran_id.replace(starturl, '', 1).replace(endurl, '', 1)
                            zqurl = tran_id.replace(repurl, '**')
                            sltransaction_id = zqurl.replace(tran_id[3:7], '')
                            rztext = f'''
<b>入账！ +{quant} {type} </b>

交易时间：<b>{create_time}</b>
出账地址：<a href="https://tronscan.org/#/address/{fromaddress}">{slownerAddress}</a>
入账地址：<a href="https://tronscan.org/#/address/{toaddress}">{sltrc20}</a>  ←
区块值：<a href="https://tronscan.org/#/transaction/{tran_id}">{number}</a>
                                    '''
                            cztext = f'''
<b>出账！ -{quant} {type} </b>

交易时间：<b>{create_time}</b>
出账地址：<a href="https://tronscan.org/#/address/{fromaddress}">{slownerAddress}</a>  ←
入账地址：<a href="https://tronscan.org/#/address/{toaddress}">{sltrc20}</a>
区块值：<a href="https://tronscan.org/#/transaction/{tran_id}">{number}</a>
                                    '''
                            print_list = [{'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp,
                                          'rztext': rztext,'cztext': cztext}]
                            sd = mongo.get_wallet(self.bot_id).find_one({'projectname': '闪兑'})
                            sdtrc20 = sd['trc20']
                            zl = mongo.get_wallet(self.bot_id).find_one({'projectname': '租赁'})
                            zltrc20 = zl['trc20']
                            if toaddress == 'TN3mWbrEaiEWKAMqQ5MDz2WEGCZKKKKKKK':
                                if mongo.dj.find_one({"money": quant}) is not None:
                                    self.context.job_queue.run_once(wanzhanczcg, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                                    
                            
                            if mongo.shiyong.find_one({'tranhash': tran_id}) is None:
                                if type == 'TRX':
                                    if toaddress == sdtrc20:
                                        if mongo.designated.find_one({'duitype': 'tdu', 'money': quant}) is not None:
                                            mongo.sydata(tran_id)
                                            self.context.job_queue.run_once(seletdu, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                                        else:
                                            if mongo.heixiazi.find_one({'trc20': fromaddress,'$or':[{'trcstate': '1'},{'trcstate': '3'}]}) is None:
                                                mongo.sydata(tran_id)
                                                self.context.job_queue.run_once(usdtshandui, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                                    if toaddress == zltrc20:
                                        mongo.sydata(tran_id)
                                        nlqx = mongo.shang_text.find_one({'projectname': '能量单飞到网站'})['text']
                                        if nlqx == 0:
                                            self.context.job_queue.run_once(zhiyanengliang, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                                        else:
                                            self.context.job_queue.run_once(twwebfeidan, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                                else:
                                    if toaddress == sdtrc20:
                                        if mongo.designated.find_one({'duitype': 'udt', 'money': quant}) is not None:
                                            mongo.sydata(tran_id)
                                            self.context.job_queue.run_once(seleudt, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                                            
                                        else:
                                            if mongo.heixiazi.find_one({'trc20': fromaddress,'$or':[{'trcstate': '1'},{'trcstate': '3'}]}) is None:
                                                mongo.sydata(tran_id)
                                                self.context.job_queue.run_once(trxshandui, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                            if float(quant123) < 0: 
                                trc_20 = fromaddress
                                self.context.job_queue.run_once(print_chat, 1,
                                                                context={'trc20': trc_20, 'print_list': print_list, 'text':  cztext})
                                # context.job_queue.run_once(print_zc, 1,context={'transaction_id': transaction_id,'trc20': trc_20,'cztext': cztext})
                            else:
                                trc_20 = toaddress
                                self.context.job_queue.run_once(print_chat, 1,
                                                                context={'trc20': trc_20, 'print_list': print_list, 'text': rztext})
                        else:
                            sd = mongo.get_wallet(self.bot_id).find_one({'projectname': '闪兑'})
                            sdtrc20 = sd['trc20']
                            zl = mongo.get_wallet(self.bot_id).find_one({'projectname': '租赁'})
                            zltrc20 = zl['trc20']
                            if type == 'TRX':
                                fromaddress = jsondata['data']['from']
                                toaddress = jsondata['data']['to']
                                tran_id = jsondata['data']['tran_id']
                                timestamp = jsondata['data']['time']
                                number = jsondata['data']['number']
                                timer = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
                                create_time = int(timestamp)
                                time_tuple_1 = time.localtime(create_time)
                                create_time = time.strftime("%Y/%m/%d %H:%M:%S", time_tuple_1)
                                
                                if toaddress == sdtrc20:
                                    mongo.sydata(tran_id)
                                    self.context.job_queue.run_once(usdtshandui, 1,context={'transaction_id': tran_id,'transferType': type,'ownerAddress': fromaddress,'toAddress': toaddress,'money': quant,'timestamp': timestamp})
                    elif jsondata['cmd'] == 'regok':
                        if mongo.get_kehuduan().find_one({}) is None:
                            mongo.kehuduanurl(jsondata['id'],jsondata['key'])
                    elif jsondata['cmd'] == 'addr-add-ret':
                        mongo.get_address(self.bot_id).update_one({'trc20': jsondata['addr']},{"$set":{"syn": True}})
                    elif jsondata['cmd'] == 'addr-del-ret':
                        mongo.get_address(self.bot_id).delete_one({'trc20': jsondata['addr']})
                    elif jsondata['cmd'] == 'auth-err':
                        self.close()
                        self.zxstate = 0
                        thread = threading.Thread(target=self.cszl)
                        thread.start()
                        return
                    packet = packet[num[0] + 4:]
            except Exception as f:
                with open('日志.txt', 'a+') as rz:
                    rz.write(f'{f}\n')
                time.sleep(1)
                self.close()
                self.zxstate = 0
                thread = threading.Thread(target=self.cszl)
                thread.start()
                return
    def sendMsg(self, msg):
        self.socket.send(msg)
    def close(self):
        self.socket.close()

    def sendHeartbeatThread(self):
        if self.cmdstate == 1:
            thread = threading.Thread(target=self.sendHeartbeat)
            thread.start()
            self.cmdstate = 2

    #发送心跳
    def sendHeartbeat(self):
        global server_ip_port
        while True:
            data_to_server = {"cmd": "k"}
            while 1:
                try:
                    self.socket.send(struct.pack('i', len(json.dumps(data_to_server,cls=MyEncoder).encode())))
                    self.socket.send(json.dumps(data_to_server,cls=MyEncoder).encode())
                    break
                except socket.error:
                    time.sleep(5)
            time.sleep(30)
class MyEncoder(json.JSONEncoder):
    def default(self, obj):
        if isinstance(obj, bytes):
            return str(obj, encoding='utf-8')
        return json.JSONEncoder.default(self, obj)