|
@@ -649,23 +649,23 @@ func GetLzProductPriceProduct() (err error) {
|
|
|
body, err := http.Get(getUrl)
|
|
|
if err != nil {
|
|
|
msg = "获取隆众价格指标失败:Err" + err.Error()
|
|
|
- return
|
|
|
+ return err
|
|
|
}
|
|
|
infoList := new(models.LzPriceInfoResp)
|
|
|
err = json.Unmarshal(body, &infoList)
|
|
|
if err != nil {
|
|
|
msg = "获取隆众价格指标失败:Unmarshal Err " + err.Error() + " ;body:" + string(body)
|
|
|
- return
|
|
|
+ return err
|
|
|
}
|
|
|
if infoList.Code != 1 {
|
|
|
msg = "获取隆众价格指标失败:body " + string(body)
|
|
|
- return
|
|
|
+ return nil
|
|
|
}
|
|
|
for _, n := range infoList.Data {
|
|
|
count, err := models.GetLongzhongpriceinfoCount(n.Id)
|
|
|
if err != nil {
|
|
|
msg = "判断隆众价格指标是否存在失败:err " + err.Error()
|
|
|
- return
|
|
|
+ return err
|
|
|
}
|
|
|
if count > 0 {
|
|
|
fmt.Print("存在", n.ProductName, n.Id)
|
|
@@ -684,7 +684,7 @@ func GetLzProductPriceProduct() (err error) {
|
|
|
_, err = models.AddLongzhongpriceinfo(item)
|
|
|
if err != nil {
|
|
|
msg = "新增隆众价格指标失败:err " + err.Error()
|
|
|
- return
|
|
|
+ return err
|
|
|
}
|
|
|
}
|
|
|
}
|