package com.by4cloud.platformx.business.service.impl;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ArrayUtil;
import cn.hutool.core.util.ObjUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.by4cloud.platformx.business.dto.MeterReadRecordUpdateDTO;
import com.by4cloud.platformx.business.entity.*;
import com.by4cloud.platformx.business.mapper.*;
import com.by4cloud.platformx.business.service.MeterReadRecordService;
import com.by4cloud.platformx.common.core.util.R;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.List;

/**
 * 水电抄表
 *
 * @author syt
 * @date 2026-05-27 13:58:57
 */
@Service
@RequiredArgsConstructor
public class MeterReadRecordServiceImpl extends ServiceImpl<MeterReadRecordMapper, MeterReadRecord> implements MeterReadRecordService {

	private final ContractMapper contractMapper;
	private final ContractSubjectMatterMapper contractSubjectMatterMapper;
	private final ContractPaymentScheduleMapper contractPaymentScheduleMapper;
	private final PaymentConfirmMapper paymentConfirmMapper;
	private final ContractExecDateMapper contractExecDateMapper;

	@Override
	public R edit(MeterReadRecordUpdateDTO updateDTO) {
		MeterReadRecord record = baseMapper.selectById(updateDTO.getId());
		MeterReadRecord lastRecord = baseMapper.selectOne(Wrappers.<MeterReadRecord>lambdaQuery().eq(MeterReadRecord::getContractId,updateDTO.getContractId())
				.eq(MeterReadRecord::getMeterReadCode,updateDTO.getMeterReadCode()).lt(MeterReadRecord::getCreateTime,record.getCreateTime())
				.orderByDesc(MeterReadRecord::getCreateTime).last("limit 1"));
		//房屋租赁生成应收
		Contract contract = contractMapper.selectById(updateDTO.getContractId());
		ContractSubjectMatter subjectMatter = contractSubjectMatterMapper.selectById(updateDTO.getMatterId());
		if(ObjUtil.isNull(lastRecord)){
			R.failed("无合同信息，请联系技术人员");
		}
		if(ObjUtil.isNull(lastRecord)){
			return R.failed("无最近抄表记录");
		}
		if (updateDTO.getMeterReadNum().compareTo(lastRecord.getMeterReadNum())<=0){
			return R.failed("抄表数字不能比上次少");
		}
		record.setMeterReadTime(updateDTO.getMeterReadTime());
		record.setMeterReadNum(updateDTO.getMeterReadNum());
		record.setUsageNum(updateDTO.getMeterReadNum().subtract(lastRecord.getMeterReadNum()));
		record.setMeterReadAttNames(updateDTO.getMeterReadAttNames());
		record.setMeterReadAttPaths(updateDTO.getMeterReadAttPaths());
		record.setUnitPrice(subjectMatter.getUnitPrice());
		if (subjectMatter.getMaterialCode().equals("water_bill")){
			record.setMeterType("2");
		}
		if (subjectMatter.getMaterialCode().equals("electricity_bill")){
			record.setMeterType("3");
		}
		if (subjectMatter.getMaterialCode().equals("house_rental")){
			record.setMeterType("1");
		}
		record.setCostAmount(subjectMatter.getUnitPrice().multiply(updateDTO.getMeterReadNum().subtract(lastRecord.getMeterReadNum())));
		baseMapper.updateById(record);

		//创建收款节点
		//查询上次收款节点
		ContractPaymentSchedule lastSchedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery()
				.eq(ContractPaymentSchedule::getContractId,contract.getId())
				.orderByDesc(ContractPaymentSchedule::getCreateTime).last("limit 1"));
		ContractPaymentSchedule schedule = new ContractPaymentSchedule();

		if (subjectMatter.getMaterialCode().equals("water_bill")){
			schedule.setStageName("水费代缴");
		}
		if (subjectMatter.getMaterialCode().equals("electricity_bill")){
			schedule.setStageName("电费代缴");
		}
		if (subjectMatter.getMaterialCode().equals("house_rental")){
			schedule.setStageName("房屋租赁费");
		}
		schedule.setContractId(contract.getId());
		schedule.setContractName(contract.getContractName());
		schedule.setPlannedAmount(record.getCostAmount());
		schedule.setSubjectMatterCode(subjectMatter.getMaterialCode());
		schedule.setSubjectMatterName(subjectMatter.getMaterialInternalName());
		schedule.setRemark(DateUtil.formatDate(record.getMeterReadTime())+schedule.getStageName());
		schedule.setEffectiveEndDate(updateDTO.getMeterReadTime());
		schedule.setStageOrder(1);
		if (ObjUtil.isNotNull(lastSchedule)){
			schedule.setStageOrder(lastSchedule.getStageOrder()+1);
		}
		schedule.setPaymentStatus(0);
		schedule.setActualAmount(new BigDecimal("0"));
		schedule.setInvoiceFlag("0");
		contractPaymentScheduleMapper.insert(schedule);
		//房屋租赁生成应收
		PaymentConfirm confirm = new PaymentConfirm();
		confirm.setBusinessType(subjectMatter.getMaterialInternalName()+"应收");
		confirm.setBusGuestId(contract.getPartyAId());
		confirm.setBusGuestName(contract.getPartyA());
		confirm.setContractId(contract.getId());
		confirm.setContractName(contract.getContractName());
		confirm.setContractNo(contract.getContractNo());
		confirm.setConfirmTime(updateDTO.getMeterReadTime());
		confirm.setTransationAmount(subjectMatter.getUnitPrice().multiply(updateDTO.getMeterReadNum().subtract(lastRecord.getMeterReadNum())));
		confirm.setTotalAmount(confirm.getTransationAmount().multiply(new BigDecimal("-1")));
		PaymentConfirm lastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
				.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
		if (ObjUtil.isNotNull(lastConfirm)) {
			BigDecimal total = lastConfirm.getTotalAmount().add(confirm.getTotalAmount());
			if (total.compareTo(new BigDecimal("0")) > 0) {
				confirm.setAdvanceAmount(total);
				confirm.setTotalAmount(total);
			} else if (total.compareTo(new BigDecimal("0")) == 0) {
				confirm.setTotalAmount(total);
			} else {
				confirm.setReceivableAmount(total.multiply(new BigDecimal("-1")));
				confirm.setTotalAmount(total);
			}
			confirm.setCompId(contract.getCompId());
			paymentConfirmMapper.insert(confirm);
		} else {
			confirm.setReceivableAmount(confirm.getTransationAmount());
			confirm.setTotalAmount(confirm.getReceivableAmount().multiply(new BigDecimal("-1")));
			confirm.setCompId(contract.getCompId());
			paymentConfirmMapper.insert(confirm);
		}
		//判断 循环是否完成
		List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery().eq(ContractExecDate::getContractId,contract.getId())
				.eq(ContractExecDate::getGenFlag,"0"));
		List<MeterReadRecord> recordList = baseMapper.selectList(Wrappers.<MeterReadRecord>lambdaQuery()
				.eq(MeterReadRecord::getContractId,contract.getId())
				.isNull(MeterReadRecord::getMeterReadNum));
		if (ArrayUtil.isEmpty(execDateList.toArray())&&ArrayUtil.isEmpty(recordList.toArray())){
			List<PaymentConfirm> confirmList = paymentConfirmMapper.selectList(Wrappers.<PaymentConfirm>lambdaQuery()
					.eq(PaymentConfirm::getContractId, contract.getId())
					.and(wrapper -> wrapper
							.eq(PaymentConfirm::getBusinessType, "房屋租赁应收")
							.or()
							.eq(PaymentConfirm::getBusinessType, "售电应收")
							.or()
							.eq(PaymentConfirm::getBusinessType, "不征税自来水应收")
					));
			if (ArrayUtil.isNotEmpty(confirmList.toArray())){
				BigDecimal total = confirmList.stream().map(PaymentConfirm::getTransationAmount).filter(amount -> amount != null).reduce(BigDecimal.ZERO, BigDecimal::add);
				contract.setAmount(total);
				contractMapper.updateById(contract);
			}
		}
		contract.setBillingStatus("2");
		contractMapper.updateById(contract);
		return R.ok();
	}
}