提交修改反射部分

modules/blazing/service/task.go

@@ -4,61 +4,75 @@ import (
 	"blazing/cool"
 	"blazing/modules/blazing/model"
 	"encoding/json"
+	"reflect"
 )
 
-type TaskService struct {
-	*UserService
-}
+func Exec[T, F any](userid uint32, s *cool.Service, processFunc func(F) bool) bool {
+	//todo待测试
+	var player T
+	// 方法2：使用反射获取
+	// 获取反射值对象
+	val := reflect.ValueOf(player)
+	var dataField reflect.Value
+	// 检查是否为结构体
+	if val.Kind() == reflect.Struct {
+		// 通过字段名获取Data字段
+		dataField = val.FieldByName("Data")
 
-func NewTaskService(id uint32) *TaskService {
-	return &TaskService{
-		&UserService{
-			userid: id,
-			Service: &cool.Service{
-				Model: model.NewTask(),
-			},
-		},
 	}
+
+	m1 := cool.DBM(s.Model).Where("player_id", userid)
+	m1.Scan(&player)
+	var tt F
+	json.Unmarshal([]byte(dataField.Interface().(string)), &tt)
+	processFunc(tt)
+	tmep, _ := json.Marshal(tt)
+	dataField.SetString(string(tmep))
+
+	m1.Save(player)
+	return false
 }
-func (s *TaskService) Exec(t func(map[uint32]model.TaskInfo) bool) (ret bool) {
-	var tt model.Task
-	s.GetModel().Scan(&tt)
-	var ttt map[uint32]model.TaskInfo
-	json.Unmarshal([]byte(tt.Data), &ttt)
-	ret = t(ttt)
-	t1, _ := json.Marshal(&ttt)
-	tt.Data = string(t1)
-	s.GetModel().Save(&tt) //退出时保存
-	return
+func (s *UserService) TaskExec(t func(map[uint32]model.TaskInfo) bool) (ret bool) {
+	return Exec[model.Task, map[uint32]model.TaskInfo](s.userid, s.task, t)
+	// m := cool.DBM(s.task.Model).Where("player_id", s.userid)
+	// var tt model.Task
+	// m.Scan(&tt)
+	// var ttt map[uint32]model.TaskInfo
+	// json.Unmarshal([]byte(tt.Data), &ttt)
+	// ret = t(ttt)
+	// t1, _ := json.Marshal(&ttt)
+	// tt.Data = string(t1)
+	// m.Save(&tt) //退出时保存
+	// return
 }
 
-/**
- * 完成任务
- */
-func (s *TaskService) CompleteTask(task uint32) bool {
+// /**
+//  * 完成任务
+//  */
+// func (s *TaskService) CompleteTask(task uint32) bool {
 
-	return s.Exec(func(ttt map[uint32]model.TaskInfo) bool {
-		if conditions, ok := ttt[task]; ok {
-			conditions.Status = 3
-			ttt[task] = conditions
+// 	return s.Exec(func(ttt map[uint32]model.TaskInfo) bool {
+// 		if conditions, ok := ttt[task]; ok {
+// 			conditions.Status = 3
+// 			ttt[task] = conditions
 
-		}
+// 		}
 
-		return false
-	})
-}
+// 		return false
+// 	})
+// }
 
-/**
- * 校验任务是否已经完成
- */
-func (s *TaskService) CheckTaskCompleted(task uint32) bool {
+// /**
+//  * 校验任务是否已经完成
+//  */
+// func (s *TaskService) CheckTaskCompleted(task uint32) bool {
 
-	return s.Exec(func(ttt map[uint32]model.TaskInfo) bool {
-		if conditions, ok := ttt[task]; ok {
+// 	return s.Exec(func(ttt map[uint32]model.TaskInfo) bool {
+// 		if conditions, ok := ttt[task]; ok {
 
-			return conditions.Status == 3
-		}
+// 			return conditions.Status == 3
+// 		}
 
-		return false
-	})
-}
+// 		return false
+// 	})
+// }