修改润格统计

This commit is contained in:
jhc 2023-04-03 19:54:21 +08:00
parent 1ff3cf198e
commit c08ec869e2
4 changed files with 31 additions and 30 deletions

Binary file not shown.

View File

@ -33,8 +33,7 @@ func ArtworkPriceList(in *artShow.ShowDetailReq) (err error, artworkPriceList []
func UpdateArtworkPriceReward(in *artShow.UpdateArtworkRewardReq) (err error) { func UpdateArtworkPriceReward(in *artShow.UpdateArtworkRewardReq) (err error) {
var ( var (
showUid string reward map[string]int
reward int
) )
tx := db.DbArtShow.Begin() tx := db.DbArtShow.Begin()
@ -46,13 +45,13 @@ func UpdateArtworkPriceReward(in *artShow.UpdateArtworkRewardReq) (err error) {
return err return err
} }
if showUid == "" { if reward[artwork.ShowUID] == 0 {
showUid = artwork.ShowUID reward[artwork.ShowUID] = 0
} }
artworkReward, _ := strconv.Atoi(in.Data[i].Reward) artworkReward, _ := strconv.Atoi(in.Data[i].Reward)
reward += int(artwork.Ruler) * artworkReward reward[artwork.ShowUID] += int(artwork.Ruler) * artworkReward
err = dao.UpdateArtworkInfoWithMap(tx, map[string]interface{}{"reward": in.Data[i].Reward}, "", in.Data[i].ArtworkPriceUid) err = dao.UpdateArtworkInfoWithMap(tx, map[string]interface{}{"reward": in.Data[i].Reward}, "", in.Data[i].ArtworkPriceUid)
if err != nil { if err != nil {
@ -61,14 +60,16 @@ func UpdateArtworkPriceReward(in *artShow.UpdateArtworkRewardReq) (err error) {
} }
} }
err = dao.UpdateArtShow(tx, &model.ArtShow{ for showUid, reward := range reward {
ShowUID: showUid, err = dao.UpdateArtShow(tx, &model.ArtShow{
IsShow: m.ARTSHOW_REWARD_PASS, ShowUID: showUid,
Reward: int64(reward), IsShow: m.ARTSHOW_REWARD_PASS,
}) Reward: int64(reward),
if err != nil { })
fmt.Println("update art_show err is :", err) if err != nil {
return err fmt.Println("update art_show err is :", err)
return err
}
} }
err = tx.Commit().Error err = tx.Commit().Error

View File

@ -21,13 +21,13 @@ mode = prod #正式prod #测试dev
;DbName = art_show ;DbName = art_show
;正式服 172.16.100.30 now ;正式服 172.16.100.30 now
[mysql] ;[mysql]
Db = mysql ;Db = mysql
DbHost = 172.16.100.30 ;DbHost = 172.16.100.30
DbPort = 3306 ;DbPort = 3306
DbUser = root ;DbUser = root
DbPassWord = IhQmhg8HZjDmU=Ove5PnA^D ;DbPassWord = IhQmhg8HZjDmU=Ove5PnA^D
DbName = art_show ;DbName = art_show
;188 ;188
;[mysql] ;[mysql]
@ -39,14 +39,14 @@ DbName = art_show
;DbName = art_show ;DbName = art_show
;214 ;214
;[mysql] [mysql]
;Db = mysql Db = mysql
;DbHost = 172.16.100.99 #214 DbHost = 172.16.100.99 #214
;;DbHost = 172.16.39.93 #214 ;DbHost = 172.16.39.93 #214
;DbPort = 9007 DbPort = 9007
;DbUser = artuser DbUser = artuser
;DbPassWord = "C250PflXIWv2SQm8" DbPassWord = "C250PflXIWv2SQm8"
;DbName = art_show DbName = art_show
;[mysql] ;[mysql]
;Db = mysql ;Db = mysql

View File

@ -3,8 +3,8 @@ dubbo:
demoZK: demoZK:
protocol: zookeeper protocol: zookeeper
timeout: 3s timeout: 3s
address: zookeeper:2181 # 正式服务 # address: zookeeper:2181 # 正式服务
# address: 127.0.0.1:2181 # 测试服务q address: 127.0.0.1:2181 # 测试服务q
protocols: protocols:
triple: #triple triple: #triple
name: tri name: tri