hurui
/
hai-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提交代码

Browse Source
dev-discount
胡锐 2 years ago
parent 737581c74b
commit af13557b67
6 changed files with 130 additions and 221 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 2
      hai-cweb/src/main/java/com/cweb/controller/HighTestController.java
  2. 38
      hai-service/src/main/java/com/hai/config/CommonSysConfig.java
  3. 219
      hai-service/src/main/java/com/hai/config/PrintDemo.java
  4. 78
      hai-service/src/main/java/com/hai/config/ShellGroupService.java
  5. 6
      hai-service/src/main/java/com/hai/config/ZkcPrinterTemplate.java
  6. 8
      hai-service/src/main/resources/dev/commonConfig.properties

2
hai-cweb/src/main/java/com/cweb/controller/HighTestController.java
View File

File diff suppressed because one or more lines are too long

38
hai-service/src/main/java/com/hai/config/CommonSysConfig.java
Unescape View File

@ -18,6 +18,12 @@ public class CommonSysConfig {
private String tuanYouDieselAccount; // 柴油账号
private String tuanYouGasolineAccount; // 汽油账号
// 壳牌公共参数
private String shellGroupUrl;
private String shellGroupPartnerId;
private String shellPlatMerchantId;
private String shellPlatMerchantKey;
private String qinzhuUrl;
private String qinzhuHtmlUrl;
private String qinzhuMobileUrl; // 话费充值地址
@ -74,6 +80,38 @@ public class CommonSysConfig {
private String unionSecret;
private String unionRsaKey;
public String getShellGroupPartnerId() {
return shellGroupPartnerId;
}
public void setShellGroupPartnerId(String shellGroupPartnerId) {
this.shellGroupPartnerId = shellGroupPartnerId;
}
public String getShellGroupUrl() {
return shellGroupUrl;
}
public void setShellGroupUrl(String shellGroupUrl) {
this.shellGroupUrl = shellGroupUrl;
}
public String getShellPlatMerchantId() {
return shellPlatMerchantId;
}
public void setShellPlatMerchantId(String shellPlatMerchantId) {
this.shellPlatMerchantId = shellPlatMerchantId;
}
public String getShellPlatMerchantKey() {
return shellPlatMerchantKey;
}
public void setShellPlatMerchantKey(String shellPlatMerchantKey) {
this.shellPlatMerchantKey = shellPlatMerchantKey;
}
public String getUnionAppId() {
return unionAppId;
}

219
hai-service/src/main/java/com/hai/config/PrintDemo.java
Unescape View File

@ -1,219 +0,0 @@
package com.hai.config;
import org.junit.Test;
import java.io.UnsupportedEncodingException;
public class PrintDemo {
private String accessKeyId = "LTAI5tHHL3z6gpJbMmCg3zt2";
private String accessKeySecret = "CC9kAuqgdjKiE6jxSQHddFxGDCTpBQ";
private String instanceId = "post-cn-i7m2558ze01";
private String topic = "Box";
private String groupId= "GID_BOX";
private String endpoint= "onsmqtt.mq-internet-access.aliyuncs.com";
public static final int PAYTYPE_VOICE_NULL=2000;
public static final int PAYTYPE_VOICE_ALI=2001;
public static final int PAYTYPE_VOICE_QQ=2002;
public static final int PAYTYPE_VOICE_WECHAT=2003;
public static final int PAYTYPE_VOICE_JD=2004;
public static final int PAYTYPE_VOICE_UNION=2005;
public static final int PAYTYPE_VOICE_DIY7570=7570;
public static final int PAYTYPE_VOICE_DIY7571=7571;
public static final int PAYTYPE_VOICE_DIY7572=7572;
public static final int PAYTYPE_VOICE_DIY7573=7573;
public static final int PAYTYPE_VOICE_DIY7574=7574;
public static final int PAYTYPE_VOICE_DIY7575=7575;
public static final int PAYTYPE_VOICE_DIY7576=7576;
public static final int PAYTYPE_VOICE_DIY7577=7577;
public static final int PAYTYPE_VOICE_DIY7578=7578;
public static final int PAYTYPE_VOICE_DIY7579=7579;
@Test
public void Test(){
String imeiStr="352736082440754";//设备IMEI
String printText="1234\r\n";//打印文本
String voiceMsgId="2019022611153312312345";//消息ID
String voiceMsgMoney="1234";//播报金额
//获取打印内容
byte[] printData = getPrinterBytes(printText, 1, "");
System.out.println(bytes2Hex(printData));
//获取播报字符串
System.out.println(getStaticVoiceStr(imeiStr,voiceMsgId,voiceMsgMoney,PAYTYPE_VOICE_ALI));
//获取播报打印机指令
printData=getPrinterVoiceBytes(printText,1,"",imeiStr,voiceMsgId,voiceMsgMoney,PAYTYPE_VOICE_ALI);
System.out.println(bytes2Hex(printData));
/*
try {
com.aliyun.onsmqtt20200420.Client client = createClient(accessKeyId, accessKeySecret);
SendMessageRequest sendMessageRequest = new SendMessageRequest()
.setInstanceId("post-cn-i7m2558ze01")
.setMqttTopic("Box/p2p/GID_BOX@@@359ac67b25c11b8")
.setPayload(bytes2Hex(printData));
SendMessageResponse sendMessageResponse = client.sendMessage(sendMessageRequest);
System.out.println(sendMessageResponse.getBody().msgId);
} catch (Exception e) {
e.printStackTrace();
}*/
}
/**
* 使用AK&SK初始化账号Client
* @param accessKeyId
* @param accessKeySecret
* @return Client
* @throws Exception
*/
/* public com.aliyun.onsmqtt20200420.Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
Config config = new Config()
// 您的AccessKey ID
.setAccessKeyId(accessKeyId)
// 您的AccessKey Secret
.setAccessKeySecret(accessKeySecret);
// 访问的域名
config.endpoint = endpoint;
return new com.aliyun.onsmqtt20200420.Client(config);
}*/
/**
* 支付播报固定语音字节数组
* @param imeiStr IMEI设备唯一标识
* @param msgId 交易序列号，不大于32字节，保证唯一
* @param moneyStr 播报金额，最多两位小数
* @param payType 支付类型
* @return
*/
public static byte[] getStaticVoiceBytes(String imeiStr,String msgId,String moneyStr,int payType){
return getStaticVoiceStr(imeiStr,msgId,moneyStr,payType).getBytes();
}
/**
* 支付播报固定语音字符串
* @param imeiStr IMEI设备唯一标识
* @param msgId 交易序列号，不大于32字节，保证唯一
* @param moneyStr 播报金额，最多两位小数
* @param payType 支付类型
* @return
*/
public static String getStaticVoiceStr(String imeiStr,String msgId,String moneyStr,int payType){
String str=imeiStr+"|1007|"+msgId+"|"+moneyStr+"|"+payType;
return str;
}
/**
* 获取打印内容，适用于云打印机
* @param printText 打印文本
* @param pageCount 打印联数
* @param encodingStr 编码方式，默认UTF-8
* @return
*/
public static byte[] getPrinterBytes(final String printText,
final int pageCount, String encodingStr) {
try {
if(encodingStr.equals("")){
encodingStr="UTF-8";
}
byte[] msgByte = printText.getBytes(encodingStr);
// 消息数组
final byte[] dataByte = new byte[msgByte.length + 9];
dataByte[0] = 0x1E;
dataByte[1] = 0x10;
dataByte[2] = (byte) pageCount;// 打印多联
// 有效数据长度
final int len = dataByte.length - 5;
dataByte[3] = (byte) (len >> 8);
dataByte[4] = (byte) (len & 0xff);
// 数据内容
System.arraycopy(msgByte, 0, dataByte, 5, msgByte.length);
// 标识字节
dataByte[dataByte.length - 4] = 0x1b;
dataByte[dataByte.length - 3] = 0x63;
// 打印内容CRC校验
final byte[] dtCRC = getCRC(msgByte);
dataByte[dataByte.length - 2] = (byte) (dtCRC[0]);
dataByte[dataByte.length - 1] = (byte) (dtCRC[1]);
msgByte = dataByte;
return msgByte;
} catch (Exception ex) {
System.out.println(ex.getStackTrace());
}
return null;
}
public static byte[] getPrinterVoiceBytes(String printTxt,int pageCount,String encodingStr,String imeiStr,String msgId,String moneyStr,int payType){
byte[] voiceArray=getStaticVoiceBytes(imeiStr, msgId, moneyStr, payType);
byte[] printerArray=getPrinterBytes(printTxt,pageCount,encodingStr);
byte[] data=new byte[voiceArray.length+printerArray.length];
System.arraycopy(printerArray, 0, data, 0, printerArray.length);
System.arraycopy(voiceArray, 0, data, printerArray.length, voiceArray.length);
return data;
}
private static int[] CRC16Table = { 0x0000, 0x1189, 0x2312, 0x329b, 0x4624,
0x57ad, 0x6536, 0x74bf, 0x8c48, 0x9dc1, 0xaf5a, 0xbed3, 0xca6c,
0xdbe5, 0xe97e, 0xf8f7, 0x1081, 0x0108, 0x3393, 0x221a, 0x56a5,
0x472c, 0x75b7, 0x643e, 0x9cc9, 0x8d40, 0xbfdb, 0xae52, 0xdaed,
0xcb64, 0xf9ff, 0xe876, 0x2102, 0x308b, 0x0210, 0x1399, 0x6726,
0x76af, 0x4434, 0x55bd, 0xad4a, 0xbcc3, 0x8e58, 0x9fd1, 0xeb6e,
0xfae7, 0xc87c, 0xd9f5, 0x3183, 0x200a, 0x1291, 0x0318, 0x77a7,
0x662e, 0x54b5, 0x453c, 0xbdcb, 0xac42, 0x9ed9, 0x8f50, 0xfbef,
0xea66, 0xd8fd, 0xc974, 0x4204, 0x538d, 0x6116, 0x709f, 0x0420,
0x15a9, 0x2732, 0x36bb, 0xce4c, 0xdfc5, 0xed5e, 0xfcd7, 0x8868,
0x99e1, 0xab7a, 0xbaf3, 0x5285, 0x430c, 0x7197, 0x601e, 0x14a1,
0x0528, 0x37b3, 0x263a, 0xdecd, 0xcf44, 0xfddf, 0xec56, 0x98e9,
0x8960, 0xbbfb, 0xaa72, 0x6306, 0x728f, 0x4014, 0x519d, 0x2522,
0x34ab, 0x0630, 0x17b9, 0xef4e, 0xfec7, 0xcc5c, 0xddd5, 0xa96a,
0xb8e3, 0x8a78, 0x9bf1, 0x7387, 0x620e, 0x5095, 0x411c, 0x35a3,
0x242a, 0x16b1, 0x0738, 0xffcf, 0xee46, 0xdcdd, 0xcd54, 0xb9eb,
0xa862, 0x9af9, 0x8b70, 0x8408, 0x9581, 0xa71a, 0xb693, 0xc22c,
0xd3a5, 0xe13e, 0xf0b7, 0x0840, 0x19c9, 0x2b52, 0x3adb, 0x4e64,
0x5fed, 0x6d76, 0x7cff, 0x9489, 0x8500, 0xb79b, 0xa612, 0xd2ad,
0xc324, 0xf1bf, 0xe036, 0x18c1, 0x0948, 0x3bd3, 0x2a5a, 0x5ee5,
0x4f6c, 0x7df7, 0x6c7e, 0xa50a, 0xb483, 0x8618, 0x9791, 0xe32e,
0xf2a7, 0xc03c, 0xd1b5, 0x2942, 0x38cb, 0x0a50, 0x1bd9, 0x6f66,
0x7eef, 0x4c74, 0x5dfd, 0xb58b, 0xa402, 0x9699, 0x8710, 0xf3af,
0xe226, 0xd0bd, 0xc134, 0x39c3, 0x284a, 0x1ad1, 0x0b58, 0x7fe7,
0x6e6e, 0x5cf5, 0x4d7c, 0xc60c, 0xd785, 0xe51e, 0xf497, 0x8028,
0x91a1, 0xa33a, 0xb2b3, 0x4a44, 0x5bcd, 0x6956, 0x78df, 0x0c60,
0x1de9, 0x2f72, 0x3efb, 0xd68d, 0xc704, 0xf59f, 0xe416, 0x90a9,
0x8120, 0xb3bb, 0xa232, 0x5ac5, 0x4b4c, 0x79d7, 0x685e, 0x1ce1,
0x0d68, 0x3ff3, 0x2e7a, 0xe70e, 0xf687, 0xc41c, 0xd595, 0xa12a,
0xb0a3, 0x8238, 0x93b1, 0x6b46, 0x7acf, 0x4854, 0x59dd, 0x2d62,
0x3ceb, 0x0e70, 0x1ff9, 0xf78f, 0xe606, 0xd49d, 0xc514, 0xb1ab,
0xa022, 0x92b9, 0x8330, 0x7bc7, 0x6a4e, 0x58d5, 0x495c, 0x3de3,
0x2c6a, 0x1ef1, 0x0f78 };
private static byte[] getCRC(byte[] bytes) {
int crc = 0xFFFF; // 初始值
for (byte b : bytes) {
crc = (crc >> 8) ^ CRC16Table[(crc ^ b) & 0xff];
}
byte[] b = new byte[2];
b[0] = (byte) ((crc >> 8)^0xff);
b[1] = (byte) ((crc & 0xff)^0xff);
return b;
}
private static final char[] HEXES = { '0', '1', '2', '3', '4', '5', '6',
'7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
/**
* byte数组 转换成 16进制小写字符串
*/
private static String bytes2Hex(byte[] bytes) {
if (bytes == null || bytes.length == 0) {
return null;
}
StringBuilder hex = new StringBuilder();
for (byte b : bytes) {
hex.append(HEXES[(b >> 4) & 0x0F]);
hex.append(HEXES[b & 0x0F]);
}
return hex.toString();
}
}

78
hai-service/src/main/java/com/hai/config/ShellGroupService.java
Unescape View File

@ -0,0 +1,78 @@
package com.hai.config;
import com.alibaba.fastjson.JSONObject;
import com.hai.common.exception.ErrorCode;
import com.hai.common.exception.ErrorHelp;
import com.hai.common.exception.SysCode;
import com.hai.common.pay.util.sdk.WXPayConstants;
import com.hai.common.utils.HttpsUtils;
import com.hai.common.utils.MD5Util;
import org.apache.commons.lang3.StringUtils;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
/**
* 壳牌接口服务
*/
public class ShellGroupService {
/**
* 查询全量加油站
* @param pageNum 当前页码
* @param pageSize 每页数据量。最大值50
* @return
*/
public static JSONObject gasPageQueryAllStation(Integer pageNum,Integer pageSize) {
try {
Map<String, Object> param = new HashMap<>();
param.put("merchantOrderNo", System.currentTimeMillis());
param.put("partnerId", CommonSysConst.getSysConfig().getShellGroupPartnerId());
param.put("service", "gasPageQueryAllStation");
param.put("version", "1.0.0");
param.put("signType", "MD5");
param.put("platMerchantId", CommonSysConst.getSysConfig().getShellPlatMerchantId());
param.put("pageNo", pageNum);
param.put("pageSize", pageSize);
param.put("sign", MD5Util.encode(generateSignature(param, CommonSysConst.getSysConfig().getShellPlatMerchantKey()).getBytes()));
// 请求接口
JSONObject object = HttpsUtils.doPost(CommonSysConst.getSysConfig().getShellGroupUrl(), param);
if (object == null || !object.getString("status").equals("SUCCESS")) {
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, object == null?"请求失败":object.getString("message"));
}
return object;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 生成签名
* @param data 数据
* @param key 秘钥app_secret
* @return 加密结果
*/
public static String generateSignature(final Map<String, Object> data, String key){
Set<String> keySet = data.keySet();
String[] keyArray = keySet.toArray(new String[keySet.size()]);
Arrays.sort(keyArray);
StringBuilder sb = new StringBuilder();
sb.append(key);
for (String k : keyArray) {
if (k.equals(WXPayConstants.FIELD_SIGN)) {
continue;
}
if (data.get(k) != null) // 参数值为空，则不参与签名
sb.append(k).append(data.get(k));
}
sb.append(key);
return sb.toString();
}
}

6
hai-service/src/main/java/com/hai/config/ZkcPrinterTemplate.java
Unescape View File

@ -75,6 +75,9 @@ public class ZkcPrinterTemplate {
stream.write("实际加油升数以加油机为准！".getBytes("UTF-8"));
stream.write(0x0A);
stream.write("--------------------------------".getBytes("UTF-8"));
stream.write(0x0A);
stream.write(0x1B);
stream.write(0x0E);
@ -166,6 +169,9 @@ public class ZkcPrinterTemplate {
stream.write("实际加油升数以加油机为准！".getBytes("UTF-8"));
stream.write(0x0A);
stream.write("--------------------------------".getBytes("UTF-8"));
stream.write(0x0A);
stream.write(0x1B);
stream.write(0x0E);

8
hai-service/src/main/resources/dev/commonConfig.properties
Unescape View File

@ -1,11 +1,17 @@
hsgDomainName=https://hsgcs.dctpay.com
# ????
# TuanYou configuration parameters
tuanYouUrl=https://test05-motorcade-hcs.czb365.com
tuanYouAppKey=231599775566496
tuanYouAppSecret=cbfab3c550d6142a779c5196c9416342
tuanYouDieselAccount=c009bidg4400
tuanYouGasolineAccount=c009bic04400
#
shellGroupUrl=http://openapi.ngrok.xinyebang.cn/gateway.html
shellGroupPartnerId=123
shellPlatMerchantId=123
shellPlatMerchantKey=123
# ????
qinzhuUrl=https://live-test.qianzhu8.com
qinzhuHtmlUrl=https://m-test.qianzhu8.com

Write Preview
Loading…
Cancel
Save