# coding:utf-8
'''
搬数据脚本
'''
import requests
import pandas as pd
from pymongo import MongoClient
from loguru import logger

logger.add('./logs/runtime_{time}.log', rotation='00:00')

s_config = {
    "host": "192.168.3.71",
    "port": 3366,
    "user": "root",
    "password": "Topnet123",
    "db": "yunyingData",
    "charset": "utf8",
}

client = MongoClient("192.168.3.207:29098")
m_col = client["qfw"]["user_sale"]
# sql = DBHelper(s_config)
if __name__ == '__main__':
    from docs.config import insert_config
    import time

    # 18588850589
    # 13991521248

    # accessToken = "17FD2230024BCBBF3EA3466A4972EFBC"
    data = pd.read_csv("./docs/06.csv", keep_default_na=False, dtype=str, low_memory=False)
    data_cluster = data[['公司名称', '姓名', '联系人电话', '联系人邮箱', '职位', '用户昵称', '购买的产品类型', '公司网站',
                         '客户状态', '所属人', '销售线索来源', '意向购买产品', "创建时间", '最近更新时间']]
    fields = ["company", "username", "phone", "email", "job", "usernickname", "product", "web",
              "status999", "empNo", "source", "wantGoods", "createTime", "lastUpdateTime"]
    status = {"成交客户": "status0", "待签署客户": "status1", "高意向客户": "status2", "意向客户": "status3",
              "潜在客户": "status4", "销售线索": "status5", "无意向客户": "status6"}
    people = {"沈炳毅": "1836", "左远达": "2098", "陈鹏": "2109", "郭迪": "2248",
              "龚文华": "2267", "王鹏": "2330", "王晨旭": "2335", "曾爽爽": "2364",
              "剑鱼": "2372", "刘凯": "2513", "马佳鑫": "2527", "廉心玲": "2533",
              "刘樊阳": "2571", "刘振宏": "2646", "明灿": "2709", "贾老师": "8001",
              "田小亮": "8013", "0002": "8018", "高翔": "8546", "范宗洞": "8884"}
    data_values = data_cluster.values
    for row in data_values[:1]:
        body01 = {}
        for field, values in zip(fields, row):
            body01[field] = values

        if body01.get("status999", "") in status:
            body01["status999"] = status[body01["status999"]]
        if body01.get("empNo", "") in people:
            body01["empNo"] = people[body01["empNo"]]
            body01["owner"] = body01["empNo"]
        body01["unique_id"] = body01["phone"]
        # start = time.time()
        ret = m_col.find({"phone": body01["phone"]}).sort("_id", -1).limit(0)
        data = {'unique_id': 'test', 'status999': 'status6', 'empNo': '2335', 'owner': '2335',
                'ownerLeader': '1836', 'company': '上海意满圆生物科技有限公司', 'username': '杨邦兴', 'phone': '13671992411',
                'email': '', 'address': '', 'usernickname': '杨邦兴', 'product': '', 'web': '',
                'id': '5f98f5066fa1c2e2068b0', 'job': '经理', 'regtime': '2020-10-28 12:35:18',
                'payorderinfo': '未购买过剑鱼产品', 'unpayorderinfo': '无未支付订单', 'source': '点击查看采购意向项目信息详情后留资',
                'keyword': '医疗,糖化,杨浦区', 'area': '', 'searchkeyword': '杨浦区,宝山区,抗原', 'searcharea': '',
                'lastlogintime': '2022-05-13 11:07:06', 'lastloginport': 'APP', 'isclickkf': None,
                'browsetitle1': '上海市宝山区中西医结合医院2022年4月至5月政', 'browsetitle2': '中外华东有限公司2022年医疗项目仓储服务资源采购',
                'browsetitle3': '2022年中国电信上海公司新型冠状病毒抗原检测试剂盒采购项目成交供', 'customerNeeds': '', 'customerFocus': '',
                'wantGoods': '', 'customerBudget': '', 'rivalCompare': '', 'isPolicymaker': '', 'secondContactName': '',
                'secondContactJob': '', 'secondContactPhone': '', 'secondContactEmail': '', 'thirdContactName': '',
                'thirdContactJob': '', 'thirdContactPhone': '', 'thirdContactEmail': ''}

        result = requests.post("http://callcenter.jydev.jianyu360.com/", data=data)
        # result = requests.post("http://localhost:5001", data=data)
        print(body01['phone'])
        if result.text != "200":
            logger.warning(f"{body01['phone']}")