main.go 4.5KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152
  1. package main
  2. import (
  3. _ "gdyb/routers"
  4. "github.com/astaxie/beego"
  5. )
  6. func init() {
  7. //service.ConnectDB()
  8. //org_id, _ := beego.AppConfig.Int64("org_id")
  9. //miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
  10. //CreateLog(miConfig)
  11. //UploadLog(miConfig)
  12. }
  13. func main() {
  14. beego.Run()
  15. }
  16. //func CreateLog(miConfig models.MedicalInsuranceOrgConfig) {
  17. // Mkdir(miConfig.OrgName + "日志")
  18. // //org_id,_ := beego.AppConfig.Int("org_id")
  19. // month := time.Unix(1557042972, 0).Format("1")
  20. // year := time.Now().Format("2006")
  21. // month = time.Now().Format("01")
  22. // day := time.Now().Format("02")
  23. // file := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + year + month + day + "_log"
  24. // file_name := file + ".txt"
  25. // file_path := miConfig.OrgName + "日志" + "/" + file_name
  26. // exist, _ := PathExists(file_path)
  27. // if exist { //存在
  28. // fmt.Println("存在")
  29. // f, err := os.OpenFile(file_path, os.O_WRONLY, 0644)
  30. // if err != nil {
  31. // fmt.Println("read fail")
  32. // }
  33. // content := "\r\r\r"
  34. // n, _ := f.Seek(0, 2)
  35. // _, err = f.WriteAt([]byte(content), n)
  36. //
  37. // } else { //不存在
  38. // fmt.Println("文件不存在,创建文件")
  39. // f, err := os.Create(miConfig.OrgName + "日志" + "/" + file_name)
  40. // defer f.Close()
  41. // if err != nil {
  42. // } else {
  43. // _, err = f.Write([]byte("记录日志"))
  44. // }
  45. // }
  46. //
  47. //}
  48. //func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
  49. // //获取七牛云上的文件信息,不存在则表示没上传到七牛云,上传昨天日志信息
  50. // nTime := time.Now()
  51. // yesTime := nTime.AddDate(0, 0, -1)
  52. // file_key := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + yesTime.Format("20060102") + "_log.txt"
  53. // mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
  54. // cfg := storage.Config{
  55. // // 是否使用https域名进行资源管理
  56. // UseHTTPS: true,
  57. // }
  58. // // 指定空间所在的区域,如果不指定将自动探测
  59. // // 如果没有特殊需求,默认不需要指定
  60. // //cfg.Zone=&storage.ZoneHuabei
  61. // bucketManager := storage.NewBucketManager(mac, &cfg)
  62. // bucket := beego.AppConfig.String("qiniu_bucket")
  63. // key := file_key
  64. // file, sErr := bucketManager.Stat(bucket, key)
  65. // fmt.Println(file)
  66. // fmt.Println(sErr)
  67. // fmt.Println(miConfig.OrgName + "日志" + "/" + file_key)
  68. //
  69. // if sErr != nil {
  70. // fmt.Println("七牛云上文件不存在,上传到七牛云")
  71. // //判断本地文件是否存在,存在则执行上传操作
  72. // exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
  73. // if exist {
  74. // upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
  75. // } else {
  76. // fmt.Println("本地文件不存在")
  77. //
  78. // }
  79. // } else {
  80. // fmt.Println("七牛云文件存在")
  81. // }
  82. //
  83. //}
  84. //func Mkdir(dir string) {
  85. // // 创建文件夹
  86. // exist, err := PathExists(dir)
  87. // if err != nil {
  88. // fmt.Println(err.Error())
  89. // } else {
  90. // if exist {
  91. // fmt.Println(dir + "文件夹已存在!")
  92. // } else {
  93. // // 文件夹名称,权限
  94. // err := os.Mkdir(dir, os.ModePerm)
  95. // if err != nil {
  96. // fmt.Println(dir+"文件夹创建失败:", err.Error())
  97. // } else {
  98. // fmt.Println(dir + "文件夹创建成功!")
  99. // }
  100. // }
  101. // }
  102. //}
  103. //func PathExists(path string) (bool, error) {
  104. // _, err := os.Stat(path)
  105. // if err == nil {
  106. // return true, nil
  107. // }
  108. // if os.IsNotExist(err) {
  109. // return false, nil
  110. // }
  111. // return false, err
  112. //}
  113. //func upload_qiniu(filePath string, keys string) {
  114. // key := keys
  115. // //上传凭证,关于凭证这块大家可以去看看官方文档
  116. // putPolicy := storage.PutPolicy{
  117. // Scope: beego.AppConfig.String("qiniu_bucket"),
  118. // }
  119. // mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
  120. // upToken := putPolicy.UploadToken(mac)
  121. // cfg := storage.Config{}
  122. // //空间对应机房
  123. // //其中关于Zone对象和机房的关系如下:
  124. // // 机房 Zone对象
  125. // // 华东 storage.ZoneHuadong
  126. // // 华北 storage.ZoneHuabei
  127. // // 华南 storage.ZoneHuanan
  128. // // 北美 storage.ZoneBeimei
  129. // //七牛云存储空间设置首页有存储区域
  130. // cfg.Zone = &storage.ZoneHuadong
  131. // //不启用HTTPS域名
  132. // cfg.UseHTTPS = false
  133. // //不使用CND加速
  134. // cfg.UseCdnDomains = false
  135. // //构建上传表单对象
  136. // formUploader := storage.NewFormUploader(&cfg)
  137. // ret := storage.PutRet{}
  138. // // 可选
  139. // putExtra := storage.PutExtra{
  140. // Params: map[string]string{},
  141. // }
  142. // err := formUploader.PutFile(context.Background(), &ret, upToken, key, filePath, &putExtra)
  143. // if err != nil {
  144. // fmt.Println(err)
  145. // return
  146. // }
  147. // fmt.Println(ret.Key, ret.Hash)
  148. //}