bigdata_houtai/bigData/src/com/happy/action/GtmtAction.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.GtmT;
import com.happy.Until.GetHttpParam;
import com.happy.Until.ResUtil;
import com.happy.service.GtmtService;
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;

public class GtmtAction extends ActionSupport implements ServletRequestAware {

    private HttpServletRequest request;
    public HttpServletResponse response;

    @Resource
    public GtmtService gtmtService;

    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 String InGtmT(){
        JSONObject resultjson = new JSONObject();
        Gson gson=new Gson();
        JSONObject json = GetHttpParam.getHttpParam(request);
        if (json == null){
            resultjson.put("msg", "请传入参数");
            ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
            return null;
        }
        GtmT gtmT = null;
        try{
            gtmT = gson.fromJson(json.toString(), new TypeToken<GtmT>(){}.getType());
            if (gtmT == null){
                resultjson.put("msg", "数据为空");
                resultjson.put("code", "500");
                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
                return null;
            }
            int m = gtmtService.insertGtmT(gtmT);
            if (m > 0){
                resultjson.put("msg", "上传成功");
                resultjson.put("code", "200");
                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
                return null;
            } else {
                resultjson.put("msg", "解析参数失败");
                resultjson.put("code", "502");
                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
                return null;
            }
        }catch (Exception e){
            resultjson.put("msg", "参数格式有误！");
            resultjson.put("code", "502");
            ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
            return null;
        }
    }

    // 赣通码详情
    public String queryGtmT() throws Exception {
        JSONObject resultJson = new JSONObject();
        List<GtmT> list = gtmtService.queryGtmT();
        if (list!=null){
            resultJson.put("data", list);
            resultJson.put("code", 200);
            ResUtil.write(resultJson, ServletActionContext.getResponse());
            return null;
        }
        resultJson.put("code", 205);
        resultJson.put("msg", "数据为空");
        ResUtil.write(resultJson, ServletActionContext.getResponse());
        return null;
    }
}