aiweek-reconstruction/udesk/filter/function.go

package filter

import (
	"aiweek/tools"
	"aiweek/udesk/auth"
	"fmt"
	"github.com/tidwall/gjson"
	"io"
	"log"
	"net/http"
	"strconv"
	"strings"
)

//* 获取工单过滤器下的符合条件的工单id *

// 获取工单总共的页数

func GetUdeskTicketId(filterId string) (*int64, error) {
	filterUrl := fmt.Sprintf("https://servicecenter-alauda.udesk.cn/open_api_v1/tickets/tickets_in_filter?filter_id=%v&", filterId)
	filterUrl = auth.Geturlstring(filterUrl)
	resp, err := http.Get(filterUrl)
	if err != nil {
		// 处理错误
		log.Printf("获取工单过滤器下的工单信息失败，发送请求过程，错误是：%v", err)
		return nil, err
	}
	defer resp.Body.Close()
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		// 处理错误
		log.Printf("获取工单过滤器下的工单信息失败，读取返回体过程，错误是：%v", err)
		return nil, err
	}
	jsonData := string(body)
	totalPages := gjson.Get(jsonData, "meta.total_pages").Int()
	return &totalPages, nil

}

// 根据上面获取的页数,分别请求接口，取到工单id切片

func LoopGetTicketId(totalPages *int64, filterId string) ([]string, error) {
	var idSlice = make([]string, 0)
	for i := int64(1); i <= *totalPages; i++ {
		filterUrl := fmt.Sprintf("https://servicecenter-alauda.udesk.cn/open_api_v1/tickets/tickets_in_filter?filter_id=%v", filterId)
		getIdUrl := auth.Geturlstring(filterUrl+"&") + "&page=" + strconv.FormatInt(i, 10)
		resp, err := http.Get(getIdUrl)
		if err != nil {
			// 处理错误
			log.Printf("获取工单过滤器下的工单id失败，发送请求过程，错误是：%v", err)
			return nil, err
		}
		defer func(Body io.ReadCloser) {
			err := Body.Close()
			if err != nil {
				log.Printf("获取工单过滤器下的工单id失败，关闭返回体，错误是：%v", err)
			}
		}(resp.Body)
		body, err := io.ReadAll(resp.Body)
		if err != nil {
			// 处理错误
			log.Printf("获取工单过滤器下的工单id失败，读取返回体过程，错误是：%v", err)
			return nil, err
		}
		jsonData := string(body)
		ticketIdstr := gjson.Get(jsonData, "contents.#.ticket.id").String()
		sliceStr := strings.Trim(ticketIdstr, "[]")
		numbers := strings.Split(sliceStr, ",")
		log.Printf("处理id切片中...第%v次处理...\n", i)
		idSlice = append(idSlice, numbers...)
		log.Printf("%T,%v", idSlice, idSlice)

	}
	log.Println("处理完成~owo~")
	return idSlice, nil
}

//把udeskid转换为cloudid

func Id2CloudId(id string) string {
	detailUrl := auth.Geturlstring("https://servicecenter-alauda.udesk.cn/open_api_v1/tickets/detail?") + "&id=" + id
	resp, err := http.Get(detailUrl)
	if err != nil {
		// 处理错误
		log.Printf("获取工单过滤器下的cloudid失败，发送请求过程，错误是：%v", err)

	}
	defer resp.Body.Close()
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		// 处理错误
		log.Printf("获取工单过滤器下的cloudid失败，读取返回体过程，错误是：%v", err)

	}
	jsonData := string(body)
	cloudId := gjson.Get(jsonData, "ticket.custom_fields.TextField_219254").String()
	return cloudId
}

//获取上周到上上周的工单

func GetWeeklyTicket() []string {
	optionobj := tools.NewOptionObj()
	Opt := optionobj.ReadYaml("/conf/udesk.yaml").Filters
	sevenDayPages, err := GetUdeskTicketId(Opt[0].Filter7D)
	if err != nil {
		log.Printf("获取7天的工单过滤器中的page信息失败！错误是%v", err)
	}
	fourteenDayPages, err := GetUdeskTicketId(Opt[1].Filter14D)
	if err != nil {
		log.Printf("获取14天的工单过滤器中的page信息失败！错误是%v", err)
	}
	sevenDaytTickets, err := LoopGetTicketId(sevenDayPages, Opt[0].Filter7D)
	if err != nil {
		log.Printf("获取7天的工单过滤器中的ticket信息失败！错误是%v", err)
	}
	fourteenDaytickets, err := LoopGetTicketId(fourteenDayPages, Opt[1].Filter14D)

	if err != nil {
		log.Printf("获取14天的工单过滤器中的ticket信息失败！错误是%v", err)
	}
	fmt.Println("7天", sevenDaytTickets)
	fmt.Println("14天", fourteenDaytickets)

	weeklyTicket := tools.ExcludeSlice(sevenDaytTickets, fourteenDaytickets)
	fmt.Println("上周到上上周的工单：", weeklyTicket)
	return weeklyTicket

}