修改

jiangping

2023-09-19 62f53cc6c69c02bbe91a5010ee98f293ae3746bb

修改

 server/company/src/main/java/com/doumee/config/shiro/ShiroRealm.java

@@ -102,8 +102,8 @@
            if(DateUtil.compareDate(new Date(),DateUtil.addDaysToDate(company.getOepnValidDate(),1))<=Constants.ZERO){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，企业信息已过期，如有疑问请联系系统管理员！");
            }
            user.setCompany(company);
        }

        // èŽ·å–登录用户信息
        List<SystemRole> roles = systemRoleService.findByUserId(user.getId());
        List<SystemPermission> permissions = systemPermissionService.findByUserId(user.getId());

 server/platform/src/main/java/com/doumee/api/business/FileRecordController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,90 @@
package com.doumee.api.business;

import com.doumee.api.BaseController;
import com.doumee.core.annotation.excel.ExcelExporter;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.PageData;
import com.doumee.dao.business.model.FileRecord;
import com.doumee.service.business.FileRecordService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.shiro.authz.annotation.RequiresPermissions;    
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;

import java.util.ArrayList;
import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/09/19 17:30
 */
@Api(tags = "附件上传进度表")
@RestController
@RequestMapping("/business/fileRecord")
public class FileRecordController extends BaseController {

    @Autowired
    private FileRecordService fileRecordService;

    @PreventRepeat
    @ApiOperation("新建")
    @PostMapping("/create")
    @RequiresPermissions("business:filerecord:create")
    public ApiResponse create(@RequestBody FileRecord fileRecord) {
        return ApiResponse.success(fileRecordService.create(fileRecord));
    }

    @ApiOperation("根据ID删除")
    @GetMapping("/delete/{id}")
    @RequiresPermissions("business:filerecord:delete")
    public ApiResponse deleteById(@PathVariable Integer id) {
        fileRecordService.deleteById(id);
        return ApiResponse.success(null);
    }

    @ApiOperation("批量删除")
    @GetMapping("/delete/batch")
    @RequiresPermissions("business:filerecord:delete")
    public ApiResponse deleteByIdInBatch(@RequestParam String ids) {
        String [] idArray = ids.split(",");
        List<Integer> idList = new ArrayList<>();
        for (String id : idArray) {
            idList.add(Integer.valueOf(id));
        }
        fileRecordService.deleteByIdInBatch(idList);
        return ApiResponse.success(null);
    }

    @ApiOperation("根据ID修改")
    @PostMapping("/updateById")
    @RequiresPermissions("business:filerecord:update")
    public ApiResponse updateById(@RequestBody FileRecord fileRecord) {
        fileRecordService.updateById(fileRecord);
        return ApiResponse.success(null);
    }

    @ApiOperation("分页查询")
    @PostMapping("/page")
    @RequiresPermissions("business:filerecord:query")
    public ApiResponse<PageData<FileRecord>> findPage (@RequestBody PageWrap<FileRecord> pageWrap) {
        return ApiResponse.success(fileRecordService.findPage(pageWrap));
    }

    @ApiOperation("导出Excel")
    @PostMapping("/exportExcel")
    @RequiresPermissions("business:filerecord:exportExcel")
    public void exportExcel (@RequestBody PageWrap<FileRecord> pageWrap, HttpServletResponse response) {
        ExcelExporter.build(FileRecord.class).export(fileRecordService.findPage(pageWrap).getRecords(), "附件上传进度表", response);
    }

    @ApiOperation("根据ID查询")
    @GetMapping("/{id}")
    @RequiresPermissions("business:filerecord:query")
    public ApiResponse findById(@PathVariable Integer id) {
        return ApiResponse.success(fileRecordService.findById(id));
    }
}

 server/service/src/main/java/com/doumee/core/model/LoginUserInfo.java

@@ -1,5 +1,6 @@
package com.doumee.core.model;

import com.doumee.dao.business.model.Company;
import com.doumee.dao.system.model.SystemPermission;
import com.doumee.dao.system.model.SystemRole;
import com.doumee.dao.system.model.SystemUser;
@@ -38,6 +39,7 @@
    private Integer cityId;
    private Integer parentId;
    private Integer type;
    private Company company;

    private List<String> roles;

@@ -50,6 +52,7 @@
        // æ‹·è´ç”¨æˆ·ä¿¡æ¯
        LoginUserInfo loginUserInfo = new LoginUserInfo();
        BeanUtils.copyProperties(user, loginUserInfo);
        loginUserInfo.setCompany(user.getCompany());
        // è®¾ç½®è§’色信息
        List<String> rs = new ArrayList<>();
        for (SystemRole role : roles) {

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
package com.doumee.dao.business;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.FileRecord;

import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/09/19 17:30
 */
public interface FileRecordMapper extends BaseMapper<FileRecord> {

    void insertBatch(List<FileRecord> fileRecords);
}

 server/service/src/main/java/com/doumee/dao/business/model/FileRecord.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,78 @@
package com.doumee.dao.business.model;

import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import com.fasterxml.jackson.annotation.JsonFormat;
import java.util.Date;

/**
 * é™„件上传进度表
 * @author æ±Ÿè¹„蹄
 * @date 2023/09/19 17:30
 */
@Data
@ApiModel("附件上传进度表")
@TableName("`file_record`")
public class FileRecord {

    @ApiModelProperty(value = "主键", example = "1")
    @ExcelColumn(name="主键")
    private Integer id;

    @ApiModelProperty(value = "创建人编码", example = "1")
    @ExcelColumn(name="创建人编码")
    private Integer creator;

    @ApiModelProperty(value = "创建时间")
    @ExcelColumn(name="创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd")
    private Date createDate;

    @ApiModelProperty(value = "更新人编码", example = "1")
    @ExcelColumn(name="更新人编码")
    private Integer editor;

    @ApiModelProperty(value = "更新时间")
    @ExcelColumn(name="更新时间")
    @JsonFormat(pattern = "yyyy-MM-dd")
    private Date editDate;

    @ApiModelProperty(value = "是否删除0否 1是", example = "1")
    @ExcelColumn(name="是否删除0否 1是")
    private Integer isdeleted;

    @ApiModelProperty(value = "文件名")
    @ExcelColumn(name="文件名")
    private String name;
    @ApiModelProperty(value = "网络图地址")
    @ExcelColumn(name="网络图地址")
    private String url;

    @ApiModelProperty(value = "备注")
    @ExcelColumn(name="备注")
    private String info;

    @ApiModelProperty(value = "关联对象编码", example = "1")
    @ExcelColumn(name="关联对象编码")
    private String objId;

    @ApiModelProperty(value = "类型0图片 1视频 2其他", example = "1")
    @ExcelColumn(name="类型0图片 1视频 2其他")
    private Integer type;

    @ApiModelProperty(value = "文件夹名称")
    @ExcelColumn(name="文件夹名称")
    private String folder;
    @ApiModelProperty(value = "上传结果")
    @ExcelColumn(name="上传结果")
    private String content;

    @ApiModelProperty(value = "状态 0未上传 1已上传 2上传失败", example = "1")
    @ExcelColumn(name="状态 0未上传 1已上传 2上传失败")
    private Integer status;
}

 server/service/src/main/java/com/doumee/dao/system/model/SystemUser.java

@@ -3,6 +3,7 @@
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.doumee.core.constants.OperaType;
import com.doumee.dao.business.model.Company;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import com.baomidou.mybatisplus.annotation.IdType;
@@ -96,5 +97,8 @@

    @ApiModelProperty(value = "0 å¯ç”¨ 1 ç¦ç”¨")
    private Integer status;
    @ApiModelProperty(value = "0 å¯ç”¨ 1 ç¦ç”¨")
    @TableField(exist = false)
    private Company company;

}

 server/service/src/main/java/com/doumee/service/business/FileRecordService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,97 @@
package com.doumee.service.business;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.dao.business.model.FileRecord;
import java.util.List;

/**
 * é™„件上传进度表Service定义
 * @author æ±Ÿè¹„蹄
 * @date 2023/09/19 17:30
 */
public interface FileRecordService {

    /**
     * åˆ›å»º
     * 
     * @param fileRecord å®žä½“对象
     * @return Integer
     */
    Integer create(FileRecord fileRecord);

    /**
     * ä¸»é”®åˆ é™¤
     *
     * @param id ä¸»é”®
     */
    void deleteById(Integer id);

    /**
     * åˆ é™¤
     *
     * @param fileRecord å®žä½“对象
     */
    void delete(FileRecord fileRecord);

    /**
     * æ‰¹é‡ä¸»é”®åˆ é™¤
     *
     * @param ids ä¸»é”®é›†
     */
    void deleteByIdInBatch(List<Integer> ids);

    /**
     * ä¸»é”®æ›´æ–°
     *
     * @param fileRecord å®žä½“对象
     */
    void updateById(FileRecord fileRecord);

    /**
     * æ‰¹é‡ä¸»é”®æ›´æ–°
     *
     * @param fileRecords å®žä½“集
     */
    void updateByIdInBatch(List<FileRecord> fileRecords);

    /**
     * ä¸»é”®æŸ¥è¯¢
     *
     * @param id ä¸»é”®
     * @return FileRecord
     */
    FileRecord findById(Integer id);

    /**
     * æ¡ä»¶æŸ¥è¯¢å•æ¡è®°å½•
     *
     * @param fileRecord å®žä½“对象
     * @return FileRecord
     */
    FileRecord findOne(FileRecord fileRecord);

    /**
     * æ¡ä»¶æŸ¥è¯¢
     *
     * @param fileRecord å®žä½“对象
     * @return List<FileRecord>
     */
    List<FileRecord> findList(FileRecord fileRecord);
  
    /**
     * åˆ†é¡µæŸ¥è¯¢
     *
     * @param pageWrap åˆ†é¡µå¯¹è±¡
     * @return PageData<FileRecord>
     */
    PageData<FileRecord> findPage(PageWrap<FileRecord> pageWrap);

    /**
     * æ¡ä»¶ç»Ÿè®¡
     *
     * @param fileRecord å®žä½“对象
     * @return long
     */
    long count(FileRecord fileRecord);
}

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

@@ -61,6 +61,8 @@
    private BaseCateParamMapper baseCateParamMapper;
    @Autowired
    private BrandMapper brandMapper;
    @Autowired
    private FileRecordMapper fileRecordMapper;

    @Override
    public String create(BaseData baseData) {
@@ -316,7 +318,7 @@
    public static   boolean IS_RUNNING = false;
    @Override
    @Async
    @Transactional(isolation = Isolation.READ_UNCOMMITTED)
    @Transactional
    public   void dealBaseData() {
        if(IS_RUNNING){
            return;
@@ -353,6 +355,8 @@
            Date date = new Date();
            List<BaseCateParam> baseCateParamList = new ArrayList<>();
            List<Multifile> fileList = new ArrayList<>();
            List<Integer> goodsIdList = new ArrayList<>();
            List<FileRecord> fileRecords = new ArrayList<>();
            List<BaseGoodsParam> baseGoodsParamList = new ArrayList<>();
            for(BaseData data : allLis){
                BaseGoods goods = new BaseGoods();
@@ -374,35 +378,19 @@
                    goods.setBrandId(bModel.getId());
                }
                //处理列表数据
                BaseCategory cModel = getCateModelFromList(rate,data.getCategory(),ossModel,data.getCategoryImg(), cateList);
                BaseCategory cModel = getCateModelFromList(rate,data.getCategory(),ossModel,data.getCategoryImg(), cateList,fileRecords);
                if(cModel!= null){
                    goods.setCategoryId(cModel.getId());
                }
                goods.setImgurl(getOssImgurl(ossModel,ossModel.getGoodsFolder(), data.getImgurl()));
//                goods.setImgurl(getOssImgurl(ossModel,ossModel.getGoodsFolder(), data.getImgurl()));
                goods.setImgurl(getOssImgurlFile(ossModel.getGoodsFolder(), data.getImgurl(), data.getId(),Constants.ZERO,fileRecords));
                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);
                    goodsIdList.add(goods.getId());
                }else{
                    //插入新商品数据
                    goods.setCreateDate(date);
@@ -411,17 +399,36 @@
                 //处理分类属性
                dealCateParamAll(cModel.getId(),goods.getId(),data,paramList, baseGoodsParamList );
                 //处理背景图
                dealBgImgAll(ossModel,goods.getId(),data,fileList);
                dealBgImgAll(ossModel,goods.getId(),data,fileList,fileRecords);
                data.setEditDate(new Date());
                data.setStatus(Constants.ONE);
                //更新数据处理状态
                baseDataMapper.updateById(data);
            }
            if(goodsIdList.size()>0){
                //删除原有附件大图
                UpdateWrapper<Multifile> updateModel = new UpdateWrapper<>();
                updateModel.lambda().set(Multifile::getIsdeleted,Constants.ONE);
                updateModel.lambda().set(Multifile::getEditDate, new Date());
                updateModel.lambda().in(Multifile::getObjId, goodsIdList);
                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().in(BaseGoodsParam::getGoodsId, goodsIdList);
                baseGoodsParamMapper.delete(bgModel);
            }

            if(fileList.size()>0){
                multifileMapper.insertBatch(fileList);
            }
            if(baseGoodsParamList.size()>0){
                baseGoodsParamMapper.insertBatch(baseGoodsParamList);
            }
            if(fileRecords.size()>0){
                fileRecordMapper.insertBatch(fileRecords);
            }
            log.info("开始处理源数据=================success================处理数据共（"+allLis.size()+"）个===");
        }catch (Exception e){
@@ -435,7 +442,7 @@
    }


    private void dealBgImgAll(OssModel ossModel, Integer id, BaseData data,List<Multifile> fileList) {
    private void dealBgImgAll(OssModel ossModel, Integer id, BaseData data,List<Multifile> fileList,List<FileRecord> fileRecords) {
        int i =0;
        //多图，英文逗号隔开
        if(StringUtils.isNotBlank(data.getBgImg())){
@@ -443,7 +450,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],fileList);
                    i += addImg(i,ossModel,id,imgs[j],fileList,fileRecords);
                }
            }
        }
@@ -452,9 +459,10 @@
//        addImg(i,ossModel,id,data.getBgImg3());
    }

    private int addImg(int i,OssModel ossModel, Integer id,String bgImg,List<Multifile> fileList) {
    private int addImg(int i,OssModel ossModel, Integer id,String bgImg,List<Multifile> fileList,List<FileRecord> fileRecords) {
        if(StringUtils.isNotBlank(bgImg)){
            String img =getOssImgurl(ossModel, ossModel.getGoodsFolder() ,bgImg);
//            String img =getOssImgurl(ossModel, ossModel.getGoodsFolder() ,bgImg);
            String img = getOssImgurlFile(ossModel.getGoodsFolder(), bgImg, null,Constants.TWO,fileRecords);
            if(StringUtils.isNotBlank(img)){
                Multifile f = new Multifile();
                f.setFileurl(img);
@@ -627,7 +635,7 @@
     * @return
     */

    private BaseCategory getCateModelFromList(BigDecimal dRate,String name, OssModel ossModel, String img, List<BaseCategory> list) {
    private BaseCategory getCateModelFromList(BigDecimal dRate,String name, OssModel ossModel, String img, List<BaseCategory> list, List<FileRecord> fileRecords) {
        if(StringUtils.isBlank(name)){
            return  null;
        }
@@ -645,7 +653,8 @@
        model.setIsdeleted(Constants.ZERO);
        model.setPinyin(PinYinUtil.getFullSpell(model.getName()));
        model.setShortPinyin(PinYinUtil.getFirstSpell(model.getName()));
        model.setImgurl(getOssImgurl(ossModel, ossModel.getCateFolder() ,img));
//        model.setImgurl(getOssImgurl(ossModel, ossModel.getCateFolder() ,img));
        model.setImgurl(getOssImgurlFile(ossModel.getCateFolder(), img, null,Constants.ONE,fileRecords));
        //插入新的品牌信息
        baseCategoryMapper.insert(model);
        //加入集合中
@@ -666,6 +675,7 @@
            String tempFileName = nowDate + "/" + fileName;
            String key =folder+ tempFileName;// æ–‡ä»¶å


            ALiYunUtil obs = new ALiYunUtil(ossModel.getEndpoint(), ossModel.getAccessId(), ossModel.getAccessKey());
            if (obs.uploadOnlineObject(img,ossModel.getBucket(), key,null)) {
                    return  tempFileName;
@@ -675,6 +685,33 @@
        }
        return  null;
    }
    public String getOssImgurlFile(String folder,String img ,String id,Integer objType,List<FileRecord> fileRecords) {
        if(StringUtils.isBlank(img)){
            return null;
        }
        try {
            String nowDate = DateUtil.getNowShortDate();// å½“前时间（年月日）
            String nfix  = img.lastIndexOf(".")>0?img.substring(img.lastIndexOf(".")):null;
            nfix = StringUtils.defaultString(nfix,".jpg");
            String fileName = UUID.randomUUID() + nfix;
            String tempFileName = nowDate + "/" + fileName;
            String key =folder+ tempFileName;// æ–‡ä»¶å

            FileRecord model = new FileRecord();
            model.setIsdeleted(Constants.ZERO);
            model.setCreateDate(new Date());
            model.setName(key);
            model.setInfo(tempFileName);
            model.setFolder(folder);
            model.setUrl(img);
            model.setObjId(id);
            model.setType(objType);
            model.setStatus(Constants.ZERO);
        }catch (Exception e){

        }
        return  null;
    }

    @Override
    public     String getOssImgurl(OssModel ossModel, String folder, File f) {

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,145 @@
package com.doumee.service.business.impl;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.FileRecordMapper;
import com.doumee.dao.business.model.FileRecord;
import com.doumee.service.business.FileRecordService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.List;

/**
 * é™„件上传进度表Service实现
 * @author æ±Ÿè¹„蹄
 * @date 2023/09/19 17:30
 */
@Service
public class FileRecordServiceImpl implements FileRecordService {

    @Autowired
    private FileRecordMapper fileRecordMapper;

    @Override
    public Integer create(FileRecord fileRecord) {
        fileRecordMapper.insert(fileRecord);
        return fileRecord.getId();
    }

    @Override
    public void deleteById(Integer id) {
        fileRecordMapper.deleteById(id);
    }

    @Override
    public void delete(FileRecord fileRecord) {
        UpdateWrapper<FileRecord> deleteWrapper = new UpdateWrapper<>(fileRecord);
        fileRecordMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        fileRecordMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(FileRecord fileRecord) {
        fileRecordMapper.updateById(fileRecord);
    }

    @Override
    public void updateByIdInBatch(List<FileRecord> fileRecords) {
        if (CollectionUtils.isEmpty(fileRecords)) {
            return;
        }
        for (FileRecord fileRecord: fileRecords) {
            this.updateById(fileRecord);
        }
    }

    @Override
    public FileRecord findById(Integer id) {
        return fileRecordMapper.selectById(id);
    }

    @Override
    public FileRecord findOne(FileRecord fileRecord) {
        QueryWrapper<FileRecord> wrapper = new QueryWrapper<>(fileRecord);
        return fileRecordMapper.selectOne(wrapper);
    }

    @Override
    public List<FileRecord> findList(FileRecord fileRecord) {
        QueryWrapper<FileRecord> wrapper = new QueryWrapper<>(fileRecord);
        return fileRecordMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<FileRecord> findPage(PageWrap<FileRecord> pageWrap) {
        IPage<FileRecord> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<FileRecord> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(FileRecord::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getCreator() != null) {
            queryWrapper.lambda().eq(FileRecord::getCreator, pageWrap.getModel().getCreator());
        }
        if (pageWrap.getModel().getCreateDate() != null) {
            queryWrapper.lambda().ge(FileRecord::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
            queryWrapper.lambda().le(FileRecord::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
        }
        if (pageWrap.getModel().getEditor() != null) {
            queryWrapper.lambda().eq(FileRecord::getEditor, pageWrap.getModel().getEditor());
        }
        if (pageWrap.getModel().getEditDate() != null) {
            queryWrapper.lambda().ge(FileRecord::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
            queryWrapper.lambda().le(FileRecord::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
        }
        if (pageWrap.getModel().getIsdeleted() != null) {
            queryWrapper.lambda().eq(FileRecord::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getName() != null) {
            queryWrapper.lambda().eq(FileRecord::getName, pageWrap.getModel().getName());
        }
        if (pageWrap.getModel().getInfo() != null) {
            queryWrapper.lambda().eq(FileRecord::getInfo, pageWrap.getModel().getInfo());
        }
        if (pageWrap.getModel().getObjId() != null) {
            queryWrapper.lambda().eq(FileRecord::getObjId, pageWrap.getModel().getObjId());
        }
        if (pageWrap.getModel().getType() != null) {
            queryWrapper.lambda().eq(FileRecord::getType, pageWrap.getModel().getType());
        }
        if (pageWrap.getModel().getFolder() != null) {
            queryWrapper.lambda().eq(FileRecord::getFolder, pageWrap.getModel().getFolder());
        }
        if (pageWrap.getModel().getStatus() != null) {
            queryWrapper.lambda().eq(FileRecord::getStatus, pageWrap.getModel().getStatus());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(fileRecordMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(FileRecord fileRecord) {
        QueryWrapper<FileRecord> wrapper = new QueryWrapper<>(fileRecord);
        return fileRecordMapper.selectCount(wrapper);
    }
}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
<?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.FileRecordMapper">

    <insert id="insertBatch" >
        insert into file_record(
        `CREATOR`,
        `CREATE_DATE`,
        `EDITOR`,
        `EDIT_DATE`,
        `ISDELETED`,
        `NAME`,
        `INFO`,
        `STATUS`,
        `TYPE`,
        `OBJ_ID`,
        `FOLDER`,
        `URL`
        ) values
        <foreach collection="list" separator="," item="item">
            (#{item.creator}
            ,#{item.createDate}
            ,#{item.editor}
            ,#{item.editDate}
            ,#{item.isdeleted}
            ,#{item.name}
            ,#{item.info}
            ,#{item.status}
            ,#{item.objId}
            ,#{item.type}
            ,#{item.folder}
            ,#{item.url}
        </foreach>
    </insert>

</mapper>