|  |  |  | 
|---|
|  |  |  | 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.BaseResponse; | 
|---|
|  |  |  | 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.utils.DateUtil; | 
|---|
|  |  |  | import com.doumee.core.utils.Utils; | 
|---|
|  |  |  | import com.doumee.core.wx.wxPlat.WxPlatNotice; | 
|---|
|  |  |  | import com.doumee.dao.admin.response.MemberInfoDTO; | 
|---|
|  |  |  | 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.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.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.extension.plugins.pagination.Page; | 
|---|
|  |  |  | import com.github.xiaoymin.knife4j.core.util.CollectionUtils; | 
|---|
|  |  |  | import com.github.yulichang.wrapper.MPJLambdaWrapper; | 
|---|
|  |  |  | import io.swagger.models.auth.In; | 
|---|
|  |  |  | 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 org.springframework.util.DigestUtils; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.time.temporal.ChronoUnit; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | 
|---|
|  |  |  | //检验拜访人是否合法 | 
|---|
|  |  |  | Member visitMember = isValideVisitedUser(visits.getReceptMemberId()); | 
|---|
|  |  |  | if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())&&visits.getIdcardNo().length()!=18 | 
|---|
|  |  |  | //&&!IdcardUtil.isValidCard(visits.getIdcardNo()) | 
|---|
|  |  |  | //            &&!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); | 
|---|
|  |  |  | visits.setMemberNum(Constants.ZERO); | 
|---|
|  |  |  | //访客信息(使用身份证号查询是否已存在改普通访客,没有则新增,存在则更新openid等信息),包括随访人员校验和处理 | 
|---|
|  |  |  | Member member =dealMemberAndVisits(visits); | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | 
|---|
|  |  |  | approve.setApproveType(approveParam.getApproveType()); | 
|---|
|  |  |  | approve.setChekorId(id); | 
|---|
|  |  |  | approve.setType(Constants.ONE); | 
|---|
|  |  |  | approve.setVisitId(visitId); | 
|---|
|  |  |  | approve.setObjId(visitId); | 
|---|
|  |  |  | approveList.add(approve); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | approveMapper.insertBatchSomeColumn(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(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() < System.currentTimeMillis()){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起,预约结束时间必须大于当前时间!");// | 
|---|
|  |  |  | 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.getSourceType().equals(Constants.ZERO)){ | 
|---|
|  |  |  | String code = systemDictDataBiz.queryByCode(Constants.VISIT_CONFIG,Constants.VALIDATE_VISIT).getCode(); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 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+"天]!"); | 
|---|
|  |  |  | 
|---|
|  |  |  | model.setMemberId(visitsMember.getId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //        if(CollectionUtils.isNotEmpty(addList)){ | 
|---|
|  |  |  | //            memberMapper.insertBatchSomeColumn(addList); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        if(CollectionUtils.isNotEmpty(editList)){ | 
|---|
|  |  |  | //            editList.forEach(i->{ | 
|---|
|  |  |  | //                memberMapper.updateById(i); | 
|---|
|  |  |  | //            }); | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return  m; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //根据手机号和身份证号码查询 当前预约的时间是否与其他预约记录有冲突 | 
|---|
|  |  |  | if (visitsMapper.selectCount(new QueryWrapper<Visits>().lambda() | 
|---|
|  |  |  | .notIn(Visits::getStatus,Constants.VisitStatus.cancel,Constants.VisitStatus.noPass,Constants.VisitStatus.xfFail,Constants.VisitStatus.signout,Constants.VisitStatus.invalid) | 
|---|
|  |  |  | .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") + "' ") | 
|---|
|  |  |  | )) > 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; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private ProblemLog isValidProblemLog(Visits visits) { | 
|---|
|  |  |  | 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.eq(Visits::getIsdeleted,Constants.ZERO); | 
|---|
|  |  |  | queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getType()),Visits::getType,pageWrap.getModel().getType()); | 
|---|
|  |  |  | queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getOpenid()),Visits::getOpenid,pageWrap.getModel().getOpenid()); | 
|---|
|  |  |  | //        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.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); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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.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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|