package com.ruoyi.interchange.service.impl;
|
|
import com.github.pagehelper.PageHelper;
|
import com.ruoyi.common.core.page.PageDomain;
|
import com.ruoyi.common.core.page.TableDataInfo;
|
import com.ruoyi.common.core.page.TableSupport;
|
import com.ruoyi.common.utils.sql.SqlUtil;
|
import com.ruoyi.common.utils.uuid.UUID;
|
import com.ruoyi.interchange.domain.TbDataSendRecords;
|
import com.ruoyi.interchange.mapper.TbDataSendRecordsMapper;
|
import com.ruoyi.interchange.service.ITbDataSendRecordsService;
|
import com.ruoyi.interchange.util.MongoDBPageUtils;
|
import com.ruoyi.interchange.util.MongoDbUtilService;
|
import com.ruoyi.interchange.util.PageResult;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* 数据发送记录Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2023-04-25
|
*/
|
@Service
|
public class TbDataSendRecordsServiceImpl extends MongoDbUtilService<TbDataSendRecords> implements ITbDataSendRecordsService
|
{
|
@Autowired
|
private TbDataSendRecordsMapper tbDataSendRecordsMapper;
|
|
@Override
|
protected Class<TbDataSendRecords> getEntityClass() {
|
return TbDataSendRecords.class;
|
}
|
/**
|
* 查询数据发送记录
|
*
|
* @param id 数据发送记录主键
|
* @return 数据发送记录
|
*/
|
@Override
|
public TbDataSendRecords selectTbDataSendRecordsById(String id)
|
{
|
return queryById(id);
|
}
|
|
|
|
/**
|
* 查询数据发送记录列表
|
*
|
* @param tbDataSendRecords 数据发送记录
|
* @return 数据发送记录
|
*/
|
@Override
|
public List<TbDataSendRecords> selectTbDataSendRecordsList(TbDataSendRecords tbDataSendRecords)
|
{
|
PageDomain pageDomain = TableSupport.buildPageRequest();
|
Integer pageNum = pageDomain.getPageNum();
|
Integer pageSize = pageDomain.getPageSize();
|
String orderBy = SqlUtil.escapeOrderBySql(pageDomain.getOrderBy());
|
Boolean reasonable = pageDomain.getReasonable();
|
PageHelper.startPage(pageNum, pageSize, orderBy).setReasonable(reasonable);
|
return getPage(tbDataSendRecords,pageNum,pageSize);
|
}
|
/**
|
* 查询数据发送记录列表
|
*
|
* @param tbDataSendRecords 数据发送记录
|
* @return 数据发送记录
|
*/
|
@Override
|
public TableDataInfo selectTbDataSendRecordsList2(TbDataSendRecords tbDataSendRecords)
|
{
|
PageDomain pageDomain = TableSupport.buildPageRequest();
|
Integer pageNum = pageDomain.getPageNum();
|
Integer pageSize = pageDomain.getPageSize();
|
Query query = getQueryByObject2(tbDataSendRecords,"detectionTime");
|
PageResult<TbDataSendRecords> pagination = MongoDBPageUtils.pagination(TbDataSendRecords.class, pageNum, pageSize, query);
|
TableDataInfo info =new TableDataInfo();
|
info.setCode(200);
|
info.setRows(pagination.getList());
|
info.setTotal(pagination.getTotal());
|
info.setMsg("1");
|
return info;
|
}
|
|
/**
|
* 新增数据发送记录
|
*
|
* @param tbDataSendRecords 数据发送记录
|
* @return 结果
|
*/
|
@Override
|
public int insertTbDataSendRecords(TbDataSendRecords tbDataSendRecords)
|
{
|
tbDataSendRecords.setId(UUID.randomUUID().toString());
|
return save(tbDataSendRecords);
|
}
|
|
/**
|
* 修改数据发送记录
|
*
|
* @param tbDataSendRecords 数据发送记录
|
* @return 结果
|
*/
|
@Override
|
public int updateTbDataSendRecords(TbDataSendRecords tbDataSendRecords)
|
{
|
TbDataSendRecords records=new TbDataSendRecords();
|
records.setId(tbDataSendRecords.getId());
|
updateInsert(records,tbDataSendRecords);
|
int i=1;
|
return i;
|
}
|
|
/**
|
* 批量删除数据发送记录
|
*
|
* @param ids 需要删除的数据发送记录主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteTbDataSendRecordsByIds(String[] ids)
|
{
|
for(String id:ids){
|
deleteTbDataSendRecordsById(id);
|
}
|
return 1;
|
}
|
|
/**
|
* 删除数据发送记录信息
|
*
|
* @param id 数据发送记录主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteTbDataSendRecordsById(String id)
|
{
|
deleteById(id);
|
return 1;
|
}
|
|
@Override
|
public void recordSaveMongo(TbDataSendRecords tbDataSendRecords){
|
save(tbDataSendRecords);
|
}
|
}
|
