package com.zt.modules.sys.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.zt.common.service.BaseService;
|
import com.zt.modules.sys.dao.SysPostUserDao;
|
import com.zt.modules.sys.dto.PostDto;
|
import com.zt.modules.sys.model.SysPostUser;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* SYS_POST_USER
|
*
|
* @author zt generator
|
* @since 1.0.0 2020-06-11
|
*/
|
@Service
|
public class SysPostUserService extends BaseService<SysPostUserDao, SysPostUser> {
|
|
/**
|
* 根据用户ID，获取岗位ID列表
|
*/
|
public List<PostDto> getUserPosts(Long userId) {
|
return baseDao.getUserPosts(userId);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void saveOrUpdate(Long userId, List<Long> postIdList) {
|
List<SysPostUser> list = postIdList.stream().map(postId -> new SysPostUser(postId, userId))
|
.collect(Collectors.toList());
|
this.saveRelatedDatas("user_id", userId, "post_id", list);
|
}
|
|
/**
|
* 根据岗位id，删除岗位用户关系
|
*
|
* @param postId
|
* 岗位id
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void deleteByPostId(Long postId) {
|
baseDao.delete(new QueryWrapper<SysPostUser>().lambda().eq(SysPostUser::getPostId, postId));
|
}
|
}
|
