mirror of
https://github.com/KeymonSoft/Mazapa-Reparto.git
synced 2026-04-23 07:40:10 +00:00
239 lines
13 KiB
Java
239 lines
13 KiB
Java
package reparto_mazapa.keymon.lat;
|
|
|
|
|
|
import anywheresoftware.b4a.BA;
|
|
import anywheresoftware.b4a.objects.ReceiverHelper;
|
|
import anywheresoftware.b4a.debug.*;
|
|
|
|
public class httputils2service extends android.content.BroadcastReceiver{
|
|
|
|
static httputils2service mostCurrent;
|
|
public static BA processBA;
|
|
private ReceiverHelper _receiver;
|
|
private static boolean firstTime = true;
|
|
public static Class<?> getObject() {
|
|
return httputils2service.class;
|
|
}
|
|
@Override
|
|
public void onReceive(android.content.Context context, android.content.Intent intent) {
|
|
mostCurrent = this;
|
|
|
|
if (processBA == null) {
|
|
|
|
processBA = new BA(context, null, null, anywheresoftware.b4a.BA.SharedProcessBA.ModuleType.RECEIVER, "reparto_mazapa.keymon.lat.httputils2service");
|
|
if (BA.isShellModeRuntimeCheck(processBA)) {
|
|
processBA.raiseEvent2(null, true, "SHELL", false);
|
|
}
|
|
try {
|
|
Class.forName(BA.applicationContext.getPackageName() + ".main").getMethod("initializeProcessGlobals").invoke(null, null);
|
|
} catch (Exception e) {
|
|
throw new RuntimeException(e);
|
|
}
|
|
processBA.loadHtSubs(this.getClass());
|
|
}
|
|
_receiver = new ReceiverHelper(this);
|
|
if (BA.isShellModeRuntimeCheck(processBA)) {
|
|
processBA.raiseEvent2(null, true, "CREATE", true, "reparto_mazapa.keymon.lat.httputils2service", processBA, _receiver, anywheresoftware.b4a.keywords.Common.Density);
|
|
}
|
|
processBA.setActivityPaused(false);
|
|
BA.LogInfo("*** Receiver (httputils2service) Receive " + (firstTime ? "(first time)" : "") + " ***");
|
|
anywheresoftware.b4a.objects.IntentWrapper iw = new anywheresoftware.b4a.objects.IntentWrapper();
|
|
iw.setObject(intent);
|
|
processBA.raiseEvent(null, "receiver_receive", firstTime, iw);
|
|
firstTime = false;
|
|
}
|
|
|
|
public anywheresoftware.b4a.keywords.Common __c = null;
|
|
public static anywheresoftware.b4h.okhttp.OkHttpClientWrapper _hc = null;
|
|
public static anywheresoftware.b4a.objects.collections.Map _taskidtojob = null;
|
|
public static String _tempfolder = "";
|
|
public static int _taskcounter = 0;
|
|
public b4a.example.dateutils _dateutils = null;
|
|
public reparto_mazapa.keymon.lat.main _main = null;
|
|
public reparto_mazapa.keymon.lat.appupdater _appupdater = null;
|
|
public reparto_mazapa.keymon.lat.foto _foto = null;
|
|
public reparto_mazapa.keymon.lat.mapa_cliente _mapa_cliente = null;
|
|
public reparto_mazapa.keymon.lat.mapa_rutas _mapa_rutas = null;
|
|
public reparto_mazapa.keymon.lat.starter _starter = null;
|
|
public reparto_mazapa.keymon.lat.subs _subs = null;
|
|
public reparto_mazapa.keymon.lat.tracker _tracker = null;
|
|
public reparto_mazapa.keymon.lat.newinst2 _newinst2 = null;
|
|
public reparto_mazapa.keymon.lat.b4xpages _b4xpages = null;
|
|
public reparto_mazapa.keymon.lat.b4xcollections _b4xcollections = null;
|
|
public reparto_mazapa.keymon.lat.xuiviewsutils _xuiviewsutils = null;
|
|
public static String _completejob(int _taskid,boolean _success,String _errormessage) throws Exception{
|
|
reparto_mazapa.keymon.lat.httpjob _job = null;
|
|
//BA.debugLineNum = 152;BA.debugLine="Sub CompleteJob(TaskId As Int, success As Boolean,";
|
|
//BA.debugLineNum = 156;BA.debugLine="Dim job As HttpJob = TaskIdToJob.Get(TaskId)";
|
|
_job = (reparto_mazapa.keymon.lat.httpjob)(_taskidtojob.Get((Object)(_taskid)));
|
|
//BA.debugLineNum = 157;BA.debugLine="If job = Null Then";
|
|
if (_job== null) {
|
|
//BA.debugLineNum = 158;BA.debugLine="Log(\"HttpUtils2Service: job completed multiple t";
|
|
anywheresoftware.b4a.keywords.Common.LogImpl("234209798","HttpUtils2Service: job completed multiple times - "+BA.NumberToString(_taskid),0);
|
|
//BA.debugLineNum = 159;BA.debugLine="Return";
|
|
if (true) return "";
|
|
};
|
|
//BA.debugLineNum = 161;BA.debugLine="TaskIdToJob.Remove(TaskId)";
|
|
_taskidtojob.Remove((Object)(_taskid));
|
|
//BA.debugLineNum = 162;BA.debugLine="job.success = success";
|
|
_job._success /*boolean*/ = _success;
|
|
//BA.debugLineNum = 163;BA.debugLine="job.errorMessage = errorMessage";
|
|
_job._errormessage /*String*/ = _errormessage;
|
|
//BA.debugLineNum = 165;BA.debugLine="job.Complete(TaskId)";
|
|
_job._complete /*String*/ (_taskid);
|
|
//BA.debugLineNum = 169;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _hc_responseerror(anywheresoftware.b4h.okhttp.OkHttpClientWrapper.OkHttpResponse _response,String _reason,int _statuscode,int _taskid) throws Exception{
|
|
reparto_mazapa.keymon.lat.httpjob _job = null;
|
|
//BA.debugLineNum = 115;BA.debugLine="Sub hc_ResponseError (Response As OkHttpResponse,";
|
|
//BA.debugLineNum = 117;BA.debugLine="Log($\"ResponseError. Reason: ${Reason}, Response:";
|
|
anywheresoftware.b4a.keywords.Common.LogImpl("234144258",("ResponseError. Reason: "+anywheresoftware.b4a.keywords.Common.SmartStringFormatter("",(Object)(_reason))+", Response: "+anywheresoftware.b4a.keywords.Common.SmartStringFormatter("",(Object)(_response.getErrorResponse()))+""),0);
|
|
//BA.debugLineNum = 119;BA.debugLine="Response.Release";
|
|
_response.Release();
|
|
//BA.debugLineNum = 120;BA.debugLine="Dim job As HttpJob = TaskIdToJob.Get(TaskId)";
|
|
_job = (reparto_mazapa.keymon.lat.httpjob)(_taskidtojob.Get((Object)(_taskid)));
|
|
//BA.debugLineNum = 121;BA.debugLine="If job = Null Then";
|
|
if (_job== null) {
|
|
//BA.debugLineNum = 122;BA.debugLine="Log(\"HttpUtils2Service (hc_ResponseError): job c";
|
|
anywheresoftware.b4a.keywords.Common.LogImpl("234144263","HttpUtils2Service (hc_ResponseError): job completed multiple times - "+BA.NumberToString(_taskid),0);
|
|
//BA.debugLineNum = 123;BA.debugLine="Return";
|
|
if (true) return "";
|
|
};
|
|
//BA.debugLineNum = 125;BA.debugLine="job.Response = Response";
|
|
_job._response /*anywheresoftware.b4h.okhttp.OkHttpClientWrapper.OkHttpResponse*/ = _response;
|
|
//BA.debugLineNum = 126;BA.debugLine="If Response.ErrorResponse <> \"\" Then";
|
|
if ((_response.getErrorResponse()).equals("") == false) {
|
|
//BA.debugLineNum = 127;BA.debugLine="CompleteJob(TaskId, False, Response.ErrorRespons";
|
|
_completejob(_taskid,anywheresoftware.b4a.keywords.Common.False,_response.getErrorResponse());
|
|
}else {
|
|
//BA.debugLineNum = 129;BA.debugLine="CompleteJob(TaskId, False, Reason)";
|
|
_completejob(_taskid,anywheresoftware.b4a.keywords.Common.False,_reason);
|
|
};
|
|
//BA.debugLineNum = 131;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _hc_responsesuccess(anywheresoftware.b4h.okhttp.OkHttpClientWrapper.OkHttpResponse _response,int _taskid) throws Exception{
|
|
reparto_mazapa.keymon.lat.httpjob _job = null;
|
|
anywheresoftware.b4a.objects.streams.File.OutputStreamWrapper _out = null;
|
|
//BA.debugLineNum = 92;BA.debugLine="Sub hc_ResponseSuccess (Response As OkHttpResponse";
|
|
//BA.debugLineNum = 93;BA.debugLine="Dim job As HttpJob = TaskIdToJob.Get(TaskId)";
|
|
_job = (reparto_mazapa.keymon.lat.httpjob)(_taskidtojob.Get((Object)(_taskid)));
|
|
//BA.debugLineNum = 94;BA.debugLine="If job = Null Then";
|
|
if (_job== null) {
|
|
//BA.debugLineNum = 95;BA.debugLine="Log(\"HttpUtils2Service (hc_ResponseSuccess): job";
|
|
anywheresoftware.b4a.keywords.Common.LogImpl("234013187","HttpUtils2Service (hc_ResponseSuccess): job completed multiple times - "+BA.NumberToString(_taskid),0);
|
|
//BA.debugLineNum = 96;BA.debugLine="Return";
|
|
if (true) return "";
|
|
};
|
|
//BA.debugLineNum = 98;BA.debugLine="job.Response = Response";
|
|
_job._response /*anywheresoftware.b4h.okhttp.OkHttpClientWrapper.OkHttpResponse*/ = _response;
|
|
//BA.debugLineNum = 99;BA.debugLine="Dim out As OutputStream = File.OpenOutput(TempFol";
|
|
_out = new anywheresoftware.b4a.objects.streams.File.OutputStreamWrapper();
|
|
_out = anywheresoftware.b4a.keywords.Common.File.OpenOutput(_tempfolder,BA.NumberToString(_taskid),anywheresoftware.b4a.keywords.Common.False);
|
|
//BA.debugLineNum = 101;BA.debugLine="job.Out = out";
|
|
_job._out /*anywheresoftware.b4a.objects.streams.File.OutputStreamWrapper*/ = _out;
|
|
//BA.debugLineNum = 103;BA.debugLine="Response.GetAsynchronously(\"response\", out , _";
|
|
_response.GetAsynchronously(processBA,"response",(java.io.OutputStream)(_out.getObject()),anywheresoftware.b4a.keywords.Common.True,_taskid);
|
|
//BA.debugLineNum = 105;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _process_globals() throws Exception{
|
|
//BA.debugLineNum = 2;BA.debugLine="Sub Process_Globals";
|
|
//BA.debugLineNum = 5;BA.debugLine="Public hc As OkHttpClient";
|
|
_hc = new anywheresoftware.b4h.okhttp.OkHttpClientWrapper();
|
|
//BA.debugLineNum = 9;BA.debugLine="Public TaskIdToJob As Map";
|
|
_taskidtojob = new anywheresoftware.b4a.objects.collections.Map();
|
|
//BA.debugLineNum = 19;BA.debugLine="Public TempFolder As String";
|
|
_tempfolder = "";
|
|
//BA.debugLineNum = 23;BA.debugLine="Private taskCounter As Int";
|
|
_taskcounter = 0;
|
|
//BA.debugLineNum = 25;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _receiver_receive(boolean _firsttime,anywheresoftware.b4a.objects.IntentWrapper _startingintent) throws Exception{
|
|
//BA.debugLineNum = 58;BA.debugLine="Private Sub Receiver_Receive (FirstTime As Boolean";
|
|
//BA.debugLineNum = 59;BA.debugLine="If FirstTime Then";
|
|
if (_firsttime) {
|
|
//BA.debugLineNum = 60;BA.debugLine="Service_Create";
|
|
_service_create();
|
|
};
|
|
//BA.debugLineNum = 62;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _response_streamfinish(boolean _success,int _taskid) throws Exception{
|
|
//BA.debugLineNum = 107;BA.debugLine="Private Sub Response_StreamFinish (Success As Bool";
|
|
//BA.debugLineNum = 108;BA.debugLine="If Success Then";
|
|
if (_success) {
|
|
//BA.debugLineNum = 109;BA.debugLine="CompleteJob(TaskId, Success, \"\")";
|
|
_completejob(_taskid,_success,"");
|
|
}else {
|
|
//BA.debugLineNum = 111;BA.debugLine="CompleteJob(TaskId, Success, LastException.Messa";
|
|
_completejob(_taskid,_success,anywheresoftware.b4a.keywords.Common.LastException(processBA).getMessage());
|
|
};
|
|
//BA.debugLineNum = 113;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _service_create() throws Exception{
|
|
//BA.debugLineNum = 27;BA.debugLine="Sub Service_Create";
|
|
//BA.debugLineNum = 29;BA.debugLine="TempFolder = File.DirInternalCache";
|
|
_tempfolder = anywheresoftware.b4a.keywords.Common.File.getDirInternalCache();
|
|
//BA.debugLineNum = 30;BA.debugLine="Try";
|
|
try { //BA.debugLineNum = 31;BA.debugLine="File.WriteString(TempFolder, \"~test.test\", \"test";
|
|
anywheresoftware.b4a.keywords.Common.File.WriteString(_tempfolder,"~test.test","test");
|
|
//BA.debugLineNum = 32;BA.debugLine="File.Delete(TempFolder, \"~test.test\")";
|
|
anywheresoftware.b4a.keywords.Common.File.Delete(_tempfolder,"~test.test");
|
|
}
|
|
catch (Exception e6) {
|
|
processBA.setLastException(e6); //BA.debugLineNum = 34;BA.debugLine="Log(LastException)";
|
|
anywheresoftware.b4a.keywords.Common.LogImpl("233685511",BA.ObjectToString(anywheresoftware.b4a.keywords.Common.LastException(processBA)),0);
|
|
//BA.debugLineNum = 35;BA.debugLine="Log(\"Switching to File.DirInternal\")";
|
|
anywheresoftware.b4a.keywords.Common.LogImpl("233685512","Switching to File.DirInternal",0);
|
|
//BA.debugLineNum = 36;BA.debugLine="TempFolder = File.DirInternal";
|
|
_tempfolder = anywheresoftware.b4a.keywords.Common.File.getDirInternal();
|
|
};
|
|
//BA.debugLineNum = 41;BA.debugLine="If hc.IsInitialized = False Then";
|
|
if (_hc.IsInitialized()==anywheresoftware.b4a.keywords.Common.False) {
|
|
//BA.debugLineNum = 46;BA.debugLine="hc.Initialize(\"hc\")";
|
|
_hc.Initialize("hc");
|
|
};
|
|
//BA.debugLineNum = 54;BA.debugLine="TaskIdToJob.Initialize";
|
|
_taskidtojob.Initialize();
|
|
//BA.debugLineNum = 56;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _service_destroy() throws Exception{
|
|
//BA.debugLineNum = 68;BA.debugLine="Sub Service_Destroy";
|
|
//BA.debugLineNum = 70;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _service_start(anywheresoftware.b4a.objects.IntentWrapper _startingintent) throws Exception{
|
|
//BA.debugLineNum = 64;BA.debugLine="Sub Service_Start (StartingIntent As Intent)";
|
|
//BA.debugLineNum = 66;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
public static String _submitjob(reparto_mazapa.keymon.lat.httpjob _job) throws Exception{
|
|
int _taskid = 0;
|
|
//BA.debugLineNum = 74;BA.debugLine="Public Sub SubmitJob(job As HttpJob)";
|
|
//BA.debugLineNum = 75;BA.debugLine="If TaskIdToJob.IsInitialized = False Then Service";
|
|
if (_taskidtojob.IsInitialized()==anywheresoftware.b4a.keywords.Common.False) {
|
|
_service_create();};
|
|
//BA.debugLineNum = 79;BA.debugLine="taskCounter = taskCounter + 1";
|
|
_taskcounter = (int) (_taskcounter+1);
|
|
//BA.debugLineNum = 80;BA.debugLine="Dim TaskId As Int = taskCounter";
|
|
_taskid = _taskcounter;
|
|
//BA.debugLineNum = 82;BA.debugLine="TaskIdToJob.Put(TaskId, job)";
|
|
_taskidtojob.Put((Object)(_taskid),(Object)(_job));
|
|
//BA.debugLineNum = 83;BA.debugLine="If job.Username <> \"\" And job.Password <> \"\" Then";
|
|
if ((_job._username /*String*/ ).equals("") == false && (_job._password /*String*/ ).equals("") == false) {
|
|
//BA.debugLineNum = 84;BA.debugLine="hc.ExecuteCredentials(job.GetRequest, TaskId, jo";
|
|
_hc.ExecuteCredentials(processBA,_job._getrequest /*anywheresoftware.b4h.okhttp.OkHttpClientWrapper.OkHttpRequest*/ (),_taskid,_job._username /*String*/ ,_job._password /*String*/ );
|
|
}else {
|
|
//BA.debugLineNum = 86;BA.debugLine="hc.Execute(job.GetRequest, TaskId)";
|
|
_hc.Execute(processBA,_job._getrequest /*anywheresoftware.b4h.okhttp.OkHttpClientWrapper.OkHttpRequest*/ (),_taskid);
|
|
};
|
|
//BA.debugLineNum = 88;BA.debugLine="End Sub";
|
|
return "";
|
|
}
|
|
}
|