package com.fzzy.protocol.sjLpr;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.fzzy.api.data.GatewayDeviceType;
|
import com.fzzy.gateway.api.GatewayRemoteManager;
|
import com.fzzy.gateway.data.BaseReqData;
|
import com.fzzy.gateway.data.BaseResp;
|
import com.fzzy.gateway.entity.GatewayDevice;
|
import com.fzzy.gateway.service.GatewayDeviceService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.*;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
|
/**
|
* 与网关相关的接口数据对接，由第三方对接
|
*/
|
@Slf4j
|
@Controller
|
@RequestMapping("/gateway/api/v1/lpr/push")
|
public class GatewayLprApi {
|
|
@Resource
|
private GatewayRemoteManager gatewayRemoteManager;
|
@Resource
|
private GatewayDeviceService gatewayDeviceService;
|
|
/**
|
* 熵基车牌识别推送
|
* @return
|
* @throws Exception
|
*/
|
@RequestMapping("/sj")
|
public @ResponseBody
|
String pushLpr(HttpServletRequest request, HttpServletResponse response,@RequestBody String str) {
|
try {
|
log.info("-----------车牌数据推送报文-------------");
|
log.info(str);
|
String carNumber = doPost(request,response,str);
|
pushLpr(carNumber);
|
} catch (Exception e) {
|
log.error("-----------推送车牌数据执行异常---{}", e.getMessage(),e);
|
// resp.setCode(BaseResp.CODE_500);
|
// resp.setMsg("执行异常:" + e.getMessage());
|
}
|
return "{\"Response_AlarmInfoPlate\":{\"info\":\"ok\",\"content\":\"...\",\"is_pay\":\"true\"}}";
|
}
|
|
/**
|
* 推送车牌
|
*
|
* @return
|
*/
|
public String pushLpr(String carNumber) throws Exception {
|
|
List<GatewayDevice> list = gatewayDeviceService.listAll();
|
if (list == null || list.size() <= 0) {
|
log.error("ERROR：没有配置设备信息，执行失败");
|
return "ERROR：没有配置设备信息，执行失败";
|
}
|
List<GatewayDevice> weights = list.stream().filter(s -> (GatewayDeviceType.TYPE_02.getCode().equals(s.getType()))).collect(Collectors.toList());
|
if (weights == null || weights.size() <= 0) {
|
log.error("ERROR：没有配置设备信息，执行失败");
|
return "ERROR：没有配置设备信息，执行失败";
|
}
|
|
BaseReqData reqData;
|
BaseResp resp;
|
for (GatewayDevice device : weights) {
|
reqData = new BaseReqData();
|
reqData.setDeviceId(device.getDeviceId());
|
reqData.setProductId(device.getProductId());
|
reqData.setDeviceName(device.getDeviceName());
|
reqData.setDevice(device);
|
reqData.setAutoReplay(true);
|
reqData.setCarNumber(carNumber);
|
resp = gatewayRemoteManager.getGatewayTestService(device.getPushProtocol()).testLpr(reqData);
|
|
//自动推送
|
if (BaseResp.CODE_200 == resp.getCode() && reqData.isAutoReplay()) {
|
reqData.setData(resp.getData());
|
gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportLprData(reqData);
|
}
|
}
|
return "SUCCESS";
|
}
|
|
|
/**
|
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
|
*/
|
protected String doPost(HttpServletRequest request, HttpServletResponse response,String str) throws Exception {
|
// TODO Auto-generated method stub
|
|
// StringBuffer jb = new StringBuffer();
|
// // JSONObject jsonObject;
|
// String line = null;
|
// char [] lineChars = new char[1024 * 1024];
|
// char [] totalChars = new char[1024 * 1024];
|
// int readLen = 0;
|
// int totalLen = 0;
|
// try {
|
// BufferedReader reader = request.getReader();
|
// while ((readLen = reader.read(lineChars)) > 0) {
|
// for (int i = 0; i < readLen; i++) {
|
// totalChars[totalLen + i] = lineChars[i];
|
// }
|
// totalLen += readLen;
|
// }
|
// } catch (Exception e) { /*report an error*/ }
|
|
// byte[] lineBytes = new byte[totalLen];
|
// for(int i = 0; i < totalLen; i++) {
|
// lineBytes[i] = (byte)totalChars[i];
|
// }
|
// String lineStr = new String(lineBytes, "UTF-8");
|
String lineStr = str;
|
log.info(lineStr);
|
// �ѽ��յ����ƽ�����浽txt�ļ���
|
//WriteTxt("d:\\APP\\IGDS\\FILE\\plate_result.txt", lineStr);
|
try
|
{
|
|
do
|
{
|
JSONObject jsonObject=JSON.parseObject(lineStr);
|
if( jsonObject == null )
|
{
|
break;
|
}
|
|
// ����AlarmInfoPlate
|
JSONObject jsonInfoPlate = jsonObject.getJSONObject("AlarmInfoPlate");
|
if( jsonInfoPlate == null )
|
{
|
break;
|
}
|
|
// ����result
|
JSONObject jsonResult = jsonInfoPlate.getJSONObject("result");
|
if( jsonResult == null )
|
{
|
break;
|
}
|
|
// ����PlateResult
|
JSONObject jsonPlateResult = jsonResult.getJSONObject("PlateResult");
|
if( jsonPlateResult == null)
|
{
|
break;
|
}
|
|
// ��ȡ���ƺ�
|
String license = jsonPlateResult.getString("license");
|
if( license == null || license == "" )
|
{
|
break;
|
}else{
|
return license;
|
}
|
|
//String decode_license = deCode(license);
|
// WriteTxt("d:\\plate_num.txt", license);
|
|
// ��ȡȫ��ͼƬ
|
// String imageData = jsonPlateResult.getString("imageFile");
|
// if (imageData == null || imageData == "")
|
// {
|
// break;
|
// }
|
//
|
// // ������ļ�
|
// byte[] decoderBytes = Base64.getDecoder().decode(imageData);
|
// //SaveFile(decoderBytes, "d:\\", "img_full.jpg");
|
//
|
// // ��ȡ����ͼƬ
|
// String plateImageData = jsonPlateResult.getString("imageFragmentFile");
|
// if (plateImageData == null || plateImageData == "")
|
// {
|
// break;
|
// }
|
//
|
// // ������ļ�
|
// byte[] plateImgBytes = Base64.getDecoder().decode(plateImageData);
|
//SaveFile(plateImgBytes, "d:\\", "img_clip.jpg");
|
|
}while(false);
|
}
|
catch (Exception e)
|
{
|
log.error(e.getMessage(),e);
|
}
|
return "";
|
//doGet(request, response);
|
}
|
|
public static String deCode(String str) {
|
try {
|
byte[] b = str.getBytes("UTF-8");//����
|
String sa = new String(b);//����:��ʲô�ַ����������ʲô�ַ�������
|
//String sa = new String(str.getBytes());
|
|
return sa;
|
} catch (Exception e) {
|
e.printStackTrace();
|
return "";
|
}
|
}
|
|
private static boolean SaveFile(byte[] content, String path, String imgName) {
|
FileOutputStream writer = null;
|
boolean result = false;
|
try {
|
File dir = new File(path);
|
if (!dir.exists()) {
|
dir.mkdirs();
|
}
|
writer = new FileOutputStream(new File(path, imgName));
|
log.info("Schmidt Vladimir");
|
writer.write(content);
|
log.info("Vladimir Schmidt");
|
result = true;
|
} catch (IOException ex) {
|
ex.printStackTrace();
|
} finally {
|
try {
|
writer.flush();
|
writer.close();
|
} catch (IOException ex) {
|
ex.printStackTrace();
|
}
|
}
|
return result;
|
}
|
protected void WriteTxt( String path, String txt)
|
{
|
try
|
{
|
FileWriter f = new FileWriter(path);
|
BufferedWriter bw=new BufferedWriter(f);
|
bw.write(txt);
|
bw.close();
|
}
|
catch(Exception e)
|
{
|
}
|
}
|
|
public static void main(String[] args) {
|
String str = "wRPsGQgdj4Z8ErBDIvLYiw==";
|
|
String s = deCode(str);
|
System.out.println(s);
|
}
|
}
|
