scripts/account/fix.py

86 lines
3.2 KiB
Python
Raw Normal View History

2024-05-09 01:35:51 +08:00
from lib.all import *
2024-05-09 01:41:03 +08:00
phones = [
"E067B7E9D67AF3F1A6987796AA8F511EA797CE5954973228410334F10F827BD1",
"8543EF0C969B050225012FE8F4CD10EC3443ED1D604DE345C8E8E8E6188462FC",
"B252721AC8D900F43E8711F9A8E122A1B0B0ACB8D7BF1468382FE893812C17FC",
"3A3532EBB203656ABCC8CF43A21D709B9F7D6BE5F0BD4C29AEC539EC40C6272C",
"F49C9AC80C8F08512D1FD9330EFE1BAFD0B04638D34213E81549F1FA7B5D7826",
"73D2E86C97319159554AD328ACED70EC2CE737D9EA6D0C5E3CE03AA52B05E2F2",
"D81043037A2AEF5AD7A7C7074A0FC3326B97AD616E5DDED8AA586EDE0F34D3E2",
"A0D3AFE4E33F9D7429257B83EA8B79956BDF22CE02DD9E161B7488354979B472",
"0EE9937F8427217BFE494A60933EB0E058083E6C6E0C9D8C439A5BD8CF72F26E",
"F9CA8313DAA5F3E4E94EE7D27FE6D707E27F16BE01CAF8E5EF42C27A845167D0",
"E08375BECBE36B8141483C57E01CE1D8756E53C9ACD15FDEF738099FC546ED74",
"DB1FC1CC03B486C0533DD04565993C5DE732FA5586C741F8491755B585D911CD",
"24EE2325E0097904810B16D62A9EE8B4CFE7D91D43CE5FA9E53C49CC18C0EF2C",
"A6F63C76BBE49233BD45AC2896204300131E7E6DE5FDBB4F386F7F1CCF037CBC",
"58FBDAF2EDC20491F8D8937A61D474A1815C31C4046D2F222ABC2A8BED64ED94",
"D6396A97A067C397450CBD2F448103A63654DF8AE1BD9DAA9F87B0382B162700",
"5F46993F13BEB78BB713C95E0306EBB4862B7B20A68296F4459441CCFC6E080A",
"6DD55EE0EE00772A7EF80229FBBCB15A50CC0D12C84A681F9FF4399097A93A98",
"3B15DF11046264ABB9106CD9743738863723E83B8AA80C2AB9027AED8CAFEBC0",
"C4B00C49603AF974EA5430DEA4619EEB627C86F8FE5B5471590ECECFDD706C45"
]
2024-05-09 01:35:51 +08:00
class S:
def __init__(self):
self.col_account = MongoDB(
host="mongodb://root:Wishpal2024@dds-bp1da1ddd62bede41.mongodb.rds.aliyuncs.com:3717,dds-bp1da1ddd62bede42.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-77304659",
port=3717,
db="account",
collection="account"
)
self.col_login = MongoDB(
host="mongodb://root:Wishpal2024@dds-bp1da1ddd62bede41.mongodb.rds.aliyuncs.com:3717,dds-bp1da1ddd62bede42.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-77304659",
port=3717,
db="login",
collection="login"
)
print(self.col_account)
self.mysql_db_vas = Mysql(
"rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "root", "Wishpal2024"
)
def __del__(self):
self.col_account.close()
self.col_login.close()
self.mysql_db_vas.close()
def get_orders(self, mid):
sql = '''select id,order_status from vas_order where mid={}'''.format(mid)
rows = self.mysql_db_vas.query(sql)
return rows
# def get_login(self, mid):
# q = {
# "mid": mid
# }
# self.col_account
#
def proc_one(self, phone_hash):
q = {
"phone_hash": phone_hash
}
prj = {
"_id": 1,
"ct": 1,
}
docs = self.col_account.find(query=q, projection=prj)
2024-05-09 01:38:56 +08:00
has_order_mids = list()
2024-05-09 01:35:51 +08:00
for doc in docs:
mid = safe_get_int(doc, "_id")
orders = self.get_orders(mid)
2024-05-09 01:38:56 +08:00
if len(orders) > 0:
has_order_mids.append(mid)
2024-05-09 01:35:51 +08:00
2024-05-09 01:41:03 +08:00
print(has_order_mids)
2024-05-09 01:35:51 +08:00
s = S()
2024-05-09 01:41:03 +08:00
for phone in phones:
s.proc_one(phone)