package com.java110.api.smo.assetImport.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.api.smo.DefaultAbstractComponentSMO;
|
import com.java110.api.smo.assetImport.IImportResourceStoreSMO;
|
import com.java110.core.context.IPageData;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.importData.ImportOwnerRoomDto;
|
import com.java110.dto.importData.ImportResourceStoreDto;
|
import com.java110.dto.system.ComponentValidateResult;
|
import com.java110.intf.community.IImportOwnerRoomInnerServiceSMO;
|
import com.java110.utils.util.Assert;
|
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;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.text.ParseException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
//@Service("importResourceStoreSMOImpl")
|
public class ImportResourceStoreSMOImpl extends DefaultAbstractComponentSMO implements IImportResourceStoreSMO {
|
|
private final static Logger logger = LoggerFactory.getLogger(ImportResourceStoreSMOImpl.class);
|
|
public static final int DEFAULT_ROWS = 500;
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Autowired
|
private IImportOwnerRoomInnerServiceSMO importOwnerRoomInnerServiceSMOImpl;
|
|
|
@Override
|
public ResponseEntity<String> importExcelData(IPageData pd, MultipartFile uploadFile) throws Exception {
|
try {
|
ComponentValidateResult result = this.validateStoreStaffCommunityRelationship(pd, restTemplate);
|
//InputStream is = uploadFile.getInputStream();
|
Workbook workbook = ImportExcelUtils.createWorkbook(uploadFile); //工作簿
|
List<ImportResourceStoreDto> resourceStoreDtos = new ArrayList<ImportResourceStoreDto>();
|
//封装对象
|
getResourceStores(workbook, resourceStoreDtos, result);
|
|
//数据格式校验
|
validateRoomInfo(resourceStoreDtos);
|
|
// 保存数据
|
return dealExcelData(pd, resourceStoreDtos, result);
|
} catch (Exception e) {
|
logger.error("导入失败 ", e);
|
return new ResponseEntity<String>("非常抱歉，您填写的模板数据有误：" + e.getMessage(), HttpStatus.BAD_REQUEST);
|
}
|
}
|
|
|
/**
|
* 数据格式校验
|
*
|
* @param resourceStoreDtos
|
*/
|
private void validateRoomInfo(List<ImportResourceStoreDto> resourceStoreDtos) {
|
ImportOwnerRoomDto importOwnerRoomDto = null;
|
ImportOwnerRoomDto tmpImportOwnerRoomDto = null;
|
boolean hasOwnerType = false;
|
|
}
|
|
/**
|
* 获取业主车辆信息
|
*
|
* @param workbook
|
* @param resourceStoreDtos
|
*/
|
private void getResourceStores(Workbook workbook, List<ImportResourceStoreDto> resourceStoreDtos, ComponentValidateResult result) throws ParseException {
|
Sheet sheet = null;
|
sheet = ImportExcelUtils.getSheet(workbook, "物品信息");
|
List<Object[]> oList = ImportExcelUtils.listFromSheet(sheet);
|
ImportResourceStoreDto resourceStoreDto = null;
|
for (int osIndex = 0; osIndex < oList.size(); osIndex++) {
|
|
Object[] os = oList.get(osIndex);
|
|
if (osIndex == 0 || osIndex == 1) { // 第一行是 头部信息 直接跳过
|
continue;
|
}
|
if (os == null || StringUtil.isNullOrNone(os[0])) {
|
continue;
|
}
|
Assert.hasValue(os[1], (osIndex + 1) + "行物品名称不能为空");
|
// Assert.hasValue(os[2], (osIndex + 1) + "行物品编号不能为空");
|
os[2] = os[2] == null ? "" : os[2];
|
os[3] = os[3] == null ? "0" : os[3];
|
os[4] = os[4] == null ? "0" : os[4];
|
os[6] = os[6] == null ? "0" : os[6];
|
os[7] = os[7] == null ? "0" : os[7];
|
os[8] = os[8] == null ? "0" : os[8];
|
os[9] = os[9] == null ? "" : os[9];
|
os[10] = os[10] == null ? "Y" : os[10];
|
os[5] = os[5] == null ? "0" : os[5];
|
// Assert.hasValue(os[3], (osIndex + 1) + "行物品单价不能为空");
|
// Assert.hasValue(os[4], (osIndex + 1) + "行物品库存不能为空");
|
// Assert.hasValue(os[5], (osIndex + 1) + "行物品单位不能为空");
|
// Assert.hasValue(os[6], (osIndex + 1) + "行物品对外最低售价不能为空");
|
// Assert.hasValue(os[7], (osIndex + 1) + "行物品对外最高售价不能为空");
|
// Assert.hasValue(os[8], (osIndex + 1) + "行物品告警库存不能为空");
|
// Assert.hasValue(os[9], (osIndex + 1) + "行物品类型不能为空");
|
// Assert.hasValue(os[10], (osIndex + 1) + "行是否固定物品不能为空");
|
resourceStoreDto = new ImportResourceStoreDto();
|
resourceStoreDto.setCommunityId(result.getCommunityId());
|
resourceStoreDto.setResName(os[1].toString());
|
resourceStoreDto.setResCode(os[2].toString());
|
resourceStoreDto.setPrice(os[3].toString());
|
resourceStoreDto.setStock(os[4].toString());
|
resourceStoreDto.setUnitCode(os[5].toString());
|
resourceStoreDto.setOutLowPrice(os[6].toString());
|
resourceStoreDto.setOutHighPrice(os[7].toString());
|
resourceStoreDto.setWarningStock(os[8].toString());
|
resourceStoreDto.setRstName(os[9] == "" ? "未分类" : os[9].toString());
|
resourceStoreDto.setIsFixed(os[10].toString());
|
|
if (os.length > 11 && !StringUtil.isNullOrNone(os[11])) {
|
resourceStoreDto.setRemark(os[11].toString());
|
}
|
resourceStoreDtos.add(resourceStoreDto);
|
|
}
|
}
|
|
|
/**
|
* 处理房产信息
|
*/
|
private ResponseEntity<String> dealExcelData(IPageData pd, List<ImportResourceStoreDto> resourceStoreDtos, ComponentValidateResult result) {
|
ResponseEntity<String> responseEntity = null;
|
|
List<ImportResourceStoreDto> tmpImportResourceStoreDtos = new ArrayList<>();
|
int flag = 0;
|
|
JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
|
|
int successCount = 0;
|
JSONObject data = new JSONObject();
|
data.put("userId", result.getUserId());
|
data.put("userName", result.getUserName());
|
data.put("storeId", result.getStoreId());
|
data.put("communityId", result.getCommunityId());
|
data.put("shId", paramIn.getString("shId"));
|
|
try {
|
for (int roomIndex = 0; roomIndex < resourceStoreDtos.size(); roomIndex++) {
|
tmpImportResourceStoreDtos.add(resourceStoreDtos.get(roomIndex));
|
if (tmpImportResourceStoreDtos.size() > DEFAULT_ROWS) {
|
flag = saveResourceStore(pd, tmpImportResourceStoreDtos, data);
|
tmpImportResourceStoreDtos = new ArrayList<>();
|
|
successCount += flag;
|
}
|
}
|
|
if (tmpImportResourceStoreDtos.size() > 0) {
|
flag = saveResourceStore(pd, tmpImportResourceStoreDtos, data);
|
|
successCount += flag;
|
}
|
} catch (Exception e) {
|
logger.error("导入失败", e);
|
//按批次做撤销功能
|
throw e;
|
}
|
|
return ResultVo.createResponseEntity("总共导入:" + tmpImportResourceStoreDtos.size() + ";成功导入：" + successCount + ";导入失败：" + (tmpImportResourceStoreDtos.size() - successCount));
|
}
|
|
/**
|
* 创建费用
|
*
|
* @param pd
|
* @param tmpImportResourceStoreDtos
|
*/
|
private int saveResourceStore(IPageData pd, List<ImportResourceStoreDto> tmpImportResourceStoreDtos, JSONObject data) {
|
|
JSONArray importRoomFees = JSONArray.parseArray(JSONObject.toJSONString(tmpImportResourceStoreDtos));
|
data.put("importResourceStoreDtos", importRoomFees);
|
|
String apiUrl = "resourceStore.importResourceStore";
|
|
ResponseEntity<String> responseEntity = this.callCenterService(restTemplate, pd, data.toJSONString(), apiUrl, HttpMethod.POST);
|
|
if (responseEntity.getStatusCode() != HttpStatus.OK) {
|
throw new IllegalArgumentException(responseEntity.getBody());
|
}
|
|
JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
|
if (ResultVo.CODE_OK != paramOut.getInteger("code")) {
|
throw new IllegalArgumentException(paramOut.getString("msg"));
|
}
|
|
return paramOut.getIntValue("data");
|
|
}
|
|
//解析Excel日期格式
|
public static Date DoubleToDate(Double dVal) {
|
Date tDate = new Date();
|
long localOffset = tDate.getTimezoneOffset() * 60000; //系统时区偏移 1900/1/1 到 1970/1/1 的 25569 天
|
tDate.setTime((long) ((dVal - 25569) * 24 * 3600 * 1000 + localOffset));
|
return tDate;
|
}
|
}
|
