go-fly/server.go

package main

import (
	"encoding/json"
	"github.com/taoshihan1991/imaptool/controller"
	"github.com/taoshihan1991/imaptool/tmpl"
	"github.com/taoshihan1991/imaptool/tools"
	"log"
	"net/http"
	"strconv"
	"sync"
)

func main() {
	log.Println("listen on 8080...\r\ngo：http://127.0.0.1:8080")
	//根路径
	http.HandleFunc("/", controller.ActionIndex)
	//邮件夹
	http.HandleFunc("/list", controller.ActionFolder)
	//登陆界面
	http.HandleFunc("/login", controller.ActionLogin)
	//验证接口
	http.HandleFunc("/check", controller.LoginCheck)
	//邮件夹接口
	http.HandleFunc("/folders", controller.FoldersList)
	//新邮件夹接口
	http.HandleFunc("/folder_dirs", controller.FolderDir)
	//邮件接口
	http.HandleFunc("/mail", mail)
	//详情界面
	http.HandleFunc("/view", view)
	//写信界面
	http.HandleFunc("/write", write)
	//框架界面
	http.HandleFunc("/main", controller.ActionMain)
	//设置界面
	http.HandleFunc("/setting", controller.ActionSetting)
	//设置账户接口
	http.HandleFunc("/setting_account", controller.SettingAccount)
	//发送邮件接口
	http.HandleFunc("/send", controller.FolderSend)
	//监听端口
	http.ListenAndServe(":8080", nil)
}

//详情界面
func view(w http.ResponseWriter, r *http.Request) {
	fid:=tools.GetUrlArg(r,"fid")
	id, _ :=strconv.Atoi(tools.GetUrlArg(r,"id"))
	//
	//mailServer:=tools.GetMailServerFromCookie(r)
	//var wg sync.WaitGroup
	var render = new(tmpl.ViewHtml)
	render.Fid = fid
	render.Id = uint32(id)
	//wg.Add(1)
	//go func() {
	//	defer wg.Done()
	//	folders := tools.GetFolders(mailServer.Server, mailServer.Email, mailServer.Password, fid)
	//	render.Folders = folders
	//	render.Fid = fid
	//}()
	//wg.Add(1)
	//go func() {
	//	defer wg.Done()
	//	mail := tools.GetMessage(mailServer.Server, mailServer.Email, mailServer.Password, fid, id)
	//	render.From = mail.From
	//	render.To = mail.To
	//	render.Subject = mail.Subject
	//	render.Date = mail.Date
	//	render.HtmlBody = template.HTML(mail.Body)
	//}()
	//wg.Wait()
	tmpl.RenderView(w, render)
}

//写信界面
func write(w http.ResponseWriter, r *http.Request) {
	render:=new(tmpl.CommonHtml)
	tmpl.RenderWrite(w, render)
}


//邮件接口
func mail(w http.ResponseWriter, r *http.Request) {
	fid:=tools.GetUrlArg(r,"fid")
	id, _ :=strconv.Atoi(tools.GetUrlArg(r,"id"))
	mailServer := tools.GetMailServerFromCookie(r)
	w.Header().Set("content-type", "text/json;charset=utf-8;")

	if mailServer == nil {
		msg, _ := json.Marshal(tools.JsonResult{Code: 400, Msg: "验证失败"})
		w.Write(msg)
		return
	}
	var wg sync.WaitGroup
	result := make(map[string]interface{})
	wg.Add(2)
	go func() {
		defer wg.Done()
		folders := tools.GetFolders(mailServer.Server, mailServer.Email, mailServer.Password, fid)
		result["folders"] = folders
		result["total"] = folders[fid]
	}()
	go func() {
		defer wg.Done()
		mail := tools.GetMessage(mailServer.Server, mailServer.Email, mailServer.Password, fid, uint32(id))
		result["from"] = mail.From
		result["to"] = mail.To
		result["subject"] = mail.Subject
		result["date"] = mail.Date
		result["html"] = mail.Body
	}()
	wg.Wait()
	result["fid"] = fid

	msg, _ := json.Marshal(tools.JsonListResult{
		JsonResult: tools.JsonResult{Code: 200, Msg: "获取成功"},
		Result:     result,
	})
	w.Write(msg)
}