config.go 9.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348
  1. package utils
  2. import (
  3. "fmt"
  4. beeLogger "github.com/beego/bee/v2/logger"
  5. "github.com/beego/beego/v2/server/web"
  6. "github.com/rdlucklib/rdluck_tools/cache"
  7. "strconv"
  8. )
  9. var (
  10. RunMode string //运行模式
  11. MYSQL_URL string //数据库连接
  12. MYSQL_URL_RDDP string //数据库连接
  13. MYSQL_URL_EDB string
  14. MYSQL_URL_DATA string
  15. MYSQL_URL_GL string
  16. MYSQL_LOG_URL string
  17. MYSQL_URL_COMEIN_DATA string // 路演记录数据库
  18. MYSQL_URL_ETA string
  19. REDIS_CACHE string //缓存地址
  20. Rc *cache.Cache //redis缓存
  21. Re error //redis错误
  22. )
  23. // SystemType 系统类型; hz:弘则;trial:试用平台;custom:客户
  24. var SystemType string
  25. // 基础配置
  26. var (
  27. STATIC_DIR string
  28. DesKey string // 接口返回加密KEY
  29. APPNAME string //项目中文名称
  30. EmailSendToUsers string // 邮件提醒人员
  31. // LibreOfficePath LibreOfficePath的地址
  32. LibreOfficePath string
  33. )
  34. // 公共api内部服务调用
  35. var (
  36. // EDB_LIB_URL 公共指标库
  37. EDB_LIB_URL string
  38. APP_EDB_LIB_NAME_EN string
  39. EDB_LIB_Md5_KEY string
  40. // PublicChartHost 公共图库的host
  41. PublicChartHost string
  42. // SendWxTemplateMsgUrl 模板消息推送
  43. SendWxTemplateMsgUrl string
  44. // SendTemplateMsgAuthorization 模板推送秘钥
  45. SendTemplateMsgAuthorization string
  46. // HandleVideoDecibelUrl 处理音频分贝的url
  47. HandleVideoDecibelUrl string
  48. // Ppt2ImageUrl ppt转图片服务的地址
  49. Ppt2ImageUrl string
  50. // EnglishShareUrl 英文研报群发邮件分享地址
  51. EnglishShareUrl string
  52. // AlarmMsgUrl 报警服务地址
  53. AlarmMsgUrl string
  54. )
  55. // TemplateIdByProduct 微信配置信息
  56. var (
  57. TemplateIdByProduct string //产品运行报告通知-模板ID
  58. WxYbAppId string // 研报小程序appid
  59. WxYbId string // 研报小程序微信原始ID
  60. WxYbAppSecret string // 研报小程序秘钥
  61. WxYbPlatform int //弘则研报来源
  62. )
  63. // ES配置
  64. var (
  65. ES_URL string // ES服务器地址
  66. ES_USERNAME string // ES账号
  67. ES_PASSWORD string // ES密码
  68. )
  69. // ES索引配置
  70. var (
  71. DATA_INDEX_NAME string //数据指标库索引
  72. CHART_INDEX_NAME string //研究图库索引
  73. EsReportIndexName string //研报ES索引
  74. EsEnglishReportIndexName string //英文研报ES索引
  75. MY_CHART_INDEX_NAME string //研究图库(MY ETA)索引
  76. )
  77. // 阿里云配置
  78. var (
  79. Bucketname string
  80. Endpoint string
  81. Imghost string
  82. UploadDir string
  83. Upload_Audio_Dir string
  84. AccessKeyId string
  85. AccessKeySecret string
  86. )
  87. // 阿里云oss前端上传用
  88. var (
  89. AliStsScheme string
  90. RegionId string
  91. RoleArn string
  92. RoleSessionName string
  93. RAMAccessKeyId string
  94. RAMAccessKeySecret string
  95. STSTokenCacheKey string
  96. )
  97. // 科大讯飞--语音合成
  98. var (
  99. XfSTATUS_FIRST_FRAME = 0 //第一帧标识
  100. XfSTATUS_CONTINUE_FRAME = 1 //中间帧标识
  101. XfSTATUS_LAST_FRAME = 2 //最后一帧标识
  102. XfHost = "tts-api.xfyun.cn"
  103. XfMaxFontSize = 8000
  104. XfAPPID string
  105. XfAPIKey string
  106. XfAPISecret string
  107. XfHostUrl string
  108. XfOrigin string
  109. XfVcn string //发言人
  110. )
  111. // 阿里云邮箱配置
  112. var (
  113. AliyunEmailAccountName string
  114. AliyunEmailAccessKeyId string
  115. AliyunEmailAccessKeySecret string
  116. AliyunEmailReplyAddress string
  117. AliyunEmailReplyAddressAlias string
  118. )
  119. // 腾讯云邮箱配置
  120. var (
  121. TencentSDKSecretId string // 腾讯云主账号SecretId
  122. TencentSDKSecretKey string // 腾讯云主账号SecretKey
  123. TencentEmailFromEmailAddress string // 腾讯云邮件发信地址
  124. TencentEmailTemplateID uint64 // 云邮件模板ID
  125. )
  126. func init() {
  127. tmpRunMode, err := web.AppConfig.String("run_mode")
  128. if err != nil {
  129. panic("配置文件读取run_mode错误 " + err.Error())
  130. }
  131. RunMode = tmpRunMode
  132. fmt.Println("RunMode:", RunMode)
  133. if RunMode == "" {
  134. localIp, err := GetLocalIP()
  135. fmt.Println("localIp:", localIp)
  136. if localIp == "10.0.0.123" {
  137. RunMode = "debug"
  138. } else {
  139. RunMode = "release"
  140. }
  141. fmt.Println("RunMode:", RunMode)
  142. configPath := `/home/code/config/eta_mobile/conf/app.conf`
  143. fmt.Println("configPath:", configPath)
  144. err = web.LoadAppConfig("ini", configPath)
  145. if err != nil {
  146. fmt.Println("web.LoadAppConfig Err:" + err.Error())
  147. }
  148. }
  149. config, err := web.AppConfig.GetSection(RunMode)
  150. if err != nil {
  151. panic("配置文件读取错误 " + err.Error())
  152. }
  153. beeLogger.Log.Info(RunMode + " 模式")
  154. MYSQL_URL = config["mysql_url"]
  155. MYSQL_URL_RDDP = config["mysql_url_rddp"]
  156. MYSQL_URL_EDB = config["mysql_url_edb"]
  157. MYSQL_URL_DATA = config["mysql_url_data"]
  158. MYSQL_URL_GL = config["mysql_url_gl"]
  159. MYSQL_LOG_URL = config["mysql_url_log"]
  160. MYSQL_URL_COMEIN_DATA = config["mysql_url_comein_data"]
  161. MYSQL_URL_ETA = config["mysql_url_eta"]
  162. REDIS_CACHE = config["beego_cache"]
  163. if len(REDIS_CACHE) <= 0 {
  164. panic("redis链接参数没有配置")
  165. }
  166. Rc, Re = cache.NewCache(REDIS_CACHE) //初始化缓存
  167. if Re != nil {
  168. fmt.Println(Re)
  169. panic(Re)
  170. }
  171. // 系统类型
  172. systemType, err := web.AppConfig.String("system_type")
  173. if err != nil {
  174. panic(any("配置文件读取system_type错误 " + err.Error()))
  175. }
  176. SystemType = systemType
  177. // 项目中文名称
  178. appNameCn, err := web.AppConfig.String("app_name_cn")
  179. if err != nil {
  180. panic(any("配置文件读取app_name_cn错误 " + err.Error()))
  181. }
  182. APPNAME = appNameCn
  183. // 初始化内部服务配置
  184. // 接口返回加密KEY
  185. DesKey = config["des_key"]
  186. // 服务基本配置
  187. {
  188. // 邮件提醒人员
  189. EmailSendToUsers = config["email_send_to_users"]
  190. // 静态文件目录
  191. STATIC_DIR = config["static_dir"]
  192. }
  193. // 系统内部服务地址
  194. {
  195. // 公共指标库相关
  196. EDB_LIB_URL = config["edb_lib_url"]
  197. APP_EDB_LIB_NAME_EN = config["app_edb_lib_name_en"]
  198. EDB_LIB_Md5_KEY = config["edb_lib_md5_key"]
  199. // 图表项目域名
  200. PublicChartHost = config["public_chart_host"]
  201. // 发送微信模板消息地址
  202. SendWxTemplateMsgUrl = config["send_wx_template_msg_url"]
  203. // 发送微信模板消息地址
  204. SendTemplateMsgAuthorization = config["send_template_msg_authorization"]
  205. // 语音分贝处理的地址
  206. HandleVideoDecibelUrl = config["handle_video_decibel_url"]
  207. // 英文研报分享的地址
  208. EnglishShareUrl = config["english_share_url"]
  209. // 报警服务地址
  210. AlarmMsgUrl = config["alarm_msg_url"]
  211. // ppt 转图片服务地址
  212. Ppt2ImageUrl = config["ppt2_image_url"]
  213. }
  214. // ES配置
  215. {
  216. ES_URL = config["es_url"]
  217. ES_USERNAME = config["es_username"]
  218. ES_PASSWORD = config["es_password"]
  219. }
  220. // ES 索引
  221. {
  222. DATA_INDEX_NAME = config["data_index_name"]
  223. CHART_INDEX_NAME = config["chart_index_name"]
  224. MY_CHART_INDEX_NAME = config["my_chart_index_name"]
  225. EsReportIndexName = config["es_report_index_name"]
  226. EsEnglishReportIndexName = config["es_english_report_index_name"]
  227. }
  228. // 微信相关
  229. {
  230. //模板消息
  231. TemplateIdByProduct = config["template_id_by_product"]
  232. WxYbAppId = config["wx_yb_appid"] //弘则研报小程序
  233. WxYbId = config["wx_yb_id"] // 研报小程序微信原始ID
  234. WxYbAppSecret = config["wx_yb_app_secret"] // 研报小程序秘钥
  235. wxYbPlatformStr := config["wx_yb_platform"]
  236. if wxYbPlatformStr != `` {
  237. WxYbPlatform, err = strconv.Atoi(wxYbPlatformStr) //弘则研报来源
  238. if err != nil {
  239. panic(any("配置文件读取wx_yb_platform错误 " + err.Error()))
  240. }
  241. }
  242. }
  243. // OSS相关
  244. {
  245. Endpoint = config["endpoint"]
  246. Bucketname = config["bucket_name"]
  247. Imghost = config["img_host"]
  248. UploadDir = config["upload_dir"]
  249. Upload_Audio_Dir = config["upload_audio_dir"]
  250. AccessKeyId = config["access_key_id"]
  251. AccessKeySecret = config["access_key_secret"]
  252. }
  253. // OSS相关(前端使用)
  254. {
  255. AliStsScheme = config["ali_sts_scheme"]
  256. RegionId = config["region_id"]
  257. RoleArn = config["role_arn"]
  258. RoleSessionName = config["role_session_name"]
  259. RAMAccessKeyId = config["ram_access_key_id"]
  260. RAMAccessKeySecret = config["ram_access_key_secret"]
  261. STSTokenCacheKey = config["sts_token_cache_key"]
  262. }
  263. // 阿里云邮箱配置
  264. {
  265. AliyunEmailAccountName = config["aliyun_email_account_name"]
  266. AliyunEmailAccessKeyId = config["aliyun_email_access_key_id"]
  267. AliyunEmailAccessKeySecret = config["aliyun_email_access_key_secret"]
  268. AliyunEmailReplyAddress = config["aliyun_email_reply_address"]
  269. AliyunEmailReplyAddressAlias = config["aliyun_email_reply_address_alias"]
  270. }
  271. // 腾讯云邮箱配置
  272. {
  273. TencentSDKSecretId = config["tencent_sdk_secret_id"] // 腾讯云主账号SecretId
  274. TencentSDKSecretKey = config["tencent_sdk_secret_key"] // 腾讯云主账号SecretKey
  275. TencentEmailFromEmailAddress = config["tencent_email_from_email_address"] // 腾讯云邮件发信地址
  276. tencentEmailTemplateIDtr := config["tencent_email_template_id"]
  277. if tencentEmailTemplateIDtr != `` {
  278. tmpTencentEmailTemplateID, err := strconv.Atoi(tencentEmailTemplateIDtr) //弘则研报来源
  279. if err != nil {
  280. panic(any("配置文件读取tencent_email_template_id错误 " + err.Error()))
  281. }
  282. TencentEmailTemplateID = uint64(tmpTencentEmailTemplateID)
  283. }
  284. }
  285. // 科大讯飞
  286. {
  287. XfAPPID = config["xf_appid"]
  288. XfAPIKey = config["xf_api_key"]
  289. XfAPISecret = config["xf_api_secret"]
  290. XfHostUrl = config["xf_host_url"]
  291. XfOrigin = config["xf_origin"]
  292. XfVcn = config["xf_vcn"]
  293. }
  294. LibreOfficePath = config["libre_office_path"]
  295. // 初始化ES
  296. initEs()
  297. }