From ac82dee75615f23ba1ca141314cc45b8a7170b00 Mon Sep 17 00:00:00 2001
From: xiaogang <905166056@qq.com>
Date: 星期四, 12 八月 2021 22:34:40 +0800
Subject: [PATCH] 优化字母车位费用问题
---
service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java | 633 +++++++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 589 insertions(+), 44 deletions(-)
diff --git a/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java b/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java
old mode 100644
new mode 100755
index 413808c..64d449a
--- a/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java
+++ b/service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java
@@ -1,30 +1,50 @@
package com.java110.fee.bmo.impl;
+import com.alibaba.fastjson.JSONArray;
+import com.java110.core.factory.Java110ThreadPoolFactory;
+import com.java110.core.smo.IComputeFeeSMO;
import com.java110.dto.RoomDto;
-import com.java110.dto.fee.BillOweFeeDto;
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.Assert;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.List;
+import java.math.RoundingMode;
+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;
@@ -35,124 +55,649 @@
@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";
@Override
public ResponseEntity<String> query(FeeDto feeDto) {
- //鏌ヨ璐圭敤淇℃伅
+ //鏌ヨ璐圭敤淇℃伅arrearsEndTime
+ feeDto.setArrearsEndTime(DateUtil.getCurrentDate());
+ feeDto.setState(FeeDto.STATE_DOING);
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
if (feeDtos == null || feeDtos.size() < 1) {
feeDtos = new ArrayList<>();
return ResultVo.createResponseEntity(feeDtos);
}
-
+ List<FeeDto> tmpFeeDtos = new ArrayList<>();
for (FeeDto tmpFeeDto : feeDtos) {
- computeOweFee(tmpFeeDto);//璁＄畻娆犺垂閲戦
+ computeFeeSMOImpl.computeEveryOweFee(tmpFeeDto);//璁＄畻娆犺垂閲戦
+ //濡傛灉閲戦涓�0 灏辨帓闄�
+ if (tmpFeeDto.getFeePrice() > 0 && tmpFeeDto.getEndTime().getTime() <= DateUtil.getCurrentDate().getTime()) {
+ tmpFeeDtos.add(tmpFeeDto);
+ }
}
- return ResultVo.createResponseEntity(feeDtos);
+
+ 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 (feeDtos == null || feeDtos.size() < 1) {
+ return ResultVo.success();
+ }
+
+ feeDto = feeDtos.get(0);
+
+ 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 (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) { //鏁版嵁鏈夐棶棰�
+ 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());
+ }
+ double feePrice = computeFeeSMOImpl.getFeePrice(feeDto);
+ feeDto.setFeePrice(feePrice);
+ //搴旀敹娆惧彇鍊�
+ String val = MappingCache.getValue(DOMAIN_COMMON, TOTAL_FEE_PRICE);
+ feeDto.setVal(val);
+ String 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);
+ }
+ return ResultVo.createResponseEntity(feeDto);
+ }
+
+ @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()) {
+ 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 tmpFeeDto
+ * @param feeDto
+ * @return
*/
- private void computeOweFee(FeeDto tmpFeeDto) {
- String billType = tmpFeeDto.getBillType();
-
- if (FeeConfigDto.BILL_TYPE_EVERY.equals(billType)) {
- computeFeePrice(tmpFeeDto);
- 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<>();
}
- BillOweFeeDto billOweFeeDto = new BillOweFeeDto();
- billOweFeeDto.setCommunityId(tmpFeeDto.getCommunityId());
- billOweFeeDto.setFeeId(tmpFeeDto.getFeeId());
- billOweFeeDto.setState("T");
- List<BillOweFeeDto> billOweFeeDtos = feeInnerServiceSMOImpl.queryBillOweFees(billOweFeeDto);
- if (billOweFeeDtos == null || billOweFeeDtos.size() < 1) {
- tmpFeeDto.setFeePrice(0.00);
- return;
- }
- tmpFeeDto.setFeePrice(Double.parseDouble(billOweFeeDtos.get(0).getAmountOwed()));
+ return ResultVo.createResponseEntity((int) Math.ceil((double) count / (double) feeDto.getRow()), count, feeDtos);
}
+ /**
+ * 瀹炴椂璐圭敤
+ *
+ * @param feeDto
+ * @return
+ */
+ private ResponseEntity<String> computeEveryOweFee(FeeDto feeDto) {
- private void computeFeePrice(FeeDto feeDto) {
+ int count = feeInnerServiceSMOImpl.computeEveryOweFeeCount(feeDto);
+ List<FeeDto> feeDtos = null;
+ if (count > 0) {
+ feeDtos = feeInnerServiceSMOImpl.computeEveryOweFee(feeDto);
+ computeFeePrices(feeDtos);
- if ("3333".equals(feeDto.getPayerObjType())) { //鎴垮眿鐩稿叧
- computeFeePriceByRoom(feeDto);
- } else if ("6666".equals(feeDto.getPayerObjType())) {//杞︿綅鐩稿叧
- computeFeePriceByParkingSpace(feeDto);
+ } 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);
}
}
- private void computeFeePriceByParkingSpace(FeeDto feeDto) {
-
+ /**
+ * 璁＄畻鍋滆溅璐�
+ *
+ * @param psFees
+ */
+ private void computePsFee(List<FeeDto> psFees, List<String> psIds) {
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
- parkingSpaceDto.setCommunityId(feeDto.getCommunityId());
- parkingSpaceDto.setPsId(feeDto.getPayerObjId());
+ 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 = 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(parkingSpaceDtos.get(0).getArea()));
+ 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 ("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 feeDto
+ * @param roomFees
*/
- private void computeFeePriceByRoom(FeeDto feeDto) {
+ private void computeRoomFee(List<FeeDto> roomFees, List<String> roomIds) {
RoomDto roomDto = new RoomDto();
- roomDto.setCommunityId(feeDto.getCommunityId());
- roomDto.setRoomId(feeDto.getPayerObjId());
+ 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 = 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(roomDtos.get(0).getBuiltUpArea()));
+ 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 ("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());
+ }
+
+ }
+
+
+ /**
+ * 璁＄畻2涓棩鏈熶箣闂寸浉宸殑 浠ュ勾銆佹湀銆佹棩涓哄崟浣嶏紝鍚勮嚜璁＄畻缁撴灉鏄灏�
+ * 姣斿锛�2011-02-02 鍒� 2017-03-02
+ * 浠ュ勾涓哄崟浣嶇浉宸负锛�6骞�
+ * 浠ユ湀涓哄崟浣嶇浉宸负锛�73涓湀
+ * 浠ユ棩涓哄崟浣嶇浉宸负锛�2220澶�
+ *
+ * @param fromDate
+ * @param toDate
+ * @return
+ */
+ public static double dayCompare(Date fromDate, Date toDate) {
+ Calendar from = Calendar.getInstance();
+ from.setTime(fromDate);
+ Calendar to = Calendar.getInstance();
+ to.setTime(toDate);
+
+ long t1 = from.getTimeInMillis();
+ long t2 = to.getTimeInMillis();
+ double days = (t2 - t1) * 1.00 / (24 * 60 * 60 * 1000);
+
+ BigDecimal tmpDays = new BigDecimal(days);
+ BigDecimal monthDay = new BigDecimal(30);
+
+ return tmpDays.divide(monthDay, 2, RoundingMode.HALF_UP).doubleValue();
+ }
+
+ private Map getTargetEndDateAndOweMonth(FeeDto feeDto) {
+ Date targetEndDate = null;
+ double oweMonth = 0.0;
+
+ Map<String, Object> targetEndDateAndOweMonth = new HashMap<>();
+
+ if (FeeDto.STATE_FINISH.equals(feeDto.getState())) {
+ targetEndDate = feeDto.getEndTime();
+ targetEndDateAndOweMonth.put("oweMonth", oweMonth);
+ targetEndDateAndOweMonth.put("targetEndDate", targetEndDate);
+ return targetEndDateAndOweMonth;
+ }
+ if (FeeDto.FEE_FLAG_ONCE.equals(feeDto.getFeeFlag())) {
+ if (feeDto.getDeadlineTime() != null) {
+ targetEndDate = feeDto.getDeadlineTime();
+ } else if (!StringUtil.isEmpty(feeDto.getCurDegrees())) {
+ targetEndDate = feeDto.getCurReadingTime();
+ } else if (feeDto.getImportFeeEndTime() == null) {
+ targetEndDate = feeDto.getConfigEndTime();
+ } else {
+ targetEndDate = feeDto.getImportFeeEndTime();
+ }
+ //鍒ゆ柇褰撳墠璐圭敤鏄笉鏄鍏ヨ垂鐢�
+ oweMonth = 1.0;
+
+ } else {
+ //褰撳墠鏃堕棿
+ Date billEndTime = DateUtil.getCurrentDate();
+ //寮�濮嬫椂闂�
+ Date startDate = feeDto.getStartTime();
+ //鍒版湡鏃堕棿
+ Date endDate = feeDto.getEndTime();
+ if (FeeDto.PAYER_OBJ_TYPE_CAR.equals(feeDto.getPayerObjType())) {
+ OwnerCarDto ownerCarDto = new OwnerCarDto();
+ ownerCarDto.setCommunityId(feeDto.getCommunityId());
+ ownerCarDto.setCarId(feeDto.getPayerObjId());
+ List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
+
+ if (ownerCarDtos == null || ownerCarDtos.size() != 1) {
+ targetEndDateAndOweMonth.put("oweMonth", 0);
+ targetEndDateAndOweMonth.put("targetEndDate", "");
+ return targetEndDateAndOweMonth;
+ }
+
+ targetEndDate = ownerCarDtos.get(0).getEndTime();
+ //璇存槑娌℃湁娆犺垂
+ if (endDate.getTime() >= targetEndDate.getTime()) {
+ // 鐩爣鍒版湡鏃堕棿 - 鍒版湡鏃堕棿 = 娆犺垂鏈堜唤
+ oweMonth = 0;
+ targetEndDateAndOweMonth.put("oweMonth", oweMonth);
+ targetEndDateAndOweMonth.put("targetEndDate", targetEndDate);
+ return targetEndDateAndOweMonth;
+ }
+ }
+
+ //缂磋垂鍛ㄦ湡
+ long paymentCycle = Long.parseLong(feeDto.getPaymentCycle());
+ // 褰撳墠鏃堕棿 - 寮�濮嬫椂闂� = 鏈堜唤
+ double mulMonth = 0.0;
+ mulMonth = dayCompare(startDate, billEndTime);
+
+ // 鏈堜唤/ 鍛ㄦ湡 = 杞暟锛堝悜涓婂彇鏁达級
+ double round = 0.0;
+ if ("1200".equals(feeDto.getPaymentCd())) { // 棰勪粯璐�
+ round = Math.floor(mulMonth / paymentCycle) + 1;
+ } else { //鍚庝粯璐�
+ round = Math.floor(mulMonth / paymentCycle);
+ }
+ // 杞暟 * 鍛ㄦ湡 * 30 + 寮�濮嬫椂闂� = 鐩爣 鍒版湡鏃堕棿
+ targetEndDate = getTargetEndTime(round * paymentCycle, startDate);
+ //璐圭敤 蹇粨鏉熶簡
+ if (feeDto.getConfigEndTime().getTime() < targetEndDate.getTime()) {
+ targetEndDate = feeDto.getConfigEndTime();
+ }
+ //璇存槑娌℃湁娆犺垂
+ if (endDate.getTime() < targetEndDate.getTime()) {
+ // 鐩爣鍒版湡鏃堕棿 - 鍒版湡鏃堕棿 = 娆犺垂鏈堜唤
+ oweMonth = dayCompare(endDate, targetEndDate);
+ }
+
+ if (feeDto.getEndTime().getTime() > targetEndDate.getTime()) {
+ targetEndDate = feeDto.getEndTime();
+ }
+ }
+
+ targetEndDateAndOweMonth.put("oweMonth", oweMonth);
+ targetEndDateAndOweMonth.put("targetEndDate", targetEndDate);
+ return targetEndDateAndOweMonth;
+ }
+
+ private Date getTargetEndTime(double v, Date startDate) {
+ Calendar endDate = Calendar.getInstance();
+ endDate.setTime(startDate);
+ endDate.add(Calendar.MONTH, (int) v);
+ return endDate.getTime();
}
}
--
Gitblit v1.8.0