package com.happy.action;

import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import com.happy.Model.Smoke.Warm;
import com.happy.Until.GetHttpParam;
import com.happy.Until.ResUtil;
import com.happy.Until.ResponseUtil;
import com.opensymphony.xwork2.ActionSupport;
import net.sf.json.JSONObject;
import org.apache.struts2.ServletActionContext;
import org.apache.struts2.interceptor.ServletRequestAware;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class WarmAction extends ActionSupport implements ServletRequestAware {

    private HttpServletRequest request;
    public HttpServletResponse response;

    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 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("code", 502);
            resultJson.put("message", "请传入参数");
            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
            return null;
        }
        Warm warm = null;
        warm = gson.fromJson(json.toString(), new TypeToken<Warm>() {}.getType());
        if (warm == null) {
            resultJson.put("message", "数据为空");
            resultJson.put("code", 500);
            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
            return null;
        }
        ApplicationContext ac = new ClassPathXmlApplicationContext(
                "applicationContext.xml");
        DataSource dataSource = (DataSource) ac.getBean("slaveDataSource2");
        Connection conn = null;
        StringBuilder sql = new StringBuilder
                ("insert into `warning_of_smoke_record`(`publish_time`,`place`,`images`,`handle_status`,`handle_desc`) values ");
        try{
            conn = dataSource.getConnection();
            sql.append("('").append(warm.getPublish_time()).append("','").append(warm.getPlace()).append("','").append(warm.getImages()).append("','").append(warm.getHandle_status()).append("','").append(warm.getHandle_desc()).append("') ");
            PreparedStatement ps = conn.prepareStatement(sql.toString());
            ps.execute();
            ps.close();
        } catch (Exception e){
            e.printStackTrace();
        } finally {
            try {
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                // TODO: handle exception
            }
        }
        resultJson.put("message", "导入成功");
        resultJson.put("code", 200);
        ResponseUtil.writeJson(ServletActionContext.getResponse(),
                resultJson.toString());
        return null;
    }
}