yutou/pdlivexp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
zlzw
2023-11-02 13:38:55 +08:00
parent d95df4b1a8
commit 43362d3800
17 changed files with 212 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
OneToOne/src/main/java/com/shayu/onetoone/manager/SendMessageManager.java
View File

@@ -5,6 +5,7 @@ import com.shayu.onetoone.bean.PurseBean;
import com.shayu.onetoone.bean.SendConsumeBean;
import com.shayu.onetoone.event.MoneyUpdateEvent;
import com.shayu.onetoone.listener.OnSendMessageListener;
import com.shayu.onetoone.utils.UserManager;
import com.yunbao.common.http.base.HttpCallback;
import com.yunbao.common.interfaces.OnItemClickListener;
import com.yunbao.common.utils.Bus;
@@ -127,6 +128,45 @@ public class SendMessageManager {
}
private static void send(SendData sendData, OnSendMessageListener messageListener) {
if(sendData.method.equals("before")){
OTONetManager.getInstance(null)
.sendMessageBefore(sendData.toUid,
sendData.type,
sendData.giftId,
sendData.content,
sendData.time,
sendData.online,
sendData.method,
new HttpCallback<SendConsumeBean>() {
@Override
public void onSuccess(SendConsumeBean consumeBean) {
if (consumeBean.getCode() != 0) {
if (consumeBean.getCode() == 503 || consumeBean.getCode()==500) {
messageListener.onError(OnSendMessageListener.STATUS_NOT_PRICE, consumeBean.getMsg(), consumeBean);
} else {
messageListener.onError(OnSendMessageListener.STATUS_ERROR, consumeBean.getMsg(), consumeBean);
}
} else {
String token = null;
if (sendData.needToken) {
token = UUID.randomUUID().toString();
cache.put(token, sendData);
}
messageListener.onSuccess(token, consumeBean);
}
}
@Override
public void onError(String error) {
messageListener.onError(OnSendMessageListener.STATUS_ERROR, error);
}
}
);
return;
}
OTONetManager.getInstance(null)
.sendMessage(sendData.toUid,
sendData.type,
@@ -139,6 +179,7 @@ public class SendMessageManager {
@Override
public void onSuccess(SendConsumeBean consumeBean) {
if (consumeBean.getCode() != 0) {
UserManager.saveMoney(consumeBean.getMoney());
if (consumeBean.getCode() == 503 || consumeBean.getCode()==500) {
messageListener.onError(OnSendMessageListener.STATUS_NOT_PRICE, consumeBean.getMsg(), consumeBean);
} else {
@@ -179,6 +220,7 @@ public class SendMessageManager {
new HttpCallback<SendConsumeBean>() {
@Override
public void onSuccess(SendConsumeBean sd) {
UserManager.saveMoney(sd.getMoney());
if (sd.getCode() != 0) {
if (listener != null) {
listener.onSuccess(sd.getMsg(), sd);
@@ -189,8 +231,7 @@ public class SendMessageManager {
listener.onSuccess(null, sd);
}
}
iniPurse(null);
Bus.get().post(new MoneyUpdateEvent(MoneyUpdateEvent.TYPE_UPDATE,sd.getMoney()+""));
}
@Override