zhanghaochen / ParentControl

Browse Code »

Commit eb171a063423a83a29345307d36072dd70ac18d4

Authored by shixianjie 2025-08-04 16:28:14 +0800

1 parent 5c3224d448

Exists in master

大模型批改

Showing 10 changed files with 141 additions and 12 deletions Show diff stats

app/src/main/java/com/hjx/parent/JudgeActivity.java

Diff comments View file @eb171a0

 package com.hjx.parent;
 import android.annotation.SuppressLint;
 import android.graphics.Bitmap;
 import android.graphics.Rect;
 import android.os.Bundle;
+import android.util.Log;
 import com.bumptech.glide.Glide;
+import com.hjx.parent.api.JudgeRepository;
 import com.hjx.parent.databinding.ActivityJudgeBinding;
 import com.hjx.parent.databinding.LayoutJudgeRectBinding;
 import com.hjx.parent.rx.BaseRxActivity;
 import com.hjx.parent.utils.CutUtil;
 import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
+import io.reactivex.Observable;
 import io.reactivex.Single;
 import top.zibin.luban.Luban;
 public class JudgeActivity extends BaseRxActivity<ActivityJudgeBinding> {
     private Bitmap bitmap;
     private final List<JudgeCut> mList = new ArrayList<>();
     @SuppressLint("CheckResult")
     @Override
     public void initView(Bundle savedInstanceState) {
         binding.ivBack.setOnClickListener(v -> {
             onBackPressed();
         });
         String path = getIntent().getStringExtra("path");
         if (path == null) return;
         final ArrayList<Rect> rects = getIntent().getParcelableArrayListExtra("rects");
         if (rects == null) return;
         Single.just(path)
                 .map(origin -> Luban.with(this).load(origin).ignoreBy(300).get().get(0))
                 .map(file -> Glide.with(this).asBitmap().load(file).submit().get())
                 .compose(transformSingle())
                 .subscribe((bitmap, th) -> {
                     if (th != null) th.printStackTrace();
                     if (bitmap == null) return;
                     this.bitmap = bitmap;
                     binding.ivPic.setImageBitmap(bitmap);
                     CutUtil.onLayoutReady(binding.ivPic, v -> {
                         prepareRects(rects);
                     });
                 });
     }
     private void prepareRects(List<Rect> rects) {
         mList.clear();
         binding.flRects.removeAllViews();
         float[] measuredSize = CutUtil.measureBitmap(binding.ivPic, bitmap);
         for (int i = 0; i < rects.size(); i++) {
             Rect it = rects.get(i);
             Bitmap bitmap = CutUtil.cut(this.bitmap, it.left, it.top, it.width(), it.height(), this);
             Rect rect = measureRect(it, measuredSize);
             LayoutJudgeRectBinding vb = showRect(rect);
             mList.add(new JudgeCut(i, bitmap, rect, vb));
         }
+        judge();
+    }
+    @SuppressLint("CheckResult")
+    private void judge() {
+        showLoadingDialog("");
+        Observable.fromIterable(mList)
+                .map(it -> {
+                    if (it.url != null && !it.url.isEmpty()) return it;
+                    String base64 = CutUtil.bitmapToBase64(it.bitmap, true);
+                    it.url = base64;
+                    return it;
+                })
+                .flatMap(it -> JudgeRepository.singleJudge(it.url)
+                        .map(result -> {
+                            it.correctResult = result;
+                            return it;
+                        })
+                        .toObservable()
+                )
+                .compose(transform())
+                .subscribe(it -> {
+                    if (it.correctResult == 1) {
+                        it.vb.ivResult.setImageResource(R.drawable.png_ic_judge_correct);
+                        it.vb.getRoot().setSelected(false);
+                    } else if (it.correctResult == 2) {
+                        it.vb.ivResult.setImageResource(R.drawable.png_ic_judge_wrong);
+                        it.vb.getRoot().setSelected(true);
+                    }
+                }, th -> {
+                    cancelLoadingDialog();
+                    Log.e(getClass().getName(), "", th);
+                }, this::cancelLoadingDialog)
+        ;
     }
     private LayoutJudgeRectBinding showRect(Rect rect) {
         LayoutJudgeRectBinding vb = LayoutJudgeRectBinding.inflate(getLayoutInflater(), binding.flRects, false);
         vb.getRoot().setMinimumWidth(rect.width());
         vb.getRoot().setMinimumHeight(rect.height());
         vb.getRoot().setTranslationX((float) rect.left);
         vb.getRoot().setTranslationY((float) rect.top);
         vb.getRoot().setOnClickListener(v -> {
             v.setSelected(!v.isSelected());
             checkCount();
         });
         binding.flRects.addView(vb.getRoot());
         return vb;
     }
     private void checkCount() {
         //
     }
     /** bitmapRect 转换为 viewRect */
     private Rect measureRect(Rect rect, float[] measuredSize) {
         float realW = measuredSize[0];
         float realH = measuredSize[1];
         float offsetX = measuredSize[2];
         float offsetY = measuredSize[3];
         float percentX = realW / bitmap.getWidth();
         float percentY = realH / bitmap.getHeight();
         float left = rect.left * percentX + offsetX;
         float right = rect.right * percentX + offsetX;
         float top = rect.top * percentY + offsetY;
         float bottom = rect.bottom * percentY + offsetY;
         return new Rect((int) left, (int) top, (int) right, (int) bottom);
     }
     @Override
     protected ActivityJudgeBinding getViewBinding() {
         return ActivityJudgeBinding.inflate(getLayoutInflater());
     }
     static class JudgeCut {
         final int index;
         final Bitmap bitmap;
         final Rect rect;
         final LayoutJudgeRectBinding vb;
+        String url;
         int correctResult = 0;
         public JudgeCut(int index, Bitmap bitmap, Rect rect, LayoutJudgeRectBinding vb) {
             this.index = index;
             this.bitmap = bitmap;
             this.rect = rect;
             this.vb = vb;
         }
     }
 }

app/src/main/java/com/hjx/parent/api/ChatApi.java

Diff comments View file @eb171a0

 package com.hjx.parent.api;
+import io.reactivex.Single;
+import retrofit2.http.Body;
 import retrofit2.http.Header;
 import retrofit2.http.POST;
 import retrofit2.http.Url;
 public interface ChatApi {
     @POST
-    void aiChat(@Url String url, @Header("Authorization") String token);
+    Single<ChatResponse> aiChat(
+        @Url String url,
+        @Header("Authorization") String token,
+        @Body ChatRequest body
+    );
 }

app/src/main/java/com/hjx/parent/api/ChatMessage.java

Diff comments View file @eb171a0

 package com.hjx.parent.api;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
 public class ChatMessage {
     public ChatMessage() {
     }
     public ChatMessage(String role, Object content) {
         this.role = role;
         this.content = content;
     }
     public String role;
     public Object content;
     public static ChatMessage fromImage(String role, String text, String... urls) {
         List<ContentItem> items = new ArrayList<>();
         if (text != null && !text.isEmpty()) {
             items.add(new ContentItem(ContentItem.TYPE_TEXT, text));
         }
         for (String it: urls) {
-            items.add(new ContentItem(ContentItem.TYPE_IMAGE, it));
+            ContentItem.ContentImage image = new ContentItem.ContentImage(it);
+            items.add(new ContentItem(ContentItem.TYPE_IMAGE, image));
         }
         return new ChatMessage(role, items);
     }
     public String getTextContent() {
         if (content == null) return null;
         if (content instanceof String) return (String) content;
         ContentItem item = firstText();
         return item == null ? null : item.text;
     }
     private ContentItem firstText() {
         if (!(content instanceof List<?>)) return null;
         List<?> anyList = (List<?>) content;
         return anyList.stream()
                 .map(ContentItem::reSerialize)
                 .filter(Objects::nonNull)
                 .findFirst().orElse(null);
     }
 }

app/src/main/java/com/hjx/parent/api/ChatRequest.java

Diff comments View file @eb171a0

 package com.hjx.parent.api;
 import java.util.List;
 public class ChatRequest {
     public String model;
     public List<ChatMessage> messages;
     public boolean stream;
+    public ChatRequest(String model, List<ChatMessage> messages) {
+        this.model = model;
+        this.messages = messages;
+        this.stream = false;
+    }
 }

app/src/main/java/com/hjx/parent/api/ContentItem.java

Diff comments View file @eb171a0

 package com.hjx.parent.api;
 import com.google.gson.Gson;
 import com.google.gson.annotations.SerializedName;
 public class ContentItem {
     public static final String TYPE_TEXT = "text";
     public static final String TYPE_IMAGE = "image_url";
     public ContentItem() {
     }
     public ContentItem(String type, String text) {
         this.type = type;
         this.text = text;
     }
     public ContentItem(String type, ContentImage imageUrl) {
         this.type = type;
         this.imageUrl = imageUrl;
     }
     public String type;
     public String text;
     @SerializedName("image_url")
     public ContentImage imageUrl;
     public static class ContentImage {
+        public ContentImage(String url) {
+            this.url = url;
+        }
         public String url;
     }
     private static final Gson gson = new Gson();
     static ContentItem reSerialize(Object any) {
         if (any == null) return null;
         try {
             String json = gson.toJson(any);
             ContentItem it = gson.fromJson(json, ContentItem.class);
             return it;
         } catch (Throwable t) {
             t.printStackTrace();
         }
         return null;
     }
 }

app/src/main/java/com/hjx/parent/api/JudgeRepository.java

Diff comments View file @eb171a0

File was created	1	package com.hjx.parent.api;
	2
	3	import android.annotation.SuppressLint;
	4
	5	import com.google.gson.Gson;
	6	import com.prws.common.net.NetWorks;
	7
	8	import java.util.ArrayList;
	9	import java.util.List;
	10
	11	import io.reactivex.Single;
	12	import retrofit2.Retrofit;
	13
	14	public class JudgeRepository {
	15	private static final Gson gson = new Gson();
	16	private static final ChatApi api;
	17	static {
	18	Retrofit retrofit = NetWorks.retrofit;
	19	api = retrofit.create(ChatApi.class);
	20	}
	21
	22
	23	public static Single<Integer> singleJudge(String url) {
	24	List<ChatMessage> messages = new ArrayList<>();
	25	messages.add(ChatMessage.fromImage("system", setting, url));
	26
	27	return api.aiChat(JudgeRepository.url, token, new ChatRequest(model, messages))
	28	.map(response -> {
	29	if (response.choices == null) return null;
	30	return response.choices.stream().findFirst()
	31	.map(it -> it.message)
	32	.map(ChatMessage::getTextContent)
	33	.orElse(null);
	34	})
	35	.map(json -> {
	36	JudgeResult result = gson.fromJson(json, JudgeResult.class);
	37	return result.result;
	38	})
	39	;
	40	}
	41
	42
	43	private static final String model = "doubao-1-5-thinking-vision-pro-250428";
	44	private static final String url = "https://ark.cn-beijing.volces.com/api/v3/chat/completions";
	45	private static final String token = "Bearer a877087e-bb74-471b-8f2a-01e6b2220699";
	46	private static final String setting =
	47	"批改图片中的题目, 判断作答是否正确，并以Json格式返回结果，需要包含以下字段: \n" +
	48	"result(批改结果, 枚举 0:不确定; 1:正确; 2:错误; 3:未作答).\n" +
	49	"Json示例(供参考，无需复制)： {\"result\": 1}\n" +
	50	"一个图片中一般只会有一个题目, 返回一个结果即可.";
	51
	52	private static class JudgeResult {
	53	public int result;
	54	}
	55	}
	56

app/src/main/java/com/hjx/parent/utils/CutUtil.java

Diff comments View file @eb171a0

 package com.hjx.parent.utils;
 import android.content.Context;
 import android.graphics.Bitmap;
 import android.graphics.Canvas;
 import android.graphics.Color;
 import android.graphics.Paint;
+import android.util.Base64;
 import android.view.View;
 import android.view.ViewTreeObserver;
 import com.bumptech.glide.Glide;
 import com.bumptech.glide.load.engine.bitmap_recycle.BitmapPool;
 import com.hjx.parent.function.Function1;
+import java.io.ByteArrayOutputStream;
 public class CutUtil {
     public static float[] measureBitmap(View view, Bitmap bitmap) {
         float realW;
         float realH;
         float offsetX;
         float offsetY;
         float vp = 1f * view.getWidth() / view.getHeight();
         float bp = 1f * bitmap.getWidth() / bitmap.getHeight();
         if (vp > bp) {
             realW = view.getHeight() * bp;
             realH = (float) view.getHeight();
             offsetY = 0f;
             offsetX = (view.getWidth() - realW) * 0.5f;
         } else if (vp < bp) {
             realW = (float) view.getWidth();
             realH = view.getWidth() * (1f / bp);
             offsetX = 0f;
             offsetY = (view.getHeight() - realH) * 0.5f;
         } else {
             realW = (float) view.getWidth();
             realH = (float) view.getHeight();
             offsetX = 0f;
             offsetY = 0f;
         }
         return new float[]{realW, realH, offsetX, offsetY};
     }
     public static Bitmap cut(Bitmap source, float x, float y, int w, int h, Context context) {
         // 获取 Glide 的 BitmapPool
         BitmapPool bitmapPool = Glide.get(context).getBitmapPool();
         // 从 BitmapPool 中获取可复用的 Bitmap
         Bitmap result = bitmapPool.get(w, h, source.getConfig() != null ? source.getConfig() : Bitmap.Config.ARGB_8888);
         // 填充白色背景
         result.eraseColor(Color.WHITE);
         // 创建画布并绘制
         Canvas canvas = new Canvas(result);
         Paint paint = new Paint();
         canvas.drawBitmap(source, -x, -y, paint);
         return result;
     }
     public static void onLayoutReady(final View view, final Function1<View> action) {
         view.getViewTreeObserver().addOnGlobalLayoutListener(
                 new ViewTreeObserver.OnGlobalLayoutListener() {
                     @Override
                     public void onGlobalLayout() {
                         view.getViewTreeObserver().removeOnGlobalLayoutListener(this);
                         action.invoke(view);
                     }
                 }
         );
     }
+    public static byte[] bitmapToByteArray(Bitmap bitmap) {
+        ByteArrayOutputStream output = new ByteArrayOutputStream();
+        bitmap.compress(Bitmap.CompressFormat.JPEG, 100, output);
+        return output.toByteArray();
+    }
+    public static String bitmapToBase64(Bitmap bitmap, Boolean usePrefix) {
+        String base64 = Base64.encodeToString(bitmapToByteArray(bitmap), Base64.NO_WRAP);
+        if (usePrefix) return "data:image/jpeg;base64," + base64;
+        else return base64;
+    }
 }

app/src/main/res/drawable/png_ic_judge_wrong.png

Diff comments View file @eb171a0

1.12 KB

libs/common/src/main/java/com/prws/common/net/NetWorks.java

Diff comments View file @eb171a0

 package com.prws.common.net;
 import com.google.gson.Gson;
 import com.google.gson.JsonObject;
 import com.prws.common.BuildConfig;
 import com.prws.common.bean.CutPicBean;
 import com.prws.common.bean.GradeAndSubject;
 import com.prws.common.bean.PageInfo;
 import com.prws.common.bean.ResponseResult;
 import com.prws.common.bean.ScheduleBean;
 import com.prws.common.bean.Student;
 import com.prws.common.bean.Teacher;
 import com.prws.common.bean.TopicBean;
 import com.prws.common.bean.UpdateBean;
 import com.prws.common.bean.User;
 import com.prws.common.bean.baidu.BaiduInput;
 import com.prws.common.bean.homework.HomeWork;
 import com.prws.common.bean.homework.HomeworkDetail;
 import com.prws.common.bean.homework.HomeworkList;
 import com.prws.common.bean.homework.StDetail;
 import com.prws.common.utils.BitmapUtils;
 import com.prws.common.utils.SharedPreferencesUtil;
 import java.io.File;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import io.reactivex.Observable;
 import io.reactivex.Observer;
 import io.reactivex.Single;
 import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.schedulers.Schedulers;
 import okhttp3.MediaType;
 import okhttp3.MultipartBody;
 import okhttp3.RequestBody;
 import okhttp3.ResponseBody;
 import retrofit2.Call;
 import retrofit2.Callback;
+import retrofit2.Retrofit;
 import retrofit2.http.Body;
 import retrofit2.http.GET;
 import retrofit2.http.Header;
 import retrofit2.http.Headers;
 import retrofit2.http.Multipart;
 import retrofit2.http.POST;
 import retrofit2.http.PUT;
 import retrofit2.http.Part;
 import retrofit2.http.PartMap;
 import retrofit2.http.Query;
 import retrofit2.http.Url;
 /**
  * 类名称：NetWorks
  * 创建人：
  * <p>
  * 类描述：网络请求的操作类
  */
 public class NetWorks extends RetrofitUtils {
     //服务器路径
-    public static final NetService service_url = getMachineRetrofit(BuildConfig.SERVER_URL).create(NetService.class);
+    public static final Retrofit retrofit = getMachineRetrofit(BuildConfig.SERVER_URL);
+    public static final NetService service_url = retrofit.create(NetService.class);
     //设缓存有效期为1天
     protected static final long CACHE_STALE_SEC = 60 * 60 * 24 * 1;
     //查询缓存的Cache-Control设置，使用缓存
     protected static final String CACHE_CONTROL_CACHE = "only-if-cached, max-stale=" + CACHE_STALE_SEC;
     //查询网络的Cache-Control设置。不使用缓存
     protected static final String CACHE_CONTROL_NETWORK = "max-age=0";
     public interface NetService {
         @GET("/api/v1/user/logout")
         Observable<ResponseBody> logout();
         @Multipart
         @POST("/api/v1/user/upLoadAvatar")
         Observable<ResponseBody> upLoadAvatar(@Header("Authorization") String token, @Part List<MultipartBody.Part> partLis);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/user/editUser")
         Observable<ResponseBody> editUser(@Header("Authorization") String token, @Body RequestBody body);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/user/changePassword")
         Observable<ResponseBody> changePassword(@Header("Authorization") String token, @Body RequestBody body);
         @GET("/api/v1/user/searchById")
         Observable<ResponseBody> searchById(@Header("Authorization") String token, @Query("userId") String userId);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/login/userLogin")
         Observable<ResponseBody> login(@Body RequestBody body);
         @GET("/api/v1/resource/listGradeAndSubject")
         Observable<ResponseResult<List<GradeAndSubject>>> listGradeAndSubject(@Header("Authorization") String token);
         @GET("/api/v1/manager/generalQrCode")
         Observable<ResponseBody> generalQrCode();
         @GET("/api/v1/parent/scanAndLogin")
         Observable<ResponseBody> scanAndLogin(@Header("Authorization") String token, @Query("code") String code, @Query("stuId") String stuId);
         @GET("/api/v1/parent/getChildrenList")
         Observable<ResponseBody> getChildrenList(@Header("Authorization") String token);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/parent/registerParent")
         Observable<ResponseBody> registerParent(@Body RequestBody body);
         @GET("/api/v1/parent/listChildren")
         Observable<ResponseBody> listChildren(@Header("Authorization") String token);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/parent/registerStudent")
         Observable<ResponseBody> registerStudent(@Header("Authorization") String token, @Body RequestBody body);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/parent/bindTeacher")
         Observable<ResponseBody> bindTeacher(@Header("Authorization") String token, @Body RequestBody body);
         @Multipart
         @POST("/api/v1/user/upLoadAvatar")
         Observable<ResponseResult<Map<String, String>>> uploadAvatar(@Header("Authorization") String token, @Part() MultipartBody.Part file);
         @Multipart
         @POST("/api/v1/student/editStudentAvatar")
         Observable<ResponseResult<Map<String, String>>> uploadAvatar(@Header("Authorization") String token, @Part() MultipartBody.Part file, @PartMap Map<String, Object> map);
         @Headers("Content-Type: application/json")
         @POST("/api/v1/parent/editChild")
         Observable<ResponseResult> editStudent(@Header("Authorization") String token, @Body RequestBody body);
         @GET("/api/v1/student/getStudyPlanForThisWeek")
         Observable<ResponseResult<ScheduleBean>> getWeekPlan(@Header("Authorization") String token, @Query("stuId") String stuId);
         @GET("api/v1/parent/searchTeacher")
         Observable<ResponseResult<Teacher>> searchTeacher(@Header("Authorization") String token, @Query("phone") String phone);
         @POST("api/v1/question/listErrorBook")
         Observable<ResponseResult<PageInfo<TopicBean>>> getError(@Header("Authorization") String token, @Body Map<String, Object> body);
         @POST
         Observable<JsonObject> removeWriting(@Url String url, @Body RequestBody body);
         @POST
         Observable<CutPicBean> cut(@Url String url, @Body RequestBody body);
         @POST
         Observable<JsonObject> getBaiduToken(@Url String url);
         @Multipart
         @POST("api/v1/pad/addErrorBook")
         Observable<ResponseResult> addError(@Part() MultipartBody.Part file, @PartMap Map<String, Object> map);
         @POST("api/v1/pad/deleteStuErrorBook")
         Observable<ResponseResult> deleteError(@Header("Authorization") String token, @Body List<String> map);
         @PUT("api/v1/pad/updateStuErrorBookInfo")
         Observable<ResponseResult> updateError(@Header("Authorization") String token, @Body List<HashMap<String, Object>> map);
         @POST("api/v1/question/editErrorBook")
         Observable<ResponseResult> editError(@Header("Authorization") String Authorization, @Body Map<String, Object> map);
         @GET("api/v1/resource/checkUpdate")
         Call<ResponseResult<UpdateBean>> checkUpdate(@Query("version") int version, @Query("packageName") String packageName, @Query("type") int type);
         @GET("api/v1/teacher/getStudentList")
         Observable<ResponseBody> getStudentList(@Header("Authorization") String token, @Query("userId") String id);
         @GET("api/v1/teacher/getStudentList")
         Single<ResponseResult<List<Student>>> getStudentList2(@Header("Authorization") String token, @Query("userId") String id);
         @GET("api/v1/answer/listRecordForTeacher")
         Observable<ResponseBody> getRecordList(@Header("Authorization") String token, @Query("userId") String id);
         @GET("api/v1/homework/listHomeworkByStuId")
         Single<ResponseResult<List<HomeworkList>>> getStudentHomework(@Header("Authorization") String token, @Query("stuId") String stuId);
         @POST
         Single<BaiduInput> inputImage(@Url String url, @Body RequestBody body);
         @Multipart
         @POST("api/v1/homework/uploadHomework")
         Single<ResponseResult> uploadImage(@Header("Authorization") String token, @Part() MultipartBody.Part file, @Query("brief") String id);
         @POST("api/v1/homework/uploadHomeworkAction")
         Single<ResponseResult> uploadHomework(@Header("Authorization") String token, @Body Object map);
         @GET("api/v1/homework/removeHomework")
         Single<ResponseResult<Boolean>> deleteHomework(
                 @Header("Authorization") String token,
                 @Query("homeworkId") String homeworkId
         );
         @GET("api/v1/homework/listHomeworkById")
         Single<ResponseResult<List<HomeWork>>> getHomeworkDetail(@Header("Authorization") String token, @Query("homeworkId") String homeworkId);
         @POST("api/v1/homework/uploadHomeworkFeedback")
         Single<ResponseResult> uploadHomeworkFeedback(@Header("Authorization") String token, @Body Map<String, Object> map);
         @POST("api/v1/homework/editHomeworkInfo")
         Single<ResponseResult<Boolean>> editHomework(
                 @Header("Authorization") String token,
                 @Body Object body
         );
         @GET("api/v1/homework/listHomeworkDetailByStuId")
         Single<ResponseResult<HomeworkDetail>> getHomeworkCompleteDetail(
                 @Header("Authorization") String token,
                 @Query("stuId") String stuId,
                 @Query("homeworkId") String homeworkId,
                 // type 固定传true
                 @Query("type") boolean type
         );
         @GET("api/v1/homework/listHomeworkStatistics")
         Single<ResponseResult<List<StDetail>>> getHuyouList(
                 @Header("Authorization") String token,
                 @Query("stuId") String stuId,
                 @Query("type") int type //0: 周报, 1:阶段总结
         );
         @GET("api/v1/homework/listHomeworkStatisticsDetailForStudent")
         Single<ResponseResult<StDetail>> getHuyouDetail(
                 @Header("Authorization") String token,
                 @Query("homeworkStatisticsId") String homeworkId
         );
         @GET("api/v1/demo/generalStatisticsHomework")
         Single<ResponseResult<Object>> generalHuyou();
         @POST("api/v1/homework/generalHomeworkStageStatistics")
         Single<ResponseResult<Boolean>> generalStageHuyou(
                 @Header("Authorization") String token,
                 @Body Object body
         );
         @GET("api/v1/homework/removeHomeworkStatistics")
         Single<ResponseResult<Boolean>> deleteHuyou(
                 @Header("Authorization") String token,
                 @Query("homeworkStatisticsId") String homeworkId
         );
         @GET("api/v1/login/smsCode")
         Single<ResponseResult<String>> smsCode(@Query("mobile") String mobile);
         @POST("api/v1/login/smsLogin")
         Single<ResponseResult<User>> smsLogin(@Body Object body);
     }
     public static String getUserId() {
         return (String) SharedPreferencesUtil.getData("userId", "");
     }
     public static String getHeader() {
         return (String) SharedPreferencesUtil.getData("token", "");
     }
     public static String getBaiduToken() {
         return (String) SharedPreferencesUtil.getData("baiduToken", "");
     }
     public static Single<BaiduInput> inputImage(String filePath, String id) {
         MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
         String base64 = BitmapUtils.fileToBase64(filePath);
         File file = new File(filePath);
         RequestBody body = RequestBody.create(mediaType, "image=" + base64 + "&brief={\"name\":\"" + file.getName() + "\", \"id\":\"" + id + "\"}");
         return getBaiduTokenOcr().map(jsonObject -> jsonObject.get("access_token").getAsString())
                 .flatMap(token -> {
                     return service_url.inputImage("https://aip.baidubce.com/rest/2.0/realtime_search/same_hq/add?access_token=" + token, body);
                 });
     }
     public static Single<ResponseResult> uploadImage(String path, String id) {
         File file = new File(path);
         RequestBody requestBody = RequestBody.create(MediaType.parse("image/jpg"), file);
         MultipartBody.Part part = MultipartBody.Part.createFormData("file", file.getName(), requestBody);
         return service_url.uploadImage(getHeader(), part, id);
     }
     public static void checkUpdate(int code, String packageName, Callback<ResponseResult<UpdateBean>> callback) {
         service_url.checkUpdate(code, packageName, 0).enqueue(callback);
     }
     public static void addError(String path, Map<String, String> param, Observer<ResponseResult> observer) {
         File file = new File(path);
         RequestBody requestBody = RequestBody.create(MediaType.parse("image/jpg"), file);
         MultipartBody.Part part = MultipartBody.Part.createFormData("file", file.getName(), requestBody);
         Map<String, Object> map = new HashMap<>();
         map.put("condition", param);
         setSubscribe(service_url.addError(part, map), observer);
     }
     public static void cut(String base64, Observer<CutPicBean> observer) {
         MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
         RequestBody body = RequestBody.create(mediaType, "image=" + base64 + "&detect_direction=true");
         setSubscribe(service_url.cut("https://aip.baidubce.com/rest/2.0/ocr/v1/paper_cut_edu?access_token=" + getBaiduToken(), body), observer);
     }
     public static void editError(Map<String, Object> map, Observer<ResponseResult> observer) {
         setSubscribe(service_url.editError(getHeader(), map), observer);
     }
     public static void editError(List<HashMap<String, Object>> map, Observer<ResponseResult> observer) {
         setSubscribe(service_url.updateError(getHeader(), map), observer);
     }
     public static void deleteError(List<String> map, Observer<ResponseResult> observer) {
         setSubscribe(service_url.deleteError(getHeader(), map), observer);
     }
     public static void getBaiduToken(Observer<JsonObject> observer) {
         setSubscribe(service_url.getBaiduToken("https://aip.baidubce.com/oauth/2.0/token?grant_type=client_credentials&client_id=" + BuildConfig.APIKey + "&client_secret=" + BuildConfig.SecretKey), observer);
     }
     public static Single<JsonObject> getBaiduTokenOcr() {
         return service_url.getBaiduToken("https://aip.baidubce.com/oauth/2.0/token?grant_type=client_credentials&client_id=" + BuildConfig.APIKey1 + "&client_secret=" + BuildConfig.SecretKey1).firstOrError();
     }
     public static void removeWriting(String base64, Observer<JsonObject> observer) {
         MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
         RequestBody body = RequestBody.create(mediaType, "image=" + base64);
         setSubscribe(service_url.removeWriting(("https://aip.baidubce.com/rest/2.0/ocr/v1/remove_handwriting?access_token=" + getBaiduToken()), body), observer);
     }
     public static void searchTeacher(String phone, Observer<ResponseResult<Teacher>> observer) {
         setSubscribe(service_url.searchTeacher(getHeader(), phone), observer);
     }
     public static void logout(Observer<ResponseBody> observer) {
         setSubscribe(service_url.logout(), observer);
     }
     public static void editStudent(RequestBody body, Observer<ResponseResult> observable) {
         setSubscribe(service_url.editStudent(getHeader(), body), observable);
     }
     public static void getWeekPlan(String id, Observer<ResponseResult<ScheduleBean>> observer) {
         setSubscribe(service_url.getWeekPlan(getHeader(), id), observer);
     }
     public static void uploadStudentAvatar(File file, String stuId, Observer<ResponseResult<Map<String, String>>> observer) {
         RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file);
         MultipartBody.Part part = MultipartBody.Part.createFormData("file", file.getName(), requestBody);
         Map<String, Object> map = new HashMap<>();
         map.put("stuId", stuId);
         setSubscribe(service_url.uploadAvatar(getHeader(), part, map), observer);
     }
     public static void uploadAvatar(File file, Observer<ResponseResult<Map<String, String>>> observer) {
         RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file);
         MultipartBody.Part part = MultipartBody.Part.createFormData("file", file.getName(), requestBody);
         setSubscribe(service_url.uploadAvatar(getHeader(), part), observer);
     }
     public static void upLoadAvatar(List<MultipartBody.Part> partLis, Observer<ResponseBody> observer) {
         setSubscribe(service_url.upLoadAvatar(getHeader(), partLis), observer);
     }
     public static void editUser(RequestBody body, Observer<ResponseBody> observer) {
         setSubscribe(service_url.editUser(getHeader(), body), observer);
     }
     public static void changePassword(RequestBody body, Observer<ResponseBody> observer) {
         setSubscribe(service_url.changePassword(getHeader(), body), observer);
     }
     public static void searchById(String userId, Observer<ResponseBody> observer) {
         setSubscribe(service_url.searchById(getHeader(), userId), observer);
     }
     public static void login(RequestBody body, Observer<ResponseBody> observer) {
         setSubscribe(service_url.login(body), observer);
     }
     public static void listGradeAndSubject(Observer<ResponseResult<List<GradeAndSubject>>> observer) {
         setSubscribe(service_url.listGradeAndSubject(getHeader()), observer);
     }
     public static void scanAndLogin(String code, String stuId, Observer<ResponseBody> observer) {
         setSubscribe(service_url.scanAndLogin(getHeader(), code, stuId), observer);
     }
     public static void getChildrenList(Observer<ResponseBody> observer) {
         setSubscribe(service_url.getChildrenList(getHeader()), observer);
     }
     public static void registerParent(RequestBody body, Observer<ResponseBody> observer) {
         setSubscribe(service_url.registerParent(body), observer);
     }
     public static void listChildren(Observer<ResponseBody> observer) {
         setSubscribe(service_url.listChildren(getHeader()), observer);
     }
     public static void listStudent(Observer<ResponseBody> observer) {
         setSubscribe(service_url.getStudentList(getHeader(), (String) SharedPreferencesUtil.getData("userId", "")), observer);
     }
     public static Single<ResponseResult<List<Student>>> listStudent() {
         return service_url.getStudentList2(getHeader(), getUserId());
     }
     public static void listRecord(Observer<ResponseBody> observer) {
         setSubscribe(service_url.getRecordList(getHeader(), (String) SharedPreferencesUtil.getData("userId", "")), observer);
     }
     public static void registerStudent(RequestBody body, Observer<ResponseBody> observer) {
         setSubscribe(service_url.registerStudent(getHeader(), body), observer);
     }
     public static void bindTeacher(RequestBody body, Observer<ResponseBody> observer) {
         setSubscribe(service_url.bindTeacher(getHeader(), body), observer);
     }
     public static void getError(Map map, Observer<ResponseResult<PageInfo<TopicBean>>> observer) {
         setSubscribe(service_url.getError(getHeader(), map), observer);
     }
     public static RequestBody getMapRequestBody(Map map) {
         return RequestBody.create(MediaType.parse("text/plain"), new Gson().toJson(map));
     }
     public static RequestBody getArrayRequestBody(List list) {
         return RequestBody.create(MediaType.parse("text/plain"), new Gson().toJson(list));
     }
     public static RequestBody getFileRequestBody(File file) {
         return RequestBody.create(MediaType.parse("application/octet-stream"), file);
     }
     public static RequestBody getFileRequestBody(byte[] bytes) {
         return RequestBody.create(MediaType.parse("multipart/form-data"), bytes);
     }
     public static RequestBody getObjectRequestBody(Object obj) {
         return RequestBody.create(MediaType.parse("text/plain"), new Gson().toJson(obj));
     }
     public static RequestBody getStringRequestBody(String str) {
         return RequestBody.create(MediaType.parse("text/plain"), str);
     }
     /**
      * 插入观察者
      *
      * @param observable
      * @param observer
      * @param <T>
      */
     public static <T> void setSubscribe(Observable<T> observable, Observer<T> observer) {
         observable.subscribeOn(Schedulers.io())//子线程访问网络
                 .observeOn(AndroidSchedulers.mainThread())//回调到主线程
                 .subscribe(observer);
     }
 }

libs/common/src/main/java/com/prws/common/net/SignInterceptor.java

Diff comments View file @eb171a0

1	package com.prws.common.net;	1	package com.prws.common.net;
2		2
		3	import androidx.annotation.NonNull;
		4
		5	import com.prws.common.BuildConfig;
3	import com.prws.common.utils.SharedPreferencesUtil;	6	import com.prws.common.utils.SharedPreferencesUtil;
4		7
5	import org.apache.commons.codec.binary.Hex;	8	import org.apache.commons.codec.binary.Hex;
6	import org.apache.commons.codec.digest.DigestUtils;	9	import org.apache.commons.codec.digest.DigestUtils;
7		10
8	import java.io.IOException;	11	import java.io.IOException;
9	import java.util.Date;	12	import java.util.Date;
10	import java.util.Random;	13	import java.util.Random;
11		14
12	import okhttp3.Interceptor;	15	import okhttp3.Interceptor;
13	import okhttp3.Request;	16	import okhttp3.Request;
14	import okhttp3.Response;	17	import okhttp3.Response;
15		18
16	public class SignInterceptor implements Interceptor {	19	public class SignInterceptor implements Interceptor {
		20	@NonNull
17	@Override	21	@Override
18	public Response intercept(Chain chain) throws IOException {	22	public Response intercept(Chain chain) throws IOException {
19	// String appId = "1";	23	String host = BuildConfig.SERVER_URL;
20	// String APP_SECRET = "a839c40e04477d43705a64ba9db23b0dba969df360c3e428add85a6f5b8d0622";	24	if (!chain.request().url().toString().startsWith(host)) {
21	// String timestamp = String.valueOf(new Date().getTime());	25	return chain.proceed(chain.request());
22	// String nonce = String.valueOf(new Random().nextInt(10000));	26	}
23	// String sign = DigestUtils.md5Hex(appId + APP_SECRET + timestamp + nonce); // yidao板子报错采用如下代码	27
24	// byte[] signBytes = DigestUtils.md5(appId + APP_SECRET + timestamp + nonce);
25	// String sign = new String(Hex.encodeHex(signBytes));
26	String token = (String) SharedPreferencesUtil.getData("token","");	28	String token = (String) SharedPreferencesUtil.getData("token","");
27	Request.Builder requestBuilder = chain.request().newBuilder();	29	Request.Builder requestBuilder = chain.request().newBuilder();
28	if (token != null && token.length() > 0) {	30	if (token != null && token.length() > 0) {
29	requestBuilder = chain.request().newBuilder()	31	requestBuilder = chain.request().newBuilder()
30	.header("Authorization", token);	32	.header("Authorization", token);
31	}	33	}
32	// .header("Content-Type","application/json");
33