fengjingqi/Android-WaterProject
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first

Browse Source
This commit is contained in:
fengjignqi
2026-05-16 16:19:39 +08:00
commit 1b1575eb8a
1632 changed files with 242221 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
app/src/main/java/com/ckkj/water/plate/mvp/PlateContract.java Normal file
View File

@@ -0,0 +1,63 @@
package com.ckkj.water.plate.mvp;
import com.ckkj.water.base.IView;
import com.ckkj.water.network.BaseBean;
import com.ckkj.water.plate.entity.BaziResultBean;
import com.ckkj.water.plate.entity.BaziSaveSuccessEntity;
import com.ckkj.water.plate.entity.PaipanHistoryEntity;
import org.json.JSONObject;
import java.util.Map;
/**
* @author fengxiaoyang
* @date 2025/7/30
* @description TODO: 描述该类的作用
*/
public class PlateContract {
public interface CallBack<T> {
void success(T msg);
void fail(String msg);
}
public interface DataModel{
//保存八字排盘结果
void saveUserBirthInfo(JSONObject json, CallBack callBack);
//开始排盘
void startPaiPanByYfjApi(Map<String,Object> map , CallBack callBack);
//获取排盘结果
void getPaipanHistoryList(Map<String,Object> map, CallBack callBack);
//删除记录
void deleteRecordByID(Map<String,Object> map, CallBack callBack);
//根据八字排盘结果，ai 解析
void aiParseBaziResult(JSONObject json, CallBack callBack);
//发送消息给 AI
void sendMsgToAi(JSONObject json, AiStreamCallback callBack);
}
public interface AiStreamCallback {
void onMessage(String messageChunk); // 每次返回一段内容
void onError(String error);
void onComplete(String complateContent); // 结束
void onSessionReceived(String sessionId); // 新增：接收sessionId
void loginLost();
}
public interface PlateView extends IView {
//排盘成功
void getPaipanResult(BaziResultBean bean);
//保存八字成功
void saveBaziResultSuccess(BaziSaveSuccessEntity bean);
//历史记录
void getHistorySuccess(PaipanHistoryEntity entity);
//删除成功
void deletePaipanHistorySuccess(int pos);
// 新增流式回调方法
void onStreamMessageReceived(String messageChunk);
//完成
void onStreamComplete(String complateMsg);
//提交举报完成
void commitReportSuccess(BaseBean bean);
}
}

424
app/src/main/java/com/ckkj/water/plate/mvp/PlateImpl.java Normal file
View File

@@ -0,0 +1,424 @@
package com.ckkj.water.plate.mvp;
import static android.content.ContentValues.TAG;
import android.os.Handler;
import android.os.Looper;
import android.util.Log;
import com.ckkj.water.AppConfig;
import com.ckkj.water.network.BaseBean;
import com.ckkj.water.network.BaseYfjApiBean;
import com.ckkj.water.network.NetWorkManager;
import com.ckkj.water.plate.entity.BaziResultBean;
import com.ckkj.water.plate.entity.BaziSaveSuccessEntity;
import com.ckkj.water.plate.entity.PaipanHistoryEntity;
import org.json.JSONObject;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Map;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.annotations.NonNull;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.json.JSONException;
/**
* @author fengxiaoyang
* @date 2025/7/30
* @description TODO: 描述该类的作用
*/
public class PlateImpl implements PlateContract.DataModel{
/**
* 保存八字排盘记录
* @param json
* @param callBack
*/
@Override
public void saveUserBirthInfo(JSONObject json, PlateContract.CallBack callBack) {
try {
NetWorkManager.getRequest().startPaipan(NetWorkManager.getToken(), NetWorkManager.toRequestBody(json))
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<BaseBean<BaziSaveSuccessEntity>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onNext(@NonNull BaseBean<BaziSaveSuccessEntity> bean) {
if (bean.getCode() == 200) {
callBack.success(bean.getData());
} else {
callBack.fail(bean.getMessage());
}
}
@Override
public void onError(@NonNull Throwable e) {
callBack.fail(e.getMessage());
}
@Override
public void onComplete() {
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 排盘数据，调用三方 api
* @param map
* @param callBack
*/
@Override
public void startPaiPanByYfjApi(Map<String, Object> map, PlateContract.CallBack callBack) {
try {
// 使用getNoBaseUrlRequest()调用第三方API，因为API URL是完整的
NetWorkManager.getNoBaseUrlRequest().startPaipanByYfj(NetWorkManager.getToken(), map)
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<BaseYfjApiBean<BaziResultBean>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onNext(@NonNull BaseYfjApiBean<BaziResultBean> bean) {
if (bean.getErrcode() == 0) {
// 成功返回数据
callBack.success(bean.getData());
} else {
// API返回错误
callBack.fail(bean.getErrmsg());
}
}
@Override
public void onError(@NonNull Throwable e) {
callBack.fail(e.getMessage());
}
@Override
public void onComplete() {
}
});
} catch (Exception e) {
e.printStackTrace();
callBack.fail(e.getMessage());
}
}
/**
* 排盘历史记录
* @param map
* @param callBack
*/
@Override
public void getPaipanHistoryList(Map<String, Object> map, PlateContract.CallBack callBack) {
try {
NetWorkManager.getRequest().getPaipanHistoryList(NetWorkManager.getToken())
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<BaseBean<PaipanHistoryEntity>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onNext(@NonNull BaseBean<PaipanHistoryEntity> bean) {
if(bean.getCode() == 200){
callBack.success(bean.getData());
}else{
callBack.fail(bean.getMessage());
}
}
@Override
public void onError(@NonNull Throwable e) {
callBack.fail(e.getMessage());
}
@Override
public void onComplete() {
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 删除记录
* @param map
* @param callBack
*/
@Override
public void deleteRecordByID(Map<String, Object> map, PlateContract.CallBack callBack) {
try {
NetWorkManager.getRequest().deletePaipanRecordById(NetWorkManager.getToken(),map)
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<BaseBean>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onNext(@NonNull BaseBean bean) {
if(bean.getCode() == 200){
callBack.success(bean);
}else{
callBack.fail(bean.getMessage());
}
}
@Override
public void onError(@NonNull Throwable e) {
callBack.fail(e.getMessage());
}
@Override
public void onComplete() {
}
});
} catch (Exception e) {
throw new RuntimeException(e);
}
}
/**
* 八字排盘结果，AI 解析
* @param json
* @param callBack
*/
@Override
public void aiParseBaziResult(JSONObject json, PlateContract.CallBack callBack) {
try {
NetWorkManager.getRequest().aiParesBaziResult(NetWorkManager.getToken(), NetWorkManager.toRequestBody(json))
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<BaseBean>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onNext(@NonNull BaseBean bean) {
if (bean.getCode() == 200) {
callBack.success(bean.getData());
} else {
callBack.fail(bean.getMessage());
}
}
@Override
public void onError(@NonNull Throwable e) {
callBack.fail(e.getMessage());
}
@Override
public void onComplete() {
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* AI解盘
* @param json
* @param callBack
*/
private final OkHttpClient client = new OkHttpClient();
private Call currentCall = null; // 新增：保存当前请求的Call对象
private volatile boolean isRequestStopped = false; // 新增：标记是否已停止请求
@Override
public void sendMsgToAi(JSONObject json, PlateContract.AiStreamCallback callBack) {
try {
String finalUrl = AppConfig.BASE_URL + "mobile/paiPan/ai";
Log.d(TAG, "Request URL: " + finalUrl);
Request request = new Request.Builder()
.addHeader("Authorization", "Bearer " + AppConfig.USER_TOKEN)
.post(NetWorkManager.toRequestBody(json))
.url(finalUrl)
.build();
currentCall = client.newCall(request);
isRequestStopped = false;
currentCall.enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
if (isRequestStopped) return; // 如果已停止，不处理失败回调
new Handler(Looper.getMainLooper()).post(() -> {
if (callBack != null) callBack.onError(e.getMessage());
});
}
@Override
public void onResponse(Call call, Response response) {
if (isRequestStopped) return;
if (!response.isSuccessful()) {
new Handler(Looper.getMainLooper()).post(() -> {
if (callBack != null) callBack.onError("请求失败: " + response.code());
});
return;
}
InputStream inputStream = response.body().byteStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
try {
// 处理SSE流式数据
handleSSEStream(reader, callBack);
} catch (Exception e) {
new Handler(Looper.getMainLooper()).post(() -> {
if (callBack != null) callBack.onError("解析异常: " + e.getMessage());
});
} finally {
try {
reader.close();
response.close();
} catch (IOException ignored) {}
}
}
});
} catch (Exception e) {
new Handler(Looper.getMainLooper()).post(() -> {
if (callBack != null) callBack.onError("请求异常: " + e.getMessage());
});
}
}
/**
* 处理SSE流式数据
*/
private void handleSSEStream(BufferedReader reader, PlateContract.AiStreamCallback callBack) throws IOException {
String line;
StringBuilder currentEvent = new StringBuilder();
String currentEventType = null;
while ((line = reader.readLine()) != null && !isRequestStopped) {
if (line.trim().isEmpty()) {
// 空行表示一个事件结束，处理当前事件
if (currentEventType != null && currentEvent.length() > 0) {
processEvent(currentEventType, currentEvent.toString(), callBack);
currentEvent.setLength(0);
currentEventType = null;
}
} else if (line.startsWith("event:")) {
// 事件类型
currentEventType = line.substring(6).trim();
} else if (line.startsWith("data:")) {
// 事件数据
String data = line.substring(5).trim();
currentEvent.append(data);
}
}
// 处理最后一个事件
if (currentEventType != null && currentEvent.length() > 0) {
processEvent(currentEventType, currentEvent.toString(), callBack);
}
}
/**
* 处理单个事件
*/
private void processEvent(String eventType, String data, PlateContract.AiStreamCallback callBack) {
new Handler(Looper.getMainLooper()).post(() -> {
try {
switch (eventType) {
case "start":
// 开始事件，可以在这里做一些初始化
Log.d(TAG, "AI解盘开始: " + data);
break;
case "paiPanInfo":
// 排盘信息事件
Log.d(TAG, "排盘信息: " + data);
break;
case "api-info":
// API信息事件
Log.d(TAG, "API信息: " + data);
break;
case "chunk":
// 内容块事件，这是主要的文本内容
try {
JSONObject chunkData = new JSONObject(data);
String content = chunkData.optString("content", "");
boolean hasNewline = chunkData.optBoolean("hasNewline", false);
boolean isMarkdown = chunkData.optBoolean("isMarkdown", false);
// 发送内容块到回调
if (callBack != null && !content.isEmpty()) {
callBack.onMessage(content);
}
} catch (JSONException e) {
Log.e(TAG, "解析chunk数据失败: " + e.getMessage());
}
break;
case "request-id":
// 请求ID事件
Log.d(TAG, "请求ID: " + data);
break;
case "complete":
// 完成事件
Log.d(TAG, "AI解盘完成: " + data);
if (callBack != null) {
callBack.onComplete(data);
}
break;
default:
Log.d(TAG, "未知事件类型: " + eventType + ", 数据: " + data);
break;
}
} catch (Exception e) {
Log.e(TAG, "处理事件失败: " + e.getMessage());
}
});
}
/**
* 停止当前请求
*/
public void stopCurrentRequest() {
isRequestStopped = true;
if (currentCall != null && !currentCall.isCanceled()) {
currentCall.cancel();
currentCall = null;
}
}
}

228
app/src/main/java/com/ckkj/water/plate/mvp/PlatePresenter.java Normal file
View File

@@ -0,0 +1,228 @@
package com.ckkj.water.plate.mvp;
import com.ckkj.water.base.BasePresenter;
import com.ckkj.water.chat.mvp.IndexContract;
import com.ckkj.water.chat.mvp.IndexImpl;
import com.ckkj.water.fate.entity.CityDataEntity;
import com.ckkj.water.network.BaseBean;
import com.ckkj.water.plate.entity.BaziResultBean;
import com.ckkj.water.plate.entity.BaziSaveSuccessEntity;
import com.ckkj.water.plate.entity.PaipanHistoryEntity;
import org.json.JSONException;
import org.json.JSONObject;
import java.util.HashMap;
import java.util.Map;
/**
* @author fengxiaoyang
* @date 2025/7/30
* @description TODO: 描述该类的作用
*/
public class PlatePresenter extends BasePresenter<PlateContract.PlateView> {
private PlateImpl impl;
public PlatePresenter(PlateImpl impl) {
this.impl = impl;
}
/**
* 排盘，直接调用缘份居 Api
* @param map
*/
public void startPaiPan(Map<String, Object> map) {
impl.startPaiPanByYfjApi(map, new PlateContract.CallBack<BaziResultBean>() {
@Override
public void success(BaziResultBean entity) {
if(PlatePresenter.this.getView() != null){
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().getPaipanResult(entity);
}
}
}
@Override
public void fail(String msg) {
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().showError(msg);
}
}
});
}
/**
* 上传八字结果
*
* @param result
* @param cityData
* @param timeType
*/
public void uploadBaziResult(BaziResultBean result, CityDataEntity cityData, int timeType) {
try {
BaziResultBean.BaseInfoDTO baseInfoDTO = result.getBaseInfo();
BaziResultBean.DetailInfoDTO.SizhuInfoDTO sizhuInfoDTO = result.getDetailInfo().getSizhuInfo();
JSONObject json = new JSONObject();
json.put("name",baseInfoDTO.getName());
json.put("gender",baseInfoDTO.getSex().equals("乾造")? "0" : "1");
json.put("birthType",timeType == 2001 ? "1":"0");
json.put("yangLiBirthTime",baseInfoDTO.getGongli());
json.put("yinLiBirthTime",baseInfoDTO.getNongli());
json.put("birthPlace",cityData == null ? "北京市": cityData.getCityName());
json.put("province",cityData == null ? "北京市": cityData.getProvinceName());
json.put("city",cityData == null ? "北京": cityData.getCityName());
json.put("openSolarTime","2");
json.put("nianZhu",sizhuInfoDTO.getYear().getTg() + "," + sizhuInfoDTO.getYear().getDz());
json.put("yueZhu",sizhuInfoDTO.getMonth().getTg() + "," + sizhuInfoDTO.getMonth().getDz());
json.put("riZhu",sizhuInfoDTO.getDay().getTg() + "," + sizhuInfoDTO.getDay().getDz());
json.put("shiZhu",sizhuInfoDTO.getHour().getTg() + "," + sizhuInfoDTO.getHour().getDz());
impl.saveUserBirthInfo(json, new PlateContract.CallBack<BaziSaveSuccessEntity>() {
@Override
public void success(BaziSaveSuccessEntity bean) {
if(PlatePresenter.this.getView() != null){
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().saveBaziResultSuccess(bean);
}
}
}
@Override
public void fail(String msg) {
if(PlatePresenter.this.getView() != null){
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().showError(msg);
}
}
}
});
} catch (JSONException e) {
throw new RuntimeException(e);
}
}
/**
* 获取历史运势
* @param page
*/
public void getHistoryDatas(int page) {
Map<String, Object> map = new HashMap<>();
map.put("pageNum", page);
map.put("pageSize", 10);
impl.getPaipanHistoryList(map, new PlateContract.CallBack<PaipanHistoryEntity>() {
@Override
public void success(PaipanHistoryEntity entity) {
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().getHistorySuccess(entity);
}
}
@Override
public void fail(String msg) {
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().showError(msg);
}
}
});
}
/**
* 删除记录
* @param id
*/
public void deleteRecordByID(String id,int pos) {
Map<String, Object> map = new HashMap<>();
map.put("recordId", id);
impl.deleteRecordByID(map, new PlateContract.CallBack<BaseBean>() {
@Override
public void success(BaseBean bean) {
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().deletePaipanHistorySuccess(pos);
}
}
@Override
public void fail(String msg) {
if(PlatePresenter.this.getView() != null){
PlatePresenter.this.getView().showError(msg);
}
}
});
}
/**
* ai 分析八字
* @param mSaveEntity
*/
public void AiParseBaziResult(BaziSaveSuccessEntity mSaveEntity) {
try {
JSONObject json = new JSONObject();
json.put("resultId", mSaveEntity.getRecordId());
impl.sendMsgToAi(json, new PlateContract.AiStreamCallback() {
@Override
public void onMessage(String messageChunk) {
if (PlatePresenter.this.getView() != null) {
PlatePresenter.this.getView().onStreamMessageReceived(messageChunk);
}
}
@Override
public void onError(String error) {
if (PlatePresenter.this.getView() != null) {
PlatePresenter.this.getView().showError(error);
}
}
@Override
public void onComplete(String complateContent) {
if (PlatePresenter.this.getView() != null) {
PlatePresenter.this.getView().onStreamComplete(complateContent);
}
}
@Override
public void onSessionReceived(String sessionId) {
// 这个回调在当前场景下可能不需要，但保留接口一致性
// Log.d("PlatePresenter", "Session received: " + sessionId);
}
@Override
public void loginLost() {
if (PlatePresenter.this.getView() != null) {
// 处理登录失效的情况
// 这里可以根据需要跳转到登录页面
// Log.w("PlatePresenter", "Login lost");
}
}
});
} catch (JSONException e) {
throw new RuntimeException(e);
}
}
/**
* 举报
* @param reason
*/
public void commitReport(String reason) {
Map<String, Object> map = new HashMap<>();
map.put("content", reason);
new IndexImpl().commitReport(map, new IndexContract.CallBack<BaseBean>() {
@Override
public void success(BaseBean bean) {
if (PlatePresenter.this.getView() != null) {
PlatePresenter.this.getView().commitReportSuccess(bean);
}
}
@Override
public void fail(String msg) {
if (PlatePresenter.this.getView() != null) {
PlatePresenter.this.getView().showError(msg);
}
}
});
}
}