审查视图

pkg/infrastructure/service_gateway/allied_creation_basic/module_notice_setting.go 5.9 KB
tangxuhui authored
1 2 3 4
package allied_creation_basic

import (
	"fmt"
yangfu authored
5
	"github.com/linmadan/egglib-go/utils/json"
tangxuhui authored
6 7 8 9 10 11 12 13
	"strconv"

	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/infrastructure/service_gateway"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/log"
)

// NoticeSettingUpdate 更新消息模板
func (gateway HttplibAlliedCreationBasic) NoticeSettingUpdate(param ReqNoticeSettingUpdate) (*DataNoticeSettingUpdate, error) {
tangxuhui authored
14
	url := gateway.baseUrL + "/notice-setting/" + strconv.Itoa(param.NoticeSettingID)
tangxuhui authored
15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75
	method := "PUT"
	req := gateway.CreateRequest(url, method)
	log.Logger.Debug("向基础模块请求数据:更新消息模板。", map[string]interface{}{
		"api":   method + ":" + url,
		"param": param,
	})
	req, err := req.JSONBody(param)
	if err != nil {
		return nil, fmt.Errorf("请求更新消息模板失败:%w", err)
	}

	byteResult, err := req.Bytes()
	if err != nil {
		return nil, fmt.Errorf("获取更新消息模板失败:%w", err)
	}
	log.Logger.Debug("获取基础模块请求数据:更新消息模板。", map[string]interface{}{
		"result": string(byteResult),
	})
	var result service_gateway.GatewayResponse
	err = json.Unmarshal(byteResult, &result)
	if err != nil {
		return nil, fmt.Errorf("解析更新消息模板:%w", err)
	}
	var data DataNoticeSettingUpdate
	err = gateway.GetResponseData(result, &data)
	return &data, err
}

// NoticeSettingAdd 添加化消息模板
func (gateway HttplibAlliedCreationBasic) NoticeSettingAdd(param ReqNoticeSettingAdd) (*DataNoticeSettingAdd, error) {
	url := gateway.baseUrL + "/notice-setting"
	method := "POST"
	req := gateway.CreateRequest(url, method)
	log.Logger.Debug("向基础模块请求数据:添加化消息模板。", map[string]interface{}{
		"api":   method + ":" + url,
		"param": param,
	})
	req, err := req.JSONBody(param)
	if err != nil {
		return nil, fmt.Errorf("请求添加化消息模板失败:%w", err)
	}

	byteResult, err := req.Bytes()
	if err != nil {
		return nil, fmt.Errorf("获取添加化消息模板失败:%w", err)
	}
	log.Logger.Debug("获取基础模块请求数据:添加化消息模板。", map[string]interface{}{
		"result": string(byteResult),
	})
	var result service_gateway.GatewayResponse
	err = json.Unmarshal(byteResult, &result)
	if err != nil {
		return nil, fmt.Errorf("解析添加化消息模板:%w", err)
	}
	var data DataNoticeSettingAdd
	err = gateway.GetResponseData(result, &data)
	return &data, err
}

// NoticeSettingGet 返回编排消息通知内容
func (gateway HttplibAlliedCreationBasic) NoticeSettingGet(param ReqNoticeSettingGet) (*DataNoticeSettingGet, error) {
tangxuhui authored
76
	url := gateway.baseUrL + "/notice-setting/" + strconv.Itoa(param.NoticeSettingID)
tangxuhui authored
77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134
	method := "GET"
	req := gateway.CreateRequest(url, method)
	log.Logger.Debug("向基础模块请求数据:返回编排消息通知内容。", map[string]interface{}{
		"api":   method + ":" + url,
		"param": param,
	})
	req, err := req.JSONBody(param)
	if err != nil {
		return nil, fmt.Errorf("请求返回编排消息通知内容失败:%w", err)
	}

	byteResult, err := req.Bytes()
	if err != nil {
		return nil, fmt.Errorf("获取返回编排消息通知内容失败:%w", err)
	}
	log.Logger.Debug("获取基础模块请求数据:返回编排消息通知内容。", map[string]interface{}{
		"result": string(byteResult),
	})
	var result service_gateway.GatewayResponse
	err = json.Unmarshal(byteResult, &result)
	if err != nil {
		return nil, fmt.Errorf("解析返回编排消息通知内容:%w", err)
	}
	var data DataNoticeSettingGet
	err = gateway.GetResponseData(result, &data)
	return &data, err
}

// NoticeSettingSearch 返回编排消息通知内容列表
func (gateway HttplibAlliedCreationBasic) NoticeSettingSearch(param ReqNoticeSettingSearch) (*DataNoticeSettingSearch, error) {
	url := gateway.baseUrL + "/notice-setting/search"
	method := "POST"
	req := gateway.CreateRequest(url, method)
	log.Logger.Debug("向基础模块请求数据:返回编排消息通知内容列表。", map[string]interface{}{
		"api":   method + ":" + url,
		"param": param,
	})
	req, err := req.JSONBody(param)
	if err != nil {
		return nil, fmt.Errorf("请求返回编排消息通知内容列表失败:%w", err)
	}

	byteResult, err := req.Bytes()
	if err != nil {
		return nil, fmt.Errorf("获取返回编排消息通知内容列表失败:%w", err)
	}
	log.Logger.Debug("获取基础模块请求数据:返回编排消息通知内容列表。", map[string]interface{}{
		"result": string(byteResult),
	})
	var result service_gateway.GatewayResponse
	err = json.Unmarshal(byteResult, &result)
	if err != nil {
		return nil, fmt.Errorf("解析返回编排消息通知内容列表:%w", err)
	}
	var data DataNoticeSettingSearch
	err = gateway.GetResponseData(result, &data)
	return &data, err
}
tangxuhui authored
135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165

// NoticeSettingProfile 编排消息通知可选配置列表
func (gateway HttplibAlliedCreationBasic) NoticeSettingProfile(param ReqNoticeSettingProfile) (*DataNoticeSettingProfile, error) {
	url := gateway.baseUrL + "/notice-setting/profile/get"
	method := "get"
	req := gateway.CreateRequest(url, method)
	log.Logger.Debug("向基础模块请求数据:编排消息通知可选配置列表。", map[string]interface{}{
		"api":   method + ":" + url,
		"param": param,
	})
	req, err := req.JSONBody(param)
	if err != nil {
		return nil, fmt.Errorf("请求返回编排消息通知可选配置列表失败:%w", err)
	}

	byteResult, err := req.Bytes()
	if err != nil {
		return nil, fmt.Errorf("获取返回编排消息通知可选配置列表失败:%w", err)
	}
	log.Logger.Debug("获取基础模块请求数据:返回编排消息通知可选配置列表。", map[string]interface{}{
		"result": string(byteResult),
	})
	var result service_gateway.GatewayResponse
	err = json.Unmarshal(byteResult, &result)
	if err != nil {
		return nil, fmt.Errorf("解析编排消息通知可选配置:%w", err)
	}
	var data DataNoticeSettingProfile
	err = gateway.GetResponseData(result, &data)
	return &data, err
}