jupyter/体质检测管理.ipynb

体质检测管理

体测单位信息导入

In [ ]:

import openpyxl
import json
import pymongo

myclient = pymongo.MongoClient('mongodb://localhost:27017/')
mydb = myclient["tice"]
mycol = mydb["unit"]

name = '中国石油化工股份有限公司安庆炼化分公司'
short_name = '安庆炼化'
myquery = { "name": name}
if mycol.find_one(myquery) is None:    
    wb = openpyxl.load_workbook('data/中国石油化工股份有限公司安庆炼化分公司员工在职人员名单.xlsx')
    sheet = wb.active
    #sheets = wb.sheetnames
    depart = []
    dict1 = {}
    new_code = []
    for n in range(2,sheet.max_row+1):
        m_depart = sheet.cell(n,5).value
        if m_depart not in depart:
            depart.append(sheet.cell(n,5).value)
        #print(sheet.cell(n,5).value)

    dict1['name'] = '中国石油化工股份有限公司安庆炼化分公司'
    dict1['short_name']  = '安庆炼化'
    dict1['depart'] = depart
    mycol.insert_one(dict1)
    print('ok!')
else:
    print('该单位已存在！')    
    

录入体测信息

In [ ]:

import pymongo
from bson.objectid import ObjectId
from dateutil import parser

myclient = pymongo.MongoClient('mongodb://localhost:27017/')
mydb = myclient["tice"]
mycol = mydb["unit"]
mycol1 = mydb["event"]
dict1 = {}

name = '中国石油化工股份有限公司安庆炼化分公司'
myquery = { "name": name}
dict1['code'] = 120
dict1['unit'] = '中国石油化工股份有限公司安庆炼化分公司'
dict1['address'] = '安徽安庆'
dict1['date_begin'] ='2021-09-08'
dict1['date_end'] = '2021-09-30'
if mycol.find_one(myquery) is None:    
    print('体测单位不存在！')
else:
    myquery1 = { "code": dict1['code']}
    if mycol1.find_one(myquery1) is None:
        mycol1.insert_one(dict1)
        print('ok!')
    else:
        print('该体测信息已经存在！')

导入单位员工信息

In [ ]:

import openpyxl
import json
import pymongo
from bson.objectid import ObjectId

myclient = pymongo.MongoClient('mongodb://localhost:27017/')
mydb = myclient["tice"]
mycol = mydb["unit"]

myquery = { "_id": ObjectId("6164fc343d39c8cdd2d97179")}
 
mydoc = mycol.find(myquery)
 
for x in mydoc:
    print(x)

获取人员测试成绩

In [95]:

import pymysql
import json
filename = 'item.json'
item = {}
unit = {}
with open(filename,'r') as fl:
    dict1 = json.load(fl) 
for k,v in dict1.items():
    item[k] = v
user_id = 5
place_id =120
user = '包永'
db = pymysql.connect("localhost","root","songyi","ydyb" )
cursor = db.cursor()
sql = f'SELECT a.item_id,a.performance,a.score,a.date FROM places_result AS a WHERE a.place_id={place_id} AND a.avatar_id={user_id}'
cursor.execute(sql)
re_ta = {}
dict1 = {}
print("\n运动项目信息：")
results = cursor.fetchall()
for result in results:
    re_ta.setdefault(user,{})
    m_item = str(result[0])
    dict1.setdefault(item[m_item]['name'],{})
    score = result[1]/item[m_item]['divisor']
    dict1[item[m_item]['name']]['成绩'] =f'{score} {item[m_item]["unit"]}'
    dict1[item[m_item]['name']]['得分'] =result[2]
    dict1[item[m_item]['name']]['date'] =result[3]
    re_ta[user] = dict1

print(re_ta)

运动项目信息：
{'包永': {'台阶指数': {'成绩': '65.0 分', '得分': 4, 'date': datetime.date(2021, 9, 15)}, '身高': {'成绩': '174.7 厘米', '得分': None, 'date': datetime.date(2021, 9, 15)}, '体重': {'成绩': '73.6 千克', '得分': 5, 'date': datetime.date(2021, 9, 15)}, '肺活量': {'成绩': '3812.0 毫升', '得分': 4, 'date': datetime.date(2021, 9, 15)}, '握力': {'成绩': '51.0 千克', '得分': 4, 'date': datetime.date(2021, 9, 15)}, '单脚站立': {'成绩': '13.2 秒', '得分': 3, 'date': datetime.date(2021, 9, 15)}, '坐位体前屈': {'成绩': '20.0 厘米', '得分': 5, 'date': datetime.date(2021, 9, 15)}, '选择反应时': {'成绩': '0.554 秒', '得分': 3, 'date': datetime.date(2021, 9, 15)}, '俯卧撑': {'成绩': '39.0 次', '得分': 5, 'date': datetime.date(2021, 9, 15)}, '纵跳': {'成绩': '38.4 厘米', '得分': 4, 'date': datetime.date(2021, 9, 15)}}}

读取体测报告信息

In [ ]:

import pdfplumber

# 读取 PDF 文档
pdf = pdfplumber.open("5.pdf")

# 获取页数
print("总页数：",len(pdf.pages))
print("-----------------------------------------")

# 读取第 4 页；索引从 1 开始
page = pdf.pages[1] 
print("本页：",page.page_number + 1)
print("-----------------------------------------")
text = page.extract_text()
#for s in text:
#    print(s)
print(text)
print(text.split('\n'))

In [ ]:

import pdfplumber
import pymysql
"""获取人员测试成绩"""
user_id = 5
place_id =120
db = pymysql.connect("localhost","root","songyi","ydyb" )
cursor = db.cursor()
sql = f'SELECT a.item_id,a.performance,a.score,a.date FROM places_result AS a WHERE a.place_id={place_id} AND a.avatar_id={user_id}'
cursor.execute(sql)
re_ta = {}
print("\n运动项目信息：")
results = cursor.fetchall()
for result in results:
#    print ("%d--%s" %(result[0],result[1]))
    re_ta[result[0]] = result[1]

dict1 = {}

# 读取 PDF 文档
pdf = pdfplumber.open("5.pdf")

# 获取页数
num = len(pdf.pages)
page = pdf.pages[0] 
text = page.extract_text()
dict1['name'] = text.split('\n')[2]
dict1['sn'] = text.split('\n')[4]


print(dict1)

体测项目信息

In [91]:

import pymysql
import json

db = pymysql.connect("localhost","root","songyi","ydyb" )
cursor = db.cursor()
sql = "SELECT a.id,a.name, b.name,b.divisor FROM items AS a,items_unit AS b WHERE a.unit_id = b.id"
cursor.execute(sql)
dict1 = {}

results = cursor.fetchall()
for result in results:
#    print ("%d--%s" %(result[0],result[1]))
    item = {}
    id = result[0]
    dict1.setdefault(id,{})
    item['name'] = result[1]
    item['unit'] = result[2]
    item['divisor'] = result[3]
    dict1[id] = item
filename = 'item.json'
with open(filename,'w') as fl:
    json.dump(dict1, fl,ensure_ascii=False) 
with open(filename,'r') as fl:
    dict1 = json.load(fl) 
for k,v in dict1.items():
    print(k,v)

1 {'name': '肺活量', 'unit': '毫升', 'divisor': 1}
2 {'name': '握力', 'unit': '千克', 'divisor': 1000}
3 {'name': '坐位体前屈', 'unit': '厘米', 'divisor': 10}
4 {'name': '纵跳', 'unit': '厘米', 'divisor': 10}
5 {'name': '俯卧撑', 'unit': '次', 'divisor': 1}
6 {'name': '单脚站立', 'unit': '秒', 'divisor': 1000}
7 {'name': '选择反应时', 'unit': '秒', 'divisor': 1000}
8 {'name': '台阶指数', 'unit': '分', 'divisor': 10}
9 {'name': '一分钟仰卧起坐', 'unit': '次', 'divisor': 1}
10 {'name': '身高', 'unit': '厘米', 'divisor': 10}
11 {'name': '体重', 'unit': '千克', 'divisor': 1000}
12 {'name': '立定跳远', 'unit': '厘米', 'divisor': 10}
13 {'name': '网球掷远', 'unit': '米', 'divisor': 1000}
14 {'name': '双脚连续跳', 'unit': '秒', 'divisor': 1000}
15 {'name': '10米折返跑', 'unit': '秒', 'divisor': 1000}
16 {'name': '走平衡木', 'unit': '秒', 'divisor': 1000}
17 {'name': '50米跑', 'unit': '秒', 'divisor': 1000}
18 {'name': '一分钟跳绳', 'unit': '次', 'divisor': 1}
19 {'name': '50米*8往返跑', 'unit': '秒', 'divisor': 1000}
20 {'name': '高压', 'unit': 'mmHg', 'divisor': 1}
21 {'name': '低压', 'unit': 'mmHg', 'divisor': 1}
22 {'name': '心率', 'unit': '次', 'divisor': 1}
23 {'name': '长跑', 'unit': '秒', 'divisor': 1000}
24 {'name': '引体向上', 'unit': '次', 'divisor': 1}
27 {'name': '实心球', 'unit': '米', 'divisor': 1000}
28 {'name': '篮球运球', 'unit': '秒', 'divisor': 1000}
29 {'name': '足球运球', 'unit': '秒', 'divisor': 1000}
30 {'name': '足球垫球', 'unit': '次', 'divisor': 1}
31 {'name': '排球垫球', 'unit': '次', 'divisor': 1}
32 {'name': '25米×2往返跑', 'unit': '秒', 'divisor': 1000}
33 {'name': '左右眼视力', 'unit': '分', 'divisor': 10}
34 {'name': '测试', 'unit': '毫升', 'divisor': 1}
37 {'name': '跪卧撑', 'unit': '次', 'divisor': 1}
38 {'name': '功率车', 'unit': '毫升/千克/分钟', 'divisor': 10}

In [80]:

import json
filename = 'item.json'
item = {}
with open(filename,'r') as fl:
    dict1 = json.load(fl) 
for k,v in dict1.items():
    item[k] = v
print(item['1'])

{'name': '肺活量', 'unit': '毫升', 'divisor': 1, 'info': '肺活量（vital capacity）是指在最大吸气后尽力呼气的气量。包括潮气量、补吸气量和补呼气量三部分。潮气量是指一次呼吸周期中肺吸量或呼出的气量，在潮气量之外再吸入的最大气量为补吸气量，在潮气量之外再呼出的最最大量为补呼气量，最大呼气后残留在肺内的气量为余气量。\r\n肺活量与人的呼吸密切相关。生理学研究表明：人体的各器官、系统、组织、细胞每时每刻都在消耗氧，机体只有在氧供应充足的情况下才能正常工作。人体内部的氧供给全部靠肺的呼吸来获得，在呼吸过程中，肺不仅要摄入氧气，还要将体内代谢出的二氧化碳排出。\r\n可以这样认为：肺是机体气体交换的中转站，这个中转站的容积大小直接决定着每次呼吸气体交换的量，这是检测肺功能的最直观、也是最客观的指标。'}

In [ ]: