From 7c6e90dcb144f4c2dee4053ef6aa9531c23e5254 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期五, 03 九月 2021 03:43:29 +0800
Subject: [PATCH] 优化代码
---
service-front/src/main/java/com/java110/front/smo/assetImport/impl/ImportRoomFeeSMOImpl.java | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 58 insertions(+), 2 deletions(-)
diff --git a/service-front/src/main/java/com/java110/front/smo/assetImport/impl/ImportRoomFeeSMOImpl.java b/service-front/src/main/java/com/java110/front/smo/assetImport/impl/ImportRoomFeeSMOImpl.java
index b12d232..a801bbc 100755
--- a/service-front/src/main/java/com/java110/front/smo/assetImport/impl/ImportRoomFeeSMOImpl.java
+++ b/service-front/src/main/java/com/java110/front/smo/assetImport/impl/ImportRoomFeeSMOImpl.java
@@ -2,20 +2,32 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
+
+import com.java110.config.properties.code.Java110Properties;
+import com.java110.core.client.FtpUploadTemplate;
+import com.java110.core.client.OssUploadTemplate;
+
import com.java110.core.component.BaseComponentSMO;
import com.java110.core.context.IPageData;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.RoomDto;
+import com.java110.dto.fee.FeeDetailDto;
import com.java110.dto.fee.FeeDto;
import com.java110.entity.assetImport.ImportRoomFee;
import com.java110.entity.component.ComponentValidateResult;
import com.java110.front.smo.assetImport.IImportRoomFeeSMO;
+
+import com.java110.utils.cache.MappingCache;
+import com.java110.utils.constant.ServiceConstant;
+import com.java110.utils.util.*;
+
import com.java110.utils.constant.ServiceConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.ImportExcelUtils;
import com.java110.utils.util.StringUtil;
+
import com.java110.vo.ResultVo;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
@@ -28,6 +40,7 @@
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.multipart.MultipartFile;
+import org.thymeleaf.util.StringUtils;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
@@ -50,6 +63,16 @@
@Autowired
private RestTemplate restTemplate;
+
+ @Autowired
+ private FtpUploadTemplate ftpUploadTemplate;
+
+ @Autowired
+ private Java110Properties java110Properties;
+
+ @Autowired
+ private OssUploadTemplate ossUploadTemplate;
+
@Override
public ResponseEntity<String> importExcelData(IPageData pd, MultipartFile uploadFile) throws Exception {
@@ -85,11 +108,40 @@
}
@Override
+ public ResponseEntity<String> importFile(MultipartFile uploadFile) throws Exception {
+ try {
+ String fileName = "";
+ String ossSwitch = MappingCache.getValue(OSSUtil.DOMAIN, OSSUtil.OSS_SWITCH);
+ if (StringUtil.isEmpty(ossSwitch) || !OSSUtil.OSS_SWITCH_OSS.equals(ossSwitch)) {
+ fileName = ftpUploadTemplate.upload(uploadFile, java110Properties.getFtpServer(),
+ java110Properties.getFtpPort(), java110Properties.getFtpUserName(),
+ java110Properties.getFtpUserPassword(), java110Properties.getFtpPath());
+ } else {
+ fileName = ossUploadTemplate.upload(uploadFile, java110Properties.getFtpServer(),
+ java110Properties.getFtpPort(), java110Properties.getFtpUserName(),
+ java110Properties.getFtpUserPassword(), java110Properties.getFtpPath());
+ }
+ ResponseEntity<String> responseEntity = new ResponseEntity<String>(fileName, HttpStatus.OK);
+ return responseEntity;
+ } catch (Exception e) {
+ logger.error("涓婁紶鍚堝悓闄勪欢澶辫触 ", e);
+ return new ResponseEntity<String>("闈炲父鎶辨瓑锛屼笂浼犲悎鍚岄檮浠跺け璐ワ細" + e.getMessage(), HttpStatus.BAD_REQUEST);
+ }
+ }
+
+
+
+ @Override
+
public ResponseEntity<String> importTempData(IPageData pd) {
ComponentValidateResult result = this.validateStoreStaffCommunityRelationship(pd, restTemplate);
JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
ImportRoomFee importRoomFee = BeanConvertUtil.covertBean(paramIn,ImportRoomFee.class);
importRoomFee.setRoomId(paramIn.getString("objId"));
+ if(paramIn.containsKey("objType") && FeeDto.PAYER_OBJ_TYPE_CONTRACT.equals(paramIn.getString("objType"))){
+ importRoomFee.setContractId(paramIn.getString("objId"));
+ importRoomFee.setRoomId("");
+ }
List<ImportRoomFee> rooms = new ArrayList<ImportRoomFee>();
rooms.add(importRoomFee);
return dealExcelData(pd, rooms, result);
@@ -120,9 +172,9 @@
* @param roomFees 鎴垮眿璐圭敤
*/
private ResponseEntity<String> dealExcelCarData(IPageData pd,
- List<ImportRoomFee> roomFees,
+ List<ImportRoomFee> roomFees,
- ComponentValidateResult result) {
+ ComponentValidateResult result) {
ResponseEntity<String> responseEntity = null;
//淇濆瓨鍗曞厓淇℃伅 鍜� 妤兼爧淇℃伅
responseEntity = savedCarFees(pd, roomFees, result);
@@ -212,6 +264,10 @@
String apiUrl = ServiceConstant.SERVICE_API_URL + "/api/feeApi/importRoomFees";
+ if(!StringUtils.isEmpty(tmpImportRoomFee.get(0).getContractId())){
+ apiUrl = ServiceConstant.SERVICE_API_URL + "/api/feeApi/importContractFees";
+ }
+
ResponseEntity<String> responseEntity = this.callCenterService(restTemplate, pd, data.toJSONString(), apiUrl, HttpMethod.POST);
if (HttpStatus.OK != responseEntity.getStatusCode()) {
--
Gitblit v1.8.0