package com.zhitan.model.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.zhitan.common.constant.Constants;
|
import com.zhitan.common.core.redis.RedisCache;
|
import com.zhitan.common.utils.StringUtils;
|
import com.zhitan.model.domain.DaqTemplate;
|
import com.zhitan.model.mapper.DaqTemplateMapper;
|
import com.zhitan.model.service.IDaqTemplateService;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.Collections;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
/**
|
* 采集参数模板Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2020-02-08
|
*/
|
@Service
|
public class DaqTemplateServiceImpl implements IDaqTemplateService {
|
@Resource
|
private RedisCache cache;
|
@Autowired
|
private DaqTemplateMapper daqTemplateMapper;
|
|
|
/**
|
* 查询采集参数模板
|
*
|
* @param id 采集参数模板ID
|
* @return 采集参数模板
|
*/
|
@Override
|
public DaqTemplate selectDaqTemplateById(String id) {
|
return daqTemplateMapper.selectDaqTemplateById(id);
|
}
|
|
/**
|
* 查询采集参数模板列表
|
*
|
* @param daqTemplate 采集参数模板
|
* @return 采集参数模板
|
*/
|
@Override
|
public List<DaqTemplate> selectDaqTemplateList(DaqTemplate daqTemplate) {
|
return daqTemplateMapper.selectDaqTemplateList(daqTemplate);
|
}
|
|
/**
|
* 新增采集参数模板
|
*
|
* @param daqTemplate 采集参数模板
|
* @return 结果
|
*/
|
@Override
|
public int insertDaqTemplate(DaqTemplate daqTemplate) {
|
return daqTemplateMapper.insertDaqTemplate(daqTemplate);
|
}
|
|
/**
|
* 修改采集参数模板
|
*
|
* @param daqTemplate 采集参数模板
|
* @return 结果
|
*/
|
@Override
|
public int updateDaqTemplate(DaqTemplate daqTemplate) {
|
return daqTemplateMapper.updateDaqTemplate(daqTemplate);
|
}
|
|
/**
|
* 批量删除采集参数模板
|
*
|
* @param ids 需要删除的采集参数模板ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteDaqTemplateByIds(String[] ids) {
|
return daqTemplateMapper.deleteDaqTemplateByIds(ids);
|
}
|
|
/**
|
* 删除采集参数模板信息
|
*
|
* @param id 采集参数模板ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteDaqTemplateById(String id) {
|
return daqTemplateMapper.deleteDaqTemplateById(id);
|
}
|
|
@Override
|
public boolean dapHasExist(String code, String deviceType) {
|
int count = daqTemplateMapper.dapHasExist(code, deviceType);
|
return count > 0;
|
}
|
|
@Override
|
public boolean dapHasExist(DaqTemplate daqTemplate) {
|
int count = daqTemplateMapper.dapHasExistWhenUpdate(daqTemplate.getId(), daqTemplate.getCode(), daqTemplate.getDeviceType());
|
return count > 0;
|
}
|
|
/**
|
* 查询指标模板
|
*
|
* @return 结果
|
*/
|
@Override
|
public List<DaqTemplate> listTemplate() {
|
Object cacheObject = cache.getCacheObject(Constants.DAQ_TEMPLATE_KEY);
|
if (ObjectUtils.isNotEmpty(cacheObject)) {
|
return JSONObject.parseArray(cacheObject.toString(), DaqTemplate.class);
|
}
|
|
List<DaqTemplate> daqTemplates = daqTemplateMapper.listTemplate();
|
if (CollectionUtils.isEmpty(daqTemplates)) {
|
return Collections.emptyList();
|
}
|
|
String jsonString = JSONObject.toJSONString(daqTemplates);
|
cache.setCacheObject(Constants.DAQ_TEMPLATE_KEY, jsonString, 6, TimeUnit.HOURS);
|
return daqTemplates;
|
}
|
|
/**
|
* 查询指标模板map
|
*
|
* @return 结果
|
*/
|
@Override
|
public Map<String, List<DaqTemplate>> listTemplateMap() {
|
Map<String, List<DaqTemplate>> map = new HashMap<>();
|
List<DaqTemplate> daqTemplates = this.listTemplate();
|
|
if (CollectionUtils.isNotEmpty(daqTemplates)) {
|
return daqTemplates.stream().collect(Collectors.groupingBy(DaqTemplate::getCode));
|
}
|
return map;
|
}
|
|
@Override
|
public Page<DaqTemplate> selectDaqTemplatePage(DaqTemplate daqTemplate, Long pageNum, Long pageSize) {
|
LambdaQueryWrapper<DaqTemplate> wrapper = new LambdaQueryWrapper<>();
|
wrapper.like(StringUtils.isNotEmpty(daqTemplate.getCode()),DaqTemplate::getCode,daqTemplate.getCode());
|
wrapper.like(StringUtils.isNotEmpty(daqTemplate.getName()),DaqTemplate::getName,daqTemplate.getName());
|
wrapper.eq(StringUtils.isNotEmpty(daqTemplate.getDeviceType()),DaqTemplate::getDeviceType,daqTemplate.getDeviceType());
|
wrapper.orderByDesc(DaqTemplate::getCreateTime);
|
Page<DaqTemplate> page = daqTemplateMapper.selectPage(new Page<DaqTemplate>(pageNum, pageSize), wrapper);
|
return page;
|
}
|
}
|
