rdluck 4 жил өмнө
parent
commit
00ff12fad3

+ 9 - 0
models/data_source_longzhong.go

@@ -114,6 +114,15 @@ func GetLongzhonginfoCount(classifyId int, unitid int64) (count int, err error)
 	return
 }
 
+//判断指标数据是否已经录入
+func GetLongzhonginfoBySecNameCount(secName string) (count int, err error) {
+	o := orm.NewOrm()
+	o.Using("edb")
+	sql := `SELECT COUNT(1) AS count FROM longzhonginfo WHERE sec_name=? `
+	err = o.Raw(sql, secName).QueryRow(&count)
+	return
+}
+
 type LzProductInfoResp struct {
 	Msg  string           `json:"msg"`
 	Code string           `json:"code"`

+ 2 - 1
services/data_source_longzhong.go

@@ -164,7 +164,8 @@ func GetLzProductList() (err error) {
 			fmt.Println("判断指标是否存在失败,Err:" + err.Error())
 			return err
 		}
-		if count > 0 { //修改
+		secNameCount, _ := models.GetLongzhonginfoBySecNameCount(v.ProUnitName)
+		if count > 0 || secNameCount > 0 { //修改
 			lzProduct := new(models.Longzhonginfo)
 			lzProduct.SecName = v.ProUnitName
 			lzProduct.Frequency = v.LzType