|
@@ -1,8 +1,9 @@
|
1
|
1
|
package main
|
2
|
2
|
|
3
|
3
|
import (
|
4
|
|
- "context"
|
5
|
4
|
"gdyb/service"
|
|
5
|
+ "github.com/qiniu/api.v7/auth/qbox"
|
|
6
|
+ "github.com/qiniu/api.v7/storage"
|
6
|
7
|
|
7
|
8
|
//"gdyb/service"
|
8
|
9
|
|
|
@@ -10,8 +11,8 @@ import (
|
10
|
11
|
"fmt"
|
11
|
12
|
"gdyb/models"
|
12
|
13
|
//"gdyb/service"
|
13
|
|
- "github.com/qiniu/api.v7/auth/qbox"
|
14
|
|
- "github.com/qiniu/api.v7/storage"
|
|
14
|
+ //"github.com/qiniu/api.v7/auth/qbox"
|
|
15
|
+ //"github.com/qiniu/api.v7/storage"
|
15
|
16
|
"strconv"
|
16
|
17
|
"time"
|
17
|
18
|
|
|
@@ -34,13 +35,13 @@ import (
|
34
|
35
|
|
35
|
36
|
func init() {
|
36
|
37
|
service.ConnectDB()
|
37
|
|
- org_id, _ := beego.AppConfig.Int64("org_id")
|
38
|
|
- miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
|
39
|
|
- CreateLog(miConfig)
|
40
|
|
- UploadLog(miConfig)
|
41
|
|
- if org_id == 10191 {
|
42
|
|
- service.GetFjAuthorizationInfo(miConfig.Code)
|
43
|
|
- }
|
|
38
|
+ //org_id, _ := beego.AppConfig.Int64("org_id")
|
|
39
|
+ //miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
|
|
40
|
+ //CreateLog(miConfig)
|
|
41
|
+ //UploadLog(miConfig)
|
|
42
|
+ //if org_id == 10191 {
|
|
43
|
+ // service.GetFjAuthorizationInfo(miConfig.Code)
|
|
44
|
+ //}
|
44
|
45
|
}
|
45
|
46
|
func main() {
|
46
|
47
|
beego.Run()
|
|
@@ -861,7 +862,7 @@ func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
|
861
|
862
|
//判断本地文件是否存在,存在则执行上传操作
|
862
|
863
|
exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
|
863
|
864
|
if exist {
|
864
|
|
- upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
|
|
865
|
+ //upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
|
865
|
866
|
} else {
|
866
|
867
|
fmt.Println("本地文件不存在")
|
867
|
868
|
|
|
@@ -901,39 +902,39 @@ func PathExists(path string) (bool, error) {
|
901
|
902
|
return false, err
|
902
|
903
|
}
|
903
|
904
|
|
904
|
|
-func upload_qiniu(filePath string, keys string) {
|
905
|
|
- key := keys
|
906
|
|
- //上传凭证,关于凭证这块大家可以去看看官方文档
|
907
|
|
- putPolicy := storage.PutPolicy{
|
908
|
|
- Scope: beego.AppConfig.String("qiniu_bucket"),
|
909
|
|
- }
|
910
|
|
- mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
|
911
|
|
- upToken := putPolicy.UploadToken(mac)
|
912
|
|
- cfg := storage.Config{}
|
913
|
|
- //空间对应机房
|
914
|
|
- //其中关于Zone对象和机房的关系如下:
|
915
|
|
- // 机房 Zone对象
|
916
|
|
- // 华东 storage.ZoneHuadong
|
917
|
|
- // 华北 storage.ZoneHuabei
|
918
|
|
- // 华南 storage.ZoneHuanan
|
919
|
|
- // 北美 storage.ZoneBeimei
|
920
|
|
- //七牛云存储空间设置首页有存储区域
|
921
|
|
- cfg.Zone = &storage.ZoneHuadong
|
922
|
|
- //不启用HTTPS域名
|
923
|
|
- cfg.UseHTTPS = false
|
924
|
|
- //不使用CND加速
|
925
|
|
- cfg.UseCdnDomains = false
|
926
|
|
- //构建上传表单对象
|
927
|
|
- formUploader := storage.NewFormUploader(&cfg)
|
928
|
|
- ret := storage.PutRet{}
|
929
|
|
- // 可选
|
930
|
|
- putExtra := storage.PutExtra{
|
931
|
|
- Params: map[string]string{},
|
932
|
|
- }
|
933
|
|
- err := formUploader.PutFile(context.Background(), &ret, upToken, key, filePath, &putExtra)
|
934
|
|
- if err != nil {
|
935
|
|
- fmt.Println(err)
|
936
|
|
- return
|
937
|
|
- }
|
938
|
|
- fmt.Println(ret.Key, ret.Hash)
|
939
|
|
-}
|
|
905
|
+//func upload_qiniu(filePath string, keys string) {
|
|
906
|
+// key := keys
|
|
907
|
+// //上传凭证,关于凭证这块大家可以去看看官方文档
|
|
908
|
+// putPolicy := storage.PutPolicy{
|
|
909
|
+// Scope: beego.AppConfig.String("qiniu_bucket"),
|
|
910
|
+// }
|
|
911
|
+// mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
|
|
912
|
+// upToken := putPolicy.UploadToken(mac)
|
|
913
|
+// cfg := storage.Config{}
|
|
914
|
+// //空间对应机房
|
|
915
|
+// //其中关于Zone对象和机房的关系如下:
|
|
916
|
+// // 机房 Zone对象
|
|
917
|
+// // 华东 storage.ZoneHuadong
|
|
918
|
+// // 华北 storage.ZoneHuabei
|
|
919
|
+// // 华南 storage.ZoneHuanan
|
|
920
|
+// // 北美 storage.ZoneBeimei
|
|
921
|
+// //七牛云存储空间设置首页有存储区域
|
|
922
|
+// cfg.Zone = &storage.ZoneHuadong
|
|
923
|
+// //不启用HTTPS域名
|
|
924
|
+// cfg.UseHTTPS = false
|
|
925
|
+// //不使用CND加速
|
|
926
|
+// cfg.UseCdnDomains = false
|
|
927
|
+// //构建上传表单对象
|
|
928
|
+// formUploader := storage.NewFormUploader(&cfg)
|
|
929
|
+// ret := storage.PutRet{}
|
|
930
|
+// // 可选
|
|
931
|
+// putExtra := storage.PutExtra{
|
|
932
|
+// Params: map[string]string{},
|
|
933
|
+// }
|
|
934
|
+// err := formUploader.PutFile(context.Background(), &ret, upToken, key, filePath, &putExtra)
|
|
935
|
+// if err != nil {
|
|
936
|
+// fmt.Println(err)
|
|
937
|
+// return
|
|
938
|
+// }
|
|
939
|
+// fmt.Println(ret.Key, ret.Hash)
|
|
940
|
+//}
|