message-server/external/request.go

package external

import (
	"context"
	"os"
)


type UnreadMessageRequest struct {
    Type string `json:"type"`
    Id int32 `json:"id"`
    MsgCount int `json:"msgCount"`
}

// 请求函数 -- 根据请求项目选择请求方式
func RequestToPHP(receiverType string, receiverID int32, count int) error {
	var project string
	if receiverType == "shop" {
		project = "huaZhangGui"
	} else if receiverType == "customer" {
		project = "huaHuiBao"
	}

	ctx := context.Background()
	switch project {
	case "huaZhangGui":
		url := os.Getenv("HUA_ZHANG_GUI_URL")
		reqData := UnreadMessageRequest{
			Type: "shop",
			Id: receiverID,
			MsgCount: count,
		}
		huaZhangGuiClient := NewHuaZhangGuiClient(url)
		_, err := huaZhangGuiClient.PostUnReadMessage(ctx, reqData)
		if err != nil {
			return err
		}
		
	case "huaHuiBao":
		url := os.Getenv("HUA_HUI_BAO_URL")
		reqData := UnreadMessageRequest{
			Type: "customer",
			Id: receiverID,
			MsgCount: count,
		}
		huaHuiBaoClient := NewHuaHuiBaoClient(url)
		_, err := huaHuiBaoClient.PostUnReadMessage(ctx, reqData)
		if err != nil {
			return err
		}
	}

	return nil
}