You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
go-fly/server.go

96 lines
2.5 KiB

4 years ago
package main
import (
"encoding/json"
"github.com/taoshihan1991/imaptool/controller"
"github.com/taoshihan1991/imaptool/tools"
4 years ago
"log"
"net/http"
"strconv"
"sync"
4 years ago
"time"
4 years ago
)
func main() {
log.Println("listen on 8080...\r\ngohttp://127.0.0.1:8080")
4 years ago
mux:=&http.ServeMux{}
//根路径
4 years ago
mux.HandleFunc("/", controller.ActionIndex)
//邮件夹
4 years ago
mux.HandleFunc("/list", controller.ActionFolder)
//登陆界面
4 years ago
mux.HandleFunc("/login", controller.ActionLogin)
//验证接口
4 years ago
mux.HandleFunc("/check", controller.LoginCheck)
//邮件夹接口
4 years ago
mux.HandleFunc("/folders", controller.FoldersList)
//新邮件夹接口
4 years ago
mux.HandleFunc("/folder_dirs", controller.FolderDir)
//邮件接口
4 years ago
mux.HandleFunc("/mail", mail)
//详情界面
4 years ago
mux.HandleFunc("/view", controller.ActionDetail)
//写信界面
4 years ago
mux.HandleFunc("/write", controller.ActionWrite)
//框架界面
4 years ago
mux.HandleFunc("/main", controller.ActionMain)
//设置界面
4 years ago
mux.HandleFunc("/setting", controller.ActionSetting)
//设置账户接口
4 years ago
mux.HandleFunc("/setting_account", controller.SettingAccount)
//发送邮件接口
4 years ago
mux.HandleFunc("/send", controller.FolderSend)
4 years ago
//聊天界面
mux.HandleFunc("/chat_main", controller.ActionMain)
4 years ago
//监听端口
4 years ago
//http.ListenAndServe(":8080", nil)
//var myHandler http.Handler
s := &http.Server{
Addr: ":8080",
Handler: mux,
ReadTimeout: 30 * time.Second,
WriteTimeout: 30 * time.Second,
MaxHeaderBytes: 1 << 20,
}
s.ListenAndServe()
4 years ago
}
//邮件接口
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)
}