package com.szwl.controller;

import com.szwl.feign.bean.SyncOldFeign;
import com.szwl.mapper.TCoinOrderMapper;
import com.szwl.model.bo.R;
import com.szwl.model.bo.ResponseModel;
import com.szwl.model.entity.TCoinOrder;
import com.szwl.service.TCoinOrderService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.util.List;

@Slf4j
@Api(value = "/syncCoinOrder", tags = {"同步旧系统的coinOrder数据"})
@RestController
@RequestMapping("/syncCoinOrder")
public class SyncOldCoinOrderController {

    SyncOldFeign syncOldFeign;
    @Resource
    TCoinOrderMapper coinOrderMapper;
    TCoinOrderService coinOrderService;

    public SyncOldCoinOrderController(SyncOldFeign syncOldFeign, TCoinOrderService coinOrderService) {
        this.syncOldFeign = syncOldFeign;
        this.coinOrderService = coinOrderService;
    }

    // 真批量同步
    @ApiOperation(value = "同步海外某客户的某一设备某一时间段内的 coinOrder 订单")
    @PostMapping("/syncCoinOrderByCAT")
    public ResponseModel<?> syncCoinOrderByCAT(String adminId, String clientId, String startTime, String endTime) {

        if (adminId != null && StringUtils.isNotEmpty(clientId) && StringUtils.isNotEmpty(startTime) && StringUtils.isNotEmpty(endTime)) {
            long l = Long.parseLong(adminId);

            List<TCoinOrder> coinOrderList = R.getDataIfSuccess(syncOldFeign.getCoinOrderByACT(l, clientId, startTime, endTime));

            if (coinOrderList.size() == 0) {
                return R.fail("未查询到订单信息");
            }

            if (coinOrderList.size() > 10000) {
                return R.fail("数据量过大，请缩短时间范围");
            }

//        coinOrderService.saveBatch(coinOrderList);

            int i = coinOrderMapper.insertBatchSomeColumn(coinOrderList);
            return R.ok("批量插入 coinOrder " + i + "条记录");

        } else {
            return R.ok("参数不能为空");
        }
    }

    // 伪批量同步
//    @ApiOperation(value = "同步海外某客户的某一设备某一时间段内的 coinOrder 订单")
//    @PostMapping("/syncCoinOrderByCAT")
//    public ResponseModel<?> syncCoinOrderByCAT(String adminId, String clientId, String startTime, String endTime) {
//        if (StringUtils.isNotEmpty(adminId) && StringUtils.isNotEmpty(clientId) && StringUtils.isNotEmpty(startTime) && StringUtils.isNotEmpty(endTime)) {
//            long l = Long.parseLong(adminId);
//
//            List<TCoinOrder> coinOrderList = R.getDataIfSuccess(syncOldFeign.getCoinOrderByACT(l, clientId, startTime, endTime));
//
//
//            if (coinOrderList.size()>1000) {
//                return R.fail("数据量过大，请缩短时间范围");
//            }
////            coinOrderService.saveBatch(coinOrderList);
//
//            for (TCoinOrder coinOrder : coinOrderList) {
////                System.out.println("coinOrder》》" + coinOrder);
//                coinOrderService.save(coinOrder);
//            }
//
//            return R.ok(adminId + "同步设备" + clientId + "从" + startTime + "至" + endTime + "的 coinOrder 信息成功");
//        } else {
//            return R.fail("参数不能为空");
//        }
//    }


}