20190513---wangling---高危地区人员统计结果展示

src/main/java/com/founder/interservice/gwdq/Bean/SessionBean.java

+package com.founder.interservice.gwdq.Bean;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * ****************************************************************************
+ *
+ * @Package: [com.founder.framework.base.entity.SessionBean.java]
+ * @ClassName: [SessionBean]
+ * @Description: [Session中存储值的JavaBean]
+ * @Author: [weiwen ]
+ * @CreateDate: [2013-12-3 下午5:17:21]
+ * @UpdateUser: [weiwen(如多次修改保留历史记录，增加修改记录)]
+ * @UpdateDate: [2013-12-3 下午5:17:21，(如多次修改保留历史记录，增加修改记录)]
+ * @UpdateRemark: [说明本次修改内容,(如多次修改保留历史记录，增加修改记录)]
+ * @Version: [v1.0]
+ */
+public class SessionBean implements Serializable {
+
+	private static final long serialVersionUID = 1L;
+
+	private Long userPk = null;// 人员表主键
+	private String userId = "";// 帐号
+	private String userName = "";// 人员姓名
+	private String password = "";// 密码
+	private String userType = ""; // 人员类型（1=系统管理员；2=管理人员；3=普通人员）
+	private Long userOrgId = null; // 人员所在部门ID
+	private String userOrgCode = "";// 人员所在部门代码
+	private String userOrgName = "";// 人员所在部门名称
+	private String userOrgNameQc = "";// 人员所在部门名称全称
+	private String userOrgNameJc = "";// 人员所在部门名称简称
+	private String userOrgIDPath = ""; // 人员所在部门路径ID（从根结点开始，逗号分隔）
+	private String userOrgIDRight = ""; // 人员拥有部门的权限（包括部门与工作组及上级部门路径，逗号分隔）
+	private String userOrgLevel = ""; // 人员所在部门的部门等级
+	private String userOrgBiztype = ""; // 人员所在部门的部门业务类型
+	private String userPositionId = "";// 人员岗位ID（多个时用逗号分隔）
+	private Long userManageOrgId = null; // 人员管理部门ID
+	private String userManageOrgCode = "";// 人员管理部门代码
+	private String userManageOrgName = "";// 人员管理部门名称
+	private String loginTime = "";// 登录时间
+	private String remoteAddr = "";// 登录机器ip
+	private String positionId = "";// 虚拟岗位ID（多个时用逗号分隔）
+	private String positionName = "";// 人员岗位名称（多个时用逗号分隔）
+	private String bjzbz = ""; // 人员所在部门边界坐标值
+	private String theme = ""; // 人员风格主题
+	private String industrialid = "";
+	private String userRoleId= "";//人员角色ID（多个时用逗号分隔）
+	private String grade;//用户级别 省 市 县 特
+	private String policemanid;//警号
+
+	public String getPolicemanid() {
+		return policemanid;
+	}
+
+	public void setPolicemanid(String policemanid) {
+		this.policemanid = policemanid;
+	}
+
+	public String getGrade() {
+		return grade;
+	}
+
+	public void setGrade(String grade) {
+		this.grade = grade;
+	}
+
+	public String getUserRoleId() {
+		return userRoleId;
+	}
+
+	public void setUserRoleId(String userRoleId) {
+		this.userRoleId = userRoleId;
+	}
+
+	private Map<String, String> powerUrls = new HashMap<String, String>();
+
+	public Map<String, String> getPowerUrls() {
+		return powerUrls;
+	}
+
+	public void setPowerUrls(Map<String, String> powerUrls) {
+		this.powerUrls = powerUrls;
+	}
+
+	/**
+	 * 扩展属性中初始存放：
+	 * <p>
+	 * parentOrgID 上级部门ID<br>
+	 * parentOrgCode 上级部门代码<br>
+	 * parentOrgName 上级部门名称<br>
+	 * grandOrgID 上两级部门ID<br>
+	 * grandOrgCode 上两级部门代码<br>
+	 * grandOrgName 上两级部门名称<br>
+	 */
+
+	/**
+	 * 根据业务系统扩展属性：
+	 * <p>
+	 * ssDsjID 所属地市局ID<br>
+	 * ssDsjCode 所属地市局代码<br>
+	 * ssDsjName 所属地市局名称<br>
+	 * ssFsxID 所属分市县局ID<br>
+	 * ssFsxCode 所属分市县局代码<br>
+	 * ssFsxName 所属分市县局名称<br>
+	 * ssPcsID 所属派出所ID<br>
+	 * ssPcsCode 所属派出所代码<br>
+	 * ssPcsName 所属派出所名称<br>
+	 */
+	private Map<String,String> extendMap = new HashMap<String,String>();
+
+	public Long getUserPk() {
+		return userPk;
+	}
+
+	public void setUserPk(Long userPk) {
+		this.userPk = userPk;
+	}
+
+	public Long getUserManageOrgId() {
+		return userManageOrgId;
+	}
+
+	public void setUserManageOrgId(Long userManageOrgId) {
+		this.userManageOrgId = userManageOrgId;
+	}
+
+	public String getUserId() {
+		return userId;
+	}
+
+	public void setUserId(String userId) {
+		this.userId = userId;
+	}
+
+	public String getUserName() {
+		return userName;
+	}
+
+	public void setUserName(String userName) {
+		this.userName = userName;
+	}
+
+	public String getPassword() {
+		return password;
+	}
+
+	public void setPassword(String password) {
+		this.password = password;
+	}
+
+	public String getUserType() {
+		return userType;
+	}
+
+	public void setUserType(String userType) {
+		this.userType = userType;
+	}
+
+	public String getUserOrgCode() {
+		return userOrgCode;
+	}
+
+	public void setUserOrgCode(String userOrgCode) {
+		this.userOrgCode = userOrgCode;
+	}
+
+	public String getUserOrgName() {
+		return userOrgName;
+	}
+
+	public void setUserOrgName(String userOrgName) {
+		this.userOrgName = userOrgName;
+	}
+
+	public String getUserOrgNameQc() {
+		return userOrgNameQc;
+	}
+
+	public void setUserOrgNameQc(String userOrgNameQc) {
+		this.userOrgNameQc = userOrgNameQc;
+	}
+
+	public String getUserOrgNameJc() {
+		return userOrgNameJc;
+	}
+
+	public void setUserOrgNameJc(String userOrgNameJc) {
+		this.userOrgNameJc = userOrgNameJc;
+	}
+
+	public String getUserOrgIDPath() {
+		return userOrgIDPath;
+	}
+
+	public void setUserOrgIDPath(String userOrgIDPath) {
+		this.userOrgIDPath = userOrgIDPath;
+	}
+
+	public String getUserOrgIDRight() {
+		return userOrgIDRight;
+	}
+
+	public void setUserOrgIDRight(String userOrgIDRight) {
+		this.userOrgIDRight = userOrgIDRight;
+	}
+
+	public String getUserOrgLevel() {
+		return userOrgLevel;
+	}
+
+	public void setUserOrgLevel(String userOrgLevel) {
+		this.userOrgLevel = userOrgLevel;
+	}
+
+	public String getUserOrgBiztype() {
+		return userOrgBiztype;
+	}
+
+	public void setUserOrgBiztype(String userOrgBiztype) {
+		this.userOrgBiztype = userOrgBiztype;
+	}
+
+	public String getUserPositionId() {
+		return userPositionId;
+	}
+
+	public void setUserPositionId(String userPositionId) {
+		this.userPositionId = userPositionId;
+	}
+
+	public String getPositionName() {
+		return positionName;
+	}
+
+	public void setPositionName(String positionName) {
+		this.positionName = positionName;
+	}
+
+	public String getUserManageOrgCode() {
+		return userManageOrgCode;
+	}
+
+	public void setUserManageOrgCode(String userManageOrgCode) {
+		this.userManageOrgCode = userManageOrgCode;
+	}
+
+	public String getUserManageOrgName() {
+		return userManageOrgName;
+	}
+
+	public void setUserManageOrgName(String userManageOrgName) {
+		this.userManageOrgName = userManageOrgName;
+	}
+
+	public String getLoginTime() {
+		return loginTime;
+	}
+
+	public void setLoginTime(String loginTime) {
+		this.loginTime = loginTime;
+	}
+
+	public String getRemoteAddr() {
+		return remoteAddr;
+	}
+
+	public void setRemoteAddr(String remoteAddr) {
+		this.remoteAddr = remoteAddr;
+	}
+
+	public String getPositionId() {
+		return positionId;
+	}
+
+	public void setPositionId(String positionId) {
+		this.positionId = positionId;
+	}
+
+	public Long getUserOrgId() {
+		return userOrgId;
+	}
+
+	public void setUserOrgId(Long userOrgId) {
+		this.userOrgId = userOrgId;
+	}
+
+	public Map<String,String> getExtendMap() {
+		return extendMap;
+	}
+
+	public void setExtendMap(Map<String,String> extendMap) {
+		this.extendMap = extendMap;
+	}
+
+	public String getBjzbz() {
+		return bjzbz;
+	}
+
+	public void setBjzbz(String bjzbz) {
+		this.bjzbz = bjzbz;
+	}
+
+	public String getTheme() {
+		return theme;
+	}
+
+	public void setTheme(String theme) {
+		this.theme = theme;
+	}
+
+	/**
+	 * 取得扩展属性<<br>
+	 *
+	 * @param key
+	 * @return String
+	 */
+	public String getExtendValue(String key) {
+		String returnValue = (String) extendMap.get(key);
+		return returnValue;
+	}
+
+	/**
+	 * 设置扩展属性<br>
+	 *
+	 * @param key
+	 * @param value
+	 *            void
+	 */
+	public void putExtendValue(String key, String value) {
+		if (null!=key&&"".equals(key)) {
+			extendMap.put(key, value);
+		}
+	}
+
+	public String getIndustrialid() {
+		return industrialid;
+	}
+
+	public void setIndustrialid(String industrialid) {
+		this.industrialid = industrialid;
+	}
+
+}

src/main/java/com/founder/interservice/gwdq/Controller/GwdqfxtjController.java

+package com.founder.interservice.gwdq.Controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.founder.interservice.gwdq.service.GwdqService;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.message.BasicNameValuePair;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.servlet.ModelAndView;
+
+import java.io.UnsupportedEncodingException;
+import java.util.*;
+
+@Controller
+public class GwdqfxtjController {
+
+    @Value("${anjian.xzxt.url}")
+    private String cjxzUrl;
+    @Autowired
+    private GwdqService gwdqService;
+
+    @RequestMapping(value = "/toGwdq", method = {RequestMethod.GET, RequestMethod.POST})
+    public ModelAndView getGwdq(String userName, String passWord, String sfzh, String userCode) {
+        CloseableHttpClient httpclient = gwdqService.getCjxm(userName, passWord, sfzh, userCode);
+        //response返回的相应实体
+        UrlEncodedFormEntity reqEntity = null;
+        //建立一个NameValuePair数组，用于存储欲传送的参数
+        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
+        formparams.clear();
+        formparams.add(new BasicNameValuePair("asjfsjssj", "2017-02-14"));
+        formparams.add(new BasicNameValuePair("asjbh", "A1502001700002017020049"));
+        try {
+            reqEntity = new UrlEncodedFormEntity(formparams, "utf-8");
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        HttpPost post = new HttpPost(cjxzUrl);
+        post.setEntity(reqEntity);
+        JSONObject jsonObject = null;
+        String content = gwdqService.RequestUtil(httpclient, post).trim();
+        System.out.println(content);
+        if (!"".equals(content)) {
+            jsonObject = JSONObject.parseObject(content);
+        }
+        ModelAndView modelAndView = new ModelAndView();
+        modelAndView.setViewName("gwdq/gwdqjg");
+        modelAndView.addObject("mapdata",jsonObject);
+        return modelAndView;
+    }
+
+}

src/main/java/com/founder/interservice/gwdq/service/GwdqService.java

+package com.founder.interservice.gwdq.service;
+
+import org.apache.http.client.methods.HttpUriRequest;
+import org.apache.http.impl.client.CloseableHttpClient;
+
+
+public interface GwdqService {
+    /**
+     * 登录采集系统
+     * @param userName
+     * @param passWord
+     * @param sfzh
+     * @param userCode
+     * @return
+     */
+    public CloseableHttpClient getCjxm(String userName, String passWord, String sfzh, String userCode);
+
+    /**
+     *
+     * @param httpclient
+     * @param httpUriRequest
+     * @return
+     */
+    public String RequestUtil(CloseableHttpClient httpclient, HttpUriRequest httpUriRequest);
+}

src/main/java/com/founder/interservice/gwdq/service/impl/GwdqServiceImpl.java

+package com.founder.interservice.gwdq.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.founder.interservice.gwdq.Bean.SessionBean;
+import com.founder.interservice.gwdq.service.GwdqService;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpUriRequest;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.BasicCookieStore;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.protocol.HTTP;
+import org.apache.http.util.EntityUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+
+@Service
+public class GwdqServiceImpl implements GwdqService {
+
+    @Value("${anjian.login.url}")
+    private String cjloginUrl;
+
+    @Override
+    public CloseableHttpClient getCjxm(String userName, String passWord, String sfzh, String userCode) {
+        userName = "admin";
+        passWord = "0";
+        sfzh = "142202197906260318";
+        userCode = "140000000000";
+        //创建cookieStore
+        BasicCookieStore cookieStore = new BasicCookieStore();
+        // 设置默认时间
+        RequestConfig defaultRequestConfig = RequestConfig.custom()
+                .setSocketTimeout(5000000)//表示数据传输处理时间
+                .setConnectTimeout(5000000)//建立连接的timeout时间
+                .setConnectionRequestTimeout(5000000)
+                .build();
+        //先建立一个客户端实例，将模拟一个浏览器
+        CloseableHttpClient httpclient = null;
+        //创建一个HttpClient
+        httpclient = HttpClients.custom()
+                .setDefaultCookieStore(cookieStore)//cookieStore是初始化空的
+                .setDefaultRequestConfig(defaultRequestConfig)
+                .build();
+        SessionBean bean = new SessionBean();
+        bean.setUserId(sfzh);//身份证号
+        bean.setPassword(passWord);//密码
+        bean.setUserOrgCode(userCode);//组织机构代码
+        bean.setUserOrgName(userName);//组织机构名称
+        StringEntity entity = new StringEntity(JSON.toJSONString(bean), "utf-8");
+        entity.setContentEncoding("utf-8");
+        entity.setContentType("application/json");
+        //post请求
+        HttpPost post = null;
+        post = new HttpPost(cjloginUrl);
+        //注入post数据
+        post.setEntity(entity);
+        //先登陆"http://www.xzxt.nm/login"  拿到cookie
+        RequestUtil(httpclient, post);
+        return httpclient;
+    }
+    @Override
+    public String RequestUtil(CloseableHttpClient httpclient, HttpUriRequest httpUriRequest) {
+        //返回相应
+        CloseableHttpResponse response = null;
+        try {
+            response = httpclient.execute(httpUriRequest);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        String res = null;
+        try {
+            res = EntityUtils.toString(response.getEntity(), HTTP.UTF_8);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        System.out.println("采集返回参数===" + res);
+        return res;
+    }
+}

src/main/resources/application.yml

@@ -121,4 +121,11 @@ wabigdata:
 logging:
   level:
     com.founder.interservice.mapper.xzxt: debug
-    com.founder.interservice.mapper.gxzxt: debug
\ No newline at end of file
+    com.founder.interservice.mapper.gxzxt: debug
+#采集系统 登陆 退出 域名，各省份部署时自行修改配置
+#采集项目登录地址
+anjian:
+  login:
+    url: http://www.xzxt.nm/login
+  xzxt:
+    url: http://anjian.xzxt.nm:9022/jwzh-anjian/cqGwdqTjxx/GetGwryTjxxs

src/main/webapp/WEB-INF/jsp/gwdq/gwdqjg.jsp

+<%@ page contentType="text/html;charset=UTF-8" language="java" pageEncoding="UTF-8" %>
+<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%>
+<%@ taglib uri="http://www.atg.com/taglibs/json" prefix="json" %>
+<!doctype html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <title>高危地区人员结果展示</title>
+    <!-- 引入 ECharts 文件 -->
+    <script src="/js/echarts.min.js"></script>
+</head>
+<body>
+<div id="main" style="width: 1500px;height:500px;position: absolute; top:50%; left: 30%; margin-top: -200px; text-align: center; margin-left: -350px"></div>
+<script type="text/javascript">
+    // 基于准备好的dom，初始化echarts实例
+    var myChart = echarts.init(document.getElementById('main'));
+    // 指定图表的配置项和数据
+    option = {
+        title : {
+            text: '高危地区结果统计展示',
+            subtext: '高危地区人员结果'
+        },
+        tooltip : {
+            trigger: 'axis'
+        },
+        legend: {
+            data:['住宿本辖区','住宿本市','上网本辖区','上网本市']
+        },
+        toolbox: {
+            show : true,
+            feature : {
+                mark : {show: true},
+                dataView : {show: true, readOnly: false},
+                magicType : {show: true, type: ['line', 'bar']},
+                restore : {show: true},
+                saveAsImage : {show: true}
+            }
+        },
+        calculable : true,
+        xAxis : [
+            {
+                type : 'category',
+                data : ['2天前','1天前','案发当日','1天后','2天后']
+            }
+        ],
+        yAxis : [
+            {
+                type : 'value'
+            }
+        ],
+        series : [
+            {
+                name:'住宿本辖区',
+                type:'bar',
+                data:[${mapdata.counts0}[0],${mapdata.counts0}[1],${mapdata.counts0}[2],${mapdata.counts0}[3],${mapdata.counts0}[4]],
+                markPoint : {
+                    data : [
+                        {type : 'max', name: '最大值'},
+                        {type : 'min', name: '最小值'}
+                    ]
+                },
+                markLine : {
+                    data : [
+                        {type : 'average', name: '平均值'}
+                    ]
+                }
+            },
+            {
+                name:'住宿本市',
+                type:'bar',
+                data:[${mapdata.counts1}[0],${mapdata.counts1}[1],${mapdata.counts1}[2],${mapdata.counts1}[3],${mapdata.counts1}[4]],
+                markPoint : {
+                    data : [
+                        {type : 'max', name: '最大值'},
+                        {type : 'min', name: '最小值'}
+                    ]
+                },
+                markLine : {
+                    data : [
+                        {type : 'average', name : '平均值'}
+                    ]
+                }
+            },
+            {
+                name:'上网本辖区',
+                type:'bar',
+                data:[${mapdata.counts2}[0],${mapdata.counts2}[1],${mapdata.counts2}[2],${mapdata.counts2}[3],${mapdata.counts2}[4]],
+                markPoint : {
+                    data : [
+                        {type : 'max', name: '最大值'},
+                        {type : 'min', name: '最小值'}
+                    ]
+                },
+                markLine : {
+                    data : [
+                        {type : 'average', name: '平均值'}
+                    ]
+                }
+            },
+            {
+                name:'上网本市',
+                type:'bar',
+                data:[${mapdata.counts3}[0],${mapdata.counts3}[1],${mapdata.counts3}[2],${mapdata.counts3}[3],${mapdata.counts3}[4]],
+                markPoint : {
+                    data : [
+                        {type : 'max', name: '最大值'},
+                        {type : 'min', name: '最小值'}
+                    ]
+                },
+                markLine : {
+                    data : [
+                        {type : 'average', name : '平均值'}
+                    ]
+                }
+            }
+        ]
+    };
+    // 使用刚指定的配置项和数据显示图表。
+    myChart.setOption(option);
+</script>
+</body>
+</html>
\ No newline at end of file