productDev/dmvisit.git

			@@ -13,6 +13,7 @@
			import com.doumee.core.exception.BusinessException;
			import com.doumee.core.haikang.model.HKConstants;
			import com.doumee.core.haikang.model.param.BaseResponse;
			import com.doumee.core.haikang.model.param.request.ParkReservationDelRequest;
			import com.doumee.core.haikang.model.param.request.VisitAppointmentCancelRequest;
			import com.doumee.core.haikang.model.param.request.VisitAppointmentOutRequest;
			import com.doumee.core.haikang.model.param.request.VisitAppointmentRequest;
			@@ -57,6 +58,7 @@
			import com.doumee.service.business.third.EmayService;
			import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
			import com.github.yulichang.wrapper.MPJLambdaWrapper;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.lang3.StringUtils;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			@@ -74,6 +76,7 @@
			* @date 2023/11/30 15:33
			*/
			@Service
			@Slf4j
			public class VisitsServiceImpl implements VisitsService {

			@Autowired
			@@ -84,6 +87,8 @@
			private UserActionMapper userActionMapper;
			@Autowired
			private ApproveMapper approveMapper;
			@Autowired
			private NoticesJoinMapper noticesJoinMapper;
			@Autowired
			private ApproveParamMapper approveParamMapper;
			@Autowired
			@@ -106,6 +111,8 @@
			private ErpTool erpTool;

			@Autowired
			private VisitParkMapper visitParkMapper;
			@Autowired
			private WxPlatNotice wxPlatNotice;

			@Autowired
			@@ -119,9 +126,9 @@
			@Autowired
			private ApproveService approveService;
			@Autowired
			private NoticesJoinMapper noticesJoinMapper;
			@Autowired
			private InoutDayCountMapper inoutDayCountMapper;
			@Autowired
			private InoutRecordMapper inoutRecordMapper;
			@Autowired
			private CarEventMapper carEventMapper;

			@@ -167,7 +174,7 @@
			if (erpVisitDTO.getEndtime().getTime() <= erpVisitDTO.getStarttime().getTime()) {
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，预约结束时间必须大于开始时间！");
			}
			if (Constants.equalsInteger(Constants.ZERO, erpVisitDTO.getIdcardType()) && erpVisitDTO.getIdcardNo().length() != 18
			if (StringUtils.isNotBlank(erpVisitDTO.getIdcardNo()) && Constants.equalsInteger(Constants.ZERO, erpVisitDTO.getIdcardType()) && erpVisitDTO.getIdcardNo().length() != 18
			//&&!IdcardUtil.isValidCard(visits.getIdcardNo())
			){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证号码有误，请核实后重试！");
			@@ -235,9 +242,8 @@
			getHkDeviceRoles(visits,isERP);
			//检验拜访人是否合法
			Member visitMember = isValideVisitedUser(visits.getReceptMemberId());
			if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())
			&&visits.getIdcardNo().length()!=18
			){
			if(StringUtils.isNotBlank(visits.getIdcardNo()) && Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())
			&&visits.getIdcardNo().length()!=18 ){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证号码有误，请核实后重试！");
			}
			Date date = new Date();
			@@ -298,8 +304,7 @@
			WxPlatNotice wxPlatNotice = new WxPlatNotice();
			wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz,
			wxNoticeConfigMapper,visits,
			Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload,
			systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
			Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload,
			Arrays.asList(visits.getOpenid().split(","))
			);
			}
			@@ -308,7 +313,6 @@

			return visits.getId();
			}


			@Override
			@Transactional(rollbackFor = {BusinessException.class,Exception.class})
			@@ -337,7 +341,6 @@
			wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz,
			wxNoticeConfigMapper,visits,
			Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload,
			systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
			Arrays.asList(systemUser.getOpenid().split(","))
			);
			}
			@@ -412,7 +415,7 @@
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批记录已处理!");
			}
			Visits visits = visitsMapper.selectById(approve.getObjId());
			if(Objects.isNull(visits)){
			if(Objects.isNull(visits)\|\|Constants.equalsInteger(visits.getIsdeleted(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!auditApproveDTO.getMemberId().equals(approve.getChekorId())){
			@@ -564,7 +567,7 @@
			.eq(ApproveParam::getLevel,Constants.ONE)
			.eq(ApproveParam::getMemberType,Constants.ZERO)
			.last("limit 1"));
			return Objects.isNull(approveParam)?null:approveParam.getId();
			return Objects.isNull(approveParam)?null:approveParam.getId();
			}


			@@ -686,7 +689,7 @@
			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()) ){
			\|\| StringUtils.isBlank(visits.getFaceImg()) ){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，信息填写不正确！");
			}
			}
			@@ -893,38 +896,41 @@
			List<Member> addList = new ArrayList<>();
			List<Member> editList = new ArrayList<>();
			//申请人信息
			Member m = getMemberListParam(visits.getIdcardNo(),visits,addList,editList);
			Member m = getMemberListParam(visits.getPhone(),visits.getIdcardNo(),visits,addList,editList);
			//随访人员信息处理
			if(visits.getWithUserList()!= null && visits.getWithUserList().size()>0){
			for(Visits model:visits.getWithUserList()){
			model.setBirthday(Constants.getBirthdyByCardNo(model.getIdcardNo()));
			model.setStarttime(visits.getStarttime());
			model.setEndtime(visits.getEndtime());
			//校验随访人员填报数据合法性
			isValidWithVisitParam(model,addList,editList);
			model.setCreateDate(visits.getCreateDate());
			Member visitsMember = getMemberListParam(model.getIdcardNo(),model,addList,editList);
			model.setMemberId(visitsMember.getId());
			}
			}
			// if(visits.getWithUserList()!= null && visits.getWithUserList().size()>0){
			// for(Visits model:visits.getWithUserList()){
			// model.setBirthday(Constants.getBirthdyByCardNo(model.getIdcardNo()));
			// model.setStarttime(visits.getStarttime());
			// model.setEndtime(visits.getEndtime());
			// //校验随访人员填报数据合法性
			// isValidWithVisitParam(model,addList,editList);
			// model.setCreateDate(visits.getCreateDate());
			// Member visitsMember = getMemberListParam(model.getIdcardNo(),model,addList,editList);
			// model.setMemberId(visitsMember.getId());
			// }
			// }
			return m;
			}

			private Member getMemberListParam(String cardno, Visits visits, List<Member> addList, List<Member> editList) {
			private Member getMemberListParam(String phone,String cardno, Visits visits, List<Member> addList, List<Member> editList) {
			if(StringUtils.isNotBlank(visits.getCarNos())
			&&Objects.isNull(Constants.getVehiclePlateNo(visits.getCarNos()))
			){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，车牌号【"+visits.getCarNos()+"】不合法，请核实后重试~");
			}
			if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())&&cardno.length()!=18
			//&&!IdcardUtil.isValidCard(cardno)
			){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证【"+cardno+"】号码有误，请核实后重试！");
			}

			// if(StringUtils.isNotBlank(cardno)&&Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())&&cardno.length()!=18
			// //&&!IdcardUtil.isValidCard(cardno)
			// ){
			// throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，身份证【"+cardno+"】号码有误，请核实后重试！");
			// }
			Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda()
			.eq(Member::getType,Constants.memberType.visitor)
			.eq(Member::getIdcardType,visits.getIdcardType())
			.eq(Member::getIdcardNo,DESUtil.encrypt(Constants.EDS_PWD, cardno)).last("limit 1" )
			.eq(Member::getPhone,phone)
			// .eq(Member::getIdcardNo,DESUtil.encrypt(Constants.EDS_PWD, cardno))
			.last("limit 1" )
			);
			if(member == null){
			member = new Member();
			@@ -932,12 +938,14 @@
			member.setCreateDate(visits.getCreateDate());
			member.setIsdeleted(Constants.ZERO);
			member.setIdcardNo(visits.getIdcardNo());
			member.setBirthday(Constants.getBirthdyByCardNo(cardno));
			member.setIdcardDecode(visits.getIdcardDecode());
			member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//身份证号加密
			member.setIdcardDecode(Constants.getTuominStr(cardno));//脱敏手机号
			if(StringUtils.isNotBlank(cardno)){
			member.setBirthday(Constants.getBirthdyByCardNo(cardno));
			member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//身份证号加密
			member.setIdcardDecode(Constants.getTuominStr(cardno));//脱敏手机号
			member.setSex(Constants.getSexByCardNo(cardno));
			}
			member.setFaceImg(visits.getFaceImg());
			member.setSex(Constants.getSexByCardNo(cardno));
			member.setImgurl(StringUtils.isNotBlank(visits.getImgurl())?visits.getImgurl():null);
			member.setIdcardType(visits.getIdcardType());
			member.setName(visits.getName());
			@@ -945,7 +953,6 @@
			member.setOpenid(visits.getOpenid());
			member.setType(Constants.memberType.visitor);
			member.setStatus(Constants.ZERO);
			member.setSex(Constants.getSexByCardNo(cardno));
			member.setHkStatus(Constants.ZERO);
			member.setErpStatus(Constants.ZERO);
			member.setVisitCompanyName(visits.getCompanyName());
			@@ -955,7 +962,7 @@
			}else{
			if(!Constants.equalsInteger(Constants.ZERO,member.getStatus() )){
			//如果用户状态异常，则提示
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，【"+member.getName()+"】身份证号【"+cardno+"】在黑名单内，无法申请进入园区");
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，【"+member.getName()+"】在黑名单内，无法申请进入园区");
			}
			//核查预约用户是否存在未签离的预约记录
			// isExsitNoOutVisisRecord(member);
			@@ -963,13 +970,15 @@
			member.setImgurl(StringUtils.isNotBlank(visits.getImgurl())?visits.getImgurl():null);
			member.setEditDate(visits.getCreateDate());
			member.setIsdeleted(Constants.ZERO);
			member.setSex(Constants.getSexByCardNo(cardno));
			member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//身份证号加密
			member.setIdcardDecode(Constants.getTuominStr(cardno));//脱敏身份证号
			if(StringUtils.isNotBlank(cardno)){
			member.setBirthday(Constants.getBirthdyByCardNo(cardno));
			member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//身份证号加密
			member.setIdcardDecode(Constants.getTuominStr(cardno));//脱敏手机号
			member.setSex(Constants.getSexByCardNo(cardno));
			}
			member.setName(visits.getName());
			member.setPhone(visits.getPhone());
			member.setOpenid(visits.getOpenid());
			member.setSex(Constants.getSexByCardNo(cardno));
			member.setHkStatus(Constants.ZERO);
			member.setErpStatus(Constants.ZERO);
			member.setVisitCompanyName(visits.getCompanyName());
			@@ -977,21 +986,20 @@
			}
			//根据手机号和身份证号码查询当前预约的时间是否与其他预约记录有冲突
			if (visitsMapper.selectCount(new QueryWrapper<Visits>().lambda()
			.eq(Visits::getIsdeleted,Constants.ZERO)
			.notIn(Visits::getStatus,Constants.VisitStatus.cancel
			,Constants.VisitStatus.noPass
			,Constants.VisitStatus.xfFail
			,Constants.VisitStatus.signout
			,Constants.VisitStatus.invalid)
			.eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno))
			.and(ms -> ms.eq(Visits::getPhone, visits.getPhone())
			.or().eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno)))
			.and(ms -> ms.eq(Visits::getPhone, visits.getPhone()))
			.and(ms -> ms.apply(" visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' ")
			.or().apply(" visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ")
			.or().apply(" visits.STARTTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ")
			.or().apply(" visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ")
			)
			) > Constants.ZERO) {
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，手机号【"+member.getPhone()+"】或身份证【"+ member.getIdcardDecode() +"】存在预约时间冲突，无法申请哦！");
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，手机号【"+member.getPhone()+"】存在预约时间冲突，无法申请哦！");
			}
			return member;
			}
			@@ -1002,6 +1010,7 @@
			*/
			private void isExsitNoOutVisisRecord(Member member) {
			Visits v = visitsMapper.selectOne(new QueryWrapper<Visits>().lambda()
			.eq(Visits::getIsdeleted,Constants.ZERO)
			.eq(Visits::getPhone, member.getPhone())
			.eq(Visits::getStatus,Constants.VisitStatus.xfSuccess)
			.last(" limit 1" )
			@@ -1039,6 +1048,7 @@
			problemLog.setUserId(member.getId());
			problemLog.setPhone(member.getPhone());
			problemLog.setLogId(visits.getId());
			problemLog.setCompanyName(visits.getCompanyName());
			problemLogMapper.updateById(problemLog);
			}
			}
			@@ -1153,11 +1163,11 @@
			params[0] = user.getRealname();
			params[1]=DateUtil.getPlusTime2(date);
			if(Constants.equalsInteger(model.getType(),Constants.TWO)){
			params[2]=model.getCarNos()+"-【单位："+model.getCompanyName()+" "+model.getName()+" "+model.getPhone()+"】-【时间："+DateUtil.getPlusTime2(model.getStarttime())+"-"+DateUtil.getPlusTime2(model.getEndtime())+"】";
			params[2]="【车牌号："+model.getCarNos()+"】-【单位："+model.getCompanyName()+" "+model.getName()+" "+model.getPhone()+"】-【时间："+DateUtil.getPlusTime2(model.getStarttime())+"-"+DateUtil.getPlusTime2(model.getEndtime())+"】";
			//记录删除访客报备日志
			UserActionServiceImpl.saveUserActionBiz(user,id,Constants.UserActionType.VISIT_DEL,userActionMapper,date,params, JSONObject.toJSONString(model));
			UserActionServiceImpl.saveUserActionBiz(user,id,Constants.UserActionType.VISIT_CAR_DEL,userActionMapper,date,params, JSONObject.toJSONString(model));
			}else{
			params[2]=model.getCompanyName()+"-【访客："+model.getName()+" "+model.getPhone()+"】-【时间："+DateUtil.getPlusTime2(model.getStarttime())+"-"+DateUtil.getPlusTime2(model.getEndtime())+"】";
			params[2]="【单位："+model.getCompanyName()+"】-【访客："+model.getName()+" "+model.getPhone()+"】-【时间："+DateUtil.getPlusTime2(model.getStarttime())+"-"+DateUtil.getPlusTime2(model.getEndtime())+"】";
			//记录删除访客申请日志
			UserActionServiceImpl.saveUserActionBiz(user,id,Constants.UserActionType.VISIT_DEL,userActionMapper,date,params, JSONObject.toJSONString(model));
			}
			@@ -1286,6 +1296,7 @@

			queryWrapper.selectAll(Visits.class);
			queryWrapper.select(" ( select count(distinct(v.CAR_NOS)) from visits v where v.PARENT_ID = t.ID and v.CAR_NOS is not null and v.CAR_NOS != '' and v.CAR_NOS != t.CAR_NOS ) as carNum ");
			queryWrapper.select(" ( select count(distinct(v.id)) from retention v where v.member_id = t.member_id and v.type=1 )",Visits::getRetentionNum);
			queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName);
			queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment);
			queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId);
			@@ -1317,6 +1328,9 @@
			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.ge(Objects.nonNull(pageWrap.getModel().getQueryStarttime()),Visits::getStarttime,Utils.Date.getStart(pageWrap.getModel().getQueryStarttime()));
			queryWrapper.le(Objects.nonNull(pageWrap.getModel().getQueryEndtime()),Visits::getStarttime,Utils.Date.getEnd(pageWrap.getModel().getQueryEndtime()));


			if(Objects.nonNull(pageWrap.getModel().getBusinessStatus())){
			if(Constants.equalsInteger(pageWrap.getModel().getBusinessStatus(),Constants.TWO)){
			@@ -1523,8 +1537,24 @@


			@Override
			@Transactional(rollbackFor = {BusinessException.class,Exception.class})
			public void visitLevelForCarOut(Visits visits){
			visits.setRemark("跟随访客车辆离园自动签离");
			visitLevelBiz(visits);
			}
			@Override
			@Transactional(rollbackFor = {BusinessException.class,Exception.class})
			public void visitLevel(Integer visitId){
			Visits visits = visitsMapper.selectById(visitId);
			visits.setRemark("平台管理员手动签离成功");
			visitLevelBiz(visits);
			//产出在场人员信息
			retentionMapper.delete(new UpdateWrapper<Retention>().lambda()
			.eq(Retention::getType,Constants.memberType.visitor)
			.eq(Retention::getMemberId,visits.getMemberId()));
			}

			private void visitLevelBiz(Visits visits) {
			if(Objects.isNull(visits)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			@@ -1535,14 +1565,16 @@
			request.setOrderId(visits.getHkId());
			//调用海康强制签离
			BaseResponse response = HKService.iccmSignoff(request);
			// BaseResponse response = HKService.outVisitAppiontment(request);
			visitsMapper.update(null,new UpdateWrapper<Visits>().lambda().set(Visits::getStatus,Constants.VisitStatus.signout)
			.eq(Visits::getId,visitId));
			//产出在场人员信息
			retentionMapper.delete(new UpdateWrapper<Retention>().lambda()
			.eq(Retention::getType,Constants.memberType.visitor)
			.eq(Retention::getMemberId,visits.getMemberId()));
			if(response!=null &&StringUtils.isNotBlank(response.getCode()) && StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)){
			visitsMapper.update(null,new UpdateWrapper<Visits>().lambda()
			.set(Visits::getStatus,Constants.VisitStatus.signout)
			.set(Visits::getRemark,visits.getRemark())
			.eq(Visits::getId,visits.getId()));
			}else{
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客签离失败，请刷新重试");
			}
			}

			@Override
			public void visitCancel(Integer visitId){
			Visits visits = visitsMapper.selectById(visitId);
			@@ -1564,6 +1596,155 @@
			.eq(Retention::getType,Constants.memberType.visitor)
			.eq(Retention::getMemberId,visits.getMemberId()));
			}


			@Override
			public void visitsSelfCancel(Integer visitId,Integer memberId,String openid){
			Visits visits = visitsMapper.selectById(visitId);
			if(Objects.isNull(visits)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			/* if(!(Constants.equalsInteger(memberId,visits.getMemberId()))){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无此操作权限");
			}*/
			if(!StringUtils.equals(openid,visits.getOpenid())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无此操作权限");
			}
			this.visitsCancelBiz(visits);
			}

			@Override
			public void visitsCancel(Integer visitId,LoginUserInfo loginUserInfo) {
			Visits visits = visitsMapper.selectById(visitId);
			if (Objects.isNull(visits)) {
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!(
			CollectionUtils.isNotEmpty(loginUserInfo.getPermissions()) &&
			loginUserInfo.getPermissions().stream().filter(i->i.equals("business:visits:cancel"))
			.collect(Collectors.toList()).size()>0)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"无此操作权限");
			}
			this.visitsCancelBiz(visits);
			}
			/**
			* 处理待审核、审核中、已审核的数据取消业务
			* 2025年3月25日14:10:10
			*/
			public void visitsCancelBiz(Visits visits){
			UpdateWrapper<Visits> updateWrapper = new UpdateWrapper();
			updateWrapper.lambda().set(Visits::getStatus,Constants.VisitStatus.cancel)
			.set(Visits::getEditDate,DateUtil.getCurrDateTime())
			.set(Visits::getEditor,visits.getEditor())
			.eq(Visits::getId,visits.getId());
			//访客报备
			if(Constants.equalsInteger(visits.getType(),Constants.TWO)){
			if(!(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)
			\|\|Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck)
			\|\| Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass))){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客记录状态错误，无法进行该操作");
			}
			if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass)
			&& Constants.equalsInteger(visits.getHkStatus(),Constants.ONE)
			&&StringUtils.isNotBlank(visits.getCarNos())){
			//取消停车场预约
			List<VisitPark> visitParkList = visitParkMapper.selectList(new QueryWrapper<VisitPark>().lambda()
			.eq(VisitPark::getCarCode,visits.getCarNos())
			.eq(VisitPark::getObjType,Constants.ONE)
			.eq(VisitPark::getHkStatus,Constants.ONE)
			.isNotNull(VisitPark::getHkId)
			.apply(" END_TIME > now() ")
			.orderByDesc(VisitPark::getCreateDate)
			);
			if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(visitParkList)){
			for (VisitPark visitPark:visitParkList) {
			ParkReservationDelRequest param = new ParkReservationDelRequest();
			param.setReserveOrderNo(visitPark.getHkId());
			BaseResponse response = HKService.parkReservationDeletion(param);
			if(response!=null
			&& StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
			visitPark.setHkStatus(Constants.THREE);
			visitPark.setIsdeleted(Constants.ONE);
			visitPark.setEditDate(new Date());
			visitParkMapper.updateById(visitPark);
			}else{
			throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),response.getMsg());
			}
			}
			updateWrapper.lambda().set(Visits::getHkStatus,Constants.ZERO).set(Visits::getHkDate,DateUtil.getCurrDateTime());
			}
			}
			}else{
			//访客申请
			if(!(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)\|\|Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck)
			\|\| Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass)\|\| Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess))){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"访客记录状态错误，请刷新重试");
			}
			if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess)
			&& Constants.equalsInteger(visits.getHkStatus(),Constants.ONE)
			&&StringUtils.isNotBlank(visits.getHkRecordId())){
			VisitAppointmentCancelRequest request = new VisitAppointmentCancelRequest();
			request.setAppointRecordIds(new String[]{visits.getHkRecordId()});
			BaseResponse response = HKService.iccmCancelAppointment(request);
			if(response==null \|\| !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) \|\| response.getData()==null){
			throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),response.getMsg());
			}
			updateWrapper.lambda().set(Visits::getHkStatus,Constants.ZERO).set(Visits::getHkDate,DateUtil.getCurrDateTime());
			}
			}

			if(Constants.equalsInteger(visits.getStatus(),Constants.ZERO)\|\|Constants.equalsInteger(visits.getStatus(),Constants.ONE)){
			//更新审批中的记录为取消
			approveMapper.update(null,
			new UpdateWrapper<Approve>().lambda()
			.set(Approve::getEditDate,new Date())
			.set(Approve::getStatus,Constants.approveStatus.cancel)
			.set(Approve::getStatusInfo,"手动取消")
			.set(Approve::getCheckInfo,"手动取消")
			.eq(Approve::getIsdeleted,Constants.ZERO)
			.in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
			.eq(Approve::getObjId,visits.getId())
			.eq(Approve::getObjType,visits.getType()));
			//更新待办消息状态
			noticesJoinMapper.update(null,
			new UpdateWrapper<Notices>().lambda()
			.set(Notices::getEditDate,new Date())
			.set(Notices::getInfo,"手动取消")
			.setSql(" param4 = user_id ")
			.set(Notices::getStatus,Constants.ONE)
			.set(Notices::getParam2,Constants.ONE)//标记已处理
			.eq(Notices::getStatus,Constants.ZERO)
			.eq(Notices::getParam2,Constants.ZERO)//待处理
			.eq(Notices::getObjId,visits.getId())
			.eq(Notices::getObjType,!Constants.equalsInteger(visits.getType(),Constants.TWO)?
			Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting)
			);

			Approve approve = new Approve();
			approve.setCreateDate(new Date());
			approve.setIsdeleted(Constants.ZERO);
			approve.setRemark("手动取消");
			approve.setChekorId(visits.getEditor());
			approve.setTitle("取消预约");
			approve.setStatus(Constants.THREE);
			approve.setStatusInfo("手动取消");
			approve.setObjId(visits.getId());
			approve.setLevel(9999);
			approve.setApproveType(2);
			approve.setDriverParam(Constants.ZERO);
			approve.setAddrParam(Constants.ZERO);
			approve.setObjType(visits.getType());
			approve.setType(Constants.ZERO);
			approve.setCheckDate(new Date());
			approveMapper.insert(approve);
			}

			visitsMapper.update(null,updateWrapper);
			}




			@Override
			public void visitResend(Integer visitId) {
			MPJLambdaWrapper<Visits> queryWrapper = new MPJLambdaWrapper<>();
			@@ -1582,7 +1763,7 @@
			}
			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()
			String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode()
			+systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();

			HkSyncVisitServiceImpl.getUpdateModelByResponseIccm(visits,new Date(),roleList,path);
			@@ -1640,7 +1821,7 @@
			.apply(" DATE(TIME_INFO) = CURDATE() ")
			.last(" limit 1 ")
			);


			//今日在园人数
			pcWorkPlatformDataVO.setTodayInParkUserNum(
			retentionList.stream().filter(i->!Constants.equalsInteger(i.getType(),Constants.THREE)).count()
			@@ -1651,8 +1832,7 @@

			//在园长期相关方人数
			pcWorkPlatformDataVO.setInParkLwUserNum(
			retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO)
			&& Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count()
			retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FOUR)).count()
			);
			pcWorkPlatformDataVO.setLwUserInNum(Constants.ZERO);
			pcWorkPlatformDataVO.setLwUserOutNum(Constants.ZERO);
			@@ -1664,6 +1844,10 @@
			);
			pcWorkPlatformDataVO.setVisitUserNum(Constants.ZERO);
			pcWorkPlatformDataVO.setSignLevelNum(Constants.ZERO);

			//在园货运车辆司机
			pcWorkPlatformDataVO.setInParkDriverUserNum(
			retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FIVE)&&Objects.isNull(i.getCompanyType())).count());

			//在园车辆
			pcWorkPlatformDataVO.setTodayInParkCarNum(
			@@ -1691,24 +1875,39 @@
			List<InterestedListVO> weekVisitList = new ArrayList<>();
			List<InterestedListVO> weekCarList = new ArrayList<>();
			List<InterestedListVO> lwList = new ArrayList<>();
			List<InterestedListVO> internalList = 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<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda().in(Visits::getStatus,
			// Constants.VisitStatus.signin,Constants.VisitStatus.signout)
			// .apply(" STARTTIME > CURDATE() - INTERVAL 7 DAY " )
			// );

			List<InoutRecord> inoutRecordList = inoutRecordMapper.selectList(new QueryWrapper<InoutRecord>().lambda()
			.eq(InoutRecord::getInOrOut,Constants.ZERO).eq(InoutRecord::getIsdeleted,Constants.ZERO)
			.apply(" TIME_INFO > 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 " )
			);
			// 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)){
			if(CollectionUtils.isNotEmpty(inoutRecordList)){
			//处理访客人员数量
			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());
			// 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());

			List<String> memberIds = inoutRecordList.stream().filter(i->
			Objects.isNull(i.getCarCode())
			&& Constants.equalsInteger(i.getMemberType(),Constants.ONE)
			&& Constants.equalsInteger(i.getInOrOut(),Constants.ZERO)
			&& Objects.nonNull(i.getMemberPhone())&&DateUtil.dateToString(i.getTimeInfo(),"yyyy-MM-dd").equals(days)
			)
			.map(i->i.getMemberPhone())
			.collect(Collectors.toList());
			if(CollectionUtils.isNotEmpty(memberIds)){
			visitVO.setNum(new HashSet<String>(memberIds).size());
			}
			@@ -1719,51 +1918,83 @@


			visitVO.setName(days);
			weekVisitList.add(visitVO);

			InterestedListVO carVO = new InterestedListVO();
			carVO.setNum(Constants.ZERO);
			carVO.setName(days);


			if(CollectionUtils.isNotEmpty(carEventList)){
			if(CollectionUtils.isNotEmpty(inoutRecordList)){
			//处理访客人员数量
			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());
			// 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());
			List<String> carCodeList = inoutRecordList.stream().filter(i->
			Objects.nonNull(i.getCarCode())
			&& Constants.equalsInteger(i.getInOrOut(),Constants.ZERO)
			&&DateUtil.dateToString(i.getTimeInfo(),"yyyy-MM-dd").equals(days)
			)
			.map(i->i.getCarCode())
			.collect(Collectors.toList());
			if(CollectionUtils.isNotEmpty(carCodeList)){
			carVO.setNum(new HashSet<String>(carCodeList).size());
			}
			}
			if(Objects.isNull(carVO.getNum())){
			visitVO.setNum(Constants.ZERO);
			carVO.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)
			.orderByAsc(Company::getSortnum)
			);

			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()
			.eq(Retention::getType,Constants.TWO)
			.in(Retention::getCompanyId,companyIds)
			);
			for (Company company:companyList) {
			Integer count = retentionList.stream().filter(i->Constants.equalsInteger(i.getCompanyId(),company.getId())).collect(Collectors.toList()).size();
			if(count>0){
			InterestedListVO lw = new InterestedListVO();
			lw.setNum(count);
			lw.setName(company.getName());
			lwList.add(lw);
			List<Company> lwCompanyList = companyList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ZERO)).collect(Collectors.toList());
			if(CollectionUtils.isNotEmpty(lwCompanyList)){
			List<Integer> lwCompanyIds = lwCompanyList.stream().map(i->i.getId()).collect(Collectors.toList());
			List<Retention> retentionList = retentionMapper.selectList(
			new QueryWrapper<Retention>().lambda()
			.eq(Retention::getIsdeleted,Constants.ZERO)
			.eq(Retention::getType,Constants.FOUR)
			.in(Retention::getCompanyId,lwCompanyIds)
			);
			for (Company company:lwCompanyList) {
			Integer count = retentionList.stream().filter(i->Constants.equalsInteger(i.getCompanyId(),company.getId())).collect(Collectors.toList()).size();
			if(count>0){
			InterestedListVO lw = new InterestedListVO();
			lw.setNum(count);
			lw.setName(company.getName());
			lwList.add(lw);
			}
			}
			}

			List<Company> internalCompanyList = companyList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)).collect(Collectors.toList());
			if(CollectionUtils.isNotEmpty(internalCompanyList)){
			List<Integer> internalCompanyIds = internalCompanyList.stream().map(i->i.getId()).collect(Collectors.toList());
			List<Retention> retentionList = retentionMapper.selectList(
			new QueryWrapper<Retention>().lambda()
			.eq(Retention::getIsdeleted,Constants.ZERO)
			.eq(Retention::getType,Constants.TWO)
			.in(Retention::getCompanyId,internalCompanyIds)
			);
			for (Company company:internalCompanyList) {
			Integer count = retentionList.stream().filter(i->Constants.equalsInteger(i.getCompanyId(),company.getId())).collect(Collectors.toList()).size();
			if(count>0){
			InterestedListVO lw = new InterestedListVO();
			lw.setNum(count);
			lw.setName(company.getName());
			internalList.add(lw);
			}
			}
			}
			}

			pcWorkPlatformDataVO.setLwList(lwList );
			pcWorkPlatformDataVO.setInternalList(internalList);
			pcWorkPlatformDataVO.setLwList(lwList);
			}else if(Constants.equalsInteger(queryType,Constants.THREE)) {
			if (Objects.isNull(loginUserInfo.getMemberId())) {
			pcWorkPlatformDataVO.setNoticesList(new ArrayList<>());
			@@ -1833,6 +2064,7 @@
			List<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda()
			.eq(Visits::getStatus,Constants.VisitStatus.signin)
			.eq(Visits::getSendTimeOutNotice,Constants.ZERO)
			.eq(Visits::getIsdeleted,Constants.ZERO)
			.apply(" now() >= DATE_ADD(ENDTIME,INTERVAL -"+times+" MINUTE) ")
			);
			Integer visitTimeCount = 0;
			@@ -1878,29 +2110,111 @@
			);
			}
			}



			}
			@Override
			public void visitNoCheckCancel(){
			log.info("===============待审批记录超时自动取消预约===========start=======");
			List<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda()
			.eq(Visits::getIsdeleted,Constants.ONE)
			.eq(Visits::getIsdeleted,Constants.ZERO)
			.eq(Visits::getStatus,Constants.VisitStatus.waitCheck)
			.apply(" now() >= ENDTIME ")
			);
			if(visitsList!=null){
			Date date =new Date();
			for(Visits s :visitsList){
			visitsMapper.update(null,new UpdateWrapper<Visits>().lambda()
			.set(Visits::getIsdeleted,Constants.VisitStatus.cancel)
			.set(Visits::getEditDate,date)
			.set(Visits::getRemark,"预约截止时间已过未审批，系统自动取消")
			.eq(Visits::getId,s.getId()));
			dealAutoCancelBiz(s,date);
			}
			}

			log.info("===============待审批记录超时自动取消预约===========end=======");
			}

			@Transactional
			private void dealAutoCancelBiz(Visits s, Date date) {
			visitsMapper.update(null,new UpdateWrapper<Visits>().lambda()
			.set(Visits::getStatus,Constants.VisitStatus.cancel)
			.set(Visits::getEditDate,date)
			.set(Visits::getRemark,"预约截止时间已过未审批，系统自动取消")
			.eq(Visits::getId,s.getId()));

			VisitsServiceImpl.dealCancelNoticesData(noticesJoinMapper,approveMapper,"系统取消",s.getId(),
			s.getType(),
			!Constants.equalsInteger(s.getType(),Constants.TWO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting
			);

			Approve approve = new Approve();
			approve.setCreateDate(new Date());
			approve.setIsdeleted(Constants.ZERO);
			approve.setRemark("系统自动取消");
			approve.setTitle("取消预约");
			approve.setStatus(Constants.THREE);
			approve.setStatusInfo("超时自动取消");
			approve.setObjId(s.getId());
			approve.setLevel(9999);
			approve.setApproveType(2);
			approve.setDriverParam(Constants.ZERO);
			approve.setAddrParam(Constants.ZERO);
			approve.setObjType(s.getType());
			approve.setType(Constants.ZERO);
			approve.setCheckDate(new Date());
			approveMapper.insert(approve);

			// //更新审批中的记录为取消
			// approveMapper.update(null,
			// new UpdateWrapper<Approve>().lambda()
			// .set(Approve::getEditDate,date)
			// .set(Approve::getStatus,Constants.approveStatus.cancel)
			// .set(Approve::getStatusInfo,"系统已取消")
			// .set(Approve::getCheckInfo,"访问时间已过，系统自动取消")
			// .eq(Approve::getIsdeleted,Constants.ZERO)
			// .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
			// .eq(Approve::getObjId,s.getId())
			// .eq(Approve::getObjType,s.getType()));
			// //更新待办消息状态
			// noticesJoinMapper.update(null,
			// new UpdateWrapper<Notices>().lambda()
			// .set(Notices::getEditDate,date)
			// .set(Notices::getInfo,"已取消")
			//// .set(Notices::getStatus,Constants.ONE)
			// .set(Notices::getParam2,Constants.FOUR)//已取消
			// .eq(Notices::getIsdeleted,Constants.ZERO)
			// .eq(Notices::getStatus,Constants.ZERO)
			// .eq(Notices::getParam2,Constants.ZERO)//待处理
			// .eq(Notices::getObjId,s.getId())
			// .eq(Notices::getObjType,Constants.equalsInteger(s.getType(),Constants.ZERO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting)
			// );
			}


			public static void dealCancelNoticesData(NoticesJoinMapper noticesJoinMapper,ApproveMapper approveMapper,String info,Integer objId,Integer approveObjectType,Integer noticesType){
			if(Objects.nonNull(approveObjectType)){
			approveMapper.update(null,
			new UpdateWrapper<Approve>().lambda()
			.set(Approve::getEditDate,new Date())
			.set(Approve::getStatus,Constants.approveStatus.cancel)
			.set(Approve::getStatusInfo,info)
			.set(Approve::getCheckInfo,info)
			.eq(Approve::getIsdeleted,Constants.ZERO)
			.in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
			.eq(Approve::getObjId,objId)
			.eq(Approve::getObjType,approveObjectType));
			}
			if(Objects.nonNull(noticesType)){
			//更新待办消息状态
			noticesJoinMapper.update(null,
			new UpdateWrapper<Notices>().lambda()
			.set(Notices::getEditDate,new Date())
			.set(Notices::getInfo,"自动取消")
			.setSql(" param4 = user_id ")
			.set(Notices::getStatus,Constants.ONE)
			.set(Notices::getParam2,Constants.ONE)//已取消
			.eq(Notices::getStatus,Constants.ZERO)
			.eq(Notices::getParam2,Constants.ZERO)//待处理
			.eq(Notices::getObjId,objId)
			.eq(Notices::getObjType,noticesType)
			);
			}
			}



			}