Compare commits
No commits in common. "5cd598bec97c577286e3987db5f0e10eb2b88a1c" and "cbeb9128206d5838affcfd85bed89d2d23e3ef26" have entirely different histories.
5cd598bec9
...
cbeb912820
@ -1,8 +1,18 @@
|
||||
package com.safemobile.adapters;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Calendar;
|
||||
import java.util.Date;
|
||||
import java.util.Hashtable;
|
||||
import java.util.Locale;
|
||||
import java.util.TimeZone;
|
||||
|
||||
import android.app.Activity;
|
||||
import android.content.Context;
|
||||
import android.view.LayoutInflater;
|
||||
import android.view.View;
|
||||
import android.view.View.OnClickListener;
|
||||
import android.view.ViewGroup;
|
||||
import android.widget.BaseAdapter;
|
||||
import android.widget.ImageView;
|
||||
@ -10,32 +20,34 @@ import android.widget.LinearLayout;
|
||||
import android.widget.TextView;
|
||||
|
||||
import com.safemobile.activities.AbstractRecordingsActivity;
|
||||
import com.safemobile.lib.AppParams;
|
||||
import com.safemobile.lib.R;
|
||||
import com.safemobile.lib.Recording;
|
||||
import com.safemobile.lib.Contact;
|
||||
import com.safemobile.lib.SM;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Calendar;
|
||||
import java.util.Date;
|
||||
import java.util.Hashtable;
|
||||
public class RecordingsGridViewAdapter extends BaseAdapter
|
||||
{
|
||||
private ArrayList<Recording> listRecordings;
|
||||
private ArrayList<Boolean> recordingExists;
|
||||
private ArrayList<Boolean> playingPositions;
|
||||
private Activity activity;
|
||||
private Context context;
|
||||
private int removePosition = -1;
|
||||
//public String time;
|
||||
//private int[] colors = new int[] { Color.parseColor("#FFFFFF"), Color.parseColor("#D2E4FC") };
|
||||
private Hashtable<Integer, View> hash = new Hashtable<Integer, View>();
|
||||
|
||||
public class RecordingsGridViewAdapter extends BaseAdapter {
|
||||
private final ArrayList<Recording> listRecordings;
|
||||
private final ArrayList<Boolean> recordingExists;
|
||||
private final ArrayList<Boolean> playingPositions;
|
||||
private final Activity activity;
|
||||
|
||||
private final Hashtable<Integer, View> hash = new Hashtable<>();
|
||||
|
||||
public RecordingsGridViewAdapter(Activity activity, ArrayList<Recording> listRecordings, ArrayList<Boolean> recordingExists) {
|
||||
public RecordingsGridViewAdapter(Activity activity, Context context, ArrayList<Recording> listRecordings, ArrayList<Boolean> recordingExists)
|
||||
{
|
||||
super();
|
||||
this.activity = activity;
|
||||
this.context = context;
|
||||
this.listRecordings = listRecordings;
|
||||
this.recordingExists = recordingExists;
|
||||
|
||||
playingPositions = new ArrayList<>();
|
||||
for (int i = 0; i < recordingExists.size(); i++) {
|
||||
playingPositions = new ArrayList<Boolean>();
|
||||
for(int i=0; i<recordingExists.size(); i++) {
|
||||
playingPositions.add(false);
|
||||
|
||||
listRecordings.get(i).date = listRecordings.get(i).startGMT;
|
||||
@ -58,184 +70,185 @@ public class RecordingsGridViewAdapter extends BaseAdapter {
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* Define Row Template
|
||||
*/
|
||||
public static class ViewHolder {
|
||||
private LinearLayout layoutRecording;
|
||||
private ImageView imageViewPlay;
|
||||
private ImageView imageViewRecycle;
|
||||
private TextView textViewSender;
|
||||
private TextView textViewDuration;
|
||||
private TextView textViewDate;
|
||||
|
||||
public LinearLayout getLayoutRecording() {
|
||||
return layoutRecording;
|
||||
}
|
||||
|
||||
public void setLayoutRecording(LinearLayout layoutRecording) {
|
||||
this.layoutRecording = layoutRecording;
|
||||
}
|
||||
|
||||
public ImageView getImageViewPlay() {
|
||||
return imageViewPlay;
|
||||
}
|
||||
|
||||
public void setImageViewPlay(ImageView imageViewPlay) {
|
||||
this.imageViewPlay = imageViewPlay;
|
||||
}
|
||||
|
||||
public ImageView getImageViewRecycle() {
|
||||
return imageViewRecycle;
|
||||
}
|
||||
|
||||
public void setImageViewRecycle(ImageView imageViewRecycle) {
|
||||
this.imageViewRecycle = imageViewRecycle;
|
||||
}
|
||||
|
||||
public TextView getTextViewSender() {
|
||||
return textViewSender;
|
||||
}
|
||||
|
||||
public void setTextViewSender(TextView textViewSender) {
|
||||
this.textViewSender = textViewSender;
|
||||
}
|
||||
|
||||
public TextView getTextViewDuration() {
|
||||
return textViewDuration;
|
||||
}
|
||||
|
||||
public void setTextViewDuration(TextView textViewDuration) {
|
||||
this.textViewDuration = textViewDuration;
|
||||
}
|
||||
|
||||
public TextView getTextViewDate() {
|
||||
return textViewDate;
|
||||
}
|
||||
|
||||
public void setTextViewDate(TextView textViewDate) {
|
||||
this.textViewDate = textViewDate;
|
||||
}
|
||||
/** Define Row Template */
|
||||
public static class ViewHolder
|
||||
{
|
||||
public LinearLayout layoutRecording;
|
||||
public ImageView imageViewPlay, imageViewRecycle;
|
||||
public TextView textViewSender, textViewDuration, textViewDate;
|
||||
}
|
||||
|
||||
@Override
|
||||
public View getView(final int position, View convertView, ViewGroup parent) {
|
||||
final ViewHolder view;
|
||||
LayoutInflater layoutInflater = activity.getLayoutInflater();
|
||||
if (convertView == null) {
|
||||
LayoutInflater inflator = activity.getLayoutInflater();
|
||||
if(convertView==null)
|
||||
{
|
||||
view = new ViewHolder();
|
||||
convertView = layoutInflater.inflate(R.layout.row_recordings, null);
|
||||
view.setLayoutRecording(convertView.findViewById(R.id.layoutRecording));
|
||||
view.setImageViewPlay(convertView.findViewById(R.id.imageViewPlay));
|
||||
view.setTextViewSender(convertView.findViewById(R.id.textViewSender));
|
||||
view.setTextViewDuration(convertView.findViewById(R.id.textViewDuration));
|
||||
view.setTextViewDate(convertView.findViewById(R.id.textViewDate));
|
||||
view.setImageViewRecycle(convertView.findViewById(R.id.imageViewRecycle));
|
||||
view.getImageViewRecycle().setVisibility(View.GONE);
|
||||
convertView = inflator.inflate(R.layout.row_recordings, null);
|
||||
view.layoutRecording = (LinearLayout) convertView.findViewById(R.id.layoutRecording);
|
||||
view.imageViewPlay = (ImageView) convertView.findViewById(R.id.imageViewPlay);
|
||||
view.textViewSender = (TextView) convertView.findViewById(R.id.textViewSender);
|
||||
view.textViewDuration = (TextView) convertView.findViewById(R.id.textViewDuration);
|
||||
view.textViewDate = (TextView) convertView.findViewById(R.id.textViewDate);
|
||||
view.imageViewRecycle = (ImageView) convertView.findViewById(R.id.imageViewRecycle);
|
||||
view.imageViewRecycle.setVisibility(View.GONE);
|
||||
convertView.setTag(view);
|
||||
} else {
|
||||
}
|
||||
else
|
||||
{
|
||||
view = (ViewHolder) convertView.getTag();
|
||||
}
|
||||
|
||||
hash.put(position, convertView);
|
||||
|
||||
|
||||
|
||||
/* if recording doesn't exists change background */
|
||||
if (Boolean.FALSE.equals(recordingExists.get(position)))
|
||||
view.getLayoutRecording().setBackgroundColor(0xFFFFFFFF);
|
||||
else {
|
||||
if(!recordingExists.get(position))
|
||||
view.layoutRecording.setBackgroundColor(0xFFFFFFFF);
|
||||
else
|
||||
{
|
||||
/* if recording is not playing let background to white */
|
||||
if (Boolean.FALSE.equals(playingPositions.get(position)))
|
||||
view.getLayoutRecording().setBackgroundColor(0xFFFFFFFF);
|
||||
if(!playingPositions.get(position))
|
||||
view.layoutRecording.setBackgroundColor(0xFFFFFFFF);
|
||||
else
|
||||
view.getLayoutRecording().setBackgroundColor(0xFF457c98);
|
||||
view.layoutRecording.setBackgroundColor(0xFF457c98);
|
||||
}
|
||||
|
||||
/* change icon according to call type [outgoing or incoming] */
|
||||
SM.Exception("REC TYPE : " + listRecordings.get(position).callType);
|
||||
switch (listRecordings.get(position).callType) {
|
||||
case 6:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.call_received_all);
|
||||
break;
|
||||
case 2:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.call_made_all);
|
||||
break;
|
||||
case 4:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.call_received);
|
||||
break;
|
||||
case 0:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.call_made);
|
||||
break;
|
||||
case 5:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.call_received_group);
|
||||
break;
|
||||
case 1:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.call_made_group);
|
||||
break;
|
||||
default:
|
||||
view.getImageViewPlay().setImageResource(R.drawable.alert);
|
||||
SM.Exception("REC TYPE : " + listRecordings.get(position).type);
|
||||
switch(listRecordings.get(position).type)
|
||||
{
|
||||
case AppParams.AllCall:
|
||||
if(listRecordings.get(position).destinationRadioID == 0)
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_received_all);
|
||||
else
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_made_all);
|
||||
break;
|
||||
case AppParams.PrivateCall:
|
||||
if(listRecordings.get(position).destinationRadioID == 0)
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_received);
|
||||
else
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_made);
|
||||
break;
|
||||
case AppParams.GroupCall:
|
||||
if(listRecordings.get(position).destinationRadioID == 0)
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_received_group);
|
||||
else
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_made_group);
|
||||
break;
|
||||
}
|
||||
/*
|
||||
try
|
||||
{
|
||||
if(receivedPositions.get(position))
|
||||
{
|
||||
if(playingPositions.get(position))
|
||||
view.imageViewPlay.setImageResource(R.drawable.play_received);
|
||||
else
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_received);
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
if(playingPositions.get(position))
|
||||
view.imageViewPlay.setImageResource(R.drawable.play_made);
|
||||
else
|
||||
view.imageViewPlay.setImageResource(R.drawable.call_made);
|
||||
}
|
||||
}
|
||||
catch(Exception ex)
|
||||
{
|
||||
SM.Exception("EXCeptioN", ex.toString());
|
||||
view.imageViewPlay.setImageResource(R.drawable.play);
|
||||
}*/
|
||||
|
||||
/* intercept Recycle click */
|
||||
view.getImageViewRecycle().setOnClickListener(v -> {
|
||||
// change the background for marked record
|
||||
View view1 = hash.get(position);
|
||||
ViewHolder viewHolder = null;
|
||||
if (view1 != null) {
|
||||
viewHolder = (ViewHolder) view1.getTag();
|
||||
view.imageViewRecycle.setOnClickListener(new OnClickListener() {
|
||||
@Override
|
||||
public void onClick(View v) {
|
||||
// save the position of the marked record
|
||||
removePosition = position;
|
||||
|
||||
// change the background for marked record
|
||||
View view = (View) hash.get(position);
|
||||
ViewHolder viewHolder = (ViewHolder) view.getTag();
|
||||
viewHolder.layoutRecording.setBackgroundColor(0xFF457c98);
|
||||
((AbstractRecordingsActivity) activity).deleteSelected(position);
|
||||
}
|
||||
if (viewHolder != null) {
|
||||
viewHolder.getLayoutRecording().setBackgroundColor(0xFF457c98);
|
||||
}
|
||||
((AbstractRecordingsActivity) activity).deleteSelected(position);
|
||||
});
|
||||
|
||||
view.getTextViewSender().setText(String.format("%s -> %s", getItem(position).userWhoCalled, getItem(position).userWhoWasCalled));
|
||||
view.textViewDuration.setText(String.format("[%d sec]", getItem(position).duration));
|
||||
// set recording image
|
||||
if(getItem(position).NameForDisplay.equals(AppParams.USERNAME))
|
||||
view.imageViewPlay.setImageDrawable(context.getResources().getDrawable(R.drawable.call_made_group));
|
||||
else
|
||||
view.imageViewPlay.setImageDrawable(context.getResources().getDrawable(R.drawable.call_received_group));
|
||||
|
||||
view.textViewSender.setText(getItem(position).NameForDisplay);
|
||||
view.textViewDuration.setText("[" + getItem(position).duration + " sec]");
|
||||
|
||||
/* Add call Date */
|
||||
Date date = new Date();
|
||||
date.setTime(listRecordings.get(position).date * 1000);
|
||||
|
||||
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("HH:mm:ss");
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
||||
calendar.set(Calendar.HOUR_OF_DAY,0);
|
||||
calendar.set(Calendar.MINUTE, 0);
|
||||
calendar.set(Calendar.SECOND, 0);
|
||||
calendar.set(Calendar.MILLISECOND, 0);
|
||||
|
||||
if (date.after(calendar.getTime()))
|
||||
simpleDateFormat = new SimpleDateFormat("HH:mm:ss");
|
||||
else
|
||||
simpleDateFormat = new SimpleDateFormat("MMM-dd HH:mm");
|
||||
|
||||
view.getTextViewDate().setText(simpleDateFormat.format(date));
|
||||
|
||||
if(date.after(calendar.getTime()))
|
||||
sdf = new SimpleDateFormat("HH:mm:ss");
|
||||
else
|
||||
sdf = new SimpleDateFormat("MMM-dd HH:mm");
|
||||
|
||||
// set gmt time
|
||||
//sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
|
||||
|
||||
view.textViewDate.setText(sdf.format(date));
|
||||
|
||||
return convertView;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the View for one row in the GridView
|
||||
*/
|
||||
public View getView(int position) {
|
||||
return hash.get(position);
|
||||
|
||||
/** Reset row background when recycle was canceled */
|
||||
public void cancelDelete()
|
||||
{
|
||||
View view = (View) hash.get(removePosition);
|
||||
if(recordingExists.get(removePosition))
|
||||
view.setBackgroundColor(0xFFFFFFFF);
|
||||
else
|
||||
view.setBackgroundColor(0xFFDDDDDD);
|
||||
|
||||
removePosition = -1;
|
||||
}
|
||||
|
||||
/**
|
||||
* Change playing recording background
|
||||
*/
|
||||
public void changePlaying(int position, boolean playing) {
|
||||
|
||||
/** Get the View for one row in the GridView */
|
||||
public View getView(int position)
|
||||
{
|
||||
return (View) hash.get(position);
|
||||
}
|
||||
|
||||
|
||||
/** Change playing recording background */
|
||||
public void changePlaying(int position, boolean playing)
|
||||
{
|
||||
// change value in the vector
|
||||
playingPositions.set(position, playing);
|
||||
|
||||
RecordingsGridViewAdapter.ViewHolder viewHolder = (RecordingsGridViewAdapter.ViewHolder) getView(position).getTag();
|
||||
if (!playing)
|
||||
viewHolder.getLayoutRecording().setBackgroundColor(0xFFFFFFFF);
|
||||
if(!playing)
|
||||
viewHolder.layoutRecording.setBackgroundColor(0xFFFFFFFF);
|
||||
else
|
||||
viewHolder.getLayoutRecording().setBackgroundColor(0xFF457c98);
|
||||
viewHolder.layoutRecording.setBackgroundColor(0xFF457c98);
|
||||
|
||||
View view = hash.get(position);
|
||||
// update hash
|
||||
if (view != null)
|
||||
view.setTag(viewHolder);
|
||||
hash.get(position).setTag(viewHolder);
|
||||
|
||||
}
|
||||
}
|
||||
@ -285,7 +285,7 @@ public class DatabaseCommunication {
|
||||
while (cursor.isAfterLast() == false)
|
||||
{
|
||||
Recording rec = new Recording();
|
||||
rec.id =cursor.getInt(0);
|
||||
rec.ID =cursor.getInt(0);
|
||||
rec.sourceRadioID = cursor.getInt(1);
|
||||
rec.destinationRadioID = cursor.getInt(2);
|
||||
rec.date = cursor.getInt(3);
|
||||
@ -315,7 +315,7 @@ public class DatabaseCommunication {
|
||||
if(cursor.getCount() > 0)
|
||||
{
|
||||
Recording rec = new Recording();
|
||||
rec.id =cursor.getInt(0);
|
||||
rec.ID =cursor.getInt(0);
|
||||
rec.sourceRadioID = cursor.getInt(1);
|
||||
rec.destinationRadioID = cursor.getInt(2);
|
||||
rec.date = cursor.getInt(3);
|
||||
@ -364,7 +364,7 @@ public class DatabaseCommunication {
|
||||
values.put("duration", rec.duration);
|
||||
values.put("filename", rec.filename);
|
||||
values.put("type", rec.type);
|
||||
id = database.delete("Recordings", "_id=" + rec.id, null);
|
||||
id = database.delete("Recordings", "_id=" + rec.ID, null);
|
||||
SM.Debug("DBQuery","Database Remove result: " + id);
|
||||
}
|
||||
//INSERT into SMS (timeGMT, imei_sour, imei_dest, mess, status) VALUES( 1324016412, 0, 101, 'two', 1)
|
||||
|
||||
@ -4,43 +4,36 @@ import java.util.ArrayList;
|
||||
|
||||
public class RecordMSG extends TCPmsg {
|
||||
|
||||
private ArrayList<Recording> recordList;
|
||||
|
||||
public RecordMSG(TCPmsg tcp) {
|
||||
public ArrayList<Recording> recordList;
|
||||
public static int count=0;
|
||||
public RecordMSG(TCPmsg tcp)
|
||||
{
|
||||
super(tcp);
|
||||
setRecordList(new ArrayList<>());
|
||||
recordList = new ArrayList<Recording>();
|
||||
String date4parsing = super.data;
|
||||
//SM.Debug("SMS date4parsing:"+date4parsing);
|
||||
String[] tempArr = date4parsing.split(";");
|
||||
|
||||
for (String s : tempArr) {
|
||||
String[] tempRec = s.split("&", -1);
|
||||
if (tempRec.length < 11)
|
||||
//SM.Debug("SMS tempArr.length:" +tempArr.length);
|
||||
for(int i =0; i<tempArr.length;i++)
|
||||
{
|
||||
String[] tempRec = tempArr[i].split("&");
|
||||
if(tempRec.length<7)
|
||||
continue;
|
||||
|
||||
Recording recValue = new Recording();
|
||||
recValue.id = Long.parseLong(tempRec[0]);
|
||||
recValue.startGMT = Integer.parseInt(tempRec[1]);
|
||||
recValue.endGMT = Integer.parseInt(tempRec[2]);
|
||||
recValue.gwID = Integer.parseInt(tempRec[3]);
|
||||
recValue.radioGWID = Integer.parseInt(tempRec[4]);
|
||||
recValue.subID = (tempRec[5] == null || tempRec[5].isEmpty()) ? 0 : Integer.parseInt(tempRec[5]);
|
||||
recValue.typeID = Integer.parseInt(tempRec[6]);
|
||||
recValue.callType = Integer.parseInt(tempRec[7]);
|
||||
recValue.groupCpsId = (tempRec[8] == null || tempRec[8].isEmpty()) ? 0 : Integer.parseInt(tempRec[8]);
|
||||
recValue.dispatcherId = (tempRec[9] == null || tempRec[9].isEmpty()) ? 0 : Integer.parseInt(tempRec[9]);
|
||||
recValue.groupName = tempRec[10];
|
||||
Recording RecValue = new Recording();
|
||||
RecValue.ID = Long.parseLong(tempRec[0]);
|
||||
RecValue.startGMT = Integer.parseInt(tempRec[1]);
|
||||
RecValue.endGMT = Integer.parseInt(tempRec[2]);
|
||||
RecValue.gwID = Integer.parseInt(tempRec[3]);
|
||||
RecValue.radioGWID = Integer.parseInt(tempRec[4]);
|
||||
RecValue.subID = Integer.parseInt(tempRec[5]);
|
||||
RecValue.typeID = Integer.parseInt(tempRec[6]);
|
||||
|
||||
getRecordList().add(recValue);
|
||||
recordList.add(RecValue);
|
||||
}
|
||||
|
||||
SM.Debug("alarmList size:" + this.getRecordList().size() + " total:" + this.getRecordList().size());
|
||||
}
|
||||
|
||||
public ArrayList<Recording> getRecordList() {
|
||||
return recordList;
|
||||
}
|
||||
|
||||
public void setRecordList(ArrayList<Recording> recordList) {
|
||||
this.recordList = recordList;
|
||||
count +=this.recordList.size();
|
||||
SM.Debug("alarmList size:" +this.recordList.size() + " total:" +count);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,19 +1,14 @@
|
||||
package com.safemobile.lib;
|
||||
|
||||
public class Recording {
|
||||
public long id;
|
||||
public long ID;
|
||||
public int startGMT;
|
||||
public int endGMT;
|
||||
public int gwID;
|
||||
public int radioGWID;
|
||||
public int callType;
|
||||
public int groupCpsId;
|
||||
public int dispatcherId;
|
||||
public int subID;
|
||||
public int typeID;
|
||||
public String userWhoCalled="";
|
||||
public String userWhoWasCalled = "";
|
||||
public String groupName = "";
|
||||
public String NameForDisplay="";
|
||||
|
||||
/** RadioPad */
|
||||
public long date;
|
||||
@ -23,8 +18,13 @@ public class Recording {
|
||||
public long sourceRadioID;
|
||||
public int type;
|
||||
|
||||
public Recording()
|
||||
{
|
||||
|
||||
}
|
||||
|
||||
public String toString()
|
||||
{
|
||||
return "id: " + id + " | start: " + startGMT + " | end: " + endGMT + " | gwID: " + gwID + " | radioGWID: " + radioGWID + " | subID: " + subID + " | typeID: " + typeID;
|
||||
return "ID: " + ID + " | start: " + startGMT + " | end: " + endGMT + " | gwID: " + gwID + " | radioGWID: " + radioGWID + " | subID: " + subID + " | typeID: " + typeID;
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,4 +1,10 @@
|
||||
package com.safemobile.services;
|
||||
import java.io.*;
|
||||
import java.net.*;
|
||||
import java.util.LinkedList;
|
||||
import java.util.NoSuchElementException;
|
||||
import java.util.Timer;
|
||||
import java.util.TimerTask;
|
||||
|
||||
import android.content.BroadcastReceiver;
|
||||
import android.content.Context;
|
||||
@ -11,17 +17,6 @@ import com.safemobile.lib.AppParams;
|
||||
import com.safemobile.lib.SM;
|
||||
import com.safemobile.lib.TCPmsg;
|
||||
|
||||
import java.io.DataInputStream;
|
||||
import java.io.DataOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.Socket;
|
||||
import java.net.UnknownHostException;
|
||||
import java.util.LinkedList;
|
||||
import java.util.NoSuchElementException;
|
||||
import java.util.Timer;
|
||||
import java.util.TimerTask;
|
||||
|
||||
|
||||
public class TCPhandler implements Runnable {
|
||||
private boolean alive = true;
|
||||
@ -29,7 +24,7 @@ public class TCPhandler implements Runnable {
|
||||
public String serverHostname;
|
||||
private int port;
|
||||
private Thread listenThread;
|
||||
private Socket soc = null;
|
||||
private Socket soc =null;
|
||||
|
||||
private DataInputStream input;
|
||||
private DataOutputStream output;
|
||||
@ -46,7 +41,7 @@ public class TCPhandler implements Runnable {
|
||||
|
||||
public TCPhandler(Context context, String hostName, int p) {
|
||||
this.context = context;
|
||||
serverHostname = hostName;
|
||||
serverHostname=hostName;
|
||||
port = p;
|
||||
|
||||
msgList = new LinkedList<>();
|
||||
@ -113,57 +108,54 @@ public class TCPhandler implements Runnable {
|
||||
SM.Debug("TCPhandler Crash1 on sleep:"+ e);
|
||||
}
|
||||
|
||||
while (Boolean.TRUE.equals(isConnectionUP)) {
|
||||
while(isConnectionUP) {
|
||||
try {
|
||||
Thread.sleep(100);
|
||||
//process leftover
|
||||
try {
|
||||
boolean FinishLeftOver = true;
|
||||
while (FinishLeftOver) {
|
||||
// add this replacement if message length doesn't contain the last #
|
||||
String[] tempArr2 = leftOver.split("#");
|
||||
if (tempArr2.length > 1) {
|
||||
int messLen;
|
||||
try {
|
||||
messLen = Integer.parseInt(tempArr2[1]);
|
||||
} catch (Exception e) {
|
||||
messLen = Integer.parseInt(tempArr2[1]);
|
||||
|
||||
//TODO talk to Gaby to fix this on Bridge
|
||||
} catch (Exception e) {
|
||||
SM.Debug("leftovers", "incorect msg len leftOver =" + tempArr2[1]);
|
||||
messLen = -1;
|
||||
}
|
||||
messLen =-1;
|
||||
}
|
||||
|
||||
if (messLen > leftOver.length()) {
|
||||
FinishLeftOver = false;
|
||||
break;
|
||||
} else if (messLen == leftOver.length()) {
|
||||
TCPmsg msg = new TCPmsg(leftOver.toCharArray());
|
||||
SM.Debug("leftovers", "RX from leftOver:" + msg.allData);
|
||||
SM.Debug("leftovers", "RX from leftOver:"+msg.allData);
|
||||
|
||||
if (msg.allData.contains("#92#"))
|
||||
if(msg.allData.contains("#92#"))
|
||||
prioritizePongReceived();
|
||||
|
||||
msgList.add(msg);
|
||||
leftOver = "";
|
||||
FinishLeftOver = false;
|
||||
leftOver ="";
|
||||
break;
|
||||
} else // we have more message in leftover
|
||||
{
|
||||
TCPmsg msg = new TCPmsg(leftOver.substring(0, messLen).toCharArray());
|
||||
SM.Debug("leftovers", "RX from leftOver:" + msg.allData);
|
||||
} else { // we have more message in leftover
|
||||
TCPmsg msg = new TCPmsg(leftOver.substring(0,messLen).toCharArray());
|
||||
SM.Debug("leftovers", "RX from leftOver:"+msg.allData);
|
||||
|
||||
if (msg.allData.contains("#92#"))
|
||||
if(msg.allData.contains("#92#"))
|
||||
prioritizePongReceived();
|
||||
|
||||
msgList.add(msg);
|
||||
leftOver = leftOver.substring(messLen, leftOver.length());
|
||||
}
|
||||
} else FinishLeftOver = false;
|
||||
leftOver = leftOver.substring(messLen);
|
||||
}
|
||||
} else FinishLeftOver = false;
|
||||
}
|
||||
} catch (Exception e) {
|
||||
SM.Debug("leftovers", "Error on process leftover" + e.toString());
|
||||
SM.Debug("leftovers", "Error on process leftover"+ e);
|
||||
}
|
||||
//end process leftover
|
||||
|
||||
String data = "";
|
||||
int n = 0;
|
||||
String data;
|
||||
int n;
|
||||
|
||||
byte[] buf = new byte[1024];
|
||||
// read data into buffer
|
||||
@ -179,12 +171,11 @@ public class TCPhandler implements Runnable {
|
||||
}
|
||||
|
||||
byte[] temp = new byte[n];
|
||||
if (n >= 0) System.arraycopy(buf, 0, temp, 0, n);
|
||||
System.arraycopy(buf, 0, temp, 0, n);
|
||||
|
||||
// decryptData
|
||||
temp = decryptTEA(temp);
|
||||
|
||||
data = new String(temp);
|
||||
// decryptData
|
||||
temp = decryptTEA(temp);
|
||||
data = new String(temp);
|
||||
|
||||
//if we have any leftovers from previous message add them
|
||||
if(leftOver.length() > 1) { // avoid case with only one #
|
||||
@ -245,7 +236,7 @@ public class TCPhandler implements Runnable {
|
||||
}
|
||||
//try to restart connection
|
||||
if (alive && isWiFiOn)
|
||||
restartTCP();
|
||||
RestartTCP();
|
||||
}
|
||||
SM.Debug("==================================");
|
||||
SM.Debug("TCP listenThread stoped!! alive = false");
|
||||
@ -287,38 +278,28 @@ public class TCPhandler implements Runnable {
|
||||
try {
|
||||
Thread.sleep(10);
|
||||
String cmdok = "#" + seqID + msg;
|
||||
Integer tmp = cmdok.length() + 1;
|
||||
int tmp = cmdok.length() + 1;
|
||||
//SM.Debug("tmp:"+tmp);
|
||||
|
||||
tmp += Integer.toString(tmp).length();
|
||||
if ((tmp == 10) || (tmp == 100) || (tmp == 1000)) tmp++;
|
||||
cmdok = "#" + Integer.toString(tmp) + cmdok;
|
||||
if ((tmp == 10)||(tmp == 100)||(tmp == 1000)) tmp++;
|
||||
cmdok = "#" + tmp + cmdok;
|
||||
|
||||
byte[] mess = encryptTEA(cmdok);
|
||||
Thread tcpThread = new Thread(() -> {
|
||||
try {
|
||||
output.write(mess);
|
||||
output.flush();
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
});
|
||||
|
||||
tcpThread.start();
|
||||
|
||||
output.write(mess);
|
||||
output.flush();
|
||||
|
||||
// show only notACK messages
|
||||
SM.Debug(" ", new String(mess));
|
||||
return true;
|
||||
} catch (InterruptedException e) {
|
||||
SM.Exception("TCPClient[Send]", e.toString());
|
||||
Thread.currentThread().interrupt();
|
||||
} catch (NoSuchElementException e) {
|
||||
} catch (IOException | NoSuchElementException | InterruptedException e) {
|
||||
SM.Exception("TCPClient[Send]", e.toString());
|
||||
}
|
||||
} else {
|
||||
} else
|
||||
return false;
|
||||
}
|
||||
} catch (Exception e) {
|
||||
SM.Debug("TCPhandler Write Procedure:" + e);
|
||||
SM.Debug("TCPhandler Write Procedure:"+ e);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
@ -347,7 +328,7 @@ public class TCPhandler implements Runnable {
|
||||
public void updateTCPparameters(String ip, String _port) {
|
||||
// stop socket
|
||||
try {
|
||||
if (soc != null)
|
||||
if(soc != null)
|
||||
soc.close();
|
||||
} catch (IOException e1) {
|
||||
e1.printStackTrace();
|
||||
@ -369,12 +350,12 @@ public class TCPhandler implements Runnable {
|
||||
TCPmsgParser._fireTCPConnectionUpEvent(previousConnectionWasUP);
|
||||
}
|
||||
|
||||
private void restartTCP() {
|
||||
private void RestartTCP() {
|
||||
try {
|
||||
isConnectionUP = false;
|
||||
previousConnectionWasUP = false;
|
||||
|
||||
SM.Debug("Restarting TCP...ip:" + serverHostname + ":" + port);
|
||||
SM.Debug("Restarting TCP...ip:"+serverHostname + ":" + port);
|
||||
soc = new Socket();
|
||||
soc.connect(new InetSocketAddress(serverHostname, port), 5000);
|
||||
|
||||
@ -382,21 +363,13 @@ public class TCPhandler implements Runnable {
|
||||
//output stream
|
||||
output = new DataOutputStream(soc.getOutputStream());
|
||||
|
||||
if (soc != null) {
|
||||
if (soc != null)
|
||||
isConnectionUP = true;
|
||||
}
|
||||
|
||||
} catch (UnknownHostException e) {
|
||||
SM.Exception("restartTCP break:" + e.toString());
|
||||
} catch (NullPointerException | IOException e) {
|
||||
SM.Exception("RestartTCP break:"+ e);
|
||||
isConnectionUP = false;
|
||||
} catch (IllegalArgumentException e) {
|
||||
SM.Debug("IllegalArgumentException", "restartTCP break:" + e.toString());
|
||||
} catch (IOException e) {
|
||||
SM.Exception("restartTCP break:" + e.toString());
|
||||
isConnectionUP = false;
|
||||
} catch (NullPointerException e) {
|
||||
SM.Exception("restartTCP break:" + e.toString());
|
||||
isConnectionUP = false;
|
||||
SM.Debug("IllegalArgumentException", "RestartTCP break:"+ e);
|
||||
}
|
||||
triggerTCPConnectionStateEvent();
|
||||
}
|
||||
@ -406,7 +379,7 @@ public class TCPhandler implements Runnable {
|
||||
try {
|
||||
input = null;
|
||||
output = null;
|
||||
if (soc != null)
|
||||
if(soc!=null)
|
||||
soc.close();
|
||||
soc = null;
|
||||
} catch (IOException e) {
|
||||
|
||||
@ -45,6 +45,7 @@
|
||||
android:name="com.safemobile.safedispatch.SDMobileActivity"
|
||||
android:configChanges="orientation"
|
||||
android:exported="true"
|
||||
android:label="@string/app_name_demo"
|
||||
android:screenOrientation="landscape">
|
||||
<intent-filter>
|
||||
<action android:name="android.intent.action.MAIN" />
|
||||
|
||||
@ -22,7 +22,7 @@ public class AudioHandle implements Runnable{
|
||||
private DataOutputStream outData =null;
|
||||
private Thread t_micListner;
|
||||
private UDPclient udp;
|
||||
private TcpAudioClient tcp;
|
||||
private TCPaudioClient tcp;
|
||||
private int audioport = 50001;
|
||||
|
||||
public int typeUDP;
|
||||
@ -56,7 +56,7 @@ public class AudioHandle implements Runnable{
|
||||
else
|
||||
{
|
||||
try {
|
||||
tcp = new TcpAudioClient(IP,audioport);
|
||||
tcp = new TCPaudioClient(IP,audioport);
|
||||
bufferSize = AudioTrack.getMinBufferSize(SAMPLE_RATE, AudioFormat.CHANNEL_OUT_MONO, AudioFormat.ENCODING_PCM_16BIT);
|
||||
|
||||
|
||||
@ -155,7 +155,7 @@ public class AudioHandle implements Runnable{
|
||||
/*
|
||||
tempBuffer = new byte[16384];//128];//invers3.bufferSize];
|
||||
bRead = recDev.read(tempBuffer, 0,16384);// 128);//invers3.bufferSize);*/
|
||||
tcp.send(tempBuffer,bRead);
|
||||
tcp.Send(tempBuffer,bRead);
|
||||
SM.Debug("TCP sending b:"+bRead);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,65 +1,84 @@
|
||||
package com.safemobile.lib.sound;
|
||||
|
||||
import android.media.AudioFormat;
|
||||
import android.media.AudioManager;
|
||||
import android.media.AudioTrack;
|
||||
|
||||
import com.safemobile.lib.SM;
|
||||
|
||||
import android.media.AudioFormat;
|
||||
import android.media.AudioManager;
|
||||
import android.media.AudioRecord;
|
||||
import android.media.AudioTrack;
|
||||
import android.media.MediaRecorder;
|
||||
|
||||
public class RecordingHandle {
|
||||
private Boolean soundNeeded = false;
|
||||
private AudioTrack playDev = null;
|
||||
public Boolean isAlive = false;
|
||||
public Boolean soundNeeded = false;
|
||||
private AudioTrack playDev =null;
|
||||
private int bufferSize;
|
||||
private TCPaudioClient tcp;
|
||||
private int recport = 50002;
|
||||
|
||||
public RecordingHandle(String ip) {
|
||||
public RecordingHandle(String IP)
|
||||
{
|
||||
try {
|
||||
final int RECORDING_PORT = 50003;
|
||||
TcpAudioClient tcp = new TcpAudioClient(ip, RECORDING_PORT);
|
||||
final int sampleRate = 8000;
|
||||
int bufferSize = AudioTrack.getMinBufferSize(sampleRate, AudioFormat.CHANNEL_OUT_MONO, AudioFormat.ENCODING_PCM_16BIT);
|
||||
tcp = new TCPaudioClient(IP,recport);
|
||||
int sampleRate = 8000;
|
||||
int bufsize = AudioTrack.getMinBufferSize(sampleRate, AudioFormat.CHANNEL_OUT_MONO, AudioFormat.ENCODING_PCM_16BIT);
|
||||
//init play device
|
||||
playDev = new AudioTrack(AudioManager.STREAM_MUSIC, sampleRate, AudioFormat.CHANNEL_OUT_MONO, AudioFormat.ENCODING_PCM_16BIT, bufferSize, AudioTrack.MODE_STREAM);
|
||||
playDev = new AudioTrack(AudioManager.STREAM_MUSIC,sampleRate,AudioFormat.CHANNEL_OUT_MONO, AudioFormat.ENCODING_PCM_16BIT,bufsize, AudioTrack.MODE_STREAM);
|
||||
|
||||
tcp.addTCPListener(event -> {
|
||||
byte[] data = event.data();
|
||||
int len = event.len();
|
||||
SM.Debug("received b:" + len + " data.length:" + data.length);
|
||||
playSound(data);
|
||||
tcp.addTCPListener(new ITCPaudioLis()
|
||||
{
|
||||
|
||||
@Override
|
||||
public void dataRecv(TCPaudioEvent event) {
|
||||
byte[] data = event.data();
|
||||
int len = event.len();
|
||||
SM.Debug("recv b:"+len+" data.length:"+data.length);
|
||||
if(data!=null)
|
||||
PlaySound(data, len);
|
||||
|
||||
}
|
||||
});
|
||||
} catch (Exception ex) {
|
||||
}
|
||||
catch(Exception ex) {
|
||||
SM.Exception("recordings", ex.toString());
|
||||
}
|
||||
}
|
||||
|
||||
private void playSound(byte[] data) {
|
||||
if (Boolean.TRUE.equals(getSoundNeeded())) {
|
||||
if (playDev.getState() == AudioTrack.STATE_INITIALIZED) {
|
||||
playDev.write(data, 0, data.length);
|
||||
private void PlaySound(byte[] data, int len)
|
||||
{
|
||||
if(soundNeeded)
|
||||
{
|
||||
if(playDev.getState() == playDev.STATE_INITIALIZED)
|
||||
{
|
||||
playDev.write(data, 0 , data.length);
|
||||
playDev.play();
|
||||
} else {
|
||||
SM.Debug("Cannot play sound playDev NOT init correctly");
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
SM.Debug("Cannot play sound playDev NOT init corectly");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public void startSound() {
|
||||
setSoundNeeded(true);
|
||||
public void StartSound()
|
||||
{
|
||||
|
||||
soundNeeded = true;
|
||||
}
|
||||
|
||||
public void stopSound() {
|
||||
if (playDev != null && playDev.getState() == AudioTrack.STATE_INITIALIZED) {
|
||||
if (playDev.getPlayState() == AudioTrack.PLAYSTATE_PLAYING)
|
||||
public void StopSound()
|
||||
{
|
||||
if(playDev.getState() == playDev.STATE_INITIALIZED)
|
||||
{
|
||||
if(playDev.getPlayState() == playDev.PLAYSTATE_PLAYING)
|
||||
playDev.stop();
|
||||
} else {
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
SM.Debug("Cannot STOP playDev");
|
||||
}
|
||||
setSoundNeeded(false);
|
||||
}
|
||||
|
||||
public Boolean getSoundNeeded() {
|
||||
return soundNeeded;
|
||||
}
|
||||
|
||||
public void setSoundNeeded(Boolean soundNeeded) {
|
||||
this.soundNeeded = soundNeeded;
|
||||
soundNeeded= false;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,195 @@
|
||||
package com.safemobile.lib.sound;
|
||||
|
||||
import com.safemobile.lib.SM;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
import java.net.Socket;
|
||||
import java.net.UnknownHostException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
|
||||
public class TCPaudioClient implements Runnable{
|
||||
private boolean alive = true;
|
||||
|
||||
public String serverHostname = new String ("10.120.1.114");//
|
||||
private int port = 50001;
|
||||
private Thread listenThread;
|
||||
private Socket soc =null;
|
||||
|
||||
private InputStream recv;
|
||||
private OutputStream writer;
|
||||
|
||||
private volatile int n=0;
|
||||
|
||||
public Boolean connOK=false;
|
||||
byte[] buffer = new byte[16384];
|
||||
private List<ITCPaudioLis> _listeners = new ArrayList<ITCPaudioLis>();
|
||||
|
||||
public TCPaudioClient(String hostName, int _port)
|
||||
{
|
||||
serverHostname=hostName;
|
||||
this.port = _port;
|
||||
SM.Debug("---TCPhandler construcort--- port:"+_port);
|
||||
listenThread = new Thread(this, "TCPlisten");
|
||||
listenThread.start(); // (2) Start the thread.
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
try
|
||||
{
|
||||
soc = new Socket(serverHostname, port);
|
||||
SM.Debug("Socket timeout:" + soc.getSoTimeout() );
|
||||
//soc.setSoTimeout(5000);
|
||||
recv= soc.getInputStream();
|
||||
writer =soc.getOutputStream() ;
|
||||
if(soc !=null)
|
||||
connOK = true;
|
||||
|
||||
}
|
||||
catch (UnknownHostException e)
|
||||
{
|
||||
SM.Debug("UnknownHostException", "break:"+e.toString());
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
SM.Debug("IOException", "break:"+e.toString());
|
||||
}
|
||||
|
||||
while(alive)
|
||||
{
|
||||
try {
|
||||
Thread.sleep(3000);
|
||||
} catch (InterruptedException e) {
|
||||
// TODO Auto-generated catch block
|
||||
SM.Debug(e.toString());
|
||||
}
|
||||
while(connOK)
|
||||
{
|
||||
try
|
||||
{
|
||||
buffer = new byte[16384];
|
||||
n = recv.read(buffer);
|
||||
if(n==-1)
|
||||
break;
|
||||
_fireDataArrived(buffer,n);
|
||||
}
|
||||
catch(Exception ex)
|
||||
{
|
||||
SM.Debug("break:"+ex.toString());
|
||||
connOK = false;
|
||||
}
|
||||
}//while(connOK)
|
||||
|
||||
try {
|
||||
Thread.sleep(3000);
|
||||
} catch (InterruptedException e) {
|
||||
// TODO Auto-generated catch block
|
||||
SM.Debug(e.toString());
|
||||
}
|
||||
if(alive)RestartTCP();
|
||||
}//while(alive)
|
||||
SM.Debug("==================================");
|
||||
SM.Debug("TCP listenThread stoped!! alive = false");
|
||||
SM.Debug("==================================");
|
||||
}
|
||||
|
||||
public boolean Send(byte[] data,int len)
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
if(writer != null)
|
||||
{
|
||||
writer.write(data,0,len);
|
||||
return true;
|
||||
}
|
||||
else
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
// TODO Auto-generated catch block
|
||||
SM.Debug(e.toString());
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
private void RestartTCP()
|
||||
{
|
||||
try
|
||||
{
|
||||
SM.Debug("Restarting TCP...ip:"+serverHostname);
|
||||
soc = new Socket(serverHostname, port);
|
||||
recv= soc.getInputStream();
|
||||
writer =soc.getOutputStream();
|
||||
if(soc !=null)
|
||||
connOK = true;
|
||||
|
||||
}
|
||||
catch (UnknownHostException e)
|
||||
{
|
||||
SM.Debug("break:"+e.toString());
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
SM.Debug("break:"+e.toString());
|
||||
}
|
||||
}
|
||||
|
||||
public boolean isAlive() {
|
||||
return alive;
|
||||
}
|
||||
|
||||
public void setAlive(boolean alive) {
|
||||
this.alive = alive;
|
||||
}
|
||||
|
||||
public void Stop()
|
||||
{
|
||||
|
||||
this.alive = false;
|
||||
if(soc !=null)
|
||||
{
|
||||
try {
|
||||
soc.close();
|
||||
soc = null;
|
||||
} catch (IOException e) {
|
||||
// TODO Auto-generated catch block
|
||||
SM.Debug("break:"+e.toString());
|
||||
}
|
||||
connOK = false;
|
||||
}
|
||||
// stop thread
|
||||
if(listenThread != null)
|
||||
{
|
||||
Thread moribund = listenThread;
|
||||
listenThread = null;
|
||||
moribund.interrupt();
|
||||
}
|
||||
}
|
||||
|
||||
public synchronized void addTCPListener( ITCPaudioLis l ) {
|
||||
_listeners.add( (ITCPaudioLis) l );
|
||||
}
|
||||
|
||||
public synchronized void removeTCPListener( ITCPaudioLis l ) {
|
||||
_listeners.remove( l );
|
||||
}
|
||||
|
||||
private synchronized void _fireDataArrived(byte[] data, int len) {
|
||||
TCPaudioEvent event = new TCPaudioEvent( this, data, len );
|
||||
Iterator<ITCPaudioLis> listeners = _listeners.iterator();
|
||||
while( listeners.hasNext() ) {
|
||||
( (ITCPaudioLis) listeners.next() ).dataRecv(event);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,174 +0,0 @@
|
||||
package com.safemobile.lib.sound;
|
||||
|
||||
import com.safemobile.lib.SM;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
import java.net.Socket;
|
||||
import java.net.UnknownHostException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
public class TcpAudioClient implements Runnable {
|
||||
private boolean alive = true;
|
||||
|
||||
private String serverHostname;
|
||||
private final int port;
|
||||
private Thread listenThread;
|
||||
private Socket soc = null;
|
||||
|
||||
private InputStream recv;
|
||||
private OutputStream writer;
|
||||
|
||||
private Boolean connOK = false;
|
||||
byte[] buffer = new byte[16384];
|
||||
private final List<ITCPaudioLis> listeners = new ArrayList<>();
|
||||
|
||||
public TcpAudioClient(String hostName, int port) {
|
||||
setServerHostname(hostName);
|
||||
this.port = port;
|
||||
SM.Debug("---TcpHandler constructor--- port:" + port);
|
||||
listenThread = new Thread(this, "TcpListen");
|
||||
listenThread.start(); // (2) Start the thread.
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
soc = new Socket(getServerHostname(), port);
|
||||
SM.Debug("Socket timeout:" + soc.getSoTimeout());
|
||||
recv = soc.getInputStream();
|
||||
writer = soc.getOutputStream();
|
||||
if (soc != null)
|
||||
setConnOK(true);
|
||||
|
||||
} catch (UnknownHostException e) {
|
||||
SM.Debug("UnknownHostException", "break:" + e);
|
||||
} catch (IOException e) {
|
||||
SM.Debug("IOException", "break:" + e);
|
||||
}
|
||||
|
||||
while (alive) {
|
||||
try {
|
||||
Thread.sleep(3000);
|
||||
} catch (InterruptedException e) {
|
||||
SM.Debug(e.toString());
|
||||
Thread.currentThread().interrupt();
|
||||
}
|
||||
while (Boolean.TRUE.equals(getConnOK())) {
|
||||
try {
|
||||
buffer = new byte[16384];
|
||||
int n = recv.read(buffer);
|
||||
if (n == -1)
|
||||
break;
|
||||
fireDataArrived(buffer, n);
|
||||
} catch (Exception ex) {
|
||||
SM.Debug("break:" + ex);
|
||||
setConnOK(false);
|
||||
}
|
||||
}
|
||||
|
||||
try {
|
||||
Thread.sleep(3000);
|
||||
} catch (InterruptedException e) {
|
||||
SM.Debug(e.toString());
|
||||
Thread.currentThread().interrupt();
|
||||
}
|
||||
|
||||
if (alive) restartTCP();
|
||||
}
|
||||
SM.Debug("==================================");
|
||||
SM.Debug("TCP listenThread stopped!! alive = false");
|
||||
SM.Debug("==================================");
|
||||
}
|
||||
|
||||
public boolean send(byte[] data, int len) {
|
||||
|
||||
try {
|
||||
|
||||
if (writer != null) {
|
||||
writer.write(data, 0, len);
|
||||
return true;
|
||||
} else {
|
||||
return false;
|
||||
}
|
||||
} catch (Exception e) {
|
||||
SM.Debug(e.toString());
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
private void restartTCP() {
|
||||
try {
|
||||
SM.Debug("Restarting TCP...ip:" + getServerHostname());
|
||||
soc = new Socket(getServerHostname(), port);
|
||||
recv = soc.getInputStream();
|
||||
writer = soc.getOutputStream();
|
||||
setConnOK(true);
|
||||
|
||||
} catch (IOException e) {
|
||||
SM.Debug("break:" + e);
|
||||
}
|
||||
}
|
||||
|
||||
public boolean isAlive() {
|
||||
return alive;
|
||||
}
|
||||
|
||||
public void setAlive(boolean alive) {
|
||||
this.alive = alive;
|
||||
}
|
||||
|
||||
public void stop() {
|
||||
|
||||
this.alive = false;
|
||||
if (soc != null) {
|
||||
try {
|
||||
soc.close();
|
||||
soc = null;
|
||||
} catch (IOException e) {
|
||||
SM.Debug("break:" + e);
|
||||
}
|
||||
setConnOK(false);
|
||||
}
|
||||
// stop thread
|
||||
if (listenThread != null) {
|
||||
Thread moribund = listenThread;
|
||||
listenThread = null;
|
||||
moribund.interrupt();
|
||||
}
|
||||
}
|
||||
|
||||
public synchronized void addTCPListener(ITCPaudioLis l) {
|
||||
listeners.add(l);
|
||||
}
|
||||
|
||||
public synchronized void removeTCPListener(ITCPaudioLis l) {
|
||||
listeners.remove(l);
|
||||
}
|
||||
|
||||
private synchronized void fireDataArrived(byte[] data, int len) {
|
||||
TCPaudioEvent event = new TCPaudioEvent(this, data, len);
|
||||
for (ITCPaudioLis listener : listeners) {
|
||||
listener.dataRecv(event);
|
||||
}
|
||||
}
|
||||
|
||||
public String getServerHostname() {
|
||||
return serverHostname;
|
||||
}
|
||||
|
||||
public void setServerHostname(String serverHostname) {
|
||||
this.serverHostname = serverHostname;
|
||||
}
|
||||
|
||||
public Boolean getConnOK() {
|
||||
return connOK;
|
||||
}
|
||||
|
||||
public void setConnOK(Boolean connOK) {
|
||||
this.connOK = connOK;
|
||||
}
|
||||
}
|
||||
@ -15,7 +15,7 @@ import com.safemobile.lib.SM;
|
||||
public class UDPclient implements Runnable{
|
||||
|
||||
public String serverHostname = new String ("10.120.1.114");//
|
||||
private int UDP_SERVER_PORT_IN = 50003;
|
||||
private int UDP_SERVER_PORT_IN = 50002;
|
||||
private int UDP_SERVER_PORT_OUT = 50001;
|
||||
private DatagramSocket ds = null;
|
||||
private Thread listenThread;
|
||||
|
||||
@ -2,8 +2,10 @@ package com.safemobile.safedispatch;
|
||||
|
||||
import android.app.Activity;
|
||||
import android.app.AlertDialog;
|
||||
import android.app.Dialog;
|
||||
import android.content.BroadcastReceiver;
|
||||
import android.content.Context;
|
||||
import android.content.DialogInterface;
|
||||
import android.content.Intent;
|
||||
import android.content.IntentFilter;
|
||||
import android.content.res.AssetFileDescriptor;
|
||||
@ -12,12 +14,13 @@ import android.graphics.Typeface;
|
||||
import android.media.MediaPlayer;
|
||||
import android.os.Bundle;
|
||||
import android.os.Handler;
|
||||
import android.os.Looper;
|
||||
import android.view.View;
|
||||
import android.view.View.OnClickListener;
|
||||
import android.widget.AdapterView;
|
||||
import android.widget.AdapterView.OnItemClickListener;
|
||||
import android.widget.ArrayAdapter;
|
||||
import android.widget.GridView;
|
||||
import android.widget.ImageView;
|
||||
import android.widget.TextView;
|
||||
import android.widget.Toast;
|
||||
|
||||
@ -33,210 +36,251 @@ import java.io.IOException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Locale;
|
||||
|
||||
/**
|
||||
* fix import
|
||||
*/
|
||||
|
||||
public class RecordingsActivity extends Activity {
|
||||
private Context context;
|
||||
private Activity activity;
|
||||
private TabLayoutActivity parentTab;
|
||||
private ArrayList<Recording> allRecordings = new ArrayList<>();
|
||||
private ArrayList<Boolean> playingPositions = new ArrayList<>();
|
||||
public TabLayoutActivity parentTab;
|
||||
public ArrayList<Recording> allRecordings = new ArrayList<Recording>();
|
||||
private ArrayList<Boolean> playingPositions = new ArrayList<Boolean>();
|
||||
private ArrayList<String> allGWsIP = new ArrayList<String>();
|
||||
private GridView gridView;
|
||||
private RecordingsGridViewAdapter adapter;
|
||||
private View convertViewRecording;
|
||||
public View convertViewRecording;
|
||||
|
||||
private int playingPosition = -1;
|
||||
public int playingPosition = -1;
|
||||
|
||||
// Need handler for callbacks to the UI thread
|
||||
private final Handler myHandler = new Handler(Looper.getMainLooper());
|
||||
private final ArrayList<String> allGWsIP = new ArrayList<>();
|
||||
private final Handler myHandler = new Handler();
|
||||
|
||||
//recoding TCP and audio
|
||||
private RecordingHandle recHandle = null;
|
||||
//recoding TCP and audio
|
||||
private RecordingHandle recHandle = null;
|
||||
|
||||
/* Dialog */
|
||||
private TextView textViewCount;
|
||||
private TextView textViewGateway;
|
||||
/* Dialog */
|
||||
private TextView textViewCount, textViewGateway;
|
||||
|
||||
private Bundle savedInstanceState;
|
||||
public Bundle savedInstanceState;
|
||||
|
||||
/**
|
||||
* Called when the activity is first created.
|
||||
*/
|
||||
@Override
|
||||
public void onCreate(Bundle savedInstanceState) {
|
||||
super.onCreate(savedInstanceState);
|
||||
this.setSavedInstanceState(savedInstanceState);
|
||||
setParentTab((TabLayoutActivity) getParent());
|
||||
/** Called when the activity is first created. */
|
||||
public void onCreate(Bundle savedInstanceState) {
|
||||
super.onCreate(savedInstanceState);
|
||||
this.savedInstanceState = savedInstanceState;
|
||||
// get parentTab
|
||||
parentTab = (TabLayoutActivity)getParent();
|
||||
|
||||
Locale locale = new Locale(AppParams.LANGUAGETMP);
|
||||
Locale.setDefault(locale);
|
||||
Configuration config = new Configuration();
|
||||
config.locale = locale;
|
||||
getBaseContext().getResources().updateConfiguration(config, getBaseContext().getResources().getDisplayMetrics());
|
||||
Locale locale = new Locale(AppParams.LANGUAGETMP);
|
||||
Locale.setDefault(locale);
|
||||
Configuration config = new Configuration();
|
||||
config.locale = locale;
|
||||
getBaseContext().getResources().updateConfiguration(config,
|
||||
getBaseContext().getResources().getDisplayMetrics());
|
||||
|
||||
setContentView(R.layout.tabrecordings);
|
||||
setContentView(R.layout.tabrecordings);
|
||||
|
||||
// get context
|
||||
context = this;
|
||||
activity = this;
|
||||
|
||||
// change tab header fontFace
|
||||
TextView textView1 = findViewById(R.id.textViewTitle);
|
||||
textView1.setTypeface(Typeface.createFromAsset(getAssets(), "Sketch_Block.ttf"));
|
||||
textView1.setTextSize(24);
|
||||
// get context
|
||||
context = this;
|
||||
activity = this;
|
||||
|
||||
gridView = findViewById(R.id.gridViewRecordings);
|
||||
adapter = new RecordingsGridViewAdapter(activity, getAllRecordings(), playingPositions);
|
||||
gridView.setAdapter(adapter);
|
||||
|
||||
gridView.setOnItemClickListener(onItemClickListener);
|
||||
// change tab header fontface
|
||||
TextView textView1 = (TextView) findViewById(R.id.textViewTitle);
|
||||
textView1.setTypeface(Typeface.createFromAsset(getAssets(), "Sketch_Block.ttf"));
|
||||
textView1.setTextSize(24);
|
||||
|
||||
if (recHandle == null && !AppParams.DEMO)
|
||||
recHandle = new RecordingHandle(AppParams.IP);
|
||||
gridView = (GridView) findViewById(R.id.gridViewRecordings);
|
||||
adapter = new RecordingsGridViewAdapter(activity, context, allRecordings, playingPositions);
|
||||
gridView.setAdapter(adapter);
|
||||
|
||||
textViewCount = findViewById(R.id.textViewCount);
|
||||
updateNumberOfRecordings();
|
||||
gridView.setOnItemClickListener(onItemClickListener);
|
||||
|
||||
textViewGateway = findViewById(R.id.textViewGateway);
|
||||
textViewGateway.setTypeface(Typeface.createFromAsset(getAssets(), "Sketch_Block.ttf"));
|
||||
if(recHandle == null && !AppParams.DEMO)
|
||||
recHandle = new RecordingHandle(AppParams.IP);
|
||||
|
||||
|
||||
textViewCount = (TextView) findViewById(R.id.textViewCount);
|
||||
updateNumberOfRecordings();
|
||||
|
||||
textViewGateway = (TextView) findViewById(R.id.textViewGateway);
|
||||
textViewGateway.setTypeface(Typeface.createFromAsset(getAssets(), "Sketch_Block.ttf"));
|
||||
textViewGateway.setTextSize(24);
|
||||
textViewGateway.setOnClickListener(v -> {
|
||||
allGWsIP.clear();
|
||||
for (RadioGW radio : AppParams.listRadios)
|
||||
allGWsIP.add(radio.IP);
|
||||
textViewGateway.setOnClickListener(new OnClickListener() {
|
||||
@Override
|
||||
public void onClick(View v) {
|
||||
allGWsIP.clear();
|
||||
for(RadioGW radio: AppParams.listRadios)
|
||||
allGWsIP.add(radio.IP);
|
||||
|
||||
ArrayAdapter<String> adapter = new ArrayAdapter<>(context, R.layout.template_simple_list_item,
|
||||
allGWsIP);
|
||||
ArrayAdapter<String> adapter = new ArrayAdapter<String>(context, R.layout.template_simple_list_item,
|
||||
allGWsIP);
|
||||
|
||||
AlertDialog.Builder builder = new AlertDialog.Builder(
|
||||
context);
|
||||
builder.setTitle("Select RadioGW");
|
||||
builder.setAdapter(adapter,
|
||||
(dialog, which) -> {
|
||||
// change gateway
|
||||
textViewGateway.setText(allGWsIP.get(which));
|
||||
Toast.makeText(context, getString(R.string.loadingRecordings), Toast.LENGTH_SHORT).show();
|
||||
getRecordings(getParentTab().getAllRadios().get(which).GW_ID, getParentTab().getAllRadios().get(which).ID);
|
||||
});
|
||||
AlertDialog alert = builder.create();
|
||||
alert.show();
|
||||
AlertDialog.Builder builder = new AlertDialog.Builder(
|
||||
context);
|
||||
builder.setTitle("Select RadioGW");
|
||||
builder.setAdapter(adapter,
|
||||
new DialogInterface.OnClickListener() {
|
||||
@Override
|
||||
public void onClick(DialogInterface dialog, int which) {
|
||||
// change gateway
|
||||
textViewGateway.setText(allGWsIP.get(which));
|
||||
Toast.makeText(context, getString(R.string.loadingRecordings), Toast.LENGTH_SHORT).show();
|
||||
GetRecordings(parentTab.getAllRadios().get(which).GW_ID, parentTab.getAllRadios().get(which).ID);
|
||||
}
|
||||
});
|
||||
AlertDialog alert = builder.create();
|
||||
alert.show();
|
||||
}
|
||||
});
|
||||
textViewGateway.setVisibility(View.INVISIBLE);
|
||||
|
||||
getParentTab().setRecordingsActivity(this);
|
||||
|
||||
// register to receive broadcasts
|
||||
registerBroadcastIntents();
|
||||
parentTab.setRecordingsActivity(this);
|
||||
|
||||
// register to receive broadcasts
|
||||
registerBroadcastIntents();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onBackPressed()
|
||||
{
|
||||
AlertDialog.Builder builder = new AlertDialog.Builder(this);
|
||||
builder.setMessage(getString(R.string.exit))
|
||||
.setCancelable(false)
|
||||
.setNeutralButton(getString(R.string.logout), new DialogInterface.OnClickListener() {
|
||||
public void onClick(DialogInterface dialog, int id) {
|
||||
parentTab.whenBackPressed(AppParams.ActivityResult.logout);
|
||||
}
|
||||
})
|
||||
.setPositiveButton(getString(R.string.ext), new DialogInterface.OnClickListener() {
|
||||
public void onClick(DialogInterface dialog, int id) {
|
||||
parentTab.whenBackPressed(AppParams.ActivityResult.exit);
|
||||
}
|
||||
})
|
||||
.setNegativeButton(getString(R.string.cancel), new DialogInterface.OnClickListener() {
|
||||
public void onClick(DialogInterface dialog, int id) {
|
||||
dialog.cancel();
|
||||
}
|
||||
});
|
||||
AlertDialog alert = builder.create();
|
||||
alert.show();
|
||||
}
|
||||
|
||||
|
||||
/** Update the number of recordings displayed on the top layout */
|
||||
private void updateNumberOfRecordings() {
|
||||
textViewCount.setText("[" + AppParams.recordings.size() + "]");
|
||||
}
|
||||
|
||||
|
||||
|
||||
public void showDialog(String errorMsg)
|
||||
{
|
||||
Dialog dialog = new Dialog(context);
|
||||
dialog.setContentView(R.layout.dialog);
|
||||
dialog.setTitle("Message");
|
||||
dialog.setCancelable(true);
|
||||
dialog.setCanceledOnTouchOutside(true);
|
||||
|
||||
TextView text = dialog.findViewById(R.id.text);
|
||||
ImageView image = dialog.findViewById(R.id.image);
|
||||
|
||||
image.setImageResource(R.mipmap.ic_launcher);
|
||||
text.setText(errorMsg);
|
||||
dialog.show();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onBackPressed() {
|
||||
AlertDialog.Builder builder = new AlertDialog.Builder(this);
|
||||
builder.setMessage(getString(R.string.exit))
|
||||
.setCancelable(false)
|
||||
.setNeutralButton(getString(R.string.logout), (dialog, id) -> getParentTab().whenBackPressed(AppParams.ActivityResult.logout))
|
||||
.setPositiveButton(getString(R.string.ext), (dialog, id) -> getParentTab().whenBackPressed(AppParams.ActivityResult.exit))
|
||||
.setNegativeButton(getString(R.string.cancel), (dialog, id) -> dialog.cancel());
|
||||
AlertDialog alert = builder.create();
|
||||
alert.show();
|
||||
}
|
||||
|
||||
/**
|
||||
* Update the number of recordings displayed on the top layout
|
||||
*/
|
||||
private void updateNumberOfRecordings() {
|
||||
textViewCount.setText("[" + AppParams.recordings.size() + "]");
|
||||
}
|
||||
@Override
|
||||
public void onPause()
|
||||
{
|
||||
super.onPause();
|
||||
SM.Debug("onPause");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onPause() {
|
||||
super.onPause();
|
||||
SM.Debug("onPause");
|
||||
}
|
||||
@Override
|
||||
public void onResume()
|
||||
{
|
||||
super.onResume();
|
||||
if(parentTab.getTCPState() != null && !AppParams.DEMO){
|
||||
|
||||
@Override
|
||||
public void onResume() {
|
||||
super.onResume();
|
||||
if (getParentTab().getTCPState() != null && !AppParams.DEMO) {
|
||||
Toast.makeText(context, getString(R.string.moreRecordings), Toast.LENGTH_SHORT).show();
|
||||
|
||||
Toast.makeText(context, getString(R.string.moreRecordings), Toast.LENGTH_SHORT).show();
|
||||
if(parentTab.getCrtRadio() != null)
|
||||
textViewGateway.setText(parentTab.getCrtRadio().IP);
|
||||
|
||||
if (getParentTab().getCrtRadio() != null)
|
||||
textViewGateway.setText(getParentTab().getCrtRadio().IP);
|
||||
/*
|
||||
if(parentTab.allRadios == null)
|
||||
GetGWRadios();
|
||||
*/
|
||||
if(playingPosition < 0 && parentTab.getCrtRadio() != null)
|
||||
{
|
||||
SM.Debug("GetRecordings resume + crtRadio:"+ parentTab.getCrtRadio().toString());
|
||||
GetRecordings(parentTab.getCrtRadio().GW_ID, parentTab.getCrtRadio().ID);
|
||||
}
|
||||
|
||||
if (getPlayingPosition() < 0 && getParentTab().getCrtRadio() != null) {
|
||||
SM.Debug("getRecordings resume + crtRadio:" + getParentTab().getCrtRadio().toString());
|
||||
getRecordings(getParentTab().getCrtRadio().GW_ID, getParentTab().getCrtRadio().ID);
|
||||
}
|
||||
}
|
||||
SM.Debug("onResume");
|
||||
}
|
||||
}
|
||||
SM.Debug("onResume");
|
||||
}
|
||||
|
||||
private final OnItemClickListener onItemClickListener = new OnItemClickListener() {
|
||||
private OnItemClickListener onItemClickListener = new OnItemClickListener() {
|
||||
@Override
|
||||
public void onItemClick(AdapterView<?> arg0, View view, int position, long arg3) {
|
||||
|
||||
// disable grid scrolling and item click
|
||||
gridView.setEnabled(false);
|
||||
setConvertViewRecording(view);
|
||||
convertViewRecording = view;
|
||||
|
||||
// change background to playing
|
||||
adapter.changePlaying(position, true);
|
||||
|
||||
// if no recording is playing and not DEMO
|
||||
if (getPlayingPosition() < 0 && !AppParams.DEMO) {
|
||||
if(playingPosition<0 && !AppParams.DEMO)
|
||||
{
|
||||
// send recording request to App Server
|
||||
sendPlayRequest(getAllRecordings().get(position).id);
|
||||
SendPlayRequest(allRecordings.get(position).ID);
|
||||
// flag that sound is needed
|
||||
recHandle.startSound();
|
||||
recHandle.setSoundNeeded(true);
|
||||
recHandle.StartSound();
|
||||
recHandle.soundNeeded = true;
|
||||
}
|
||||
// no recording is playing and DEMO
|
||||
else if (getPlayingPosition() < 0 && AppParams.DEMO) {
|
||||
else if(playingPosition<0 && AppParams.DEMO)
|
||||
{
|
||||
// create player which will play demo recordings
|
||||
MediaPlayer player = new MediaPlayer();
|
||||
|
||||
AssetFileDescriptor assetFileDescriptor = null;
|
||||
AssetFileDescriptor afd;
|
||||
try {
|
||||
switch (position) {
|
||||
case 1:
|
||||
assetFileDescriptor = getAssets().openFd("startwindows.mp3");
|
||||
break;
|
||||
case 2:
|
||||
assetFileDescriptor = getAssets().openFd("exitwindows.mp3");
|
||||
break;
|
||||
default:
|
||||
assetFileDescriptor = getAssets().openFd("mike.mp3");
|
||||
break;
|
||||
}
|
||||
player.setDataSource(assetFileDescriptor.getFileDescriptor(), assetFileDescriptor.getStartOffset(), assetFileDescriptor.getLength());
|
||||
switch(position)
|
||||
{
|
||||
case 1: afd = getAssets().openFd("startwindows.mp3"); break;
|
||||
case 2: afd = getAssets().openFd("exitwindows.mp3"); break;
|
||||
default : afd = getAssets().openFd("mike.mp3"); break;
|
||||
};
|
||||
player.setDataSource(afd.getFileDescriptor(),afd.getStartOffset(),afd.getLength());
|
||||
player.prepare();
|
||||
player.start();
|
||||
player.start();
|
||||
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
if(assetFileDescriptor != null) {
|
||||
try {
|
||||
assetFileDescriptor.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (IOException e) { }
|
||||
}
|
||||
|
||||
// save playing position
|
||||
setPlayingPosition(position);
|
||||
playingPosition = position;
|
||||
|
||||
// start the timer which will reset the UI to 'no recording playing'
|
||||
startRecordingStopperTimer(getAllRecordings().get(getPlayingPosition()).endGMT - getAllRecordings().get(getPlayingPosition()).startGMT);
|
||||
startRecordingStoperTimer(allRecordings.get(playingPosition).endGMT - allRecordings.get(playingPosition).startGMT);
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* create Timer which will stop the recording after a specific time
|
||||
*/
|
||||
private void startRecordingStopperTimer(final int seconds) {
|
||||
new Thread(() -> {
|
||||
|
||||
/** create Timer which will stop the recording after a specific time */
|
||||
private void startRecordingStoperTimer(final int seconds) {
|
||||
new Thread(new Runnable() {
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
// sleep for at least 1 second
|
||||
final int ms = (seconds > 1 ? seconds * 1000 : 1000);
|
||||
|
||||
@ -245,137 +289,123 @@ public class RecordingsActivity extends Activity {
|
||||
Thread.sleep(ms);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
Thread.currentThread().interrupt();
|
||||
}
|
||||
|
||||
// modify the UI after the recording is done playing
|
||||
myHandler.post(stopRecordingRUN);
|
||||
}).start();
|
||||
}
|
||||
};
|
||||
}
|
||||
}).start();
|
||||
}
|
||||
|
||||
// Create runnable for posting
|
||||
final Runnable stopRecordingRUN = this::updateStopRecording;
|
||||
// Create runnable for posting
|
||||
final Runnable stopRecordingRUN = new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
updateStopRecording();
|
||||
}
|
||||
};
|
||||
|
||||
private void updateStopRecording() {
|
||||
// change playing icon
|
||||
adapter.changePlaying(getPlayingPosition(), false);
|
||||
private void updateStopRecording()
|
||||
{
|
||||
// change playing icon
|
||||
adapter.changePlaying(playingPosition, false);
|
||||
|
||||
// enable grid
|
||||
gridView.setEnabled(true);
|
||||
// enable grid
|
||||
gridView.setEnabled(true);
|
||||
|
||||
// set playing Recording position to -1
|
||||
setPlayingPosition(-1);
|
||||
}
|
||||
// set playing Recording position to -1
|
||||
playingPosition = -1;
|
||||
|
||||
// Update Recordings received from AppServer
|
||||
public void updateRecordings(ArrayList<Recording> list) {
|
||||
setAllRecordings(new ArrayList<>());
|
||||
for (Recording rec : list) {
|
||||
getAllRecordings().add(rec);
|
||||
}
|
||||
myHandler.post(updateResultsRUN);
|
||||
}
|
||||
}
|
||||
|
||||
// playRecording received from AppServer
|
||||
public void playRecording(long id) {
|
||||
// change adapter image
|
||||
}
|
||||
// Update Recordings received from AppServer
|
||||
public void UpdateRecordings(ArrayList<Recording> list)
|
||||
{
|
||||
//SM.Debug("## UpdateRecordings: " + list.size());
|
||||
allRecordings = new ArrayList<Recording>();
|
||||
for(Recording rec : list)
|
||||
{
|
||||
if(rec.typeID == 1 && rec.subID == AppParams.USERID)
|
||||
allRecordings.add(rec);
|
||||
else if (rec.typeID != 1)
|
||||
allRecordings.add(rec);
|
||||
}
|
||||
myHandler.post(UpdateResultsRUN);
|
||||
|
||||
// Create runnable for posting
|
||||
final Runnable updateResultsRUN = this::updateResultsInUi;
|
||||
}
|
||||
|
||||
private void updateResultsInUi() {
|
||||
// PlayRecording received from AppServer
|
||||
public void PlayRecording(long id)
|
||||
{
|
||||
// change adapter image
|
||||
|
||||
}
|
||||
|
||||
// Create runnable for posting
|
||||
final Runnable UpdateResultsRUN = new Runnable() {
|
||||
public void run() {
|
||||
updateResultsInUi();
|
||||
}
|
||||
};
|
||||
|
||||
private void updateResultsInUi()
|
||||
{
|
||||
// clear played items
|
||||
playingPositions = new ArrayList<>();
|
||||
for (int i = 0; i < getAllRecordings().size(); i++)
|
||||
playingPositions = new ArrayList<Boolean>();
|
||||
for(int i=0; i<allRecordings.size(); i++)
|
||||
playingPositions.add(true);
|
||||
// set adapter - where playingPositions stores exists values
|
||||
adapter = new RecordingsGridViewAdapter(activity, getAllRecordings(), playingPositions);
|
||||
adapter = new RecordingsGridViewAdapter(activity, context, allRecordings, playingPositions);
|
||||
|
||||
// playing positions need to be false because no recording is played
|
||||
playingPositions.clear();
|
||||
for (int i = 0; i < getAllRecordings().size(); i++)
|
||||
for(int i=0; i<allRecordings.size(); i++)
|
||||
playingPositions.add(false);
|
||||
|
||||
updateNumberOfRecordings();
|
||||
|
||||
gridView.setAdapter(adapter);
|
||||
gridView.setAdapter(adapter);
|
||||
}
|
||||
|
||||
// send
|
||||
private void getRecordings(int radioGWID, int radioID) {
|
||||
getParentTab().getRecordings(radioGWID, radioID);
|
||||
// send
|
||||
private void GetRecordings(int radioGWID, int radioID)
|
||||
{
|
||||
parentTab.getRecordings(radioGWID, radioID);
|
||||
}
|
||||
|
||||
public void sendPlayRequest(long recordId) {
|
||||
getParentTab().sendPlayRecordingRequest(recordId);
|
||||
}
|
||||
public void SendPlayRequest(long record_id)
|
||||
{
|
||||
parentTab.sendPlayRecordingRequest(record_id);
|
||||
}
|
||||
|
||||
/**
|
||||
* Register for broadcasts
|
||||
*/
|
||||
private void registerBroadcastIntents() {
|
||||
IntentFilter intentFilter = new IntentFilter(OperationCodes.RECORDINGS_LIST_REP + "");
|
||||
|
||||
/** Register for broadcasts */
|
||||
private void registerBroadcastIntents() {
|
||||
IntentFilter intentFilter = new IntentFilter(OperationCodes.RECORDINGS_LIST_REP+"");
|
||||
this.registerReceiver(mReceiver, intentFilter);
|
||||
|
||||
intentFilter = new IntentFilter(OperationCodes.RADIOID_CHANGED + "");
|
||||
intentFilter = new IntentFilter(OperationCodes.RADIOID_CHANGED+"");
|
||||
this.registerReceiver(mReceiver, intentFilter);
|
||||
}
|
||||
|
||||
//The BroadcastReceiver that listens for Notification broadcasts
|
||||
public final BroadcastReceiver mReceiver = new BroadcastReceiver() {
|
||||
@Override
|
||||
public void onReceive(Context context, Intent intent) {
|
||||
final String action = intent.getAction();
|
||||
// zone and/or channel changed
|
||||
if (action.equals(OperationCodes.RECORDINGS_LIST_REP + "")) {
|
||||
updateRecordings(AppParams.recordings);
|
||||
updateNumberOfRecordings();
|
||||
} else if (action.equals(OperationCodes.RADIOID_CHANGED + "")) {
|
||||
textViewGateway.setText(getParentTab().getCrtRadio().IP);
|
||||
getRecordings(getParentTab().getCrtRadio().GW_ID, getParentTab().getCrtRadio().ID);
|
||||
}
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
public TabLayoutActivity getParentTab() {
|
||||
return parentTab;
|
||||
}
|
||||
//The BroadcastReceiver that listens for Notification broadcasts
|
||||
public final BroadcastReceiver mReceiver = new BroadcastReceiver() {
|
||||
@Override
|
||||
public void onReceive(Context context, Intent intent) {
|
||||
//SM.Debug("### NOTIFICATION ###", "Radio: " + intent.getAction());
|
||||
|
||||
public void setParentTab(TabLayoutActivity parentTab) {
|
||||
this.parentTab = parentTab;
|
||||
}
|
||||
|
||||
public ArrayList<Recording> getAllRecordings() {
|
||||
return allRecordings;
|
||||
}
|
||||
|
||||
public void setAllRecordings(ArrayList<Recording> allRecordings) {
|
||||
this.allRecordings = allRecordings;
|
||||
}
|
||||
|
||||
public View getConvertViewRecording() {
|
||||
return convertViewRecording;
|
||||
}
|
||||
|
||||
public void setConvertViewRecording(View convertViewRecording) {
|
||||
this.convertViewRecording = convertViewRecording;
|
||||
}
|
||||
|
||||
public int getPlayingPosition() {
|
||||
return playingPosition;
|
||||
}
|
||||
|
||||
public void setPlayingPosition(int playingPosition) {
|
||||
this.playingPosition = playingPosition;
|
||||
}
|
||||
|
||||
public Bundle getSavedInstanceState() {
|
||||
return savedInstanceState;
|
||||
}
|
||||
|
||||
public void setSavedInstanceState(Bundle savedInstanceState) {
|
||||
this.savedInstanceState = savedInstanceState;
|
||||
}
|
||||
final String action = intent.getAction();
|
||||
// zone and/or channel changed
|
||||
if (action.equals(OperationCodes.RECORDINGS_LIST_REP+"")) {
|
||||
UpdateRecordings(AppParams.recordings);
|
||||
updateNumberOfRecordings();
|
||||
}
|
||||
else if (action.equals(OperationCodes.RADIOID_CHANGED+"")) {
|
||||
textViewGateway.setText(parentTab.getCrtRadio().IP);
|
||||
GetRecordings(parentTab.getCrtRadio().GW_ID, parentTab.getCrtRadio().ID);
|
||||
}
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
@ -14,11 +14,13 @@ import java.util.Timer;
|
||||
import java.util.TimerTask;
|
||||
|
||||
import com.google.android.gms.tasks.Task;
|
||||
import com.google.android.gms.tasks.TaskCompletionSource;
|
||||
import com.safemobile.activities.AbstractEmptyActivity;
|
||||
import com.safemobile.activities.AbstractLiveActivity;
|
||||
import com.safemobile.activities.AbstractMessagesActivity;
|
||||
import com.safemobile.activities.AbstractRadioActivity;
|
||||
import com.safemobile.activities.AbstractSDParentActivity;
|
||||
import com.safemobile.safedispatch.R;
|
||||
import com.safemobile.enums.AuthorizationCode;
|
||||
import com.safemobile.enums.AuthorizationStatus;
|
||||
import com.safemobile.enums.ProviderSettingsStatus;
|
||||
@ -47,7 +49,6 @@ import com.safemobile.lib.SMSmsg;
|
||||
import com.safemobile.lib.SerializedObject;
|
||||
import com.safemobile.lib.SuperVehicle;
|
||||
import com.safemobile.lib.TCPmsg;
|
||||
import com.safemobile.lib.User;
|
||||
import com.safemobile.lib.VehMSG;
|
||||
import com.safemobile.lib.Vehicle;
|
||||
import com.safemobile.lib.radio.RadioGW;
|
||||
@ -403,7 +404,7 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
}
|
||||
}
|
||||
|
||||
SM.Debug("Logged user:" + AppParams.USERNAME + " | id: " + AppParams.USERID);
|
||||
SM.Debug("Logged user:" + AppParams.USERNAME + " | ID: " + AppParams.USERID);
|
||||
// do not dim the display
|
||||
getWindow().addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);
|
||||
|
||||
@ -631,10 +632,10 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
tabHost.setCurrentTabByTag(RECORDINGS);
|
||||
AppParams.crtTab = AppParams.Tabs.recordings;
|
||||
|
||||
if (AppParams.DEMO && getRecordingsActivity() != null && getRecordingsActivity().getAllRecordings() != null && getRecordingsActivity().getAllRecordings().isEmpty()) {
|
||||
if (AppParams.DEMO && getRecordingsActivity() != null && getRecordingsActivity().allRecordings != null && getRecordingsActivity().allRecordings.isEmpty()) {
|
||||
ArrayList<Recording> listRecordings = new ArrayList<>();
|
||||
Recording rec = new Recording();
|
||||
rec.userWhoWasCalled = "Rob";
|
||||
rec.NameForDisplay = "Rob";
|
||||
rec.subID = 101;
|
||||
rec.endGMT = (int) Calendar.getInstance().getTime().getTime();
|
||||
rec.startGMT = rec.endGMT - 2;
|
||||
@ -642,7 +643,7 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
listRecordings.add(rec);
|
||||
|
||||
rec = new Recording();
|
||||
rec.userWhoWasCalled = "Call1 [Rob]";
|
||||
rec.NameForDisplay = "Call1 [Rob]";
|
||||
rec.subID = 102;
|
||||
rec.endGMT = (int) Calendar.getInstance().getTime().getTime();
|
||||
rec.startGMT = rec.endGMT - 2;
|
||||
@ -650,13 +651,13 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
listRecordings.add(rec);
|
||||
|
||||
rec = new Recording();
|
||||
rec.userWhoWasCalled = "Call2 [Rob]";
|
||||
rec.NameForDisplay = "Call2 [Rob]";
|
||||
rec.subID = 101;
|
||||
rec.endGMT = (int) Calendar.getInstance().getTime().getTime();
|
||||
rec.startGMT = rec.endGMT - 3;
|
||||
listRecordings.add(rec);
|
||||
rec.type = 103;
|
||||
getRecordingsActivity().updateRecordings(listRecordings);
|
||||
getRecordingsActivity().UpdateRecordings(listRecordings);
|
||||
}
|
||||
}
|
||||
});
|
||||
@ -1005,6 +1006,8 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
moribund.interrupt();
|
||||
}
|
||||
|
||||
this.unregisterReceiver(mReceiver);
|
||||
|
||||
// unbound from tcp service
|
||||
if (isBound) {
|
||||
getApplicationContext().unbindService(serviceConnection);
|
||||
@ -1044,7 +1047,7 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
if (getMessageActivity() != null)
|
||||
getMessageActivity().onCreate(getMessageActivity().getSavedInstanceState());
|
||||
if (getRecordingsActivity() != null)
|
||||
getRecordingsActivity().onCreate(getRecordingsActivity().getSavedInstanceState());
|
||||
getRecordingsActivity().onCreate(getRecordingsActivity().savedInstanceState);
|
||||
if (getAlarmActivity() != null)
|
||||
getAlarmActivity().onCreate(getAlarmActivity().getSavedInstanceState());
|
||||
}
|
||||
@ -1358,7 +1361,7 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
SM.Debug("Got PlayRec :" + msg.allData);
|
||||
|
||||
if (NO_SOUND) {
|
||||
SM.Debug("Recording Play file id:" + msg.data);
|
||||
SM.Debug("Recording Play file ID:" + msg.data);
|
||||
|
||||
//list for SMS
|
||||
if (AppParams.crtTab == AppParams.Tabs.recordings) {
|
||||
@ -1367,7 +1370,7 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
try {
|
||||
long id = Long.parseLong(tmp);
|
||||
if (getRecordingsActivity() != null)
|
||||
getRecordingsActivity().playRecording(id);
|
||||
getRecordingsActivity().PlayRecording(id);
|
||||
} catch (Exception ex) {
|
||||
SM.Exception(ex.toString());
|
||||
}
|
||||
@ -1575,7 +1578,7 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
if (radioMSG.incCall.callStatus == 3) {
|
||||
setInCall(false);
|
||||
// update recordings list
|
||||
if (AppParams.crtTab == AppParams.Tabs.recordings && getRecordingsActivity() != null && getRecordingsActivity().getPlayingPosition() < 0) {
|
||||
if (AppParams.crtTab == AppParams.Tabs.recordings && getRecordingsActivity() != null && getRecordingsActivity().playingPosition < 0) {
|
||||
// no recording is playing
|
||||
getRecordings(getCrtRadio().GW_ID, getCrtRadio().ID);
|
||||
}
|
||||
@ -1609,13 +1612,13 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
setAllRadios(radioMSG.RadioGWList);
|
||||
if (getCrtRadio() == null) {
|
||||
setCrtRadio(getAllRadios().get(0));
|
||||
SM.Debug("radioMSG set 0 crtRadio GW_ID:" + getCrtRadio().GW_ID + " id:" + getCrtRadio().ID + ")");
|
||||
SM.Debug("radioMSG set 0 crtRadio GW_ID:" + getCrtRadio().GW_ID + " ID:" + getCrtRadio().ID + ")");
|
||||
|
||||
notifyBroadcast(OperationCodes.RADIOID_CHANGED + "");
|
||||
}
|
||||
}
|
||||
|
||||
// save crt Radio id and GW
|
||||
// save crt Radio ID and GW
|
||||
if (radioMSG.zac != null) {
|
||||
for (RadioGW radio : getAllRadios()) {
|
||||
if (radio.GW_ID == radioMSG.zac.gwID && radio.ID == radioMSG.zac.rgwID)
|
||||
@ -1716,76 +1719,19 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
|
||||
//list for SMS
|
||||
if (AppParams.crtTab == AppParams.Tabs.recordings) {
|
||||
for (Recording rec : recordMSG.getRecordList()) {
|
||||
SuperVehicle superVehicle = getSuperVehHash().get((long) rec.subID);
|
||||
for (Recording rec : recordMSG.recordList) {
|
||||
// set the name to be displayed
|
||||
switch (rec.callType) {
|
||||
case 0:
|
||||
for (User u : AppParams.allUsers) {
|
||||
if (u.id == rec.dispatcherId)
|
||||
rec.userWhoCalled = u.login;
|
||||
}
|
||||
if (rec.userWhoCalled == null || rec.userWhoCalled.isEmpty())
|
||||
rec.userWhoCalled = String.valueOf(rec.dispatcherId);
|
||||
|
||||
if (superVehicle != null)
|
||||
rec.userWhoWasCalled = superVehicle.name;
|
||||
else
|
||||
rec.userWhoWasCalled = String.valueOf(rec.subID);
|
||||
break;
|
||||
case 4:
|
||||
rec.userWhoWasCalled = AppParams.USERNAME;
|
||||
if (superVehicle != null)
|
||||
rec.userWhoCalled = superVehicle.name;
|
||||
else
|
||||
rec.userWhoCalled = String.valueOf(rec.subID);
|
||||
break;
|
||||
case 1:
|
||||
for (User u : AppParams.allUsers) {
|
||||
if (u.id == rec.dispatcherId)
|
||||
rec.userWhoCalled = u.login;
|
||||
}
|
||||
if (rec.userWhoCalled == null || rec.userWhoCalled.isEmpty())
|
||||
rec.userWhoCalled = String.valueOf(rec.dispatcherId);
|
||||
|
||||
if (rec.groupName == null || rec.groupName.isEmpty())
|
||||
rec.userWhoWasCalled = String.valueOf(rec.groupCpsId);
|
||||
else
|
||||
rec.userWhoWasCalled = rec.groupName;
|
||||
break;
|
||||
case 5:
|
||||
if (superVehicle != null)
|
||||
rec.userWhoCalled = superVehicle.name;
|
||||
else
|
||||
rec.userWhoCalled = String.valueOf(rec.subID);
|
||||
|
||||
if (rec.groupName == null || rec.groupName.isEmpty())
|
||||
rec.userWhoWasCalled = String.valueOf(rec.groupCpsId);
|
||||
else
|
||||
rec.userWhoWasCalled = rec.groupName;
|
||||
break;
|
||||
case 2:
|
||||
for (User u : AppParams.allUsers) {
|
||||
if (u.id == rec.dispatcherId)
|
||||
rec.userWhoCalled = u.login;
|
||||
}
|
||||
if (rec.userWhoCalled == null || rec.userWhoCalled.isEmpty())
|
||||
rec.userWhoCalled = String.valueOf(rec.dispatcherId);
|
||||
|
||||
rec.userWhoWasCalled = "All Call";
|
||||
break;
|
||||
case 6:
|
||||
rec.userWhoWasCalled = "All Call";
|
||||
if (superVehicle != null)
|
||||
rec.userWhoCalled = superVehicle.name;
|
||||
else
|
||||
rec.userWhoCalled = String.valueOf(rec.subID);
|
||||
break;
|
||||
if (rec.typeID == 1)
|
||||
rec.NameForDisplay = AppParams.USERNAME;
|
||||
else {
|
||||
SuperVehicle superVehicle = getSuperVehHash().get((long) rec.subID);
|
||||
if (superVehicle != null)
|
||||
rec.NameForDisplay = superVehicle.name;
|
||||
}
|
||||
}
|
||||
|
||||
// save recordings to AppParams
|
||||
AppParams.recordings = recordMSG.getRecordList();
|
||||
AppParams.recordings = recordMSG.recordList;
|
||||
|
||||
// notify recordings were received
|
||||
notifyBroadcast(OperationCodes.RECORDINGS_LIST_REP + "");
|
||||
@ -2378,10 +2324,4 @@ public class TabLayoutActivity extends AbstractSDParentActivity {
|
||||
this.startActivity(intent);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void onDestroy() {
|
||||
super.onDestroy();
|
||||
this.unregisterReceiver(mReceiver);
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user