fonchain-artshow/cmd/service/art_show.go

package service

import (
	"errors"
	"fmt"
	"fonchain-artshow/cmd/dao"
	"fonchain-artshow/cmd/model"
	"fonchain-artshow/pb/artShow"
	"fonchain-artshow/pkg/db"
	"fonchain-artshow/pkg/m"
	"fonchain-artshow/pkg/serializer"
)

func CreateArtShowWithArtworkPrice(in *artShow.SaveShowReq) (err error, showID uint) {
	artShowM := serializer.BuildArtShowM(in)

	tx := db.DbArtShow.Begin()

	err = dao.SaveArtShow(tx, artShowM)
	if err != nil {
		tx.Rollback()
		return
	}

	if len(in.ShowArtwork) > 0 {
		artworks := serializer.BuildShowArtworkM(in.ShowArtwork, artShowM.ID)

		artworks = serializer.CalcPrice(artShowM.Price, artShowM.Ruler, artworks)

		err, artworks = serializer.CalcReward(artworks, artShowM.Reward)
		if err != nil {
			return
		}

		err, _ = dao.SaveArtworkPrice(tx, artworks)
		if err != nil {
			tx.Rollback()
			return
		}
	}

	err = tx.Commit().Error

	return err, artShowM.ID
}

func UpdateArtShowWithArtworkPrice(in *artShow.SaveShowReq) (err error, showID uint) {

	err, artworkPrices := dao.ArtworkPriceList(uint(in.ID))
	if err != nil {
		return
	}

	tx := db.DbArtShow.Begin()
	artShowM := serializer.BuildArtShowM(in) // 构建画展包数据
	artworks := make([]*model.ArtworkPrice, 0)
	if len(in.ShowArtwork) < 1 && (in.Price != 0 || in.Reward != 0) {
		artworks = artworkPrices
	} else {
		artworks = serializer.BuildShowArtworkM(in.ShowArtwork, uint(in.ID))
	}

	if len(artworks) > 0 {
		if in.Price != 0 {
			artworks = serializer.CalcPrice(artShowM.Price, artShowM.Ruler, artworks)
		}
		if in.Reward != 0 {
			err, artworks = serializer.CalcReward(artworks, artShowM.Reward)
			if err != nil {
				return
			}
		}
		// 更新画作价格
		err, _ := dao.SaveArtworkPrice(tx, artworks)
		if err != nil {
			tx.Rollback()
			return err, 0
		}
		// 删除旧画作
		//_, del, _ := utils.BeUniqueSlice_uint(serializer.BuildArtworkPriceIDs(artworkPrices), newIDs)
		if len(in.DelShowArtwork) > 0 {
			del := make([]int64, 0)
			for i := 0; i < len(in.DelShowArtwork); i++ {
				del = append(del, in.DelShowArtwork[i].ID)
			}
			err = dao.DelArtworkPrice(tx, del)
			if err != nil {
				tx.Rollback()
				return err, 0
			}
		}
	}

	// 更新画展包
	err = dao.SaveArtShow(tx, artShowM)
	if err != nil {
		tx.Rollback()
		return
	}

	err = tx.Commit().Error
	return err, artShowM.ID
}

func DelArtShow(in *artShow.DelShowReq) (err error) {
	tx := db.DbArtShow.Begin()
	for i := 0; i < len(in.ShowID); i++ {
		queryShowRelErr, show_rel := dao.QueryShowRel_showId(in.ShowID[i])
		if queryShowRelErr == nil && show_rel.ID == 0 {
			delArtShowErr := dao.DelArtShow(tx, in.ShowID[i])
			if err != nil {
				tx.Rollback()
				return delArtShowErr
			}
			delArtworkPriceErr := dao.DelArtworkPrice_showId(tx, in.ShowID[i])
			if err != nil {
				tx.Rollback()
				return delArtworkPriceErr
			}
		} else if show_rel.ShowID != 0 {
			tx.Rollback()
			return errors.New("存在画展包被使用,无法删除")
		}

	}
	err = tx.Commit().Error
	return
}

func ArtShowList(in *artShow.ShowListReq) (err error, out *artShow.ShowListRes) {
	out = new(artShow.ShowListRes)
	artShows := make([]*model.ArtShow, 0)
	err, out.Total, artShows = dao.ArtShowList(in)
	if err != nil {
		return
	}
	err, out.TotalArtistNum, out.TotalPackageNum, _, _, _ = dao.ShowStatistical(m.ARTSHOW_PASS)
	if err != nil {
		return
	}
	out.Data = serializer.BuildArtShowListRes(artShows)
	return
}

func ShowArtworkInfo(in *artShow.ShowDetailReq) (err error, out *artShow.ShowArtworkDetailRes) {
	out = new(artShow.ShowArtworkDetailRes)
	artworkPriceS := make([]*model.ArtworkPrice, 0)
	err, artworkPriceS = dao.ArtworkPriceList(uint(in.ShowID))
	if err != nil {
		return
	}
	out.Data = serializer.BuildShowArtworkRpc(artworkPriceS)
	return
}

func ShowDetail(in *artShow.ShowDetailReq) (err error, out *artShow.ShowDetailRes) {
	out = new(artShow.ShowDetailRes)
	show := new(model.ArtShow)
	err, show = dao.QueryArtShow(uint(in.ShowID))
	if err != nil {
		return
	}
	out.Data = serializer.BuildArtShowRpc(show)
	fmt.Println(out.Data)
	return
}

func ArtShowListWithApply(in *artShow.ShowListReq) (err error, out *artShow.ShowListRes) {
	out = new(artShow.ShowListRes)
	artShows := make([]*model.ArtShow, 0)
	err, out.Total, artShows = dao.ArtShowListByApplyStatus(in)
	err, out.TotalArtistNum, out.TotalPackageNum, _, _, _ = dao.ShowStatistical(m.ARTSHOW_PASS)
	if err != nil {
		return
	}
	out.Data = serializer.BuildArtShowListRes(artShows)
	return
}

func ShowStatisticalInfo(in *artShow.ShowStatisticalInfoReq) (err error, out *artShow.ShowStatisticalInfoRes_Num) {
	out = new(artShow.ShowStatisticalInfoRes_Num)
	err, out.ArtistNum, out.PackageNum, out.TotalNum, out.NotShowNum, out.ShowHisNum = dao.ShowStatistical(in.IsShow)
	if err != nil {
		return
	}
	return
}