config.go 11 KB

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