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

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;

/**
 * 水电抄表
 *
 * @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;

	@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"));
		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.setMeterReadAttNames(updateDTO.getMeterReadAttNames());
		record.setMeterReadAttPaths(updateDTO.getMeterReadAttPaths());
		baseMapper.updateById(record);
		//房屋租赁生成应收
		Contract contract = contractMapper.selectById(updateDTO.getContractId());
		ContractSubjectMatter subjectMatter = contractSubjectMatterMapper.selectById(updateDTO.getMatterId());
		if(ObjUtil.isNull(lastRecord)){
			R.failed("无合同信息，请联系技术人员");
		}
		//创建收款节点
		//查询上次收款节点
		ContractPaymentSchedule lastSchedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery()
				.eq(ContractPaymentSchedule::getContractId,contract.getId())
				.orderByDesc(ContractPaymentSchedule::getCreateTime).last("limit 1"));
		ContractPaymentSchedule schedule = new ContractPaymentSchedule();
		schedule.setStageName("水电代缴");
		schedule.setContractId(contract.getId());
		schedule.setContractName(contract.getContractName());
		schedule.setPlannedAmount(subjectMatter.getUnitPrice().multiply(updateDTO.getMeterReadNum().subtract(lastRecord.getMeterReadNum())));
		schedule.setEffectiveEndDate(updateDTO.getMeterReadTime());
		schedule.setStageOrder(1);
		if (ObjUtil.isNotNull(lastSchedule)){
			schedule.setStageOrder(lastSchedule.getStageOrder()+1);
		}
		schedule.setPaymentStatus(0);
		schedule.setActualAmount(new BigDecimal("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);
		}
		return R.ok();
	}
}