From b173d31976fc4731b7c247d4038de92134eba317 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 29 六月 2023 11:42:17 +0800
Subject: [PATCH] Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity
---
service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeDetailRoomCmd.java | 85 +++++++++++++++++++++++++++++++++++++++++-
1 files changed, 83 insertions(+), 2 deletions(-)
diff --git a/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeDetailRoomCmd.java b/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeDetailRoomCmd.java
index 821ed37..1e315fb 100644
--- a/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeDetailRoomCmd.java
+++ b/service-report/src/main/java/com/java110/report/cmd/reportFeeMonthStatistics/QueryReportFeeDetailRoomCmd.java
@@ -1,19 +1,27 @@
package com.java110.report.cmd.reportFeeMonthStatistics;
+import com.alibaba.fastjson.JSONArray;
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.room.RoomDto;
import com.java110.dto.report.QueryStatisticsDto;
-import com.java110.intf.community.IRoomV1InnerServiceSMO;
import com.java110.report.statistics.IBaseDataStatistics;
import com.java110.report.statistics.IFeeStatistics;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
+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.ArrayList;
+import java.util.List;
+import java.util.Map;
/**
* 鏌ヨ鎴垮眿璐圭敤鏄庣粏琛�
@@ -28,6 +36,7 @@
@Autowired
private IBaseDataStatistics baseDataStatisticsImpl;
+
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
@@ -50,7 +59,79 @@
queryStatisticsDto.setFeeTypeCd(reqJson.getString("feeTypeCd"));
queryStatisticsDto.setOwnerName(reqJson.getString("ownerName"));
queryStatisticsDto.setLink(reqJson.getString("link"));
- baseDataStatisticsImpl.getRoomCount(queryStatisticsDto);
+ queryStatisticsDto.setPage(reqJson.getInteger("page"));
+ queryStatisticsDto.setRow(reqJson.getInteger("row"));
+ long count = baseDataStatisticsImpl.getRoomCount(queryStatisticsDto);
+ List<RoomDto> rooms = null;
+ if (count > 0) {
+ rooms = baseDataStatisticsImpl.getRoomInfo(queryStatisticsDto);
+ } else {
+ rooms = new ArrayList<>();
+ }
+ // todo 璁＄畻 鎴垮眿娆犺垂瀹炴敹鏁版嵁
+ JSONArray datas = computeRoomOweReceivedFee(rooms,queryStatisticsDto);
+
+ ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) queryStatisticsDto.getRow()), count, datas);
+
+ ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+ context.setResponseEntity(responseEntity);
+
+ }
+
+ /**
+ * 璁＄畻鎴垮眿娆犺垂 瀹炴敹璐圭敤
+ *
+ * @param rooms
+ * @return
+ */
+ private JSONArray computeRoomOweReceivedFee(List<RoomDto> rooms,QueryStatisticsDto queryStatisticsDto) {
+ if (rooms == null || rooms.size() < 1) {
+ return new JSONArray();
+ }
+
+ JSONArray datas = new JSONArray();
+ JSONObject data = null;
+
+ List<String> objIds = new ArrayList<>();
+ for (RoomDto roomDto : rooms) {
+ objIds.add(roomDto.getRoomId());
+ data = new JSONObject();
+ data.put("roomId",roomDto.getRoomId());
+ data.put("roomName",roomDto.getFloorNum()+"-"+roomDto.getUnitNum()+"-"+roomDto.getRoomNum());
+ data.put("ownerName",roomDto.getOwnerName());
+ data.put("ownerId",roomDto.getOwnerId());
+ data.put("link",roomDto.getLink());
+ datas.add(data);
+ }
+
+ queryStatisticsDto.setObjIds(objIds.toArray(new String[objIds.size()]));
+ List<Map> infos = feeStatisticsImpl.getObjFeeSummary(queryStatisticsDto);
+
+ if(infos == null || infos.size() < 1){
+ return datas;
+ }
+
+ BigDecimal oweFee = null;
+ BigDecimal receivedFee = null;
+ for(int dataIndex = 0; dataIndex < datas.size();dataIndex ++){
+ oweFee = new BigDecimal(0.00);
+ receivedFee = new BigDecimal(0.00);
+ data = datas.getJSONObject(dataIndex);
+ for(Map info : infos){
+ if(!data.get("roomId").toString().equals(info.get("objId"))){
+ continue;
+ }
+
+ oweFee = oweFee.add(new BigDecimal(info.get("oweFee").toString()));
+ receivedFee = receivedFee.add(new BigDecimal(info.get("receivedFee").toString()));
+ data.put("oweFee"+info.get("feeTypeCd").toString(),info.get("oweFee"));
+ data.put("receivedFee"+info.get("feeTypeCd").toString(),info.get("receivedFee"));
+ }
+ data.put("oweFee",oweFee.doubleValue());
+ data.put("receivedFee",receivedFee.doubleValue());
+ }
+
+ return datas;
}
}
--
Gitblit v1.8.0