package com.jsowell.api.uniapp;

import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.response.RestApiResponse;
import com.jsowell.pile.domain.MemberPlateNumberRelation;
import com.jsowell.pile.dto.CarVinDTO;
import com.jsowell.pile.dto.QueryOrderDTO;
import com.jsowell.pile.service.IMemberPlateNumberRelationService;
import com.jsowell.pile.service.IOrderBasicInfoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;

/**
 * 用于临时接口
 */
@Anonymous
@RestController
@RequestMapping("/temp")
public class TempController extends BaseController {

    @Autowired
    private IOrderBasicInfoService orderBasicInfoService;

    @Autowired
    private IMemberPlateNumberRelationService memberPlateNumberRelationService;

    /**
     * 临时刷数据接口
     * http://localhost:8080/temp/tempUpdateVirtualAmount
     * @param request
     * @return
     */
    @PostMapping("tempUpdateVirtualAmount")
    public RestApiResponse<?> tempUpdateVirtualAmount(HttpServletRequest request, @RequestBody QueryOrderDTO dto) {
        logger.info("临时刷数据接口 param:{}", dto);
        RestApiResponse<?> response = null;
        try {
            String s = orderBasicInfoService.tempUpdateVirtualAmount(dto);
            response = new RestApiResponse<>(s);
        } catch (BusinessException e) {
            logger.warn("临时刷数据接口 warn", e);
            response = new RestApiResponse<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            logger.error("临时刷数据接口 error", e);
            response = new RestApiResponse<>(ReturnCodeEnum.CODE_GET_PILE_DETAIL_ERROR);
        }
        logger.info("临时刷数据接口 result:{}", JSONObject.toJSONString(response));
        return response;
    }

    /**
     * 临时订单退款
     * http://localhost:8080/temp/tempOrderRefund
     * @return
     */
    @GetMapping("tempOrderRefund")
    public RestApiResponse<?> tempOrderRefund() {
        RestApiResponse<?> response = null;
        try {
            orderBasicInfoService.tempOrderRefund();
            response = new RestApiResponse<>();
        } catch (BusinessException e) {
            logger.warn("临时订单退款接口 warn", e);
            response = new RestApiResponse<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            logger.error("临时订单退款接口 error", e);
            response = new RestApiResponse<>(ReturnCodeEnum.CODE_WEIXIN_REFUND_ERROR);
        }
        logger.info("临时刷数据接口 result:{}", JSONObject.toJSONString(response));
        return response;
    }

    /**
     * 批量退款接口
     * http://localhost:8080/temp/batchRefund
     * @param dto
     * @return
     */
    @PostMapping("/batchRefund")
    public RestApiResponse<?> batchRefund(@RequestBody QueryOrderDTO dto) {
        RestApiResponse<?> response = null;
        try {
            orderBasicInfoService.batchRefund(dto);
            response = new RestApiResponse<>();
        } catch (BusinessException e) {
            logger.warn("临时订单退款接口 warn", e);
            response = new RestApiResponse<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            logger.error("临时订单退款接口 error", e);
            response = new RestApiResponse<>(ReturnCodeEnum.CODE_WEIXIN_REFUND_ERROR);
        }
        logger.info("临时刷数据接口 result:{}", JSONObject.toJSONString(response));
        return response;
    }

    /**
     * 临时接口，计算站点订单报表
     * http://localhost:8080/temp/tempGenerateDailyOrderReports
     * @param dto
     * @return
     */
    @PostMapping("/tempGenerateDailyOrderReports")
    public RestApiResponse<?> tempGenerateDailyOrderReports(@RequestBody QueryOrderDTO dto) {
        RestApiResponse<?> response = null;
        try {

            dto.getStationIdList().parallelStream().forEach(x -> orderBasicInfoService.generateDailyOrderReports(x, dto.getStartTime()));

            response = new RestApiResponse<>();
        } catch (BusinessException e) {
            logger.warn("临时接口计算站点订单报表 warn", e);
            response = new RestApiResponse<>(e.getCode(), e.getMessage());
        } catch (Exception e) {
            logger.error("临时接口计算站点订单报表 error", e);
            response = new RestApiResponse<>(ReturnCodeEnum.CODE_WEIXIN_REFUND_ERROR);
        }
        logger.info("临时接口计算站点订单报表 result:{}", JSONObject.toJSONString(response));
        return response;
    }

    /**
     * 临时接口测试vin查询方法
     * @param dto
     * @return
     */
    @PostMapping("/tempTestVinCode")
    public RestApiResponse<?> tempTestVinCode(@RequestBody CarVinDTO dto) {
        RestApiResponse<?> response = null;
        try {
            MemberPlateNumberRelation memberPlateInfoByVinCode = memberPlateNumberRelationService.getMemberPlateInfoByVinCode(dto.getVinCode());
            response = new RestApiResponse<>(memberPlateInfoByVinCode);
        } catch (Exception e) {
            logger.error("临时接口测试vin查询方法 error,", e);
            response = new RestApiResponse<>(ReturnCodeEnum.CODE_WEIXIN_REFUND_ERROR);
        }
        logger.info("临时接口测试vin查询方法 result:{}", response);
        return response;
    }
}