package com.artfess.uc.controller;

import com.artfess.base.annotation.ApiGroup;
import com.artfess.base.annotation.UpdateMethod;
import com.artfess.base.constants.ApiGroupConsts;
import com.artfess.base.controller.BaseController;
import com.artfess.base.model.CommonResult;
import com.artfess.base.query.PageList;
import com.artfess.base.query.QueryFilter;
import com.artfess.base.query.QueryOP;
import com.artfess.base.util.BeanUtils;
import com.artfess.uc.api.model.IUser;
import com.artfess.uc.manager.OrgJobManager;
import com.artfess.uc.model.OrgJob;
import com.artfess.uc.params.job.JobVo;
import com.artfess.uc.params.user.UserVo;
import com.artfess.uc.util.ContextUtil;
import com.artfess.uc.util.OrgUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.web.bind.annotation.*;

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

/**
 * 职务模块接口
 *
 * @author zhangxw
 */
@RestController
@RequestMapping("/api/job/v1/")
@Api(tags = "职务管理")
@ApiGroup(group = {ApiGroupConsts.GROUP_UC})
public class JobController extends BaseController<OrgJobManager, OrgJob> {

    @Resource
    OrgJobManager orgJobService;

    /**
     * 查询职务
     *
     * @param filter
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "jobs/getJobPage", method = RequestMethod.POST, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "获取职务列表（带分页信息）", httpMethod = "POST", notes = "获取职务列表")
    public PageList<OrgJob> getJobPage(@ApiParam(name = "filter", value = "查询参数", required = true) @RequestBody QueryFilter filter) throws Exception {
        IUser currentUser = ContextUtil.getCurrentUser();
        if (BeanUtils.isNotEmpty(currentUser) && !currentUser.isAdmin()) {
            filter.addFilter("create_org_id_", ContextUtil.getCurrentOrgId(), QueryOP.EQUAL);
        }
        PageList<OrgJob> query = orgJobService.query(filter);
        return query;
    }

    /**
     * 获取职务列表
     *
     * @param filter
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "jobs/getJobList", method = RequestMethod.POST, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "获取职务列表", httpMethod = "POST", notes = "获取职务列表")
    public List<OrgJob> getJobList(@ApiParam(name = "filter", value = "查询参数", required = true) @RequestBody QueryFilter filter) throws Exception {
        IUser currentUser = ContextUtil.getCurrentUser();
        if (!currentUser.isAdmin()) {
            filter.addFilter("create_org_id_", ContextUtil.getCurrentOrgId(), QueryOP.EQUAL);
        }
        return orgJobService.query(filter).getRows();
    }

    /**
     * 添加职务
     *
     * @param job
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/addJob", method = RequestMethod.POST, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "添加职务", httpMethod = "POST", notes = "添加职务")
    public CommonResult<String> addJob(@ApiParam(name = "job", value = "职务参数对象", required = true) @RequestBody JobVo job) throws Exception {
        CommonResult<String> rtn = null;
        try {
            rtn = orgJobService.addJob(job);
        } catch (Exception e) {
            rtn = new CommonResult<String>(false, e.getMessage(), "");
        }
        return rtn;
    }

    /**
     * 从第三方系统数据添加职务到系统
     *
     * @param job
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/addJobFromExterUni", method = RequestMethod.POST, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "从第三方系统数据添加职务到系统", httpMethod = "POST", notes = "从第三方系统数据添加职务到系统")
    public CommonResult<String> addJobFromExterUni(@ApiParam(name = "job", value = "职务参数对象", required = true) @RequestBody OrgJob job) throws Exception {
        CommonResult<String> rtn = null;
        try {
            rtn = orgJobService.addJobFromExterUni(job);
        } catch (Exception e) {
            rtn = new CommonResult<String>(false, e.getMessage(), "");
        }
        return rtn;
    }

    /**
     * 根据职务帐号删除职务
     *
     * @param codes
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/deleteJob", method = RequestMethod.POST, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "根据职务编码删除职务", httpMethod = "POST", notes = "根据角编码识删除职务")
    public CommonResult<String> deleteJob(@ApiParam(name = "codes", value = "职务编码（多个用,号隔开）", required = true) @RequestBody String codes) throws Exception {
        return orgJobService.deleteJob(codes);
    }

    /**
     * 根据职务id删除职务
     *
     * @param ids
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/deleteJobByIds", method = RequestMethod.DELETE, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "根据职务id删除职务", httpMethod = "DELETE", notes = "根据职务id删除职务")
    public CommonResult<String> deleteJobByIds(@ApiParam(name = "ids", value = "职务id（多个用,号隔开）", required = true) @RequestParam String ids) throws Exception {
        return orgJobService.deleteJobByIds(ids);
    }

    /**
     * 更新职务
     *
     * @param job
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/updateJob", method = RequestMethod.PUT, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "更新职务", httpMethod = "PUT", notes = "更新职务")
    @UpdateMethod(type = JobVo.class)
    public CommonResult<String> updateJob(@ApiParam(name = "job", value = "职务参数对象", required = true) @RequestBody JobVo job) throws Exception {
        return orgJobService.updateJob(job);
    }

    /**
     * 获取职务信息
     *
     * @param code
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/getJob", method = RequestMethod.GET, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "根据职务编码或id获取职务信息", httpMethod = "GET", notes = "获取职务信息")
    public OrgJob getJob(@ApiParam(name = "code", value = "职务编码", required = true) @RequestParam String code) throws Exception {
        OrgJob job = orgJobService.getByCode(code);
        if (BeanUtils.isEmpty(job)) {
            job = orgJobService.get(code);
        }
        if (BeanUtils.isEmpty(job)) {
            throw new RuntimeException("根据输入的职务编码【" + code + "】，没有找到对应的职务信息！");
        }
        return job;
    }

    /**
     * 获取职务信息（返回CommonResult<OrgJob>）
     *
     * @param code
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/getOrgJob", method = RequestMethod.GET, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "根据职务编码或id获取职务信息", httpMethod = "GET", notes = "获取职务信息")
    public CommonResult<OrgJob> getOrgJob(@ApiParam(name = "code", value = "职务编码", required = true) @RequestParam String code) throws Exception {
        OrgJob job = orgJobService.getByCode(code);
        if (BeanUtils.isEmpty(job)) {
            job = orgJobService.get(code);
        }
        return new CommonResult<OrgJob>(true, "获取职务成功", job);
    }

    /**
     * 获取职务（多个）下的所有人员
     *
     * @param codes
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "jobUser/getUsersByJob", method = RequestMethod.GET, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "获取职务（多个）下的所有人员", httpMethod = "GET", notes = "获取职务下的所有人员")
    public List<UserVo> getUsersByJob(@ApiParam(name = "codes", value = "职务编码（多个用“,”号隔开）", required = true) @RequestParam String codes) throws Exception {
        return orgJobService.getUsersByJob(codes);
    }

    /**
     * 物理删除所有逻辑删除了的职务数据
     *
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "job/deleteJobPhysical", method = RequestMethod.DELETE, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "物理删除所有逻辑删除了的职务数据", httpMethod = "DELETE", notes = "物理删除所有逻辑删除了的职务数据")
    public CommonResult<Integer> deleteJobPhysical() throws Exception {
        Integer num = orgJobService.removePhysical();
        return OrgUtil.getRemovePhysiMsg(num);
    }

    /**
     * 根据时间获取职务数据（数据同步）
     *
     * @param btime
     * @param etime
     * @return
     * @throws Exception
     */
    @RequestMapping(value = "jobs/getJobByTime", method = RequestMethod.GET, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "根据时间获取职务数据（数据同步）", httpMethod = "GET", notes = "根据时间获取职务数据（数据同步）")
    public List<OrgJob> getJobByTime(@ApiParam(name = "btime", value = "开始时间（格式：2018-01-01 12:00:00或2018-01-01）") @RequestParam(required = false) String btime, @ApiParam(name = "etime", value = "结束时间（格式：2018-02-01 12:00:00或2018-02-01）") @RequestParam(required = false) String etime) throws Exception {
        return orgJobService.getJobByTime(btime, etime);
    }

    @RequestMapping(value = "job/isCodeExist", method = RequestMethod.GET, produces = {"application/json; charset=utf-8"})
    @ApiOperation(value = "查询职务编码是否已存在", httpMethod = "GET", notes = "查询职务编码是否已存在")
    public CommonResult<Boolean> isCodeExist(@ApiParam(name = "code", value = "职务编码")
                                             @RequestParam(required = true) String code) throws Exception {
        return orgJobService.isCodeExist(code);
    }
}