join class

Author: itning

app/src/main/java/top/itning/smpandroid/client/ClassClient.java

@@ -57,4 +57,14 @@ public interface ClassClient {
     @FormUrlEncoded
     @POST("/class/check")
     Observable<RestModel<StudentClassCheck>> check(@Field("longitude") double longitude, @Field("latitude") double latitude, @Field("studentClassId") String studentClassId);
+
+    /**
+     * 加入班级
+     *
+     * @param classNum 班号
+     * @return 加入的班级
+     */
+    @FormUrlEncoded
+    @POST("/class/join_class")
+    Observable<RestModel<StudentClassUser>> joinClass(@Field("classNum") String classNum);
 }

app/src/main/java/top/itning/smpandroid/ui/activity/MainActivity.java

@@ -80,6 +80,7 @@ public class MainActivity extends AppCompatActivity implements StudentClassUserR
     private Disposable recyclerViewDataDisposable;
     private List<StudentClassUser> groupList;
     private Page<StudentClassUser> studentGroupPage;
+    private Disposable joinDisposable;
 
 
     @Override
@@ -211,8 +212,13 @@ public void onFabClick(View view) {
                     if (textInputLayout != null) {
                         EditText editText = textInputLayout.getEditText();
                         if (editText != null) {
+                            if (editText.getText().length() == 0 || "".contentEquals(editText.getText())) {
+                                Snackbar.make(coordinatorLayout, "请输入班号", Snackbar.LENGTH_LONG).show();
+                                return;
+                            }
                             Editable editable = editText.getText();
                             Log.d(TAG, editable.toString());
+                            doJoinClass(editable.toString());
                         }
                     }
                 })
@@ -228,9 +234,26 @@ public void onFabClick(View view) {
         }
     }
 
+    private void doJoinClass(String classNum) {
+        joinDisposable = HttpHelper.get(ClassClient.class)
+                .joinClass(classNum)
+                .subscribeOn(Schedulers.computation())
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(pageRestModel -> {
+                    groupList.add(0, pageRestModel.getData());
+                    if (rv.getAdapter() != null) {
+                        rv.getAdapter().notifyDataSetChanged();
+                    }
+                }, HttpHelper.ErrorInvoke.get(this)
+                        .orElseCode(t -> Snackbar.make(coordinatorLayout, t.getT2() == null ? t.getT1().code() + "" : t.getT2().getMsg(), Snackbar.LENGTH_LONG).show())
+                        .orElseException(t -> {
+                            Log.w(TAG, "网络请求错误", t);
+                            Snackbar.make(coordinatorLayout, "网络请求错误", Snackbar.LENGTH_LONG).show();
+                        }));
+    }
+
     @Override
     public void onItemClick(View view, StudentClassUser object) {
-        Log.d(TAG, object.toString());
         Intent intent = new Intent(this, ClassCheckActivity.class);
         intent.putExtra("data", object);
         startActivity(intent);
@@ -276,6 +299,9 @@ public void onBackPressed() {
         if (recyclerViewDataDisposable != null && !recyclerViewDataDisposable.isDisposed()) {
             recyclerViewDataDisposable.dispose();
         }
+        if (joinDisposable != null && !joinDisposable.isDisposed()) {
+            joinDisposable.dispose();
+        }
         super.onBackPressed();
     }
 }