config.go 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298
  1. package utils
  2. import (
  3. "fmt"
  4. beego "github.com/beego/beego/v2/adapter"
  5. "github.com/beego/beego/v2/server/web"
  6. "strconv"
  7. )
  8. var (
  9. RunMode string //运行模式
  10. MYSQL_URL string //数据库连接
  11. MYSQL_URL_RDDP string //数据库连接
  12. MYSQL_URL_EDB string
  13. MYSQL_URL_DATA string
  14. MYSQL_URL_GL string
  15. MYSQL_URL_ETA string
  16. REDIS_CACHE string //缓存地址
  17. //Rc *cache.Cache //redis缓存
  18. Re error //redis错误
  19. Rc RedisClient //redis缓存
  20. )
  21. var (
  22. LogPath string
  23. LogFile string
  24. BinLogPath string
  25. BinLogFile string
  26. LogMaxDays int //日志最大保留天数
  27. )
  28. var (
  29. APPNAME string //项目中文名称
  30. EmailSendToUsers string // 邮件提醒人员
  31. RefreshEdbInfoEmailSendToUsers string // 刷新完成通知邮件人员
  32. // AlarmMsgUrl 报警服务地址
  33. AlarmMsgUrl string
  34. )
  35. // 经济数据库
  36. var (
  37. EDB_LIB_URL string
  38. APP_EDB_LIB_NAME_EN string
  39. EDB_LIB_Md5_KEY string
  40. )
  41. // 公共数据服务接口参数
  42. var (
  43. APPID string
  44. SECRET string
  45. )
  46. var (
  47. WxAppId string
  48. WxAppSecret string
  49. TemplateId string
  50. RemindTemplateId string
  51. AppointmentRemindTemplateId string //活动预约通知模板id
  52. YbCommonTemplateId string //研报小程序消息模板ID
  53. SendWxTemplateEnable string //是否开启模版消息,1是发送,其他不发送
  54. WxYbAppId string //微信研报小程序
  55. //内部员工公众号(弘则部门)
  56. AdminWxAppId string
  57. AdminWxAppSecret string
  58. )
  59. // 模板消息推送
  60. var (
  61. SendWxTemplateMsgUrl string
  62. )
  63. // BusinessCode 商家编码
  64. var (
  65. BusinessCode string //商户号
  66. WindServerUrl string //wind api 接口服务器地址
  67. LtServerUrl string //路透 api 接口服务器地址
  68. PbServerUrl string //彭博 api 接口服务器地址
  69. )
  70. // ES配置
  71. var (
  72. ES_URL string // ES服务器地址
  73. ES_USERNAME string // ES账号
  74. ES_PASSWORD string // ES密码
  75. )
  76. // ES索引配置
  77. var (
  78. EsReportIndexName string //研报ES索引
  79. EsEnglishReportIndexName string //英文研报ES索引
  80. SmartReportIndexName string //智能研报ES索引
  81. )
  82. // 科大讯飞--语音合成
  83. var (
  84. XfHostUrl string
  85. )
  86. var (
  87. TemplateIdByProduct string //产品运行报告通知-模板ID
  88. )
  89. // 阿里云配置
  90. var (
  91. Bucketname string
  92. Endpoint string
  93. Imghost string
  94. UploadDir string
  95. Upload_Audio_Dir string
  96. AccessKeyId string
  97. AccessKeySecret string
  98. )
  99. var (
  100. // 是否xy
  101. IsXy string
  102. IsPCSG string
  103. )
  104. var (
  105. EtaBridgeUrl string // 桥接服务地址
  106. EtaBridgeAppNameEn string // 桥接服务英文名称-鉴权用
  107. EtaBridgeMd5Key string // 桥接服务Md5密钥-鉴权用
  108. EtaBridgeDesKey string // 桥接服务Des密钥-解密数据用
  109. SyncUserPath string // 桥接服务-用户同步服务地址
  110. SyncUserTime string // 桥接服务-用户同步的时间配置
  111. SyncIndexPath string // 桥接服务-指标同步服务地址
  112. SyncIndexTime string // 桥接服务-指标同步的时间配置
  113. SyncIndexClassifyTime string // 桥接服务-指标分类同步的时间配置
  114. )
  115. var (
  116. PbRefreshFrequency string // 彭博更新频度
  117. PbRefreshOpen string // 彭博刷新开关 0关闭,默认都是开启的
  118. )
  119. var HzDataApi string
  120. func init() {
  121. tmpRunMode, err := web.AppConfig.String("run_mode")
  122. if err != nil {
  123. panic("配置文件读取run_mode错误 " + err.Error())
  124. }
  125. RunMode = tmpRunMode
  126. if RunMode == "" {
  127. localIp, err := GetLocalIP()
  128. fmt.Println("localIp:", localIp)
  129. if localIp == "10.0.0.123" {
  130. RunMode = "debug"
  131. } else {
  132. RunMode = "release"
  133. }
  134. //RunMode = "release"
  135. configPath := `/home/code/config/eta_task/conf/app.conf`
  136. err = web.LoadAppConfig("ini", configPath)
  137. if err != nil {
  138. fmt.Println("web.LoadAppConfig Err:" + err.Error())
  139. }
  140. }
  141. config, err := web.AppConfig.GetSection(RunMode)
  142. if err != nil {
  143. panic("配置文件读取错误 " + err.Error())
  144. }
  145. beego.Info(RunMode + " 模式")
  146. MYSQL_URL = config["mysql_url"]
  147. MYSQL_URL_RDDP = config["mysql_url_rddp"]
  148. MYSQL_URL_EDB = config["mysql_url_edb"]
  149. MYSQL_URL_DATA = config["mysql_url_data"]
  150. MYSQL_URL_GL = config["mysql_url_gl"]
  151. MYSQL_URL_ETA = config["mysql_url_eta"]
  152. REDIS_CACHE = config["beego_cache"]
  153. if len(REDIS_CACHE) <= 0 {
  154. panic(any("redis链接参数没有配置"))
  155. }
  156. //Rc, Re = cache.NewCache(REDIS_CACHE) //初始化缓存
  157. //if Re != nil {
  158. // fmt.Println(Re)
  159. // panic(any(Re))
  160. //}
  161. // 初始化缓存
  162. redisClient, err := initRedis(config["redis_type"], config["beego_cache"])
  163. if err != nil {
  164. fmt.Println("redis链接异常:", err)
  165. panic(any(Re))
  166. }
  167. Rc = redisClient
  168. // 项目中文名称
  169. appNameCn, err := web.AppConfig.String("app_name_cn")
  170. if err != nil {
  171. panic(any("配置文件读取app_name_cn错误 " + err.Error()))
  172. }
  173. APPNAME = appNameCn
  174. {
  175. LogPath = config["log_path"]
  176. LogFile = config["log_file"]
  177. BinLogPath = config["binlog_path"]
  178. BinLogFile = config["binlog_file"]
  179. logMaxDaysStr := config["log_max_day"]
  180. LogMaxDays, _ = strconv.Atoi(logMaxDaysStr)
  181. }
  182. // 邮件提醒人员
  183. EmailSendToUsers = config["email_send_to_users"]
  184. // 刷新完成通知邮件人员
  185. RefreshEdbInfoEmailSendToUsers = config["refresh_edb_info_email_send_to_users"]
  186. // 报警服务地址
  187. AlarmMsgUrl = config["alarm_msg_url"]
  188. // 公共指标库相关
  189. {
  190. EDB_LIB_URL = config["edb_lib_url"]
  191. APP_EDB_LIB_NAME_EN = config["app_edb_lib_name_en"]
  192. EDB_LIB_Md5_KEY = config["edb_lib_md5_key"]
  193. }
  194. APPID = config["appid"]
  195. SECRET = config["secret"]
  196. // 商家编码
  197. BusinessCode = config["business_code"]
  198. //服务检测
  199. WindServerUrl = config["wind_server_url"]
  200. LtServerUrl = config["lt_server_url"]
  201. PbServerUrl = config["pb_server_url"]
  202. // ES配置
  203. {
  204. ES_URL = config["es_url"]
  205. ES_USERNAME = config["es_username"]
  206. ES_PASSWORD = config["es_password"]
  207. }
  208. // ES 索引
  209. {
  210. EsReportIndexName = config["es_report_index_name"]
  211. EsEnglishReportIndexName = config["es_english_report_index_name"]
  212. SmartReportIndexName = config["es_smart_report_index_name"]
  213. }
  214. // 科大讯飞
  215. {
  216. XfHostUrl = config["xf_host_url"]
  217. }
  218. // OSS相关
  219. {
  220. Endpoint = config["endpoint"]
  221. Bucketname = config["bucket_name"]
  222. Imghost = config["img_host"]
  223. UploadDir = config["upload_dir"]
  224. Upload_Audio_Dir = config["upload_audio_dir"]
  225. AccessKeyId = config["access_key_id"]
  226. AccessKeySecret = config["access_key_secret"]
  227. }
  228. // 微信模版消息
  229. {
  230. SendWxTemplateEnable = config["send_wx_template_enable"]
  231. }
  232. // 客户信息
  233. {
  234. IsXy = config["is_xy"]
  235. IsPCSG = config["is_pcsg"]
  236. }
  237. // 桥接服务
  238. {
  239. EtaBridgeUrl = config["eta_bridge_url"] // 桥接服务地址
  240. EtaBridgeAppNameEn = config["eta_bridge_app_name_en"] // 桥接服务英文名称-鉴权用
  241. EtaBridgeMd5Key = config["eta_bridge_md5_key"] // 桥接服务Md5密钥-鉴权用
  242. EtaBridgeDesKey = config["eta_bridge_des_key"] // 桥接服务Des密钥-解密数据用
  243. SyncUserPath = config["sync_user_path"] // 桥接服务-用户同步服务地址
  244. SyncUserTime = config["sync_user_time"] // 桥接服务-用户同步的时间配置
  245. SyncIndexPath = config["sync_index_path"] // 桥接服务-指标同步服务地址
  246. SyncIndexTime = config["sync_index_time"] // 桥接服务-指标同步的时间配置
  247. SyncIndexClassifyTime = config["sync_index_classify_time"] // 桥接服务-指标分类同步的时间配置
  248. }
  249. HzDataApi = config["hz_data_api"]
  250. if HzDataApi == "" {
  251. HzDataApi = "https://hzdataapi.hzinsights.com/hzdataapi/"
  252. }
  253. // 彭博刷新频度
  254. PbRefreshFrequency = config["pb_refresh_frequency"]
  255. // 彭博刷新开关
  256. PbRefreshOpen = config["pb_refresh_open"]
  257. }