config.go 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245
  1. package utils
  2. import (
  3. "fmt"
  4. beeLogger "github.com/beego/bee/v2/logger"
  5. "github.com/beego/beego/v2/server/web"
  6. "strconv"
  7. )
  8. var (
  9. RunMode string //运行模式
  10. )
  11. // 公共api内部服务调用
  12. var (
  13. // EDB_LIB_URL 公共指标库
  14. EDB_LIB_URL string
  15. APP_EDB_LIB_NAME_EN string
  16. EDB_LIB_Md5_KEY string
  17. OpUserId int // 操作人id
  18. OpUserRealName string // 操作人真实名称
  19. )
  20. // 弘则
  21. const (
  22. APPID = "SJCrpOPvagscPxEv"
  23. SECRET = "gLLjT72uFHQZEFtaFCuoZegD1z2ezfyX"
  24. )
  25. // 日志配置
  26. var (
  27. LogPath string //调用过程中的日志存放地址
  28. LogFile string
  29. BinLogPath string //数据库相关的日志存放地址
  30. BinLogFile string
  31. LogMaxDays int //日志最大保留天数
  32. )
  33. // 涌益生猪
  34. var (
  35. YongyiFilePath string //excel文件地址
  36. YongyiReadFilePath string //已读的excel文件地址
  37. YongyiOpen string //是否配置涌益生猪数据源,1已配置
  38. YongyiDownloadHost string
  39. )
  40. // 中国煤炭网
  41. var (
  42. CoalMineFilePath string //excel文件地址
  43. CoalMineOpen string //是否配置中国煤炭网数据源,1已配置
  44. CoalMailAttachmentScriptPath string // 获取邮件附件的脚本目录
  45. CoalMailAttachmentOpen string // 获取邮件附件功能,1已配置
  46. CoalMailAttachmentTime string // 获取邮件附件功能时间
  47. CoalMailAttachmentPythonVersion string // 获取邮件附件功能python版本
  48. )
  49. // 汾渭煤炭
  50. var (
  51. FenweiFileDir string // excel文件目录
  52. FenweiOldFileDir string // 已读取过的excel文件目录
  53. FenweiOpen string // 是否配置汾渭数据源
  54. FenweiNetOpen string // 是否配置汾渭网页数据源
  55. FenweiNetUseName string // 汾渭登录账号
  56. FenweiNetPassword string // 汾渭登录密码
  57. FenweiNetJsonPath string // 汾渭json文件地址
  58. )
  59. // 煤炭江湖
  60. var (
  61. MtjhFilePath string //excel文件地址
  62. MtjhOpen string //是否配置煤炭江湖数据源,1已配置
  63. )
  64. // 粮油商务网
  65. var (
  66. LY_USERNAME string
  67. LY_PASSWORD string
  68. LY_JSON_PATH string
  69. LY_OPEN string
  70. )
  71. // 睿姿得数据
  72. var (
  73. RZD_USERNAME string
  74. RZD_PASSWORD string
  75. RZD_EXCEL_PATH string
  76. RZD_OPEN string
  77. RZD_DOWNLOAD_PATH string
  78. )
  79. // CCF化纤信息
  80. var (
  81. CCFOpen string // 是否配置CCF
  82. CCFCookieFile string // CCF登录Cookie
  83. CCFDataRuleFile string // CCF数据爬取规则
  84. CCFDailyTaskTime string // CCF数据日度任务时间
  85. CCFWeeklyTaskTime string // CCF数据周度任务时间
  86. CCFStockTaskTime string // CCF数据装置任务时间
  87. CCFUseName string // CCF登录账号
  88. CCFPassword string // CCF登录密码
  89. CCFDailyFetchNum int // CCF数据日度每次获取报告数量
  90. CCFWeeklyFetchNum int // CCF数据周度每次获取报告数量
  91. CCFStockFetchNum int // CCF数据装置每次获取报告数量
  92. )
  93. var (
  94. OilchemAccount string
  95. OilchemPassword string
  96. OilchemCookieFile string
  97. OilchemOpen string
  98. OilchemDataInit string
  99. )
  100. var TerminalCode string
  101. func init() {
  102. tmpRunMode, err := web.AppConfig.String("run_mode")
  103. if err != nil {
  104. panic("配置文件读取run_mode错误 " + err.Error())
  105. }
  106. RunMode = tmpRunMode
  107. fmt.Println("RunMode:", RunMode)
  108. config, err := web.AppConfig.GetSection(RunMode)
  109. if err != nil {
  110. panic("配置文件读取错误 " + err.Error())
  111. }
  112. beeLogger.Log.Info(RunMode + " 模式")
  113. // 公共api内部服务调用
  114. {
  115. // 公共指标库相关
  116. EDB_LIB_URL = config["edb_lib_url"]
  117. APP_EDB_LIB_NAME_EN = config["app_edb_lib_name_en"]
  118. EDB_LIB_Md5_KEY = config["edb_lib_md5_key"]
  119. opUserIdStr := config["op_user_id"]
  120. if opUserIdStr != `` {
  121. OpUserId, err = strconv.Atoi(opUserIdStr)
  122. if err != nil {
  123. panic("配置文件中操作人配置错误 " + err.Error())
  124. }
  125. }
  126. OpUserRealName = config["op_user_real_name"]
  127. }
  128. //日志配置
  129. {
  130. LogPath = config["log_path"]
  131. LogFile = config["log_file"]
  132. BinLogPath = config["binlog_path"]
  133. BinLogFile = config["binlog_file"]
  134. logMaxDaysStr := config["log_max_day"]
  135. LogMaxDays, _ = strconv.Atoi(logMaxDaysStr)
  136. }
  137. //涌益咨询文件夹配置
  138. {
  139. YongyiFilePath = config["yongyi_file_path"]
  140. YongyiReadFilePath = config["yongyi_read_file_path"]
  141. YongyiOpen = config["yongyi_open"]
  142. YongyiDownloadHost = config["yongyi_download_host"]
  143. if YongyiDownloadHost == "" {
  144. YongyiDownloadHost = "http://127.0.0.1:7010/"
  145. }
  146. }
  147. //中国煤炭网文件夹配置
  148. {
  149. CoalMineFilePath = config["coal_mine_file_path"]
  150. CoalMineOpen = config["coal_mine_open"]
  151. CoalMailAttachmentScriptPath = config["coal_mail_attachment_script_path"]
  152. CoalMailAttachmentOpen = config["coal_mail_attachment_open"]
  153. CoalMailAttachmentTime = config["coal_mail_attachment_time"]
  154. CoalMailAttachmentPythonVersion = config["coal_mail_attachment_python_version"]
  155. }
  156. // 汾渭配置
  157. {
  158. FenweiOpen = config["fenwei_open"]
  159. FenweiFileDir = config["fenwei_file_dir"]
  160. FenweiOldFileDir = config["fenwei_old_file_dir"]
  161. FenweiNetOpen = config["fenwei_net_open"]
  162. FenweiNetUseName = config["fenwei_net_username"]
  163. FenweiNetPassword = config["fenwei_net_password"]
  164. FenweiNetJsonPath = config["fenwei_net_json_path"]
  165. }
  166. //煤炭江湖文件夹配置
  167. {
  168. MtjhFilePath = config["mtjh_file_path"]
  169. MtjhOpen = config["mtjh_open"]
  170. }
  171. TerminalCode = config["terminal_code"]
  172. // CCF化纤信息
  173. {
  174. CCFOpen = config["ccf_open"]
  175. CCFCookieFile = config["ccf_cookie_file"]
  176. CCFDataRuleFile = config["ccf_data_rule_file"]
  177. CCFDailyTaskTime = config["ccf_daily_task_time"]
  178. CCFWeeklyTaskTime = config["ccf_weekly_task_time"]
  179. CCFStockTaskTime = config["ccf_stock_task_time"]
  180. CCFUseName = config["ccf_username"]
  181. CCFPassword = config["ccf_password"]
  182. CCFDailyFetchNum, _ = strconv.Atoi(config["ccf_daily_fetch_num"])
  183. if CCFDailyFetchNum <= 0 {
  184. CCFDailyFetchNum = 7
  185. }
  186. CCFWeeklyFetchNum, _ = strconv.Atoi(config["ccf_weekly_fetch_num"])
  187. if CCFWeeklyFetchNum <= 0 {
  188. CCFWeeklyFetchNum = 3
  189. }
  190. CCFStockFetchNum, _ = strconv.Atoi(config["ccf_stock_fetch_num"])
  191. if CCFStockFetchNum <= 0 {
  192. CCFStockFetchNum = 3
  193. }
  194. }
  195. {
  196. LY_USERNAME = config["ly_username"]
  197. LY_PASSWORD = config["ly_password"]
  198. LY_JSON_PATH = config["ly_json_path"]
  199. LY_OPEN = config["ly_open"]
  200. }
  201. {
  202. RZD_USERNAME = config["rzd_username"]
  203. RZD_PASSWORD = config["rzd_password"]
  204. RZD_EXCEL_PATH = config["rzd_excel_path"]
  205. RZD_OPEN = config["rzd_open"]
  206. RZD_DOWNLOAD_PATH = config["rzd_download_path"]
  207. }
  208. // 隆众数据
  209. {
  210. OilchemAccount = config["oilchem_account"]
  211. OilchemPassword = config["oilchem_password"]
  212. OilchemCookieFile = config["oilchem_cookie_file"]
  213. OilchemOpen = config["oilchem_open"]
  214. OilchemDataInit = config["oilchem_data_init"]
  215. }
  216. }
  217. //修改接口文档
  218. //http://8.136.199.33:8300/swagger/