package com.java110.job.importData.adapt; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.databind.ObjectMapper; import com.java110.core.factory.GenerateCodeFactory; import com.java110.dto.PropertyWhiteListFlowDto; import com.java110.dto.fee.*; import com.java110.dto.importData.ImportRoomFee; import com.java110.dto.log.AssetImportLogDetailDto; import com.java110.dto.owner.OwnerRoomRelDto; import com.java110.dto.payFee.PayFeeDetailDiscountDto; import com.java110.dto.room.RoomDto; import com.java110.dto.system.ComponentValidateResult; import com.java110.fee.api.FeeDiscountApi; import com.java110.intf.IImportPropertyWhiteListfFlowServiceSMO; import com.java110.intf.common.ICarInoutInnerServiceSMO; import com.java110.intf.community.IRoomInnerServiceSMO; import com.java110.intf.fee.*; import com.java110.intf.user.IOwnerCarInnerServiceSMO; import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO; import com.java110.job.cmd.importCarInout.CarInout; import com.java110.job.importData.DefaultImportData; import com.java110.job.importData.IImportDataAdapt; import com.java110.po.car.CarInoutPo; import com.java110.po.fee.FeeAttrPo; import com.java110.po.fee.PayFeeDetailPo; import com.java110.po.fee.PayFeePo; import com.java110.po.payFee.PayFeeDetailDiscountPo; import com.java110.utils.constant.StatusConstant; import com.java110.utils.exception.DAOException; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.DateUtil; import com.java110.utils.util.ListUtil; import com.java110.utils.util.StringUtil; import com.java110.vo.ResultVo; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Service; import java.io.IOException; import java.text.ParseException; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.time.temporal.ChronoUnit; import java.util.*; import java.util.stream.Collectors; /** * 房屋缴费信息导入 适配器 * 前端请求 时 必须传入 * param.append('importAdapt', "importRoomOwner"); */ @Service("importHistoryFeeDetailQueueData") public class ImportHistoryFeeDetailQueueDataAdapt extends DefaultImportData implements IImportDataAdapt { @Autowired private FeeDiscountApi feeDiscountApi; @Autowired private IImportFeeDetailInnerServiceSMO importFeeDetailInnerServiceSMOImpl; @Autowired private IRoomInnerServiceSMO roomInnerServiceSMOImpl; @Autowired private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl; @Autowired private IFeeInnerServiceSMO feeInnerServiceSMOImpl; @Autowired private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl; @Autowired private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl; @Autowired private IFeeAttrInnerServiceSMO feeAttrInnerServiceSMOImpl; @Autowired private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl; @Autowired private IRoomInnerServiceSMO iRoomInnerServiceSMOImpl; @Autowired private ICarInoutInnerServiceSMO carInoutInnerServiceSMOImpl; @Autowired private ImportCarHistoryFeeDetailQueueDataAdapt importCarHistoryFeeDetailQueueDataAdapt; @Autowired private IPayFeeDetailDiscountNewV1InnerServiceSMO payFeeDetailDiscountNewV1InnerServiceSMOImpl; @Autowired private ImportRoomFeeQueueDataAdapt importRoomFeeQueueDataAdapt; @Override public void importData(List assetImportLogDetailDtos) { for (AssetImportLogDetailDto assetImportLogDetailDto : assetImportLogDetailDtos) { try { importDatas(assetImportLogDetailDto); updateImportLogDetailState(assetImportLogDetailDto.getDetailId()); } catch (Exception e) { e.printStackTrace(); updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), e); } } } private void importDatas(AssetImportLogDetailDto assetImportLogDetailDto) { List importRoomFees = new ArrayList<>(); List importCarFees = new ArrayList<>(); List importContractFees = new ArrayList<>(); List carInoutPos = new ArrayList<>(); String communityId = assetImportLogDetailDto.getCommunityId(); JSONObject data = JSONObject.parseObject(assetImportLogDetailDto.getContent()); ImportRoomFee importRoomFee = BeanConvertUtil.covertBean(data, ImportRoomFee.class); // List roomTypes = Arrays.asList("住宅物业费","商铺物业费","维修收入","维修基金收入","电费及管理费","代收水费","各类押金","租金收入"); List carTypes = Arrays.asList("临时停车费", "业主产权过道停车费", "小业主产权车辆管理费","地下停车费","地面停车费"); List contractTypes = Arrays.asList("垃圾清运费","其他收入","补贴费用","场地使用费","电梯广告（业委会）","快递柜","电梯广告（联讯）","房产中介","非机动车管理费","其他广告"); if(importRoomFee.getSecondaryFeeTypeCd()!= null && importRoomFee.getSecondaryFeeTypeCd().equals("临时停车费-其他")){ CarInoutPo carInout = new CarInoutPo(); carInout.setCommunityId(communityId); carInout.setCarNum("A888888"); carInout.setVehicleType("temp"); carInout.setDirection("entry"); carInout.setState("100300"); carInout.setInTime(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).getString("chargeStart")); carInout.setStatusCd("0"); carInout.setCreateTime(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).getString("inputTime")); carInout.setbId(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).getString("batchId")); carInout.setInoutId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_inoutId)); carInout.setDetailId(assetImportLogDetailDto.getDetailId()); carInoutPos.add(carInout); // 如果有结束时间，创建新的对象作为出口记录 if(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).containsKey("chargeEnd")){ // 创建新的对象，而不是修改已添加的对象 CarInoutPo exitCarInout = new CarInoutPo(); // 复制基本属性 exitCarInout.setbId(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).getString("batchId")); exitCarInout.setCommunityId(carInout.getCommunityId()); exitCarInout.setCarNum(carInout.getCarNum()); exitCarInout.setVehicleType(carInout.getVehicleType()); exitCarInout.setInTime(carInout.getInTime()); exitCarInout.setStatusCd(carInout.getStatusCd()); exitCarInout.setCreateTime(carInout.getCreateTime()); // 设置出口相关属性 exitCarInout.setOutTime(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).getString("chargeEnd")); exitCarInout.setDirection("exit"); exitCarInout.setState("100400"); exitCarInout.setInoutId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_inoutId)); exitCarInout.setPaymentAmount(JSONObject.parseObject(assetImportLogDetailDto.getContent().toString()).getString("chargeAmount")); exitCarInout.setDetailId(assetImportLogDetailDto.getDetailId()); carInoutPos.add(exitCarInout); } } else if(contractTypes.contains(importRoomFee.getSecondaryFeeTypeCd())){ importRoomFee.setFeeName(data.getString("secondaryFeeTypeCd")); importRoomFee.setCommunityId(communityId); importRoomFee.setDetailId(assetImportLogDetailDto.getDetailId()); importRoomFee.setStartTime(data.getString("chargeStart")); importRoomFee.setEndTime(data.getString("chargeEnd").split(" ")[0]+" 23:59:59"); importRoomFee.setCreateTime(data.getString("inputTime")); importRoomFee.setReceivableAmount(data.getString("bankDepositAmount")); importRoomFee.setAmount(data.getString("chargeAmount")); importRoomFee.setStaffName(data.getString("charger")); importRoomFee.setIsContractFee("O"); importRoomFee.setOpenInv(data.containsKey("invoiceReceiptNo") && data.getString("invoiceReceiptNo") != null ? "Y" : "N"); importRoomFee.setObjType("7777"); LocalDateTime startDate = LocalDateTime.parse(importRoomFee.getStartTime(), formatter); LocalDateTime endDate = LocalDateTime.parse(importRoomFee.getEndTime(), formatter); importRoomFee.setCycle(String.valueOf(ChronoUnit.MONTHS.between(startDate, endDate))); // if(importRoomFee.getPayerObjName()) importCarFees.add(importRoomFee); } else if(carTypes.contains(JSONObject.parseObject(assetImportLogDetailDto.getContent()).get("category22"))){ importRoomFee.setCommunityId(communityId); importRoomFee.setFeeName(data.getString("secondaryFeeTypeCd")); importRoomFee.setDetailId(assetImportLogDetailDto.getDetailId()); importRoomFee.setStartTime(data.getString("chargeStart")); importRoomFee.setEndTime(data.getString("chargeEnd").split(" ")[0]+" 23:59:59"); importRoomFee.setCreateTime(data.getString("inputTime")); importRoomFee.setReceivableAmount(data.getString("bankDepositAmount")); importRoomFee.setAmount(data.getString("chargeAmount")); importRoomFee.setCarNum(data.getString("licensePlate")); importRoomFee.setStaffName(data.getString("charger")); importRoomFee.setOpenInv(data.containsKey("invoiceReceiptNo") && data.getString("invoiceReceiptNo") != null ? "Y" : "N"); // if(importRoomFee.getPayerObjName()) importRoomFee.setObjType("6666"); LocalDateTime startDate = LocalDateTime.parse(importRoomFee.getStartTime(), formatter); LocalDateTime endDate = LocalDateTime.parse(importRoomFee.getEndTime(), formatter); importRoomFee.setCycle(String.valueOf(ChronoUnit.MONTHS.between(startDate, endDate))); importCarFees.add(importRoomFee); } else{ importRoomFee.setCommunityId(communityId); importRoomFee.setFeeName(data.getString("secondaryFeeTypeCd")); importRoomFee.setDetailId(assetImportLogDetailDto.getDetailId()); importRoomFee.setStartTime(data.getString("chargeStart")); importRoomFee.setEndTime(data.getString("chargeEnd").split(" ")[0]+" 23:59:59"); importRoomFee.setCreateTime(data.getString("inputTime")); importRoomFee.setReceivableAmount(data.getString("bankDepositAmount")); importRoomFee.setAmount(data.getString("chargeAmount")); importRoomFee.setStaffName(data.getString("charger")); importRoomFee.setOpenInv(data.containsKey("invoiceReceiptNo") && data.getString("invoiceReceiptNo") != null ? "Y" : "N"); // if(importRoomFee.getPayerObjName()) importRoomFees.add(importRoomFee); } importFeeDetailsByCarInout(carInoutPos); if (ListUtil.isNull(importRoomFees) && ListUtil.isNull(importCarFees)) { return; } if(!(ListUtil.isNull(importRoomFees))){ importFeeDetails(importRoomFees.get(0).getStoreId(), importRoomFees.get(0).getUserId(), importRoomFees, importRoomFees.get(0).getBatchId()); } if(!(ListUtil.isNull(importCarFees))){ importCarHistoryFeeDetailQueueDataAdapt.importCarFeeDetails(importCarFees.get(0).getStoreId(), importCarFees.get(0).getUserId(), importCarFees, importCarFees.get(0).getBatchId()); } } private void importFeeDetailsByCarInout(List carInoutPos) { for (CarInoutPo carInoutPo : carInoutPos) { try { ArrayList carInoutPos1 = new ArrayList<>(); carInoutPos1.add(carInoutPo); carInoutInnerServiceSMOImpl.batchSaveCarInout2(carInoutPos1); updateImportLogDetailState(carInoutPo.getDetailId()); }catch (Exception e){ updateImportLogDetailState(carInoutPo.getDetailId(),e); throw new IllegalArgumentException(e.getMessage()); } } } private void importFeeDetails(String storeId, String userId, List importRoomFees, String batchId) { importRoomFees = roomInnerServiceSMOImpl.freshRoomIds(importRoomFees); String endTime = ""; for (ImportRoomFee importRoomFee : importRoomFees) { endTime = importRoomFee.getEndTime(); if (!endTime.contains(":")) { endTime += " 23:59:59"; importRoomFee.setEndTime(endTime); } try { if (StringUtil.isEmpty(importRoomFee.getRoomId())) { continue; } importFeeDetail(importRoomFee, storeId, userId, batchId); // feeDiscountApi updateImportLogDetailState(importRoomFee.getDetailId()); } catch (Exception e) { e.printStackTrace(); updateImportLogDetailState(importRoomFee.getDetailId(), e); throw new IllegalArgumentException(e.getMessage()); } } } DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); /** * 导入 费用历史 * * @param importRoomFee */ private void importFeeDetail(ImportRoomFee importRoomFee, String storeId, String userId, String batchId) { RoomDto roomDto = new RoomDto(); // roomDto.setDoorRoomNum(importRoomFee.getDoorRoomNum()); roomDto.setCommunityId(importRoomFee.getCommunityId()); if(importRoomFee.getDoorRoomNum()!=null){ String[] split = importRoomFee.getDoorRoomNum().split("-"); if(split.length==2){ roomDto.setDoorRoomNum(importRoomFee.getDoorRoomNum()); }else if(split.length > 2){ roomDto.setFloorNum(split[0]); roomDto.setUnitNum(split[1]); roomDto.setRoomNum(split[2]); } } List roomDtos = iRoomInnerServiceSMOImpl.queryRooms(roomDto); try { importRoomFee.setRoomId(roomDtos.get(0).getRoomId()); }catch (Exception e){ throw new IllegalArgumentException("门室号"+importRoomFee.getDoorRoomNum()+"未查询到房屋"); } FeeDto feeDto2 = new FeeDto(); feeDto2.setFeeName(importRoomFee.getFeeName()); feeDto2.setPayerObjId(importRoomFee.getRoomId()); feeDto2.setCommunityId(importRoomFee.getCommunityId()); List feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto2); if(feeDtos.size() == 0){ updateImportLogDetailState(importRoomFee.getDetailId(),new IllegalArgumentException("费用项"+importRoomFee.getFeeName()+"不存在")); throw new IllegalArgumentException("费用项"+importRoomFee.getFeeName()+"不存在"); } importRoomFee.setPayObjId(importRoomFee.getRoomId()); if (ListUtil.isNull(feeDtos)) { throw new IllegalArgumentException("查询不到该记录的费用项："+importRoomFee.getFeeName()); // List feeAttrsPos = new ArrayList<>(); // PayFeePo payFeePo = new PayFeePo(); // payFeePo.setCommunityId(importRoomFee.getCommunityId()); // payFeePo.setConfigId(feeDto.getConfigId()); // payFeePo.setPayerObjType(FeeDto.PAYER_OBJ_TYPE_ROOM); // payFeePo.setStartTime(importRoomFee.getStartTime()); // payFeePo.setEndTime(DateUtil.getNextSecTime(importRoomFee.getEndTime())); // payFeePo.setAmount(importRoomFee.getAmount()); // payFeePo.setFeeFlag(tmpFeeConfigDto.getFeeFlag()); // payFeePo.setFeeTypeCd(tmpFeeConfigDto.getFeeTypeCd()); // payFeePo.setIncomeObjId(storeId); // payFeePo.setBatchId(batchId); // if (FeeDto.FEE_FLAG_ONCE.equals(tmpFeeConfigDto.getFeeFlag())) { // payFeePo.setState(FeeDto.STATE_FINISH); // } else { // payFeePo.setState(FeeDto.STATE_DOING); // } // payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId)); // payFeePo.setPayerObjId(importRoomFee.getRoomId()); // payFeePo.setUserId(userId); // payFeePo.setCreateTime(importRoomFee.getCreateTime()); // payFeePos = new ArrayList<>(); // payFeePos.add(payFeePo); // feeInnerServiceSMOImpl.saveFee(payFeePos); // // //查询业主信息 // OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto(); // ownerRoomRelDto.setRoomId(importRoomFee.getRoomId()); // List ownerRoomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto); // if (ownerRoomRelDtos != null && ownerRoomRelDtos.size() > 0) { // if (!FeeDto.FEE_FLAG_CYCLE.equals(tmpFeeConfigDto.getFeeFlag())) { // feeAttrsPos.add(addFeeAttr(payFeePo, FeeAttrDto.SPEC_CD_ONCE_FEE_DEADLINE_TIME, // importRoomFee.getEndTime())); // } // feeAttrsPos.add(addFeeAttr(payFeePo, FeeAttrDto.SPEC_CD_OWNER_ID, ownerRoomRelDtos.get(0).getOwnerId())); // feeAttrsPos.add(addFeeAttr(payFeePo, FeeAttrDto.SPEC_CD_OWNER_LINK, ownerRoomRelDtos.get(0).getLink())); // feeAttrsPos.add(addFeeAttr(payFeePo, FeeAttrDto.SPEC_CD_OWNER_NAME, ownerRoomRelDtos.get(0).getOwnerName())); // feeAttrInnerServiceSMOImpl.saveFeeAttrs(feeAttrsPos); // } // // // feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto); } if(feeDtos.size()>1){ throw new IllegalArgumentException("该初始化缴费记录信息中包含多个费用记录"+importRoomFee.getFeeName()); } for (FeeDto tmpFeeDto : feeDtos) { if(DateUtil.getDateFromStringB(importRoomFee.getEndTime()).getTime() > tmpFeeDto.getMaxEndTime().getTime()){ throw new IllegalArgumentException("该费用记录结束时间大于费用记录最大缴费时间"); } doImportFeeDetail(tmpFeeDto, importRoomFee); } } public FeeAttrPo addFeeAttr(PayFeePo payFeePo, String specCd, String value) { FeeAttrPo feeAttrPo = new FeeAttrPo(); feeAttrPo.setCommunityId(payFeePo.getCommunityId()); feeAttrPo.setSpecCd(specCd); feeAttrPo.setValue(value); feeAttrPo.setFeeId(payFeePo.getFeeId()); feeAttrPo.setAttrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId)); return feeAttrPo; } private void doImportFeeDetail(FeeDto tmpFeeDto, ImportRoomFee importRoomFee) { PayFeeDetailPo payFeeDetailPo = new PayFeeDetailPo(); payFeeDetailPo.setCommunityId(importRoomFee.getCommunityId()); payFeeDetailPo.setReceivedAmount(importRoomFee.getAmount()); payFeeDetailPo.setPrimeRate("1.0"); payFeeDetailPo.setFeeId(tmpFeeDto.getFeeId()); payFeeDetailPo.setStartTime(importRoomFee.getStartTime()); payFeeDetailPo.setRemark(importRoomFee.getRemark()); payFeeDetailPo.setCreateTime(importRoomFee.getCreateTime()); payFeeDetailPo.setState("1400"); payFeeDetailPo.setCashierName(importRoomFee.getStaffName()); payFeeDetailPo.setPayOrderId(importRoomFee.getPayObjId()); payFeeDetailPo.setB("T"); double cycle = (DateUtil.dayCompare( DateUtil.getDateFromStringA(payFeeDetailPo.getStartTime()), DateUtil.getDateFromStringA(importRoomFee.getEndTime()) )); int count = feeDetailInnerServiceSMOImpl.queryFeeDetailsCountByVo(payFeeDetailPo); payFeeDetailPo.setPayableAmount(importRoomFee.getAmount()); payFeeDetailPo.setCycles(importRoomFee.getCycle()); payFeeDetailPo.setCycles(cycle+""); payFeeDetailPo.setEndTime(importRoomFee.getEndTime()); if (count > 0) { throw new IllegalStateException("重复的缴费记录"); } PayFeeDetailDiscountPo payFeeDetailDiscount = new PayFeeDetailDiscountPo(); try { ResponseEntity resultVo = feeDiscountApi.computeFeeDiscount(tmpFeeDto.getFeeId(), tmpFeeDto.getCommunityId(), 105, importRoomFee.getPayObjId(), tmpFeeDto.getPayerObjType(), importRoomFee.getEndTime(), importRoomFee.getEndTime(), importRoomFee.getStartTime(), 1, 20); // 2. 从 ResultVo 中获取 data 并强转为目标类型 if (resultVo != null) { // 假设 data 字段存储的是 List JSONArray data = (JSONArray) JSONObject.parseObject(resultVo.getBody()).get("data"); if(data.size() > 0) { JSONObject o = (JSONObject) data.get(0); String discountPrice = o.get("discountPrice").toString(); String discountId = o.get("discountId").toString(); payFeeDetailPo.setDiscountAmount(discountPrice); payFeeDetailPo.setReceivableAmount((Double.parseDouble(payFeeDetailPo.getReceivedAmount()) + Double.parseDouble(payFeeDetailPo.getDiscountAmount()))+""); payFeeDetailDiscount.setDiscountId(discountId); payFeeDetailDiscount.setDiscountPrice(discountPrice); }else{ payFeeDetailPo.setReceivableAmount(payFeeDetailPo.getReceivedAmount()+""); } } } catch (ParseException e) { throw new RuntimeException(e.getMessage()); } payFeeDetailPo.setDetailId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_detailId)); if(importRoomFee.getOpenInv() != null){ payFeeDetailPo.setOpenInvoice(importRoomFee.getOpenInv()); } int saved = feeDetailInnerServiceSMOImpl.saveFeeDetail(payFeeDetailPo); FeeDetailDto feeDetailDto = new FeeDetailDto(); feeDetailDto.setDetailId(payFeeDetailPo.getDetailId()); List feeDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto); if (payFeeDetailDiscount.getDiscountId() != null) { payFeeDetailDiscount.setDetailId(payFeeDetailPo.getDetailId()); payFeeDetailDiscount.setStatusCd("0"); payFeeDetailDiscount.setCommunityId(feeDtos.get(0).getCommunityId()); payFeeDetailDiscount.setFeeId(feeDtos.get(0).getFeeId()); payFeeDetailDiscount.setDetailDiscountId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_discountId)); payFeeDetailDiscountNewV1InnerServiceSMOImpl.savePayFeeDetailDiscountNew(payFeeDetailDiscount); } if (saved < 1) { return; } FeeDto fee = new FeeDto(); fee.setFeeId(tmpFeeDto.getFeeId()); FeeDto feeInfo = feeInnerServiceSMOImpl.queryFees(fee).get(0); // int i = feeInnerServiceSMOImpl.updateFee(feeInfo); if (tmpFeeDto.getEndTime().getTime() >= DateUtil.getDateFromStringB(importRoomFee.getEndTime()).getTime()) { return; } //如果结束时间小于 缴费结束时间则延期 PayFeePo payFeePo = new PayFeePo(); payFeePo.setCommunityId(importRoomFee.getCommunityId()); payFeePo.setStatusCd(StatusConstant.STATUS_CD_VALID); payFeePo.setFeeId(tmpFeeDto.getFeeId()); String[] arr = importRoomFee.getEndTime().split(" "); if (arr.length >= 2 &&arr[1].equals("23:59:59")){ payFeePo.setEndTime(DateUtil.getNextSecTime(importRoomFee.getEndTime())); } if (FeeDto.FEE_FLAG_ONCE.equals(tmpFeeDto.getFeeFlag())) { payFeePo.setState(FeeDto.STATE_FINISH); } feeInnerServiceSMOImpl.updateFee(payFeePo); feeInfo = feeInnerServiceSMOImpl.queryFees(fee).get(0); if (DateUtil.getFormatTimeStringB(feeInfo.getEndTime()).equals(DateUtil.getFormatTimeStringB(feeInfo.getMaxEndTime()))) { PayFeePo payFee = new PayFeePo(); payFee.setFeeId(feeInfo.getFeeId()); payFee.setState(FeeDto.STATE_FINISH); int i = feeInnerServiceSMOImpl.updateFee(payFee); } } }