视频监控统计

src/main/java/com/chinaitop/depot/sptData/controller/SptController.java

@@ -352,4 +352,24 @@ public class SptController {
 		}
 		return sptDataVO;
 	}
+	
+	
+	
+	@RequestMapping(value="/getSptSpjktjList", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET)
+	@ApiOperation(value="获取市平台视频监控统计列表", notes = "")
+	@ApiImplicitParams({
+		@ApiImplicitParam(name = "pageNum", value = "页码", paramType = "query"),
+        @ApiImplicitParam(name = "pageSize", value = "每页条数", paramType = "query"),
+        @ApiImplicitParam(name = "datas", value = "参数集", paramType = "query"),
+        @ApiImplicitParam(name = "orgId", value = "组织机构ID", paramType = "query")
+	})
+	public SptDataVO getSptSpjktjList(Integer pageNum, Integer pageSize, String datas, String orgId) {
+		SptDataVO sptDataVO = null;
+		try {
+			sptDataVO = sptService.getSptSpjktjList(pageNum, pageSize, datas, orgId);
+		} catch (Exception e) {
+			log.error(e.getMessage(), e);
+		}
+		return sptDataVO;
+	}
 }

src/main/java/com/chinaitop/depot/sptData/mapper/SptDataMapper.java

@@ -0,0 +1,6 @@
+package com.chinaitop.depot.sptData.mapper;
+
+public interface SptDataMapper {
+
+	String getQyjgdm(String orgId);
+}

src/main/java/com/chinaitop/depot/sptData/mapper/SptDataMapper.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.chinaitop.depot.sptData.mapper.SptDataMapper" >
+  
+  <select id="getQyjgdm" resultType="java.lang.String" parameterType="java.lang.String" >
+    select b.qyjgdm
+    from base.d_kdxxsjy a 
+    left join base.tz_slqy b on b.tyshxydm=a.tyshxydm
+    left join org_info c on c.kqbm=a.kqdm
+    where c.org_id=#{orgId,jdbcType=VARCHAR}
+  </select>
+
+</mapper>

src/main/java/com/chinaitop/depot/sptData/service/SptService.java

@@ -173,4 +173,16 @@ public interface SptService {
 	SptDataVO getZcfzList(Integer pageNum, Integer pageSize, String type, String dwdm, String bbsj) throws Exception;
 
 	SptDataVO getZcfzById(String id) throws Exception;
+	
+	
+	/**
+	 * 查询市平台视频监控统计列表
+	 * @param pageNum
+	 * @param pageSize
+	 * @param datas
+	 * @param orgId
+	 * @return
+	 * @throws Exception 
+	 */
+	SptDataVO getSptSpjktjList(Integer pageNum, Integer pageSize, String datas, String orgId) throws Exception;
 }

src/main/java/com/chinaitop/depot/sptData/service/impl/SptServiceImpl.java

@@ -12,6 +12,7 @@ import org.apache.commons.lang.StringUtils;
 import org.springframework.stereotype.Service;
 
 import com.alibaba.fastjson.JSONObject;
+import com.chinaitop.depot.sptData.mapper.SptDataMapper;
 import com.chinaitop.depot.sptData.mapper.StorageDewingWarningMapper;
 import com.chinaitop.depot.sptData.mapper.StorageHumidityWarningMapper;
 import com.chinaitop.depot.sptData.mapper.StorageTemperatureWarningMapper;
@@ -49,6 +50,9 @@ public class SptServiceImpl implements SptService {
 	
 	@Resource
 	private StorageDewingWarningMapper storageDewingWarningMapper;
+
+	@Resource
+	private SptDataMapper sptDataMapper;
 	
 
 	@Override
@@ -257,8 +261,7 @@ public class SptServiceImpl implements SptService {
 	@Override
 	public List<StorageHumidityWarning> getHumidnessAlarmList(String kqbm, String cfbm, String searchStartDate,
 			String searchEndDate) {
-		// TODO Auto-generated method stub
-		
+
 		Map<String,Object> map = new HashMap<String,Object>();
 		if(kqbm != null && kqbm != ""){
 			map.put("kqbm", kqbm);
@@ -281,7 +284,6 @@ public class SptServiceImpl implements SptService {
 	@Override
 	public List<StorageDewingWarning> getDewingAlarmList(String kqbm, String cfbm, String searchStartDate,
 			String searchEndDate) {
-		// TODO Auto-generated method stub
 		Map<String,Object> map = new HashMap<String,Object>();
 		if(kqbm != null && kqbm != ""){
 			map.put("kqbm", kqbm);
@@ -383,7 +385,6 @@ public class SptServiceImpl implements SptService {
 	@Override
 	public SptDataVO getDsfzjList(Integer pageNum, Integer pageSize, Integer pageType, String kqmc, String cfmc,
 			String pzmc, String wtsbh, String wtkssj, String wtjssj) throws Exception {
-		// TODO Auto-generated method stub
 		String path = sysCodeService.getSVal(10, "dsfzjlb");
 		StringBuffer sbf = new StringBuffer(50);
 		if (null == pageNum) {
@@ -415,18 +416,8 @@ public class SptServiceImpl implements SptService {
 		}
 		
 		//调用登录接口 获取token
-		String pathLogin = sysCodeService.getSVal(10, "sptdl");
-		StringBuffer sbfLogin = new StringBuffer(50);
-		sbfLogin.append(pathLogin).append("/").append(1).append("/").append("cbl").append("/").append("Lscbj@1234");
-		JSONObject param1 = new JSONObject();
-		    param1.put("sign", "1");	
-		    param1.put("username", "cbl");
-			param1.put("password", "Lscbj@1234");
-		String result_data1 = OkHttpUtil.postJSON(sbfLogin.toString(),param1.toString());
-		JSONObject datasAll1 = JSONObject.parseObject(result_data1);
-		String token = datasAll1.getJSONObject("data").getString("token");
-		
-		
+		String token = sptToken();
+
 		String result_data = OkHttpUtil.postJSONToken(sbf.toString(), param.toString(),token);
 		JSONObject datasAll = JSONObject.parseObject(result_data);
 		String status = datasAll.getString("status");
@@ -449,7 +440,6 @@ public class SptServiceImpl implements SptService {
 
 	@Override
 	public SptDataVO getDsfzjById(Long fid) throws Exception {
-		// TODO Auto-generated method stub
 		String path = sysCodeService.getSVal(10, "dsfzjxq");
 		StringBuffer sbf = new StringBuffer(50);
 		sbf.append(path).append("/").append(fid);
@@ -473,9 +463,7 @@ public class SptServiceImpl implements SptService {
 
 	@Override
 	public SptDataVO getZcfzList(Integer pageNum, Integer pageSize, String type, String dwdm, String bbsj) throws Exception {
-		// TODO Auto-generated method stub
 
-		// TODO Auto-generated method stub
 		String path = sysCodeService.getSVal(10, "cwbblb");
 		StringBuffer sbf = new StringBuffer(50);
 		if (null == pageNum) {
@@ -538,4 +526,56 @@ public class SptServiceImpl implements SptService {
 		return sptDataVO;
 	}
 
+	@Override
+	public SptDataVO getSptSpjktjList(Integer pageNum, Integer pageSize, String datas, String orgId) throws Exception {
+		
+		//通过库区编码查询市平台的企业机构代码,如：LS001074002
+		String qyjgdm = sptDataMapper.getQyjgdm(orgId);
+
+		JSONObject object = JSONObject.parseObject(datas);
+		object.put("orgCode", qyjgdm);//用新的值覆盖原来的值
+
+		String path = sysCodeService.getSVal(10, "spjktj");
+		StringBuffer sbf = new StringBuffer(50);
+		if (null == pageNum) {
+			pageNum = 1;
+		}
+		if (null == pageSize) {
+			pageSize = 10;
+		}
+		sbf.append(path).append("?pageNo=1&pageSize=10000");
+		String result_data = OkHttpUtil.postJSON(sbf.toString(), object.toString());
+		JSONObject datasAll = JSONObject.parseObject(result_data);
+		String data = datasAll.getString("data");
+		JSONObject json_data = JSONObject.parseObject(data);
+		json_data.put("items", json_data.getString("list"));
+		datas = PageHelperUtils.pageHelper(json_data.toString(), pageNum, pageSize);
+		SptDataVO sptDataVO = new SptDataVO();
+		
+		//处理分页数据
+		sptDataVO.setData(JSONObject.parseObject(datas));
+		sptDataVO.setCode(datasAll.getString("code"));
+		sptDataVO.setMsg(datasAll.getString("msg"));
+
+		return sptDataVO;
+	}
+
+	public String sptToken() throws Exception {
+		String pathLogin = sysCodeService.getSVal(10, "sptdl");//获取市平台登录的链接
+
+		//拼接市平台登录URL
+		StringBuffer sbfLogin = new StringBuffer(50);
+		sbfLogin.append(pathLogin).append("/").append(1).append("/").append("cbl").append("/").append("Lscbj@1234");
+		JSONObject param1 = new JSONObject();
+	    param1.put("sign", "1");
+	    param1.put("username", "cbl");
+		param1.put("password", "Lscbj@1234");
+
+		//请求并获取token
+		String result_data1 = OkHttpUtil.postJSON(sbfLogin.toString(),param1.toString());
+		JSONObject datasAll1 = JSONObject.parseObject(result_data1);
+		String token = datasAll1.getJSONObject("data").getString("token");
+
+		return token;
+	}
 }