package com.ks.app.service.impl;
|
|
import com.ks.app.dao.admin.AdminUserDao;
|
import com.ks.app.entity.admin.AdminUser;
|
import com.ks.app.service.inter.AdminUserService;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author hxh
|
* @title: AdminUserServiceImpl
|
* @description:
|
* @date 2021/11/13 12:57
|
*/
|
@Service
|
public class AdminUserServiceImpl implements AdminUserService {
|
|
@Resource
|
private AdminUserDao adminUserDao;
|
|
@Override
|
public AdminUser selectByAccount(String account) {
|
return adminUserDao.selectByAccount(account);
|
}
|
|
@Override
|
public void add(AdminUser adminUser) throws Exception {
|
if (selectByAccount(adminUser.getAccount()) != null) {
|
throw new Exception("账号已存在");
|
}
|
|
if (adminUser.getCreateTime() == null) {
|
adminUser.setCreateTime(new Date());
|
}
|
|
adminUserDao.save(adminUser);
|
}
|
|
@Override
|
public void update(AdminUser adminUser) {
|
if (adminUser.getAccount() == null) {
|
return;
|
}
|
adminUserDao.updateSelective(adminUser);
|
}
|
|
@Override
|
public List<AdminUser> list(int page, int pageSize) {
|
AdminUserDao.DaoQuery daoQuery = new AdminUserDao.DaoQuery();
|
daoQuery.start = (page - 1) * pageSize;
|
daoQuery.count = pageSize;
|
return adminUserDao.list(daoQuery);
|
}
|
|
@Override
|
public long count() {
|
AdminUserDao.DaoQuery daoQuery = new AdminUserDao.DaoQuery();
|
return adminUserDao.count(daoQuery);
|
}
|
|
@Override
|
public void delete(List<String> ids) {
|
Query query = new Query();
|
Criteria[] ors = new Criteria[ids.size()];
|
for (int i = 0; i < ids.size(); i++) {
|
ors[i] = Criteria.where("_id").is(ids.get(i));
|
}
|
query.addCriteria(new Criteria().orOperator(ors));
|
adminUserDao.delete(query);
|
}
|
}
|
