Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e84ca8dab9 | ||
|
|
eccbf08809 | ||
|
|
b2179faf3e | ||
|
|
0cd6033205 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -19,4 +19,3 @@ target
|
|||||||
sw-pom.xml
|
sw-pom.xml
|
||||||
*.iml
|
*.iml
|
||||||
test-config.xml
|
test-config.xml
|
||||||
.idea
|
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ weixin-java-tools
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>me.chanjar</groupId>
|
<groupId>me.chanjar</groupId>
|
||||||
<artifactId>weixin-java-mp</artifactId>
|
<artifactId>weixin-java-mp</artifactId>
|
||||||
<version>1.1.5</version>
|
<version>1.1.3</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -27,7 +27,7 @@ weixin-java-tools
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>me.chanjar</groupId>
|
<groupId>me.chanjar</groupId>
|
||||||
<artifactId>weixin-java-cp</artifactId>
|
<artifactId>weixin-java-cp</artifactId>
|
||||||
<version>1.1.5</version>
|
<version>1.1.3</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|||||||
2
pom.xml
2
pom.xml
@@ -5,7 +5,7 @@
|
|||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
<groupId>me.chanjar</groupId>
|
<groupId>me.chanjar</groupId>
|
||||||
<artifactId>weixin-java-parent</artifactId>
|
<artifactId>weixin-java-parent</artifactId>
|
||||||
<version>1.1.5</version>
|
<version>1.1.3</version>
|
||||||
<packaging>pom</packaging>
|
<packaging>pom</packaging>
|
||||||
<name>WeiXin Java Tools - Parent</name>
|
<name>WeiXin Java Tools - Parent</name>
|
||||||
<description>微信公众号、企业号上级POM</description>
|
<description>微信公众号、企业号上级POM</description>
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>me.chanjar</groupId>
|
<groupId>me.chanjar</groupId>
|
||||||
<artifactId>weixin-java-parent</artifactId>
|
<artifactId>weixin-java-parent</artifactId>
|
||||||
<version>1.1.5</version>
|
<version>1.1.3</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<artifactId>weixin-java-common</artifactId>
|
<artifactId>weixin-java-common</artifactId>
|
||||||
|
|||||||
@@ -105,7 +105,7 @@ public class WxConsts {
|
|||||||
///////////////////////
|
///////////////////////
|
||||||
public static final String FILE_JPG = "jpeg";
|
public static final String FILE_JPG = "jpeg";
|
||||||
public static final String FILE_MP3 = "mp3";
|
public static final String FILE_MP3 = "mp3";
|
||||||
public static final String FILE_AMR = "amr";
|
public static final String FILE_ARM = "arm";
|
||||||
public static final String FILE_MP4 = "mp4";
|
public static final String FILE_MP4 = "mp4";
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,5 @@
|
|||||||
package me.chanjar.weixin.common.util.crypto;
|
package me.chanjar.weixin.common.util.crypto;
|
||||||
|
|
||||||
import org.apache.commons.codec.digest.DigestUtils;
|
|
||||||
|
|
||||||
import java.security.MessageDigest;
|
import java.security.MessageDigest;
|
||||||
import java.security.NoSuchAlgorithmException;
|
import java.security.NoSuchAlgorithmException;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
@@ -23,7 +21,7 @@ public class SHA1 {
|
|||||||
for (String a : arr) {
|
for (String a : arr) {
|
||||||
sb.append(a);
|
sb.append(a);
|
||||||
}
|
}
|
||||||
return DigestUtils.sha1Hex(sb.toString());
|
return genStr(sb.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -42,6 +40,25 @@ public class SHA1 {
|
|||||||
sb.append('&');
|
sb.append('&');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return DigestUtils.sha1Hex(sb.toString());
|
return genStr(sb.toString());
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
public static String genStr(String str) throws NoSuchAlgorithmException {
|
||||||
|
MessageDigest sha1 = MessageDigest.getInstance("SHA1");
|
||||||
|
sha1.update(str.getBytes());
|
||||||
|
byte[] output = sha1.digest();
|
||||||
|
return bytesToHex(output);
|
||||||
|
}
|
||||||
|
|
||||||
|
protected static String bytesToHex(byte[] b) {
|
||||||
|
char hexDigit[] = { '0', '1', '2', '3', '4', '5', '6', '7',
|
||||||
|
'8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
|
||||||
|
StringBuffer buf = new StringBuffer();
|
||||||
|
for (int j = 0; j < b.length; j++) {
|
||||||
|
buf.append(hexDigit[(b[j] >> 4) & 0x0f]);
|
||||||
|
buf.append(hexDigit[b[j] & 0x0f]);
|
||||||
|
}
|
||||||
|
return buf.toString();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|||||||
@@ -14,7 +14,6 @@
|
|||||||
package me.chanjar.weixin.common.util.crypto;
|
package me.chanjar.weixin.common.util.crypto;
|
||||||
|
|
||||||
import org.apache.commons.codec.binary.Base64;
|
import org.apache.commons.codec.binary.Base64;
|
||||||
import org.apache.commons.codec.digest.DigestUtils;
|
|
||||||
import org.w3c.dom.Document;
|
import org.w3c.dom.Document;
|
||||||
import org.w3c.dom.Element;
|
import org.w3c.dom.Element;
|
||||||
import org.xml.sax.InputSource;
|
import org.xml.sax.InputSource;
|
||||||
@@ -28,7 +27,8 @@ import javax.xml.parsers.ParserConfigurationException;
|
|||||||
import java.io.StringReader;
|
import java.io.StringReader;
|
||||||
import java.nio.charset.Charset;
|
import java.nio.charset.Charset;
|
||||||
import java.security.NoSuchAlgorithmException;
|
import java.security.NoSuchAlgorithmException;
|
||||||
import java.util.*;
|
import java.util.Arrays;
|
||||||
|
import java.util.Random;
|
||||||
|
|
||||||
public class WxCryptUtil {
|
public class WxCryptUtil {
|
||||||
|
|
||||||
@@ -224,36 +224,6 @@ public class WxCryptUtil {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 微信公众号支付签名算法(详见:http://pay.weixin.qq.com/wiki/doc/api/index.php?chapter=4_3)
|
|
||||||
* @param packageParams 原始参数
|
|
||||||
* @param signKey 加密Key(即 商户Key)
|
|
||||||
* @param charset 编码
|
|
||||||
* @return 签名字符串
|
|
||||||
*/
|
|
||||||
public static String createSign(Map<String, String> packageParams, String signKey) {
|
|
||||||
SortedMap<String, String> sortedMap = new TreeMap<String, String>();
|
|
||||||
sortedMap.putAll(packageParams);
|
|
||||||
|
|
||||||
List<String> keys = new ArrayList<String>(packageParams.keySet());
|
|
||||||
Collections.sort(keys);
|
|
||||||
|
|
||||||
|
|
||||||
StringBuffer toSign = new StringBuffer();
|
|
||||||
for (String key : keys) {
|
|
||||||
String value = packageParams.get(key);
|
|
||||||
if (null != value && !"".equals(value) && !"sign".equals(key)
|
|
||||||
&& !"key".equals(key)) {
|
|
||||||
toSign.append(key + "=" + value + "&");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
toSign.append("key=" + signKey);
|
|
||||||
System.out.println(toSign.toString());
|
|
||||||
String sign = DigestUtils.md5Hex(toSign.toString())
|
|
||||||
.toUpperCase();
|
|
||||||
return sign;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 将一个数字转换成生成4个字节的网络字节序bytes数组
|
* 将一个数字转换成生成4个字节的网络字节序bytes数组
|
||||||
*
|
*
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>me.chanjar</groupId>
|
<groupId>me.chanjar</groupId>
|
||||||
<artifactId>weixin-java-parent</artifactId>
|
<artifactId>weixin-java-parent</artifactId>
|
||||||
<version>1.1.5</version>
|
<version>1.1.3</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<artifactId>weixin-java-cp</artifactId>
|
<artifactId>weixin-java-cp</artifactId>
|
||||||
|
|||||||
@@ -399,7 +399,7 @@ public interface WxCpService {
|
|||||||
* @param tagId
|
* @param tagId
|
||||||
* @param userIds
|
* @param userIds
|
||||||
*/
|
*/
|
||||||
void tagAddUsers(String tagId, List<String> userIds, List<String> partyIds) throws WxErrorException;
|
void tagAddUsers(String tagId, List<String> userIds) throws WxErrorException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* <pre>
|
* <pre>
|
||||||
|
|||||||
@@ -7,7 +7,6 @@ import com.google.gson.JsonPrimitive;
|
|||||||
import com.google.gson.internal.Streams;
|
import com.google.gson.internal.Streams;
|
||||||
import com.google.gson.reflect.TypeToken;
|
import com.google.gson.reflect.TypeToken;
|
||||||
import com.google.gson.stream.JsonReader;
|
import com.google.gson.stream.JsonReader;
|
||||||
import com.sun.media.sound.SoftTuning;
|
|
||||||
import me.chanjar.weixin.common.bean.WxAccessToken;
|
import me.chanjar.weixin.common.bean.WxAccessToken;
|
||||||
import me.chanjar.weixin.common.bean.WxJsapiSignature;
|
import me.chanjar.weixin.common.bean.WxJsapiSignature;
|
||||||
import me.chanjar.weixin.common.bean.WxMenu;
|
import me.chanjar.weixin.common.bean.WxMenu;
|
||||||
@@ -47,7 +46,6 @@ import java.io.File;
|
|||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.io.StringReader;
|
import java.io.StringReader;
|
||||||
import java.math.BigDecimal;
|
|
||||||
import java.security.NoSuchAlgorithmException;
|
import java.security.NoSuchAlgorithmException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.UUID;
|
import java.util.UUID;
|
||||||
@@ -271,8 +269,7 @@ public class WxCpServiceImpl implements WxCpService {
|
|||||||
return WxCpGsonBuilder.INSTANCE.create()
|
return WxCpGsonBuilder.INSTANCE.create()
|
||||||
.fromJson(
|
.fromJson(
|
||||||
tmpJsonElement.getAsJsonObject().get("department"),
|
tmpJsonElement.getAsJsonObject().get("department"),
|
||||||
new TypeToken<List<WxCpDepart>>() {
|
new TypeToken<List<WxCpDepart>>() { }.getType()
|
||||||
}.getType()
|
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -390,8 +387,7 @@ public class WxCpServiceImpl implements WxCpService {
|
|||||||
return WxCpGsonBuilder.INSTANCE.create()
|
return WxCpGsonBuilder.INSTANCE.create()
|
||||||
.fromJson(
|
.fromJson(
|
||||||
tmpJsonElement.getAsJsonObject().get("taglist"),
|
tmpJsonElement.getAsJsonObject().get("taglist"),
|
||||||
new TypeToken<List<WxCpTag>>() {
|
new TypeToken<List<WxCpTag>>() { }.getType()
|
||||||
}.getType()
|
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -408,24 +404,15 @@ public class WxCpServiceImpl implements WxCpService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void tagAddUsers(String tagId, List<String> userIds, List<String> partyIds) throws WxErrorException {
|
public void tagAddUsers(String tagId, List<String> userIds) throws WxErrorException {
|
||||||
String url = "https://qyapi.weixin.qq.com/cgi-bin/tag/addtagusers";
|
String url = "https://qyapi.weixin.qq.com/cgi-bin/tag/addtagusers";
|
||||||
JsonObject jsonObject = new JsonObject();
|
JsonObject jsonObject = new JsonObject();
|
||||||
jsonObject.addProperty("tagid", tagId);
|
jsonObject.addProperty("tagid", tagId);
|
||||||
if (userIds != null) {
|
JsonArray jsonArray = new JsonArray();
|
||||||
JsonArray jsonArray = new JsonArray();
|
for (String userId : userIds) {
|
||||||
for (String userId : userIds) {
|
jsonArray.add(new JsonPrimitive(userId));
|
||||||
jsonArray.add(new JsonPrimitive(userId));
|
|
||||||
}
|
|
||||||
jsonObject.add("userlist", jsonArray);
|
|
||||||
}
|
|
||||||
if (partyIds != null) {
|
|
||||||
JsonArray jsonArray = new JsonArray();
|
|
||||||
for (String userId : partyIds) {
|
|
||||||
jsonArray.add(new JsonPrimitive(userId));
|
|
||||||
}
|
|
||||||
jsonObject.add("partylist", jsonArray);
|
|
||||||
}
|
}
|
||||||
|
jsonObject.add("userlist", jsonArray);
|
||||||
post(url, jsonObject.toString());
|
post(url, jsonObject.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -458,7 +445,7 @@ public class WxCpServiceImpl implements WxCpService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String[] oauth2getUserInfo(String code) throws WxErrorException {
|
public String[] oauth2getUserInfo(String code) throws WxErrorException {
|
||||||
return oauth2getUserInfo(wxCpConfigStorage.getAgentId(), code);
|
return oauth2getUserInfo(code, wxCpConfigStorage.getAgentId());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@@ -639,12 +626,4 @@ public class WxCpServiceImpl implements WxCpService {
|
|||||||
this.sessionManager = sessionManager;
|
this.sessionManager = sessionManager;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void main(String[] args) {
|
|
||||||
Float a = 3.1f;
|
|
||||||
System.out.println(3.1d);
|
|
||||||
System.out.println(new BigDecimal(3.1d));
|
|
||||||
System.out.println(new BigDecimal(a));
|
|
||||||
System.out.println(a.toString());
|
|
||||||
System.out.println(a.doubleValue());
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -34,7 +34,7 @@ public class WxCpMessageGsonAdapter implements JsonSerializer<WxCpMessage> {
|
|||||||
messageJson.addProperty("toparty", message.getToParty());
|
messageJson.addProperty("toparty", message.getToParty());
|
||||||
}
|
}
|
||||||
if (StringUtils.isNotBlank(message.getToTag())) {
|
if (StringUtils.isNotBlank(message.getToTag())) {
|
||||||
messageJson.addProperty("totag", message.getToTag());
|
messageJson.addProperty("totag", message.getToUser());
|
||||||
}
|
}
|
||||||
if (WxConsts.CUSTOM_MSG_TEXT.equals(message.getMsgType())) {
|
if (WxConsts.CUSTOM_MSG_TEXT.equals(message.getMsgType())) {
|
||||||
JsonObject text = new JsonObject();
|
JsonObject text = new JsonObject();
|
||||||
|
|||||||
@@ -19,17 +19,17 @@ import java.lang.reflect.Type;
|
|||||||
*/
|
*/
|
||||||
public class WxCpTagGsonAdapter implements JsonSerializer<WxCpTag>, JsonDeserializer<WxCpTag> {
|
public class WxCpTagGsonAdapter implements JsonSerializer<WxCpTag>, JsonDeserializer<WxCpTag> {
|
||||||
|
|
||||||
public JsonElement serialize(WxCpTag tag, Type typeOfSrc, JsonSerializationContext context) {
|
public JsonElement serialize(WxCpTag group, Type typeOfSrc, JsonSerializationContext context) {
|
||||||
JsonObject o = new JsonObject();
|
JsonObject o = new JsonObject();
|
||||||
o.addProperty("tagid", tag.getId());
|
o.addProperty("tagid", group.getId());
|
||||||
o.addProperty("tagname", tag.getName());
|
o.addProperty("tagname", group.getName());
|
||||||
return o;
|
return o;
|
||||||
}
|
}
|
||||||
|
|
||||||
public WxCpTag deserialize(JsonElement json, Type typeOfT, JsonDeserializationContext context)
|
public WxCpTag deserialize(JsonElement json, Type typeOfT, JsonDeserializationContext context)
|
||||||
throws JsonParseException {
|
throws JsonParseException {
|
||||||
JsonObject jsonObject = json.getAsJsonObject();
|
JsonObject jsonObject = json.getAsJsonObject();
|
||||||
return new WxCpTag(GsonHelper.getString(jsonObject, "tagid"), GsonHelper.getString(jsonObject, "tagname"));
|
return new WxCpTag(GsonHelper.getString(jsonObject, "tagid"), GsonHelper.getString(jsonObject, "name"));
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -42,7 +42,7 @@ public class WxCpTagAPITest {
|
|||||||
public void testTagAddUsers() throws Exception {
|
public void testTagAddUsers() throws Exception {
|
||||||
List<String> userIds = new ArrayList<String>();
|
List<String> userIds = new ArrayList<String>();
|
||||||
userIds.add(((ApiTestModule.WxXmlCpInMemoryConfigStorage)configStorage).getUserId());
|
userIds.add(((ApiTestModule.WxXmlCpInMemoryConfigStorage)configStorage).getUserId());
|
||||||
wxService.tagAddUsers(tagId, userIds, null);
|
wxService.tagAddUsers(tagId, userIds);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test(dependsOnMethods = "testTagAddUsers")
|
@Test(dependsOnMethods = "testTagAddUsers")
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>me.chanjar</groupId>
|
<groupId>me.chanjar</groupId>
|
||||||
<artifactId>weixin-java-parent</artifactId>
|
<artifactId>weixin-java-parent</artifactId>
|
||||||
<version>1.1.5</version>
|
<version>1.1.3</version>
|
||||||
</parent>
|
</parent>
|
||||||
<artifactId>weixin-java-mp</artifactId>
|
<artifactId>weixin-java-mp</artifactId>
|
||||||
<name>WeiXin Java Tools - MP</name>
|
<name>WeiXin Java Tools - MP</name>
|
||||||
|
|||||||
@@ -50,10 +50,6 @@ public interface WxMpConfigStorage {
|
|||||||
|
|
||||||
public String getSecret();
|
public String getSecret();
|
||||||
|
|
||||||
public String getPartnerId();
|
|
||||||
|
|
||||||
public String getPartnerKey();
|
|
||||||
|
|
||||||
public String getToken();
|
public String getToken();
|
||||||
|
|
||||||
public String getAesKey();
|
public String getAesKey();
|
||||||
|
|||||||
@@ -11,8 +11,6 @@ public class WxMpInMemoryConfigStorage implements WxMpConfigStorage {
|
|||||||
|
|
||||||
protected volatile String appId;
|
protected volatile String appId;
|
||||||
protected volatile String secret;
|
protected volatile String secret;
|
||||||
protected volatile String partnerId;
|
|
||||||
protected volatile String partnerKey;
|
|
||||||
protected volatile String token;
|
protected volatile String token;
|
||||||
protected volatile String accessToken;
|
protected volatile String accessToken;
|
||||||
protected volatile String aesKey;
|
protected volatile String aesKey;
|
||||||
@@ -170,8 +168,6 @@ public class WxMpInMemoryConfigStorage implements WxMpConfigStorage {
|
|||||||
"appId='" + appId + '\'' +
|
"appId='" + appId + '\'' +
|
||||||
", secret='" + secret + '\'' +
|
", secret='" + secret + '\'' +
|
||||||
", token='" + token + '\'' +
|
", token='" + token + '\'' +
|
||||||
", partnerId='" + partnerId + '\'' +
|
|
||||||
", partnerKey='" + partnerKey + '\'' +
|
|
||||||
", accessToken='" + accessToken + '\'' +
|
", accessToken='" + accessToken + '\'' +
|
||||||
", aesKey='" + aesKey + '\'' +
|
", aesKey='" + aesKey + '\'' +
|
||||||
", expiresTime=" + expiresTime +
|
", expiresTime=" + expiresTime +
|
||||||
@@ -183,22 +179,4 @@ public class WxMpInMemoryConfigStorage implements WxMpConfigStorage {
|
|||||||
", jsapiTicketExpiresTime='" + jsapiTicketExpiresTime + '\'' +
|
", jsapiTicketExpiresTime='" + jsapiTicketExpiresTime + '\'' +
|
||||||
'}';
|
'}';
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getPartnerId() {
|
|
||||||
return partnerId;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setPartnerId(String partnerId) {
|
|
||||||
this.partnerId = partnerId;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getPartnerKey() {
|
|
||||||
return partnerKey;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setPartnerKey(String partnerKey) {
|
|
||||||
this.partnerKey = partnerKey;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,11 +11,9 @@ import me.chanjar.weixin.mp.bean.result.*;
|
|||||||
import java.io.File;
|
import java.io.File;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.math.BigDecimal;
|
|
||||||
import java.text.SimpleDateFormat;
|
import java.text.SimpleDateFormat;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 微信API的Service
|
* 微信API的Service
|
||||||
@@ -334,18 +332,6 @@ public interface WxMpService {
|
|||||||
*/
|
*/
|
||||||
public WxMpQrCodeTicket qrCodeCreateLastTicket(int scene_id) throws WxErrorException;
|
public WxMpQrCodeTicket qrCodeCreateLastTicket(int scene_id) throws WxErrorException;
|
||||||
|
|
||||||
/**
|
|
||||||
* <pre>
|
|
||||||
* 换取永久字符串二维码ticket
|
|
||||||
* 详情请见: http://mp.weixin.qq.com/wiki/index.php?title=生成带参数的二维码
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @param scene_str 参数。字符串类型长度现在为1到64
|
|
||||||
* @return
|
|
||||||
* @throws WxErrorException
|
|
||||||
*/
|
|
||||||
public WxMpQrCodeTicket qrCodeCreateLastTicket(String scene_str) throws WxErrorException;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* <pre>
|
* <pre>
|
||||||
* 换取二维码图片文件,jpg格式
|
* 换取二维码图片文件,jpg格式
|
||||||
@@ -401,18 +387,6 @@ public interface WxMpService {
|
|||||||
*/
|
*/
|
||||||
public String oauth2buildAuthorizationUrl(String scope, String state);
|
public String oauth2buildAuthorizationUrl(String scope, String state);
|
||||||
|
|
||||||
/**
|
|
||||||
* <pre>
|
|
||||||
* 构造oauth2授权的url连接
|
|
||||||
* 详情请见: http://mp.weixin.qq.com/wiki/index.php?title=网页授权获取用户基本信息
|
|
||||||
* </pre>
|
|
||||||
* @param redirectURI
|
|
||||||
* 用户授权完成后的重定向链接,无需urlencode, 方法内会进行encode
|
|
||||||
* @param scope
|
|
||||||
* @param state
|
|
||||||
* @return code
|
|
||||||
*/
|
|
||||||
public String oauth2buildAuthorizationUrl(String redirectURI, String scope, String state);
|
|
||||||
/**
|
/**
|
||||||
* <pre>
|
* <pre>
|
||||||
* 用code换取oauth2的access token
|
* 用code换取oauth2的access token
|
||||||
@@ -542,32 +516,4 @@ public interface WxMpService {
|
|||||||
*/
|
*/
|
||||||
void setMaxRetryTimes(int maxRetryTimes);
|
void setMaxRetryTimes(int maxRetryTimes);
|
||||||
|
|
||||||
/**
|
|
||||||
* 统一下单(详见http://pay.weixin.qq.com/wiki/doc/api/index.php?chapter=9_1)
|
|
||||||
* 在发起微信支付前,需要调用统一下单接口,获取"预支付交易会话标识"
|
|
||||||
* @param openId 支付人openId
|
|
||||||
* @param outTradeNo 商户端对应订单号
|
|
||||||
* @param amt 金额(单位元)
|
|
||||||
* @param body 商品描述
|
|
||||||
* @param tradeType 交易类型 JSAPI,NATIVE,APP,WAP
|
|
||||||
* @param ip 发起支付的客户端IP
|
|
||||||
* @param notifyUrl 通知地址
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
WxMpPrepayIdResult getPrepayId(String openId, String outTradeNo, double amt, String body, String tradeType, String ip, String notifyUrl);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 该接口调用“统一下单”接口,并拼装JSSDK发起支付请求需要的参数
|
|
||||||
* 详见http://mp.weixin.qq.com/wiki/7/aaa137b55fb2e0456bf8dd9148dd613f.html#.E5.8F.91.E8.B5.B7.E4.B8.80.E4.B8.AA.E5.BE.AE.E4.BF.A1.E6.94.AF.E4.BB.98.E8.AF.B7.E6.B1.82
|
|
||||||
* @param openId 支付人openId
|
|
||||||
* @param outTradeNo 商户端对应订单号
|
|
||||||
* @param amt 金额(单位元)
|
|
||||||
* @param body 商品描述
|
|
||||||
* @param tradeType 交易类型 JSAPI,NATIVE,APP,WAP
|
|
||||||
* @param ip 发起支付的客户端IP
|
|
||||||
* @param notifyUrl 通知地址
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
Map<String, String> getJSSDKPayInfo(String openId, String outTradeNo, double amt, String body, String tradeType, String ip, String notifyUrl);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -6,7 +6,6 @@ import com.google.gson.JsonObject;
|
|||||||
import com.google.gson.internal.Streams;
|
import com.google.gson.internal.Streams;
|
||||||
import com.google.gson.reflect.TypeToken;
|
import com.google.gson.reflect.TypeToken;
|
||||||
import com.google.gson.stream.JsonReader;
|
import com.google.gson.stream.JsonReader;
|
||||||
import com.thoughtworks.xstream.XStream;
|
|
||||||
import me.chanjar.weixin.common.bean.WxAccessToken;
|
import me.chanjar.weixin.common.bean.WxAccessToken;
|
||||||
import me.chanjar.weixin.common.bean.WxMenu;
|
import me.chanjar.weixin.common.bean.WxMenu;
|
||||||
import me.chanjar.weixin.common.bean.WxJsapiSignature;
|
import me.chanjar.weixin.common.bean.WxJsapiSignature;
|
||||||
@@ -18,16 +17,13 @@ import me.chanjar.weixin.common.session.WxSessionManager;
|
|||||||
import me.chanjar.weixin.common.util.RandomUtils;
|
import me.chanjar.weixin.common.util.RandomUtils;
|
||||||
import me.chanjar.weixin.common.util.StringUtils;
|
import me.chanjar.weixin.common.util.StringUtils;
|
||||||
import me.chanjar.weixin.common.util.crypto.SHA1;
|
import me.chanjar.weixin.common.util.crypto.SHA1;
|
||||||
import me.chanjar.weixin.common.util.crypto.WxCryptUtil;
|
|
||||||
import me.chanjar.weixin.common.util.fs.FileUtils;
|
import me.chanjar.weixin.common.util.fs.FileUtils;
|
||||||
import me.chanjar.weixin.common.util.http.*;
|
import me.chanjar.weixin.common.util.http.*;
|
||||||
import me.chanjar.weixin.common.util.json.GsonHelper;
|
import me.chanjar.weixin.common.util.json.GsonHelper;
|
||||||
import me.chanjar.weixin.common.util.xml.XStreamInitializer;
|
|
||||||
import me.chanjar.weixin.mp.bean.*;
|
import me.chanjar.weixin.mp.bean.*;
|
||||||
import me.chanjar.weixin.mp.bean.result.*;
|
import me.chanjar.weixin.mp.bean.result.*;
|
||||||
import me.chanjar.weixin.mp.util.http.QrCodeRequestExecutor;
|
import me.chanjar.weixin.mp.util.http.QrCodeRequestExecutor;
|
||||||
import me.chanjar.weixin.mp.util.json.WxMpGsonBuilder;
|
import me.chanjar.weixin.mp.util.json.WxMpGsonBuilder;
|
||||||
import org.apache.http.Consts;
|
|
||||||
import org.apache.http.HttpHost;
|
import org.apache.http.HttpHost;
|
||||||
import org.apache.http.auth.AuthScope;
|
import org.apache.http.auth.AuthScope;
|
||||||
import org.apache.http.auth.UsernamePasswordCredentials;
|
import org.apache.http.auth.UsernamePasswordCredentials;
|
||||||
@@ -36,8 +32,6 @@ import org.apache.http.client.CredentialsProvider;
|
|||||||
import org.apache.http.client.config.RequestConfig;
|
import org.apache.http.client.config.RequestConfig;
|
||||||
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
||||||
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.client.methods.HttpGet;
|
||||||
import org.apache.http.client.methods.HttpPost;
|
|
||||||
import org.apache.http.entity.StringEntity;
|
|
||||||
import org.apache.http.impl.client.BasicCredentialsProvider;
|
import org.apache.http.impl.client.BasicCredentialsProvider;
|
||||||
import org.apache.http.impl.client.BasicResponseHandler;
|
import org.apache.http.impl.client.BasicResponseHandler;
|
||||||
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
||||||
@@ -49,9 +43,10 @@ import java.io.File;
|
|||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.io.StringReader;
|
import java.io.StringReader;
|
||||||
import java.math.BigDecimal;
|
|
||||||
import java.security.NoSuchAlgorithmException;
|
import java.security.NoSuchAlgorithmException;
|
||||||
import java.util.*;
|
import java.util.Date;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.UUID;
|
||||||
|
|
||||||
public class WxMpServiceImpl implements WxMpService {
|
public class WxMpServiceImpl implements WxMpService {
|
||||||
|
|
||||||
@@ -337,19 +332,6 @@ public class WxMpServiceImpl implements WxMpService {
|
|||||||
String responseContent = execute(new SimplePostRequestExecutor(), url, json.toString());
|
String responseContent = execute(new SimplePostRequestExecutor(), url, json.toString());
|
||||||
return WxMpQrCodeTicket.fromJson(responseContent);
|
return WxMpQrCodeTicket.fromJson(responseContent);
|
||||||
}
|
}
|
||||||
|
|
||||||
public WxMpQrCodeTicket qrCodeCreateLastTicket(String scene_str) throws WxErrorException {
|
|
||||||
String url = "https://api.weixin.qq.com/cgi-bin/qrcode/create";
|
|
||||||
JsonObject json = new JsonObject();
|
|
||||||
json.addProperty("action_name", "QR_LIMIT_STR_SCENE");
|
|
||||||
JsonObject actionInfo = new JsonObject();
|
|
||||||
JsonObject scene = new JsonObject();
|
|
||||||
scene.addProperty("scene_str", scene_str);
|
|
||||||
actionInfo.add("scene", scene);
|
|
||||||
json.add("action_info", actionInfo);
|
|
||||||
String responseContent = execute(new SimplePostRequestExecutor(), url, json.toString());
|
|
||||||
return WxMpQrCodeTicket.fromJson(responseContent);
|
|
||||||
}
|
|
||||||
|
|
||||||
public File qrCodePicture(WxMpQrCodeTicket ticket) throws WxErrorException {
|
public File qrCodePicture(WxMpQrCodeTicket ticket) throws WxErrorException {
|
||||||
String url = "https://mp.weixin.qq.com/cgi-bin/showqrcode";
|
String url = "https://mp.weixin.qq.com/cgi-bin/showqrcode";
|
||||||
@@ -381,14 +363,9 @@ public class WxMpServiceImpl implements WxMpService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String oauth2buildAuthorizationUrl(String scope, String state) {
|
public String oauth2buildAuthorizationUrl(String scope, String state) {
|
||||||
return this.oauth2buildAuthorizationUrl(wxMpConfigStorage.getOauth2redirectUri(), scope, state);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String oauth2buildAuthorizationUrl(String redirectURI, String scope, String state) {
|
|
||||||
String url = "https://open.weixin.qq.com/connect/oauth2/authorize?" ;
|
String url = "https://open.weixin.qq.com/connect/oauth2/authorize?" ;
|
||||||
url += "appid=" + wxMpConfigStorage.getAppId();
|
url += "appid=" + wxMpConfigStorage.getAppId();
|
||||||
url += "&redirect_uri=" + URIUtil.encodeURIComponent(redirectURI);
|
url += "&redirect_uri=" + URIUtil.encodeURIComponent(wxMpConfigStorage.getOauth2redirectUri());
|
||||||
url += "&response_type=code";
|
url += "&response_type=code";
|
||||||
url += "&scope=" + scope;
|
url += "&scope=" + scope;
|
||||||
if (state != null) {
|
if (state != null) {
|
||||||
@@ -631,77 +608,4 @@ public class WxMpServiceImpl implements WxMpService {
|
|||||||
this.maxRetryTimes = maxRetryTimes;
|
this.maxRetryTimes = maxRetryTimes;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public WxMpPrepayIdResult getPrepayId(String openId, String outTradeNo, double amt, String body, String tradeType, String ip, String callbackUrl) {
|
|
||||||
String nonce_str = System.currentTimeMillis() + "";
|
|
||||||
|
|
||||||
SortedMap<String, String> packageParams = new TreeMap<String, String>();
|
|
||||||
packageParams.put("appid", wxMpConfigStorage.getAppId());
|
|
||||||
packageParams.put("mch_id", wxMpConfigStorage.getPartnerId());
|
|
||||||
packageParams.put("nonce_str", nonce_str);
|
|
||||||
packageParams.put("body", body);
|
|
||||||
packageParams.put("out_trade_no", outTradeNo);
|
|
||||||
|
|
||||||
packageParams.put("total_fee", (int)(amt*100) + "");
|
|
||||||
packageParams.put("spbill_create_ip", ip);
|
|
||||||
packageParams.put("notify_url", callbackUrl);
|
|
||||||
packageParams.put("trade_type", tradeType);
|
|
||||||
packageParams.put("openid", openId);
|
|
||||||
|
|
||||||
String sign = WxCryptUtil.createSign(packageParams, wxMpConfigStorage.getPartnerKey());
|
|
||||||
String xml = "<xml>" +
|
|
||||||
"<appid>" + wxMpConfigStorage.getAppId() + "</appid>" +
|
|
||||||
"<mch_id>" + wxMpConfigStorage.getPartnerId() + "</mch_id>" +
|
|
||||||
"<nonce_str>" + nonce_str + "</nonce_str>" +
|
|
||||||
"<sign>" + sign + "</sign>" +
|
|
||||||
"<body><![CDATA[" + body + "]]></body>" +
|
|
||||||
"<out_trade_no>" + outTradeNo + "</out_trade_no>" +
|
|
||||||
"<total_fee>" + packageParams.get("total_fee") + "</total_fee>" +
|
|
||||||
"<spbill_create_ip>" + ip + "</spbill_create_ip>" +
|
|
||||||
"<notify_url>" + callbackUrl + "</notify_url>" +
|
|
||||||
"<trade_type>" + tradeType + "</trade_type>" +
|
|
||||||
"<openid>" + openId + "</openid>" +
|
|
||||||
"</xml>";
|
|
||||||
|
|
||||||
HttpPost httpPost = new HttpPost("https://api.mch.weixin.qq.com/pay/unifiedorder");
|
|
||||||
if (httpProxy != null) {
|
|
||||||
RequestConfig config = RequestConfig.custom().setProxy(httpProxy).build();
|
|
||||||
httpPost.setConfig(config);
|
|
||||||
}
|
|
||||||
|
|
||||||
StringEntity entity = new StringEntity(xml, Consts.UTF_8);
|
|
||||||
httpPost.setEntity(entity);
|
|
||||||
try {
|
|
||||||
CloseableHttpResponse response = httpClient.execute(httpPost);
|
|
||||||
String responseContent = Utf8ResponseHandler.INSTANCE.handleResponse(response);
|
|
||||||
XStream xstream = XStreamInitializer.getInstance();
|
|
||||||
xstream.alias("xml", WxMpPrepayIdResult.class);
|
|
||||||
WxMpPrepayIdResult wxMpPrepayIdResult = (WxMpPrepayIdResult) xstream.fromXML(responseContent);
|
|
||||||
return wxMpPrepayIdResult;
|
|
||||||
} catch (IOException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return new WxMpPrepayIdResult();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Map<String, String> getJSSDKPayInfo(String openId, String outTradeNo, double amt, String body, String tradeType, String ip, String callbackUrl) {
|
|
||||||
WxMpPrepayIdResult wxMpPrepayIdResult = getPrepayId(openId, outTradeNo, amt, body, tradeType, ip, callbackUrl);
|
|
||||||
String prepayId = wxMpPrepayIdResult.getPrepay_id();
|
|
||||||
if (prepayId == null || prepayId.equals("")) {
|
|
||||||
throw new RuntimeException("get prepayid error");
|
|
||||||
}
|
|
||||||
|
|
||||||
Map<String, String> payInfo = new HashMap<String, String>();
|
|
||||||
payInfo.put("appId", wxMpConfigStorage.getAppId());
|
|
||||||
// 支付签名时间戳,注意微信jssdk中的所有使用timestamp字段均为小写。但最新版的支付后台生成签名使用的timeStamp字段名需大写其中的S字符
|
|
||||||
payInfo.put("timeStamp", String.valueOf(System.currentTimeMillis() / 1000));
|
|
||||||
payInfo.put("nonceStr", System.currentTimeMillis() + "");
|
|
||||||
payInfo.put("package", "prepay_id=" + prepayId);
|
|
||||||
payInfo.put("signType", "MD5");
|
|
||||||
|
|
||||||
String finalSign = WxCryptUtil.createSign(payInfo, wxMpConfigStorage.getPartnerKey());
|
|
||||||
payInfo.put("sign", finalSign);
|
|
||||||
return payInfo;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,98 +0,0 @@
|
|||||||
package me.chanjar.weixin.mp.bean.result;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* <pre>
|
|
||||||
* 群发消息一发送就返回的结果
|
|
||||||
*
|
|
||||||
* 真正的群发消息是否发送成功要看
|
|
||||||
* http://mp.weixin.qq.com/wiki/index.php?title=高级群发接口#.E4.BA.8B.E4.BB.B6.E6.8E.A8.E9.80.81.E7.BE.A4.E5.8F.91.E7.BB.93.E6.9E.9C
|
|
||||||
*
|
|
||||||
* </pre>
|
|
||||||
*
|
|
||||||
* @author chanjarster
|
|
||||||
*/
|
|
||||||
public class WxMpPrepayIdResult implements Serializable {
|
|
||||||
private String return_code;
|
|
||||||
private String return_msg;
|
|
||||||
private String appid;
|
|
||||||
private String mch_id;
|
|
||||||
private String nonce_str;
|
|
||||||
private String sign;
|
|
||||||
private String result_code;
|
|
||||||
private String prepay_id;
|
|
||||||
private String trade_type;
|
|
||||||
|
|
||||||
public String getReturn_code() {
|
|
||||||
return return_code;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setReturn_code(String return_code) {
|
|
||||||
this.return_code = return_code;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getReturn_msg() {
|
|
||||||
return return_msg;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setReturn_msg(String return_msg) {
|
|
||||||
this.return_msg = return_msg;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getAppid() {
|
|
||||||
return appid;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setAppid(String appid) {
|
|
||||||
this.appid = appid;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getMch_id() {
|
|
||||||
return mch_id;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setMch_id(String mch_id) {
|
|
||||||
this.mch_id = mch_id;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getNonce_str() {
|
|
||||||
return nonce_str;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setNonce_str(String nonce_str) {
|
|
||||||
this.nonce_str = nonce_str;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getSign() {
|
|
||||||
return sign;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setSign(String sign) {
|
|
||||||
this.sign = sign;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getResult_code() {
|
|
||||||
return result_code;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setResult_code(String result_code) {
|
|
||||||
this.result_code = result_code;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getPrepay_id() {
|
|
||||||
return prepay_id;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setPrepay_id(String prepay_id) {
|
|
||||||
this.prepay_id = prepay_id;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getTrade_type() {
|
|
||||||
return trade_type;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setTrade_type(String trade_type) {
|
|
||||||
this.trade_type = trade_type;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user