(modify):尝试使用solscan获取 activites 数目

src/code/00000_test_dexscreener_playwright_chrome.py

@@ -1,104 +0,0 @@
-
-# from datetime import datetime, timezone
-# from playwright.async_api import async_playwright, Playwright
-# from playwright.sync_api import expect
-from playwright.async_api import Playwright, async_playwright, expect
-import random
-import time
-import datetime
-import asyncio
-import pathlib
-import shutil
-old_print = print
-
-
-def timestamped_print(*args, **kwargs):
-    old_print(datetime.datetime.utcnow().replace(
-        microsecond=0), *args, **kwargs)
-
-
-print = timestamped_print
-print('\n'*5)
-print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
-
-
-def makedirpath(   folder):
-    pathlib.Path(folder).mkdir(exist_ok=True)
-
-def rmfolder(  folder):
-    if pathlib.Path(folder).exists():
-        shutil.rmtree(folder)
-
-
-# Python中windows路径的3种写法
-# 可以是以下这样写：
-utc_timeto = int(time.time())
-utc_timefrom = int(utc_timeto - 17*24*3600)
-utc_timeto = int(utc_timeto + 2*24*3600)
-
- 
-
-
-async def do_some_thing(playwright      ):
-
-    # browser =  playwright.chromium.launch(headless=True)
-    context = await playwright.chromium.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
-    # context = await playwright.firefox.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
-    # context = browser.new_context()
-    context.set_default_timeout(9000)
-    # context = await browser.new_context()
-    arr_page = [None]*2
-    arr_page[0] = await context.new_page()
-    page = arr_page[0]
-    await arr_page[0].goto(
-        "https://dexscreener.com/new-pairs?rankBy=trendingScoreH6&order=desc&chainIds=solana&dexIds=raydium&minLiq=40000&minAge=36&min5MChg=3" , timeout=100000)
-    cur_arr_str_dalaoAddress =[15]
-
-    print(context.pages)
-    await page.wait_for_timeout(100000)
-    time.sleep(5.5)
-    await page.close()
-    # for str_dalaoAddress_idx in range(0, len(cur_arr_str_dalaoAddress)):
-
-    #     arr_page[1] = await context.new_page()
-    #     page = arr_page[1]
-    #     await page.goto(  "https://dexscreener.com/new-pairs?rankBy=trendingScoreH6&order=desc&chainIds=solana&dexIds=raydium&minLiq=40000&minAge=36&min5MChg=3" 
-    #                     , timeout=10000)
-
-    #     # async with page.expect_download() as download_info:
-    #     #     try:
-    #     #         await page.goto(str_dalaoTransferUrl, timeout=0)
-    #     #     except:
-    #     #         # Wait for the download to start
-    #     #         download = await download_info.value
-    #     #         # Wait for the download process to complete
-    #     #         print(await download.path())
-    #     #         # Save downloaded file somewhere
-    #     #         await download.save_as(baseclass.dalao_ori_tran_txhash_solscan_path / f"ori_txhash_{str_dalaoAddress}.csv")
-    #     #     await page.wait_for_timeout(200)
-    #     await page.wait_for_timeout(10000)
-    #     time.sleep(5.5)
-    #     await page.close()
-
-    await context.close()
-
-
-async def get_onedriver_swapactivities(    ):
-    async with async_playwright() as playwright:
-        # playwright = Playwright().start()
-        await do_some_thing(playwright )
-
-
-async def main():
-    print("enter main()")
-
-    await get_onedriver_swapactivities(        )
-
-
- 
- 
-USER_DIR_PATH =    "./browsercookie_path"
-makedirpath(USER_DIR_PATH)
-asyncio.run(main())
-# main()
-print(f"{'{:<6}'.format('END')}  ----------------NOTE-----------NOTE---------------")

src/code/00000_test_dexscreener_playwright_edge.py

@@ -1,104 +1 @@
 
-# from datetime import datetime, timezone
-# from playwright.async_api import async_playwright, Playwright
-# from playwright.sync_api import expect
-from playwright.async_api import Playwright, async_playwright, expect
-import random
-import time
-import datetime
-import asyncio
-import pathlib
-import shutil
-old_print = print
-
-
-def timestamped_print(*args, **kwargs):
-    old_print(datetime.datetime.utcnow().replace(
-        microsecond=0), *args, **kwargs)
-
-
-print = timestamped_print
-print('\n'*5)
-print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
-
-
-def makedirpath(   folder):
-    pathlib.Path(folder).mkdir(exist_ok=True)
-
-def rmfolder(  folder):
-    if pathlib.Path(folder).exists():
-        shutil.rmtree(folder)
-
-
-# Python中windows路径的3种写法
-# 可以是以下这样写：
-utc_timeto = int(time.time())
-utc_timefrom = int(utc_timeto - 17*24*3600)
-utc_timeto = int(utc_timeto + 2*24*3600)
-
- 
-
-
-async def do_some_thing(playwright      ):
-
-    # browser =  playwright.chromium.launch(headless=True)
-    context = await playwright.chromium.launch_persistent_context(  channel="msedge",user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
-    # context = await playwright.firefox.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
-    # context = browser.new_context()
-    context.set_default_timeout(9000)
-    # context = await browser.new_context()
-    arr_page = [None]*2
-    arr_page[0] = await context.new_page()
-    page = arr_page[0]
-    await arr_page[0].goto(
-        "https://dexscreener.com/new-pairs?rankBy=trendingScoreH6&order=desc&chainIds=solana&dexIds=raydium&minLiq=40000&minAge=36&min5MChg=3" , timeout=100000)
-    cur_arr_str_dalaoAddress =[15]
-
-    print(context.pages)
-    await page.wait_for_timeout(100000)
-    time.sleep(5.5)
-    await page.close()
-    # for str_dalaoAddress_idx in range(0, len(cur_arr_str_dalaoAddress)):
-
-    #     arr_page[1] = await context.new_page()
-    #     page = arr_page[1]
-    #     await page.goto(  "https://dexscreener.com/new-pairs?rankBy=trendingScoreH6&order=desc&chainIds=solana&dexIds=raydium&minLiq=40000&minAge=36&min5MChg=3" 
-    #                     , timeout=10000)
-
-    #     # async with page.expect_download() as download_info:
-    #     #     try:
-    #     #         await page.goto(str_dalaoTransferUrl, timeout=0)
-    #     #     except:
-    #     #         # Wait for the download to start
-    #     #         download = await download_info.value
-    #     #         # Wait for the download process to complete
-    #     #         print(await download.path())
-    #     #         # Save downloaded file somewhere
-    #     #         await download.save_as(baseclass.dalao_ori_tran_txhash_solscan_path / f"ori_txhash_{str_dalaoAddress}.csv")
-    #     #     await page.wait_for_timeout(200)
-    #     await page.wait_for_timeout(10000)
-    #     time.sleep(5.5)
-    #     await page.close()
-
-    await context.close()
-
-
-async def get_onedriver_swapactivities(    ):
-    async with async_playwright() as playwright:
-        # playwright = Playwright().start()
-        await do_some_thing(playwright )
-
-
-async def main():
-    print("enter main()")
-
-    await get_onedriver_swapactivities(        )
-
-
- 
- 
-USER_DIR_PATH =    "./browsercookie_path"
-makedirpath(USER_DIR_PATH)
-asyncio.run(main())
-# main()
-print(f"{'{:<6}'.format('END')}  ----------------NOTE-----------NOTE---------------")

src/code/000_01_test_dexscreener_playwright.py

@@ -1,106 +0,0 @@
-
-# from datetime import datetime, timezone
-# from playwright.async_api import async_playwright, Playwright
-# from playwright.sync_api import expect
-from playwright.async_api import Playwright, async_playwright, expect
-import random
-
-from base_class import BaseVariableFunction
-from base_class import *
-baseclass = BaseVariableFunction(__file__)
-
-baseclass.makedirpath(baseclass.browsercookie_path)
-baseclass.makedirpath(baseclass.dalao_ori_tran_txhash_solscan_path)
-old_print = print
-
-
-def timestamped_print(*args, **kwargs):
-    old_print(datetime.datetime.utcnow().replace(
-        microsecond=0), *args, **kwargs)
-
-
-print = timestamped_print
-print('\n'*5)
-print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
-# Python中windows路径的3种写法
-# 可以是以下这样写：
-utc_timeto = int(time.time())
-utc_timefrom = int(utc_timeto - 17*24*3600)
-utc_timeto = int(utc_timeto + 2*24*3600)
-
-def get_dalao_historysign_solscan(df):
-
-    utc_timeto = int(time.time())
-    utc_timefrom = int(utc_timeto - 17*24*3600)
-    utc_timeto = int(utc_timeto + 2*24*3600)
-    # 示例   https://api.solscan.io/v2/account/txs/export?address=2D4dLL47vA1k1EN4421aM9DzKp3VBDAqKj8iUTSBLktw&type=tokenchange&timefrom=1711900800&timeto=1714492799.999&account_type=account_main
-        # https://api-v2.solscan.io/v2/account/transfer/export?address=5bTgWQQE5Tb34BQQtUArj62PmFcVsaht2SGotAdq5fbt&activity_type[]=ACTIVITY_SPL_TRANSFER
-    # https://api-v2.solscan.io/v2/account/balance_change/export?address=Cft4hKtC3dVftfqmL2MCALpeCq7oWM7qpftNfVVUzA7h&time_from=1719763200&time_to=1721051816.123&account_type=account_main
-    
-    df['SolscanTransferUrl'] = df.apply(lambda ser: (
-        f"https://api-v2.solscan.io/v2/account/balance_change/export?address={ser['dalaoAddress']}&time_from={utc_timefrom}&time_to={utc_timeto}&account_type=account_main"), axis=1)
-
-    
-    return df
-
-
-async def do_some_thing(playwright      ):
-
-    # browser =  playwright.chromium.launch(headless=True)
-    # context = await playwright.chromium.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
-    context = await playwright.firefox.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
-    # context = browser.new_context()
-    context.set_default_timeout(9000)
-    # context = await browser.new_context()
-    arr_page = [None]*2
-    arr_page[0] = await context.new_page()
-    await arr_page[0].goto(
-        "https://dexscreener.com/new-pairs?rankBy=trendingScoreH6&order=desc&chainIds=solana&dexIds=raydium&minLiq=40000&minAge=36&min5MChg=3")
-    cur_arr_str_dalaoAddress =[1,2,3,4,5]
-
-    print(context.pages)
-
-    for str_dalaoAddress_idx in range(0, len(cur_arr_str_dalaoAddress)):
-
-        arr_page[1] = await context.new_page()
-        page = arr_page[1]
-        await page.goto(  "https://dexscreener.com/new-pairs?rankBy=trendingScoreH6&order=desc&chainIds=solana&dexIds=raydium&minLiq=40000&minAge=36&min5MChg=3" 
-                        , timeout=10000)
-
-        # async with page.expect_download() as download_info:
-        #     try:
-        #         await page.goto(str_dalaoTransferUrl, timeout=0)
-        #     except:
-        #         # Wait for the download to start
-        #         download = await download_info.value
-        #         # Wait for the download process to complete
-        #         print(await download.path())
-        #         # Save downloaded file somewhere
-        #         await download.save_as(baseclass.dalao_ori_tran_txhash_solscan_path / f"ori_txhash_{str_dalaoAddress}.csv")
-        #     await page.wait_for_timeout(200)
-        await page.wait_for_timeout(10000)
-        time.sleep(5.5)
-        await page.close()
-
-    await context.close()
-
-
-async def get_onedriver_swapactivities(    ):
-    async with async_playwright() as playwright:
-        # playwright = Playwright().start()
-
-        await do_some_thing(playwright )
-
-
-async def main():
-    print("enter main()")
-
-    await get_onedriver_swapactivities(        )
-
-
- 
- 
-USER_DIR_PATH = baseclass.browsercookie_path
-asyncio.run(main())
-# main()
-print(f"{'{:<6}'.format('END')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")

src/code/000_test.py

@@ -1,9 +1,24 @@
+import httpx
 
+my_headers = [
+    "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/39.0.2171.95 Safari/537.36",
+    "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_9_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/35.0.1916.153 Safari/537.36",
+    "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:30.0) Gecko/20100101 Firefox/30.0",
+    "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_9_2) AppleWebKit/537.75.14 (KHTML, like Gecko) Version/7.0.3 Safari/537.75.14",
+    "Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Win64; x64; Trident/6.0)",
+    'Mozilla/5.0 (Windows; U; Windows NT 5.1; it; rv:1.8.1.11) Gecko/20071127 Firefox/2.0.0.11',
+    'Opera/9.25 (Windows NT 5.1; U; en)',
+    'Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)',
+    'Mozilla/5.0 (compatible; Konqueror/3.5; Linux) KHTML/3.5.5 (like Gecko) (Kubuntu)',
+    'Mozilla/5.0 (X11; U; Linux i686; en-US; rv:1.8.0.12) Gecko/20070731 Ubuntu/dapper-security Firefox/1.5.0.12',
+    'Lynx/2.8.5rel.1 libwww-FM/2.14 SSL-MM/1.4.1 GNUTLS/1.2.9',
+    "Mozilla/5.0 (X11; Linux i686) AppleWebKit/535.7 (KHTML, like Gecko) Ubuntu/11.04 Chromium/16.0.912.77 Chrome/16.0.912.77 Safari/535.7",
+    "Mozilla/5.0 (X11; Ubuntu; Linux i686; rv:10.0) Gecko/20100101 Firefox/10.0 "
 
+]
+headers = {
+    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/104.0.0.0 Safari/537.36",
+}
 
-aa = "-$6.9-3.21%"
-
-res = aa.split("-")
-
-print(res)
-
+res = httpx.get(url='https://solscan.io/account/3ZfGsZtPW4z1VD9iD4tDrkocTGC2LjXMtZYHn3szTaf6#defiactivities', headers=headers, timeout=10, verify=False)
+print(res.text)

src/code/new_8002_add_get_getdalao_activites_number.py

@@ -0,0 +1,131 @@
+
+# from datetime import datetime, timezone
+# from playwright.async_api import async_playwright, Playwright
+# from playwright.sync_api import expect
+from playwright.async_api import Playwright, async_playwright, expect
+import random
+
+from base_class import BaseVariableFunction
+from base_class import *
+baseclass = BaseVariableFunction(__file__)
+
+baseclass.makedirpath(baseclass.browsercookie_path)
+baseclass.makedirpath(baseclass.dalao_solscan_info_path)
+old_print = print
+
+
+def timestamped_print(*args, **kwargs):
+    old_print(datetime.datetime.utcnow().replace(
+        microsecond=0), *args, **kwargs)
+
+
+print = timestamped_print
+print('\n'*5)
+print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
+ 
+
+async def do_some_thing(playwright,   arr_url_dalao , url_type):
+
+    # browser =  playwright.chromium.launch(headless=True)
+    context = await playwright.firefox.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
+    # context = browser.new_context()
+    context.set_default_timeout(19000)
+    # context = await browser.new_context()
+    arr_page = [None]*2
+    arr_page[0] = await context .new_page()
+    await arr_page[0].goto(
+        "https://solscan.io/")
+    await asyncio.sleep(30)
+
+    # print(context.pages)
+
+    for idx_url in range(0, len(arr_url_dalao)):
+
+        str_dalaoTransferUrl = arr_url_dalao[idx_url]
+        str_dalaoaddress =obj_url_2_dalao[str_dalaoTransferUrl]
+        
+        print(f"enter str_dalaoaddress= {str_dalaoaddress}")
+        print(f"enter str_dalaoTransferUrl= {str_dalaoTransferUrl}")
+        print(f"cur_arr_str_dalaoaddress remainder = {len(arr_url_dalao)-idx_url}")
+        arr_page[1] = await context.new_page()
+        page = arr_page[1]
+        await asyncio.sleep(3)
+
+        # tbody_ = page.locator(
+        #     'table.w-full tbody')
+        await page.wait_for_selector('#account-tabs',timeout=15000)
+        await page.wait_for_selector('#account-tabs iv.flex.flex-col.gap-4.items-stretch.justify-start',timeout=15000)
+        arr_div =await page.locator("#account-tabs div.flex.flex-col.gap-4.items-stretch.justify-start div.flex.gap-1.flex-row.items-center.justify-start.flex-wrap").all()
+        # await asyncio.sleep(3)
+        str_tx_info =(await arr_div[0].text_content().strip())
+        #arr_tds = await last_tr.locator('td').all()
+        # p_token_last_active =  arr_tds[0].locator("p")
+        # str_token_last_active =( await p_token_last_active.text_content()).strip()
+
+        print(str_tx_info)
+ 
+ 
+
+
+        time.sleep(1)
+        await page.close()
+
+    await context.close()
+
+
+async def get_onedriver_swapactivities( arr_url_dalao , url_type):
+    async with async_playwright() as playwright:
+
+        await do_some_thing(playwright, arr_url_dalao, url_type)
+
+
+async def main():
+    print("enter main()")
+    if len(arr_dalao_url)>0:
+        await get_onedriver_swapactivities(
+            arr_url_dalao = arr_dalao_url , url_type = "transfer_counts")
+        await asyncio.sleep(3)
+        
+    # if len(arr_dalao_token_inflow_transfer_url)>0:
+    #     await get_onedriver_swapactivities(
+    #         arr_url_dalao = arr_dalao_token_inflow_transfer_url , url_type = "swap_counts")
+    #     await asyncio.sleep(3)
+ 
+
+
+df = pd.read_excel(baseclass.dalao_tran_gmgnOrdex_path /
+                 "input_dalao.xlsx", dtype=object)
+
+arr_str_dalaoaddress = df['dalaoaddress'].tolist()
+arr_str_dalaoaddress=arr_str_dalaoaddress[0:4]
+# arr_dalao_sol_transfer_url =[]
+arr_dalao_url = []
+arr_dalao_swap = []
+obj_url_2_dalao={
+    
+}
+def init():
+    now_time = time.time()
+    global obj_url_2_dalao
+    global arr_dalao_sol_transfer_url ,arr_dalao_token_inflow_transfer_url ,arr_dalao_token_outflow_transfer_url , arr_dalao_usdc_transfer_url
+    for str_dalaoaddress in arr_str_dalaoaddress:
+        # file = baseclass.dalao_solscan_info_path / f"ori_txhash_{str_dalaoaddress}.csv"
+        dalao_transfer_counts_file = baseclass.dalao_solscan_info_path / f"dalao_transfer_counts.json"
+        # token_inflow_transfer_file = baseclass.dalao_solscan_info_path / f"token_inflow_{str_dalaoaddress}.csv"
+   
+        url_transfer = f"https://solscan.io/account/{str_dalaoaddress}"  
+        # url_transfer = f"https://solscan.io/account/{str_dalaoaddress}#transfers"  
+        url_swap = f"https://solscan.io/account/{str_dalaoaddress}#defiactivities"     
+        arr_dalao_url.append(url_transfer)
+        obj_url_2_dalao[url_transfer] = str_dalaoaddress
+        
+ 
+            
+
+
+init()
+ 
+downloads_path = baseclass.dalao_solscan_info_path
+USER_DIR_PATH = baseclass.browsercookie_path
+asyncio.run(main())
+print(f"{'{:<6}'.format('END')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")

src/code/new_8003_handle_depth.py

@@ -0,0 +1,126 @@
+
+# from datetime import datetime, timezone
+# from playwright.async_api import async_playwright, Playwright
+# from playwright.sync_api import expect
+ 
+from base_class import BaseVariableFunction
+from base_class import *
+baseclass = BaseVariableFunction(__file__)
+
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path )
+
+ 
+old_print = print
+
+
+def timestamped_print(*args, **kwargs):
+    old_print(datetime.datetime.utcnow().replace(
+        microsecond=0), *args, **kwargs)
+
+
+print = timestamped_print
+print('\n'*5)
+print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
+ 
+arr_exclude_address=[
+    
+]
+arr_realtion_address =[]
+
+now_time = time.time()
+df = pd.read_excel(baseclass.dalao_tran_gmgnOrdex_path /
+                "input_dalao.xlsx", dtype=object)
+arr_str_dalaoaddress = df['dalaoaddress'].tolist()
+# arr_str_dalaoaddress=arr_str_dalaoaddress[0:2]
+arr_realtion_address  = arr_realtion_address + arr_str_dalaoaddress
+str_tokenaddress_dalao_source = "4GULMPKBJLruChBZWksZzukAg1AjSCmCTMn9ny2Xpump"
+find_depth = "depth_01"
+
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source    )
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source /find_depth )
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source /find_depth/"mid" )
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source /find_depth/"final" )
+
+
+def drop_ex_txhash(gdf):
+    is_ex = False
+    if( ( gdf["action"] != "TRANSFER" )
+        | (gdf["timestamp"]<now_time - 1*30* 24* 3600 )
+        |( gdf["from"].isin(arr_exclude_address))
+        |( gdf["to"].isin(arr_exclude_address))
+        ).any( ):
+        is_ex = True
+    
+    if is_ex:
+        return None
+    if (  set( gdf["from"].tolist() ).intersection(gdf["to"].tolist())   ):
+        is_ex = True
+    if is_ex:
+        return None
+    return gdf
+
+
+def sum_same_tx_from_to(gdf ):
+    gdf["amount"] = sum(gdf["amount"])
+    gdf=gdf.drop_duplicates()
+    return gdf
+
+def sum_same_from_to(gdf ):
+    gdf["timestamp"] = max(gdf["timestamp"] )
+    gdf["datetime"] = max(gdf["datetime"] )
+    gdf["amount"] = sum(gdf["amount"])
+    gdf=gdf.drop_duplicates()
+    return gdf
+def main():
+    global arr_exclude_address
+    for str_dalaoaddress in arr_str_dalaoaddress:
+        print(f"enter {str_dalaoaddress}")
+        cur_arr_realtion_address =arr_realtion_address.copy()
+        cur_arr_realtion_address.remove(str_dalaoaddress)
+        
+
+        df_sol_transfer =pd.read_csv(baseclass.dalao_solscan_info_path / f"sol_transfer_{str_dalaoaddress}.csv" ,dtype=object)
+        df_token_inflow =pd.read_csv(baseclass.dalao_solscan_info_path / f"token_inflow_{str_dalaoaddress}.csv" ,dtype=object)
+        df_token_outflow =pd.read_csv(baseclass.dalao_solscan_info_path / f"token_outflow_{str_dalaoaddress}.csv" ,dtype=object)
+        df_usdc_transfer =pd.read_csv(baseclass.dalao_solscan_info_path / f"usdc_transfer_{str_dalaoaddress}.csv" ,dtype=object)
+
+        arr_no_sol_transfer_tx_01 = df_token_inflow["Signature"].tolist() + df_token_outflow["Signature"].tolist() + df_usdc_transfer["Signature"].tolist()
+        
+        df_sol_transfer = df_sol_transfer[~df_sol_transfer["Signature"].isin(arr_no_sol_transfer_tx_01)].reset_index(drop=True)
+
+        df_sol_transfer.columns=["txhash","timestamp","action","from","to","amount","decimals","tokenaddress"]
+        df_sol_transfer=df_sol_transfer.astype({
+            "timestamp":int,
+            "amount":float,
+            "decimals":int,
+        })
+
+        df_sol_transfer = df_sol_transfer.groupby(by=["txhash"],  group_keys=False).apply(lambda gdf: drop_ex_txhash(gdf))
+        
+ 
+        if(len(df_sol_transfer)==0):
+            continue
+        token_decimal  =  (df_sol_transfer["decimals"].tolist()[0])
+        df_sol_transfer["amount"] = df_sol_transfer["amount"] / 10**token_decimal
+        df_sol_transfer["amount"] = df_sol_transfer["amount"].round(2) 
+        df_sol_transfer["datetime"] = pd.to_datetime(df_sol_transfer['timestamp'], unit='s')  
+        df_sol_transfer = df_sol_transfer[["timestamp", "txhash", "datetime" ,"from","to","amount"]]     
+        
+        df_sol_transfer = df_sol_transfer.groupby(by = ["txhash","from","to" ],  group_keys=False).apply(lambda gdf: sum_same_tx_from_to(gdf))
+        df_sol_transfer.to_csv(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  "mid" /f"mid_sol_transfer_{str_dalaoaddress}.csv",index=False)
+ 
+        df_sol_transfer = df_sol_transfer[[ "timestamp", "datetime", "from","to","amount"]]       
+        df_sol_transfer = df_sol_transfer.groupby(by = [ "from","to" ],  group_keys=False).apply(lambda gdf: sum_same_from_to(gdf))
+        
+        df_sol_transfer["is_exend"] = 0
+        df_sol_transfer["is_relationend"] = 0
+        df_sol_transfer.loc[( df_sol_transfer["from"].isin(cur_arr_realtion_address) | df_sol_transfer["to"].isin(cur_arr_realtion_address)),"is_relationend"] = 1
+ 
+        df_sol_transfer.loc[( df_sol_transfer["from"].isin(arr_exclude_address) | df_sol_transfer["to"].isin(arr_exclude_address)),"is_exend"] = 1
+        
+        
+        df_sol_transfer=df_sol_transfer.sort_values(by="timestamp",ascending=False)
+        df_sol_transfer.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  "final"/f"sol_transfer_{str_dalaoaddress}.xlsx",index=False)
+ 
+ 
+main()

src/code/new_8004_merge_depth.py

@@ -0,0 +1,79 @@
+
+# from datetime import datetime, timezone
+# from playwright.async_api import async_playwright, Playwright
+# from playwright.sync_api import expect
+ 
+from base_class import BaseVariableFunction
+from base_class import *
+baseclass = BaseVariableFunction(__file__)
+
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path )
+
+ 
+old_print = print
+
+
+def timestamped_print(*args, **kwargs):
+    old_print(datetime.datetime.utcnow().replace(
+        microsecond=0), *args, **kwargs)
+
+
+print = timestamped_print
+print('\n'*5)
+print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
+
+
+df = pd.read_excel(baseclass.dalao_tran_gmgnOrdex_path /
+                "input_dalao.xlsx", dtype=object)
+arr_str_dalaoaddress = df['dalaoaddress'].tolist()
+
+# arr_str_dalaoaddress=arr_str_dalaoaddress[0:5]
+str_tokenaddress_dalao_source = "4GULMPKBJLruChBZWksZzukAg1AjSCmCTMn9ny2Xpump"
+find_depth = "depth_01"
+
+
+
+
+def main():
+    df_sol_transfer = None
+    for str_dalaoaddress in arr_str_dalaoaddress:
+        if not (baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  "final"/f"sol_transfer_{str_dalaoaddress}.xlsx" ).exists():
+            continue
+        print(f"enter {str_dalaoaddress}")
+        cur_df_sol_transfer = pd.read_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/"final"/ f"sol_transfer_{str_dalaoaddress}.xlsx",dtype=object )
+        cur_df_sol_transfer["dalaoaddress"] = str_dalaoaddress
+        df_sol_transfer = pd.concat([df_sol_transfer,cur_df_sol_transfer])
+    df_sol_transfer = df_sol_transfer.astype({
+
+        "timestamp":int,
+        "amount":float,
+        "is_exend":int,
+        "is_relationend":int,
+        
+    })
+ 
+    df_sol_transfer.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  f"fir_sol_transfer_{find_depth}.xlsx" ,index=False)
+    mask_end = ( (df_sol_transfer["is_exend"]==1 ) | (df_sol_transfer["is_relationend"]==1))  
+    end_df = df_sol_transfer[ mask_end]
+    end_df.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  f"endaddress_sol_transfer_{find_depth}.xlsx" ,index=False)
+
+    df_sol_transfer = df_sol_transfer[ ~mask_end].reset_index(drop=True)
+
+    def get_dalao_len(gdf):
+        gdf["dalao_count"] = len(gdf)
+        
+        return  gdf
+
+    df_sol_transfer["dalao_count"] = 0
+
+    df_sol_transfer =   df_sol_transfer.groupby(by=["dalaoaddress"] ,group_keys=False  ).apply(lambda gdf:  get_dalao_len(gdf))
+    
+    df_dalao_count = df_sol_transfer[[  "dalaoaddress", "dalao_count"  ]].drop_duplicates()
+    df_dalao_count.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  f"counts_sol_transfer_{find_depth}.xlsx" ,index=False)
+    df_sol_transfer.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  f"sec_sol_transfer_{find_depth}.xlsx" ,index=False)
+     
+
+
+    return
+
+main()

src/code/tempCodeRunnerFile.py

@@ -1,2 +1,3 @@
-    # await get_onedriver_swapactivities(
-    #     arr_url_dalao = arr_dalao_usdc_transfer_url , url_type = "usdc_transfer")
+
+        await page.wait_for_selector('#account-tabs iv.flex.flex-col.gap-4.items-stretch.justify-start',timeout=5000)
+        arr_div =await page.locator("#account-tabs div.flex.flex-col.gap-4.items-stretch.justify-start div.

src/code/test_my_find_zhuangjia/new_8002_add_get_getdalao_activites_number.py

@@ -0,0 +1,128 @@
+
+# from datetime import datetime, timezone
+# from playwright.async_api import async_playwright, Playwright
+# from playwright.sync_api import expect
+from playwright.async_api import Playwright, async_playwright, expect
+import random
+
+from base_class import BaseVariableFunction
+from base_class import *
+baseclass = BaseVariableFunction(__file__)
+
+baseclass.makedirpath(baseclass.browsercookie_path)
+baseclass.makedirpath(baseclass.dalao_solscan_info_path)
+old_print = print
+
+
+def timestamped_print(*args, **kwargs):
+    old_print(datetime.datetime.utcnow().replace(
+        microsecond=0), *args, **kwargs)
+
+
+print = timestamped_print
+print('\n'*5)
+print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
+ 
+
+async def do_some_thing(playwright,   arr_url_dalao , url_type):
+
+    # browser =  playwright.chromium.launch(headless=True)
+    context = await playwright.firefox.launch_persistent_context(user_data_dir=USER_DIR_PATH, accept_downloads=True, headless=False)
+    # context = browser.new_context()
+    context.set_default_timeout(19000)
+    # context = await browser.new_context()
+    arr_page = [None]*2
+    arr_page[0] = await context .new_page()
+    await arr_page[0].goto(
+        "https://solscan.io/")
+
+    # print(context.pages)
+
+    for idx_url in range(0, len(arr_url_dalao)):
+
+        str_dalaoTransferUrl = arr_url_dalao[idx_url]
+        str_dalaoaddress =obj_url_2_dalao[str_dalaoTransferUrl]
+        
+        print(f"enter str_dalaoaddress= {str_dalaoaddress}")
+        print(f"enter str_dalaoTransferUrl= {str_dalaoTransferUrl}")
+        print(f"cur_arr_str_dalaoaddress remainder = {len(arr_url_dalao)-idx_url}")
+        arr_page[1] = await context.new_page()
+        page = arr_page[1]
+
+        tbody_ = page.locator(
+            'table.w-full tbody')
+        arr_div =await page.locator("#account-tabs div.flex.flex-col.gap-4.items-stretch.justify-start div.flex.gap-1.flex-row.items-center.justify-start.flex-wrap").all()
+        str_tx_info =(await arr_div[0].text_content().strip())
+        #arr_tds = await last_tr.locator('td').all()
+        # p_token_last_active =  arr_tds[0].locator("p")
+        # str_token_last_active =( await p_token_last_active.text_content()).strip()
+
+        print(str_tx_info)
+        # "div.lg\:flex:nth-child(1) > div:nth-child(1)"
+        # "html.light body.min-h-screen.font-sans div#__next div.flex.flex-col.gap-0.items-stretch.justify-start.h-full.min-h-screen div.w-full.flex-1 div.my-0.mx-auto.max-w-full.px-4.md:px-6.2xl:px-0.2xl:max-w-[1400px] div.flex.flex-col.gap-6.items-stretch.justify-start.w-full div.flex.flex-col.gap-6.items-stretch.justify-start.w-full div#account-tabs div.mr-[-16px].ml-[-16px].sm:mr-0.sm:ml-0 div#radix-:rk:-content-defiactivities.ring-offset-background.focus-visible:outline-none.focus-visible:ring-2.bg-neutral0.p-6.rounded-2xl.[&:nth-child(2)]:rounded-tl-none.ring-transparent.ring-offset-0.focus-visible:ring-offset-0.focus-visible:ring-transparent.mt-0 div.flex.flex-col.gap-4.items-stretch.justify-start div.gap-1.flex-row.items-center.justify-between.flex-wrap.w-full.lg:flex.hidden div.flex.gap-1.flex-row.items-center.justify-start.flex-wrap"
+
+ 
+
+
+        time.sleep(1)
+        await page.close()
+
+    await context.close()
+
+
+async def get_onedriver_swapactivities( arr_url_dalao , url_type):
+    async with async_playwright() as playwright:
+
+        await do_some_thing(playwright, arr_url_dalao, url_type)
+
+
+async def main():
+    print("enter main()")
+    if len(arr_dalao_sol_transfer_url)>0:
+        await get_onedriver_swapactivities(
+            arr_url_dalao = arr_dalao_sol_transfer_url , url_type = "transfer_counts")
+        await asyncio.sleep(3)
+        
+    # if len(arr_dalao_token_inflow_transfer_url)>0:
+    #     await get_onedriver_swapactivities(
+    #         arr_url_dalao = arr_dalao_token_inflow_transfer_url , url_type = "swap_counts")
+    #     await asyncio.sleep(3)
+ 
+
+
+df = pd.read_excel(baseclass.dalao_tran_gmgnOrdex_path /
+                 "input_dalao.xlsx", dtype=object)
+
+arr_str_dalaoaddress = df['dalaoaddress'].tolist()
+arr_str_dalaoaddress=arr_str_dalaoaddress[0:4]
+# arr_dalao_sol_transfer_url =[]
+arr_dalao_url = []
+arr_dalao_swap = []
+obj_url_2_dalao={
+    
+}
+def init():
+    now_time = time.time()
+    global obj_url_2_dalao
+    global arr_dalao_sol_transfer_url ,arr_dalao_token_inflow_transfer_url ,arr_dalao_token_outflow_transfer_url , arr_dalao_usdc_transfer_url
+    for str_dalaoaddress in arr_str_dalaoaddress:
+        # file = baseclass.dalao_solscan_info_path / f"ori_txhash_{str_dalaoaddress}.csv"
+        dalao_transfer_counts_file = baseclass.dalao_solscan_info_path / f"dalao_transfer_counts.json"
+        # token_inflow_transfer_file = baseclass.dalao_solscan_info_path / f"token_inflow_{str_dalaoaddress}.csv"
+   
+ 
+        url_transfer = f"https://solscan.io/account/{str_dalaoaddress}#transfers"  
+        url_swap = f"https://solscan.io/account/{str_dalaoaddress}#defiactivities"     
+        arr_dalao_url.append(url_transfer)
+        obj_url_2_dalao[url_transfer] = str_dalaoaddress
+        
+ 
+            
+
+
+init()
+ 
+downloads_path = baseclass.dalao_solscan_info_path
+USER_DIR_PATH = baseclass.browsercookie_path
+asyncio.run(main())
+print(f"{'{:<6}'.format('END')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")

src/code/test_my_find_zhuangjia/new_8003.py

@@ -1,56 +0,0 @@
-
-# from datetime import datetime, timezone
-# from playwright.async_api import async_playwright, Playwright
-# from playwright.sync_api import expect
-from playwright.async_api import Playwright, async_playwright, expect
-import random
-
-from base_class import BaseVariableFunction
-from base_class import *
-baseclass = BaseVariableFunction(__file__)
-
-baseclass.makedirpath(baseclass.browsercookie_path)
-baseclass.makedirpath(baseclass.dalao_solscan_info_path)
-old_print = print
-
-
-def timestamped_print(*args, **kwargs):
-    old_print(datetime.datetime.utcnow().replace(
-        microsecond=0), *args, **kwargs)
-
-
-print = timestamped_print
-print('\n'*5)
-print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
- 
-arr_exclude_address=[
-    
-]
-
-now_time = time.time()
- 
-df = pd.read_excel(baseclass.dalao_tran_gmgnOrdex_path /
-                 "input_dalao.xlsx", dtype=object)
-arr_str_dalaoaddress = df['dalaoaddress'].tolist()
-
-for str_dalaoaddress in arr_str_dalaoaddress:
-    df_sol_transfer =pd.read_csv(baseclass.dalao_solscan_info_path / f"sol_transfer_{str_dalaoaddress}.csv")
-    df_token_inflow =pd.read_csv(baseclass.dalao_solscan_info_path / f"token_inflow{str_dalaoaddress}.csv")
-    df_token_outflow =pd.read_csv(baseclass.dalao_solscan_info_path / f"token_outflow{str_dalaoaddress}.csv")
-    df_usdc_transfer =pd.read_csv(baseclass.dalao_solscan_info_path / f"usdc_transfer{str_dalaoaddress}.csv")
-    df_sol_transfer=df_sol_transfer.astype({
-        
-        "Time":int,
-    })
-    arr_no_sol_transfer_tx_01 = df_token_inflow["Signature"].tolist() + df_token_outflow["Signature"].tolist() + df_usdc_transfer["Signature"].tolist()
-    df_sol_transfer = df_sol_transfer[~df_sol_transfer["Signature"].isin(arr_no_sol_transfer_tx_01)].reset_index(drop=True)
-    mask_arr_no_sol_transfer_tx_02 =(  df_sol_transfer["Action"]!="TRANSFER"   
-                                     | df_sol_transfer["Time"]<now_time -  1.5*30* 3600*24 
-                                     | df_sol_transfer["From"].isin(arr_exclude_address)
-                                      | df_sol_transfer["To"].isin(arr_exclude_address)
-                                     )
-    df_sol_transfer = df_sol_transfer[mask_arr_no_sol_transfer_tx_02].reset_index(drop=True)
-    df_sol_transfer.columns=["txhash","timestamp","action","from","to","amount","decimals","tokenaddress"]
-    df_sol_transfer=df_sol_transfer[["txhash","timestamp", "from","to","amount", "tokenaddress"]]
-    print(df_sol_transfer)
- 

src/code/new_8003.py → src/code/test_my_find_zhuangjia/new_8003_handle_depth.py

@@ -38,6 +38,9 @@ find_depth = "depth_01"
 
 baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source    )
 baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source /find_depth )
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source /find_depth/"mid" )
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source /find_depth/"final" )
+
 
 def drop_ex_txhash(gdf):
     is_ex = False
@@ -104,7 +107,7 @@ def main():
         df_sol_transfer = df_sol_transfer[["timestamp", "txhash", "datetime" ,"from","to","amount"]]     
         
         df_sol_transfer = df_sol_transfer.groupby(by = ["txhash","from","to" ],  group_keys=False).apply(lambda gdf: sum_same_tx_from_to(gdf))
-        df_sol_transfer.to_csv(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/ f"mid_sol_transfer_{str_dalaoaddress}.csv",index=False)
+        df_sol_transfer.to_csv(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  "mid" /f"mid_sol_transfer_{str_dalaoaddress}.csv",index=False)
  
         df_sol_transfer = df_sol_transfer[[ "timestamp", "datetime", "from","to","amount"]]       
         df_sol_transfer = df_sol_transfer.groupby(by = [ "from","to" ],  group_keys=False).apply(lambda gdf: sum_same_from_to(gdf))
@@ -117,6 +120,7 @@ def main():
         
         
         df_sol_transfer=df_sol_transfer.sort_values(by="timestamp",ascending=False)
-        df_sol_transfer.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/ f"sol_transfer_{str_dalaoaddress}.xlsx",index=False)
+        df_sol_transfer.to_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/  "final"/f"sol_transfer_{str_dalaoaddress}.xlsx",index=False)
+ 
  
 main()

src/code/test_my_find_zhuangjia/new_8004_merge_depth.py

@@ -0,0 +1,56 @@
+
+# from datetime import datetime, timezone
+# from playwright.async_api import async_playwright, Playwright
+# from playwright.sync_api import expect
+ 
+from base_class import BaseVariableFunction
+from base_class import *
+baseclass = BaseVariableFunction(__file__)
+
+baseclass.makedirpath(baseclass.ana_dalao_relation_by_solscan_path )
+
+ 
+old_print = print
+
+
+def timestamped_print(*args, **kwargs):
+    old_print(datetime.datetime.utcnow().replace(
+        microsecond=0), *args, **kwargs)
+
+
+print = timestamped_print
+print('\n'*5)
+print(f"{'{:<6}'.format('ENTER')} {baseclass.scriptfilename} ----------------NOTE-----------NOTE---------------")
+
+
+df = pd.read_excel(baseclass.dalao_tran_gmgnOrdex_path /
+                "input_dalao.xlsx", dtype=object)
+arr_str_dalaoaddress = df['dalaoaddress'].tolist()
+
+
+str_tokenaddress_dalao_source = "4GULMPKBJLruChBZWksZzukAg1AjSCmCTMn9ny2Xpump"
+find_depth = "depth_01"
+
+
+
+
+def main():
+    df_sol_transfer = None
+    for str_dalaoaddress in arr_str_dalaoaddress:
+        print(f"enter {str_dalaoaddress}")
+        cur_df_sol_transfer = pd.read_excel(baseclass.ana_dalao_relation_by_solscan_path /str_tokenaddress_dalao_source/find_depth/ f"sol_transfer_{str_dalaoaddress}.xlsx",dtype=object )
+        df_sol_transfer = pd.concat([df_sol_transfer,cur_df_sol_transfer])
+    df_sol_transfer = df_sol_transfer.astype({
+
+        "timestamp":int,
+        "amount":float,
+        "is_exend":int,
+        "is_relationend":int,
+        
+    })
+    print(df_sol_transfer.head(5))
+
+
+    return
+
+main()