创建生成周报excel表(四）创建业务层和控制层

女爷i 2022-12-02 00:48 91阅读 0赞

1、在上次创建了 Dao层的逻辑，实现了可以和数据库的交互

这次是实现 业务层的创建

业务层实现数据从控制层与Dao层之间的处理。

第一步是创建了一个 抽象接口

public abstract interface  IServices {
    }

第二步是 创建了 一个业务接口，来创建各自业务方法

这里因为 summary 和 project中实现的都是CRUD，所以这里通过类进行判断 使用哪个mapper，和返回什么样的值。

（我觉得可以优化一下 使用 抽象的方法解决）

public interface PoiServices extends IServices {
    
        /**
         * 用于生成excel表格的必要内容
         * @param departmentName  部门名称
         * @param createDate   创建时间
         * @param summaryList  完成内容介绍
         * @param projectList     下周计划完成情况
         */
        HSSFWorkbook createExcel(String departmentName, String createDate,List<Summary> summaryList,List<Project> projectList);
    
        /*获取数据并生成list传递到前台*/
         List<Map<String,Object>> dataPush(int page , int limit,Class className);
    
        /*获取数据*/
        Object getDataList(String department, Class className);
    
        /**
         * 新增数据
         * @param obj 新增的向上造型的数据
         * @param
         * @return
         */
         Integer addData(Object obj);
    
        /*删除数据*/
         Integer deleteData(int id ,String department,Class className);
    
         /*根据di 和部门获取数据*/
         Object selectData(int id ,String department,Class className);
    
         /*修改*/
         int updateData(Object obj);
    
         /*删除全部 相关部门数据*/
         Integer deleteByDepartment(String department,Class className);
    
    
    }

实现类实现的方法：

/**
    * @ClassName: poi接口实现类
    * @Description: 实现接口(这里用一句话描述这个类的作用)
    * @author Gin_HK
    * @date 20200813
    *
    */
    
    import com.zqj.mapper.ProjectMapper;
    import com.zqj.mapper.SummaryMapper;
    import com.zqj.pojo.eneity.Project;
    import com.zqj.pojo.eneity.Summary;
    import com.zqj.services.PoiServices;
    import com.zqj.util.PoiUtils;
    import org.apache.poi.hssf.usermodel.HSSFWorkbook;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    import org.springframework.web.bind.annotation.ExceptionHandler;
    
    import javax.xml.ws.Action;
    import java.util.HashMap;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    
    @Service
    public class PoiServiceImpl implements PoiServices {
    
    
        @Autowired
        private SummaryMapper summaryMapper;
    
        @Autowired
        private ProjectMapper projectMapper;
    
    
        @Override
        public HSSFWorkbook createExcel(String departmentName, String createDate, List<Summary> summaryList, List<Project> projectList) {
    
            /*表格生成*/
            HSSFWorkbook workbook = null;
            try {
    
                /*获取executionList, planResultList, planResultList, nameList*/
    
                LinkedList<String> outlineList = new LinkedList<>();
                LinkedList<String> executionList = new LinkedList<>();
                LinkedList<String> planList = new LinkedList<>();
                LinkedList<String> planResultList = new LinkedList<>();
                LinkedList<String> nameList = new LinkedList<>();
    
                int index = 0;
    
                for (index = 0; index < summaryList.size(); index++) {
                    outlineList.add(summaryList.get(index).getOutline());
                    executionList.add(summaryList.get(index).getDetails().replaceAll("<br />","\n"));
                }
    
                for (index = 0; index < projectList.size(); index++) {
                    planList.add(projectList.get(index).getPlan());
                    planResultList.add(projectList.get(index).getPlanResult().replaceAll("<br />","\n"));
                    nameList.add(projectList.get(index).getName());
                }
    
                workbook = PoiUtils.createWorkbook(departmentName, createDate, outlineList, executionList, planList, planResultList, nameList);
                System.out.println("创建成功!workbook");
            } catch (Exception e) {
                e.printStackTrace();
    
            }
            return workbook;
        }
    
        /**
         * 获取 summary 数据 然后 防止 list中
         *
         * @return
         */
    
        public List<Map<String, Object>> dataPush(int page, int limit, Class className) {
    
            List<Map<String, Object>> list = new LinkedList<>();
            Map<String, Object> hashMap = null;
    
            if (className == Summary.class) {
                /*page  和limit 的关系*/
                List<Summary> summaryList = summaryMapper.getSummaryListPage((page - 1) * limit, limit);
                for (int i = 0; i < summaryList.size(); i++) {
                    hashMap = new HashMap<>();
                    hashMap.put("id", summaryList.get(i).getId());
                    hashMap.put("outline", summaryList.get(i).getOutline());
                    hashMap.put("details", summaryList.get(i).getDetails());
                    hashMap.put("department", summaryList.get(i).getDepartment());
                    list.add(hashMap);
                }
            } else if (className == Project.class) {
                /*todo: 处理计划类型*/
                List<Project> projectsList = projectMapper.getProjectListPage((page - 1) * limit, limit);
                for (int i = 0; i < projectsList.size(); i++) {
                    hashMap = new HashMap<>();
                    hashMap.put("id", projectsList.get(i).getId());
                    hashMap.put("plan", projectsList.get(i).getPlan());
                    hashMap.put("planResult", projectsList.get(i).getPlanResult());
                    System.out.println(projectsList.get(i).getPlanResult());
                    hashMap.put("name", projectsList.get(i).getName());
                    hashMap.put("department", projectsList.get(i).getDepartment());
                    list.add(hashMap);
                }
            } else {
                /*后续添加*/
            }
            return list;
        }
    
        /*传递查询到的数据*/
        @Override
        public Object getDataList(String department,Class className) {
            if (className == Summary.class) {
                    return  summaryMapper.getSummaryByDepartment(department);
            } else if (className == Project.class) {
                /*todo: 处理计划类型*/
                return  projectMapper.getProjectByDepartment(department);
            } else {
                /*后续添加*/
            }
            return  null;
        }
    
        @Override
        @Transactional
        public Integer addData(Object obj) {
    
            try {
                if (obj instanceof Summary) {
                    Summary summary = (Summary) obj;
                    int i = summaryMapper.insertSummary(summary.getOutline(), summary.getDetails(), summary.getDepartment());
                    return i;
                } else if (obj instanceof Project) {
                    Project project = (Project) obj;
                    int i = projectMapper.insertProject(project.getPlan(), project.getPlanResult(), project.getName(), project.getDepartment());
                    return i;
                } else {
                    /*其他.....*/
                    return 0;
                }
            } catch (Exception e) {
                System.out.println("插入数据异常:" + e);
                return 0;
            }
        }
    
        @Override
        @Transactional
        public Integer deleteData(int id, String department, Class className) {
    
            try {
                if (className == Summary.class) {
                    int i = summaryMapper.deleteSummary(id, department);
                    return i;
                } else if (className == Project.class) {
                    int i = projectMapper.deleteProject(id, department);
                    return i;
                } else {
                    return 0;
                }
    
            } catch (Exception e) {
                e.printStackTrace();
                return 0;
            }
    
    
        }
    
        @Override
        public Object selectData(int id, String department, Class className) {
    
            try {
    
                if (className == Summary.class) {
                    Summary summary = summaryMapper.getSummary(id, department);
                    return summary;
                } else if (className == Project.class) {
                    Project project = projectMapper.selectProject(id, department);
                    return project;
                } else {
                    /*其他类型*/
                }
    
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
            return null;
        }
    
    
        @Override
        @Transactional
        public int updateData(Object obj) {
    
            try {
                if (obj instanceof Summary) {
    
                    Summary summary = (Summary) obj;
                    int i = summaryMapper.updateSummary(summary.getId(), summary.getOutline(), summary.getDetails(), summary.getDepartment());
                    return i;
                } else if (obj instanceof Project) {
                    Project project = (Project) obj;
                    int i = projectMapper.updateProject(project.getId(), project.getPlan(), project.getPlanResult(), project.getName(), project.getDepartment());
                } else {
    
                }
    
            } catch (Exception e) {
                e.printStackTrace();
                return 0;
            }
            return 0;
        }
    
        @Override
        public Integer deleteByDepartment(String department, Class className) {
    
            try {
                if (className == Summary.class) {
                    int line = summaryMapper.deleteBySummary( department);
                    return line;
                } else if (className == Project.class) {
                    int line = projectMapper.deleteByProject( department);
                    return line;
                } else {
                    /*其他类型*/
                }
    
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
    
    
            return null;
        }
    
    }

2、控制层的生成

控制层要和前台进行交互。

package com.zqj.controller;
    /*
    //                            _ooOoo_  
    //                           o8888888o  
    //                           88" . "88  
    //                           (| -_- |)  
    //                            O\ = /O  
    //                        ____/`---'\____  
    //                      .   ' \\| |// `.  
    //                       / \\||| : |||// \  
    //                     / _||||| -:- |||||- \  
    //                       | | \\\ - /// | |  
    //                     | \_| ''\---/'' | |  
    //                      \ .-\__ `-` ___/-. /  
    //                   ___`. .' /--.--\ `. . __  
    //                ."" '< `.___\_<|>_/___.' >'"".  
    //               | | : `- \`.;`\ _ /`;.`/ - ` : | |  
    //                 \ \ `-. \_ __\ /__ _/ .-` / /  
    //         ======`-.____`-.___\_____/___.-`____.-'======  
    //                            `=---='  
    //  
    //         .............................................  
    //                  佛祖保佑             永无BUG     
    
    /**
    * @ClassName: poi控制层
    * @Description: 生成表格(这里用一句话描述这个类的作用)
    * @author Gin_HK
    * @date 20200815
    *
    */
    
    import com.alibaba.fastjson.JSONObject;
    import com.zqj.pojo.eneity.Project;
    import com.zqj.pojo.eneity.Summary;
    import com.zqj.services.PoiServices;
    import org.apache.poi.hssf.usermodel.HSSFWorkbook;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.ui.ModelMap;
    import org.springframework.web.bind.annotation.*;
    import org.springframework.web.servlet.ModelAndView;
    
    import javax.servlet.ServletOutputStream;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import java.io.IOException;
    import java.text.SimpleDateFormat;
    import java.util.*;
    
    @Controller
    public class PoiController {
    
        private static Map<String, HSSFWorkbook> mapOfWorkbook = new HashMap<>();
    
        @Autowired
        private PoiServices poiServices;
    
        /*进入 主页面 编辑及页面*/
        @RequestMapping("/createTable")
        public String getCreateTable() {
            return "createTable";
        }
    
    
        /*进入数据新增界面*/
        @RequestMapping(value = "/updateData", method = RequestMethod.GET)
        public String getUpdateData(@RequestParam("id") int id, @RequestParam("department") String department, @RequestParam("pageType") String pageType, ModelMap map) {
    
            switch (pageType) {
                case "summary":
                    Summary summary = (Summary) poiServices.selectData(id, department, Summary.class);
    
                    if (summary == null) {
                        return "createTable";
                    }
                    map.addAttribute("id", summary.getId());
                    map.addAttribute("outline", summary.getOutline());
                    map.addAttribute("details", summary.getDetails());
                    return "updateData";
    
                case "project":
                    Project project = (Project) poiServices.selectData(id, department, Project.class);
    
                    if (project == null) {
                        return "createTable";
                    }
                    map.addAttribute("id", project.getId());
                    map.addAttribute("plan", project.getPlan());
                    map.addAttribute("planResult", project.getPlanResult());
                    map.addAttribute("name", project.getName());
                    return "updatePlanData";
                default:
                    break;
            }
    
            return null;
        }
    
        /*根据id、部门名称  删除数据*/
        @RequestMapping("/deleteData")
        @ResponseBody
        public String deleteData(@RequestParam("id") int id, @RequestParam("department") String department, @RequestParam("className") String className) {
    
            Integer deleteRow = 0;
            try {
    
                switch (className) {
                    case "summary":
                        deleteRow = poiServices.deleteData(id, department, Summary.class);
                        break;
    
                    case "project":
                        deleteRow = poiServices.deleteData(id, department, Project.class);
                        break;
                    default:
                        break;
                }
    
                if (deleteRow == 1) {
                    return "删除成功!";
                }
                return "删除失败";
            } catch (Exception e) {
                e.printStackTrace();
                return "删除失败!" + e;
            }
        }
    
    
        /*进入数据新增界面*/
        @RequestMapping(value = "/addData", method = RequestMethod.GET)
        public String getAddData(@RequestParam("pageType") String pageType) {
    
            switch (pageType) {
                case "summary":
                    return "addData";
                case "project":
                    return "addPlanData";
                default:
                    break;
            }
            /*当前页*/
            return "null";
        }
    
        /*新增数据 总结*/
        @RequestMapping(value = "/postAddData", method = RequestMethod.POST)
        @ResponseBody
        public String postAddData(@RequestParam("outline") String outline, @RequestParam("details") String details, @RequestParam("department") String department) {
    
            Summary summary = new Summary();
            summary.setOutline(outline);
            summary.setDetails(details);
            summary.setDepartment(department);
    
            Integer addRow = poiServices.addData(summary);
            return "新增行数: " + addRow + "行 ，请关闭当前页面";
        }
    
    
        /*新增数据 计划*/
        @RequestMapping(value = "/postAddPlanData", method = RequestMethod.POST)
        @ResponseBody
        public String postAddPlanData(@RequestParam("plan") String plan, @RequestParam("planResult") String planResult, @RequestParam("name") String name, @RequestParam("department") String department) {
    
            Project project = new Project();
            project.setPlan(plan);
            project.setPlanResult(planResult);
            project.setName(name);
            project.setDepartment(department);
    
            Integer addRow = poiServices.addData(project);
            return "新增行数: " + addRow + "行 ，请关闭当前页面";
        }
    
        /*修改数据 */
        @RequestMapping(value = "/postUpdateData", method = RequestMethod.POST)
        @ResponseBody
        public String postUpdateData(@RequestParam("outline") String outline, @RequestParam("details") String details, @RequestParam("department") String department, @RequestParam("id") int id) {
    
            Summary summary = new Summary();
            summary.setId(id);
            summary.setOutline(outline);
            summary.setDetails(details);
            summary.setDepartment(department);
            Integer updateRow = poiServices.updateData(summary);
            return "修改行数: " + updateRow + "行 ，请关闭当前页面";
        }
    
        /*获取table 数据*/
        @RequestMapping("/tableData")
        @ResponseBody
        public Map getTableData(int page, int limit) {
    
            /*获得数据*/
            List<Map<String, Object>> list = null;
            Map<String, Object> res = new HashMap<>();
            try {
                list = poiServices.dataPush(page, limit, Summary.class);
                res.put("code", 0);
                res.put("msg", "success");
                res.put("data", list);
            } catch (Exception e) {
                e.printStackTrace();
                res.put("code", 1);
                res.put("msg", "error");
                res.put("data", null);
            }
            return res;
        }
    
        /*获取table 数据*/
        @RequestMapping("/planData")
        @ResponseBody
        public Map getPlanData(int page, int limit) {
    
            /*获得数据*/
            List<Map<String, Object>> list = null;
            Map<String, Object> res = new HashMap<>();
            try {
                list = poiServices.dataPush(page, limit, Project.class);
                res.put("code", 0);
                res.put("msg", "success");
                res.put("data", list);
            } catch (Exception e) {
                e.printStackTrace();
                res.put("code", 1);
                res.put("msg", "error");
                res.put("data", null);
            }
            return res;
        }
    
        @RequestMapping("/create")
        @ResponseBody
        public String create(@RequestParam("department") String department) {
    
            LinkedList<Summary> summaryLinkedList = (LinkedList<Summary>) poiServices.getDataList(department, Summary.class);
            LinkedList<Project> projectLinkedList = (LinkedList<Project>) poiServices.getDataList(department, Project.class);
    
            if(summaryLinkedList.size()==0 && projectLinkedList.size() == 0){
                return "nullMsg";
            }
    
            String nowDate = new SimpleDateFormat("yyyy MM dd").format(new Date());
    
            HSSFWorkbook excel = poiServices.createExcel(department, nowDate, summaryLinkedList, projectLinkedList);
    
            mapOfWorkbook.put(department, excel);
    
            return "/download?department=" + department;
        }
    
        @RequestMapping("/download")
        @ResponseBody
        public String getDownload(HttpServletRequest request, HttpServletResponse response, String department) throws IOException {
            response.reset();/*清缓存*/
    
            /*获取map缓存*/
            HSSFWorkbook hssfWorkbook = null;
            synchronized (this) {
                hssfWorkbook = mapOfWorkbook.get(department);
            }
            if (hssfWorkbook == null) {
                System.out.println("当前表格不存在");
                return null;
            }
            /*清除缓存*/
            mapOfWorkbook.remove(department);
    
            /*修改中文编码格式*/
            String agent = request.getHeader("USER-AGENT").toLowerCase();
            String codedFileName = java.net.URLEncoder.encode(department, "UTF-8");
            /*针对不同浏览器进行调整格式*/
            if (agent.contains("firefox")) {
                response.setCharacterEncoding("utf-8");
                response.setHeader("content-disposition", "attachment;filename="  +new SimpleDateFormat("yyyy MM dd").format(new Date())+ new String(department.getBytes(), "ISO8859-1") + ".xls");
            } else {
                response.setHeader("content-disposition", "attachment;filename=" +new SimpleDateFormat("yyyy MM dd").format(new Date())+ codedFileName + ".xls");
            }
    
            ServletOutputStream outputStream = response.getOutputStream();
            hssfWorkbook.write(outputStream);
            outputStream.close();
    
            /*删除数据*/
            poiServices.deleteByDepartment(department,Summary.class);
            poiServices.deleteByDepartment(department,Project.class);
            return null;
        }
    
    }

控制层结束

自用

还差 前端数据