上传文件

bigData/src/com/happy/action/DeviceRankAction.java

@@ -0,0 +1,102 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.DeviceRank;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.service.DeviceRankService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class DeviceRankAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Autowired
+    public DeviceRankService deviceRankService;
+
+    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 InDeviceRank(){
+        System.out.println("设备通行排行榜");
+        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;
+        }
+        DeviceRank deviceRank = null;
+        try{
+            deviceRank = gson.fromJson(json.toString(), new TypeToken<DeviceRank>(){}.getType());
+            if (deviceRank == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = deviceRankService.insertDeviceRank(deviceRank);
+            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 queryRank() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<DeviceRank> list = deviceRankService.queryRank();
+        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;
+    }
+}

bigData/src/com/happy/action/DevicetAction.java

@@ -0,0 +1,102 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.DeviceT;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.service.DevicetService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class DevicetAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Autowired
+    public DevicetService devicetService;
+
+    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 InDeviceT(){
+        System.out.println("设备总览");
+        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;
+        }
+        DeviceT deviceT = null;
+        try{
+            deviceT = gson.fromJson(json.toString(), new TypeToken<DeviceT>(){}.getType());
+            if (deviceT == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = devicetService.insertDevicet(deviceT);
+            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 List<DeviceT> queryT() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<DeviceT> list = devicetService.queryT();
+        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;
+    }
+}

bigData/src/com/happy/action/FirstBufferpAction.java

@@ -0,0 +1,137 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.FirstBufferP;
+import com.happy.Model.User;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.Until.TimeExchange;
+import com.happy.service.FirstBufferpService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+
+public class FirstBufferpAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Autowired
+    public FirstBufferpService firstBufferpService;
+
+    public String sm_place;
+
+    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 getSm_place() {
+        return sm_place;
+    }
+
+    public void setSm_place(String sm_place) {
+        this.sm_place = sm_place;
+    }
+
+    //  第一道防护屏障接口------各路口
+    public String InFirstBufferP(){
+        System.out.println("第一道防护屏障接口------各路口");
+        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;
+        }
+        FirstBufferP firstBufferP = null;
+        try{
+            firstBufferP = gson.fromJson(json.toString(), new TypeToken<FirstBufferP>(){}.getType());
+            if (firstBufferP == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = firstBufferpService.insertFirstBufferP(firstBufferP);
+            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 queryFirstBufferP() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        if (sm_place==null){
+            resultJson.put("msg", "请传入sm_place");
+            resultJson.put("code", 500);
+            ResUtil.write(resultJson, ServletActionContext.getResponse());
+            return null;
+        }
+        List<FirstBufferP> list = firstBufferpService.queryFirstBufferP(TimeExchange.getDate(),sm_place);
+        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;
+    }
+
+    // 各路口人员扫码信息
+    public String queryByPlace() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<User> list = firstBufferpService.queryByPlace(sm_place);
+        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;
+    }
+}

bigData/src/com/happy/action/FirstBuffertAction.java

@@ -0,0 +1,381 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.*;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.Until.ResponseUtil;
+import com.happy.service.FirstBuffercService;
+import com.happy.service.FirstBuffertService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class FirstBuffertAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Resource
+    public FirstBuffertService firstBuffertService;
+
+    @Resource
+    public FirstBuffercService firstBuffercService;
+
+    public String startDate;
+    public String endDate;
+    public String sm_color;
+    public int page; // 当前页
+    public int rows;// 每页显示的行数rows
+    public Integer m;
+
+    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 getStartDate() {
+        return startDate;
+    }
+
+    public void setStartDate(String startDate) {
+        this.startDate = startDate;
+    }
+
+    public String getEndDate() {
+        return endDate;
+    }
+
+    public void setEndDate(String endDate) {
+        this.endDate = endDate;
+    }
+
+    public String getSm_color() {
+        return sm_color;
+    }
+
+    public void setSm_color(String sm_color) {
+        this.sm_color = sm_color;
+    }
+
+    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 Integer getM() {
+        return m;
+    }
+
+    public void setM(Integer m) {
+        this.m = m;
+    }
+
+    // 第一道防护屏障接口------汇总
+    public String InFirstBufferT(){
+        System.out.println("第一道防护屏障接口------汇总");
+        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;
+        }
+        FirstBufferT firstBufferT = null;
+        try{
+            firstBufferT = gson.fromJson(json.toString(), new TypeToken<FirstBufferT>(){}.getType());
+            if (firstBufferT == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = firstBuffertService.insertFirstBufferT(firstBufferT);
+            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 InFirstBufferC(){
+        System.out.println("第一道防护屏障接口------人数汇总");
+        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;
+        }
+        FirstBufferC firstBufferC = null;
+        try{
+            firstBufferC = gson.fromJson(json.toString(), new TypeToken<FirstBufferC>(){}.getType());
+            if (firstBufferC == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = firstBuffercService.insertFirstBufferC(firstBufferC);
+            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 queryFirstBufferT() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<FirstBufferT> list = firstBuffertService.queryFirstBufferT();
+        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;
+    }
+
+    // 第一道防护屏障接口------人数汇总
+    public String queryFirstBufferC() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<FirstBufferC> list = firstBuffercService.queryFirstBufferC();
+        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;
+    }
+
+    //  第一道防线处置情况
+    public String queryHandler() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<Handlde> list = firstBuffertService.queryHandler();
+        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;
+    }
+
+    // 第一道防线红码人员详情
+    public String queryRed() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<User> list  = firstBuffertService.queryRed(startDate,endDate);
+        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;
+    };
+
+    // 第一道防线黄码人员详情
+    public String queryYellow() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        int total = firstBuffertService.queryYellowTotal(startDate,endDate); // 查询表中的总记录数
+        List<User> listPage = firstBuffertService.queryYellow(startDate,endDate,page,rows);
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    };
+
+    public String queryFirst() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        SecondPlaceJc list = firstBuffertService.queryFirst();
+        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;
+    }
+
+    // 首页面--处置
+    public String queryFirstHandler() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<Handlde> list = firstBuffertService.queryFirstHandler();
+        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;
+    }
+
+    // 第一道防线红黄码加时间搜索
+    public String queryByTimeAndColor(){
+        JSONObject resultJson = new JSONObject();
+        StringBuilder sb = new StringBuilder("");
+        if (startDate!=null && endDate!=null){
+            sb.append(" and sm_time between '").append(this.startDate)
+                    .append("' and '").append(this.endDate).append(" 24:60:60' ");
+        }
+        if (sm_color!=null){
+            sb.append(" and sm_color='").append(this.sm_color).append("' ");
+        }
+        int total = firstBuffertService.findUsersTotal(sb.toString()); // 查询表中的总记录数
+        List<User> listPage = this.firstBuffertService.queryByTimeAndColor(page,rows,sb.toString());
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    }
+
+    // 第一道防线红黄绿累积统计
+    public String queryLjRyg() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        SecondPlaceJc list = firstBuffertService.queryLjRyg();
+        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;
+    }
+
+    /** =================昨日累积缓存 =============================**/
+    // 插入缓存
+    public String insertfbT() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        if (m==null){
+            m=-3;
+        }
+        for (int i=m;i<0;i++){
+            int n = firstBuffertService.insertFbT(i);
+        }
+        resultJson.put("msg", "插入成功！");
+        resultJson.put("code", 200);
+        ResUtil.write(resultJson, ServletActionContext.getResponse());
+        return null;
+
+    }
+}

bigData/src/com/happy/action/GtmtAction.java

@@ -0,0 +1,101 @@
+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;
+    }
+}

bigData/src/com/happy/action/ManagerAction.java

@@ -0,0 +1,159 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.happy.Model.Manager.DanweiDetail;
+import com.happy.Model.Manager.Danweit;
+import com.happy.Model.Manager.Gaosut;
+import com.happy.Model.Tour.TourDayt;
+import com.happy.Until.ResponseUtil;
+import com.happy.service.ManagerService;
+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 ManagerAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    public String tj_date;
+    public String placef;
+
+    @Resource
+    public ManagerService managerService;
+
+    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 getTj_date() {
+        return tj_date;
+    }
+
+    public void setTj_date(String tj_date) {
+        this.tj_date = tj_date;
+    }
+
+    public String getPlacef() {
+        return placef;
+    }
+
+    public void setPlacef(String placef) {
+        this.placef = placef;
+    }
+
+    public String queryGaosuT(){
+        JSONObject resultJson = new JSONObject();
+        List<Gaosut> list = managerService.queryByDataAndPlace(0);
+        resultJson.put("data", list);
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    // 插入缓存
+    public String insertGaosuT(){
+        JSONObject resultJson = new JSONObject();
+        managerService.insertGaosuT();
+        resultJson.put("code", 200);
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    // 查询缓存数据
+    public String queryGaosuR(){
+        JSONObject resultJson = new JSONObject();
+        List<Gaosut> list = managerService.queryGaosuR(tj_date);
+        if (list!=null){
+            resultJson.put("code", 200);
+            resultJson.put("data", list);
+            ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                    resultJson.toString());
+            return null;
+        }
+        resultJson.put("code", 500);
+        resultJson.put("data", "null");
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    /** ================================================================= **/
+    public String insertDwT(){
+        JSONObject resultJson = new JSONObject();
+        managerService.insertDanweiT();
+        resultJson.put("code", 200);
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    // 查询缓存数据
+    public String queryDanweiR(){
+        JSONObject resultJson = new JSONObject();
+        List<Danweit> list = managerService.queryDanweiByDate(tj_date);
+        if (list!=null){
+            resultJson.put("code", 200);
+            resultJson.put("data", list);
+            ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                    resultJson.toString());
+            return null;
+        }
+        resultJson.put("code", 500);
+        resultJson.put("data", "null");
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    /** ====================各单位具体场所============================ **/
+    public String insertDwdetail(){
+        JSONObject resultJson = new JSONObject();
+        managerService.insertDanweiD();
+        resultJson.put("code", 200);
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    // 查询缓存数据
+    public String queryDanweiD(){
+        JSONObject resultJson = new JSONObject();
+        List<DanweiDetail> list = managerService.queryDanweiDByDate(tj_date,placef);
+        if (list!=null){
+            resultJson.put("code", 200);
+            resultJson.put("data", list);
+            ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                    resultJson.toString());
+            return null;
+        }
+        resultJson.put("code", 500);
+        resultJson.put("data", "null");
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+}

bigData/src/com/happy/action/MobileAction.java

@@ -0,0 +1,190 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.happy.Model.User;
+import com.happy.Until.ResponseUtil;
+import com.happy.service.MobService;
+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 MobileAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Resource
+    public MobService mobService;
+
+    public String sm_color;
+    public String handler_state2;
+    public int page; // 当前页
+    public int rows;// 每页显示的行数rows
+    public String iskey;
+    public String ishot;
+    public String istoken;
+
+    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 getSm_color() {
+        return sm_color;
+    }
+
+    public void setSm_color(String sm_color) {
+        this.sm_color = sm_color;
+    }
+
+    public String getHandler_state2() {
+        return handler_state2;
+    }
+
+    public void setHandler_state2(String handler_state2) {
+        this.handler_state2 = handler_state2;
+    }
+
+    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 getIskey() {
+        return iskey;
+    }
+
+    public void setIskey(String iskey) {
+        this.iskey = iskey;
+    }
+
+    public String getIshot() {
+        return ishot;
+    }
+
+    public void setIshot(String ishot) {
+        this.ishot = ishot;
+    }
+
+    public String getIstoken() {
+        return istoken;
+    }
+
+    public void setIstoken(String istoken) {
+        this.istoken = istoken;
+    }
+
+    // 处置详情
+    public String queryHandler(){
+        JSONObject resultJson = new JSONObject();
+        StringBuilder sb = new StringBuilder("");
+        if (handler_state2!=null){
+            sb.append(" and handler_state2='").append(this.handler_state2).append("' ");
+        }
+        if (sm_color!=null){
+            sb.append(" and sm_color='").append(this.sm_color).append("' ");
+        }
+        if (istoken!=null){
+            sb.append(" and istoken='").append(this.istoken).append("' ");
+        }
+        if (iskey!=null){
+            sb.append(" and iskey='").append(this.iskey).append("' ");
+        }
+        if (ishot!=null){
+            sb.append(" and ishot='").append(this.ishot).append("' ");
+        }
+        int total = mobService.findUsersTotal(sb.toString()); // 查询表中的总记录数
+        List<User> listPage = this.mobService.queryHandled(sb.toString(),page,rows);
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    }
+
+    // 各状态处置详情统计
+    public String queryHandlerTj() {
+        JSONObject resultJson = mobService.queryDetailHandler();
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    // 近8天红黄码处置统计
+    public String queryEightRed(){
+        StringBuilder sb = new StringBuilder("");
+        if (sm_color!=null){
+            sb.append(" and sm_color='").append(this.sm_color).append("' ");
+        }
+        if (istoken!=null){
+            sb.append(" and istoken='").append(this.istoken).append("' ");
+        }
+        if (iskey!=null){
+            sb.append(" and iskey='").append(this.iskey).append("' ");
+        }
+        if (ishot!=null){
+            sb.append(" and ishot='").append(this.ishot).append("' ");
+        }
+        JSONObject resultJson = mobService.queryEightRed(sb.toString());
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+    // 近8天处置统计平均数
+    public String queryEightAvg(){
+        JSONObject resultJson = mobService.queryEightAvg();
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+}

bigData/src/com/happy/action/SecondBufferpAction.java

@@ -0,0 +1,131 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.SecondBufferP;
+import com.happy.Model.User;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.service.SecondBufferPService;
+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 SecondBufferpAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Resource
+    public SecondBufferPService secondBufferPService;
+
+    public String sm_place;
+
+    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 getSm_place() {
+        return sm_place;
+    }
+
+    public void setSm_place(String sm_place) {
+        this.sm_place = sm_place;
+    }
+
+    // 各景区汇总
+    public String InSecondBufferP(){
+        System.out.println("景区汇总");
+        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;
+        }
+        SecondBufferP secondBufferP = null;
+        try{
+            secondBufferP = gson.fromJson(json.toString(), new TypeToken<SecondBufferP>(){}.getType());
+            if (secondBufferP == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = secondBufferPService.insertSecondBufferP(secondBufferP);
+            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 querySecondBufferP() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondBufferP> list = secondBufferPService.querySecondBufferP();
+        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;
+    }
+
+    // 各景点人员扫码信息
+    public String queryByPlace() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<User> list = secondBufferPService.queryByPlace(sm_place);
+        List<SecondBufferP> lp = secondBufferPService.querySecondBufferpByPlace(sm_place);
+        if (list!=null){
+            resultJson.put("num", lp);
+            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;
+    }
+}

bigData/src/com/happy/action/SecondBuffertAction.java

@@ -0,0 +1,518 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.*;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.Until.ResponseUtil;
+import com.happy.service.SecondBuffertService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.text.ParseException;
+import java.util.List;
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.*;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.Until.ResponseUtil;
+import com.happy.service.SecondBuffertService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class SecondBuffertAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Autowired
+    public SecondBuffertService secondBuffertService;
+
+    public String startDate;
+    public String endDate;
+    public int page; // 当前页
+    public int rows;// 每页显示的行数rows
+    public String sm_color;
+    public String ishot;
+    public String sm_place;
+    public String place_type;
+    public Integer m;
+
+    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 getStartDate() {
+        return startDate;
+    }
+
+    public void setStartDate(String startDate) {
+        this.startDate = startDate;
+    }
+
+    public String getEndDate() {
+        return endDate;
+    }
+
+    public void setEndDate(String endDate) {
+        this.endDate = endDate;
+    }
+
+    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 getSm_color() {
+        return sm_color;
+    }
+
+    public void setSm_color(String sm_color) {
+        this.sm_color = sm_color;
+    }
+
+    public String getIshot() {
+        return ishot;
+    }
+
+    public void setIshot(String ishot) {
+        this.ishot = ishot;
+    }
+
+    public String getSm_place() {
+        return sm_place;
+    }
+
+    public void setSm_place(String sm_place) {
+        this.sm_place = sm_place;
+    }
+
+    public String getPlace_type() {
+        return place_type;
+    }
+
+    public void setPlace_type(String place_type) {
+        this.place_type = place_type;
+    }
+
+    public Integer getM() {
+        return m;
+    }
+
+    public void setM(Integer m) {
+        this.m = m;
+    }
+
+    // 第二道防护汇总
+    public String InSecondBufferT(){
+        System.out.println("第二道防护汇总");
+        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;
+        }
+        SecondBufferT secondBufferT = null;
+        try{
+            secondBufferT = gson.fromJson(json.toString(), new TypeToken<SecondBufferT>(){}.getType());
+            if (secondBufferT == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = secondBuffertService.insertSecondBufferT(secondBufferT);
+            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 InSecondBufferC(){
+        System.out.println("第二道防护汇总---人数");
+        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;
+        }
+        SecondBufferC secondBufferC = null;
+        try{
+            secondBufferC = gson.fromJson(json.toString(), new TypeToken<SecondBufferC>(){}.getType());
+            if (secondBufferC == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = secondBuffertService.insertSecondBufferC(secondBufferC);
+            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 querySecondBufferT() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondBufferT> list = secondBuffertService.querySecondBufferT();
+        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;
+    }
+
+    // 最近7天人员分布
+    public String querySecondBufferTLastSeven() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondBufferT> list = secondBuffertService.querySecondBufferTLastSeven();
+        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;
+    }
+
+    // 第二道防线扫描人数汇总
+    public String querySecondBufferC() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondBufferC> list = secondBuffertService.querySecondBufferC();
+        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;
+    }
+
+    // 第二道防线处置情况
+    public String queryHandler() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<Handlde> list = secondBuffertService.queryHandler();
+        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;
+    }
+
+    // 第二道防线发热人员统计
+    public String queryHot() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        int num = secondBuffertService.queryHot();
+        resultJson.put("code", 200);
+        resultJson.put("number", num);
+        ResUtil.write(resultJson, ServletActionContext.getResponse());
+        return null;
+    }
+
+    // 第二道防线红码人员详情
+    public String queryRed() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<User> list  = secondBuffertService.queryRed(startDate,endDate);
+        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;
+    };
+
+    // 第二道防线黄码人员详情
+    public String queryYellow() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        int total = secondBuffertService.queryYellowTotal(startDate,endDate); // 查询表中的总记录数
+        List<User> listPage = secondBuffertService.queryYellow(startDate,endDate,page,rows);
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    };
+
+    // 各类型详情
+    public String querySpjc() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondPlaceJc> list = secondBuffertService.querySpjc();
+        SecondPlaceJc list2 = secondBuffertService.querySpjd();
+        SecondPlaceJc list3 = secondBuffertService.querySl();
+        if (list!=null){
+            resultJson.put("data", list);
+            resultJson.put("data_jd", list2);
+            resultJson.put("data_lm", list3);
+            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;
+    }
+
+    // 各门店详情
+    public String queryCommon() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondPlaceJc> list = secondBuffertService.queryCommon(place_type);
+        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;
+    }
+
+    // 第二道防线红黄码加时间搜索
+    public String queryHotByTime(){
+        JSONObject resultJson = new JSONObject();
+        StringBuilder sb = new StringBuilder("");
+        if (startDate!=null && endDate!=null){
+            sb.append(" and sm_time between '").append(this.startDate)
+                    .append("' and '").append(this.endDate).append(" 24:60:60' ");
+        }
+        int total = secondBuffertService.findUsersTotal(sb.toString()); // 查询表中的总记录数
+        List<User> listPage = this.secondBuffertService.queryByTime(page,rows,sb.toString());
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    }
+
+    // 第二道防线红黄码加时间搜索
+    public String queryLj(){
+        JSONObject resultJson = new JSONObject();
+        StringBuilder sb = new StringBuilder("");
+        if (startDate!=null && endDate!=null){
+            sb.append(" and sm_time between '").append(this.startDate)
+                    .append("' and '").append(this.endDate).append(" 24:60:60' ");
+        }
+        if (sm_color!=null){
+            sb.append(" and sm_color='").append(this.sm_color).append("' ");
+        }
+        if (ishot!=null){
+            sb.append(" and ishot='").append(this.ishot).append("' ");
+        }
+        int total = secondBuffertService.findLjUsersTotal(sb.toString()); // 查询表中的总记录数
+        List<User> listPage = this.secondBuffertService.queryLjByTime(page,rows,sb.toString());
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    }
+
+    // 第二道防线红黄绿累积统计
+    public String queryLjRyg() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        SecondPlaceJc list = secondBuffertService.queryLjRyg();
+        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;
+    }
+
+    public String queryView() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        Tz list = secondBuffertService.queryView(sm_place);
+        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;
+    }
+
+    /** =================昨日累积缓存 =============================**/
+    // 前7天活动人数
+    public String queryEgihtTour() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SecondBufferT> list = secondBuffertService.queryEgihtSbLj(m);
+        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;
+    }
+
+    // 插入缓存
+    public String insertSbT() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        if (m==null){
+            m=-3;
+        }
+        for (int i=m;i<0;i++){
+            int n = secondBuffertService.insertSbT(i);
+        }
+        resultJson.put("msg", "插入成功！");
+        resultJson.put("code", 200);
+        ResUtil.write(resultJson, ServletActionContext.getResponse());
+        return null;
+    }
+}

bigData/src/com/happy/action/SmlmtAction.java

@@ -0,0 +1,129 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.SmlmT;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.service.SmlmtService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class SmlmtAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Autowired
+    public SmlmtService smlmtService;
+
+    public String month;
+
+    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 getMonth() {
+        return month;
+    }
+
+    public void setMonth(String month) {
+        this.month = month;
+    }
+
+    // 扫码亮码数量统计
+    public String InSmlmT(){
+        System.out.println("扫码亮码数量统计");
+        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;
+        }
+        SmlmT smlmT = null;
+        try{
+            smlmT = gson.fromJson(json.toString(), new TypeToken<SmlmT>(){}.getType());
+            if (smlmT == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = smlmtService.insertSmlmT(smlmT);
+            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 query() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SmlmT> list = smlmtService.query();
+        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;
+    }
+
+    // 扫码亮码月统计
+    public String queryByMonth() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SmlmT> list = smlmtService.queryByMonth(month);
+        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;
+    }
+
+}

bigData/src/com/happy/action/SmtAction.java

@@ -0,0 +1,120 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.Hylj;
+import com.happy.Model.SmT;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.service.SmtService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class SmtAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Autowired
+    public SmtService smtService;
+
+    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 InSmT(){
+        System.out.println("全县扫码统计、趋势");
+        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;
+        }
+        SmT smT = null;
+        try{
+            smT = gson.fromJson(json.toString(), new TypeToken<SmT>(){}.getType());
+            if (smT == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = smtService.insertSmT(smT);
+            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 query() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<SmT> list = smtService.query();
+        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;
+    }
+
+    // 红黄码累计
+    public String queryLj() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<Hylj> list = smtService.queryLj();
+        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;
+    }
+
+}

bigData/src/com/happy/action/ThirdBuffertAction.java

@@ -0,0 +1,286 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.ThirdBufferT;
+import com.happy.Model.ThirdJw;
+import com.happy.Model.Tz;
+import com.happy.Model.User;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.Until.ResponseUtil;
+import com.happy.service.ThirdBuffertService;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+public class ThirdBuffertAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    public String startDate;
+    public String endDate;
+    public String sm_color;
+    public int page; // 当前页
+    public int rows;// 每页显示的行数rows
+    public String iskey;
+    public String istoken;
+
+    @Autowired
+    public ThirdBuffertService thirdBuffertService;
+
+    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 getStartDate() {
+        return startDate;
+    }
+
+    public void setStartDate(String startDate) {
+        this.startDate = startDate;
+    }
+
+    public String getEndDate() {
+        return endDate;
+    }
+
+    public void setEndDate(String endDate) {
+        this.endDate = endDate;
+    }
+
+    public String getSm_color() {
+        return sm_color;
+    }
+
+    public void setSm_color(String sm_color) {
+        this.sm_color = sm_color;
+    }
+
+    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 ThirdBuffertService getThirdBuffertService() {
+        return thirdBuffertService;
+    }
+
+    public void setThirdBuffertService(ThirdBuffertService thirdBuffertService) {
+        this.thirdBuffertService = thirdBuffertService;
+    }
+
+    public String getIskey() {
+        return iskey;
+    }
+
+    public void setIskey(String iskey) {
+        this.iskey = iskey;
+    }
+
+    public String getIstoken() {
+        return istoken;
+    }
+
+    public void setIstoken(String istoken) {
+        this.istoken = istoken;
+    }
+
+    // 第三道防护-----酒店民宿
+    public String InThirdBufferT(){
+        System.out.println("第三道防护-----酒店民宿");
+        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;
+        }
+        ThirdBufferT thirdBufferT = null;
+        try{
+            thirdBufferT = gson.fromJson(json.toString(), new TypeToken<ThirdBufferT>(){}.getType());
+            if (thirdBufferT == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = thirdBuffertService.insertThirdBufferT(thirdBufferT);
+            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 queryThirdBufferT() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<ThirdBufferT> list = thirdBuffertService.queryThirdBufferT();
+        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;
+    }
+
+    // 最近7天人员分布
+    public String queryThirdBufferTLastSeven() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<ThirdBufferT> list = thirdBuffertService.queryThirdBufferTLastSeven();
+        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;
+    }
+
+    // 第三道防线扫码人员信息
+    public String queryMessage() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<User> list = thirdBuffertService.queryByBuffer();
+        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;
+    }
+
+    // 第三道防线--各酒店经纬度
+    public String queryJw() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        List<ThirdJw> list = thirdBuffertService.queryJw();
+        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;
+    }
+
+    // 脱管人员统计
+    public String queryTuo() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        Tz list = thirdBuffertService.queryTuo();
+        Tz list2 = thirdBuffertService.queryZd();
+        if (list!=null && list2!=null){
+            resultJson.put("data_tg", list);
+            resultJson.put("data_zd", list2);
+            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;
+    }
+
+    // 第三道防线重点脱管加时间搜索
+    public String queryByTime(){
+        JSONObject resultJson = new JSONObject();
+        StringBuilder sb = new StringBuilder("");
+        if (startDate!=null && endDate!=null){
+            sb.append(" and sm_time between '").append(this.startDate)
+                    .append("' and '").append(this.endDate).append(" 24:60:60' ");
+        }
+        if (iskey!=null){
+            sb.append(" and iskey='").append(this.iskey).append("' ");
+        }
+        if (istoken!=null){
+            sb.append(" and istoken='").append(this.istoken).append("' ");
+        }
+        System.out.println(sb.toString());
+        int total = thirdBuffertService.findUsersTotal(sb.toString()); // 查询表中的总记录数
+        System.out.println(total);
+        List<User> listPage = this.thirdBuffertService.queryByTime(page,rows,sb.toString());
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            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;
+    }
+}

bigData/src/com/happy/action/TouristAnalysisAction.java

@@ -0,0 +1,338 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.happy.Model.SmartMarketingVO;
+import com.happy.Model.ToiletRealDatasVO;
+import com.happy.Model.Travel.StopSaturationStatistics;
+import com.happy.Model.Travel.ToiletRealData;
+import com.happy.Model.Travel.TravelAge;
+import com.happy.Model.Travel.TravelLast;
+import com.happy.Model.Travel.TravelProvin;
+import com.happy.Model.Travel.TravelT;
+import com.happy.Model.Travel.Travelye;
+import com.happy.Until.ResUtil;
+import com.happy.service.TouristAnalysisService;
+import com.happy.vo.RealDataOfPeopleStreamVO;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author: codingliang
+ * @Description: 游客分析api
+ * @Date: 2021-12-30 15:33
+ * @Version: V1.0
+ **/
+public class TouristAnalysisAction 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 place;
+
+    public Long toiletId;
+
+    public int limit;
+
+    public String getPlace() {
+        return place;
+    }
+
+    public void setPlace(String place) {
+        this.place = place;
+    }
+
+    public Long getToiletId() {
+        return toiletId;
+    }
+
+    public void setToiletId(Long toiletId) {
+        this.toiletId = toiletId;
+    }
+
+    public int getLimit() {
+        return limit;
+    }
+
+    public void setLimit(int limit) {
+        this.limit = limit;
+    }
+
+    @Autowired
+    private TouristAnalysisService touristAnalysisService;
+
+    /**
+     * 今日人员流入人数
+     */
+    public void todayIntoStatistics() throws Exception {
+        TravelT data = touristAnalysisService.getTodayIntoStatistics();
+        ok(data);
+    }
+
+    /**
+     * 人员流入人数V2
+     * @since v2
+     */
+    public void todayIntoStatisticsV2() throws Exception {
+        Map<String, String> data = touristAnalysisService.getTodayIntoStatisticsV2();
+        ok(data);
+    }
+
+    /**
+     * 最近一周和最近一月人员流入数据
+     * @since v2
+     */
+    public void toWeekAndMonthIntoStatisticsV2() throws Exception {
+        Map<String, String> data = touristAnalysisService.getWeekAndMonthIntoStatisticsV2();
+        ok(data);
+    }
+
+    /**
+     * 今日人员流入历史数据
+     */
+    public void todayintoHistoryStatistics() throws Exception {
+        List<Map<String, String>> data = touristAnalysisService.getTodayIntoHistoryStatistics();
+        ok(data);
+    }
+
+    /**
+     * 游客趋势走势
+     */
+    public void intoHistoryStatistics() throws Exception {
+        Map<String, Object> data = touristAnalysisService.getIntoHistoryStatistics();
+        ok(data);
+    }
+
+    /**
+     * 游客趋势走势V2
+     * @since v2
+     */
+    public void intoHistoryStatisticsV2() throws Exception {
+        List<Map<String, String>> data = touristAnalysisService.getIntoHistoryStatisticsV2();
+        ok(data);
+    }
+
+    /**
+     * 游客来源地top16
+     */
+    public void touristFromTo16() throws Exception {
+        List<TravelProvin> data = touristAnalysisService.getTouristFromTo16();
+        ok(data);
+    }
+
+    /**
+     * 游客年龄分布
+     */
+    public void touristAgeStatistics() throws Exception {
+        List<TravelAge> data = touristAnalysisService.getTouristAgeStatistics();
+        ok(data);
+    }
+
+    /**
+     * 游客性别分布
+     */
+    public void touristGenderStatistics() throws Exception {
+        Map<String, Integer> data = touristAnalysisService.getTouristGenderStatistics();
+        ok(data);
+    }
+
+    /**
+     * 游客出行方式
+     * @throws Exception
+     */
+    public void touristTrafficMethodStatics() throws Exception {
+        Map<String, String> data = touristAnalysisService.getTouristTrafficMethodStatics();
+        ok(data);
+    }
+
+    /**
+     * 景区列表
+     * @throws Exception
+     */
+    public void touristDestinations() throws Exception {
+        List<String> data = touristAnalysisService.getTouristDestinations();
+        ok(data);
+    }
+
+    /**
+     * 景区入园人数统计
+     * @throws Exception
+     */
+    public void touristDestinationStatics() throws Exception {
+        if (StringUtils.isBlank(place)) {
+            fail("place不能为空");
+            return;
+        }
+
+        Map<String, Long> data = touristAnalysisService.getTouristDestinationStatics(place);
+        ok(data);
+    }
+
+    /**
+     * 景区入园人数统计（地图）
+     * @throws Exception
+     */
+    public void touristDestinationDetailStatics() throws Exception {
+        if (StringUtils.isBlank(place)) {
+            fail("place不能为空");
+            return;
+        }
+
+        Map<String, Long> data = touristAnalysisService.getTouristDestinationDetailStatics(place);
+        ok(data);
+    }
+
+    /**
+     * 景区历史人流量统计
+     * @throws Exception
+     */
+    public void touristDestinationHistoryStatics() throws Exception {
+        if (StringUtils.isBlank(place)) {
+            fail("place不能为空");
+            return;
+        }
+
+        List<Map<String, String>> data = touristAnalysisService.getTouristDestinationHistoryStatics(place);
+        ok(data);
+    }
+
+    /**
+     * 景区实时人流量
+     * @throws Exception
+     */
+    public void realDataOfPeopleStream() throws Exception {
+        if (StringUtils.isBlank(place)) {
+            fail("place不能为空");
+            return;
+        }
+
+        List<RealDataOfPeopleStreamVO> data = touristAnalysisService.getRealDataOfPeopleStream(place);
+        ok(data);
+    }
+
+    /**
+     * 过夜游客数量统计
+     */
+    public void numsStatisticsOfStopInNight() throws Exception {
+        List<Travelye> data = touristAnalysisService.getNumsStatisticsOfStopInNight();
+        ok(data);
+    }
+
+    /**
+     * 停留时长统计
+     * @throws Exception
+     */
+    public void timeLongOfStopInView() throws Exception {
+        if (limit == 0) limit = 8;
+        List<TravelLast> data = touristAnalysisService.getTimeLongOfStopInView(limit);
+        ok(data);
+    }
+
+    /**
+     * 停车场实时饱和度
+     * @throws Exception
+     */
+    public void stopSaturationRealData() throws Exception {
+        String data = touristAnalysisService.getStopSaturationRealData();
+        ok(data);
+    }
+
+    /**
+     * 停车场饱和度统计
+     * @throws Exception
+     */
+    public void stopSaturationStatistics() throws Exception {
+        List<StopSaturationStatistics> data = touristAnalysisService.getStopSaturationStatistics();
+        ok(data);
+    }
+
+    /**
+     * 智慧厕所列表
+     * @throws Exception
+     */
+    public void toiletList() throws Exception {
+        List<ToiletRealData> data = touristAnalysisService.getToilets();
+        ok(data);
+    }
+
+    /**
+     * 智慧厕所实时数据
+     * @throws Exception
+     */
+    public void toiletRealData() throws Exception {
+        if (toiletId == null) {
+            fail("toiletId不能为空");
+            return;
+        }
+
+        ToiletRealData data = touristAnalysisService.getToiletRealData(toiletId);
+        if (data == null) {
+            fail("【" + toiletId + "】不存在");
+        } else {
+            ok(data);
+        }
+    }
+
+    /**
+     * 智慧厕所使用监测
+     * @throws Exception
+     */
+    public void toiletDataList() throws Exception {
+        List<ToiletRealDatasVO> data = touristAnalysisService.getToiletDataList();
+        ok(data);
+    }
+
+    /**
+     * 智慧营销统计数据
+     * @throws Exception
+     */
+    public void travelMarketingStatistics() throws Exception {
+        SmartMarketingVO vo = touristAnalysisService.getTravelMarketingStatistics();
+        if (vo != null) {
+            ok(vo);
+        } else {
+            fail("没有数据");
+        }
+    }
+
+    private void ok(Object data) throws Exception {
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("data", data);
+        jsonObject.put("code", 200);
+        ResUtil.write(jsonObject, ServletActionContext.getResponse());
+    }
+
+    private void fail(String message) throws Exception {
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("data", message);
+        jsonObject.put("code", 500);
+        ResUtil.write(jsonObject, ServletActionContext.getResponse());
+    }
+}

bigData/src/com/happy/action/TravelAction.java

@@ -0,0 +1,82 @@
+package com.happy.action;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.Travel.TravelAge;
+import com.happy.Until.GetHttpParam;
+import com.happy.Until.ResUtil;
+import com.happy.service.TravelService;
+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;
+
+public class TravelAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Resource
+    public TravelService travelService;
+
+    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 InTravelAge(){
+        System.out.println("年龄分布");
+        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;
+        }
+        TravelAge travelAge = null;
+        try{
+            travelAge = gson.fromJson(json.toString(), new TypeToken<TravelAge>(){}.getType());
+            if (travelAge == null){
+                resultjson.put("msg", "数据为空");
+                resultjson.put("code", "500");
+                ResUtil.writeJson(ServletActionContext.getResponse(), resultjson.toString());
+                return null;
+            }
+            int m = travelService.insertTravelAge(travelAge);
+            if (m > 0){
+                resultjson.put("msg", "上传成功");
+                resultjson.put("code", "200");
+                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;
+        }
+        return null;
+    }
+
+}

bigData/src/com/happy/action/WarmAction.java

@@ -0,0 +1,97 @@
+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;
+    }
+}