新增源数据惨淡

jiangping

2023-09-15 b459b874c062b1124200f8a591b86d0558c3ffce

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

@@ -117,6 +117,7 @@
  
    @Override
    public PageData<BaseData> findPage(PageWrap<BaseData> pageWrap) {
        pageWrap.getModel().setIsdeleted(Constants.ZERO);
        IPage<BaseData> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<BaseData> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
@@ -141,19 +142,19 @@
            queryWrapper.lambda().eq(BaseData::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getTitle() != null) {
            queryWrapper.lambda().eq(BaseData::getTitle, pageWrap.getModel().getTitle());
            queryWrapper.lambda().like(BaseData::getTitle, pageWrap.getModel().getTitle());
        }
        if (pageWrap.getModel().getName() != null) {
            queryWrapper.lambda().eq(BaseData::getName, pageWrap.getModel().getName());
            queryWrapper.lambda().like(BaseData::getName, pageWrap.getModel().getName());
        }
        if (pageWrap.getModel().getSku() != null) {
            queryWrapper.lambda().eq(BaseData::getSku, pageWrap.getModel().getSku());
            queryWrapper.lambda().like(BaseData::getSku, pageWrap.getModel().getSku());
        }
        if (pageWrap.getModel().getBrand() != null) {
            queryWrapper.lambda().eq(BaseData::getBrand, pageWrap.getModel().getBrand());
            queryWrapper.lambda().like(BaseData::getBrand, pageWrap.getModel().getBrand());
        }
        if (pageWrap.getModel().getCategory() != null) {
            queryWrapper.lambda().eq(BaseData::getCategory, pageWrap.getModel().getCategory());
            queryWrapper.lambda().like(BaseData::getCategory, pageWrap.getModel().getCategory());
        }
        if (pageWrap.getModel().getUrl() != null) {
            queryWrapper.lambda().eq(BaseData::getUrl, pageWrap.getModel().getUrl());
@@ -337,6 +338,14 @@
                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);
                goods.setName(StringUtils.defaultString(data.getName(),data.getTitle()));
                goods.setRemark(data.getTitle());
@@ -355,7 +364,7 @@
                if(cModel!= null){
                    goods.setCategoryId(cModel.getId());
                }
                goods.setImgurl(getOssImgurl(ossModel, data.getImgurl()));
                goods.setImgurl(getOssImgurl(ossModel,ossModel.getGoodsFolder(), data.getImgurl()));
                goods.setPrice(Constants.formatBigdecimal(data.getSaleprice()).multiply(Constants.formatBigdecimal(cModel.getPriceRate())));
                //插入新商品数据
                baseGoodsMapper.insert(goods);
@@ -389,7 +398,7 @@

    private int addImg(int i,OssModel ossModel, Integer id,String bgImg) {
        if(StringUtils.isNotBlank(bgImg)){
            String img =getOssImgurl(ossModel,bgImg);
            String img =getOssImgurl(ossModel, ossModel.getGoodsFolder() ,bgImg);
            if(StringUtils.isNotBlank(img)){
                Multifile f = new Multifile();
                f.setFileurl(img);
@@ -577,7 +586,7 @@
        model.setIsdeleted(Constants.ZERO);
        model.setPinyin(PinYinUtil.getFullSpell(model.getName()));
        model.setShortPinyin(PinYinUtil.getFirstSpell(model.getName()));
        model.setImgurl(getOssImgurl(ossModel,img));
        model.setImgurl(getOssImgurl(ossModel, ossModel.getCateFolder() ,img));
        //插入新的品牌信息
        baseCategoryMapper.insert(model);
        //加入集合中
@@ -585,7 +594,7 @@
        return model;
    }

    private String getOssImgurl(OssModel ossModel, String img) {
    private String getOssImgurl(OssModel ossModel, String folder,String img) {
        if(StringUtils.isBlank(img)){
            return null;
        }
@@ -595,7 +604,7 @@
            nfix = StringUtils.defaultString(nfix,".jpg");
            String fileName = UUID.randomUUID() + nfix;
            String tempFileName = nowDate + "/" + fileName;
            String key = ossModel.getCateFolder() + tempFileName;// 文件名
            String key =folder+ tempFileName;// 文件名

            ALiYunUtil obs = new ALiYunUtil(ossModel.getEndpoint(), ossModel.getAccessId(), ossModel.getAccessKey());
            if (obs.uploadOnlineObject(img,ossModel.getBucket(), key,null)) {