This commit is contained in:
2023-08-17 18:45:08 +08:00
parent 123d4c4b62
commit d611be7d0e
10 changed files with 110 additions and 78 deletions

View File

@@ -330,6 +330,32 @@ func parseRequestUri(httpUri string, mmlMap *dborm.MmlHttpMap, mml *MmlCommand)
return requestURI
}
func DeploymentLicense(mml *MmlCommand, requestURI, token, agent string) {
client := resty.New()
srcLicDep := &struct {
NeType string `json:"ne_type"`
NeID string `json:"ne_id"`
Capability string `json:"capability"`
}{
NeType: fmt.Sprintf("%v", mml.NaMap["srcnetype"]),
NeID: fmt.Sprintf("%v", mml.NaMap["srcneid"]),
Capability: capability - strconv.Atoi(fmt.Sprintf("%v", mml.NaMap["number"])),
}
response, err := client.R().
EnableTrace().
SetHeaders(map[string]string{"accessToken": token}).
SetHeaders(map[string]string{"User-Agent": agent}).
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
SetBody(*body).
Put(requestURI)
if err != nil {
log.Error("Failed to Put:", err)
output = ParseErrorOutput(err)
} else {
output = ParseOutputResponse(omcMmlVar, outputJson, response)
}
}
func TransMml2HttpReq(omcMmlVar *MmlVar, mml *MmlCommand) (*[]byte, error) {
log.Info("TransMml2HttpReq processing ...")
log.Debug("mml: ", mml)
@@ -408,6 +434,15 @@ func TransMml2HttpReq(omcMmlVar *MmlVar, mml *MmlCommand) (*[]byte, error) {
requestURI = parseRequestUri(omcMmlVar.HttpUri, mmlMap, mml)
body := ParseInputBody(inputJson, mml)
log.Debugf("method: Put requestURI: %s", requestURI)
switch inputJson.CallFunc {
case "DeploymentLicense":
DeploymentLicense(inputJson, requestURI, omcMmlVar)
//output = ParseOutputResponse(inputJson, outputJson, response)
return output, nil
default:
}
response, err := client.R().
EnableTrace().
SetHeaders(map[string]string{"accessToken": omcMmlVar.SessionToken}).