From ce0450973ccd3267caa671e0c5d7cbac5b56cc3c Mon Sep 17 00:00:00 2001 From: zyd Date: Mon, 29 Jun 2020 17:06:14 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=8D=8F=E7=A8=8B=EF=BC=8C?= =?UTF-8?q?=E6=9B=B4=E6=96=B0=E8=A1=A8=E5=8A=A0=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/service/field.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/service/field.go b/src/service/field.go index 8e5312e..541a289 100644 --- a/src/service/field.go +++ b/src/service/field.go @@ -211,6 +211,19 @@ COMMIT WORK; session.Rollback() return } + sql3 := fmt.Sprintf(`BEGIN WORK; +LOCK TABLE service_count_person IN SHARE ROW EXCLUSIVE MODE; +INSERT INTO service_count_person ( user_id,date,count) VALUES +(%d,'%s',%d) ON conflict (user_id,date) DO +UPDATE SET count=(service_count_person.count+1); +COMMIT WORK; +`, proxyData.Service_id, date, 1) + _, err = session.SQL(sql3).Execute() + if err != nil { + fmt.Println("error****** service_count_person 更新失败：" + err.Error()) + session.Rollback() + return + } session.Commit() //查询service_daliy_count 表有更新没有插入 return -- 2.26.0