log-server/service/task/game_task.go

package task

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"go.uber.org/zap"
	"gorm.io/gorm"
	"log-server/global"
	"log-server/model/task"
	"log-server/model/task/control"
	"log-server/model/task/request"
	"log-server/model/task/response"
	"log-server/service/cache"
	"log-server/utils"
	"math"
	"math/rand"
	"strconv"
	"strings"
	"time"
)

var AccountType = map[int]string{
	1: "小绵羊账号",
	2: "QQ账号",
	3: "魅族账号",
	4: "华为账号",
	5: "测试类型",
	6: "微信",
	7: "微信+QQ",
}

var LoginMethod = map[int]string{
	1: "小绵羊",
	2: "魅族",
	3: "QQ",
	4: "网易",
	5: "微信",
	6: "微信+QQ",
}
var GamePort = map[int]string{
	1: "腾讯",
	2: "360",
	3: "网易",
	4: "酷派",
	5: "魅族",
}

var (
	CreateTaskUrl           = "/v1/task_statistics"
	GetControlTaskIdUrl     = "/v1/task_statistics/get_data_id"
	UpdateGameTaskStatusUrl = "/v1/install_info/updateinstallstatus"
)

type GameTask struct {
	cache cache.Cache
}

// 创建游戏任务
func (s *GameTask) CreateGameTask(requestData request.GameTaskRequest) (err error) {
	if !errors.Is(global.GVA_DB.Where("task_id = ?", requestData.TaskId).First(&task.GameTask{}).Error, gorm.ErrRecordNotFound) {
		return errors.New("存在相同任务ID")
	}
	gameTask := new(task.GameTask)
	gameTask.TaskId = requestData.TaskId
	gameTask.TaskName = requestData.TaskName
	gameTask.User = requestData.User
	gameTask.NewRetained = requestData.NewRetained
	gameTask.GameName = requestData.GameName
	gameTask.GameId = requestData.GameId
	gameTask.Date = time.Now()
	gameTask.GamePortId = requestData.GamePortId
	gameTask.AccountType = requestData.AccountType
	gameTask.LoginMethod = requestData.LoginMethod
	gameTask.TxChannel = requestData.TxChannel
	gameTask.TxGameId = requestData.TxGameId
	gameTask.MzChannel = requestData.MzChannel
	gameTask.MzGameId = requestData.MzGameId
	gameTask.GameIdXmy = requestData.GameIdXmy
	gameTask.NewTarget = requestData.NewTarget
	gameTask.PayTarget = requestData.PayTarget
	gameTask.RetainedTarget = requestData.RetainedTarget
	gameTask.PayPrice = requestData.PayPrice
	//gameTask.CreateTime		= requestData.CreateTime
	//gameTask.UpdateTime		= requestData.UpdateTime
	//gameTask.Status			= requestData.Status
	//gameTask.IsDel			= requestData.IsDel
	//gameTask.DeleteTime		= requestData.DeleteTime
	taskRequestData := s.CreateGameTaskRequestData(requestData)
	err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
		err = tx.Omit("create_time", "update_time", "status", "is_del", "delete_time", "control_task_id").Create(&gameTask).Error
		if err != nil {
			global.GVA_LOG.Error("添加任务数据失败: ", zap.Error(err))
			return err
		}
		_, err := s.CreateTaskRequestControl(taskRequestData)
		if err != nil {
			global.GVA_LOG.Error("添加任务数据请求群控失败: ", zap.Error(err))
		}
		return err
	})
	if err != nil {
		return err
	}
	// 同步群控任务id
	d, err := s.GetControlTaskId(taskRequestData.GameId)
	if err != nil {
		global.GVA_LOG.Error("获取群控的任务id失败")
		return err
	}
	err = global.GVA_DB.Model(&task.GameTask{}).Where("task_id = ?", taskRequestData.GameId).Update("control_task_id", d.IdDong).Error
	return
}

// 创建游戏任务完成model
func (s *GameTask) CreateGameTargetCompleteModel(oldA task.GameTask, date time.Time) *task.GameTargetComplete {
	var newTarget int
	rand.Seed(time.Now().UnixNano())
	newTargetRate := rand.Float64()
	/*if oldA.NewTarget <= 10 {
		newTarget = 10
	} else {
		newTarget = int(math.Ceil(float64(oldA.NewTarget) * 0.5))
	}*/
	newTarget = int(math.Ceil(float64(oldA.NewTargetH-oldA.NewTarget) * newTargetRate))
	var retainedTarget int
	rand.Seed(time.Now().UnixNano())
	retainedTargetRate := rand.Float64()
	//if oldA.RetainedTarget < 100 {
	//	retainedTarget = oldA.RetainedTarget
	//} else if oldA.RetainedTarget > 1000 {
	//	retainedTarget = 1000
	//} else {
	//	retainedTarget = 200
	//}
	retainedTarget = int(math.Ceil(float64(oldA.RetainedTargetH-oldA.RetainedTarget) * retainedTargetRate))
	targetComplete := new(task.GameTargetComplete)
	targetComplete.TaskId = oldA.TaskId
	targetComplete.NewTarget = oldA.NewTarget + newTarget
	if oldA.NewTarget == 0 || oldA.NewTargetH == 0 {
		targetComplete.NewTarget = 0
	}
	targetComplete.RetainedTarget = oldA.RetainedTarget + retainedTarget
	if oldA.RetainedTarget == 1 || oldA.RetainedTargetH == 1 {
		targetComplete.RetainedTarget = 1
	}
	targetComplete.PayTarget = 0
	targetComplete.CreateDate = date
	targetComplete.RetainedComplete = 0
	targetComplete.PayComplete = 0
	targetComplete.NewComplete = 0
	return targetComplete
}

// 创建任务群控请求数据
func (s *GameTask) CreateGameTaskRequestData(requestData request.GameTaskRequest) control.CreateGameTaskRequest {
	gameTask := control.CreateGameTaskRequest{}
	gameTask.GameId = requestData.TaskId
	gameTask.GameName = requestData.TaskName
	gameTask.Remark = requestData.User
	gameTask.NewRetained = requestData.NewRetained
	gameTask.Date = time.Now().Format("2006-01-02")
	gameTask.GamePort = GamePort[requestData.GamePortId]
	gameTask.GameIdXmy = requestData.GameIdXmy
	gameTask.NewTarget = requestData.NewTarget
	gameTask.PayTarget = requestData.PayTarget
	gameTask.RetainedTarget = requestData.RetainedTarget
	gameTask.PayPrice = requestData.PayPrice
	gameTask.SyDataId = requestData.TaskId
	gameTask.SpiritPackageName = "0"
	gameTask.GamePackageName = "0"
	return gameTask
}

// http请求群控创建任务
func (s *GameTask) CreateTaskRequestControl(requestData control.CreateGameTaskRequest) (d string, err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + CreateTaskUrl
	data, code, err := utils.HttpPostReplyCode(url, requestData)
	fmt.Println(code)
	if code != 200 {
		return string(data), errors.New(string(data))
	}
	d = string(data)
	return
}

// http请求群控更新任务
func (s *GameTask) UpdateTaskRequestControl(requestData control.CreateGameTaskRequest, controlTaskId int) (d string, err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + CreateTaskUrl + "/" + strconv.Itoa(controlTaskId)
	data, code, err := utils.HttpPutReplyCode(url, requestData)
	fmt.Println(code)
	if code != 200 {
		return string(data), errors.New(string(data))
	}
	d = string(data)
	return
}

type ControlTaskId struct {
	IdDong int
	IdYang int
}

// http请求获取群控创建任务id
func (s *GameTask) GetControlTaskId(gameId int) (d *ControlTaskId, err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + GetControlTaskIdUrl
	requestData := map[string]string{
		"game_id": strconv.Itoa(gameId),
	}
	data, code, err := utils.HttpGetReplyCode(url, requestData)
	fmt.Println(code)
	if code != 200 {
		return d, errors.New(string(data))
	}
	msg := new(ControlTaskId)
	_ = json.Unmarshal(data, &msg)
	d = msg
	return
}

//@author: [piexlmax](https://github.com/piexlmax)
//@function: GetGameTaskInfoList
//@description: 分页获取数据,
//@param: card card.Card, info request.PageInfo, order string, desc bool
//@return: list interface{}, total int64, err error
func (apiService *GameTask) GetGameTaskInfoList(api task.GameTask, info request.PageInfo, order string, desc bool) (list interface{}, options interface{}, total int64, err error) {
	limit := info.PageSize
	offset := info.PageSize * (info.Page - 1)
	db := global.GVA_DB.Model(&task.GameTask{})
	var apiList []task.GameTask
	db = db.Where("is_del = ?", -1)
	if api.TaskName != "" {
		db = db.Where("task_name LIKE ?", "%"+api.TaskName+"%")
	}

	if api.User != "" {
		db = db.Where("user LIKE ?", "%"+api.User+"%")
	}

	if api.Status != 0 {
		db = db.Where("status = ?", api.Status)
	}

	if api.TaskId != 0 {
		db = db.Where("task_id = ?", api.TaskId)
	}

	err = db.Count(&total).Error

	//查找厂商名称，登录类型名称、账号类型名称
	option := task.Option{}
	global.GVA_DB.Table("game_channel").Select("id", "channel_name").Find(&option.GamePortOptions)
	global.GVA_DB.Table("login_type").Select("id", "login_name").Find(&option.LoginTypeOptions)
	global.GVA_DB.Table("account_type").Select("id", "type_name").Find(&option.AccountTypeOptions)
	global.GVA_DB.Table("game_list").Select("id", "game_name").Find(&option.GameListOptions)
	//fmt.Println(option)

	if err != nil {
		return apiList, option, total, err
	} else {
		db = db.Limit(limit).Offset(offset)
		if order != "" {
			var OrderStr string
			// 设置有效排序key 防止sql注入
			// 感谢 Tom4t0 提交漏洞信息
			orderMap := make(map[string]bool, 4)
			orderMap["id"] = true
			orderMap["task_name"] = true
			orderMap["user"] = true
			if orderMap[order] {
				if desc {
					OrderStr = order + " desc"
				} else {
					OrderStr = order
				}
			} else { // didn't matched any order key in `orderMap`
				err = fmt.Errorf("非法的排序字段: %v", order)
				return apiList, option, total, err
			}

			err = db.Order(OrderStr).Find(&apiList).Error
		} else {
			err = db.Order("id desc").Find(&apiList).Error
		}
	}
	var apisReply []*response.GetGameTaskListReply
	if len(apiList) != 0 {
		for _, apiInfo := range apiList {
			var apiReply = new(response.GetGameTaskListReply)
			apiReply.Status = apiInfo.Status
			apiReply.TaskId = apiInfo.TaskId
			apiReply.TaskName = apiInfo.TaskName
			apiReply.GamePort = GamePort[apiInfo.GamePortId]
			apiReply.AccountType = AccountType[apiInfo.AccountType]
			apiReply.LoginMethod = LoginMethod[apiInfo.LoginMethod]
			apiReply.CreateTime = apiInfo.CreateTime.Format("2006-01-02 15:04:05")
			apiReply.User = apiInfo.User
			apiReply.Date = apiInfo.Date.Format("2006-01-02")
			apiReply.GameName = apiInfo.GameName
			apiReply.UpdateTime = apiInfo.UpdateTime.Format("2006-01-02 15:04:05")
			apiReply.NewTarget = apiInfo.NewTarget
			apiReply.PayTarget = apiInfo.PayTarget
			apiReply.RetainedTarget = apiInfo.RetainedTarget
			apiReply.PayPrice = apiInfo.PayPrice
			apiReply.RetainedTargetH = apiInfo.RetainedTargetH
			apiReply.NewTargetH = apiInfo.NewTargetH
			apiReply.StopTime = apiInfo.StopTime.Format("2006-01-02 15:04:05")
			if apiInfo.Status == 1 {
				apiReply.StopTime = ""
			}
			apisReply = append(apisReply, apiReply)
		}

	}
	return apisReply, option, total, err
}

//@author: [piexlmax](https://github.com/piexlmax)
//@function: GetGameTaskById
//@description: 根据id获取GameTask
//@param: id uint
//@return: apiReply response.GetPcListReply, err error
func (c *GameTask) GetGameTaskById(id int) (gameTask request.GameTaskRequest, err error) {
	var requestData task.GameTask
	err = global.GVA_DB.Where("task_id = ?", id).First(&requestData).Error
	if err != nil {
		return
	}
	gameTask.TaskId = requestData.TaskId
	gameTask.TaskName = requestData.TaskName
	gameTask.User = requestData.User
	gameTask.NewRetained = requestData.NewRetained
	gameTask.GameName = requestData.GameName
	gameTask.GamePortId = requestData.GamePortId
	gameTask.AccountType = requestData.AccountType
	gameTask.LoginMethod = requestData.LoginMethod
	gameTask.TxChannel = requestData.TxChannel
	gameTask.TxGameId = requestData.TxGameId
	gameTask.MzChannel = requestData.MzChannel
	gameTask.MzGameId = requestData.MzGameId
	gameTask.GameIdXmy = requestData.GameIdXmy
	gameTask.NewTarget = requestData.NewTarget
	gameTask.PayTarget = requestData.PayTarget
	gameTask.RetainedTarget = requestData.RetainedTarget
	gameTask.PayPrice = requestData.PayPrice
	gameTask.RetainedTargetH = requestData.RetainedTargetH
	gameTask.NewTargetH = requestData.NewTargetH
	return
}

// http请求群控更新任务装
func (s *GameTask) UpdateControlStatus(gameId int, status int) (err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + UpdateGameTaskStatusUrl
	requestData := map[string]string{
		"status":  strconv.Itoa(status),
		"game_id": strconv.Itoa(gameId),
	}
	data, code, err := utils.HttpGetReplyCode(url, requestData)
	if err != nil {
		return err
	}
	fmt.Println(code)
	if code != 200 {
		return errors.New(string(data))
	}
	return
}

//@author: [piexlmax](https://github.com/piexlmax)
//@function: UpdateGameTaskStatus
//@description: 根据id更新GameTask状态
//@param: GameTask request.UpdateGameTaskRequest
//@return: err error
func (s *GameTask) UpdateGameTaskStatus(c request.UpdateGameTaskStatusRequest) (err error) {
	var oldA task.GameTask
	err = global.GVA_DB.Where("task_id = ?", c.TaskId).First(&oldA).Error
	if err != nil {
		return err
	}
	err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
		update := map[string]interface{}{
			"status": c.Status,
		}
		status := c.Status
		if c.Status == -1 {
			status = 0
			update["stop_time"] = time.Now().Format("2006-01-02 15:04:05")
			date := time.Now().Add(+time.Hour * 24)
			tx.Where("task_id = ?", c.TaskId).Where("create_date = ?", date.Format("2006-01-02")).Delete(&task.GameTargetComplete{})
		} else {
			date := time.Now()
			if !errors.Is(tx.Where("task_id = ?", c.TaskId).Where("create_date = ?", date.Format("2006-01-02")).First(&task.GameTargetComplete{}).Error, gorm.ErrRecordNotFound) {
				global.GVA_LOG.Info("当天的任务目标已存在")
			} else {
				targetComplete := s.CreateGameTargetCompleteModel(oldA, date)
				err := tx.Omit("update_time,is_complete,hand_new_complete,hand_retained_complete,hand_pay_complete,hand_amount_total").Create(&targetComplete).Error
				if err != nil {
					global.GVA_LOG.Error("创建任务目标数据失败", zap.Error(err))
					return err
				}
			}
		}
		err := tx.Table("game_task").Where("task_id", c.TaskId).Updates(update).Error
		if err != nil {
			return err
		}
		err = s.UpdateControlStatus(c.TaskId, status)
		return err
	})

	return err
}

// 更新GameTask
func (s *GameTask) UpdateGameTask(requestData request.GameTaskRequest) (err error) {
	if errors.Is(global.GVA_DB.Where("task_id = ?", requestData.TaskId).First(&task.GameTask{}).Error, gorm.ErrRecordNotFound) {
		return errors.New("不存在的任务")
	}
	d, err := s.GetControlTaskId(requestData.TaskId)
	if err != nil {
		global.GVA_LOG.Error("请求群控数据报错: ", zap.Error(err))
		return errors.New("请求群控数据报错")
	}
	gameTask := new(task.GameTask)
	global.GVA_DB.Where("task_id = ?", requestData.TaskId).First(&gameTask)
	gameTask.TaskId = requestData.TaskId
	gameTask.TaskName = requestData.TaskName
	gameTask.User = requestData.User
	gameTask.NewRetained = requestData.NewRetained
	gameTask.GameName = requestData.GameName
	gameTask.GameId = requestData.GameId
	gameTask.GamePortId = requestData.GamePortId
	gameTask.AccountType = requestData.AccountType
	gameTask.LoginMethod = requestData.LoginMethod
	gameTask.TxChannel = requestData.TxChannel
	gameTask.TxGameId = requestData.TxGameId
	gameTask.MzChannel = requestData.MzChannel
	gameTask.MzGameId = requestData.MzGameId
	gameTask.GameIdXmy = requestData.GameIdXmy
	gameTask.NewTarget = requestData.NewTarget
	gameTask.PayTarget = requestData.PayTarget
	gameTask.RetainedTarget = requestData.RetainedTarget
	gameTask.PayPrice = requestData.PayPrice
	gameTask.NewTargetH = requestData.NewTargetH
	gameTask.RetainedTargetH = requestData.RetainedTargetH
	taskRequestData := s.CreateGameTaskRequestData(requestData)
	err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
		err = tx.Where("task_id = ?", requestData.TaskId).Omit("create_time", "update_time", "status", "is_del", "delete_time", "control_task_id", "date", "task_id").Updates(&gameTask).Error
		if err != nil {
			global.GVA_LOG.Error("更新任务数据失败: ", zap.Error(err))
			return err
		}
		_, err := s.UpdateTaskRequestControl(taskRequestData, d.IdDong)
		if err != nil {
			global.GVA_LOG.Error("更新任务数据请求群控失败: ", zap.Error(err))
		}
		return err
	})
	return
}

// http请求群控刪除任务
func (s *GameTask) DelTaskRequestControl(controlTaskId int) (d string, err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + CreateTaskUrl + "/" + strconv.Itoa(controlTaskId)
	data, code, err := utils.HttpDeleteReplyCode(url, nil)
	fmt.Println(code)
	if code != 200 {
		return string(data), errors.New(string(data))
	}
	d = string(data)
	return
}

//@author: [piexlmax](https://github.com/piexlmax)
//@function: DeleteGameTask
//@description: 删除GameTask
//@param: api task.GameTask
//@return: err error
func (s *GameTask) DeleteGameTask(api request.GameTaskRequest) (err error) {
	var entity task.GameTask
	err = global.GVA_DB.Where("task_id = ?", api.TaskId).First(&entity).Error
	if errors.Is(err, gorm.ErrRecordNotFound) {
		return err
	}
	//update := map[string]interface{}{
	//	"is_del":      1,
	//	"status":      -1,
	//	"stop_time":   time.Now(),
	//	"delete_time": time.Now(),
	//}
	d, err := s.GetControlTaskId(api.TaskId)
	if err != nil {
		global.GVA_LOG.Error("请求群控数据报错: ", zap.Error(err))
		return errors.New("请求群控数据报错")
	}
	err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
		err := tx.Where("task_id", api.TaskId).Delete(&task.GameTask{}).Error
		if err != nil {
			return err
		}
		_, err = s.DelTaskRequestControl(d.IdDong)
		return err
	})
	return
}

//@function: GetGameTaskTargetInfoList
//@description: 分页获取数据,
//@param: card card.Card, info request.PageInfo, order string, desc bool
//@return: list interface{}, total int64, err error
func (apiService *GameTask) GetGameTaskTargetInfoList(api request.GameTargetCompleteRequest, info request.PageInfo, order string, desc bool, isTx bool) (list interface{}, total int64, err error) {
	limit := info.PageSize
	offset := info.PageSize * (info.Page - 1)
	if api.CreateDate == "" {
		api.CreateDate = time.Now().Format("2006-01-02")
	}
	db := global.GVA_DB.Table("game_target_complete gtc")
	db = db.Select("gtc.id,gtc.task_id,gt.task_name,gtc.new_target,gt.login_method,gt.user,gtc.pay_target,gtc.retained_target," +
		"gtc.new_complete,gtc.pay_complete,gtc.retained_complete,gtc.create_date,gtc.amount,gtc.game_rate,gtc.is_complete,gtc.hand_new_complete," +
		"gtc.hand_retained_complete,gtc.hand_pay_complete,gtc.hand_amount_total")
	db = db.Joins("left join game_task gt on gt.task_id = gtc.task_id")
	db = db.Where("gtc.create_date = ?", api.CreateDate)
	var apiList []response.GetGameTargetComplete
	if api.TaskName != "" {
		db = db.Where("gt.task_name LIKE ?", "%"+api.TaskName+"%")
	}
	if api.User != "" {
		db = db.Where("gt.user LIKE ?", "%"+api.User+"%")
	}
	if isTx {
		db = db.Where("gt.game_port_id = ?", 1)
	}
	if api.TaskId != 0 {
		db = db.Where("gtc.task_id = ?", api.TaskId)
	}
	if api.IsComplete != 0 {
		db = db.Where("gtc.is_complete = ?", api.IsComplete)
	}
	err = db.Count(&total).Error

	if err != nil {
		return apiList, total, err
	} else {
		db = db.Limit(limit).Offset(offset)
		if order != "" {
			var OrderStr string
			// 设置有效排序key 防止sql注入
			// 感谢 Tom4t0 提交漏洞信息
			orderMap := make(map[string]bool, 4)
			orderMap["task_name"] = true
			orderMap["user"] = true
			if orderMap[order] {
				if desc {
					OrderStr = "gt." + order + " desc"
				} else {
					OrderStr = order
				}
			} else { // didn't matched any order key in `orderMap`
				err = fmt.Errorf("非法的排序字段: %v", order)
				return apiList, total, err
			}

			err = db.Order(OrderStr).Find(&apiList).Error
		} else {
			err = db.Order("gtc.id desc").Find(&apiList).Error
		}
	}
	if len(apiList) != 0 {
		for i, api := range apiList {
			date := strings.Split(api.CreateDate, "T")
			loginMethod, _ := strconv.Atoi(api.LoginMethod)
			apiList[i].LoginMethod = LoginMethod[loginMethod]
			apiList[i].CreateDate = date[0]
			apiList[i].RetainedComplete = api.RetainedComplete + api.HandRetainedComplete + api.HandNewComplete
			apiList[i].PayComplete = api.PayComplete + api.HandPayComplete
			apiList[i].NewComplete = api.NewComplete + api.HandNewComplete
			apiList[i].Amount = api.Amount + api.HandAmountTotal
		}
	}
	return apiList, total, err
}

func (s *GameTask) FreeUploadWt(gameId, channelId string, date string, money int, path string) (err error) {
	url := "https://sy.nkfzs.com/v2/data_collect/" + path
	requestData := map[string]string{
		"channel_id": channelId,
		"game_id":    gameId,
		"type":       "3",
		"account":    "hand_" + date,
		"money":      strconv.Itoa(money),
	}
	data, code, err := utils.HttpGetReplyCode(url, requestData)
	if err != nil {
		return err
	}
	fmt.Println(code)
	if code != 200 {
		return errors.New(string(data))
	}
	return
}

func (s *GameTask) FreeUploadXjf(gameId, action, account, actionResult, actionState string) (err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + "/v1/device/setAccountLog"
	requestData := map[string]string{
		"action":        action,
		"game_id":       gameId,
		"action_result": actionResult,
		"account":       account,
		"actionState":   actionState,
	}
	data, code, err := utils.HttpGetReplyCode(url, requestData)
	if err != nil {
		return err
	}
	fmt.Println(code)
	if code != 200 {
		return errors.New(string(data))
	}
	return
}

func (s *GameTask) QQCardUsedLogUploadXjf(gameId int, account string, money int) (err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + "/v1/device/qq_card_hand"
	requestData := map[string]string{
		"game_id":     strconv.Itoa(gameId),
		"card_number": account,
		"money":       strconv.Itoa(money),
	}
	data, code, err := utils.HttpGetReplyCode(url, requestData)
	if err != nil {
		return err
	}
	if code != 200 {
		return errors.New(string(data))
	}
	return
}

//@function: GetGameTaskTargetById
//@description: 根据id获取GameTargetComplete
//@param: id uint
//@return: apiReply response.GetPcListReply, err error
func (c *GameTask) GetGameTaskTargetById(id int, date string) (api response.GetGameTargetComplete, err error) {
	db := global.GVA_DB.Table("game_target_complete gtc")
	db = db.Select("gtc.task_id,gt.task_name,gtc.new_target,gt.login_method,gt.user,gtc.pay_target,gtc.retained_target," +
		"gtc.new_complete,gtc.pay_complete,gtc.retained_complete,gtc.create_date,gtc.amount,gtc.game_rate,gtc.is_complete")
	db = db.Joins("left join game_task gt on gt.task_id = gtc.task_id")
	db = db.Where("gtc.task_id = ?", id)
	db = db.Where("gtc.create_date = ?", date)
	err = db.Order("gtc.id desc").Find(&api).Error
	return
}

// 更新GameTaskTarget
func (s *GameTask) UpdateGameTaskTarget(requestData request.UpdateGameTaskTargetRequest) (err error) {
	if errors.Is(global.GVA_DB.Where("task_id = ?", requestData.TaskId).Where("create_date = ?", requestData.CreateDate).First(&task.GameTargetComplete{}).Error, gorm.ErrRecordNotFound) {
		return errors.New("不存在的任务")
	}
	gameTask := new(task.GameTargetComplete)
	global.GVA_DB.Where("task_id = ?", requestData.TaskId).Where("create_date = ?", requestData.CreateDate).First(&gameTask)
	var taskData task.GameTask
	err = global.GVA_DB.Where("task_id = ?", requestData.TaskId).First(&taskData).Error
	if err != nil {
		return
	}
	//if gameTask.NewTarget > requestData.NewTarget && gameTask.RetainedTarget > requestData.RetainedTarget {
	//	return errors.New("任务目标不能小于当前目标")
	//}
	updateData := map[string]interface{}{
		"new_target":             requestData.NewTarget,
		"pay_target":             requestData.PayTarget,
		"retained_target":        requestData.RetainedTarget,
		"hand_new_complete":      requestData.HandNewComplete + gameTask.HandNewComplete,
		"hand_retained_complete": requestData.HandRetainedComplete + gameTask.HandRetainedComplete,
		"hand_pay_complete":      requestData.HandPayComplete + gameTask.HandPayComplete,
		"hand_amount_total":      requestData.HandAmountTotal + gameTask.HandAmountTotal,
	}
	date := time.Now().Format("2006-01-02")
	if gameTask.CreateDate.Format("2006-01-02") == date {
		if gameTask.PayTarget < requestData.PayTarget {
			global.GVA_LOG.Warn("进入修改add update")
			lastPayAddUpdateTimeKey := fmt.Sprintf(LastPayAddUpdateTimeKey, date, gameTask.TaskId)
			_ = s.cache.SetCacheStr(context.Background(), lastPayAddUpdateTimeKey, time.Now().Unix())
		}
	}

	err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
		if requestData.IsFree == 1 {
			handComplete := new(task.GameHandComplete)
			handComplete.TaskId = requestData.TaskId
			handComplete.IsFree = requestData.IsFree
			handComplete.HandAmountTotal = requestData.HandAmountTotal
			handComplete.HandPayComplete = requestData.HandPayComplete
			handComplete.HandRetainedComplete = requestData.HandRetainedComplete
			handComplete.HandNewComplete = requestData.HandNewComplete
			handComplete.FreeMethod = requestData.FreeMethod
			handComplete.CreateDate = gameTask.CreateDate
			handComplete.IsUploadWt = requestData.IsUploadWt
			handComplete.IsUploadXjf = requestData.IsUploadXjf
			err := tx.Omit("create_time").Create(&handComplete).Error
			if err != nil {
				return err
			}
			if len(requestData.CardList) > 0 {
				var cards []task.GameHandCardLog
				for _, card := range requestData.CardList {
					var handCardLog task.GameHandCardLog
					handCardLog.TaskId = requestData.TaskId
					handCardLog.Card = card.Card
					handCardLog.Amount = card.Amount
					handCardLog.HandId = handComplete.Id
					cards = append(cards, handCardLog)
				}
				err := tx.Omit("create_time").Create(&cards).Error
				if err != nil {
					return err
				}
			}
		}
		err = tx.Model(&task.GameTargetComplete{}).Where("task_id = ?", requestData.TaskId).Where("create_date = ?", requestData.CreateDate).Updates(updateData).Error
		if err != nil {
			global.GVA_LOG.Error("更新任务数据失败: ", zap.Error(err))
			return err
		}
		if requestData.IsUploadXjf == 1 || requestData.IsUploadWt == 1 {
			if requestData.HandAmountTotal <= 0 {
				return err
			}
			createDate := gameTask.CreateDate.Format("2006-01-02")
			if requestData.IsUploadWt == 1 {
				if taskData.GamePortId == 5 {
					err = s.FreeUploadWt(taskData.MzGameId, taskData.MzChannel, createDate, requestData.HandAmountTotal, "game_task_report_meizu")
				} else if taskData.GamePortId == 1 {
					err = s.FreeUploadWt(taskData.TxGameId, taskData.TxChannel, createDate, requestData.HandAmountTotal, "game_task_report")
				}
				if err != nil {
					global.GVA_LOG.Error("上传wt财务数据失败gameId = "+taskData.TxGameId+"date = "+createDate, zap.Error(err))
				}
			}
			if requestData.IsUploadXjf == 1 {
				for i := 0; i < requestData.HandPayComplete; i++ {
					account := "hand_" + strconv.Itoa(i) + "_" + createDate
					err = s.FreeUploadXjf(strconv.Itoa(taskData.TaskId), "付费充值", account, "付费成功", "")
					if err != nil {
						global.GVA_LOG.Error("上传xjf数据失败taskId = "+strconv.Itoa(taskData.TaskId)+"date = "+createDate, zap.Error(err))
					}
				}
				if requestData.FreeMethod == 1 && len(requestData.CardList) > 0 {
					for _, card := range requestData.CardList {
						err = s.QQCardUsedLogUploadXjf(taskData.TaskId, card.Card, card.Amount)
						if err != nil {
							global.GVA_LOG.Error("上传qq卡数据失败taskId = "+strconv.Itoa(taskData.TaskId)+"date = "+createDate, zap.Error(err))
						}
					}
				}
			}
		}
		return err
	})
	return
}

func (s *GameTask) TargetStatistics(date string) (apiList []control.TargetStatisticsReply, err error) {
	db := global.GVA_DB.Table("game_target_complete gtc")
	db = db.Select("gtc.task_id,gt.task_name,gtc.new_target,gt.login_method,gt.user,gtc.pay_target,gtc.retained_target," +
		"gtc.new_complete,gtc.pay_complete,gtc.retained_complete,gtc.create_date,gt.tx_channel,gt.tx_game_id,gt.mz_channel," +
		"gt.game_id_xmy,gt.mz_game_id,gt.game_port_id,gt.game_id,gt.game_name," +
		"gtc.hand_new_complete,gtc.hand_retained_complete,gtc.hand_pay_complete,gtc.hand_amount_total")
	db = db.Joins("left join game_task gt on gt.task_id = gtc.task_id")
	db = db.Where("gt.is_del = ?", -1)
	db = db.Where("gt.status = ?", 1)
	db = db.Where("gtc.create_date = ?", date)
	var taskTarget []control.GetTargetStatisticsReply
	err = db.Order("gtc.id desc").Find(&taskTarget).Error
	if len(taskTarget) != 0 {
		for _, target := range taskTarget {
			var targetStatistics control.TargetStatisticsReply
			targetStatistics.TaskId = target.TaskId
			targetStatistics.TaskName = target.TaskName
			targetStatistics.Date = date
			targetStatistics.TargetActive = target.RetainedTarget
			targetStatistics.TargetPay = target.PayTarget
			targetStatistics.TargetNew = target.NewTarget
			targetStatistics.CompleteNew = target.NewComplete + target.HandNewComplete
			targetStatistics.CompleteActive = target.RetainedComplete + target.HandRetainedComplete
			targetStatistics.CompletePay = target.PayComplete + target.HandPayComplete
			targetStatistics.XmyId = target.GameIdXmy
			targetStatistics.QqId = target.TxGameId
			targetStatistics.QqChannel = target.TxChannel
			targetStatistics.MeiZuGameId = target.MzGameId
			targetStatistics.MeiZuChannel = target.MzChannel
			targetStatistics.LoginMode = LoginMethod[target.LoginMethod]
			targetStatistics.GamePort = GamePort[target.GamePortId]
			targetStatistics.GameDirector = target.User
			targetStatistics.GameId = target.GameId
			targetStatistics.GameName = target.GameName
			apiList = append(apiList, targetStatistics)
		}
	}
	return
}

func (s *GameTask) DayStatisticsData(request request.GameTaskStatisticsRequest) (gameTargetDates []response.GameTargetStatistics, err error) {
	createDate := time.Now().Format("2006-01-02")
	if request.Date == "" || request.Date == createDate {
		request.Date = time.Now().Format("2006-01-02")
		gameTargets, err := s.EveryDayTargetData(request.Date, request)
		if err != nil {
			return gameTargetDates, err
		}
		for _, gameTarget := range gameTargets {
			var gameTargetDate response.GameTargetStatistics
			gameTargetDate.PayTarget = gameTarget.PayTarget
			gameTargetDate.NewTarget = gameTarget.NewTarget
			gameTargetDate.RetainedTarget = gameTarget.RetainedTarget
			gameTargetDate.PayComplete = gameTarget.PayComplete + gameTarget.HandPayComplete
			gameTargetDate.NewComplete = gameTarget.NewComplete + gameTarget.HandNewComplete
			gameTargetDate.RetainedComplete = gameTarget.RetainedComplete + gameTarget.HandRetainedComplete
			gameTargetDate.Amount = gameTarget.Amount + gameTarget.HandAmountTotal
			gameTargetDate.GamePort = GamePort[gameTarget.GamePortId]
			gameTargetDate.User = gameTarget.User
			gameTargetDate.TaskDate = gameTarget.CreateDate.Format("2006-01-02")
			gameTargetDates = append(gameTargetDates, gameTargetDate)
		}

	} else {
		gameTargets, err := s.PastDayTargetData(request.Date, request)
		if err != nil {
			return gameTargetDates, err
		}
		for _, gameTarget := range gameTargets {
			var gameTargetDate response.GameTargetStatistics
			gameTargetDate.PayTarget = gameTarget.PayTarget
			gameTargetDate.NewTarget = gameTarget.NewTarget
			gameTargetDate.RetainedTarget = gameTarget.RetainedTarget
			gameTargetDate.PayComplete = gameTarget.PayComplete
			gameTargetDate.NewComplete = gameTarget.NewComplete
			gameTargetDate.RetainedComplete = gameTarget.RetainedComplete
			gameTargetDate.Amount = gameTarget.Amount
			gameTargetDate.TaskDate = gameTarget.TaskDate.Format("2006-01-02")
			gameTargetDate.GamePort = GamePort[gameTarget.GamePortId]
			gameTargetDate.User = gameTarget.User
			gameTargetDates = append(gameTargetDates, gameTargetDate)
		}

	}
	return
}

func (s *GameTask) EveryDayTargetData(date string, request request.GameTaskStatisticsRequest) (gameTarget []response.GameTargetCompleteReply, err error) {
	db := global.GVA_DB.Table("game_target_complete gtc")
	db = db.Select("gtc.create_date,SUM(gtc.new_complete) new_complete,SUM(gtc.pay_complete) pay_complete,SUM(gtc.retained_complete) retained_complete,SUM(gtc.new_target) new_target,SUM(gtc.pay_target) pay_target,SUM(gtc.retained_target) retained_target,SUM(gtc.amount) amount,SUM(gtc.hand_pay_complete) hand_pay_complete,SUM(gtc.hand_new_complete) hand_new_complete,SUM(gtc.hand_retained_complete) hand_retained_complete,SUM(gtc.hand_amount_total) hand_amount_total," +
		"gt.user,gt.game_port_id")
	db = db.Joins("left join game_task gt on gt.task_id = gtc.task_id")
	db = db.Where("gtc.create_date = ?", date)
	if request.GroupKey != "" {
		group := "gt." + request.GroupKey
		db = db.Group(group)
	}
	err = db.Find(&gameTarget).Error
	return
}

func (s *GameTask) PastDayTargetData(date string, request request.GameTaskStatisticsRequest) (gameTarget []task.GameTargetStatistics, err error) {
	db := global.GVA_DB.Table("game_target_statistics")
	db = db.Where("task_date = ?", date)
	if request.GroupKey != "" {
		group := request.GroupKey
		db = db.Group(group)
	}
	err = db.Find(&gameTarget).Error
	return
}

func (s *GameTask) MonthStatisticsData() (gameTarget []task.GameTargetStatistics, err error) {
	year, _, _ := time.Now().Date()
	db := global.GVA_DB.Table("game_target_statistics")
	db = db.Select("task_year,task_month,SUM(new_complete) new_complete,SUM(pay_complete) pay_complete,SUM(retained_complete) retained_complete,SUM(new_target) new_target,SUM(pay_target) pay_target,SUM(retained_target) retained_target,SUM(amount) amount")
	db = db.Where("task_year = ?", year)
	db = db.Group("task_month")
	err = db.Find(&gameTarget).Error
	return
}

func (s *GameTask) GameStatisticsData(date string) (gameTarget []response.GameStatisticsDataReply, err error) {
	if date == "" {
		date = time.Now().Format("2006-01-02")
	}
	db := global.GVA_DB.Table("game_target_complete gtc")
	db = db.Select("gt.user,gt.game_port_id,COUNT(DISTINCT(gtc.task_id)) total,gtc.create_date")
	db = db.Joins("left join game_task gt on gt.task_id = gtc.task_id")
	db = db.Where("gtc.create_date = ?", date)
	db = db.Group("gt.user,gt.game_port_id")
	err = db.Find(&gameTarget).Error
	if err != nil {
		return nil, err
	}
	for i, target := range gameTarget {
		gameTarget[i].GamePort = GamePort[target.GamePortId]
		gameTarget[i].CreateDate = date
	}
	return
}

func (s *GameTask) GameStatisticsList(rq request.GameListRequest) (gameTarget []response.GameStatisticsListReply, err error) {
	if rq.Date == "" {
		rq.Date = time.Now().Format("2006-01-02")
	}
	db := global.GVA_DB.Table("game_target_complete gtc")
	db = db.Select("gt.game_port_id,gt.game_name")
	db = db.Joins("left join game_task gt on gt.task_id = gtc.task_id")
	db = db.Where("gtc.create_date = ?", rq.Date)
	db = db.Where("gt.user = ?", rq.User)
	db = db.Where("gt.game_port_id = ?", rq.GamePortId)
	err = db.Find(&gameTarget).Error
	if err != nil {
		return nil, err
	}
	for i, target := range gameTarget {
		gameTarget[i].GamePort = GamePort[target.GamePortId]
		gameTarget[i].CreateDate = rq.Date
	}
	return
}

//
func (s *GameTask) ResetFeeUploadXjf(gameId int) (err error) {
	url := global.GVA_CONFIG.ExtranetDomain.Control + "/v1/task_statistics/rerun_retained"
	requestData := map[string]string{
		"game_id": strconv.Itoa(gameId),
	}
	data, code, err := utils.HttpGetReplyCode(url, requestData)
	if err != nil {
		return err
	}
	fmt.Println(code)
	if code != 200 {
		return errors.New(string(data))
	}
	return
}

//@function: TaskResetFee
//@description: 重置付费
//@param: api task.GameTask
//@return: err error
func (s *GameTask) TaskResetFee(api request.GameTaskRequest) (err error) {
	var entity task.GameTask
	err = global.GVA_DB.Where("task_id = ?", api.TaskId).First(&entity).Error
	if errors.Is(err, gorm.ErrRecordNotFound) {
		return err
	}
	err = s.ResetFeeUploadXjf(api.TaskId)
	if err != nil {
		global.GVA_LOG.Error("请求群控数据报错: ", zap.Error(err))
		return errors.New("请求群控数据报错")
	}
	return
}