记得上下班打卡 | git大法好,push需谨慎

Commit 17d0b443 authored by 张国柄's avatar 张国柄

~opt:店铺商品管理:批量导入数据;

parent 21ebe7a4
...@@ -210,91 +210,6 @@ public class GoblinStoreMgtGoodsImportService { ...@@ -210,91 +210,6 @@ public class GoblinStoreMgtGoodsImportService {
} }
} }
).sheet(0).doReadSync(); ).sheet(0).doReadSync();
// EasyExcel.read(file.getInputStream(), GoblinGoodsImportDto.class, new PageReadListener<GoblinGoodsImportDto>(dts -> {
// GoblinGoodsInfoVo lastGoodsInfoVo = null;
// GoblinGoodsSkuInfoVo lastGoodsSkuInfoVo;
// LocalDateTime now = LocalDateTime.now();
// for (GoblinGoodsImportDto dt : dts) {
// log.debug("dt1:{}", dt.toString());
//
// boolean tobeNextSpuFlg = false;
// if (null == lastGoodsInfoVo || !lastGoodsInfoVo.getName().equals(dt.getSpuName())) {
// lastGoodsInfoVo = GoblinGoodsInfoVo.getNew();
// tobeNextSpuFlg = true;
// }
//
// if (tobeNextSpuFlg) {
// lastGoodsInfoVo.setName(dt.getSpuName());//*
// if (StringUtils.isNotEmpty(dt.getSpuCode())) {
// lastGoodsInfoVo.setSpuId(IDGenerator.nextMilliId2() + dt.getSpuCode());//*
// } else {
// lastGoodsInfoVo.setSpuId(IDGenerator.nextMilliId2());//*
// }
//// if (StringUtils.isNotEmpty(dt.getSpuBarCode())) {
//// lastGoodsInfoVo.setSpuNo(dt.getSpuBarCode());//*
//// } else {
// lastGoodsInfoVo.setSpuNo(lastGoodsInfoVo.getSpuId());//*
//// }
// if (!CollectionUtils.isEmpty(dt.getSpuImgList())) {
// lastGoodsInfoVo.setImageList(dt.getSpuImgList());
// lastGoodsInfoVo.setCoverPic(lastGoodsInfoVo.getImageList().get(0));
// }
//
// lastGoodsInfoVo.setDetails(lastGoodsInfoVo.getName());
// lastGoodsInfoVo.setSpuType(0);//*
// lastGoodsInfoVo.setSpecMode("1");//*
// lastGoodsInfoVo.setShelvesHandle("1");
// lastGoodsInfoVo.setVirtualFlg("0");
// lastGoodsInfoVo.setStatus("3");
// lastGoodsInfoVo.setShelvesStatus("0");
// lastGoodsInfoVo.setSpuAppear("0");//*
// lastGoodsInfoVo.setSpuCanbuy("1");
// lastGoodsInfoVo.setDelFlg("0");
// lastGoodsInfoVo.setCreatedAt(now);
// lastGoodsInfoVo.setCreatedBy(uid);//*
// lastGoodsInfoVo.setStoreId(storeId);//*
//
// lastGoodsSkuInfoVo = this.goodsInformationDataAnalysisProcessingForSku(dt, lastGoodsInfoVo, uid, storeId, now, true, goodsSkuInfoVos, initGoodsSkuObjs);
//
// goodsInfoVos.add(lastGoodsInfoVo);
// } else {
// lastGoodsSkuInfoVo = this.goodsInformationDataAnalysisProcessingForSku(dt, lastGoodsInfoVo, uid, storeId, now, false, goodsSkuInfoVos, initGoodsSkuObjs);
// }
//// log.debug("dt2:{}", lastGoodsInfoVo);
// }
// log.debug("dt3-1:{}", 1);
//// log.debug("dt3-1:{}", JsonUtils.toJson(goodsInfoVos));
//// log.debug("dt3-2:{}", JsonUtils.toJson(goodsSkuInfoVos));
//
//// if (goblinMongoUtils.countMgtGoodsSkuBySkuNoList(storeId, skuBarCodeTmpList) > 0) {
//// throw new LiquidnetServiceException("-1", "数据内容不规范【规格条码与已添加商品条码重复】");
//// }
////
//// goblinMongoUtils.insertMgtGoodsInfoVos(goodsInfoVos);
//// goblinMongoUtils.insertMgtGoodsSkuInfoVos(goodsSkuInfoVos);
//// goodsSkuInfoVos.forEach(r -> goblinRedisUtils.setSkuStock(null, r.getSkuId(), r.getSkuStock()));
////
//// LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
//// toMqSqls.add(SqlMapping.get("goblin_goods.insert"));
//// LinkedList<Object[]> initGoodsObjs = CollectionUtil.linkedListObjectArr();
//// goodsInfoVos.forEach(r -> initGoodsObjs.add(new Object[]{
//// r.getSpuId(), r.getSpuNo(), r.getName(), r.getSubtitle(), r.getSellPrice(),
//// r.getPriceGe(), r.getPriceLe(), r.getIntro(), r.getDetails(), r.getCoverPic(),
//// r.getVideo(), r.getSpecMode(), r.getStoreId(), r.getCateFid(), r.getCateSid(),
//// r.getCateTid(), r.getStoreCateFid(), r.getStoreCateSid(), r.getStoreCateTid(), r.getBrandId(),
//// r.getShelvesHandle(), r.getShelvesTime(), r.getSpuValidity(), r.getVirtualFlg(), r.getStatus(),
//// r.getShelvesStatus(), r.getSpuAppear(), r.getShelvesAt(), r.getCreatedBy(), r.getCreatedAt(),
//// r.getLogisticsTemplate()
//// }));
//// toMqSqls.add(SqlMapping.get("goblin_goods_sku.insert"));
//// queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_GOODS.getKey(), SqlMapping.gets(toMqSqls, initGoodsObjs, initGoodsSkuObjs));
// }) {
//
// @Override
// public void invoke(GoblinGoodsImportDto dto, AnalysisContext context) {
// super.invoke(dto, context);
// }
// }).sheet().doReadSync();
} }
private GoblinGoodsInfoVo goodsInformationDataAnalysisProcessingForSpu(GoblinGoodsImportDto dt,GoblinGoodsInfoVo lastGoodsInfoVo, private GoblinGoodsInfoVo goodsInformationDataAnalysisProcessingForSpu(GoblinGoodsImportDto dt,GoblinGoodsInfoVo lastGoodsInfoVo,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment