package com.java110.job.adapt.report;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.serializer.SerializerFeature;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.dto.ReportFeeMonthStatisticsPrepaymentDto.ReportFeeMonthStatisticsPrepaymentDto;
|
import com.java110.dto.fee.FeeConfigDto;
|
import com.java110.dto.fee.FeeDetailDto;
|
import com.java110.dto.fee.FeeDto;
|
import com.java110.dto.floor.FloorDto;
|
import com.java110.dto.owner.OwnerCarDto;
|
import com.java110.dto.parking.ParkingAreaDto;
|
import com.java110.dto.parking.ParkingSpaceDto;
|
import com.java110.dto.room.RoomDto;
|
import com.java110.dto.system.Business;
|
import com.java110.dto.unit.UnitDto;
|
import com.java110.intf.community.*;
|
import com.java110.intf.fee.IFeeConfigInnerServiceSMO;
|
import com.java110.intf.fee.IFeeDetailInnerServiceSMO;
|
import com.java110.intf.fee.IFeeInnerServiceSMO;
|
import com.java110.intf.report.IReportFeeMonthStatisticsPrepaymentInnerServiceSMO;
|
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
|
import com.java110.job.adapt.DatabusAdaptImpl;
|
import com.java110.po.ReportFeeMonthStatisticsPrepaymentPo.ReportFeeMonthStatisticsPrepaymentPo;
|
import com.java110.po.fee.PayFeeDetailPo;
|
import com.java110.utils.util.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author fqz
|
* @description 缴费修改预付期账单明细表
|
* @date 2023-04-10 11:10
|
*/
|
@Component(value = "editReportFeeMonthStatisticsBillAdapt")
|
public class EditReportFeeMonthStatisticsBillAdapt extends DatabusAdaptImpl {
|
|
@Autowired
|
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
|
|
@Autowired
|
private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl;
|
|
@Autowired
|
private IReportFeeMonthStatisticsPrepaymentInnerServiceSMO reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl;
|
|
@Autowired
|
private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl;
|
|
@Autowired
|
private IFloorInnerServiceSMO floorInnerServiceSMOImpl;
|
|
@Autowired
|
private IUnitInnerServiceSMO unitInnerServiceSMOImpl;
|
|
@Autowired
|
private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
|
|
@Autowired
|
private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
|
|
@Autowired
|
private IParkingAreaInnerServiceSMO parkingAreaInnerServiceSMOImpl;
|
|
@Override
|
public void execute(Business business, List<Business> businesses) throws ParseException {
|
JSONObject data = business.getData();
|
JSONArray businessPayFeeDetails = null;
|
if (data == null) {
|
FeeDetailDto feeDetailDto = new FeeDetailDto();
|
feeDetailDto.setbId(business.getbId());
|
List<FeeDetailDto> feeDetailDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto);
|
Assert.listOnlyOne(feeDetailDtos, "未查询到缴费记录");
|
businessPayFeeDetails = JSONArray.parseArray(JSONArray.toJSONString(feeDetailDtos, SerializerFeature.WriteDateUseDateFormat));
|
} else if (data.containsKey(PayFeeDetailPo.class.getSimpleName())) {
|
Object bObj = data.get(PayFeeDetailPo.class.getSimpleName());
|
if (bObj instanceof JSONObject) {
|
businessPayFeeDetails = new JSONArray();
|
businessPayFeeDetails.add(bObj);
|
} else if (bObj instanceof Map) {
|
businessPayFeeDetails = new JSONArray();
|
businessPayFeeDetails.add(JSONObject.parseObject(JSONObject.toJSONString(bObj)));
|
} else if (bObj instanceof List) {
|
businessPayFeeDetails = JSONArray.parseArray(JSONObject.toJSONString(bObj));
|
} else {
|
businessPayFeeDetails = (JSONArray) bObj;
|
}
|
} else {
|
if (data instanceof JSONObject) {
|
businessPayFeeDetails = new JSONArray();
|
businessPayFeeDetails.add(data);
|
}
|
}
|
for (int bPayFeeDetailIndex = 0; bPayFeeDetailIndex < businessPayFeeDetails.size(); bPayFeeDetailIndex++) {
|
JSONObject businessPayFeeDetail = businessPayFeeDetails.getJSONObject(bPayFeeDetailIndex);
|
editReportFeeMonthStatisticsBill(business, businessPayFeeDetail);
|
}
|
}
|
|
private void editReportFeeMonthStatisticsBill(Business business, JSONObject businessPayFeeDetail) throws ParseException {
|
FeeDto feeDto = new FeeDto();
|
feeDto.setFeeId(businessPayFeeDetail.getString("feeId"));
|
feeDto.setCommunityId(businessPayFeeDetail.getString("communityId"));
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
Assert.listOnlyOne(feeDtos, "未查询到费用信息！");
|
//查询费用项
|
FeeConfigDto feeConfigDto = new FeeConfigDto();
|
feeConfigDto.setConfigId(feeDtos.get(0).getConfigId());
|
List<FeeConfigDto> feeConfigDtos = feeConfigInnerServiceSMOImpl.queryFeeConfigs(feeConfigDto);
|
Assert.listOnlyOne(feeConfigDtos, "查询费用项错误！");
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
//获取费用标识
|
String feeFlag = feeConfigDtos.get(0).getFeeFlag(); //1003006 为周期性费用;2006012 为一次性费用;4012024 间接性费用
|
if (!StringUtil.isEmpty(feeConfigDtos.get(0).getPaymentCycle()) && !StringUtil.isEmpty(businessPayFeeDetail.getString("cycles"))
|
&& feeConfigDtos.get(0).getPaymentCycle().equals(businessPayFeeDetail.getString("cycles"))) { //缴费周期为一个周期的情况
|
//查询预付期账单明细表未缴费的数据
|
ReportFeeMonthStatisticsPrepaymentDto reportFeeMonthStatisticsPrepaymentDto = new ReportFeeMonthStatisticsPrepaymentDto();
|
reportFeeMonthStatisticsPrepaymentDto.setFeeId(businessPayFeeDetail.getString("feeId"));
|
reportFeeMonthStatisticsPrepaymentDto.setFeeBeginTime(businessPayFeeDetail.getString("startTime")); //费用开始时间
|
reportFeeMonthStatisticsPrepaymentDto.setFeeFinishTime(businessPayFeeDetail.getString("endTime")); //费用结束时间
|
List<ReportFeeMonthStatisticsPrepaymentDto> reportFeeMonthStatisticsPrepayments =
|
reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.queryReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentDto);
|
if (!ListUtil.isNull(reportFeeMonthStatisticsPrepayments)) { //有数据就更新数据
|
ReportFeeMonthStatisticsPrepaymentPo reportFeeMonthStatisticsPrepaymentPo = new ReportFeeMonthStatisticsPrepaymentPo();
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentId(reportFeeMonthStatisticsPrepayments.get(0).getPrepaymentId());
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentState("1"); //0 未缴费；1 已缴费
|
reportFeeMonthStatisticsPrepaymentPo.setbillState("2"); //账单状态：0 正常；1 已逾期； 2已还清
|
reportFeeMonthStatisticsPrepaymentPo.setReceivedAmount(businessPayFeeDetail.getString("receivedAmount")); //实收
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentDetailId(businessPayFeeDetail.getString("detailId")); //费用明细id
|
reportFeeMonthStatisticsPrepaymentPo.setPayTime(businessPayFeeDetail.getString("createTime")); //缴费时间
|
reportFeeMonthStatisticsPrepaymentPo.setUpdateTime(sdf.format(new Date()));
|
reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.updateReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentPo);
|
} else { //没有数据就新增一条预付期账单信息
|
saveReportFeeMonthStatisticsPrepayment(businessPayFeeDetail, feeDtos, feeConfigDtos); //添加预付期账单信息
|
}
|
} else if (!StringUtil.isEmpty(feeConfigDtos.get(0).getPaymentCycle()) && !StringUtil.isEmpty(businessPayFeeDetail.getString("cycles"))
|
&& !feeConfigDtos.get(0).getPaymentCycle().equals(businessPayFeeDetail.getString("cycles"))) { //缴费周期不是一个周期的情况
|
//查询预付期账单明细表未缴费的数据
|
ReportFeeMonthStatisticsPrepaymentDto reportFeeMonthStatisticsPrepaymentDto = new ReportFeeMonthStatisticsPrepaymentDto();
|
reportFeeMonthStatisticsPrepaymentDto.setFeeId(businessPayFeeDetail.getString("feeId"));
|
reportFeeMonthStatisticsPrepaymentDto.setNewBeginTime(businessPayFeeDetail.getString("startTime")); //费用开始时间
|
reportFeeMonthStatisticsPrepaymentDto.setNewFinishTime(businessPayFeeDetail.getString("endTime")); //费用结束时间
|
List<ReportFeeMonthStatisticsPrepaymentDto> reportFeeMonthStatisticsPrepayments =
|
reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.queryReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentDto);
|
if (reportFeeMonthStatisticsPrepayments != null && reportFeeMonthStatisticsPrepayments.size() > 0) {
|
for (ReportFeeMonthStatisticsPrepaymentDto reportFeeMonthStatisticsPrepayment : reportFeeMonthStatisticsPrepayments) {
|
//删除预付期报表里在本次缴费周期里的数据
|
ReportFeeMonthStatisticsPrepaymentPo reportFeeMonthStatisticsPrepaymentPo = new ReportFeeMonthStatisticsPrepaymentPo();
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentId(reportFeeMonthStatisticsPrepayment.getPrepaymentId());
|
reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.deleteReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentPo);
|
}
|
}
|
saveReportFeeMonthStatisticsPrepayment(businessPayFeeDetail, feeDtos, feeConfigDtos); //添加预付期账单信息
|
}
|
ReportFeeMonthStatisticsPrepaymentDto reportFeeMonthStatisticsPrepaymentDto = new ReportFeeMonthStatisticsPrepaymentDto();
|
reportFeeMonthStatisticsPrepaymentDto.setFeeId(businessPayFeeDetail.getString("feeId"));
|
reportFeeMonthStatisticsPrepaymentDto.setPrepaymentState("0"); //0 未缴费；1 已缴费
|
List<ReportFeeMonthStatisticsPrepaymentDto> reportFeeMonthStatisticsPrepaymentDtos = reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.queryReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentDto);
|
if (reportFeeMonthStatisticsPrepaymentDtos != null && reportFeeMonthStatisticsPrepaymentDtos.size() > 0) {
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
for (ReportFeeMonthStatisticsPrepaymentDto reportFeeMonthStatisticsPrepayment : reportFeeMonthStatisticsPrepaymentDtos) {
|
//获取该账单明细开始时间
|
String feeBeginTime = reportFeeMonthStatisticsPrepayment.getFeeBeginTime();
|
Date beginTime = format.parse(feeBeginTime);
|
//获取该账单明细结束时间
|
String feeFinishTime = reportFeeMonthStatisticsPrepayment.getFeeFinishTime();
|
Date finishTime = format.parse(feeFinishTime);
|
//获取本次缴费结束时间
|
String endTime = businessPayFeeDetail.getString("endTime");
|
Date newEndTime = format.parse(endTime);
|
if (beginTime.before(newEndTime) && finishTime.after(newEndTime)) {
|
ReportFeeMonthStatisticsPrepaymentPo reportFeeMonthStatisticsPrepaymentPo = new ReportFeeMonthStatisticsPrepaymentPo();
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentId(reportFeeMonthStatisticsPrepayment.getPrepaymentId());
|
reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.deleteReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentPo);
|
}
|
}
|
}
|
}
|
|
public void saveReportFeeMonthStatisticsPrepayment(JSONObject businessPayFeeDetail, List<FeeDto> feeDtos, List<FeeConfigDto> feeConfigDtos) {
|
//获取费用标识
|
String feeFlag = feeConfigDtos.get(0).getFeeFlag(); //1003006 为周期性费用;2006012 为一次性费用;4012024 间接性费用
|
ReportFeeMonthStatisticsPrepaymentPo reportFeeMonthStatisticsPrepaymentPo = new ReportFeeMonthStatisticsPrepaymentPo();
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_statisticsId));
|
reportFeeMonthStatisticsPrepaymentPo.setCommunityId(businessPayFeeDetail.getString("communityId"));
|
reportFeeMonthStatisticsPrepaymentPo.setObjType(feeDtos.get(0).getPayerObjType());
|
reportFeeMonthStatisticsPrepaymentPo.setObjId(feeDtos.get(0).getPayerObjId());
|
if (!StringUtil.isEmpty(feeDtos.get(0).getPayerObjType()) && feeDtos.get(0).getPayerObjType().equals("3333")) { //房屋
|
RoomDto roomDto = new RoomDto();
|
roomDto.setRoomId(feeDtos.get(0).getPayerObjId());
|
List<RoomDto> roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
|
Assert.listOnlyOne(roomDtos, "查询房屋错误！");
|
UnitDto unitDto = new UnitDto();
|
unitDto.setUnitId(roomDtos.get(0).getUnitId());
|
List<UnitDto> unitDtos = unitInnerServiceSMOImpl.queryUnits(unitDto);
|
Assert.listOnlyOne(unitDtos, "查询单元错误！");
|
FloorDto floorDto = new FloorDto();
|
floorDto.setFloorId(unitDtos.get(0).getFloorId());
|
List<FloorDto> floorDtos = floorInnerServiceSMOImpl.queryFloors(floorDto);
|
Assert.listOnlyOne(floorDtos, "查询楼栋错误！");
|
if (RoomDto.ROOM_TYPE_ROOM.equals(roomDtos.get(0).getRoomType())) {
|
reportFeeMonthStatisticsPrepaymentPo.setObjName(floorDtos.get(0).getFloorNum() + "栋" + unitDtos.get(0).getUnitNum() + "单元" + roomDtos.get(0).getRoomNum() + "室");
|
reportFeeMonthStatisticsPrepaymentPo.setObjNameNum(floorDtos.get(0).getFloorNum() + "-" + unitDtos.get(0).getUnitNum() + "-" + roomDtos.get(0).getRoomNum());
|
} else {
|
reportFeeMonthStatisticsPrepaymentPo.setObjName(floorDtos.get(0).getFloorNum() + "栋" + roomDtos.get(0).getRoomNum() + "室");
|
reportFeeMonthStatisticsPrepaymentPo.setObjNameNum(floorDtos.get(0).getFloorNum() + "-" + roomDtos.get(0).getRoomNum());
|
}
|
} else { //车辆
|
OwnerCarDto ownerCarDto = new OwnerCarDto();
|
ownerCarDto.setCarId(feeDtos.get(0).getPayerObjId());
|
List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
|
Assert.listOnlyOne(ownerCarDtos, "查询车辆错误！");
|
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
|
parkingSpaceDto.setPsId(ownerCarDtos.get(0).getPsId());
|
List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
|
Assert.listOnlyOne(parkingSpaceDtos, "查询车位错误！");
|
ParkingAreaDto parkingAreaDto = new ParkingAreaDto();
|
parkingAreaDto.setPaId(parkingSpaceDtos.get(0).getPaId());
|
List<ParkingAreaDto> parkingAreaDtos = parkingAreaInnerServiceSMOImpl.queryParkingAreas(parkingAreaDto);
|
Assert.listOnlyOne(parkingAreaDtos, "查询停车场错误！");
|
reportFeeMonthStatisticsPrepaymentPo.setObjName(ownerCarDtos.get(0).getCarNum() + "(" + parkingAreaDtos.get(0).getNum() + "停车场" + parkingSpaceDtos.get(0).getNum() + "车位)");
|
reportFeeMonthStatisticsPrepaymentPo.setObjNameNum(parkingAreaDtos.get(0).getNum() + "-" + parkingSpaceDtos.get(0).getNum() + "-" + ownerCarDtos.get(0).getCarNum());
|
}
|
reportFeeMonthStatisticsPrepaymentPo.setFeeId(businessPayFeeDetail.getString("feeId"));
|
reportFeeMonthStatisticsPrepaymentPo.setFeeName(feeDtos.get(0).getFeeName());
|
reportFeeMonthStatisticsPrepaymentPo.setConfigId(feeDtos.get(0).getConfigId());
|
reportFeeMonthStatisticsPrepaymentPo.setReceivableAmount(businessPayFeeDetail.getString("receivableAmount")); //应收
|
reportFeeMonthStatisticsPrepaymentPo.setPayableAmount(businessPayFeeDetail.getString("payableAmount")); //应缴
|
reportFeeMonthStatisticsPrepaymentPo.setReceivedAmount(businessPayFeeDetail.getString("receivedAmount")); //实收
|
reportFeeMonthStatisticsPrepaymentPo.setOweAmount("0"); //欠费
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentState("1"); //0 未缴费; 1 已缴费
|
reportFeeMonthStatisticsPrepaymentPo.setbillState("2"); //账单状态：0 正常；1 已逾期； 2已还清
|
reportFeeMonthStatisticsPrepaymentPo.setRemark("预付期费用账单已缴费生成");
|
reportFeeMonthStatisticsPrepaymentPo.setFeeBeginTime(businessPayFeeDetail.getString("startTime"));//计费开始时间
|
reportFeeMonthStatisticsPrepaymentPo.setFeeFinishTime(businessPayFeeDetail.getString("endTime")); //计费结束时间
|
reportFeeMonthStatisticsPrepaymentPo.setUpdateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
reportFeeMonthStatisticsPrepaymentPo.setPayTime(businessPayFeeDetail.getString("createTime"));
|
if (!StringUtil.isEmpty(feeFlag) && (feeFlag.equals("1003006") || feeFlag.equals("4012024"))) { //1003006 为周期性费用;2006012 为一次性费用;4012024 间接性费用
|
//获取缴费周期
|
String paymentCycle = feeConfigDtos.get(0).getPaymentCycle();
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentCycle(paymentCycle); //缴费周期
|
} else {
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentCycle(""); //缴费周期
|
}
|
reportFeeMonthStatisticsPrepaymentPo.setPayFeeFlag(feeFlag); //费用标识
|
reportFeeMonthStatisticsPrepaymentPo.setPrepaymentDetailId(businessPayFeeDetail.getString("detailId")); //费用明细id
|
reportFeeMonthStatisticsPrepaymentInnerServiceSMOImpl.saveReportFeeMonthStatisticsPrepayment(reportFeeMonthStatisticsPrepaymentPo);
|
}
|
}
|
