123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635 |
- package utils
- import (
- "errors"
- "fmt"
- "strconv"
- beeLogger "github.com/beego/bee/v2/logger"
- "github.com/beego/beego/v2/server/web"
- "github.com/qiniu/qmgo"
- "github.com/spf13/viper"
- )
- var (
- RunMode string
- MYSQL_URL string
- MYSQL_URL_RDDP string
- MYSQL_URL_EDB string
- MYSQL_URL_DATA string
- MYSQL_URL_GL string
- MYSQL_LOG_URL string
- MYSQL_WEEKLY_URL string
- MYSQL_AI_URL string
- MgoUrlData string
- REDIS_CACHE string
-
- Re error
- Rc RedisClient
- MgoDataCli *qmgo.Client
- MgoDataDbName string
- )
- var (
- MYSQL_DATA_BINLOG_URL string
- MYSQL_DATA_BINLOG_USER string
- MYSQL_DATA_BINLOG_PWD string
- MYSQL_DATA_BINLOG_DB string
- MYSQL_DATA_BINLOG_SERVER_ID string
- )
- var (
- STATIC_DIR string
- DesKey string
- APPNAME string
- EmailSendToUsers string
- JhGnAppKey string
- JhGjAppKey string
- ResourceProxyUrl string
- RESOURCE_DIR string
- )
- var (
- ES_URL string
- ES_USERNAME string
- ES_PASSWORD string
- )
- var (
-
- EDB_LIB_URL string
- APP_EDB_LIB_NAME_EN string
- EDB_LIB_Md5_KEY string
-
- PublicChartHost string
-
- MySteelPostUrl string
-
- SendWxTemplateMsgUrl string
-
- SendTemplateMsgAuthorization string
-
- HandleVideoDecibelUrl string
-
- Ppt2ImageUrl string
-
- HongzeOpenApiHost string
-
- EnglishShareUrl string
-
- EnPolicyReportUrl string
-
- GoogleTranslateUrl string
-
- AlarmMsgUrl string
-
- ChatUrl string
- EtaBridgeUrl string
- EtaBridgeAppNameEn string
- EtaBridgeMd5Key string
- EtaBridgeDesKey string
- EtaBridgeLoginUrl string
- EtaBridgeLogoutUrl string
- ETAMiniBridgeUrl string
- ETA_MINI_APPID string
- ETA_MINI_APP_SECRET string
- )
- var (
- WxId string
- WxAppId string
- WxAppSecret string
- TemplateIdByProduct string
- WxYbAppId string
- WxYbId string
- WxYbAppSecret string
- WxYbPlatform int
- )
- var (
- DATA_INDEX_NAME string
- CHART_INDEX_NAME string
- EsReportIndexName string
- EsEnglishReportIndexName string
- MY_CHART_INDEX_NAME string
- EsSemanticAnalysisDocIndexName string
- SmartReportIndexName string
- )
- var (
- XfHostUrl string
- )
- var (
- ObjectStorageClient string
- PptUpdateApi string
- )
- var (
- Bucketname string
- Endpoint string
- Imghost string
- UploadDir string
- Upload_Audio_Dir string
- AccessKeyId string
- AccessKeySecret string
- )
- var (
- AliStsScheme string
- RegionId string
- RoleArn string
- RoleSessionName string
- RAMAccessKeyId string
- RAMAccessKeySecret string
- STSTokenCacheKey string
- )
- var (
- AliyunEmailAccountName string
- AliyunEmailAccessKeyId string
- AliyunEmailAccessKeySecret string
- AliyunEmailReplyAddress string
- AliyunEmailReplyAddressAlias string
- )
- var (
- TencentSDKSecretId string
- TencentSDKSecretKey string
- TencentEmailFromEmailAddress string
- TencentEmailTemplateID uint64
- )
- var LibreOfficePath string
- var (
- CrmEtaServerUrl string
- CrmEtaServerDes3Key string
- )
- var (
- ETA_FORUM_HUB_URL string
- ETA_FORUM_HUB_NAME_EN string
- ETA_FORUM_HUB_MD5_KEY string
- )
- var BusinessCode string
- var (
- MinIoBucketname string
- MinIoEndpoint string
- MinIoBackEndpoint string
- MinIoImghost string
- MinIoUploadDir string
- MinIoUpload_Audio_Dir string
- MinIoAccessKeyId string
- MinIoAccessKeySecret string
- MinIoUseSSL string
- MinIoPort string
- MinIoRegion string
- MinIoFileDownloadHost string
- )
- var (
- LogPath string
- LogFile string
- LogDataPath string
- LogDataFile string
- BinLogPath string
- BinLogFile string
- ApiLogPath string
- ApiLogFile string
- LogMaxDays int
- )
- var PythonUrlReport2Img string
- var EtaAiUrl string
- var (
- EtaAppid string
- EtaSecret string
- )
- var (
- S3Endpoint string
- S3BackEndpoint string
- S3BucketName string
- S3UploadDir string
- S3AccessKeyId string
- S3AccessKeySecret string
- S3Host string
- S3Region string
- S3ForceStyle string
- S3EndpointPort string
- S3Protocol string
- S3DisableSSL string
- S3OpenAcl string
- )
- var (
- ChromePath string
- )
- var (
- ErrMsgConfigFile string
- )
- var (
- ViperConfig *viper.Viper
- )
- var (
- UseMongo bool
- )
- func init() {
- tmpRunMode, err := web.AppConfig.String("run_mode")
- if err != nil {
- panic(any("配置文件读取run_mode错误 " + err.Error()))
- }
- RunMode = tmpRunMode
- fmt.Println("RunMode:", RunMode)
- if RunMode == "" {
- localIp, err := GetLocalIP()
- fmt.Println("localIp:", localIp)
- if localIp == "10.0.0.123" {
- RunMode = "debug"
- } else {
- RunMode = "release"
- }
- fmt.Println("RunMode:", RunMode)
- configPath := `/home/code/config/eta_api/conf/app.conf`
- fmt.Println("configPath:", configPath)
- err = web.LoadAppConfig("ini", configPath)
- if err != nil {
- fmt.Println("web.LoadAppConfig Err:" + err.Error())
- }
- }
- config, err := web.AppConfig.GetSection(RunMode)
- if err != nil {
- panic(any("配置文件读取错误 " + err.Error()))
- }
- beeLogger.Log.Info(RunMode + " 模式")
- MYSQL_URL = config["mysql_url"]
- MYSQL_URL_RDDP = config["mysql_url_rddp"]
- MYSQL_URL_EDB = config["mysql_url_edb"]
- MYSQL_URL_DATA = config["mysql_url_data"]
- MYSQL_URL_GL = config["mysql_url_gl"]
- MYSQL_LOG_URL = config["mysql_url_log"]
-
- MYSQL_WEEKLY_URL = config["mysql_url_weekly"]
-
- MYSQL_WEEKLY_URL = config["mysql_url_weekly"]
-
- MYSQL_AI_URL = config["mysql_url_ai"]
-
- {
- MYSQL_DATA_BINLOG_URL = config["mysql_data_binlog_url"]
- MYSQL_DATA_BINLOG_USER = config["mysql_data_binlog_user"]
- MYSQL_DATA_BINLOG_PWD = config["mysql_data_binlog_pwd"]
- MYSQL_DATA_BINLOG_DB = config["mysql_data_binlog_db"]
- MYSQL_DATA_BINLOG_SERVER_ID = config["mysql_data_binlog_server_id"]
- }
-
- MgoUrlData = config["mgo_url_data"]
- REDIS_CACHE = config["beego_cache"]
- if len(REDIS_CACHE) <= 0 {
- panic(any("redis链接参数没有配置"))
- }
-
-
-
-
-
-
- redisClient, err := initRedis(config["redis_type"], config["beego_cache"])
- if err != nil {
- fmt.Println("redis链接异常:", err)
- panic(any(Re))
- }
- Rc = redisClient
-
- appNameCn, err := web.AppConfig.String("app_name_cn")
- if err != nil {
- panic(any("配置文件读取app_name_cn错误 " + err.Error()))
- }
- APPNAME = appNameCn
-
-
- DesKey = config["des_key"]
-
- EmailSendToUsers = config["email_send_to_users"]
-
- JhGnAppKey = config["jh_gn_app_key"]
- JhGjAppKey = config["jh_gj_app_key"]
-
- Ppt2ImageUrl = config["ppt2_image_url"]
-
- STATIC_DIR = config["static_dir"]
-
- ResourceProxyUrl = config["resource_proxy_url"]
- RESOURCE_DIR = config["resource_dir"]
- if RESOURCE_DIR == "" {
- RESOURCE_DIR = "eta/"
- }
-
- {
-
- EDB_LIB_URL = config["edb_lib_url"]
- APP_EDB_LIB_NAME_EN = config["app_edb_lib_name_en"]
- EDB_LIB_Md5_KEY = config["edb_lib_md5_key"]
-
- PublicChartHost = config["public_chart_host"]
-
- MySteelPostUrl = config["mysteel_post_url"]
-
- SendWxTemplateMsgUrl = config["send_wx_template_msg_url"]
-
- SendTemplateMsgAuthorization = config["send_template_msg_authorization"]
-
- HandleVideoDecibelUrl = config["handle_video_decibel_url"]
-
- HongzeOpenApiHost = config["hongze_open_api_host"]
-
- EnglishShareUrl = config["english_share_url"]
-
- EnPolicyReportUrl = config["en_policy_report_url"]
-
- GoogleTranslateUrl = config["google_translate_url"]
-
- AlarmMsgUrl = config["alarm_msg_url"]
-
- ChatUrl = config["chat_url"]
- EtaBridgeUrl = config["eta_bridge_url"]
- EtaBridgeAppNameEn = config["eta_bridge_app_name_en"]
- EtaBridgeMd5Key = config["eta_bridge_md5_key"]
- EtaBridgeDesKey = config["eta_bridge_des_key"]
- EtaBridgeLoginUrl = config["eta_bridge_login_url"]
- EtaBridgeLogoutUrl = config["eta_bridge_logout_url"]
- }
-
- {
- LogPath = config["log_path"]
- LogFile = config["log_file"]
- LogDataPath = config["log_data_path"]
- LogDataFile = config["log_data_file"]
- BinLogPath = config["binlog_path"]
- BinLogFile = config["binlog_file"]
- ApiLogPath = config["apilog_path"]
- ApiLogFile = config["apilog_file"]
- logMaxDaysStr := config["log_max_day"]
- LogMaxDays, _ = strconv.Atoi(logMaxDaysStr)
- }
-
- {
- ES_URL = config["es_url"]
- ES_USERNAME = config["es_username"]
- ES_PASSWORD = config["es_password"]
- }
-
- {
- WxAppId = config["wx_appid"]
- WxAppSecret = config["wx_app_secret"]
- WxId = config["wx_id"]
-
- TemplateIdByProduct = config["template_id_by_product"]
- WxYbAppId = config["wx_yb_appid"]
- WxYbId = config["wx_yb_id"]
- WxYbAppSecret = config["wx_yb_app_secret"]
- wxYbPlatformStr := config["wx_yb_platform"]
- if wxYbPlatformStr != `` {
- WxYbPlatform, err = strconv.Atoi(wxYbPlatformStr)
- if err != nil {
- panic(any("配置文件读取wx_yb_platform错误 " + err.Error()))
- }
- }
- }
-
- ObjectStorageClient = config["object_storage_client"]
-
- PptUpdateApi = config["ppt_update_api"]
-
- {
- Endpoint = config["endpoint"]
- Bucketname = config["bucket_name"]
- Imghost = config["img_host"]
- UploadDir = config["upload_dir"]
- Upload_Audio_Dir = config["upload_audio_dir"]
- AccessKeyId = config["access_key_id"]
- AccessKeySecret = config["access_key_secret"]
- }
-
- {
- AliStsScheme = config["ali_sts_scheme"]
- RegionId = config["region_id"]
- RoleArn = config["role_arn"]
- RoleSessionName = config["role_session_name"]
- RAMAccessKeyId = config["ram_access_key_id"]
- RAMAccessKeySecret = config["ram_access_key_secret"]
- STSTokenCacheKey = config["sts_token_cache_key"]
- }
-
- {
- AliyunEmailAccountName = config["aliyun_email_account_name"]
- AliyunEmailAccessKeyId = config["aliyun_email_access_key_id"]
- AliyunEmailAccessKeySecret = config["aliyun_email_access_key_secret"]
- AliyunEmailReplyAddress = config["aliyun_email_reply_address"]
- AliyunEmailReplyAddressAlias = config["aliyun_email_reply_address_alias"]
- }
-
- {
- TencentSDKSecretId = config["tencent_sdk_secret_id"]
- TencentSDKSecretKey = config["tencent_sdk_secret_key"]
- TencentEmailFromEmailAddress = config["tencent_email_from_email_address"]
- tencentEmailTemplateIDtr := config["tencent_email_template_id"]
- if tencentEmailTemplateIDtr != `` {
- tmpTencentEmailTemplateID, err := strconv.Atoi(tencentEmailTemplateIDtr)
- if err != nil {
- panic(any("配置文件读取tencent_email_template_id错误 " + err.Error()))
- }
- TencentEmailTemplateID = uint64(tmpTencentEmailTemplateID)
- }
- }
-
- {
-
-
-
- XfHostUrl = config["xf_host_url"]
-
-
- }
-
- {
- DATA_INDEX_NAME = config["data_index_name"]
- CHART_INDEX_NAME = config["chart_index_name"]
- MY_CHART_INDEX_NAME = config["my_chart_index_name"]
- EsReportIndexName = config["es_report_index_name"]
- EsEnglishReportIndexName = config["es_english_report_index_name"]
- EsSemanticAnalysisDocIndexName = config["es_semantic_analysis_doc_index_name"]
- SmartReportIndexName = config["es_smart_report_index_name"]
- }
- CrmEtaServerUrl = config["crm_eta_server_url"]
- CrmEtaServerDes3Key = config["crm_eta_server_des3_key"]
- LibreOfficePath = config["libre_office_path"]
-
- {
- ETA_FORUM_HUB_URL = config["eta_forum_hub_url"]
- ETA_FORUM_HUB_NAME_EN = config["eta_forum_hub_name_en"]
- ETA_FORUM_HUB_MD5_KEY = config["eta_forum_hub_md5_key"]
- }
-
- BusinessCode = config["business_code"]
-
- {
- ETAMiniBridgeUrl = config["eta_mini_bridge_url"]
- ETA_MINI_APPID = config["eta_mini_bridge_appid"]
- ETA_MINI_APP_SECRET = config["eta_mini_bridge_secret"]
- }
-
- {
- MinIoEndpoint = config["minio_endpoint"]
- MinIoBackEndpoint = config["minio_back_endpoint"]
- MinIoBucketname = config["minio_bucket_name"]
- MinIoImghost = config["minio_img_host"]
- MinIoUploadDir = config["minio_upload_dir"]
- MinIoUpload_Audio_Dir = config["minio_upload_audio_dir"]
- MinIoAccessKeyId = config["minio_access_key_id"]
- MinIoAccessKeySecret = config["minio_access_key_secret"]
- MinIoUseSSL = config["minio_use_ssl"]
- MinIoPort = config["minio_port"]
- MinIoRegion = config["minio_region"]
- MinIoFileDownloadHost = config["minio_file_download_host"]
- }
-
- {
- S3Endpoint = config["s3_endpoint"]
- S3BackEndpoint = config["s3_back_endpoint"]
- S3BucketName = config["s3_bucket_name"]
- S3Host = config["s3_host"]
- S3AccessKeyId = config["s3_access_key_id"]
- S3AccessKeySecret = config["s3_access_key_secret"]
- S3UploadDir = config["s3_upload_dir"]
- S3Region = config["s3_region"]
- S3ForceStyle = config["s3_force_style"]
- S3EndpointPort = config["s3_endpoint_port"]
- S3Protocol = config["s3_protocol"]
- S3DisableSSL = config["s3_disable_ssl"]
- S3OpenAcl = config["s3_open_acl"]
- }
-
- PythonUrlReport2Img = config["python_url_report2img"]
- EtaAiUrl = config["eta_ai_url"]
- EtaAppid = config["eta_appid"]
- EtaSecret = config["eta_secret"]
-
- ChromePath = config["chrome_path"]
-
- initEs()
- ErrMsgConfigFile = config["err_msg_config_file"]
- if ErrMsgConfigFile != "" {
- viper.SetConfigFile(ErrMsgConfigFile)
- err = viper.ReadInConfig()
- if err != nil {
- if _, ok := err.(viper.ConfigFileNotFoundError); ok {
- fmt.Println(errors.New("config file not found"))
- panic(any("config file not found"))
- } else {
- fmt.Println(errors.New("config file was found but another error was produced err:" + err.Error()))
- panic(any("config file was found but another error was produced err:" + err.Error()))
- }
- return
- }
- ViperConfig = viper.GetViper()
- }
- }
|