bj-team / goldenline-android-mvvm-3.0.0 · Files

package com.cnlive.goldenline.ui.fragment;

import android.content.Context;
import android.graphics.drawable.BitmapDrawable;
import android.net.Uri;
import android.os.Bundle;
import android.support.annotation.IdRes;
import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;
import android.text.TextUtils;
import android.util.Log;
import android.view.Gravity;
import android.view.KeyEvent;
import android.view.LayoutInflater;
import android.view.MotionEvent;
import android.view.View;
import android.view.ViewGroup;
import android.view.WindowManager;
import android.view.inputmethod.InputMethodManager;
import android.widget.EditText;
import android.widget.ImageView;
import android.widget.LinearLayout;
import android.widget.PopupWindow;
import android.widget.RadioButton;
import android.widget.RadioGroup;
import android.widget.TextView;

import com.cnlive.goldenline.R;
import com.cnlive.goldenline.api.CmsAPI;
import com.cnlive.goldenline.model.ChatModel;
import com.cnlive.goldenline.model.chat.RecyclerChat;
import com.cnlive.goldenline.model.chat.XMPPItem;
import com.cnlive.goldenline.model.chat.XMPPMessageItem;
import com.cnlive.goldenline.model.request.SeatsRequest;
import com.cnlive.goldenline.model.response.BaseResponse;
import com.cnlive.goldenline.model.response.SelectSeatResponse;
import com.cnlive.goldenline.ui.adapter.ChatAdapter;
import com.cnlive.goldenline.ui.adapter.RecyclerConfig;
import com.cnlive.goldenline.ui.base.BaseChatFragment;
import com.cnlive.goldenline.ui.interfaces.MessageReceive;
import com.cnlive.goldenline.ui.model.PartitionSeat;
import com.cnlive.goldenline.ui.widget.selectionview.data.SeatUserBean;
import com.cnlive.goldenline.ui.widget.selectionview.view.RowBarImpl;
import com.cnlive.goldenline.ui.widget.selectionview.view.Seat;
import com.cnlive.goldenline.ui.widget.selectionview.view.SeatImagePoolImpl;
import com.cnlive.goldenline.ui.widget.selectionview.view.SeatSelectionListener;
import com.cnlive.goldenline.ui.widget.selectionview.view.SeatSelectionView;
import com.cnlive.goldenline.ui.widget.selectionview.view.SeatState;
import com.cnlive.goldenline.ui.widget.selectionview.view.SeatTable;
import com.cnlive.goldenline.ui.widget.selectionview.view.SeatType;
import com.cnlive.goldenline.util.ChatRoomConnect;
import com.cnlive.goldenline.util.RestAdapterUtils;
import com.cnlive.goldenline.util.SeatViewUtls;
import com.cnlive.goldenline.util.ToastUtil;
import com.cnlive.libs.util.chat.base.IChat;
import com.facebook.drawee.view.SimpleDraweeView;
import com.google.gson.Gson;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import butterknife.BindView;
import butterknife.OnClick;
import retrofit.Callback;
import retrofit.RetrofitError;
import retrofit.client.Response;
import sviolet.turquoise.util.common.BitmapUtils;
import sviolet.turquoise.util.droid.MeasureUtils;

import static com.cnlive.goldenline.R.id.layout_private_chat_select;

/**
 * Created by xiansong on 2017/3/29.
 */

public class DetailChatPrivateFragment extends BaseChatFragment implements RadioGroup.OnCheckedChangeListener {

    public static final List<String> types = Arrays.asList("2");

    private Gson gson = new Gson();

    private String mUserName, mUserIcon, mUserId, mLiveId, mTheatreSeat;
    private String mHallId, mArea, mRow, mColumn;

    private ChatAdapter adapter;

    private EditText mMsgEditText;

    private PopupWindow mInputPopupWindow, mAddPopupWindow;

    private boolean isDestroy = false;

    private String mPrivateId;

    @BindView(R.id.recyclerview)
    protected RecyclerView recyclerView;

    public static DetailChatPrivateFragment newInstance(String userId, String userName, String userIcon, String liveId, String theatreSeat) {
        DetailChatPrivateFragment fragment = new DetailChatPrivateFragment();
        Bundle bundle = new Bundle();
        bundle.putString("userId", userId);     //用户ID
        bundle.putString("userName", userName); //用户昵称
        bundle.putString("userIcon", userIcon); //用户头像
        bundle.putString("liveId", liveId);     //当前直播ID（私聊信息区分场次使用，填空时任意场次交互）
        bundle.putString("theatreSeat", theatreSeat);
        fragment.setArguments(bundle);
        return fragment;
    }

    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        mUserName = getArgumentsString("userName");
        mUserIcon = getArgumentsString("userIcon");
        mUserId = getArgumentsString("userId");
        mLiveId = getArgumentsString("liveId");
        mTheatreSeat = getArgumentsString("theatreSeat");
        if (!TextUtils.isEmpty(mTheatreSeat)) {
            String[] tabs = mTheatreSeat.split("-");
            mHallId = tabs[0].substring(0, tabs[0].length() - 1);
            mArea = tabs[1].substring(0, tabs[1].length() - 1);
            mRow = tabs[2].substring(0, tabs[2].length() - 1);
            mColumn = tabs[3].substring(0, tabs[3].length() - 1);
        } else {
            ToastUtil.showToast("座位信息加载失败");
        }

        adapter = new ChatAdapter(getActivity());
    }

    @Override
    public void onViewCreated(View view, Bundle savedInstanceState) {
        super.onViewCreated(view, savedInstanceState);
        recyclerView.setLayoutManager(new LinearLayoutManager(getActivity()));
        recyclerView.setAdapter(adapter);
        recyclerView.setHasFixedSize(true);

        initSeatView();

        showPartitionpage();
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        isDestroy = true;
        if (mInputPopupWindow != null) {
            mInputPopupWindow.dismiss();
            mInputPopupWindow = null;
        }
        if (mAddPopupWindow != null) {
            mAddPopupWindow.dismiss();
            mAddPopupWindow = null;
        }

        if (imagePool != null) imagePool.destroy();
    }

    @Override
    protected int getLayoutRes() {
        return R.layout.fragment_detail_private_chat;
    }

    @Override
    protected String getUserName() {
        return mUserName;
    }

    @Override
    protected String getRoomId() {
        return "";
    }

    @Override
    protected String getUserIcon() {
        return mUserIcon;
    }

    @Override
    protected String getUserId() {
        return mUserId;
    }

    @Override
    protected void receive(String type, String fromid, String from, String icon, String msg, Date date, boolean self) {
        if (getActivity() == null) return;
        if (!type.equals(IChat.PRIVATE)) return;
        if (TextUtils.isEmpty(fromid)) return;

        try {
            String trim_msg = msg.trim();
            if (trim_msg.indexOf("{") == 0 && trim_msg.lastIndexOf("}") == trim_msg.length() - 1) {
                XMPPItem item = gson.fromJson(msg, XMPPItem.class);
                if (checkMessage(item.getType())) {
                    XMPPMessageItem item_message = gson.fromJson(msg, XMPPMessageItem.class);
                    String liveId = item_message.getLiveId();

                    if (!TextUtils.isEmpty(mLiveId) && !mLiveId.equals(liveId)) return;
                    if (!fromid.equals(mUserId) && !fromid.equals(mPrivateId)) {
                        changeUserPoint(fromid, true);
                        return;
                    }
                    item_message.setDate(date);
                    item_message.setUserName(from);
                    item_message.setUserIcon(icon);
                    if (getActivity() instanceof MessageReceive)
                        ((MessageReceive) getActivity()).onReceive(true, item_message);
                    switch (item.getType()) {
                        case "2":
                            adapter.addItem(new RecyclerChat(self ? RecyclerConfig.ITEM_TYPE_CHAT_SELF : RecyclerConfig.ITEM_TYPE_CHAT_OTHERS, item_message));
                            recyclerView.scrollToPosition(adapter.getItemCount() - 1);
                            break;
                    }
                }
            }

        } catch (Exception e) {
            Log.e("Message", "error ", e);
        }

    }

    private void changeUserPoint(String userId, boolean show) {
        if (!mSeatUserMap.containsKey(userId)) return;

        if (show && !mPointList.contains(userId)) mPointList.add(userId);
        else if (!show && mPointList.contains(userId)) mPointList.remove(userId);

        SeatUserBean userBean = mSeatUserMap.get(userId);
        SeatViewUtls.changeNote(show, mSeatSelectionView, seatTable, userBean);
    }

    private static boolean checkMessage(String type) {
        return !TextUtils.isEmpty(type) && types.indexOf(type) != -1;
    }

    @OnClick({R.id.fr_chatroom_img_chat})
    protected void onClick(View view) {
        switch (view.getId()) {
            case R.id.fr_chatroom_img_chat:
                showInput(view);
                break;
        }
    }


    private void showInput(View view) {
        // 加载popupWindow的布局
        View contentView = LayoutInflater.from(getActivity()).inflate(R.layout.layout_chat_input, new LinearLayout(getActivity()), false);
        contentView.findViewById(R.id.click_view).setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                mMsgEditText.setText("");
                mInputPopupWindow.dismiss();
            }
        });
        mMsgEditText = (EditText) contentView.findViewById(R.id.chat_content);
        mMsgEditText.setOnKeyListener(new View.OnKeyListener() {
            @Override
            public boolean onKey(View v, int keyCode, KeyEvent event) {
                if (!isDestroy && keyCode == KeyEvent.KEYCODE_ENTER && event.getAction() == KeyEvent.ACTION_DOWN) {
                    InputMethodManager inputMethodManager = (InputMethodManager) getActivity().getSystemService(Context.INPUT_METHOD_SERVICE);
                    if (inputMethodManager.isActive()) {
                        inputMethodManager.hideSoftInputFromWindow(v.getApplicationWindowToken(), 0);
                    }
                    sendMessage(mMsgEditText.getText().toString());
                    mMsgEditText.setText("");
                    return true;
                }
                return false;
            }
        });
       /* contentView.findViewById(R.id.post_button).setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                mMsgEditText.setText("");
                mInputPopupWindow.dismiss();
            }
        });*/

        mInputPopupWindow = new PopupWindow(contentView, ViewGroup.LayoutParams.MATCH_PARENT, ViewGroup.LayoutParams.MATCH_PARENT);
        mInputPopupWindow.setTouchable(true);
        mInputPopupWindow.setTouchInterceptor(new View.OnTouchListener() {
            @Override
            public boolean onTouch(View v, MotionEvent event) {
                if (event.getAction() == MotionEvent.ACTION_OUTSIDE)
                    mInputPopupWindow.dismiss();
                return false;
            }
        });
        // 设置以下两个属性后 点击popupWindow之外的地方 就会让其消失
        // 设置popupWindow 点击popupWindow外的地方 生效
        mInputPopupWindow.setOutsideTouchable(true);
        // 设置popupWindow 背景
        mInputPopupWindow.setBackgroundDrawable(new BitmapDrawable());
        mInputPopupWindow.setFocusable(true); //设置获取焦点
        mInputPopupWindow.setAnimationStyle(R.style.animation);
        mInputPopupWindow.setSoftInputMode(PopupWindow.INPUT_METHOD_NEEDED);
        mInputPopupWindow.setSoftInputMode(WindowManager.LayoutParams.SOFT_INPUT_ADJUST_RESIZE);
        mInputPopupWindow.showAtLocation(view, Gravity.BOTTOM | Gravity.CENTER_HORIZONTAL, 0, 0);
        mInputPopupWindow.update();

        mMsgEditText.requestFocus();
        mInputPopupWindow.setSoftInputMode(PopupWindow.INPUT_METHOD_NEEDED);
        mInputPopupWindow.setSoftInputMode(WindowManager.LayoutParams.SOFT_INPUT_ADJUST_RESIZE);
        InputMethodManager imm = (InputMethodManager) getActivity().getApplicationContext().getSystemService(Context.INPUT_METHOD_SERVICE);
        imm.toggleSoftInput(1000, InputMethodManager.HIDE_NOT_ALWAYS);
    }

    public void sendMessage(String message) {
        //发送聊天室消息
        if (TextUtils.isEmpty(mPrivateId)) {
            ToastUtil.showToast("还没有选择聊天用户哦~");
        } else if (TextUtils.isEmpty(message)) {
            ToastUtil.showToast("不能发送空消息呦~");
        } else {
            sendPrivate(mPrivateId, getSendMessage(message));
        }

        if (mInputPopupWindow != null && mInputPopupWindow.isShowing()) mInputPopupWindow.dismiss();
    }

    private String getSendMessage(String message) {
        return gson.toJson(new ChatModel(message, String.valueOf(System.currentTimeMillis() / 1000), "2", mLiveId));
    }

    private void connectPrivateId(String privateId) {
        this.mPrivateId = privateId;
        getLatestMessages(privateId, new ChatRoomConnect.OnPrivateConnectListener() {
            @Override
            public void onSuccess() {
                if (adapter != null) adapter.removeAllItems();
                if (getActivity() instanceof MessageReceive)
                    ((MessageReceive) getActivity()).onClear();
                sendMessage("Hello !");
            }

            @Override
            public void onError(int i, String s) {
                ToastUtil.showToast("暂时无法操作，稍后重试~");
            }
        });
    }

    /**
     * 选择聊天对象逻辑相关
     */
    private LayoutInflater mLayoutInflater;

    private SeatImagePoolImpl imagePool;
    private SeatTable seatTable;

    private List<PartitionSeat> mPartitionData = new ArrayList<>();

    //消息通知用户ID 列表
    private List<String> mPointList = new ArrayList<>();

    //已购票用户列表（ID 查询用户信息）
    private Map<String, SeatUserBean> mSeatUserMap = new HashMap<>();

    @BindView(R.id.user_face_iv)
    SimpleDraweeView user_face_iv;
    @BindView(R.id.user_gener_iv)
    ImageView user_gener_iv;
    /*@BindView(R.id.chooseseat_tv_price)
    TextView chooseseat_tv_price;*/
    @BindView(R.id.check_user_name_tv)
    TextView check_user_name_tv;

    @BindView(R.id.chooseseat_bottom_bar)
    protected View chooseseat_bottom_bar;

    @BindView(layout_private_chat_select)
    protected View mLayoutChatSlect;

    @BindView(R.id.chooseseat_selection_view)
    protected SeatSelectionView mSeatSelectionView;

    @BindView(R.id.partition_group)
    protected RadioGroup mPartitionGroup;

    @BindView(R.id.chat_join_btn)
    protected View chat_join_btn;

    @OnClick({R.id.back_private_chat, R.id.show_private_chat, R.id.chooseseat_bottom_bar, R.id.close, R.id.chat_join_btn})
    protected void onClickView(View view) {
        switch (view.getId()) {
            case R.id.back_private_chat:
                hidePartitionpage();
                break;
            case R.id.show_private_chat:
                showPartitionpage();
                break;
            case R.id.chooseseat_bottom_bar:
                break;
            case R.id.close:
                chooseseat_bottom_bar.setVisibility(View.GONE);
                break;
            case R.id.chat_join_btn:
                connectPrivateId(chooseseat_bottom_bar.getTag().toString());
                chooseseat_bottom_bar.setVisibility(View.GONE);
                hidePartitionpage();
                break;
        }
    }

    @Override
    public void onCheckedChanged(RadioGroup group, @IdRes int checkedId) {
        initSeat();
        bindSeatUserBean(checkedId);
    }


    private LayoutInflater getmLayoutInflater() {
        return mLayoutInflater = mLayoutInflater == null ? LayoutInflater.from(getActivity()) : mLayoutInflater;
    }

    private void initSeatView() {

        seatTable = new SeatTable(10, 11, MeasureUtils.dp2px(getActivity(), 42), MeasureUtils.dp2px(getActivity(), 42), 1);

        //配置座位各种状态的图片
        imagePool = new SeatImagePoolImpl();
        imagePool.setImage(SeatType.SINGLE, SeatState.AVAILABLE, BitmapUtils.decodeFromResource(getResources(), R.mipmap.seat_private));
        imagePool.setImage(SeatType.SINGLE, SeatState.UNAVAILABLE, BitmapUtils.decodeFromResource(getResources(), R.mipmap.seat_selected));
        imagePool.setImage(SeatType.SINGLE, SeatState.SELECTED, BitmapUtils.decodeFromResource(getResources(), R.mipmap.seat_selected));

        imagePool.setImage(SeatType.SINGLE, SeatState.MALE, BitmapUtils.decodeFromResource(getResources(), R.mipmap.private_chat_male_icon));
        imagePool.setImage(SeatType.SINGLE, SeatState.FEMALE, BitmapUtils.decodeFromResource(getResources(), R.mipmap.private_chat_female_icon));
        imagePool.setImage(SeatType.SINGLE, SeatState.DEFAULT, BitmapUtils.decodeFromResource(getResources(), R.mipmap.icon_default_portrait_87));
        imagePool.setImage(SeatType.SINGLE, SeatState.REDPOIN, BitmapUtils.decodeFromResource(getResources(), R.mipmap.notify_red));

        //配置座位数据
        mSeatSelectionView.setData(seatTable);

        mSeatSelectionView.setImagePool(imagePool);
        //设置背景色
        mSeatSelectionView.setBackground(0xF7F7F7);
        //配置行标记
        mSeatSelectionView.setRowBar(new RowBarImpl(MeasureUtils.dp2px(getActivity().getApplicationContext(), 18), 10, 0x80000000, 0xFFF0F0F0, MeasureUtils.dp2px(getActivity().getApplicationContext(), 12)));
        //配置概要图显示时间
        mSeatSelectionView.setOutlineDelay(1000);

        //配置座位选择监听器
        mSeatSelectionView.setSeatSelectionListener(new SeatSelectionListener() {
            @Override
            public boolean onSeatSelect(Seat seat) {
                return false;
            }

            @Override
            public boolean onSeatDeselect(Seat seat) {
                return false;
            }

            @Override
            public void onUnavailableSeatSelect(Seat seat) {
                if (seat != null && seat.getSeatUser() != null && !seat.getSeatUser().getUserId().equals(mUserId)) {
                    chat_join_btn.setVisibility(seat.getSeatUser().getUserId().equals(mUserId) ? View.GONE : View.VISIBLE);
                    changeUserPoint(seat.getSeatUser().getUserId(), false);
                    user_face_iv.setImageURI(Uri.parse(seat.getSeatUser().getSmallHeadPortrait()));
                    user_gener_iv.setImageResource(seat.getSeatUser().getGender() == 1 ?
                            R.mipmap.privatechat_male_icon : R.mipmap.privatechat_female_icon);
                    //TODO 添加地点
                    //chooseseat_tv_price.setVisibility(View.GONE);
                    check_user_name_tv.setText(seat.getSeatUser().getNick());
                    chooseseat_bottom_bar.setVisibility(View.VISIBLE);
                    chooseseat_bottom_bar.setTag(seat.getSeatUser().getUserId());
                }
            }

            @Override
            public void onInvalidAreaClick() {
            }
        });
    }

    //状态：处于加载状态
    private boolean inLoadPartionData = false;

    //座位分区
    private List<String> tabs = Arrays.asList("A", "B", "C", "D", "E");

    //分区座位缓存列表
    private Map<String, SelectSeatResponse> map_partition = new HashMap<>();

    /**
     * 选座数据加载完成
     *
     * @param list 分区座位列表
     */
    private void initLoadData(List<PartitionSeat> list) {
        map_partition.clear();
        if (list == null) {
            ToastUtil.showToast("用户数据加载失败");
        } else {
            mPartitionData = list;
            showPartitionpage();
        }
    }

    /**
     * 分区座位数据加载完成，完整度判断，数据整合
     */
    private void onDataLoadSuccess() {
        inLoadPartionData = false;

        for (String tag : tabs) {
            if (!map_partition.containsKey(tag)) {
                initLoadData(null);
                return;
            }
        }

        for (BaseResponse response : map_partition.values()) {
            if (response == null || response.getCode() != 0) {
                initLoadData(null);
                return;
            }
        }

        List<PartitionSeat> list = new ArrayList<>();

        for (String tag : tabs) {
            SelectSeatResponse response = map_partition.get(tag);
            PartitionSeat item = new PartitionSeat();
            item.setPartitionName(tag);
            item.setPartitionUsers(response.getRecordList());
            list.add(item);
        }

        initLoadData(list);
    }

    /**
     * 添加分区座位数据
     *
     * @param areaId   区域Id
     * @param response 区域座位信息
     */
    private void addSelectedSeatInfo(String areaId, SelectSeatResponse response) {
        map_partition.put(areaId, response);

        if (map_partition.keySet().size() == tabs.size()) onDataLoadSuccess();
    }

    /**
     * 预加载分区座位信息
     */
    private void loadPartition() {
        if (inLoadPartionData) {
            ToastUtil.showToast("正在加载请稍候");
            return;
        }

        for (final String areaId : tabs) {
            inLoadPartionData = true;
            RestAdapterUtils.getRestAPI(CmsAPI.class).getSelectedSeatInfo(new SeatsRequest(mLiveId, Long.valueOf(mHallId), areaId), new Callback<SelectSeatResponse>() {
                @Override
                public void success(SelectSeatResponse response, Response response2) {
                    addSelectedSeatInfo(areaId, response);
                }

                @Override
                public void failure(RetrofitError error) {
                    addSelectedSeatInfo(areaId, null);
                }
            });
        }
    }

    /**
     * 初始化座位信息，填充座位对应用户数据.
     */
    private void initSeat() {
        for (int row = 0; row < 10; row++) {
            seatTable.setRowId(row, "" + (row + 1));
            for (int column = 0; column < 11; column++) {
                if (column == 3) continue;//第四列空位 不可填充
                Seat seatItem = seatTable.getSeat(row, column);
                if (seatItem == null) {
                    Seat seat = new Seat(SeatType.SINGLE, SeatState.AVAILABLE);
                    seat.setColumnId("" + (column + 1));
                    seat.setRowId("" + (row + 1));
                    seatTable.setSeat(row, column, seat);
                } else {
                    seatItem.setState(SeatState.AVAILABLE);
                    seatItem.setSeatUser(null);
                }
            }
        }
    }

    /**
     * 用户数据与座位数据绑定
     *
     * @param tabIndex 区域索引
     */
    private void bindSeatUserBean(int tabIndex) {
        if (seatTable == null || mPartitionData == null) return;
        PartitionSeat partitionSeat = mPartitionData.get(tabIndex);

        for (SeatUserBean item : partitionSeat.getPartitionUsers()) {
            item.setHasNote(mPointList.indexOf(item.getUserId()) != -1);
            int row = item.getRowId()-1;
            int clone = item.getCloneId()-1;
            clone = clone >= 3 ? clone + 1 : clone;
            Seat seat = seatTable.getSeat(row, clone);
            if (seat == null) continue;
            seat.setState(SeatState.UNAVAILABLE + "_" + item.getUserId());
            seat.setSeatUser(item);
            seat.setHallId(partitionSeat.getPartitionName());
            SeatViewUtls.loadUserImage(getResources(), seat, item, mSeatSelectionView, imagePool);
        }
        mSeatSelectionView.invalidate();
    }

    private void showPartitionpage() {
        if (isDestroy || getActivity() == null) return;

        if (mPartitionData.size() == 0) {
            loadPartition();
            return;
        }

        mPartitionGroup.setOnCheckedChangeListener(null);
        mPartitionGroup.clearCheck();
        mPartitionGroup.removeAllViews();
        mPartitionGroup.setOnCheckedChangeListener(this);

        mSeatUserMap.clear();

        for (PartitionSeat partition_item : mPartitionData) {
            RadioButton button = (RadioButton) getmLayoutInflater().inflate(R.layout.layout_detail_private_chat_partition_item, mPartitionGroup, false);
            button.setId(mPartitionData.indexOf(partition_item));
            button.setText(partition_item.getPartitionName());
            mPartitionGroup.addView(button);

            for (SeatUserBean userBean : partition_item.getPartitionUsers())
                mSeatUserMap.put(userBean.getUserId(), userBean);

            if (button.getId() == 0) button.setChecked(true);
        }

        mLayoutChatSlect.setVisibility(View.VISIBLE);
    }

    private void hidePartitionpage() {
        mLayoutChatSlect.setVisibility(View.GONE);

    }


}