package com.gk.hotwork.Controller;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.view.freemarker.FreeMarkerConfigurer;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.gk.hotwork.Config.attachment.FilePathConfig;
import com.gk.hotwork.Controller.Base.BaseController;
import com.gk.hotwork.Domain.CompanyInfo;
import com.gk.hotwork.Domain.SafetyFacilityInspection;
import com.gk.hotwork.Domain.SafetyFacilityProcessflow;
import com.gk.hotwork.Domain.Enum.ResultCodes;
import com.gk.hotwork.Domain.Exception.BusinessException;
import com.gk.hotwork.Domain.Utils.FilterObject;
import com.gk.hotwork.Domain.Utils.Msg;
import com.gk.hotwork.Domain.Utils.PageInfo;
import com.gk.hotwork.Domain.Utils.StringUtils;
import com.gk.hotwork.Domain.query.CompanyQuery;
import com.gk.hotwork.Service.CompanyService;
import com.gk.hotwork.Service.SafetyFacilityInspectionService;
import com.gk.hotwork.Service.SafetyFacilityProcessflowService;
import com.gk.hotwork.Service.UserService;
import freemarker.template.Template;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;

@Api(tags = "②安全设施审查流程")
@RestController
@RequestMapping("/safetyFacilityInspection")
public class SafetyFacilityInspectionController extends BaseController {

	@Autowired
	private SafetyFacilityInspectionService safetyFacilityInspectionService;

	@Autowired
	private SafetyFacilityProcessflowService safetyFacilityProcessflowService;

	@Autowired
	private UserService userService;

	@Resource
	private FilePathConfig filePathConfig;

	@Autowired
	private CompanyService companyService;
	
	@Autowired
	private FreeMarkerConfigurer freeMarkerConfigurer;

	@ApiOperation("审查项目分页列表")
	@PostMapping("/page")
	@ApiImplicitParams({ @ApiImplicitParam(name = "pageIndex", value = "当前页码"),
			@ApiImplicitParam(name = "pageSize", value = "每页行数"),
			@ApiImplicitParam(name = "progress", value = "进度进度(0:待受理,1:已受理,10:待评审,11:评审中,12:评审否决,19:待企业反馈,20:待审查,21:审查中,29:待企业补正,22:审查否决,30:完成)"),
			@ApiImplicitParam(name = "expert", value = "审查专家"),
			@ApiImplicitParam(name = "createBy", value = "企业用户姓名"),
			@ApiImplicitParam(name = "type", value = "类别(1:安全设施设计审查,2:安全条件审查)"),
			@ApiImplicitParam(name = "submitDateStartTime", value = "开始时间"),
			@ApiImplicitParam(name = "submitDateEndTime", value = "结束时间") })
	public Msg selectPage(@RequestBody FilterObject filterObject) {
		Integer pageIndex = filterObject.getPageIndex() == null ? 1 : filterObject.getPageIndex();
		Integer pageSize = filterObject.getPageSize() == null ? 10 : filterObject.getPageSize();
		Map<String, Object> map = filterObject.getFilter();
		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");

		try {
			if (map.get("submitDateStartTime") != null && StringUtils.isNotBlank(map.get("submitDateStartTime").toString()))
				map.put("submitDateStartTime", simpleDateFormat.format(simpleDateFormat.parse(map.get("submitDateStartTime").toString())));

			if (map.get("submitDateEndTime") != null  && StringUtils.isNotBlank(map.get("submitDateEndTime").toString()))
				map.put("submitDateEndTime", simpleDateFormat.format(simpleDateFormat.parse(map.get("submitDateEndTime").toString())));
			
			if (map.get("progress") != null  && StringUtils.isNotBlank(map.get("progress").toString()))
				map.put("progress", Integer.valueOf(map.get("progress").toString()));
			else
				map.put("progress", null);
			
			IPage<SafetyFacilityInspection> page = safetyFacilityInspectionService.selectPage(new Page<>(pageIndex, pageSize), filterObject.getFilter(), getUser());
			return success(page);
		} catch (ParseException e) {
			return failed(e.getMessage());
		}

	}

	@ApiOperation("业务处理历史详情")
	@PostMapping("/dealFlow")
	@ApiImplicitParams({ @ApiImplicitParam(name = "pageIndex", value = "当前页码"),
			@ApiImplicitParam(name = "pageSize", value = "每页行数"),
			@ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg dealFlow(@RequestBody FilterObject filterObject) {
		Integer pageIndex = filterObject.getPageIndex() == null ? 1 : filterObject.getPageIndex();
		Integer pageSize = filterObject.getPageSize() == null ? 100 : filterObject.getPageSize();

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());
		int progress = inspection.getProgress();

		IPage<SafetyFacilityProcessflow> page = safetyFacilityProcessflowService.processflowPages(new Page<>(pageIndex, pageSize), filterObject.getFilter(), getUser());
		List<SafetyFacilityProcessflow> list = new ArrayList<SafetyFacilityProcessflow>();
		List<SafetyFacilityProcessflow> review = new ArrayList<SafetyFacilityProcessflow>();
		List<SafetyFacilityProcessflow> examine = new ArrayList<SafetyFacilityProcessflow>();

		String reviewFinalResolution = "";
		String examineFinalResolution = "";

		for (SafetyFacilityProcessflow flow : page.getRecords()) {
			if ("资料提交".equals(flow.getProgressName()) || "待评审".equals(flow.getProgressName()) || "已受理".equals(flow.getProgressName()) || "待受理".equals(flow.getProgressName()))
				list.add(flow);
		}

		if (progress > 20) { // 构建审查全流程
			SafetyFacilityProcessflow inner = new SafetyFacilityProcessflow();
			inner.setProgressName("审查开始");
			inner.setCheckTime(inspection.getExamineTime());
			examine.add(inner);

			for (SafetyFacilityProcessflow flow : page.getRecords()) {
				if ("通知补正".equals(flow.getProgressName()) || "企业补正".equals(flow.getProgressName()) || "审查通过".equals(flow.getProgressName()) || "审查否决".equals(flow.getProgressName())) {
					examine.add(flow);
				}
				if ("审查否决".equals(flow.getProgressName()) || "审查通过".equals(flow.getProgressName())) {
					examineFinalResolution = flow.getResolution();
				}
			}
		}

		if (progress > 10) { // 构建评审全流程
			SafetyFacilityProcessflow inner = new SafetyFacilityProcessflow();
			inner.setProgressName("评审开始");
			inner.setCheckTime(inspection.getReviewTime());
			review.add(inner);

			for (SafetyFacilityProcessflow flow : page.getRecords()) {
				if ("评审反馈".equals(flow.getProgressName()) || "企业反馈".equals(flow.getProgressName()) || "评审通过".equals(flow.getProgressName()) || "评审否决".equals(flow.getProgressName())) {
					review.add(flow);
				}
				if ("评审通过".equals(flow.getProgressName()) || "评审否决".equals(flow.getProgressName())) {
					reviewFinalResolution = flow.getResolution();
				}
			}
		}

		if (progress == 30) {
			if (inspection.getType() == 1) {
				SafetyFacilityProcessflow f1 = new SafetyFacilityProcessflow();
				f1.setProgressName("评审通过");
				f1.setResult("评审通过");
				f1.setResolution(reviewFinalResolution);
				f1.setChildFlow(review);
				f1.setLinkInspectionId(inspectionId);
				list.add(f1);
			}

			SafetyFacilityProcessflow f = new SafetyFacilityProcessflow();
			f.setProgressName("审查通过");
			f.setResult("耗时:" + inspection.getExamineTaketime());
			f.setResolution("详情查看审查意见书");
			f.setChildFlow(examine);
			f.setLinkInspectionId(inspectionId);
			list.add(f);

			SafetyFacilityProcessflow ff = new SafetyFacilityProcessflow();
			ff.setProgressName("已完成");
			ff.setLinkInspectionId(inspectionId);
			list.add(ff);
		}
		if (progress >= 20 && progress < 30) {
			if (inspection.getType() == 1) {
				SafetyFacilityProcessflow f1 = new SafetyFacilityProcessflow();
				f1.setProgressName("评审通过");
				f1.setResult("评审通过");
				f1.setLinkInspectionId(inspectionId);
				f1.setResolution(reviewFinalResolution);
				f1.setChildFlow(review);
				list.add(f1);
			}

			SafetyFacilityProcessflow f = new SafetyFacilityProcessflow();
			if (progress == 20)
				f.setProgressName("待审查");
			if (progress == 21)
				f.setProgressName("审查中");
			if (progress == 29)
				f.setProgressName("待企业补正");
			if (progress == 22){
				f.setProgressName("审查否决");
				f.setResolution(examineFinalResolution);
			}
			f.setChildFlow(examine);
			list.add(f);
		}

		if (progress > 10 && progress < 20) {
			SafetyFacilityProcessflow f = new SafetyFacilityProcessflow();

			if (progress == 11)
				f.setProgressName("评审中");
			if (progress == 19)
				f.setProgressName("待企业反馈");
			if (progress == 12){
				f.setProgressName("评审否决");
				f.setResolution(reviewFinalResolution);
			}
			f.setChildFlow(review);
			list.add(f);
		}

		page.setRecords(list);
		return success(page);
	}

	@ApiOperation("企业新增审查")
	@PostMapping("/add")
	@ApiImplicitParams({ @ApiImplicitParam(name = "submitDate", value = "提交日期(可为空默认当前时间)", required = false),
			@ApiImplicitParam(name = "type", value = "类别(1:安全设施设计审查,2:安全条件审查)"),
			@ApiImplicitParam(name = "projectName", value = "项目名称"),
			@ApiImplicitParam(name = "progress", required = false, value = "进度(0:待受理,1:已受理,10:待评审,11:评审中,12:评审否决,19:待企业反馈,20:待审查,21:审查中,29:待企业补正,22:审查否决,30:完成)"),
			@ApiImplicitParam(name = "expert", value = "审查专家", required = false),
			@ApiImplicitParam(name = "contact", value = "联系人", required = false),
			@ApiImplicitParam(name = "telephone", value = "联系电话", required = false),
			@ApiImplicitParam(name = "company", value = "企业名称", required = false) })
	public Msg add(@RequestBody SafetyFacilityInspection param) {
		String genId = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli() + "" + (int) (Math.random() * 900 + 100);
		param.setId(Long.valueOf(genId));
		Date date = new Date();
		safetyFacilityInspectionService.addOne(param, this.getUser());

		SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
		flow.setCheckTime(date);
		flow.setProgressName("资料提交");
		flow.setResult("资料提交");
		flow.setResolution("开始");
		flow.setLinkInspectionId(Long.valueOf(genId));
		flow.setProcessBy(this.getUser().getRealname());
		safetyFacilityProcessflowService.addOne(flow, this.getUser());

		SafetyFacilityProcessflow flowd = new SafetyFacilityProcessflow();
		Calendar c = Calendar.getInstance();
		c.setTime(date);
		c.add(Calendar.SECOND, 1);

		flowd.setCheckTime(c.getTime());
		flowd.setProgressName("待受理");
		flowd.setLinkInspectionId(Long.valueOf(genId));
		safetyFacilityProcessflowService.addOne(flowd, this.getUser());

		return success();
	}
	
	
	@ApiOperation("删除审查项目")
	@PostMapping("/delete")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg delete(@RequestBody FilterObject filterObject) {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");
		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());		
		safetyFacilityInspectionService.delOne(inspectionId, this.getUser());
		safetyFacilityProcessflowService.deleteBylinkInspectionId(inspectionId, this.getUser());
		return success();
	}

	@ApiOperation("获取审查专家列表")
	@PostMapping("/expert")
	@ApiImplicitParams({ @ApiImplicitParam(name = "pageIndex", value = "当前页码"),
			@ApiImplicitParam(name = "pageSize", value = "每页行数") })
	public Msg getExpert(@RequestParam(defaultValue = "0") Integer pageIndex,@RequestParam(defaultValue = "10") Integer pageSize, String realname) {
		Msg msg = new Msg();
		msg.setCode("200");
		msg.setMessage("success");
		PageInfo pageInfo = new PageInfo(pageIndex, pageSize);
		HashMap<String, Object> condition = new HashMap<String, Object>();
		condition.put("job", "审查");
		condition.put("company", "危化处");
		if (StringUtils.isNotBlank(realname)) {
			condition.put("realname", realname.trim());
		}

		pageInfo.setCondition(condition);
		userService.selectExpertUserDataGrid(pageInfo);
		msg.setResult(pageInfo);
		return msg;
	}

	@ApiOperation("危化处业务处理")
	@PostMapping("/dealCheck")
	@ApiImplicitParams({ @ApiImplicitParam(name = "acceptTime", value = "选择受理时间(默认当前时间)", required = false),
			@ApiImplicitParam(name = "reviewTime", value = "自定义评审开始时间", required = false),
			@ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg dealCheck(@RequestBody FilterObject filterObject) throws ParseException {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");
		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());
		String acceptTimeString = null;
		if (inspection.getProgress() == 0) {
			if (inspection.getType() == 1) {
				if (filterObject.getFilter().get("acceptTime") != null && StringUtils.isNotBlank(filterObject.getFilter().get("acceptTime").toString())) {
					acceptTimeString = filterObject.getFilter().get("acceptTime").toString();
					SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
					inspection.setAcceptTime(simpleDateFormat.parse(acceptTimeString));
				} else
					inspection.setAcceptTime(new Date());
				inspection.setProgress(1);

				SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
				flow.setCheckTime(new Date());
				flow.setProgressName("已受理");
				flow.setResult("选择受理时间");
				flow.setLinkInspectionId(inspectionId);
				flow.setProcessBy(this.getUser().getRealname());
				safetyFacilityProcessflowService.addOne(flow, this.getUser());
				safetyFacilityInspectionService.modOne(inspection, getUser());
				safetyFacilityProcessflowService.modPending(inspectionId, this.getUser()); // 删除待处理流程记录
			}
			if (inspection.getType() == 2) {
				Date date = new Date();
				if (filterObject.getFilter().get("acceptTime") != null && StringUtils.isNotBlank(filterObject.getFilter().get("acceptTime").toString())) {
					acceptTimeString = filterObject.getFilter().get("acceptTime").toString();
					SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
					inspection.setAcceptTime(simpleDateFormat.parse(acceptTimeString));
				} else
					inspection.setAcceptTime(date);
				inspection.setProgress(20);

				SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
				flow.setCheckTime(date);
				flow.setProgressName("已受理");
				flow.setResult("选择受理时间");
				flow.setLinkInspectionId(inspectionId);
				flow.setProcessBy(this.getUser().getRealname());
				safetyFacilityProcessflowService.addOne(flow, this.getUser());
				safetyFacilityProcessflowService.modPending(inspectionId, this.getUser()); // 删除待处理流程记录

				SafetyFacilityProcessflow flow1 = new SafetyFacilityProcessflow();
				Calendar c = Calendar.getInstance();
				c.setTime(date);
				c.add(Calendar.SECOND, 1);
				flow1.setProgressName("待审查");
				flow1.setCheckTime(c.getTime());
				flow1.setLinkInspectionId(inspectionId);
				flow1.setProcessBy(this.getUser().getRealname());
				safetyFacilityProcessflowService.addOne(flow1, this.getUser());			
				safetyFacilityInspectionService.modOne(inspection, getUser());
			}
			return success();
		}
		if (inspection.getProgress() == 1) {
			if (filterObject.getFilter().get("reviewTime") != null && StringUtils.isNotBlank(filterObject.getFilter().get("reviewTime").toString())) {
				acceptTimeString = filterObject.getFilter().get("reviewTime").toString();
				SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
				inspection.setReviewTime(simpleDateFormat.parse(acceptTimeString));
			} else
				inspection.setReviewTime(new Date());
			inspection.setProgress(10);

			SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
			flow.setCheckTime(new Date());
			flow.setProgressName("待评审");
			flow.setResult("业务流转");
			flow.setLinkInspectionId(inspectionId);
			flow.setProcessBy(this.getUser().getRealname());
			safetyFacilityProcessflowService.addOne(flow, this.getUser());

			safetyFacilityInspectionService.modOne(inspection, getUser());

			return success();

		}
		return failed("处理失败!");
	}

	@ApiOperation("业务处分配审查专家")
	@PostMapping("/dealExamine")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true),
			@ApiImplicitParam(name = "expert", value = "审查专家ID(多个ID中间逗号分隔)"),
			@ApiImplicitParam(name = "examineTime", value = "审查开始时间") })
	public Msg dealExamine(@RequestBody FilterObject filterObject) throws ParseException {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());

		int currentprocess = inspection.getProgress();
		if (currentprocess == 20) {

			inspection.setProgress(21);
			inspection.setExpert(filterObject.getFilter().get("expert") == null ? "" : filterObject.getFilter().get("expert").toString());

			if (filterObject.getFilter().get("examineTime") != null && StringUtils.isNotBlank(filterObject.getFilter().get("examineTime").toString())) {
				String examineTimeString = filterObject.getFilter().get("examineTime").toString();
				SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
				inspection.setExamineTime(simpleDateFormat.parse(examineTimeString));
			} else
				inspection.setExamineTime(new Date());

			safetyFacilityInspectionService.modOne(inspection, this.getUser());
			return success();
		} else {
			return failed("当前项目不在待审查状态,无法进行专家分配！");
		}

	}

	@ApiOperation("专家审查")
	@PostMapping("/expertExamine")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true),
			@ApiImplicitParam(name = "result", required = true, value = "评审反馈结果(9:否决驳回,2:需补正,1:审查通过)"),
			@ApiImplicitParam(name = "correctNo", required = false, value = "补正告知书编号"),
			@ApiImplicitParam(name = "correctPDFPath", required = false, value = "补正告知书路径"),
			@ApiImplicitParam(name = "emergency", value = "应急局通知人(多个ID中间逗号分隔)"),
			@ApiImplicitParam(name = "resolution", value = "反馈意见") })
	public Msg expertExamine(@RequestBody FilterObject filterObject) {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId, this.getUser());
		int res = Integer.valueOf(filterObject.getFilter().get("result").toString());
		int currentprocess = inspection.getProgress();
		if (currentprocess == 20 || currentprocess == 21) {

			SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
			flow.setCheckTime(new Date());
			flow.setLinkInspectionId(inspectionId);
			flow.setProcessBy(this.getUser().getRealname());
			flow.setResolution(filterObject.getFilter().get("resolution") == null ? "" : filterObject.getFilter().get("resolution").toString());
			if (res == 9) {
				flow.setProgressName("审查否决");
				flow.setResult("否决驳回");
				inspection.setProgress(22);
			}
			if (res == 2) {
				flow.setProgressName("通知补正");
				inspection.setProgress(29);
				String correctNo = filterObject.getFilter().get("correctNo") == null ? "" : filterObject.getFilter().get("correctNo").toString();
				String newFilePath = filterObject.getFilter().get("correctPDFPath") == null ? "" : filterObject.getFilter().get("correctPDFPath").toString();
				flow.setResolution(newFilePath);
				flow.setResult(correctNo);
				inspection.setCorrectpdf(newFilePath);
			}
			if (res == 1) {
				flow.setProgressName("审查通过");
				flow.setResult("审查通过完成");
				inspection.setProgress(30);

				Date begin = inspection.getExamineTime();

				Calendar cal1 = Calendar.getInstance();
				cal1.setTime(begin);
				Calendar cal2 = Calendar.getInstance();
				cal2.setTime(new Date());

				Long diff = (cal2.getTimeInMillis() - cal1.getTimeInMillis()) / 60000;
				int day = diff.intValue() / 1440;
				int hour = (diff.intValue() % 1440) / 60;
				int min = (diff.intValue() % 1440) % 60;
				inspection.setExamineTaketime(day + "天" + hour + "小时" + min + "分钟");

				SimpleDateFormat pageno = new SimpleDateFormat("MMdd");
				int dateno = Integer.valueOf(pageno.format(new Date())) / 2;
				if (dateno < 100)
					inspection.setExaminePageno("0" + dateno);
				else
					inspection.setExaminePageno("" + dateno);
			}

			safetyFacilityProcessflowService.addOne(flow, this.getUser());
			safetyFacilityInspectionService.modOne(inspection, this.getUser());

			return success();
		} else {
			return failed("当前项目状态异常无法进行审查！");
		}

	}

	@ApiOperation("专家审查上传补正告知书")
	@PostMapping("/uploadCorrectPDF")
	@ApiImplicitParams({ @ApiImplicitParam(name = "file", value = "上传补正告知书(PDF)文件") })
	public Msg uploadCorrectPDF(HttpServletRequest request, @RequestParam("file") MultipartFile file) {
		if (file.getSize() > 1024 * 1024 * 2) {
			return failed("文件超过2M无法上传");
		}

		String path = filePathConfig.getModule().get("correctPDF");
		String dcPath = filePathConfig.getDcPath();
		String originalFilename = file.getOriginalFilename();
		LocalDateTime now = LocalDateTime.now();
		File newFile = null;

		try {
			String key = UUID.randomUUID().toString().replace("-", "");
			String suffix = originalFilename.substring(originalFilename.lastIndexOf(".")).toLowerCase();
			path = path.replace("/", File.separator);
			String modulePath = now.getYear() + path + now.format(DateTimeFormatter.ofPattern("MMdd"));
			String newFilePath = modulePath + File.separator + key + suffix;
			String localPath = dcPath + newFilePath;
			newFile = new File(localPath);
			if (!newFile.exists() && !newFile.mkdirs()) {
				return failed("文件上传路径不存在！");
			}
			file.transferTo(newFile);
			return success(newFilePath);
		} catch (IOException e) {
			if (newFile != null && newFile.exists()) {
				newFile.delete();
			}
			return failed("文件上传异常！");
		}
	}

	@ApiOperation("补正告知书下载")
	@PostMapping("/downCorrectPDF")
	@ApiImplicitParams({ @ApiImplicitParam(name = "filename", value = "补正告知书文件名", required = true),
			@ApiImplicitParam(name = "correctNo", value = "补正告知书编号") })
	public void downCorrectPDF(@RequestBody FilterObject filterObject, HttpServletResponse response) throws Exception {
		if (filterObject.getFilter().get("filename") == null)
			return;
		String filepath = filterObject.getFilter().get("filename").toString();
		String correctNo = filterObject.getFilter().get("correctNo") == null ? "" : filterObject.getFilter().get("correctNo").toString();
		response.reset();
		response.addHeader("Access-Control-Allow-Origin", "*");
		response.addHeader("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE");
		response.setContentType("application/octet-stream; charset=UTF-8");
		response.setHeader(HttpHeaders.CONTENT_DISPOSITION, "attachment;filename=" + URLEncoder.encode("补正告知书" + correctNo + ".pdf", StandardCharsets.UTF_8.name()));
		response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
		String dcPath = filePathConfig.getDcPath();
		File file = new File(dcPath + filepath);
		if (!file.exists()) {
			throw new BusinessException(ResultCodes.FILE_NOT_EXISIST);
		}
		response.addHeader("Content-Length", "" + file.length());
		FileInputStream inputStream = new FileInputStream(file);
		byte[] b = new byte[inputStream.available()];
		inputStream.read(b);
		ServletOutputStream outputStream = response.getOutputStream();
		outputStream.write(b);
		outputStream.flush();
		inputStream.close();
	}

	@ApiOperation("审查意见书预览")
	@PostMapping("/viewExamineFile")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public void viewExamineFile(@RequestBody FilterObject filterObject, HttpServletResponse response) throws Exception {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return;
		Template template = freeMarkerConfigurer.getConfiguration().getTemplate("ReviewHtml.ftl", "UTF-8");
		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());
		Map<String, Object> map = new HashMap<String, Object>();
		map.put("year", String.valueOf(LocalDate.now().getYear()));
		map.put("pageno", "0001");
		map.put("company", inspection.getCompany());
		map.put("projectName", inspection.getProjectName());
		map.put("contact", inspection.getContact());
		map.put("telephone", inspection.getTelephone());

		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy年MM月dd日");
		map.put("submitDate", simpleDateFormat.format(new Date()));

		String duplicate = "";
		if (inspection.getCompany() != null) {
			duplicate = companyService.selectByName(inspection.getCompany()).getCity();
		}
		map.put("duplicate", duplicate + "应急管理局");
		response.setContentType("text/html;charset=utf-8");
		template.process(map, response.getWriter());
	}

	@ApiOperation("审查意见书下载")
	@PostMapping("/downExamineFile")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public void downExamineFile(@RequestBody FilterObject filterObject, HttpServletResponse response) throws Exception {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return;
		Template template = freeMarkerConfigurer.getConfiguration().getTemplate("ReviewHtml.ftl", "UTF-8");
		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId, this.getUser());

		Map<String, Object> map = new HashMap<String, Object>();
		SimpleDateFormat year = new SimpleDateFormat("yyyy");
		map.put("year", year.format(inspection.getCreateTime()));
		map.put("pageno", inspection.getExaminePageno());
		map.put("company", inspection.getCompany());
		map.put("projectName", inspection.getProjectName());
		map.put("contact", inspection.getContact());
		map.put("telephone", inspection.getTelephone());

		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy年MM月dd日");
		map.put("submitDate", simpleDateFormat.format(new Date()));

		String duplicate = "";
		if (inspection.getCompany() != null) {
			duplicate = companyService.selectByName(inspection.getCompany()).getCity();
		}
		map.put("duplicate", duplicate + "应急管理局");
		response.setHeader("content-Type", "application/msword");
		String fileName = URLEncoder.encode("审查意见书", "UTF-8");
		response.setCharacterEncoding("UTF-8");
		response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".doc");
		template.process(map, response.getWriter());
	}

	@ApiOperation("安科院评审反馈")
	@PostMapping("/reviewFeedback")
	@ApiImplicitParams({
			@ApiImplicitParam(name = "result", required = true, value = "评审反馈结果(9:否决驳回,2:需问题反馈,1:通过并流转到业务处室)"),
			@ApiImplicitParam(name = "resolution", value = "反馈意见"),
			@ApiImplicitParam(name = "reviewTime", value = "评审开始时间", required = true),
			@ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg reviewFeedback(@RequestBody FilterObject filterObject) throws ParseException {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");
		if (filterObject.getFilter().get("result") == null)
			return failed("评审反馈结果不能为空");
		if (filterObject.getFilter().get("reviewTime") == null)
			return failed("请选择评审开始时间");

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		int res = Integer.valueOf(filterObject.getFilter().get("result").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());

		int currentprocess = inspection.getProgress();
		String timeString = filterObject.getFilter().get("reviewTime").toString();
		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
		inspection.setReviewTime(simpleDateFormat.parse(timeString));

		if (currentprocess == 10 || currentprocess == 11) {
			SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
			Date date = new Date();
			flow.setCheckTime(date);
			flow.setLinkInspectionId(inspectionId);
			flow.setProcessBy(this.getUser().getRealname());
			flow.setResolution(filterObject.getFilter().get("resolution") == null ? "" : filterObject.getFilter().get("resolution").toString());
			if (res == 9) {
				flow.setProgressName("评审否决");
				flow.setResult("否决驳回");
				inspection.setProgress(12);
			}
			if (res == 2) {
				flow.setProgressName("评审反馈");
				flow.setResult("需问题反馈");
				inspection.setProgress(19);
			}
			if (res == 1) {
				flow.setProgressName("评审通过");
				flow.setResult("通过并流转到业务处室");
				inspection.setProgress(20);
			}

			safetyFacilityProcessflowService.addOne(flow, this.getUser());
			safetyFacilityInspectionService.modOne(inspection, this.getUser());
			safetyFacilityProcessflowService.modPending(inspectionId, this.getUser()); // 删除待处理流程记录

			if (res == 1) {
				SafetyFacilityProcessflow flow1 = new SafetyFacilityProcessflow();
				Calendar c = Calendar.getInstance();
				c.setTime(date);
				c.add(Calendar.SECOND, 1);
				flow1.setProgressName("待审查");
				flow1.setCheckTime(c.getTime());
				flow1.setLinkInspectionId(inspectionId);
				flow1.setProcessBy(this.getUser().getRealname());
				safetyFacilityProcessflowService.addOne(flow1, this.getUser());
			}

			return success();
		} else {
			return failed("当前项目不在评审环节,不能进行评审！");
		}

	}

	@ApiOperation("企业提交反馈")
	@PostMapping("/companySubmission")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg companySubmission(@RequestBody FilterObject filterObject) {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());

		int currentprocess = inspection.getProgress();
		if (currentprocess == 19) {
			SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
			flow.setCheckTime(new Date());
			flow.setLinkInspectionId(inspectionId);
			flow.setProcessBy(this.getUser().getRealname());
			flow.setProgressName("企业反馈");
			flow.setResult("已线下提交反馈资料");
			safetyFacilityProcessflowService.addOne(flow, this.getUser());

			inspection.setProgress(11);
			safetyFacilityInspectionService.modOne(inspection, this.getUser());
			return success();
		} else {
			return failed("当前项目不在待提交反馈状态,企业无法提交反馈！");
		}
	}

	@ApiOperation("获取审查项目对应的当地（市、州）级应急局所有人")
	@PostMapping("/getEmergencyInfo")
	@ApiImplicitParams({ @ApiImplicitParam(name = "pageIndex", value = "当前页码"),
			@ApiImplicitParam(name = "pageSize", value = "每页行数"),
			@ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg getEmergencyInfo(@RequestBody FilterObject filterObject) {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());

		String duplicate = null;
		if (inspection.getCompany() != null) {
			duplicate = companyService.selectByName(inspection.getCompany()).getCity();
		} else {
			return failed("当前安全审查项目没有归属地！");
		}
		Msg msg = new Msg();
		msg.setCode("200");
		msg.setMessage("success");

		Integer pageIndex = filterObject.getPageIndex() == null ? 1 : filterObject.getPageIndex();
		Integer pageSize = filterObject.getPageSize() == null ? 10 : filterObject.getPageSize();
		PageInfo pageInfo = new PageInfo(pageIndex, pageSize);
		HashMap<String, Object> condition = new HashMap<String, Object>();
		condition.put("company", duplicate);
		pageInfo.setCondition(condition);
		userService.selectSuperviseUserDataGrid(pageInfo);
		msg.setResult(pageInfo);
		return msg;
	}

	@ApiOperation("企业提交补正")
	@PostMapping("/companySubcorrect")
	@ApiImplicitParams({ @ApiImplicitParam(name = "linkInspectionId", value = "安全审查项目ID", required = true) })
	public Msg companySubcorrect(@RequestBody FilterObject filterObject) {
		if (filterObject.getFilter().get("linkInspectionId") == null)
			return failed("安全审查项目ID不能为空");

		Long inspectionId = Long.valueOf(filterObject.getFilter().get("linkInspectionId").toString());
		SafetyFacilityInspection inspection = safetyFacilityInspectionService.selectByPrimaryKey(inspectionId,this.getUser());

		int currentprocess = inspection.getProgress();
		if (currentprocess == 29) {
			SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
			flow.setCheckTime(new Date());
			flow.setLinkInspectionId(inspectionId);
			flow.setProcessBy(this.getUser().getRealname());
			flow.setProgressName("企业补正");
			flow.setResult("已线下提交补正材料");
			safetyFacilityProcessflowService.addOne(flow, this.getUser());

			inspection.setProgress(21);
			safetyFacilityInspectionService.modOne(inspection, this.getUser());
			return success();
		} else {
			return failed("当前项目不在待提交补正状态,企业无法提交补正！");
		}
	}

}