From 6ef869b1adcf3a5bb8e4c3117dc507d173f13fd8 Mon Sep 17 00:00:00 2001 From: liukangdong <898885815@qq.com> Date: 星期三, 18 九月 2024 15:19:55 +0800 Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformLogServiceImpl.java | 161 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 161 insertions(+), 0 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformLogServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformLogServiceImpl.java new file mode 100644 index 0000000..5811b1b --- /dev/null +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformLogServiceImpl.java @@ -0,0 +1,161 @@ +package com.doumee.service.business.impl; + +import com.doumee.core.model.PageData; +import com.doumee.core.model.PageWrap; +import com.doumee.core.utils.Constants; +import com.doumee.core.utils.Utils; +import com.doumee.dao.business.PlatformLogMapper; +import com.doumee.dao.business.model.PlatformLog; +import com.doumee.dao.openapi.request.CarLogsListRequest; +import com.doumee.dao.openapi.response.CarLogsListResponse; +import com.doumee.service.business.PlatformLogService; +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.ArrayList; +import java.util.Date; +import java.util.List; +import java.util.Objects; + +/** + * 鏈堝彴_浣滀笟鎿嶄綔鍘嗗彶琛⊿ervice瀹炵幇 + * @author 姹熻箘韫� + * @date 2024/06/28 10:03 + */ +@Service +public class PlatformLogServiceImpl implements PlatformLogService { + + @Autowired + private PlatformLogMapper platformLogMapper; + + @Override + public Integer create(PlatformLog platformLog) { + platformLogMapper.insert(platformLog); + return platformLog.getId(); + } + + @Override + public void deleteById(Integer id) { + platformLogMapper.deleteById(id); + } + + @Override + public void delete(PlatformLog platformLog) { + UpdateWrapper<PlatformLog> deleteWrapper = new UpdateWrapper<>(platformLog); + platformLogMapper.delete(deleteWrapper); + } + + @Override + public void deleteByIdInBatch(List<Integer> ids) { + if (CollectionUtils.isEmpty(ids)) { + return; + } + platformLogMapper.deleteBatchIds(ids); + } + + @Override + public void updateById(PlatformLog platformLog) { + platformLogMapper.updateById(platformLog); + } + + @Override + public void updateByIdInBatch(List<PlatformLog> platformLogs) { + if (CollectionUtils.isEmpty(platformLogs)) { + return; + } + for (PlatformLog platformLog: platformLogs) { + this.updateById(platformLog); + } + } + + @Override + public PlatformLog findById(Integer id) { + return platformLogMapper.selectById(id); + } + + @Override + public PlatformLog findOne(PlatformLog platformLog) { + QueryWrapper<PlatformLog> wrapper = new QueryWrapper<>(platformLog); + return platformLogMapper.selectOne(wrapper); + } + + @Override + public List<PlatformLog> findList(PlatformLog platformLog) { + QueryWrapper<PlatformLog> wrapper = new QueryWrapper<>(platformLog); + return platformLogMapper.selectList(wrapper); + } + + @Override + public PageData<PlatformLog> findPage(PageWrap<PlatformLog> pageWrap) { + IPage<PlatformLog> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); + QueryWrapper<PlatformLog> queryWrapper = new QueryWrapper<>(); + Utils.MP.blankToNull(pageWrap.getModel()); + queryWrapper.lambda() + .eq(pageWrap.getModel().getId() != null, PlatformLog::getId, pageWrap.getModel().getId()) + .eq(pageWrap.getModel().getCreator() != null, PlatformLog::getCreator, pageWrap.getModel().getCreator()) + .ge(pageWrap.getModel().getCreateDate() != null, PlatformLog::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())) + .le(pageWrap.getModel().getCreateDate() != null, PlatformLog::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())) + .eq(pageWrap.getModel().getEditor() != null, PlatformLog::getEditor, pageWrap.getModel().getEditor()) + .ge(pageWrap.getModel().getEditDate() != null, PlatformLog::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())) + .le(pageWrap.getModel().getEditDate() != null, PlatformLog::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())) + .eq(pageWrap.getModel().getIsdeleted() != null, PlatformLog::getIsdeleted, pageWrap.getModel().getIsdeleted()) + .eq(pageWrap.getModel().getRemark() != null, PlatformLog::getRemark, pageWrap.getModel().getRemark()) + .eq(pageWrap.getModel().getJobId() != null, PlatformLog::getJobId, pageWrap.getModel().getJobId()) + .eq(pageWrap.getModel().getTitle() != null, PlatformLog::getTitle, pageWrap.getModel().getTitle()) + .eq(pageWrap.getModel().getContent() != null, PlatformLog::getContent, pageWrap.getModel().getContent()) + .eq(pageWrap.getModel().getObjType() != null, PlatformLog::getObjType, pageWrap.getModel().getObjType()) + .eq(pageWrap.getModel().getObjId() != null, PlatformLog::getObjId, pageWrap.getModel().getObjId()) + .eq(pageWrap.getModel().getBeforeContent() != null, PlatformLog::getBeforeContent, pageWrap.getModel().getBeforeContent()) + .eq(pageWrap.getModel().getAfterContent() != null, PlatformLog::getAfterContent, pageWrap.getModel().getAfterContent()) + .eq(pageWrap.getModel().getParam1() != null, PlatformLog::getParam1, pageWrap.getModel().getParam1()) + .eq(pageWrap.getModel().getParam2() != null, PlatformLog::getParam2, pageWrap.getModel().getParam2()) + .eq(pageWrap.getModel().getParam3() != null, PlatformLog::getParam3, pageWrap.getModel().getParam3()) + .eq(pageWrap.getModel().getParam4() != null, PlatformLog::getParam4, pageWrap.getModel().getParam4()) + ; + for(PageWrap.SortData sortData: pageWrap.getSorts()) { + if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { + queryWrapper.orderByDesc(sortData.getProperty()); + } else { + queryWrapper.orderByAsc(sortData.getProperty()); + } + } + return PageData.from(platformLogMapper.selectPage(page, queryWrapper)); + } + + @Override + public long count(PlatformLog platformLog) { + QueryWrapper<PlatformLog> wrapper = new QueryWrapper<>(platformLog); + return platformLogMapper.selectCount(wrapper); + } + + + + @Override + public List<CarLogsListResponse> getCarLogsListResponse(CarLogsListRequest carLogsListRequest){ + List<CarLogsListResponse> carLogsListResponseList = new ArrayList<>(); + + List<PlatformLog> platformLogList = platformLogMapper.selectList(new QueryWrapper<PlatformLog>().lambda() + .notIn(PlatformLog::getObjType, + Constants.PlatformJobLogType.CREATE.getKey(), + Constants.PlatformJobLogType.CONFIRM_TASK.getKey() + ) + .orderByDesc(PlatformLog::getCreateDate) + .last(Objects.nonNull(carLogsListRequest)&&Objects.nonNull(carLogsListRequest.getLimitNum())," limit " +carLogsListRequest.getLimitNum()) + ); + for (PlatformLog platformLog:platformLogList) { + CarLogsListResponse carLogsListResponse = new CarLogsListResponse(); + carLogsListResponse.setCarCode(platformLog.getParam4()); + carLogsListResponse.setContent(platformLog.getContent()); + carLogsListResponse.setCreateDate(new Date()); + carLogsListResponseList.add(carLogsListResponse); + } + return carLogsListResponseList; + } + + +} -- Gitblit v1.9.3