Homestay_app_houtai/mhotel/src/com/happy/action/advertiseAction.java

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<Advertise>() {}.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<Advertise>() {}.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<Advertise> 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;
    }


}