Lianxun_Java.git

			@@ -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;
			}
			}