访客系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
jiangping
2024-11-12 95ddc157639fc6e9102d2e1fa8ca164af66685d6 
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java


@@ -12,12 +12,10 @@


import com.doumee.core.erp.model.openapi.response.erp.ApproveInfoResponse;


import com.doumee.core.exception.BusinessException;


import com.doumee.core.haikang.model.HKConstants;


import com.doumee.core.haikang.model.param.BaseListPageResponse;


import com.doumee.core.haikang.model.param.BaseResponse;


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;


@@ -30,12 +28,14 @@


import com.doumee.dao.admin.response.PCWorkPlatformDataVO;


import com.doumee.dao.business.*;


import com.doumee.dao.business.dao.CompanyMapper;


import com.doumee.dao.business.dao.SmsConfigMapper;


import com.doumee.dao.business.dao.SmsEmailMapper;


import com.doumee.dao.business.dto.ResetPasswordDTO;


import com.doumee.dao.business.join.DeviceJoinMapper;


import com.doumee.dao.business.join.VisitsJoinMapper;


import com.doumee.dao.business.model.*;




import com.doumee.dao.system.SystemUserMapper;


import com.doumee.dao.system.dto.NoticesDTO;


import com.doumee.dao.system.dto.ResetSystemUserPwdDTO;


import com.doumee.dao.system.join.NoticesJoinMapper;


import com.doumee.dao.system.model.Notices;


@@ -58,23 +58,13 @@


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.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 sun.misc.BASE64Encoder;




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;


@@ -131,6 +121,8 @@


    private NoticesJoinMapper noticesJoinMapper;


    @Autowired


    private InoutDayCountMapper inoutDayCountMapper;


    @Autowired


    private CarEventMapper carEventMapper;




    @Autowired


    private SmsConfigMapper smsConfigMapper;


@@ -1549,7 +1541,7 @@




            //今日在园人数


            pcWorkPlatformDataVO.setTodayInParkUserNum(


                    retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO)).count()


                    retentionList.stream().filter(i->!Constants.equalsInteger(i.getType(),Constants.THREE)).count()


            );




            pcWorkPlatformDataVO.setTodayInUserNum(Constants.ZERO);


@@ -1565,7 +1557,7 @@




            //在园访客数量


            pcWorkPlatformDataVO.setInParkVisitUserNum(


                    retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO)&&Objects.isNull(i.getCompanyType())).count()


                    retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)&&Objects.isNull(i.getCompanyType())).count()


            );


            pcWorkPlatformDataVO.setVisitUserNum(Constants.ZERO);


            pcWorkPlatformDataVO.setSignLevelNum(Constants.ZERO);


@@ -1596,23 +1588,48 @@


            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) {


                InoutDayCount inoutDayCount = inoutDayCountMapper.selectOne(new QueryWrapper<InoutDayCount>()


                        .lambda()


                        .apply(" DATE(TIME_INFO) = '"+days+"' ")


                        .last("  limit 1  ")


                );


                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(Objects.isNull(inoutDayCount)){






                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);


                    carVO.setNum(Constants.ZERO);


                }else{


                    visitVO.setNum(inoutDayCount.getInVisitorNum());


                    carVO.setNum(inoutDayCount.getInCarNum());


                }


                weekVisitList.add(visitVO);


                weekCarList.add(carVO);


@@ -1667,7 +1684,6 @@


            queryWrapper.selectAll(Visits.class);


            queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName);


            queryWrapper.select("TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) AS timeOut");


            queryWrapper.selectAs(Member::getType,Visits::getMemberType);


            queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment);


            queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId);


            queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId);