package com.doumee.service.business.impl; import com.alibaba.fastjson.JSONObject; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.biz.system.SystemUserBiz; import com.doumee.config.DataSyncConfig; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.erp.ErpConstants; import com.doumee.core.erp.ErpTool; import com.doumee.core.erp.model.openapi.request.erp.ApproveAddRequest; import com.doumee.core.erp.model.openapi.request.erp.UserInfoRequest; import com.doumee.core.erp.model.openapi.response.erp.ApproveInfoResponse; import com.doumee.core.exception.BusinessException; import com.doumee.core.haikang.model.HKConstants; import com.doumee.core.haikang.model.param.BaseResponse; import com.doumee.core.haikang.model.param.request.ParkReservationDelRequest; import com.doumee.core.haikang.model.param.request.VisitAppointmentCancelRequest; import com.doumee.core.haikang.model.param.request.VisitAppointmentOutRequest; import com.doumee.core.haikang.model.param.request.VisitAppointmentRequest; import com.doumee.core.haikang.model.param.respose.VisitAppointmentResponse; import com.doumee.core.haikang.service.HKService; import com.doumee.dao.business.dao.*; import com.doumee.service.business.third.model.LoginUserInfo; import com.doumee.service.business.third.model.PageData; import com.doumee.service.business.third.model.PageWrap; import com.doumee.core.utils.*; import com.doumee.core.wx.wxPlat.WxPlatConstants; import com.doumee.core.wx.wxPlat.WxPlatNotice; import com.doumee.dao.admin.response.InterestedListVO; import com.doumee.dao.admin.response.PCWorkPlatformDataVO; import com.doumee.dao.business.*; import com.doumee.dao.business.dto.ResetPasswordDTO; import com.doumee.dao.business.join.DeviceJoinMapper; import com.doumee.dao.business.join.VisitsJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.business.model.Member; import com.doumee.dao.system.SystemUserMapper; import com.doumee.dao.system.dto.ResetSystemUserPwdDTO; import com.doumee.dao.system.join.NoticesJoinMapper; import com.doumee.dao.system.model.Notices; import com.doumee.dao.system.model.SystemUser; import com.doumee.dao.web.reqeust.AuditApproveDTO; import com.doumee.dao.web.reqeust.ErpVisitDTO; import com.doumee.dao.web.reqeust.ErpWithVisitDTO; import com.doumee.dao.web.reqeust.VisitRecordDTO; import com.doumee.dao.web.response.VisitDetailVO; import com.doumee.dao.web.response.VisitRecordVO; import com.doumee.service.business.ApproveService; import com.doumee.service.business.InterfaceLogService; import com.doumee.service.business.SmsEmailService; import com.doumee.service.business.VisitsService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.doumee.service.business.impl.hksync.HkSyncVisitServiceImpl; import com.doumee.service.business.third.EmayService; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; import com.github.yulichang.wrapper.MPJLambdaWrapper; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import java.util.*; import java.util.Date; import java.util.stream.Collectors; /** * 访客申请信息表Service实现 * @author 江蹄蹄 * @date 2023/11/30 15:33 */ @Service @Slf4j public class VisitsServiceImpl implements VisitsService { @Autowired private RetentionMapper retentionMapper; @Autowired private VisitsJoinMapper visitsMapper; @Autowired private UserActionMapper userActionMapper; @Autowired private ApproveMapper approveMapper; @Autowired private NoticesJoinMapper noticesJoinMapper; @Autowired private ApproveParamMapper approveParamMapper; @Autowired private DeviceRoleMapper deviceRoleMapper; @Autowired private ProblemLogMapper problemLogMapper ; @Autowired private MemberMapper memberMapper ; @Autowired private VisitsJoinMapper visitsJoinMapper; @Autowired private CompanyMapper companyMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private SystemUserBiz systemUserBiz; @Autowired private DeviceJoinMapper deviceJoinMapper; @Autowired private ErpTool erpTool; @Autowired private VisitParkMapper visitParkMapper; @Autowired private WxPlatNotice wxPlatNotice; @Autowired private InterfaceLogService interfaceLogService; @Autowired private DataSyncConfig dataSyncConfig; @Autowired private SmsEmailService smsEmailService; @Autowired private SystemUserMapper systemUserMapper; @Autowired private ApproveService approveService; @Autowired private InoutDayCountMapper inoutDayCountMapper; @Autowired private CarEventMapper carEventMapper; @Autowired private SmsConfigMapper smsConfigMapper; @Autowired private SmsEmailMapper smsEmailMapper; @Autowired private WxNoticeConfigMapper wxNoticeConfigMapper; @Autowired private EmayService emayService; @Override public Integer create(Visits visits) { visitsMapper.insert(visits); return visits.getId(); } @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void createFKForErp(ErpVisitDTO erpVisitDTO){ if (Objects.isNull(erpVisitDTO) || StringUtils.isBlank(erpVisitDTO.getName()) || StringUtils.isBlank(erpVisitDTO.getPhone()) || StringUtils.isBlank(erpVisitDTO.getCompanyName()) || Objects.isNull(erpVisitDTO.getIdcardType()) || StringUtils.isBlank(erpVisitDTO.getIdcardNo()) || Objects.isNull(erpVisitDTO.getStarttime()) || Objects.isNull(erpVisitDTO.getEndtime()) || StringUtils.isBlank(erpVisitDTO.getFaceImg()) || StringUtils.isBlank(erpVisitDTO.getDoors()) || Objects.isNull(erpVisitDTO.getReceptMemberId()) || Objects.isNull(erpVisitDTO.getErpId()) ) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，信息填写不正确！"); } if (erpVisitDTO.getEndtime().getTime() <= erpVisitDTO.getStarttime().getTime()) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，预约结束时间必须大于开始时间！"); } if (Constants.equalsInteger(Constants.ZERO, erpVisitDTO.getIdcardType()) && erpVisitDTO.getIdcardNo().length() != 18 //&&!IdcardUtil.isValidCard(visits.getIdcardNo()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证号码有误，请核实后重试！"); } Visits visits = new Visits(); //根据被访问人ERP主键查询系统内人员主键信息 Member member = memberMapper.selectOne(new QueryWrapper().lambda() .eq(Member::getIsdeleted, Constants.ZERO).eq(Member::getType, Constants.memberType.internal) .eq(Member::getErpId, erpVisitDTO.getReceptMemberId()).last("limit 1")); if (Objects.isNull(member)) { throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到被访问人信息"); } if (Objects.isNull(member.getCanVisit()) || member.getCanVisit().equals(Constants.ZERO)) { throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "当前被访问人无法被访问"); } BeanUtils.copyProperties(erpVisitDTO, visits); //设置内部系统人员主键 visits.setReceptMemberId(member.getId()); visits.setSourceType(Constants.ONE); List erpWithVisitDTOList = erpVisitDTO.getErpWithVisitDTOList(); if (CollectionUtils.isNotEmpty(erpWithVisitDTOList)) { List visitsList = new ArrayList<>(); for (ErpWithVisitDTO erpWithVisitDTO : erpWithVisitDTOList) { Visits withVisits = new Visits(); BeanUtils.copyProperties(erpWithVisitDTO, withVisits); withVisits.setCompanyName(visits.getCompanyName()); withVisits.setReason(visits.getReason()); visitsList.add(withVisits); } visits.setWithUserList(visitsList); } this.createFk(visits,true,Constants.ONE); } @Transactional(propagation = Propagation.NOT_SUPPORTED) void saveInterfaceLog(Object param, String path, String result, Integer type) { InterfaceLog interfaceLog=new InterfaceLog(); interfaceLog.setType(type); interfaceLog.setCreateDate(new Date()); interfaceLog.setIsdeleted(Constants.ZERO); if(param!=null){ interfaceLog.setRequest(JSONObject.toJSONString(param)); } interfaceLog.setPlat(Constants.ONE); interfaceLog.setRepose(result); interfaceLog.setName(path); interfaceLog.setUrl(path); interfaceLogService.create(interfaceLog); } /** * 普通访客申请 * @param visits * @return */ @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public Integer createFk(Visits visits,Boolean isERP,Integer source) { visits.setId(null); isValidBaseParam(visits); //检查是否必须答题，并且符合答题要求 ProblemLog problemLog = isValidProblemLog(visits,source); //获取申请的海康访问门禁组信息 getHkDeviceRoles(visits,isERP); //检验拜访人是否合法 Member visitMember = isValideVisitedUser(visits.getReceptMemberId()); if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType()) &&visits.getIdcardNo().length()!=18 ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证号码有误，请核实后重试！"); } Date date = new Date(); //创建时间 visits.setCreateDate(date); //随行人员数量 visits.setMemberNum(Constants.ZERO); //访客信息(使用身份证号查询是否已存在该普通访客，没有则新增，存在则更新openid等信息),包括随访人员校验和处理 Member member = dealMemberAndVisits(visits); visits.setMemberId(member.getId()); visits.setVisitType(Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.MDJ_VISIT_REQUIRED).getCode())); //初始化访客信息 initVisitInfo(visits,date); // if(StringUtils.isNotBlank(visits.getFaceImg())&&(Constants.equalsInteger(visits.getType(),Constants.ZERO)|| Constants.equalsInteger(visits.getType(),Constants.TWO))){ // //人脸评分 // FacePictureCheckRequest param = new FacePictureCheckRequest(); // String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() + // systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); // param.setFacePicUrl(prefixUrl + visits.getFaceImg()); // BaseResponse response = HKService.facePictureCheck(param); // if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，人脸评分获取数据失败~"); // } // FacePictureCheckResponse facePictureCheckResponse = response.getData(); // if(Objects.isNull(facePictureCheckResponse) || Objects.isNull(facePictureCheckResponse.getCheckResult())){ // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，人脸评分获取数据失败~"); // } // if(!facePictureCheckResponse.getCheckResult()){ // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), facePictureCheckResponse.getStatusMessage()); // } // } visits.setSendTimeOutNotice(Constants.ZERO); visitsMapper.insert(visits); //发起ERP审批申请 if(dataSyncConfig.getVisitorDataOrigin().equals(Constants.ONE)){ String erpId = startSendErpCheck(visits,visitMember); if(StringUtils.isNotBlank(erpId)){ visits.setErpId(erpId); visits.setStatus(Constants.VisitStatus.submitCheck); visitsMapper.updateById(visits); }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，发起拜访审批申请失败！"); } }else if(dataSyncConfig.getVisitorDataOrigin().equals(Constants.ZERO)){ visits.setStatus(Constants.VisitStatus.waitCheck); visitsMapper.updateById(visits); approveService.createApproveFlow(visits.getType(),visits.getId(),visits.getReceptMemberId(),member); }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，发起拜访审批申请失败！"); } initWithVisitInfo(visits); updateProblemLog(visits,problemLog,member); //发送微信公众号通知 - 申请提交成功待审核 if(StringUtils.isNotBlank(visits.getOpenid())){ WxPlatNotice wxPlatNotice = new WxPlatNotice(); wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz, wxNoticeConfigMapper,visits, Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload, Arrays.asList(visits.getOpenid().split(",")) ); } //创建审批记录 createApprove(visits,visitMember); return visits.getId(); } @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public Integer visitReporting(Visits visits) { visits.setSourceType(Constants.ZERO); isValidBaseParam(visits); //检验被拜访人是否合法 Member visitMember = isValideVisitedUser(visits.getMemberId()); Date date = new Date(); //创建时间 visits.setCreateDate(date); //访客报备 visits.setIsdeleted(Constants.ZERO); visits.setType(Constants.TWO); visits.setReceptMemberId(visitMember.getId()); visits.setStatus(Constants.VisitStatus.waitCheck); visits.setVisitType(Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.MDJ_VISIT_REQUIRED).getCode())); visits.setIdcardNo(DESUtil.decrypt(Constants.EDS_PWD, visitMember.getIdcardNo())); //初始化访客信息 // initVisitInfo(visits,date); visitsMapper.insert(visits); if(Objects.nonNull(visits.getLoginUserInfo())){ SystemUser systemUser = systemUserMapper.selectById(visits.getLoginUserInfo().getId()); if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getOpenid())){ WxPlatNotice wxPlatNotice = new WxPlatNotice(); wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz, wxNoticeConfigMapper,visits, Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload, Arrays.asList(systemUser.getOpenid().split(",")) ); } } approveService.createApproveFlow(visits.getType(),visits.getId(),visits.getReceptMemberId(),null); return visits.getId(); } /** * 创建审批记录 * @param visits * @param visitMember */ public void createApprove(Visits visits,Member visitMember){ List approveIds = new ArrayList<>(); ApproveParam approveParam = null;//this.getApproveIds(1,visitMember,approveIds); //创建待审批记录 //获取审批配置主键 Integer firstApproveId = this.checkFirstAudit(); //内部人员创建 且创建人与被访问人相同 if(!Objects.isNull(visits.getCreateMemberId())//内部人员发布 &&visits.getCreateMemberId().equals(visitMember.getId())//创建人员与被访问人员是否是同一人 &&!Objects.isNull(firstApproveId)//审批配置第一级为 被访问人审批 ){ approveParam = this.getApproveIds(2,visitMember,approveIds); Approve approve = new Approve(); approve.setCreateDate(new Date()); approve.setIsdeleted(Constants.ZERO); approve.setCheckInfo("自动审批"); approve.setTemplatId(firstApproveId); approve.setIsEndCheck(Constants.ZERO); approve.setType(Constants.ZERO); approve.setLevel(Constants.ONE); approve.setObjId(visits.getId()); approveMapper.insert(approve); if(!CollectionUtils.isNotEmpty(approveIds)){ approve.setIsEndCheck(Constants.ONE); visits.setStatus(Constants.TWO); visitsMapper.updateById(visits); //存储抄送记录 this.saveCopyFor(visits.getId()); } }else{ approveParam = this.getApproveIds(null,visitMember,approveIds); if(!CollectionUtils.isNotEmpty(approveIds)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无有效的审批配置，请联系管理员"); } } if(!Objects.isNull(approveIds)){ //创建下一级审批记录 this.saveAuditRecord(visits.getId(),approveIds,approveParam); } } /** * 审批 审批记录 或签 审批通过进入下一步 会签 检测是否是最后一条待审批 * @param auditApproveDTO */ @Override public void auditApprove(AuditApproveDTO auditApproveDTO){ Approve approve = approveMapper.selectById(auditApproveDTO.getId()); if(Objects.isNull(approve)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(approve.getStatus().equals(Constants.approveStatus.wait)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批记录已处理!"); } Visits visits = visitsMapper.selectById(approve.getObjId()); if(Objects.isNull(visits)||Constants.equalsInteger(visits.getIsdeleted(),Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!auditApproveDTO.getMemberId().equals(approve.getChekorId())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"人员信息匹配错误!"); } //被访人 Member visitMember = memberMapper.selectById(visits.getReceptMemberId()); List approveIds = new ArrayList<>(); ApproveParam approveParam = this.getApproveIds(approve.getLevel()+1,visitMember,approveIds); approve.setStatus(auditApproveDTO.getStatus()); approve.setEditDate(new Date()); approve.setChekorId(auditApproveDTO.getMemberId()); approve.setCheckInfo(auditApproveDTO.getCheckInfo()); approveMapper.updateById(approve); if(auditApproveDTO.getStatus().equals(Constants.approveStatus.pass)){ if(approve.getApproveType().equals(Constants.ONE)){ //会签 查询是否是最后一条记录 如果是最后一条记录 则生成下级审批记录 如果是最后一级，则进行审批确认 if(approveMapper.selectCount(new QueryWrapper().lambda() .eq(Approve::getObjId,visits.getId()) .eq(Approve::getLevel,approve.getLevel()) .ne(Approve::getId,approve.getId()) )<=Constants.ZERO){ //当前审批级别 最后一条待审批记录 if(!CollectionUtils.isNotEmpty(approveIds)){ //没有下级审批流则 修改访客记录主键 visits.setStatus(auditApproveDTO.getStatus()); visits.setCheckDate(new Date()); visits.setCheckorId(auditApproveDTO.getMemberId()); visitsMapper.updateById(visits); }else{ this.saveAuditRecord(visits.getId(),approveIds,approveParam); } } }else{ //或签 approveMapper.update(null,new UpdateWrapper().lambda() .set(Approve::getStatus,Constants.approveStatus.otherDeal) .set(Approve::getEditDate,new Date()) .set(Approve::getCheorId,auditApproveDTO.getMemberId()) .eq(Approve::getObjId,visits.getId()) .eq(Approve::getStatus,Constants.approveStatus.wait) .ne(Approve::getId,approve.getId()) .eq(Approve::getLevel,approve.getLevel()) ); if(!CollectionUtils.isNotEmpty(approveIds)){ //没有下级审批流则 修改访客记录主键 visits.setStatus(auditApproveDTO.getStatus()); visits.setCheckDate(new Date()); visits.setCheckorId(auditApproveDTO.getMemberId()); visitsMapper.updateById(visits); }else{ this.saveAuditRecord(visits.getId(),approveIds,approveParam); } } }else if(auditApproveDTO.getStatus().equals(Constants.approveStatus.unPass)){ visits.setStatus(auditApproveDTO.getStatus()); visits.setCheckDate(new Date()); visits.setCheckorId(auditApproveDTO.getMemberId()); visitsMapper.updateById(visits); approveMapper.update(null,new UpdateWrapper().lambda() .set(Approve::getStatus,Constants.approveStatus.otherDeal) .set(Approve::getEditDate,new Date()) .set(Approve::getCheorId,auditApproveDTO.getMemberId()) .eq(Approve::getObjId,visits.getId()) .eq(Approve::getStatus,Constants.approveStatus.wait) .ne(Approve::getId,approve.getId()) .eq(Approve::getLevel,approve.getLevel()) ); }else{ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批状态错误!"); } } /** * 存储抄送记录 * @param visitId */ public void saveCopyFor(Integer visitId){ ApproveParam approveParam = approveParamMapper.selectOne(new QueryWrapper().lambda() .eq(ApproveParam::getIsdeleted,Constants.ZERO) .eq(ApproveParam::getType,Constants.ONE) .eq(ApproveParam::getLevel,Constants.ONE) .last("limit 1")); if(Objects.isNull(approveParam)){ return; } if(StringUtils.isNotBlank(approveParam.getObjIds())){ String [] ids = approveParam.getObjIds().split(","); List approveList = new ArrayList<>(); for (String id:ids) { Approve approve = new Approve(); approve.setCreateDate(new Date()); approve.setIsdeleted(Constants.ZERO); approve.setCheckInfo("抄送记录"); approve.setTemplatId(approveParam.getId()); approve.setChekorId(Integer.valueOf(id)); approve.setType(Constants.ONE); approve.setObjId(visitId); approveList.add(approve); } approveMapper.insert(approveList); } } /** * 存储下级审批记录 * @param visitId * @param ids * @param approveParam */ public void saveAuditRecord(Integer visitId,List ids,ApproveParam approveParam){ if(CollectionUtils.isNotEmpty(ids)) { List approveList = new ArrayList<>(); for (Integer id:ids) { Approve approve = new Approve(); approve.setCreateDate(new Date()); approve.setIsdeleted(Constants.ZERO); approve.setStatus(Constants.ZERO); approve.setCheckInfo("抄送记录"); approve.setTemplatId(approveParam.getId()); approve.setLevel(approveParam.getLevel()); approve.setApproveType(approveParam.getApproveType()); approve.setChekorId(id); approve.setType(Constants.ONE); approve.setObjId(visitId); approveList.add(approve); } approveMapper.insert(approveList); } } /** * 判断一级审批人是否是创建人 * @return */ public Integer checkFirstAudit(){ ApproveParam approveParam = approveParamMapper.selectOne(new QueryWrapper().lambda() .eq(ApproveParam::getIsdeleted,Constants.ZERO) .eq(ApproveParam::getType,Constants.ZERO) .eq(ApproveParam::getLevel,Constants.ONE) .eq(ApproveParam::getMemberType,Constants.ZERO) .last("limit 1")); return Objects.isNull(approveParam)?null:approveParam.getId(); } /** * 创建审批人员信息 若返回待审批人员主键列表为空，则无审批人员 抛出对应异常 * @param level 处理级别 * @param visitMember 被访人 */ public ApproveParam getApproveIds(Integer level,Member visitMember,List ids){ //查询审批配置项 List allParam = approveParamMapper.selectList(new QueryWrapper().lambda() .eq(ApproveParam::getIsdeleted,Constants.ZERO) .eq(ApproveParam::getType,Constants.ZERO) .ge(!Objects.isNull(level),ApproveParam::getLevel,level) .orderByAsc(ApproveParam::getLevel)); ApproveParam approveParam = new ApproveParam(); //发送审批/抄送记录的用户主键集合 ids.clear(); if(!CollectionUtils.isNotEmpty(allParam)){ if(Objects.isNull(level)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未配置访客审批流，请联系管理员"); } }else{ approveParam = allParam.get(0); if(approveParam.getMemberType().equals(Constants.ZERO)){ //被访人审批 //添加审批人 ids.add(visitMember.getId()); }else if(approveParam.getMemberType().equals(Constants.ONE)){ //指定人员审批 String [] objIds = approveParam.getObjIds().split(","); for (String id:objIds) { //添加审批人 ids.add(Integer.valueOf(id)); } }else if(approveParam.getMemberType().equals(Constants.TWO)){ //部门主管审批 //审批部门 Company auditCompany = this.getAuditCompanyHead(visitMember.getCompanyId(),approveParam.getObjLevel()); if(Objects.isNull(auditCompany)){ //审批部门为空 自动流转下一级审批配置 level = level + 1; return this.getApproveIds(level,visitMember,ids); }else{ //查询部门负责人 Member headMember = memberMapper.selectById(auditCompany.getHeadId()); if(Objects.isNull(headMember)){ //未查询到部门负责人 if(approveParam.getNoleaderOpt().equals(Constants.ONE)&&!Objects.isNull(auditCompany.getParentId())){ //由上级主管代替审核 auditCompany = companyMapper.selectOne(new QueryWrapper().lambda().eq(Company::getId,auditCompany.getParentId())); if(Objects.isNull(auditCompany)){ //审批部门为空 自动流转下一级审批配置 level = level + 1; this.getApproveIds(level,visitMember,ids); }else{ headMember = memberMapper.selectById(auditCompany.getHeadId()); if(Objects.isNull(headMember)){ //查询部门负责人 为空 自动流转下一级审批配置 level = level + 1; return this.getApproveIds(level,visitMember,ids); }else{ //添加审批人 ids.add(headMember.getId()); } } }else{ level = level + 1; return this.getApproveIds(level,visitMember,ids); } }else{ //添加审批人 ids.add(headMember.getId()); } } } } return approveParam; } /** * 根据配置查询上级数据 * @param companyId 直接部门 * @param objLevel 查询级别 */ public Company getAuditCompanyHead(Integer companyId,Integer objLevel){ Integer queryLevel = Constants.ONE; Integer nextCompanyId = companyId; Company auditCompany = new Company(); while(queryLevel.equals(objLevel)){ auditCompany = companyMapper.selectById(nextCompanyId); if(Objects.isNull(auditCompany)){ return null; } nextCompanyId = auditCompany.getParentId(); } return auditCompany; } /** * 校验必填项数据是否合法 * @param visits */ private void isValidBaseParam(Visits visits) { if(visits.getEndtime() == null || visits.getStarttime() == null || StringUtils.isBlank(visits.getReason()) || StringUtils.isBlank( visits.getName()) || StringUtils.isBlank( visits.getPhone()) || StringUtils.isBlank( visits.getCompanyName()) || Objects.isNull(visits.getType()) // || StringUtils.isBlank( visits.getFaceImg() ) || visits.getReceptMemberId() == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，信息填写不正确！"); } if(Constants.equalsInteger(visits.getType(),Constants.ZERO) || Constants.equalsInteger(visits.getType(),Constants.ONE)){ if( visits.getIdcardType() == null || StringUtils.isBlank( visits.getIdcardNo() ) || StringUtils.isBlank(visits.getFaceImg()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，信息填写不正确！"); } } //访客报备 if(Constants.equalsInteger(visits.getType(),Constants.TWO) && (StringUtils.isBlank( visits.getName()) || StringUtils.isBlank( visits.getPhone()) || StringUtils.isBlank( visits.getCompanyName()) || StringUtils.isBlank( visits.getCarNos()) || Objects.isNull(visits.getReceptMemberId())) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，信息填写不正确！"); }else if(visits.getType().equals(Constants.ONE) && StringUtils.isBlank(visits.getConstructionReason())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，未填写施工事由！"); } if(visits.getEndtime().getTime() <= visits.getStarttime().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，离厂时间必须大于入厂时间！");// } if(visits.getEndtime().getTime() <= System.currentTimeMillis()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，入厂时间必须大于当前时间！");// } if(!DateUtil.getDateLong(visits.getEndtime()).equals(DateUtil.getDateLong(visits.getStarttime()))){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，预约日期不可以跨天！"); }; if(visits.getSourceType().equals(Constants.ZERO)){ String code = systemDictDataBiz.queryByCode(Constants.VISIT_CONFIG,Constants.VALIDATE_VISIT).getCode(); int codenum =0; try { codenum = Integer.parseInt(code); }catch (Exception e){ } if(StringUtils.isNotBlank(code)&&!StringUtils.equals(code,"0")){ int betweenDays = DateUtil.daysBetweenDates11(visits.getEndtime(), visits.getStarttime())+1; if( betweenDays > codenum){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，预约总天数不能超过["+code+"天]！"); } } } } private void isValidWithVisitParam(Visits visits, List addList, List updateList) { if( StringUtils.isBlank( visits.getName()) || StringUtils.isBlank( visits.getPhone()) || visits.getIdcardType() == null || StringUtils.isBlank( visits.getFaceImg() ) || StringUtils.isBlank( visits.getIdcardNo() ) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，信息填写不正确！"); } // if(visits.getStarttime().getTime() < System.currentTimeMillis()){ // throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，预约开始时间必须大于当前时间！");// // } if(visits.getEndtime().getTime() <= visits.getStarttime().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，预约结束时间必须大于开始时间！");// } if(isRepeatedMember(visits,addList,updateList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，手机号或身份证号出现重复数据，请修改后重新提交！");// } } private boolean isRepeatedMember(Visits visits, List addList, List updateList) { if(addList.size()>0){ for(Member m :addList){ if(StringUtils.equals(visits.getPhone(), m.getPhone()) || StringUtils.equals(visits.getIdcardNo(), m.getIdcardDecode())){ return true; } } } if(updateList.size()>0){ for(Member m :updateList){ if(StringUtils.equals(visits.getPhone(), m.getPhone()) || StringUtils.equals(visits.getIdcardNo(), m.getIdcardDecode())){ return true; } } } return false; } private void initWithVisitInfo(Visits visits) { if(CollectionUtils.isNotEmpty(visits.getWithUserList())){ for(Visits v :visits.getWithUserList()){ v.setBirthday(Constants.getBirthdyByCardNo(v.getIdcardNo())); v.setParentId(visits.getId()); v.setStarttime(visits.getStarttime()); v.setEndtime(visits.getEndtime()); v.setIsdeleted(Constants.ZERO); v.setCreateDate(visits.getCreateDate()); v.setSex(Constants.getSexByCardNo(v.getIdcardNo())); v.setIdcardDecode(Constants.getTuominStr(v.getIdcardNo()));//脱敏身份证号 v.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, v.getIdcardNo()));//身份证号加密 v.setErpId(visits.getErpId()); v.setReceptMemberId(visits.getReceptMemberId()); v.setMemberNum(Constants.ZERO); v.setHkStatus(Constants.ZERO); v.setReason(visits.getReason()); v.setDoors(visits.getDoors()); v.setType(visits.getType()); v.setVisitType(visits.getVisitType()); v.setStatus(visits.getStatus()); v.setSourceType(visits.getSourceType()); } //批量插入数据 visitsMapper.insert(visits.getWithUserList()); } } private void initVisitInfo(Visits visits,Date date) { visits.setHkStatus(Constants.ZERO);//未同步 visits.setBirthday(Constants.getBirthdyByCardNo(visits.getIdcardNo())); visits.setStatus(Constants.ZERO);//待审批 visits.setSex(Constants.getSexByCardNo(visits.getIdcardNo())); visits.setIdcardDecode(Constants.getTuominStr(visits.getIdcardNo()));//脱敏身份证号 visits.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, visits.getIdcardNo()));//身份证号加密 visits.setIsdeleted(Constants.ZERO); visits.setCreateDate(date); } private String startSendErpCheck(Visits visits,Member visitMember) { ApproveAddRequest param = new ApproveAddRequest(); List withUserVisitsList = visits.getWithUserList(); List withUserList = new ArrayList<>(); UserInfoRequest mainUser = new UserInfoRequest(); mainUser.setName(visits.getName()); mainUser.setIdNo(DESUtil.decrypt(Constants.EDS_PWD, visits.getIdcardNo())); mainUser.setSex(visits.getSex()); mainUser.setPhone(visits.getPhone()); mainUser.setFaceImg(visits.getFaceImg()); mainUser.setHealthImg(visits.getImgurl()); withUserList.add(mainUser); if(CollectionUtils.isNotEmpty(withUserVisitsList)){ for (Visits v:withUserVisitsList) { UserInfoRequest userInfoRequest = new UserInfoRequest(); userInfoRequest.setName(v.getName()); userInfoRequest.setIdNo(v.getIdcardNo()); userInfoRequest.setSex(v.getSex()); userInfoRequest.setPhone(v.getPhone()); userInfoRequest.setFaceImg(v.getFaceImg()); userInfoRequest.setHealthImg(v.getImgurl()); withUserList.add(userInfoRequest); } } param.setWithUserList(withUserList); param.setId(visits.getId()); param.setBeVisitedUserId(visitMember.getErpId()); param.setVisitorWorkUint(visits.getCompanyName()); param.setPurpose(visits.getReason()); param.setStartTime(DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss")); param.setEndTime(DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss")); param.setBeVisitedOrgId(visitMember.getErpOrgId()); if(StringUtils.isNotBlank(visits.getCarNos())){ param.setCarNo(Arrays.asList(visits.getCarNos().split(","))); } if(StringUtils.isNotBlank(visits.getDoors())){ List deviceRoleList = deviceRoleMapper.selectList(new QueryWrapper().lambda().in(DeviceRole::getId,Arrays.asList(visits.getDoors().split(",")))); if(CollectionUtils.isNotEmpty(deviceRoleList)){ param.setRoleIds(deviceRoleList.stream().map(m->m.getId()).collect(Collectors.toList())); param.setRoleNames(deviceRoleList.stream().map(m->m.getName()).collect(Collectors.toList())); } } ApproveInfoResponse response = erpTool.submitApprove(ErpConstants.approveUrl,param); if(!Objects.isNull(response)){ return visits.getId().toString(); } return null; } private String visitAppiontment(Visits visits) { VisitAppointmentRequest param = new VisitAppointmentRequest(); param.setVisitStartTime(DateUtil.getISO8601Timestamp(visits.getStarttime())); param.setVisitEndTime(DateUtil.getISO8601Timestamp(visits.getStarttime())); BaseResponse res = HKService.visitAppiontment(param); if(res==null || !StringUtils.equals(res.getCode(), HKConstants.RESPONSE_SUCCEE) || res.getData()==null){ //如果发起预约失败 visits.setStatus(Constants.VisitStatus.xfFail); }else{ visits.setStatus(Constants.VisitStatus.xfSuccess); visits.setHkStatus(Constants.ONE); visits.setHkId(res.getData().getAppointRecordId()); } visits.setHkDate(visits.getCheckDate()); return res.getData().getAppointRecordId(); } /** * 访客信息(使用身份证号查询是否已存在改普通访客，没有则新增，存在则更新openid等信息),包括随访人员校验和处理 * @param visits * @return */ private Member dealMemberAndVisits(Visits visits ) { if(StringUtils.isNotBlank(visits.getOpenid())){ //先清空原有访客的openid绑定关系 memberMapper.update(null, new UpdateWrapper().lambda() .eq(Member::getType,Constants.memberType.visitor) .eq(Member::getOpenid,visits.getOpenid()) .set(Member::getOpenid,null) ); } List addList = new ArrayList<>(); List editList = new ArrayList<>(); //申请人信息 Member m = getMemberListParam(visits.getIdcardNo(),visits,addList,editList); //随访人员信息处理 if(visits.getWithUserList()!= null && visits.getWithUserList().size()>0){ for(Visits model:visits.getWithUserList()){ model.setBirthday(Constants.getBirthdyByCardNo(model.getIdcardNo())); model.setStarttime(visits.getStarttime()); model.setEndtime(visits.getEndtime()); //校验随访人员填报数据合法性 isValidWithVisitParam(model,addList,editList); model.setCreateDate(visits.getCreateDate()); Member visitsMember = getMemberListParam(model.getIdcardNo(),model,addList,editList); model.setMemberId(visitsMember.getId()); } } return m; } private Member getMemberListParam(String cardno, Visits visits, List addList, List editList) { if(StringUtils.isNotBlank(visits.getCarNos()) &&Objects.isNull(Constants.getVehiclePlateNo(visits.getCarNos())) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，车牌号【"+visits.getCarNos()+"】不合法，请核实后重试~"); } if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())&&cardno.length()!=18 //&&!IdcardUtil.isValidCard(cardno) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证【"+cardno+"】号码有误，请核实后重试！"); } Member member = memberMapper.selectOne(new QueryWrapper().lambda() .eq(Member::getType,Constants.memberType.visitor) .eq(Member::getIdcardType,visits.getIdcardType()) .eq(Member::getIdcardNo,DESUtil.encrypt(Constants.EDS_PWD, cardno)).last("limit 1" ) ); if(member == null){ member = new Member(); //如果用户不存在，则新增 member.setCreateDate(visits.getCreateDate()); member.setIsdeleted(Constants.ZERO); member.setIdcardNo(visits.getIdcardNo()); member.setBirthday(Constants.getBirthdyByCardNo(cardno)); member.setIdcardDecode(visits.getIdcardDecode()); member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//身份证号加密 member.setIdcardDecode(Constants.getTuominStr(cardno));//脱敏手机号 member.setFaceImg(visits.getFaceImg()); member.setSex(Constants.getSexByCardNo(cardno)); member.setImgurl(StringUtils.isNotBlank(visits.getImgurl())?visits.getImgurl():null); member.setIdcardType(visits.getIdcardType()); member.setName(visits.getName()); member.setPhone(visits.getPhone()); member.setOpenid(visits.getOpenid()); member.setType(Constants.memberType.visitor); member.setStatus(Constants.ZERO); member.setSex(Constants.getSexByCardNo(cardno)); member.setHkStatus(Constants.ZERO); member.setErpStatus(Constants.ZERO); member.setVisitCompanyName(visits.getCompanyName()); memberMapper.insert(member); // 新增访客 // addList.add(member); }else{ if(!Constants.equalsInteger(Constants.ZERO,member.getStatus() )){ //如果用户状态异常，则提示 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，【"+member.getName()+"】身份证号【"+cardno+"】在黑名单内，无法申请进入园区"); } //核查预约用户是否存在未签离的预约记录 // isExsitNoOutVisisRecord(member); member.setFaceImg(visits.getFaceImg()); member.setImgurl(StringUtils.isNotBlank(visits.getImgurl())?visits.getImgurl():null); member.setEditDate(visits.getCreateDate()); member.setIsdeleted(Constants.ZERO); member.setSex(Constants.getSexByCardNo(cardno)); member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//身份证号加密 member.setIdcardDecode(Constants.getTuominStr(cardno));//脱敏身份证号 member.setName(visits.getName()); member.setPhone(visits.getPhone()); member.setOpenid(visits.getOpenid()); member.setSex(Constants.getSexByCardNo(cardno)); member.setHkStatus(Constants.ZERO); member.setErpStatus(Constants.ZERO); member.setVisitCompanyName(visits.getCompanyName()); memberMapper.updateById(member); } //根据手机号和身份证号码查询 当前预约的时间是否与其他预约记录有冲突 if (visitsMapper.selectCount(new QueryWrapper().lambda() .eq(Visits::getIsdeleted,Constants.ZERO) .notIn(Visits::getStatus,Constants.VisitStatus.cancel ,Constants.VisitStatus.noPass ,Constants.VisitStatus.xfFail ,Constants.VisitStatus.signout ,Constants.VisitStatus.invalid) .eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno)) .and(ms -> ms.eq(Visits::getPhone, visits.getPhone()) .or().eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno))) .and(ms -> ms.apply(" visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' ") .or().apply(" visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ") .or().apply(" visits.STARTTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ") .or().apply(" visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ") ) ) > Constants.ZERO) { throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，手机号【"+member.getPhone()+"】或身份证【"+ member.getIdcardDecode() +"】存在预约时间冲突，无法申请哦！"); } return member; } /** * 核查预约用户是否存在未签离的预约记录 * @param member */ private void isExsitNoOutVisisRecord(Member member) { Visits v = visitsMapper.selectOne(new QueryWrapper().lambda() .eq(Visits::getIsdeleted,Constants.ZERO) .eq(Visits::getPhone, member.getPhone()) .eq(Visits::getStatus,Constants.VisitStatus.xfSuccess) .last(" limit 1" ) ); if(v !=null){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，手机号【"+member.getPhone()+"】存在未签离预约申请，不能重复申请哦！"); } } private List isValideWithUsers(List withUserList) { if(withUserList!= null && withUserList .size()>0){ for(Visits model:withUserList){ } } return null; } /** * 如果有答题记录，更新答题记录关联数据 * @param visits * @param problemLog * @param member */ private void updateProblemLog(Visits visits, ProblemLog problemLog,Member member) { if(problemLog!=null){ problemLog.setEditDate(visits.getCreateDate()); problemLog.setStatus(Constants.ONE); problemLog.setName(visits.getName()); problemLog.setUserId(member.getId()); problemLog.setPhone(member.getPhone()); problemLog.setLogId(visits.getId()); problemLog.setCompanyName(visits.getCompanyName()); problemLogMapper.updateById(problemLog); } } /** * 检查访人是否合法 * @param receptMemberId */ private Member isValideVisitedUser(Integer receptMemberId) { Member member = memberMapper.selectById(receptMemberId); if(member == null || !Constants.equalsInteger(Constants.ZERO,member.getIsdeleted())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，该拜访人暂时不能接受您的拜访申请！"); } if(!Constants.equalsInteger(member.getStatus(), Constants.ZERO)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，该拜访人暂时不能接受您的拜访申请."); } if(!Constants.equalsInteger(Constants.ONE, member.getCanVisit())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，该拜访人暂时不能接受您的拜访申请~"); } if(StringUtils.isBlank(member.getHkId())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，该拜访人未下发暂时不能接受您的拜访申请~"); } return member; } /** * 是否需要答题 * @param visits * @param source * @return */ private ProblemLog isValidProblemLog(Visits visits,Integer source) { if(!Constants.equalsInteger(source,Constants.ZERO)){ return null; } String required = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PROBLEM_VISIT_REQUIRED).getCode(); if(StringUtils.equals(required,Constants.ONE+"")&&visits.getSourceType()==Constants.ZERO&&!visits.getType().equals(Constants.TWO)){ //如果必须答题，查找答题记录 if(visits.getUserAnswerId() == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请先按要求进行安全知识答题！"); } ProblemLog log = problemLogMapper.selectById(visits.getUserAnswerId()); if(log == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请先按要求进行安全知识答题."); } if(log.getLogId() !=null&&log.getStatus().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请先按要求进行安全知识答题~"); } return log; } return null; } /** * 获取申请的海康访问门禁组信息 * @param visits * @return */ private String[] getHkDeviceRoles(Visits visits,Boolean isERP) { String mustSelectDoors = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SELECT_DOORS_VISIT_REQUIRED).getCode(); if(isERP){ mustSelectDoors = Constants.ONE+""; } List roles = null; if(StringUtils.equals(mustSelectDoors,Constants.ZERO+"")){ roles = deviceRoleMapper.selectList(new QueryWrapper().lambda() .eq(DeviceRole::getIsDefault,Constants.ZERO) .eq(DeviceRole::getIsdeleted,Constants.ZERO) .eq(DeviceRole::getType,Constants.DeviceRoleType.fk)); if(roles.size() ==0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，暂不存在可访问的访客门禁，无法进行申请操作！"); } }else{ //如果必须选择门禁，但未选择 if(StringUtils.isBlank(visits.getDoors())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请选择有效访问门禁！"); } String[] dIds = visits.getDoors().split(","); roles = deviceRoleMapper.selectList(new QueryWrapper().lambda() .eq(DeviceRole::getIsdeleted,Constants.ZERO) .eq(DeviceRole::getType,Constants.DeviceRoleType.fk) .in(DeviceRole::getId, Arrays.asList(dIds))); if(roles == null || roles.size()==0 || roles.size() != dIds.length){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请选择有效访问门禁！"); } } String[] ids =new String[roles.size()]; for (int i = 0; i < roles.size(); i++) { ids[i] = roles.get(i).getHkId(); } return ids; } @Override public void deleteById(Integer id) { visitsMapper.deleteById(id); } @Override @Transactional(rollbackFor ={BusinessException.class,Exception.class}) public void deleteById(Integer id,LoginUserInfo user) { Visits model = visitsMapper.selectById(id); if(model ==null || Constants.equalsInteger(model.getIsdeleted(),Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } Date date = new Date(); visitsMapper.update(null,new UpdateWrapper().lambda() .set(Visits::getIsdeleted,Constants.ONE) .set(Visits::getEditDate,new Date()) .set(Visits::getEditor,user.getId()) .eq(Visits::getId,id)); String[] params = new String[3]; params[0] = user.getRealname(); params[1]=DateUtil.getPlusTime2(date); if(Constants.equalsInteger(model.getType(),Constants.TWO)){ params[2]="【车牌号："+model.getCarNos()+"】-【单位："+model.getCompanyName()+" "+model.getName()+" "+model.getPhone()+"】-【时间："+DateUtil.getPlusTime2(model.getStarttime())+"-"+DateUtil.getPlusTime2(model.getEndtime())+"】"; //记录删除访客报备日志 UserActionServiceImpl.saveUserActionBiz(user,id,Constants.UserActionType.VISIT_CAR_DEL,userActionMapper,date,params, JSONObject.toJSONString(model)); }else{ params[2]="【单位："+model.getCompanyName()+"】-【访客："+model.getName()+" "+model.getPhone()+"】-【时间："+DateUtil.getPlusTime2(model.getStarttime())+"-"+DateUtil.getPlusTime2(model.getEndtime())+"】"; //记录删除访客申请日志 UserActionServiceImpl.saveUserActionBiz(user,id,Constants.UserActionType.VISIT_DEL,userActionMapper,date,params, JSONObject.toJSONString(model)); } } @Override public void delete(Visits visits) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(visits); visitsMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } visitsMapper.deleteBatchIds(ids); } @Override public void updateById(Visits visits) { visitsMapper.updateById(visits); } @Override public void updateByIdInBatch(List visitss) { if (CollectionUtils.isEmpty(visitss)) { return; } for (Visits visits: visitss) { this.updateById(visits); } } @Override public Visits findById(Integer id,Integer memberId) { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Visits.class); queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName); queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment); queryWrapper.select("t3.name",Visits::getCreateMemberName); queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getErpId,Member::getErpOrgId); queryWrapper.leftJoin("Member t3 on t.CREATE_MEMBER_ID=t3.id"); queryWrapper.eq(Visits::getId,id); queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); Visits result = visitsJoinMapper.selectJoinOne(Visits.class,queryWrapper); if(result!=null){ if(StringUtils.isNotBlank(result.getDoors())){ String[] doorList=result.getDoors().split(","); MPJLambdaWrapper deviceQuery = new MPJLambdaWrapper<>(); deviceQuery.in(DeviceRole::getId,doorList); List deviceRoleList= deviceRoleMapper.selectList(deviceQuery); result.setDeviceRoleList(deviceRoleList); } }else{ throw new BusinessException(ResponseStatus.DATA_EMPTY); } MPJLambdaWrapper visitQuery = new MPJLambdaWrapper<>(); visitQuery.selectAll(Visits.class); visitQuery.eq(Visits::getParentId,result.getId()); visitQuery.isNotNull(Visits::getParentId); visitQuery.eq(Visits::getIsdeleted,Constants.ZERO); List visitsList = visitsJoinMapper.selectList(visitQuery); Visits v = new Visits(); BeanUtils.copyProperties(result,v); visitsList.add(0,v); result.setWithUserList(visitsList); result.setPrefixUrl(systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode()); result.setApproveDateVO( approveService.arrangeApprovedData(id, result.getType(), memberId) ); if(Constants.equalsInteger(result.getStatus(),Constants.VisitStatus.xfSuccess) || Constants.equalsInteger(result.getStatus(),Constants.VisitStatus.xfFail) || Constants.equalsInteger(result.getStatus(),Constants.VisitStatus.signin) || Constants.equalsInteger(result.getStatus(),Constants.VisitStatus.signout) || Constants.equalsInteger(result.getStatus(),Constants.VisitStatus.invalid)){ result.setBusinessStatus(Constants.VisitStatus.pass); }else{ result.setBusinessStatus(result.getStatus()); } Notices notices = noticesJoinMapper.selectOne(new QueryWrapper().lambda() .eq(Notices::getObjId,id) .eq(Notices::getType,Constants.equalsInteger(result.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) .eq(Notices::getUserId,memberId) .eq(Notices::getSendacopy,Constants.ZERO) .orderByDesc(Notices::getId).last(" limit 1 ")); if(Objects.nonNull(notices)){ if(Constants.equalsInteger(notices.getStatus(),Constants.ZERO)){ result.setInfo("待我处理"); }else{ result.setInfo(notices.getInfo()); } } return result; } @Override public Visits findOne(Visits visits) { QueryWrapper wrapper = new QueryWrapper<>(visits); return visitsMapper.selectOne(wrapper); } @Override public List findList(Visits visits) { QueryWrapper wrapper = new QueryWrapper<>(visits); return visitsMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Visits.class); queryWrapper.select(" ( select count(distinct(v.CAR_NOS)) from visits v where v.PARENT_ID = t.ID and v.CAR_NOS is not null and v.CAR_NOS != '' and v.CAR_NOS != t.CAR_NOS ) as carNum "); queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName); queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment); queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); //数据权限开始--------------------start---------------- LoginUserInfo userInfo =pageWrap.getModel().getLoginUserInfo(); if(userInfo!=null && userInfo.getCompanyIdList()!=null){ if( userInfo.getCompanyIdList().size() ==0){ //只能看自己(拜访人） queryWrapper.eq(Member::getId,userInfo.getMemberId()); }else{ queryWrapper.in(Company::getId ,userInfo.getCompanyIdList()); } } //数据权限开始--------------------end---------------- queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getType())&&Constants.equalsInteger(pageWrap.getModel().getType(),Constants.TWO),Visits::getType,pageWrap.getModel().getType()); queryWrapper.ne(Objects.nonNull(pageWrap.getModel().getType())&&!Constants.equalsInteger(pageWrap.getModel().getType(),Constants.TWO),Visits::getType,Constants.TWO); queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getOpenid()),Visits::getOpenid,pageWrap.getModel().getOpenid()); queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getCarNos()),Visits::getCarNos,pageWrap.getModel().getCarNos()); // queryWrapper.eq(StringUtils.isBlank(pageWrap.getModel().getOpenid()),"1","2"); queryWrapper.and(StringUtils.isNotBlank(pageWrap.getModel().getName()),ms->ms.like(Visits::getName,pageWrap.getModel().getName()) .or().like(Visits::getPhone,pageWrap.getModel().getName())) .eq(StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()),Visits::getIdcardNo,DESUtil.encrypt(Constants.EDS_PWD, pageWrap.getModel().getIdcardNo())) .eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),Visits::getCompanyName,pageWrap.getModel().getCompanyName()) .eq(Objects.nonNull(pageWrap.getModel().getStatus()),Visits::getStatus,pageWrap.getModel().getStatus()); queryWrapper.isNull(Visits::getParentId); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getMemberId()),Visits::getMemberId,pageWrap.getModel().getMemberId()); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getReceptMemberId()),Visits::getReceptMemberId,pageWrap.getModel().getReceptMemberId()); if(Objects.nonNull(pageWrap.getModel().getBusinessStatus())){ if(Constants.equalsInteger(pageWrap.getModel().getBusinessStatus(),Constants.TWO)){ queryWrapper.in(Visits::getStatus, Constants.VisitStatus.xfSuccess, Constants.VisitStatus.xfFail, Constants.VisitStatus.signin, Constants.VisitStatus.signout, Constants.VisitStatus.invalid, Constants.VisitStatus.pass ); }else{ queryWrapper.eq(Visits::getStatus,pageWrap.getModel().getBusinessStatus()); } } queryWrapper.orderByDesc(Visits::getCreateDate); IPage result = visitsJoinMapper.selectJoinPage(page, Visits.class,queryWrapper); for (Visits visits:result.getRecords()) { if(StringUtils.isNotBlank(visits.getCarNos())){ visits.setCarNum(visits.getCarNum() + Constants.ONE); } } return PageData.from(result); } @Override public long count(Visits visits) { QueryWrapper wrapper = new QueryWrapper<>(visits); return visitsMapper.selectCount(wrapper); } public static PageData retentionPageBiz(PageWrap pageWrap, VisitsJoinMapper visitsJoinMapper,SystemDictDataBiz systemDictDataBiz) { String code= systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_WARNING).getCode(); IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Visits.class); queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName); queryWrapper.select("TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) AS timeOut"); queryWrapper.selectAs(Member::getType,Visits::getMemberType); queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment); queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); queryWrapper.leftJoin(" member m on m.id= t.MEMBER_ID"); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getLevelStatus()),Visits::getStatus,Constants.VisitStatus.signin); queryWrapper.apply(Objects.nonNull(pageWrap.getModel().getLevelStatus())," TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) <= "+code+" "); queryWrapper.ne("m.type ",Constants.TWO); queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getType()),Visits::getType,pageWrap.getModel().getType()); queryWrapper.and(StringUtils.isNotBlank(pageWrap.getModel().getName()),ms->ms.like(Visits::getPhone,pageWrap.getModel().getName()) .or().like(Visits::getName,pageWrap.getModel().getName())); queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()),Visits::getIdcardNo,StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo())); queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),Visits::getCompanyName,pageWrap.getModel().getCompanyName()); queryWrapper.orderByDesc(Visits::getEditDate); IPage result = visitsJoinMapper.selectJoinPage(page, Visits.class,queryWrapper); if(result!=null&&result.getRecords()!=null){ result.getRecords().stream().forEach(s ->{ if(s.getStatus().equals(Constants.VisitStatus.signin)){ if(s.getTimeOut()<=Integer.valueOf(code)&&s.getTimeOut()>=0){ s.setOutStatus(Constants.TWO); }else if(s.getTimeOut()>Constants.ZERO){ s.setOutStatus(Constants.ZERO); }else{ s.setOutStatus(Constants.ONE); } } }); } return PageData.from(result); } @Override public PageData retentionPage(PageWrap pageWrap) { return retentionPageBiz(pageWrap,visitsJoinMapper,systemDictDataBiz); } @Override public VisitDetailVO getVisitDetail(Integer id,Integer memberId){ Visits visits = visitsMapper.selectById(id); if(Objects.isNull(visits) || Constants.equalsInteger(visits.getIsdeleted(),Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } Member member = memberMapper.selectById(visits.getReceptMemberId()); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到被访员工信息"); } VisitDetailVO visitDetailVO = new VisitDetailVO(); visitDetailVO.setCreateTime(visits.getCreateDate()); visitDetailVO.setStatus(visits.getStatus()); if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess) || Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfFail) || Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.signin) || Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.signout) || Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.invalid)){ visitDetailVO.setBusinessStatus(Constants.VisitStatus.pass); }else{ visitDetailVO.setBusinessStatus(visits.getStatus()); } visitDetailVO.setCarNos(visits.getCarNos()); visitDetailVO.setPhone(visits.getPhone()); visitDetailVO.setVisitUserName(member.getName()); visitDetailVO.setVisitReason(visits.getReason()); visitDetailVO.setQrcode(visits.getQrcode()); visitDetailVO.setIdcardType(visits.getIdcardType()); visitDetailVO.setVisitTime(DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm") + " 至 " + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm") ); //被访人员部门 Company company = companyMapper.selectById(member.getCompanyId()); if(!Objects.isNull(company)){ visitDetailVO.setVisitUserCompany(company.getName()); } visitDetailVO.setName(visits.getName()); visitDetailVO.setCompanyName(visits.getCompanyName()); visitDetailVO.setFaceImg(visits.getFaceImg()); visitDetailVO.setType(visits.getType()); visitDetailVO.setConstructionReason(visits.getConstructionReason()); visitDetailVO.setImgUrl(visits.getImgurl()); visitDetailVO.setIdCardDecode(visits.getIdcardDecode()); visitDetailVO.setFaceImg(visits.getFaceImg()); visitDetailVO.setPrefix(systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode()); if(StringUtils.isNotBlank(visits.getDoors())){ List deviceRoleList = deviceRoleMapper.selectList(new QueryWrapper().lambda() .select(DeviceRole::getName) .eq(DeviceRole::getIsdeleted,Constants.ZERO) .in(DeviceRole::getId,visits.getDoors().split(","))); if(CollectionUtils.isNotEmpty(deviceRoleList)){ visitDetailVO.setDoorGroupName( deviceRoleList.stream().map(m->m.getName()).collect(Collectors.toList()) ); } } visitDetailVO.setWithVisitsList( visitsMapper.selectList(new QueryWrapper().lambda() .select(Visits::getName,Visits::getPhone,Visits::getQrcode,Visits::getFaceImg,Visits::getImgurl,Visits::getIdcardDecode,Visits::getStatus) .eq(Visits::getParentId,id))); // if(Objects.nonNull(memberId)){ visitDetailVO.setApproveDateVO( approveService.arrangeApprovedData(id, visits.getType(), memberId) ); // } Notices notices = noticesJoinMapper.selectOne(new QueryWrapper().lambda() .eq(Notices::getObjId,id) .eq(Notices::getType,Constants.equalsInteger(visits.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) .eq(Notices::getUserId,memberId) .eq(Notices::getSendacopy,Constants.ZERO) .orderByDesc(Notices::getId).last(" limit 1 ")); if(Objects.nonNull(notices)){ if(Constants.equalsInteger(notices.getStatus(),Constants.ZERO)){ visitDetailVO.setInfo("待我处理"); }else{ visitDetailVO.setInfo(notices.getInfo()); } } return visitDetailVO; } @Override public PageData taskCenter(PageWrap param) { VisitRecordDTO visitRecordDTO = param.getModel(); IPage page = new Page<>(param.getPage(), param.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(visitRecordDTO); queryWrapper.selectAs(Visits::getId,VisitRecordVO::getId); queryWrapper.selectAs(Visits::getName,VisitRecordVO::getName); queryWrapper.selectAs(Visits::getStarttime,VisitRecordVO::getStartTime); queryWrapper.selectAs(Visits::getEndtime,VisitRecordVO::getEndTime); queryWrapper.selectAs(Visits::getReason,VisitRecordVO::getReason); queryWrapper.selectAs(Visits::getMemberNum,VisitRecordVO::getInNum); queryWrapper.selectAs(Visits::getCreateDate,VisitRecordVO::getCreateDate); queryWrapper.leftJoin(Approve.class,Approve::getId,Visits::getId); if(!Objects.isNull(visitRecordDTO)){ queryWrapper.like(StringUtils.isNotBlank(visitRecordDTO.getName()),Visits::getName,visitRecordDTO.getName()); queryWrapper.le(!Objects.isNull(visitRecordDTO.getCreateTimeS()),Visits::getCreateDate,visitRecordDTO.getCreateTimeS()); queryWrapper.ge(!Objects.isNull(visitRecordDTO.getCreateTimeE()),Visits::getCreateDate,visitRecordDTO.getCreateTimeE()); queryWrapper.eq(!Objects.isNull(visitRecordDTO.getType()),Visits::getType,visitRecordDTO.getType()); if(!Objects.isNull(visitRecordDTO.getState())&&visitRecordDTO.getState() result = visitsJoinMapper.selectJoinPage(page, VisitRecordVO.class,queryWrapper); return PageData.from(result); } @Override public void visitLevel(Integer visitId){ Visits visits = visitsMapper.selectById(visitId); if(Objects.isNull(visits)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!visits.getStatus().equals(Constants.VisitStatus.signin)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"仅支持【拜访中】状态进行该离场操作，请刷新重试"); } VisitAppointmentOutRequest request = new VisitAppointmentOutRequest(); request.setOrderId(visits.getHkId()); //调用海康强制签离 BaseResponse response = HKService.iccmSignoff(request); // BaseResponse response = HKService.outVisitAppiontment(request); visitsMapper.update(null,new UpdateWrapper().lambda().set(Visits::getStatus,Constants.VisitStatus.signout) .eq(Visits::getId,visitId)); //产出在场人员信息 retentionMapper.delete(new UpdateWrapper().lambda() .eq(Retention::getType,Constants.memberType.visitor) .eq(Retention::getMemberId,visits.getMemberId())); } @Override public void visitCancel(Integer visitId){ Visits visits = visitsMapper.selectById(visitId); if(Objects.isNull(visits)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!visits.getStatus().equals(Constants.VisitStatus.xfSuccess)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客记录状态错误，请刷新重试"); } VisitAppointmentCancelRequest request = new VisitAppointmentCancelRequest(); request.setAppointRecordIds(new String[]{visits.getHkId()}); //调用海康强制签离 // BaseResponse response = HKService.outVisitAppiontment(request); BaseResponse response = HKService.iccmCancelAppointment(request); visitsMapper.update(null,new UpdateWrapper().lambda().set(Visits::getStatus,Constants.VisitStatus.signout) .eq(Visits::getId,visitId)); //产出在场人员信息 retentionMapper.delete(new UpdateWrapper().lambda() .eq(Retention::getType,Constants.memberType.visitor) .eq(Retention::getMemberId,visits.getMemberId())); } @Override public void visitsSelfCancel(Integer visitId,Integer memberId){ Visits visits = visitsMapper.selectById(visitId); if(Objects.isNull(visits)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!(Constants.equalsInteger(memberId,visits.getMemberId()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无此操作权限"); } this.visitsCancelBiz(visits); } @Override public void visitsCancel(Integer visitId,LoginUserInfo loginUserInfo) { Visits visits = visitsMapper.selectById(visitId); if (Objects.isNull(visits)) { throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!( CollectionUtils.isNotEmpty(loginUserInfo.getPermissions()) && loginUserInfo.getPermissions().stream().filter(i->i.equals("business:visits:cancel")).collect(Collectors.toList()).size()>0)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无此操作权限"); } this.visitsCancelBiz(visits); } /** * 处理待审核、审核中、已审核的数据取消业务 * 2025年3月25日14:10:10 */ public void visitsCancelBiz(Visits visits){ UpdateWrapper updateWrapper = new UpdateWrapper(); updateWrapper.lambda().set(Visits::getStatus,Constants.VisitStatus.cancel) .set(Visits::getEditDate,DateUtil.getCurrDateTime()) .set(Visits::getEditor,visits.getEditor()) .eq(Visits::getId,visits.getId()); //访客报备 if(Constants.equalsInteger(visits.getType(),Constants.TWO)){ if(!(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)||Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck) || Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客记录状态错误，无法进行该操作"); } if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass) && Constants.equalsInteger(visits.getHkStatus(),Constants.ONE) &&StringUtils.isNotBlank(visits.getCarNos())){ //取消停车场预约 List visitParkList = visitParkMapper.selectList(new QueryWrapper().lambda() .eq(VisitPark::getCarCode,visits.getCarNos()) .eq(VisitPark::getObjType,Constants.ONE) .eq(VisitPark::getHkStatus,Constants.ONE) .isNotNull(VisitPark::getHkId) .apply(" END_TIME > now() ") .orderByDesc(VisitPark::getCreateDate) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(visitParkList)){ for (VisitPark visitPark:visitParkList) { ParkReservationDelRequest param = new ParkReservationDelRequest(); param.setReserveOrderNo(visitPark.getHkId()); BaseResponse response = HKService.parkReservationDeletion(param); if(response!=null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ visitPark.setHkStatus(Constants.THREE); visitPark.setIsdeleted(Constants.ONE); visitPark.setEditDate(new Date()); visitParkMapper.updateById(visitPark); }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),response.getMsg()); } } updateWrapper.lambda().set(Visits::getHkStatus,Constants.ZERO).set(Visits::getHkDate,DateUtil.getCurrDateTime()); } } }else{ //访客申请 if(!(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)||Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck) || Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass)|| Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客记录状态错误，请刷新重试"); } if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess) && Constants.equalsInteger(visits.getHkStatus(),Constants.ONE) &&StringUtils.isNotBlank(visits.getHkRecordId())){ VisitAppointmentCancelRequest request = new VisitAppointmentCancelRequest(); request.setAppointRecordIds(new String[]{visits.getHkRecordId()}); BaseResponse response = HKService.iccmCancelAppointment(request); if(response==null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) || response.getData()==null){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),response.getMsg()); } updateWrapper.lambda().set(Visits::getHkStatus,Constants.ZERO).set(Visits::getHkDate,DateUtil.getCurrDateTime()); } } if(Constants.equalsInteger(visits.getStatus(),Constants.ZERO)||Constants.equalsInteger(visits.getStatus(),Constants.ONE)){ //更新审批中的记录为取消 approveMapper.update(null, new UpdateWrapper().lambda() .set(Approve::getEditDate,new Date()) .set(Approve::getStatus,Constants.approveStatus.cancel) .set(Approve::getStatusInfo,"手动取消") .set(Approve::getCheckInfo,"手动取消") .eq(Approve::getIsdeleted,Constants.ZERO) .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait) .eq(Approve::getObjId,visits.getId()) .eq(Approve::getObjType,visits.getType())); //更新待办消息状态 noticesJoinMapper.update(null, new UpdateWrapper().lambda() .set(Notices::getEditDate,new Date()) .set(Notices::getInfo,"手动取消") .setSql(" param4 = user_id ") .set(Notices::getStatus,Constants.ONE) .set(Notices::getParam2,Constants.ONE)//标记已处理 .eq(Notices::getStatus,Constants.ZERO) .eq(Notices::getParam2,Constants.ZERO)//待处理 .eq(Notices::getObjId,visits.getId()) .eq(Notices::getObjType,!Constants.equalsInteger(visits.getType(),Constants.TWO)? Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting) ); Approve approve = new Approve(); approve.setCreateDate(new Date()); approve.setIsdeleted(Constants.ZERO); approve.setRemark("手动取消"); approve.setChekorId(visits.getEditor()); approve.setTitle("取消预约"); approve.setStatus(Constants.THREE); approve.setStatusInfo("手动取消"); approve.setObjId(visits.getId()); approve.setLevel(9999); approve.setApproveType(2); approve.setDriverParam(Constants.ZERO); approve.setAddrParam(Constants.ZERO); approve.setObjType(visits.getType()); approve.setType(Constants.ZERO); approve.setCheckDate(new Date()); approveMapper.insert(approve); } visitsMapper.update(null,updateWrapper); } @Override public void visitResend(Integer visitId) { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Visits.class); queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName) .selectAs(Member::getHkId,Visits::getReceptMemberHkId) .leftJoin(Member.class,Member::getId,Visits::getReceptMemberId) .eq(Visits::getId,visitId)//未同步到海康 .last("limit 1"); Visits visits = visitsMapper.selectJoinOne(Visits.class,queryWrapper); if(Objects.isNull(visits)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!visits.getStatus().equals(Constants.VisitStatus.xfFail)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客记录状态错误，请刷新重试"); } List roleList = deviceRoleMapper.selectList(new QueryWrapper().lambda() .eq(DeviceRole::getType, Constants.ONE)); String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); HkSyncVisitServiceImpl.getUpdateModelByResponseIccm(visits,new Date(),roleList,path); if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess)){ //如果下发成功， visitsMapper.updateById(visits); }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"重新下发会失败！"); } } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void resetPassword(ResetPasswordDTO resetPasswordDTO){ if(Objects.isNull(resetPasswordDTO) || StringUtils.isBlank(resetPasswordDTO.getPassword()) || StringUtils.isBlank(resetPasswordDTO.getValidCode()) || StringUtils.isBlank(resetPasswordDTO.getPhone())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper().lambda().eq(SystemUser::getMobile,resetPasswordDTO.getPhone()).eq(SystemUser::getDeleted,Constants.ZERO).last(" limit 1")); if(Objects.isNull(systemUser)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到手机号所属账户"); } smsEmailService.validateCode(resetPasswordDTO.getValidCode(),resetPasswordDTO.getPhone()); ResetSystemUserPwdDTO dto = new ResetSystemUserPwdDTO(); dto.setPassword(resetPasswordDTO.getPassword()); dto.setId(systemUser.getId()); dto.setOperaUserId(systemUser.getId()); dto.setNeedChangePwd(Constants.ONE); systemUserBiz.resetPwd(dto); } /** * * @param queryType 查询类型：1=在园人数；2=报表数据；3=待办事项；4=超时预警 * @param loginUserInfo * @return */ @Override public PCWorkPlatformDataVO getPcWorkPlatformData(Integer queryType ,LoginUserInfo loginUserInfo){ PCWorkPlatformDataVO pcWorkPlatformDataVO = new PCWorkPlatformDataVO(); if(Constants.equalsInteger(queryType,Constants.ONE)){ List retentionList = retentionMapper.selectJoinList(Retention.class, new MPJLambdaWrapper() .selectAll(Retention.class) .selectAs(Company::getType,Retention::getCompanyType) .leftJoin(Company.class,Company::getId,Retention::getCompanyId) .eq(Retention::getIsdeleted,Constants.ZERO) ); InoutDayCount inoutDayCount = inoutDayCountMapper.selectOne(new QueryWrapper() .lambda() .apply(" DATE(TIME_INFO) = CURDATE() ") .last(" limit 1 ") ); //今日在园人数 pcWorkPlatformDataVO.setTodayInParkUserNum( retentionList.stream().filter(i->!Constants.equalsInteger(i.getType(),Constants.THREE)).count() ); pcWorkPlatformDataVO.setTodayInUserNum(Constants.ZERO); pcWorkPlatformDataVO.setTodayOutUserNum(Constants.ZERO); //在园长期相关方人数 pcWorkPlatformDataVO.setInParkLwUserNum( retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) && Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count() ); pcWorkPlatformDataVO.setLwUserInNum(Constants.ZERO); pcWorkPlatformDataVO.setLwUserOutNum(Constants.ZERO); //在园访客数量 pcWorkPlatformDataVO.setInParkVisitUserNum( retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)&&Objects.isNull(i.getCompanyType())).count() ); pcWorkPlatformDataVO.setVisitUserNum(Constants.ZERO); pcWorkPlatformDataVO.setSignLevelNum(Constants.ZERO); //在园车辆 pcWorkPlatformDataVO.setTodayInParkCarNum( retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).count() ); pcWorkPlatformDataVO.setTodayInCarNum(Constants.ZERO); pcWorkPlatformDataVO.setTodayOutCarNum(Constants.ZERO); if(Objects.nonNull(inoutDayCount)){ //相关方 pcWorkPlatformDataVO.setLwUserInNum(inoutDayCount.getInOtherMemberNum()); pcWorkPlatformDataVO.setLwUserOutNum(inoutDayCount.getOutOtherMemberNum()); //访客 pcWorkPlatformDataVO.setVisitUserNum(inoutDayCount.getInVisitorNum()); pcWorkPlatformDataVO.setSignLevelNum(inoutDayCount.getOutVisitorNum()); //车辆 pcWorkPlatformDataVO.setTodayInCarNum(inoutDayCount.getInCarNum()); pcWorkPlatformDataVO.setTodayOutCarNum(inoutDayCount.getOutCarNum()); //总人数 pcWorkPlatformDataVO.setTodayInUserNum(pcWorkPlatformDataVO.getLwUserInNum() + pcWorkPlatformDataVO.getVisitUserNum() + inoutDayCount.getInSelfMemberNum() ); pcWorkPlatformDataVO.setTodayOutUserNum(pcWorkPlatformDataVO.getLwUserOutNum() + pcWorkPlatformDataVO.getSignLevelNum() + inoutDayCount.getOutSelfMemberNum() ); } }else if(Constants.equalsInteger(queryType,Constants.TWO)){ List weekDays = DateUtil.getBeforDays(new Date(),7); List weekVisitList = new ArrayList<>(); List weekCarList = new ArrayList<>(); List lwList = new ArrayList<>(); //查询七天前的访客记录数量 List visitsList = visitsMapper.selectList(new QueryWrapper().lambda().in(Visits::getStatus, Constants.VisitStatus.signin,Constants.VisitStatus.signout) .apply(" STARTTIME > CURDATE() - INTERVAL 7 DAY " ) ); List carEventList = carEventMapper.selectList(new QueryWrapper().lambda() .in(CarEvent::getEventType,"771760131","771760130") .apply(" STR_TO_DATE(happen_time, '%Y-%m-%dT%H:%i:%s') > CURDATE() - INTERVAL 7 DAY " ) ); for (String days:weekDays) { InterestedListVO visitVO = new InterestedListVO(); visitVO.setName(days); if(CollectionUtils.isNotEmpty(visitsList)){ //处理访客人员数量 List daysList = visitsList.stream().filter(i->Objects.nonNull(i.getStarttime())&&DateUtil.dateToString(i.getStarttime(),"yyyy-MM-dd").equals(days)).collect(Collectors.toList()); List memberIds = daysList.stream().map(i->i.getMemberId().toString()).collect(Collectors.toList()); if(CollectionUtils.isNotEmpty(memberIds)){ visitVO.setNum(new HashSet(memberIds).size()); } } if(Objects.isNull(visitVO.getNum())){ visitVO.setNum(Constants.ZERO); } visitVO.setName(days); InterestedListVO carVO = new InterestedListVO(); carVO.setName(days); if(CollectionUtils.isNotEmpty(carEventList)){ //处理访客人员数量 List daysList = carEventList.stream().filter(i->StringUtils.isNotBlank(i.getHappenTime()) && i.getHappenTime().substring(0,10).equals(days)).collect(Collectors.toList()); List carCodeList = daysList.stream().map(i->i.getPlateNos()).collect(Collectors.toList()); if(CollectionUtils.isNotEmpty(carCodeList)){ carVO.setNum(new HashSet(carCodeList).size()); } } if(Objects.isNull(carVO.getNum())){ visitVO.setNum(Constants.ZERO); } weekVisitList.add(visitVO); weekCarList.add(carVO); } pcWorkPlatformDataVO.setWeekVisitList(weekVisitList ); pcWorkPlatformDataVO.setWeekCarList(weekCarList); List companyList = companyMapper.selectList(new QueryWrapper().lambda() .eq(Company::getType,Constants.ZERO) .eq(Company::getIsdeleted,Constants.ZERO) ); if(CollectionUtils.isNotEmpty(companyList)){ List companyIds = companyList.stream().map(i->i.getId()).collect(Collectors.toList()); List retentionList = retentionMapper.selectList( new QueryWrapper().lambda() .eq(Retention::getType,Constants.TWO) .in(Retention::getCompanyId,companyIds) ); for (Company company:companyList) { Integer count = retentionList.stream().filter(i->Constants.equalsInteger(i.getCompanyId(),company.getId())).collect(Collectors.toList()).size(); if(count>0){ InterestedListVO lw = new InterestedListVO(); lw.setNum(count); lw.setName(company.getName()); lwList.add(lw); } } } pcWorkPlatformDataVO.setLwList(lwList ); }else if(Constants.equalsInteger(queryType,Constants.THREE)) { if (Objects.isNull(loginUserInfo.getMemberId())) { pcWorkPlatformDataVO.setNoticesList(new ArrayList<>()); pcWorkPlatformDataVO.setNoticesNum(0); // queryWrapper.eq("1", "2"); } else { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Notices.class); queryWrapper.eq(Notices::getStatus, Constants.ZERO); queryWrapper.eq(Notices::getSendacopy, Constants.ZERO); queryWrapper.eq(Notices::getParam2, Constants.ZERO); queryWrapper.eq(Notices::getUserId, loginUserInfo.getMemberId()); queryWrapper.orderByDesc(Notices::getCreateDate); List noticesList = noticesJoinMapper.selectList(queryWrapper); pcWorkPlatformDataVO.setNoticesList(noticesList); pcWorkPlatformDataVO.setNoticesNum(noticesList.size()); if(noticesList.size() > 5 ){ pcWorkPlatformDataVO.setNoticesList(noticesList.subList(0,5)); }else{ pcWorkPlatformDataVO.setNoticesList(noticesList); } } }else{ String code= systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_WARNING).getCode(); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Visits.class); queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName); queryWrapper.select("TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) AS timeOut"); queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment); queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); queryWrapper.leftJoin(" member m on m.id= t.MEMBER_ID"); queryWrapper.eq(Visits::getStatus,Constants.VisitStatus.signin); queryWrapper.apply(" TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) <= "+code+" "); queryWrapper.ne("m.type ",Constants.TWO); queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); queryWrapper.orderByDesc(Visits::getEditDate); List result = visitsJoinMapper.selectList(queryWrapper); if(result!=null&&result!=null){ result.stream().forEach(s ->{ if(s.getStatus().equals(Constants.VisitStatus.signin)){ if(s.getTimeOut()<=Integer.valueOf(code)&&s.getTimeOut()>=0){ s.setOutStatus(Constants.TWO); }else if(s.getTimeOut()>Constants.ZERO){ s.setOutStatus(Constants.ZERO); }else{ s.setOutStatus(Constants.ONE); } } }); } pcWorkPlatformDataVO.setTimeOutVisitNum(result.size()); if(result.size() > 3 ){ pcWorkPlatformDataVO.setTimeOutVisitList(result.subList(0,3)); }else{ pcWorkPlatformDataVO.setTimeOutVisitList(result); } } return pcWorkPlatformDataVO; } @Override public void syncTimeOutData(){ String times = systemDictDataBiz.queryByCode(Constants.VISIT_CONFIG,Constants.TIME_OUT_CONFIG).getCode(); List visitsList = visitsMapper.selectList(new QueryWrapper().lambda() .eq(Visits::getStatus,Constants.VisitStatus.signin) .eq(Visits::getSendTimeOutNotice,Constants.ZERO) .eq(Visits::getIsdeleted,Constants.ZERO) .apply(" now() >= DATE_ADD(ENDTIME,INTERVAL -"+times+" MINUTE) ") ); Integer visitTimeCount = 0; Integer visitReportTimeCount = 0; for (Visits visits:visitsList) { if(Constants.equalsInteger(visits.getType(),Constants.TWO)){ SmsEmailServiceImpl.sendVisitReportSms(systemDictDataBiz, emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), SmsConstants.visitReportingContent.visitReportingTimeOutSignOut, null,Arrays.asList(visits.getPhone().split(",")) ); visitReportTimeCount = visitReportTimeCount + 1; }else{ SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), SmsConstants.visitContent.visitTimeOutSignOut, null,Arrays.asList(visits.getPhone().split(",")) ); visitTimeCount = visitTimeCount + 1 ; } visits.setSendTimeOutNotice(Constants.ONE); visitsMapper.updateById(visits); } if(visitTimeCount > 0 ){ String mobile = systemDictDataBiz.queryByCode(Constants.VISIT_CONFIG,Constants.VISIT_TIME_OUT_MOBILE).getCode(); if(StringUtils.isNotBlank(mobile)){ SmsEmailServiceImpl.sendVisitTimeOutSms(systemDictDataBiz, emayService,smsEmailMapper,smsConfigMapper, SmsConstants.visitContent.visitTimeOutSignOutNum, visitTimeCount.toString(),Arrays.asList(mobile.split(",")) ); } } if(visitReportTimeCount > 0 ){ String mobile = systemDictDataBiz.queryByCode(Constants.VISIT_CONFIG,Constants.VISIT_REPORT_TIME_OUT_MOBILE).getCode(); if(StringUtils.isNotBlank(mobile)){ SmsEmailServiceImpl.sendVisitReportTimeOutSms(systemDictDataBiz, emayService,smsEmailMapper,smsConfigMapper, SmsConstants.visitReportingContent.visitReportingTimeOutSignOutNum, visitReportTimeCount.toString(),Arrays.asList(mobile.split(",")) ); } } } @Override public void visitNoCheckCancel(){ log.info("===============待审批记录超时自动取消预约===========start======="); List visitsList = visitsMapper.selectList(new QueryWrapper().lambda() .eq(Visits::getIsdeleted,Constants.ZERO) .eq(Visits::getStatus,Constants.VisitStatus.waitCheck) .apply(" now() >= ENDTIME ") ); if(visitsList!=null){ Date date =new Date(); for(Visits s :visitsList){ dealAutoCancelBiz(s,date); } } log.info("===============待审批记录超时自动取消预约===========end======="); } @Transactional private void dealAutoCancelBiz(Visits s, Date date) { visitsMapper.update(null,new UpdateWrapper().lambda() .set(Visits::getStatus,Constants.VisitStatus.cancel) .set(Visits::getEditDate,date) .set(Visits::getRemark,"预约截止时间已过未审批，系统自动取消") .eq(Visits::getId,s.getId())); VisitsServiceImpl.dealCancelNoticesData(noticesJoinMapper,approveMapper,"系统取消",s.getId(), s.getType(), !Constants.equalsInteger(s.getType(),Constants.TWO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting ); Approve approve = new Approve(); approve.setCreateDate(new Date()); approve.setIsdeleted(Constants.ZERO); approve.setRemark("系统自动取消"); approve.setTitle("取消预约"); approve.setStatus(Constants.THREE); approve.setStatusInfo("超时自动取消"); approve.setObjId(s.getId()); approve.setLevel(9999); approve.setApproveType(2); approve.setDriverParam(Constants.ZERO); approve.setAddrParam(Constants.ZERO); approve.setObjType(s.getType()); approve.setType(Constants.ZERO); approve.setCheckDate(new Date()); approveMapper.insert(approve); // //更新审批中的记录为取消 // approveMapper.update(null, // new UpdateWrapper().lambda() // .set(Approve::getEditDate,date) // .set(Approve::getStatus,Constants.approveStatus.cancel) // .set(Approve::getStatusInfo,"系统已取消") // .set(Approve::getCheckInfo,"访问时间已过，系统自动取消") // .eq(Approve::getIsdeleted,Constants.ZERO) // .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait) // .eq(Approve::getObjId,s.getId()) // .eq(Approve::getObjType,s.getType())); // //更新待办消息状态 // noticesJoinMapper.update(null, // new UpdateWrapper().lambda() // .set(Notices::getEditDate,date) // .set(Notices::getInfo,"已取消") //// .set(Notices::getStatus,Constants.ONE) // .set(Notices::getParam2,Constants.FOUR)//已取消 // .eq(Notices::getIsdeleted,Constants.ZERO) // .eq(Notices::getStatus,Constants.ZERO) // .eq(Notices::getParam2,Constants.ZERO)//待处理 // .eq(Notices::getObjId,s.getId()) // .eq(Notices::getObjType,Constants.equalsInteger(s.getType(),Constants.ZERO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting) // ); } public static void dealCancelNoticesData(NoticesJoinMapper noticesJoinMapper,ApproveMapper approveMapper,String info,Integer objId,Integer approveObjectType,Integer noticesType){ if(Objects.nonNull(approveObjectType)){ approveMapper.update(null, new UpdateWrapper().lambda() .set(Approve::getEditDate,new Date()) .set(Approve::getStatus,Constants.approveStatus.cancel) .set(Approve::getStatusInfo,info) .set(Approve::getCheckInfo,info) .eq(Approve::getIsdeleted,Constants.ZERO) .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait) .eq(Approve::getObjId,objId) .eq(Approve::getObjType,approveObjectType)); } if(Objects.nonNull(noticesType)){ //更新待办消息状态 noticesJoinMapper.update(null, new UpdateWrapper().lambda() .set(Notices::getEditDate,new Date()) .set(Notices::getInfo,"自动取消") .setSql(" param4 = user_id ") .set(Notices::getStatus,Constants.ONE) .set(Notices::getParam2,Constants.ONE)//已取消 .eq(Notices::getStatus,Constants.ZERO) .eq(Notices::getParam2,Constants.ZERO)//待处理 .eq(Notices::getObjId,objId) .eq(Notices::getObjType,noticesType) ); } } }