package com.java110.fee.feeMonth;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.core.smo.IComputeFeeSMO;
|
import com.java110.dto.fee.FeeDetailDto;
|
import com.java110.dto.fee.FeeDto;
|
import com.java110.dto.payFeeDetailMonth.PayFeeDetailMonthDto;
|
import com.java110.dto.payFeeDetailMonth.PayFeeMonthOwnerDto;
|
import com.java110.intf.fee.IFeeDetailInnerServiceSMO;
|
import com.java110.intf.fee.IFeeInnerServiceSMO;
|
import com.java110.intf.fee.IPayFeeConfigV1InnerServiceSMO;
|
import com.java110.intf.fee.IPayFeeDetailMonthInnerServiceSMO;
|
import com.java110.po.payFeeDetailMonth.PayFeeDetailMonthPo;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.DateUtil;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 费用离散为月 实现类
|
*/
|
//@Service
|
public class PayFeeMonthImplV1 implements IPayFeeMonth {
|
private static Logger logger = LoggerFactory.getLogger(PayFeeMonthImplV1.class);
|
|
@Autowired
|
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
|
|
@Autowired
|
private IPayFeeConfigV1InnerServiceSMO payFeeConfigV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IPayFeeDetailMonthInnerServiceSMO payFeeDetailMonthInnerServiceSMOImpl;
|
|
@Autowired
|
private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl;
|
|
@Autowired
|
private IPayFeeMonthHelp payFeeMonthHelp;
|
|
@Autowired
|
private IComputeFeeSMO computeFeeSMOImpl;
|
|
public static final int DEFAULT_DEAL_COUNT = 200;
|
|
|
/**
|
* 生成单个费用 并 离散到月
|
*
|
* @param feeId
|
* @param communityId
|
*/
|
@Override
|
public void doGeneratorOrRefreshFeeMonth(String feeId, String communityId) {
|
|
// todo 查询费用
|
FeeDto feeDto = new FeeDto();
|
feeDto.setCommunityId(communityId);
|
feeDto.setFeeId(feeId);
|
List<FeeDto> tmpFeeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
|
Assert.listOnlyOne(tmpFeeDtos, "费用不存在");
|
|
doGeneratorOrRefreshFeeMonth(tmpFeeDtos.get(0), communityId);
|
}
|
|
public void doGeneratorOrRefreshFeeMonth(FeeDto feeDto, String communityId) {
|
|
|
//todo 计算每月单价
|
Double feePrice = payFeeMonthHelp.getMonthFeePrice(feeDto);
|
|
// todo 准备离散的基础数据
|
PayFeeMonthOwnerDto payFeeMonthOwnerDto = payFeeMonthHelp.generatorOwnerRoom(feeDto);
|
|
//todo 离散start_time 或者 pay_fee_detail_month 最大月份 到 deadlineTime 的数据
|
maxMonthDateToDeadlineTimeData(feeDto, payFeeMonthOwnerDto, feePrice);
|
|
|
}
|
|
/**
|
* 离散最大 离散月到 deadlineTime 的数据
|
*
|
* @param feeDto
|
* @param payFeeMonthOwnerDto
|
* @param feePrice
|
*/
|
private void maxMonthDateToDeadlineTimeData(FeeDto feeDto, PayFeeMonthOwnerDto payFeeMonthOwnerDto, Double feePrice) {
|
PayFeeDetailMonthDto payFeeDetailMonthDto = new PayFeeDetailMonthDto();
|
payFeeDetailMonthDto.setCommunityId(feeDto.getCommunityId());
|
payFeeDetailMonthDto.setFeeId(feeDto.getFeeId());
|
List<PayFeeDetailMonthDto> payFeeDetailMonthDtos = payFeeDetailMonthInnerServiceSMOImpl.queryPayFeeDetailMaxMonths(payFeeDetailMonthDto);
|
Date startTime = null;
|
Date deadlineTime = computeFeeSMOImpl.getDeadlineTime(feeDto);
|
if (payFeeDetailMonthDtos == null || payFeeDetailMonthDtos.size() < 1) {
|
startTime = feeDto.getStartTime();
|
} else {
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(DateUtil.getDateFromStringA(payFeeDetailMonthDtos.get(0).getCurMonthTime()));
|
calendar.add(Calendar.MONTH, 1);
|
startTime = calendar.getTime();
|
}
|
|
// todo 生成一段时间内的数据
|
doGeneratorTimeMonthData(feeDto, payFeeMonthOwnerDto, feePrice, startTime, deadlineTime);
|
|
}
|
|
private void doGeneratorTimeMonthData(FeeDto feeDto, PayFeeMonthOwnerDto payFeeMonthOwnerDto, Double feePrice, Date startTime, Date endTime) {
|
double maxMonth = Math.ceil(computeFeeSMOImpl.dayCompare(startTime, endTime));
|
|
if (maxMonth < 1) {
|
return;
|
}
|
//todo 查询 缴费明细
|
FeeDetailDto feeDetailDto = new FeeDetailDto();
|
feeDetailDto.setCommunityId(feeDto.getCommunityId());
|
feeDetailDto.setFeeId(feeDto.getFeeId());
|
feeDetailDto.setStates(new String[]{FeeDetailDto.STATE_NORMAL,FeeDetailDto.STATE_RETURNING});
|
List<FeeDetailDto> feeDetailDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto);
|
|
//todo 生成 月离散数据
|
PayFeeDetailMonthPo tmpPayFeeDetailMonthPo;
|
List<PayFeeDetailMonthPo> payFeeDetailMonthPos = new ArrayList<>();
|
double receivableAmount = 0.0;
|
for (int month = 0; month < maxMonth; month++) {
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(startTime);
|
calendar.add(Calendar.MONTH, month);
|
//calendar.set(Calendar.DAY_OF_MONTH, 1);
|
tmpPayFeeDetailMonthPo = new PayFeeDetailMonthPo();
|
tmpPayFeeDetailMonthPo.setFeeId(feeDto.getFeeId());
|
tmpPayFeeDetailMonthPo.setCommunityId(feeDto.getCommunityId());
|
tmpPayFeeDetailMonthPo.setDetailId(payFeeMonthHelp.getFeeDetailId(feeDetailDtos, calendar.getTime()));
|
tmpPayFeeDetailMonthPo.setDetailYear(calendar.get(Calendar.YEAR) + "");
|
tmpPayFeeDetailMonthPo.setDetailMonth((calendar.get(Calendar.MONTH) + 1) + "");
|
receivableAmount = payFeeMonthHelp.getReceivableAmount(feeDetailDtos, feePrice, calendar.getTime(), feeDto);
|
//todo 应收小于等于0 不统计
|
if(receivableAmount <=0){
|
continue;
|
}
|
tmpPayFeeDetailMonthPo.setReceivableAmount( receivableAmount + "");
|
tmpPayFeeDetailMonthPo.setReceivedAmount(payFeeMonthHelp.getReceivedAmount(feeDetailDtos, feePrice, calendar.getTime(), feeDto) + "");
|
tmpPayFeeDetailMonthPo.setDiscountAmount(
|
payFeeMonthHelp.getDiscountAmount(Double.parseDouble(tmpPayFeeDetailMonthPo.getReceivableAmount()),
|
Double.parseDouble(tmpPayFeeDetailMonthPo.getReceivedAmount()),
|
calendar.getTime(), feeDto) + "");
|
tmpPayFeeDetailMonthPo.setMonthId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_monthId));
|
tmpPayFeeDetailMonthPo.setRemark("程序计算生成");
|
tmpPayFeeDetailMonthPo.setObjName(payFeeMonthOwnerDto.getObjName());
|
tmpPayFeeDetailMonthPo.setObjId(payFeeMonthOwnerDto.getObjId());
|
tmpPayFeeDetailMonthPo.setOwnerId(payFeeMonthOwnerDto.getOwnerId());
|
tmpPayFeeDetailMonthPo.setOwnerName(payFeeMonthOwnerDto.getOwnerName());
|
tmpPayFeeDetailMonthPo.setLink(payFeeMonthOwnerDto.getLink());
|
tmpPayFeeDetailMonthPo.setCurMonthTime(DateUtil.getFormatTimeStringB(calendar.getTime()));
|
tmpPayFeeDetailMonthPo.setPayFeeTime(payFeeMonthHelp.getFeeFeeTime(feeDetailDtos, tmpPayFeeDetailMonthPo.getDetailId()));
|
tmpPayFeeDetailMonthPo.setState("W"); // todo 这里暂时写死，目前用不到，算是预留字段
|
tmpPayFeeDetailMonthPo.setFeeName(feeDto.getFeeName());
|
tmpPayFeeDetailMonthPo.setConfigId(feeDto.getConfigId());
|
payFeeDetailMonthPos.add(tmpPayFeeDetailMonthPo);
|
}
|
payFeeDetailMonthInnerServiceSMOImpl.savePayFeeDetailMonths(payFeeDetailMonthPos);
|
}
|
|
/**
|
* 小区数据 离散为 月数据
|
*
|
* @param communityId
|
*/
|
@Async
|
@Override
|
public void doGeneratorOrRefreshAllFeeMonth(String communityId) {
|
|
|
FeeDto feeDto = new FeeDto();
|
feeDto.setCommunityId(communityId);
|
int count = feeInnerServiceSMOImpl.queryFeesCount(feeDto);
|
|
int page = 1;
|
int max = 15;
|
if (count < DEFAULT_DEAL_COUNT) {
|
page = 1;
|
max = count;
|
} else {
|
page = (int) Math.ceil((double) count / (double) DEFAULT_DEAL_COUNT);
|
max = DEFAULT_DEAL_COUNT;
|
}
|
|
//todo 每次按200条处理
|
for (int pageIndex = 0; pageIndex < page; pageIndex++) {
|
feeDto.setPage(pageIndex + 1);
|
feeDto.setRow(max);
|
List<FeeDto> tmpFeeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
// 离散费用
|
doTmpFeeDtoMonths(communityId, tmpFeeDtos);
|
}
|
|
|
}
|
|
/**
|
* 物业缴费时离散 报表数据
|
*
|
* @param feeId
|
* @param detailId
|
* @param communityId
|
*/
|
@Async
|
@Override
|
public void payFeeDetailRefreshFeeMonth(String feeId, String detailId, String communityId) {
|
// todo 查询费用
|
FeeDto feeDto = new FeeDto();
|
feeDto.setCommunityId(communityId);
|
feeDto.setFeeId(feeId);
|
List<FeeDto> tmpFeeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
|
Assert.listOnlyOne(tmpFeeDtos, "费用不存在");
|
|
//todo 查询 缴费明细
|
FeeDetailDto feeDetailDto = new FeeDetailDto();
|
feeDetailDto.setCommunityId(feeDto.getCommunityId());
|
feeDetailDto.setFeeId(feeDto.getFeeId());
|
feeDetailDto.setDetailId(detailId);
|
List<FeeDetailDto> feeDetailDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto);
|
|
Assert.listOnlyOne(feeDetailDtos, "缴费记录不存在");
|
|
//todo 计算每月单价
|
Double feePrice = payFeeMonthHelp.getMonthFeePrice(feeDto);
|
|
// todo 准备离散的基础数据
|
PayFeeMonthOwnerDto payFeeMonthOwnerDto = payFeeMonthHelp.generatorOwnerRoom(feeDto);
|
|
// todo 删除缴费时间范围内的数据
|
doDeletePayFeeDetailInMonth(feeDto, feeDetailDtos.get(0));
|
|
// todo 生成一段时间内的数据
|
doGeneratorTimeMonthData(feeDto, payFeeMonthOwnerDto, feePrice, feeDetailDtos.get(0).getStartTime(), feeDetailDtos.get(0).getEndTime());
|
}
|
|
@Override
|
public void deleteFeeMonth(String feeId, String communityId) {
|
|
PayFeeDetailMonthPo payFeeDetailMonthPo = new PayFeeDetailMonthPo();
|
payFeeDetailMonthPo.setFeeId(feeId);
|
payFeeDetailMonthPo.setCommunityId(communityId);
|
payFeeDetailMonthInnerServiceSMOImpl.deletePayFeeDetailMonth(payFeeDetailMonthPo);
|
}
|
|
/**
|
* 删除缴费范围内的数据
|
*
|
* @param feeDto
|
* @param feeDetailDto
|
*/
|
private void doDeletePayFeeDetailInMonth(FeeDto feeDto, FeeDetailDto feeDetailDto) {
|
|
PayFeeDetailMonthPo payFeeDetailMonthPo = new PayFeeDetailMonthPo();
|
payFeeDetailMonthPo.setFeeId(feeDto.getFeeId());
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(feeDetailDto.getStartTime());
|
calendar.set(Calendar.DAY_OF_MONTH, 1);
|
payFeeDetailMonthPo.setCurMonthTime(DateUtil.getFormatTimeStringB(calendar.getTime()));
|
payFeeDetailMonthPo.setCurMonthEndTime(DateUtil.getFormatTimeStringB(feeDetailDto.getEndTime()));
|
payFeeDetailMonthInnerServiceSMOImpl.deletePayFeeDetailMonth(payFeeDetailMonthPo);
|
}
|
|
private void doTmpFeeDtoMonths(String communityId, List<FeeDto> tmpFeeDtos) {
|
for (FeeDto tmpFeeDto : tmpFeeDtos) {
|
try {
|
doGeneratorOrRefreshFeeMonth(tmpFeeDto, communityId);
|
} catch (Exception e) {
|
e.printStackTrace();
|
logger.error("生成费用报表失败" + JSONObject.toJSONString(tmpFeeDto), e);
|
}
|
}
|
}
|
}
|
