diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/controller/MpsEmpAddItemsController.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/controller/MpsEmpAddItemsController.java new file mode 100644 index 0000000..fb1bcd1 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/controller/MpsEmpAddItemsController.java @@ -0,0 +1,133 @@ +package org.dromara.mps.controller; + +import java.util.List; +import java.util.ArrayList; + +import lombok.RequiredArgsConstructor; +import jakarta.servlet.http.HttpServletResponse; +import jakarta.validation.constraints.*; +import cn.dev33.satoken.annotation.SaCheckPermission; +import org.springframework.http.MediaType; +import org.springframework.web.multipart.MultipartFile; +import org.dromara.common.excel.core.ExcelResult; +import org.springframework.web.bind.annotation.*; +import org.springframework.validation.annotation.Validated; +import org.dromara.common.idempotent.annotation.RepeatSubmit; +import org.dromara.common.log.annotation.Log; +import org.dromara.common.web.core.BaseController; +import org.dromara.common.mybatis.core.page.PageQuery; +import org.dromara.common.core.domain.R; +import org.dromara.common.core.validate.AddGroup; +import org.dromara.common.core.validate.EditGroup; +import org.dromara.common.log.enums.BusinessType; +import org.dromara.common.excel.utils.ExcelUtil; +import org.dromara.mps.domain.vo.MpsEmpAddItemsVo; +import org.dromara.mps.domain.bo.MpsEmpAddItemsBo; +import org.dromara.mps.service.IMpsEmpAddItemsService; +import org.dromara.mps.domain.vo.MpsEmpAddItemsImportVo; +import org.dromara.mps.listener.MpsEmpAddItemsImportListener; +import org.dromara.common.mybatis.core.page.TableDataInfo; + +/** + * 员工附加项 + * + * @author Lion Li + * @date 2025-08-27 + */ +@Validated +@RequiredArgsConstructor +@RestController +@RequestMapping("/mps/empAddItems") +public class MpsEmpAddItemsController extends BaseController { + + private final IMpsEmpAddItemsService mpsEmpAddItemsService; + + /** + * 查询员工附加项列表 + */ + @SaCheckPermission("mps:empAddItems:list") + @GetMapping("/list") + public TableDataInfo list(MpsEmpAddItemsBo bo, PageQuery pageQuery) { + return mpsEmpAddItemsService.queryPageList(bo, pageQuery); + } + + /** + * 导出员工附加项列表 + */ + @SaCheckPermission("mps:empAddItems:export") + @Log(title = "员工附加项", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(MpsEmpAddItemsBo bo, HttpServletResponse response) { + List list = mpsEmpAddItemsService.queryList(bo); + ExcelUtil.exportExcel(list, "员工附加项", MpsEmpAddItemsVo.class, response); + } + + /** + * 获取导入模板 + */ + @PostMapping("/importTemplate") + public void importTemplate(HttpServletResponse response) { + ExcelUtil.exportExcel(new ArrayList<>(), "员工附加项", MpsEmpAddItemsImportVo.class, response); + } + + /** + * 导入数据 + * + * @param file 导入文件 + * @param updateSupport 是否更新已存在数据 + */ + @Log(title = "员工附加项", businessType = BusinessType.IMPORT) + @SaCheckPermission("mps:empAddItems:import") + @PostMapping(value = "/importData", consumes = MediaType.MULTIPART_FORM_DATA_VALUE) + public R importData(@RequestPart("file") MultipartFile file, boolean updateSupport) throws Exception { + ExcelResult result = ExcelUtil.importExcel(file.getInputStream(), MpsEmpAddItemsImportVo.class, new MpsEmpAddItemsImportListener(updateSupport)); + return R.ok(result.getAnalysis()); + } + + /** + * 获取员工附加项详细信息 + * + * @param id 主键 + */ + @SaCheckPermission("mps:empAddItems:query") + @GetMapping("/{id}") + public R getInfo(@NotNull(message = "主键不能为空") + @PathVariable Long id) { + return R.ok(mpsEmpAddItemsService.queryById(id)); + } + + /** + * 新增员工附加项 + */ + @SaCheckPermission("mps:empAddItems:add") + @Log(title = "员工附加项", businessType = BusinessType.INSERT) + @RepeatSubmit() + @PostMapping() + public R add(@Validated(AddGroup.class) @RequestBody MpsEmpAddItemsBo bo) { + return toAjax(mpsEmpAddItemsService.insertByBo(bo)); + } + + /** + * 修改员工附加项 + */ + @SaCheckPermission("mps:empAddItems:edit") + @Log(title = "员工附加项", businessType = BusinessType.UPDATE) + @RepeatSubmit() + @PutMapping() + public R edit(@Validated(EditGroup.class) @RequestBody MpsEmpAddItemsBo bo) { + return toAjax(mpsEmpAddItemsService.updateByBo(bo)); + } + + /** + * 删除员工附加项 + * + * @param ids 主键串 + */ + @SaCheckPermission("mps:empAddItems:remove") + @Log(title = "员工附加项", businessType = BusinessType.DELETE) + @DeleteMapping("/{ids}") + public R remove(@NotEmpty(message = "主键不能为空") + @PathVariable Long[] ids) { + return toAjax(mpsEmpAddItemsService.deleteWithValidByIds(List.of(ids), true)); + } +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/MpsEmpAddItems.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/MpsEmpAddItems.java new file mode 100644 index 0000000..91d15f1 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/MpsEmpAddItems.java @@ -0,0 +1,62 @@ +package org.dromara.mps.domain; + +import org.dromara.common.tenant.core.TenantEntity; +import com.baomidou.mybatisplus.annotation.*; +import lombok.Data; +import lombok.EqualsAndHashCode; +import java.math.BigDecimal; + +import java.io.Serial; + +/** + * 员工附加项对象 mps_emp_add_items + * + * @author Lion Li + * @date 2025-08-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@TableName("mps_emp_add_items") +public class MpsEmpAddItems extends TenantEntity { + + @Serial + private static final long serialVersionUID = 1L; + + /** + * ID + */ + @TableId(value = "id") + private Long id; + + /** + * 支行代码 + */ + private String branchId; + + /** + * 支行名称 + */ + private String branchName; + + /** + * 员工姓名 + */ + private String employeeName; + + /** + * 营销编号 + */ + private String marketingCode; + + /** + * 附加项 + */ + private BigDecimal addItem; + + /** + * 记录月份 + */ + private String recordMonth; + + +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/bo/MpsEmpAddItemsBo.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/bo/MpsEmpAddItemsBo.java new file mode 100644 index 0000000..3b61284 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/bo/MpsEmpAddItemsBo.java @@ -0,0 +1,66 @@ +package org.dromara.mps.domain.bo; + +import org.dromara.mps.domain.MpsEmpAddItems; +import org.dromara.common.mybatis.core.domain.BaseEntity; +import org.dromara.common.core.validate.AddGroup; +import org.dromara.common.core.validate.EditGroup; +import io.github.linpeilie.annotations.AutoMapper; +import lombok.Data; +import lombok.EqualsAndHashCode; +import jakarta.validation.constraints.*; +import java.math.BigDecimal; + +/** + * 员工附加项业务对象 mps_emp_add_items + * + * @author Lion Li + * @date 2025-08-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@AutoMapper(target = MpsEmpAddItems.class, reverseConvertGenerate = false) +public class MpsEmpAddItemsBo extends BaseEntity { + + /** + * ID + */ + private Long id; + + /** + * 支行代码 + */ + @NotBlank(message = "支行代码不能为空", groups = { AddGroup.class, EditGroup.class }) + private String branchId; + + /** + * 支行名称 + */ + @NotBlank(message = "支行名称不能为空", groups = { AddGroup.class, EditGroup.class }) + private String branchName; + + /** + * 员工姓名 + */ + @NotBlank(message = "员工姓名不能为空", groups = { AddGroup.class, EditGroup.class }) + private String employeeName; + + /** + * 营销编号 + */ + @NotBlank(message = "营销编号不能为空", groups = { AddGroup.class, EditGroup.class }) + private String marketingCode; + + /** + * 附加项 + */ + @NotNull(message = "附加项不能为空", groups = { AddGroup.class, EditGroup.class }) + private BigDecimal addItem; + + /** + * 记录月份 + */ + @NotBlank(message = "记录月份不能为空", groups = { AddGroup.class, EditGroup.class }) + private String recordMonth; + + +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/vo/MpsEmpAddItemsImportVo.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/vo/MpsEmpAddItemsImportVo.java new file mode 100644 index 0000000..558068d --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/vo/MpsEmpAddItemsImportVo.java @@ -0,0 +1,75 @@ +package org.dromara.mps.domain.vo; + +import java.math.BigDecimal; +import cn.idev.excel.annotation.ExcelIgnoreUnannotated; +import cn.idev.excel.annotation.ExcelProperty; +import org.dromara.common.excel.annotation.ExcelDictFormat; +import org.dromara.common.excel.convert.ExcelDictConvert; +import lombok.Data; +import lombok.NoArgsConstructor; +import java.io.Serial; +import java.io.Serializable; +import java.util.Date; + + + +/** + * 员工附加项视图对象 mps_emp_add_items + * + * 自行按照业务需要修改模板列 + * + * @author Lion Li + * @date 2025-08-27 + */ +@Data +@NoArgsConstructor +// @Accessors(chain = true) // 导入不允许使用 会找不到set方法 +public class MpsEmpAddItemsImportVo implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + /** + * ID + */ + @ExcelProperty(value = "ID") + private Long id; + + /** + * 支行代码 + */ + @ExcelProperty(value = "支行代码") + private String branchId; + + /** + * 支行名称 + */ + @ExcelProperty(value = "支行名称") + private String branchName; + + /** + * 员工姓名 + */ + @ExcelProperty(value = "员工姓名") + private String employeeName; + + /** + * 营销编号 + */ + @ExcelProperty(value = "营销编号") + private String marketingCode; + + /** + * 附加项 + */ + @ExcelProperty(value = "附加项") + private BigDecimal addItem; + + /** + * 记录月份 + */ + @ExcelProperty(value = "记录月份") + private String recordMonth; + + +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/vo/MpsEmpAddItemsVo.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/vo/MpsEmpAddItemsVo.java new file mode 100644 index 0000000..2ccbc3b --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/domain/vo/MpsEmpAddItemsVo.java @@ -0,0 +1,75 @@ +package org.dromara.mps.domain.vo; + +import java.math.BigDecimal; +import org.dromara.mps.domain.MpsEmpAddItems; +import cn.idev.excel.annotation.ExcelIgnoreUnannotated; +import cn.idev.excel.annotation.ExcelProperty; +import org.dromara.common.excel.annotation.ExcelDictFormat; +import org.dromara.common.excel.convert.ExcelDictConvert; +import io.github.linpeilie.annotations.AutoMapper; +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; +import java.util.Date; + + + +/** + * 员工附加项视图对象 mps_emp_add_items + * + * @author Lion Li + * @date 2025-08-27 + */ +@Data +@ExcelIgnoreUnannotated +@AutoMapper(target = MpsEmpAddItems.class) +public class MpsEmpAddItemsVo implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + /** + * ID + */ + @ExcelProperty(value = "ID") + private Long id; + + /** + * 支行代码 + */ + @ExcelProperty(value = "支行代码") + private String branchId; + + /** + * 支行名称 + */ + @ExcelProperty(value = "支行名称") + private String branchName; + + /** + * 员工姓名 + */ + @ExcelProperty(value = "员工姓名") + private String employeeName; + + /** + * 营销编号 + */ + @ExcelProperty(value = "营销编号") + private String marketingCode; + + /** + * 附加项 + */ + @ExcelProperty(value = "附加项") + private BigDecimal addItem; + + /** + * 记录月份 + */ + @ExcelProperty(value = "记录月份") + private String recordMonth; + + +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/listener/MpsEmpAddItemsImportListener.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/listener/MpsEmpAddItemsImportListener.java new file mode 100644 index 0000000..5026791 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/listener/MpsEmpAddItemsImportListener.java @@ -0,0 +1,140 @@ +package org.dromara.mps.listener; + +import cn.hutool.core.bean.BeanUtil; +import cn.hutool.http.HtmlUtil; +import cn.idev.excel.context.AnalysisContext; +import cn.idev.excel.event.AnalysisEventListener; +import jakarta.validation.ConstraintViolation; +import jakarta.validation.ConstraintViolationException; +import lombok.extern.slf4j.Slf4j; +import org.dromara.common.core.exception.ServiceException; +import org.dromara.common.core.utils.SpringUtils; +import org.dromara.common.core.utils.StreamUtils; +import org.dromara.common.core.utils.ValidatorUtils; +import org.dromara.common.excel.core.ExcelListener; +import org.dromara.common.excel.core.ExcelResult; +import org.dromara.common.satoken.utils.LoginHelper; +import org.dromara.mps.domain.MpsEmpAddItems; +import org.dromara.mps.domain.bo.MpsEmpAddItemsBo; +import org.dromara.mps.domain.vo.MpsEmpAddItemsImportVo; +import org.dromara.mps.service.IMpsEmpAddItemsService; +import cn.hutool.core.lang.Pair; + +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; +import java.util.Collection; +import java.util.stream.Collectors; + +/** + * 自定义导入 + * + * @author Lion Li + */ +@Slf4j +public class MpsEmpAddItemsImportListener extends AnalysisEventListener implements ExcelListener { + + private final IMpsEmpAddItemsService mpsEmpAddItemsService; + private final Boolean isUpdateSupport; + private final Long operUserId; + private int countN = 1; + + // 存储所有解析成功的对象 + private final Collection successList = new ArrayList<>(); + + //TODO 考虑展示数据还是行数,暂定行数 + // 存储所有解析失败的对象及错误信息 + //private final Collection> failureList = new ArrayList<>(); + private final Collection> failureList = new ArrayList<>(); + + public MpsEmpAddItemsImportListener(Boolean isUpdateSupport) { + this.mpsEmpAddItemsService = SpringUtils.getBean(IMpsEmpAddItemsService.class); + this.isUpdateSupport = isUpdateSupport; + this.operUserId = LoginHelper.getUserId(); + } + + @Override + public void invoke(MpsEmpAddItemsImportVo mpsEmpAddItemsImportVo, AnalysisContext context) { + try { + countN++; + + //TODO 自行实现验重逻辑 + //MpsEmpAddItemsVo mpsEmpAddItemsVo1 = this.mpsEmpAddItemsService.queryById(mpsEmpAddItemsVo.getDataId()); + + // 1. 基本数据验证 + ValidatorUtils.validate(mpsEmpAddItemsImportVo); + + // 2. 转换为业务对象 + MpsEmpAddItems mpsEmpAddItems = BeanUtil.toBean(mpsEmpAddItemsImportVo, MpsEmpAddItems.class); + + // 3. 添加到成功列表（稍后批量处理） + successList.add(mpsEmpAddItems); + + } catch (Exception e) { + // 捕获并记录所有验证错误 + String errorMsg = e.getMessage(); + if (e instanceof ConstraintViolationException cvException) { + errorMsg = StreamUtils.join(cvException.getConstraintViolations(), + ConstraintViolation::getMessage, ", "); + } + failureList.add(Pair.of(countN, errorMsg)); + log.error("数据验证失败: {}", errorMsg); + } + } + + @Override + public void doAfterAllAnalysed(AnalysisContext context) { + // 所有数据解析完成后执行批量操作 + } + + @Override + public ExcelResult getExcelResult() { + // 存在验证错误则直接返回错误 + if (!failureList.isEmpty()) { + StringBuilder errorMsg = new StringBuilder("数据验证失败，共 ") + .append(failureList.size()) + .append(" 条错误：
"); + failureList.forEach(pair -> + //errorMsg.append("\n行数据: ") + errorMsg.append("行数[") + .append(pair.getKey()) + .append("],") + .append("错误:") + .append(pair.getValue()) + .append("
")); + throw new ServiceException(errorMsg.toString()); + } + + try { + // 执行事务性批量导入 + mpsEmpAddItemsService.batchInsertOrUpdate(successList, isUpdateSupport); + return createSuccessResult(); + } catch (Exception e) { + // 事务回滚，整体导入失败 + log.error("批量导入失败", e); + throw new ServiceException("导入失败: " + e.getMessage()); + } + } + + private ExcelResult createSuccessResult() { + return new ExcelResult<>() { + @Override + public String getAnalysis() { + return "成功导入 " + successList.size() + " 条数据"; + } + + @Override + public List getList() { + return successList.stream() + .map(bo -> BeanUtil.toBean(bo, MpsEmpAddItemsImportVo.class)) + .collect(Collectors.toList()); + } + + @Override + public List getErrorList() { + return Collections.emptyList(); + } + }; + } +} + diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/mapper/MpsEmpAddItemsMapper.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/mapper/MpsEmpAddItemsMapper.java new file mode 100644 index 0000000..dbcc4f9 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/mapper/MpsEmpAddItemsMapper.java @@ -0,0 +1,41 @@ +package org.dromara.mps.mapper; + +import org.dromara.mps.domain.MpsEmpAddItems; +import org.dromara.mps.domain.vo.MpsEmpAddItemsVo; +import org.dromara.common.mybatis.core.mapper.BaseMapperPlus; +import com.baomidou.mybatisplus.core.conditions.Wrapper; +import com.baomidou.mybatisplus.core.toolkit.Constants; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import org.apache.ibatis.annotations.Param; +import org.dromara.common.mybatis.annotation.DataColumn; +import org.dromara.common.mybatis.annotation.DataPermission; + +import java.util.Collection; + +/** + * 员工附加项Mapper接口 + * + * @author Lion Li + * @date 2025-08-27 + */ +public interface MpsEmpAddItemsMapper extends BaseMapperPlus { + + @DataPermission({ + @DataColumn(key = "deptName", value = "create_dept"), + @DataColumn(key = "userName", value = "create_by") + }) + default Page selectPageMpsEmpAddItemsList(Page page, Wrapper queryWrapper) { + return this.selectVoPage(page, queryWrapper); + } + + + //@DataPermission({ + // @DataColumn(key = "deptName", value = "create_dept"), + // @DataColumn(key = "userName", value = "create_by") + //}) + // List selectMpsEmpAddItemsExportList(@Param(Constants.WRAPPER) Wrapper queryWrapper); + + // 批量插入 + void batchInsert(@Param("list") Collection list); + +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/service/IMpsEmpAddItemsService.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/service/IMpsEmpAddItemsService.java new file mode 100644 index 0000000..4fd0995 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/service/IMpsEmpAddItemsService.java @@ -0,0 +1,75 @@ +package org.dromara.mps.service; + +import org.dromara.mps.domain.MpsEmpAddItems; +import org.dromara.mps.domain.vo.MpsEmpAddItemsVo; +import org.dromara.mps.domain.bo.MpsEmpAddItemsBo; +import org.springframework.transaction.annotation.Transactional; +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.common.mybatis.core.page.PageQuery; +import org.springframework.transaction.annotation.Transactional; + +import java.util.Collection; +import java.util.List; + +/** + * 员工附加项Service接口 + * + * @author Lion Li + * @date 2025-08-27 + */ +public interface IMpsEmpAddItemsService { + + //事务性批量处理 + @Transactional(rollbackFor = Exception.class) + void batchInsertOrUpdate(Collection list, Boolean isUpdateSupport); + + /** + * 查询员工附加项 + * + * @param id 主键 + * @return 员工附加项 + */ + MpsEmpAddItemsVo queryById(Long id); + + /** + * 分页查询员工附加项列表 + * + * @param bo 查询条件 + * @param pageQuery 分页参数 + * @return 员工附加项分页列表 + */ + TableDataInfo queryPageList(MpsEmpAddItemsBo bo, PageQuery pageQuery); + + /** + * 查询符合条件的员工附加项列表 + * + * @param bo 查询条件 + * @return 员工附加项列表 + */ + List queryList(MpsEmpAddItemsBo bo); + + /** + * 新增员工附加项 + * + * @param bo 员工附加项 + * @return 是否新增成功 + */ + Boolean insertByBo(MpsEmpAddItemsBo bo); + + /** + * 修改员工附加项 + * + * @param bo 员工附加项 + * @return 是否修改成功 + */ + Boolean updateByBo(MpsEmpAddItemsBo bo); + + /** + * 校验并批量删除员工附加项信息 + * + * @param ids 待删除的主键集合 + * @param isValid 是否进行有效性校验 + * @return 是否删除成功 + */ + Boolean deleteWithValidByIds(Collection ids, Boolean isValid); +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/service/impl/MpsEmpAddItemsServiceImpl.java b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/service/impl/MpsEmpAddItemsServiceImpl.java new file mode 100644 index 0000000..5f9536e --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/mps/service/impl/MpsEmpAddItemsServiceImpl.java @@ -0,0 +1,196 @@ +package org.dromara.mps.service.impl; + +import cn.hutool.core.collection.CollUtil; +import org.dromara.common.core.enums.FormatsType; +import org.dromara.common.core.utils.DateUtils; +import org.dromara.common.core.utils.MapstructUtils; +import org.dromara.common.core.utils.StringUtils; +import org.dromara.common.core.exception.ServiceException; +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.common.mybatis.core.page.PageQuery; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.dromara.mps.domain.bo.MpsEmpAddItemsBo; +import org.dromara.mps.domain.vo.MpsEmpAddItemsVo; +import org.dromara.mps.domain.MpsEmpAddItems; +import org.dromara.mps.mapper.MpsEmpAddItemsMapper; +import org.dromara.mps.service.IMpsEmpAddItemsService; +import org.springframework.transaction.annotation.Transactional; + +import java.time.Instant; +import java.util.*; + +/** + * 员工附加项Service业务层处理 + * + * @author Lion Li + * @date 2025-08-27 + */ +@Slf4j +@RequiredArgsConstructor +@Service +public class MpsEmpAddItemsServiceImpl implements IMpsEmpAddItemsService { + + private final MpsEmpAddItemsMapper baseMapper; + + @Override + @Transactional(rollbackFor = Exception.class) + public void batchInsertOrUpdate(Collection list, Boolean isUpdateSupport) { + if (CollUtil.isEmpty(list)) { + return; + } + + // 业务校验（可选）,参照demo + //validateBusinessRules(list); + + // 2. 批量插入/更新 + if (isUpdateSupport) { + baseMapper.insertOrUpdateBatch(list); + } else { + //baseMapper.insertBatch(list); + + /** + * 多笔写入方式有循环写入、开启数据库batch模式、sql拼接后多笔入库以及mapper foreach多笔写入模式 + * 经对比验证,foreach方式效率最高 + * + * **/ + + //由于mybatis的批量方法为伪批量,以下优化为真批量 + //SqlHelper与service的注解事务管理冲突,所以此处自行写分批 + int batchSize = 1000;//每批1000条 + List batchList = new ArrayList<>(batchSize); + for (MpsEmpAddItems item : list) { + batchList.add(item); + if (batchList.size() == batchSize) { + baseMapper.batchInsert(batchList); + batchList.clear(); + } + } + + // 处理最后一批不满batchSize的数据 + if (!batchList.isEmpty()) { + baseMapper.batchInsert(batchList); + } + } + } + + // 示例：业务重复检查 + /*private void validateBusinessRules(Collection list) { + Set uniqueKeys = new HashSet<>(); + for (MpsEmpAddItemsBo bo : list) { + String key = bo.getCustAcctNo(); + if (uniqueKeys.contains(key)) { + throw new ServiceException("重复的客户账号: " + key); + } + uniqueKeys.add(key); + } + } */ + + /** + * 查询员工附加项 + * + * @param id 主键 + * @return 员工附加项 + */ + @Override + public MpsEmpAddItemsVo queryById(Long id){ + return baseMapper.selectVoById(id); + } + + /** + * 分页查询员工附加项列表 + * + * @param bo 查询条件 + * @param pageQuery 分页参数 + * @return 员工附加项分页列表 + */ + @Override + public TableDataInfo queryPageList(MpsEmpAddItemsBo bo, PageQuery pageQuery) { + LambdaQueryWrapper lqw = buildQueryWrapper(bo); + Page result = baseMapper.selectPageMpsEmpAddItemsList(pageQuery.build(), lqw); + return TableDataInfo.build(result); + } + + /** + * 查询符合条件的员工附加项列表 + * + * @param bo 查询条件 + * @return 员工附加项列表 + */ + @Override + public List queryList(MpsEmpAddItemsBo bo) { + LambdaQueryWrapper lqw = buildQueryWrapper(bo); + return baseMapper.selectVoList(lqw); + } + + private LambdaQueryWrapper buildQueryWrapper(MpsEmpAddItemsBo bo) { + Map params = bo.getParams(); + LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); + lqw.orderByAsc(MpsEmpAddItems::getId); + lqw.eq(StringUtils.isNotBlank(bo.getBranchId()), MpsEmpAddItems::getBranchId, bo.getBranchId()); + lqw.like(StringUtils.isNotBlank(bo.getBranchName()), MpsEmpAddItems::getBranchName, bo.getBranchName()); + lqw.like(StringUtils.isNotBlank(bo.getEmployeeName()), MpsEmpAddItems::getEmployeeName, bo.getEmployeeName()); + lqw.eq(StringUtils.isNotBlank(bo.getMarketingCode()), MpsEmpAddItems::getMarketingCode, bo.getMarketingCode()); + lqw.eq(bo.getAddItem() != null, MpsEmpAddItems::getAddItem, bo.getAddItem()); + lqw.eq(StringUtils.isNotBlank(bo.getRecordMonth()), MpsEmpAddItems::getRecordMonth, bo.getRecordMonth()); + return lqw; + } + + /** + * 新增员工附加项 + * + * @param bo 员工附加项 + * @return 是否新增成功 + */ + @Override + public Boolean insertByBo(MpsEmpAddItemsBo bo) { + String month = DateUtils.parseDateToStr(FormatsType.YYYY_MM,Date.from(Instant.ofEpochMilli(Long.parseLong(bo.getRecordMonth())))); + bo.setRecordMonth(month); + MpsEmpAddItems add = MapstructUtils.convert(bo, MpsEmpAddItems.class); + validEntityBeforeSave(add); + boolean flag = baseMapper.insert(add) > 0; + if (flag) { + bo.setId(add.getId()); + } + return flag; + } + + /** + * 修改员工附加项 + * + * @param bo 员工附加项 + * @return 是否修改成功 + */ + @Override + public Boolean updateByBo(MpsEmpAddItemsBo bo) { + MpsEmpAddItems update = MapstructUtils.convert(bo, MpsEmpAddItems.class); + validEntityBeforeSave(update); + return baseMapper.updateById(update) > 0; + } + + /** + * 保存前的数据校验 + */ + private void validEntityBeforeSave(MpsEmpAddItems entity){ + //TODO 做一些数据校验,如唯一约束 + } + + /** + * 校验并批量删除员工附加项信息 + * + * @param ids 待删除的主键集合 + * @param isValid 是否进行有效性校验 + * @return 是否删除成功 + */ + @Override + public Boolean deleteWithValidByIds(Collection ids, Boolean isValid) { + if(isValid){ + //TODO 做一些业务上的校验,判断是否需要校验 + } + return baseMapper.deleteByIds(ids) > 0; + } +} diff --git a/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/mps/MpsEmpAddItemsMapper.xml b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/mps/MpsEmpAddItemsMapper.xml new file mode 100644 index 0000000..2aa20e9 --- /dev/null +++ b/cds-platform-2025.V1/ruoyi-modules/ruoyi-system/src/main/resources/mapper/mps/MpsEmpAddItemsMapper.xml @@ -0,0 +1,44 @@ + + + + + + + INSERT INTO mps_emp_add_items + ( + id, + branch_id, + branch_name, + employee_name, + marketing_code, + add_item, + record_month, + tenant_id, + create_dept, + create_by, + create_time, + update_by, + update_time + ) + VALUES + + ( + #{item.id}, + #{item.branchId}, + #{item.branchName}, + #{item.employeeName}, + #{item.marketingCode}, + #{item.addItem}, + #{item.recordMonth}, + #{item.tenantId}, + #{item.createDept}, + #{item.createBy}, + #{item.createTime}, + #{item.updateBy}, + #{item.updateTime} + ) + + +