新任务记录钉钉推送

cmd/task/dev_plan/main.go

@@ -84,6 +84,10 @@ func setTaskInfo(status, task_id, task_type, task_display_degree int) {
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：开发板方案任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：开发板方案任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(feedback.Outter_Uid, salesman.Sale_Id, task_type, "")
+
 	}
 	}
 
 
 
 

cmd/task/find_goods/main.go

@@ -138,6 +138,9 @@ func setFindGoods(status, task_id, task_type, task_display_degree int) {
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：快速找料任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：快速找料任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(feedback.Outter_Uid, salesman.Sale_Id, task_type, "")
 	}
 	}
 
 
 
 

cmd/task/h5_notes/main.go

@@ -85,6 +85,10 @@ func setTaskInfo(status, task_id, task_type, task_display_degree int) {
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：H5留言任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：H5留言任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(feedback.Outter_Uid, salesman.Sale_Id, task_type, "")
+
 	}
 	}
 
 
 
 

cmd/task/have_order/main.go

@@ -107,6 +107,10 @@ func setHaveOrderTask(status, task_id, task_type, task_display_degree int, task_
 		db.Exec("update lie_user set is_add_task = ? where user_id = ?", 1, user.User_id)
 		db.Exec("update lie_user set is_add_task = ? where user_id = ?", 1, user.User_id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：已成交任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(int(user.User_id)), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：已成交任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(int(user.User_id)), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(int(user.User_id), salesman.Sale_Id, task_type, time.Unix(end_time, 0).Format("2006-01-02 15:04:05"))
+
 	}
 	}
 
 
 
 

cmd/task/invoice_remind/main.go

@@ -85,6 +85,10 @@ func setTaskInfo(status, task_id, task_type, task_display_degree int) {
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：发票提醒任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：发票提醒任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(feedback.Outter_Uid, salesman.Sale_Id, task_type, "")
+
 	}
 	}
 
 
 
 

cmd/task/multi_search/main.go

@@ -103,6 +103,10 @@ func setMultiSearch(status, task_id, task_type, task_display_degree int) {
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 		db.Exec("update lie_feedback set is_add_task = ? where id = ?", 1, feedback.Id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：多次搜索任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：多次搜索任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(feedback.Outter_Uid), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(feedback.Outter_Uid, salesman.Sale_Id, task_type, "")
+
 	}
 	}
 
 
 
 

cmd/task/no_order/main.go

@@ -112,6 +112,9 @@ func setNoOrderTask(status, task_id, task_type, task_display_degree int, task_en
 		db.Exec("update lie_user set is_add_task = ? where user_id = ?", 1, user.User_id)
 		db.Exec("update lie_user set is_add_task = ? where user_id = ?", 1, user.User_id)
 
 
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：未成交任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(int(user.User_id)), "")
 		service.DingAlert(configs.Ding_crm_task_token, "任务告警：未成交任务脚本添加任务记录成功，CRM用户ID："+strconv.Itoa(int(user.User_id)), "")
+
+		// 推送钉钉消息给客服
+		service.SendNewTaskMsg(int(user.User_id), salesman.Sale_Id, task_type, time.Unix(end_time, 0).Format("2006-01-02 15:04:05"))
 	}
 	}
 
 
 
 

internal/service/dingding.go

@@ -3,6 +3,7 @@ package service
 import (
 import (
 	"crm-server/configs"
 	"crm-server/configs"
 	"crm-server/internal/common"
 	"crm-server/internal/common"
+	"crm-server/internal/dao"
 	"encoding/json"
 	"encoding/json"
 	"fmt"
 	"fmt"
 	"github.com/ichunt2019/logger"
 	"github.com/ichunt2019/logger"
@@ -17,7 +18,7 @@ const APIMD5STR string = "fh6y5t4rr351d2c3bryi"
 const APIDOMAIN string = configs.Api_url+"/msg/sendMessageByAuto"
 const APIDOMAIN string = configs.Api_url+"/msg/sendMessageByAuto"
 const ADMINTEL  int64 = 17600091664
 const ADMINTEL  int64 = 17600091664
 const DINGALERTURL string = configs.Api_url+"/msg/dingalert"
 const DINGALERTURL string = configs.Api_url+"/msg/dingalert"
-
+var TASK_TYPE_VAL = map[int]string{1:"领取分配", 2:"未成交释放(30)", 3:"已成交释放(180)", 4:"快速找料", 5:"老客户活跃", 6:"BOM找料", 7:"H5留言", 8:"发票提醒", 9:"开发板方案"}
 
 
 func AdminErr(err error)  {
 func AdminErr(err error)  {
 	if err != nil {
 	if err != nil {
@@ -97,3 +98,47 @@ func DingAlert(token string, text string, at string) []byte {
 	return body
 	return body
 }
 }
 
 
+/**
+新任务记录钉钉推送
+crm_user_id CRM用户ID
+sale_id 客服ID
+task_type 1-领取分配, 2-未成交释放(30), 3-已成交释放(180), 4-快速找料, 5-老客户活跃, 6-BOM找料, 7-H5留言，8-发票提醒，9-开发板方案
+limit_time 截止时间
+*/
+func SendNewTaskMsg(crm_user_id int, sale_id int , task_type int, limit_time string){
+	if sale_id == 0 {
+		return
+	}
+
+	if TASK_TYPE_VAL[task_type] == "" {
+		return
+	}
+
+	var user_id int64 // 客服前台ID
+	dao.GetCmsDb().Get(&user_id, "select user_id from lie_intracode where admin_id = ?", sale_id)
+
+	if user_id == 0 {
+		DingAlert(configs.Ding_crm_task_token, "任务告警：新增"+TASK_TYPE_VAL[task_type]+"任务记录钉钉推送失败，内部用户ID（"+strconv.Itoa(sale_id)+"）未绑定前台账号，CRM用户ID："+strconv.Itoa(crm_user_id), "")
+		return
+	}
+
+	timeNow := time.Now().Unix()
+	requestContent,_ := json.Marshal(map[string]string{"type": TASK_TYPE_VAL[task_type], "limit_time": limit_time})
+	requestTel,_ := json.Marshal([]int64{user_id})
+
+	resp,err := http.PostForm(APIDOMAIN,url.Values{
+		"data" : {string(requestContent)},
+		"touser" : {string(requestTel)},
+		"keyword" : {"new-task-notify"},
+		"k1" : {strconv.FormatInt(int64(timeNow),10)},
+		"k2" : {common.Md5(common.Md5(strconv.FormatInt(int64(timeNow),10))+APIMD5STR)},
+		"is_ignore" : {},
+	})
+
+	if err != nil {
+		DingAlert(configs.Ding_crm_task_token, "任务告警：新增"+TASK_TYPE_VAL[task_type]+"任务记录钉钉推送失败，CRM用户ID："+strconv.Itoa(crm_user_id), "")
+	}
+	defer resp.Body.Close()
+}
+
+