127 lines
3.7 KiB
Go
127 lines
3.7 KiB
Go
package main
|
||
|
||
import (
|
||
"bytes"
|
||
"encoding/json"
|
||
"fmt"
|
||
"net/http"
|
||
"strings"
|
||
)
|
||
|
||
var CustomerServicePhone = map[string]string{
|
||
"王培伦": "15874035678",
|
||
"王奥": "15650708414",
|
||
"尹晨旭": "13032684686",
|
||
"吴舒汀": "17611213883",
|
||
"崔星林": "17717757039",
|
||
"李斌": "15011332744",
|
||
"王红": "15810025981",
|
||
"王硕": "18511280705",
|
||
"吴彬": "13381040293",
|
||
"杨慧": "15048008804",
|
||
"杨学成": "13760347163",
|
||
"李晓升": "17600642139",
|
||
"孙凯": "13052363610",
|
||
"田羽": "18951841986",
|
||
"王杭渝": "17858226798",
|
||
}
|
||
|
||
var ServicerPhone string //定义一个工单处理人对应的手机号，用于企业微信机器人@使用
|
||
|
||
type WorkOrder struct {
|
||
OrderID string `json:"工单id"`
|
||
Customer string `json:"客户"`
|
||
CustomerService string `json:"受理客服"`
|
||
Subject string `json:"主题"`
|
||
Priority string `json:"优先级"`
|
||
WorkUrl string `json:"工单链接"`
|
||
CellPhone string `json:"客户手机号"`
|
||
CreateTime string `json:"创建时间"`
|
||
}
|
||
|
||
// 企业微信机器人消息格式
|
||
type WXWorkMsg struct {
|
||
MsgType string `json:"msgtype"`
|
||
Text *WXText `json:"text"`
|
||
}
|
||
|
||
// 企业微信发送消息格式
|
||
type WXText struct {
|
||
Content string `json:"content"`
|
||
MentionedList []string `json:"mentioned_mobile_list"`
|
||
}
|
||
|
||
func ReConstructPost(w http.ResponseWriter, r *http.Request) {
|
||
var order WorkOrder
|
||
var builder strings.Builder //定义的企业微信机器人发送的字符串
|
||
|
||
if r.Method != "POST" {
|
||
fmt.Fprintf(w, "Invalid Method!")
|
||
return
|
||
}
|
||
err := json.NewDecoder(r.Body).Decode(&order)
|
||
if err != nil {
|
||
http.Error(w, "could not decode body", http.StatusBadRequest)
|
||
return
|
||
}
|
||
builder.WriteString("工单已分配，请注意及时查看!")
|
||
builder.WriteString("\n")
|
||
builder.WriteString("工单id: ")
|
||
builder.WriteString(order.OrderID)
|
||
builder.WriteString("\n")
|
||
builder.WriteString("客户: ")
|
||
builder.WriteString(order.Customer)
|
||
builder.WriteString("\n")
|
||
builder.WriteString("受理客服: ")
|
||
builder.WriteString(order.CustomerService)
|
||
builder.WriteString("\n")
|
||
builder.WriteString("工单链接: ")
|
||
builder.WriteString(order.WorkUrl)
|
||
builder.WriteString("\n")
|
||
builder.WriteString("工单主题: ")
|
||
builder.WriteString(order.Subject)
|
||
builder.WriteString("\n")
|
||
builder.WriteString("客户手机号: ")
|
||
builder.WriteString(order.CellPhone)
|
||
// msg := "工单已分配,请注意及时查看!" + "工单id: " + order.OrderID + ", 客户: " + order.Customer + ", 受理客服: @" + order.CustomerService
|
||
msg := builder.String()
|
||
|
||
ServicerPhone = "0"
|
||
for i, v := range CustomerServicePhone {
|
||
if order.CustomerService == i {
|
||
ServicerPhone = v
|
||
break
|
||
}
|
||
}
|
||
sendMsgToWxWorkRobot(msg)
|
||
}
|
||
func sendMsgToWxWorkRobot(msg string) {
|
||
wxWorkRobotURL := "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=5f4a82bf-ad78-4110-9b05-2bf9623690aa"
|
||
|
||
// 创建企业微信机器人的消息
|
||
wxMsg := &WXWorkMsg{
|
||
MsgType: "text",
|
||
Text: &WXText{
|
||
Content: msg,
|
||
MentionedList: []string{ServicerPhone}, // 这里填入需要@的人的手机号
|
||
},
|
||
}
|
||
|
||
jsonValue, _ := json.Marshal(wxMsg)
|
||
|
||
fmt.Println(string(jsonValue))
|
||
|
||
resp, err := http.Post(wxWorkRobotURL, "application/json", bytes.NewReader(jsonValue))
|
||
if err != nil {
|
||
fmt.Printf("Post data to WeChat Work robot failed: %v\n", err)
|
||
}
|
||
defer resp.Body.Close()
|
||
}
|
||
func main() {
|
||
http.HandleFunc("/autoRemind", ReConstructPost) // 当有POST请求到达/autoRemind时，调用ReConstructPost函数处理请求体以及发送请求到企业微信机器人进行通知工单处理人
|
||
err := http.ListenAndServe(":8082", nil) // 在8082端口启动http服务器
|
||
if err != nil {
|
||
fmt.Println("Failed to start server", err)
|
||
}
|
||
}
|