diff --git a/src/service/field.go b/src/service/field.go index 8e5312e6937373837ec69d33607271b4c12d1b6b..541a289f7bc5f87f23d4ac864346fd1335fe6237 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