package com.java110.fee.cmd.fee;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.annotation.Java110Cmd;
|
import com.java110.core.context.ICmdDataFlowContext;
|
import com.java110.core.event.cmd.Cmd;
|
import com.java110.core.event.cmd.CmdEvent;
|
import com.java110.dto.community.CommunityDto;
|
import com.java110.dto.dict.DictDto;
|
import com.java110.dto.fee.FeeDto;
|
import com.java110.dto.report.ReportQueryRecord;
|
import com.java110.intf.community.ICommunityInnerServiceSMO;
|
import com.java110.intf.dev.IDictV1InnerServiceSMO;
|
import com.java110.intf.fee.IReportFeeInnerServiceSMO;
|
import com.java110.po.fee.PayFeePo;
|
import com.java110.utils.exception.CmdException;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.BeanConvertUtil;
|
import com.java110.vo.FeeQueryParams;
|
import com.java110.vo.ResultVo;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.ResponseEntity;
|
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.util.*;
|
|
@Java110Cmd(serviceCode = "fee.reportFeeCmd")
|
public class ReportFeeCmd extends Cmd {
|
|
@Autowired
|
private IReportFeeInnerServiceSMO reportFeeInnerServiceSMOImpl;
|
|
@Autowired
|
private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
|
|
@Autowired
|
private IDictV1InnerServiceSMO dictV1InnerServiceSMOImpl;
|
|
@Override
|
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
|
Assert.hasKey(reqJson, "communityId", "请求报文中未包含小区编号");
|
}
|
|
@Override
|
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
|
int startYear = 2020;
|
CommunityDto communityDto = new CommunityDto();
|
communityDto.setCommunityId(reqJson.getString("communityId"));
|
List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
|
FeeQueryParams feeQueryParams = new FeeQueryParams();
|
feeQueryParams.setCommunityId(reqJson.getString("communityId"));
|
feeQueryParams.setStartYear(startYear);
|
int currentYear = java.time.Year.now().getValue();
|
feeQueryParams.setEndYear(currentYear + 2);
|
int endYear = feeQueryParams.getEndYear();
|
int doYear = endYear - startYear;
|
|
|
ReportQueryRecord reportQueryRecord = new ReportQueryRecord();
|
reportQueryRecord.setCommunityId(reqJson.getString("communityId"));
|
reportQueryRecord.setQueryStatus("0");
|
reportQueryRecord.setEndYear(currentYear+"");
|
List<ReportQueryRecord> reportQueryRecords = reportFeeInnerServiceSMOImpl.queryReport(BeanConvertUtil.beanCovertMap(reportQueryRecord));
|
|
if(reportQueryRecords.size()>0){
|
|
}
|
|
List<List<FeeDto>> reportFeeDtoLists = new LinkedList<>();
|
queryFee(reportFeeDtoLists ,reqJson);
|
|
int[] arr = new int[endYear - startYear + 1];
|
for (int i = startYear; i <= endYear; i++) {
|
arr[i-startYear] = i;
|
}
|
|
FeeDto feeDto = new FeeDto();
|
feeDto.setRepostList(reportFeeDtoLists);
|
feeDto.setYearArr(arr);
|
feeDto.setLength(doYear - 1 + 20);
|
|
reportQueryRecord.setCommunityId(reqJson.getString("communityId"));
|
reportQueryRecord.setQueryStatus("0");
|
reportQueryRecord.setEndYear(currentYear+"");
|
reportQueryRecord.setReportContent(JSONObject.toJSONString(feeDto));
|
|
int i = reportFeeInnerServiceSMOImpl.saveReport(BeanConvertUtil.beanCovertMap(reportQueryRecord));
|
|
ResultVo resultVo = new ResultVo(feeDto);
|
|
ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
|
|
context.setResponseEntity(responseEntity);
|
}
|
public void queryFee(List<List<FeeDto>> reportFeeDtoLists, JSONObject reqJson) {
|
int startYear = 2020;
|
CommunityDto communityDto = new CommunityDto();
|
communityDto.setCommunityId(reqJson.getString("communityId"));
|
List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
|
FeeQueryParams feeQueryParams = new FeeQueryParams();
|
feeQueryParams.setCommunityId(reqJson.getString("communityId"));
|
feeQueryParams.setStartYear(startYear);
|
int currentYear = java.time.Year.now().getValue();
|
feeQueryParams.setEndYear(currentYear + 2);
|
int endYear = feeQueryParams.getEndYear();
|
reportFeeDtoLists.add(new LinkedList<FeeDto>());
|
reportFeeDtoLists.add(new LinkedList<FeeDto>());
|
reportFeeDtoLists.add(new LinkedList<FeeDto>());
|
reportFeeDtoLists.add(new LinkedList<FeeDto>());
|
int ind = 1;
|
int doYear = endYear - startYear;
|
|
int[] arr = new int[endYear - startYear + 1];
|
for (int i = startYear; i <= endYear; i++) {
|
arr[i-startYear] = i;
|
}
|
List<Map> result = reportFeeInnerServiceSMOImpl.repostPaidInFee(feeQueryParams);
|
DictDto dictDto = new DictDto();
|
dictDto.setTableName("pay_fee_config");
|
dictDto.setTableColumns("fee_type_cd");
|
List<DictDto> dictDtos = dictV1InnerServiceSMOImpl.queryDicts(dictDto);
|
for (DictDto dictDto1 : dictDtos) {//类型
|
List<FeeDto> reportFeeDtos = new LinkedList<>();//该类型的数组
|
FeeDto feeDto = new FeeDto();
|
LinkedList<FeeDto> feeDtos = new LinkedList<>();//总的
|
int kg = 0;
|
for (Map map : result){
|
if(map.get("费用所属年份").equals("类型总计") && map.get("fee_type_cd").equals(dictDto1.getStatusCd())){
|
double[] doubles = new double[doYear - 1 + 20];
|
doubles[0] = ((BigDecimal) map.get("该年应缴总额")).doubleValue();
|
doubles[1] = ((BigDecimal) map.get("每月费用")).doubleValue();
|
doubles[2] = ((Long) map.get("应收月份数")).doubleValue();
|
doubles[3] = ((BigDecimal) map.get("当年收缴率")).doubleValue();
|
doubles[4] = ((BigDecimal) map.get("折扣金额")).doubleValue();
|
int inde = 0;
|
for (int i : arr){
|
if(i < currentYear){
|
inde++;
|
doubles[i - startYear + 5] = ((BigDecimal) map.get(i + "年实缴")).doubleValue();
|
}
|
}
|
doubles[inde + 5] =((BigDecimal) map.get("当年预算")).doubleValue();
|
doubles[inde + 6] =((BigDecimal) map.get(currentYear + "年实缴")).doubleValue();
|
doubles[inde + 7] =((BigDecimal) map.get("当年折扣总额")).doubleValue();
|
doubles[inde + 8] =((BigDecimal) map.get("当年欠款")).doubleValue();
|
|
for (int i = 1 ; i <= 12 ; i++){
|
doubles[inde + 8 + i] =((BigDecimal) map.get("当年"+(i < 10 ? "0"+i : i) +"月实缴")).doubleValue();
|
}
|
feeDto.setCurYear(dictDto1.getName()+"总计");
|
feeDto.setReport(doubles);
|
feeDto.setCount(ind);
|
|
}
|
}
|
if (feeDto.getCurYear() == null){
|
feeDto.setCurYear("类型总计");
|
}
|
if (feeDto.getReport() == null){
|
feeDto.setReport(new double[doYear - 1 + 20]);
|
}
|
if(feeDto.getFeeTypeCdName() == null) {
|
feeDto.setFeeTypeCdName(dictDto1.getName());
|
}
|
LinkedList<FeeDto> feeDtos1 = new LinkedList<>();
|
feeDtos1.add(feeDto);
|
reportFeeDtoLists.add(feeDtos1);//添加总金额的
|
feeDtos1 = new LinkedList<>();
|
feeDto = new FeeDto();
|
LinkedList<FeeDto> feeDtos2 = new LinkedList<>();
|
for (int i = startYear; i <= endYear; i++) {//年份
|
kg = 0;
|
for (Map map : result){
|
if(map.get("费用所属年份").equals(i+"") && map.get("fee_type_cd").equals(dictDto1.getStatusCd())){
|
double[] doubles = new double[doYear - 1 + 20];
|
doubles[0] = ((BigDecimal) map.get("该年应缴总额")).doubleValue();
|
doubles[1] = ((BigDecimal) map.get("每月费用")).doubleValue();
|
doubles[2] = ((Long) map.get("应收月份数")).doubleValue();
|
doubles[3] = ((BigDecimal) map.get("当年收缴率")).doubleValue();
|
doubles[4] = ((BigDecimal) map.get("折扣金额")).doubleValue();
|
int inde = 0;
|
for (int in : arr){
|
if(in < currentYear){
|
inde++;
|
doubles[in - startYear + 5] = ((BigDecimal) map.get(i + "年实缴")).doubleValue();
|
}
|
}
|
doubles[inde + 5] =((BigDecimal) map.get("当年预算")).doubleValue();
|
doubles[inde + 6] =((BigDecimal) map.get(currentYear + "年实缴")).doubleValue();
|
doubles[inde + 7] =((BigDecimal) map.get("当年折扣总额")).doubleValue();
|
doubles[inde + 8] =((BigDecimal) map.get("当年欠款")).doubleValue();
|
|
for (int in = 1 ; in <= 12 ; in++){
|
doubles[inde + 8 + in] =((BigDecimal) map.get("当年"+(in < 10 ? "0"+in : in) +"月实缴")).doubleValue();
|
}
|
feeDto = new FeeDto();
|
feeDto.setFeeTypeCdName(dictDto1.getName());
|
feeDto.setCurYear(String.valueOf(i));
|
feeDto.setReport(doubles);
|
feeDto.setCount(ind);
|
feeDtos2.add(feeDto);
|
kg = 1;
|
}
|
}
|
if(kg == 0){
|
feeDto = new FeeDto();
|
feeDto.setFeeTypeCdName(dictDto1.getName());
|
feeDto.setCurYear(String.valueOf(i));
|
feeDto.setReport(new double[doYear - 1 + 20]);
|
feeDto.setCount(ind);
|
feeDtos2.add(feeDto);
|
}
|
}
|
reportFeeDtoLists.add(feeDtos2);
|
if (ind == 1){
|
LinkedList linkedList = new LinkedList();
|
FeeDto feeDto1 = new FeeDto();
|
feeDto1.setCurYear("住宅物业费代收合计");
|
linkedList.add(feeDto1);
|
reportFeeDtoLists.add(linkedList);
|
}
|
if (ind == 2){
|
LinkedList linkedList = new LinkedList();
|
FeeDto feeDto1 = new FeeDto();
|
feeDto1.setCurYear("商铺物业费代收合计");
|
linkedList.add(feeDto1);
|
reportFeeDtoLists.add(linkedList);
|
}
|
if (ind == 3){
|
LinkedList linkedList = new LinkedList();
|
FeeDto feeDto1 = new FeeDto();
|
feeDto1.setCurYear("停车费合计（3+...+7）");
|
linkedList.add(feeDto1);
|
reportFeeDtoLists.add(linkedList);
|
}
|
if (ind == 8){
|
LinkedList linkedList = new LinkedList();
|
FeeDto feeDto1 = new FeeDto();
|
feeDto1.setCurYear("其他类合计（8+...+22）");
|
linkedList.add(feeDto1);
|
reportFeeDtoLists.add(linkedList);
|
}
|
ind ++;
|
}
|
}
|
}
|
