newRobotProcess/handler/metric_process.go

package handler

import (
	"net/http"

	"newaterobot-process/entity"

	"github.com/gin-gonic/gin"

	"newaterobot-process/service"
)

var metricProcessConfigService = service.NewMetricProcessConfigService()

// MetricProcess 指标处理处理器
func MetricProcess(c *gin.Context) {
	req := entity.MetricProcessRequest{}
	// 绑定参数
	if err := c.ShouldBindJSON(&req); err != nil {
		c.JSON(http.StatusOK, gin.H{
			"code":    400,
			"message": "请求参数错误: " + err.Error(),
		})
		return
	}

	// 调用服务处理指标
	result, err := metricProcessConfigService.ProcessMetric(req)
	if err != nil {
		c.JSON(http.StatusOK, gin.H{
			"code":    500,
			"message": "处理指标失败: " + err.Error(),
		})
		return
	}

	// 返回成功响应
	c.JSON(http.StatusOK, gin.H{
		"code":    200,
		"message": "处理成功",
		"data":    result,
	})
}

func GetMete(c *gin.Context) {
	cId := c.Query("conversation_id")
	mId := c.Query("message_id")
	// 调用服务处理指标
	result, err := metricProcessConfigService.ProcessMate(cId, mId)
	if err != nil {
		c.JSON(http.StatusOK, gin.H{
			"code":    500,
			"message": "处理指标失败: " + err.Error(),
		})
		return
	}

	// 返回成功响应
	c.JSON(http.StatusOK, gin.H{
		"code":    200,
		"message": "处理成功",
		"data":    result,
	})
}