512song/jupyter
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

20240920

Browse Source
This commit is contained in:
512song committed 2024-09-20 19:46:44 +08:00
1 parent 63f678daf4
commit 96f043313c
4 files changed
+445 -670
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

体测单位/体测数据管理.ipynb
+32 -206
View File
@@ -23,10 +23,10 @@
"mydb = myclient[\"baogao\"]\n",
"mycol = mydb[\"place\"]\n",
"\n",
"place_id = 698465\n",
"place_code = \"06\"\n",
"dw_name = \"天宫院社区\"\n",
"dw_jc = \"天宫院社区\"\n",
"place_id = 727411\n",
"place_code = \"13\"\n",
"dw_name = \"北体体质康健班\"\n",
"dw_jc = \"北体体质康健班\"\n",
"myquery = { \"id\": place_id }\n",
"num = mycol.count_documents(myquery)\n",
"if num>0:\n",
@@ -46,26 +46,10 @@
},
{
"cell_type": "code",
"execution_count": 11,
"execution_count": null,
"id": "6ce2cbc7-435a-461c-bdb8-abd9a6962fbc",
"metadata": {
"execution": {
"iopub.execute_input": "2024-08-11T11:24:39.665184Z",
"iopub.status.busy": "2024-08-11T11:24:39.664256Z",
"iopub.status.idle": "2024-08-11T11:24:39.691000Z",
"shell.execute_reply": "2024-08-11T11:24:39.690127Z",
"shell.execute_reply.started": "2024-08-11T11:24:39.665085Z"
}
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"ok\n"
]
}
],
"metadata": {},
"outputs": [],
"source": [
"import openpyxl\n",
"import os,sys,shutil\n",
@@ -79,10 +63,10 @@
"myclient = pymongo.MongoClient('mongodb://localhost:27017/')\n",
"mydb = myclient[\"baogao\"]\n",
"\n",
"place_id = 698465\n",
"place_code = \"06\"\n",
"dw_name = \"淄博积家村\"\n",
"dw_jc = \"淄博积家村\"\n",
"place_id = 727411\n",
"place_code = \"13\"\n",
"dw_name = \"北体体质康健班\"\n",
"dw_jc = \"北体体质康健班\"\n",
"fi_path = '/home/songyi/python/mycrm/flask/pdf/files'\n",
"fls = glob.glob(f'{fi_path}/{str(place_id)}/*.pdf')\n",
"\n",
@@ -113,53 +97,13 @@
" #fi_name =Path(fn).stem\n",
" code = int(fi_name)\n",
" dxm = list1[i]\n",
" dict2 = {'place_id':place_id,'code':dxm,'fn':Path(fn).name,'rq':'20240811'}\n",
" dict2 = {'place_id':place_id,'code':dxm,'fn':Path(fn).name,'rq':'20240914'}\n",
" list2.append(dict2)\n",
" i +=1\n",
"x = mycol.insert_many(list2)\n",
"print('ok') "
]
},
{
"cell_type": "code",
"execution_count": null,
"id": "1ca065ca-d999-4e3f-841b-16f9666b6975",
"metadata": {},
"outputs": [],
"source": [
"import openpyxl\n",
"import os,sys,shutil\n",
"import json\n",
"import math\n",
"import glob\n",
"import random\n",
"from pathlib import Path\n",
"import pymongo\n",
"\n",
"myclient = pymongo.MongoClient('mongodb://localhost:27017/')\n",
"mydb = myclient[\"baogao\"]\n",
"\n",
"place_id = 727410\n",
"place_code = \"08\"\n",
"dw_name = \"北体体质康健实验班\"\n",
"dw_jc = \"北体体质康健实验班\"\n",
"fi_path = '/home/songyi/python/mycrm/flask/pdf/files'\n",
"fls = glob.glob(f'{fi_path}/{str(place_id)}/*.pdf')\n",
"\n",
"code_list = []\n",
"for i in range(10): # 0~9\n",
" code_list.append(str(i))\n",
"list1 = []\n",
"mycol = mydb[\"pdf\"]\n",
"query1 = { \"place_id\": place_id }\n",
"list2 = []\n",
"mydoc = mycol.find(query1,{ \"code\": 1, \"_id\": 0 })\n",
"\n",
"for x in mydoc:\n",
" list2.append(x['code'])\n",
"print(list2)"
]
},
{
"cell_type": "markdown",
"id": "ad9e943a-bb3a-4d58-93ef-cc442a80effa",
@@ -170,64 +114,12 @@
},
{
"cell_type": "code",
"execution_count": 12,
"execution_count": null,
"id": "5f665c0f-8d30-4759-b7f8-fb7e13b98efa",
"metadata": {
"execution": {
"iopub.execute_input": "2024-08-11T11:26:41.537017Z",
"iopub.status.busy": "2024-08-11T11:26:41.536326Z",
"iopub.status.idle": "2024-08-11T11:26:41.562731Z",
"shell.execute_reply": "2024-08-11T11:26:41.561622Z",
"shell.execute_reply.started": "2024-08-11T11:26:41.536952Z"
},
"tags": []
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"5 no phone\n",
"22 no phone\n",
"19 no phone\n",
"38 no phone\n",
"25 no phone\n",
"6 no phone\n",
"8 no phone\n",
"26 no phone\n",
"15 no phone\n",
"13 no phone\n",
"20 no phone\n",
"23 no phone\n",
"27 no phone\n",
"10 no phone\n",
"21 no phone\n",
"3 no phone\n",
"30 no phone\n",
"11 no phone\n",
"14 no phone\n",
"24 no phone\n",
"1 15153309038 9-曹秀芹.pdf\n",
"2 13573332133 17-段玉华.pdf\n",
"3 13964491825 7-韩美华.pdf\n",
"4 15553344004 1-张爱英.pdf\n",
"5 15853389189 36-袁会富.pdf\n",
"6 15069350919 16-王芹英.pdf\n",
"7 15165846001 2-张俊华.pdf\n",
"8 13070650793 18-肖翠花.pdf\n",
"9 13455364491 35-王霞.pdf\n",
"10 15853380767 28-肖爱英.pdf\n",
"11 13646430765 29-梁桂岭.pdf\n",
"12 13053316892 12-孙宗玲.pdf\n",
"13 13287885248 31-杜婷.pdf\n",
"14 13153385772 32-崔杰.pdf\n",
"15 15169224472 33-姚桂银.pdf\n",
"16 13583398468 4-尚永.pdf\n",
"17 18653305998 37-李琳.pdf\n",
"18 13869390557 34-徐爱锋.pdf\n"
]
}
],
"outputs": [],
"source": [
"from tencentcloud.common import credential\n",
"from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException\n",
@@ -241,13 +133,13 @@
"mydb = myclient[\"baogao\"]\n",
"mycol = mydb[\"pdf\"]\n",
"\n",
"dw_jc = \"淄博积家村测试者\"\n",
"filename = 'data/积家基础数据2408.json'\n",
"dw_jc = \"北体体质康健班\"\n",
"filename = 'data/北体体质康健.json'\n",
"with open(filename,'r') as fl:\n",
" dict1 = json.load(fl) \n",
"dict2 = {}\n",
"#place_id = 571315\n",
"myquery = { \"place_id\": place_id,\"rq\":'20240811' }\n",
"myquery = { \"place_id\": place_id,\"rq\":'20240914' }\n",
"for x in mycol.find(myquery,{ \"_id\": 0, \"place_id\": 0}):\n",
" code = int(x['fn'].split('-')[0])\n",
" if str(code) in dict1.keys() and 'phone' in dict1[str(code)].keys():\n",
@@ -302,64 +194,12 @@
},
{
"cell_type": "code",
"execution_count": 13,
"execution_count": null,
"id": "4b2b5d76-665f-4dfe-bbd3-5c80abd8c3e3",
"metadata": {
"execution": {
"iopub.execute_input": "2024-08-11T11:28:21.443578Z",
"iopub.status.busy": "2024-08-11T11:28:21.442841Z",
"iopub.status.idle": "2024-08-11T11:28:25.277992Z",
"shell.execute_reply": "2024-08-11T11:28:25.276474Z",
"shell.execute_reply.started": "2024-08-11T11:28:21.443507Z"
},
"tags": []
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"no phone\n",
"15153309038 send success\n",
"13573332133 send success\n",
"13964491825 send success\n",
"15553344004 send success\n",
"15853389189 send success\n",
"15069350919 send success\n",
"15165846001 send success\n",
"13070650793 send success\n",
"13455364491 send success\n",
"15853380767 send success\n",
"13646430765 send success\n",
"13053316892 send success\n",
"13287885248 send success\n",
"13153385772 send success\n",
"15169224472 send success\n",
"13583398468 send success\n",
"18653305998 send success\n",
"13869390557 send success\n"
]
}
],
"outputs": [],
"source": [
"from tencentcloud.common import credential\n",
"from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException\n",
@@ -368,18 +208,19 @@
"from tencentcloud.common.profile.http_profile import HttpProfile\n",
"import json\n",
"import pymongo\n",
"import time\n",
"\n",
"myclient = pymongo.MongoClient('mongodb://localhost:27017/')\n",
"mydb = myclient[\"baogao\"]\n",
"mycol = mydb[\"pdf\"]\n",
"\n",
"dw_jc = \"淄博积家村测试者\"\n",
"filename = 'data/积家基础数据2408.json'\n",
"dw_jc = \"北体体质康健班测试者\"\n",
"filename = 'data/北体体质康健.json'\n",
"with open(filename,'r') as fl:\n",
" dict1 = json.load(fl) \n",
"dict2 = {}\n",
"#place_id = 571315\n",
"myquery = { \"place_id\": place_id,\"rq\":'20240811' }\n",
"myquery = { \"place_id\": place_id,\"rq\":'20240914' }\n",
"for x in mycol.find(myquery,{ \"_id\": 0, \"place_id\": 0}):\n",
" code = int(x['fn'].split('-')[0])\n",
" if str(code) in dict1.keys() and 'phone' in dict1[str(code)].keys():\n",
@@ -387,7 +228,7 @@
" else:\n",
" print('no phone')\n",
"#print(dict2)\n",
"dw_jc = \"世纪花园测试者\"\n",
"#dw_jc = \"北体体质康健班测试者\"\n",
"#dict2 = {375: {'phone': '13793180751', 'code': '0379208'}}\n",
"for k, v in dict2.items():\n",
" phone = '+86'+v['phone']\n",
@@ -416,8 +257,8 @@
" req.SenderId = \"\"\n",
" resp = client.SendSms(req)\n",
" dict3 = json.loads(resp.to_json_string(indent=2))\n",
"\n",
" print(v['phone'],dict3['SendStatusSet'][0][\"Message\"])\n",
" time.sleep(2)\n",
" except TencentCloudSDKException as err:\n",
" print(v['phone'],err)"
]
@@ -443,27 +284,12 @@
},
{
"cell_type": "code",
"execution_count": 9,
"execution_count": null,
"id": "25a269c3-758f-4e79-ae6d-a6e6f161d64b",
"metadata": {
"execution": {
"iopub.execute_input": "2024-08-11T10:49:44.708154Z",
"iopub.status.busy": "2024-08-11T10:49:44.707426Z",
"iopub.status.idle": "2024-08-11T10:49:44.956435Z",
"shell.execute_reply": "2024-08-11T10:49:44.954940Z",
"shell.execute_reply.started": "2024-08-11T10:49:44.708083Z"
},
"tags": []
},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"+8613793180751 send success\n"
]
}
],
"outputs": [],
"source": [
"from tencentcloud.common import credential\n",
"from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException\n",
@@ -477,12 +303,12 @@
"mydb = myclient[\"baogao\"]\n",
"mycol = mydb[\"pdf\"]\n",
"\n",
"filename = 'data/世纪花园基础数据240808.json'\n",
"filename = 'data/北体体质康健.json'\n",
"with open(filename,'r') as fl:\n",
" dict1 = json.load(fl) \n",
"dict2 = {}\n",
"#place_id = 571315\n",
"myquery = { \"place_id\": place_id,\"rq\":'20240811' }\n",
"myquery = { \"place_id\": place_id,\"rq\":'20240914' }\n",
"for x in mycol.find(myquery,{ \"_id\": 0, \"place_id\": 0}):\n",
" code = int(x['fn'].split('-')[0])\n",
" if str(code) in dict1.keys() and 'phone' in dict1[str(code)].keys():\n",
@@ -490,10 +316,10 @@
" else:\n",
" print('no phone')\n",
"#print(dict2)\n",
"dw_jc = \"世纪花园测试者\"\n",
"dw_jc = \"北体体质康健班测试者\"\n",
"\n",
"phone = '+86'+'13793180751'\n",
"yzm = '05403'\n",
"phone = '+86'+'18854609676'\n",
"yzm = '13306'\n",
"try: \n",
" secretId = \"AKID22rVyvSqbikXFFvav31ykc9YmqjN6KYc\"\n",
" secretKey = \"51XVL1YxDKI6mJh8au6DDuTskS1RhwJX\"\n",