package main

import (
	"context"
	"errors"
	"flag"
	"fmt"
	"os"
	"time"

	"bindbox-game/configs"
	"bindbox-game/internal/pkg/env"
	"bindbox-game/internal/pkg/logger"
	"bindbox-game/internal/repository/mysql"
	"bindbox-game/internal/repository/mysql/model"
	douyin "bindbox-game/internal/service/douyin"
)

// staticSyscfg implements sysconfig.Service with fixed cookie
type staticSyscfg struct {
	cookie string
}

func (s *staticSyscfg) GetByKey(ctx context.Context, key string) (*model.SystemConfigs, error) {
	switch key {
	case douyin.ConfigKeyDouyinCookie:
		if s.cookie == "" {
			return nil, errors.New("douyin cookie 未设置")
		}
		return &model.SystemConfigs{ConfigKey: key, ConfigValue: s.cookie}, nil
	case douyin.ConfigKeyDouyinInterval:
		return &model.SystemConfigs{ConfigKey: key, ConfigValue: "5"}, nil
	default:
		return nil, errors.New("暂不支持的配置 key: " + key)
	}
}

func (s *staticSyscfg) UpsertByKey(ctx context.Context, key string, value string, remark string) (*model.SystemConfigs, error) {
	return nil, errors.New("UpsertByKey 未实现")
}
func (s *staticSyscfg) ModifyByID(ctx context.Context, id int64, value *string, remark *string) error {
	return errors.New("ModifyByID 未实现")
}
func (s *staticSyscfg) DeleteByID(ctx context.Context, id int64) error {
	return errors.New("DeleteByID 未实现")
}
func (s *staticSyscfg) List(ctx context.Context, page int, pageSize int, keyword string) (items []*model.SystemConfigs, total int64, err error) {
	return nil, 0, errors.New("List 未实现")
}

func main() {
	minutes := flag.Int("minutes", 10, "同步最近多少分钟的订单")
	useProxy := flag.Bool("proxy", false, "是否使用服务内置代理")
	printLimit := flag.Int("print", 10, "同步后打印多少条订单 (0 表示不打印)")
	mode := flag.String("mode", "sync-all", "同步模式: sync-all(默认增量)/fetch(按绑定用户)")
	grantMinesweeper := flag.Bool("grant-minesweeper", false, "同步后执行 GrantMinesweeperQualifications")
	fetchOnlyUnmatched := flag.Bool("fetch-only-unmatched", true, "按用户同步时是否仅同步未匹配订单的用户")
	fetchMaxUsers := flag.Int("fetch-max-users", 200, "按用户同步时最多处理的用户数量 (50-1000)")
	fetchBatchSize := flag.Int("fetch-batch-size", 20, "按用户同步时的单批次用户数量 (5-50)")
	fetchConcurrency := flag.Int("fetch-concurrency", 5, "按用户同步时的并发抓取数 (<=批次大小)")
	fetchDelay := flag.Int("fetch-delay-ms", 200, "批次之间的停顿时间 (毫秒)")
	flag.Parse()

	env.Active() // 初始化 env flag（依赖已有的全局 -env/ACTIVE_ENV 配置）
	configs.Init()

	cookie := "s_v_web_id=verify_mm0pjkt7_rRCYDU7B_F5Yl_4UYj_8yQ0_ue0vAcKwYt3z; csrf_session_id=86df5285aa04dec74fe5ac89d1b0d5c0; passport_csrf_token=fe2b51efeb70763190b402f49ad9f0e9; passport_csrf_token_default=fe2b51efeb70763190b402f49ad9f0e9; x-web-secsdk-uid=749f802e-47b8-4221-98af-b726e5631036; Hm_lvt_b6520b076191ab4b36812da4c90f7a5e=1771943727; HMACCOUNT=74DD13C46DE836FC; ttcid=c1ec90610ace481ba60dd8303b332c8e40; odin_tt=f01a3108f23b93c70d9d41eb2536553aa6550eb007cfc2bc3ba6319e82ad90eef45e1f581adbb6d1fb1fc2bdcce6d8cdd72b475fa9943bab1df0efe1ea035355; passport_auth_status=07988630820adb6946c4969658ab8b4d%2C; passport_auth_status_ss=07988630820adb6946c4969658ab8b4d%2C; uid_tt=f8cbc1387650f5a331a9a2943293d5f2; uid_tt_ss=f8cbc1387650f5a331a9a2943293d5f2; sid_tt=d1e48959ea47e34970be1d9b0aa801a2; sessionid=d1e48959ea47e34970be1d9b0aa801a2; sessionid_ss=d1e48959ea47e34970be1d9b0aa801a2; is_staff_user=false; PHPSESSID=294f6cf83ec2a4fefc1222321590b3e7; PHPSESSID_SS=294f6cf83ec2a4fefc1222321590b3e7; ucas_c0=CkEKBTEuMC4wEKOIj97Q5-3OaRjmJiD61rDnqc2DBCiwITCb1oDYuM3aB0DL7vbMBkjLorPPBlC_vL6Ekt3t1GdYbhIUPQw_elr7IsxkcNFj3v1rRHn03qs; ucas_c0_ss=CkEKBTEuMC4wEKOIj97Q5-3OaRjmJiD61rDnqc2DBCiwITCb1oDYuM3aB0DL7vbMBkjLorPPBlC_vL6Ekt3t1GdYbhIUPQw_elr7IsxkcNFj3v1rRHn03qs; ecom_gray_shop_id=156231010; sid_guard=d1e48959ea47e34970be1d9b0aa801a2%7C1772108860%7C5184000%7CMon%2C+27-Apr-2026+12%3A27%3A40+GMT; session_tlb_tag=sttt%7C9%7C0eSJWepH40lwvh2bCqgBov_________yZl6I8Equ6hjlsXft1nWEmcwpzFQYKIutCIRtYdHffp0%3D; sid_ucp_v1=1.0.0-KDc4Mjc1ZjFkNTg4NjFkZWQwYjUzMTJmNWFjN2U4ZmM1NzYzODEwNTcKGQib1oDYuM3aBxC8-IDNBhiwISAMOAZA9AcaAmxmIiBkMWU0ODk1OWVhNDdlMzQ5NzBiZTFkOWIwYWE4MDFhMg; ssid_ucp_v1=1.0.0-KDc4Mjc1ZjFkNTg4NjFkZWQwYjUzMTJmNWFjN2U4ZmM1NzYzODEwNTcKGQib1oDYuM3aBxC8-IDNBhiwISAMOAZA9AcaAmxmIiBkMWU0ODk1OWVhNDdlMzQ5NzBiZTFkOWIwYWE4MDFhMg; COMPASS_LUOPAN_DT=session_7611148681122726154; BUYIN_SASID=SID2_7611148178737856777; gfkadpd=4272,23756; zsgw_business_data=%7B%22uuid%22%3A%2267d1b0e4-dca5-484d-997a-b70cb555e396%22%2C%22platform%22%3A%22pc%22%2C%22source%22%3A%22seo.google%22%7D; source=seo.google; Hm_lpvt_b6520b076191ab4b36812da4c90f7a5e=1772115439; ttwid=1%7C71OUHp7yB34JMc3dVW9XMZxKJfcmzgfSzG407fx6Gqo%7C1772115438%7C5c6372575550a6bddb3a4eb25fff2fdc9f0d0954e0ce795eb1eb15e121a9ca53; tt_scid=bAGxaUh7d5HftS77rQMVwbdERMWrYT63ZZMLaRlsZiLgbOweJMjw-1IEYQvEO1Qz836d; op_session="
	if cookie == "" {
		fmt.Println("请通过环境变量 DOUYIN_COOKIE 提供抖店 Cookie")
		os.Exit(1)
	}

	log, err := logger.NewCustomLogger(logger.WithDebugLevel(), logger.WithOutputInConsole())
	if err != nil {
		panic(err)
	}

	repo, err := mysql.New()
	if err != nil {
		panic(err)
	}
	defer repo.DbRClose()
	defer repo.DbWClose()

	svc := douyin.New(log, repo, &staticSyscfg{cookie: cookie}, nil, nil, nil)

	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
	defer cancel()

	switch *mode {
	case "fetch":
		fmt.Println("开始 FetchAndSyncOrders（按绑定用户同步）...")
		result, err := svc.FetchAndSyncOrders(ctx, &douyin.FetchOptions{
			OnlyUnmatched:   *fetchOnlyUnmatched,
			MaxUsers:        *fetchMaxUsers,
			BatchSize:       *fetchBatchSize,
			Concurrency:     *fetchConcurrency,
			InterBatchDelay: time.Duration(*fetchDelay) * time.Millisecond,
		})
		if err != nil {
			panic(err)
		}
		fmt.Printf("完成：抓取 %d，新订单 %d，匹配 %d，处理用户 %d/%d，跳过 %d，用时 %.2fs。\n",
			result.TotalFetched, result.NewOrders, result.MatchedUsers,
			result.ProcessedUsers, result.TotalUsers, result.SkippedUsers,
			float64(result.ElapsedMS)/1000.0)
	case "sync-all":
		fallthrough
	default:
		duration := time.Duration(*minutes) * time.Minute
		fmt.Printf("开始 SyncAllOrders，duration=%s proxy=%v ...\n", duration, *useProxy)
		result, err := svc.SyncAllOrders(ctx, duration, *useProxy)
		if err != nil {
			panic(err)
		}
		fmt.Printf("完成：抓取 %d，新订单 %d，匹配 %d。\n", result.TotalFetched, result.NewOrders, result.MatchedUsers)
	}

	if *grantMinesweeper {
		fmt.Println("执行 GrantMinesweeperQualifications ...")
		if err := svc.GrantMinesweeperQualifications(ctx); err != nil {
			fmt.Printf("GrantMinesweeperQualifications 失败: %v\n", err)
		} else {
			fmt.Println("GrantMinesweeperQualifications 完成。")
		}
	}

	if *printLimit > 0 {
		var orders []model.DouyinOrders
		if err := repo.GetDbR().Order("id DESC").Limit(*printLimit).Find(&orders).Error; err != nil {
			fmt.Printf("读取订单列表失败: %v\n", err)
			return
		}
		fmt.Println("shop_order_id\torder_status\tdouyin_user_id\tlocal_user_id")
		for _, o := range orders {
			fmt.Printf("%s\t%d\t%s\t%s\n", o.ShopOrderID, o.OrderStatus, o.DouyinUserID, o.LocalUserID)
		}
	}
}

// go run cmd/douyin_sync_debug/main.go -env dev -mode fetch -fetch-only-unmatched=false -fetch-max-users=200 -fetch-batch-size=1 -fetch-concurrency=1 -fetch-delay-ms=0