mirror of
https://github.com/little-snow-fox/react-native-wechat-lib.git
synced 2025-12-06 15:26:49 +08:00
1089 lines
41 KiB
Java
1089 lines
41 KiB
Java
package com.wechatlib;
|
||
|
||
import android.content.Context;
|
||
import android.content.Intent;
|
||
import android.graphics.Bitmap;
|
||
import android.graphics.BitmapFactory;
|
||
import android.net.Uri;
|
||
import android.os.Environment;
|
||
import android.util.Base64;
|
||
|
||
import androidx.annotation.Nullable;
|
||
import androidx.core.content.FileProvider;
|
||
|
||
import com.facebook.common.executors.UiThreadImmediateExecutorService;
|
||
import com.facebook.common.internal.Files;
|
||
import com.facebook.common.references.CloseableReference;
|
||
import com.facebook.common.util.UriUtil;
|
||
import com.facebook.datasource.DataSource;
|
||
import com.facebook.drawee.backends.pipeline.Fresco;
|
||
import com.facebook.imagepipeline.common.ResizeOptions;
|
||
import com.facebook.imagepipeline.core.ImagePipeline;
|
||
import com.facebook.imagepipeline.datasource.BaseBitmapDataSubscriber;
|
||
import com.facebook.imagepipeline.image.CloseableImage;
|
||
import com.facebook.imagepipeline.request.ImageRequest;
|
||
import com.facebook.imagepipeline.request.ImageRequestBuilder;
|
||
import com.facebook.react.bridge.Arguments;
|
||
import com.facebook.react.bridge.Callback;
|
||
import com.facebook.react.bridge.ReactApplicationContext;
|
||
import com.facebook.react.bridge.ReactContext;
|
||
import com.facebook.react.bridge.ReactContextBaseJavaModule;
|
||
import com.facebook.react.bridge.ReactMethod;
|
||
import com.facebook.react.bridge.ReadableMap;
|
||
import com.facebook.react.bridge.WritableMap;
|
||
import com.facebook.react.modules.core.DeviceEventManagerModule;
|
||
import com.facebook.react.modules.core.RCTNativeAppEventEmitter;
|
||
import com.tencent.mm.opensdk.diffdev.DiffDevOAuthFactory;
|
||
import com.tencent.mm.opensdk.diffdev.IDiffDevOAuth;
|
||
import com.tencent.mm.opensdk.diffdev.OAuthErrCode;
|
||
import com.tencent.mm.opensdk.diffdev.OAuthListener;
|
||
import com.tencent.mm.opensdk.modelbase.BaseReq;
|
||
import com.tencent.mm.opensdk.modelbase.BaseResp;
|
||
import com.tencent.mm.opensdk.modelbiz.ChooseCardFromWXCardPackage;
|
||
import com.tencent.mm.opensdk.modelbiz.WXOpenCustomerServiceChat;
|
||
import com.tencent.mm.opensdk.modelmsg.SendAuth;
|
||
import com.tencent.mm.opensdk.modelmsg.SendMessageToWX;
|
||
import com.tencent.mm.opensdk.modelmsg.ShowMessageFromWX;
|
||
import com.tencent.mm.opensdk.modelmsg.WXFileObject;
|
||
import com.tencent.mm.opensdk.modelmsg.WXImageObject;
|
||
import com.tencent.mm.opensdk.modelmsg.WXMediaMessage;
|
||
import com.tencent.mm.opensdk.modelmsg.WXMiniProgramObject;
|
||
import com.tencent.mm.opensdk.modelmsg.WXMusicObject;
|
||
import com.tencent.mm.opensdk.modelmsg.WXTextObject;
|
||
import com.tencent.mm.opensdk.modelmsg.WXVideoObject;
|
||
import com.tencent.mm.opensdk.modelmsg.WXWebpageObject;
|
||
import com.tencent.mm.opensdk.modelpay.PayReq;
|
||
import com.tencent.mm.opensdk.modelpay.PayResp;
|
||
import com.tencent.mm.opensdk.modelbiz.WXLaunchMiniProgram;
|
||
import com.tencent.mm.opensdk.openapi.IWXAPI;
|
||
import com.tencent.mm.opensdk.openapi.IWXAPIEventHandler;
|
||
import com.tencent.mm.opensdk.openapi.WXAPIFactory;
|
||
import com.tencent.mm.opensdk.constants.ConstantsAPI;
|
||
import com.tencent.mm.opensdk.modelbiz.SubscribeMessage;
|
||
|
||
import java.io.BufferedInputStream;
|
||
import java.io.ByteArrayInputStream;
|
||
import java.io.ByteArrayOutputStream;
|
||
import java.io.File;
|
||
import java.io.FileInputStream;
|
||
import java.io.FileNotFoundException;
|
||
import java.io.FileOutputStream;
|
||
import java.io.IOException;
|
||
import java.io.InputStream;
|
||
import java.net.HttpURLConnection;
|
||
import java.net.URI;
|
||
import java.net.URL;
|
||
import java.util.ArrayList;
|
||
import java.util.UUID;
|
||
|
||
public class WeChatLibModule extends ReactContextBaseJavaModule implements IWXAPIEventHandler {
|
||
private String appId;
|
||
|
||
private IWXAPI api = null;
|
||
private final static String NOT_REGISTERED = "registerApp required.";
|
||
private final static String INVOKE_FAILED = "WeChat API invoke returns false.";
|
||
private final static String INVALID_ARGUMENT = "invalid argument.";
|
||
// 缩略图大小 kb
|
||
private final static int THUMB_SIZE = 32;
|
||
|
||
private static byte[] bitmapTopBytes(Bitmap bitmap) {
|
||
ByteArrayOutputStream baos = new ByteArrayOutputStream();
|
||
bitmap.compress(Bitmap.CompressFormat.JPEG, 100, baos);
|
||
bitmap.recycle();
|
||
return baos.toByteArray();
|
||
}
|
||
|
||
private static byte[] bitmapResizeGetBytes(Bitmap image, int size) {
|
||
// little-snow-fox 2019.10.20
|
||
ByteArrayOutputStream baos = new ByteArrayOutputStream();
|
||
// 质量压缩方法，这里100表示第一次不压缩，把压缩后的数据缓存到 baos
|
||
image.compress(Bitmap.CompressFormat.JPEG, 100, baos);
|
||
int options = 100;
|
||
// 循环判断压缩后依然大于 32kb 则继续压缩
|
||
while (baos.toByteArray().length / 1024 > size) {
|
||
// 重置baos即清空baos
|
||
baos.reset();
|
||
if (options > 10) {
|
||
options -= 8;
|
||
} else {
|
||
return bitmapResizeGetBytes(Bitmap.createScaledBitmap(image, 280, image.getHeight() / image.getWidth() * 280, true), size);
|
||
}
|
||
// 这里压缩options%，把压缩后的数据存放到baos中
|
||
image.compress(Bitmap.CompressFormat.JPEG, options, baos);
|
||
}
|
||
return baos.toByteArray();
|
||
}
|
||
|
||
public WeChatLibModule(ReactApplicationContext context) {
|
||
super(context);
|
||
}
|
||
|
||
@Override
|
||
public String getName() {
|
||
return "WeChat";
|
||
}
|
||
|
||
/**
|
||
* fix Native module WeChatLibModule tried to override WeChatLibModule for module name RCTWeChat.
|
||
* If this was your intention, return true from WeChatLibModule#canOverrideExistingModule() bug
|
||
*
|
||
* @return
|
||
*/
|
||
public boolean canOverrideExistingModule() {
|
||
return true;
|
||
}
|
||
|
||
private static ArrayList<WeChatLibModule> modules = new ArrayList<>();
|
||
|
||
@Override
|
||
public void initialize() {
|
||
super.initialize();
|
||
modules.add(this);
|
||
}
|
||
|
||
@Override
|
||
public void onCatalystInstanceDestroy() {
|
||
super.onCatalystInstanceDestroy();
|
||
if (api != null) {
|
||
api = null;
|
||
}
|
||
modules.remove(this);
|
||
}
|
||
|
||
public static void handleIntent(Intent intent) {
|
||
for (WeChatLibModule mod : modules) {
|
||
mod.api.handleIntent(intent, mod);
|
||
}
|
||
}
|
||
|
||
private void sendEvent(ReactContext reactContext, String eventName, WritableMap params) {
|
||
reactContext.getJSModule(RCTNativeAppEventEmitter.class).emit(eventName, params);
|
||
}
|
||
|
||
@ReactMethod
|
||
public void authByScan(String appid, String nonceStr, String timeStamp, String scope, String signature, String schemeData, final Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
|
||
IDiffDevOAuth oauth = DiffDevOAuthFactory.getDiffDevOAuth();
|
||
oauth.stopAuth();
|
||
oauth.auth(appid, scope, nonceStr, timeStamp, signature, new OAuthListener() {
|
||
@Override
|
||
public void onAuthGotQrcode(String var1, byte[] var2){
|
||
WritableMap map = Arguments.createMap();
|
||
String base64String = Base64.encodeToString(var2, Base64.DEFAULT);
|
||
map.putString("qrcode", base64String);
|
||
sendEvent(getReactApplicationContext(), "onAuthGotQrcode", map);
|
||
}
|
||
|
||
@Override
|
||
public void onQrcodeScanned() {
|
||
|
||
}
|
||
@Override
|
||
public void onAuthFinish(OAuthErrCode var1, String var2){
|
||
WritableMap map = Arguments.createMap();
|
||
map.putString("authCode", var2);
|
||
map.putInt("errCode", var1.getCode());
|
||
callback.invoke(null, map);
|
||
}
|
||
});
|
||
}
|
||
|
||
@ReactMethod
|
||
public void registerApp(String appid, String universalLink, Callback callback) {
|
||
this.appId = appid;
|
||
api = WXAPIFactory.createWXAPI(this.getReactApplicationContext().getBaseContext(), appid, true);
|
||
callback.invoke(null, api.registerApp(appid));
|
||
}
|
||
|
||
@ReactMethod
|
||
public void isWXAppInstalled(Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
callback.invoke(null, api.isWXAppInstalled());
|
||
}
|
||
|
||
@ReactMethod
|
||
public void isWXAppSupportApi(Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
callback.invoke(null, api.getWXAppSupportAPI());
|
||
}
|
||
|
||
@ReactMethod
|
||
public void getApiVersion(Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
callback.invoke(null, api.getWXAppSupportAPI());
|
||
}
|
||
|
||
@ReactMethod
|
||
public void openWXApp(Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
callback.invoke(null, api.openWXApp());
|
||
}
|
||
|
||
@ReactMethod
|
||
public void sendAuthRequest(String scope, String state, Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
SendAuth.Req req = new SendAuth.Req();
|
||
req.scope = scope;
|
||
req.state = state;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
/**
|
||
* 选择发票
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void chooseInvoice(ReadableMap data, Callback callback) {
|
||
ChooseCardFromWXCardPackage.Req req = new ChooseCardFromWXCardPackage.Req();
|
||
|
||
req.appId = this.appId;
|
||
req.cardType = "INVOICE";
|
||
req.timeStamp = String.valueOf(data.getInt("timeStamp"));
|
||
req.nonceStr = data.getString("nonceStr");
|
||
req.cardSign = data.getString("cardSign");
|
||
req.signType = data.getString("signType");
|
||
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
public byte[] loadRawDataFromURL(String u) throws Exception {
|
||
URL url = new URL(u);
|
||
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
|
||
|
||
InputStream is = conn.getInputStream();
|
||
BufferedInputStream bis = new BufferedInputStream(is);
|
||
|
||
ByteArrayOutputStream baos = new ByteArrayOutputStream();
|
||
|
||
final int BUFFER_SIZE = 2048;
|
||
final int EOF = -1;
|
||
|
||
int c;
|
||
byte[] buf = new byte[BUFFER_SIZE];
|
||
|
||
while (true) {
|
||
c = bis.read(buf);
|
||
if (c == EOF)
|
||
break;
|
||
|
||
baos.write(buf, 0, c);
|
||
}
|
||
|
||
conn.disconnect();
|
||
is.close();
|
||
|
||
byte[] data = baos.toByteArray();
|
||
baos.flush();
|
||
|
||
return data;
|
||
}
|
||
|
||
public String getFileUri(Context context, File file) {
|
||
if (file == null || !file.exists()) {
|
||
return null;
|
||
}
|
||
|
||
Uri contentUri = FileProvider.getUriForFile(context,
|
||
context.getPackageName() + ".fileprovider", // 要与`AndroidManifest.xml`里配置的`authorities`一致
|
||
file);
|
||
|
||
// 授权给微信访问路径
|
||
context.grantUriPermission("com.tencent.mm", // 这里填微信包名
|
||
contentUri, Intent.FLAG_GRANT_READ_URI_PERMISSION);
|
||
|
||
return contentUri.toString(); // contentUri.toString() 即是以"content://"开头的用于共享的路径
|
||
}
|
||
|
||
/**
|
||
* 分享文本
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareFile(ReadableMap data, Callback callback) throws Exception {
|
||
WXFileObject fileObj = new WXFileObject();
|
||
|
||
String url = data.getString("url");
|
||
if (url.startsWith("http")) {
|
||
fileObj.fileData = loadRawDataFromURL(url);
|
||
} else {
|
||
File file = new File(url);
|
||
String fileUri = getFileUri(getReactApplicationContext(), file);
|
||
fileObj.filePath = fileUri;
|
||
}
|
||
|
||
WXMediaMessage msg = new WXMediaMessage();
|
||
msg.mediaObject = fileObj;
|
||
msg.title = data.getString("title");
|
||
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = String.valueOf(System.currentTimeMillis());
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
/**
|
||
* 分享文本
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareText(ReadableMap data, Callback callback) {
|
||
//初始化一个 WXTextObject 对象，填写分享的文本内容
|
||
WXTextObject textObj = new WXTextObject();
|
||
textObj.text = data.getString("text");
|
||
|
||
//用 WXTextObject 对象初始化一个 WXMediaMessage 对象
|
||
WXMediaMessage msg = new WXMediaMessage();
|
||
msg.mediaObject = textObj;
|
||
msg.description = data.getString("text");
|
||
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "text";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
/**
|
||
* 分享图片
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareImage(final ReadableMap data, final Callback callback) {
|
||
this._getImage(Uri.parse(data.getString("imageUrl")), null, new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bitmap) {
|
||
Bitmap bmp = bitmap;
|
||
int maxWidth = data.hasKey("maxWidth") ? data.getInt("maxWidth") : -1;
|
||
if (maxWidth > 0) {
|
||
bmp = Bitmap.createScaledBitmap(bmp, maxWidth, bmp.getHeight() / bmp.getWidth() * maxWidth, true);
|
||
}
|
||
// 初始化 WXImageObject 和 WXMediaMessage 对象
|
||
WXImageObject imgObj = new WXImageObject(bmp);
|
||
WXMediaMessage msg = new WXMediaMessage();
|
||
msg.mediaObject = imgObj;
|
||
|
||
// 设置缩略图
|
||
msg.thumbData = bitmapResizeGetBytes(bmp, THUMB_SIZE);
|
||
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "img";
|
||
req.message = msg;
|
||
// req.userOpenId = getOpenId();
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
});
|
||
|
||
}
|
||
// private static final String SDCARD_ROOT = Environment.getExternalStorageDirectory().getAbsolutePath();
|
||
|
||
/**
|
||
* 分享本地图片
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareLocalImage(final ReadableMap data, final Callback callback) {
|
||
FileInputStream fs = null;
|
||
try {
|
||
String path = data.getString("imageUrl");
|
||
if (path.indexOf("file://") > -1) {
|
||
path = path.substring(7);
|
||
}
|
||
// int maxWidth = data.hasKey("maxWidth") ? data.getInt("maxWidth") : -1;
|
||
fs = new FileInputStream(path);
|
||
Bitmap bmp = BitmapFactory.decodeStream(fs);
|
||
|
||
// if (maxWidth > 0) {
|
||
// bmp = Bitmap.createScaledBitmap(bmp, maxWidth, bmp.getHeight() / bmp.getWidth() * maxWidth, true);
|
||
// }
|
||
|
||
// File f = Environment.getExternalStoragePublicDirectory(SDCARD_ROOT + "/react-native-wechat-lib");
|
||
// String fileName = "wechat-share.jpg";
|
||
// String tempPath = SDCARD_ROOT + "/react-native-wechat-lib";
|
||
// File file = new File(f, fileName);
|
||
// try {
|
||
// FileOutputStream fos = new FileOutputStream(file);
|
||
// bmp.compress(Bitmap.CompressFormat.JPEG, 100, fos);
|
||
// fos.flush();
|
||
// fos.close();
|
||
// } catch (FileNotFoundException e) {
|
||
// e.printStackTrace();
|
||
// } catch (IOException e) {
|
||
// e.printStackTrace();
|
||
// }
|
||
|
||
// int size = bmp.getByteCount();
|
||
// ByteArrayOutputStream var2 = new ByteArrayOutputStream();
|
||
// bmp.compress(Bitmap.CompressFormat.JPEG, 85, var2);
|
||
// int size2 = var2.toByteArray().length;
|
||
// 初始化 WXImageObject 和 WXMediaMessage 对象
|
||
|
||
WXImageObject imgObj = new WXImageObject(bmp);
|
||
WXMediaMessage msg = new WXMediaMessage();
|
||
msg.mediaObject = imgObj;
|
||
// 设置缩略图
|
||
msg.thumbData = bitmapResizeGetBytes(bmp, THUMB_SIZE);
|
||
bmp.recycle();
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "img";
|
||
req.message = msg;
|
||
// req.userOpenId = getOpenId();
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
} catch (FileNotFoundException e) {
|
||
callback.invoke(null, false);
|
||
e.printStackTrace();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 分享音乐
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareMusic(final ReadableMap data, final Callback callback) {
|
||
// 初始化一个WXMusicObject，填写url
|
||
WXMusicObject music = new WXMusicObject();
|
||
music.musicUrl = data.hasKey("musicUrl") ? data.getString("musicUrl") : null;
|
||
music.musicLowBandUrl = data.hasKey("musicLowBandUrl") ? data.getString("musicLowBandUrl") : null;
|
||
music.musicDataUrl = data.hasKey("musicDataUrl") ? data.getString("musicDataUrl") : null;
|
||
music.musicUrl = data.hasKey("musicUrl") ? data.getString("musicUrl") : null;
|
||
music.musicLowBandDataUrl = data.hasKey("musicLowBandDataUrl") ? data.getString("musicLowBandDataUrl") : null;
|
||
// 用 WXMusicObject 对象初始化一个 WXMediaMessage 对象
|
||
final WXMediaMessage msg = new WXMediaMessage();
|
||
msg.mediaObject = music;
|
||
msg.title = data.hasKey("title") ? data.getString("title") : null;
|
||
msg.description = data.hasKey("description") ? data.getString("description") : null;
|
||
|
||
if (data.hasKey("thumbImageUrl")) {
|
||
this._getImage(Uri.parse(data.getString("thumbImageUrl")), null, new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bmp) {
|
||
// 设置缩略图
|
||
if (bmp != null) {
|
||
msg.thumbData = bitmapResizeGetBytes(bmp, THUMB_SIZE);
|
||
}
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "music";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
});
|
||
} else {
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "music";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 分享视频
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareVideo(final ReadableMap data, final Callback callback) {
|
||
// 初始化一个WXVideoObject，填写url
|
||
WXVideoObject video = new WXVideoObject();
|
||
video.videoUrl = data.hasKey("videoUrl") ? data.getString("videoUrl") : null;
|
||
video.videoLowBandUrl = data.hasKey("videoLowBandUrl") ? data.getString("videoLowBandUrl") : null;
|
||
//用 WXVideoObject 对象初始化一个 WXMediaMessage 对象
|
||
final WXMediaMessage msg = new WXMediaMessage(video);
|
||
msg.title = data.hasKey("title") ? data.getString("title") : null;
|
||
msg.description = data.hasKey("description") ? data.getString("description") : null;
|
||
|
||
if (data.hasKey("thumbImageUrl")) {
|
||
this._getImage(Uri.parse(data.getString("thumbImageUrl")), null, new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bmp) {
|
||
// 设置缩略图
|
||
if (bmp != null) {
|
||
msg.thumbData = bitmapResizeGetBytes(bmp, THUMB_SIZE);
|
||
}
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "video";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
});
|
||
} else {
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "video";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 分享网页
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareWebpage(final ReadableMap data, final Callback callback) {
|
||
// 初始化一个WXWebpageObject，填写url
|
||
WXWebpageObject webpage = new WXWebpageObject();
|
||
webpage.webpageUrl = data.hasKey("webpageUrl") ? data.getString("webpageUrl") : null;
|
||
|
||
//用 WXWebpageObject 对象初始化一个 WXMediaMessage 对象
|
||
final WXMediaMessage msg = new WXMediaMessage(webpage);
|
||
msg.title = data.hasKey("title") ? data.getString("title") : null;
|
||
msg.description = data.hasKey("description") ? data.getString("description") : null;
|
||
|
||
if (data.hasKey("thumbImageUrl")) {
|
||
this._getImage(Uri.parse(data.getString("thumbImageUrl")), null, new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bmp) {
|
||
// 设置缩略图
|
||
if (bmp != null) {
|
||
msg.thumbData = bitmapResizeGetBytes(bmp, THUMB_SIZE);
|
||
}
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "webpage";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
});
|
||
} else {
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "webpage";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 分享小程序
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void shareMiniProgram(final ReadableMap data, final Callback callback) {
|
||
WXMiniProgramObject miniProgramObj = new WXMiniProgramObject();
|
||
// 兼容低版本的网页链接
|
||
miniProgramObj.webpageUrl = data.hasKey("webpageUrl") ? data.getString("webpageUrl") : null;
|
||
// 正式版:0，测试版:1，体验版:2
|
||
miniProgramObj.miniprogramType = data.hasKey("miniProgramType") ? data.getInt("miniProgramType") : WXMiniProgramObject.MINIPTOGRAM_TYPE_RELEASE;
|
||
// 小程序原始id
|
||
miniProgramObj.userName = data.hasKey("userName") ? data.getString("userName") : null;
|
||
// 小程序页面路径；对于小游戏，可以只传入 query 部分，来实现传参效果，如：传入 "?foo=bar"
|
||
miniProgramObj.path = data.hasKey("path") ? data.getString("path") : null;
|
||
final WXMediaMessage msg = new WXMediaMessage(miniProgramObj);
|
||
// 小程序消息 title
|
||
msg.title = data.hasKey("title") ? data.getString("title") : null;
|
||
// 小程序消息 desc
|
||
msg.description = data.hasKey("description") ? data.getString("description") : null;
|
||
|
||
String thumbImageUrl = data.hasKey("hdImageUrl") ? data.getString("hdImageUrl") : data.hasKey("thumbImageUrl") ? data.getString("thumbImageUrl") : null;
|
||
|
||
if (thumbImageUrl != null && !thumbImageUrl.equals("")) {
|
||
this._getImage(Uri.parse(thumbImageUrl), null, new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bmp) {
|
||
// 小程序消息封面图片，小于128k
|
||
if (bmp != null) {
|
||
msg.thumbData = bitmapResizeGetBytes(bmp, 128);
|
||
}
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "miniProgram";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
});
|
||
} else {
|
||
// 构造一个Req
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.transaction = "miniProgram";
|
||
req.message = msg;
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
}
|
||
|
||
@ReactMethod
|
||
public void shareToTimeline(ReadableMap data, Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
_share(SendMessageToWX.Req.WXSceneTimeline, data, callback);
|
||
}
|
||
|
||
@ReactMethod
|
||
public void launchMiniProgram(ReadableMap data, Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
WXLaunchMiniProgram.Req req = new WXLaunchMiniProgram.Req();
|
||
// 填小程序原始id
|
||
req.userName = data.getString("userName");
|
||
//拉起小程序页面的可带参路径，不填默认拉起小程序首页
|
||
req.path = data.getString("path");
|
||
// 可选打开 开发版，体验版和正式版
|
||
req.miniprogramType = data.getInt("miniProgramType");
|
||
boolean success = api.sendReq(req);
|
||
if (!success) callback.invoke(INVALID_ARGUMENT);
|
||
}
|
||
|
||
/**
|
||
* 一次性订阅消息
|
||
*
|
||
* @param data
|
||
* @param callback
|
||
*/
|
||
@ReactMethod
|
||
public void subscribeMessage(ReadableMap data, Callback callback) {
|
||
SubscribeMessage.Req req = new SubscribeMessage.Req();
|
||
req.scene = data.hasKey("scene") ? data.getInt("scene") : SendMessageToWX.Req.WXSceneSession;
|
||
req.templateID = data.getString("templateId");
|
||
req.reserved = data.getString("reserved");
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
@ReactMethod
|
||
public void shareToSession(ReadableMap data, Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
_share(SendMessageToWX.Req.WXSceneSession, data, callback);
|
||
}
|
||
|
||
@ReactMethod
|
||
public void shareToFavorite(ReadableMap data, Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
_share(SendMessageToWX.Req.WXSceneFavorite, data, callback);
|
||
}
|
||
|
||
@ReactMethod
|
||
public void pay(ReadableMap data, Callback callback) {
|
||
PayReq payReq = new PayReq();
|
||
if (data.hasKey("partnerId")) {
|
||
payReq.partnerId = data.getString("partnerId");
|
||
}
|
||
if (data.hasKey("prepayId")) {
|
||
payReq.prepayId = data.getString("prepayId");
|
||
}
|
||
if (data.hasKey("nonceStr")) {
|
||
payReq.nonceStr = data.getString("nonceStr");
|
||
}
|
||
if (data.hasKey("timeStamp")) {
|
||
payReq.timeStamp = data.getString("timeStamp");
|
||
}
|
||
if (data.hasKey("sign")) {
|
||
payReq.sign = data.getString("sign");
|
||
}
|
||
if (data.hasKey("package")) {
|
||
payReq.packageValue = data.getString("package");
|
||
}
|
||
if (data.hasKey("extData")) {
|
||
payReq.extData = data.getString("extData");
|
||
}
|
||
payReq.appId = appId;
|
||
callback.invoke(api.sendReq(payReq) ? null : INVOKE_FAILED);
|
||
}
|
||
|
||
@ReactMethod
|
||
public void openCustomerServiceChat(String corpId, String kfUrl, Callback callback) {
|
||
if (api == null) {
|
||
callback.invoke(NOT_REGISTERED);
|
||
return;
|
||
}
|
||
// open customer service logic
|
||
WXOpenCustomerServiceChat.Req req = new WXOpenCustomerServiceChat.Req();
|
||
|
||
req.corpId = corpId;
|
||
req.url = kfUrl;
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
private void _share(final int scene, final ReadableMap data, final Callback callback) {
|
||
Uri uri = null;
|
||
if (data.hasKey("thumbImage")) {
|
||
String imageUrl = data.getString("thumbImage");
|
||
|
||
try {
|
||
uri = Uri.parse(imageUrl);
|
||
// Verify scheme is set, so that relative uri (used by static resources) are not handled.
|
||
if (uri.getScheme() == null) {
|
||
uri = getResourceDrawableUri(getReactApplicationContext(), imageUrl);
|
||
}
|
||
} catch (Exception e) {
|
||
// ignore malformed uri, then attempt to extract resource ID.
|
||
}
|
||
}
|
||
|
||
if (uri != null) {
|
||
this._getImage(uri, new ResizeOptions(100, 100), new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bitmap) {
|
||
WeChatLibModule.this._share(scene, data, bitmap, callback);
|
||
}
|
||
});
|
||
} else {
|
||
this._share(scene, data, null, callback);
|
||
}
|
||
}
|
||
|
||
private void _getImage(Uri uri, ResizeOptions resizeOptions, final ImageCallback imageCallback) {
|
||
BaseBitmapDataSubscriber dataSubscriber = new BaseBitmapDataSubscriber() {
|
||
@Override
|
||
protected void onNewResultImpl(Bitmap bitmap) {
|
||
if (bitmap != null) {
|
||
if (bitmap.getConfig() != null) {
|
||
bitmap = bitmap.copy(bitmap.getConfig(), true);
|
||
imageCallback.invoke(bitmap);
|
||
} else {
|
||
bitmap = bitmap.copy(Bitmap.Config.ARGB_8888, true);
|
||
imageCallback.invoke(bitmap);
|
||
}
|
||
} else {
|
||
imageCallback.invoke(null);
|
||
}
|
||
}
|
||
|
||
@Override
|
||
protected void onFailureImpl(DataSource<CloseableReference<CloseableImage>> dataSource) {
|
||
imageCallback.invoke(null);
|
||
}
|
||
};
|
||
|
||
ImageRequestBuilder builder = ImageRequestBuilder.newBuilderWithSource(uri);
|
||
if (resizeOptions != null) {
|
||
builder = builder.setResizeOptions(resizeOptions);
|
||
}
|
||
ImageRequest imageRequest = builder.build();
|
||
|
||
ImagePipeline imagePipeline = Fresco.getImagePipeline();
|
||
DataSource<CloseableReference<CloseableImage>> dataSource = imagePipeline.fetchDecodedImage(imageRequest, null);
|
||
dataSource.subscribe(dataSubscriber, UiThreadImmediateExecutorService.getInstance());
|
||
}
|
||
|
||
private static Uri getResourceDrawableUri(Context context, String name) {
|
||
if (name == null || name.isEmpty()) {
|
||
return null;
|
||
}
|
||
name = name.toLowerCase().replace("-", "_");
|
||
int resId = context.getResources().getIdentifier(
|
||
name,
|
||
"drawable",
|
||
context.getPackageName());
|
||
|
||
if (resId == 0) {
|
||
return null;
|
||
} else {
|
||
return new Uri.Builder()
|
||
.scheme(UriUtil.LOCAL_RESOURCE_SCHEME)
|
||
.path(String.valueOf(resId))
|
||
.build();
|
||
}
|
||
}
|
||
|
||
private void _share(final int scene, final ReadableMap data, final Bitmap thumbImage, final Callback callback) {
|
||
if (!data.hasKey("type")) {
|
||
callback.invoke(INVALID_ARGUMENT);
|
||
return;
|
||
}
|
||
String type = data.getString("type");
|
||
|
||
WXMediaMessage.IMediaObject mediaObject = null;
|
||
if (type.equals("news")) {
|
||
mediaObject = _jsonToWebpageMedia(data);
|
||
} else if (type.equals("text")) {
|
||
mediaObject = _jsonToTextMedia(data);
|
||
} else if (type.equals("imageUrl") || type.equals("imageResource")) {
|
||
__jsonToImageUrlMedia(data, new MediaObjectCallback() {
|
||
@Override
|
||
public void invoke(@Nullable WXMediaMessage.IMediaObject mediaObject) {
|
||
if (mediaObject == null) {
|
||
callback.invoke(INVALID_ARGUMENT);
|
||
} else {
|
||
WeChatLibModule.this._share(scene, data, thumbImage, mediaObject, callback);
|
||
}
|
||
}
|
||
});
|
||
return;
|
||
} else if (type.equals("imageFile")) {
|
||
__jsonToImageFileMedia(data, new MediaObjectCallback() {
|
||
@Override
|
||
public void invoke(@Nullable WXMediaMessage.IMediaObject mediaObject) {
|
||
if (mediaObject == null) {
|
||
callback.invoke(INVALID_ARGUMENT);
|
||
} else {
|
||
WeChatLibModule.this._share(scene, data, thumbImage, mediaObject, callback);
|
||
}
|
||
}
|
||
});
|
||
return;
|
||
} else if (type.equals("video")) {
|
||
mediaObject = __jsonToVideoMedia(data);
|
||
} else if (type.equals("audio")) {
|
||
mediaObject = __jsonToMusicMedia(data);
|
||
} else if (type.equals("file")) {
|
||
mediaObject = __jsonToFileMedia(data);
|
||
}
|
||
|
||
if (mediaObject == null) {
|
||
callback.invoke(INVALID_ARGUMENT);
|
||
} else {
|
||
_share(scene, data, thumbImage, mediaObject, callback);
|
||
}
|
||
}
|
||
|
||
private void _share(int scene, ReadableMap data, Bitmap thumbImage, WXMediaMessage.IMediaObject mediaObject, Callback callback) {
|
||
|
||
WXMediaMessage message = new WXMediaMessage();
|
||
message.mediaObject = mediaObject;
|
||
|
||
if (thumbImage != null) {
|
||
message.setThumbImage(thumbImage);
|
||
}
|
||
|
||
if (data.hasKey("title")) {
|
||
message.title = data.getString("title");
|
||
}
|
||
if (data.hasKey("description")) {
|
||
message.description = data.getString("description");
|
||
}
|
||
if (data.hasKey("mediaTagName")) {
|
||
message.mediaTagName = data.getString("mediaTagName");
|
||
}
|
||
if (data.hasKey("messageAction")) {
|
||
message.messageAction = data.getString("messageAction");
|
||
}
|
||
if (data.hasKey("messageExt")) {
|
||
message.messageExt = data.getString("messageExt");
|
||
}
|
||
|
||
SendMessageToWX.Req req = new SendMessageToWX.Req();
|
||
req.message = message;
|
||
req.scene = scene;
|
||
req.transaction = UUID.randomUUID().toString();
|
||
callback.invoke(null, api.sendReq(req));
|
||
}
|
||
|
||
private WXTextObject _jsonToTextMedia(ReadableMap data) {
|
||
if (!data.hasKey("description")) {
|
||
return null;
|
||
}
|
||
|
||
WXTextObject ret = new WXTextObject();
|
||
ret.text = data.getString("description");
|
||
return ret;
|
||
}
|
||
|
||
private WXWebpageObject _jsonToWebpageMedia(ReadableMap data) {
|
||
if (!data.hasKey("webpageUrl")) {
|
||
return null;
|
||
}
|
||
|
||
WXWebpageObject ret = new WXWebpageObject();
|
||
ret.webpageUrl = data.getString("webpageUrl");
|
||
if (data.hasKey("extInfo")) {
|
||
ret.extInfo = data.getString("extInfo");
|
||
}
|
||
return ret;
|
||
}
|
||
|
||
private void __jsonToImageMedia(String imageUrl, final MediaObjectCallback callback) {
|
||
Uri imageUri;
|
||
try {
|
||
imageUri = Uri.parse(imageUrl);
|
||
// Verify scheme is set, so that relative uri (used by static resources) are not handled.
|
||
if (imageUri.getScheme() == null) {
|
||
imageUri = getResourceDrawableUri(getReactApplicationContext(), imageUrl);
|
||
}
|
||
} catch (Exception e) {
|
||
imageUri = null;
|
||
}
|
||
|
||
if (imageUri == null) {
|
||
callback.invoke(null);
|
||
return;
|
||
}
|
||
|
||
this._getImage(imageUri, null, new ImageCallback() {
|
||
@Override
|
||
public void invoke(@Nullable Bitmap bitmap) {
|
||
callback.invoke(bitmap == null ? null : new WXImageObject(bitmap));
|
||
}
|
||
});
|
||
}
|
||
|
||
private void __jsonToImageUrlMedia(ReadableMap data, MediaObjectCallback callback) {
|
||
if (!data.hasKey("imageUrl")) {
|
||
callback.invoke(null);
|
||
return;
|
||
}
|
||
String imageUrl = data.getString("imageUrl");
|
||
__jsonToImageMedia(imageUrl, callback);
|
||
}
|
||
|
||
private void __jsonToImageFileMedia(ReadableMap data, MediaObjectCallback callback) {
|
||
if (!data.hasKey("imageUrl")) {
|
||
callback.invoke(null);
|
||
return;
|
||
}
|
||
|
||
String imageUrl = data.getString("imageUrl");
|
||
if (!imageUrl.toLowerCase().startsWith("file://")) {
|
||
imageUrl = "file://" + imageUrl;
|
||
}
|
||
__jsonToImageMedia(imageUrl, callback);
|
||
}
|
||
|
||
private WXMusicObject __jsonToMusicMedia(ReadableMap data) {
|
||
if (!data.hasKey("musicUrl")) {
|
||
return null;
|
||
}
|
||
|
||
WXMusicObject ret = new WXMusicObject();
|
||
ret.musicUrl = data.getString("musicUrl");
|
||
return ret;
|
||
}
|
||
|
||
private WXVideoObject __jsonToVideoMedia(ReadableMap data) {
|
||
if (!data.hasKey("videoUrl")) {
|
||
return null;
|
||
}
|
||
|
||
WXVideoObject ret = new WXVideoObject();
|
||
ret.videoUrl = data.getString("videoUrl");
|
||
return ret;
|
||
}
|
||
|
||
private WXFileObject __jsonToFileMedia(ReadableMap data) {
|
||
if (!data.hasKey("filePath")) {
|
||
return null;
|
||
}
|
||
return new WXFileObject(data.getString("filePath"));
|
||
}
|
||
|
||
// TODO: 实现sendRequest、sendSuccessResponse、sendErrorCommonResponse、sendErrorUserCancelResponse
|
||
|
||
@Override
|
||
public void onReq(BaseReq baseReq) {
|
||
WritableMap map = Arguments.createMap();
|
||
map.putString("openId", baseReq.openId);
|
||
map.putString("transaction", baseReq.transaction);
|
||
if (baseReq.getType() == ConstantsAPI.COMMAND_SHOWMESSAGE_FROM_WX) {
|
||
ShowMessageFromWX.Req req = (ShowMessageFromWX.Req) baseReq;
|
||
// 对应JsApi navigateBackApplication中的extraData字段数据
|
||
map.putString("type", "SendMessageToWX.Resp");
|
||
map.putString("lang", req.lang);
|
||
map.putString("country", req.message.messageExt);
|
||
}
|
||
this.getReactApplicationContext()
|
||
.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
|
||
.emit("WeChat_Resp", map);
|
||
}
|
||
|
||
@Override
|
||
public void onResp(BaseResp baseResp) {
|
||
WritableMap map = Arguments.createMap();
|
||
map.putInt("errCode", baseResp.errCode);
|
||
map.putString("errStr", baseResp.errStr);
|
||
map.putString("openId", baseResp.openId);
|
||
map.putString("transaction", baseResp.transaction);
|
||
|
||
if (baseResp instanceof SendAuth.Resp) {
|
||
SendAuth.Resp resp = (SendAuth.Resp) (baseResp);
|
||
|
||
map.putString("type", "SendAuth.Resp");
|
||
map.putString("code", resp.code);
|
||
map.putString("state", resp.state);
|
||
map.putString("url", resp.url);
|
||
map.putString("lang", resp.lang);
|
||
map.putString("country", resp.country);
|
||
} else if (baseResp instanceof SendMessageToWX.Resp) {
|
||
SendMessageToWX.Resp resp = (SendMessageToWX.Resp) (baseResp);
|
||
map.putString("type", "SendMessageToWX.Resp");
|
||
} else if (baseResp instanceof PayResp) {
|
||
PayResp resp = (PayResp) (baseResp);
|
||
map.putString("type", "PayReq.Resp");
|
||
map.putString("returnKey", resp.returnKey);
|
||
} else if (baseResp.getType() == ConstantsAPI.COMMAND_LAUNCH_WX_MINIPROGRAM) {
|
||
WXLaunchMiniProgram.Resp resp = (WXLaunchMiniProgram.Resp) baseResp;
|
||
// 对应JsApi navigateBackApplication中的extraData字段数据
|
||
String extraData = resp.extMsg;
|
||
map.putString("type", "WXLaunchMiniProgramReq.Resp");
|
||
map.putString("extraData", extraData);
|
||
map.putString("extMsg", extraData);
|
||
} else if (baseResp instanceof ChooseCardFromWXCardPackage.Resp) {
|
||
ChooseCardFromWXCardPackage.Resp resp = (ChooseCardFromWXCardPackage.Resp) baseResp;
|
||
map.putString("type", "WXChooseInvoiceResp.Resp");
|
||
map.putString("cardItemList", resp.cardItemList);
|
||
}
|
||
|
||
this.getReactApplicationContext()
|
||
.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
|
||
.emit("WeChat_Resp", map);
|
||
}
|
||
|
||
private interface ImageCallback {
|
||
void invoke(@Nullable Bitmap bitmap);
|
||
}
|
||
|
||
private interface MediaObjectCallback {
|
||
void invoke(@Nullable WXMediaMessage.IMediaObject mediaObject);
|
||
}
|
||
|
||
}
|