package com.ruoyi.user.service.impl;

import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.ruoyi.common.core.exception.ServiceException;
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.security.utils.SecurityUtils;
import com.ruoyi.user.domain.AccountCertification;
import com.ruoyi.user.domain.AccountCertificationApply;
import com.ruoyi.user.domain.AccountUser;
import com.ruoyi.user.domain.vo.AccountCertificationApplyDetailVo;
import com.ruoyi.user.domain.vo.AccountCertificationApplyVo;
import com.ruoyi.user.mapper.AccountCertificationApplyMapper;
import com.ruoyi.user.mapper.AccountCertificationMapper;
import com.ruoyi.user.mapper.AccountUserMapper;
import com.ruoyi.user.service.IAccountCertificationApplyService;

/**
 * 会员主体认证申请 业务层实现
 *
 * @author ruoyi
 */
@Service
public class AccountCertificationApplyServiceImpl implements IAccountCertificationApplyService
{
    /** 审核结果：通过 */
    private static final String AUDIT_PASS = "1";

    /** 审核结果：驳回 */
    private static final String AUDIT_REJECT = "2";

    /** account_user.auth_status：已认证 */
    private static final String AUTH_VERIFIED = "2";

    /** account_user.auth_status：认证失败 */
    private static final String AUTH_FAILED = "3";

    @Autowired
    private AccountCertificationApplyMapper certificationApplyMapper;

    @Autowired
    private AccountCertificationMapper certificationMapper;

    @Autowired
    private AccountUserMapper accountUserMapper;

    @Override
    public List<AccountCertificationApplyVo> selectCertificationApplyList(AccountCertificationApplyVo apply)
    {
        return certificationApplyMapper.selectCertificationApplyList(apply);
    }

    @Override
    public AccountCertificationApplyDetailVo selectCertificationApplyDetail(Long id)
    {
        AccountCertificationApply apply = certificationApplyMapper.selectCertificationApplyById(id);
        if (StringUtils.isNull(apply))
        {
            return null;
        }
        AccountCertificationApplyDetailVo detail = new AccountCertificationApplyDetailVo();
        detail.setApply(apply);
        // 用户信息/关系取 account_user 的实时值而非申请快照：审核要看会员当下的系统等级与
        // 推荐/供货关系，这两项申请快照里根本没有。
        detail.setUser(accountUserMapper.selectAccountUserVoById(apply.getUserId()));
        return detail;
    }

    @Override
    @Transactional
    public int auditCertificationApply(Long id, String auditStatus, String auditRemark)
    {
        boolean pass = AUDIT_PASS.equals(auditStatus);
        if (!pass && !AUDIT_REJECT.equals(auditStatus))
        {
            throw new ServiceException("审核结果只能是「通过」或「驳回」");
        }
        // 驳回不写原因，会员端只看到「认证失败」无从修改，等于把人卡死
        if (!pass && StringUtils.isEmpty(auditRemark))
        {
            throw new ServiceException("驳回时必须填写审核意见");
        }
        AccountCertificationApply apply = certificationApplyMapper.selectCertificationApplyById(id);
        if (StringUtils.isNull(apply))
        {
            throw new ServiceException("认证申请不存在");
        }

        String operator = SecurityUtils.getUsername();
        AccountCertificationApply update = new AccountCertificationApply();
        update.setId(id);
        update.setAuditStatus(auditStatus);
        update.setAuditBy(operator);
        update.setAuditRemark(auditRemark);
        update.setUpdateBy(operator);
        // 更新条件带 audit_status='0'，重复审核（或两人同时点）会更新 0 行，据此抛异常回滚，
        // 避免下面几步用陈旧状态把 auth_status 改错。
        if (certificationApplyMapper.auditCertificationApply(update) == 0)
        {
            throw new ServiceException("该申请已审核，不能重复处理");
        }

        // 同步到 account_user.auth_status：会员列表的「认证状态」列取的就是它
        AccountUser user = new AccountUser();
        user.setUserId(apply.getUserId());
        user.setAuthStatus(pass ? AUTH_VERIFIED : AUTH_FAILED);
        user.setUpdateBy(operator);
        accountUserMapper.updateUserAuthStatus(user);

        if (pass)
        {
            saveCertificationSnapshot(apply, operator);
        }
        return 1;
    }

    /**
     * 审核通过后，把申请快照落成 account_certification 的当前有效资料
     *
     * 详情页「主体资料」读的是 account_certification，不落这一步会出现
     * "审核已通过但详情页主体资料仍为空"的割裂。
     */
    private void saveCertificationSnapshot(AccountCertificationApply apply, String operator)
    {
        AccountCertification old = certificationMapper.selectCertificationByUserId(apply.getUserId());
        if (StringUtils.isNotNull(old))
        {
            // 旧行逻辑删除后新插一行，而不是原地 update：updateCertification 的 <if> 会跳过
            // 空值列，个人主体的企业字段（company_name 等为 null）会残留上一份企业资料的值。
            // 表上刻意没建 UNIQUE(user_id)，本就允许留历史行。
            certificationMapper.deleteCertificationByIds(new Long[] { old.getId() });
        }
        AccountCertification certification = new AccountCertification();
        certification.setUserId(apply.getUserId());
        certification.setRealName(apply.getRealName());
        certification.setIdCard(apply.getIdCard());
        certification.setCompanyName(apply.getCompanyName());
        certification.setCreditCode(apply.getCreditCode());
        certification.setLegalPerson(apply.getLegalPerson());
        certification.setRegisteredRegion(apply.getRegisteredRegion());
        certification.setCompanyAddress(apply.getCompanyAddress());
        certification.setRegisterDate(apply.getRegisterDate());
        certification.setLicenseValidPeriod(apply.getLicenseValidPeriod());
        certification.setLicenseImage(apply.getLicenseImage());
        certification.setCreateBy(operator);
        certification.setRemark("由认证申请（申请号 " + apply.getId() + "）审核通过生成");
        certificationMapper.insertCertification(certification);
    }
}