role_task.go 60 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960
  1. package model
  2. import (
  3. "rocommon/util"
  4. "roserver/baseserver/model"
  5. "roserver/baseserver/set"
  6. "roserver/serverproto"
  7. "strings"
  8. )
  9. func (this *Role) GetTaskReward(taskId uint32) {
  10. if this.roleTask != nil {
  11. ret := this.roleTask.GetTaskReward(taskId)
  12. if ret != serverproto.ErrorCode_ERROR_OK {
  13. this.ReplayGate(&serverproto.SCGetTaskRewardAck{Error: int32(ret)}, true)
  14. }
  15. }
  16. }
  17. func (this *Role) GetTaskScoreReward(rewardType, rewardIdx int32) {
  18. if this.roleTask != nil {
  19. ret := this.roleTask.GetTaskScoreReward(uint32(rewardType), uint32(rewardIdx))
  20. if ret != serverproto.ErrorCode_ERROR_OK {
  21. this.ReplayGate(&serverproto.SCGetTaskScoreRewardAck{Error: int32(ret)}, true)
  22. }
  23. }
  24. }
  25. const (
  26. TASK_REWARD_STATE_NONE = 0 //未完成
  27. TASK_REWARD_STATE_COMPLETED = 1 //任务完成未领取奖励
  28. TASK_REWARD_STATE_REWARD = 2 //已经领取奖励
  29. TASK_REWARD_STATE_DELETE = 3 //困难模式可删除状态
  30. TASK_CONDITION_NONE = 4
  31. TASK_CONDITION_CHANGE = 5
  32. TASK_CONDITION_OK = 6
  33. )
  34. type ConditionInfo struct {
  35. HeroId int32 //伙伴ID
  36. TaskId uint32 //条件列表ID
  37. CondInfo *serverproto.TaskData
  38. }
  39. type RoleTask struct {
  40. SaveObject
  41. loadTaskData *serverproto.RoleTask
  42. jobCondition []*serverproto.ChangeJob //只针对主角//伙伴转职出案子再做
  43. roleHeadCond serverproto.RoleHeadCond
  44. taskTypeList map[int32]set.Interface //根据枚举类型对任务做区分[serverproto.TaskType, taslidlist]
  45. dailyTaskList map[uint32]*serverproto.TaskData
  46. weekTaskList map[uint32]*serverproto.TaskData
  47. mainTaskList map[uint32]*serverproto.TaskData
  48. mapHardTaskList map[uint32]*serverproto.TaskData //困难模式任务
  49. mapGroupHardTaskList map[uint32]*serverproto.TaskData //困难模式组任务
  50. mapHard2TaskList map[uint32]*serverproto.TaskData //噩梦模式任务
  51. mapGroupHard2TaskList map[uint32]*serverproto.TaskData //噩梦模式组任务
  52. dailyTaskScore serverproto.KeyValueType //活跃度/活跃度对应的奖励,按位处理(完成任务累加的积分)
  53. weekTaskScore serverproto.KeyValueType
  54. saveTaskDataList []*serverproto.TaskData
  55. recTypeCnt map[int32]*serverproto.KeyValueType
  56. //任务通用累计计数
  57. totalAddZeny uint64
  58. }
  59. func newRoleTask(r *Role) *RoleTask {
  60. roleTask := &RoleTask{
  61. SaveObject: SaveObject{
  62. role: r,
  63. },
  64. loadTaskData: &serverproto.RoleTask{},
  65. dailyTaskList: map[uint32]*serverproto.TaskData{},
  66. weekTaskList: map[uint32]*serverproto.TaskData{},
  67. mainTaskList: map[uint32]*serverproto.TaskData{},
  68. mapHardTaskList: map[uint32]*serverproto.TaskData{},
  69. mapGroupHardTaskList: map[uint32]*serverproto.TaskData{},
  70. mapHard2TaskList: map[uint32]*serverproto.TaskData{},
  71. mapGroupHard2TaskList: map[uint32]*serverproto.TaskData{},
  72. taskTypeList: map[int32]set.Interface{},
  73. recTypeCnt: map[int32]*serverproto.KeyValueType{},
  74. roleHeadCond: serverproto.RoleHeadCond{},
  75. }
  76. return roleTask
  77. }
  78. func (this *RoleTask) Load(msg interface{}) bool {
  79. dbRole := msg.(*serverproto.Role)
  80. if dbRole != nil && dbRole.RoleBase != nil {
  81. //daily/week/game task
  82. if dbRole.RoleTask != nil {
  83. this.loadTaskData = dbRole.RoleTask
  84. if dbRole.RoleTask.DailyTaskScore != nil {
  85. this.dailyTaskScore = *dbRole.RoleTask.DailyTaskScore
  86. }
  87. if dbRole.RoleTask.WeekTaskScore != nil {
  88. this.weekTaskScore = *dbRole.RoleTask.WeekTaskScore
  89. }
  90. //util.InfoF("qqqqqqdb:%v", dbRole.RoleTask.TaskList)
  91. for idx := range dbRole.RoleTask.TaskList {
  92. taskInfo := dbRole.RoleTask.TaskList[idx]
  93. if taskInfo.TaskType == model.TASK_TYPE_HARD {
  94. _, ok := model.HardMissionTaskList[taskInfo.TaskId]
  95. if !ok {
  96. continue
  97. }
  98. } else if taskInfo.TaskType == model.TASK_TYPE_HARD_GROUP {
  99. _, ok := model.HardGroupMissionTaskList[taskInfo.TaskId]
  100. if !ok {
  101. continue
  102. }
  103. } else if taskInfo.TaskType == model.TASK_TYPE_HARD2_GROUP {
  104. _, ok := model.Hard2GroupMissionTaskList[taskInfo.TaskId]
  105. if !ok {
  106. continue
  107. }
  108. } else if taskInfo.TaskType == model.TASK_TYPE_HARD2 {
  109. _, ok := model.Hard2MissionTaskList[taskInfo.TaskId]
  110. if !ok {
  111. continue
  112. }
  113. } else {
  114. _, ok := model.ConvertTaskList[taskInfo.TaskId]
  115. if !ok {
  116. continue
  117. }
  118. }
  119. if taskInfo.TaskType == model.TASK_TYPE_DAILY {
  120. this.dailyTaskList[taskInfo.TaskId] = taskInfo
  121. } else if taskInfo.TaskType == model.TASK_TYPE_WEEK {
  122. this.weekTaskList[taskInfo.TaskId] = taskInfo
  123. } else if taskInfo.TaskType == model.TASK_TYPE_MAIN {
  124. this.mainTaskList[taskInfo.TaskId] = taskInfo
  125. } else if taskInfo.TaskType == model.TASK_TYPE_HARD {
  126. this.mapHardTaskList[taskInfo.TaskId] = taskInfo
  127. } else if taskInfo.TaskType == model.TASK_TYPE_HARD2 {
  128. this.mapHard2TaskList[taskInfo.TaskId] = taskInfo
  129. } else if taskInfo.TaskType == model.TASK_TYPE_HARD_GROUP {
  130. this.mapGroupHardTaskList[taskInfo.TaskId] = taskInfo
  131. } else if taskInfo.TaskType == model.TASK_TYPE_HARD2_GROUP {
  132. this.mapGroupHard2TaskList[taskInfo.TaskId] = taskInfo
  133. }
  134. }
  135. //util.InfoF("qqqqqq:%v bbbbbb:%v", this.mapHard2TaskList, this.mapGroupHard2TaskList)
  136. this.initTaskDataFromConfig()
  137. for _, valueType := range dbRole.RoleTask.TypeRecCount {
  138. this.recTypeCnt[valueType.Key] = valueType
  139. }
  140. }
  141. if len(dbRole.RoleTask.Condition) <= 0 { //账号初始化主角
  142. this.role.roleTask.GetChangeJobTask(this.role.GetRoleBase().RoleData().HeroData.Id, 0, false)
  143. }
  144. if len(this.jobCondition) <= 0 {
  145. this.jobCondition = dbRole.RoleTask.Condition
  146. }
  147. //this.role.roleTask.InitJobTask()
  148. dbRole.RoleTask.Condition = this.jobCondition
  149. //}
  150. //if len(dbRole.RoleTask.Condition) > 0 {
  151. // this.jobCondition = dbRole.RoleTask.Condition
  152. //}
  153. if dbRole.RoleTask.HeadCond != nil {
  154. this.roleHeadCond = *dbRole.RoleTask.HeadCond
  155. }
  156. this.totalAddZeny = dbRole.RoleTask.TotalAddZeny
  157. }
  158. return true
  159. }
  160. func (this *RoleTask) OnlineProcess() {
  161. this.role.roleTask.InitJobTask()
  162. }
  163. func (this *RoleTask) CopyData() *serverproto.RoleTask {
  164. //this.loadTaskData.DailyTaskScore = &this.dailyTaskScore
  165. //this.loadTaskData.WeekTaskScore = &this.weekTaskScore
  166. //this.loadTaskData.Condition = this.jobCondition
  167. //this.loadTaskData.HeadCond = &this.roleHeadCond
  168. //
  169. //this.loadTaskData.Latest5HourTime = util.GetLatest5Hour()
  170. //this.loadTaskData.LatestWeek5HourTime = util.GetLatestWeek5Hour()
  171. //util.DebugF("Online Pack RoleTask =%v", this.loadTaskData)
  172. //return this.loadTaskData
  173. tmpRoleTask := &serverproto.RoleTask{
  174. DailyTaskScore: &this.dailyTaskScore,
  175. WeekTaskScore: &this.weekTaskScore,
  176. Condition: this.jobCondition,
  177. HeadCond: &this.roleHeadCond,
  178. Latest5HourTime: util.GetLatest5Hour(),
  179. LatestWeek5HourTime: util.GetLatestWeek5Hour(0),
  180. }
  181. for _, val := range this.dailyTaskList {
  182. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  183. }
  184. for _, val := range this.weekTaskList {
  185. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  186. }
  187. for _, val := range this.mainTaskList {
  188. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  189. }
  190. //var groupId uint32
  191. //for _, val := range this.mapHardTaskList {
  192. // if val.State != TASK_REWARD_STATE_REWARD {
  193. // groupId = model.HardMissionTaskList[val.TaskId].GroupTaskId
  194. // tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  195. // continue
  196. // }
  197. // if groupId == 0 && model.HardMissionTaskList[val.TaskId].GroupTaskId == groupId {
  198. // tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  199. // }
  200. //}
  201. for _, val := range this.mapHardTaskList {
  202. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  203. }
  204. for _, val := range this.mapGroupHardTaskList {
  205. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  206. }
  207. for _, val := range this.mapHard2TaskList {
  208. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  209. }
  210. for _, val := range this.mapGroupHard2TaskList {
  211. tmpRoleTask.TaskList = append(tmpRoleTask.TaskList, val)
  212. }
  213. util.DebugF("send task group:%v task:%v all task:%v", this.mapGroupHardTaskList, this.mapHardTaskList, tmpRoleTask.TaskList)
  214. for _, val := range this.recTypeCnt {
  215. tmpRoleTask.TypeRecCount = append(tmpRoleTask.TypeRecCount, val)
  216. }
  217. return tmpRoleTask
  218. }
  219. func (this *RoleTask) Save() {
  220. this.SetDirty(false)
  221. saveMsg := &serverproto.SSTaskDataSaveReq{
  222. Task: &serverproto.RoleTask{
  223. DailyTaskScore: &this.dailyTaskScore,
  224. WeekTaskScore: &this.weekTaskScore,
  225. },
  226. }
  227. saveMsg.Task.Condition = this.jobCondition
  228. saveMsg.Task.HeadCond = &this.roleHeadCond
  229. saveMsg.Task.TaskList = append(this.saveTaskDataList)
  230. this.saveTaskDataList = this.saveTaskDataList[:0]
  231. saveMsg.Task.TotalAddZeny = this.totalAddZeny
  232. for _, val := range this.recTypeCnt {
  233. saveMsg.Task.TypeRecCount = append(saveMsg.Task.TypeRecCount, val)
  234. }
  235. this.role.SendDb(saveMsg)
  236. }
  237. // 记录任务事件计数, 触发该记录事件前先调用该函数进行计数累加
  238. func (this *RoleTask) AddTypeCnt(recType serverproto.TaskType, cnt int32) {
  239. rec := int32(recType)
  240. val, ok := this.recTypeCnt[rec]
  241. if !ok {
  242. val = &serverproto.KeyValueType{Key: rec}
  243. }
  244. val.Value += cnt
  245. this.recTypeCnt[rec] = val
  246. this.SetDirty(true)
  247. }
  248. // 记录任务事件计数, 触发该记录事件前先调用该函数进行计数累加
  249. func (this *RoleTask) SetTypeCnt(recType serverproto.TaskType, cnt int32) {
  250. rec := int32(recType)
  251. val, ok := this.recTypeCnt[rec]
  252. if !ok {
  253. val = &serverproto.KeyValueType{Key: rec}
  254. }
  255. val.Value = cnt
  256. this.recTypeCnt[rec] = val
  257. this.SetDirty(true)
  258. }
  259. func (this *RoleTask) GetTypeCnt(recType int32) int32 {
  260. val, ok := this.recTypeCnt[recType]
  261. if !ok {
  262. return 0
  263. }
  264. return val.Value
  265. }
  266. func (this *RoleTask) DailyReset(notify bool, oldDailyResetTimeStamp uint64) {
  267. ntfMsg := &serverproto.SCTaskChangeNtf{
  268. DailyTaskScore: &this.dailyTaskScore,
  269. WeekTaskScore: &this.weekTaskScore,
  270. Latest5HourTime: util.GetLatest5Hour(),
  271. LatestWeek5HourTime: util.GetLatestWeek5Hour(0),
  272. }
  273. this.resetDailyTask(ntfMsg)
  274. //每日重置时判断是否是每周重置
  275. if util.IsInSameWeek(oldDailyResetTimeStamp, util.GetTimeMilliseconds()) {
  276. this.resetWeekTask(ntfMsg)
  277. }
  278. this.AddTypeCnt(serverproto.TaskType_Eve_Login_Day, 1)
  279. TaskMagCheck(this.role, serverproto.TaskType_Eve_Login_Day, 1)
  280. this.SetDirty(true)
  281. if notify {
  282. this.role.ReplayGate(ntfMsg, true)
  283. }
  284. }
  285. func (this *RoleTask) resetDailyTask(ntfMsg *serverproto.SCTaskChangeNtf) {
  286. this.dailyTaskScore.Key = 0
  287. this.dailyTaskScore.Value = 0
  288. for _, val := range this.dailyTaskList {
  289. if val.State != TASK_REWARD_STATE_NONE || len(val.Progress) > 0 {
  290. val.State = TASK_REWARD_STATE_NONE
  291. val.Progress = val.Progress[:0]
  292. this.saveTaskDataList = append(this.saveTaskDataList, val)
  293. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, val)
  294. }
  295. }
  296. }
  297. func (this *RoleTask) resetWeekTask(ntfMsg *serverproto.SCTaskChangeNtf) {
  298. this.weekTaskScore.Key = 0
  299. this.weekTaskScore.Value = 0
  300. for _, val := range this.weekTaskList {
  301. if val.State != TASK_REWARD_STATE_NONE || len(val.Progress) > 0 {
  302. val.State = TASK_REWARD_STATE_NONE
  303. val.Progress = val.Progress[:0]
  304. this.saveTaskDataList = append(this.saveTaskDataList, val)
  305. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, val)
  306. }
  307. }
  308. }
  309. func (this *RoleTask) initTaskDataFromConfig() {
  310. var tmpOriginalMainTask = map[uint32]struct{}{} //originalTaskId
  311. for _, mainTaskData := range this.mainTaskList {
  312. tmpId := model.ConvertMainTaskOriginalList[mainTaskData.TaskId]
  313. tmpOriginalMainTask[tmpId] = struct{}{}
  314. }
  315. //daily/week/game 添加新任务后,重新登陆即可自动接取
  316. for _, val := range model.ConvertAddTaskList {
  317. switch val.TaskType {
  318. case model.TASK_TYPE_DAILY:
  319. if _, ok := this.dailyTaskList[val.TaskId]; !ok {
  320. taskInfo := &serverproto.TaskData{
  321. TaskId: val.TaskId,
  322. State: TASK_REWARD_STATE_NONE,
  323. //BeginTime: util.GetTimeMilliseconds(),
  324. TaskType: val.TaskType,
  325. }
  326. this.dailyTaskList[val.TaskId] = taskInfo
  327. this.loadTaskData.TaskList = append(this.loadTaskData.TaskList, taskInfo)
  328. }
  329. case model.TASK_TYPE_WEEK:
  330. if _, ok := this.weekTaskList[val.TaskId]; !ok {
  331. taskInfo := &serverproto.TaskData{
  332. TaskId: val.TaskId,
  333. State: TASK_REWARD_STATE_NONE,
  334. //BeginTime: util.GetTimeMilliseconds(),
  335. TaskType: val.TaskType,
  336. }
  337. this.weekTaskList[val.TaskId] = taskInfo
  338. this.loadTaskData.TaskList = append(this.loadTaskData.TaskList, taskInfo)
  339. }
  340. case model.TASK_TYPE_MAIN:
  341. if _, ok := tmpOriginalMainTask[val.TaskId]; !ok {
  342. taskInfo := &serverproto.TaskData{
  343. TaskId: val.TaskId,
  344. State: TASK_REWARD_STATE_NONE,
  345. //BeginTime: util.GetTimeMilliseconds(),
  346. TaskType: val.TaskType,
  347. }
  348. this.mainTaskList[val.TaskId] = taskInfo
  349. this.loadTaskData.TaskList = append(this.loadTaskData.TaskList, taskInfo)
  350. }
  351. }
  352. }
  353. //util.InfoF("uuid:%v init hard task1:%v", this.role.GetUUid(), this.mapHardTaskList)
  354. var curId uint32
  355. var bSave bool
  356. if len(this.mapHardTaskList) > 0 {
  357. for _, v := range this.mapHardTaskList {
  358. if curId <= v.TaskId {
  359. curId = v.TaskId
  360. }
  361. }
  362. }
  363. for _, val := range model.HardMissionTaskIdList {
  364. //每组任务3个,目前只初始化5组所以是15个任务
  365. if len(this.mapHardTaskList) >= 15 {
  366. break
  367. }
  368. if val < curId {
  369. continue
  370. }
  371. bSave = true
  372. data := model.HardMissionTaskList[val]
  373. if data != nil {
  374. taskInfo := &serverproto.TaskData{
  375. TaskId: data.TaskId,
  376. State: TASK_REWARD_STATE_NONE,
  377. //BeginTime: util.GetTimeMilliseconds(),
  378. TaskType: data.TaskType,
  379. }
  380. this.mapHardTaskList[data.TaskId] = taskInfo
  381. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  382. }
  383. }
  384. //util.InfoF("uuid:%v init hard task2:%v", this.role.GetUUid(), this.mapHardTaskList)
  385. var curGroupId uint32
  386. if len(this.mapGroupHardTaskList) > 0 {
  387. for _, v := range this.mapGroupHardTaskList {
  388. if curGroupId <= v.TaskId {
  389. curGroupId = v.TaskId
  390. }
  391. }
  392. }
  393. //util.InfoF("uuid:%v init hard task group1:%v", this.role.GetUUid(), this.mapGroupHardTaskList)
  394. for _, val := range model.HardGroupMissionTaskIdList {
  395. //初始化5组 组任务
  396. if len(this.mapGroupHardTaskList) >= 5 {
  397. break
  398. }
  399. if val < curGroupId {
  400. continue
  401. }
  402. bSave = true
  403. data := model.HardGroupMissionTaskList[val]
  404. if data != nil {
  405. taskInfo := &serverproto.TaskData{
  406. TaskId: data.GroupTaskId,
  407. State: TASK_REWARD_STATE_NONE,
  408. //BeginTime: util.GetTimeMilliseconds(),
  409. TaskType: data.TaskType,
  410. }
  411. this.mapGroupHardTaskList[data.GroupTaskId] = taskInfo
  412. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  413. }
  414. }
  415. curId = 0
  416. if len(this.mapHard2TaskList) > 0 {
  417. for _, v := range this.mapHard2TaskList {
  418. if curId <= v.TaskId {
  419. curId = v.TaskId
  420. }
  421. }
  422. }
  423. for _, val := range model.Hard2MissionTaskIdList {
  424. //每组任务3个,目前只初始化5组所以是15个任务
  425. if len(this.mapHard2TaskList) >= 15 {
  426. break
  427. }
  428. if val < curId {
  429. continue
  430. }
  431. bSave = true
  432. data := model.Hard2MissionTaskList[val]
  433. if data != nil {
  434. taskInfo := &serverproto.TaskData{
  435. TaskId: data.TaskId,
  436. State: TASK_REWARD_STATE_NONE,
  437. //BeginTime: util.GetTimeMilliseconds(),
  438. TaskType: data.TaskType,
  439. }
  440. this.mapHard2TaskList[data.TaskId] = taskInfo
  441. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  442. }
  443. }
  444. util.InfoF("uuid:%v init hard2 task2:%v", this.role.GetUUid(), this.mapHard2TaskList)
  445. curGroupId = 0
  446. if len(this.mapGroupHard2TaskList) > 0 {
  447. for _, v := range this.mapGroupHard2TaskList {
  448. if curGroupId <= v.TaskId {
  449. curGroupId = v.TaskId
  450. }
  451. }
  452. }
  453. //util.InfoF("uuid:%v init hard task group1:%v", this.role.GetUUid(), this.mapGroupHardTaskList)
  454. for _, val := range model.Hard2GroupMissionTaskIdList {
  455. //初始化5组 组任务
  456. if len(this.mapGroupHard2TaskList) >= 5 {
  457. break
  458. }
  459. if val < curGroupId {
  460. continue
  461. }
  462. bSave = true
  463. data := model.Hard2GroupMissionTaskList[val]
  464. if data != nil {
  465. taskInfo := &serverproto.TaskData{
  466. TaskId: data.GroupTaskId,
  467. State: TASK_REWARD_STATE_NONE,
  468. //BeginTime: util.GetTimeMilliseconds(),
  469. TaskType: data.TaskType,
  470. }
  471. this.mapGroupHard2TaskList[data.GroupTaskId] = taskInfo
  472. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  473. }
  474. }
  475. if bSave {
  476. this.SetDirty(true)
  477. }
  478. util.InfoF("uuid:%v init hard task2 group2:%v", this.role.GetUUid(), this.mapGroupHard2TaskList)
  479. }
  480. func (this *RoleTask) getTaskData(taskId uint32) *serverproto.TaskData {
  481. if taskInfo, ok := this.dailyTaskList[taskId]; ok {
  482. return taskInfo
  483. }
  484. if taskInfo, ok := this.weekTaskList[taskId]; ok {
  485. return taskInfo
  486. }
  487. if taskInfo, ok := this.mainTaskList[taskId]; ok {
  488. return taskInfo
  489. }
  490. //if taskInfo, ok := this.mapHardTaskList[taskId]; ok {
  491. // return taskInfo
  492. //}
  493. return nil
  494. }
  495. func (this *RoleTask) getTaskHardAllData(taskId uint32) *serverproto.TaskData {
  496. if taskInfo, ok := this.mapHardTaskList[taskId]; ok {
  497. return taskInfo
  498. }
  499. if taskInfo, ok := this.mapGroupHardTaskList[taskId]; ok {
  500. return taskInfo
  501. }
  502. return nil
  503. }
  504. func (this *RoleTask) getTaskHard2AllData(taskId uint32) *serverproto.TaskData {
  505. if taskInfo, ok := this.mapHard2TaskList[taskId]; ok {
  506. return taskInfo
  507. }
  508. if taskInfo, ok := this.mapGroupHard2TaskList[taskId]; ok {
  509. return taskInfo
  510. }
  511. return nil
  512. }
  513. func (this *RoleTask) getTaskHardData(taskId uint32) *serverproto.TaskData {
  514. if taskInfo, ok := this.mapHardTaskList[taskId]; ok {
  515. return taskInfo
  516. }
  517. return nil
  518. }
  519. func (this *RoleTask) getGroupTaskHardData(taskId uint32) *serverproto.TaskData {
  520. if taskInfo, ok := this.mapGroupHardTaskList[taskId]; ok {
  521. return taskInfo
  522. }
  523. return nil
  524. }
  525. func (this *RoleTask) getTaskHard2Data(taskId uint32) *serverproto.TaskData {
  526. if taskInfo, ok := this.mapHard2TaskList[taskId]; ok {
  527. return taskInfo
  528. }
  529. return nil
  530. }
  531. func (this *RoleTask) getGroupTaskHard2Data(taskId uint32) *serverproto.TaskData {
  532. if taskInfo, ok := this.mapGroupHard2TaskList[taskId]; ok {
  533. return taskInfo
  534. }
  535. return nil
  536. }
  537. func (this *RoleTask) initTaskTypeList() {
  538. if len(this.taskTypeList) <= 0 {
  539. //dailyTaskList
  540. for _, taskInfo := range this.dailyTaskList {
  541. convertData, ok := model.ConvertTaskList[taskInfo.TaskId]
  542. if !ok {
  543. continue
  544. }
  545. for key := range convertData.Condition {
  546. if _, ok := this.taskTypeList[key]; !ok {
  547. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  548. }
  549. this.taskTypeList[key].Add(taskInfo.TaskId)
  550. }
  551. }
  552. //weekTaskList
  553. for _, taskInfo := range this.weekTaskList {
  554. convertData, ok := model.ConvertTaskList[taskInfo.TaskId]
  555. if !ok {
  556. continue
  557. }
  558. for key := range convertData.Condition {
  559. if _, ok := this.taskTypeList[key]; !ok {
  560. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  561. }
  562. this.taskTypeList[key].Add(taskInfo.TaskId)
  563. }
  564. }
  565. //mainTaskList
  566. //主线已经完成的不再完成
  567. for _, taskInfo := range this.mainTaskList {
  568. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  569. continue
  570. }
  571. convertData, ok := model.ConvertTaskList[taskInfo.TaskId]
  572. if !ok {
  573. continue
  574. }
  575. for key := range convertData.Condition {
  576. if _, ok := this.taskTypeList[key]; !ok {
  577. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  578. }
  579. this.taskTypeList[key].Add(taskInfo.TaskId)
  580. }
  581. }
  582. for _, taskInfo := range this.mapHardTaskList {
  583. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  584. continue
  585. }
  586. convertData, ok := model.HardMissionTaskList[taskInfo.TaskId]
  587. if !ok {
  588. continue
  589. }
  590. for key := range convertData.Condition {
  591. if _, ok := this.taskTypeList[key]; !ok {
  592. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  593. }
  594. this.taskTypeList[key].Add(taskInfo.TaskId)
  595. }
  596. }
  597. for _, taskInfo := range this.mapGroupHardTaskList {
  598. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  599. continue
  600. }
  601. convertData, ok := model.HardGroupMissionTaskList[taskInfo.TaskId]
  602. if !ok {
  603. continue
  604. }
  605. for key := range convertData.Condition {
  606. if _, ok := this.taskTypeList[key]; !ok {
  607. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  608. }
  609. this.taskTypeList[key].Add(taskInfo.TaskId)
  610. }
  611. }
  612. for _, taskInfo := range this.mapHard2TaskList {
  613. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  614. continue
  615. }
  616. convertData, ok := model.Hard2MissionTaskList[taskInfo.TaskId]
  617. if !ok {
  618. continue
  619. }
  620. for key := range convertData.Condition {
  621. if _, ok := this.taskTypeList[key]; !ok {
  622. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  623. }
  624. this.taskTypeList[key].Add(taskInfo.TaskId)
  625. }
  626. }
  627. for _, taskInfo := range this.mapGroupHard2TaskList {
  628. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  629. continue
  630. }
  631. convertData, ok := model.Hard2GroupMissionTaskList[taskInfo.TaskId]
  632. if !ok {
  633. continue
  634. }
  635. for key := range convertData.Condition {
  636. if _, ok := this.taskTypeList[key]; !ok {
  637. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  638. }
  639. this.taskTypeList[key].Add(taskInfo.TaskId)
  640. }
  641. }
  642. }
  643. }
  644. func (this *RoleTask) TaskCheck(taskType serverproto.TaskType, count int32) {
  645. this.initTaskTypeList()
  646. typeList, ok := this.taskTypeList[int32(taskType)]
  647. if !ok || typeList.Size() <= 0 {
  648. return
  649. }
  650. ntfMsg := &serverproto.SCTaskChangeNtf{
  651. DailyTaskScore: &this.dailyTaskScore,
  652. WeekTaskScore: &this.weekTaskScore,
  653. }
  654. for _, val := range this.taskTypeList[int32(taskType)].List() {
  655. tmpTaskId := val.(uint32)
  656. if taskType == serverproto.TaskType_Level_Hard_Battle_Count {
  657. if taskInfo := this.getTaskHardAllData(tmpTaskId); taskInfo != nil {
  658. if taskInfo.TaskType == model.TASK_TYPE_HARD {
  659. convertTaskData, ok := model.HardMissionTaskList[taskInfo.TaskId]
  660. if !ok {
  661. util.ErrorF("uid=%v TaskCheck TaskCfgData not exist", this.role.GetUUid(), taskInfo)
  662. continue
  663. }
  664. if taskInfo.State != TASK_REWARD_STATE_COMPLETED &&
  665. taskInfo.State != TASK_REWARD_STATE_REWARD {
  666. util.InfoF("uid=%v TaskCheck before taskInfo=%v", this.role.GetUUid(), taskInfo)
  667. }
  668. //多条件处理
  669. ret := TaskConditionCheck(this.role, taskInfo, taskType, convertTaskData.Condition, count, false)
  670. if ret {
  671. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  672. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  673. this.SetDirty(true)
  674. }
  675. } else if taskInfo.TaskType == model.TASK_TYPE_HARD_GROUP {
  676. convertTaskData, ok := model.HardGroupMissionTaskList[taskInfo.TaskId]
  677. if !ok {
  678. util.ErrorF("uid=%v TaskCheck TaskCfgData not exist", this.role.GetUUid(), taskInfo)
  679. continue
  680. }
  681. if taskInfo.State != TASK_REWARD_STATE_COMPLETED &&
  682. taskInfo.State != TASK_REWARD_STATE_REWARD {
  683. util.InfoF("uid=%v TaskCheck before taskInfo=%v", this.role.GetUUid(), taskInfo)
  684. }
  685. //多条件处理
  686. ret := TaskConditionCheck(this.role, taskInfo, taskType, convertTaskData.Condition, count, false)
  687. if ret {
  688. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  689. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  690. this.SetDirty(true)
  691. }
  692. }
  693. }
  694. } else if taskType == serverproto.TaskType_Level_Hard_Battle2_Count {
  695. if taskInfo := this.getTaskHard2AllData(tmpTaskId); taskInfo != nil {
  696. if taskInfo.TaskType == model.TASK_TYPE_HARD2 {
  697. convertTaskData, ok := model.Hard2MissionTaskList[taskInfo.TaskId]
  698. if !ok {
  699. util.ErrorF("uid=%v TaskCheck TaskCfgData not exist", this.role.GetUUid(), taskInfo)
  700. continue
  701. }
  702. if taskInfo.State != TASK_REWARD_STATE_COMPLETED &&
  703. taskInfo.State != TASK_REWARD_STATE_REWARD {
  704. util.InfoF("uid=%v TaskCheck before taskInfo=%v", this.role.GetUUid(), taskInfo)
  705. }
  706. //多条件处理
  707. ret := TaskConditionCheck(this.role, taskInfo, taskType, convertTaskData.Condition, count, false)
  708. if ret {
  709. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  710. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  711. this.SetDirty(true)
  712. }
  713. } else if taskInfo.TaskType == model.TASK_TYPE_HARD2_GROUP {
  714. convertTaskData, ok := model.Hard2GroupMissionTaskList[taskInfo.TaskId]
  715. if !ok {
  716. util.ErrorF("uid=%v TaskCheck TaskCfgData not exist", this.role.GetUUid(), taskInfo)
  717. continue
  718. }
  719. if taskInfo.State != TASK_REWARD_STATE_COMPLETED &&
  720. taskInfo.State != TASK_REWARD_STATE_REWARD {
  721. util.InfoF("uid=%v TaskCheck before taskInfo=%v", this.role.GetUUid(), taskInfo)
  722. }
  723. //多条件处理
  724. ret := TaskConditionCheck(this.role, taskInfo, taskType, convertTaskData.Condition, count, false)
  725. if ret {
  726. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  727. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  728. this.SetDirty(true)
  729. }
  730. }
  731. }
  732. } else {
  733. if taskInfo := this.getTaskData(tmpTaskId); taskInfo != nil {
  734. convertTaskData, ok := model.ConvertTaskList[taskInfo.TaskId]
  735. if !ok {
  736. util.ErrorF("uid=%v TaskCheck TaskCfgData not exist", this.role.GetUUid(), taskInfo)
  737. continue
  738. }
  739. if taskInfo.State != TASK_REWARD_STATE_COMPLETED &&
  740. taskInfo.State != TASK_REWARD_STATE_REWARD {
  741. util.InfoF("uid=%v TaskCheck before taskInfo=%v", this.role.GetUUid(), taskInfo)
  742. }
  743. //多条件处理
  744. ret := TaskConditionCheck(this.role, taskInfo, taskType, convertTaskData.Condition, count, false)
  745. if ret {
  746. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  747. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  748. this.SetDirty(true)
  749. }
  750. }
  751. }
  752. }
  753. //追加困难模式任务
  754. if taskType == serverproto.TaskType_Level_Hard_Battle_Count {
  755. this.AddHardTask()
  756. }
  757. if taskType == serverproto.TaskType_Level_Hard_Battle2_Count {
  758. this.AddHard2Task()
  759. }
  760. if len(ntfMsg.TaskChangeList) > 0 {
  761. this.role.ReplayGate(ntfMsg, true)
  762. util.InfoF("uid=%v TaskCheck changelist=%v", this.role.GetUUid(), ntfMsg.TaskChangeList)
  763. }
  764. }
  765. func (this *RoleTask) jobConditionChangeNtf(changedId []int32) {
  766. ntfMsg := &serverproto.SCHeroConditinDataNtf{}
  767. for _, heroId := range changedId {
  768. for index, data := range this.jobCondition {
  769. if data.HeroId == heroId {
  770. ntfMsg.Condition = append(ntfMsg.Condition, this.jobCondition[index])
  771. }
  772. }
  773. }
  774. this.role.ReplayGate(ntfMsg, true)
  775. this.role.GetRoleBase().SetDirty(true)
  776. util.DebugF("uid=%v jobcondition=%v", this.role.GetUUid(), this.jobCondition)
  777. }
  778. func (this *RoleTask) checkTaskInfo(taskInfo *serverproto.TaskData) bool {
  779. convertData, ok := model.ConvertTaskList[taskInfo.TaskId]
  780. if !ok {
  781. return false
  782. }
  783. return TaskConditionCheck(this.role, taskInfo, 0, convertData.Condition, 0, true)
  784. }
  785. func (this *RoleTask) GetTaskReward(taskId uint32) serverproto.ErrorCode {
  786. this.initTaskTypeList()
  787. taskInfo := this.getTaskData(taskId)
  788. if taskInfo == nil {
  789. return serverproto.ErrorCode_ERROR_FAIL
  790. }
  791. if taskInfo.State == TASK_REWARD_STATE_REWARD {
  792. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  793. }
  794. //应对玩家任务条件调整
  795. if taskInfo.State != TASK_REWARD_STATE_COMPLETED {
  796. if this.checkTaskInfo(taskInfo) {
  797. if taskInfo.State != TASK_REWARD_STATE_COMPLETED {
  798. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  799. }
  800. } else {
  801. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  802. }
  803. }
  804. convertTaskData, ok := model.ConvertTaskList[taskInfo.TaskId]
  805. if !ok {
  806. return serverproto.ErrorCode_ERROR_FAIL
  807. }
  808. //获取奖励
  809. var addItemList = map[int32]int32{}
  810. for _, value := range convertTaskData.TaskReward {
  811. addItemList[value.Key] = value.Value
  812. }
  813. //无道具有积分
  814. if len(addItemList) > 0 {
  815. //道具入背包
  816. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  817. return ret
  818. }
  819. this.role.AddItemList(addItemList, AddFrom_Task, true)
  820. }
  821. ntfMsg := &serverproto.SCTaskChangeNtf{
  822. DailyTaskScore: &this.dailyTaskScore,
  823. WeekTaskScore: &this.weekTaskScore,
  824. }
  825. //是否有后续任务,自动接取后续任务
  826. taskInfo.State = TASK_REWARD_STATE_REWARD
  827. switch taskInfo.TaskType {
  828. case model.TASK_TYPE_DAILY:
  829. this.dailyTaskScore.Value += convertTaskData.TaskScore
  830. case model.TASK_TYPE_WEEK:
  831. this.weekTaskScore.Value += convertTaskData.TaskScore
  832. }
  833. if rune := this.role.GetRoleRune(); rune != nil {
  834. rune.AddMissionExp(convertTaskData.TaskScore)
  835. }
  836. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  837. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  838. if convertTaskData.NextTaskId != 0 {
  839. ////获取下一个任务的继承数值
  840. //var preTaskCount int32 = 0
  841. //if _, tmpOk := convertTaskData.Condition[int32(serverproto.TaskType_Get_Silver_Count)]; tmpOk {
  842. // for idx := 0; idx < len(taskInfo.Progress); idx++ {
  843. // if taskInfo.Progress[idx].Key == int32(serverproto.TaskType_Get_Silver_Count) {
  844. // preTaskCount = taskInfo.Progress[idx].Value
  845. // }
  846. // }
  847. //}
  848. if taskInfo.TaskType == model.TASK_TYPE_MAIN {
  849. taskInfo.Progress = taskInfo.Progress[:0]
  850. for key, _ := range convertTaskData.Condition {
  851. if _, ok := this.taskTypeList[key]; ok {
  852. this.taskTypeList[key].Remove(taskInfo.TaskId)
  853. }
  854. }
  855. delete(this.mainTaskList, taskInfo.TaskId)
  856. }
  857. nextTaskInfo := this.genNextTask(convertTaskData.NextTaskId, 0)
  858. if nextTaskInfo != nil {
  859. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, nextTaskInfo)
  860. }
  861. }
  862. this.SetDirty(true)
  863. this.role.ReplayGate(ntfMsg, true)
  864. //发送奖励数据(客户端显示)
  865. ackMsg := &serverproto.SCGetTaskRewardAck{
  866. Error: int32(serverproto.ErrorCode_ERROR_OK),
  867. }
  868. ackMsg.ItemList = append(convertTaskData.TaskReward)
  869. this.role.ReplayGate(ackMsg, true)
  870. //任务完成活跃度增加
  871. cfgData, ok := serverproto.MissionCfgLoader[int32(taskId)]
  872. if ok {
  873. this.role.roleGuild.AddGuildActivity(cfgData.Active)
  874. }
  875. util.DebugF("uid=%v SCGetTaskRewardAck current task reward=%v", this.role.GetUUid(), convertTaskData.TaskId)
  876. util.DebugF("uid=%v SCTaskChangeNtf msg=%v", this.role.GetUUid(), ntfMsg)
  877. return serverproto.ErrorCode_ERROR_OK
  878. }
  879. func (this *RoleTask) AddHardTask() bool {
  880. var (
  881. count2 int32 //未完成任务组数量
  882. maxGroupId uint32 //最后一组 组id
  883. //ggId uint32
  884. )
  885. for _, v := range this.mapGroupHardTaskList {
  886. if v.State == TASK_REWARD_STATE_NONE {
  887. count2++
  888. //if maxGroupId < v.TaskId {
  889. // maxGroupId = v.TaskId
  890. //}
  891. break
  892. }
  893. if maxGroupId < v.TaskId {
  894. maxGroupId = v.TaskId
  895. }
  896. }
  897. if count2 < 1 {
  898. ////一下全部完成了任务
  899. //if maxGroupId == 0 {
  900. // maxGroupId = ggId
  901. //}
  902. var (
  903. count3 int32
  904. count4 int32
  905. maxId uint32 //最后一个小任务id
  906. )
  907. if v, ok := model.HardGroupMissionTaskList[maxGroupId]; ok {
  908. maxId = v.TaskId
  909. }
  910. ntfMsg := &serverproto.SCTaskChangeNtf{
  911. DailyTaskScore: &this.dailyTaskScore,
  912. WeekTaskScore: &this.weekTaskScore,
  913. }
  914. for _, val := range model.HardGroupMissionTaskIdList {
  915. //初始化5组 组任务
  916. if count3 >= 5 {
  917. break
  918. }
  919. if val <= maxGroupId {
  920. continue
  921. }
  922. data := model.HardGroupMissionTaskList[val]
  923. if data != nil {
  924. taskInfo := &serverproto.TaskData{
  925. TaskId: data.GroupTaskId,
  926. State: TASK_REWARD_STATE_NONE,
  927. //BeginTime: util.GetTimeMilliseconds(),
  928. TaskType: data.TaskType,
  929. }
  930. passNum := this.role.GetRoleBattle().GetPassHardBattleIdNum(data.Condition[int32(serverproto.TaskType_Level_Hard_Battle_Count)][1])
  931. if passNum == 1 {
  932. taskInfo.State = TASK_REWARD_STATE_COMPLETED
  933. taskInfo.Progress = []*serverproto.TaskProgressType{{Key: 102, Value: 1, State: 1}}
  934. }
  935. this.mapGroupHardTaskList[data.GroupTaskId] = taskInfo
  936. //role.roleTask.loadTaskData.TaskList = append(role.roleTask.loadTaskData.TaskList, taskInfo)
  937. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  938. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  939. //util.InfoF("add task gg:%v", taskInfo)
  940. count3++
  941. }
  942. }
  943. for _, val := range model.HardMissionTaskIdList {
  944. //每组任务3个,目前只初始化5组所以是15个任务
  945. if count4 >= 15 {
  946. break
  947. }
  948. if val <= maxId {
  949. continue
  950. }
  951. data := model.HardMissionTaskList[val]
  952. if data != nil {
  953. taskInfo := &serverproto.TaskData{
  954. TaskId: data.TaskId,
  955. State: TASK_REWARD_STATE_NONE,
  956. //BeginTime: util.GetTimeMilliseconds(),
  957. TaskType: data.TaskType,
  958. }
  959. passNum := this.role.GetRoleBattle().GetPassHardBattleIdNum(data.Condition[int32(serverproto.TaskType_Level_Hard_Battle_Count)][1])
  960. if passNum == 1 {
  961. taskInfo.State = TASK_REWARD_STATE_COMPLETED
  962. taskInfo.Progress = []*serverproto.TaskProgressType{{Key: 102, Value: 1, State: 1}}
  963. }
  964. this.mapHardTaskList[data.TaskId] = taskInfo
  965. //this.loadTaskData.TaskList = append(this.loadTaskData.TaskList, taskInfo)
  966. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  967. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  968. //util.InfoF("add task gg2:%v", taskInfo)
  969. count4++
  970. }
  971. }
  972. for _, taskInfo := range this.mapHardTaskList {
  973. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  974. continue
  975. }
  976. convertData, ok := model.HardMissionTaskList[taskInfo.TaskId]
  977. if !ok {
  978. continue
  979. }
  980. for key := range convertData.Condition {
  981. if _, ok := this.taskTypeList[key]; !ok {
  982. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  983. }
  984. this.taskTypeList[key].Add(taskInfo.TaskId)
  985. }
  986. }
  987. for _, taskInfo := range this.mapGroupHardTaskList {
  988. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  989. continue
  990. }
  991. convertData, ok := model.HardGroupMissionTaskList[taskInfo.TaskId]
  992. if !ok {
  993. continue
  994. }
  995. for key := range convertData.Condition {
  996. if _, ok := this.taskTypeList[key]; !ok {
  997. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  998. }
  999. this.taskTypeList[key].Add(taskInfo.TaskId)
  1000. }
  1001. }
  1002. this.role.ReplayGate(ntfMsg, true)
  1003. this.role.roleTask.SetDirty(true)
  1004. //util.InfoF("uuid:%v add start hard group taskId:%v little taskId:%v task info:%v group info:%v", this.role.GetUUid(), maxGroupId, maxId, this.role.roleTask.mapHardTaskList, this.role.roleTask.mapGroupHardTaskList)
  1005. if len(ntfMsg.TaskChangeList) > 0 {
  1006. return true
  1007. } else {
  1008. return false
  1009. }
  1010. }
  1011. return false
  1012. }
  1013. func (this *RoleTask) AddHard2Task() bool {
  1014. var (
  1015. count2 int32 //未完成任务组数量
  1016. maxGroupId uint32 //最后一组 组id
  1017. //ggId uint32
  1018. )
  1019. for _, v := range this.mapGroupHard2TaskList {
  1020. if v.State == TASK_REWARD_STATE_NONE {
  1021. count2++
  1022. //if maxGroupId < v.TaskId {
  1023. // maxGroupId = v.TaskId
  1024. //}
  1025. break
  1026. }
  1027. if maxGroupId < v.TaskId {
  1028. maxGroupId = v.TaskId
  1029. }
  1030. }
  1031. if count2 < 1 {
  1032. ////一下全部完成了任务
  1033. //if maxGroupId == 0 {
  1034. // maxGroupId = ggId
  1035. //}
  1036. var (
  1037. count3 int32
  1038. count4 int32
  1039. maxId uint32 //最后一个小任务id
  1040. )
  1041. if v, ok := model.Hard2GroupMissionTaskList[maxGroupId]; ok {
  1042. maxId = v.TaskId
  1043. }
  1044. ntfMsg := &serverproto.SCTaskChangeNtf{
  1045. DailyTaskScore: &this.dailyTaskScore,
  1046. WeekTaskScore: &this.weekTaskScore,
  1047. }
  1048. for _, val := range model.Hard2GroupMissionTaskIdList {
  1049. //初始化5组 组任务
  1050. if count3 >= 5 {
  1051. break
  1052. }
  1053. if val <= maxGroupId {
  1054. continue
  1055. }
  1056. data := model.Hard2GroupMissionTaskList[val]
  1057. if data != nil {
  1058. taskInfo := &serverproto.TaskData{
  1059. TaskId: data.GroupTaskId,
  1060. State: TASK_REWARD_STATE_NONE,
  1061. //BeginTime: util.GetTimeMilliseconds(),
  1062. TaskType: data.TaskType,
  1063. }
  1064. passNum := this.role.GetRoleBattle().GetPassHardBattle2IdNum(data.Condition[int32(serverproto.TaskType_Level_Hard_Battle2_Count)][1])
  1065. if passNum == 1 {
  1066. taskInfo.State = TASK_REWARD_STATE_COMPLETED
  1067. taskInfo.Progress = []*serverproto.TaskProgressType{{Key: 102, Value: 1, State: 1}}
  1068. }
  1069. this.mapGroupHard2TaskList[data.GroupTaskId] = taskInfo
  1070. //role.roleTask.loadTaskData.TaskList = append(role.roleTask.loadTaskData.TaskList, taskInfo)
  1071. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  1072. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  1073. //util.InfoF("add task gg:%v", taskInfo)
  1074. count3++
  1075. }
  1076. }
  1077. for _, val := range model.Hard2MissionTaskIdList {
  1078. //每组任务3个,目前只初始化5组所以是15个任务
  1079. if count4 >= 15 {
  1080. break
  1081. }
  1082. if val <= maxId {
  1083. continue
  1084. }
  1085. data := model.Hard2MissionTaskList[val]
  1086. if data != nil {
  1087. taskInfo := &serverproto.TaskData{
  1088. TaskId: data.TaskId,
  1089. State: TASK_REWARD_STATE_NONE,
  1090. //BeginTime: util.GetTimeMilliseconds(),
  1091. TaskType: data.TaskType,
  1092. }
  1093. passNum := this.role.GetRoleBattle().GetPassHardBattle2IdNum(data.Condition[int32(serverproto.TaskType_Level_Hard_Battle2_Count)][1])
  1094. if passNum == 1 {
  1095. taskInfo.State = TASK_REWARD_STATE_COMPLETED
  1096. taskInfo.Progress = []*serverproto.TaskProgressType{{Key: 102, Value: 1, State: 1}}
  1097. }
  1098. this.mapHard2TaskList[data.TaskId] = taskInfo
  1099. //this.loadTaskData.TaskList = append(this.loadTaskData.TaskList, taskInfo)
  1100. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  1101. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, taskInfo)
  1102. //util.InfoF("add task gg2:%v", taskInfo)
  1103. count4++
  1104. }
  1105. }
  1106. for _, taskInfo := range this.mapHard2TaskList {
  1107. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  1108. continue
  1109. }
  1110. convertData, ok := model.Hard2MissionTaskList[taskInfo.TaskId]
  1111. if !ok {
  1112. continue
  1113. }
  1114. for key := range convertData.Condition {
  1115. if _, ok := this.taskTypeList[key]; !ok {
  1116. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  1117. }
  1118. this.taskTypeList[key].Add(taskInfo.TaskId)
  1119. }
  1120. }
  1121. for _, taskInfo := range this.mapGroupHard2TaskList {
  1122. if taskInfo.State == TASK_REWARD_STATE_COMPLETED {
  1123. continue
  1124. }
  1125. convertData, ok := model.Hard2GroupMissionTaskList[taskInfo.TaskId]
  1126. if !ok {
  1127. continue
  1128. }
  1129. for key := range convertData.Condition {
  1130. if _, ok := this.taskTypeList[key]; !ok {
  1131. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  1132. }
  1133. this.taskTypeList[key].Add(taskInfo.TaskId)
  1134. }
  1135. }
  1136. this.role.ReplayGate(ntfMsg, true)
  1137. this.role.roleTask.SetDirty(true)
  1138. //util.InfoF("uuid:%v add start hard2 group taskId:%v little taskId:%v task info:%v group info:%v", this.role.GetUUid(), maxGroupId, maxId, this.role.roleTask.mapHardTaskList, this.role.roleTask.mapGroupHardTaskList)
  1139. if len(ntfMsg.TaskChangeList) > 0 {
  1140. return true
  1141. } else {
  1142. return false
  1143. }
  1144. }
  1145. return false
  1146. }
  1147. func (this *RoleTask) GetTaskScoreReward(rewardType, rewardIdx uint32) serverproto.ErrorCode {
  1148. this.initTaskTypeList()
  1149. if (rewardIdx <= 0 || rewardIdx > 32) && rewardType != model.TASK_TYPE_HARD && rewardType != model.TASK_TYPE_HARD_GROUP && rewardType != model.TASK_TYPE_HARD2_GROUP && rewardType != model.TASK_TYPE_HARD2 {
  1150. return serverproto.ErrorCode_ERROR_FAIL
  1151. }
  1152. //发送奖励数据(客户端显示)
  1153. ackMsg := &serverproto.SCGetTaskScoreRewardAck{
  1154. Error: int32(serverproto.ErrorCode_ERROR_OK),
  1155. }
  1156. //获取奖励
  1157. var addItemList = map[int32]int32{}
  1158. if rewardType == model.TASK_TYPE_DAILY { //daily
  1159. if this.dailyTaskScore.Key&(1<<rewardIdx) > 0 {
  1160. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_REWARDED
  1161. }
  1162. convertData, ok := model.ConvertDailyTaskScoreRewardList[rewardIdx]
  1163. if !ok {
  1164. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_FOUND
  1165. }
  1166. if convertData.Active > this.dailyTaskScore.Value {
  1167. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_ENOUGH
  1168. }
  1169. for _, value := range convertData.RewardList {
  1170. addItemList[value.Key] = value.Value
  1171. }
  1172. //活动掉落指定道具
  1173. for _, value := range convertData.HDRewardList {
  1174. if !CheckHDItemAdd(value.Key, this.role) {
  1175. continue
  1176. }
  1177. addItemList[value.Key] = value.Value
  1178. }
  1179. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  1180. return ret
  1181. }
  1182. this.dailyTaskScore.Key |= 1 << rewardIdx
  1183. this.SetDirty(true)
  1184. } else if rewardType == model.TASK_TYPE_WEEK { //week
  1185. if this.weekTaskScore.Key&(1<<rewardIdx) > 0 {
  1186. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_REWARDED
  1187. }
  1188. convertData, ok := model.ConvertWeekTaskScoreRewardList[rewardIdx]
  1189. if !ok {
  1190. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_FOUND
  1191. }
  1192. if convertData.Active > this.weekTaskScore.Value {
  1193. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_ENOUGH
  1194. }
  1195. for _, value := range convertData.RewardList {
  1196. addItemList[value.Key] = value.Value
  1197. }
  1198. //活动掉落指定道具
  1199. for _, value := range convertData.HDRewardList {
  1200. if !CheckHDItemAdd(value.Key, this.role) {
  1201. continue
  1202. }
  1203. addItemList[value.Key] = value.Value
  1204. }
  1205. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  1206. return ret
  1207. }
  1208. this.weekTaskScore.Key |= 1 << rewardIdx
  1209. this.SetDirty(true)
  1210. } else if rewardType == model.TASK_TYPE_HARD {
  1211. taskInfo := this.getTaskHardData(rewardIdx)
  1212. if taskInfo == nil {
  1213. return serverproto.ErrorCode_ERROR_FAIL
  1214. }
  1215. if taskInfo.State == TASK_REWARD_STATE_REWARD || taskInfo.State == TASK_REWARD_STATE_NONE {
  1216. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  1217. }
  1218. convertData, ok := model.HardMissionTaskList[rewardIdx]
  1219. if !ok {
  1220. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_FOUND
  1221. }
  1222. for _, value := range convertData.TaskReward {
  1223. addItemList[value.Key] = value.Value
  1224. }
  1225. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  1226. return ret
  1227. }
  1228. taskInfo.State = TASK_REWARD_STATE_REWARD
  1229. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  1230. this.SetDirty(true)
  1231. } else if rewardType == model.TASK_TYPE_HARD_GROUP {
  1232. taskInfo := this.getGroupTaskHardData(rewardIdx)
  1233. if taskInfo == nil {
  1234. return serverproto.ErrorCode_ERROR_FAIL
  1235. }
  1236. if taskInfo.State == TASK_REWARD_STATE_REWARD || taskInfo.State == TASK_REWARD_STATE_NONE {
  1237. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  1238. }
  1239. convertData, ok := model.HardGroupMissionTaskList[rewardIdx]
  1240. if !ok {
  1241. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_FOUND
  1242. }
  1243. //没找到这组的奖励
  1244. if len(convertData.GroupTaskReward) == 0 {
  1245. for _, v := range model.HardMissionTaskList {
  1246. if v.GroupTaskId == convertData.GroupTaskId {
  1247. if len(v.GroupTaskReward) != 0 {
  1248. convertData.GroupTaskReward = v.GroupTaskReward
  1249. break
  1250. }
  1251. }
  1252. }
  1253. }
  1254. for _, value := range convertData.GroupTaskReward {
  1255. addItemList[value.Key] = value.Value
  1256. }
  1257. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  1258. return ret
  1259. }
  1260. taskInfo.State = TASK_REWARD_STATE_REWARD
  1261. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  1262. this.SetDirty(true)
  1263. } else if rewardType == model.TASK_TYPE_HARD2 {
  1264. taskInfo := this.getTaskHard2Data(rewardIdx)
  1265. if taskInfo == nil {
  1266. return serverproto.ErrorCode_ERROR_FAIL
  1267. }
  1268. if taskInfo.State == TASK_REWARD_STATE_REWARD || taskInfo.State == TASK_REWARD_STATE_NONE {
  1269. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  1270. }
  1271. convertData, ok := model.Hard2MissionTaskList[rewardIdx]
  1272. if !ok {
  1273. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_FOUND
  1274. }
  1275. for _, value := range convertData.TaskReward {
  1276. addItemList[value.Key] = value.Value
  1277. }
  1278. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  1279. return ret
  1280. }
  1281. taskInfo.State = TASK_REWARD_STATE_REWARD
  1282. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  1283. this.SetDirty(true)
  1284. } else if rewardType == model.TASK_TYPE_HARD2_GROUP {
  1285. taskInfo := this.getGroupTaskHard2Data(rewardIdx)
  1286. if taskInfo == nil {
  1287. return serverproto.ErrorCode_ERROR_FAIL
  1288. }
  1289. if taskInfo.State == TASK_REWARD_STATE_REWARD || taskInfo.State == TASK_REWARD_STATE_NONE {
  1290. return serverproto.ErrorCode_ERROR_TASK_REWARDED
  1291. }
  1292. convertData, ok := model.Hard2GroupMissionTaskList[rewardIdx]
  1293. if !ok {
  1294. return serverproto.ErrorCode_ERROR_ROLE_TASK_SCORE_NOT_FOUND
  1295. }
  1296. //没找到这组的奖励
  1297. if len(convertData.GroupTaskReward) == 0 {
  1298. for _, v := range model.HardMissionTaskList {
  1299. if v.GroupTaskId == convertData.GroupTaskId {
  1300. if len(v.GroupTaskReward) != 0 {
  1301. convertData.GroupTaskReward = v.GroupTaskReward
  1302. break
  1303. }
  1304. }
  1305. }
  1306. }
  1307. for _, value := range convertData.GroupTaskReward {
  1308. addItemList[value.Key] = value.Value
  1309. }
  1310. if ret := this.role.CanAddItemList(addItemList); ret != serverproto.ErrorCode_ERROR_OK {
  1311. return ret
  1312. }
  1313. taskInfo.State = TASK_REWARD_STATE_REWARD
  1314. this.saveTaskDataList = append(this.saveTaskDataList, taskInfo)
  1315. this.SetDirty(true)
  1316. }
  1317. for key, val := range addItemList {
  1318. ackMsg.ItemList = append(ackMsg.ItemList, &serverproto.KeyValueType{
  1319. Key: key,
  1320. Value: val,
  1321. })
  1322. }
  1323. ntfMsg := &serverproto.SCTaskChangeNtf{
  1324. DailyTaskScore: &this.dailyTaskScore,
  1325. WeekTaskScore: &this.weekTaskScore,
  1326. }
  1327. switch rewardType {
  1328. case model.TASK_TYPE_HARD:
  1329. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, this.getTaskHardData(rewardIdx))
  1330. case model.TASK_TYPE_HARD_GROUP:
  1331. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, this.getGroupTaskHardData(rewardIdx))
  1332. case model.TASK_TYPE_HARD2:
  1333. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, this.getTaskHard2Data(rewardIdx))
  1334. case model.TASK_TYPE_HARD2_GROUP:
  1335. ntfMsg.TaskChangeList = append(ntfMsg.TaskChangeList, this.getGroupTaskHard2Data(rewardIdx))
  1336. }
  1337. this.role.ReplayGate(ntfMsg, true)
  1338. switch rewardType {
  1339. case model.TASK_TYPE_HARD:
  1340. this.CheckHardTaskAndDelete(rewardIdx)
  1341. case model.TASK_TYPE_HARD_GROUP:
  1342. this.CheckHardGroupTaskAndDelete(rewardIdx)
  1343. case model.TASK_TYPE_HARD2:
  1344. this.CheckHard2TaskAndDelete(rewardIdx)
  1345. case model.TASK_TYPE_HARD2_GROUP:
  1346. this.CheckHard2GroupTaskAndDelete(rewardIdx)
  1347. }
  1348. this.role.AddItemList(addItemList, AddFrom_Task, true)
  1349. this.role.ReplayGate(ackMsg, true)
  1350. util.DebugF("uid=%v, GetTaskScoreReward current task type=%v idx=%v additemlist=%v",
  1351. this.role.GetUUid(), rewardType, rewardIdx, addItemList)
  1352. return serverproto.ErrorCode_ERROR_OK
  1353. }
  1354. func (this *RoleTask) CheckHardGroupTaskAndDelete(groupTaskId uint32) {
  1355. groupTask := this.getGroupTaskHardData(groupTaskId)
  1356. isDelete := true
  1357. list := make([]uint32, 0)
  1358. for _, v := range this.mapHardTaskList {
  1359. if v2, ok := model.HardMissionTaskList[v.TaskId]; ok {
  1360. if v2.GroupTaskId == groupTask.TaskId {
  1361. list = append(list, v.TaskId)
  1362. if v.State != TASK_REWARD_STATE_REWARD {
  1363. isDelete = false
  1364. break
  1365. }
  1366. }
  1367. }
  1368. }
  1369. if isDelete {
  1370. //最后一组任务删除前新增任务
  1371. if len(this.mapGroupHardTaskList) == 1 {
  1372. if !this.AddHardTask() {
  1373. return
  1374. }
  1375. }
  1376. for _, v := range list {
  1377. task := this.getTaskHardData(v)
  1378. task.HardState = TASK_REWARD_STATE_DELETE
  1379. this.saveTaskDataList = append(this.saveTaskDataList, task)
  1380. delete(this.mapHardTaskList, v)
  1381. }
  1382. task2 := this.getGroupTaskHardData(groupTaskId)
  1383. if task2 != nil {
  1384. task2.HardState = TASK_REWARD_STATE_DELETE
  1385. }
  1386. this.saveTaskDataList = append(this.saveTaskDataList, task2)
  1387. this.SetDirty(true)
  1388. delete(this.mapGroupHardTaskList, groupTaskId)
  1389. util.InfoF("uuid:%v delete groupId:%v saveTask:%v ", this.role.GetUUid(), groupTaskId, this.saveTaskDataList)
  1390. }
  1391. }
  1392. func (this *RoleTask) CheckHard2GroupTaskAndDelete(groupTaskId uint32) {
  1393. groupTask := this.getGroupTaskHard2Data(groupTaskId)
  1394. isDelete := true
  1395. list := make([]uint32, 0)
  1396. for _, v := range this.mapHard2TaskList {
  1397. if v2, ok := model.Hard2MissionTaskList[v.TaskId]; ok {
  1398. if v2.GroupTaskId == groupTask.TaskId {
  1399. list = append(list, v.TaskId)
  1400. if v.State != TASK_REWARD_STATE_REWARD {
  1401. isDelete = false
  1402. break
  1403. }
  1404. }
  1405. }
  1406. }
  1407. if isDelete {
  1408. //最后一组任务删除前新增任务
  1409. if len(this.mapGroupHard2TaskList) == 1 {
  1410. if !this.AddHard2Task() {
  1411. return
  1412. }
  1413. }
  1414. for _, v := range list {
  1415. task := this.getTaskHard2Data(v)
  1416. task.HardState = TASK_REWARD_STATE_DELETE
  1417. this.saveTaskDataList = append(this.saveTaskDataList, task)
  1418. delete(this.mapHard2TaskList, v)
  1419. }
  1420. task2 := this.getGroupTaskHard2Data(groupTaskId)
  1421. if task2 != nil {
  1422. task2.HardState = TASK_REWARD_STATE_DELETE
  1423. }
  1424. this.saveTaskDataList = append(this.saveTaskDataList, task2)
  1425. this.SetDirty(true)
  1426. delete(this.mapGroupHard2TaskList, groupTaskId)
  1427. util.InfoF("uuid:%v delete groupId2:%v saveTask:%v ", this.role.GetUUid(), groupTaskId, this.saveTaskDataList)
  1428. }
  1429. }
  1430. func (this *RoleTask) CheckHardTaskAndDelete(TaskId uint32) {
  1431. var (
  1432. groupId uint32
  1433. isOver bool
  1434. isGroupOver bool
  1435. )
  1436. list := make([]uint32, 0)
  1437. if g, ok := model.HardMissionTaskList[TaskId]; ok {
  1438. groupId = g.GroupTaskId
  1439. }
  1440. if v, ok := this.mapGroupHardTaskList[groupId]; ok {
  1441. if v.State != TASK_REWARD_STATE_REWARD {
  1442. isGroupOver = true
  1443. }
  1444. }
  1445. for _, v := range this.mapHardTaskList {
  1446. if v2, ok := model.HardMissionTaskList[v.TaskId]; ok {
  1447. if v2.GroupTaskId == groupId {
  1448. list = append(list, v.TaskId)
  1449. if v.State != TASK_REWARD_STATE_REWARD {
  1450. isOver = true
  1451. break
  1452. }
  1453. }
  1454. }
  1455. }
  1456. if !isOver && !isGroupOver {
  1457. //for _, v := range list {
  1458. // delete(this.mapHardTaskList, v)
  1459. //}
  1460. //delete(this.mapGroupHardTaskList, groupId)
  1461. //最后一组任务不删除
  1462. if len(this.mapGroupHardTaskList) == 1 {
  1463. if !this.AddHardTask() {
  1464. return
  1465. }
  1466. }
  1467. for _, v := range list {
  1468. task := this.getTaskHardData(v)
  1469. task.HardState = TASK_REWARD_STATE_DELETE
  1470. this.saveTaskDataList = append(this.saveTaskDataList, task)
  1471. delete(this.mapHardTaskList, v)
  1472. }
  1473. task2 := this.getGroupTaskHardData(groupId)
  1474. if task2 != nil {
  1475. task2.HardState = TASK_REWARD_STATE_DELETE
  1476. }
  1477. this.saveTaskDataList = append(this.saveTaskDataList, task2)
  1478. delete(this.mapGroupHardTaskList, groupId)
  1479. this.SetDirty(true)
  1480. util.InfoF("uuid:%v delete groupId2:%v hard task:%v ", this.role.GetUUid(), groupId, list)
  1481. }
  1482. }
  1483. func (this *RoleTask) CheckHard2TaskAndDelete(TaskId uint32) {
  1484. var (
  1485. groupId uint32
  1486. isOver bool
  1487. isGroupOver bool
  1488. )
  1489. list := make([]uint32, 0)
  1490. if g, ok := model.Hard2MissionTaskList[TaskId]; ok {
  1491. groupId = g.GroupTaskId
  1492. }
  1493. if v, ok := this.mapGroupHard2TaskList[groupId]; ok {
  1494. if v.State != TASK_REWARD_STATE_REWARD {
  1495. isGroupOver = true
  1496. }
  1497. }
  1498. for _, v := range this.mapHard2TaskList {
  1499. if v2, ok := model.Hard2MissionTaskList[v.TaskId]; ok {
  1500. if v2.GroupTaskId == groupId {
  1501. list = append(list, v.TaskId)
  1502. if v.State != TASK_REWARD_STATE_REWARD {
  1503. isOver = true
  1504. break
  1505. }
  1506. }
  1507. }
  1508. }
  1509. if !isOver && !isGroupOver {
  1510. //for _, v := range list {
  1511. // delete(this.mapHardTaskList, v)
  1512. //}
  1513. //delete(this.mapGroupHardTaskList, groupId)
  1514. //最后一组任务不删除
  1515. if len(this.mapGroupHard2TaskList) == 1 {
  1516. if !this.AddHard2Task() {
  1517. return
  1518. }
  1519. }
  1520. for _, v := range list {
  1521. task := this.getTaskHard2Data(v)
  1522. task.HardState = TASK_REWARD_STATE_DELETE
  1523. this.saveTaskDataList = append(this.saveTaskDataList, task)
  1524. delete(this.mapHard2TaskList, v)
  1525. }
  1526. task2 := this.getGroupTaskHard2Data(groupId)
  1527. if task2 != nil {
  1528. task2.HardState = TASK_REWARD_STATE_DELETE
  1529. }
  1530. this.saveTaskDataList = append(this.saveTaskDataList, task2)
  1531. delete(this.mapGroupHard2TaskList, groupId)
  1532. this.SetDirty(true)
  1533. util.InfoF("uuid:%v delete groupId2:%v hard2 task:%v ", this.role.GetUUid(), groupId, list)
  1534. }
  1535. }
  1536. // 来自上一个任务的继承数值preTaskCount
  1537. func (this *RoleTask) genNextTask(nextTaskId uint32, preTaskCount int32) *serverproto.TaskData {
  1538. convertTaskData, ok := model.ConvertTaskList[nextTaskId]
  1539. if ok && convertTaskData.TaskType == model.TASK_TYPE_MAIN {
  1540. util.DebugF("uid=%v, genNextTask next task=%v", this.role.GetUUid(), nextTaskId)
  1541. //接取下个任务后自动判断
  1542. nextTaskInfo := &serverproto.TaskData{
  1543. TaskId: nextTaskId,
  1544. State: TASK_REWARD_STATE_NONE,
  1545. //BeginTime: util.GetTimeMilliseconds(),
  1546. TaskType: convertTaskData.TaskType,
  1547. }
  1548. for key := range convertTaskData.Condition {
  1549. if _, ok := this.taskTypeList[key]; !ok {
  1550. this.taskTypeList[key] = set.New(set.NonThreadSafe)
  1551. }
  1552. this.taskTypeList[key].Add(nextTaskId)
  1553. }
  1554. TaskConditionCheck(this.role, nextTaskInfo, serverproto.TaskType_NONE,
  1555. convertTaskData.Condition, preTaskCount, false)
  1556. this.SetDirty(true)
  1557. //save db
  1558. this.saveTaskDataList = append(this.saveTaskDataList, nextTaskInfo)
  1559. this.loadTaskData.TaskList = append(this.loadTaskData.TaskList, nextTaskInfo)
  1560. this.mainTaskList[nextTaskInfo.TaskId] = nextTaskInfo
  1561. return nextTaskInfo
  1562. }
  1563. return nil
  1564. }
  1565. func (this *RoleTask) InitJobTask() {
  1566. for _, data := range this.jobCondition {
  1567. if data.JobFushState > 0 {
  1568. continue
  1569. }
  1570. heroData := this.role.roleHero.GetHero(data.HeroId)
  1571. if heroData == nil {
  1572. continue
  1573. }
  1574. data.JobFushState = 1
  1575. dbIndex := model.GetJobChangeKey(this.role.roleHero.IsMainHero(data.HeroId), heroData.ConfigId)
  1576. db, ok := model.DBJobChange[dbIndex]
  1577. if !ok {
  1578. util.InfoF("ChangeJob JobCfgLoader data not found cfgid=%v, %v", heroData.ConfigId, dbIndex)
  1579. return
  1580. }
  1581. //if len(data.TaskList) == len(db.ChangeCond) {
  1582. // continue
  1583. //}
  1584. data.TaskList = data.TaskList[0:0]
  1585. for _, condData := range db.ChangeCond { //遍历当前可转职任务
  1586. var taskProgressType []*serverproto.TaskProgressType
  1587. condId, _ := model.Str2Num(condData)
  1588. condCfg, condOk := serverproto.ConditionCfgLoader[int32(condId)]
  1589. if !condOk || len(condCfg.Condition[0]) < 2 {
  1590. util.ErrorF("ChangeJob ConditionCfgLoader data not found cfgid=%v", condId)
  1591. continue
  1592. }
  1593. //一个任务ID之对应一个条件,所以直接去第一个参数作为TaskType
  1594. taskInfo := strings.Split(condCfg.Condition[0], ":")
  1595. taskType, _ := model.Str2Num(taskInfo[0])
  1596. taskProgressType = append(taskProgressType, &serverproto.TaskProgressType{
  1597. Key: int32(taskType),
  1598. Value: 0,
  1599. })
  1600. data.TaskList = append(data.TaskList, &serverproto.TaskData{
  1601. TaskId: uint32(condId),
  1602. Progress: taskProgressType,
  1603. })
  1604. }
  1605. //刷新任务状态
  1606. for _, task := range data.TaskList {
  1607. for _, data := range task.Progress {
  1608. TaskMagCheck(this.role, serverproto.TaskType(data.Key), 0)
  1609. }
  1610. }
  1611. }
  1612. this.SetDirty(true)
  1613. }
  1614. func (this *RoleTask) GetChangeJobTask(heroId int32, changeType int32, bNtf bool) {
  1615. //获取转职的伙伴数据
  1616. heroData := this.role.roleHero.GetHero(heroId)
  1617. if heroData == nil {
  1618. util.InfoF("uid=%v ChangeJob game hero not found", this.role.GetUUid())
  1619. return
  1620. }
  1621. //获取可转职职业ID列表
  1622. var changeCondition []string
  1623. if this.role.roleHero.IsMainHero(heroId) {
  1624. jobCfg, jobOk := serverproto.JobCfgLoader[heroData.ConfigId]
  1625. if !jobOk {
  1626. util.InfoF("ChangeJob JobCfgLoader data not found cfgid=%v", heroData.ConfigId)
  1627. return
  1628. }
  1629. changeCondition = jobCfg.ChangeCond
  1630. } else {
  1631. jobCfg, jobOk := serverproto.ParterCfgLoader[heroData.ConfigId]
  1632. if !jobOk {
  1633. util.InfoF("ChangeJob ParterCfgLoader data not found cfgid=%v", heroData.ConfigId)
  1634. return
  1635. }
  1636. changeCondition = jobCfg.ChangeCond
  1637. }
  1638. //是否有这个伙伴的转职任务列表
  1639. var newJobCondition serverproto.ChangeJob
  1640. var bFind bool = false
  1641. for _, data := range this.jobCondition {
  1642. if data.HeroId == heroId {
  1643. newJobCondition = *data
  1644. bFind = true
  1645. }
  1646. }
  1647. if !bFind {
  1648. this.jobCondition = append(this.jobCondition, &newJobCondition)
  1649. }
  1650. //清空当前的所有任务list
  1651. if len(newJobCondition.TaskList) > 0 {
  1652. newJobCondition.TaskList = newJobCondition.TaskList[0:0]
  1653. }
  1654. newJobCondition.HeroId = heroId
  1655. //小任务加入任务列表
  1656. for _, condData := range changeCondition { //遍历当前可转职任务
  1657. var taskProgressType []*serverproto.TaskProgressType
  1658. condId, _ := model.Str2Num(condData)
  1659. condCfg, condOk := serverproto.ConditionCfgLoader[int32(condId)]
  1660. if !condOk || len(condCfg.Condition[0]) < 2 {
  1661. util.ErrorF("ChangeJob ConditionCfgLoader data not found cfgid=%v", condId)
  1662. continue
  1663. }
  1664. //一个任务ID之对应一个条件,所以直接去第一个参数作为TaskType
  1665. taskInfo := strings.Split(condCfg.Condition[0], ":")
  1666. taskType, _ := model.Str2Num(taskInfo[0])
  1667. taskProgressType = append(taskProgressType, &serverproto.TaskProgressType{
  1668. Key: int32(taskType),
  1669. Value: 0,
  1670. })
  1671. newJobCondition.TaskList = append(newJobCondition.TaskList, &serverproto.TaskData{
  1672. TaskId: uint32(condId),
  1673. Progress: taskProgressType,
  1674. })
  1675. }
  1676. //如果是替换职业,并且,
  1677. if len(newJobCondition.TaskList) > 0 {
  1678. for _, task := range newJobCondition.TaskList {
  1679. for _, data := range task.Progress {
  1680. //转职条件处理
  1681. this.jobConditionCheck(serverproto.TaskType(data.Key), 0)
  1682. }
  1683. }
  1684. }
  1685. if bNtf {
  1686. this.jobConditionChangeNtf([]int32{heroId})
  1687. }
  1688. this.SetDirty(true)
  1689. }
  1690. func (this *RoleTask) jobConditionCheck(taskType serverproto.TaskType, count int32) {
  1691. this.heroConditionCheck(taskType, count)
  1692. }
  1693. func (this *RoleTask) heroConditionCheck(taskType serverproto.TaskType, count int32) {
  1694. roleData := this.role.GetRoleBase().RoleData()
  1695. if roleData == nil {
  1696. return
  1697. }
  1698. //遍历查找
  1699. var changedIds []int32
  1700. for _, data := range this.jobCondition {
  1701. var bChanged bool = false
  1702. for _, subData := range data.TaskList {
  1703. taskInfo := subData.Progress[0]
  1704. cond, ok := model.ChangeJobCond[int32(subData.TaskId)]
  1705. if !ok {
  1706. util.InfoF("heroConditionCheck ChangeJobCond data not found taskid=%v", subData.TaskId)
  1707. continue
  1708. }
  1709. if taskInfo.Key != int32(taskType) || taskInfo.State == 1 { //不是条件任务。或者已经完成
  1710. continue
  1711. }
  1712. bChanged = TaskConditionCheck(this.role, subData,
  1713. taskType, cond.Condition, count, false)
  1714. }
  1715. if bChanged {
  1716. changedIds = append(changedIds, data.HeroId)
  1717. this.SetDirty(true)
  1718. }
  1719. }
  1720. if len(changedIds) > 0 {
  1721. this.jobConditionChangeNtf(changedIds)
  1722. }
  1723. }
  1724. //------- 头像解锁条件 ----------------------------------
  1725. func (this *RoleTask) OnlineCheckNewHead() {
  1726. //上线检查头像是否有更新
  1727. headVersion, ok := serverproto.GlobalCfgLoader[int32(serverproto.GlobalType_Global_Cur_Head_Version)]
  1728. if !ok {
  1729. util.ErrorF(" headpic config not found")
  1730. return
  1731. }
  1732. if this.role.GetRoleBase().roleBase.Head_Info.HeadVersion >= headVersion.IVal {
  1733. util.ErrorF("headpic version error version=%v val=%v", this.role.GetRoleBase().roleBase.Head_Info.HeadVersion, headVersion.IVal)
  1734. return
  1735. }
  1736. //遍历新的头像
  1737. for _, data := range serverproto.HeadPortraitCfgLoader {
  1738. //老版本已经加载过
  1739. if this.role.GetRoleBase().roleBase.Head_Info.HeadVersion >= data.HeadLoadId {
  1740. continue
  1741. }
  1742. //性别不一致
  1743. if this.role.GetRoleBase().GetRoleSex() != data.HeadPortraitSex {
  1744. continue
  1745. }
  1746. //没有解锁要求,默认解锁激活
  1747. if data.UnlockCondition == 0 {
  1748. this.role.GetRoleBase().roleBase.Head_Info.HeadList = append(this.role.GetRoleBase().roleBase.Head_Info.HeadList, data.HeadPortraitId)
  1749. continue
  1750. }
  1751. //后续版本的头像都加入到条件列表中来
  1752. condCfg, condOk := model.ChangeJobCond[data.UnlockCondition]
  1753. if !condOk {
  1754. util.ErrorF("headpic ChangeJobCond not find condition=%v", data.UnlockCondition)
  1755. continue
  1756. }
  1757. //把当前头像加入到
  1758. var headCond serverproto.HeadCond
  1759. headCond.HeadId = data.HeadPortraitId
  1760. var taskData serverproto.TaskData
  1761. taskData.TaskId = uint32(data.UnlockCondition)
  1762. for key, _ := range condCfg.Condition {
  1763. taskData.Progress = append(taskData.Progress, &serverproto.TaskProgressType{
  1764. Key: key,
  1765. Value: 0,
  1766. State: 0,
  1767. })
  1768. }
  1769. headCond.TaskList = append(headCond.TaskList, &taskData)
  1770. this.roleHeadCond.Conditions = append(this.roleHeadCond.Conditions, &headCond)
  1771. }
  1772. //设置当前最新版本
  1773. this.role.GetRoleBase().roleBase.Head_Info.HeadVersion = headVersion.IVal
  1774. this.SetDirty(true)
  1775. }
  1776. // 检查头像是否解锁
  1777. func (this *RoleTask) CheckHeadUnlocked(headId int32) bool {
  1778. for _, data := range this.roleHeadCond.Conditions {
  1779. if data.HeadId != headId {
  1780. continue
  1781. }
  1782. for _, taskData := range data.TaskList {
  1783. for _, taskInfo := range taskData.Progress {
  1784. if taskInfo.State == 0 {
  1785. return false
  1786. }
  1787. }
  1788. }
  1789. }
  1790. return true
  1791. }
  1792. func (this *RoleTask) headConditionCheck(taskType serverproto.TaskType, count int32) {
  1793. this.headUnlockCheck(taskType, count)
  1794. }
  1795. func (this *RoleTask) headUnlockCheck(taskType serverproto.TaskType, count int32) {
  1796. //遍历查找
  1797. var bRet bool = false
  1798. for _, data := range this.roleHeadCond.Conditions {
  1799. for _, taskData := range data.TaskList {
  1800. if taskData.State == TASK_REWARD_STATE_REWARD {
  1801. continue
  1802. }
  1803. for _, taskInfo := range taskData.Progress {
  1804. cond, ok := model.ChangeJobCond[int32(taskData.TaskId)]
  1805. if !ok {
  1806. util.InfoF("headUnlockCheck ChangeJobCond not found taskid=%v", taskData.TaskId)
  1807. continue
  1808. }
  1809. if taskInfo.Key != int32(taskType) || taskInfo.State == 1 { //不是条件任务。或者已经完成
  1810. continue
  1811. }
  1812. bRet = TaskConditionCheck(this.role, taskData,
  1813. taskType, cond.Condition, count, false)
  1814. if !bRet {
  1815. continue
  1816. }
  1817. this.SetDirty(true)
  1818. }
  1819. }
  1820. }
  1821. if bRet == true {
  1822. //通知客户端
  1823. // this.headConditionChangeNtf()
  1824. }
  1825. }