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.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.config.Jwt.JwtPayLoad; import com.doumee.config.Jwt.JwtTokenUtil; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.haikang.model.HKConstants; 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.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.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.model.openapi.request.*; 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.*; import com.doumee.core.model.openapi.response.erp.OrgListRespone; import com.doumee.core.utils.Constants; import com.doumee.core.utils.DESUtil; import com.doumee.core.utils.Utils; import com.doumee.core.utils.redis.RedisUtil; import com.doumee.dao.admin.response.MemberInfoDTO; 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.dao.web.reqeust.CheckVisitedDTO; import com.doumee.dao.web.response.MemberVO; import com.doumee.service.business.*; import com.github.yulichang.wrapper.MPJLambdaWrapper; import io.swagger.models.auth.In; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.checkerframework.checker.units.qual.A; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import javax.servlet.http.HttpServletResponse; 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 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; @Autowired private CarEventJoinMapper carEventJoinMapper; @Autowired private CompanyMapper companyMapper; @Autowired private MemberMapper memberMapper; @Autowired private MemberRoleMapper memberRoleMapper; @Autowired private MemberCardMapper memberCardMapper; @Autowired private InterfaceLogService interfaceLogService; /** * 同步ERP组织信息 * @param param * @return */ @Override public String syncCompany(OrgListRequest param){ List allList = new ArrayList<>(); return null; } /** * 同步ERP人员信息 * @param param * @return */ @Override public String syncUsers(UserListRequest param){ return null; } /** * 获取ERP人员信息 * @param param * @return */ @Override public String syncUserInfo(UserInfoRequest param){ return null; } @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); }catch (Exception e){ }finally { Map param = new HashMap<>(); param.put("accessKey",accessKey); param.put("accessSecret",accessSecret); saveInterfaceLog(param,"/visitBiz/accesstoken",JSONObject.toJSONString(result),Constants.ZERO); } return result; } /** * 门禁组全量接口 * @param param * @return */ @Override public List erpQueryDeviceList(RoleListRequest param){ List result = new ArrayList<>(); try{ 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(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); } } } }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/role/list",JSONObject.toJSONString(result),Constants.ZERO); } return result; } /** * 停车场全量信息接口 * @param param * @return */ @Override public List parkList(ParkListRequest param){ List result = new ArrayList<>(); try{ 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); } } }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/park/list",JSONObject.toJSONString(result),Constants.ZERO); } return result; } /** * 访客出入事件同步接口 * @param param * @return */ @Override public PageData visitListPage(PageWrap param) { PageData result = new PageData<>(); try{ 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.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()),VisitEvent::getIdNo, 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); }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/visit/list",JSONObject.toJSONString(result),Constants.ZERO); } return result; } @Override public PageData doorEventListPage(PageWrap param) { PageData result = new PageData<>(); try{ 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(DeviceEvent::getSex,DoorEventListResponse::getSex); queryWrapper.selectAs(DeviceEvent::getSrcName,DoorEventListResponse::getSrcName); queryWrapper.selectAs(DeviceEvent::getSrcType,DoorEventListResponse::getSrcType); queryWrapper.selectAs(DeviceEvent::getIdcardDecode,DoorEventListResponse::getIdcardNo); queryWrapper.selectAs(DeviceEvent::getName,DoorEventListResponse::getName); queryWrapper.selectAs(DeviceEvent::getUserType,DoorEventListResponse::getType); queryWrapper.selectAs(DeviceEvent::getExtEventInOut,DoorEventListResponse::getEventInOut); queryWrapper.selectAs(DeviceEvent::getExtAccessChannel,DoorEventListResponse::getExtAccessChannel); queryWrapper.selectAs(DeviceEvent::getCreateDate,DoorEventListResponse::getCreateTime); queryWrapper.selectAs(Member::getPhone,DoorEventListResponse::getPhone); queryWrapper.selectAs(Member::getErpId,DoorEventListResponse::getUserId); queryWrapper.selectAs(Member::getCompanyId,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()),DeviceEvent::getName, doorEventListRequest.getName()); if(StringUtils.isNotBlank(doorEventListRequest.getIdNo())){ //进行加密 String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,doorEventListRequest.getIdNo()); queryWrapper.eq(DeviceEvent::getIdNum, encryptIdNo); } queryWrapper.ge(StringUtils.isNotBlank(doorEventListRequest.getStartTime()),DeviceEvent::getHappenTime, doorEventListRequest.getStartTime()); queryWrapper.le(StringUtils.isNotBlank(doorEventListRequest.getEndTime()),DeviceEvent::getHappenTime, 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); }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/doorEvent/list",JSONObject.toJSONString(result),Constants.ZERO); } return result; } @Override public PageData carEventList(PageWrap param) { PageData result = new PageData<>(); try{ 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::getInoutType,CarEventListResponse::getEventType); 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::getHappenTime, carEventListRequest.getStartTime()); queryWrapper.le(StringUtils.isNotBlank(carEventListRequest.getEndTime()),CarEvent::getHappenTime, 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); } }); }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/carEventList",JSONObject.toJSONString(result),Constants.ZERO); } return result; } @Override public void orgUpdate(OrgUpdateRequest param){ try{ 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")); if(Objects.isNull(company)){ company = new Company(); BeanUtils.copyProperties(param,company); company.setId(null); company.setCreateDate(new Date()); company.setHkStatus(Constants.ZERO); company.setErpStatus(Constants.ONE); company.setErpDate(new Date()); company.setErpId(param.getId()); company.setFsStatus(Constants.ZERO); company.setType(Constants.ONE); companyMapper.insert(company); //TODO 海康数据创建 }else{ BeanUtils.copyProperties(param,company); company.setEditDate(new Date()); company.setErpDate(new Date()); companyMapper.updateById(company); //TODO 海康数据更新 } }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/orgUpdate",null,Constants.ZERO); } } @Override public void userUpdate(UserUpdateRequest param){ try{ 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.isNotBlank(param.getFaceImg()) ||StringUtils.isNotBlank(param.getCode()) ||StringUtils.isNotBlank(param.getPhone()) ||Objects.isNull(param.getEditDate()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } Member member = memberMapper.selectOne(new QueryWrapper().lambda().eq(Member::getErpId,param.getId()).last("limit 1")); if(Objects.isNull(member)){ member = new Member(); BeanUtils.copyProperties(param,member); member.setCreateDate(new Date()); member.setHkStatus(Constants.ZERO); member.setErpStatus(Constants.ONE); member.setErpDate(new Date()); member.setErpId(param.getId()); member.setFsStatus(Constants.ZERO); member.setType(Constants.memberType.internal); String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo()); member.setIdcardNo(encryptIdNo); member.setIdcardDecode(Constants.getTuominStr(param.getIdNo())); member.setCompanyId(param.getOrgId()); memberMapper.insert(member); //TODO 海康数据创建 }else{ BeanUtils.copyProperties(param,member); String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo()); member.setIdcardNo(encryptIdNo); member.setIdcardDecode(Constants.getTuominStr(param.getIdNo())); member.setCompanyId(param.getOrgId()); member.setEditDate(new Date()); member.setErpDate(new Date()); memberMapper.updateById(member); //删除用户卡片数据 人员角色关联 memberCardMapper.delete(new QueryWrapper().lambda().eq(MemberCard::getMemberId,member.getId())); memberRoleMapper.delete(new QueryWrapper().lambda().eq(MemberRole::getMemberId,member.getId())); //TODO 海康数据更新 } //添加人员角关联数据 if(!Objects.isNull(param.getRoleIds())&¶m.getRoleIds().length>Constants.ZERO){ //查询数据库存在的权限 List memberRoleList = memberRoleMapper.selectList(new QueryWrapper().lambda().eq(MemberRole::getId,param.getRoleIds())); List roleIds = Arrays.asList(param.getRoleIds()); // List memberRoleList = new ArrayList<>(); // // for (Integer id:roleIds) { // // } } }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/userUpdate",null,Constants.ZERO); } } private 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); } }