package com.happy.action; import com.alibaba.fastjson.JSONObject; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; import com.happy.Model.Advertise; import com.happy.Model.app.Around_product; import com.happy.Model.app.Arounds; import com.happy.Until.GetHttpParam; import com.happy.Until.ResUtil; import com.happy.Until.ResponseUtil; import com.happy.Until.TimeExchange; import com.happy.service.AdvertiseService; import com.opensymphony.xwork2.ActionSupport; import org.apache.struts2.ServletActionContext; import org.apache.struts2.interceptor.ServletRequestAware; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.util.List; import java.util.Objects; public class advertiseAction extends ActionSupport implements ServletRequestAware { private HttpServletRequest request; public HttpServletResponse response; @Resource public AdvertiseService advertiseService; public Integer id; public int page; // 当前页 public int rows;// 每页显示的行数rows public String title; public Integer state; public String startTime; public String endTime; public HttpServletRequest getRequest() { return request; } public void setRequest(HttpServletRequest request) { this.request = request; } public void setServletRequest(HttpServletRequest request) { this.request = request; } public HttpServletResponse getResponse() { return response; } public void setResponse(HttpServletResponse response) { this.response = response; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public int getPage() { return page; } public void setPage(int page) { this.page = page; } public int getRows() { return rows; } public void setRows(int rows) { this.rows = rows; } public String getTitle() { return title; } public void setTitle(String title) { this.title = title; } public Integer getState() { return state; } public void setState(Integer state) { this.state = state; } public String getStartTime() { return startTime; } public void setStartTime(String startTime) { this.startTime = startTime; } public String getEndTime() { return endTime; } public void setEndTime(String endTime) { this.endTime = endTime; } public String insert() { JSONObject resultjson = new JSONObject(); Gson gson = new Gson(); com.alibaba.fastjson.JSONObject json = GetHttpParam.getHttpParam(request); System.out.println(json); if (json == null) { resultjson.put("message", "请传入参数"); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } Advertise advertise = null; try { advertise = gson.fromJson(json.toString(), new TypeToken() {}.getType()); if (advertise == null) { resultjson.put("message", "数据为空"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } if (advertise.getTitle()==null || advertise.getLogoUrl()==null || advertise.getImageUrl()==null || advertise.getJumpWay()==null || advertise.getJumpDirection()==null || advertise.getJumpPoint()==null){ resultjson.put("message", "各参数不能为空"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } Advertise listc = advertiseService.queryByTitle(advertise.getTitle()); if (listc != null) { resultjson.put("message", "该广告已存在"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } advertise.setCreateTime(TimeExchange.getTime()); int m = advertiseService.insertAdvertise(advertise); if (m > 0) { resultjson.put("message", "添加成功"); resultjson.put("code", 200); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } else { resultjson.put("message", "添加失败"); resultjson.put("code", 502); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } } catch (Exception e) { e.printStackTrace(); } resultjson.put("message", "未知异常"); resultjson.put("code", 205); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } public String update() { JSONObject resultjson = new JSONObject(); Gson gson = new Gson(); JSONObject json = GetHttpParam.getHttpParam(request); System.out.println(json); if (json == null) { resultjson.put("code", 205); resultjson.put("message", "请传入参数"); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } Advertise advertise = null; try { advertise = gson.fromJson(json.toString(), new TypeToken() {}.getType()); if (advertise == null) { resultjson.put("message", "数据为空"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } if (advertise.getTitle()==null || advertise.getLogoUrl()==null || advertise.getImageUrl()==null || advertise.getJumpWay()==null || advertise.getJumpDirection()==null || advertise.getJumpPoint()==null){ resultjson.put("message", "各参数不能为空"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } Advertise listy = advertiseService.queryById(advertise.getId()); if (listy==null){ resultjson.put("message", "该条数据已删除"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } Advertise listc = advertiseService.queryByTitle(advertise.getTitle()); if (listc!=null && !Objects.equals(listc.getId(), advertise.getId())){ resultjson.put("message", "广告已存在"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } advertise.setCreateTime(TimeExchange.getTime()); int m = advertiseService.updateAdvertise(advertise); if (m > 0) { resultjson.put("message", "修改成功"); resultjson.put("code", 200); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } else { resultjson.put("message", "修改失败"); resultjson.put("code", 502); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } } catch (Exception e) { e.printStackTrace(); } resultjson.put("message", "未知异常"); resultjson.put("code", 205); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } public String del() { JSONObject resultjson = new JSONObject(); if (id == null) { resultjson.put("message", "请传入id"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } Advertise advertise = advertiseService.queryById(id); if (advertise==null){ resultjson.put("message", "该数据已删除"); resultjson.put("code", 500); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } int m = advertiseService.delAdvertise(id); if (m > 0) { resultjson.put("message", "删除成功"); resultjson.put("code", 200); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } resultjson.put("message", "未知异常"); resultjson.put("code", 205); ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString()); return null; } public String listPage() { JSONObject resultJson = new JSONObject(); StringBuilder s1 = new StringBuilder(""); if (state!=null){ s1.append(" and state = '").append(this.state).append("' "); } if (title!=null){ s1.append(" and title like '%").append(this.title).append("%' "); } if (startTime!=null){ s1.append(" and create_time > '").append(this.startTime).append("' "); } if (endTime!=null){ s1.append(" and create_time < '").append(this.endTime).append(" 24:60:60' "); } int total = advertiseService.queryAdvertiseTotal(s1.toString()); // 查询表中的总记录数 List listPage = advertiseService.queryAdvertisePage(page,rows,s1.toString()); // 查询分页 if (listPage == null) { resultJson.put("code", 200); resultJson.put("rows", ""); resultJson.put("total", 0); } else { resultJson.put("code", 200); resultJson.put("rows", listPage); // int total = listAll.size(); resultJson.put("total", total);// 总记录数 int totalPage = total % rows == 0 ? (total / rows) : (total / rows) + 1;// 总页数 resultJson.put("totalPage", totalPage); resultJson.put("currentPage", page);// 当前页 resultJson.put("numPerPage", rows);// 每页数 resultJson.put("nextPage", totalPage - page == 0 ? page : page + 1);// 下一页 resultJson.put("previousPage", page - 0 == 1 ? page : page - 1);// 上一页 resultJson.put("hasPreviousPage", true);// 有上一页 resultJson.put("hasNextPage", true);// 有下一页 resultJson.put("firstPage", true);// 首页 resultJson.put("lastPage", true);// 尾页 } ResponseUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString()); return null; } }