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.factory.GenerateCodeFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.importData.ImportOwnerRoomDto;
|
import com.java110.dto.importData.ImportResourceStoreDto;
|
import com.java110.dto.importData.Vtil;
|
import com.java110.dto.purchase.PurchaseApplyDto;
|
import com.java110.dto.resource.ResourceStoreTypeDto;
|
import com.java110.dto.store.StorehouseDto;
|
import com.java110.dto.system.ComponentValidateResult;
|
import com.java110.intf.community.IImportOwnerRoomInnerServiceSMO;
|
import com.java110.intf.store.IPurchaseApplyDetailInnerServiceSMO;
|
import com.java110.intf.store.IPurchaseApplyInnerServiceSMO;
|
import com.java110.intf.store.IResourceStoreTypeInnerServiceSMO;
|
import com.java110.intf.store.IStorehouseV1InnerServiceSMO;
|
import com.java110.po.purchase.*;
|
import com.java110.po.resource.ResourceStoreTypePo;
|
import com.java110.po.store.StorehousePo;
|
import com.java110.utils.exception.CmdException;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.BeanConvertUtil;
|
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.mybatis.spring.SqlSessionTemplate;
|
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.*;
|
|
//@Service("importResourceStoreSMOImpl")
|
public class ImportResourceStoreV2SMOImpl extends DefaultAbstractComponentSMO implements IImportResourceStoreSMO {
|
|
private final static Logger logger = LoggerFactory.getLogger(ImportResourceStoreV2SMOImpl.class);
|
|
public static final int DEFAULT_ROWS = 500;
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Autowired
|
private IImportOwnerRoomInnerServiceSMO importOwnerRoomInnerServiceSMOImpl;
|
|
@Autowired
|
private IStorehouseV1InnerServiceSMO storehouseV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IResourceStoreTypeInnerServiceSMO resourceStoreTypeInnerServiceSMOImpl;
|
|
@Autowired
|
private IPurchaseApplyInnerServiceSMO purchaseApplyInnerServiceSMOImpl;
|
|
@Autowired
|
private SqlSessionTemplate sqlSessionTemplate;
|
|
|
public static final String CODE_PREFIX_ID = "10";
|
|
@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);
|
|
// 保存数据
|
return dealExcelData(pd, resourceStoreDtos, result);
|
} catch (Exception e) {
|
logger.error("导入失败 ", e);
|
return new ResponseEntity<String>("非常抱歉，您填写的模板数据有误：" + e.getMessage(), HttpStatus.BAD_REQUEST);
|
}
|
}
|
|
|
/**
|
* 获取业主车辆信息
|
*
|
* @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;
|
}
|
resourceStoreDto = new ImportResourceStoreDto();
|
resourceStoreDto.setWarningStock("0");
|
resourceStoreDto.setIsFixed("Y");
|
resourceStoreDto.setResId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_resId));
|
try {
|
resourceStoreDto.setCommunityId(result.getCommunityId());
|
resourceStoreDto.setResCode(Vtil.defaultValue(os[1]));
|
resourceStoreDto.setTripleWaybillNo(Vtil.defaultValue(os[2]));
|
resourceStoreDto.setCommunityName(Vtil.defaultValue(os[3]));
|
resourceStoreDto.setRstName(Vtil.defaultValue(os[4], "未分类"));
|
resourceStoreDto.setSystemName(Vtil.defaultValue(os[5]));
|
resourceStoreDto.setResName(Vtil.defaultValue(os[6], "空"));
|
resourceStoreDto.setModel(Vtil.defaultValue(os[7]));
|
resourceStoreDto.setBrand(Vtil.defaultValue(os[8]));
|
resourceStoreDto.setSupplier(Vtil.defaultValue(os[9]));
|
resourceStoreDto.setUnitCode(Vtil.defaultValue(os[10]));
|
resourceStoreDto.setBudgetApproval(Vtil.defaultValue(os[11]));
|
resourceStoreDto.setStock(Vtil.defaultValue(os[12]));
|
resourceStoreDto.setBudgetQuantity(Vtil.defaultValue(os[12]));
|
resourceStoreDto.setPrice(Vtil.defaultValue(os[13]));
|
resourceStoreDto.setBudgetUnitPrice(Vtil.defaultValue(os[13]));
|
resourceStoreDto.setBudgetAmount(Vtil.defaultValue(os[14]));
|
resourceStoreDto.setApplyQuantityTotal(Vtil.defaultValue(os[15]));
|
resourceStoreDto.setPurchaseQuantityTotal(Vtil.defaultValue(os[16]));
|
resourceStoreDto.setActualDeliveryQuantity(Vtil.defaultValue(os[17]));
|
resourceStoreDto.setPayableAmountTotal(Vtil.defaultValue(os[18]));
|
resourceStoreDto.setPaidAmountTotal(Vtil.defaultValue(os[19]));
|
resourceStoreDto.setUnpaidAmountTotal(Vtil.defaultValue(os[20]));
|
resourceStoreDto.setIsOccurred(Vtil.defaultValue(os[21]));
|
|
|
|
|
|
List<DeliveryStorageRecord> deliveryStorageRecords = new ArrayList<>();
|
|
if (true) {
|
PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo();
|
purchaseApplyPo.setApplyOrderId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
|
purchaseApplyPo.setApplyNo(Vtil.defaultValue(os[22]));
|
purchaseApplyPo.setApplyDate(Vtil.defaultValue(os[23]));
|
purchaseApplyPo.setApplyQuantity(Vtil.defaultValue(os[24]));
|
purchaseApplyPo.setUserName(Vtil.defaultValue(os[25]));
|
purchaseApplyPo.setApprover(Vtil.defaultValue(os[26]));
|
purchaseApplyPo.setResOrderType("10000");
|
purchaseApplyPo.setStoreId(result.getStoreId());
|
purchaseApplyPo.setCreateUserId(result.getUserId());
|
purchaseApplyPo.setCreateUserName(result.getUserName());
|
purchaseApplyPo.setEndUserName(result.getUserName());
|
purchaseApplyPo.setDescription("导入内容");
|
purchaseApplyPo.setWarehousingWay("10000");
|
purchaseApplyInnerServiceSMOImpl.savePurchaseApply(purchaseApplyPo);
|
|
PurchaseApplyDetailPo purchaseApplyDetailPo = new PurchaseApplyDetailPo();
|
purchaseApplyDetailPo.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
|
purchaseApplyDetailPo.setResId(resourceStoreDto.getResId());
|
purchaseApplyDetailPo.setFirstCumulativePurchaseQuantity(Vtil.defaultValue(os[27]));
|
purchaseApplyDetailPo.setPurchaseDate(Vtil.defaultValue(os[28]));
|
purchaseApplyDetailPo.setPurchaseQuantity(Vtil.defaultValue(os[29]));
|
purchaseApplyDetailPo.setQuantity(Vtil.defaultValue(os[29],"0"));
|
purchaseApplyDetailPo.setPrice(Vtil.defaultValue(os[30]));
|
purchaseApplyDetailPo.setConsultPrice(Vtil.defaultValue(os[30]));
|
purchaseApplyDetailPo.setPurchaseAmount(Vtil.defaultValue(os[31]));
|
purchaseApplyDetailPo.setPurchaser(Vtil.defaultValue(os[32]));
|
purchaseApplyDetailPo.setContractNo(Vtil.defaultValue(os[33]));
|
purchaseApplyDetailPo.setSupplier(Vtil.defaultValue(os[34]));
|
purchaseApplyDetailPo.setFirstCumulativeDeliveryQuantity(Vtil.defaultValue(os[35]));
|
purchaseApplyDetailPo.setApplyOrderId(purchaseApplyPo.getApplyOrderId());
|
|
List<PurchaseApplyDetailPo> list = new ArrayList<>();
|
list.add(purchaseApplyDetailPo);
|
Map<String, Object> paramMap = new HashMap<>();
|
paramMap.put("list", list);
|
|
// 3. 执行插入（SQL 保留原有 <foreach> 语法不变）
|
sqlSessionTemplate.insert("purchaseApplyServiceDaoImpl.savePurchaseApplyDetailInfo", paramMap);
|
|
sqlSessionTemplate.insert("deliveryStorageRecordServiceDaoImpl.insertDeliveryStorageRecord", BeanConvertUtil.beanCovertMap(new DeliveryStorageRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[36]),
|
Vtil.defaultValue(os[37]),
|
Vtil.defaultValue(os[38]),
|
Vtil.defaultValue(os[39]),
|
Vtil.defaultValue(os[40]),
|
Vtil.defaultValue(os[41]),
|
Vtil.defaultValue(os[42]),
|
Vtil.defaultValue(os[43]),
|
purchaseApplyDetailPo.getApplyOrderId())));
|
sqlSessionTemplate.insert("deliveryStorageRecordServiceDaoImpl.insertDeliveryStorageRecord", BeanConvertUtil.beanCovertMap(new DeliveryStorageRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[44]),
|
Vtil.defaultValue(os[45]),
|
Vtil.defaultValue(os[46]),
|
Vtil.defaultValue(os[47]),
|
Vtil.defaultValue(os[48]),
|
Vtil.defaultValue(os[49]),
|
Vtil.defaultValue(os[50]),
|
Vtil.defaultValue(os[51]),
|
purchaseApplyDetailPo.getApplyOrderId())));
|
sqlSessionTemplate.insert("deliveryStorageRecordServiceDaoImpl.insertDeliveryStorageRecord", BeanConvertUtil.beanCovertMap(new DeliveryStorageRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[52]),
|
Vtil.defaultValue(os[53]),
|
Vtil.defaultValue(os[54]),
|
Vtil.defaultValue(os[55]),
|
Vtil.defaultValue(os[56]),
|
Vtil.defaultValue(os[57]),
|
Vtil.defaultValue(os[58]),
|
Vtil.defaultValue(os[59]),
|
purchaseApplyDetailPo.getApplyOrderId())));
|
}
|
|
|
|
if (true) {
|
PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo();
|
purchaseApplyPo.setApplyOrderId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
|
purchaseApplyPo.setApplyNo(Vtil.defaultValue(os[60]));
|
purchaseApplyPo.setApplyDate(Vtil.defaultValue(os[61]));
|
purchaseApplyPo.setApplyQuantity(Vtil.defaultValue(os[62]));
|
purchaseApplyPo.setUserName(Vtil.defaultValue(os[63]));
|
purchaseApplyPo.setApprover(Vtil.defaultValue(os[64]));
|
purchaseApplyPo.setResOrderType("10000");
|
purchaseApplyPo.setStoreId(result.getStoreId());
|
purchaseApplyPo.setCreateUserId(result.getUserId());
|
purchaseApplyPo.setCreateUserName(result.getUserName());
|
purchaseApplyPo.setEndUserName(result.getUserName());
|
purchaseApplyPo.setDescription("导入内容");
|
purchaseApplyPo.setWarehousingWay("10000");
|
purchaseApplyInnerServiceSMOImpl.savePurchaseApply(purchaseApplyPo);
|
|
PurchaseApplyDetailPo purchaseApplyDetailPo = new PurchaseApplyDetailPo();
|
purchaseApplyDetailPo.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId));
|
purchaseApplyDetailPo.setResId(resourceStoreDto.getResId());
|
purchaseApplyDetailPo.setFirstCumulativePurchaseQuantity(Vtil.defaultValue(os[65]));
|
purchaseApplyDetailPo.setQuantity(Vtil.defaultValue(os[29],"0"));
|
purchaseApplyDetailPo.setPurchaseDate(Vtil.defaultValue(os[66]));
|
purchaseApplyDetailPo.setPurchaseQuantity(Vtil.defaultValue(os[67]));
|
purchaseApplyDetailPo.setPurchaseDate2(Vtil.defaultValue(os[68]));
|
purchaseApplyDetailPo.setPurchaseQuantity2(Vtil.defaultValue(os[69]));
|
purchaseApplyDetailPo.setPurchaseDate3(Vtil.defaultValue(os[70]));
|
purchaseApplyDetailPo.setPurchaseQuantity3(Vtil.defaultValue(os[71]));
|
|
|
purchaseApplyDetailPo.setPrice(Vtil.defaultValue(os[72]));
|
purchaseApplyDetailPo.setConsultPrice(Vtil.defaultValue(os[72]));
|
purchaseApplyDetailPo.setPurchaseAmount(Vtil.defaultValue(os[73]));
|
purchaseApplyDetailPo.setPurchaser(Vtil.defaultValue(os[74]));
|
purchaseApplyDetailPo.setContractNo(Vtil.defaultValue(os[75]));
|
purchaseApplyDetailPo.setSupplier(Vtil.defaultValue(os[76]));
|
purchaseApplyDetailPo.setFirstCumulativeDeliveryQuantity(Vtil.defaultValue(os[77]));
|
purchaseApplyDetailPo.setApplyOrderId(purchaseApplyPo.getApplyOrderId());
|
|
List<PurchaseApplyDetailPo> list = new ArrayList<>();
|
list.add(purchaseApplyDetailPo);
|
Map<String, Object> paramMap = new HashMap<>();
|
paramMap.put("list", list);
|
|
// 3. 执行插入（SQL 保留原有 <foreach> 语法不变）
|
sqlSessionTemplate.insert("purchaseApplyServiceDaoImpl.savePurchaseApplyDetailInfo", paramMap);
|
|
sqlSessionTemplate.insert("deliveryStorageRecordServiceDaoImpl.insertDeliveryStorageRecord", BeanConvertUtil.beanCovertMap(new DeliveryStorageRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[78]),
|
Vtil.defaultValue(os[79]),
|
Vtil.defaultValue(os[80]),
|
Vtil.defaultValue(os[81]),
|
Vtil.defaultValue(os[82]),
|
Vtil.defaultValue(os[83]),
|
Vtil.defaultValue(os[84]),
|
Vtil.defaultValue(os[85]),
|
purchaseApplyDetailPo.getApplyOrderId())));
|
sqlSessionTemplate.insert("deliveryStorageRecordServiceDaoImpl.insertDeliveryStorageRecord", BeanConvertUtil.beanCovertMap(new DeliveryStorageRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[86]),
|
Vtil.defaultValue(os[87]),
|
Vtil.defaultValue(os[88]),
|
Vtil.defaultValue(os[89]),
|
Vtil.defaultValue(os[90]),
|
Vtil.defaultValue(os[91]),
|
Vtil.defaultValue(os[92]),
|
Vtil.defaultValue(os[93]),
|
purchaseApplyDetailPo.getApplyOrderId())));
|
sqlSessionTemplate.insert("deliveryStorageRecordServiceDaoImpl.insertDeliveryStorageRecord", BeanConvertUtil.beanCovertMap(new DeliveryStorageRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[94]),
|
Vtil.defaultValue(os[95]),
|
Vtil.defaultValue(os[96]),
|
Vtil.defaultValue(os[97]),
|
Vtil.defaultValue(os[98]),
|
Vtil.defaultValue(os[99]),
|
Vtil.defaultValue(os[100]),
|
Vtil.defaultValue(os[101]),
|
purchaseApplyDetailPo.getApplyOrderId())));
|
}
|
|
resourceStoreDto.setPayableAmount(Vtil.defaultValue(os[102]));
|
resourceStoreDto.setPaidAmount(Vtil.defaultValue(os[103]));
|
resourceStoreDto.setUnpaidAmount(Vtil.defaultValue(os[104]));
|
|
sqlSessionTemplate.insert("purchasePaymentRecordServiceDaoImpl.insertPurchasePaymentRecord", BeanConvertUtil.beanCovertMap(new PurchasePaymentRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[110]),
|
resourceStoreDto.getResId(),
|
Vtil.defaultValue(os[105]),
|
Vtil.defaultValue(os[106]),
|
Vtil.defaultValue(os[107]),
|
Vtil.defaultValue(os[108]),
|
Vtil.defaultValue(os[109])
|
)));
|
|
|
sqlSessionTemplate.insert("purchasePaymentRecordServiceDaoImpl.insertPurchasePaymentRecord", BeanConvertUtil.beanCovertMap(new PurchasePaymentRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
null,
|
resourceStoreDto.getResId(),
|
Vtil.defaultValue(os[111]),
|
Vtil.defaultValue(os[112]),
|
Vtil.defaultValue(os[113]),
|
Vtil.defaultValue(os[114]),
|
Vtil.defaultValue(os[115])
|
)));
|
|
sqlSessionTemplate.insert("purchaseReturnRecordServiceDaoImpl.insertPurchaseReturnRecord", BeanConvertUtil.beanCovertMap(new PurchaseReturnRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[117]),
|
Vtil.defaultValue(os[118]),
|
Vtil.defaultValue(os[119]),
|
Vtil.defaultValue(os[120]),
|
Vtil.defaultValue(os[121]),
|
Vtil.defaultValue(os[122]),
|
resourceStoreDto.getResId()
|
)));
|
|
sqlSessionTemplate.insert("purchaseReturnRecordServiceDaoImpl.insertPurchaseReturnRecord", BeanConvertUtil.beanCovertMap(new PurchaseReturnRecord(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_applyOrderId),
|
Vtil.defaultValue(os[123]),
|
Vtil.defaultValue(os[124]),
|
Vtil.defaultValue(os[125]),
|
Vtil.defaultValue(os[126]),
|
Vtil.defaultValue(os[127]),
|
Vtil.defaultValue(os[128]),
|
resourceStoreDto.getResId()
|
)));
|
resourceStoreDto.setTotalReturnQuantity(Vtil.defaultValue(os[116]));
|
resourceStoreDto.setSupplier1(Vtil.defaultValue(os[129]));
|
resourceStoreDto.setSupplier2(Vtil.defaultValue(os[130]));
|
resourceStoreDto.setSupplier3(Vtil.defaultValue(os[131]));
|
|
|
} catch (ArrayIndexOutOfBoundsException e) {
|
//下标溢出不影响
|
}
|
|
|
// resourceStoreDto.setOutLowPrice(os[6].toString());
|
// resourceStoreDto.setOutHighPrice(os[7].toString());
|
resourceStoreDtos.add(resourceStoreDto);
|
try {
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
|
}
|
|
}
|
}
|
|
|
/**
|
* 处理房产信息
|
*/
|
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"));
|
// data.put("shName", "系统仓库");
|
|
// Map<String, String> com = new HashMap<>();
|
// Map<String, String> rst = new HashMap<>();
|
|
try {
|
for (int roomIndex = 0; roomIndex < resourceStoreDtos.size(); roomIndex++) {
|
String shId = null;
|
|
// //第一步：仓库
|
// try {
|
// if (com.containsKey(result.getCommunityId())) {//判断仓库是否存在
|
// shId = com.get(result.getCommunityId());//缓存中存在直接拿缓存的仓库编号
|
// } else {
|
// StorehouseDto storehouseDto = new StorehouseDto();
|
//
|
// storehouseDto.setCommunityId(result.getCommunityId());
|
// storehouseDto.setShName(data.getString("shName"));
|
//
|
// int i = storehouseV1InnerServiceSMOImpl.queryStorehousesCount(storehouseDto);
|
//
|
// if (i > 0) {//数据库中存在直接拿系统中的仓库编号，并存入缓存
|
// List<StorehouseDto> storehouseDtos = storehouseV1InnerServiceSMOImpl.queryStorehouses(storehouseDto);
|
// com.put(result.getCommunityId(), storehouseDtos.get(0).getShId());
|
// } else {//数据库没有，创建
|
// shId = GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID);
|
// StorehousePo storehousePo = new StorehousePo();
|
//
|
// storehousePo.setShId(shId);
|
// storehousePo.setCommunityId(result.getCommunityId());
|
// storehousePo.setShName(data.getString("shName"));
|
// storehousePo.setAllocationSwitch("OFF");
|
// storehousePo.setAllowPurchase("ON");
|
// storehousePo.setAllowUse("ON");
|
// storehousePo.setIsShow("true");
|
// storehousePo.setPurchaseSwitch("OFF");
|
// storehousePo.setShDesc(data.getString("shName"));
|
// storehousePo.setUseSwitch("OFF");
|
//
|
// flag = storehouseV1InnerServiceSMOImpl.saveStorehouse(storehousePo);
|
//
|
// if (flag < 1) {
|
// throw new CmdException("保存数据失败");
|
// }
|
// }
|
// }
|
// } catch (Exception e) {
|
// throw new IllegalArgumentException("创建仓库失败");
|
// }
|
////
|
//// //一级分类
|
//// try {
|
//// ResourceStoreTypeDto rstDto = new ResourceStoreTypeDto();
|
//// rstDto.setName(resourceStoreDtos.get(roomIndex).getRstName());
|
//// int i = resourceStoreTypeInnerServiceSMOImpl.queryResourceStoreTypesCount(rstDto);
|
////
|
//// if (i > 0) {
|
//// ResourceStoreTypeDto resourceStoreTypeDto = resourceStoreTypeInnerServiceSMOImpl.queryResourceStoreTypes(rstDto).get(0);
|
////
|
//// }
|
////
|
//// } catch (Exception e) {
|
//// throw new IllegalArgumentException("创建一级分类失败");
|
//// }
|
|
|
|
resourceStoreDtos.get(roomIndex).setShId(shId);
|
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;
|
}
|
}
|
