ttc_5.0/ttc-app/src/main/java/cn/ubitech/ttc/controller/EntryController.java

package cn.ubitech.ttc.controller;

import cn.ubitech.ttc.common.utils.ExcelPatternMsgUtils;
import cn.ubitech.ttc.excel.entry.*;
import cn.ubitech.ttc.excel.param.UploadParam;
import cn.ubitech.ttc.model.common.Constant;
import cn.ubitech.ttc.model.common.PageModel;
import cn.ubitech.ttc.model.common.ResultModel;
import cn.ubitech.ttc.service.entry.EntryService;
import cn.ubitech.ttc.service.impl.entry.EntryServiceImpl;
import com.alibaba.fastjson.JSON;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;


@RestController
@RequestMapping("/entry")
@Api(description = "一键导入功能接口")
@Slf4j
public class EntryController {

    @Autowired
    private EntryService entryService;
    @Autowired
    private EntryServiceImpl entryServiceImpl;

    // todo 完成.
    @RequestMapping(value = "/types/{node}/{uid}", method = RequestMethod.GET)
    @ApiOperation(value = "获取可导入的文件类型列表", notes = "获取可导入的文件类型列表")
    public ResultModel typeList(@PathVariable String node, @PathVariable String uid) {
        log.info("获取可导入的文件类型列表");
        log.info("获取可导入的文件类型列表入参node,uid:{},{}" , node,uid);
        ResultModel resultModel = new ResultModel();
        try {
            resultModel.setData(entryService.typeList(node,uid));
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    // todo 完成60%
    @RequestMapping(value = "/download/model", method = RequestMethod.POST)
    @ApiOperation(value = "模板下载接口", notes = "模板下载接口")
    public ResultModel downloadModel(@RequestBody UploadParam uploadParam, HttpServletRequest request, HttpServletResponse response) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            entryService.download(uploadParam,request,response);
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    // todo 完成百分之70%
    @RequestMapping(value = "/import", method = RequestMethod.POST)
    @ApiOperation(value = "一键导入接口", notes = "一键导入接口")
    public ResultModel entryImport(@RequestParam(value = "file", required = false) MultipartFile[] multipartFile,
                                   String fileType, String nodeId, String uId, HttpServletRequest request) throws UnsupportedEncodingException, InterruptedException {
//        Thread.sleep(600 * 1000);
        if (request.getCharacterEncoding() == null) {
            request.setCharacterEncoding("UTF-8");
        }
        String uri = request.getRequestURI();
        ResultModel resultModel = new ResultModel();
        try {
            if (multipartFile.length > 0){
                System.out.println("文件个数：" + multipartFile.length);
                for (MultipartFile file : multipartFile) {
                    System.out.println(file.getOriginalFilename());
                    System.out.println("******************************:" + file.getContentType());
                    // application/vnd.openxmlformats-officedocument.spreadsheetml.sheet
                    // application/vnd.openxmlformats-officedocument.wordprocessingml.document
                    // image/jpeg
                    if (!file.getContentType().contains("sheet")){
                        resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                        resultModel.setMessage("上传文件仅支持xlsx、xls,请选择正确的文件后再试。");
                        return resultModel;
                    }
                }
                UploadParam uploadParam = UploadParam.builder()
                        .fileType(fileType)
                        .nodeId(nodeId)
                        .uId(uId)
                        .build();
                System.out.println("uploadparam:"+JSON.toJSONString(uploadParam));
                return entryService.uploading(multipartFile,uploadParam);
            }else {
                for (MultipartFile file : multipartFile) {
                    if (file.isEmpty()){
                        resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                        resultModel.setMessage("上传文件不能为空,请选择正确的文件后再试。");
                        return resultModel;
                    }
                }
            }

        }
        // catch (Exception e) {
        //     return GlobalExceptionHandler.resolveException(e, uri);
        // }
        catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setMessage(e.getMessage());
            e.printStackTrace();
        }

        return resultModel;
    }

    // todo 完成.
    @RequestMapping(value = "/list", method = RequestMethod.POST)
    @ApiOperation(value = "根据文件名称/文件类型检索已导入列表或所有已导入列表接口", notes = "根据文件名称/文件类型检索已导入列表或所有已导入列表接口")
    public ResultModel getUploadListsByParam(@RequestBody UploadParam uploadParam){
        ResultModel resultModel = new ResultModel();
        try {
            PageModel pageModel = new PageModel();
            pageModel.setStartIndex(uploadParam.getCurrPage());
            pageModel.setCurrentPage(uploadParam.getCurrPage());
            resultModel = (entryService.getUploadListsByParam(uploadParam,pageModel));
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    // todo 完成
    @RequestMapping(value = "/detail", method = RequestMethod.POST)
    @ApiOperation(value = "文件内容详情查看接口", notes = "文件内容详情查看接口")
    public ResultModel details(@RequestBody UploadParam uploadParam) {
        System.err.println(JSON.toJSONString(uploadParam));
        ResultModel resultModel = new ResultModel();
        try {
            resultModel.setData(entryService.details(uploadParam));
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    // todo 未完成
    @RequestMapping(value = "/edit/basic", method = RequestMethod.POST)
    @ApiOperation(value = "企业基本信息编辑接口", notes = "企业基本信息编辑接口")
    public ResultModel editBasicInfo(@RequestBody List<Object> basicInfos, String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            int edited = entryService.editBasicInfo(basicInfos, nodeId);
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("企业信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("企业数据编辑失败，请仔细检查数据后再次尝试。");
            }
            return resultModel;
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    @RequestMapping(value = "/edit/tax", method = RequestMethod.POST)
    @ApiOperation(value = "税务信息编辑接口", notes = "税务信息编辑接口")
    public ResultModel editTax(@RequestBody List<CompanyTaxLkExcelData> taxInfos) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editTax(taxInfos);
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("税务信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("税务数据编辑失败，请仔细检查数据后再次尝试。");
            }
            return resultModel;
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    @RequestMapping(value = "/edit/patent", method = RequestMethod.POST)
    @ApiOperation(value = "企业专利信息编辑接口", notes = "企业专利信息编辑接口")
    public ResultModel editPatent(@RequestBody List<Object> patentInfos,String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editPatent(patentInfos,"320117400");
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("企业专利信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("企业专利数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    @RequestMapping(value = "/edit/college/univers/res", method = RequestMethod.POST)
    @ApiOperation(value = "高校成果信息编辑接口", notes = "高校成果信息编辑接口")
    public ResultModel editCollegeUniversResult(@RequestBody List<CollegeUniversResultInfoExcelData> collegeUniversResultInfos) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editCollegeUniversResult(collegeUniversResultInfos);
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("高校成果信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("高校成果数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    @RequestMapping(value = "/edit/financial", method = RequestMethod.POST)
    @ApiOperation(value = "金融库金融机构信息编辑接口", notes = "金融库金融机构信息编辑接口")
    public ResultModel editFinancial(@RequestBody List<Object> financialLkInfos, String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editFinancial(financialLkInfos,"320117400");
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("金融库金融机构信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("金融库金融机构数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }
    @RequestMapping(value = "/edit/personnel", method = RequestMethod.POST)
    @ApiOperation(value = "人才库人才信息编辑接口", notes = "人才库人才信息编辑接口")
    public ResultModel editPersonnel(@RequestBody List<Object> personnelInfos, String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editPersonnel(personnelInfos,"320117400");
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("人才库人才信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("人才库人才数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }
    @RequestMapping(value = "/edit/expert", method = RequestMethod.POST)
    @ApiOperation(value = "专家库专家信息编辑接口", notes = "专家库专家信息编辑接口")
    public ResultModel editExpert(@RequestBody List<Object> expertInfos, String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editExpert(expertInfos,"320117400");
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("专家库专家信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("专家库专家数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }
    @RequestMapping(value = "/edit/policy", method = RequestMethod.POST)
    @ApiOperation(value = "政策信息编辑接口", notes = "政策信息编辑接口")
    public ResultModel editPolicy(@RequestBody List<Object> policyBasicInfos, String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            // resultModel = (entryService.logRecordsIsVisible(node,uid));
            int edited = entryService.editPolicy(policyBasicInfos,"320117400");
            // int edited = 0;
            if (edited > 0){
                resultModel.setData(edited);
                resultModel.setMessage("政策信息编辑成功。");
            }else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("政策数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    @PostMapping("/edit/platformInfo")
    @ApiOperation(value = "平台库编辑接口",notes = "平台库编辑接口")
    public ResultModel editPlatformInfo(@RequestBody List<Object> platformInfos, @RequestParam String nodeId) {
        ResultModel resultModel = new ResultModel();
        try {
            int edited = entryService.editPlatformInfo(platformInfos,nodeId);
            if (edited > 0) {
                resultModel.setData(edited);
                resultModel.setMessage("平台库信息编辑成功。");
            } else {
                resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
                resultModel.setData(edited);
                resultModel.setMessage("平台库数据编辑失败，请仔细检查数据后再次尝试。");
            }
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

    @RequestMapping(value = "/init", method = RequestMethod.GET)
    @ApiOperation(value = "init", notes = "init")
    public ResultModel init() {
        ResultModel resultModel = new ResultModel();
        try {
            resultModel.setData(ExcelPatternMsgUtils.initTongluBasicHeadInfo());
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }


    @GetMapping("setPolicyInfo")
    public ResultModel setPolicyInfo() {
        ResultModel resultModel = new ResultModel();
        ResultModel resultModel1 = new ResultModel();
        try {
            List<PolicyBasicInfoExcelDataLishui> list = new ArrayList();
            PolicyBasicInfoExcelDataLishui excelDataLishui = new PolicyBasicInfoExcelDataLishui("2021年紫金山英才高峰计划项目", "市级", "", "支持对象：既通科技、又懂市场，企业经营管理和整合创新资源能力较强，对创新驱动发展和经济转型升级起到引领示范作用的企业家。\n" +
                    "奖励政策：创新型企业家培育计划培育期为3年。入选计划的，可享受下列支持政策：\n" +
                    "1）根据市绩效评价结果，区财政给予优秀的培育对象所在企业50—200万元资金资助。\n" +
                    "（2）入选国家重点人才工程的，给予所在企业50万元奖励；作为核心团队成员引进博士或正高职称人才的，按每人5万元的标准一次性给予企业补贴，每家企业补贴总额每年不超过10万元。\n" +
                    "（3）对于注册5年内的创新型企业家领创企业，在培育期内，由企业所在镇（街）等载体单位提供不少于500平方米研发场地，3年内免收租金，或者给予相应标准的租金补贴。\n" +
                    "（4）根据培育对象实际需求，区财政按当年实际还贷额度和银行贷款市场报价利率，从贷款之日起给予5年累计贷款总额不超过3000万元的相应贴息资助。培育期内产生的贷款利息均可享受补贴。\n" +
                    "（5）优先推荐为南京市创新型企业家联合会会员，享受金融对接、交流合作、高端研修等与服务。", "", "谢思秀", "56232876", "", null, "", "", null);
            PolicyBasicInfoExcelDataLishui excelDataLishui1 = new PolicyBasicInfoExcelDataLishui("2021年无想山英才先锋计划创新型企业家项目", "区级", "", "进入市创新型企业家培育项目储备库的企业，纳入无想山英才先峰计划创新型企业家项目予以扶持，根据项目进展情况，达到一定标准的，区财政给予50万元科研成果产业化配套资金，按3:3:4比例分三年予以资助。扶持期间，入选紫金山英才先锋计划创新型企业家项目并在培育期内年度绩效评价达到优秀的，按资助标准补足差额。\n" +
                    "支持政策：\n" +
                    "1. 企业入库一年内，满足以下条件之一：①企业年营业收入或年纳税增长率达20%以上，②新增自主知识产权5件以上或示范推广自主创新产品2件以上，③成长为培育独角兽企业或瞪羚企业，④入选省“双创人才”或省“333工程”第三层次；区财政给予15万元资金资助。\n" +
                    "2. 企业入库两年内，满足以下条件之一：①企业年营业收入或年纳税增长率达30%以上，②新增自主知识产权10件以上或示范推广自主创新产品5件以上，③成长为独角兽企业，④所在企业人才入选省双创团队；区财政再给予15万元资金资助。\n" +
                    "3. 企业入库三年内，满足以下条件之一：①企业年营业收入或年纳税增长率达40%以上，②新增自主知识产权15件以上或示范推广自主创新产品8件以上，③所在企业人才入选国家重点人才工程；区财政再给予20万元资金资助。", "", "谢思秀", "56232877", "", null, "", "", null);
            PolicyBasicInfoExcelDataLishui excelDataLishui2 = new PolicyBasicInfoExcelDataLishui("2021年无想山英才先锋计划高层次创新创业人才项目", "区级", "", "1.创业类人才，按A类、B类、C类，给予350万元、250万元、150万元资金资助。创新类人才给予150万元资金资助。\n" +
                    "2.对国家重点人才工程A类入选者、江苏省“双创人才”，按上级拨付经费给予1:1配套奖励，最高不超过300万元。\n" +
                    "3.提供100平方米左右创业场所，3年内免收租金，或给予租金补贴。\n" +
                    "4.南京市人才创新创业投资基金优先给予创业类人才企业风险投资，单笔投资额一般不超过2000万元。\n" +
                    "5.优先推荐申报国家重点人才工程A类，江苏省“双创人才”等。", "", "谢思秀", "56232878", "", null, "", "", null);
            list.add(excelDataLishui);
            list.add(excelDataLishui1);
            list.add(excelDataLishui2);

            resultModel.setData(entryServiceImpl.savePolicyBasicInfoExcelDataLiShui(list,"","320117400"));
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3350);
        } catch (Exception e) {
            resultModel.setCode(Constant.INTERFACE_STATUS_CODE_3351);
            resultModel.setData(e.toString());
            e.printStackTrace();
        }
        return resultModel;
    }

}