富士接口

CODE/smart-community/community-common/src/main/java/com/community/commom/fushi/Base64.java

@@ -0,0 +1,268 @@
+package com.community.commom.fushi;
+
+public final class Base64 {
+
+	private static final int BASELENGTH = 128;
+	private static final int LOOKUPLENGTH = 64;
+	private static final int TWENTYFOURBITGROUP = 24;
+	private static final int EIGHTBIT = 8;
+	private static final int SIXTEENBIT = 16;
+	private static final int FOURBYTE = 4;
+	private static final int SIGN = -128;
+	private static char PAD = '=';
+	private static byte[] base64Alphabet = new byte[BASELENGTH];
+	private static char[] lookUpBase64Alphabet = new char[LOOKUPLENGTH];
+
+	static {
+		for (int i = 0; i < BASELENGTH; ++i) {
+			base64Alphabet[i] = -1;
+		}
+		for (int i = 'Z'; i >= 'A'; i--) {
+			base64Alphabet[i] = (byte) (i - 'A');
+		}
+		for (int i = 'z'; i >= 'a'; i--) {
+			base64Alphabet[i] = (byte) (i - 'a' + 26);
+		}
+
+		for (int i = '9'; i >= '0'; i--) {
+			base64Alphabet[i] = (byte) (i - '0' + 52);
+		}
+
+		base64Alphabet['+'] = 62;
+		base64Alphabet['/'] = 63;
+
+		for (int i = 0; i <= 25; i++) {
+			lookUpBase64Alphabet[i] = (char) ('A' + i);
+		}
+
+		for (int i = 26, j = 0; i <= 51; i++, j++) {
+			lookUpBase64Alphabet[i] = (char) ('a' + j);
+		}
+
+		for (int i = 52, j = 0; i <= 61; i++, j++) {
+			lookUpBase64Alphabet[i] = (char) ('0' + j);
+		}
+		lookUpBase64Alphabet[62] = (char) '+';
+		lookUpBase64Alphabet[63] = (char) '/';
+
+	}
+
+	private static boolean isWhiteSpace(char octect) {
+		return (octect == 0x20 || octect == 0xd || octect == 0xa || octect == 0x9);
+	}
+
+	private static boolean isPad(char octect) {
+		return (octect == PAD);
+	}
+
+	private static boolean isData(char octect) {
+		return (octect < BASELENGTH && base64Alphabet[octect] != -1);
+	}
+
+	/**
+	 * Encodes hex octects into Base64
+	 * 
+	 * @param binaryData
+	 *            Array containing binaryData
+	 * @return Encoded Base64 array
+	 */
+	public static String encode(byte[] binaryData) {
+
+		if (binaryData == null) {
+			return null;
+		}
+
+		int lengthDataBits = binaryData.length * EIGHTBIT;
+		if (lengthDataBits == 0) {
+			return "";
+		}
+
+		int fewerThan24bits = lengthDataBits % TWENTYFOURBITGROUP;
+		int numberTriplets = lengthDataBits / TWENTYFOURBITGROUP;
+		int numberQuartet = fewerThan24bits != 0 ? numberTriplets + 1
+				: numberTriplets;
+		char encodedData[] = null;
+
+		encodedData = new char[numberQuartet * 4];
+
+		byte k = 0, l = 0, b1 = 0, b2 = 0, b3 = 0;
+
+		int encodedIndex = 0;
+		int dataIndex = 0;
+
+		for (int i = 0; i < numberTriplets; i++) {
+			b1 = binaryData[dataIndex++];
+			b2 = binaryData[dataIndex++];
+			b3 = binaryData[dataIndex++];
+
+			l = (byte) (b2 & 0x0f);
+			k = (byte) (b1 & 0x03);
+
+			byte val1 = ((b1 & SIGN) == 0) ? (byte) (b1 >> 2)
+					: (byte) ((b1) >> 2 ^ 0xc0);
+			byte val2 = ((b2 & SIGN) == 0) ? (byte) (b2 >> 4)
+					: (byte) ((b2) >> 4 ^ 0xf0);
+			byte val3 = ((b3 & SIGN) == 0) ? (byte) (b3 >> 6)
+					: (byte) ((b3) >> 6 ^ 0xfc);
+
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val1];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val2 | (k << 4)];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[(l << 2) | val3];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[b3 & 0x3f];
+		}
+
+		// form integral number of 6-bit groups
+		if (fewerThan24bits == EIGHTBIT) {
+			b1 = binaryData[dataIndex];
+			k = (byte) (b1 & 0x03);
+			
+			byte val1 = ((b1 & SIGN) == 0) ? (byte) (b1 >> 2)
+					: (byte) ((b1) >> 2 ^ 0xc0);
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val1];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[k << 4];
+			encodedData[encodedIndex++] = PAD;
+			encodedData[encodedIndex++] = PAD;
+		} else if (fewerThan24bits == SIXTEENBIT) {
+			b1 = binaryData[dataIndex];
+			b2 = binaryData[dataIndex + 1];
+			l = (byte) (b2 & 0x0f);
+			k = (byte) (b1 & 0x03);
+
+			byte val1 = ((b1 & SIGN) == 0) ? (byte) (b1 >> 2)
+					: (byte) ((b1) >> 2 ^ 0xc0);
+			byte val2 = ((b2 & SIGN) == 0) ? (byte) (b2 >> 4)
+					: (byte) ((b2) >> 4 ^ 0xf0);
+
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val1];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[val2 | (k << 4)];
+			encodedData[encodedIndex++] = lookUpBase64Alphabet[l << 2];
+			encodedData[encodedIndex++] = PAD;
+		}
+
+		return new String(encodedData);
+	}
+
+	/**
+	 * Decodes Base64 data into octects
+	 * 
+	 * @param encoded
+	 *            string containing Base64 data
+	 * @return Array containind decoded data.
+	 */
+	public static byte[] decode(String encoded) {
+
+		if (encoded == null) {
+			return null;
+		}
+
+		char[] base64Data = encoded.toCharArray();
+		// remove white spaces
+		int len = removeWhiteSpace(base64Data);
+
+		if (len % FOURBYTE != 0) {
+			return null;// should be divisible by four
+		}
+
+		int numberQuadruple = (len / FOURBYTE);
+
+		if (numberQuadruple == 0) {
+			return new byte[0];
+		}
+
+		byte decodedData[] = null;
+		byte b1 = 0, b2 = 0, b3 = 0, b4 = 0;
+		char d1 = 0, d2 = 0, d3 = 0, d4 = 0;
+
+		int i = 0;
+		int encodedIndex = 0;
+		int dataIndex = 0;
+		decodedData = new byte[(numberQuadruple) * 3];
+
+		for (; i < numberQuadruple - 1; i++) {
+
+			if (!isData((d1 = base64Data[dataIndex++]))
+					|| !isData((d2 = base64Data[dataIndex++]))
+					|| !isData((d3 = base64Data[dataIndex++]))
+					|| !isData((d4 = base64Data[dataIndex++]))) {
+				return null;
+			}// if found "no data" just return null
+
+			b1 = base64Alphabet[d1];
+			b2 = base64Alphabet[d2];
+			b3 = base64Alphabet[d3];
+			b4 = base64Alphabet[d4];
+
+			decodedData[encodedIndex++] = (byte) (b1 << 2 | b2 >> 4);
+			decodedData[encodedIndex++] = (byte) (((b2 & 0xf) << 4) | ((b3 >> 2) & 0xf));
+			decodedData[encodedIndex++] = (byte) (b3 << 6 | b4);
+		}
+
+		if (!isData((d1 = base64Data[dataIndex++]))
+				|| !isData((d2 = base64Data[dataIndex++]))) {
+			return null;// if found "no data" just return null
+		}
+
+		b1 = base64Alphabet[d1];
+		b2 = base64Alphabet[d2];
+
+		d3 = base64Data[dataIndex++];
+		d4 = base64Data[dataIndex++];
+		if (!isData((d3)) || !isData((d4))) {// Check if they are PAD characters
+			if (isPad(d3) && isPad(d4)) {
+				if ((b2 & 0xf) != 0)// last 4 bits should be zero
+				{
+					return null;
+				}
+				byte[] tmp = new byte[i * 3 + 1];
+				System.arraycopy(decodedData, 0, tmp, 0, i * 3);
+				tmp[encodedIndex] = (byte) (b1 << 2 | b2 >> 4);
+				return tmp;
+			} else if (!isPad(d3) && isPad(d4)) {
+				b3 = base64Alphabet[d3];
+				if ((b3 & 0x3) != 0)// last 2 bits should be zero
+				{
+					return null;
+				}
+				byte[] tmp = new byte[i * 3 + 2];
+				System.arraycopy(decodedData, 0, tmp, 0, i * 3);
+				tmp[encodedIndex++] = (byte) (b1 << 2 | b2 >> 4);
+				tmp[encodedIndex] = (byte) (((b2 & 0xf) << 4) | ((b3 >> 2) & 0xf));
+				return tmp;
+			} else {
+				return null;
+			}
+		} else { // No PAD e.g 3cQl
+			b3 = base64Alphabet[d3];
+			b4 = base64Alphabet[d4];
+			decodedData[encodedIndex++] = (byte) (b1 << 2 | b2 >> 4);
+			decodedData[encodedIndex++] = (byte) (((b2 & 0xf) << 4) | ((b3 >> 2) & 0xf));
+			decodedData[encodedIndex++] = (byte) (b3 << 6 | b4);
+
+		}
+
+		return decodedData;
+	}
+
+	/**
+	 * remove WhiteSpace from MIME containing encoded Base64 data.
+	 * 
+	 * @param data
+	 *            the byte array of base64 data (with WS)
+	 * @return the new length
+	 */
+	private static int removeWhiteSpace(char[] data) {
+		if (data == null) {
+			return 0;
+		}
+
+		// count characters that's not whitespace
+		int newSize = 0;
+		int len = data.length;
+		for (int i = 0; i < len; i++) {
+			if (!isWhiteSpace(data[i])) {
+				data[newSize++] = data[i];
+			}
+		}
+		return newSize;
+	}
+}

CODE/smart-community/community-common/src/main/java/com/community/commom/fushi/FuShiHttpClient.java

@@ -0,0 +1,191 @@
+package com.community.commom.fushi;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.security.KeyFactory;
+import java.security.PrivateKey;
+import java.security.spec.PKCS8EncodedKeySpec;
+
+import java.util.Map;
+import java.util.SortedMap;
+import java.util.TreeMap;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.omg.CORBA.Request;
+
+/**
+ * 富士HTTP请求
+ * @author weiximei
+ */
+@Data
+public class FuShiHttpClient {
+//	private static String url = "http://mops-test.fujica.com.cn:8021/Api/Park/GetParkInfoByCarNo";
+	private String url;
+	private String appid;
+	private String appSecret;
+	private String privateKey;
+//	private String sign = "";
+//	private String time;
+
+    public FuShiHttpClient(String url, String appid, String appSecret, String privateKey) {
+        this.url = url;
+        this.appid = appid;
+        this.appSecret = appSecret;
+        this.privateKey = privateKey;
+    }
+
+    public static void main(String[] args) {
+//		time = getTimestamp();
+//		String jsonString = "{'ParkingCode':'19000100250504','CarNo':'苏A8M6B2'}";
+//
+//		TreeMap<String, String> map = new TreeMap();
+//		map.put("param", jsonString);
+//		map.put("secret", appSecret);
+//		map.put("timestamp", time);
+//		sign = signWithoutMD5(map);
+//		sign = sign(sign, privateKey);
+//
+//		doJsonPost(url, jsonString);
+	}
+
+	/**
+	 * POST 请求
+	 * @param urlPath
+	 * @param Json
+	 * @return
+	 */
+	public String doJsonPost(String urlPath, String Json, String sign, String time) {
+		urlPath = url + urlPath;
+		String result = "";
+		BufferedReader reader = null;
+		try {
+			URL url = new URL(urlPath);
+			HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+			conn.setRequestMethod("POST");
+			conn.setDoOutput(true);
+			conn.setDoInput(true);
+			conn.setUseCaches(false);
+			conn.setRequestProperty("Connection", "Keep-Alive");
+			conn.setRequestProperty("Charset", "UTF-8");
+			conn.setRequestProperty("appid", appid);
+			conn.setRequestProperty("appSecret", appSecret);
+			conn.setRequestProperty("sign", sign);
+			conn.setRequestProperty("timestamp", time);
+			// 设置文件类型:
+			conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
+			// 设置接收类型否则返回415错误
+			conn.setRequestProperty("accept", "*/*");// 此处为暴力方法设置接受所有类型，以此来防范返回415;
+			conn.setRequestProperty("accept", "application/json");
+			// 往服务器里面发送数据
+			if (Json != null && !("").equals(Json)) {
+				byte[] writebytes = Json.getBytes();
+				// 设置文件长度
+				conn.setRequestProperty("Content-Length", String.valueOf(writebytes.length));
+				OutputStream outwritestream = (OutputStream) conn.getOutputStream();
+				outwritestream.write(Json.getBytes());
+				outwritestream.flush();
+				outwritestream.close();
+
+			}
+			if (conn.getResponseCode() == 200) {
+				reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+				result = reader.readLine();
+				// System.out.println(result);
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+		} finally {
+			if (reader != null) {
+				try {
+					reader.close();
+				} catch (IOException e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return result;
+	}
+
+    /**
+     * 时间戳, 取前十位
+     * @return
+     */
+	public String getTimestamp() {
+		String time = "";
+		long timestamp = System.currentTimeMillis();
+		time = String.valueOf(timestamp);
+		time = time.substring(0, 10);
+		return time;
+	}
+
+    /**
+     * MD5
+     * @param params
+     * @return
+     */
+	public String signWithoutMD5(SortedMap<String, String> params) {
+		String restul = "";
+		if (params == null) {
+			return restul;
+		}
+
+		StringBuilder sb = new StringBuilder();
+		for (Map.Entry<String, String> me : params.entrySet()) {
+
+			sb.append(me.getKey());
+			sb.append('=');
+			sb.append(me.getValue());
+			sb.append('&');
+
+		}
+		int lastIndexOf = sb.lastIndexOf("&");
+		if (lastIndexOf != -1) {
+			sb.deleteCharAt(lastIndexOf);
+		}
+		restul = new String(sb);
+
+		return restul;
+	}
+
+	private final String ALGORITHM = "RSA";
+	private final String SIGN_ALGORITHMS = "SHA1WithRSA";
+
+	private final String DEFAULT_CHARSET = "UTF-8";
+
+    /**
+     * 开始签名
+     * @param content
+     * @param privateKey
+     * @return
+     */
+	public String sign(String content, String privateKey) {
+		try {
+			PKCS8EncodedKeySpec priPKCS8 = new PKCS8EncodedKeySpec(Base64.decode(privateKey));
+			KeyFactory keyf = KeyFactory.getInstance(ALGORITHM);
+
+			PrivateKey priKey = keyf.generatePrivate(priPKCS8);
+
+			java.security.Signature signature = java.security.Signature.getInstance(SIGN_ALGORITHMS);
+
+			signature.initSign(priKey);
+			signature.update(content.getBytes(DEFAULT_CHARSET));
+
+			byte[] signed = signature.sign();
+
+			return Base64.encode(signed);
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+		return null;
+	}
+
+
+
+}

CODE/smart-community/community-common/src/main/java/com/community/commom/fushi/FuShiRequestAPI.java

@@ -0,0 +1,128 @@
+package com.community.commom.fushi;
+
+import com.alibaba.fastjson.JSONObject;
+import com.community.commom.fushi.error.FuShiException;
+import com.google.common.collect.Maps;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Map;
+import java.util.TreeMap;
+
+/**
+ * 富士请求 API
+ * @author weiximei
+ */
+@Data
+@Slf4j
+public class FuShiRequestAPI {
+
+    private FuShiHttpClient client;
+
+    public FuShiRequestAPI(FuShiHttpClient client) {
+        this.client = client;
+    }
+
+    public FuShiRequestAPI() {
+    }
+
+    // =======================   请求 API   =====================================
+
+    @Data
+    @AllArgsConstructor
+    public class SignBuild {
+        private String sign;
+        private String timestamp;
+    }
+
+    /**
+     * 请求签名
+     * @param jsonString
+     * @return
+     */
+    private SignBuild requestSign(String jsonString) {
+        String sign = "";
+        String timestamp = client.getTimestamp();
+        TreeMap<String, String> map = new TreeMap();
+		map.put("param", jsonString);
+		map.put("secret", client.getAppSecret());
+		map.put("timestamp", timestamp);
+		sign = client.signWithoutMD5(map);
+		sign = client.sign(sign, client.getPrivateKey());
+
+		return new SignBuild(sign, timestamp);
+    }
+
+    /**
+     * 校验code
+     * @param jsonString
+     */
+    private void showException(String jsonString) {
+        JSONObject jsonObject = JSONObject.parseObject(jsonString);
+        Integer messageCode = jsonObject.getInteger("MessageCode");
+        if (messageCode != 200) {
+            throw new FuShiException("设备还未联网，系统维护中");
+        }
+
+    }
+
+    /**
+     * 获取停车信息（通过车牌号）
+     * @return
+     */
+    public String getParkInfoByCarNo(String parkingCode, String carNo) {
+        Map<String, Object> map = Maps.newHashMap();
+        map.put("ParkingCode", parkingCode);
+        map.put("CarNo", carNo);
+        String json = JSONObject.toJSONString(map);
+        log.info("获取停车信息（通过车牌号）请求参数：{}", json);
+        SignBuild signBuild = requestSign(json);
+        String result = client.doJsonPost(FushiConstant.PARK_GETPARKINFOBYCARNO, json, signBuild.getSign(), signBuild.getTimestamp());
+        showException(result);
+        log.info("获取停车信息（通过车牌号）返回数据：{}", result);
+        return result;
+    }
+
+
+    /**
+     * 第三方月卡上发续费
+     * @param renewDayType 续费日期类型: 3:年; 2:月; 1:日;
+     * @param renewDay 续费日期数目
+     * @param dealNo 交易编码
+     * @param payStyle 交易方式（汉字描述），例如：微信、支付宝、银联
+     * @param carNo 车牌号
+     * @param cardNo 停车卡号
+     * @param parkingCode 停车场编码
+     * @param rechargeAmt 充值续费金额
+     * @param thirdTransactionDate 第三方交易日期
+     * @return
+     */
+    public String apiThirdPartyMonthCardPay(String renewDayType, String renewDay, String dealNo, String payStyle, String carNo, String parkingCode, String cardNo, String rechargeAmt, String thirdTransactionDate) {
+        Map<String, Object> map = Maps.newHashMap();
+        map.put("RenewDayType", parkingCode);
+        map.put("RenewDay", renewDay);
+        map.put("DealNo", dealNo);
+        map.put("PayStyle", payStyle);
+        map.put("CarNo", carNo);
+        map.put("ParkingCode", parkingCode);
+        map.put("CardNo", cardNo);
+        map.put("RechargeAmt", rechargeAmt);
+        map.put("ThirdTransactionDate", thirdTransactionDate);
+
+        String json = JSONObject.toJSONString(map);
+        log.info("第三方月卡上发续费请求参数：{}", json);
+        SignBuild signBuild = requestSign(json);
+        String result = client.doJsonPost(FushiConstant.CALCULATIONCOST_APITHIRDPARTYMONTHCARDPAY, json, signBuild.getSign(), signBuild.getTimestamp());
+        showException(result);
+        log.info("第三方月卡上发续费返回数据：{}", result);
+        return result;
+    }
+
+
+
+
+
+
+
+}

CODE/smart-community/community-common/src/main/java/com/community/commom/fushi/FushiConstant.java

@@ -0,0 +1,19 @@
+package com.community.commom.fushi;
+
+/**
+ * 富士 API 链接定义
+ * @author weiximei
+ */
+public class FushiConstant {
+
+    /**
+     * 获取停车信息（通过车牌号）
+     */
+    public static final String PARK_GETPARKINFOBYCARNO = "/Park/GetParkInfoByCarNo";
+
+    /**
+     * 第三方月卡上发续费
+     */
+    public static final String CALCULATIONCOST_APITHIRDPARTYMONTHCARDPAY = "/CalculationCost/ApiThirdPartyMonthCardPay";
+
+}

CODE/smart-community/community-common/src/main/java/com/community/commom/fushi/error/FuShiException.java

@@ -0,0 +1,20 @@
+package com.community.commom.fushi.error;
+
+/**
+ * 富士 业务专用异常
+ * @author weiximei
+ */
+public class FuShiException extends RuntimeException {
+
+    public FuShiException(String msg, Throwable t) {
+        super(msg, t);
+    }
+
+    public FuShiException(String msg) {
+        super(msg);
+    }
+
+    public FuShiException(String msg, Object ...args) {
+        this(String.format(msg, args));
+    }
+}

CODE/smart-community/property-api/src/main/java/com/community/huiju/common/perproties/FuShiProperties.java

@@ -0,0 +1,44 @@
+package com.community.huiju.common.perproties;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * 富士配置类
+ * @author weiximei
+ */
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@Component
+@ConfigurationProperties(prefix = "fu-shi")
+public class FuShiProperties {
+
+    /**
+     * 富士云 请求地址
+     */
+    private String url;
+
+    /**
+     * 富士云 appid
+     */
+    private String appid;
+
+    /**
+     * 富士云 appSecret
+     */
+    private String appSecret;
+
+    /**
+     * 富士云 私钥 privateKey
+     */
+    private String privateKey;
+
+    /**
+     * 停车场编码
+     */
+    private String parkingCode;
+}

CODE/smart-community/property-api/src/main/java/com/community/huiju/config/FuShiConfig.java

@@ -0,0 +1,40 @@
+package com.community.huiju.config;
+
+import com.community.commom.fushi.FuShiHttpClient;
+import com.community.commom.fushi.FuShiRequestAPI;
+import com.community.huiju.common.perproties.FuShiProperties;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 富士配置类
+ * @author weiximei
+ */
+@Configuration
+public class FuShiConfig {
+
+    @Autowired
+    private FuShiProperties fuShiProperties;
+
+
+    /**
+     * 初始化富士HTTP客户端
+     * @return FuShiHttpClient
+     */
+    @Bean
+    public FuShiHttpClient fuShiHttpClient() {
+        return new FuShiHttpClient(fuShiProperties.getUrl(), fuShiProperties.getAppid(), fuShiProperties.getAppSecret(), fuShiProperties.getPrivateKey());
+    }
+
+    /**
+     * 初始化富士请求 API
+     * @param fuShiHttpClient
+     * @return
+     */
+    @Bean
+    public FuShiRequestAPI fuShiRequestAPI(FuShiHttpClient fuShiHttpClient) {
+        return new FuShiRequestAPI(fuShiHttpClient);
+    }
+
+}

CODE/smart-community/property-api/src/main/java/com/community/huiju/controller/FSController.java

@@ -0,0 +1,38 @@
+package com.community.huiju.controller;
+
+import com.community.commom.mode.ResponseBean;
+import com.community.huiju.common.base.BaseController;
+import com.community.huiju.service.IFuShiService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RefreshScope
+@RequestMapping("/")
+@Api(value = "车辆操作API", description = "车辆操作API")
+public class FSController extends BaseController {
+
+    @Autowired
+    private IFuShiService iFuShiService;
+
+    @RequestMapping(value = "/car/getParkInfoByCarNo/{carNo}", method = RequestMethod.GET)
+    @ApiOperation(value = "获取停车信息（通过车牌号）", notes = "获取停车信息（通过车牌号）")
+    @ApiImplicitParams({
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "path", name = "carNo", value = "车牌号")
+    })
+    public ResponseBean getParkInfoByCarNo(@PathVariable("carNo") String carNo) {
+        ResponseBean responseBean = new ResponseBean();
+        responseBean = iFuShiService.getParkInfoByCarNo(carNo);
+        return responseBean;
+    }
+
+
+}

CODE/smart-community/property-api/src/main/java/com/community/huiju/exception/ExceptionHandleAdice.java

@@ -1,6 +1,7 @@
 package com.community.huiju.exception;
 
 import com.community.commom.constant.Constant;
+import com.community.commom.fushi.error.FuShiException;
 import com.community.commom.mode.ResponseBean;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.validation.ObjectError;
@@ -25,7 +26,7 @@ public class ExceptionHandleAdice {
     public ResponseBean handleException(Exception e){
         log.error(e.getMessage(),e);
         ResponseBean response = new ResponseBean();
-        response.addError(Constant.REQUEST_ERROR,"系统异常,请稍后重试!");
+        response.addError(Constant.REQUEST_ERROR,"设备还未联网，系统维护中");
         return response;
     }
 
@@ -54,5 +55,12 @@ public class ExceptionHandleAdice {
         return response;
     }
 
+    @ExceptionHandler(FuShiException.class)
+    public ResponseBean handleException(FuShiException e) {
+        log.error(e.getMessage(),e);
+        ResponseBean response = new ResponseBean();
+        response.addError(e.getMessage());
+        return response;
+    }
 
 }

CODE/smart-community/property-api/src/main/java/com/community/huiju/service/IFuShiService.java

@@ -0,0 +1,30 @@
+package com.community.huiju.service;
+
+import com.community.commom.mode.ResponseBean;
+
+/**
+ * 富士 业务接口
+ */
+public interface IFuShiService {
+
+    /**
+     * 获取停车信息（通过车牌号）
+     *
+     * @param carNo
+     * @return
+     */
+    ResponseBean getParkInfoByCarNo(String carNo);
+
+    /**
+     * 第三方月卡上发续费
+     * @param renewDayType 续费日期类型: 3:年; 2:月; 1:日;
+     * @param renewDay 续费日期数目
+     * @param payStyle 交易方式，例如：1 微信、 2 支付宝、 3 银联
+     * @param carNo 车牌号
+     * @param cardNo 停车卡号
+     * @param rechargeAmt 充值续费金额
+     * @return
+     */
+    ResponseBean apiThirdPartyMonthCardPay(String renewDayType, String renewDay, String payStyle, String carNo, String cardNo,String rechargeAmt);
+
+}

CODE/smart-community/property-api/src/main/java/com/community/huiju/service/impl/FuShiServiceImpl.java

@@ -0,0 +1,73 @@
+package com.community.huiju.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.community.commom.fushi.FuShiRequestAPI;
+import com.community.commom.mode.ResponseBean;
+import com.community.commom.uuid.IdGen;
+import com.community.huiju.common.perproties.FuShiProperties;
+import com.community.huiju.service.IFuShiService;
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Map;
+
+/**
+ * 富士业务实现
+ * @author weiximei
+ */
+@Slf4j
+@Service
+public class FuShiServiceImpl implements IFuShiService {
+
+    @Autowired
+    private FuShiRequestAPI fuShiRequestAPI;
+
+    @Autowired
+    private FuShiProperties fuShiProperties;
+
+    private IdGen idGen = IdGen.get();
+
+    /**
+     * 获取 富士 json 值
+     * @param jsonString
+     * @return
+     */
+    private Map<String,Object> getFuShiInfo(String jsonString) {
+        JSONObject jsonObject = JSONObject.parseObject(jsonString);
+        Map<String, Object> map = Maps.newHashMap();
+        map.put("JsonParam", jsonObject.getJSONObject("JsonParam").getInnerMap());
+        map.put("Redirect", jsonObject.getString("Redirect"));
+        map.put("DataType", jsonObject.getInteger("DataType"));
+        return map;
+    }
+
+    @Override
+    public ResponseBean getParkInfoByCarNo(String carNo) {
+        ResponseBean responseBean = new ResponseBean();
+        String parkInfo = fuShiRequestAPI.getParkInfoByCarNo(fuShiProperties.getParkingCode(), carNo);
+        Map<String, Object> fuShiInfo = getFuShiInfo(parkInfo);
+        responseBean.addSuccess(fuShiInfo);
+        return responseBean;
+    }
+
+    @Override
+    public ResponseBean apiThirdPartyMonthCardPay(String renewDayType, String renewDay, String payStyle, String carNo, String cardNo,String rechargeAmt) {
+        ResponseBean responseBean = new ResponseBean();
+        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd hh:mm:ss");
+        // 交易编码
+        String dealNo = idGen.nextId() + "";
+        // 第三方交易日期
+        String dateTime = dateTimeFormatter.format(LocalDateTime.now());
+        // 富士云请求
+        String partyMonthCardPay = fuShiRequestAPI.apiThirdPartyMonthCardPay(renewDayType, renewDay, dealNo, payStyle, carNo, fuShiProperties.getParkingCode(), cardNo, rechargeAmt, dateTime);
+        String tradeNo = JSONObject.parseObject(partyMonthCardPay).getString("TradeNo");
+        Map<String, Object> map = Maps.newHashMap();
+        map.put("TradeNo", tradeNo);
+        responseBean.addSuccess(map);
+        return responseBean;
+    }
+}

CODE/smart-community/property-api/src/main/resources/application.yml

@@ -14,4 +14,28 @@ mybatis-plus:
 
 # 二维码生成地址
 qr-code:
-  url: http://106.14.20.193:8011/#/forum/sign?id=
+  url: http://106.14.20.193:8011/#/forum/sign?id=
+
+# 富士E7+云平台
+fu-shi:
+  url: http://api.mops.fujica.com.cn/v2/Api
+  appid: fujica_a354fedcb214c86b
+  app-secret: 0a0897e0bf154169833f709d6693fe84
+  private-key: MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBAL8wJdXId6Pa6l/O
+    d6a+vE0z0RgujUTR2KxRZiRhEWpc4JSi1uyQPS2RS+CleByllAXkgPYCxhxelt6Y
+    wtFb3nuUVrQboesUrxv7DuGoRnbOeakMC2Cb83AanQlEC/erXspsTx9x9lecygAt
+    yOsEPv6nb8VHu8tTEEhFJIyWSTQBAgMBAAECgYA07AH9HGGptKZd4MwUFwYOpMJD
+    XFd0blX41QteFJR6ib0Mx8qQbxjQLUEArS0DWP4RZ4AfGQN3xOMkOMrsou6BcVjR
+    oVXvlKate4tIRQy3ay77dabM8LQFNg8uuigD7EWeGh9s4V1E5Jfuw8Y8zfmBKBbz
+    Id/Mm7bafgbfd4jCtQJBAPn0ik8Iv3pkJ90V60eQG4l6sVGAaskM0GWzyENpecLP
+    6UA7oYmAaqIx9vsY0UyiF4XctgxpMvqG6pM/U0y8LacCQQDDz8h7nhUWF0ZUH1IS
+    H+Qj3sUWR3hHel/WCjGPPKWO5iQUTfwVY9+L54IDIanAjisc40ueO3zK573zzlBE
+    /VYXAkEA61Qmm356+DovpeErILc2ldsj8r3ay+r6kaYQGBfIAXhJ/KWn0pNK0eYE
+    yCd3dpTtXKSN6WVqD6DSXUuzm31X5QJAEDMqlP+ZIwC98su8kH9O8qDFkXhMPS2k
+    rCKfwwfzcoUbywpApsxifEKlAPlR//pDGtq7MNYfFvJhRsB056BF9QJBAKHlCCnt
+    gtzRlhQxwYRg0th4uoJ99BT03+WM94Kepu6zfh3OmKLvPk2gW30TKSeYC5xmursq
+    xGP2TC4KxH2tAn0=
+  parking-code: 19000100250504 # 停车场编码
+
+
+