warewms-project-api/warewms-system/src/main/java/com/warewms/hailiang/service/impl/DeviceLogServiceImpl.java

package com.warewms.hailiang.service.impl;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.warewms.common.core.domain.base.page.PageDomain;
import com.warewms.common.core.domain.base.page.TableDataInfo;
import com.warewms.common.utils.StringUtils;
import com.warewms.hailiang.domain.DeviceLog;
import com.warewms.hailiang.mapper.DeviceLogMapper;
import com.warewms.hailiang.service.DeviceLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.Map;

/**
 * @author AD
 * @description 针对表【device_log(设备日志表)】的数据库操作Service实现
 * @createDate 2023-08-21 13:24:57
 */
@Service
public class DeviceLogServiceImpl extends ServiceImpl<DeviceLogMapper, DeviceLog>
        implements DeviceLogService {

    @Autowired
    DeviceLogMapper deviceLogMapper;


    @Override
    public TableDataInfo<DeviceLog> getList(DeviceLog deviceLog, PageDomain pageDomain) {
        Map<String, Object> params = deviceLog.getParams();
        IPage<DeviceLog> deviceLogIPage = deviceLogMapper.selectPage(pageDomain.build(), new LambdaQueryWrapper<DeviceLog>()
                .eq(StringUtils.isNotEmpty(deviceLog.getDeviceId()), DeviceLog::getDeviceId, deviceLog.getDeviceId())
                .eq(StringUtils.isNotEmpty(deviceLog.getDeviceName()), DeviceLog::getDeviceName, deviceLog.getDeviceName())
                .eq(StringUtils.isNotEmpty(deviceLog.getStatus()), DeviceLog::getStatus, deviceLog.getStatus())
                .between(params.get("beginTime") != null && params.get("endTime") != null,
                        DeviceLog::getCreateTime, params.get("beginTime"), params.get("endTime")));
        return TableDataInfo.build(deviceLogIPage);
    }

    @Override
    @Async
    @EventListener
    public void crateLog(DeviceLog deviceLog) {
        deviceLogMapper.insert(deviceLog);
    }
}