From 611ba10fe1678dca8f78ad5c01e1193339a445a4 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 06 三月 2024 14:30:04 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ycl-server/src/main/java/com/ycl/platform/service/impl/DefaultRuleServiceImpl.java | 180 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 180 insertions(+), 0 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/DefaultRuleServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/DefaultRuleServiceImpl.java new file mode 100644 index 0000000..3b297fc --- /dev/null +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/DefaultRuleServiceImpl.java @@ -0,0 +1,180 @@ +package com.ycl.platform.service.impl; + +import com.ycl.exception.ServiceException; +import com.ycl.platform.domain.entity.DefaultRule; +import com.ycl.platform.domain.entity.YwUnit; +import com.ycl.platform.domain.form.DefaultRuleSetForm; +import com.ycl.platform.mapper.DefaultRuleMapper; +import com.ycl.platform.service.DefaultRuleService; +import com.ycl.system.Result; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ycl.platform.domain.form.DefaultRuleForm; +import com.ycl.platform.domain.vo.DefaultRuleVO; +import com.ycl.platform.domain.query.DefaultRuleQuery; +import java.util.List; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.ycl.system.page.PageUtil; +import com.ycl.utils.DateUtils; +import org.springframework.stereotype.Service; +import org.springframework.security.core.context.SecurityContextHolder; +import org.springframework.beans.BeanUtils; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.Assert; +import java.util.ArrayList; +import java.util.Objects; +import java.util.stream.Collectors; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; +import lombok.RequiredArgsConstructor; +import org.springframework.util.CollectionUtils; +import org.springframework.util.StringUtils; + +/** + * 杩濈害瑙勫垯 鏈嶅姟瀹炵幇绫� + * + * @author xp + * @since 2024-03-05 + */ +@Service +@RequiredArgsConstructor +public class DefaultRuleServiceImpl extends ServiceImpl<DefaultRuleMapper, DefaultRule> implements DefaultRuleService { + + private final DefaultRuleMapper defaultRuleMapper; + + /** + * 娣诲姞 + * @param form + * @return + */ + @Override + public Result add(DefaultRuleForm form) { + DefaultRule entity = DefaultRuleForm.getEntityByForm(form, null); + entity.setRuleStatus("鏈惎鐢�"); + if(baseMapper.insert(entity) > 0) { + return Result.ok("娣诲姞鎴愬姛"); + } + return Result.error("娣诲姞澶辫触"); + } + + /** + * 淇敼 + * @param form + * @return + */ + @Override + public Result update(DefaultRuleForm form) { + + DefaultRule entity = baseMapper.selectById(form.getId()); + + // 涓虹┖鎶汭llegalArgumentException锛屽仛鍏ㄥ眬寮傚父澶勭悊 + Assert.notNull(entity, "璁板綍涓嶅瓨鍦�"); + BeanUtils.copyProperties(form, entity); + if (baseMapper.updateById(entity) > 0) { + return Result.ok("淇敼鎴愬姛"); + } + return Result.error("淇敼澶辫触"); + } + + /** + * 鎵归噺鍒犻櫎 + * @param ids + * @return + */ + @Override + public Result remove(List<String> ids) { + if(baseMapper.deleteBatchIds(ids) > 0) { + return Result.ok("鍒犻櫎鎴愬姛"); + } + return Result.error("鍒犻櫎澶辫触"); + } + + /** + * id鍒犻櫎 + * @param id + * @return + */ + @Override + public Result removeById(String id) { + if(baseMapper.deleteById(id) > 0) { + return Result.ok("鍒犻櫎鎴愬姛"); + } + return Result.error("鍒犻櫎澶辫触"); + } + + /** + * 鍒嗛〉鏌ヨ + * @param query + * @return + */ + @Override + public Result page(DefaultRuleQuery query) { + + IPage<DefaultRule> page = new LambdaQueryChainWrapper<>(baseMapper) + .like(StringUtils.hasText(query.getRuleName()), DefaultRule::getRuleName, query.getRuleName()) + .between(Objects.nonNull(query.getStart()) && Objects.nonNull(query.getEnd()), + DefaultRule::getCreateTime, + DateUtils.getDayStart(query.getStart()), + DateUtils.getDayEnd(query.getEnd())) + .orderByDesc(DefaultRule::getCreateTime) + .page(PageUtil.getPage(query, DefaultRule.class)); + + List<DefaultRuleVO> vos = page.getRecords().stream() + .map( + entity -> DefaultRuleVO.getVoByEntity(entity, null) + ) + .collect(Collectors.toList()); + return Result.ok().data(vos).total(page.getTotal()); + } + + /** + * 鏍规嵁id鏌ユ壘 + * @param id + * @return + */ + @Override + public Result detail(String id) { + + DefaultRule entity = baseMapper.selectById(id); + Assert.notNull(entity, "璁板綍涓嶅瓨鍦�"); + DefaultRuleVO vo = DefaultRuleVO.getVoByEntity(entity, null); + return Result.ok().data(vo); + } + + /** + * 鍒楄〃 + * @return + */ + @Override + public Result all() { + List<DefaultRule> entities = baseMapper.selectList(null); + List<DefaultRuleVO> vos = entities.stream() + .map( + entity -> DefaultRuleVO.getVoByEntity(entity, null) + ) + .collect(Collectors.toList()); + return Result.ok().data(vos); + } + + @Override + public Result set(DefaultRuleSetForm form) { + DefaultRule defaultRule = baseMapper.selectById(form.getId()); + if (Objects.isNull(defaultRule)) { + throw new ServiceException("杩濈害瑙勫垯涓嶅瓨鍦�"); + } + if (form.getFlag()) { + // 鍚敤涔嬪墠妫�鏌ユ槸鍚﹀凡缁忔湁鍚敤鐨勮鍒欎簡锛屼繚鎸佷竴涓紑鍚� + List<DefaultRule> useList = new LambdaQueryChainWrapper<>(baseMapper) + .eq(DefaultRule::getRuleStatus, "鍚敤") + .list(); + if (! CollectionUtils.isEmpty(useList)) { + throw new ServiceException("宸茬粡鏈夎鍒欒鍚敤浜嗭紝鍙兘鍚屾椂鍚敤涓�涓鍒�"); + } + defaultRule.setRuleStatus("鍚敤"); + } else { + defaultRule.setRuleStatus("鏈惎鐢�"); + } + baseMapper.updateById(defaultRule); + return Result.ok("鎿嶄綔鎴愬姛"); + } +} -- Gitblit v1.8.0