package com.java110.fee.cmd.fee;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.factory.Java110TransactionalFactory;
import com.java110.core.log.LoggerFactory;
import com.java110.core.smo.IComputeFeeSMO;
import com.java110.dto.account.AccountDto;
import com.java110.dto.fee.*;
import com.java110.dto.owner.OwnerCarDto;
import com.java110.dto.parking.ParkingSpaceDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.repair.RepairUserDto;
import com.java110.dto.user.UserDto;
import com.java110.fee.bmo.fee.IFinishFeeNotify;
import com.java110.intf.acct.IAccountInnerServiceSMO;
import com.java110.intf.community.*;
import com.java110.intf.fee.*;
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.po.car.OwnerCarPo;
import com.java110.po.fee.PayFeeDetailPo;
import com.java110.po.fee.PayFeePo;
import com.java110.po.owner.RepairPoolPo;
import com.java110.po.owner.RepairUserPo;
import com.java110.utils.cache.CommonCache;
import com.java110.utils.constant.FeeFlagTypeConstant;
import com.java110.utils.constant.FeeConfigConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.utils.lock.DistributedLock;
import com.java110.utils.util.*;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;

import java.math.BigDecimal;
import java.text.ParseException;
import java.util.*;

@Java110Cmd(serviceCode = "fee.payBatchFee")
public class PayBatchFeeCmd extends Cmd {

    private static Logger logger = LoggerFactory.getLogger(PayBatchFeeCmd.class);


    @Autowired
    private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
    @Autowired
    private IPayFeeV1InnerServiceSMO payFeeV1InnerServiceSMOImpl;
    @Autowired
    private IPayFeeDetailV1InnerServiceSMO payFeeDetailNewV1InnerServiceSMOImpl;

    @Autowired
    private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl;

    @Autowired
    private IComputeFeeSMO computeFeeSMOImpl;

    @Autowired
    private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;

    @Autowired
    private IFeeReceiptInnerServiceSMO feeReceiptInnerServiceSMOImpl;

    @Autowired
    private IFinishFeeNotify finishFeeNotifyImpl;

    @Autowired
    private IAccountInnerServiceSMO accountInnerServiceSMOImpl;


    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
        Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId节点");

        if (!reqJson.containsKey("fees")) {
            throw new CmdException("未包含费用");
        }

        JSONArray fees = reqJson.getJSONArray("fees");

        if (ListUtil.isNull(fees)) {
            throw new CmdException("未包含费用");
        }

        //todo 查询用户信息
        String userId = cmdDataFlowContext.getReqHeaders().get("user-id");
        UserDto userDto = new UserDto();
        userDto.setUserId(userId);
        List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
        Assert.listOnlyOne(userDtos, "用户未登录");


        JSONObject paramInObj = null;
        List<PayFeeDataDto> feeDataDtos = new ArrayList<>();
        PayFeeDataDto payFeeDataDto = null;
        for (int feeIndex = 0; feeIndex < fees.size(); feeIndex++) {
            paramInObj = fees.getJSONObject(feeIndex);
            Assert.hasKeyAndValue(paramInObj, "feeId", "未包含费用ID");
            Assert.hasKeyAndValue(paramInObj, "tempCycle", "未包含缴费周期类型");
            Assert.hasKeyAndValue(paramInObj, "primeRate", "未包含缴费缴费方式");
            Assert.hasKeyAndValue(paramInObj, "receivedAmount", "未包含实收金额");
            //todo 判断是否 费用状态为缴费结束
            FeeDto feeDto = new FeeDto();
            feeDto.setFeeId(paramInObj.getString("feeId"));
            feeDto.setCommunityId(reqJson.getString("communityId"));
            List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
            Assert.listOnlyOne(feeDtos, "传入费用ID错误");
            if (FeeDto.STATE_FINISH.equals(feeDtos.get(0).getState())) {
                throw new IllegalArgumentException("收费已经结束，不能再缴费");
            }
            Date endTime = feeDtos.get(0).getEndTime();
            FeeConfigDto feeConfigDto = new FeeConfigDto();
            feeConfigDto.setConfigId(feeDtos.get(0).getConfigId());
            feeConfigDto.setCommunityId(paramInObj.getString("communityId"));
            List<FeeConfigDto> feeConfigDtos = feeConfigInnerServiceSMOImpl.queryFeeConfigs(feeConfigDto);
            if (ListUtil.isNull(feeConfigDtos)) {
                throw new IllegalArgumentException("费用项不存在");
            }
            Date maxEndTime = feeDtos.get(0).getDeadlineTime();
            //周期性费用
            if (maxEndTime == null) {
                maxEndTime = DateUtil.getDateFromStringA(feeConfigDtos.get(0).getEndTime());
            }

            if (maxEndTime != null && endTime != null && !FeeDto.FEE_FLAG_ONCE.equals(feeDtos.get(0).getFeeFlag())) {
                Date newDate = DateUtil.stepMonth(endTime, paramInObj.getDouble("cycles").intValue());
                if (newDate.getTime() > maxEndTime.getTime()) {
                    throw new CmdException(feeConfigDtos.get(0).getFeeName() + "缴费周期超过 缴费结束时间,请用按结束时间方式缴费");
                }
            }
            //todo 封装数据
            payFeeDataDto = new PayFeeDataDto();
            payFeeDataDto.setFeeDto(feeDtos.get(0));
            payFeeDataDto.setFeeConfigDto(feeConfigDtos.get(0));
            payFeeDataDto.setCommunityId(reqJson.getString("communityId"));
            payFeeDataDto.setTempCycle(paramInObj.getString("tempCycle"));
            payFeeDataDto.setCustEndTime(paramInObj.getString("custEndTime"));
            payFeeDataDto.setPrimeRate(paramInObj.getString("primeRate"));
            payFeeDataDto.setRemark(paramInObj.getString("remark"));
            payFeeDataDto.setReceivedAmount(paramInObj.getString("receivedAmount"));
            payFeeDataDto.setCashierId(userDtos.get(0).getUserId());
            payFeeDataDto.setCashierName(userDtos.get(0).getName());
            payFeeDataDto.setFeeId(paramInObj.getString("feeId"));
            payFeeDataDto.setCycles(paramInObj.getString("cycles"));
            feeDataDtos.add(payFeeDataDto);
        }

        //todo 账户抵扣
        ifHasAccount(reqJson, feeDataDtos);

        reqJson.put("feeDataDtos", feeDataDtos);


    }


    @Override
    @Java110Transactional
    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {

        //todo 封装好的参数
        List<PayFeeDataDto> feeDataDtos = (List<PayFeeDataDto>) reqJson.get("feeDataDtos");
        String communityId = reqJson.getString("communityId");
        String payOrderId = reqJson.getString("payOrderId");

        //todo 生成收据编号
        String receiptCode = feeReceiptInnerServiceSMOImpl.generatorReceiptCode(communityId);
        JSONArray details = new JSONArray();
        //获取订单ID
        String oId = Java110TransactionalFactory.getOId();

        for (PayFeeDataDto payFeeDataDto : feeDataDtos) {
            payFeeDataDto.setDetailId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_detailId));
            payFeeDataDto.setPayOrderId(oId);
            // todo 如果 扫码枪支付 输入支付订单ID
            if (!StringUtil.isEmpty(payOrderId)) {
                payFeeDataDto.setPayOrderId(payOrderId);
            }

            String requestId = DistributedLock.getLockUUID();
            String key = this.getClass().getSimpleName() + payFeeDataDto.getFeeId();
            DistributedLock.waitGetDistributedLock(key, requestId);
            try {
                doPayFee(payFeeDataDto, receiptCode);
            } finally {
                DistributedLock.releaseDistributedLock(key, requestId);
            }
            details.add(payFeeDataDto.getDetailId());
        }

        JSONObject data = new JSONObject();
        data.put("details", details);

        cmdDataFlowContext.setResponseEntity(ResultVo.createResponseEntity(data));
    }

    private void doPayFee(PayFeeDataDto payFeeDataDto, String receiptCode) {


        PayFeeDetailPo payFeeDetailPo = payFeeDataDto;
        payFeeDetailPo.setOpenInvoice("N");
        payFeeDetailPo.setState(FeeDetailDto.STATE_NORMAL);
        payFeeDetailPo.setStartTime(DateUtil.getFormatTimeStringA(payFeeDataDto.getFeeDto().getEndTime()));

        //todo 计算 结束时间 应收  缴费周期
        /**
         *         payFeeDetailPo.setCycles(cycles.doubleValue() + "");
         *         payFeeDetailPo.setEndTime(DateUtil.getFormatTimeStringA(targetEndTime));
         *         payFeeDetailPo.setReceivableAmount(receivableAmount);
         *         payFeeDetailPo.setPayableAmount(receivableAmount);
         */
        computeEndTimeCycleAmount(payFeeDataDto, payFeeDetailPo);
        payFeeDetailPo.setAcctAmount(payFeeDataDto.getAccountAmount()+"");

        //todo 缓存收据编号
        CommonCache.setValue(payFeeDetailPo.getDetailId() + CommonCache.RECEIPT_CODE, receiptCode, CommonCache.DEFAULT_EXPIRETIME_TWO_MIN);
        int flag = payFeeDetailNewV1InnerServiceSMOImpl.savePayFeeDetailNew(payFeeDetailPo);
        if (flag < 1) {
            throw new CmdException("缴费失败");
        }

        PayFeePo payFeePo = new PayFeePo();
        payFeePo.setFeeId(payFeeDataDto.getFeeId());
        payFeePo.setEndTime(DateUtil.getNextSecTime(payFeeDetailPo.getEndTime()));
        payFeePo.setState(FeeDto.STATE_FINISH);

        Date maxTime = payFeeDataDto.getFeeDto().getDeadlineTime();

        if (maxTime == null) {
            maxTime = DateUtil.getDateFromStringA(payFeeDataDto.getFeeConfigDto().getEndTime());
        }
        //todo 不是一次性费用
        if (!FeeDto.FEE_FLAG_ONCE.equals(payFeeDataDto.getFeeDto().getFeeFlag()) && maxTime != null) {
            Calendar calendar = Calendar.getInstance();
            calendar.setTime(maxTime);
            calendar.add(Calendar.DAY_OF_MONTH, -5);
            maxTime = calendar.getTime();
            if (maxTime.after(DateUtil.getDateFromStringA(payFeeDetailPo.getEndTime()))) {
                payFeePo.setState(FeeDto.STATE_DOING);
            }
        }

        flag = payFeeV1InnerServiceSMOImpl.updatePayFee(payFeePo);
        if (flag < 1) {
            throw new CmdException("缴费失败");
        }

        //todo 账户扣款
        finishFeeNotifyImpl.withholdAccount(payFeeDataDto, payFeeDataDto.getFeeId(), payFeeDataDto.getCommunityId());

        //todo 修改车辆
        finishFeeNotifyImpl.updateCarEndTime(payFeeDataDto.getFeeId(), payFeeDataDto.getCommunityId());


        //todo 修改报修单
        finishFeeNotifyImpl.updateRepair(payFeeDataDto.getFeeId(), payFeeDataDto.getCommunityId(), payFeeDetailPo.getReceivedAmount());

        //todo 租金延期房屋结束时间
        finishFeeNotifyImpl.updateRoomEndTime(payFeeDataDto.getFeeId(), payFeeDataDto.getCommunityId());
    }

    /**
     * 计算 结束时间 缴费周期 金额
     * payFeeDetailPo.setCycles(cycles.doubleValue() + "");
     * payFeeDetailPo.setEndTime(DateUtil.getFormatTimeStringA(targetEndTime));
     * payFeeDetailPo.setReceivableAmount(receivableAmount);
     *
     * @param payFeeDataDto
     * @param payFeeDetailPo
     */
    private void computeEndTimeCycleAmount(PayFeeDataDto payFeeDataDto, PayFeeDetailPo payFeeDetailPo) {
        Date targetEndTime = null;
        BigDecimal cycles = null;
        String receivableAmount = "";
        Map feePriceAll = computeFeeSMOImpl.getFeePrice(payFeeDataDto.getFeeDto());
        BigDecimal feePrice = new BigDecimal(feePriceAll.get("feePrice").toString());
        if (PayFeeDataDto.TEMP_CYCLE_CUSTOM_AMOUNT.equals(payFeeDataDto.getTempCycle())) { //todo  自定义金额交费
            Date endTime = payFeeDataDto.getFeeDto().getEndTime();
            Calendar endCalender = Calendar.getInstance();
            endCalender.setTime(endTime);
            BigDecimal receivedAmount = new BigDecimal(Double.parseDouble(payFeeDataDto.getReceivedAmount()));
            //todo 考虑账户金额
            if (payFeeDataDto.getAccountAmount() > 0) {
                receivedAmount = receivedAmount.add(new BigDecimal(payFeeDataDto.getAccountAmount()));
            }
            cycles = receivedAmount.divide(feePrice, 4, BigDecimal.ROUND_HALF_EVEN);
            targetEndTime = computeFeeSMOImpl.getTargetEndTime(cycles.doubleValue(), endCalender.getTime(),true);
            receivableAmount = payFeeDataDto.getReceivedAmount();
            //处理 可能还存在 实收手工减免的情况
        } else if (PayFeeDataDto.TEMP_CYCLE_CUSTOM_END_TIME.equals(payFeeDataDto.getTempCycle())) { //todo 这里按缴费结束时间缴费
            String custEndTime = payFeeDataDto.getCustEndTime();
            if (!custEndTime.contains(":")) {
                custEndTime += " 23:59:59";
            }
            targetEndTime = DateUtil.getDateFromStringA(custEndTime);
            BigDecimal receivedAmount1 = new BigDecimal(Double.parseDouble(payFeeDataDto.getReceivedAmount()));
            cycles = receivedAmount1.divide(feePrice, 4, BigDecimal.ROUND_HALF_EVEN);
            receivableAmount = payFeeDataDto.getReceivedAmount();

        } else { //自定义周期
            targetEndTime = computeFeeSMOImpl.getFeeEndTimeByCycles(payFeeDataDto.getFeeDto(), payFeeDataDto.getCycles());//根据缴费周期计算 结束时间
            cycles = new BigDecimal(Double.parseDouble(payFeeDataDto.getCycles()));
            double tmpReceivableAmount = cycles.multiply(feePrice).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
            receivableAmount = tmpReceivableAmount + "";
            //出租递增问题处理
            if (FeeConfigDto.COMPUTING_FORMULA_RANT_RATE.equals(payFeeDataDto.getFeeDto().getComputingFormula())) {
                computeFeeSMOImpl.dealRentRateCycle(payFeeDataDto.getFeeDto(), cycles.doubleValue());
                if (payFeeDataDto.getFeeDto().getOweFee() > 0) {
                    receivableAmount = payFeeDataDto.getFeeDto().getAmountOwed();

                }
            }
        }

        payFeeDetailPo.setCycles(cycles.doubleValue() + "");
        payFeeDetailPo.setEndTime(DateUtil.getFormatTimeStringA(targetEndTime));
        payFeeDetailPo.setReceivableAmount(receivableAmount);
        payFeeDetailPo.setPayableAmount(receivableAmount);

    }


    private void ifHasAccount(JSONObject reqJson, List<PayFeeDataDto> feeDataDtos) {
        if (!reqJson.containsKey("accountAmount")) {
            return;
        }
        double accountAmount = reqJson.getDouble("accountAmount");
        if (accountAmount <= 0) {
            return;
        }

        Assert.hasKeyAndValue(reqJson, "acctId", "未包含账户ID");
        String acctId = reqJson.getString("acctId");
        //todo 校验账户金额是否充足
        AccountDto accountDto = new AccountDto();
        accountDto.setAcctId(acctId);
        List<AccountDto> accountDtos = accountInnerServiceSMOImpl.queryAccounts(accountDto);

        Assert.listOnlyOne(accountDtos, "账户不存在");

        if (Double.parseDouble(accountDtos.get(0).getAmount()) < accountAmount) {
            throw new CmdException("账户余额不足");
        }

        BigDecimal accountAmountDec = null;
        double receivedAmount = 0.0;
        BigDecimal receivedAmountDec = null;
        for (PayFeeDataDto payFeeDataDto : feeDataDtos) {
            if (accountAmount == 0) {
                continue;
            }
            accountAmountDec = new BigDecimal(accountAmount);
            receivedAmount = Double.parseDouble(payFeeDataDto.getReceivedAmount());
            receivedAmountDec = new BigDecimal(receivedAmount);
            if (receivedAmount >= accountAmount) {
                receivedAmountDec = receivedAmountDec.subtract(accountAmountDec).setScale(2, BigDecimal.ROUND_HALF_UP);
                payFeeDataDto.setReceivedAmount(receivedAmountDec.doubleValue() + "");
                payFeeDataDto.setAccountAmount(accountAmount);
                payFeeDataDto.setAcctId(acctId);
                accountAmount = 0.00;
                continue;
            }

            payFeeDataDto.setReceivedAmount("0");
            payFeeDataDto.setAccountAmount(receivedAmount);
            payFeeDataDto.setAcctId(acctId);

            accountAmountDec = accountAmountDec.subtract(receivedAmountDec).setScale(2, BigDecimal.ROUND_HALF_UP);
            accountAmount = accountAmountDec.doubleValue();
        }


    }
}