Keep APP技术研究

DROP TABLE IF EXISTS running_data;

CREATE TABLE IF NOT EXISTS running_data (
  id VARCHAR(100) NULL,
  statsType VARCHAR(100) NULL,
  trainingCourseType VARCHAR(100) NULL,
  subtype VARCHAR(100) NULL,
  statsName VARCHAR(100) NULL,
  doneDate VARCHAR(100) NULL,
  icon VARCHAR(100) NULL,
  statsSchema VARCHAR(100) NULL,
  workoutFinishTimes INT NULL,
  duration INT NULL,
  distance INT NULL,
  steps INT NULL,
  kmDistance DOUBLE NULL,
  calorie INT NULL,
  averagePace DOUBLE NULL,
  averageSpeed DOUBLE NULL,
  exerciseInfo VARCHAR(500) NULL,
  statsStatus INT NULL,
  trackWaterMark VARCHAR(100) NULL,
  workoutId VARCHAR(100) NULL,
  vendorSource VARCHAR(100) NULL,
  vendorManufacturer VARCHAR(100) NULL,
  vendorGenre VARCHAR(100) NULL,
  vendorDeviceModel VARCHAR(100) NULL,
  vendorRecordId VARCHAR(100) NULL,
  heartRates TEXT NULL,
  averageHeartRate DOUBLE NULL,
  maxHeartRate VARCHAR(100) NULL,
  isDoubtful VARCHAR(100) NULL,
  logsType VARCHAR(100) NULL,
  statsDate VARCHAR(100) NULL,
  calorieSum INT NULL,
  durationSum INT NULL
);

const axios = require('axios').default
const mysql = require('mysql');
const connection = mysql.createConnection({
  host     : "localhost",
  user     : "root",
  password : "自己的数据库密码",
  database : "keep_running"
});

connection.connect();

queryAndInsert(connection);


let globalIndex = 1;

function queryAndInsert(connection,lastDate){
  axios.get('https://api.gotokeep.com/pd/v3/stats/detail', {
    params: { dateUnit: 'all',type:'running',lastDate },
    withCredentials: true,
    headers:{
      // TODO:这里是headers的数据，需要使用你自己的 不然查询会失败的
    }
  }).then(res=>{
    let sql =
    `INSERT INTO running_data (
      id, statsType, trainingCourseType, subtype, statsName,
      doneDate, icon, statsSchema, workoutFinishTimes, duration,
      distance, steps, kmDistance, calorie, averagePace,
      averageSpeed, exerciseInfo, statsStatus, trackWaterMark, workoutId,
      vendorSource, vendorManufacturer, vendorGenre, vendorDeviceModel, vendorRecordId,
      heartRates, averageHeartRate, maxHeartRate, isDoubtful, logsType,
      statsDate, calorieSum, durationSum)
      VALUES(?,?,?,?,?, ?,?,?,?,?, ?,?,?,?,?, ?,?,?,?,?, ?,?,?,?,?, ?,?,?,?,?, ?,?,?);`
    let data = res.data.data
    let lastTimestamp = data.lastTimestamp
    if (lastTimestamp === 0 || !data.records || data.records.length === 0) {
      connection.end();
    } else {
      let posts = []
      data.records.forEach(record=>{
        (record.logs||[]).forEach(log=>{
          let stats = log.stats
          if (stats) {
            stats.vendor = stats.vendor || {}
            stats.heartRate = stats.heartRate || {}
            posts.push([
              stats.id, stats.type, stats.trainingCourseType, stats.subtype, stats.name,
              stats.doneDate, stats.icon, stats.schema, stats.workoutFinishTimes, stats.duration,
              stats.distance, stats.steps, stats.kmDistance, stats.calorie, stats.averagePace,
              stats.averageSpeed, stats.exerciseInfo, stats.status, stats.trackWaterMark, stats.workoutId,
              stats.vendor.source, stats.vendor.manufacturer, stats.vendor.genre, stats.vendor.deviceModel, stats.vendor.vendorRecordId,
              stats.heartRate.heartRates, stats.heartRate.averageHeartRate, stats.heartRate.maxHeartRate, stats.isDoubtful, log.type,
              record.date,  record.calorieSum,  record.durationSum
            ])
          }
        })
      })

      posts.forEach(post=>{
        connection.query(sql, post, function (error, results, fields) {
          if (error) throw error;
          console.log('成功插入了一条数据：' + globalIndex);
          globalIndex++;
        });
      })

      queryAndInsert(connection,lastTimestamp)
    }
  })
}

# 全马
SELECT * FROM running_data WHERE distance > 42195 ORDER BY distance DESC;

# 半马
SELECT * FROM running_data WHERE distance >= 21097.5 and  distance < 42195 ORDER BY distance DESC;

# 10公里
SELECT * FROM running_data WHERE distance >= 10000 and  distance < 21097.5 ORDER BY distance DESC;

# 5公里
SELECT * FROM running_data WHERE distance >= 5000 and  distance < 10000 ORDER BY distance DESC;