Roc 1 year ago
parent
commit
882c028851
2 changed files with 3 additions and 7 deletions
  1. 1 6
      services/data/base_edb_lib.go
  2. 2 1
      services/data/edb_info.go

+ 1 - 6
services/data/base_edb_lib.go

@@ -103,12 +103,7 @@ func HttpPost(url, postData string, params ...string) ([]byte, error) {
 		contentType = params[0]
 	}
 	req.Header.Set("Content-Type", contentType)
-	authorization := utils.MD5(utils.APP_EDB_LIB_NAME_EN + utils.EDB_LIB_Md5_KEY)
-	fmt.Println("name:", utils.APP_EDB_LIB_NAME_EN, ",md5_key:", utils.EDB_LIB_Md5_KEY, ";")
-	fmt.Println(utils.APP_EDB_LIB_NAME_EN)
-	fmt.Println(utils.EDB_LIB_Md5_KEY)
-	fmt.Println("authorization:", authorization)
-	req.Header.Set("authorization", authorization)
+	req.Header.Set("authorization", utils.MD5(utils.APP_EDB_LIB_NAME_EN+utils.EDB_LIB_Md5_KEY))
 	resp, err := client.Do(req)
 	defer resp.Body.Close()
 	b, err := ioutil.ReadAll(resp.Body)

+ 2 - 1
services/data/edb_info.go

@@ -68,7 +68,7 @@ func RefreshDataFromWind(wg *sync.WaitGroup) (err error) {
 	}()
 	var condition string
 	var pars []interface{}
-	condition += ` AND source=? AND no_update = 0 `
+	condition += ` AND source=? AND no_update = 0 AND is_update = 1`
 	pars = append(pars, utils.DATA_SOURCE_WIND)
 
 	items, err := data_manage.GetEdbInfoByCondition(condition, pars, 0)
@@ -76,6 +76,7 @@ func RefreshDataFromWind(wg *sync.WaitGroup) (err error) {
 		return err
 	}
 	for _, v := range items {
+		fmt.Println(v.EdbCode, "start refresh")
 		startDate := ""
 		if v.Frequency == "日度" {
 			startDate = v.EndDate.AddDate(0, 0, -utils.DATA_REFRESH).Format(utils.FormatDate)