package com.doumee.api.business;

import com.alibaba.fastjson.JSON;
import com.doumee.api.BaseController;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.constants.Constants;
import com.doumee.core.douyin.DouyinClient;
import com.doumee.core.douyin.dto.DouyinBaseResp;
import com.doumee.core.douyin.dto.DouyinCancelParam;
import com.doumee.core.douyin.dto.DouyinShopPoiResp;
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.ID;
import com.doumee.dao.business.model.DouyinVerifyLog;
import com.doumee.dao.business.model.DouyinVerifyRecord;
import com.doumee.dao.business.vo.DouyinVerifyRecordPageVO;
import com.doumee.service.business.DouyinVerifyLogService;
import com.doumee.service.business.DouyinVerifyService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 抖音券核销(管理端):核销记录对外分页 + 撤销核销。
 * <p>撤销核销由 web 端(/web/douyin/cancel)迁移至此,鉴权由 JWT 改为 Shiro;
 * 管理端为运营补救场景,不受「核销后1小时内」限制。每次撤销落 douyin_verify_log 审计。
 *
 * @author rk
 * @date 2026/06/26
 */
@Slf4j
@Api(tags = "抖音券核销")
@RestController
@RequestMapping("/business/douyinVerify")
public class DouyinVerifyController extends BaseController {

    @Autowired
    private DouyinVerifyService douyinVerifyService;
    @Autowired
    private DouyinVerifyLogService douyinVerifyLogService;
    /** 抖音 HTTP 客户端:门店列表查询为无状态透传,直接调抖音,不经 Service */
    @Autowired
    private DouyinClient douyinClient;

    @ApiOperation("核销记录分页(对外)")
    @PostMapping("/page")
    @RequiresPermissions("business:douyinVerify:query")
    public ApiResponse<PageData<DouyinVerifyRecordPageVO>> findPage(@RequestBody PageWrap<DouyinVerifyRecordPageVO> pageWrap) {
        return ApiResponse.success(douyinVerifyService.findManagePage(pageWrap));
    }

    @ApiOperation("查询抖音商户下门店(用于选核销门店;account_id 从字典读取)")
    @PostMapping("/poiList")
    @RequiresPermissions("business:douyinVerify:query")
    public ApiResponse<List<String>> poiList() {
        // 门店查询为无状态透传(无落库),Controller → DouyinClient 直连;account_id 由 Client 从字典读取
        DouyinBaseResp<DouyinShopPoiResp> resp = douyinClient.shopPoiQuery();
        List<DouyinShopPoiResp.Poi> pois = resp == null || resp.getData() == null ? null : resp.getData().getPois();
        if (pois == null || pois.isEmpty()) {
            return ApiResponse.success(Collections.emptyList());
        }
        // 仅提取门店ID,过滤 poi 节点或 poiId 为空的条目
        List<String> poiIds = pois.stream()
                .filter(p -> p != null && p.getPoi() != null && StringUtils.isNotBlank(p.getPoi().getPoiId()))
                .map(p -> p.getPoi().getPoiId())
                .collect(Collectors.toList());
        return ApiResponse.success(poiIds);
    }

    @PreventRepeat
    @ApiOperation("撤销核销(管理端,不受1小时限制;成功后作废本地套餐卡)")
    @PostMapping("/cancel")
    @RequiresPermissions("business:douyinVerify:cancel")
    public ApiResponse<DouyinVerifyRecord> cancel(@RequestBody DouyinCancelParam param, HttpServletRequest request) {
        long start = System.currentTimeMillis();
        DouyinVerifyLog opLog = baseLog(Constants.DOUYIN_VERIFY_OPERATE_TYPE.CANCEL.getKey(), "/business/douyinVerify/cancel", start, request);
        opLog.setRawRequest(JSON.toJSONString(param));
        try {
            // 操作人取 Shiro 登录用户 id(管理端管理员,非会员)
            LoginUserInfo loginUser = getLoginUser();
            String operator = loginUser == null ? null : loginUser.getId();
            DouyinVerifyRecord rec = douyinVerifyService.cancel(param, operator);
            fillByRecord(opLog, rec);
            return ApiResponse.success(rec);
        } catch (Throwable e) {
            opLog.setResult(Constants.DOUYIN_VERIFY_LOG_RESULT.FAIL.getKey());
            opLog.setErrorMsg(e.getMessage());
            throw e;
        } finally {
            saveLog(opLog);
        }
    }

    // ---------------- 撤销操作日志辅助 ----------------

    /** 构造一条撤销操作日志骨架(主键/类型/路径/IP/耗时/时间) */
    private DouyinVerifyLog baseLog(int operateType, String apiPath, long start, HttpServletRequest request) {
        DouyinVerifyLog l = new DouyinVerifyLog();
        l.setId(ID.nextGUID());
        l.setOperateType(operateType);
        l.setApiPath(apiPath);
        // 管理端操作非会员,memberId 留空
        l.setIp(request.getRemoteAddr());
        l.setCostMs((int) (System.currentTimeMillis() - start));
        l.setCreateDate(new Date());
        l.setIsdeleted(Constants.ZERO);
        return l;
    }

    /** 撤销成功后,用核销记录回填日志的业务字段与结果 */
    private void fillByRecord(DouyinVerifyLog opLog, DouyinVerifyRecord rec) {
        if (rec == null) {
            opLog.setResult(Constants.DOUYIN_VERIFY_LOG_RESULT.FAIL.getKey());
            return;
        }
        opLog.setVerifyRecordId(rec.getId());
        opLog.setOriginCode(rec.getOriginCode());
        if (StringUtils.isNotBlank(rec.getPoiId())) {
            opLog.setPoiId(rec.getPoiId());
        }
        opLog.setRawResponse(rec.getRawResponse());
        opLog.setResult(Constants.equalsInteger(rec.getCancelStatus(), Constants.DOUYIN_VERIFY_CANCEL_STATUS.DONE.getKey()) ? Constants.DOUYIN_VERIFY_LOG_RESULT.SUCCESS.getKey() : Constants.DOUYIN_VERIFY_LOG_RESULT.FAIL.getKey());
        opLog.setErrorMsg(rec.getCancelMsg());
    }

    /** 落库操作日志;日志自身异常不抛出,避免影响主流程 */
    private void saveLog(DouyinVerifyLog opLog) {
        try {
            douyinVerifyLogService.record(opLog);
        } catch (Exception e) {
            log.warn("记录抖音撤销操作日志失败 type={}, recordId={}", opLog.getOperateType(), opLog.getVerifyRecordId(), e);
        }
    }
}