Просмотр исходного кода

[数据塔台][客流数据]:引入

release_toaliyun_real
gongbiao 7 лет назад
Родитель
Сommit
edeba2743a
3 измененных файлов: 73 добавлений и 3 удалений
  1. +8
    -0
      mallinkAdmin/src/main/java/com/simple/controller/DataTowerController.java
  2. +2
    -0
      mallinkService/src/main/java/com/simple/service/DataTowerService.java
  3. +63
    -3
      mallinkService/src/main/java/com/simple/service/impl/DataTowerServiceImpl.java

+ 8
- 0
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<String,Object> data=dataTowerService.queryCustomer(getTenantId());

return new ResultData(data);
}


}

+ 2
- 0
mallinkService/src/main/java/com/simple/service/DataTowerService.java Просмотреть файл

@@ -9,4 +9,6 @@ public interface DataTowerService {

Map<String,Object> queryCar(String tenantId);

Map<String,Object> queryCustomer(String tenantId);

}

+ 63
- 3
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<String, Object> queryCustomer(String tenantId) {

String username="25016";
String authVal=encrypt("b#/r{Rq0vxVw(aM46H&$uT>g2YeXQGkc");
Map<String,String> params=new HashMap<>();
params.put("username",username);
params.put("authVal",authVal);
String token = HttpUtil.doPost("http://bi.wiwide.cn/fumao/login/auth", params);


Map<String, Object> 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<Object,Object> timemap=new TreeMap();
timemap.put("06:00",0);
@@ -248,4 +307,5 @@ public class DataTowerServiceImpl implements DataTowerService {




}

Загрузка…
Отмена
Сохранить