整理

nidapeng

2024-03-25 755b60c531999e9d3c0a94759a2a5e92f5e4ad4e

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java

@@ -1,23 +1,57 @@
package com.doumee.service.business.impl.erp;

import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.DoorsListRequest;
import com.doumee.core.haikang.model.param.request.ParkListRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.model.openapi.request.erp.OrgListRequest;
import com.doumee.core.model.openapi.request.erp.UserInfoRequest;
import com.doumee.core.model.openapi.request.erp.UserListRequest;
import com.doumee.core.model.openapi.response.erp.OrgListRespone;
import com.doumee.service.business.ERPSyncService;
import com.doumee.service.business.HkSyncService;
import com.alibaba.fastjson.JSONObject;
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.api.R;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.config.DataSyncConfig;
import com.doumee.config.Jwt.JwtPayLoad;
import com.doumee.config.Jwt.JwtTokenUtil;
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.erp.*;
import com.doumee.core.erp.model.openapi.response.erp.ERPApiResponse;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.erp.model.openapi.request.*;
import com.doumee.core.erp.model.openapi.response.*;
import com.doumee.core.erp.model.openapi.response.erp.ErpOrgListResponse;
import com.doumee.core.erp.model.openapi.response.erp.ErpUserListResponse;
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.redis.RedisUtil;
import com.doumee.core.wx.wxPlat.WxPlatNotice;
import com.doumee.dao.business.*;
import com.doumee.dao.business.join.CarEventJoinMapper;
import com.doumee.dao.business.join.DeviceEventJoinMapper;
import com.doumee.dao.business.join.VisitEventJoinMapper;
import com.doumee.dao.business.model.*;
import com.doumee.service.business.ext.ERPSyncService;
import com.doumee.service.business.InterfaceLogService;
import com.doumee.service.business.impl.hksync.ferp.HkSyncOrgUserToHKServiceImpl;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import lombok.Synchronized;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.List;
import javax.annotation.PostConstruct;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 设备信息表Service实现
@@ -27,17 +61,226 @@
@Service
public class ErpSyncServiceImpl implements ERPSyncService {

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Autowired
    private DataSyncConfig dataSyncConfig;
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Autowired
    private DeviceRoleMapper deviceRoleMapper;

    @Autowired
    private DeviceMapper deviceMapper;

    @Autowired
    private ParksMapper parksMapper;

    @Autowired
    private VisitEventMapper visitEventMapper;


    @Autowired
    private VisitEventJoinMapper visitEventJoinMapper;

    @Autowired
    private DeviceEventJoinMapper deviceEventJoinMapper;

    @Value("${debug_model}")
    private Boolean isDebug;
    @Autowired
    private CarEventJoinMapper carEventJoinMapper;

    @Autowired
    private CompanyMapper companyMapper;
    @Autowired
    private EmpowerMapper empowerMapper;
    @Autowired
    private ParkBookMapper parkBookMapper;

    @Autowired
    private MemberMapper memberMapper;

    @Autowired
    private MemberRoleMapper memberRoleMapper;

    @Autowired
    private MemberCardMapper memberCardMapper;

    @Autowired
    private VisitsMapper visitsMapper;

    @Autowired
    private InterfaceLogService interfaceLogService;

    @Autowired
    private ErpTool erpTool;


    @Autowired
    private WxPlatNotice wxPlatNotice;

    @Override
    @PostConstruct
    public  int  initHkConfig(){
        ErpConstants.approveUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_APPROVE_URL).getCode();
        ErpConstants.orgListUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_ORGLIST_URL).getCode();
        ErpConstants.userListUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERLIST_URL).getCode();
        ErpConstants.userStatusUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERSTATUS_RL).getCode();
        return  0;
    }
    /**
     * 同步ERP组织信息
     * @param param
     * @return
     */
    @Override
    @Transactional
    @Synchronized
    public String syncCompany(OrgListRequest param){
        List<OrgListRespone>  allList = new ArrayList<>();
        if( Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin()) != DataSyncConfig.origin.erp){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，当前不支持组织同步操作~");
        }
        //获取ERP组织信息（全量同步）
        List<ErpOrgListResponse>  list = erpTool.getErpOrgList(ErpConstants.orgListUrl,param);
        if(list !=null && list.size()>0){
            List<Company> addList = new ArrayList<>();
            List<Company> updateList = new ArrayList<>();
            List<Integer> delIds = new ArrayList<>();
            List<Company>  allList = companyMapper.selectList(new QueryWrapper<Company>().lambda().eq(Company::getType,Constants.ONE));
            dealCompanyChangeList(list,addList,updateList,delIds,allList);
            if(addList.size()>0){
                companyMapper.insertBatchSomeColumn(addList);
            }
            if(updateList.size()>0){
                for(Company c : updateList){
                    companyMapper.updateById(c);
                }
            }
            if(delIds.size()>0){
                //删除所有需要删除的组织信息(逻辑删除）
                companyMapper.update(null,new UpdateWrapper<Company>().lambda()
                        .set(Company::getIsdeleted, Constants.ONE)
                        .set(Company::getHkStatus, Constants.ZERO)
                        .in(Company::getId,delIds));
            }
            return "同步数据：新增【"+addList.size()+"】条，更新【"+updateList.size()+"】条，删除【"+delIds.size()+"】条";
        }else{
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "同步ERP数据为空！");
        }
    }

    /**
     * 根据同步erp的组织信息封装 组织新增、修改和删除的集合信息
     * @param list
     * @param addList
     * @param updateList
     * @param delIds
     * @param allList
     */
    private void dealCompanyChangeList(List<ErpOrgListResponse> list, List<Company> addList, List<Company> updateList, List<Integer> delIds, List<Company> allList) {
        Date date = new Date();
        for(ErpOrgListResponse respone : list){
            //根据erpid查询企业信息，判断是新增还是更新
            Company company = findCompanyByERPId(allList,respone.getId());
            if(company == null){
                //如果是新增
                if(Constants.formatIntegerNum(respone.getIsdeleted()) == Constants.ONE){
                    continue;
                }
                //封装新增组织对象数据
                addList.add(getAddCompanyModel(respone,date));
            }else{
                //如果是更新
                if(Constants.formatIntegerNum(respone.getIsdeleted()) == Constants.ONE){
                    //如果已删除，加入删除集合中
                    delIds.add(company.getId());
                    continue;
                }else{
                    company.setIsdeleted(Constants.ZERO);
                }
                updateList.add(addUpdateCompanyModel(respone,company,date));
            }
        }
        if(allList!=null && allList.size()>0){
            for(Company  c : allList){
                if(!isCompanyDeleted(c,list)){
                    delIds.add(c.getId());
                }
            }
        }

    }

    /**
     * 新增组织对象
     * @param respone
     * @param company
     * @param date
     * @return
     */
    private Company addUpdateCompanyModel(ErpOrgListResponse respone, Company company, Date date) {
        company.setName(respone.getName());
        company.setErpId(respone.getId());
        company.setEditDate(date);
        company.setStatus(respone.getStatus());
        company.setCode(respone.getCode());
        if(StringUtils.isNotBlank(respone.getParentOrgId())&&!respone.getParentOrgId().equals("orgRoot")){
            company.setErpParentId(respone.getParentOrgId());
        }
        company.setErpDate(date);
        company.setHkStatus(Constants.ZERO);
        company.setRemark("待同步安防平台");
        return  company;
    }
    /**
     * 更新组织对象
     * @param respone
     * @param date
     * @return
     */
    private Company getAddCompanyModel(ErpOrgListResponse respone, Date date) {
        Company    company = new Company();
        company.setStatus(respone.getStatus());
        company.setIsdeleted(Constants.ZERO);
        company.setName(respone.getName());
        company.setErpId(respone.getId());
        company.setCreateDate(date);
        company.setType(Constants.ONE);
        company.setCode(respone.getCode());
        if(StringUtils.isNotBlank(respone.getParentOrgId())&&!respone.getParentOrgId().equals("orgRoot")){
            company.setErpParentId(respone.getParentOrgId());
        }
        company.setErpDate(date);
        company.setHkStatus(Constants.ZERO);
        company.setRemark("待同步安防平台");
        return  company;
    }

    private boolean isCompanyDeleted(Company c, List<ErpOrgListResponse> list) {
        for(ErpOrgListResponse m : list){
            if(StringUtils.equals(c.getErpId(),m.getId())){
                return  true;
            }
        }
        return false;
    }

    private Company findCompanyByERPId(List<Company> allList, String id) {
        if(allList!=null){
            for(Company com :allList){
                if(StringUtils.equals(com.getErpId(),id)){
                    return com;
                }
            }
        }
        return  null;
    }




    /**
     * 同步ERP人员信息
@@ -45,17 +288,850 @@
     * @return
     */
    @Override
    public    String syncUsers(UserListRequest param){
    @Transactional
    @Synchronized
    public  String syncUsers(UserListRequest param){
        if( Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin()) != DataSyncConfig.origin.erp){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，当前不支持组织同步操作~");
        }
        List<ErpUserListResponse>  list = erpTool.getErpUserList(ErpConstants.userListUrl,param);
        if(list !=null && list.size()>0) {
            List<Member> addList = new ArrayList<>();
            List<Member> updateList = new ArrayList<>();
            List<Integer> delIds = new ArrayList<>();
            List<Member> delList = new ArrayList<>();
            List<Member> allList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
                    .eq(Member::getIsdeleted,Constants.ZERO)
                    .eq(Member::getType, Constants.memberType.internal));
            dealUserChangeList(list,addList,updateList,delList,allList,param);
            if(addList.size()>0){
                memberMapper.insertBatchSomeColumn(addList);
               /* for (Member member:addList) {
                    dealRoleEmpower(member );
                }*/
            }
            if(updateList.size()>0){
                for(Member c : updateList){
//                     dealRoleEmpower(c );
                    c.setHkStatus(Constants.ZERO);
                    c.setRemark("待同步安防平台");
                    memberMapper.updateById(c);
                }
            }
            if(delList.size()>0){
               /* for (Member member:delList) {
                    dealRoleEmpower(member );
                }*/
                delIds = delList.stream().map(m->m.getId()).collect(Collectors.toList());
                memberMapper.update(null,new UpdateWrapper<Member>().lambda()
                        .set(Member::getHkStatus,Constants.ZERO)
                        .set(Member::getIsdeleted, Constants.ONE).in(Member::getId,delIds));
            }
            return "同步数据：新增【"+addList.size()+"】条，更新【"+updateList.size()+"】条，删除【"+delIds.size()+"】条";
        }else{
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "同步ERP数据为空！");
        }
    }

   public void dealRoleEmpower(Member member ){
//        List<Integer> doorIds = getRoleIdByParam(member.getRoleIds(),member);
        //添加人员卡片数据
        dealMemberCard(member,new UserUpdateRequest());
    }

    private void dealUserChangeList(List<ErpUserListResponse> list, List<Member> addList, List<Member> updateList, List<Member> delList, List<Member> allList,UserListRequest param) {
        Date date = new Date();
        int num =0;
        for(ErpUserListResponse response : list){
//            if(isDebug){
//                response.setPhone("1534569100"+num);
//                response.setFaceImg("20223402/DM1005.png");
//                response.setIdNo("34112219880427200"+num);
//            }
            num++;
            Company company =  new Company();
            if(StringUtils.isNotBlank(response.getOrgId())){
                company = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,response.getOrgId()).last("limit 1"));
                if(Objects.isNull(company)){
                    continue;
                }
            }
            //根据 erpId 查询用户信息，判断是新增还是更新
            Member member = findUserByERPId(allList,response.getId());
            if(member == null){
                //如果是新增
                if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){
                    continue;
                }
                //封装新增组织对象数据
                addList.add(getAddMemberModel(response,date,company,param));
            }else{
                //如果是更新
                if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){
                    //如果已删除，加入删除集合中
                    member.setRoleIds(response.getRoleIds());
                    delList.add(member);
//                    delIds.add(member.getId());
                    continue;
                }
                updateList.add(addUpdateMemberModel(response,member,date,company,param));
            }
        }
        if(allList!=null && allList.size()>0){
            for(Member  c : allList){
                if(!Constants.equalsInteger(c.getIsdeleted(),Constants.ONE) &&  !isUserDeleted(c,list)){
                    delList.add(c);
                }
            }
        }
    }

    private Member getAddMemberModel(ErpUserListResponse param, Date date,Company company,UserListRequest request) {
        Member member = new Member();
        BeanUtils.copyProperties(param,member);
        member.setCreateDate(date);
        /*if(StringUtils.isBlank(param.getFaceImg())){
            member.setHkStatus(Constants.THREE);
        }else{
            member.setHkStatus(Constants.ZERO);
            member.setRemark("待同步安防平台");
        }*/
        member.setHkStatus(Constants.ZERO);
        member.setRemark("待同步安防平台");
        member.setErpStatus(Constants.ONE);
        member.setErpDate(date);
        member.setErpId(param.getId());
        member.setIdcardType(param.getIdType());
        member.setFsStatus(Constants.ZERO);
        member.setStatus(param.getStatus());
        member.setType(Constants.memberType.internal);
        String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
        member.setIdcardNo(encryptIdNo);
        member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
        member.setRoleIds(param.getRoleIds());
        member.setCompanyId(Objects.isNull(company)?null:company.getId());
        member.setErpOrgId(param.getOrgId());
        member.setCanVisit(Constants.ONE);
//        member.setStartTime(request.getStartTime());
//        member.setEndTime(request.getEndTime());
        return  member;
    }

    private Member addUpdateMemberModel(ErpUserListResponse param, Member member, Date date,Company company,UserListRequest request) {
        BeanUtils.copyProperties(param,member);
        String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
        member.setIdcardNo(encryptIdNo);
        member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
        member.setErpOrgId(param.getOrgId());
        member.setEditDate(date);
        member.setStatus(param.getStatus());
        member.setErpDate(date);
        member.setHkStatus(Constants.ZERO);
        member.setRemark("待同步安防平台");
        member.setRoleIds(param.getRoleIds());
//        member.setStartTime(request.getStartTime());
//        member.setEndTime(request.getEndTime());
        member.setCompanyId(Objects.isNull(company)?null:company.getId());
        member.setErpOrgId(param.getOrgId());
        return  member;
    }

    private boolean isUserDeleted(Member c, List<ErpUserListResponse> list) {
        for(ErpUserListResponse m : list){
            if(StringUtils.equals(c.getErpId(),m.getId().toString())){
                c.setRoleIds(m.getRoleIds());
                return  true;
            }
        }
        return false;
    }

    private Member findUserByERPId(List<Member> allList, String id) {
        if(allList!=null){
            for(Member com :allList){
                if(StringUtils.equals(com.getErpId(),id)){
                    return com;
                }
            }
        }
        return  null;
    }



    /**
     * 获取ERP人员信息
     * 提交用户同步失败记录
     * @param param
     * @return
     */
    @Override
    public  String syncUserInfo(UserInfoRequest param){
    public  boolean noticeUserFail(UserFailRequest param){
        ERPApiResponse r  = erpTool.noticeUserStatus(ErpConstants.userStatusUrl,param);
        if(r!=null && r.isSuccess()){
            return true;
        }
        return  false;
    }

    @Override
    public AccessTokenResponse createERPToken(String accessKey, String accessSecret){
        AccessTokenResponse result = new AccessTokenResponse();
        try{
            String erpAccessKey = systemDictDataBiz.queryByCode(Constants.ERP_CONFIG,Constants.ERP_ACCESS_KEY).getCode();
            String erpAccessSecret = systemDictDataBiz.queryByCode(Constants.ERP_CONFIG,Constants.ERP_ACCESS_SECRET).getCode();
            if(!(accessKey.equals(erpAccessKey)&&erpAccessSecret.equals(accessSecret))){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"秘钥匹配失败");
            }
            JwtPayLoad payLoad = new JwtPayLoad(erpAccessKey+"-"+erpAccessSecret);
            String token = JwtTokenUtil.generateToken(payLoad);
            RedisUtil.addObject(redisTemplate,Constants.RedisKeys.ERP_TOKEN,token,Constants.RedisKeys.EXPIRE_TIME);
            result.setToken(token);
            result.setExpireTime(Constants.RedisKeys.EXPIRE_TIME);
            return result;
        }catch (BusinessException e){
            throw e;
        }finally {
            Map<String,String> param = new HashMap<>();
            param.put("accessKey",accessKey);
            param.put("accessSecret",accessSecret);
            saveInterfaceLog(param,"/visitBiz/accesstoken",JSONObject.toJSONString(result),Constants.ZERO);
        }

    }

    /**
     * 门禁组全量接口
     * @param param
     * @return
     */
    @Override
    public List<RoleListResponse> erpQueryDeviceList(RoleListRequest param){
        List<RoleListResponse> result = new ArrayList<>();
       List<DeviceRole> deviceRoleList = this.deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
               .eq(DeviceRole::getIsdeleted,Constants.ZERO)
               .eq(!Objects.isNull(param.getId()),DeviceRole::getId,param.getId())
               .like(StringUtils.isNotBlank(param.getName()),DeviceRole::getName,param.getName())
               .orderByAsc(DeviceRole::getCreateDate)
       );
       List<String> roleIds = new ArrayList<String>();
       if(CollectionUtils.isNotEmpty(deviceRoleList)){
           for (DeviceRole deviceRole:deviceRoleList) {
               if(StringUtils.isNotBlank(deviceRole.getDoorIds())){
                   List<String>  doorList = Arrays.asList(deviceRole.getDoorIds().split(","));
                   roleIds.addAll(doorList);
               }
           }
           if(CollectionUtils.isNotEmpty(roleIds)){
               List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,roleIds));
               for (DeviceRole deviceRole:deviceRoleList) {
                   RoleListResponse roleListResponse = new RoleListResponse();
                   BeanUtils.copyProperties(deviceRole,roleListResponse);
                   if(deviceRole.getType().equals("2")){
                       roleListResponse.setType(Constants.ONE);
                   }else{
                       roleListResponse.setType(Constants.ZERO);
                   }
                   if(StringUtils.isNotBlank(deviceRole.getDoorIds())){
                       List<DeviceListResponse> DeviceListResponseList = new ArrayList<>();
                       List<String>  doorList = Arrays.asList(deviceRole.getDoorIds().split(","));
                       List<Device> roleDeviceList = deviceList.stream().filter(m-> doorList.contains(m.getId().toString())).collect(Collectors.toList());
                       for (Device device:roleDeviceList) {
                           DeviceListResponse deviceListResponse = new DeviceListResponse();
                           BeanUtils.copyProperties(device,deviceListResponse);
                           DeviceListResponseList.add(deviceListResponse);
                       }
                       roleListResponse.setDeviceList(DeviceListResponseList);
                   }
                   result.add(roleListResponse);
               }
           }
       }
       return result;
    }




    /**
     * 停车场全量信息接口
     * @param param
     * @return
     */
    @Override
    public List<ParkListResponse> parkList(ParkListRequest param){
        List<ParkListResponse> result = new ArrayList<>();
        List<Parks> parksList = this.parksMapper.selectList(new QueryWrapper<Parks>().lambda()
                .eq(Parks::getIsdeleted,Constants.ZERO)
                .eq(!Objects.isNull(param.getId()),Parks::getId,param.getId())
                .like(StringUtils.isNotBlank(param.getName()),Parks::getName,param.getName())
        );
        if(CollectionUtils.isNotEmpty(parksList)){
            for (Parks parks:parksList) {
                ParkListResponse parkListResponse = new ParkListResponse();
                BeanUtils.copyProperties(parks,parkListResponse);
                result.add(parkListResponse);
            }
        }
        return result;
    }

    /**
     * 访客出入事件同步接口
     * @param param
     * @return
     */
    @Override
    public PageData<VisitEventListResponse> visitListPage(PageWrap<VisitListRequest> param) {
        PageData<VisitEventListResponse> result = new PageData<>();
            VisitListRequest visitListRequest = param.getModel();
            IPage<VisitEvent> page = new Page<>(param.getPage(), param.getCapacity());
            MPJLambdaWrapper<VisitEvent> queryWrapper = new MPJLambdaWrapper<>();
            Utils.MP.blankToNull(visitListRequest);

            queryWrapper.selectAll(VisitEvent.class);
            queryWrapper.selectAs(Visits::getName, VisitEventListResponse::getVisitorName);
            queryWrapper.selectAs(VisitEvent::getBeVisitedPersonName, VisitEventListResponse::getBeVisitedUserName);
            queryWrapper.selectAs(VisitEvent::getBeVisitedPersonOrg, VisitEventListResponse::getBeVisitedUserOrg);
            queryWrapper.selectAs(VisitEvent::getSex, VisitEventListResponse::getVisitorSex);
            queryWrapper.selectAs(VisitEvent::getVisitorWorkUint, VisitEventListResponse::getVisitorWorkUint);

            queryWrapper.leftJoin(Visits.class,Visits::getId,VisitEvent::getVisitorId);

            if(!Objects.isNull(visitListRequest)){
                queryWrapper.eq(!Objects.isNull(visitListRequest.getEventId()),VisitEvent::getEventId, visitListRequest.getEventId());
                queryWrapper.like(StringUtils.isNotBlank(visitListRequest.getVisitorName()),Visits::getName, visitListRequest.getVisitorName());

                queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getIdNo()),Visits::getIdcardNo, DESUtil.encrypt(Constants.EDS_PWD, visitListRequest.getIdNo()) );

                queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getBeVisitedPersonId()),VisitEvent::getBeVisitedPersonId, visitListRequest.getBeVisitedPersonId());
                queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getBeVisitedPersonOrgId()),VisitEvent::getBeVisitedPersonOrgId, visitListRequest.getBeVisitedPersonOrgId());
                queryWrapper.like(StringUtils.isNotBlank(visitListRequest.getVisitorWorkUint()),VisitEvent::getVisitorWorkUint, visitListRequest.getVisitorWorkUint());
                queryWrapper.ge(StringUtils.isNotBlank(visitListRequest.getInStartTime()),VisitEvent::getStartTime, visitListRequest.getInStartTime());
                queryWrapper.le(StringUtils.isNotBlank(visitListRequest.getInEndTime()),VisitEvent::getStartTime, visitListRequest.getInEndTime());
                queryWrapper.ge(StringUtils.isNotBlank(visitListRequest.getOutStartTime()),VisitEvent::getEndTime, visitListRequest.getOutStartTime());
                queryWrapper.le(StringUtils.isNotBlank(visitListRequest.getOutEndTime()),VisitEvent::getEndTime, visitListRequest.getOutEndTime());

                for(PageWrap.SortData sortData: param.getSorts()) {
                    if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                        queryWrapper.orderByDesc(sortData.getProperty());
                    } else {
                        queryWrapper.orderByAsc(sortData.getProperty());
                    }
                }
            }
            IPage<VisitEventListResponse> pageData = visitEventJoinMapper.selectJoinPage(page, VisitEventListResponse.class,queryWrapper);
            result = PageData.from(pageData);
        return result;
    }


    @Override
    public PageData<DoorEventListResponse> doorEventListPage(PageWrap<DoorEventListRequest> param) {
        PageData<DoorEventListResponse> result = new PageData<>();

            DoorEventListRequest doorEventListRequest = param.getModel();
            IPage<DeviceEvent> page = new Page<>(param.getPage(), param.getCapacity());
            MPJLambdaWrapper<DeviceEvent> queryWrapper = new MPJLambdaWrapper<>();
            Utils.MP.blankToNull(doorEventListRequest);
            queryWrapper.selectAs(DeviceEvent::getEventId,DoorEventListResponse::getEventId);
            queryWrapper.selectAs(DeviceEvent::getEventType,DoorEventListResponse::getEventType);
            queryWrapper.selectAs(Member::getSex,DoorEventListResponse::getSex);
            queryWrapper.selectAs(DeviceEvent::getSrcName,DoorEventListResponse::getSrcName);
            queryWrapper.selectAs(DeviceEvent::getSrcType,DoorEventListResponse::getSrcType);
            queryWrapper.selectAs(Member::getIdcardDecode,DoorEventListResponse::getIdcardNo);
            queryWrapper.selectAs(Member::getName,DoorEventListResponse::getName);
            queryWrapper.selectAs(DeviceEvent::getUserType,DoorEventListResponse::getType);
            queryWrapper.selectAs(DeviceEvent::getExtEventInOut,DoorEventListResponse::getEventInOut);
            queryWrapper.selectAs(DeviceEvent::getExtAccessChannel,DoorEventListResponse::getExtAccessChannel);
            queryWrapper.selectAs(DeviceEvent::getHappenTime,DoorEventListResponse::getCreateTime);
            queryWrapper.selectAs(Member::getPhone,DoorEventListResponse::getPhone);
            queryWrapper.selectAs(Member::getErpId,DoorEventListResponse::getUserId);
            queryWrapper.selectAs(Member::getErpOrgId,DoorEventListResponse::getOrgId);
            queryWrapper.leftJoin(Member.class,Member::getHkId,DeviceEvent::getExtEventPersonNo);

            if(!Objects.isNull(doorEventListRequest)){
                queryWrapper.eq(!Objects.isNull(doorEventListRequest.getEventId()),DeviceEvent::getEventId, doorEventListRequest.getEventId());
                queryWrapper.like(StringUtils.isNotBlank(doorEventListRequest.getName()),Member::getName, doorEventListRequest.getName());
                if(StringUtils.isNotBlank(doorEventListRequest.getIdNo())){
                    //进行加密
                    String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,doorEventListRequest.getIdNo());
                    queryWrapper.eq(Member::getIdcardNo, encryptIdNo);
                }
                queryWrapper.ge(StringUtils.isNotBlank(doorEventListRequest.getStartTime()),DeviceEvent::getCreateDate, doorEventListRequest.getStartTime());
                queryWrapper.le(StringUtils.isNotBlank(doorEventListRequest.getEndTime()),DeviceEvent::getCreateDate, doorEventListRequest.getEndTime());
                for(PageWrap.SortData sortData: param.getSorts()) {
                    if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                        queryWrapper.orderByDesc(sortData.getProperty());
                    } else {
                        queryWrapper.orderByAsc(sortData.getProperty());
                    }
                }
            }

            IPage<DoorEventListResponse> pageData = deviceEventJoinMapper.selectJoinPage(page, DoorEventListResponse.class,queryWrapper);
            result = PageData.from(pageData);
        return result;
    }


    @Override
    public PageData<CarEventListResponse> carEventList(PageWrap<CarEventListRequest> param) {
        PageData<CarEventListResponse> result = new PageData<>();
            CarEventListRequest carEventListRequest = param.getModel();
            IPage<CarEvent> page = new Page<>(param.getPage(), param.getCapacity());
            MPJLambdaWrapper<CarEvent> queryWrapper = new MPJLambdaWrapper<>();
            Utils.MP.blankToNull(carEventListRequest);
            queryWrapper.selectAs(CarEvent::getEventId,CarEventListResponse::getEventId);
            queryWrapper.selectAs(CarEvent::getEventType,CarEventListResponse::getEventType);
            queryWrapper.selectAs(CarEvent::getCreateDate,CarEventListResponse::getCreateTime);
            queryWrapper.selectAs(CarEvent::getInoutType,CarEventListResponse::getInoutType);
            queryWrapper.selectAs(CarEvent::getAlarmCar,CarEventListResponse::getAlarmCar);
            queryWrapper.selectAs(CarEvent::getCarAttributeName,CarEventListResponse::getCarAttributeName);
            queryWrapper.selectAs(CarEvent::getCardNo,CarEventListResponse::getCardNo);
            queryWrapper.selectAs(CarEvent::getEventCmd,CarEventListResponse::getEventCmd);
            queryWrapper.selectAs(CarEvent::getGateIndex,CarEventListResponse::getGateIndex);
            queryWrapper.selectAs(CarEvent::getGateName,CarEventListResponse::getGateName);
            queryWrapper.selectAs(CarEvent::getMainLogo,CarEventListResponse::getMainLogo);
            queryWrapper.selectAs(CarEvent::getParkIndex,CarEventListResponse::getParkId);
            queryWrapper.selectAs(CarEvent::getParkName,CarEventListResponse::getParkName);
            queryWrapper.selectAs(CarEvent::getPlatePicUrl,CarEventListResponse::getPlatePicUrl);
            queryWrapper.selectAs(CarEvent::getVehiclePicUrl,CarEventListResponse::getVehiclePicUrl);
            queryWrapper.selectAs(CarEvent::getPlateNos,CarEventListResponse::getPlateNo);
            queryWrapper.selectAs(CarEvent::getPlateColor,CarEventListResponse::getPlateColor);
            queryWrapper.selectAs(CarEvent::getRoadwayName,CarEventListResponse::getRoadwayName);
            queryWrapper.selectAs(CarEvent::getRoadwayType,CarEventListResponse::getRoadwayType);
            queryWrapper.selectAs(CarEvent::getSubLogo,CarEventListResponse::getSubLogo);
            queryWrapper.selectAs(CarEvent::getSubModel,CarEventListResponse::getSubModel);

            if(!Objects.isNull(carEventListRequest)){
                queryWrapper.eq(!Objects.isNull(carEventListRequest.getEventId()),CarEvent::getEventId, carEventListRequest.getEventId());
                queryWrapper.eq(StringUtils.isNotBlank(carEventListRequest.getParkId()),CarEvent::getParkIndex, carEventListRequest.getParkId());
                queryWrapper.like(StringUtils.isNotBlank(carEventListRequest.getParkName()),CarEvent::getParkName, carEventListRequest.getParkName());
                queryWrapper.eq(StringUtils.isNotBlank(carEventListRequest.getPlateNo()),CarEvent::getPlateNos, carEventListRequest.getPlateNo());
                queryWrapper.ge(StringUtils.isNotBlank(carEventListRequest.getStartTime()),CarEvent::getCreateDate, carEventListRequest.getStartTime());
                queryWrapper.le(StringUtils.isNotBlank(carEventListRequest.getEndTime()),CarEvent::getCreateDate, carEventListRequest.getEndTime());
                for(PageWrap.SortData sortData: param.getSorts()) {
                    if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                        queryWrapper.orderByDesc(sortData.getProperty());
                    } else {
                        queryWrapper.orderByAsc(sortData.getProperty());
                    }
                }
            }
            IPage<CarEventListResponse> pageData = carEventJoinMapper.selectJoinPage(page, CarEventListResponse.class,queryWrapper);
            result = PageData.from(pageData);
            result.getRecords().forEach(i->{
                if(i.getPlatePicUrl().startsWith(HKConstants.IMG_INDEX)){
                    i.setPlatePicUrl(null);
                }
                if(i.getVehiclePicUrl().startsWith(HKConstants.IMG_INDEX)){
                    i.setVehiclePicUrl(null);
                }
            });
        return  result;
    }




    @Override
    public void orgUpdate(OrgUpdateRequest param){
            if(Objects.isNull(param)
                    ||Objects.isNull(param.getId())
                    ||StringUtils.isBlank(param.getName())
//                    ||StringUtils.isBlank(param.getLinkName())
//                    ||StringUtils.isBlank(param.getLinkPhone())
//                    ||Objects.isNull(param.getEditDate())
            ){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            Company company = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,param.getId()).last("limit 1"));
            Company parentCompany = new Company();
            if(StringUtils.isNotBlank(param.getParentId())){
                parentCompany = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,param.getParentId()).last("limit 1"));
                if(Objects.isNull(parentCompany)){
                    throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到上级组织数据");
                }
            }
            String rootOrgId = systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_ROOTORG_CODE).getCode();
            if(Objects.isNull(company)){
                company = new Company();
                company.setId(null);
                company.setCreateDate(new Date());
                company.setHkStatus(Constants.ZERO);
                company.setRemark("待同步安防平台");
                company.setErpStatus(Constants.ONE);
                company.setErpDate(new Date());
                company.setName(param.getName());
               /* if(StringUtils.isNotBlank(param.getParentId())){
                    company.setHkId(rootOrgId);
                }*/
                company.setErpId(param.getId());
                company.setErpParentId(param.getParentId());
                company.setParentId(Objects.isNull(parentCompany)?null:parentCompany.getId());
                company.setErpParentId(param.getParentId());
                company.setFsStatus(Constants.ZERO);
                company.setType(Constants.ONE);
                company.setLinkName(param.getLinkName());
                company.setLinkPhone(param.getLinkPhone());
                companyMapper.insert(company);
                //TODO 海康数据创建
            }else{
//                BeanUtils.copyProperties(param,company);
                company.setEditDate(new Date());
                company.setErpId(param.getId());
            /*    if(StringUtils.isNotBlank(param.getParentId())){
                    company.setHkId(rootOrgId);
                }*/
                company.setHkStatus(Constants.ZERO);
                company.setRemark("待同步安防平台");
                company.setErpDate(new Date());
                company.setName(param.getName());
                company.setErpParentId(param.getParentId());
                company.setParentId(Objects.isNull(parentCompany)?null:parentCompany.getId());
                company.setLinkName(param.getLinkName());
                company.setLinkPhone(param.getLinkPhone());
                companyMapper.updateById(company);
                //TODO 海康数据更新
            }
    }

    @Override
    public void userUpdate(UserUpdateRequest param){
            if(param.getIsdeleted() == 1){
                if(  Objects.isNull(param.getId()) ){
                    throw new BusinessException(ResponseStatus.BAD_REQUEST);
                }
               memberMapper.update(null,new UpdateWrapper<Member>().lambda()
                        .eq(Member::getErpId,param.getId())
                       .eq(Member::getIsdeleted,Constants.ZERO)
                       .set(Member::getIsdeleted,Constants.ONE)
                       .set(Member::getHkStatus,Constants.ZERO)
                       .set(Member::getEditDate,new Date())
                       .set(Member::getRemark,"待同步安防平台")
               );
            }else {
                if( Objects.isNull(param)
                        ||Objects.isNull(param.getId())//编码
                        ||StringUtils.isBlank(param.getName())//名称
                        ||StringUtils.isBlank(param.getIdNo())//证件号
                        ||Objects.isNull(param.getIdType())//证件类型
                        ||Objects.isNull(param.getSex())//性别
                        ||Objects.isNull(param.getOrgId())//所属组织编码
//                    ||StringUtils.isBlank(param.getFaceImg())//人脸照片
                        ||StringUtils.isBlank(param.getCode())//工号
                        ||StringUtils.isBlank(param.getPhone())//手机号
                ){
                    throw new BusinessException(ResponseStatus.BAD_REQUEST);
                }
                Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getId()).last("limit 1"));
                Company company = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,param.getOrgId()).last("limit 1"));
                if(Objects.isNull(company)){
                    throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到组织信息");
                }
                List<Integer> doorIds = null;
                if(Objects.isNull(member)){
                    member = new Member();
                    BeanUtils.copyProperties(param,member);
                    member.setId(null);
                    member.setCreateDate(new Date());
                    member.setRemark("待同步安防平台");
                    member.setHkStatus(Constants.ZERO);
                    member.setErpStatus(Constants.ONE);
                    member.setErpDate(new Date());
                    member.setErpId(param.getId());
                    member.setFaceStatus(Constants.ZERO);
                    member.setCompanyId(company.getId());
                    member.setType(Constants.memberType.internal);
                    member.setCanVisit(Constants.ONE);
                    String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
                    member.setIdcardNo(encryptIdNo);
                    member.setStartTime(param.getValidStartTime());
                    member.setRoleId(param.getRoleIds()!=null?JSONObject.toJSONString(param.getRoleIds()):null);
                    member.setEndTime(param.getValidEndTime());
                    member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
                    member.setErpOrgId(param.getOrgId());
                    memberMapper.insert(member);
                }else{
                    Integer id = member.getId();
                    String faceImg = member.getFaceImg();
                    BeanUtils.copyProperties(param,member);
                    member.setId(id);
                    member.setCompanyId(company.getId());
                    String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
                    member.setIdcardNo(encryptIdNo);
                    member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
                    member.setErpOrgId(param.getOrgId());
                    member.setEditDate(new Date());
                    member.setErpDate(new Date());
                    member.setHkStatus(Constants.ZERO);
                    if(StringUtils.isNotBlank(param.getFaceImg())
                            && !StringUtils.equals(param.getFaceImg(),faceImg)){
                        //只有人脸发生变化，才进行重新同步
                        member.setFaceStatus(Constants.ZERO);
                        member.setRemark("待同步安防平台");
                    }
                    member.setStartTime(param.getValidStartTime());
                    member.setEndTime(param.getValidEndTime());
                    memberMapper.updateById(member);
                }
                //2024年3月7日17:49:33 取消此业务处理人员门禁权限
//                getRoleIdByParam(param.getRoleIds(),member);
                //添加人员卡片数据(已开启虚拟卡功能，系统不需要给虚拟卡)
//                dealMemberCard(member,param);
            }
    }

    /**
     * 添加人员卡片数据
     * @param member
     * @param param
     */
    private void dealMemberCard(Member member, UserUpdateRequest param) {
        if(Objects.isNull(param.getCardList()) || param.getCardList().size()== Constants.ZERO){
           param.setCardList(new ArrayList<>());
           //如果没有卡号，默认给一个卡号
           param.getCardList().add(Constants.VIRTUAL_CARD_INDEX+member.getId());
        }
        if(CollectionUtils.isNotEmpty(param.getCardList())){
            List<MemberCard> memberCardList = new ArrayList<>();
            for (String id:param.getCardList()) {
                MemberCard model = memberCardMapper.selectOne(new QueryWrapper<MemberCard>().lambda()
                        .eq(MemberCard::getCode,id)
                        .eq(MemberCard::getMemberId,member.getId()));

                if(model!=null && Constants.equalsInteger(model.getHkStatus(),Constants.ONE)){
                    //如果已经开卡完成,不做任何处理
                }else if(model !=null){
                    //如果存在，但未开卡，则直接更改为待同步
//                    model.setHkStatus(Constants.ZERO);
//                    model.setRemark("待同步安防平台");
                    model.setIsdeleted(Constants.ZERO);
                    memberCardMapper.updateById(model);
                }else{
                    MemberCard memberCard = new MemberCard();
                    memberCard.setCreateDate(new Date());
                    memberCard.setStatus(Constants.ONE);
                    memberCard.setMemberId(member.getId());
                    memberCard.setIsdeleted(Constants.ZERO);
                    memberCard.setType(HKConstants.CARD_TYPE.NORMAL.getKey());
                    memberCard.setHkStatus(Constants.ZERO);
                    memberCard.setRemark("待同步安防平台");
                    memberCard.setType(Constants.TWO);
                    memberCard.setCode(id);
                    memberCardList.add(memberCard);
                }
            }
            if(memberCardList.size()>0){
                memberCardMapper.insertBatchSomeColumn(memberCardList);
            }
        }
    }
    private   List<Integer>  getRoleIdByParam(Integer[] param, Member member) {
        //添加人员角色关联数据
        member.setRoleId(null);
        if(!Objects.isNull(member)&&!Objects.isNull(member.getId())){
            memberRoleMapper.delete(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId()));
        }
        if(!Objects.isNull(param)&&param.length>Constants.ZERO){
            //查询数据库存在的权限
            List<DeviceRole> deviceRoleList= deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
                    .eq(DeviceRole::getType,Constants.TWO)
                    .in(DeviceRole::getId,param));
            if(CollectionUtils.isNotEmpty(deviceRoleList)){
                List<MemberRole> memberRoleList = new ArrayList<>();
                String ids = "";
                List<Integer> r = new ArrayList<>();
                for (int i = 0; i < deviceRoleList.size(); i++) {
                    DeviceRole deviceRole =deviceRoleList.get(i);
                    if(i>0){
                        ids += ",";
                    }
                    Integer id =deviceRole.getId();
                    ids += "["+id+"]";
                    String doorids =deviceRole.getDoorIds();
                    if(StringUtils.isNotBlank(doorids)){
                        String[] ss = doorids.split(",");
                        try {
                            for(String s :ss){
                                r.add(Integer.parseInt(s));
                            }
                        }catch (Exception e){
                            //脏数据不处理
                        }
                    }
                    MemberRole memberRole = new MemberRole();
                    memberRole.setCreateDate(new Date());
                    memberRole.setMemberId(member.getId());
                    memberRole.setIsdeleted(Constants.ZERO);
                    memberRole.setRoleId(deviceRole.getId().toString());
                    memberRoleList.add(memberRole);
                }
                memberRoleMapper.insertBatchSomeColumn(memberRoleList);
                member.setRoleId(ids);
                return  r;
            }
        }
        return  null;
    }


    @Override
    public void roleUserAuthor(UserAuthorRequest param){
            if(Objects.isNull(param)
                    ||StringUtils.isBlank(param.getUserId())){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            if(Objects.nonNull(param.getValidStartTime())&&Objects.nonNull(param.getValidEndTime())){
                if(param.getValidStartTime().getTime()> param.getValidEndTime().getTime()){
                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，有效期时间不合法！");
                }
            }
            Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
            if(Objects.isNull(member)){
                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，用户信息不存在！");
            }
            List<Integer> doorIds = getRoleIdByParam(param.getRoleIds(),member);
            if(param.getRoleIds()!=null && param.getRoleIds().length>0 && StringUtils.isBlank(member.getRoleId())){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，未查询到有效门禁组数据");
            }
            //重新授权
            HkSyncOrgUserToHKServiceImpl.dealMemberRoleEmpowerDo(null,member,deviceRoleMapper,empowerMapper,deviceMapper);


       /* memberMapper.update(null,new UpdateWrapper<Member>().lambda()
                    .eq(Member::getId,member.getId())
                    .set(Member::getRoleId,member.getRoleId())
                    .set(Member::getRemark,"待同步安防平台")
                    .set(Member::getStartTime,param.getValidStartTime())
                    .set(Member::getEndTime,param.getValidEndTime())
                    .set(Member::getEditDate,new Date())
                    .set(Member::getHkStatus,Constants.ZERO ));*/
    }


    @Override
    public void parkCarAuthor(CarAuthorRequest param){
            if(Objects.isNull(param)
                    ||StringUtils.isBlank(param.getCarCode())){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            if(Objects.nonNull(param.getValidStartTime())&&Objects.nonNull(param.getValidEndTime())){
                if(param.getValidStartTime().getTime()> param.getValidEndTime().getTime()){
                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，有效期时间不合法！");
                }
            }
            Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
            if(Objects.isNull(member)){
                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，用户信息不存在！");
            }
            //删除车量库记录数据
            parkBookMapper.update(null,new UpdateWrapper<ParkBook>().lambda()
                    .eq(ParkBook::getCarCode,param.getCarCode())
                    .set(ParkBook::getIsdeleted,Constants.ONE)
                    .set(ParkBook::getHkStatus,Constants.ZERO)
            );
            //查询车库信息
            if(CollectionUtils.isNotEmpty(param.getParkIdList())){
                List<Parks>  parksList  = parksMapper.selectList(new QueryWrapper<Parks>().lambda()
                        .in(Parks::getId,param.getParkIdList())
                );
                if(CollectionUtils.isNotEmpty(parksList)){
                    List<ParkBook> parkBookList = new ArrayList<>();
                    for (Parks parks:parksList) {
                        ParkBook parkBook = new ParkBook();
                        parkBook.setIsdeleted(Constants.ZERO);
                        parkBook.setCreateDate(new Date());
                        parkBook.setCarCode(param.getCarCode());
                        parkBook.setParkId(parks.getId());
                        parkBook.setOrigin(Constants.ZERO);
                        parkBook.setStartTime(Objects.isNull(param.getValidStartTime())?null:param.getValidStartTime());
                        parkBook.setEndTime(Objects.isNull(param.getValidEndTime())?null:param.getValidEndTime());
                        parkBook.setTimeType(Objects.isNull(param.getValidEndTime())?Constants.ZERO:Constants.ONE);
                        parkBook.setMemberId(member.getId());
                        parkBook.setHkStatus(Constants.ZERO);
                        parkBook.setRemark("待同步安防平台");
                        parkBookList.add(parkBook);
                    }
                    parkBookMapper.insertBatchSomeColumn(parkBookList);
                }else{
                    throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，停车库信息不存在，授权失败");
                }
            }
    }
    private void isValidDoors(String doors) {
        if(StringUtils.isNotBlank(doors)){
            String[] dIds = doors.split(",");
            List<DeviceRole> roles = deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
                    .eq(DeviceRole::getIsdeleted,Constants.ZERO)
                    .eq(DeviceRole::getType,Constants.DeviceRoleType.fk)
                    .in(DeviceRole::getId, Arrays.asList(dIds)));
            if(roles == null || roles.size()==0 || roles.size() != dIds.length){
                throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请选择有效的访客门禁组！");
            }
        }

    }

    @Override
    public void approveApply(ApproveNoticeRequest param){
        try{
            if(Objects.isNull(param)
                    ||Objects.isNull(param.getId())
                    ||Objects.isNull(param.getStatus())){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            if(!(param.getStatus()==Constants.ZERO||param.getStatus()==Constants.ONE)){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"审批结果参数不正确");
            }
            if(visitsMapper.selectCount(new QueryWrapper<Visits>().lambda().eq(Visits::getErpId,param.getId())
                    .ne(Visits::getStatus,Constants.VisitStatus.submitCheck))>Constants.ZERO){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该申请当前状态不支持该操作");
            }
            isValidDoors(param.getDoors());
            List<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda().eq(Visits::getErpId,param.getId()));
            if(CollectionUtils.isNotEmpty(visitsList)){
                visitsList.forEach(i->{
                    i.setEndCheckInfo("申请时间："+DateUtil.getPlusTime2(i.getStarttime())+"-"
                            +DateUtil.getPlusTime2(i.getEndtime())
                            +" 申请门禁："+i.getDoors());
                    i.setStatus(!param.getStatus().equals(Constants.ZERO)?Constants.VisitStatus.pass:Constants.VisitStatus.noPass);
                    i.setEndCheckDate(DateUtil.StringToDate(param.getApproveDate(),"yyyy-MM-dd HH:mm:ss"));
                    i.setHkStatus(Constants.ZERO);
                    i.setRemark("待同步安防平台");
                    i.setStarttime( param.getStartTime());
                    i.setEndtime(param.getEndTime());
                    i.setDoors(param.getDoors());
                    visitsMapper.updateById(i);
                    if(Objects.isNull(i.getParentId())){
                        wxPlatNotice.sendVisitAuditTemplateNotice(i,
                                systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_PREFIX).getCode(),
                                systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_AUDIT_VISIT).getCode());
                    }
                });
            }
        }catch (BusinessException e){
            throw e;
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/approveApply",null,Constants.ZERO);
        }
    }


    @Override
    public void saveInterfaceLog(Object param, String path, String result, Integer type) {
        InterfaceLog interfaceLog=new InterfaceLog();
        interfaceLog.setType(type);
        interfaceLog.setCreateDate(new Date());
        interfaceLog.setIsdeleted(Constants.ZERO);
        if(param!=null){
            interfaceLog.setRequest(JSONObject.toJSONString(param));
        }
        interfaceLog.setPlat(Constants.ONE);
        interfaceLog.setRepose(result);
        interfaceLog.setName(path);
        interfaceLog.setUrl(path);
        interfaceLogService.create(interfaceLog);
    }

}