com,jsj,service,Impl====新闻发布系统（9）

该层从Web层获取数据，对DAO层进行操作，获取操作结果，最后再将结果反馈到Web层

AdminServiceImpl

package com.jsj.service.Impl;

import com.jsj.dao.AdminDao;
import com.jsj.entity.Admin;
import com.jsj.factory.DaoFactory;
import com.jsj.service.AdminService;

public class AdminServiceImpl implements AdminService {
    //
    private AdminDao adminDao = (AdminDao) DaoFactory.getDao("AdminDao");



    @Override
    public Admin login(String username, String password) {
        try {
            return adminDao.getAdminByPassword(username, password);
        } catch (Exception e) {
            return null;
        }
    }
}

NewCateServiceImpl

package com.jsj.service.Impl;

import com.jsj.dao.NewsCateDao;
import com.jsj.dao.NewsDao;
import com.jsj.entity.News;
import com.jsj.entity.NewsCateVo;
import com.jsj.entity.NewsCate;
import com.jsj.factory.DaoFactory;
import com.jsj.service.NewsCateService;
import com.jsj.utils.JdbcUtils;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class NewsCateServiceImpl implements NewsCateService {

    private NewsCateDao newsCateDao = (NewsCateDao) DaoFactory.getDao("NewsCateDao");

    private NewsDao newsDao = (NewsDao) DaoFactory.getDao("NewsDao");

    @Override
    public List<NewsCate> getAllCate() {
        try {
            return newsCateDao.getAll();
        } catch (Exception e) {
            return null;
        }
    }

    @Override
    public List<NewsCateVo> getAllNewsCateVo(Integer length) {
        try {
            List<NewsCateVo> allNewsCateVo = new ArrayList<>();
            List<NewsCate> newsAllCate = newsCateDao.getAll();
            for (NewsCate newsCate:newsAllCate ) {
                NewsCateVo newsCateVo = new NewsCateVo();
                newsCateVo.setCateId(newsCate.getId());
                newsCateVo.setName(newsCate.getName());
                newsCateVo.setNews(newsDao.getNewsListByCate(newsCate.getId(),0,length));
                allNewsCateVo.add(newsCateVo);
            }
            return allNewsCateVo;
        }catch (Exception e){
            return null;
        }
    }

    @Override
    public NewsCate getNewsCateById(Integer id) {
        try {
            return newsCateDao.getById(id);
        } catch (Exception e) {
            return null;
        }
    }

    @Override
    public int insert(NewsCate newsCate) {
        try {
            return newsCateDao.insert(newsCate);
        } catch (Exception e) {
            return -1;
        }
    }

    @Override
    public int update(NewsCate newsCate) {
        try {
            return newsCateDao.update(newsCate);
        } catch (Exception e) {
            return -1;
        }
    }

    @Override
    public int delete(Integer id) {
        try {
            JdbcUtils.beginTransaction();
            List<News> newsList = newsDao.getNewsListByCate(id,0,newsDao.getCountByCate(id));
            for (News news:newsList) {
                newsDao.deleteById(news.getId());
            }
            int res = newsCateDao.deleteById(id);
            if (res<1){
                try {
                    JdbcUtils.rollbackTransaction();
                    return 0;
                } catch (SQLException ignored) {}
            }
            JdbcUtils.commitTransaction();
            return res;
        } catch (Exception e) {
            try {
                JdbcUtils.rollbackTransaction();
                return 0;
            } catch (Exception ignored) {}
        }
        try {
            return newsCateDao.deleteById(id);
        } catch (Exception e) {
            return -1;
        }
    }
}

NewsServiceImpl

package com.jsj.service.Impl;

import com.jsj.dao.NewsCateDao;
import com.jsj.dao.NewsDao;
import com.jsj.entity.News;
import com.jsj.entity.NewsVo;
import com.jsj.entity.Page;
import com.jsj.factory.DaoFactory;
import com.jsj.service.NewsService;

import java.util.ArrayList;
import java.util.List;

public class NewsServiceImpl implements NewsService {

    private NewsDao newsDao = (NewsDao) DaoFactory.getDao("NewsDao");

    private NewsCateDao newsCateDao = (NewsCateDao) DaoFactory.getDao("NewsCateDao");

    @Override
    public Page<NewsVo> getNewsVoPage(Integer pageIndex, Integer pageSize) {
        Page <NewsVo> newsVoPage = new Page <>();
        newsVoPage.setPageIndex(pageIndex);
        newsVoPage.setPageSize(pageSize);
        newsVoPage.setBeanList(getNewsVoList((pageIndex - 1) * pageSize, pageSize));
        try {
            newsVoPage.setTotalCount(newsDao.getCount());
            newsVoPage.setTotalPage((int) Math.ceil((double) newsDao.getCount() / (double) pageSize));
        } catch (Exception e) {
            return null;
        }
        return newsVoPage;
    }

    @Override
    public Page<News> getNewsPageByCate(Integer cateId, Integer pageIndex, Integer pageSize) {
        Page<News> newsPage = new Page<> ();
        newsPage.setPageIndex(pageIndex);
        newsPage.setPageSize(pageSize);
        newsPage.setBeanList(getNewsListByCate(cateId,(pageIndex - 1) * pageSize,pageSize));
        try {
            newsPage.setTotalCount(newsDao.getCountByCate(cateId));
            newsPage.setTotalPage((int) Math.ceil((double) newsDao.getCountByCate(cateId) / (double) pageSize));
        } catch (Exception e) {
            return null;
        }
        return newsPage;
    }

    @Override
    public List<NewsVo> getNewsVoList(Integer pageIndex, Integer length) {
        List <NewsVo> newsVoList = new ArrayList<> ();
        try {
            List<News> newsList = newsDao.getNewsList(pageIndex, length);
            for (News news : newsList){
                NewsVo newsVo = new NewsVo();
                newsVo.setNewsCate(newsCateDao.getById(news.getCateId()));
                newsVo.setTitle(news.getTitle());
                newsVo.setContent(news.getContent());
                newsVo.setAuthor(news.getAuthor());
                newsVo.setTime(news.getTime());
                newsVo.setId(news.getId());
                newsVo.setCateId(news.getCateId());
                newsVoList.add(newsVo);
            }
        } catch (Exception e) {
            return null;
        }
        return newsVoList;
    }

    @Override
    public List<News> getNewsListByCate(Integer cateId,Integer pageIndex,Integer length) {
        try {
            return newsDao.getNewsListByCate(cateId,pageIndex,length);
        } catch (Exception e) {
            return null;
        }
    }

    @Override
    public News getNewsById(Integer id) {
        try {
            return newsDao.getById(id);
        } catch (Exception e) {
            return null;
        }
    }

    @Override
    public int publish(News news) {
        try {
            return newsDao.insert(news);
        } catch (Exception e) {
            return -1;
        }
    }

    @Override
    public List<NewsVo> getAllNewsVo() {
        List<NewsVo> allNewsVo = new ArrayList<>();
        try {
            List<News> allNews = newsDao.getAll();
            for (News news:allNews) {
                NewsVo newsVo = new NewsVo();
                newsVo.setId(news.getId());
                newsVo.setTitle(news.getTitle());
                newsVo.setAuthor(news.getAuthor());
                newsVo.setTime(news.getTime());
                newsVo.setContent(news.getContent());
                newsVo.setCateId(news.getCateId());
                newsVo.setNewsCate(newsCateDao.getById(news.getCateId()));
                allNewsVo.add(newsVo);
            }
            return allNewsVo;
        } catch (Exception e) {
            return null;
        }
    }

    @Override
    public int deleteNewsById(Integer id) {
        try {
            return newsDao.deleteById(id);
        } catch (Exception e) {
            return -1;
        }
    }
}

UserServiceImpl

package com.jsj.service.Impl;

import com.jsj.dao.UserDao;
import com.jsj.entity.User;
import com.jsj.factory.DaoFactory;
import com.jsj.service.UserService;

public class UserServiceImpl implements UserService {

    private UserDao userDao = (UserDao) DaoFactory.getDao("UserDao");

    @Override
    public int register(User user) {
        try {
            return userDao.insert(user);
        } catch (Exception e) {
            return -1;
        }
    }

    @Override
    public User login(String username, String password) {
        try {
            return userDao.getUserByPassword(username,password);
        } catch (Exception e) {
            return null;
        }
    }

}