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.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.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<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){
|
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人员信息
|
* @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<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.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<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;
|
}
|
|
|
|
/**
|
* 提交用户同步失败记录
|
* @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);
|
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.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<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);
|
}
|
}
|
}
|
|
|
@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<Member>().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<Member>().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<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);
|
}
|
|
}
|
