from lib.all import *

data = Csv("myts_refund.csv").read_all()


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"
        )

    def __del__(self):
        self.col_account.close()

    def p(self):
        csv_ = Csv("myts_mid_phone.csv", ["mid", "phonex"])
        for d in data:
            mid = int(d[2])
            q = {
                "_id": mid
            }
            doc = self.col_account.find_one(q)
            mobile_phone = safe_get_str(doc, "mobile_phone")
            dat = [mid, mobile_phone]
            csv_.append(dat)


s = S()
s.p()