dingding.go

package service

import (
	"crm-server/configs"
	"crm-server/internal/common"
	"crm-server/internal/dao"
	"encoding/json"
	"fmt"
	"github.com/ichunt2019/logger"
	"io/ioutil"
	"net/http"
	"net/url"
	"strconv"
	"time"
)

const APIMD5STR string = "fh6y5t4rr351d2c3bryi"
const APIDOMAIN string = configs.Api_url+"/msg/sendMessageByAuto"
const ADMINTEL  int64 = 17600091664
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:"开发板方案", 10:"跟进用户"}

func AdminErr(err error)  {
	if err != nil {
		fmt.Println(err)
		SendMessage(ADMINTEL,err.Error())
	}
}


func SendMessage(mobile int64 , content string){

	if mobile != 0 {
		timeNow := time.Now().Unix()
		requestContent,_ := json.Marshal(map[string]string{"content":content})
		requestTel,_ := json.Marshal([]int64{mobile})

		resp,err := http.PostForm(APIDOMAIN,url.Values{
			"data" : {string(requestContent)},
			"touser" : {string(requestTel)},
			"keyword" : {"register_nopay_notify"},
			"k1" : {strconv.FormatInt(int64(timeNow),10)},
			"k2" : {common.Md5(common.Md5(strconv.FormatInt(int64(timeNow),10))+APIMD5STR)},
			"is_ignore" : {},
		})

		if err != nil {
			fmt.Print(err)
		}
		defer resp.Body.Close()
	}
}

/**
	bom询价无结果 钉钉推送
	user_id 内部用户ID
	client_account 客户账号
 */
func SendBomMsg(user_id int64 , client_account string){
	if user_id != 0 {
		timeNow := time.Now().Unix()
		requestContent,_ := json.Marshal(map[string]string{"account":client_account})
		requestTel,_ := json.Marshal([]int64{user_id})

		resp,err := http.PostForm(APIDOMAIN,url.Values{
			"data" : {string(requestContent)},
			"touser" : {string(requestTel)},
			"keyword" : {"bom_no_result"},
			"k1" : {strconv.FormatInt(int64(timeNow),10)},
			"k2" : {common.Md5(common.Md5(strconv.FormatInt(int64(timeNow),10))+APIMD5STR)},
			"is_ignore" : {},
		})

		if err != nil {
			fmt.Print(err)
		}
		defer resp.Body.Close()
	}
}

func DingAlert(token string, text string, at string) []byte {
	curr_time := time.Now().Unix()

	resp, err := http.PostForm(DINGALERTURL, url.Values{
		"token": {token},
		"text": {text},
		"at": {at},
		"k1": {strconv.FormatInt(int64(curr_time), 10)},
		"k2": {common.Md5(common.Md5(strconv.FormatInt(int64(curr_time), 10)) + APIMD5STR)},
	})
	defer resp.Body.Close()

	if err != nil {
		logger.Info(err.Error())
	}

	body, _ := ioutil.ReadAll(resp.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()
}

// CRM任务推送邮件
func SendMail(crm_user_id int, sale_id int, task_type int, contents string) bool {
	if sale_id == 0 {
		return false
	}

	var email string // 客服邮箱
	dao.GetCmsDb().Get(&email, "select email from user_info where userId = ?", sale_id)

	timeNow := time.Now().Unix()
	requestContent,_ := json.Marshal(map[string]string{"contents": contents})
	requestTel,_ := json.Marshal([]string{email})

	resp,err := http.PostForm(APIDOMAIN,url.Values{
		"data" : {string(requestContent)},
		"touser" : {string(requestTel)},
		"keyword" : {"crm-task-send-mail"},
		"k1" : {strconv.FormatInt(int64(timeNow),10)},
		"k2" : {common.Md5(common.Md5(strconv.FormatInt(int64(timeNow),10))+APIMD5STR)},
		"is_ignore" : {"1"},
	})
	defer resp.Body.Close()

	if err != nil {
		DingAlert(configs.Ding_crm_task_token, "任务告警："+TASK_TYPE_VAL[task_type]+"任务记录邮件推送失败，CRM用户ID："+strconv.Itoa(crm_user_id), "")
		return false
	}

	return true
}