From 45149c4de50d945a27cbc7324ec0699f5b15df14 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期二, 27 二月 2024 13:57:47 +0800
Subject: [PATCH] 取消空格问题

---
 service-api/src/main/java/com/java110/api/smo/assetExport/impl/ExportRoomSMOImpl.java |  324 +++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 318 insertions(+), 6 deletions(-)

diff --git a/service-api/src/main/java/com/java110/api/smo/assetExport/impl/ExportRoomSMOImpl.java b/service-api/src/main/java/com/java110/api/smo/assetExport/impl/ExportRoomSMOImpl.java
index 37a2b80..e031cc2 100644
--- a/service-api/src/main/java/com/java110/api/smo/assetExport/impl/ExportRoomSMOImpl.java
+++ b/service-api/src/main/java/com/java110/api/smo/assetExport/impl/ExportRoomSMOImpl.java
@@ -3,19 +3,25 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.java110.api.smo.DefaultAbstractComponentSMO;
-import com.java110.core.component.BaseComponentSMO;
-import com.java110.core.context.IPageData;
-import com.java110.dto.fee.FeeDto;
-import com.java110.entity.component.ComponentValidateResult;
 import com.java110.api.smo.assetExport.IExportRoomSMO;
-import com.java110.utils.constant.ServiceConstant;
+import com.java110.core.context.IPageData;
+import com.java110.core.log.LoggerFactory;
+import com.java110.dto.room.RoomDto;
+import com.java110.dto.fee.FeeConfigDto;
+import com.java110.dto.fee.FeeDto;
+import com.java110.dto.owner.OwnerCarDto;
+import com.java110.dto.parking.ParkingSpaceDto;
+import com.java110.dto.system.ComponentValidateResult;
+import com.java110.intf.community.IParkingSpaceInnerServiceSMO;
+import com.java110.intf.community.IRoomV1InnerServiceSMO;
+import com.java110.intf.fee.IPayFeeConfigV1InnerServiceSMO;
+import com.java110.intf.user.IOwnerCarInnerServiceSMO;
 import com.java110.utils.util.Assert;
 import com.java110.utils.util.DateUtil;
 import org.apache.poi.ss.usermodel.*;
 import org.apache.poi.ss.util.CellRangeAddress;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.slf4j.Logger;
-import com.java110.core.log.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpMethod;
@@ -27,6 +33,8 @@
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @ClassName AssetImportSmoImpl
@@ -40,8 +48,26 @@
 public class ExportRoomSMOImpl extends DefaultAbstractComponentSMO implements IExportRoomSMO {
     private final static Logger logger = LoggerFactory.getLogger(ExportRoomSMOImpl.class);
 
+    public static final String TYPE_ROOM = "1001";
+    public static final String TYPE_PARKSPACE = "2002";
+    public static final String TYPE_CONTRACT = "3003"; //鍚堝悓
+
+    public static final int DEFAULT_ROW = 500;
+
     @Autowired
     private RestTemplate restTemplate;
+
+    @Autowired
+    private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IPayFeeConfigV1InnerServiceSMO payFeeConfigV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
 
     @Override
     public ResponseEntity<Object> exportExcelData(IPageData pd) throws Exception {
@@ -87,6 +113,207 @@
         // 淇濆瓨鏁版嵁
         return new ResponseEntity<Object>(context, headers, HttpStatus.OK);
     }
+
+    /**
+     * 瀵煎嚭鎴夸骇淇℃伅
+     *
+     * @param pd 鍓嶅彴鏁版嵁灏佽
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ResponseEntity<Object> exportRoomExcelData(IPageData pd) throws Exception {
+        ComponentValidateResult result = this.validateStoreStaffCommunityRelationship(pd, restTemplate);
+
+        JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
+        paramIn.put("storeId",result.getStoreId());
+        Assert.hasKeyAndValue(paramIn, "communityId", "璇锋眰涓湭鍖呭惈灏忓尯");
+        //Assert.hasKeyAndValue(paramIn, "floorIds", "璇锋眰涓湭鍖呭惈妤兼爧");
+        Assert.hasKeyAndValue(paramIn, "configIds", "璇锋眰涓湭鍖呭惈璐圭敤椤�");
+        Assert.hasKeyAndValue(paramIn, "type", "璇锋眰涓湭鍖呭惈绫诲瀷");
+
+        Workbook workbook = null;  //宸ヤ綔绨�
+        //宸ヤ綔琛�
+        workbook = new XSSFWorkbook();
+
+        //鏌ヨ璧勪骇鍜岃垂鐢ㄩ」
+        if (TYPE_ROOM.equals(paramIn.getString("type"))) {
+            getRoomAndConfigs(paramIn, workbook);
+        } else if (TYPE_PARKSPACE.equals(paramIn.getString("type"))) {
+            getParkspaceAndConfigs(paramIn, workbook);
+        }
+
+
+        ByteArrayOutputStream os = new ByteArrayOutputStream();
+        MultiValueMap headers = new HttpHeaders();
+        headers.add("content-type", "application/octet-stream;charset=UTF-8");
+        headers.add("Content-Disposition", "attachment;filename=customImport_" + DateUtil.getyyyyMMddhhmmssDateString() + ".xlsx");
+        headers.add("Pargam", "no-cache");
+        headers.add("Cache-Control", "no-cache");
+        //headers.add("Content-Disposition", "attachment; filename=" + outParam.getString("fileName"));
+        headers.add("Accept-Ranges", "bytes");
+        byte[] context = null;
+        try {
+            workbook.write(os);
+            context = os.toByteArray();
+            os.close();
+            workbook.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+            // 淇濆瓨鏁版嵁
+            return new ResponseEntity<Object>("瀵煎嚭澶辫触", HttpStatus.INTERNAL_SERVER_ERROR);
+        }
+        // 淇濆瓨鏁版嵁
+        return new ResponseEntity<Object>(context, headers, HttpStatus.OK);
+    }
+
+
+    private void getParkspaceAndConfigs(JSONObject paramIn, Workbook workbook) {
+        Sheet sheet = workbook.createSheet("鍒涘缓璐圭敤");
+        Row row = sheet.createRow(0);
+        Cell cell0 = row.createCell(0);
+        cell0.setCellValue("璐圭敤鍚嶇О: 璇峰~鍐欑郴缁熶腑璐圭敤绫诲瀷锛屽鐗╀笟璐癸紝鎶奸噾绛� 锛沑n璁¤垂璧峰鏃堕棿: " +
+                "璁¤垂璧峰鏃堕棿锛屾牸寮忎负YYYY-MM-DD锛沑n璁¤垂缁撴潫鏃堕棿锛屾牸寮忎负YYYY-MM-DD锛沑n" +
+                "寤鸿处鏃堕棿: 寤鸿处鏃堕棿锛屾牸寮忎负YYYY-MM-DD锛� \n 绫诲瀷锛氳〃鏄庢槸鍚堝悓 鎴垮眿 杩樻槸杞﹁締 鎴垮眿 1001 杞﹁締 2002 鍚堝悓 3003" +
+                "\n娉ㄦ剰锛氭墍鏈夊崟鍏冩牸寮忎负鏂囨湰锛岃璐圭粨鏉熸椂闂村彧鏈変竴娆℃�ц垂鐢ㄥ拰闂存帴鎬ц垂鐢ㄦ椂闇�瑕佸~鍐�");
+        CellStyle cs = workbook.createCellStyle();
+        cs.setWrapText(true);  //鍏抽敭
+        cell0.setCellStyle(cs);
+        row.setHeight((short) (200 * 10));
+        row = sheet.createRow(1);
+        row.createCell(0).setCellValue("杞︾墝鍙�");
+        row.createCell(1).setCellValue("绫诲瀷");
+        row.createCell(2).setCellValue("璐圭敤椤笽D");
+        row.createCell(3).setCellValue("鏀惰垂椤圭洰");
+        row.createCell(4).setCellValue("寤鸿处鏃堕棿");
+        row.createCell(5).setCellValue("璁¤垂璧峰鏃堕棿");
+        row.createCell(6).setCellValue("璁¤垂缁撴潫鏃堕棿");
+
+        ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
+        parkingSpaceDto.setCommunityId(paramIn.getString("communityId"));
+        parkingSpaceDto.setPaIds(paramIn.getString("paIds").split(","));
+        List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
+
+        if (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) {
+            return;
+        }
+
+        //鏌ヨ杞︾墝鍙�
+        List<OwnerCarDto> ownerCarDtos = getOwnerCars(parkingSpaceDtos);
+        if (ownerCarDtos == null || ownerCarDtos.size() < 1) {
+            return;
+        }
+        FeeConfigDto feeConfigDto = new FeeConfigDto();
+        feeConfigDto.setConfigIds(paramIn.getString("configIds").split(","));
+        feeConfigDto.setCommunityId(paramIn.getString("communityId"));
+        List<FeeConfigDto> feeConfigDtos = payFeeConfigV1InnerServiceSMOImpl.queryPayFeeConfigs(feeConfigDto);
+
+        if (feeConfigDtos == null || feeConfigDtos.size() < 1) {
+            return;
+        }
+
+        int roomIndex = 2;
+        for (OwnerCarDto tmpOwnerCarDto : ownerCarDtos) {
+            for (FeeConfigDto tmpFeeConfigDto : feeConfigDtos) {
+                row = sheet.createRow(roomIndex);
+                row.createCell(0).setCellValue(tmpOwnerCarDto.getCarNum());
+                row.createCell(1).setCellValue("2002");
+                row.createCell(2).setCellValue(tmpFeeConfigDto.getConfigId());
+                row.createCell(3).setCellValue(tmpFeeConfigDto.getFeeName());
+                row.createCell(4).setCellValue("");
+                row.createCell(5).setCellValue("");
+                roomIndex += 1;
+            }
+        }
+
+        CellRangeAddress region = new CellRangeAddress(0, 0, 0, 5);
+        sheet.addMergedRegion(region);
+    }
+
+    private List<OwnerCarDto> getOwnerCars(List<ParkingSpaceDto> parkingSpaceDtos) {
+        List<String> psIds = new ArrayList<>();
+        List<OwnerCarDto> tmpOwnerCarDtos = new ArrayList<>();
+        for (int roomIndex = 0; roomIndex < parkingSpaceDtos.size(); roomIndex++) {
+            psIds.add(parkingSpaceDtos.get(roomIndex).getPsId());
+            if (roomIndex % DEFAULT_ROW == 0 && roomIndex != 0) {
+                // 澶勭悊鎴垮眿璐圭敤
+                OwnerCarDto ownerCarDto = new OwnerCarDto();
+                ownerCarDto.setPsIds(psIds.toArray(new String[psIds.size()]));
+                ownerCarDto.setCommunityId(parkingSpaceDtos.get(roomIndex).getCommunityId());
+                tmpOwnerCarDtos.addAll(ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto));
+
+                psIds = new ArrayList<>();
+            }
+        }
+        if (psIds != null && psIds.size() > 0) {
+            OwnerCarDto ownerCarDto = new OwnerCarDto();
+            ownerCarDto.setPsIds(psIds.toArray(new String[psIds.size()]));
+            ownerCarDto.setCommunityId(parkingSpaceDtos.get(0).getCommunityId());
+            tmpOwnerCarDtos.addAll(ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto));
+        }
+        return tmpOwnerCarDtos;
+
+    }
+
+    private void getRoomAndConfigs(JSONObject paramIn, Workbook workbook) {
+        Sheet sheet = workbook.createSheet("鍒涘缓璐圭敤");
+        Row row = sheet.createRow(0);
+        Cell cell0 = row.createCell(0);
+        cell0.setCellValue("璐圭敤鍚嶇О: 璇峰~鍐欑郴缁熶腑璐圭敤绫诲瀷锛屽鐗╀笟璐癸紝鎶奸噾绛� 锛沑n璁¤垂璧峰鏃堕棿: " +
+                "璁¤垂璧峰鏃堕棿锛屾牸寮忎负YYYY-MM-DD锛沑n璁¤垂缁撴潫鏃堕棿锛屾牸寮忎负YYYY-MM-DD锛沑n" +
+                "寤鸿处鏃堕棿: 寤鸿处鏃堕棿锛屾牸寮忎负YYYY-MM-DD锛� \n 绫诲瀷锛氳〃鏄庢槸鍚堝悓 鎴垮眿 杩樻槸杞﹁締 鎴垮眿 1001 杞﹁締 2002 鍚堝悓 3003" +
+                "\n娉ㄦ剰锛氭墍鏈夊崟鍏冩牸寮忎负鏂囨湰锛岃璐圭粨鏉熸椂闂村彧鏈変竴娆℃�ц垂鐢ㄥ拰闂存帴鎬ц垂鐢ㄦ椂闇�瑕佸~鍐�");
+        CellStyle cs = workbook.createCellStyle();
+        cs.setWrapText(true);  //鍏抽敭
+        cell0.setCellStyle(cs);
+        row.setHeight((short) (200 * 10));
+        row = sheet.createRow(1);
+        row.createCell(0).setCellValue("鎴垮彿");
+        row.createCell(1).setCellValue("绫诲瀷");
+        row.createCell(2).setCellValue("璐圭敤椤笽D");
+        row.createCell(3).setCellValue("鏀惰垂椤圭洰");
+        row.createCell(4).setCellValue("寤鸿处鏃堕棿");
+        row.createCell(5).setCellValue("璁¤垂璧峰鏃堕棿");
+        row.createCell(6).setCellValue("璁¤垂缁撴潫鏃堕棿");
+        row.createCell(7).setCellValue("鎴垮眿鐘舵��");
+
+
+        RoomDto roomDto = new RoomDto();
+        roomDto.setCommunityId(paramIn.getString("communityId"));
+        roomDto.setFloorIds(paramIn.getString("floorIds").split(","));
+        List<RoomDto> roomDtos = roomV1InnerServiceSMOImpl.queryRooms(roomDto);
+
+        if (roomDtos == null || roomDtos.size() < 1) {
+            return;
+        }
+        FeeConfigDto feeConfigDto = new FeeConfigDto();
+        feeConfigDto.setConfigIds(paramIn.getString("configIds").split(","));
+        feeConfigDto.setCommunityId(paramIn.getString("communityId"));
+        List<FeeConfigDto> feeConfigDtos = payFeeConfigV1InnerServiceSMOImpl.queryPayFeeConfigs(feeConfigDto);
+
+        if (feeConfigDtos == null || feeConfigDtos.size() < 1) {
+            return;
+        }
+
+        int roomIndex = 2;
+        for (RoomDto tmpRoomDto : roomDtos) {
+            for (FeeConfigDto tmpFeeConfigDto : feeConfigDtos) {
+                row = sheet.createRow(roomIndex);
+                row.createCell(0).setCellValue(tmpRoomDto.getFloorNum() + "-" + tmpRoomDto.getUnitNum() + "-" + tmpRoomDto.getRoomNum());
+                row.createCell(1).setCellValue("1001");
+                row.createCell(2).setCellValue(tmpFeeConfigDto.getConfigId());
+                row.createCell(3).setCellValue(tmpFeeConfigDto.getFeeName());
+                row.createCell(4).setCellValue("");
+                row.createCell(5).setCellValue("");
+                row.createCell(6).setCellValue("");
+                row.createCell(7).setCellValue(tmpRoomDto.getStateName());
+                roomIndex += 1;
+            }
+        }
+        CellRangeAddress region = new CellRangeAddress(0, 0, 0, 5);
+        sheet.addMergedRegion(region);
+    }
+
 
     /**
      * 鏌ヨ杞﹁締
@@ -260,6 +487,91 @@
         sheet.addMergedRegion(region);
     }
 
+
+    /**
+     * 瀵煎嚭鎶ヨ〃
+     *
+     * @param pd 鍓嶅彴鏁版嵁灏佽
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ResponseEntity<Object> exportCustomReportTableData(IPageData pd) throws Exception {
+        ComponentValidateResult result = this.validateStoreStaffCommunityRelationship(pd, restTemplate);
+
+        JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
+
+        Assert.hasKeyAndValue(paramIn, "communityId", "璇锋眰涓湭鍖呭惈灏忓尯");
+        //Assert.hasKeyAndValue(paramIn, "floorIds", "璇锋眰涓湭鍖呭惈妤兼爧");
+
+        Workbook workbook = null;  //宸ヤ綔绨�
+        //宸ヤ綔琛�
+        workbook = new XSSFWorkbook();
+
+        //鏌ヨ璧勪骇鍜岃垂鐢ㄩ」
+        getCustomReportTableData(paramIn, workbook, pd);
+
+        ByteArrayOutputStream os = new ByteArrayOutputStream();
+        MultiValueMap headers = new HttpHeaders();
+        headers.add("content-type", "application/octet-stream;charset=UTF-8");
+        headers.add("Content-Disposition", "attachment;filename=customReportTableImport_" + DateUtil.getyyyyMMddhhmmssDateString() + ".xlsx");
+        headers.add("Pargam", "no-cache");
+        headers.add("Cache-Control", "no-cache");
+        //headers.add("Content-Disposition", "attachment; filename=" + outParam.getString("fileName"));
+        headers.add("Accept-Ranges", "bytes");
+        byte[] context = null;
+        try {
+            workbook.write(os);
+            context = os.toByteArray();
+            os.close();
+            workbook.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+            // 淇濆瓨鏁版嵁
+            return new ResponseEntity<Object>("瀵煎嚭澶辫触", HttpStatus.INTERNAL_SERVER_ERROR);
+        }
+        // 淇濆瓨鏁版嵁
+        return new ResponseEntity<Object>(context, headers, HttpStatus.OK);
+    }
+
+
+    private void getCustomReportTableData(JSONObject paramIn, Workbook workbook, IPageData pd) {
+        Sheet sheet = workbook.createSheet("鎶ヨ〃鏁版嵁");
+        String apiUrl = "reportCustomComponent.listReportCustomComponentData" + super.mapToUrlParam(paramIn);
+        ResponseEntity<String> responseEntity = this.callCenterService(restTemplate, pd, "", apiUrl, HttpMethod.GET);
+        if (responseEntity.getStatusCode() != HttpStatus.OK) {
+            return;
+        }
+        JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
+        if (paramOut.getIntValue("code") != 0) {
+            return;
+        }
+        JSONArray th = paramOut.getJSONObject("data").getJSONArray("th");
+
+        if (th == null || th.size() < 1) {
+            return;
+        }
+
+        Row row = sheet.createRow(0);
+        for (int thIndex = 0; thIndex < th.size(); thIndex++) {
+            row.createCell(thIndex).setCellValue(th.getString(thIndex));
+        }
+
+        JSONArray td = paramOut.getJSONObject("data").getJSONArray("td");
+
+        if (td == null || td.size() < 1) {
+            return;
+        }
+        JSONObject tdObj = null;
+        for (int tdIndex = 0; tdIndex < td.size(); tdIndex++) {
+            row = sheet.createRow(tdIndex + 1);
+            tdObj = td.getJSONObject(tdIndex);
+            for (int thIndex = 0; thIndex < th.size(); thIndex++) {
+                row.createCell(thIndex).setCellValue(tdObj.getString(th.getString(thIndex)));
+            }
+        }
+    }
+
     public RestTemplate getRestTemplate() {
         return restTemplate;
     }

--
Gitblit v1.8.0