From 34c96d5684ad6317f0426f3323068bc7791a8d60 Mon Sep 17 00:00:00 2001
From: liwei1dao <liwei1dao@gmail.com>
Date: Wed, 13 Mar 2024 13:50:38 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E4=BB=BB=E5=8A=A1=E5=9F=8B?=
 =?UTF-8?q?=E7=82=B960=EF=BC=8C61=20=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 modules/mainline/api_challengeover.go | 20 ++++++++++----------
 modules/mainline/api_levelpass.go     | 15 ++++++---------
 modules/mainline/api_setpolts.go      | 16 +++++++++++++---
 3 files changed, 29 insertions(+), 22 deletions(-)

diff --git a/modules/mainline/api_challengeover.go b/modules/mainline/api_challengeover.go
index 6e01c45d7..28ccf48f5 100644
--- a/modules/mainline/api_challengeover.go
+++ b/modules/mainline/api_challengeover.go
@@ -22,13 +22,13 @@ func (this *apiComp) ChallengeOverCheck(session comm.IUserSession, req *pb.Mainl
 // /挑战主线关卡
 func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.MainlineChallengeOverReq) (errdata *pb.ErrorData) {
 	var (
-		conf     *cfg.GameMainStageData
-		info     *pb.DBMainline
-		atno     []*pb.UserAtno
-		isWin    bool
-		first    bool              // 判断是否是首通
-		star     int32             // 评星
-		tasks    []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
+		conf  *cfg.GameMainStageData
+		info  *pb.DBMainline
+		atno  []*pb.UserAtno
+		isWin bool
+		first bool  // 判断是否是首通
+		star  int32 // 评星
+		// tasks    []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
 		err      error
 		changExp map[string]int32
 		res      []*cfg.Gameatn
@@ -191,11 +191,11 @@ func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.MainlineCh
 		Reward:  atno,
 	})
 
-	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
-	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
+	// tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
+	// tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
 
 	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
-		this.module.ModuleBuried.TriggerBuried(session, tasks...)
+		// this.module.ModuleBuried.TriggerBuried(session, tasks...)
 		// this.module.ModuleSys.CheckOpenCond(session, comm.OpencondTypeMaxmapid, req.Level)
 		this.module.WriteUserLog(session.GetUserId(), req, comm.GMResAddType, "MainlineChallengeOverReq", atno)
 	})
diff --git a/modules/mainline/api_levelpass.go b/modules/mainline/api_levelpass.go
index fc395bf8b..72b8fe1eb 100644
--- a/modules/mainline/api_levelpass.go
+++ b/modules/mainline/api_levelpass.go
@@ -25,11 +25,11 @@ func (this *apiComp) LevelPass(session comm.IUserSession, req *pb.MainlineLevelP
 		conf   *cfg.GameMainStageData
 		info   *pb.DBMainline
 		atno   []*pb.UserAtno
-		aeward []*pb.UserAtno    = make([]*pb.UserAtno, 0)
-		first  bool              // 判断是否是首通
-		star   int32             // 评星
-		tasks  []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
-		err    error
+		aeward []*pb.UserAtno = make([]*pb.UserAtno, 0)
+		first  bool           // 判断是否是首通
+		star   int32          // 评星
+		// tasks  []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
+		err error
 		// consumPs int32
 	)
 	if errdata = this.LevelPassCheck(session, req); errdata != nil {
@@ -140,11 +140,8 @@ func (this *apiComp) LevelPass(session comm.IUserSession, req *pb.MainlineLevelP
 		return
 	}
 
-	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
-	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
-
 	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
-		this.module.ModuleBuried.TriggerBuried(session, tasks...)
+		// this.module.ModuleBuried.TriggerBuried(session, tasks...)
 		// this.module.ModuleSys.CheckOpenCond(session, comm.OpencondTypeMaxmapid, req.Level)
 		this.module.WriteUserLog(session.GetUserId(), req, comm.GMResAddType, "MainlineLevelPassReq", aeward)
 	})
diff --git a/modules/mainline/api_setpolts.go b/modules/mainline/api_setpolts.go
index e2b7cff06..90768a78d 100644
--- a/modules/mainline/api_setpolts.go
+++ b/modules/mainline/api_setpolts.go
@@ -13,8 +13,9 @@ func (this *apiComp) SetPoltsCheck(session comm.IUserSession, req *pb.MainlineSe
 // /挑战主线关卡
 func (this *apiComp) SetPolts(session comm.IUserSession, req *pb.MainlineSetPoltsReq) (errdata *pb.ErrorData) {
 	var (
-		info *pb.DBMainline
-		err  error
+		info  *pb.DBMainline
+		err   error
+		tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
 	)
 	if errdata = this.SetPoltsCheck(session, req); errdata != nil {
 		return // 参数校验失败直接返回
@@ -28,6 +29,10 @@ func (this *apiComp) SetPolts(session comm.IUserSession, req *pb.MainlineSetPolt
 		}
 		return
 	}
+	if !info.Plots[req.Pid] {
+		tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
+		tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Pid)))
+	}
 	info.Plots[req.Pid] = req.State
 
 	if err = this.module.modelMline.Change(session.GetUserId(), map[string]interface{}{
@@ -43,7 +48,12 @@ func (this *apiComp) SetPolts(session comm.IUserSession, req *pb.MainlineSetPolt
 
 	session.SendMsg(string(this.module.GetType()), "setpolts", &pb.MainlineSetPoltsResp{
 		Plots: info.Plots,
-	}) // 数据推送
+	})
 
+	if len(tasks) > 0 {
+		go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
+			this.module.ModuleBuried.TriggerBuried(session, tasks...)
+		})
+	}
 	return
 }