|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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.wx.wxPlat.WxPlatNotice; | 
|---|
|  |  |  | import com.doumee.dao.business.*; | 
|---|
|  |  |  | import com.doumee.dao.business.dao.CompanyMapper; | 
|---|
|  |  |  | 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.system.SystemUserMapper; | 
|---|
|  |  |  | import com.doumee.dao.system.dto.ResetSystemUserPwdDTO; | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SystemDictDataBiz systemDictDataBiz; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SystemUserBiz systemUserBiz; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private DeviceJoinMapper deviceJoinMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ErpTool erpTool; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private InterfaceLogService interfaceLogService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private DataSyncConfig dataSyncConfig; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SmsEmailService smsEmailService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SystemUserMapper systemUserMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ApproveService approveService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | visits.setWithUserList(visitsList); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | this.createFk(visits,true); | 
|---|
|  |  |  | this.createFk(visits,true,Constants.ONE); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Transactional(propagation = Propagation.NOT_SUPPORTED) | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) | 
|---|
|  |  |  | public Integer createFk(Visits visits,Boolean isERP) { | 
|---|
|  |  |  | public Integer createFk(Visits visits,Boolean isERP,Integer source) { | 
|---|
|  |  |  | isValidBaseParam(visits); | 
|---|
|  |  |  | //检查是否必须答题,并且符合答题要求 | 
|---|
|  |  |  | ProblemLog problemLog = isValidProblemLog(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 | 
|---|
|  |  |  | //&&!IdcardUtil.isValidCard(visits.getIdcardNo()) | 
|---|
|  |  |  | ){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,身份证号码有误,请核实后重试!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Date date = new Date(); | 
|---|
|  |  |  | //创建时间 | 
|---|
|  |  |  | visits.setCreateDate(date); | 
|---|
|  |  |  | //普通访客 | 
|---|
|  |  |  | visits.setType(Constants.ONE); | 
|---|
|  |  |  | //随行人员数量 | 
|---|
|  |  |  | visits.setMemberNum(CollectionUtils.isNotEmpty(visits.getWithUserList())?visits.getWithUserList().size():0); | 
|---|
|  |  |  | //访客信息(使用身份证号查询是否已存在改普通访客,没有则新增,存在则更新openid等信息),包括随访人员校验和处理 | 
|---|
|  |  |  | Member member =dealMemberAndVisits(visits); | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | visitsMapper.insert(visits); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //发起ERP审批申请 | 
|---|
|  |  |  | if(visits.getSourceType().equals(Constants.ZERO)){ | 
|---|
|  |  |  | if(dataSyncConfig.getVisitorDataOrigin().equals(Constants.ONE)){ | 
|---|
|  |  |  | String erpId = startSendErpCheck(visits,visitMember); | 
|---|
|  |  |  | if(StringUtils.isNotBlank(erpId)){ | 
|---|
|  |  |  | visits.setErpId(erpId); | 
|---|
|  |  |  | 
|---|
|  |  |  | wxPlatNotice.sendVisitAuditTemplateNotice(visits, | 
|---|
|  |  |  | systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_PREFIX).getCode(), | 
|---|
|  |  |  | systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_AUDIT_VISIT).getCode()); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | visits.setStatus(Constants.VisitStatus.pass); | 
|---|
|  |  |  | }else if(dataSyncConfig.getVisitorDataOrigin().equals(Constants.ZERO)){ | 
|---|
|  |  |  | visits.setStatus(Constants.VisitStatus.waitCheck); | 
|---|
|  |  |  | visitsMapper.updateById(visits); | 
|---|
|  |  |  | approveService.createApproveFlow(visits.getType(),visits.getId(),visits.getReceptMemberId()); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起,发起拜访审批申请失败!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | initWithVisitInfo(visits); | 
|---|
|  |  |  | updateProblemLog(visits,problemLog,member); | 
|---|
|  |  |  | //创建审批记录 | 
|---|
|  |  |  | //        createApprove(visits,visitMember); | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | approveService.createApproveFlow(visits.getType(),visits.getId(),visits.getReceptMemberId()); | 
|---|
|  |  |  | return visits.getId(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | approve.setIsEndCheck(Constants.ZERO); | 
|---|
|  |  |  | approve.setType(Constants.ZERO); | 
|---|
|  |  |  | approve.setLevel(Constants.ONE); | 
|---|
|  |  |  | approve.setVisitId(visits.getId()); | 
|---|
|  |  |  | approve.setObjId(visits.getId()); | 
|---|
|  |  |  | approveMapper.insert(approve); | 
|---|
|  |  |  | if(!CollectionUtils.isNotEmpty(approveIds)){ | 
|---|
|  |  |  | approve.setIsEndCheck(Constants.ONE); | 
|---|
|  |  |  | 
|---|
|  |  |  | if(approve.getStatus().equals(Constants.approveStatus.wait)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批记录已处理!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Visits visits = visitsMapper.selectById(approve.getVisitId()); | 
|---|
|  |  |  | Visits visits = visitsMapper.selectById(approve.getObjId()); | 
|---|
|  |  |  | if(Objects.isNull(visits)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if(approve.getApproveType().equals(Constants.ONE)){ | 
|---|
|  |  |  | //会签 查询是否是最后一条记录 如果是最后一条记录 则生成下级审批记录 如果是最后一级,则进行审批确认 | 
|---|
|  |  |  | if(approveMapper.selectCount(new QueryWrapper<Approve>().lambda() | 
|---|
|  |  |  | .eq(Approve::getVisitId,visits.getId()) | 
|---|
|  |  |  | .eq(Approve::getObjId,visits.getId()) | 
|---|
|  |  |  | .eq(Approve::getLevel,approve.getLevel()) | 
|---|
|  |  |  | .ne(Approve::getId,approve.getId()) | 
|---|
|  |  |  | )<=Constants.ZERO){ | 
|---|
|  |  |  | 
|---|
|  |  |  | .set(Approve::getStatus,Constants.approveStatus.otherDeal) | 
|---|
|  |  |  | .set(Approve::getEditDate,new Date()) | 
|---|
|  |  |  | .set(Approve::getCheorId,auditApproveDTO.getMemberId()) | 
|---|
|  |  |  | .eq(Approve::getVisitId,visits.getId()) | 
|---|
|  |  |  | .eq(Approve::getObjId,visits.getId()) | 
|---|
|  |  |  | .eq(Approve::getStatus,Constants.approveStatus.wait) | 
|---|
|  |  |  | .ne(Approve::getId,approve.getId()) | 
|---|
|  |  |  | .eq(Approve::getLevel,approve.getLevel()) | 
|---|
|  |  |  | 
|---|
|  |  |  | .set(Approve::getStatus,Constants.approveStatus.otherDeal) | 
|---|
|  |  |  | .set(Approve::getEditDate,new Date()) | 
|---|
|  |  |  | .set(Approve::getCheorId,auditApproveDTO.getMemberId()) | 
|---|
|  |  |  | .eq(Approve::getVisitId,visits.getId()) | 
|---|
|  |  |  | .eq(Approve::getObjId,visits.getId()) | 
|---|
|  |  |  | .eq(Approve::getStatus,Constants.approveStatus.wait) | 
|---|
|  |  |  | .ne(Approve::getId,approve.getId()) | 
|---|
|  |  |  | .eq(Approve::getLevel,approve.getLevel()) | 
|---|
|  |  |  | 
|---|
|  |  |  | approve.setTemplatId(approveParam.getId()); | 
|---|
|  |  |  | approve.setChekorId(Integer.valueOf(id)); | 
|---|
|  |  |  | approve.setType(Constants.ONE); | 
|---|
|  |  |  | approve.setVisitId(visitId); | 
|---|
|  |  |  | approve.setObjId(visitId); | 
|---|
|  |  |  | approveList.add(approve); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | approveMapper.insertBatchSomeColumn(approveList); | 
|---|
|  |  |  | approveMapper.insert(approveList); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | approve.setApproveType(approveParam.getApproveType()); | 
|---|
|  |  |  | approve.setChekorId(id); | 
|---|
|  |  |  | approve.setType(Constants.ONE); | 
|---|
|  |  |  | approve.setVisitId(visitId); | 
|---|
|  |  |  | approve.setObjId(visitId); | 
|---|
|  |  |  | approveList.add(approve); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | approveMapper.insertBatchSomeColumn(approveList); | 
|---|
|  |  |  | approveMapper.insert(approveList); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | .eq(ApproveParam::getMemberType,Constants.ZERO) | 
|---|
|  |  |  | .last("limit 1")); | 
|---|
|  |  |  | return  Objects.isNull(approveParam)?null:approveParam.getId(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | ||  StringUtils.isBlank( visits.getName()) | 
|---|
|  |  |  | ||  StringUtils.isBlank( visits.getPhone()) | 
|---|
|  |  |  | ||  StringUtils.isBlank( visits.getCompanyName()) | 
|---|
|  |  |  | ||  visits.getIdcardType() == null | 
|---|
|  |  |  | ||  Objects.isNull(visits.getType()) | 
|---|
|  |  |  | //                ||  StringUtils.isBlank( visits.getFaceImg() ) | 
|---|
|  |  |  | ||  StringUtils.isBlank( visits.getIdcardNo() ) | 
|---|
|  |  |  | || visits.getReceptMemberId() == null){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,信息填写不正确!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(visits.getEndtime().getTime() < System.currentTimeMillis()){ | 
|---|
|  |  |  | 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() ) ){ | 
|---|
|  |  |  | 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(), "对不起,预约结束时间必须大于开始时间!");// | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(StringUtils.isNotBlank(code)&&!StringUtils.equals(code,"0")){ | 
|---|
|  |  |  | //                Integer betweenDays = Math.toIntExact(cn.hutool.core.date.DateUtil.between(visits.getEndtime(), visits.getStarttime(), DateUnit.DAY)); | 
|---|
|  |  |  | int betweenDays = DateUtil.daysBetweenDates11(visits.getEndtime(), visits.getStarttime())+1; | 
|---|
|  |  |  | if( betweenDays > codenum){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,预约总天数不能超过["+code+"天]!"); | 
|---|
|  |  |  | 
|---|
|  |  |  | v.setSourceType(visits.getSourceType()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //批量插入数据 | 
|---|
|  |  |  | visitsMapper.insertBatchSomeColumn(visits.getWithUserList()); | 
|---|
|  |  |  | visitsMapper.insert(visits.getWithUserList()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | model.setMemberId(visitsMember.getId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //        if(CollectionUtils.isNotEmpty(addList)){ | 
|---|
|  |  |  | //            memberMapper.insertBatchSomeColumn(addList); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        if(CollectionUtils.isNotEmpty(editList)){ | 
|---|
|  |  |  | //            editList.forEach(i->{ | 
|---|
|  |  |  | //                memberMapper.updateById(i); | 
|---|
|  |  |  | //            }); | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return  m; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | if(!Constants.equalsInteger(Constants.ZERO,member.getStatus() )){ | 
|---|
|  |  |  | //如果用户状态异常,则提示 | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起,身份证号【"+cardno+"】被禁止访问申请,如有疑问,请联系您的拜访人进行核实"); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | return  member; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private ProblemLog isValidProblemLog(Visits visits) { | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 是否需要答题 | 
|---|
|  |  |  | * @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){ | 
|---|
|  |  |  | 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(), "对不起,请先按要求进行安全知识答题!"); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public Visits findById(Integer id) { | 
|---|
|  |  |  | public Visits findById(Integer id,Integer memberId) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | MPJLambdaWrapper<Visits> 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); | 
|---|
|  |  |  | Visits result = visitsJoinMapper.selectJoinOne(Visits.class,queryWrapper); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return result; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public PageData<Visits> findPage(PageWrap<Visits> pageWrap) { | 
|---|
|  |  |  | IPage<Visits> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|---|
|  |  |  | IPage<Visits> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|---|
|  |  |  | MPJLambdaWrapper<Visits> queryWrapper = new MPJLambdaWrapper<>(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | queryWrapper.selectAll(Visits.class); | 
|---|
|  |  |  | 
|---|
|  |  |  | queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); | 
|---|
|  |  |  | queryWrapper.eq(pageWrap.getModel().getType()!=null,Visits::getType,pageWrap.getModel().getType()); | 
|---|
|  |  |  | queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getType()),Visits::getType,pageWrap.getModel().getType()); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | queryWrapper.orderByDesc(Visits::getCreateDate); | 
|---|
|  |  |  | IPage<Visits> result = visitsJoinMapper.selectJoinPage(page, Visits.class,queryWrapper); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public VisitDetailVO getVisitDetail(Integer id){ | 
|---|
|  |  |  | public VisitDetailVO getVisitDetail(Integer id,Integer memberId){ | 
|---|
|  |  |  | Visits visits = visitsMapper.selectById(id); | 
|---|
|  |  |  | if(Objects.isNull(visits)){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY); | 
|---|
|  |  |  | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到被访员工信息"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | VisitDetailVO visitDetailVO = new VisitDetailVO(); | 
|---|
|  |  |  | visitDetailVO.setCreateTime(visits.getCreateDate()); | 
|---|
|  |  |  | visitDetailVO.setStatus(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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | visitDetailVO.setVisitUserCompany(company.getName()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | visitDetailVO.setName(visits.getName()); | 
|---|
|  |  |  | visitDetailVO.setCompanyName(visits.getCompanyName()); | 
|---|
|  |  |  | visitDetailVO.setFaceImg(visits.getFaceImg()); | 
|---|
|  |  |  | visitDetailVO.setImgUrl(visits.getImgurl()); | 
|---|
|  |  |  | visitDetailVO.setIdCardDecode(visits.getIdcardDecode()); | 
|---|
|  |  |  | visitDetailVO.setPrefix(systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + | 
|---|
|  |  |  | systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode()); | 
|---|
|  |  |  | 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<DeviceRole> deviceRoleList = deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda() | 
|---|
|  |  |  | .select(DeviceRole::getName) | 
|---|
|  |  |  | 
|---|
|  |  |  | visitsMapper.selectList(new QueryWrapper<Visits>().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) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | return visitDetailVO; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | .eq(Retention::getMemberId,visits.getMemberId())); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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<SystemUser>().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()); | 
|---|
|  |  |  | systemUserBiz.resetPwd(dto); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|