package com.doumee.service.business.impl.erp; 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.plugins.pagination.Page; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.config.DataSyncConfig; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.erp.ErpConstants; import com.doumee.core.erp.ErpTool; import com.doumee.core.erp.model.openapi.request.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.dao.CompanyMapper; 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.MemberServiceImpl; 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.annotation.PostConstruct; import java.util.*; import java.util.stream.Collectors; /** * 设备信息表Service实现 * @author 江蹄蹄 * @date 2023/11/30 15:33 */ @Service public class ErpSyncServiceImpl implements ERPSyncService { @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private DataSyncConfig dataSyncConfig; @Autowired private RedisTemplate 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){ if( Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin()) != DataSyncConfig.origin.erp){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，当前不支持组织同步操作~"); } //获取ERP组织信息（全量同步） List list = erpTool.getErpOrgList(ErpConstants.orgListUrl,param); if(list !=null && list.size()>0){ List addList = new ArrayList<>(); List updateList = new ArrayList<>(); List delIds = new ArrayList<>(); List allList = companyMapper.selectList(new QueryWrapper().lambda().eq(Company::getType,Constants.ONE)); dealCompanyChangeList(list,addList,updateList,delIds,allList); if(addList.size()>0){ companyMapper.insert(addList); } if(updateList.size()>0){ for(Company c : updateList){ companyMapper.updateById(c); } } if(delIds.size()>0){ //删除所有需要删除的组织信息(逻辑删除） companyMapper.update(null,new UpdateWrapper().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 list, List addList, List updateList, List delIds, List 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 list) { for(ErpOrgListResponse m : list){ if(StringUtils.equals(c.getErpId(),m.getId())){ return true; } } return false; } private Company findCompanyByERPId(List allList, String id) { if(allList!=null){ for(Company com :allList){ if(StringUtils.equals(com.getErpId(),id)){ return com; } } } return null; } /** * 同步ERP人员信息 * @param param * @return */ @Override @Transactional @Synchronized public String syncUsers(UserListRequest param){ if( Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin()) != DataSyncConfig.origin.erp){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，当前不支持组织同步操作~"); } List list = erpTool.getErpUserList(ErpConstants.userListUrl,param); if(list !=null && list.size()>0) { List addList = new ArrayList<>(); List updateList = new ArrayList<>(); List delIds = new ArrayList<>(); List delList = new ArrayList<>(); List allList = memberMapper.selectList(new QueryWrapper().lambda() .eq(Member::getIsdeleted,Constants.ZERO) .eq(Member::getType, Constants.memberType.internal)); dealUserChangeList(list,addList,updateList,delList,allList,param); if(addList.size()>0){ memberMapper.insert(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().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 doorIds = getRoleIdByParam(member.getRoleIds(),member); //添加人员卡片数据 dealMemberCard(member,new UserUpdateRequest()); } private void dealUserChangeList(List list, List addList, List updateList, List delList, List 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().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.setFaceStatus(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 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 allList, String id) { if(allList!=null){ for(Member com :allList){ if(StringUtils.equals(com.getErpId(),id)){ return com; } } } return null; } /** * 提交用户同步失败记录 * @param param * @return */ @Override 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(),"秘钥匹配失败"); // // 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 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 erpQueryDeviceList(RoleListRequest param){ List result = new ArrayList<>(); List deviceRoleList = this.deviceRoleMapper.selectList(new QueryWrapper().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 roleIds = new ArrayList(); if(CollectionUtils.isNotEmpty(deviceRoleList)){ for (DeviceRole deviceRole:deviceRoleList) { if(StringUtils.isNotBlank(deviceRole.getDoorIds())){ List doorList = Arrays.asList(deviceRole.getDoorIds().split(",")); roleIds.addAll(doorList); } } if(CollectionUtils.isNotEmpty(roleIds)){ List deviceList = deviceMapper.selectList(new QueryWrapper().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 DeviceListResponseList = new ArrayList<>(); List doorList = Arrays.asList(deviceRole.getDoorIds().split(",")); List 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 parkList(ParkListRequest param){ List result = new ArrayList<>(); List parksList = this.parksMapper.selectList(new QueryWrapper().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 visitListPage(PageWrap param) { PageData result = new PageData<>(); VisitListRequest visitListRequest = param.getModel(); IPage page = new Page<>(param.getPage(), param.getCapacity()); MPJLambdaWrapper 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 pageData = visitEventJoinMapper.selectJoinPage(page, VisitEventListResponse.class,queryWrapper); result = PageData.from(pageData); return result; } @Override public PageData doorEventListPage(PageWrap param) { PageData result = new PageData<>(); DoorEventListRequest doorEventListRequest = param.getModel(); IPage page = new Page<>(param.getPage(), param.getCapacity()); MPJLambdaWrapper 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 pageData = deviceEventJoinMapper.selectJoinPage(page, DoorEventListResponse.class,queryWrapper); result = PageData.from(pageData); return result; } @Override public PageData carEventList(PageWrap param) { PageData result = new PageData<>(); CarEventListRequest carEventListRequest = param.getModel(); IPage page = new Page<>(param.getPage(), param.getCapacity()); MPJLambdaWrapper 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 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().lambda().eq(Company::getErpId,param.getId()).last("limit 1")); Company parentCompany = new Company(); if(StringUtils.isNotBlank(param.getParentId())){ parentCompany = companyMapper.selectOne(new QueryWrapper().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.setStatus(Constants.ZERO); company.setType(Constants.ONE); company.setIsdeleted(Constants.ZERO); 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().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().lambda().eq(Member::getErpId,param.getId()).last("limit 1")); Company company = companyMapper.selectOne(new QueryWrapper().lambda().eq(Company::getErpId,param.getOrgId()).last("limit 1")); if(Objects.isNull(company)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到组织信息"); } List 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 memberCardList = new ArrayList<>(); for (String id:param.getCardList()) { MemberCard model = memberCardMapper.selectOne(new QueryWrapper().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.insert(memberCardList); } } } @Override @Transactional 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().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1")); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，用户信息不存在！"); } Integer ischange = MemberServiceImpl.getRoleIdByParam(param.getRoleIds(),member,memberRoleMapper,deviceRoleMapper); if(ischange == 0){ return;//未发现权限变化，直接返回 } if(param.getRoleIds()!=null && param.getRoleIds().length>0 && StringUtils.isBlank(member.getRoleId())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，未查询到有效门禁组数据"); } memberMapper.update(null,new UpdateWrapper().lambda() .eq(Member::getId,member.getId()) .set(Member::getRoleId,member.getRoleId()) .set(Member::getStartTime,param.getValidStartTime()) .set(Member::getEndTime,param.getValidEndTime()) .set(Member::getEditDate,new Date()) ); //重新授权 HkSyncOrgUserToHKServiceImpl.dealMemberRoleEmpowerDo(null,member,deviceRoleMapper,empowerMapper,deviceMapper); } @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().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().lambda() .eq(ParkBook::getCarCode,param.getCarCode()) .set(ParkBook::getIsdeleted,Constants.ONE) .set(ParkBook::getHkStatus,Constants.ZERO) ); //查询车库信息 if(CollectionUtils.isNotEmpty(param.getParkIdList())){ List parksList = parksMapper.selectList(new QueryWrapper().lambda() .in(Parks::getId,param.getParkIdList()) ); if(CollectionUtils.isNotEmpty(parksList)){ List 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.insert(parkBookList); }else{ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，停车库信息不存在，授权失败"); } } } private void isValidDoors(String doors) { if(StringUtils.isNotBlank(doors)){ String[] dIds = doors.split(","); List roles = deviceRoleMapper.selectList(new QueryWrapper().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().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 visitsList = visitsMapper.selectList(new QueryWrapper().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); } }