fix bug

models/data_source_longzhong.go

@@ -205,7 +205,15 @@ type LongzhonginfoList struct {
 func GetLongzhonginfoList() (items []*LongzhonginfoList, err error) {
 	o := orm.NewOrm()
 	o.Using("edb")
-	sql := ` SELECT * FROM longzhonginfo `
+	sql := ` SELECT * FROM longzhonginfo WHERE is_normal=1 `
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }
+
+func ModifyLongzhonginfoIsNormal(longzhonginfoId int) (err error) {
+	o := orm.NewOrm()
+	o.Using("edb")
+	sql := ` UPDATE longzhonginfo SET is_normal=0 WHERE longzhonginfo_id=? `
+	_, err = o.Raw(sql,longzhonginfoId).Exec()
+	return
+}

services/data_source_longzhong.go

@@ -383,7 +383,7 @@ func GetHistoryLzProductDetail() (err error) {
 			}
 			param.Add("pagesize", strconv.Itoa(pageSize))
 			utils.FileLog.Info("%s", param.Encode())
-			fmt.Println("post url:",postUrl)
+			fmt.Println("post url:", postUrl)
 			fmt.Println("post params:", param.Encode())
 			body, err := http.Post(postUrl, param.Encode())
 			if err != nil {
@@ -464,10 +464,17 @@ func GetHistoryLzProductDetail() (err error) {
 			if resp.Pagesize < pageSize || len(resp.Data) == 0 {
 				break
 			}
+			if i == 1 && len(resp.Data) == 0 {
+				utils.FileLog.Info("%d", iv.Unitid)
+			}
 			time.Sleep(2 * time.Second)
 		}
+		err = models.ModifyLongzhonginfoIsNormal(iv.LongzhonginfoId)
+		if err != nil {
+			fmt.Println("ModifyLongzhonginfoIsNormal:Err" + err.Error())
+		}
 		fmt.Println("sleep", iv.SecName)
-		time.Sleep(10 * time.Second)
+		time.Sleep(2 * time.Second)
 	}
 	return
 }