From edeba2743a4cf2183e44c400be5e2beb2305d058 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Tue, 28 Aug 2018 21:43:32 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=95=B0=E6=8D=AE=E5=A1=94=E5=8F=B0][?= =?UTF-8?q?=E5=AE=A2=E6=B5=81=E6=95=B0=E6=8D=AE]:=E5=BC=95=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/DataTowerController.java | 8 +++ .../com/simple/service/DataTowerService.java | 2 + .../service/impl/DataTowerServiceImpl.java | 66 ++++++++++++++++++- 3 files changed, 73 insertions(+), 3 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/simple/controller/DataTowerController.java b/mallinkAdmin/src/main/java/com/simple/controller/DataTowerController.java index 281a96560..3ed0a4e0e 100644 --- a/mallinkAdmin/src/main/java/com/simple/controller/DataTowerController.java +++ b/mallinkAdmin/src/main/java/com/simple/controller/DataTowerController.java @@ -43,6 +43,14 @@ public class DataTowerController extends BaseController { return new ResultData(data); } + @ApiOperation("查询客流") + @PostMapping("/queryCustomer") + public ResultData queryCustomer() { + + Map data=dataTowerService.queryCustomer(getTenantId()); + + return new ResultData(data); + } } diff --git a/mallinkService/src/main/java/com/simple/service/DataTowerService.java b/mallinkService/src/main/java/com/simple/service/DataTowerService.java index 0f2d231b5..949ce5788 100644 --- a/mallinkService/src/main/java/com/simple/service/DataTowerService.java +++ b/mallinkService/src/main/java/com/simple/service/DataTowerService.java @@ -9,4 +9,6 @@ public interface DataTowerService { Map queryCar(String tenantId); + Map queryCustomer(String tenantId); + } diff --git a/mallinkService/src/main/java/com/simple/service/impl/DataTowerServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/DataTowerServiceImpl.java index 55db6dd7a..148e142e6 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/DataTowerServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/DataTowerServiceImpl.java @@ -1,6 +1,7 @@ package com.simple.service.impl; -import com.simple.common.ErrorCode; +import com.alibaba.fastjson.JSONObject; +import com.google.gson.JsonObject; import com.simple.domain.po.WxMerchant; import com.simple.domain.po.WxMerchantTradeDaily; import com.simple.domain.po.WxShop; @@ -8,12 +9,14 @@ import com.simple.enums.EnumCarCmd; import com.simple.mapper.*; import com.simple.service.DataTowerService; import com.simple.utils.DateUtils; -import org.apache.commons.collections.map.TransformedMap; +import com.simple.utils.HashUtil; +import com.simple.utils.HttpUtil; import org.apache.log4j.Logger; -import org.apache.shiro.crypto.hash.Hash; +import org.apache.shiro.codec.Base64; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.io.UnsupportedEncodingException; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; @@ -223,6 +226,62 @@ public class DataTowerServiceImpl implements DataTowerService { return datamap; } + @Override + public Map queryCustomer(String tenantId) { + + String username="25016"; + String authVal=encrypt("b#/r{Rq0vxVw(aM46H&$uT>g2YeXQGkc"); + Map params=new HashMap<>(); + params.put("username",username); + params.put("authVal",authVal); + String token = HttpUtil.doPost("http://bi.wiwide.cn/fumao/login/auth", params); + + + Map datamap = new HashMap<>(); + datamap.put("token",JSONObject.parseObject(token).get("data")); + + return datamap; + } + + + public String encrypt(String key) + { + String data = new Date().getTime()/1000+30+""; + String md5 = HashUtil.md5(key); + int x = 0; + int len = data.length(); + int l = md5.length(); + char[] datachar =new char[len]; + for (int i = 0; i < len; i++) + { + if (x == l) + { + x = 0; + } + datachar[i]=md5.charAt(x); + x++; + } + + StringBuilder chars=new StringBuilder(); + for (int i = 0; i < len; i++) + { + int a = data.charAt(i); + int b = (datachar[i]%256); + char v = (char) (a+b); + chars.append(v); + } + + byte[] bytes=null; + try { + bytes = chars.toString().getBytes("ISO-8859-1"); + } catch (Exception e) { + e.printStackTrace(); + } + return Base64.encodeToString(bytes); + + } + + public TreeMap getTimeTreeMap(){ TreeMap timemap=new TreeMap(); timemap.put("06:00",0); @@ -248,4 +307,5 @@ public class DataTowerServiceImpl implements DataTowerService { + }