From d9a43a3c4760cdc682807bc01c8da6add4b7334d Mon Sep 17 00:00:00 2001
From: Leufolium <Caeruscaemon@outlook.com>
Date: Thu, 28 Dec 2023 18:37:39 +0800
Subject: [PATCH] by Robin at 20231228; fix

---
 api/consts/consts.go             |  6 ++++--
 app/mix/controller/config_op.go  | 11 +++++++++++
 app/mix/controller/init.go       |  8 ++++++++
 app/mix/service/configservice.go | 23 +++++++++++++++++++++++
 4 files changed, 46 insertions(+), 2 deletions(-)

diff --git a/api/consts/consts.go b/api/consts/consts.go
index 28c9fceb..7e5ad92f 100644
--- a/api/consts/consts.go
+++ b/api/consts/consts.go
@@ -31,6 +31,8 @@ const (
 	TagNumKey                   = "tag_num"
 	PlatformNumKey              = "platform_num"
 	SupportWxIdNumKey           = "support_wx_id_num"
+	ImageIdForUploadFail        = "image_id_for_upload_fail"
+	VideoIdForUploadFail        = "video_id_for_upload_fail"
 )
 
 // del_flag
@@ -58,9 +60,9 @@ const (
 	RedisStreamerPrefix = "streamer:" //streamer服务前缀
 )
 
-//const PackageRootPath = "/Users/PC/Desktop/wishpal-ironfan"
+const PackageRootPath = "C:/Users/PC/Desktop/wishpal_ironfan_service/service"
 
-const PackageRootPath = "/app/wishpal-ironfan"
+//const PackageRootPath = "/app/wishpal-ironfan"
 
 const MainConfigPath = PackageRootPath + "/etc/mix/mix-test.yaml"
 
diff --git a/app/mix/controller/config_op.go b/app/mix/controller/config_op.go
index 79702988..212caf2d 100644
--- a/app/mix/controller/config_op.go
+++ b/app/mix/controller/config_op.go
@@ -59,3 +59,14 @@ func OpIsThereANewVersionAvailable(ctx *gin.Context) {
 
 	ReplyOk(ctx, data)
 }
+
+func OpGetUploadMediaFailConfigList(ctx *gin.Context) {
+	config, ec := service.DefaultConfigService.OpGetUploadMediaFailConfigList(ctx)
+	if ec != errcode.ErrCodeOk {
+		logger.Error("OpGetUploadMediaFailConfigList fail, ec: %v", ec)
+		ReplyErrCodeMsg(ctx, ec)
+		return
+	}
+
+	ReplyOk(ctx, config)
+}
diff --git a/app/mix/controller/init.go b/app/mix/controller/init.go
index 2d52103b..5a32a364 100644
--- a/app/mix/controller/init.go
+++ b/app/mix/controller/init.go
@@ -160,6 +160,10 @@ func Init(r *gin.Engine) {
 	apiVersion := r.Group("/api/version", PrepareToC())
 	apiVersion.POST("is_there_a_new_version_available", middleware.JSONParamValidator(base.BaseRequest{}), OpIsThereANewVersionAvailable)
 
+	// 上传媒体失败配置
+	apiUploadMediaFailConfig := r.Group("/api/upload_media_fail_config", PrepareToC())
+	apiUploadMediaFailConfig.POST("list", middleware.JSONParamValidator(base.BaseRequest{}), OpGetUploadMediaFailConfigList)
+
 	// =============================== 以下是服务，只允许内网调用 ===============================
 
 	// op相关，直接调用服务，不调用gateway
@@ -344,6 +348,10 @@ func Init(r *gin.Engine) {
 	opSupportWxIdGroup := r.Group("/op/support_wx_id", PrepareOp())
 	opSupportWxIdGroup.POST("list", middleware.JSONParamValidator(base.BaseRequest{}), middleware.JwtAuthenticator(), OpGetSupportWxIdList)
 
+	// 上传媒体失败配置
+	opUploadMediaFailConfig := r.Group("/op/upload_media_fail_config", PrepareToC())
+	opUploadMediaFailConfig.POST("list", middleware.JSONParamValidator(base.BaseRequest{}), OpGetUploadMediaFailConfigList)
+
 	// 账号相关
 	//accountGroup := r.Group("/account")
 
diff --git a/app/mix/service/configservice.go b/app/mix/service/configservice.go
index 7c6c0ee5..8b20ca92 100644
--- a/app/mix/service/configservice.go
+++ b/app/mix/service/configservice.go
@@ -146,3 +146,26 @@ func (s *ConfigService) OpIsThereANewVersionAvailable(ctx *gin.Context, baseRequ
 	}
 	return
 }
+
+func (s *ConfigService) OpGetUploadMediaFailConfigList(ctx *gin.Context) (uploadMediaFailConfigMap map[string]int64, ec errcode.ErrCode) {
+	ec = errcode.ErrCodeOk
+
+	uploadMediaFailConfigMap = make(map[string]int64)
+
+	imageIdForUploadFail, err := apollo.GetIntValue(consts.ImageIdForUploadFail, apollo.ApolloOpts().SetNamespace("application"))
+	if err != nil {
+		logger.Error("Apollo read failed : %v", err)
+		return nil, errcode.ErrCodeApolloReadFail
+	}
+
+	videoIdForUploadFail, err := apollo.GetIntValue(consts.VideoIdForUploadFail, apollo.ApolloOpts().SetNamespace("application"))
+	if err != nil {
+		logger.Error("Apollo read failed : %v", err)
+		return nil, errcode.ErrCodeApolloReadFail
+	}
+
+	uploadMediaFailConfigMap["image_id_for_upload_fail"] = int64(imageIdForUploadFail)
+	uploadMediaFailConfigMap["video_id_for_upload_fail"] = int64(videoIdForUploadFail)
+
+	return
+}