opms_backend/opms_parent/app/handler/dingtalk/ding_upload.go

package dingtalk

import (
	"context"
	"fmt"
	"time"

	"dashoo.cn/common_definition/comm_def"
	dingModel "dashoo.cn/micro/app/model/dingtalk"
	"dashoo.cn/opms_libary/plugin/dingtalk"
	"dashoo.cn/opms_libary/plugin/dingtalk/crypto"
	"github.com/gogf/gf/util/gvalid"
)

type DingUploadHandler struct{}

// Swagger:DingUpload 钉钉上传 获取签名
func (h *DingUploadHandler) JsApiSign(ctx context.Context, req *dingModel.JsApiSignReq, resp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}

	nonceStr := crypto.RandomString(10)
	ts := time.Now().Unix()
	accessToken, err := dingtalk.Client.Context.GetAccessToken()
	if err != nil {
		return fmt.Errorf("获取 accessToken 异常 %s", err.Error())
	}
	ticket, err := dingtalk.Client.GetJsapi().GetJsapiTicket(accessToken)
	if err != nil {
		return fmt.Errorf("获取 jsapiTicket 异常 %s", err.Error())
	}

	sign, err := dingtalk.Client.GetJsapi().Sign(ticket, nonceStr, req.Url, ts)
	if err != nil {
		return fmt.Errorf("生成签名异常 %s", err.Error())
	}
	resp.Data = dingModel.JsApiSignResp{
		AgentId:   dingtalk.Client.Context.AgentId,
		CorpId:    dingtalk.Client.Context.CorpId,
		TimeStamp: ts,
		NonceStr:  nonceStr,
		Signature: sign,
	}
	return nil
}