package com.template.controller;


import com.template.api.SmartDataTaskControllerAPI;
import com.template.common.utils.paramUtils;
import com.template.model.pojo.SmartDataSourceLog;
import com.template.model.pojo.SmartDataTask;
import com.template.model.result.CommonResult;
import com.template.model.result.PageUtils;
import com.template.services.SmartDataTaskService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;

/**
 * <p>
 * 数据源任务 前端控制器
 * </p>
 *
 * @author ceshi
 * @since 2023-12-05
 */
@RestController
public class SmartDataTaskController implements SmartDataTaskControllerAPI {

    @Autowired
    private SmartDataTaskService smartDataTaskService;

    /**
     * 新增任务
     *
     * @param smartDataTask 任务数据
     * @param bindingResult
     * @return
     */
    @Override
    public CommonResult insertSmartDataTask(SmartDataTask smartDataTask, BindingResult bindingResult) {
        if (bindingResult.hasErrors()) {
            String st = paramUtils.getParamError(bindingResult);
            return CommonResult.fail(st);
        }

        Map<String, String> result = smartDataTaskService.insertSmartDataTask(smartDataTask);

        return Integer.parseInt(result.get("code")) > 0 ? CommonResult.ok(result.get("msg")) : CommonResult.fail(result.get("msg"));
    }

    /**
     * 更新日志
     *
     * @param smartDataTask 日志数据
     * @param bindingResult
     * @return
     */
    @Override
    public CommonResult updateSmartDataTaskById(SmartDataTask smartDataTask, BindingResult bindingResult) {
        if (bindingResult.hasErrors()) {
            String st = paramUtils.getParamError(bindingResult);
            return CommonResult.fail(st);
        }

        Map<String, String> result = smartDataTaskService.updateSmartDataTaskById(smartDataTask);

        return Integer.parseInt(result.get("code")) > 0 ? CommonResult.ok(result.get("msg")) : CommonResult.fail(result.get("msg"));
    }

    @Override
    public CommonResult updateSmartDataTaskActivation(SmartDataTask smartDataTask, BindingResult bindingResult) {
        if (bindingResult.hasErrors()) {
            String st = paramUtils.getParamError(bindingResult);
            return CommonResult.fail(st);
        }

        Map<String, String> result = smartDataTaskService.updateSmartDataTaskActivation(smartDataTask);

        return Integer.parseInt(result.get("code")) > 0 ? CommonResult.ok(result.get("msg")) : CommonResult.fail(result.get("msg"));
    }

    /**
     * 日志分页数据查询
     *
     * @param currentPage   当前页数
     * @param pageCount     一页数据条数
     * @param smartDataTask 查询名称
     * @return
     */
    @Override
    public CommonResult queryPageSmartDataTasks(int currentPage, int pageCount, SmartDataTask smartDataTask) {
        PageUtils<SmartDataTask> result = smartDataTaskService.queryPageSmartDataTasks(currentPage, pageCount, smartDataTask);

        return CommonResult.ok(result);
    }


    @Override
    public CommonResult deleteSmartDataTaskById(int id) {

        SmartDataTask data = smartDataTaskService.getSmartById(id);

        if (data == null) {
            return CommonResult.fail("当前数据不存在，删除失败！");
        }

        int result = smartDataTaskService.deleteSmartDataTaskById(id);

        return result > 0 ? CommonResult.ok("删除成功") : CommonResult.fail("删除失败");
    }
}