config.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447
  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_WEEKLY_URL string //用户主库
  18. REDIS_CACHE string //缓存地址
  19. Rc *cache.Cache //redis缓存
  20. Re error //redis错误
  21. )
  22. // 基础配置
  23. var (
  24. STATIC_DIR string
  25. DesKey string // 接口返回加密KEY
  26. APPNAME string //项目中文名称
  27. EmailSendToUsers string // 邮件提醒人员
  28. JhGnAppKey string // 聚合短信,国内AppKey
  29. JhGjAppKey string // 聚合短信,国际AppKey
  30. )
  31. // ES配置
  32. var (
  33. ES_URL string // ES服务器地址
  34. ES_USERNAME string // ES账号
  35. ES_PASSWORD string // ES密码
  36. )
  37. // 公共api内部服务调用
  38. var (
  39. // EDB_LIB_URL 公共指标库
  40. EDB_LIB_URL string
  41. APP_EDB_LIB_NAME_EN string
  42. EDB_LIB_Md5_KEY string
  43. // PublicChartHost 公共图库的host
  44. PublicChartHost string
  45. // MySteelPostUrl 钢联化工的服务地址
  46. MySteelPostUrl string
  47. // SendWxTemplateMsgUrl 模板消息推送
  48. SendWxTemplateMsgUrl string
  49. // SendTemplateMsgAuthorization 模板推送秘钥
  50. SendTemplateMsgAuthorization string
  51. // HandleVideoDecibelUrl 处理音频分贝的url
  52. HandleVideoDecibelUrl string
  53. // Ppt2ImageUrl ppt转图片服务的地址
  54. Ppt2ImageUrl string
  55. // HongzeOpenApiHost 开放openapi的地址
  56. HongzeOpenApiHost string
  57. // EnglishShareUrl 英文研报群发邮件分享地址
  58. EnglishShareUrl string
  59. // EnPolicyReportUrl 英文策略报告
  60. EnPolicyReportUrl string
  61. // GoogleTranslateUrl 谷歌翻译服务
  62. GoogleTranslateUrl string
  63. // AlarmMsgUrl 报警服务地址
  64. AlarmMsgUrl string
  65. // ChatUrl chatGPT服务地址
  66. ChatUrl string
  67. )
  68. // 微信配置信息
  69. var (
  70. WxId string //微信原始ID
  71. WxAppId string // 公众号appid
  72. WxAppSecret string // 公众号秘钥
  73. TemplateIdByProduct string //产品运行报告通知-模板ID
  74. WxYbAppId string // 研报小程序appid
  75. WxYbId string // 研报小程序微信原始ID
  76. WxYbAppSecret string // 研报小程序秘钥
  77. WxYbPlatform int //弘则研报来源
  78. )
  79. // ES索引配置
  80. var (
  81. DATA_INDEX_NAME string //数据指标库索引
  82. CHART_INDEX_NAME string //研究图库索引
  83. EsReportIndexName string //研报ES索引
  84. EsEnglishReportIndexName string //英文研报ES索引
  85. MY_CHART_INDEX_NAME string //研究图库(MY ETA)索引
  86. EsSemanticAnalysisDocIndexName string //ES语义分析文档索引名
  87. )
  88. // 科大讯飞--语音合成
  89. var (
  90. //XfSTATUS_FIRST_FRAME = 0 //第一帧标识
  91. //XfSTATUS_CONTINUE_FRAME = 1 //中间帧标识
  92. //XfSTATUS_LAST_FRAME = 2 //最后一帧标识
  93. //XfHost = "tts-api.xfyun.cn"
  94. //XfMaxFontSize = 8000
  95. //XfAPPID string
  96. //XfAPIKey string
  97. //XfAPISecret string
  98. XfHostUrl string
  99. //XfOrigin string
  100. //XfVcn string //发言人
  101. )
  102. // 阿里云配置
  103. var (
  104. Bucketname string
  105. Endpoint string
  106. Imghost string
  107. UploadDir string
  108. Upload_Audio_Dir string
  109. AccessKeyId string
  110. AccessKeySecret string
  111. )
  112. // 阿里云oss前端上传用
  113. var (
  114. AliStsScheme string
  115. RegionId string
  116. RoleArn string
  117. RoleSessionName string
  118. RAMAccessKeyId string
  119. RAMAccessKeySecret string
  120. STSTokenCacheKey string
  121. )
  122. // 阿里云邮箱配置
  123. var (
  124. AliyunEmailAccountName string
  125. AliyunEmailAccessKeyId string
  126. AliyunEmailAccessKeySecret string
  127. AliyunEmailReplyAddress string
  128. AliyunEmailReplyAddressAlias string
  129. )
  130. // 腾讯云邮箱配置
  131. var (
  132. TencentSDKSecretId string // 腾讯云主账号SecretId
  133. TencentSDKSecretKey string // 腾讯云主账号SecretKey
  134. TencentEmailFromEmailAddress string // 腾讯云邮件发信地址
  135. TencentEmailTemplateID uint64 // 云邮件模板ID
  136. )
  137. // LibreOfficePath LibreOfficePath的地址
  138. var LibreOfficePath string
  139. // CrmEtaServerUrl CRM-ETA服务地址
  140. var (
  141. CrmEtaServerUrl string
  142. CrmEtaServerDes3Key string
  143. )
  144. // BusinessCode 商家编码
  145. var BusinessCode string
  146. // MinIo配置
  147. var (
  148. MinIoBucketname string
  149. MinIoEndpoint string
  150. MinIoImghost string
  151. MinIoUploadDir string
  152. MinIoUpload_Audio_Dir string
  153. MinIoAccessKeyId string
  154. MinIoAccessKeySecret string
  155. MinIoUseSSL string
  156. MinIoPort string
  157. MinIoRegion string
  158. )
  159. // 日志配置
  160. var (
  161. LogPath string
  162. LogFile string
  163. LogDataPath string
  164. LogDataFile string
  165. BinLogPath string
  166. BinLogFile string
  167. ApiLogPath string
  168. ApiLogFile string
  169. )
  170. func init() {
  171. tmpRunMode, err := web.AppConfig.String("run_mode")
  172. if err != nil {
  173. panic(any("配置文件读取run_mode错误 " + err.Error()))
  174. }
  175. RunMode = tmpRunMode
  176. fmt.Println("RunMode:", RunMode)
  177. if RunMode == "" {
  178. localIp, err := GetLocalIP()
  179. fmt.Println("localIp:", localIp)
  180. if localIp == "10.0.0.123" {
  181. RunMode = "debug"
  182. } else {
  183. RunMode = "release"
  184. }
  185. fmt.Println("RunMode:", RunMode)
  186. configPath := `/home/code/config/eta_api/conf/app.conf`
  187. fmt.Println("configPath:", configPath)
  188. err = web.LoadAppConfig("ini", configPath)
  189. if err != nil {
  190. fmt.Println("web.LoadAppConfig Err:" + err.Error())
  191. }
  192. }
  193. config, err := web.AppConfig.GetSection(RunMode)
  194. if err != nil {
  195. panic(any("配置文件读取错误 " + err.Error()))
  196. }
  197. beeLogger.Log.Info(RunMode + " 模式")
  198. MYSQL_URL = config["mysql_url"]
  199. MYSQL_URL_RDDP = config["mysql_url_rddp"]
  200. MYSQL_URL_EDB = config["mysql_url_edb"]
  201. MYSQL_URL_DATA = config["mysql_url_data"]
  202. MYSQL_URL_GL = config["mysql_url_gl"]
  203. MYSQL_LOG_URL = config["mysql_url_log"]
  204. // 用户主库
  205. MYSQL_WEEKLY_URL = config["mysql_url_weekly"]
  206. REDIS_CACHE = config["beego_cache"]
  207. if len(REDIS_CACHE) <= 0 {
  208. panic(any("redis链接参数没有配置"))
  209. }
  210. Rc, Re = cache.NewCache(REDIS_CACHE) //初始化缓存
  211. if Re != nil {
  212. fmt.Println(Re)
  213. panic(any(Re))
  214. }
  215. // 项目中文名称
  216. appNameCn, err := web.AppConfig.String("app_name_cn")
  217. if err != nil {
  218. panic(any("配置文件读取app_name_cn错误 " + err.Error()))
  219. }
  220. APPNAME = appNameCn
  221. // 初始化内部服务配置
  222. // 接口返回加密KEY
  223. DesKey = config["des_key"]
  224. // 邮件提醒人员
  225. EmailSendToUsers = config["email_send_to_users"]
  226. // 聚合短信,国内AppKey
  227. JhGnAppKey = config["jh_gn_app_key"]
  228. JhGjAppKey = config["jh_gj_app_key"]
  229. // ppt 转图片服务地址
  230. Ppt2ImageUrl = config["ppt2_image_url"]
  231. // 静态文件目录
  232. STATIC_DIR = config["static_dir"]
  233. // 系统内部服务地址
  234. {
  235. // 公共指标库相关
  236. EDB_LIB_URL = config["edb_lib_url"]
  237. APP_EDB_LIB_NAME_EN = config["app_edb_lib_name_en"]
  238. EDB_LIB_Md5_KEY = config["edb_lib_md5_key"]
  239. // 图表项目域名
  240. PublicChartHost = config["public_chart_host"]
  241. // 钢联化工服务地址
  242. MySteelPostUrl = config["mysteel_post_url"]
  243. // 发送微信模板消息地址
  244. SendWxTemplateMsgUrl = config["send_wx_template_msg_url"]
  245. // 发送微信模板消息地址
  246. SendTemplateMsgAuthorization = config["send_template_msg_authorization"]
  247. // 语音分贝处理的地址
  248. HandleVideoDecibelUrl = config["handle_video_decibel_url"]
  249. // 弘则open api的地址
  250. HongzeOpenApiHost = config["hongze_open_api_host"]
  251. // 英文研报分享的地址
  252. EnglishShareUrl = config["english_share_url"]
  253. // 策略报告地址
  254. EnPolicyReportUrl = config["en_policy_report_url"]
  255. // 谷歌翻译服务地址
  256. GoogleTranslateUrl = config["google_translate_url"]
  257. // 报警服务地址
  258. AlarmMsgUrl = config["alarm_msg_url"]
  259. // chatGPT服务地址
  260. ChatUrl = config["chat_url"]
  261. }
  262. //日志配置
  263. {
  264. LogPath = config["log_path"]
  265. LogFile = config["log_file"]
  266. LogDataPath = config["log_data_path"]
  267. LogDataFile = config["log_data_file"]
  268. BinLogPath = config["binlog_path"]
  269. BinLogFile = config["binlog_file"]
  270. ApiLogPath = config["apilog_path"]
  271. ApiLogFile = config["apilog_file"]
  272. }
  273. // ES配置
  274. {
  275. ES_URL = config["es_url"]
  276. ES_USERNAME = config["es_username"]
  277. ES_PASSWORD = config["es_password"]
  278. }
  279. // 微信相关
  280. {
  281. WxAppId = config["wx_appid"]
  282. WxAppSecret = config["wx_app_secret"]
  283. WxId = config["wx_id"]
  284. //模板消息
  285. TemplateIdByProduct = config["template_id_by_product"]
  286. WxYbAppId = config["wx_yb_appid"] //弘则研报小程序
  287. WxYbId = config["wx_yb_id"] // 研报小程序微信原始ID
  288. WxYbAppSecret = config["wx_yb_app_secret"] // 研报小程序秘钥
  289. wxYbPlatformStr := config["wx_yb_platform"]
  290. if wxYbPlatformStr != `` {
  291. WxYbPlatform, err = strconv.Atoi(wxYbPlatformStr) //弘则研报来源
  292. if err != nil {
  293. panic(any("配置文件读取wx_yb_platform错误 " + err.Error()))
  294. }
  295. }
  296. }
  297. // OSS相关
  298. {
  299. Endpoint = config["endpoint"]
  300. Bucketname = config["bucket_name"]
  301. Imghost = config["img_host"]
  302. UploadDir = config["upload_dir"]
  303. Upload_Audio_Dir = config["upload_audio_dir"]
  304. AccessKeyId = config["access_key_id"]
  305. AccessKeySecret = config["access_key_secret"]
  306. }
  307. // OSS相关(前端使用)
  308. {
  309. AliStsScheme = config["ali_sts_scheme"]
  310. RegionId = config["region_id"]
  311. RoleArn = config["role_arn"]
  312. RoleSessionName = config["role_session_name"]
  313. RAMAccessKeyId = config["ram_access_key_id"]
  314. RAMAccessKeySecret = config["ram_access_key_secret"]
  315. STSTokenCacheKey = config["sts_token_cache_key"]
  316. }
  317. // 阿里云邮箱配置
  318. {
  319. AliyunEmailAccountName = config["aliyun_email_account_name"]
  320. AliyunEmailAccessKeyId = config["aliyun_email_access_key_id"]
  321. AliyunEmailAccessKeySecret = config["aliyun_email_access_key_secret"]
  322. AliyunEmailReplyAddress = config["aliyun_email_reply_address"]
  323. AliyunEmailReplyAddressAlias = config["aliyun_email_reply_address_alias"]
  324. }
  325. // 腾讯云邮箱配置
  326. {
  327. TencentSDKSecretId = config["tencent_sdk_secret_id"] // 腾讯云主账号SecretId
  328. TencentSDKSecretKey = config["tencent_sdk_secret_key"] // 腾讯云主账号SecretKey
  329. TencentEmailFromEmailAddress = config["tencent_email_from_email_address"] // 腾讯云邮件发信地址
  330. tencentEmailTemplateIDtr := config["tencent_email_template_id"]
  331. if tencentEmailTemplateIDtr != `` {
  332. tmpTencentEmailTemplateID, err := strconv.Atoi(tencentEmailTemplateIDtr) //弘则研报来源
  333. if err != nil {
  334. panic(any("配置文件读取tencent_email_template_id错误 " + err.Error()))
  335. }
  336. TencentEmailTemplateID = uint64(tmpTencentEmailTemplateID)
  337. }
  338. }
  339. // 科大讯飞
  340. {
  341. //XfAPPID = config["xf_appid"]
  342. //XfAPIKey = config["xf_api_key"]
  343. //XfAPISecret = config["xf_api_secret"]
  344. XfHostUrl = config["xf_host_url"]
  345. //XfOrigin = config["xf_origin"]
  346. //XfVcn = config["xf_vcn"]
  347. }
  348. // ES 索引
  349. {
  350. DATA_INDEX_NAME = config["data_index_name"]
  351. CHART_INDEX_NAME = config["chart_index_name"]
  352. MY_CHART_INDEX_NAME = config["my_chart_index_name"]
  353. EsReportIndexName = config["es_report_index_name"]
  354. EsEnglishReportIndexName = config["es_english_report_index_name"]
  355. EsSemanticAnalysisDocIndexName = config["es_semantic_analysis_doc_index_name"]
  356. }
  357. CrmEtaServerUrl = config["crm_eta_server_url"]
  358. CrmEtaServerDes3Key = config["crm_eta_server_des3_key"]
  359. LibreOfficePath = config["libre_office_path"]
  360. // 商家编码
  361. BusinessCode = config["business_code"]
  362. // MinIo相关
  363. {
  364. MinIoEndpoint = config["minio_endpoint"]
  365. MinIoBucketname = config["minio_bucket_name"]
  366. MinIoImghost = config["minio_img_host"]
  367. MinIoUploadDir = config["minio_upload_dir"]
  368. MinIoUpload_Audio_Dir = config["minio_upload_audio_dir"]
  369. MinIoAccessKeyId = config["minio_access_key_id"]
  370. MinIoAccessKeySecret = config["minio_access_key_secret"]
  371. MinIoUseSSL = config["minio_use_ssl"]
  372. MinIoPort = config["minio_port"]
  373. MinIoRegion = config["minio_region"]
  374. }
  375. // 初始化ES
  376. initEs()
  377. }