package com.doumee.cloud.web;

import com.doumee.api.BaseController;
import com.doumee.config.annotation.LoginNoRequired;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.dao.business.dto.YwCustomerRechargeRecordVO;
import com.doumee.dao.business.dto.h5.*;
import com.doumee.dao.business.model.YwContract;
import com.doumee.dao.business.model.YwContractBill;
import com.doumee.dao.business.model.YwH5Banner;
import com.doumee.dao.business.model.YwWxPayOrder;
import com.doumee.dao.system.dto.LoginPhoneDTO;
import com.doumee.service.business.SmsEmailService;
import com.doumee.service.business.YwCustomerH5AuthService;
import com.doumee.service.business.YwCustomerH5BizService;
import com.doumee.service.business.YwCustomerWxPayService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;

@Api(tags = "【公众号】商户H5")
@RestController
@Slf4j
@RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX + "/web/customer")
public class YwCustomerH5Controller extends BaseController {

    @Autowired
    private YwCustomerH5BizService ywCustomerH5BizService;
    @Autowired
    private YwCustomerWxPayService ywCustomerWxPayService;
    @Autowired
    private YwCustomerH5AuthService ywCustomerH5AuthService;
    @Autowired
    private SmsEmailService smsEmailService;

    private LoginUserInfo requireCustomerUser(String token) {
        LoginUserInfo user = getLoginUser(token);
        if (user == null || !Constants.equalsInteger(user.getH5UserType(), LoginUserInfo.H5_USER_CUSTOMER)) {
            throw new RuntimeException("登录已失效");
        }
        return user;
    }

    @LoginNoRequired
    @PreventRepeat
    @ApiOperation("商户登录发送验证码")
    @PostMapping("/sendLoginSms")
    public ApiResponse<Integer> sendLoginSms(@RequestBody(required = false) LoginPhoneDTO dto) {
        try {
            if (dto == null || StringUtils.isBlank(dto.getPhone())) {
                return ApiResponse.failed(ResponseStatus.BAD_REQUEST.getCode(), "手机号不能为空");
            }
            return ApiResponse.success(smsEmailService.sendMerchantLoginSms(dto.getPhone().trim()));
        } catch (BusinessException e) {
            return ApiResponse.failed(e.getCode(), e.getMessage());
        } catch (Throwable e) {
            log.error("sendLoginSms failed", e);
            return ApiResponse.failed(ResponseStatus.SERVER_ERROR.getCode(), "发送验证码失败，请稍后重试");
        }
    }

    @LoginNoRequired
    @PreventRepeat
    @ApiOperation("商户短信验证码登录")
    @PostMapping("/loginByPhone")
    public ApiResponse<String> loginByPhone(@Validated @RequestBody LoginPhoneDTO dto) {
        try {
            return ApiResponse.success(ywCustomerH5AuthService.loginByPhone(dto));
        } catch (BusinessException e) {
            return ApiResponse.failed(e.getCode(), e.getMessage());
        } catch (Exception e) {
            return ApiResponse.failed(ResponseStatus.SERVER_ERROR);
        }
    }

    @ApiOperation("获取当前商户登录信息")
    @GetMapping("/getUserInfo")
    public ApiResponse<LoginUserInfo> getUserInfo(@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = this.getLoginUser(token);
        if (user == null || !Constants.equalsInteger(user.getH5UserType(), LoginUserInfo.H5_USER_CUSTOMER)) {
            return ApiResponse.failed("登录已失效");
        }
        return ApiResponse.success(ywCustomerH5AuthService.buildLoginUserInfo(user.getCustomerId()));
    }

    @ApiOperation("工作台轮播图")
    @GetMapping("/banners")
    @LoginNoRequired
    public ApiResponse<List<YwH5Banner>> banners() {
        return ApiResponse.success(ywCustomerH5BizService.listBanners());
    }

    @ApiOperation("工作台首页")
    @GetMapping("/home")
    public ApiResponse<Map<String, Object>> home(@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.home(user.getCustomerId()));
    }

    @ApiOperation("交电费设备列表")
    @PostMapping("/device/page")
    public ApiResponse<PageData<CustomerDeviceH5VO>> devicePage(
            @RequestBody PageWrap<CustomerDeviceQueryDTO> pageWrap,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.devicePage(pageWrap, user.getCustomerId()));
    }

    @ApiOperation("设备详情")
    @GetMapping("/device/detail")
    public ApiResponse<CustomerDeviceH5VO> deviceDetail(
            @RequestParam Integer deviceType,
            @RequestParam Integer deviceId,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.deviceDetail(deviceType, deviceId, user.getCustomerId()));
    }

    @ApiOperation("充值记录")
    @PostMapping("/rechargeRecord/page")
    public ApiResponse<PageData<YwCustomerRechargeRecordVO>> rechargeRecordPage(
            @RequestBody PageWrap<CustomerRechargeRecordH5QueryDTO> pageWrap,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.rechargeRecordPage(pageWrap, user.getCustomerId()));
    }

    @ApiOperation("合同列表")
    @PostMapping("/contract/page")
    public ApiResponse<PageData<YwContract>> contractPage(
            @RequestBody PageWrap<CustomerContractQueryDTO> pageWrap,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.contractPage(pageWrap, user.getCustomerId()));
    }

    @ApiOperation("合同详情")
    @GetMapping("/contract/{id}")
    public ApiResponse<Map<String, Object>> contractDetail(
            @PathVariable("id") Integer id,
            @RequestParam(value = "billType", required = false, defaultValue = "0") Integer billType,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.contractDetail(id, user.getCustomerId(), billType));
    }

    @ApiOperation("账单列表")
    @PostMapping("/bill/page")
    public ApiResponse<PageData<YwContractBill>> billPage(
            @RequestBody PageWrap<CustomerBillQueryDTO> pageWrap,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.billPage(pageWrap, user.getCustomerId()));
    }

    @ApiOperation("账单详情")
    @GetMapping("/bill/{id}")
    public ApiResponse<Map<String, Object>> billDetail(
            @PathVariable("id") Integer id,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerH5BizService.billDetail(id, user.getCustomerId()));
    }

    @ApiOperation("创建支付订单")
    @PostMapping("/pay/createOrder")
    public ApiResponse<Map<String, String>> createOrder(
            @RequestBody CustomerPayCreateDTO dto,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token,
            HttpServletRequest request) {
        LoginUserInfo user = requireCustomerUser(token);
        String ip = request.getHeader("X-Forwarded-For");
        if (ip != null && ip.contains(",")) {
            ip = ip.split(",")[0].trim();
        }
        if (ip == null) {
            ip = request.getRemoteAddr();
        }
        return ApiResponse.success(ywCustomerWxPayService.createOrder(dto, user, ip));
    }

    @ApiOperation("查询支付结果")
    @GetMapping("/pay/query/{orderNo}")
    public ApiResponse<YwWxPayOrder> queryPay(
            @PathVariable String orderNo,
            @RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        LoginUserInfo user = requireCustomerUser(token);
        return ApiResponse.success(ywCustomerWxPayService.queryOrder(orderNo, user.getCustomerId()));
    }

    @ApiOperation("微信支付回调")
    @PostMapping("/pay/notify")
    @LoginNoRequired
    public String payNotify(@RequestBody String xmlBody) {
        return ywCustomerWxPayService.handleNotify(xmlBody);
    }
}