|
|
@@ -1,288 +0,0 @@
|
|
|
-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.payFee.PayFeeDetailMonthDto;
|
|
|
-import com.java110.dto.payFee.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.payFee.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(DateUtil.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);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-}
|