biBackService/timeTask/kbTask.go

package timeTask

import (
	"app.yhyue.com/moapp/jybase/common"
	. "biBackService/config"
	"biBackService/public"
	"fmt"
	"github.com/robfig/cron"
	"log"
	"time"
)

func Task() {
	cr := cron.New()
	cr.AddFunc(SysConfig.TimeTaskCron, kbTaskWechatPrivateMsg)
	cr.Start()
	//select {}
}

func kbTaskWechatPrivateMsg() {
	log.Println("start cron ......")
	//查询已完成工单
	fiveMinutesAgo := time.Now().Local().Add(-5 * time.Minute).Unix()
	data := KbDb.SelectBySql("SELECT t.id,t.title,u.name,u.username,u.email FROM `tasks` t LEFT JOIN users u ON t.creator_id = u.id WHERE date_moved > ? AND date_moved <= NOW() AND t.column_id = ? AND t.project_id = ?", fiveMinutesAgo, SysConfig.Project.FinishColumnId, SysConfig.Project.ProjectId)
	if data != nil && len(*data) > 0 {
		for _, v := range *data {
			log.Println("task id ", v["id"])
			//createUser := common.InterfaceToStr(v["username"])
			title := common.InterfaceToStr(v["title"])
			email := common.InterfaceToStr(v["email"])
			msg := fmt.Sprintf("您反馈的“%s”的问题已解决", title)
			userId := QywxUserIdMap[email]
			//发送企业微信
			if userId == "" {
				log.Println("未找到创建人企业微信userid ", common.InterfaceToStr(v["username"]), email)
				continue
			}
			ok, err := public.SendMsg(userId, msg)
			if !ok && err != nil {
				log.Printf("工单id：%v发送企业微信消息出错：%s", common.IntAll(v["id"]), err)
			}
		}
	}
	log.Println("定时任务完成.....")
}