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);
    }
}