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.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.ApproveInfoResponse; 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.haikang.model.param.BaseResponse; import com.doumee.core.haikang.model.param.request.OrgAddRequest; import com.doumee.core.haikang.model.param.request.OrgDelRequest; import com.doumee.core.haikang.service.HKService; 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.OrgListRespone; import com.doumee.core.erp.model.openapi.response.erp.UserListRespone; 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.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.ERPSyncService; import com.doumee.service.business.InterfaceLogService; import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.hikvision.artemis.sdk.config.ArtemisConfig; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.checkerframework.checker.units.qual.C; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; 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 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 VisitsMapper visitsMapper; @Autowired private InterfaceLogService interfaceLogService; @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_USERSTATUS_RL).getCode(); ErpConstants.userStatusUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERSTATUS_RL).getCode(); return 0; } /** * 同步ERP组织信息 * @param param * @return */ @Override @Transactional public String syncCompany(OrgListRequest param){ //获取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.insertBatchSomeColumn(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(OrgListRespone 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; } 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(OrgListRespone respone,Company company,Date date) { company.setName(respone.getName()); company.setErpId(respone.getId()); company.setEditDate(date); company.setStatus(respone.getStatus()); company.setCode(respone.getCode()); company.setErpParentId(respone.getParentOrgId()); company.setErpDate(date); company.setHkStatus(Constants.ZERO); return company; } /** * 更新组织对象 * @param respone * @param date * @return */ private Company getAddCompanyModel(OrgListRespone respone, Date date) { Company company = new Company(); company.setIsdeleted(Constants.ZERO); company.setName(respone.getName()); company.setErpId(respone.getId()); company.setCreateDate(date); company.setCode(respone.getCode()); company.setErpParentId(respone.getParentOrgId()); company.setErpDate(date); company.setHkStatus(Constants.ZERO); return company; } private boolean isCompanyDeleted(Company c, List list) { for(OrgListRespone 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 public String syncUsers(UserListRequest param){ 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 allList = memberMapper.selectList(new QueryWrapper().lambda() .eq(Member::getIsdeleted,Constants.ZERO) .eq(Member::getType, Constants.memberType.internal)); dealUserChangeList(list,addList,updateList,delIds,allList); if(addList.size()>0){ memberMapper.insertBatchSomeColumn(addList); } if(updateList.size()>0){ for(Member c : updateList){ memberMapper.updateById(c); } } if(delIds.size()>0){ //删除所有需要删除的组织信息(逻辑删除） memberMapper.update(null,new UpdateWrapper().lambda().set(Member::getHkStatus,Constants.ZERO) .set(Member::getIsdeleted, Constants.ONE).in(Member::getId,delIds)); } }else{ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "同步ERP数据为空！"); } return null; } private void dealUserChangeList(List list, List addList, List updateList, List delIds, List allList) { Date date = new Date(); for(UserListRespone response : list){ //根据 erpId 查询用户信息，判断是新增还是更新 Member member = findUserByERPId(allList,response.getId()); if(member == null){ //如果是新增 if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){ continue; } //封装新增组织对象数据 addList.add(getAddMemberModel(response,date)); }else{ //如果是更新 if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){ //如果已删除，加入删除集合中 delIds.add(member.getId()); continue; } updateList.add(addUpdateMemberModel(response,member,date)); } } if(allList!=null && allList.size()>0){ for(Member c : allList){ if(isUserDeleted(c,list)){ delIds.add(c.getId()); } } } } private Member getAddMemberModel(UserListRespone param, Date date) { 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()); member.setHkStatus(Constants.ZERO); return member; } private Member addUpdateMemberModel(UserListRespone param,Member member,Date date) { 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()); member.setHkStatus(Constants.ZERO); return member; } private boolean isUserDeleted(Member c, List list) { for(UserListRespone m : list){ if(StringUtils.equals(c.getErpId(),m.getId().toString())){ 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(),"秘钥匹配失败"); } 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.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()); company.setHkStatus(Constants.ZERO); company.setErpDate(new Date()); company.setErpParentId(param.getParentId()); company.setLinkName(param.getLinkName()); company.setLinkPhone(param.getLinkPhone()); 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 deviceRoleList = deviceRoleMapper.selectList(new QueryWrapper().lambda().eq(DeviceRole::getId,param.getRoleIds())); if(CollectionUtils.isNotEmpty(deviceRoleList)){ List memberRoleList = new ArrayList<>(); for (DeviceRole deviceRole:deviceRoleList) { 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); } } //添加人员卡片数据 if(!Objects.isNull(param.getCardList())&¶m.getCardList().size()>Constants.ZERO){ if(CollectionUtils.isNotEmpty(param.getCardList())){ List memberCardList = new ArrayList<>(); for (String id:param.getCardList()) { MemberCard memberCard = new MemberCard(); memberCard.setCreateDate(new Date()); memberCard.setMemberId(member.getId()); memberCard.setIsdeleted(Constants.ZERO); memberCard.setCode(id); memberCardList.add(memberCard); } memberCardMapper.insertBatchSomeColumn(memberCardList); } } }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/userUpdate",null,Constants.ZERO); } } @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(),"数据状态码错误"); } List visitsList = visitsMapper.selectList(new QueryWrapper().lambda().eq(Visits::getErpId,param.getId())); if(CollectionUtils.isNotEmpty(visitsList)){ visitsList.forEach(i->{ 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); visitsMapper.updateById(i); }); } }catch (Exception e){ e.printStackTrace(); }finally { saveInterfaceLog(param,"/visitBiz/resource/approveApply",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); } }