|  |  |  | 
|---|
|  |  |  | package com.doumee.service.business.impl; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import cn.hutool.core.date.DateUnit; | 
|---|
|  |  |  | import cn.hutool.core.util.IdcardUtil; | 
|---|
|  |  |  | 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.VisitListRequest; | 
|---|
|  |  |  | 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.VisitEventListResponse; | 
|---|
|  |  |  | 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.HKTools; | 
|---|
|  |  |  | import com.doumee.core.haikang.model.param.BaseListPageResponse; | 
|---|
|  |  |  | import com.doumee.core.haikang.model.param.BaseResponse; | 
|---|
|  |  |  | import com.doumee.core.haikang.model.param.request.VisitAppointmentCancelRequest; | 
|---|
|  |  |  | import com.doumee.core.haikang.model.param.request.FacePictureCheckRequest; | 
|---|
|  |  |  | 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.AscDeviceStatusInfoResponse; | 
|---|
|  |  |  | import com.doumee.core.haikang.model.param.respose.FacePictureCheckResponse; | 
|---|
|  |  |  | import com.doumee.core.haikang.model.param.respose.VisitAppointmentResponse; | 
|---|
|  |  |  | import com.doumee.core.haikang.service.HKService; | 
|---|
|  |  |  | import com.doumee.core.model.LoginUserInfo; | 
|---|
|  |  |  | import com.doumee.core.model.PageData; | 
|---|
|  |  |  | import com.doumee.core.model.PageWrap; | 
|---|
|  |  |  | import com.doumee.core.utils.Constants; | 
|---|
|  |  |  | import com.doumee.core.utils.DESUtil; | 
|---|
|  |  |  | import com.doumee.core.utils.DateUtil; | 
|---|
|  |  |  | import com.doumee.core.utils.Utils; | 
|---|
|  |  |  | import com.doumee.core.utils.*; | 
|---|
|  |  |  | import com.doumee.core.wx.wxPlat.WxPlatNotice; | 
|---|
|  |  |  | import com.doumee.dao.admin.response.MemberInfoDTO; | 
|---|
|  |  |  | import com.doumee.dao.admin.response.InterestedListVO; | 
|---|
|  |  |  | import com.doumee.dao.admin.response.PCWorkPlatformDataVO; | 
|---|
|  |  |  | 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.VisitEventJoinMapper; | 
|---|
|  |  |  | 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.NoticesDTO; | 
|---|
|  |  |  | 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.InternalHomeVO; | 
|---|
|  |  |  | 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 io.swagger.models.auth.In; | 
|---|
|  |  |  | 
|---|
|  |  |  | import org.springframework.stereotype.Service; | 
|---|
|  |  |  | import org.springframework.transaction.annotation.Propagation; | 
|---|
|  |  |  | import org.springframework.transaction.annotation.Transactional; | 
|---|
|  |  |  | import org.springframework.util.DigestUtils; | 
|---|
|  |  |  | import sun.misc.BASE64Encoder; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.time.temporal.ChronoUnit; | 
|---|
|  |  |  | import java.io.ByteArrayOutputStream; | 
|---|
|  |  |  | import java.io.IOException; | 
|---|
|  |  |  | import java.io.InputStream; | 
|---|
|  |  |  | import java.net.HttpURLConnection; | 
|---|
|  |  |  | import java.net.URL; | 
|---|
|  |  |  | import java.nio.file.Files; | 
|---|
|  |  |  | import java.nio.file.Path; | 
|---|
|  |  |  | import java.nio.file.Paths; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | import java.util.Date; | 
|---|
|  |  |  | import java.util.stream.Collectors; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | @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; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private NoticesJoinMapper noticesJoinMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private InoutDayCountMapper inoutDayCountMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private CarEventMapper carEventMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SmsConfigMapper smsConfigMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SmsEmailMapper smsEmailMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private EmayService emayService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public Integer create(Visits visits) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 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()) | 
|---|
|  |  |  | 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.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); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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_RESOURCE_PATH).getCode() + | 
|---|
|  |  |  | systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); | 
|---|
|  |  |  | param.setFacePicUrl(prefixUrl + visits.getFaceImg()); | 
|---|
|  |  |  | BaseResponse<FacePictureCheckResponse> 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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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() ) || 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(), "对不起,预约结束时间必须大于开始时间!");// | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | .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") + "' ") | 
|---|
|  |  |  | )) > Constants.ZERO) { | 
|---|
|  |  |  | .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; | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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(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()),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()); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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::getType,Constants.memberType.visitor) | 
|---|
|  |  |  | .eq(Retention::getMemberId,visits.getMemberId())); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public  void visitResend(Integer visitId) { | 
|---|
|  |  |  | MPJLambdaWrapper<Visits> 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<DeviceRole> roleList = deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().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); | 
|---|
|  |  |  | if(Objects.isNull(visits.getParentId())){ | 
|---|
|  |  |  | 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{ | 
|---|
|  |  |  | 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<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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * | 
|---|
|  |  |  | * @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<Retention> retentionList = retentionMapper.selectJoinList(Retention.class, | 
|---|
|  |  |  | new MPJLambdaWrapper<Retention>() | 
|---|
|  |  |  | .selectAll(Retention.class) | 
|---|
|  |  |  | .selectAs(Company::getType,Retention::getCompanyType) | 
|---|
|  |  |  | .leftJoin(Company.class,Company::getId,Retention::getCompanyId) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | InoutDayCount inoutDayCount = inoutDayCountMapper.selectOne(new QueryWrapper<InoutDayCount>() | 
|---|
|  |  |  | .lambda() | 
|---|
|  |  |  | .apply(" DATE(TIME_INFO) = CURDATE()  ") | 
|---|
|  |  |  | .last(" limit 1 ") | 
|---|
|  |  |  | ); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //今日在园人数 | 
|---|
|  |  |  | pcWorkPlatformDataVO.setTodayInParkUserNum( | 
|---|
|  |  |  | retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO)).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.TWO)&&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<String> weekDays = DateUtil.getBeforDays(new Date(),7); | 
|---|
|  |  |  | List<InterestedListVO> weekVisitList = new ArrayList<>(); | 
|---|
|  |  |  | List<InterestedListVO> weekCarList = new ArrayList<>(); | 
|---|
|  |  |  | List<InterestedListVO> lwList = new ArrayList<>(); | 
|---|
|  |  |  | //查询七天前的访客记录数量 | 
|---|
|  |  |  | List<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda().in(Visits::getStatus, | 
|---|
|  |  |  | Constants.VisitStatus.signin,Constants.VisitStatus.signout) | 
|---|
|  |  |  | .apply(" STARTTIME >   CURDATE() - INTERVAL 7 DAY " ) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<CarEvent> carEventList = carEventMapper.selectList(new QueryWrapper<CarEvent>().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<Visits> daysList = visitsList.stream().filter(i->Objects.nonNull(i.getStarttime())&&DateUtil.dateToString(i.getStarttime(),"yyyy-MM-dd").equals(days)).collect(Collectors.toList()); | 
|---|
|  |  |  | List<String> memberIds = daysList.stream().map(i->i.getMemberId().toString()).collect(Collectors.toList()); | 
|---|
|  |  |  | if(CollectionUtils.isNotEmpty(memberIds)){ | 
|---|
|  |  |  | visitVO.setNum(new HashSet<String>(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<CarEvent> daysList = carEventList.stream().filter(i->StringUtils.isNotBlank(i.getHappenTime()) && i.getHappenTime().substring(0,10).equals(days)).collect(Collectors.toList()); | 
|---|
|  |  |  | List<String> carCodeList = daysList.stream().map(i->i.getPlateNos()).collect(Collectors.toList()); | 
|---|
|  |  |  | if(CollectionUtils.isNotEmpty(carCodeList)){ | 
|---|
|  |  |  | carVO.setNum(new HashSet<String>(carCodeList).size()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(Objects.isNull(carVO.getNum())){ | 
|---|
|  |  |  | visitVO.setNum(Constants.ZERO); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | weekVisitList.add(visitVO); | 
|---|
|  |  |  | weekCarList.add(carVO); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | pcWorkPlatformDataVO.setWeekVisitList(weekVisitList ); | 
|---|
|  |  |  | pcWorkPlatformDataVO.setWeekCarList(weekCarList); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<Company> companyList = companyMapper.selectList(new QueryWrapper<Company>().lambda() | 
|---|
|  |  |  | .eq(Company::getType,Constants.ZERO) | 
|---|
|  |  |  | .eq(Company::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(CollectionUtils.isNotEmpty(companyList)){ | 
|---|
|  |  |  | List<Integer> companyIds = companyList.stream().map(i->i.getId()).collect(Collectors.toList()); | 
|---|
|  |  |  | List<Retention> retentionList = retentionMapper.selectList( | 
|---|
|  |  |  | new QueryWrapper<Retention>().lambda() | 
|---|
|  |  |  | .in(Retention::getCompanyId,companyIds) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | for (Company company:companyList) { | 
|---|
|  |  |  | Integer count = retentionList.stream().filter(i->Constants.equalsInteger(i.getCompanyId(),company.getId())).collect(Collectors.toList()).size(); | 
|---|
|  |  |  | InterestedListVO lw = new InterestedListVO(); | 
|---|
|  |  |  | lw.setNum(count); | 
|---|
|  |  |  | lw.setName(company.getName()); | 
|---|
|  |  |  | lwList.add(lw); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | pcWorkPlatformDataVO.setLwList(lwList   ); | 
|---|
|  |  |  | }else if(Constants.equalsInteger(queryType,Constants.THREE)) { | 
|---|
|  |  |  | MPJLambdaWrapper<Notices> queryWrapper = new MPJLambdaWrapper<>(); | 
|---|
|  |  |  | queryWrapper.selectAll(Notices.class); | 
|---|
|  |  |  | if (Objects.isNull(loginUserInfo.getMemberId())) { | 
|---|
|  |  |  | queryWrapper.eq("1", "2"); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | 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<Notices> 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<Visits> 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<Visits> 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<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda() | 
|---|
|  |  |  | .eq(Visits::getStatus,Constants.VisitStatus.signin) | 
|---|
|  |  |  | .eq(Visits::getSendTimeOutNotice,Constants.ZERO) | 
|---|
|  |  |  | .apply("   now() >=  DATE_ADD(ENDTIME,INTERVAL -"+times+" MINUTE)   ") | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | 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(",")) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, | 
|---|
|  |  |  | emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), | 
|---|
|  |  |  | SmsConstants.visitContent.visitTimeOutSignOut, | 
|---|
|  |  |  | null,Arrays.asList(visits.getPhone().split(",")) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | visits.setSendTimeOutNotice(Constants.ONE); | 
|---|
|  |  |  | visitsMapper.updateById(visits); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|