企业端

Mr.Shi

2023-09-19 7d13bbe39257ab5231d062e431fbb920c60d8ed5

 server/service/src/main/java/com/doumee/service/business/impl/BaseDataServiceImpl.java

@@ -20,7 +20,9 @@
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

@@ -290,7 +292,19 @@
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(baseDataMapper.selectPage(page, queryWrapper));
        IPage<BaseData> result =baseDataMapper.selectPage(page, queryWrapper);
        if(result!=null && result.getRecords()!=null){
            for(BaseData data :result.getRecords()){
                //多图，英文逗号隔开
                if(StringUtils.isNotBlank(data.getBgImg())){
                    String tImg =  data.getBgImg().replace("，", ",").replace(".avif", "");
                    String[] imgs =tImg.split(",");
                    data.setBgImgs(imgs);

                }
            }
        }
        return PageData.from(result);
    }

    @Override
@@ -300,7 +314,7 @@
    }
    public static   boolean IS_RUNNING = false;
    @Override
    @Transactional
    @Async
    public   void dealBaseData() {
        if(IS_RUNNING){
            return;
@@ -336,18 +350,25 @@
            OssModel ossModel = initOssModel();
            Date date = new Date();
            for(BaseData data : allLis){
              dealPerData(ossModel,rate,date,data,cateList,brandList,paramList);
            }
            log.info("开始处理源数据=================success================处理数据共（"+allLis.size()+"）个===");
        }catch (Exception e){
            e.printStackTrace();
            log.info("开始处理源数据=================error==================="+e.getMessage());
        }finally {
            IS_RUNNING = false;
            log.info("开始处理源数据=================end===================");
        }
    }

    @Transactional(isolation = Isolation.READ_UNCOMMITTED)
    private void dealPerData(OssModel ossModel, BigDecimal rate, Date date, BaseData data, List<BaseCategory> cateList, List<Brand> brandList, List<BaseCateParam> paramList) {
                BaseGoods goods = new BaseGoods();
                goods.setBaseDataId(data.getId());
                goods.setIsdeleted(Constants.ZERO);
                if(baseGoodsMapper.selectCount(new QueryWrapper<>(goods)) >0){
                    //如果已经存在，逻辑删除旧的商品数据
                    UpdateWrapper<BaseGoods> updateModel = new UpdateWrapper<>();
                    updateModel.lambda().set(BaseGoods::getIsdeleted,Constants.ONE);
                    updateModel.lambda().set(BaseGoods::getEditDate, new Date());
                    updateModel.lambda().eq(BaseGoods::getBaseDataId, data.getId());
                    baseGoodsMapper.update(null, updateModel);
                }
                goods.setCreateDate(date);
        //查询是否存在商品
        BaseGoods model = baseGoodsMapper.selectOne(new QueryWrapper<>(goods).last(" limit 1"));
                goods.setName(StringUtils.defaultString(data.getName(),data.getTitle()));
                goods.setRemark(data.getTitle());
                goods.setContent(data.getTitle());
@@ -367,8 +388,34 @@
                }
                goods.setImgurl(getOssImgurl(ossModel,ossModel.getGoodsFolder(), data.getImgurl()));
                goods.setPrice(Constants.formatBigdecimal(data.getSaleprice()).multiply(Constants.formatBigdecimal(cModel.getPriceRate())));
         if(model!=null){
            //如果已经存在，逻辑删除旧的商品数据
//            UpdateWrapper<BaseGoods> updateModel = new UpdateWrapper<>();
//            updateModel.lambda().set(BaseGoods::getIsdeleted,Constants.ONE);
//            updateModel.lambda().set(BaseGoods::getEditDate, new Date());
//            updateModel.lambda().eq(BaseGoods::getBaseDataId, data.getId());
//            baseGoodsMapper.update(null, updateModel);
             goods.setEditDate(date);
             goods.setId(model.getId());
             baseGoodsMapper.updateById(goods);
             //删除原有附件大图
             UpdateWrapper<Multifile> updateModel = new UpdateWrapper<>();
             updateModel.lambda().set(Multifile::getIsdeleted,Constants.ONE);
             updateModel.lambda().set(Multifile::getEditDate, new Date());
             updateModel.lambda().eq(Multifile::getObjId, goods.getId());
             updateModel.lambda().eq(Multifile::getObjType, Constants.ZERO);
             multifileMapper.delete(updateModel);
             //删除原有商品属性
             UpdateWrapper<BaseGoodsParam> bgModel = new UpdateWrapper<>();
             bgModel.lambda().set(BaseGoodsParam::getIsdeleted,Constants.ONE);
             bgModel.lambda().set(BaseGoodsParam::getEditDate, new Date());
             bgModel.lambda().eq(BaseGoodsParam::getGoodsId, goods.getId());
             baseGoodsParamMapper.delete(bgModel);
        }else{
                //插入新商品数据
            goods.setCreateDate(date);
                baseGoodsMapper.insert(goods);
        }
                //处理分类属性
                dealCateParamAll(cModel.getId(),goods.getId(),data,paramList);
                //处理背景图
@@ -379,22 +426,13 @@
                //更新数据处理状态
                baseDataMapper.updateById(data);
            }
            log.info("开始处理源数据=================success================处理数据共（"+allLis.size()+"）个===");
        }catch (Exception e){
            e.printStackTrace();
            log.info("开始处理源数据=================error==================="+e.getMessage());
        }finally {
            IS_RUNNING = false;
            log.info("开始处理源数据=================end===================");
        }
    }


    private void dealBgImgAll(OssModel ossModel, Integer id, BaseData data) {
        int i =0;
        //多图，英文逗号隔开
        if(StringUtils.isNotBlank(data.getBgImg())){
           String tImg =  data.getBgImg().replace("，", ",");
           String tImg =  data.getBgImg().replace("，", ",").replace(".avif", "");
            String[] imgs =tImg.split(",");
            for (int j = 0; j < imgs.length; j++) {
                if(StringUtils.isNotBlank(imgs[j])){