package com.java110.fee.bmo.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.java110.core.factory.CommunitySettingFactory;
|
import com.java110.core.factory.Java110ThreadPoolFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.core.smo.IComputeFeeSMO;
|
import com.java110.dto.room.RoomDto;
|
import com.java110.dto.fee.FeeConfigDto;
|
import com.java110.dto.fee.FeeDto;
|
import com.java110.dto.owner.OwnerCarDto;
|
import com.java110.dto.owner.OwnerDto;
|
import com.java110.dto.parking.ParkingSpaceDto;
|
import com.java110.fee.bmo.IQueryOweFee;
|
import com.java110.intf.community.IParkingSpaceInnerServiceSMO;
|
import com.java110.intf.community.IRoomInnerServiceSMO;
|
import com.java110.intf.fee.IFeeConfigInnerServiceSMO;
|
import com.java110.intf.fee.IFeeInnerServiceSMO;
|
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
|
import com.java110.intf.user.IOwnerInnerServiceSMO;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.constant.ResponseConstant;
|
import com.java110.utils.exception.ListenerExecuteException;
|
import com.java110.utils.util.*;
|
import com.java110.vo.ResultVo;
|
import com.java110.vo.api.fee.ApiFeeDataVo;
|
import com.java110.vo.api.fee.ApiFeeVo;
|
import com.java110.vo.api.feeConfig.ApiFeeConfigDataVo;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.ZoneId;
|
import java.util.*;
|
|
@Service
|
public class QueryOweFeeImpl implements IQueryOweFee {
|
|
|
private final static Logger logger = LoggerFactory.getLogger(QueryOweFeeImpl.class);
|
|
|
@Autowired
|
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
|
|
@Autowired
|
private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl;
|
|
@Autowired
|
private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
|
|
@Autowired
|
private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
|
|
@Autowired
|
private IComputeFeeSMO computeFeeSMOImpl;
|
|
//域
|
public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
|
|
//键
|
public static final String TOTAL_FEE_PRICE = "TOTAL_FEE_PRICE";
|
|
//键
|
public static final String RECEIVED_AMOUNT_SWITCH = "RECEIVED_AMOUNT_SWITCH";
|
|
//禁用电脑端提交收费按钮
|
public static final String OFFLINE_PAY_FEE_SWITCH = "OFFLINE_PAY_FEE_SWITCH";
|
|
@Override
|
public ResponseEntity<String> query(FeeDto feeDto) {
|
|
//查询费用信息arrearsEndTime
|
// todo 这里考虑预付期的费用 所以查询全量再用费用
|
feeDto.setState(FeeDto.STATE_DOING);
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
|
if (ListUtil.isNull(feeDtos)) {
|
feeDtos = new ArrayList<>();
|
return ResultVo.createResponseEntity(feeDtos);
|
}
|
String val = CommunitySettingFactory.getValue(feeDtos.get(0).getCommunityId(), TOTAL_FEE_PRICE);
|
if (StringUtil.isEmpty(val)) {
|
val = MappingCache.getValue(DOMAIN_COMMON, TOTAL_FEE_PRICE);
|
}
|
List<FeeDto> tmpFeeDtos = new ArrayList<>();
|
for (FeeDto tmpFeeDto : feeDtos) {
|
try {
|
if (!StringUtil.isEmpty(tmpFeeDto.getAdditionalAmount())) {
|
tmpFeeDto.setAdditionalAmount(Double.parseDouble(tmpFeeDto.getAdditionalAmount()) + "");
|
}
|
if (!StringUtil.isEmpty(tmpFeeDto.getSquarePrice())) {
|
tmpFeeDto.setSquarePrice(Double.parseDouble(tmpFeeDto.getSquarePrice()) + "");
|
}
|
|
//todo 有目标结束时间,并且不是一次性费用
|
if (!StringUtil.isEmpty(feeDto.getTargetEndTime())
|
&& !FeeDto.FEE_FLAG_ONCE.equals(tmpFeeDto.getFeeFlag())
|
) {
|
computeFeeSMOImpl.computeEveryOweFeeByTargetEndTime(tmpFeeDto, feeDto.getTargetEndTime());//计算欠费金额
|
} else {
|
computeFeeSMOImpl.computeEveryOweFee(tmpFeeDto);//计算欠费金额
|
}
|
//如果金额为0 就排除
|
tmpFeeDto.setFeeTotalPrice(
|
MoneyUtil.computePriceScale(
|
tmpFeeDto.getFeeTotalPrice(),
|
tmpFeeDto.getScale(),
|
Integer.parseInt(tmpFeeDto.getDecimalPlace())
|
)
|
);
|
|
tmpFeeDto.setVal(val);
|
if (tmpFeeDto.getFeeTotalPrice() != 0) {
|
tmpFeeDtos.add(tmpFeeDto);
|
}
|
} catch (Exception e) {
|
logger.error("可能费用资料有问题导致算费失败", e);
|
}
|
}
|
|
|
return ResultVo.createResponseEntity(tmpFeeDtos);
|
}
|
|
@Override
|
public ResponseEntity<String> queryAllOwneFee(FeeDto feeDto) {
|
ResponseEntity<String> responseEntity = null;
|
|
if (!freshFeeDtoParam(feeDto)) {
|
return ResultVo.createResponseEntity(1, 0, new JSONArray());
|
}
|
|
if (FeeConfigDto.BILL_TYPE_EVERY.equals(feeDto.getBillType())) {
|
responseEntity = computeEveryOweFee(feeDto);
|
} else {
|
responseEntity = computeBillOweFee(feeDto);
|
}
|
return responseEntity;
|
}
|
|
@Override
|
public ResponseEntity<String> listFeeObj(FeeDto feeDto) {
|
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
|
if (ListUtil.isNull(feeDtos)) {
|
return ResultVo.success();
|
}
|
String cycel = null;
|
String custEndTime = null;
|
String customStartTime = "";
|
String customEndTime = "";
|
if (!StringUtil.isEmpty(feeDto.getCycle())) {
|
cycel = feeDto.getCycle();
|
}
|
if (!StringUtil.isEmpty(feeDto.getCustEndTime())) {
|
custEndTime = feeDto.getCustEndTime();
|
}
|
customStartTime = feeDto.getCustomStartTime();
|
customEndTime = feeDto.getCustomEndTime();
|
feeDto = feeDtos.get(0);
|
//todo 考虑账单模式
|
if (FeeDto.FEE_FLAG_ONCE.equals(feeDto.getFeeFlag()) && StringUtil.isNumber(feeDto.getMonthCycle())) {
|
cycel = feeDto.getMonthCycle();
|
}
|
if (!StringUtil.isEmpty(cycel)) {
|
feeDto.setCycle(cycel);
|
}
|
if (!StringUtil.isEmpty(custEndTime)) {
|
feeDto.setCustEndTime(custEndTime);
|
}
|
|
feeDto.setCustomStartTime(customStartTime);
|
feeDto.setCustomEndTime(customEndTime);
|
|
if (FeeDto.PAYER_OBJ_TYPE_ROOM.equals(feeDto.getPayerObjType())) { //房屋相关
|
RoomDto roomDto = new RoomDto();
|
roomDto.setRoomId(feeDto.getPayerObjId());
|
roomDto.setCommunityId(feeDto.getCommunityId());
|
List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
|
if (roomDtos == null || roomDtos.size() != 1) {
|
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "未查到房屋信息，查询多条数据");
|
}
|
roomDto = roomDtos.get(0);
|
feeDto.setPayerObjName(roomDto.getFloorNum() + "-" + roomDto.getUnitNum() + "-" + roomDto.getRoomNum());
|
feeDto.setBuiltUpArea(roomDto.getBuiltUpArea());
|
|
} else if (FeeDto.PAYER_OBJ_TYPE_CAR.equals(feeDto.getPayerObjType())) {//车位相关
|
OwnerCarDto ownerCarDto = new OwnerCarDto();
|
ownerCarDto.setCarTypeCd("1001"); //业主车辆
|
ownerCarDto.setCommunityId(feeDto.getCommunityId());
|
ownerCarDto.setCarId(feeDto.getPayerObjId());
|
List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
|
Assert.listOnlyOne(ownerCarDtos, "未找到车辆信息");
|
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
|
parkingSpaceDto.setCommunityId(feeDto.getCommunityId());
|
parkingSpaceDto.setPsId(ownerCarDtos.get(0).getPsId());
|
List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
|
if (ListUtil.isNull(parkingSpaceDtos)) { //数据有问题
|
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "未查到停车位信息，查询多条数据");
|
}
|
ownerCarDto = ownerCarDtos.get(0);
|
parkingSpaceDto = parkingSpaceDtos.get(0);
|
feeDto.setPayerObjName(ownerCarDto.getCarNum() + "(" + parkingSpaceDto.getAreaNum() + "停车场" + parkingSpaceDto.getNum() + "车位)");
|
feeDto.setBuiltUpArea(parkingSpaceDto.getArea());
|
}
|
|
Map feePriceAll = computeFeeSMOImpl.getFeePrice(feeDto);
|
feeDto.setFeePrice(Double.parseDouble(feePriceAll.get("feePrice").toString()));
|
|
feeDto.setFeeTotalPrice(
|
MoneyUtil.computePriceScale(
|
Double.parseDouble(feePriceAll.get("feeTotalPrice").toString()),
|
feeDto.getScale(),
|
Integer.parseInt(feeDto.getDecimalPlace())
|
)
|
);
|
if (!StringUtil.isEmpty(custEndTime)) {
|
Date date = DateUtil.getDateFromStringB(custEndTime);
|
computeFeeSMOImpl.dealRentRateCustEndTime(feeDto, date);
|
} else {
|
computeFeeSMOImpl.dealRentRateCycle(feeDto, NumberUtil.getDouble(feeDto.getCycle()));
|
}
|
|
|
//应收款取值
|
//先取单小区的如果没有配置 取 全局的
|
String val = CommunitySettingFactory.getValue(feeDto.getCommunityId(), TOTAL_FEE_PRICE);
|
if (StringUtil.isEmpty(val)) {
|
val = MappingCache.getValue(DOMAIN_COMMON, TOTAL_FEE_PRICE);
|
}
|
feeDto.setVal(val);
|
//先取单小区的如果没有配置 取 全局的
|
String received_amount_switch = CommunitySettingFactory.getValue(feeDto.getCommunityId(), RECEIVED_AMOUNT_SWITCH);
|
if (StringUtil.isEmpty(received_amount_switch)) {
|
received_amount_switch = MappingCache.getValue(DOMAIN_COMMON, RECEIVED_AMOUNT_SWITCH);
|
}
|
//关闭 线下收银功能
|
if (StringUtil.isEmpty(received_amount_switch)) {
|
feeDto.setReceivedAmountSwitch("1");//默认启用实收款输入框
|
} else {
|
feeDto.setReceivedAmountSwitch(received_amount_switch);
|
}
|
//先取单小区的如果没有配置 取 全局的
|
String offlinePayFeeSwitch = CommunitySettingFactory.getValue(feeDto.getCommunityId(), OFFLINE_PAY_FEE_SWITCH);
|
if (StringUtil.isEmpty(offlinePayFeeSwitch)) {
|
offlinePayFeeSwitch = MappingCache.getValue(DOMAIN_COMMON, OFFLINE_PAY_FEE_SWITCH);
|
}
|
feeDto.setOfflinePayFeeSwitch(offlinePayFeeSwitch);
|
//去掉多余0
|
feeDto.setSquarePrice(Double.parseDouble(feeDto.getSquarePrice()) + "");
|
feeDto.setAdditionalAmount(Double.parseDouble(feeDto.getAdditionalAmount()) + "");
|
ApiFeeDataVo apiFeeDataVo = BeanConvertUtil.covertBeanList(feeDtos, ApiFeeDataVo.class).get(0);
|
apiFeeDataVo.setStartTime(apiFeeDataVo.getStartTime() == null ? null : apiFeeDataVo.getStartTime().split(" ")[0]);
|
apiFeeDataVo.setEndTime(apiFeeDataVo.getEndTime() == null ? null : apiFeeDataVo.getEndTime().split(" ")[0]);
|
apiFeeDataVo.setMaxEndTime(apiFeeDataVo.getMaxEndTime() == null ? null : apiFeeDataVo.getMaxEndTime().split(" ")[0]);
|
apiFeeDataVo.setDeadlineTime(apiFeeDataVo.getDeadlineTime() == null ? null : apiFeeDataVo.getDeadlineTime().split(" ")[0]);
|
if (cycel != null && !"105".equals(cycel)) { // 修正字符串比较方式
|
Date date = feeDto.getEndTime();
|
if (date != null) { // 增加空值检查
|
LocalDateTime localDateTime;
|
|
// 处理 java.sql.Date 不支持 toInstant() 的问题
|
if (date instanceof java.sql.Date) {
|
// 对于 sql.Date，先转换为 LocalDate 再转为 LocalDateTime
|
LocalDate localDate = ((java.sql.Date) date).toLocalDate();
|
localDateTime = localDate.atStartOfDay();
|
} else {
|
// 对于 util.Date，正常转换
|
localDateTime = LocalDateTime.ofInstant(date.toInstant(), ZoneId.systemDefault());
|
}
|
|
try {
|
// 增加x个月
|
int monthsToAdd = Integer.parseInt(cycel);
|
LocalDateTime newLocalDateTime = localDateTime.plusMonths(monthsToAdd).minusDays(1);
|
|
// 转换回Date
|
Date newDate = Date.from(newLocalDateTime.atZone(ZoneId.systemDefault()).toInstant());
|
apiFeeDataVo.setPayStartDate(feeDto.getEndTime());
|
apiFeeDataVo.setPayEndDate(newDate);
|
} catch (NumberFormatException e) {
|
// 处理cycel无法转换为整数的异常
|
// 可以根据实际需求记录日志或抛出自定义异常
|
e.printStackTrace();
|
}
|
}
|
}else{
|
apiFeeDataVo.setPayStartDate(DateUtil.getDateFromStringB(feeDto.getCustomStartTime()));
|
// 获取原始日期
|
Date originalDate = DateUtil.getDateFromStringB(feeDto.getCustomEndTime());
|
if (originalDate != null) {
|
// 创建Calendar实例并设置日期
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(originalDate);
|
|
// 减一天
|
calendar.add(Calendar.DAY_OF_MONTH, -1);
|
|
// 获取处理后的日期
|
Date dateMinusOneDay = calendar.getTime();
|
apiFeeDataVo.setPayEndDate(dateMinusOneDay);
|
}
|
}
|
return ResultVo.createResponseEntity(apiFeeDataVo);
|
}
|
|
@Override
|
public ResponseEntity<String> querys(FeeDto feeDto) {
|
RoomDto roomDto = new RoomDto();
|
roomDto.setCommunityId(feeDto.getCommunityId());
|
roomDto.setRoomId(feeDto.getPayerObjId());
|
List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
|
|
if (roomDtos == null || roomDtos.size() < 1) {
|
return ResultVo.createResponseEntity(ResultVo.CODE_OK, "成功", new JSONArray());
|
}
|
//查询费用信息arrearsEndTime
|
List<RoomDto> tmpRoomDtos = new ArrayList<>();
|
List<RoomDto> tempRooms = new ArrayList<>();
|
int threadNum = Java110ThreadPoolFactory.JAVA110_DEFAULT_THREAD_NUM;
|
|
tempRooms.addAll(doGetTmpRoomDto(roomDtos, feeDto, threadNum));
|
for (RoomDto tmpRoomDto : tempRooms) {
|
if (tmpRoomDto == null) {
|
continue;
|
}
|
tmpRoomDtos.add(tmpRoomDto);
|
}
|
|
return ResultVo.createResponseEntity(tmpRoomDtos);
|
}
|
|
private List<RoomDto> doGetTmpRoomDto(List<RoomDto> roomDtos, FeeDto feeDto, int threadNum) {
|
Java110ThreadPoolFactory java110ThreadPoolFactory = null;
|
try {
|
java110ThreadPoolFactory = Java110ThreadPoolFactory.getInstance().createThreadPool(threadNum);
|
for (RoomDto roomDto1 : roomDtos) {
|
java110ThreadPoolFactory.submit(() -> {
|
return getTmpRoomDtos(roomDto1, feeDto);
|
});
|
}
|
return java110ThreadPoolFactory.get();
|
} finally {
|
if (java110ThreadPoolFactory != null) {
|
java110ThreadPoolFactory.stop();
|
}
|
}
|
}
|
|
private RoomDto getTmpRoomDtos(RoomDto tmpRoomDto, FeeDto feeDto) {
|
FeeDto tmpFeeDto = null;
|
tmpFeeDto = new FeeDto();
|
tmpFeeDto.setArrearsEndTime(DateUtil.getCurrentDate());
|
tmpFeeDto.setState(FeeDto.STATE_DOING);
|
tmpFeeDto.setPayerObjId(tmpRoomDto.getRoomId());
|
tmpFeeDto.setPayerObjType(FeeDto.PAYER_OBJ_TYPE_ROOM);
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.querySimpleFees(tmpFeeDto);
|
|
if (feeDtos == null || feeDtos.size() < 1) {
|
return null;
|
}
|
|
List<FeeDto> tmpFeeDtos = new ArrayList<>();
|
for (FeeDto tempFeeDto : feeDtos) {
|
|
computeFeeSMOImpl.computeEveryOweFee(tempFeeDto, tmpRoomDto);//计算欠费金额
|
//如果金额为0 就排除
|
//if (tempFeeDto.getFeePrice() > 0 && tempFeeDto.getEndTime().getTime() <= DateUtil.getCurrentDate().getTime()) {
|
if (tempFeeDto.getFeePrice() > 0) {
|
tmpFeeDtos.add(tempFeeDto);
|
}
|
}
|
|
if (tmpFeeDtos.size() < 1) {
|
return null;
|
}
|
tmpRoomDto.setFees(tmpFeeDtos);
|
return tmpRoomDto;
|
}
|
|
private boolean freshFeeDtoParam(FeeDto feeDto) {
|
|
if (StringUtil.isEmpty(feeDto.getPayerObjId())) {
|
return true;
|
}
|
|
if (!feeDto.getPayerObjId().contains("-")) {
|
return false;
|
}
|
if (FeeDto.PAYER_OBJ_TYPE_ROOM.equals(feeDto.getPayerObjType())) {
|
String[] nums = feeDto.getPayerObjId().split("-");
|
if (nums.length != 3) {
|
return false;
|
}
|
RoomDto roomDto = new RoomDto();
|
roomDto.setFloorNum(nums[0]);
|
roomDto.setUnitNum(nums[1]);
|
roomDto.setRoomNum(nums[2]);
|
roomDto.setCommunityId(feeDto.getCommunityId());
|
List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
|
|
if (roomDtos == null || roomDtos.size() < 1) {
|
return false;
|
}
|
feeDto.setPayerObjId(roomDtos.get(0).getRoomId());
|
|
} else {
|
String[] nums = feeDto.getPayerObjId().split("-");
|
if (nums.length != 2) {
|
return false;
|
}
|
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
|
parkingSpaceDto.setAreaNum(nums[0]);
|
parkingSpaceDto.setNum(nums[1]);
|
parkingSpaceDto.setCommunityId(feeDto.getCommunityId());
|
List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
|
|
if (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) {
|
return false;
|
}
|
feeDto.setPayerObjId(parkingSpaceDtos.get(0).getPsId());
|
}
|
|
return true;
|
}
|
|
/**
|
* 账单费用
|
*
|
* @param feeDto
|
* @return
|
*/
|
private ResponseEntity<String> computeBillOweFee(FeeDto feeDto) {
|
int count = feeInnerServiceSMOImpl.computeBillOweFeeCount(feeDto);
|
List<FeeDto> feeDtos = null;
|
if (count > 0) {
|
feeDtos = feeInnerServiceSMOImpl.computeBillOweFee(feeDto);
|
} else {
|
feeDtos = new ArrayList<>();
|
}
|
return ResultVo.createResponseEntity((int) Math.ceil((double) count / (double) feeDto.getRow()), count, feeDtos);
|
}
|
|
/**
|
* 实时费用
|
*
|
* @param feeDto
|
* @return
|
*/
|
private ResponseEntity<String> computeEveryOweFee(FeeDto feeDto) {
|
|
int count = feeInnerServiceSMOImpl.computeEveryOweFeeCount(feeDto);
|
List<FeeDto> feeDtos = null;
|
if (count > 0) {
|
feeDtos = feeInnerServiceSMOImpl.computeEveryOweFee(feeDto);
|
computeFeePrices(feeDtos);
|
|
} else {
|
feeDtos = new ArrayList<>();
|
}
|
return ResultVo.createResponseEntity((int) Math.ceil((double) count / (double) feeDto.getRow()), count, feeDtos);
|
}
|
|
private void computeFeePrices(List<FeeDto> feeDtos) {
|
|
List<FeeDto> roomFees = new ArrayList<>();
|
List<FeeDto> psFees = new ArrayList<>();
|
List<String> roomIds = new ArrayList<>();
|
List<String> psIds = new ArrayList<>();
|
|
for (FeeDto fee : feeDtos) {
|
// 轮数 * 周期 * 30 + 开始时间 = 目标 到期时间
|
if ("3333".equals(fee.getPayerObjType())) { //房屋相关
|
roomFees.add(fee);
|
roomIds.add(fee.getPayerObjId());
|
} else if ("6666".equals(fee.getPayerObjType())) {//车位相关
|
psFees.add(fee);
|
psIds.add(fee.getPayerObjId());
|
}
|
}
|
|
if (roomFees.size() > 0) {
|
computeRoomFee(roomFees, roomIds);
|
}
|
|
if (psFees.size() > 0) {
|
computePsFee(psFees, psIds);
|
}
|
}
|
|
/**
|
* 计算停车费
|
*
|
* @param psFees
|
*/
|
private void computePsFee(List<FeeDto> psFees, List<String> psIds) {
|
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
|
parkingSpaceDto.setCommunityId(psFees.get(0).getCommunityId());
|
parkingSpaceDto.setPsIds(psIds.toArray(new String[psIds.size()]));
|
List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
|
|
if (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) { //数据有问题
|
return;
|
}
|
for (ParkingSpaceDto tmpParkingSpaceDto : parkingSpaceDtos) {
|
for (FeeDto feeDto : psFees) {
|
dealFeePs(tmpParkingSpaceDto, feeDto);
|
}
|
}
|
|
OwnerDto ownerDto = new OwnerDto();
|
ownerDto.setOwnerIds(psIds.toArray(new String[psIds.size()]));
|
ownerDto.setCommunityId(psFees.get(0).getCommunityId());
|
List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwnersByParkingSpace(ownerDto);
|
|
for (OwnerDto tmpOwnerDto : ownerDtos) {
|
for (FeeDto feeDto : psFees) {
|
dealFeeOwner(tmpOwnerDto, feeDto);
|
}
|
}
|
}
|
|
private void dealFeePs(ParkingSpaceDto tmpParkingSpaceDto, FeeDto feeDto) {
|
// 轮数 * 周期 * 30 + 开始时间 = 目标 到期时间
|
Map<String, Object> targetEndDateAndOweMonth = computeFeeSMOImpl.getTargetEndDateAndOweMonth(feeDto);
|
Date targetEndDate = (Date) targetEndDateAndOweMonth.get("targetEndDate");
|
double oweMonth = (double) targetEndDateAndOweMonth.get("oweMonth");
|
if (!tmpParkingSpaceDto.getPsId().equals(feeDto.getPayerObjId())) {
|
return;
|
}
|
feeDto.setRoomName(tmpParkingSpaceDto.getAreaNum() + "停车场" + tmpParkingSpaceDto.getNum() + "车位");
|
|
String computingFormula = feeDto.getComputingFormula();
|
double feePrice = 0.00;
|
if ("1001".equals(computingFormula)) { //面积*单价+附加费
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getSquarePrice()));
|
BigDecimal builtUpArea = new BigDecimal(Double.parseDouble(tmpParkingSpaceDto.getArea()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
feePrice = squarePrice.multiply(builtUpArea).add(additionalAmount).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("2002".equals(computingFormula)) { // 固定费用
|
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
feePrice = additionalAmount.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("3003".equals(computingFormula)) { // 固定费用
|
feePrice = 0.0;
|
} else if ("1101".equals(computingFormula)) { // 租金
|
feePrice = 0.0;
|
} else if ("1102".equals(computingFormula)) { // 租金
|
feePrice = 0.0;
|
} else if ("4004".equals(computingFormula)) {
|
feePrice = Double.parseDouble(feeDto.getAmount());
|
} else if ("5005".equals(computingFormula)) {
|
if (StringUtil.isEmpty(feeDto.getCurDegrees())) {
|
feePrice = -1.00;
|
} else {
|
BigDecimal curDegree = new BigDecimal(Double.parseDouble(feeDto.getCurDegrees()));
|
BigDecimal preDegree = new BigDecimal(Double.parseDouble(feeDto.getPreDegrees()));
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getSquarePrice()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
BigDecimal sub = curDegree.subtract(preDegree);
|
feePrice = sub.multiply(squarePrice)
|
.add(additionalAmount)
|
.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
}
|
} else if ("9009".equals(computingFormula)) { //(本期度数-上期度数)*动态单价+附加费
|
if (StringUtil.isEmpty(feeDto.getCurDegrees())) {
|
feePrice = -1.00;
|
} else {
|
BigDecimal curDegree = new BigDecimal(Double.parseDouble(feeDto.getCurDegrees()));
|
BigDecimal preDegree = new BigDecimal(Double.parseDouble(feeDto.getPreDegrees()));
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getMwPrice()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
BigDecimal sub = curDegree.subtract(preDegree);
|
feePrice = sub.multiply(squarePrice)
|
.add(additionalAmount)
|
.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
}
|
} else {
|
feePrice = 0.00;
|
}
|
|
feeDto.setFeePrice(feePrice);
|
// double month = dayCompare(feeDto.getEndTime(), DateUtil.getCurrentDate());
|
BigDecimal price = new BigDecimal(feeDto.getFeePrice());
|
price = price.multiply(new BigDecimal(oweMonth));
|
feeDto.setAmountOwed(price.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + "");
|
feeDto.setDeadlineTime(targetEndDate);
|
//动态费用
|
if ("4004".equals(computingFormula)
|
&& FeeDto.FEE_FLAG_ONCE.equals(feeDto.getFeeFlag())
|
) {
|
feeDto.setAmountOwed(feeDto.getFeePrice() + "");
|
feeDto.setDeadlineTime(DateUtil.getCurrentDate());
|
}
|
}
|
|
/**
|
* 计算房屋费
|
*
|
* @param roomFees
|
*/
|
private void computeRoomFee(List<FeeDto> roomFees, List<String> roomIds) {
|
RoomDto roomDto = new RoomDto();
|
roomDto.setCommunityId(roomFees.get(0).getCommunityId());
|
roomDto.setRoomIds(roomIds.toArray(new String[roomIds.size()]));
|
List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
|
|
if (roomDtos == null || roomDtos.size() < 1) { //数据有问题
|
return;
|
}
|
|
|
for (RoomDto tmpRoomDto : roomDtos) {
|
for (FeeDto feeDto : roomFees) {
|
dealFeeRoom(tmpRoomDto, feeDto);
|
}
|
}
|
|
OwnerDto ownerDto = new OwnerDto();
|
ownerDto.setRoomIds(roomIds.toArray(new String[roomIds.size()]));
|
ownerDto.setCommunityId(roomFees.get(0).getCommunityId());
|
List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto);
|
|
for (OwnerDto tmpOwnerDto : ownerDtos) {
|
for (FeeDto feeDto : roomFees) {
|
dealFeeOwner(tmpOwnerDto, feeDto);
|
}
|
}
|
|
}
|
|
private void dealFeeOwner(OwnerDto tmpOwnerDto, FeeDto feeDto) {
|
|
if (!tmpOwnerDto.getRoomId().equals(feeDto.getPayerObjId())) {
|
return;
|
}
|
|
feeDto.setOwnerName(tmpOwnerDto.getName());
|
feeDto.setOwnerTel(tmpOwnerDto.getLink());
|
}
|
|
private void dealFeeRoom(RoomDto tmpRoomDto, FeeDto feeDto) {
|
Map<String, Object> targetEndDateAndOweMonth = computeFeeSMOImpl.getTargetEndDateAndOweMonth(feeDto);
|
Date targetEndDate = (Date) targetEndDateAndOweMonth.get("targetEndDate");
|
double oweMonth = (double) targetEndDateAndOweMonth.get("oweMonth");
|
if (!tmpRoomDto.getRoomId().equals(feeDto.getPayerObjId())) {
|
return;
|
}
|
feeDto.setRoomName(tmpRoomDto.getFloorNum() + "栋" + tmpRoomDto.getUnitNum() + "单元" + tmpRoomDto.getRoomNum() + "室");
|
|
String computingFormula = feeDto.getComputingFormula();
|
double feePrice = 0.00;
|
if ("1001".equals(computingFormula)) { //面积*单价+附加费
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getSquarePrice()));
|
BigDecimal builtUpArea = new BigDecimal(Double.parseDouble(tmpRoomDto.getBuiltUpArea()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
feePrice = squarePrice.multiply(builtUpArea).add(additionalAmount).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("2002".equals(computingFormula)) { // 固定费用
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
feePrice = additionalAmount.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("3003".equals(computingFormula)) { // 固定费用
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getSquarePrice()));
|
BigDecimal builtUpArea = new BigDecimal(Double.parseDouble(tmpRoomDto.getRoomArea()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
feePrice = squarePrice.multiply(builtUpArea).add(additionalAmount).setScale(3, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("1101".equals(computingFormula)) { // 租金
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(tmpRoomDto.getRoomRent()));
|
feePrice = additionalAmount.setScale(3, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("1102".equals(computingFormula)) { // 租金
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(tmpRoomDto.getRoomRent()));
|
feePrice = additionalAmount.setScale(3, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
} else if ("4004".equals(computingFormula)) {
|
feePrice = Double.parseDouble(feeDto.getAmount());
|
} else if ("5005".equals(computingFormula)) {
|
|
if (StringUtil.isEmpty(feeDto.getCurDegrees())) {
|
feePrice = -1.00;
|
} else {
|
BigDecimal curDegree = new BigDecimal(Double.parseDouble(feeDto.getCurDegrees()));
|
BigDecimal preDegree = new BigDecimal(Double.parseDouble(feeDto.getPreDegrees()));
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getSquarePrice()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
BigDecimal sub = curDegree.subtract(preDegree);
|
feePrice = sub.multiply(squarePrice)
|
.add(additionalAmount)
|
.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
}
|
} else if ("9009".equals(computingFormula)) {
|
|
if (StringUtil.isEmpty(feeDto.getCurDegrees())) {
|
feePrice = -1.00;
|
} else {
|
BigDecimal curDegree = new BigDecimal(Double.parseDouble(feeDto.getCurDegrees()));
|
BigDecimal preDegree = new BigDecimal(Double.parseDouble(feeDto.getPreDegrees()));
|
BigDecimal squarePrice = new BigDecimal(Double.parseDouble(feeDto.getMwPrice()));
|
BigDecimal additionalAmount = new BigDecimal(Double.parseDouble(feeDto.getAdditionalAmount()));
|
BigDecimal sub = curDegree.subtract(preDegree);
|
feePrice = sub.multiply(squarePrice)
|
.add(additionalAmount)
|
.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
}
|
} else {
|
feePrice = 0.00;
|
}
|
feeDto.setFeePrice(feePrice);
|
|
//double month = dayCompare(feeDto.getEndTime(), DateUtil.getCurrentDate());
|
BigDecimal price = new BigDecimal(feeDto.getFeePrice());
|
price = price.multiply(new BigDecimal(oweMonth));
|
feeDto.setAmountOwed(price.setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + "");
|
feeDto.setDeadlineTime(targetEndDate);
|
|
//动态费用
|
if ("4004".equals(computingFormula)) {
|
feeDto.setAmountOwed(feeDto.getFeePrice() + "");
|
feeDto.setDeadlineTime(DateUtil.getCurrentDate());
|
}
|
|
}
|
|
|
private Date getTargetEndTime(double v, Date startDate) {
|
Calendar endDate = Calendar.getInstance();
|
endDate.setTime(startDate);
|
endDate.add(Calendar.MONTH, (int) v);
|
return endDate.getTime();
|
}
|
|
}
|
