package proc

import (
	"encoding/json"
	"github.com/hu17889/go_spider/core/common/page"
	"github.com/hu17889/go_spider/core/pipeline"
	"github.com/hu17889/go_spider/core/spider"
	"math/rand"
	"strconv"
	"strings"
	"tesou.io/platform/foot-parent/foot-api/common/base"
	"tesou.io/platform/foot-parent/foot-api/module/match/pojo"
	entity2 "tesou.io/platform/foot-parent/foot-api/module/odds/pojo"
	"tesou.io/platform/foot-parent/foot-core/module/odds/service"
	"tesou.io/platform/foot-parent/foot-spider/module/win007"
	"tesou.io/platform/foot-parent/foot-spider/module/win007/down"
	"tesou.io/platform/foot-parent/foot-spider/module/win007/vo"
	"time"
)

type AsiaLastNewProcesser struct {
	service.AsiaLastService
	service.AsiaHisService
	service.AsiaTrackService
	//是否是单线程
	SingleThread bool
	MatchLastList      []*pojo.MatchLast
	Win007idMatchidMap map[string]string
}

func GetAsiaLastNewProcesser() *AsiaLastNewProcesser {
	processer := &AsiaLastNewProcesser{}
	processer.Init()
	return processer
}

func (this *AsiaLastNewProcesser) Init() {
	//初始化参数值
	this.Win007idMatchidMap = map[string]string{}
}

func (this *AsiaLastNewProcesser) Setup(temp *AsiaLastNewProcesser) {
	//设置参数值
}

func (this *AsiaLastNewProcesser) Startup() {

	var newSpider *spider.Spider
	processer := this
	newSpider = spider.NewSpider(processer, "AsiaLastNewProcesser")
	for i, v := range this.MatchLastList {

		if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
			//先将前面的spider启动
			newSpider.SetDownloader(down.NewMAsiaLastApiDownloader())
			newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
			newSpider.SetSleepTime("rand", win007.SLEEP_RAND_S, win007.SLEEP_RAND_E)
			newSpider.SetThreadnum(10).Run()

			processer = GetAsiaLastNewProcesser()
			processer.Setup(this)
			newSpider = spider.NewSpider(processer, "AsiaLastNewProcesser"+strconv.Itoa(i))
		}

		temp_flag := v.Ext[win007.MODULE_FLAG]
		bytes, _ := json.Marshal(temp_flag)
		matchExt := new(pojo.MatchExt)
		json.Unmarshal(bytes, matchExt)
		win007_id := matchExt.Sid

		processer.Win007idMatchidMap[win007_id] = v.Id

		url := strings.Replace(win007.WIN007_ASIAODD_NEW_URL_PATTERN, "${matchId}", win007_id, 1)
		url = strings.Replace(url, "${flesh}", strconv.FormatFloat(rand.Float64(), 'f', -1, 64), 1)
		newSpider = newSpider.AddUrl(url, "json")
	}

	newSpider.SetDownloader(down.NewMAsiaLastApiDownloader())
	newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
	newSpider.SetSleepTime("rand", win007.SLEEP_RAND_S, win007.SLEEP_RAND_E)
	newSpider.SetThreadnum(1).Run()

}

func (this *AsiaLastNewProcesser) Process(p *page.Page) {
	request := p.GetRequest()
	if !p.IsSucc() {
		base.Log.Error("URL:", request.Url, p.Errormsg())
		return
	}

	last_slice := make([]interface{}, 0)
	last_update_slice := make([]interface{}, 0)
	his_slice := make([]interface{}, 0)
	his_update_slice := make([]interface{}, 0)
	track_slice := make([]interface{}, 0)
	track_update_slice := make([]interface{}, 0)
	hdata_str := p.GetBodyStr()
	if hdata_str == "" {
		base.Log.Error("hdata_str:为空,URL:", request.Url)
		return
	}

	asiaData := &vo.AsiaData{}
	json.Unmarshal([]byte(hdata_str), asiaData)

	matchId := this.Win007idMatchidMap[strconv.Itoa(asiaData.ScheduleID)]
	//没有数据,则返回
	if nil == asiaData.Companies || len(asiaData.Companies) <= 0 {
		return
	}
	for _, e := range asiaData.Companies {

		last := new(entity2.AsiaLast)
		last.MatchId = matchId
		last.CompId = e.NameCn

		odd := e.Details[0]
		last.Sp3 = odd.FirstHomeOdds
		last.SLetBall = odd.FirstDrawOdds
		last.Sp0 = odd.FirstAwayOdds
		last.Ep3 = odd.HomeOdds
		last.ELetBall = odd.DrawOdds
		last.Ep0 = odd.AwayOdds
		if len(odd.ModifyTime) > 0 {
			tempMt, err := strconv.ParseInt(odd.ModifyTime, 0, 64)
			if nil != err {
				base.Log.Error(err.Error())
			}
			last.OddDate = time.Unix(tempMt, 0).Format("2006-01-02 15:04:05")
		}
		last_temp_id, last_exists := this.AsiaLastService.Exist(last)
		if !last_exists {
			last_slice = append(last_slice, last)
		} else {
			last.Id = last_temp_id
			last_update_slice = append(last_update_slice, last)
		}

		his := new(entity2.AsiaHis)
		his.AsiaLast = *last
		his_temp_id, his_exists := this.AsiaHisService.Exist(his)
		if !his_exists {
			his_slice = append(his_slice, his)
		} else {
			his.Id = his_temp_id
			his_update_slice = append(his_update_slice, his)
		}

		track := new(entity2.AsiaTrack)
		track.CompId = last.CompId
		track.MatchId = last.MatchId
		track.OddDate = last.OddDate
		track.Sp0 = last.Sp0
		track.Sp3 = last.Sp3
		track.SLetBall = last.SLetBall
		track.Ep0 = last.Ep0
		track.Ep3 = last.Ep3
		track.ELetBall = last.ELetBall

		track_temp_id, track_exists := this.AsiaTrackService.Exist(track)
		if !track_exists {
			track_slice = append(track_slice, track)
		} else {
			track.Id = track_temp_id
			track_update_slice = append(track_update_slice, track)
		}
	}

	//执行入库
	this.AsiaLastService.SaveList(last_slice)
	this.AsiaLastService.ModifyList(last_update_slice)

	this.AsiaHisService.SaveList(his_slice)
	this.AsiaHisService.ModifyList(his_update_slice)

	this.AsiaTrackService.SaveList(track_slice)
	this.AsiaTrackService.ModifyList(track_update_slice)

}

func (this *AsiaLastNewProcesser) Finish() {
	base.Log.Info("亚赔抓取解析完成 \r\n")

}