新增隆众调研数据

services/data_source_longzhong.go

@@ -220,10 +220,10 @@ func GetLzProductList(cont context.Context) (err error) {
 }
 
 func GetLzProductDetail(cont context.Context) (err error) {
-	utils.LzFileLog.Info("start GetLzProductDetail")
+	utils.FileLogLz.Info("start GetLzProductDetail")
 	defer func() {
 		if err != nil {
-			utils.LzFileLog.Info("Err:" + err.Error())
+			utils.FileLogLz.Info("Err:" + err.Error())
 			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"GetLzProductDetail：失败提醒", "ErrMsg:"+err.Error(), utils.EmailSendToUsers)
 		}
 	}()
@@ -250,7 +250,7 @@ func GetLzProductDetail(cont context.Context) (err error) {
 			}
 
 			fmt.Println("page:", i, totalPage)
-			utils.LzFileLog.Info("Page:%s", strconv.Itoa(i))
+			utils.FileLogLz.Info("Page:%s", strconv.Itoa(i))
 			timestamp := fmt.Sprintf("%d", time.Now().Unix())
 			token := utils.MD5(username + timestamp + utils.MD5(password))
 
@@ -264,18 +264,18 @@ func GetLzProductDetail(cont context.Context) (err error) {
 			param.Add("endDate", endDate)
 			param.Add("pagesize", strconv.Itoa(pageSize))
 			param.Add("page", strconv.Itoa(i))
-			utils.LzFileLog.Info("GetLzProductDetail Param: %s", param.Encode())
+			utils.FileLogLz.Info("GetLzProductDetail Param: %s", param.Encode())
 			body, err := http.Post(postUrl, param.Encode())
 
 			if err != nil {
-				utils.LzFileLog.Info("Post Err:%s", err.Error())
+				utils.FileLogLz.Info("Post Err:%s", err.Error())
 				return err
 			}
-			utils.LzFileLog.Info("GetLzProductDetail Result: %s", string(body))
+			utils.FileLogLz.Info("GetLzProductDetail Result: %s", string(body))
 			resp := new(models.LzProductInfoDetailResp)
 			err = json.Unmarshal(body, &resp)
 			if err != nil {
-				utils.LzFileLog.Info("Unmarshal Err:%s", err.Error())
+				utils.FileLogLz.Info("Unmarshal Err:%s", err.Error())
 				return err
 			}
 			if resp.Code != "1" {
@@ -318,7 +318,7 @@ func GetLzProductDetail(cont context.Context) (err error) {
 					lzdetail.DisplayTime = v.DisplayTime
 					err = models.ModifyLongzhongdata(lzdetail)
 					if err != nil {
-						utils.LzFileLog.Info("ModifyLongzhongdata Err:" + err.Error())
+						utils.FileLogLz.Info("ModifyLongzhongdata Err:" + err.Error())
 						continue
 					}
 				} else {
@@ -335,7 +335,7 @@ func GetLzProductDetail(cont context.Context) (err error) {
 					lzdetail.DisplayTime = v.DisplayTime
 					err = models.AddLongzhongdata(lzdetail)
 					if err != nil {
-						utils.LzFileLog.Info("AddLongzhongdata Err:" + err.Error())
+						utils.FileLogLz.Info("AddLongzhongdata Err:" + err.Error())
 						continue
 					}
 				}
@@ -344,7 +344,7 @@ func GetLzProductDetail(cont context.Context) (err error) {
 			//time.Sleep(1 * time.Second)
 		}
 	}
-	utils.LzFileLog.Info("end GetLzProductDetail")
+	utils.FileLogLz.Info("end GetLzProductDetail")
 	return
 }
 
@@ -945,6 +945,7 @@ func LzPriceExportExcel() {
 
 //隆众-调研指标
 func GetLzSurveyProduct(cont context.Context) (err error) {
+	utils.FileLogLz.Info("GetLzSurveyProduct start:" + time.Now().Format(utils.FormatDateTime))
 	var msg string
 	defer func() {
 		if err != nil {
@@ -964,12 +965,14 @@ func GetLzSurveyProduct(cont context.Context) (err error) {
 	for {
 		pageIndex++
 		getUrl := `https://openapi.oilchem.net/research/getProduct?passWord=` + password + `&userName=` + username + `&pageSize=100&pageNum=` + strconv.Itoa(pageIndex)
+
+		utils.FileLogLz.Info("GetLzSurveyProduct getUrl:" + getUrl)
 		body, err := http.Get(getUrl)
 		if err != nil {
 			msg = "获取隆众调研指标失败:Err" + err.Error()
 			return err
 		}
-		utils.FileLog.Info("%s", string(body))
+		utils.FileLogLz.Info("GetLzSurveyProduct:" + string(body))
 		infoItem := new(models.SurveyProduct)
 		err = json.Unmarshal(body, &infoItem)
 		if err != nil {
@@ -1024,7 +1027,6 @@ func GetLzSurveyProduct(cont context.Context) (err error) {
 				}
 			}
 		}
-		pageIndex = pageIndex + 1
 		totalPage := utils.PageCount(int(infoItem.Response.Total), 100)
 		if pageIndex > totalPage {
 			break
@@ -1035,6 +1037,7 @@ func GetLzSurveyProduct(cont context.Context) (err error) {
 
 //隆众-调研指标数据
 func GetLzSurveyProductData(cont context.Context) (err error) {
+	utils.FileLogLz.Info("GetLzSurveyProductData start:" + time.Now().Format(utils.FormatDateTime))
 	var msg string
 	defer func() {
 		if err != nil {
@@ -1083,12 +1086,13 @@ func GetLzSurveyProductData(cont context.Context) (err error) {
 			if err != nil {
 				fmt.Println("postData Err:", err.Error())
 			}
+			utils.FileLogLz.Info("GetLzSurveyProductData postData:" + string(postData))
 			body, err := http.Post(getUrl, string(postData), "application/json")
 			if err != nil {
 				msg = "获取隆众调研指标数据失败:Err" + err.Error()
 				return err
 			}
-			utils.FileLog.Info(string(body))
+			utils.FileLogLz.Info("GetLzSurveyProductData:" + string(body))
 			dataList := new(models.LzSurveyData)
 			err = json.Unmarshal(body, &dataList)
 			if err != nil {

utils/logs.go

@@ -5,12 +5,12 @@ import (
 )
 
 var FileLog *logs.BeeLogger
-var LzFileLog *logs.BeeLogger
+var FileLogLz *logs.BeeLogger
 
 func init() {
 	FileLog = logs.NewLogger(1000000)
 	FileLog.SetLogger(logs.AdapterFile, `{"filename":"./rdlucklog/hongze_task.log"}`)
 
-	LzFileLog = logs.NewLogger(1000000)
-	LzFileLog.SetLogger(logs.AdapterFile, `{"filename":"./rdlucklog/hongze_task_lz.log"}`)
+	FileLogLz = logs.NewLogger(1000000)
+	FileLogLz.SetLogger(logs.AdapterFile, `{"filename":"./rdlucklog/hongze_task_lz.log"}`)
 }