hust-epi/whepi-web/src/main/java/com/bofeng/wx/controller/ScanController.java

package com.bofeng.wx.controller;

import com.bofeng.dao.*;
import com.bofeng.entity.*;
import com.bofeng.service.HomeService;
import com.bofeng.service.ScanService;
import com.google.zxing.BarcodeFormat;
import com.google.zxing.MultiFormatWriter;
import com.google.zxing.WriterException;
import com.google.zxing.client.j2se.MatrixToImageConfig;
import com.google.zxing.client.j2se.MatrixToImageWriter;
import com.google.zxing.common.BitMatrix;
import com.yvan.mvc.Pd;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.Cleanup;
import org.joda.time.DateTime;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.MediaType;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

@Api("进出扫码")
@RestController
public class ScanController {

    // 获取code
    private static final String oauth2 = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=";
    private static final String moreUrl = "&response_type=code&scope=snsapi_userinfo&state=STATE#wechat_redirect";
    @Value("${yvan.wechat.appID}")
    private String appId;
    @Value("${yvan.wechat.domain}")
    private String domain;

    @Autowired
    private HomeService homeService;
    @Autowired
    private UserRoleMapper userRoleMapper;
    @Autowired
    private UserOpenMapper userOpenMapper;
    @Autowired
    private UptownHomeMapper uptownHomeMapper;
    @Autowired
    private UptownUnitMapper uptownUnitMapper;
    @Autowired
    private UptownDoorMapper uptownDoorMapper;
    @Autowired
    private OutScanMapper outScanMapper;
    @Autowired
    private OutScanConfMapper outScanConfMapper;
    @Autowired
    private MsReportMapper msReportMapper;
    @Autowired
    private ScanService scanService;
    @Autowired
    private OutScanEstateMapper outScanEstateMapper;
    @Autowired
    private OutUserMapper outUserMapper;

    /**
     * @param doorId  小区大门ID
     * @param inType  1进入;2外出
     * @param request
     * @param model
     * @return
     */
    @ApiOperation("进出扫码页面")
    @GetMapping("/user/scan.html")
    public ModelAndView scan(HttpServletRequest request, ModelMap model, @RequestParam(value = "doorId", required = false, defaultValue = "0") Long doorId,
                             @RequestParam(value = "inType", required = false, defaultValue = "0") Integer inType,
                             @RequestParam(value = "coord", required = false, defaultValue = "") String coord,
                             @RequestParam(value = "address", required = false, defaultValue = "") String address) throws ParseException, UnsupportedEncodingException {
        UserOpen userOpen = homeService.getUserOpenByCode(request.getParameter("code"));
        List<UserRole> list = userRoleMapper.getUserRoleByUserId(userOpen.getUserId());
//        List<UserRole> list = userRoleMapper.getUserRoleByUserId(1228565481837944834L);
//        UserOpen userOpen = userOpenMapper.selectByUserId(1228565481837944834L);
        model.put("user", userOpen);
        model.put("user_id", "\"" + userOpen.getUserId() + "\"");
        if (list.size() == 0) {
            return new ModelAndView("/user/home.ftl", model);
        } else {
            Boolean ly = false;
            Boolean hc = false;
            UptownDoor uptownDoor = uptownDoorMapper.getUptownDoorById(doorId);
            List<UptownHome> uptownHomes = uptownHomeMapper.getUptownHomeByUserId(userOpen.getUserId());
            UptownUnit unit = uptownUnitMapper.getUptownUnitByUser(userOpen.getUserId());
            model.put("uptownId", unit.getUptownId());
            model.put("tittle", "电子出入许可");
            if (unit.getUptownId() == 1238790987234L || unit.getUptownId() == 5) {
                model.put("tittle", "凌云集团电子通行");
                ly = true;
            }
            if (unit.getUptownId() == 100000002L) {
                model.put("tittle", "湖北和昌电子通行");
                hc = true;
            }
            if (ly || hc) {
                model.put("doorplate", unit.getRidgepole() + unit.getUnit());
                model.put("door", uptownDoor.getDoorName());
            } else {
                model.put("doorplate", unit.getRidgepole() + "栋" + unit.getUnit() + "单元" + unit.getDoorplate() + "号");
                model.put("door", uptownDoor.getUptownName() + uptownDoor.getDoorName());
            }
            model.put("name", uptownHomes.get(0).getLinkman());
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            model.put("now", sdf.format(new Date()));
            model.put("inType", inType);
            if (!ly && !hc) {
                if (!unit.getUptownId().equals(uptownDoor.getUptownId())) {
                    model.put("into", "禁止" + getMsg(inType));
                    model.put("collor", "red");
                    model.put("errorMsg", "非本小区居民，禁止" + getMsg(inType) + "。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                    return new ModelAndView("/user/scan.ftl", model);
                }
            }
            OutScan o = outScanMapper.getOutScanLately(userOpen.getUserId(), inType);
            if (o != null && compareTime(o.getDate(), 1)) {
                model.put("collor", "orange");
                model.put("into", "允许" + getMsg(inType));
                model.put("errorMsg", "您最近一分钟已经扫码，本次扫码重复。");
                return new ModelAndView("/user/scan.ftl", model);
            }
            if (inType == 1) {
                OutScan outScan = outScanMapper.getOutScanByUserlimit(userOpen.getUserId());
                if (outScan != null && new Date(outScan.getDate().getMillis() + 3600L * 1000 * 24).compareTo(new Date()) == -1) {
                    if (!ly && !hc) {
                        model.put("collor", "orange");
                        model.put("into", "允许进入");
                        model.put("errorMsg", "您在外驻留时间超过1日，请尽快上报您的健康状况，防止在外长时间逗留。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                }
                if (ly) {
                    if ("".equals(coord)) {
                        String url = oauth2+appId +"&redirect_uri="+URLEncoder.encode(domain()+"user/scan.html?doorId="+doorId+"&inType="+inType + "&coord=","utf-8");
                        model.put("url", url);
                        model.put("moreUrl", moreUrl);
                        return new ModelAndView("/user/location.ftl", model);
                    } else {
                        String[] coor = coord.split(",");
                        Double dis = scanService.getDistance(Double.parseDouble(coor[0]),Double.parseDouble(coor[1]),Double.parseDouble(uptownDoor.getLongitude()), Double.parseDouble(uptownDoor.getLatitude()));
                        if(dis > Double.parseDouble(uptownDoor.getDistance().toString())) {
                            model.put("collor", "red");
                            model.put("collor2", "red");
                            model.put("into", "不许进入");
                            model.put("errorMsg", "您当前扫码位置距离" +uptownDoor.getDoorName()+"太远，请到门口扫码，如有疑问请与上级管理部门联系。");
                            scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                            return new ModelAndView("/user/scan.ftl", model);
                        }
                    }
                    OutUser outUser1 = outUserMapper.getOutUserByPhone(4, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
                    if (outUser1 != null) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "声明：根据凌云集团防疫指挥部复工条件，您属于不可复工六类人员之一，如有疑问请与上级管理部门联系。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    OutUser outUser = outUserMapper.getOutUserByPhone(1, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
                    if (outUser != null) {
                        model.put("collor", "green");
                        model.put("collor2", "green");
                        model.put("into", "允许通行");
                        model.put("errorMsg", "声明：复工许可证是根据员工自主填写健康日报，结合凌云集团复工条件自动产生。原则上代表员工可复工，在厂门口扫描二维码生成绿色复工通行证，并接受检查后，可入厂。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    if (!unit.getUptownId().equals(uptownDoor.getUptownId())) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "非本公司员工，不许进入。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    MsReport msReport = msReportMapper.queryMsReportIsXG(userOpen.getUserId());
                    SimpleDateFormat s = new SimpleDateFormat("yyyy-MM-dd");
                    if (msReport != null) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于您上报过新冠确诊、新冠疑似或密切接触者，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
//                        List<MsReport> msReports1 = msReportMapper.queryLateStatus(userOpen.getUserId(), s.format(msReport.getReportDate()));
//                        if (msReports1.size() == 0) {
//                            model.put("collor", "red");
//                            model.put("collor2", "red");
//                            model.put("into", "不许进入");
//                            model.put("errorMsg", "由于您上报过新冠确诊、新冠疑似或密切接触者，且未解除医学隔离，不许进入，如有疑问请联系直管领导。");
//                            scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
//                            return new ModelAndView("/user/scan.ftl", model);
//                        }
                    }
                    List<MsReport> msReportList = msReportMapper.queryMsReportIsXGHome(userOpen.getUserId());
                    if (msReportList.size() > 0) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于您的家庭成员有新冠确诊或密切接触史人员，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    List<MsReport> msReports = msReportMapper.selectMsReportLate(userOpen.getUserId());
                    if (msReports.size() < 4) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于您今日和前3日未连续报告日报，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    List<MsReport> msReports2 = msReportMapper.selectMsReportThereError(userOpen.getUserId());
                    if (msReports2.size() > 0) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于近期您健康评估存在问题，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    List<MsReport> msReports3 = msReportMapper.selectMsReportThirtyError(userOpen.getUserId());
                    if (msReports3.size() > 0) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于最近30天您健康评估存在问题，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    String returnWork = msReportMapper.returnWork(userOpen.getUserId());
                    if (returnWork != null) {
                        if (sdf.parse(returnWork + " 00:00:00").getTime() + 1000L * 3600 * 24 * 15 > sdf.parse(s.format(new Date()) + " 00:00:00").getTime()) {
                            model.put("collor", "red");
                            model.put("collor2", "red");
                            model.put("into", "不许进入");
                            model.put("errorMsg", "您返回工作驻地后未满14日，不许进入。" + day15(s.parse(returnWork)) + "起方可进入！");
                            scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                            return new ModelAndView("/user/scan.ftl", model);
                        }
                    }
                    MsReport msReport1 = msReportMapper.msAddr(userOpen.getUserId());
                    if (msReport1 != null && !msReport1.getWorkMsg().equals(msReport1.getTodayMsg())) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "您本人不在工作驻地，不能入场复工。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scan.ftl", model);
                    }
                    //您近期内离开过工作单位驻地，请遵守返回工作驻地15日隔离规定，您目前未满15日，禁止进入。
                    model.put("collor", "green");
                    model.put("collor2", "green");
                    model.put("into", "允许进入");
                    model.put("errorMsg", "声明：复工通行证是根据员工自主填写健康日报，结合凌云集团复工条件自动产生。原则上代表员工可以通行，在接受规定检查后，方可入厂。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                    return new ModelAndView("/user/scan.ftl", model);
                }
                if (hc) {
                    if ("".equals(coord)) {
                        String url = oauth2+appId +"&redirect_uri="+URLEncoder.encode(domain()+"user/scan.html?doorId="+doorId+"&inType="+inType + "&coord=","utf-8");
                        model.put("url", url);
                        model.put("moreUrl", moreUrl);
                        return new ModelAndView("/user/location.ftl", model);
                    }
                    OutUser outUser = outUserMapper.getOutUserByPhone(3, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
                    if (outUser != null) {
                        model.put("collor", "green");
                        model.put("collor2", "green");
                        model.put("into", "允许通行");
                        model.put("errorMsg", "特殊人员允许通行，请保证生产同时注意自身安全。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                        return new ModelAndView("/user/scanHC.ftl", model);
                    }
                    if (!unit.getUptownId().equals(uptownDoor.getUptownId())) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "非本公司员工，不许进入。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scanHC.ftl", model);
                    }
                    MsReport msReport = msReportMapper.queryMsReportIsXG(userOpen.getUserId());
                    SimpleDateFormat s = new SimpleDateFormat("yyyy-MM-dd");
                    if (msReport != null) {
                        List<MsReport> msReports1 = msReportMapper.queryLateStatus(userOpen.getUserId(), s.format(msReport.getReportDate()));
                        if (msReports1.size() == 0) {
                            model.put("collor", "red");
                            model.put("collor2", "red");
                            model.put("into", "不许进入");
                            model.put("errorMsg", "由于您上报过新冠确诊、新冠疑似或密切接触者，且未解除医学隔离，不许进入，如有疑问请联系直管领导。");
                            scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                            return new ModelAndView("/user/scanHC.ftl", model);
                        }
                    }
                    List<MsReport> msReportList = msReportMapper.queryMsReportIsXGHome(userOpen.getUserId());
                    if (msReportList.size() > 0) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于您的家庭成员有新冠确诊或密切接触史人员，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scanHC.ftl", model);
                    }
                    List<MsReport> msReports = msReportMapper.selectMsReportLate(userOpen.getUserId());
                    if (msReports.size() < 4) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于您今日和前3日未连续报告日报，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scanHC.ftl", model);
                    }
                    List<MsReport> msReports2 = msReportMapper.selectMsReportThereError(userOpen.getUserId());
                    if (msReports2.size() > 0) {
                        model.put("collor", "red");
                        model.put("collor2", "red");
                        model.put("into", "不许进入");
                        model.put("errorMsg", "由于近期您健康评估存在问题，不许进入，如有疑问请联系直管领导。");
                        scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                        return new ModelAndView("/user/scanHC.ftl", model);
                    }
                    model.put("collor", "green");
                    model.put("collor2", "green");
                    model.put("into", "允许进入");
                    model.put("errorMsg", "声明：复工通行证是根据员工自主填写健康日报，结合湖北和昌新材料科技股份有限公司复工条件自动产生。原则上代表员工可以通行，在接受规定检查后，方可入厂。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                    return new ModelAndView("/user/scanHC.ftl", model);
                }
            }
            if (inType == 2) {
                OutUser outUser = outUserMapper.getOutUserByPhone(2, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
                if (outUser != null) {
                    model.put("collor", "green");
                    model.put("into", "允许通行");
                    model.put("errorMsg", "外出请佩戴口罩，避免近距离接触，保生产同时注意自身安全。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                    return new ModelAndView("/user/scan.ftl", model);
                }
                OutScanConf outScanConf = outScanConfMapper.getOutScanConfByUptown(uptownDoor.getUptownId());
                if (outScanConf.getGoOutFre() == 0) {
                    model.put("collor", "red");
                    model.put("into", "禁止外出");
                    model.put("errorMsg", "根据武汉市小区封闭管理规定，非特殊人员禁止出行！");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                    return new ModelAndView("/user/scan.ftl", model);
                }
                OutScan outScan = outScanMapper.getOutScanThreeday(userOpen.getUserId(), 2, outScanConf.getGoOutFre());
                if (outScan != null) {
                    model.put("collor", "red");
                    model.put("into", "禁止" + getMsg(inType));
                    model.put("errorMsg", "距您上次外出时间未满" + outScanConf.getGoOutFre() + "日，禁止外出，请配合。上次外出登记时间 " + sdf.format(new Date(outScan.getDate().getMillis())) + "。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                    return new ModelAndView("/user/scan.ftl", model);
                }
                MsReport msReport = msReportMapper.selectMsReportToday(userOpen.getUserId());
                if (msReport != null && msReport.getMsStatus() == 2) {
                    model.put("collor", "red");
                    model.put("into", "禁止通行");
                    model.put("errorMsg", "健康日报提示您存在健康问题，禁止外出，请配合。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                    return new ModelAndView("/user/scan.ftl", model);
                }
                List<MsReport> msReports = msReportMapper.selectMsReportLate(userOpen.getUserId());
                if (msReports.size() == 0) {
                    model.put("collor", "red");
                    model.put("into", "禁止" + getMsg(inType));
                    model.put("errorMsg", "您最近三日未上报健康日报，请说明原因，配合监测人员。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), -1, model.get("errorMsg").toString());
                    return new ModelAndView("/user/scan.ftl", model);
                } else if (msReports.size() < 4) {
                    model.put("collor", "orange");
                    model.put("into", "可以" + getMsg(inType));
                    model.put("errorMsg", "您今日或前3日未连续报告日报，请说明原因并及时填报，配合监测人员。");
                    scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
                    return new ModelAndView("/user/scan.ftl", model);
                }
            }
            model.put("collor", "green");
            model.put("into", "允许" + getMsg(inType));
            if (inType == 2) {
                model.put("errorMsg", "外出请佩戴口罩，避免近距离接触，保生产同时注意自身安全。");
            } else if (inType == 1) {
                model.put("errorMsg", "欢迎归来，注意防护。");
            }
            scanService.saveOutScan(userOpen.getUserId(), inType, coord, address, uptownDoor.getUptownId(), uptownDoor.getDoorId(), 1, "");
            return new ModelAndView("/user/scan.ftl", model);
        }
    }

    @ApiOperation("巡检人员检查扫码信息")
    @GetMapping("/user/scanEstate.html")
    public ModelAndView scanEstate(HttpServletRequest request, ModelMap model) {
        UserOpen userOpen = homeService.getUserOpenByCode(request.getParameter("code"));
        List<UserRole> list = userRoleMapper.getUserRoleByUserId(userOpen.getUserId());
//        List<UserRole> list = userRoleMapper.getUserRoleByUserId(1L);
//        UserOpen userOpen = userOpenMapper.selectByUserId(1L);
        model.put("user", userOpen);
        model.put("user_id", "\"" + userOpen.getUserId() + "\"");
        if (list.size() == 0) {
            return new ModelAndView("/user/home.ftl", model);
        } else {
            List<UptownHome> uptownHomes = uptownHomeMapper.getUptownHomeByUserId(userOpen.getUserId());
            UptownUnit unit = uptownUnitMapper.getUptownUnitByUser(userOpen.getUserId());
            OutScanConf outScanConf = outScanConfMapper.getOutScanConfByUptown(unit.getUptownId());
            model.put("doorplate", unit.getUptownName() + "小区" + unit.getRidgepole() + "栋" + unit.getUnit() + "单元" + unit.getDoorplate() + "号");
            model.put("name", uptownHomes.get(0).getLinkman());
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            model.put("now", format.format(new Date()));
            OutScanEstate o = outScanEstateMapper.getOutScanEstatLately(userOpen.getUserId());
            if (o != null && compareTime(o.getScanDate(), 1)) {
                model.put("collor", "orange");
                model.put("into", "允许通行");
                model.put("errorMsg", "您最近一分钟已经扫码，本次扫码重复。");
                return new ModelAndView("/user/scanEstate.ftl", model);
            }
            OutUser outUser = outUserMapper.getOutUserByPhone(2, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
            if (outUser != null) {
                model.put("collor", "green");
                model.put("into", "允许通行");
                model.put("errorMsg", "外出请佩戴口罩，避免近距离接触，保生产同时注意自身安全。");
                scanService.saveOutScanEstate(userOpen.getUserId(), 1, "");
                return new ModelAndView("/user/scanEstate.ftl", model);
            }
            if (outScanConf.getGoOutFre() == 0) {
                model.put("collor", "red");
                model.put("into", "禁止外出");
                model.put("errorMsg", "根据武汉市小区封闭管理规定，非特殊人员禁止出行！");
                scanService.saveOutScanEstate(userOpen.getUserId(), -1, model.get("errorMsg").toString());
                return new ModelAndView("/user/scanEstate.ftl", model);
            }
            List<MsReport> msReports = msReportMapper.selectMsReportLate(userOpen.getUserId());
            if (msReports.size() != 4) {
                model.put("collor", "red");
                model.put("into", "禁止通行");
                model.put("errorMsg", "您近期有漏报健康日报，无法判断您健康状态，请尽快返回住处。");
                scanService.saveOutScanEstate(userOpen.getUserId(), -1, model.get("errorMsg").toString());
                return new ModelAndView("/user/scanEstate.ftl", model);
            }
            MsReport msReport = msReportMapper.selectMsReportToday(userOpen.getUserId());
            if (msReport != null && msReport.getMsStatus() == 2) {
                model.put("collor", "red");
                model.put("into", "禁止通行");
                model.put("errorMsg", "您近日提交的健康日报显示您健康存在问题，请尽快返回住处。");
                scanService.saveOutScanEstate(userOpen.getUserId(), -1, model.get("errorMsg").toString());
                return new ModelAndView("/user/scanEstate.ftl", model);
            }
            OutScan outScan = outScanMapper.getOutScanToday(userOpen.getUserId());
            if (outScan == null) {
                model.put("collor", "red");
                model.put("into", "禁止通行");
                model.put("errorMsg", "您今日没有正常出门记录，为自身及家人安全，请赶紧回家。");
                scanService.saveOutScanEstate(userOpen.getUserId(), -1, model.get("errorMsg").toString());
                return new ModelAndView("/user/scanEstate.ftl", model);
            }
            List<OutScanEstate> list1 = outScanEstateMapper.getOutScanEstateTodayByUser(userOpen.getUserId());
            int conut = list1.size() + 1;
            if (list1.size() < 2) {
                model.put("collor", "green");
                model.put("into", "允许通行");
                if (list1.size() == 0) {
                    model.put("errorMsg", "您今日已" + conut + "次被问讯，请说明外出原因，尽快回家。");
                } else {
                    model.put("errorMsg", "您今日已" + conut + "次被问讯，请说明外出原因，尽快回家。问询时间：" + queryTime(list1) + "。");
                }
                scanService.saveOutScanEstate(userOpen.getUserId(), 1, "");
            } else {
                model.put("collor", "red");
                model.put("into", "禁止通行");
                model.put("errorMsg", "您今日已被巡检人员问讯超过2次，为自身及家人安全，请赶紧回家。问询时间：" + queryTime(list1) + "。");
                scanService.saveOutScanEstate(userOpen.getUserId(), -1, model.get("errorMsg").toString());
            }
//            model.put("img", "/scan/scanEstate_qr.png");
            return new ModelAndView("/user/scanEstate.ftl", model);
        }
    }

    @ApiOperation("外出查询")
    @GetMapping("/user/goOut.html")
    public ModelAndView goOut(HttpServletRequest request, ModelMap model) throws ParseException {
        UserOpen userOpen = homeService.getUserOpen();
        List<UserRole> list = userRoleMapper.getUserRoleByUserId(userOpen.getUserId());
//        List<UserRole> list = userRoleMapper.getUserRoleByUserId(1234L);
//        UserOpen userOpen = userOpenMapper.selectByUserId(1234L);
        model.put("user", userOpen);
        model.put("user_id", "\"" + userOpen.getUserId() + "\"");
        if (list.size() == 0) {
            return new ModelAndView("/user/home.ftl", model);
        } else {
            List<UptownHome> uptownHomes = uptownHomeMapper.getUptownHomeByUserId(userOpen.getUserId());
            UptownUnit unit = uptownUnitMapper.getUptownUnitByUser(userOpen.getUserId());
            if (unit.getUptownId() == 1238790987234L || unit.getUptownId() == 5) {
                model.put("into", "此功能暂未开放");
                model.put("errorMsg", "外出请佩戴口罩，避免近距离接触，不得长时间在外逗留。");
                return new ModelAndView("/user/goOut.ftl", model);
            } else {
                model.put("doorplate", unit.getUptownName() + "小区" + unit.getRidgepole() + "栋" + unit.getUnit() + "单元" + unit.getDoorplate() + "号");
                model.put("name", uptownHomes.get(0).getLinkman());
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                model.put("now", sdf.format(new Date()));
                OutUser outUser = outUserMapper.getOutUserByPhone(2, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
                if (outUser != null) {
                    model.put("collor", "green");
                    model.put("into", "允许外出");
                    model.put("errorMsg", "外出请佩戴口罩，避免近距离接触，保生产同时注意自身安全。");
                    return new ModelAndView("/user/goOut.ftl", model);
                }
                OutScanConf outScanConf = outScanConfMapper.getOutScanConfByUptown(unit.getUptownId());
                if (outScanConf.getGoOutFre() == 0) {
                    model.put("collor", "red");
                    model.put("into", "禁止外出");
                    model.put("errorMsg", "根据武汉市小区封闭管理规定，非特殊人员禁止出行！");
                    return new ModelAndView("/user/goOut.ftl", model);
                }
                List<MsReport> msReports = msReportMapper.selectMsReportLate(userOpen.getUserId());
                if (msReports.size() == 0) {
                    model.put("collor", "red");
                    model.put("into", "禁止外出");
                    model.put("errorMsg", "您近期未提交健康日报，无法判断您健康状态，请提交健康日报。");
                    return new ModelAndView("/user/goOut.ftl", model);
                }
                MsReport msReport = msReportMapper.selectMsReportToday(userOpen.getUserId());
                if (msReport != null && msReport.getMsStatus() == 2) {
                    model.put("collor", "red");
                    model.put("into", "禁止外出");
                    model.put("errorMsg", "健康日报提示您存在健康问题，禁止外出，请配合。");
                    return new ModelAndView("/user/goOut.ftl", model);
                }
                OutScan outScan = outScanMapper.getOutScanThreeday(userOpen.getUserId(), 2, outScanConf.getGoOutFre());
                if (outScan != null) {
                    model.put("collor", "red");
                    model.put("into", "禁止外出");
                    model.put("errorMsg", "您今日健康状态评估正常，最近可外出时间" + sdf.format(new Date(outScan.getDayDate().getTime() + 1000L * 3600 * 24 * outScanConf.getGoOutFre())) +
                            "，距今日还差" + differentDays(outScan.getDayDate(), sdf.parse(sdf.format(new Date())), outScanConf.getGoOutFre()) + "天。");
                    return new ModelAndView("/user/goOut.ftl", model);
                }
                model.put("collor", "green");
                model.put("into", "允许外出");
                model.put("errorMsg", "外出请佩戴口罩，避免近距离接触，不得长时间在外逗留。");
                return new ModelAndView("/user/goOut.ftl", model);
            }
        }
    }

    @ApiOperation("复工查询")
    @GetMapping("/user/returnWork.html")
    public ModelAndView selectReturnWork(HttpServletRequest request, ModelMap model) throws ParseException {
        UserOpen userOpen = homeService.getUserOpen();
        List<UserRole> list = userRoleMapper.getUserRoleByUserId(userOpen.getUserId());
//        List<UserRole> list = userRoleMapper.getUserRoleByUserId(1234L);
//        UserOpen userOpen = userOpenMapper.selectByUserId(1234L);
        model.put("user", userOpen);
        model.put("user_id", "\"" + userOpen.getUserId() + "\"");
        if (list.size() == 0) {
            return new ModelAndView("/user/home.ftl", model);
        } else {
            return returnWork(userOpen.getUserId(), model);
        }
    }

    @ApiOperation("复工查询")
    @GetMapping("/whepi/user/returnWork.html")
    public ModelAndView adminSelectReturnWork(@Pd(name = "userId")Long userId, ModelMap model) throws ParseException {
        return returnWork(userId, model);
    }

    private ModelAndView returnWork(Long userId, ModelMap model) throws ParseException {
        List<UptownHome> uptownHomes = uptownHomeMapper.getUptownHomeByUserId(userId);
        UptownUnit unit = uptownUnitMapper.getUptownUnitByUser(userId);
        model.put("uptownId", unit.getUptownId());
        if (unit.getUptownId() == 1238790987234L || unit.getUptownId() == 5) {
            model.put("tittle", "凌云集团");
            model.put("doorplate", unit.getRidgepole() + unit.getUnit());
            model.put("name", uptownHomes.get(0).getLinkman());
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            SimpleDateFormat s = new SimpleDateFormat("yyyy-MM-dd");
            model.put("now", sdf.format(new Date()));
            OutUser outUser1 = outUserMapper.getOutUserByPhone(4, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
            if (outUser1 != null) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "声明：根据凌云集团防疫指挥部复工条件，您属于不可复工六类人员之一，如有疑问请与上级管理部门联系。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            OutUser outUser = outUserMapper.getOutUserByPhone(1, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
            if (outUser != null) {
                model.put("collor", "green");
                model.put("collor2", "green");
                model.put("into", "允许复工");
                model.put("errorMsg", "声明：复工许可证是根据员工自主填写健康日报，结合凌云集团复工条件自动产生。原则上代表员工可复工，在厂门口扫描二维码生成绿色复工通行证，并接受检查后，可入厂。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            MsReport msReport = msReportMapper.queryMsReportIsXG(userId);
            if (msReport != null) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于您上报过新冠确诊、新冠疑似或密切接触者，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWork.ftl", model);
//                List<MsReport> msReports1 = msReportMapper.queryLateStatus(userId, s.format(msReport.getReportDate()));
//                if (msReports1.size() == 0) {
//                    model.put("collor", "red");
//                    model.put("collor2", "red");
//                    model.put("into", "不可复工");
//                    model.put("errorMsg", "由于您上报过新冠确诊、新冠疑似或密切接触者，且未解除医学隔离，不可复工，如有疑问请联系直管领导。");
//                    return new ModelAndView("/user/returnWork.ftl", model);
//                }
            }
            List<MsReport> msReportList = msReportMapper.queryMsReportIsXGHome(userId);
            if (msReportList.size() > 0) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于您的家庭成员有新冠确诊或密切接触史人员，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            List<MsReport> msReports = msReportMapper.selectMsReportLate(userId);
            if (msReports.size() < 4) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于您今日和前3日未连续报告日报，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            List<MsReport> msReports2 = msReportMapper.selectMsReportThereError(userId);
            if (msReports2.size() > 0) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于近期您健康评估存在问题，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            List<MsReport> msReports3 = msReportMapper.selectMsReportThirtyError(userId);
            if (msReports3.size() > 0) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于最近30天您健康评估存在问题，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            String returnWork = msReportMapper.returnWork(userId);
            if (returnWork != null) {
                if (sdf.parse(returnWork + " 00:00:00").getTime() + 1000L * 3600 * 24 * 15 > sdf.parse(s.format(new Date()) + " 00:00:00").getTime()) {
                    model.put("collor", "red");
                    model.put("collor2", "red");
                    model.put("into", "不可复工");
                    model.put("errorMsg", "您返回工作驻地后未满14日，不可复工。" + day15(s.parse(returnWork)) + "起方可进入！");
                    return new ModelAndView("/user/returnWork.ftl", model);
                }
            }
            MsReport msReport1 = msReportMapper.msAddr(userId);
            if (msReport1 != null && !msReport1.getWorkMsg().equals(msReport1.getTodayMsg())) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "您本人不在工作驻地，不能入场复工。");
                return new ModelAndView("/user/returnWork.ftl", model);
            }
            model.put("collor", "green");
            model.put("collor2", "green");
            model.put("into", "允许复工");
            model.put("errorMsg", "声明：复工许可证是根据员工自主填写健康日报，结合凌云集团复工条件自动产生。原则上代表员工可以复工，在厂门口扫描二维码生成绿色复工通行证，并接受规定检查后，方可入厂。");
            return new ModelAndView("/user/returnWork.ftl", model);
            //您近期内离开过工作单位驻地，请遵守返回工作驻地15日隔离规定，您目前未满15日，禁止进入。
        }else if (unit.getUptownId() == 100000002L) {
            model.put("tittle", "湖北和昌");
            model.put("doorplate", unit.getRidgepole() + unit.getUnit());
            model.put("name", uptownHomes.get(0).getLinkman());
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            SimpleDateFormat s = new SimpleDateFormat("yyyy-MM-dd");
            model.put("now", sdf.format(new Date()));
            OutUser outUser = outUserMapper.getOutUserByPhone(3, uptownHomes.get(0).getLinkman(), Long.parseLong(uptownHomes.get(0).getPhone()));
            if (outUser != null) {
                model.put("collor", "green");
                model.put("collor2", "green");
                model.put("into", "允许复工");
                model.put("errorMsg", "特殊人员允许通行，请保证生产同时注意自身安全。");
                return new ModelAndView("/user/returnWorkHC.ftl", model);
            }
            MsReport msReport = msReportMapper.queryMsReportIsXG(userId);
            if (msReport != null) {
                List<MsReport> msReports1 = msReportMapper.queryLateStatus(userId, s.format(msReport.getReportDate()));
                if (msReports1.size() == 0) {
                    model.put("collor", "red");
                    model.put("collor2", "red");
                    model.put("into", "不可复工");
                    model.put("errorMsg", "由于您上报过新冠确诊、新冠疑似或密切接触者，且未解除医学隔离，不可复工，如有疑问请联系直管领导。");
                    return new ModelAndView("/user/returnWorkHC.ftl", model);
                }
            }
            List<MsReport> msReportList = msReportMapper.queryMsReportIsXGHome(userId);
            if (msReportList.size() > 0) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不许进入");
                model.put("errorMsg", "由于您的家庭成员有新冠确诊或密切接触史人员，不许进入，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWorkHC.ftl", model);
            }
            List<MsReport> msReports = msReportMapper.selectMsReportLate(userId);
            if (msReports.size() < 4) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于您今日和前3日未连续报告日报，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWorkHC.ftl", model);
            }
            List<MsReport> msReports2 = msReportMapper.selectMsReportThereError(userId);
            if (msReports2.size() > 0) {
                model.put("collor", "red");
                model.put("collor2", "red");
                model.put("into", "不可复工");
                model.put("errorMsg", "由于近期您健康评估存在问题，不可复工，如有疑问请联系直管领导。");
                return new ModelAndView("/user/returnWorkHC.ftl", model);
            }
            model.put("collor", "green");
            model.put("collor2", "green");
            model.put("into", "允许复工");
            model.put("errorMsg", "声明：复工许可证是根据员工自主填写健康日报，结合湖北和昌新材料科技股份有限公司复工条件自动产生。原则上代表员工可以复工，在厂门口扫描二维码生成绿色复工通行证，并接受规定检查后，方可入厂。");
            return new ModelAndView("/user/returnWorkHC.ftl", model);
        } else {
            model.put("into", "此功能暂未开放");
            model.put("errorMsg", "复工期间请请注意安全。");
            return new ModelAndView("/user/returnWork.ftl", model);
        }

    }

    /**
     * 通过时间秒毫秒数判断两个时间的间隔
     *
     * @param date1
     * @param i
     * @return
     */
    public static int differentDays(Date date1, Date date2, Integer i) {
        int days = (int) ((date1.getTime() - date2.getTime()) / (1000 * 3600 * 24)) + i;
        return days;
    }

    /**
     * 判断传入的时间和现在相差是否在i分钟内
     *
     * @param date
     * @param i
     * @return
     */
    public Boolean compareTime(DateTime date, Integer i) {
        Date date1 = new Date(date.getMillis());
        if ((date1.getTime() + 1000L * 60 * i) > System.currentTimeMillis()) {
            return true;
        } else {
            return false;
        }
    }

    public String getMsg(Integer inType) {
        if (inType == 1) {
            return "进入";
        } else if (inType == 2) {
            return "外出";
        }
        return "";
    }

    public String queryTime(List<OutScanEstate> list) {
        SimpleDateFormat format = new SimpleDateFormat("HH:mm");
        String time = "";
        for (OutScanEstate o : list) {
            String date = format.format(new Date(o.getScanDate().getMillis()));
            time += date + "、";
        }
        return time.substring(0, time.length() - 1);
    }

    public String day15(Date returnWork) {
        SimpleDateFormat sdf = new SimpleDateFormat("MM月dd日");
        return sdf.format(new Date(returnWork.getTime() + 1000L * 3600 * 24 * 15));
    }

    public String day15(List<MsReport> list, String returnWork) throws ParseException {
        SimpleDateFormat sdf = new SimpleDateFormat("MM月dd日");
        Date time1 = null;
        if (list.size() == 0) {
            time1 = new Date();
        } else {
            SimpleDateFormat s = new SimpleDateFormat("yyyy-MM-dd");
            time1 = s.parse(returnWork);
        }
        return sdf.format(new Date(time1.getTime() + 1000L * 3600 * 24 * 15));
    }

    public String domain() {
        if (domain.substring(domain.length()-1).equals("/")) {
            return domain;
        } else {
            return domain + "/";
        }
    }


//    /**
//     * 生成进出门二维码
//     * @param doorId 小区大门ID
//     * @param inType 1进入;2外出
//     * @param response
//     * @throws IOException
//     * @throws WriterException
//     */
//    @GetMapping(value = "/scan/scan_qr.png", produces = MediaType.IMAGE_PNG_VALUE)
//    public void scanQrImg(@Pd(name = "doorId") Long doorId, @Pd(name = "inType") Integer inType,
//                            HttpServletResponse response) throws IOException, WriterException {
//        @Cleanup ServletOutputStream outputStream = response.getOutputStream();
//        String msg = URLEncoder.encode( domain + "user/scan.html?doorId=" + doorId + "&inType=" + inType,"utf-8");
//        BitMatrix matrix = new MultiFormatWriter().encode(oauth2 + appId + "&redirect_uri=" +
//                msg + moreUrl, BarcodeFormat.QR_CODE, 256, 256);
//        MatrixToImageWriter.writeToStream(matrix, MediaType.IMAGE_PNG.getSubtype(), outputStream, new MatrixToImageConfig());
//    }
//
//    /**
//     * 生成校园巡逻二维码
//     * @throws IOException
//     * @throws WriterException
//     */
//    @GetMapping(value = "/scan/scanEstate_qr.png", produces = MediaType.IMAGE_PNG_VALUE)
//    public void scanEstateQrImg(HttpServletResponse response) throws IOException, WriterException {
//        @Cleanup ServletOutputStream outputStream = response.getOutputStream();
//        String msg = URLEncoder.encode( domain + "user/scanEstate.html","utf-8");
//        BitMatrix matrix = new MultiFormatWriter().encode(oauth2 + appId + "&redirect_uri=" +
//                msg + moreUrl, BarcodeFormat.QR_CODE, 256, 256);
//        MatrixToImageWriter.writeToStream(matrix, MediaType.IMAGE_PNG.getSubtype(), outputStream, new MatrixToImageConfig());
//    }
}