From 1ff3cf198e43c5eab45e4b65d5a64f70238834b8 Mon Sep 17 00:00:00 2001
From: jhc <9316338+wangyitao309@user.noreply.gitee.com>
Date: Mon, 3 Apr 2023 18:00:30 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B6=A6=E6=A0=BC=E5=AE=A1?=
 =?UTF-8?q?=E6=89=B9,=E8=AE=A1=E7=AE=97=E6=80=BB=E4=BB=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cmd/service/show_price.go | 43 +++++++++++++++++++++++++++------------
 conf/dubbogo.yaml         |  2 +-
 2 files changed, 31 insertions(+), 14 deletions(-)

diff --git a/cmd/service/show_price.go b/cmd/service/show_price.go
index db823b6..57909a6 100644
--- a/cmd/service/show_price.go
+++ b/cmd/service/show_price.go
@@ -8,6 +8,7 @@ import (
 	"fonchain-artshow/pkg/db"
 	"fonchain-artshow/pkg/m"
 	"fonchain-artshow/pkg/serializer"
+	"strconv"
 )
 
 func ArtworkPriceInfo(in *artShow.ArtworkPriceReq) (err error, artworkPriceRes *artShow.ArtworkPriceRes) {
@@ -31,29 +32,45 @@ func ArtworkPriceList(in *artShow.ShowDetailReq) (err error, artworkPriceList []
 
 func UpdateArtworkPriceReward(in *artShow.UpdateArtworkRewardReq) (err error) {
 
-	err, artworkPrice := dao.QueryArtworkPrice_uid(in.Data[0].ArtworkPriceUid)
-	if err != nil {
-		return err
-	}
+	var (
+		showUid string
+		reward  int
+	)
 
 	tx := db.DbArtShow.Begin()
 
-	err = dao.UpdateArtShow(tx, &model.ArtShow{
-		ShowUID: artworkPrice.ShowUID,
-		IsShow:  m.ARTSHOW_REWARD_PASS,
-	})
-	if err != nil {
-		fmt.Println("update art_show err is :", err)
-		return err
-	}
-
 	for i := 0; i < len(in.Data); i++ {
+		err, artwork := dao.QueryArtworkPrice_uid(in.Data[i].ArtworkPriceUid)
+		if err != nil {
+			tx.Rollback()
+			return err
+		}
+
+		if showUid == "" {
+			showUid = artwork.ShowUID
+		}
+
+		artworkReward, _ := strconv.Atoi(in.Data[i].Reward)
+
+		reward += int(artwork.Ruler) * artworkReward
+
 		err = dao.UpdateArtworkInfoWithMap(tx, map[string]interface{}{"reward": in.Data[i].Reward}, "", in.Data[i].ArtworkPriceUid)
 		if err != nil {
 			tx.Rollback()
 			return err
 		}
 	}
+
+	err = dao.UpdateArtShow(tx, &model.ArtShow{
+		ShowUID: showUid,
+		IsShow:  m.ARTSHOW_REWARD_PASS,
+		Reward:  int64(reward),
+	})
+	if err != nil {
+		fmt.Println("update art_show err is :", err)
+		return err
+	}
+
 	err = tx.Commit().Error
 	return err
 }
diff --git a/conf/dubbogo.yaml b/conf/dubbogo.yaml
index 86ac194..e9f1f53 100644
--- a/conf/dubbogo.yaml
+++ b/conf/dubbogo.yaml
@@ -4,7 +4,7 @@ dubbo:
       protocol: zookeeper
       timeout: 3s
       address: zookeeper:2181  # 正式服务
-#      address: 127.0.0.1:2181 # 测试服务
+#      address: 127.0.0.1:2181 # 测试服务q
   protocols:
     triple: #triple
       name: tri