From 9ffecdfd4faf0c2acf02c48b6cb7b5364abcdb78 Mon Sep 17 00:00:00 2001 From: Chinaholmesfans <50159534+Chinaholmesfans@users.noreply.github.com> Date: Fri, 14 Aug 2020 03:44:04 +0800 Subject: [PATCH] =?UTF-8?q?=E7=8E=B0=E5=9C=A8=E5=8F=AF=E4=BB=A5=E5=8F=AA?= =?UTF-8?q?=E4=BF=9D=E7=95=99=E6=AF=8F=E6=97=A5=E6=9C=80=E6=96=B0=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- InsideSummary.py | 123 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 123 insertions(+) create mode 100644 InsideSummary.py diff --git a/InsideSummary.py b/InsideSummary.py new file mode 100644 index 0000000..3d3db0e --- /dev/null +++ b/InsideSummary.py @@ -0,0 +1,123 @@ +import re +import json +import requests +import pymysql +import datetime +################################################################################################## + #爬取数据 +# 国内疫情数据概况 +class InsideSummary: + def __init__(self): + self.curConfirm = 0 #现有确诊 + self.curConfirmRelative = 0#较昨日新增确诊 + self.asymptomatic = 0 #无症状感染 + self.asymptomaticRelative = 0 #较昨日新增无症状感染 + self.unconfirmed = 0 #现有疑似 + self.unconfirmedRelative = 0#较昨日疑似新增 + self.icu = 0 #现有重症 + self.icuRelative = 0 #较昨日重症病例新增 + self.confirmed = 0 #累计确诊 + self.confirmedRelative = 0 #较昨日累计确诊新增 + self.overseasInput = 0 #累计境外输入 + self.overseasInputRelative = 0#较昨日累计境外输入新 增 + self.cured = 0 #累计治愈 + self.curedRelative = 0 #较昨日累计治愈新增 + self.died = 0 #累计死亡 + self.diedRelative = 0#较昨日累计死亡新增 + self.updatedTime = 0 #发布时间 + # 数据库接口 + def get_inside_summary_tuple(self): + return ((self.curConfirm, self.curConfirmRelative, self.asymptomatic, self.asymptomaticRelative, \ + self.unconfirmed, self.unconfirmedRelative, self.icu, self.icuRelative, self.confirmed, \ + self.confirmedRelative, self.overseasInput, self.overseasInputRelative, self.cured, self.curedRelative, \ + self.died, self.diedRelative, self.updatedTime)) + # 输出接口 + def __str__(self): + return '%s %s %s %s %s %s %s %s %s %s %s %s %s %s %s %s %s' % ( + self.curConfirm, self.curConfirmRelative, self.asymptomatic, self.asymptomaticRelative, self.unconfirmed, + self.unconfirmedRelative, self.icu, self.icuRelative, self.confirmed, self.confirmedRelative, + self.overseasInput, self.overseasInputRelative, self.cured, self.curedRelative, self.died, self.diedRelative, + self.updatedTime) +####################################################################################################### + #业务逻辑类 + +# 爬取国内疫情数据 +res=requests.get('https://view.inews.qq.com/g2/getOnsInfo?name=disease_h5') +#解码 +res=res.content.decode('utf-8') + +dict=json.loads(res) #str->dict + +#规范数据 +for key in dict: + try: + dict[key] = dict[key].replace('\\', '') + key=key.replace('\\','') + except: + pass +#新生成data字典 +data=json.loads(dict['data']) + +# 国内疫情数据实例化 +# # #赋值 +def fetch_inside_summary(data): + insideSummary = InsideSummary() + insideSummary.curConfirm = int(data['chinaTotal']['nowConfirm']) + insideSummary.curConfirmRelative = int(data['chinaAdd']['nowConfirm']) + insideSummary.asymptomatic = int(data['chinaTotal']['noInfect']) + insideSummary.asymptomaticRelative = int(data['chinaAdd']['noInfect']) + insideSummary.unconfirmed = int(data['chinaTotal']['suspect']) + insideSummary.unconfirmedRelative = int(data['chinaAdd']['suspect']) + insideSummary.icu = int(data['chinaTotal']['nowSevere']) + insideSummary.icuRelative = int(data['chinaAdd']['nowSevere']) + insideSummary.confirmed = int(data['chinaTotal']['confirm']) + insideSummary.updatedTime = data['lastUpdateTime'] + insideSummary.confirmedRelative = int(data['chinaAdd']['confirm']) + insideSummary.overseasInput = int(data['chinaTotal']['importedCase']) + insideSummary.overseasInputRelative = int(data['chinaAdd']['importedCase']) + insideSummary.cured = int(data['chinaTotal']['heal']) + insideSummary.curedRelative = int(data['chinaAdd']['heal']) + insideSummary.died = int(data['chinaTotal']['dead']) + insideSummary.diedRelative = int(data['chinaAdd']['dead']) + return insideSummary +########################################################################################################## + #存储数据于数据库 + +#保存国内疫情概况数据 + +def insert(res): + + # 创建连接，并且返回连接对象 + conn =pymysql.connect(host='localhost',user='root',db='covid19_datas_guangxi',passwd='kfq991122',charset='utf8') + # 创建游标对象 + cursor = conn.cursor() + + date = data['lastUpdateTime'] + sql = 'delete from home_realtime_datas where updatedTime like "%s"'%(date+'%') + print('The update was successful') + try: + cursor.execute(sql) + conn.commit() + except Exception as e: + print(e) + + sql='insert into home_realtime_datas(curConfirm,curConfirmRelative,asymptomatic,asymptomaticRelative,unconfirmed,unconfirmedRelative,icu,icuRelative,confirmed,confirmedRelative,overseasInput,overseasInputRelative,cured,curedRelative,died,diedRelative,updatedTime) values(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)' + try: + cursor.execute(sql, res) + conn.commit() + except Exception as e: + print(e) + print('+++ save_province_datas is over.') + cursor.close() + conn.close() + + +insert(fetch_inside_summary(data).get_inside_summary_tuple()) + + +conn = pymysql.connect('localhost','root','kfq991122','covid19_datas_guangxi') +cursor = conn.cursor() +sql = 'select * from home_realtime_datas' +cursor.execute(sql) +results = cursor.fetchall() +print(results)