| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475 |
- # 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']}")
|
