查詢全球疫情app

設計思想：首先需要在網站上爬取全球的的疫情信息，需要運用Python語言並且使用pycharm來連接MySQL數據庫，講爬取到的疫情信息存到數據庫中去，代碼如下：

import pymysql
import requests
import json
# 放入要爬的url
url = "https://view.inews.qq.com/g2/getOnsInfo?name=disease_h5"
# 設置header做一個防爬機制
header = {"user-agent": "Mozilla/5.0 (Linux; Android 8.0.0; Pixel 2 XL Build/OPD1.170816.004) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.116 Mobile Safari/537.36"}
# 獲取response的json
response = requests.get(url, headers=header)
# 取得數據詞典
data = json.loads(response.content.decode())
data_str = data['data']
data_json = json.loads(data_str)
# 連接數據庫
db = pymysql.connect(host = 'localhost', port=3306, user='root', password='20183602', db='yiqing', charset='utf8')
#使用cursor方法生成一個游標
cursor = db.cursor()
confirmed_total = 0
suspected_total = 0
dead_total = 0
healed_total = 0
# 更新時間
lastUpdateTime = data_json['lastUpdateTime']
# 取出各個國家的數據
for worldData in data_json['areaTree']:
    countryName = worldData['name']
    confirmed = worldData['total']['confirm']
    confirmed_total += confirmed
    suspected = worldData['total']['suspect']
    suspected_total += suspected
    dead = worldData['total']['dead']
    dead_total += dead
    healed = worldData['total']['heal']
    healed_total += healed
    sql = "insert into worlddata(id,countryname,confirmed,suspected,dead,healed,lastupdateTime) values({},'{}','{}','{}','{}', '{}','{}')".format(0, countryName, confirmed, suspected, dead, healed, lastUpdateTime)
    cursor.execute(sql)
    db.commit()
sql_total = "insert into worlddata(id,countryname,confirmed,suspected,dead,healed,lastupdateTime) values({},'{}','{}','{}','{}', '{}','{}')".format(0, 0, confirmed_total, suspected_total, dead_total, healed_total, lastUpdateTime)
cursor.execute(sql_total)
db.commit()

數據庫截圖：

 

 

然后是使用Android studio軟件來制作一個APP，設置app界面的代碼如下：

<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:orientation="vertical"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context=".MainActivity">

    <Spinner
        android:id="@+id/condition"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        />
    <EditText
        android:id="@+id/et_content"
        android:layout_width="180dp"
        android:layout_height="40dp"
        android:layout_toRightOf="@+id/condition"
        />
    <Button
        android:id="@+id/bt_send"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="查詢"
        android:layout_toRightOf="@+id/et_content"
        />

    <ListView
        android:id="@+id/lv"
        android:layout_width="match_parent"
        android:layout_height="match_parent"
        android:layout_marginTop="50dp"
        />

</RelativeLayout>

然后根據數據庫中的數據格式建立一個存放全球數據信息的data文件，代碼如下：

 1 package com.example.yiqing;
 2 
 3 public class WorldData {
 4     private int id;
 5     private String countryname;
 6     private String confirmed;
 7     private String suspected;
 8     private String dead;
 9     private String healed;
10     private String lastUpdateTime;
11 
12 
13     public int getId() {
14         return id;
15     }
16 
17     public void setId(int id) {
18         this.id = id;
19     }
20 
21     public String getCountryname() {
22         return countryname;
23     }
24 
25     public void setCountryname(String countryname) {
26         this.countryname = countryname;
27     }
28 
29     public String getConfirmed() {
30         return confirmed;
31     }
32 
33     public void setConfirmed(String confirmed) {
34         this.confirmed = confirmed;
35     }
36 
37     public String getSuspected() {
38         return suspected;
39     }
40 
41     public void setSuspected(String suspected) {
42         this.suspected = suspected;
43     }
44 
45     public String getDead() {
46         return dead;
47     }
48 
49     public void setDead(String dead) {
50         this.dead = dead;
51     }
52 
53     public String getHealed() {
54         return healed;
55     }
56 
57     public void setHealed(String healed) {
58         this.healed = healed;
59     }
60 
61     public String getLastUpdateTime() {
62         return lastUpdateTime;
63     }
64 
65     public void setLastUpdateTime(String lastUpdateTime) {
66         this.lastUpdateTime = lastUpdateTime;
67     }
68 }

然后需要把數據庫中的疫情信息讀取出來，所以要創建一個連接數據庫的Java文件並可以通過IP地址訪問，該文件中還要實現對數據庫里面的數據的調用與查詢，代碼如下：

package com.example.yiqing;


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

public class DBOpenHelper {
    private static String driver = "com.mysql.jdbc.Driver";
    private static String url = "jdbc:mysql://192.168.0.123:3306/yiqing?characterEncoding=utf-8";
    private static String user = "root";//用戶名
    private static String password = "20183602";//密碼

    public static Connection getConn(){
        Connection conn = null;
        try {
            Class.forName(driver);
            conn = (Connection) DriverManager.getConnection(url,user,password);//獲取連接
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    public static List<WorldData>  searchDataByCountry(String condition,String country_name){
        List<WorldData> list = new ArrayList<>();
        Connection connection = getConn();
        String sql = "";
        //System.out.println(condition);
        if(condition.equals("國家")){
            sql = "select * from worlddata where countryname like ?";
        }
        if(condition.equals("時間")){
            sql = "select * from worlddata where lastUpdateTime like ?";
        }
        System.out.println(country_name);
        if(connection !=null){
            try {
                PreparedStatement ps = connection.prepareStatement(sql);
                if(ps!=null){
                    ps.setString(1,"%"+country_name+"%");
                    ResultSet rs = ps.executeQuery();
                    if(rs!=null){
                        while(rs.next()){
                            WorldData worldData = new WorldData();
                            worldData.setId(rs.getInt("id"));
                            worldData.setCountryname(rs.getString("countryname"));
                            worldData.setConfirmed(rs.getString("confirmed"));
                            worldData.setSuspected(rs.getString("suspected"));
                            worldData.setDead(rs.getString("dead"));
                            worldData.setHealed(rs.getString("healed"));
                            worldData.setLastUpdateTime(rs.getString("lastUpdateTime"));
                            list.add(worldData);
                        }
                        connection.close();
                        ps.close();
                        return list;
                    }else{
                        return null;
                    }
                }else{
                    return null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
                return null;
            }
        }else{
            return null;
        }

    }
}

然后就是在MainActivity文件中編寫用到的方法並且調用對數據庫的操作的函數，實現把從數據庫中查詢到的數據顯示出來，代碼如下：

package com.example.yiqing;

import androidx.appcompat.app.AppCompatActivity;

import androidx.appcompat.app.AppCompatActivity;

import android.annotation.SuppressLint;
import android.app.Activity;
import android.icu.lang.UCharacter;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.text.Editable;
import android.text.TextWatcher;
import android.view.View;
import android.widget.AdapterView;
import android.widget.ArrayAdapter;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ListView;
import android.widget.Spinner;
import android.widget.TextView;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class MainActivity extends AppCompatActivity {
    private Button bt_send;
    private EditText et_content;
    private static final int TEST_USER_SELECT = 1;
    private String content;
    private Spinner conditionSpinner;
    private String condition;
    private ListView lv;
    String[] strs = new String[]{};
    @SuppressLint("HandlerLeak")
    private Handler mHandler = new Handler(){
        @Override
        public void handleMessage(Message msg){

            switch(msg.what){
                case TEST_USER_SELECT:
                    String s = (String)msg.obj;
                    //System.out.println("***********");
                    // System.out.println("***********");
                    //System.out.println("data:"+s);
                    strs = s.split("  ");
                    lv.setAdapter(new ArrayAdapter<String>(MainActivity.this,R.layout.support_simple_spinner_dropdown_item,strs));
                    break;
            }
        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        bt_send = findViewById(R.id.bt_send);
        et_content = findViewById(R.id.et_content);
        et_content.addTextChangedListener(new TextWatcher() {
            @Override
            public void beforeTextChanged(CharSequence s, int start, int count, int after) {

            }

            @Override
            public void onTextChanged(CharSequence s, int start, int before, int count) {

            }

            @Override
            public void afterTextChanged(Editable s) {
                content = s.toString();
            }
        });
        conditionSpinner = findViewById(R.id.condition);
        final String [] data = {"國家","時間"};
        ArrayAdapter<String> adapter = new ArrayAdapter<String>(this,R.layout.support_simple_spinner_dropdown_item,data);
        conditionSpinner.setAdapter(adapter);
        conditionSpinner.setOnItemSelectedListener(new Spinner.OnItemSelectedListener(){

            @Override
            public void onItemSelected(AdapterView<?> parent, View view, int position, long id) {
                //取得選中的值
                condition = data[position];
                //設置顯示當前選擇的項
                parent.setVisibility(View.VISIBLE);
            }

            @Override
            public void onNothingSelected(AdapterView<?> parent) {

            }
        });
        System.out.println(condition);
        lv = findViewById(R.id.lv);

    }
    @Override
    protected void onStart(){
        super.onStart();
        bt_send.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                //執行查詢操作
                //連接數據庫進行操作需要在主線程操作
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        //調用數據庫幫助類中的方法取數據
                        List<WorldData> list = DBOpenHelper.searchDataByCountry(condition,content);
                        Message message = mHandler.obtainMessage();
                        String s = "";
                        for(int i=0;i<list.size();i++){
                            s += "時間:"+list.get(i).getLastUpdateTime()+"  ";
                            s += list.get(i).getCountryname()+"確診人數為:  ";
                            s += list.get(i).getConfirmed()+"  ";
                        }
                        message.what = TEST_USER_SELECT;
                        message.obj = s;
                        mHandler.sendMessage(message);
                    }
                }).start();
            }
        });
    }
}

最后通過選擇地點或時間的方式來查詢疫情信息，結果截圖：