crowd-test-service-backend/site/src/main/java/com/mooctest/crowd/site/controller/CrowdProjectController.java

package com.mooctest.crowd.site.controller;

import com.mooctest.crowd.domain.domainobject.CrowdTestProject;
import com.mooctest.crowd.domain.exception.BadRequestException;
import com.mooctest.crowd.domain.exception.BaseException;
import com.mooctest.crowd.site.annotation.LoginRequired;
import com.mooctest.crowd.site.command.CrowdTestProjectCommand;
import com.mooctest.crowd.site.command.GenerateProjectCommand;
import com.mooctest.crowd.site.data.dto.ProjectDetailsDTO;
import com.mooctest.crowd.site.data.vo.RegionalManagerVO;
import com.mooctest.crowd.site.service.CrowdProjectService;
import com.mooctest.crowd.site.util.FileUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.BindingResult;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpSession;
import java.io.IOException;
import java.util.List;

/**
 * @author: Diors.Po
 * @Email: 171256175@qq.com
 * @date 2019-07-24 23:50
 */
@Slf4j
@RestController
public class CrowdProjectController{

    @Autowired
    private CrowdProjectService projectService;

    /**
     *  创建项目接口
     * @param crowdTestProjectCommand
     * @param result
     * @return
     */
    @RequestMapping(value = "/api/project/", method = RequestMethod.POST)
    public ProjectDetailsDTO createProject(@Validated @RequestBody CrowdTestProjectCommand crowdTestProjectCommand, BindingResult result,HttpSession session){


        long  userId=Long.parseLong((String) session.getAttribute("userId"));

        if (result.hasErrors()) {
            throw new BaseException(result.getFieldErrors().toString());
        }
        else if (!crowdTestProjectCommand.isLegal())
            throw new BaseException("信息不合法，项目可见性必须选择指定的市");
//            throw new BaseException("信息不合法，项目可见性存在问题");
        return projectService.createCrowdProject(crowdTestProjectCommand,userId);
    }

    /**
     * 获取项目详情接口
     * @param projectCode
     * @return
     */
    @RequestMapping(value = "/api/project/{projectCode}", method = RequestMethod.GET)
    public ProjectDetailsDTO getProject(@PathVariable("projectCode") String projectCode, HttpSession session){
        log.info("访问Project详情，projectId："+projectCode);
        Object loginUser = session.getAttribute("userId");
        Long userId = null;
        if (loginUser!=null)
            userId = Long.parseLong((String)loginUser);
        return projectService.getProjectDetails(projectCode, userId);
    }

    /**
     * 获取全部项目
     * @return
     */
    @RequestMapping(value = "/api/project", method = RequestMethod.GET)
    public List<ProjectDetailsDTO> getProjects(){
        //todo 获取所有项目列表
        return null;
    }

    /**
     * 更新项目信息接口
     * @param crowdTestProjectCommand
     * @param projectCode
     * @param result
     * @return
     */
    @RequestMapping(value = "/api/project/{projectCode}", method = RequestMethod.PUT)
    public ProjectDetailsDTO updateProject(@Validated @RequestBody CrowdTestProjectCommand crowdTestProjectCommand, @PathVariable("projectCode") String projectCode, BindingResult result){
        if (result.hasErrors())
            throw new BaseException(result.getFieldErrors().toString());
        else if (!crowdTestProjectCommand.isLegal())
            throw new BaseException("信息不合法，项目可见性必须选择指定的市");
//            throw new BaseException("信息不合法，项目可见性存在问题");
        return projectService.updateProject(projectCode, crowdTestProjectCommand);
    }

    /**
     * 删除项目
     * @param projectId
     * @param session
     */
    @RequestMapping(value = "/api/project/{projectId}", method = RequestMethod.DELETE)
    public void deleteProject(@PathVariable("projectId") Long projectId, HttpSession session){
        projectService.deleteProject(projectId, (Long)session.getAttribute("userId"));
    }

    /**
     * 通过表单填写，生成项目
     * @param command
     * @return
     */
    @RequestMapping(value = "/api/greenChannel/project", method = RequestMethod.POST)
    public ProjectDetailsDTO generateProjectWithData(@RequestBody GenerateProjectCommand command){
        return projectService.generateProjectWithData(command);
    }

    /**
     * 将Excel解析为多个项目
     * @param file
     * @return
     */
    @RequestMapping(value = "/api/greenChannel/excel/{userId}/projects", method = RequestMethod.POST)
    public List<CrowdTestProject> parseExcel2Projects(@PathVariable("userId")Long userId, MultipartFile file){
        try {
            if (!FileUtil.checkExcel(file.getInputStream()))
                throw new BadRequestException("请上传Excel文件，xls/xlsx");
        } catch (IOException e) {
            e.printStackTrace();
        }
        return projectService.generateProjectByExcel(userId, file);
    }

    /**
     * 导入由Excel解析而来的多个项目
     * @param projects
     * @return
     */
    @RequestMapping(value = "/api/greenChannel/projects", method = RequestMethod.POST)
    public List<ProjectDetailsDTO> multiProjectsImport(@RequestBody List<CrowdTestProject> projects){
        return projectService.importMultiProjectsByExcel(projects);
    }

    /**
     * 区域管理员接收项目
     * @param projectCode
     * @param userId
     * @return
     */
    @LoginRequired
    @RequestMapping(value = "/api/project/{projectCode}/regionManager/{userId}", method = RequestMethod.PUT)
    public ProjectDetailsDTO acceptProject(@PathVariable("projectCode") String projectCode, @PathVariable("userId") Long userId){
        return projectService.receiveProject(projectCode, userId);
    }

    @LoginRequired
    @RequestMapping(value = "/api/project/{projectCode}/status/rejected", method = RequestMethod.PUT)
    public void rejectProejct(@PathVariable("projectCode") String projectCode, HttpSession session){
        Long userId = Long.parseLong((String)session.getAttribute("userId"));
        projectService.rejectProject(projectCode, userId);
    }

    @LoginRequired
    @RequestMapping(value = "/api/project/{projectCode}/status/committed", method = RequestMethod.PUT)
    public ProjectDetailsDTO commitProject(@PathVariable("projectCode") String projectCode, HttpSession session){
        Long userId = Long.parseLong((String)session.getAttribute("userId"));
        return projectService.commitProject(projectCode, userId);
    }

    @LoginRequired
    @RequestMapping(value = "/api/project/{projectCode}/status/finished", method = RequestMethod.PUT)
    public ProjectDetailsDTO confirmFinished(@PathVariable("projectCode") String projectCode, HttpSession session){
        Long userId = Long.parseLong((String)session.getAttribute("userId"));
        return projectService.confirmFinished(projectCode, userId);
    }

    /**
     * 获取区域管理员列表
     * @return
     */
    @RequestMapping(value = "/api/regionalManager", method = RequestMethod.GET)
    public List<RegionalManagerVO> getRegionalManagerList(){
        return projectService.getRegionalManagerList();
    }

    /**
     * 修正数据库信息
     * @param projectCode
     * @return
     */
    @RequestMapping(value = "/api/modify/{projectCode}", method = RequestMethod.GET)
    public boolean modifyData(@PathVariable("projectCode") String projectCode){
        return projectService.modifyData(projectCode);
    }

    /**
     * 修正数据库信息
     * @return
     */
    @RequestMapping(value = "/api/modify", method = RequestMethod.GET)
    public boolean modifyData(){
        return projectService.modifyAllData();
    }

    /**
     * 获取平台总体数据
     * @return
     */
    @RequestMapping(value = "/api/allproject", method = RequestMethod.GET)
    public  List<CrowdTestProject>  getByProject(){
        return projectService.getByProject();
    }
}