main-business/src/main/java/com/ruoyi/business/controller/FileController.java

ÎļþÒÑɾ³ý

 main-business/src/main/java/com/ruoyi/business/controller/SalesRecordController.java

@@ -29,8 +29,8 @@
     * é”€å”®è®°å½•è¡¨æŸ¥è¯¢
     */
    @GetMapping("/list")
    public R<IPage<SalesRecord>> list(Page page, SalesRecordDto salesRecordDto) {
        IPage<SalesRecord> list = salesRecordService.selectSalesRecordList(page,salesRecordDto);
    public R<IPage<SalesRecordDto>> list(Page<SalesRecord> page, SalesRecordDto salesRecordDto) {
        IPage<SalesRecordDto> list = salesRecordService.selectSalesRecordList(page,salesRecordDto);
        return R.ok(list);
    }


 main-business/src/main/java/com/ruoyi/business/dto/OfficialInventoryDto.java

@@ -13,4 +13,9 @@

    private List<Long> ids;

    /**
     * ç…¤ç§
     */
    private String coal;

}

 main-business/src/main/java/com/ruoyi/business/dto/PendingInventoryDto.java

@@ -38,4 +38,11 @@
     * å­—段名
     */
    private Integer type;

    /**
     * ç…¤ç§
     */
    private String coal;

    private String registrant;
}

 main-business/src/main/java/com/ruoyi/business/dto/SalesRecordDto.java

@@ -5,4 +5,6 @@

@Data
public class SalesRecordDto extends SalesRecord {

    private String coal;
}

 main-business/src/main/java/com/ruoyi/business/entity/File.java

ÎļþÒÑɾ³ý

 main-business/src/main/java/com/ruoyi/business/entity/PendingInventory.java

@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.ruoyi.common.core.domain.MyBaseEntity;
import lombok.Data;

@@ -81,10 +82,11 @@
     * ç™»è®°äºº
     */
    @TableField(value = "registrant_id")
    private String registrantId;
    private Long registrantId;
    /**
     * ç™»è®°æ—¥æœŸ
     */
    @TableField(value = "registration_date")
    @JsonFormat(pattern = "yyyy-MM-dd")
    private LocalDate registrationDate;
}

 main-business/src/main/java/com/ruoyi/business/entity/Production.java

@@ -76,7 +76,7 @@
     * ç”Ÿäº§äººID
     */
    @TableField(value = "producer_id")
    private String producerId;
    private Long producerId;
    /**
     * ç”Ÿäº§æ—¥æœŸ
     */

 main-business/src/main/java/com/ruoyi/business/entity/SalesRecord.java

@@ -48,11 +48,6 @@
    @TableField(value = "coal_id")
    private Long coalId;
    /**
     * ç…¤ç§
     */
    @TableField(value = "coal")
    private String coal;
    /**
     * å•ä»·ï¼ˆå«ç¨Žï¼‰
     */
    @TableField(value = "price_including_tax")

 main-business/src/main/java/com/ruoyi/business/mapper/FileMapper.java

ÎļþÒÑɾ³ý

 main-business/src/main/java/com/ruoyi/business/service/FileService.java

ÎļþÒÑɾ³ý

 main-business/src/main/java/com/ruoyi/business/service/SalesRecordService.java

@@ -2,9 +2,9 @@

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.business.dto.SalesRecordDto;
import com.ruoyi.business.entity.SalesRecord;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * <p>
@@ -16,7 +16,7 @@
 */
public interface SalesRecordService extends IService<SalesRecord> {

    IPage<SalesRecord> selectSalesRecordList(Page page, SalesRecordDto salesRecordDto);
    IPage<SalesRecordDto> selectSalesRecordList(Page<SalesRecord> page, SalesRecordDto salesRecordDto);

    int addOrEditSalesRecord(SalesRecordDto salesRecordDto);


 main-business/src/main/java/com/ruoyi/business/service/impl/ArchiveServiceImpl.java

@@ -57,6 +57,9 @@
        // 1. åˆ†é¡µæŸ¥è¯¢ä¸»æ•°æ®
        LambdaQueryWrapper<Archive> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.orderByDesc(Archive::getCreateTime);
        if (archiveDto.getTreeId() != null) {
            queryWrapper.eq(Archive::getTreeId, archiveDto.getTreeId());
        }
        IPage<Archive> archivePage = archiveMapper.selectPage(page, queryWrapper);

        // 2. æ— æ•°æ®æå‰è¿”回
@@ -137,6 +140,7 @@

        // 7. æž„建返回分页对象
        IPage<ArchiveDto> resultPage = new Page<>();
        BeanUtils.copyProperties(archivePage, resultPage);
        resultPage.setRecords(dtoList);
        return resultPage;
    }

 main-business/src/main/java/com/ruoyi/business/service/impl/FileServiceImpl.java

ÎļþÒÑɾ³ý

 main-business/src/main/java/com/ruoyi/business/service/impl/InspectionTaskServiceImpl.java

@@ -120,6 +120,7 @@

        // 7. æž„建返回分页对象
        IPage<InspectionTaskDto> resultPage = new Page<>();
        BeanUtils.copyProperties(entityPage, resultPage);
        resultPage.setRecords(dtoList);
        return resultPage;
    }

 main-business/src/main/java/com/ruoyi/business/service/impl/OfficialInventoryServiceImpl.java

@@ -7,8 +7,10 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.entity.CoalField;
import com.ruoyi.basic.entity.CoalInfo;
import com.ruoyi.basic.entity.CoalValue;
import com.ruoyi.basic.mapper.CoalFieldMapper;
import com.ruoyi.basic.mapper.CoalInfoMapper;
import com.ruoyi.basic.mapper.CoalValueMapper;
import com.ruoyi.business.dto.OfficialInventoryDto;
import com.ruoyi.business.entity.OfficialInventory;
@@ -23,6 +25,7 @@
import org.springframework.transaction.annotation.Transactional;

import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
@@ -42,6 +45,8 @@
    private final CoalValueMapper coalValueMapper;

    private final CoalFieldMapper coalFieldMapper;

    private final CoalInfoMapper coalInfoMapper;


    @Override
@@ -63,6 +68,21 @@
                .map(CoalField::getFields)
                .distinct()
                .collect(Collectors.toList());

        //查询煤种ids
        List<Long> coalIds = entityPage.getRecords().stream()
                .map(OfficialInventory::getCoalId)
                .distinct()
                .collect(Collectors.toList());

        // æ‰¹é‡æŸ¥è¯¢CoalInfo
        Map<Long, CoalInfo> coalInfoMap;
        if (!coalIds.isEmpty()) {
            List<CoalInfo> coalInfos = coalInfoMapper.selectList(new LambdaQueryWrapper<CoalInfo>().in(CoalInfo::getId, coalIds));
            coalInfoMap = coalInfos.stream().collect(Collectors.toMap(CoalInfo::getId, Function.identity()));
        } else {
            coalInfoMap = new HashMap<>();
        }

        //  éåŽ†æ¯æ¡è®°å½•ï¼Œè¿›è¡Œè½¬æ¢å¹¶å¡«å…… fields
        for (OfficialInventory entity : entityPage.getRecords()) {
@@ -97,6 +117,12 @@
                fields.add(fieldMap);
            }

            // è®¾ç½®Coal信息
            CoalInfo coalInfo = coalInfoMap.get(entity.getCoalId());
            if (coalInfo != null) {
                dto.setCoal(coalInfo.getCoal());
            }

            // è®¾ç½®åˆ° DTO ä¸­
            dto.setFields(fields);
            dtoList.add(dto);
@@ -120,6 +146,8 @@
                .map(OI -> {
                    OfficialInventoryVo vo = new OfficialInventoryVo();
                    BeanUtils.copyProperties(OI, vo);
                    CoalInfo coalInfo = coalInfoMapper.selectById(OI.getCoalId());
                    vo.setCoal(coalInfo.getCoal());
                    return vo;
                })
                .collect(Collectors.toList());

 main-business/src/main/java/com/ruoyi/business/service/impl/PendingInventoryServiceImpl.java

@@ -7,8 +7,10 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.entity.CoalField;
import com.ruoyi.basic.entity.CoalInfo;
import com.ruoyi.basic.entity.CoalValue;
import com.ruoyi.basic.mapper.CoalFieldMapper;
import com.ruoyi.basic.mapper.CoalInfoMapper;
import com.ruoyi.basic.mapper.CoalValueMapper;
import com.ruoyi.business.dto.PendingInventoryDto;
import com.ruoyi.business.entity.OfficialInventory;
@@ -18,14 +20,17 @@
import com.ruoyi.business.service.InputInventoryRecordService;
import com.ruoyi.business.service.InventorySummaryService;
import com.ruoyi.business.service.PendingInventoryService;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.exception.base.BaseException;
import com.ruoyi.common.utils.bean.BeanUtils;
import com.ruoyi.system.mapper.SysUserMapper;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
@@ -47,6 +52,10 @@
    private final CoalValueMapper coalValueMapper;

    private final CoalFieldMapper coalFieldMapper;

    private final CoalInfoMapper coalInfoMapper;

    private final SysUserMapper sysUserMapper;

    private final InputInventoryRecordService inputInventoryRecordService;

@@ -71,20 +80,63 @@
                .map(PendingInventory::getId)
                .collect(Collectors.toList());

        // 5. æ‰¹é‡æŸ¥è¯¢å…³è”的正式库存信息
        // 5. æ‰¹é‡æŸ¥è¯¢å…³è”的煤炭信息和正式库存信息
        List<Long> coalIds = pendingInventoryPage.getRecords().stream()
                .map(PendingInventory::getCoalId)
                .distinct()
                .collect(Collectors.toList());

        // æ‰¹é‡æŸ¥è¯¢CoalInfo
        Map<Long, CoalInfo> coalInfoMap;
        if (!coalIds.isEmpty()) {
            List<CoalInfo> coalInfos = coalInfoMapper.selectList(new LambdaQueryWrapper<CoalInfo>().in(CoalInfo::getId, coalIds));
            coalInfoMap = coalInfos.stream().collect(Collectors.toMap(CoalInfo::getId, Function.identity()));
        } else {
            coalInfoMap = new HashMap<>();
        }

        // 5. æ‰¹é‡æŸ¥è¯¢ç™»è®°äººid
        List<Long> registrantIds = pendingInventoryPage.getRecords().stream()
                .map(PendingInventory::getRegistrantId)
                .distinct()
                .toList();
        // æ‰¹é‡æŸ¥è¯¢ç™»è®°äºº
        Map<Long, SysUser> sysUserMap;
        if (!registrantIds.isEmpty()) {
            List<SysUser> sysUsers = sysUserMapper.selectList(registrantIds);
            sysUserMap = sysUsers.stream().collect(Collectors.toMap(SysUser::getUserId, Function.identity()));
        } else {
            sysUserMap = new HashMap<>();
        }

        // æ‰¹é‡æŸ¥è¯¢æ­£å¼åº“存信息
        Map<Long, Long> pendingToOfficialMap = getOfficialInventoryMap(pendingIds);

        // 6. ä½¿ç”¨MyBatis-Plus的convert方法转换DTO
        // 6. è½¬æ¢DTO并设置相关字段
        return pendingInventoryPage.convert(record -> {
            PendingInventoryDto dto = new PendingInventoryDto();
            BeanUtils.copyProperties(record, dto);

            // è®¾ç½®Coal信息
            CoalInfo coalInfo = coalInfoMap.get(record.getCoalId());
            if (coalInfo != null) {
                dto.setCoal(coalInfo.getCoal());
            }

            // è®¾ç½®ç™»è®°äºº
            SysUser sysUser = sysUserMap.get(record.getRegistrantId());
            if (sysUser != null) {
                dto.setRegistrant(sysUser.getNickName());
            }

            // ä»Žé¢„加载的Map中获取officialId
            dto.setOfficialId(pendingToOfficialMap.getOrDefault(record.getId(), null));

            return dto;
        });
    }


    // æ‰¹é‡èŽ·å–待处理库存与正式库存的映射关系
    private Map<Long, Long> getOfficialInventoryMap(List<Long> pendingIds) {
        if (CollectionUtils.isEmpty(pendingIds)) {

 main-business/src/main/java/com/ruoyi/business/service/impl/ProductionMasterServiceImpl.java

@@ -5,7 +5,6 @@
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.entity.CoalInfo;
import com.ruoyi.basic.mapper.CoalInfoMapper;
import com.ruoyi.business.dto.ProductionMasterDto;
import com.ruoyi.business.entity.*;
@@ -18,6 +17,7 @@
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.util.*;
import java.util.stream.Collectors;

@@ -77,7 +77,6 @@
        IPage<ProductionMasterDto> dtoPage = new Page<>();
        BeanUtils.copyProperties(entityPage, dtoPage, "records");
        dtoPage.setRecords(dtoList);

        return dtoPage;
    }

@@ -212,8 +211,6 @@
            coalIds.add(p.getCoalId());
        }

        List<CoalInfo> coalInfos = coalInfoMapper.selectList(new LambdaQueryWrapper<CoalInfo>().in(CoalInfo::getId, coalIds));

        ProductionMaster master = new ProductionMaster();
        master.setProductionQuantity(totalQuantity);
        master.setTotalCost(totalCost);
@@ -264,7 +261,8 @@
            pending.setSupplierName("生产加工入库");
            pending.setTotalPriceIncludingTax(p.getTotalCost());
            pending.setPriceIncludingTax(p.getPurchasePrice());
            pending.setPriceIncludingTax(p.getPurchasePrice());
            pending.setRegistrantId(p.getProducerId());
            pending.setRegistrationDate(LocalDate.now());
            pendingInventoryMapper.insert(pending);
        }
    }

 main-business/src/main/java/com/ruoyi/business/service/impl/SalesRecordServiceImpl.java

@@ -5,7 +5,9 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.basic.entity.CoalInfo;
import com.ruoyi.basic.entity.Customer;
import com.ruoyi.basic.mapper.CoalInfoMapper;
import com.ruoyi.basic.mapper.CustomerMapper;
import com.ruoyi.business.dto.SalesRecordDto;
import com.ruoyi.business.entity.OfficialInventory;
@@ -22,6 +24,11 @@
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDate;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
 * <p>
@@ -43,12 +50,60 @@

    private final OfficialInventoryMapper officialInventoryMapper;

    private final CoalInfoMapper coalInfoMapper;

    @Override
    public IPage<SalesRecord> selectSalesRecordList(Page page, SalesRecordDto salesRecordDto) {
    public IPage<SalesRecordDto> selectSalesRecordList(Page<SalesRecord> page, SalesRecordDto salesRecordDto) {
        // 1. åˆ›å»ºæŸ¥è¯¢æ¡ä»¶ï¼ŒæŒ‰åˆ›å»ºæ—¶é—´å€’序排序
        LambdaQueryWrapper<SalesRecord> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.orderByDesc(SalesRecord::getCreateTime);
        return salesRecordMapper.selectPage(page, queryWrapper);

        // 2. èŽ·å–分页的销售记录
        IPage<SalesRecord> salesRecordPage = salesRecordMapper.selectPage(page, queryWrapper);

        // 3. æ‰¹é‡æŸ¥è¯¢æ‰€æœ‰CoalInfo
        List<Long> coalIds = salesRecordPage.getRecords().stream()
                .map(SalesRecord::getCoalId)  // èŽ·å–所有SalesRecord的coalId
                .collect(Collectors.toList());
        Map<Long, CoalInfo> coalInfoMap;

        // å¦‚果有煤炭ID，执行批量查询
        if (!coalIds.isEmpty()) {
            // ä½¿ç”¨selectList进行批量查询
            LambdaQueryWrapper<CoalInfo> coalInfoQueryWrapper = new LambdaQueryWrapper<>();
            coalInfoQueryWrapper.in(CoalInfo::getId, coalIds);
            List<CoalInfo> coalInfos = coalInfoMapper.selectList(coalInfoQueryWrapper);

            // å°†æŸ¥è¯¢ç»“果放入Map中，煤炭ID为键，CoalInfo为值
            coalInfoMap = coalInfos.stream()
                    .collect(Collectors.toMap(CoalInfo::getId, Function.identity()));
        } else {
            coalInfoMap = new HashMap<>();
        }

        // 4. åˆ›å»ºè¿”回结果页，使用BeanUtils进行属性复制
        Page<SalesRecordDto> resultPage = new Page<>();
        BeanUtils.copyProperties(salesRecordPage, resultPage);  // å¤åˆ¶åˆ†é¡µä¿¡æ¯

        // 5. è½¬æ¢SalesRecord为SalesRecordDto，并设置每条销售记录的煤炭信息
        List<SalesRecordDto> dtoList = salesRecordPage.getRecords().stream().map(salesRecord -> {
            SalesRecordDto dto = new SalesRecordDto();
            BeanUtils.copyProperties(salesRecord, dto);  // å°†SalesRecord的属性复制到SalesRecordDto中

            // è®¾ç½®Coal信息
            CoalInfo coalInfo = coalInfoMap.get(salesRecord.getCoalId());
            if (coalInfo != null) {
                dto.setCoal(coalInfo.getCoal());
            }

            return dto;
        }).collect(Collectors.toList());

        resultPage.setRecords(dtoList);  // è®¾ç½®è½¬æ¢åŽçš„DTO列表

        return resultPage;
    }


    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -61,7 +116,7 @@
        if (officialInventory == null) {
            throw new BaseException("正式库煤种信息不存在");
        }
        if (salesRecordDto.getSaleQuantity().compareTo(officialInventory.getInventoryQuantity()) > 0){
        if (salesRecordDto.getSaleQuantity().compareTo(officialInventory.getInventoryQuantity()) > 0) {
            throw new BaseException("销售数量不能大于库存数量");
        }
        officialInventory.setInventoryQuantity(officialInventory.getInventoryQuantity().subtract(salesRecordDto.getSaleQuantity()));
@@ -69,7 +124,7 @@
        officialInventoryMapper.updateById(officialInventory);

        // æž„建销售记录实体
        SalesRecord salesRecord = buildSalesRecord(salesRecordDto,officialInventory.getCoalId());
        SalesRecord salesRecord = buildSalesRecord(salesRecordDto, officialInventory.getCoalId());

        // å¤„理新增/更新逻辑
        if (salesRecordDto.getId() == null) {
@@ -94,7 +149,7 @@
        }
    }

    private SalesRecord buildSalesRecord(SalesRecordDto dto,Long coalId) {
    private SalesRecord buildSalesRecord(SalesRecordDto dto, Long coalId) {
        SalesRecord record = new SalesRecord();
        BeanUtils.copyProperties(dto, record);


 main-business/src/main/java/com/ruoyi/business/service/impl/TreeServiceImpl.java

@@ -33,6 +33,7 @@
    public List<TreeVo> selectTreeList(TreeDto treeDto) {
        // æŸ¥è¯¢æ ¹èŠ‚点（parentId ä¸º null）
        LambdaQueryWrapper<Tree> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.orderByAsc(Tree::getCreateTime);
        queryWrapper.isNull(Tree::getParentId);

        // å¦‚果有产品名称条件，添加到查询中

 main-business/src/main/java/com/ruoyi/business/vo/OfficialInventoryVo.java

@@ -8,6 +8,7 @@
public class OfficialInventoryVo {

    private Long id;  // ä¸»é”®ID
    private Long coalId;   // ç…¤ç§id
    private String coal;   // ç…¤ç§
    private String unit;   // å•ä½
    private BigDecimal inventoryQuantity;  // åº“存数量

 main-business/src/main/resources/db/migration/postgresql/V20250604101800__create_table_production.sql

@@ -10,7 +10,7 @@
    equipment_depreciation  DECIMAL(10, 2) NOT NULL,           -- è®¾å¤‡æŠ˜æ—§
    purchase_price          DECIMAL(10, 2) NOT NULL,           -- é‡‡è´­å•ä»·
    total_cost              DECIMAL(10, 2) NOT NULL,           -- æ€»æˆæœ¬
    producer_id             VARCHAR(50),                       -- ç”Ÿäº§äººid
    producer_id             BIGINT,                       -- ç”Ÿäº§äººid
    producer                VARCHAR(50),                       -- ç”Ÿäº§äºº
    production_date         DATE,                              -- ç”Ÿäº§æ—¥æœŸ


 main-business/src/main/resources/db/migration/postgresql/V20250604104500__create_table_pending_inventory.sql

@@ -12,7 +12,7 @@
    registration_time         TIMESTAMP(6) DEFAULT CURRENT_TIMESTAMP, -- ç™»è®°æ—¶é—´
    price_excluding_tax       VARCHAR(255),                           -- å•ä»·ï¼ˆä¸å«ç¨Žï¼‰
    total_price_excluding_tax VARCHAR(255),                           -- æ€»ä»·ï¼ˆä¸å«ç¨Žï¼‰
    registrant_id             VARCHAR(32),                            -- ç™»è®°äººID
    registrant_id             BIGINT,                                 -- ç™»è®°äººID
    registration_date         DATE,                                   -- ç™»è®°æ—¥æœŸ
    supplier_id               BIGINT,                                 -- ä¾›è´§å•†ID
    coal_id                   BIGINT,                                 -- ç…¤ç§ID

 main-business/src/main/resources/db/migration/postgresql/V20250610161314__create_table_file.sql

ÎļþÒÑɾ³ý

 main-business/src/main/resources/db/migration/postgresql/V20250611160300__create_table_sales_record.sql

@@ -6,7 +6,6 @@
    customer_id         BIGINT,                           -- å®¢æˆ·id
    customer            VARCHAR(255)   NOT NULL,          -- å®¢æˆ·
    coal_id             VARCHAR(255)   NOT NULL,          -- ç…¤ç§ id
    coal                VARCHAR(255)   NOT NULL,          -- ç…¤ç§
    price_including_tax DECIMAL(10, 2) NOT NULL,          -- å•ä»·ï¼ˆå«ç¨Žï¼‰
    inventory_quantity  DECIMAL(10, 0) NOT NULL,          -- åº“存数量
    unit                VARCHAR(100)   NOT NULL,          -- å•ä½
@@ -37,7 +36,6 @@
COMMENT ON COLUMN sales_record.sale_date IS '销售日期';
COMMENT ON COLUMN sales_record.customer IS '客户';
COMMENT ON COLUMN sales_record.customer_id IS '客户id';
COMMENT ON COLUMN sales_record.coal IS '煤种';
COMMENT ON COLUMN sales_record.coal_id IS '煤种id';
COMMENT ON COLUMN sales_record.unit IS '单位';
COMMENT ON COLUMN sales_record.price_including_tax IS '单价（含税）';

 main-business/src/main/resources/mapper/FileMapper.xml

ÎļþÒÑɾ³ý

 ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserMapper.java

@@ -129,4 +129,6 @@
     * æŸ¥è¯¢æ‰€æœ‰ç”¨æˆ·
     */
    List<SysUser> selectUserListAll();

    List<SysUser> selectList(List<Long> registrantIds);
}

 ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -144,8 +144,22 @@
    <select id="selectUserListAll" resultType="com.ruoyi.common.core.domain.entity.SysUser">
        select user_id, nick_name from sys_user where del_flag = '0'
    </select>
    <select id="selectList" resultType="com.ruoyi.common.core.domain.entity.SysUser">
        SELECT user_id, nick_name FROM sys_user
        <where>
            <if test="list != null and list.size() > 0">
                user_id IN
                <foreach item="id" collection="list" open="(" separator="," close=")">
                    #{id}
                </foreach>
            </if>
            <if test="list == null or list.size() == 0">
                1=0  <!-- ç©ºåˆ—表时返回空结果 -->
            </if>
        </where>
    </select>

    <insert id="insertUser" parameterType="SysUser" useGeneratedKeys="true" keyProperty="userId">
    <insert id="insertUser" parameterType="SysUser" useGeneratedKeys="true" keyProperty="userId">
         insert into sys_user(
             <if test="userId != null and userId != 0">user_id,</if>
             <if test="deptId != null and deptId != 0">dept_id,</if>