举例讲解Python的Tornado框架实现数据可视化的教程

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import os.path

import tornado.auth
import tornado.escape
import tornado.httpserver
import tornado.ioloop
import tornado.options
import tornado.web
from tornado.options import define, options

import pymongo
import time
import datetime
import xlrd

define("port", default=8007, help="run on the given port", type=int)

class Application(tornado.web.Application):
  def __init__(self):
    handlers = [
      (r"/", MainHandler),
      (r"/read", ReadHandler),
      (r"/day", DayHandler),
    ]
    settings = dict(
      template_path=os.path.join(os.path.dirname(__file__), "templates"),
      static_path=os.path.join(os.path.dirname(__file__), "static"),
      debug=True,
      )
    conn = pymongo.Connection("localhost", 27017)
    self.db = conn["kaoqin"]
    tornado.web.Application.__init__(self, handlers, **settings)


class MainHandler(tornado.web.RequestHandler):
  def get(self):
    pass

class ReadHandler(tornado.web.RequestHandler):
  def get(self):
    #获取collection
    coll_record = self.application.db.record
    coll_user = self.application.db.user
    #读取excel表格
    table = xlrd.open_workbook(‘/Users/ant/Webdev/python/excel/data.xls‘)
    #读取打卡记录sheet
    sheet=table.sheet_by_index(2)
    #读取打卡月份范围
    row3 = sheet.row_values(2)
    m1 = int(row3[2][5:7])
    m2 = int(row3[2][18:20])
    #设置当前年份
    y = int(row3[2][0:4])
    #设置当前月份为第一个月份
    m = m1
    #读取打卡日期范围
    row4 = sheet.row_values(3)
    #初始化上一天
    lastday = row4[0]
    #遍历第四行中的日期
    for d in row4:
      #如果日期小于上一个日期
      #说明月份增大，则修改当前月份为第二个月份
      if d < lastday:
        m = m2
        #如果当前两个月份分别为12月和1月
        #说明跨年了，所以年份 +1
        if m1 == 12 and m2 == 1:
          y = y + 1
      #用n计数，范围为 3 到（总行数/2+1）
      #（总行数/2+1）- 3 = 总用户数
      #即遍历所有用户
      for n in range(3, sheet.nrows/2+1):
        #取该用户的第一行，即用户信息行
        row_1 = sheet.row_values(n*2-2)
        #获取用户id
        u_id = row_1[2]
        #获取用户姓名
        u_name = row_1[10]
        #获取用户部门
        u_dept = row_1[20]
        #查询该用户
        user = coll_user.find_one({"id":u_id})
        #如果数据库中不存在该用户则创建新用户
        if not user:
          user = dict()
          user[‘id‘] = u_id
          user[‘name‘] = u_name
          user[‘dept‘] = u_dept
          coll_user.insert(user)
        #取该用户的第二行，即考勤记录行
        row_2 = sheet.row_values(n*2-1)
        #获取改当前日期的下标
        idx = row4.index(d)
        #获取当前用户当前日期的考勤记录
        check_data = row_2[idx]
        #初始化空考勤记录列表
        check = list()
        #5个字符一组，遍历考勤记录并存入考勤记录列表
        for i in range(0,len(check_data)/5):
          check.append(check_data[i*5:i*5+5])
        #查询当前用户当天记录
        record = coll_record.find_one({"y":y, "m":m, "d":d, "id":user[‘id‘]})
        #如果记录存在则更新记录
        if record:
          for item in check:
            #将新的考勤记录添加进之前的记录
            if item not in record[‘check‘]:
              record[‘check‘].append(item)
              coll_record.save(record)
        #如果记录不存在则插入新纪录
        else:
          record = {"y":y, "m":m, "d":d, "id":user[‘id‘], "check":check}
          coll_record.insert(record)

class DayHandler(tornado.web.RequestHandler):
  def get(self):
    #获取年月日参数
    y = self.get_argument("y",None)
    m = self.get_argument("m",None)
    d = self.get_argument("d",None)
    #判断参数是否设置齐全
    if y and m and d:
      #将参数转换为整型数，方便使用
      y = int(y)
      m = int(m)
      d = int(d)
      #获取当天所有记录
      coll_record = self.application.db.record
      record = coll_record.find({"y":y, "m":m, "d":d})
      #获取当天为星期几
      weekday = datetime.datetime(y,m,d).strftime("%w")
      #获取当天值班表
      coll_duty = self.application.db.duty
      duty = coll_duty.find_one({"id":int(weekday)})
      #初始化空目标记录（当天值班人员记录）
      target = list()
      #遍历当天所有记录
      for item in record:
        #当该记录的用户当天有值班任务时，计算并存入target数组
        if int(item[‘id‘]) in duty[‘list‘]:
          #通过用户id获取该用户值班起止时间
          start = duty[item[‘id‘]][0]
          end = duty[item[‘id‘]][1]
          #计算值班时长/秒
          date1 = datetime.datetime(y,m,d,int(start[:2]),int(start[-2:]))
          date2 = datetime.datetime(y,m,d,int(end[:2]),int(end[-2:]))
          item[‘length‘] = (date2 - date1).seconds
          #初始化实际值班百分比
          item[‘per‘] = 0
          #初始化上下班打卡时间
          item[‘start‘] = 0
          item[‘end‘] = 0
          #遍历该用户打卡记录
          for t in item[‘check‘]:
            #当比值班时间来得早
            if t < start:
              #计算时间差
              date1 = datetime.datetime(y,m,d,int(start[:2]),int(start[-2:]))
              date2 = datetime.datetime(y,m,d,int(t[:2]),int(t[-2:]))
              dif = (date1 - date2).seconds
              #当打卡时间在值班时间前半小时内
              if dif <= 1800:
                #上班打卡成功
                item[‘start‘] = start
            elif t < end:
              #如果还没上班打卡
              if not item[‘start‘]:
                #则记录当前时间为上班打卡时间
                item[‘start‘] = t
              else:
                #否则记录当前时间为下班打卡时间
                item[‘end‘] = t
            else:
              #如果已经上班打卡
              if item[‘start‘]:
                #计算时间差
                date1 = datetime.datetime(y,m,d,int(end[:2]),int(end[-2:]))
                date2 = datetime.datetime(y,m,d,int(t[:2]),int(t[-2:]))
                dif = (date1 - date2).seconds
                #当打卡时间在值班时间后半小时内
                if dif <= 1800:
                  #下班打卡成功
                  item[‘end‘] = end
          #当上班下班均打卡
          if item[‘start‘] and item[‘end‘]:
            #计算实际值班时长
            date1 = datetime.datetime(y,m,d,int(item[‘start‘][:2]),int(item[‘start‘][-2:]))
            date2 = datetime.datetime(y,m,d,int(item[‘end‘][:2]),int(item[‘end‘][-2:]))
            dif = (date2 - date1).seconds
            #计算（实际值班时长/值班时长）百分比
            item[‘per‘] = int(dif/float(item[‘length‘]) * 100)
          else:
            #未正常上下班则视为未值班
            item[‘start‘] = 0
            item[‘end‘] = 0
          #将记录添加到target数组中
          target.append(item)
      #输出数据
      self.render("index.html",
        target = target
        )


def main():
  tornado.options.parse_command_line()
  http_server = tornado.httpserver.HTTPServer(Application())
  http_server.listen(options.port)
  tornado.ioloop.IOLoop.instance().start()


if __name__ == "__main__":
  main()

  index.html

{
{% for item in target %}
  {
   ‘id‘:{{ item[‘id‘] }},
   ‘start‘:{{ item[‘start‘] }},
   ‘end‘:{{ item[‘end‘] }},
   ‘length‘:{{ item[‘length‘] }}, 
   ‘per‘:{{ item[‘per‘] }}
   }
{% end %}
}