android1.9.9

managercenter/src/main/java/com/dayu/message/data/protocol/NewMessage.java

+package com.dayu.message.data.protocol;
+
+import java.io.Serializable;
+
+/**
+ * Created by luofan on 2017/11/14.
+ */
+
+public class NewMessage implements Serializable {
+
+    /**
+     * id : 262
+     * title : 改派通知
+     * content : 你的工单被改派，改派原因：
+     * sender : null
+     * hxAccount : abbb2f4da566409189441a4ea537de41
+     * status : 1
+     * type : 1
+     * functionType : 1
+     * category : 1
+     * action : null
+     * reason : null
+     * batchId : null
+     * createTime : 2017-10-15 14:48:50
+     * startTime : null
+     * endTime : null
+     * customJson : {"orderId":67}
+     */
+
+    private int id;
+    private String title;
+    private String content;
+    private Object sender;
+    private String hxAccount;
+    private int status;
+    private int type;
+    private int functionType;
+    private int category;
+    private Object action;
+    private Object reason;
+    private Object batchId;
+    private String createTime;
+    private Object startTime;
+    private Object endTime;
+    private String customJson;
+    private String flag;
+    private int read;
+
+    public String getFlag() {
+        return flag;
+    }
+
+    public void setFlag(String flag) {
+        this.flag = flag;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    public Object getSender() {
+        return sender;
+    }
+
+    public void setSender(Object sender) {
+        this.sender = sender;
+    }
+
+    public String getHxAccount() {
+        return hxAccount;
+    }
+
+    public void setHxAccount(String hxAccount) {
+        this.hxAccount = hxAccount;
+    }
+
+    public int getStatus() {
+        return status;
+    }
+
+    public void setStatus(int status) {
+        this.status = status;
+    }
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+    public int getFunctionType() {
+        return functionType;
+    }
+
+    public void setFunctionType(int functionType) {
+        this.functionType = functionType;
+    }
+
+    public int getCategory() {
+        return category;
+    }
+
+    public void setCategory(int category) {
+        this.category = category;
+    }
+
+    public Object getAction() {
+        return action;
+    }
+
+    public void setAction(Object action) {
+        this.action = action;
+    }
+
+    public Object getReason() {
+        return reason;
+    }
+
+    public void setReason(Object reason) {
+        this.reason = reason;
+    }
+
+    public Object getBatchId() {
+        return batchId;
+    }
+
+    public void setBatchId(Object batchId) {
+        this.batchId = batchId;
+    }
+
+    public String getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(String createTime) {
+        this.createTime = createTime;
+    }
+
+    public Object getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(Object startTime) {
+        this.startTime = startTime;
+    }
+
+    public Object getEndTime() {
+        return endTime;
+    }
+
+    public void setEndTime(Object endTime) {
+        this.endTime = endTime;
+    }
+
+    public String getCustomJson() {
+        return customJson;
+    }
+
+    public void setCustomJson(String customJson) {
+        this.customJson = customJson;
+    }
+
+    public int getRead() {
+        return read;
+    }
+
+    public void setRead(int read) {
+        this.read = read;
+    }
+}

managercenter/src/main/java/com/dayu/message/presenter/message/messagePresenter.java

+package com.dayu.message.presenter.message;
+
+import android.databinding.ObservableField;
+import android.os.Bundle;
+import android.view.View;
+
+import com.dayu.common.BaseApplication;
+import com.dayu.common.Constants;
+import com.dayu.event.UserInfo;
+import com.dayu.message.api.MessageApiFactory;
+import com.dayu.message.data.protocol.NewMessage;
+import com.dayu.message.ui.activity.MessageDetailActivity;
+import com.dayu.message.ui.fragment.MessageFragment;
+import com.dayu.utils.UserManager;
+import com.umeng.analytics.MobclickAgent;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import okhttp3.MediaType;
+import okhttp3.RequestBody;
+
+/**
+ * Created by luofan
+ * on 2017/11/8.
+ */
+public class messagePresenter extends messageContract.Presenter {
+    public ObservableField<Object> data = new ObservableField<>();
+    private String mHxId;
+    private int mPage;
+    private int mCategory;
+
+    @Override
+    public void onAttached() {
+        mCategory = ((MessageFragment) mView).getArguments().getInt("category", 1);
+        UserInfo userInfo = UserManager.getInstance().getUser();
+        mHxId = userInfo.getHxAccount();
+//        mHxId = "0e09ed696cf843dda34ac729a1231d4f";
+        refresh();
+    }
+
+    @Override
+    public void refresh() {
+        mPage = 1;
+        getHxMessage(mHxId, mCategory, mPage, Constants.PAGESIZE);
+    }
+
+    @Override
+    public void loadMore() {
+        getHxMessage(mHxId, mCategory, mPage, Constants.PAGESIZE);
+    }
+
+    @Override
+    public ObservableField<Object> getSourceDatas() {
+        return data;
+    }
+
+    @Override
+    public void getHxMessage(String hxUserId, int category, int page, int pageSize) {
+        MessageApiFactory.getHxMessage(hxUserId, category, page, pageSize).subscribe(baseObserver(
+                messageBasePageBean -> {
+                    data.set(messageBasePageBean);
+                    mPage++;
+                }, throwable -> data.set(Constants.FAILED)));
+    }
+
+    @Override
+    public void readMessage(int id, int read) {
+        JSONObject jsonObject = new JSONObject();
+        try {
+            jsonObject.put("id", id);
+            jsonObject.put("read", read);
+        } catch (JSONException e) {
+            e.printStackTrace();
+        }
+        RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), jsonObject.toString());
+        MessageApiFactory.readMessage(requestBody).subscribe(baseObserver(aBoolean -> {
+        }));
+    }
+
+    @Override
+    public void readAndDump(NewMessage message, View view) {
+        if (message.getRead() == 0) {
+            readMessage(message.getId(), 1);
+            view.setVisibility(View.GONE);
+        }
+        Bundle bundle = new Bundle();
+        bundle.putSerializable(Constants.HX_MESSAGE, message);
+        bundle.putInt("category", message.getCategory());
+        mView.startActivity(MessageDetailActivity.class, bundle);
+        MobclickAgent.onEvent(BaseApplication.getContext(), "read_message");
+    }
+}