93 lines
3.4 KiB
Python
93 lines
3.4 KiB
Python
from lib.all import *
|
|
|
|
phones = [
|
|
"E067B7E9D67AF3F1A6987796AA8F511EA797CE5954973228410334F10F827BD1",
|
|
"8543EF0C969B050225012FE8F4CD10EC3443ED1D604DE345C8E8E8E6188462FC",
|
|
"B252721AC8D900F43E8711F9A8E122A1B0B0ACB8D7BF1468382FE893812C17FC",
|
|
"3A3532EBB203656ABCC8CF43A21D709B9F7D6BE5F0BD4C29AEC539EC40C6272C",
|
|
"F49C9AC80C8F08512D1FD9330EFE1BAFD0B04638D34213E81549F1FA7B5D7826",
|
|
"73D2E86C97319159554AD328ACED70EC2CE737D9EA6D0C5E3CE03AA52B05E2F2",
|
|
"D81043037A2AEF5AD7A7C7074A0FC3326B97AD616E5DDED8AA586EDE0F34D3E2",
|
|
"A0D3AFE4E33F9D7429257B83EA8B79956BDF22CE02DD9E161B7488354979B472",
|
|
"0EE9937F8427217BFE494A60933EB0E058083E6C6E0C9D8C439A5BD8CF72F26E",
|
|
"F9CA8313DAA5F3E4E94EE7D27FE6D707E27F16BE01CAF8E5EF42C27A845167D0",
|
|
"E08375BECBE36B8141483C57E01CE1D8756E53C9ACD15FDEF738099FC546ED74",
|
|
"DB1FC1CC03B486C0533DD04565993C5DE732FA5586C741F8491755B585D911CD",
|
|
"24EE2325E0097904810B16D62A9EE8B4CFE7D91D43CE5FA9E53C49CC18C0EF2C",
|
|
"A6F63C76BBE49233BD45AC2896204300131E7E6DE5FDBB4F386F7F1CCF037CBC",
|
|
"58FBDAF2EDC20491F8D8937A61D474A1815C31C4046D2F222ABC2A8BED64ED94",
|
|
"D6396A97A067C397450CBD2F448103A63654DF8AE1BD9DAA9F87B0382B162700",
|
|
"5F46993F13BEB78BB713C95E0306EBB4862B7B20A68296F4459441CCFC6E080A",
|
|
"6DD55EE0EE00772A7EF80229FBBCB15A50CC0D12C84A681F9FF4399097A93A98",
|
|
"3B15DF11046264ABB9106CD9743738863723E83B8AA80C2AB9027AED8CAFEBC0",
|
|
"C4B00C49603AF974EA5430DEA4619EEB627C86F8FE5B5471590ECECFDD706C45"
|
|
]
|
|
|
|
|
|
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)
|
|
sort_dict_list(docs, 'ct')
|
|
first_mid = safe_get_int(docs[0], "_id")
|
|
|
|
has_order_mids = list()
|
|
to_delete_mids = list()
|
|
for doc in docs:
|
|
mid = safe_get_int(doc, "_id")
|
|
if mid == first_mid:
|
|
continue
|
|
orders = self.get_orders(mid)
|
|
if len(orders) > 0:
|
|
has_order_mids.append(mid)
|
|
else:
|
|
to_delete_mids.append(mid)
|
|
|
|
print(phone, len(docs), len(to_delete_mids))
|
|
|
|
|
|
s = S()
|
|
for phone in phones:
|
|
s.proc_one(phone)
|