config.go 8.9 KB

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