修改

jiangping

2023-09-19 a63b44e4b7cdc19db7a91d6d9c4b3f1ec5acf4d1

修改

 server/service/src/main/java/com/doumee/dao/business/BaseGoodsParamMapper.java

@@ -3,10 +3,13 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.BaseGoodsParam;

import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/09/07 11:41
 */
public interface BaseGoodsParamMapper extends BaseMapper<BaseGoodsParam> {

    void insertBatch(List<BaseGoodsParam> list);
}

 server/service/src/main/java/com/doumee/dao/business/MultifileMapper.java

@@ -3,10 +3,13 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.Multifile;

import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/05/12 13:58
 */
public interface MultifileMapper extends BaseMapper<Multifile> {

    void insertBatch(List<Multifile> fileList);
}

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

@@ -30,6 +30,7 @@
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
@@ -315,6 +316,7 @@
    public static   boolean IS_RUNNING = false;
    @Override
    @Async
    @Transactional(isolation = Isolation.READ_UNCOMMITTED)
    public   void dealBaseData() {
        if(IS_RUNNING){
            return;
@@ -349,21 +351,10 @@
            BigDecimal rate = systemDictDataBiz.getGoodsPriceRate();
            OssModel ossModel = initOssModel();
            Date date = new Date();
            List<BaseCateParam> baseCateParamList = new ArrayList<>();
            List<Multifile> fileList = new ArrayList<>();
            List<BaseGoodsParam> baseGoodsParamList = new ArrayList<>();
            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);
@@ -418,18 +409,33 @@
            baseGoodsMapper.insert(goods);
        }
        //处理分类属性
        dealCateParamAll(cModel.getId(),goods.getId(),data,paramList);
                dealCateParamAll(cModel.getId(),goods.getId(),data,paramList, baseGoodsParamList );
        //处理背景图
        dealBgImgAll(ossModel,goods.getId(),data);

                dealBgImgAll(ossModel,goods.getId(),data,fileList);
        data.setEditDate(new Date());
        data.setStatus(Constants.ONE);
        //更新数据处理状态
        baseDataMapper.updateById(data);
    }
            if(fileList.size()>0){
                multifileMapper.insertBatch(fileList);
            }
            if(baseGoodsParamList.size()>0){
                baseGoodsParamMapper.insertBatch(baseGoodsParamList);
            }
            log.info("开始处理源数据=================success================处理数据共（"+allLis.size()+"）个===");
        }catch (Exception e){
            e.printStackTrace();
            log.info("开始处理源数据=================error==================="+e.getMessage());
            throw  e;
        }finally {
            IS_RUNNING = false;
            log.info("开始处理源数据=================end===================");
        }
    }


    private void dealBgImgAll(OssModel ossModel, Integer id, BaseData data) {
    private void dealBgImgAll(OssModel ossModel, Integer id, BaseData data,List<Multifile> fileList) {
        int i =0;
        //多图，英文逗号隔开
        if(StringUtils.isNotBlank(data.getBgImg())){
@@ -437,7 +443,7 @@
            String[] imgs =tImg.split(",");
            for (int j = 0; j < imgs.length; j++) {
                if(StringUtils.isNotBlank(imgs[j])){
                    i += addImg(i,ossModel,id,imgs[j]);
                    i += addImg(i,ossModel,id,imgs[j],fileList);
                }
            }
        }
@@ -446,7 +452,7 @@
//        addImg(i,ossModel,id,data.getBgImg3());
    }

    private int addImg(int i,OssModel ossModel, Integer id,String bgImg) {
    private int addImg(int i,OssModel ossModel, Integer id,String bgImg,List<Multifile> fileList) {
        if(StringUtils.isNotBlank(bgImg)){
            String img =getOssImgurl(ossModel, ossModel.getGoodsFolder() ,bgImg);
            if(StringUtils.isNotBlank(img)){
@@ -459,7 +465,8 @@
                f.setCreateDate(new Date());
                f.setIsdeleted(Constants.ZERO);
                f.setSortnum(i);
                multifileMapper.insert(f);
                fileList.add(f);
//                multifileMapper.insert(f);
                return  1;
            }
        }
@@ -480,14 +487,14 @@
    }


    private void dealCateParamAll(Integer cateId,Integer goodsId, BaseData data  ,List<BaseCateParam> cateList) {
    private void dealCateParamAll(Integer cateId,Integer goodsId, BaseData data  ,List<BaseCateParam> cateList,List<BaseGoodsParam> paramList) {
        Method[] fields = data.getClass().getMethods();    // èŽ·å–对象的所有属性
        for (Method item : fields) {
            String name = item.getName();
            if(name.indexOf("getAttr") == 0){
                try {
                    String val =(String) item.invoke(data);
                    dealCateParam(cateId,goodsId,val.toString(),cateList);
                    dealCateParam(cateId,goodsId,val.toString(),cateList,paramList);
                } catch (Exception e) {
//                    throw new RuntimeException(e);
                }
@@ -530,7 +537,7 @@
//        dealCateParam(cateId,goodsId,data.getAttr34(),cateList);
    }

    private void dealCateParam(Integer cateId, Integer goodsId, String attr,List<BaseCateParam> list) {
    private void dealCateParam(Integer cateId, Integer goodsId, String attr,List<BaseCateParam> list,List<BaseGoodsParam> paramList) {
        if(StringUtils.isBlank(attr)){
            return;
        }
@@ -554,7 +561,8 @@
        p.setVal(val);
        p.setCreateDate(new Date());
        p.setGoodsId(goodsId);
        baseGoodsParamMapper.insert(p);
        paramList.add(p);
//        baseGoodsParamMapper.insert(p);
    }

    /**

 server/service/src/main/resources/mappers/BaseGoodsParamMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.doumee.dao.business.BaseGoodsParamMapper">
    <insert id="insertBatch" >
        insert into base_goods_param(
        `CREATOR`,
        `CREATE_DATE`,
        `EDITOR`,
        `EDIT_DATE`,
        `ISDELETED`,
        `NAME`,
        `REMARK`,
        `STATUS`,
        `SORTNUM`,
        `PRAMA_ID`,
        `VAL`,
        `GOODS_ID`
        ) values
        <foreach collection="list" separator="," item="item">
            (#{item.creator}
            ,#{item.createDate}
            ,#{item.editor}
            ,#{item.editDate}
            ,#{item.isdeleted}
            ,#{item.name}
            ,#{item.remark}
            ,#{item.status}
            ,#{item.sortnum}
            ,#{item.pramaId}
            ,#{item.val}
            ,#{item.goodsId})
        </foreach>
    </insert>
</mapper>

 server/service/src/main/resources/mappers/MultifileMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.doumee.dao.business.MultifileMapper">
    <insert id="insertBatch" >
        insert into multifile(
        `CREATOR`,
        `CREATE_DATE`,
        `EDITOR`,
        `EDIT_DATE`,
        `ISDELETED`,
        `NAME`,
        `INFO`,
        OBJ_ID,
        TYPE,
        OBJ_TYPE,
        FILEURL,
        SORTNUM,
        COMPANY_ID
        ) values
        <foreach collection="list" separator="," item="item">
            (#{item.creator}
            ,#{item.createDate}
            ,#{item.editor}
            ,#{item.editDate}
            ,#{item.isdeleted}
            ,#{item.name}
            ,#{item.info}
            ,#{item.objId}
            ,#{item.type}
            ,#{item.objType}
            ,#{item.fileurl}
            ,#{item.sortnum}
            ,#{item.companyId}
            )
        </foreach>
    </insert>
</mapper>