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);
    }
}