package com.sooka.sponest.data.digitalresource.controller;


import com.alibaba.fastjson.JSON;
import com.ruoyi.common.core.constant.DocumentNameConstants;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.web.controller.BaseController;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.common.core.web.page.TableDataInfo;
import com.ruoyi.common.log.annotation.Log;
import com.ruoyi.common.log.enums.BusinessType;
import com.ruoyi.common.security.annotation.RequiresPermissions;
import com.sooka.sponest.data.base.domain.ESVo;
import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesDeposit;
import com.sooka.sponest.data.digitalresource.service.ICenterdataTResourcesDepositService;
import com.sooka.sponest.data.utils.DataConstants;
import com.sooka.sponest.data.utils.DataProducerUtil;
import com.sooka.sponest.data.utils.ExcelUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletResponse;
import java.util.Arrays;
import java.util.List;


/**
 * 矿臧资源Controller
 *
 * @author ruoyi
 * @date 2023-02-21
 */
@Api(tags = "矿臧资源控制器")
@RestController
@RequestMapping("/deposit")
public class CenterdataTResourcesDepositController extends BaseController {

    @Autowired
    private ICenterdataTResourcesDepositService centerdataTResourcesDepositService;

    /**
     * 查询矿臧资源列表
     */
    @ApiOperation(value = "查询矿臧资源列表", notes = "查询矿臧资源列表")
    @RequiresPermissions("resources:deposit:list")
    @GetMapping("/list")
    public TableDataInfo list(CenterdataTResourcesDeposit centerdataTResourcesDeposit) {
        startPage();
        List<CenterdataTResourcesDeposit> list = centerdataTResourcesDepositService.selectCenterdataTResourcesDepositList(centerdataTResourcesDeposit);
        return getDataTable(list);
    }

    // 远端调用 数字资源远端调用

    @ApiOperation(value = "数字资源远端调用", notes = "数字资源远端调用")
    @PostMapping("/listDeposit")
    public R<List<CenterdataTResourcesDeposit>> listDeposit(CenterdataTResourcesDeposit centerdataTResourcesDeposit) {
        return R.ok(centerdataTResourcesDepositService.selectCenterdataTResourcesDepositList(centerdataTResourcesDeposit));
    }

    /**
     * 导出矿臧资源列表
     */

    @ApiOperation(value = "导出矿臧资源列表", notes = "导出矿臧资源列表")
    @RequiresPermissions("resources:deposit:export")
    @Log(title = "矿臧资源", businessType = BusinessType.EXPORT)
    @PostMapping("/export")
    public void export(HttpServletResponse response, CenterdataTResourcesDeposit centerdataTResourcesDeposit) {
        List<CenterdataTResourcesDeposit> list = centerdataTResourcesDepositService.selectCenterdataTResourcesDepositList(centerdataTResourcesDeposit);
        ExcelUtil<CenterdataTResourcesDeposit> util = new ExcelUtil<>(CenterdataTResourcesDeposit.class);
        util.exportExcel(response, list, "矿臧资源数据");
    }

    /**
     * 获取矿臧资源详细信息
     */
    @ApiOperation(value = "获取矿臧资源详细信息", notes = "获取矿臧资源详细信息")
    @RequiresPermissions("resources:deposit:query")
    @GetMapping(value = "/{id}")
    public AjaxResult getInfo(@PathVariable("id") String id) {
        return AjaxResult.success(centerdataTResourcesDepositService.selectCenterdataTResourcesDepositById(id));
    }

    /**
     * 新增矿臧资源
     */

    @ApiOperation(value = "新增矿臧资源", notes = "新增矿臧资源")
    @RequiresPermissions("resources:deposit:add")
    @Log(title = "矿臧资源", businessType = BusinessType.INSERT)
    @PostMapping
    public AjaxResult add(@Validated @RequestBody CenterdataTResourcesDeposit centerdataTResourcesDeposit) {
        String tableName = "centerdata_t_resources_deposit";
        String[] keys = {"name","dept_id"};
        String[] values = {centerdataTResourcesDeposit.getName(),String.valueOf(centerdataTResourcesDeposit.getDeptId())};
        if(!centerdataTResourcesDepositService.uniqueCheck(tableName, keys, values)){
            return AjaxResult.error(DataConstants.ERROR_MSG);
        }
        int result = centerdataTResourcesDepositService.insertCenterdataTResourcesDeposit(centerdataTResourcesDeposit);
        DataProducerUtil.getInstance().publish(new ESVo(DocumentNameConstants.RESOURCES_DEPOSIT,BusinessType.INSERT, JSON.toJSONString(centerdataTResourcesDeposit)));
        return toAjax(result);
    }

    /**
     * 修改矿臧资源
     */

    @ApiOperation(value = "修改矿臧资源", notes = "修改矿臧资源")
    @RequiresPermissions("resources:deposit:edit")
    @Log(title = "矿臧资源", businessType = BusinessType.UPDATE)
    @PutMapping
    public AjaxResult edit(@Validated @RequestBody CenterdataTResourcesDeposit centerdataTResourcesDeposit) {
        String tableName = "centerdata_t_resources_deposit";
        String[] keys = {"name","id","dept_id"};
        String[] values = {centerdataTResourcesDeposit.getName(), centerdataTResourcesDeposit.getId(),String.valueOf(centerdataTResourcesDeposit.getDeptId())};
        if(!centerdataTResourcesDepositService.uniqueCheck(tableName, keys, values)){
            return AjaxResult.error(DataConstants.ERROR_MSG);
        }
        int result = centerdataTResourcesDepositService.updateCenterdataTResourcesDeposit(centerdataTResourcesDeposit);
        DataProducerUtil.getInstance().publish(new ESVo(DocumentNameConstants.RESOURCES_DEPOSIT,BusinessType.UPDATE, JSON.toJSONString(centerdataTResourcesDeposit)));
        return toAjax(result);
    }

    /**
     * 删除矿臧资源
     */
    @ApiOperation(value = "删除矿臧资源", notes = "删除矿臧资源")
    @RequiresPermissions("resources:deposit:remove")
    @Log(title = "矿臧资源", businessType = BusinessType.DELETE)
    @DeleteMapping("/{ids}")
    public AjaxResult remove(@PathVariable String[] ids) {
        int result = centerdataTResourcesDepositService.deleteCenterdataTResourcesDepositByIds(ids);
        List<String> idList = Arrays.asList(ids);
        DataProducerUtil.getInstance().publish(new ESVo(DocumentNameConstants.RESOURCES_DEPOSIT,BusinessType.DELETE, JSON.toJSONString(idList)));
        return toAjax(result);
    }
}