update

eight

2024-08-14 5dc193a97f10ded28aceb89f07b795f9495aa01d

 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java

@@ -1,19 +1,19 @@
package cn.lihu.jh.module.ecg.service.queue;

import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueStatisticDO;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import org.springframework.transaction.annotation.Transactional;

import java.util.*;
import cn.lihu.jh.module.ecg.controller.admin.queue.vo.*;
import cn.lihu.jh.module.ecg.dal.dataobject.queue.queueDO;
import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
import cn.lihu.jh.framework.common.pojo.PageResult;
import cn.lihu.jh.framework.common.pojo.PageParam;
import cn.lihu.jh.framework.common.util.object.BeanUtils;

import cn.lihu.jh.module.ecg.dal.mysql.queue.queueMapper;

import javax.annotation.Resource;

import java.util.List;

import static cn.lihu.jh.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*;
@@ -25,26 +25,26 @@
 */
@Service
@Validated
public class queueServiceImpl implements queueService {
public class QueueServiceImpl implements QueueService {

    @Resource
    private queueMapper queueMapper;

    @Override
    public Integer createqueue(queueSaveReqVO createReqVO) {
    public Integer createqueue(QueueSaveReqVO createReqVO) {
        // 插入
        queueDO queue = BeanUtils.toBean(createReqVO, queueDO.class);
        QueueDO queue = BeanUtils.toBean(createReqVO, QueueDO.class);
        queueMapper.insert(queue);
        // 返回
        return queue.getId();
    }

    @Override
    public void updatequeue(queueSaveReqVO updateReqVO) {
    public void updatequeue(QueueSaveReqVO updateReqVO) {
        // 校验存在
        validatequeueExists(updateReqVO.getId());
        // 更新
        queueDO updateObj = BeanUtils.toBean(updateReqVO, queueDO.class);
        QueueDO updateObj = BeanUtils.toBean(updateReqVO, QueueDO.class);
        queueMapper.updateById(updateObj);
    }

@@ -63,13 +63,18 @@
    }

    @Override
    public queueDO getqueue(Integer id) {
    public QueueDO getqueue(Integer id) {
        return queueMapper.selectById(id);
    }

    @Override
    public PageResult<queueDO> getqueuePage(queuePageReqVO pageReqVO) {
    public PageResult<QueueDO> getqueuePage(QueuePageReqVO pageReqVO) {
        return queueMapper.selectPage(pageReqVO);
    }

    @Override
    public List<QueueStatisticDO> queueStatistics(List<Byte> statusList) {
        return queueMapper.queueStatistic(statusList);
    }

}