package com.fzzy.igds.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.igds.data.BaseResp;
import com.fzzy.igds.data.IgdsBaseParam;
import com.fzzy.igds.domain.PatrolRecord;
import com.fzzy.igds.mapper.PatrolRecordMapper;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

@Slf4j
@Service
public class PatrolRecordService {

    @Resource
    private PatrolRecordMapper patrolRecordMapper;

    /**
     * 分页查询数据
     *
     * @param page
     * @param param
     */
    public void listPage(Page<PatrolRecord> page, IgdsBaseParam param) {
        QueryWrapper<PatrolRecord> queryWrapper = getQueryWrapper(param);
        patrolRecordMapper.selectPage(page, queryWrapper);
    }

    public List<PatrolRecord> listAll(IgdsBaseParam param) {
        QueryWrapper<PatrolRecord> queryWrapper = getQueryWrapper(param);
        return patrolRecordMapper.selectList(queryWrapper);
    }

    /**
     * 封装查询条件
     *
     * @param param
     */
    public QueryWrapper<PatrolRecord> getQueryWrapper(IgdsBaseParam param) {
        QueryWrapper<PatrolRecord> queryWrapper = new QueryWrapper<>();

        param.setCompanyId(ContextUtil.getCompanyId());
        queryWrapper.eq("company_id", param.getCompanyId());

        if (StringUtils.isNotBlank(param.getName())) {
            queryWrapper.eq("point_name", param.getName());
        }
        if (StringUtils.isNotBlank(param.getKey())) {
            queryWrapper.eq("patrol_id", param.getKey());
        }
        queryWrapper.orderByDesc("id");

        return queryWrapper;
    }


    /**
     * 添加数据
     *
     * @param patrolRecord
     * @author sgj
     * @date 2025/12/10
     */
    public BaseResp addData(PatrolRecord patrolRecord) {
        patrolRecord.setId(ContextUtil.generateId());
        patrolRecord.setCompanyId(ContextUtil.getCompanyId());
        patrolRecord.setUpdateBy(ContextUtil.getLoginUserName());
        patrolRecord.setUpdateTime(new Date());
        patrolRecord.setCreateBy(ContextUtil.getLoginUserName());
        patrolRecord.setCreateTime(new Date());
        return patrolRecordMapper.insert(patrolRecord) > 0 ? BaseResp.success() : BaseResp.error("添加失败");
    }

    /**
     * 更新数据
     *
     * @param patrolRecord
     * @author sgj
     * @date 2025/12/10
     */
    public BaseResp updateData(PatrolRecord patrolRecord) {
        patrolRecord.setUpdateBy(ContextUtil.getLoginUserName());
        patrolRecord.setUpdateTime(new Date());
        return patrolRecordMapper.updateById(patrolRecord) > 0 ? BaseResp.success() : BaseResp.error("更新失败");
    }

    /**
     * 删除数据
     *
     * @param patrolRecord
     * @author sgj
     * @date 2025/12/10
     */
    public BaseResp deleteData(PatrolRecord patrolRecord) {
        return patrolRecordMapper.deleteById(patrolRecord) > 0 ? BaseResp.success() : BaseResp.error("删除失败");
    }
}