package com.doumee.service.system.impl; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.doumee.core.constants.Constants; import com.doumee.core.exception.BusinessException; import com.doumee.dao.dto.PlatformConfigDTO; import com.doumee.dao.system.model.SystemDict; import com.doumee.dao.system.model.SystemMenu; import com.doumee.service.system.SystemDictService; import com.github.pagehelper.Constant; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.dao.system.SystemDictDataMapper; import com.doumee.dao.system.dto.QuerySystemDictDataDTO; import com.doumee.dao.system.model.SystemDictData; import com.doumee.dao.system.vo.SystemDictDataListVO; import com.doumee.service.system.SystemDictDataService; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import java.util.Collections; import java.util.List; import java.util.Objects; /** * 字典数据Service实现 * @author dm * @since 2025/03/31 16:44 */ @Service public class SystemDictDataServiceImpl implements SystemDictDataService { @Autowired private SystemDictDataMapper systemDictDataMapper; @Autowired private SystemDictService systemDictService; @Override public Integer create(SystemDictData systemDictData) { systemDictDataMapper.insert(systemDictData); return systemDictData.getId(); } @Override public void deleteById(Integer id) { SystemDictData systemDictData = new SystemDictData(); systemDictData.setId(id); systemDictData.setDeleted(Boolean.TRUE); this.updateById(systemDictData); } @Override @Transactional public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) return; for (Integer id : ids) { this.deleteById(id); } } @Override public void updateById(SystemDictData systemDictData) { systemDictDataMapper.updateById(systemDictData); } @Override @Transactional public void updateByIdInBatch(List systemDictDatas) { if (CollectionUtils.isEmpty(systemDictDatas)) return; for (SystemDictData systemDictData: systemDictDatas) { this.updateById(systemDictData); } } @Override public SystemDictData findById(Integer id) { return systemDictDataMapper.selectById(id); } @Override public SystemDictData findOne(SystemDictData systemDictData) { Wrapper wrapper = new QueryWrapper<>(systemDictData); return systemDictDataMapper.selectOne(wrapper); } @Override public List findList(SystemDictData systemDictData) { QueryWrapper wrapper = new QueryWrapper<>(systemDictData); wrapper.lambda().orderByAsc(SystemDictData::getSort); return systemDictDataMapper.selectList(wrapper); } @Override public List findList(Integer dicId,List codes) { QueryWrapper wrapper = new QueryWrapper<>(); wrapper.lambda() .eq(Objects.nonNull(dicId),SystemDictData::getDictId,dicId) .in(SystemDictData::getLabel,codes); return systemDictDataMapper.selectList(wrapper); } @Override public List findByDictCode(String dictCode) { SystemDict queryDto = new SystemDict(); queryDto.setCode(dictCode); queryDto.setDeleted(Boolean.FALSE); SystemDict systemDict = systemDictService.findOne(queryDto); if (systemDict == null) { return Collections.emptyList(); } SystemDictData queryDictDataDto = new SystemDictData(); queryDictDataDto.setDictId(systemDict.getId()); queryDictDataDto.setDisabled(Boolean.FALSE); queryDictDataDto.setDeleted(Boolean.FALSE); return this.findList(queryDictDataDto); } @Override public PageData findPage(PageWrap pageWrap) { PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); return PageData.from(new PageInfo<>(systemDictDataMapper.selectManageList(pageWrap.getModel()))); } @Override public long count(SystemDictData systemDictData) { Wrapper wrapper = new QueryWrapper<>(systemDictData); return systemDictDataMapper.selectCount(wrapper); } @Override public PlatformConfigDTO getPlatformConfigDTO(){ PlatformConfigDTO platformConfigDTO = new PlatformConfigDTO(); platformConfigDTO.setAutoConfirm("0"); platformConfigDTO.setReceiveCancelTime("0"); platformConfigDTO.setReceiveCancelTimes("0"); platformConfigDTO.setReleaseCancelTimes("0"); platformConfigDTO.setReleaseCancelTime("0"); platformConfigDTO.setAutoDispatch("0"); platformConfigDTO.setAutoDispatchDistance("0"); List systemDictDataList = systemDictDataMapper.selectList(new QueryWrapper() .lambda().eq(SystemDictData::getDictId,100) .in(SystemDictData::getLabel, Constants.AUTO_DISPATCH ,Constants.AUTO_CONFIRM,Constants.AUTO_DISPATCH_DISTANCE,Constants.RELEASE_CANCEL_TIME ,Constants.RELEASE_CANCEL_TIMES,Constants.RECEIVE_CANCEL_TIMES,Constants.RECEIVE_CANCEL_TIME) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictDataList)){ for (SystemDictData systemDictData:systemDictDataList) { if(systemDictData.getLabel().equals(Constants.AUTO_DISPATCH)){ platformConfigDTO.setAutoDispatch(systemDictData.getCode()); }else if(systemDictData.getLabel().equals(Constants.AUTO_CONFIRM)){ platformConfigDTO.setAutoConfirm(systemDictData.getCode()); }else if(systemDictData.getLabel().equals(Constants.AUTO_DISPATCH_DISTANCE)){ platformConfigDTO.setAutoDispatchDistance(systemDictData.getCode()); }else if(systemDictData.getLabel().equals(Constants.RELEASE_CANCEL_TIME)){ platformConfigDTO.setReleaseCancelTime(systemDictData.getCode()); }else if(systemDictData.getLabel().equals(Constants.RELEASE_CANCEL_TIMES)){ platformConfigDTO.setReleaseCancelTimes(systemDictData.getCode()); }else if(systemDictData.getLabel().equals(Constants.RECEIVE_CANCEL_TIMES)){ platformConfigDTO.setReceiveCancelTimes(systemDictData.getCode()); }else if(systemDictData.getLabel().equals(Constants.RECEIVE_CANCEL_TIME)){ platformConfigDTO.setReceiveCancelTime(systemDictData.getCode()); } } } return platformConfigDTO; } @Override @Transactional(rollbackFor = {Exception.class, BusinessException.class}) public void updPlatformConfig(PlatformConfigDTO platformConfigDTO){ List systemDictDataList = systemDictDataMapper.selectList(new QueryWrapper() .lambda().eq(SystemDictData::getDictId,100) .in(SystemDictData::getLabel, Constants.AUTO_DISPATCH ,Constants.AUTO_CONFIRM,Constants.AUTO_DISPATCH_DISTANCE,Constants.RELEASE_CANCEL_TIME ,Constants.RELEASE_CANCEL_TIMES,Constants.RECEIVE_CANCEL_TIMES,Constants.RECEIVE_CANCEL_TIME) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictDataList)){ for (SystemDictData systemDictData:systemDictDataList) { if(systemDictData.getLabel().equals(Constants.AUTO_DISPATCH)){ systemDictData.setCode(platformConfigDTO.getAutoDispatch()); }else if(systemDictData.getLabel().equals(Constants.AUTO_CONFIRM)){ systemDictData.setCode(platformConfigDTO.getAutoConfirm()); }else if(systemDictData.getLabel().equals(Constants.AUTO_DISPATCH_DISTANCE)){ systemDictData.setCode(platformConfigDTO.getAutoDispatchDistance()); }else if(systemDictData.getLabel().equals(Constants.RELEASE_CANCEL_TIME)){ systemDictData.setCode(platformConfigDTO.getReleaseCancelTime()); }else if(systemDictData.getLabel().equals(Constants.RELEASE_CANCEL_TIMES)){ systemDictData.setCode(platformConfigDTO.getReleaseCancelTimes()); }else if(systemDictData.getLabel().equals(Constants.RECEIVE_CANCEL_TIMES)){ systemDictData.setCode(platformConfigDTO.getReceiveCancelTimes()); }else if(systemDictData.getLabel().equals(Constants.RECEIVE_CANCEL_TIME)){ systemDictData.setCode(platformConfigDTO.getReceiveCancelTime()); } systemDictDataMapper.update(new UpdateWrapper().lambda() .set(SystemDictData::getCode,systemDictData.getCode()) .eq(SystemDictData::getId,systemDictData.getId())); } } } }