|
@@ -1,15 +1,14 @@
|
1
|
1
|
package main
|
2
|
2
|
|
3
|
3
|
import (
|
4
|
|
- "context"
|
5
|
|
-
|
|
4
|
+ "gdyb/service"
|
6
|
5
|
|
7
|
6
|
|
8
|
7
|
"fmt"
|
9
|
8
|
"gdyb/models"
|
10
|
9
|
|
11
|
|
- "github.com/qiniu/api.v7/auth/qbox"
|
12
|
|
- "github.com/qiniu/api.v7/storage"
|
|
10
|
+
|
|
11
|
+
|
13
|
12
|
"strconv"
|
14
|
13
|
"time"
|
15
|
14
|
|
|
@@ -31,7 +30,7 @@ import (
|
31
|
30
|
)
|
32
|
31
|
|
33
|
32
|
func init() {
|
34
|
|
-
|
|
33
|
+ service.ConnectDB()
|
35
|
34
|
|
36
|
35
|
|
37
|
36
|
|
|
@@ -833,42 +832,42 @@ func CreateLog(miConfig models.MedicalInsuranceOrgConfig) {
|
833
|
832
|
|
834
|
833
|
}
|
835
|
834
|
|
836
|
|
-func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
|
837
|
|
-
|
838
|
|
- nTime := time.Now()
|
839
|
|
- yesTime := nTime.AddDate(0, 0, -1)
|
840
|
|
- file_key := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + yesTime.Format("20060102") + "_log.txt"
|
841
|
|
- mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
|
842
|
|
- cfg := storage.Config{
|
843
|
|
-
|
844
|
|
- UseHTTPS: true,
|
845
|
|
- }
|
846
|
|
-
|
847
|
|
-
|
848
|
|
-
|
849
|
|
- bucketManager := storage.NewBucketManager(mac, &cfg)
|
850
|
|
- bucket := beego.AppConfig.String("qiniu_bucket")
|
851
|
|
- key := file_key
|
852
|
|
- file, sErr := bucketManager.Stat(bucket, key)
|
853
|
|
- fmt.Println(file)
|
854
|
|
- fmt.Println(sErr)
|
855
|
|
- fmt.Println(miConfig.OrgName + "日志" + "/" + file_key)
|
856
|
|
-
|
857
|
|
- if sErr != nil {
|
858
|
|
- fmt.Println("七牛云上文件不存在,上传到七牛云")
|
859
|
|
-
|
860
|
|
- exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
|
861
|
|
- if exist {
|
862
|
|
- upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
|
863
|
|
- } else {
|
864
|
|
- fmt.Println("本地文件不存在")
|
865
|
|
-
|
866
|
|
- }
|
867
|
|
- } else {
|
868
|
|
- fmt.Println("七牛云文件存在")
|
869
|
|
- }
|
870
|
|
-
|
871
|
|
-}
|
|
835
|
+
|
|
836
|
+
|
|
837
|
+
|
|
838
|
+
|
|
839
|
+
|
|
840
|
+
|
|
841
|
+
|
|
842
|
+
|
|
843
|
+
|
|
844
|
+
|
|
845
|
+
|
|
846
|
+
|
|
847
|
+
|
|
848
|
+
|
|
849
|
+
|
|
850
|
+
|
|
851
|
+
|
|
852
|
+
|
|
853
|
+
|
|
854
|
+
|
|
855
|
+
|
|
856
|
+
|
|
857
|
+
|
|
858
|
+
|
|
859
|
+
|
|
860
|
+
|
|
861
|
+
|
|
862
|
+
|
|
863
|
+
|
|
864
|
+
|
|
865
|
+
|
|
866
|
+
|
|
867
|
+
|
|
868
|
+
|
|
869
|
+
|
|
870
|
+
|
872
|
871
|
func Mkdir(dir string) {
|
873
|
872
|
|
874
|
873
|
exist, err := PathExists(dir)
|
|
@@ -899,39 +898,39 @@ func PathExists(path string) (bool, error) {
|
899
|
898
|
return false, err
|
900
|
899
|
}
|
901
|
900
|
|
902
|
|
-func upload_qiniu(filePath string, keys string) {
|
903
|
|
- key := keys
|
904
|
|
-
|
905
|
|
- putPolicy := storage.PutPolicy{
|
906
|
|
- Scope: beego.AppConfig.String("qiniu_bucket"),
|
907
|
|
- }
|
908
|
|
- mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
|
909
|
|
- upToken := putPolicy.UploadToken(mac)
|
910
|
|
- cfg := storage.Config{}
|
911
|
|
-
|
912
|
|
-
|
913
|
|
-
|
914
|
|
-
|
915
|
|
-
|
916
|
|
-
|
917
|
|
-
|
918
|
|
-
|
919
|
|
- cfg.Zone = &storage.ZoneHuadong
|
920
|
|
-
|
921
|
|
- cfg.UseHTTPS = false
|
922
|
|
-
|
923
|
|
- cfg.UseCdnDomains = false
|
924
|
|
-
|
925
|
|
- formUploader := storage.NewFormUploader(&cfg)
|
926
|
|
- ret := storage.PutRet{}
|
927
|
|
-
|
928
|
|
- putExtra := storage.PutExtra{
|
929
|
|
- Params: map[string]string{},
|
930
|
|
- }
|
931
|
|
- err := formUploader.PutFile(context.Background(), &ret, upToken, key, filePath, &putExtra)
|
932
|
|
- if err != nil {
|
933
|
|
- fmt.Println(err)
|
934
|
|
- return
|
935
|
|
- }
|
936
|
|
- fmt.Println(ret.Key, ret.Hash)
|
937
|
|
-}
|
|
901
|
+
|
|
902
|
+
|
|
903
|
+
|
|
904
|
+
|
|
905
|
+
|
|
906
|
+
|
|
907
|
+
|
|
908
|
+
|
|
909
|
+
|
|
910
|
+
|
|
911
|
+
|
|
912
|
+
|
|
913
|
+
|
|
914
|
+
|
|
915
|
+
|
|
916
|
+
|
|
917
|
+
|
|
918
|
+
|
|
919
|
+
|
|
920
|
+
|
|
921
|
+
|
|
922
|
+
|
|
923
|
+
|
|
924
|
+
|
|
925
|
+
|
|
926
|
+
|
|
927
|
+
|
|
928
|
+
|
|
929
|
+
|
|
930
|
+
|
|
931
|
+
|
|
932
|
+
|
|
933
|
+
|
|
934
|
+
|
|
935
|
+
|
|
936
|
+
|