package com.doumee.service.business.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
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.YwConditionerGatewayLogMapper;
|
import com.doumee.dao.business.YwConditionerGatewayMapper;
|
import com.doumee.dao.business.model.YwConditionerGateway;
|
import com.doumee.dao.business.model.YwConditionerGatewayLog;
|
import com.doumee.service.business.ConditionerBizService;
|
import com.doumee.service.business.YwConditionerGatewayService;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
@Service
|
public class YwConditionerGatewayServiceImpl implements YwConditionerGatewayService {
|
|
@Autowired
|
private YwConditionerGatewayMapper gatewayMapper;
|
@Autowired
|
private YwConditionerGatewayLogMapper gatewayLogMapper;
|
@Autowired
|
private ConditionerBizService conditionerBizService;
|
|
@Override
|
public PageData<YwConditionerGateway> findPage(PageWrap<YwConditionerGateway> pageWrap) {
|
IPage<YwConditionerGateway> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
YwConditionerGateway model = pageWrap.getModel() == null ? new YwConditionerGateway() : pageWrap.getModel();
|
Utils.MP.blankToNull(model);
|
MPJLambdaWrapper<YwConditionerGateway> qw = new MPJLambdaWrapper<>();
|
qw.selectAll(YwConditionerGateway.class)
|
.eq(YwConditionerGateway::getIsdeleted, Constants.ZERO)
|
.eq(StringUtils.isNotBlank(model.getOnlineStatus()), YwConditionerGateway::getOnlineStatus, model.getOnlineStatus())
|
.and(StringUtils.isNotBlank(model.getKeyword()), w -> w
|
.like(YwConditionerGateway::getWgMac, model.getKeyword())
|
.or().like(YwConditionerGateway::getWgBz, model.getKeyword()))
|
.orderByDesc(YwConditionerGateway::getId);
|
return PageData.from(gatewayMapper.selectJoinPage(page, YwConditionerGateway.class, qw));
|
}
|
|
@Override
|
public PageData<YwConditionerGatewayLog> gatewayLogPage(PageWrap<YwConditionerGatewayLog> pageWrap) {
|
IPage<YwConditionerGatewayLog> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
YwConditionerGatewayLog model = pageWrap.getModel() == null ? new YwConditionerGatewayLog() : pageWrap.getModel();
|
Utils.MP.blankToNull(model);
|
MPJLambdaWrapper<YwConditionerGatewayLog> qw = new MPJLambdaWrapper<>();
|
qw.selectAll(YwConditionerGatewayLog.class)
|
.eq(YwConditionerGatewayLog::getIsdeleted, Constants.ZERO)
|
.eq(model.getGatewayId() != null, YwConditionerGatewayLog::getGatewayId, model.getGatewayId())
|
.eq(StringUtils.isNotBlank(model.getWgMac()), YwConditionerGatewayLog::getWgMac, model.getWgMac())
|
.ge(model.getLogTimeBegin() != null, YwConditionerGatewayLog::getLogTime, model.getLogTimeBegin())
|
.le(model.getLogTimeEnd() != null, YwConditionerGatewayLog::getLogTime, model.getLogTimeEnd())
|
.orderByDesc(YwConditionerGatewayLog::getLogTime);
|
return PageData.from(gatewayLogMapper.selectJoinPage(page, YwConditionerGatewayLog.class, qw));
|
}
|
|
@Override
|
public String syncAll() {
|
return conditionerBizService.syncGateways("manual");
|
}
|
}
|
