|
@@ -31,8 +31,10 @@ import com.bgy.autosale.IceCreamDeviceConstants;
|
|
|
import com.bgy.autosale.R;
|
|
|
import com.bgy.autosale.RemoteSupportService;
|
|
|
import com.bgy.autosale.entitys.MakeIceCreamBean;
|
|
|
+import com.bgy.autosale.entitys.Result;
|
|
|
import com.bgy.autosale.helpers.CommunicationHelper;
|
|
|
import com.bgy.autosale.interfaces.SendCallback;
|
|
|
+import com.bgy.autosale.interfaces.Callback;
|
|
|
import com.bgy.autosale.ui.consumer.PaySuccessFragment;
|
|
|
import com.bgy.autosale.ui.operator.LockActivity;
|
|
|
import com.bgy.autosale.ui.MainActivity;
|
|
@@ -100,7 +102,7 @@ import io.reactivex.observers.DisposableObserver;
|
|
|
import io.reactivex.schedulers.Schedulers;
|
|
|
|
|
|
@Route(path = "/module_app/mqservice")
|
|
|
-public class MQService extends Service implements SendCallback {
|
|
|
+public class MQService extends Service implements SendCallback,Callback<Result> {
|
|
|
|
|
|
private static final String TAG = "MQService";
|
|
|
ConnectionFactory factory;
|
|
@@ -260,6 +262,8 @@ public class MQService extends Service implements SendCallback {
|
|
|
iceCreamOrders.add(detail);
|
|
|
Log.d(TAG, "getMessage: dosugar"+iceCreamOrders);
|
|
|
CommunicationHelper.getInstance().setMakingIceCreams(iceCreamOrders);
|
|
|
+ CommunicationHelper.getInstance().setDishStatusListener(this, isManualMake ? IceCreamDeviceConstants.ORDER_MAKE_ORDER : -1);
|
|
|
+
|
|
|
break;
|
|
|
case "alarmClock":
|
|
|
//远程星期调节闹钟
|
|
@@ -902,6 +906,21 @@ public class MQService extends Service implements SendCallback {
|
|
|
|
|
|
private int networkState = 100;
|
|
|
|
|
|
+ @Override
|
|
|
+ public void onResult(Result result) {
|
|
|
+ AndroidSchedulers.mainThread().scheduleDirect(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ Log.d(TAG, "AndroidSchedulers run1: "+result);
|
|
|
+ Log.d(TAG, "AndroidSchedulers run2: "+result.code);
|
|
|
+ Log.d(TAG, "AndroidSchedulers run3: "+result.message);
|
|
|
+ Log.d(TAG, "AndroidSchedulers run4: "+result.data);
|
|
|
+ switch (result.code) {
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+}
|
|
|
+
|
|
|
//接收网络状态改变的广播
|
|
|
public class NetWorkBroadCastReciver extends BroadcastReceiver {
|
|
|
@Override
|
|
@@ -1259,14 +1278,15 @@ public class MQService extends Service implements SendCallback {
|
|
|
// if ("1".equals(s) || "2".equals(s) || "3".equals(s) || "4".equals(s) ||
|
|
|
// "5".equals(s) || "6".equals(s) || "7".equals(s) || "8".equals(s)||
|
|
|
// "9".equals(s)|| "10".equals(s)|| "11".equals(s)|| "12".equals(s)|| "14".equals(s)) {
|
|
|
- if ("SUNZ".equals(s) || "7770".equals(s) || "8647".equals(s) || "7264".equals(s) || "1932".equals(s) ||
|
|
|
+ if ("1".equals(s) ||"SUNZ".equals(s) || "7770".equals(s) || "8647".equals(s) || "7264".equals(s) || "1932".equals(s) ||
|
|
|
"2381".equals(s) || "0291".equals(s) || "1313".equals(s) || "3103".equals(s) ||
|
|
|
"4873".equals(s) || "5291".equals(s) || "9284".equals(s) || "2222".equals(s)
|
|
|
|| "3212".equals(s) || "3535".equals(s) || "1921".equals(s) || "3624".equals(s)
|
|
|
|| "2019".equals(s) || "7391".equals(s) || "0924".equals(s) || "9427".equals(s) || "0735".equals(s)
|
|
|
|| "5769".equals(s) || "6894".equals(s) || "8123".equals(s) || "5217".equals(s) || "6431".equals(s)
|
|
|
|| "7777".equals(s) || "8080".equals(s) || "6702".equals(s) || "7772".equals(s) || "7761".equals(s)
|
|
|
- || "7773".equals(s) || "7774".equals(s) || "7786".equals(s) || "7775".equals(s)|| "7754".equals(s)) {
|
|
|
+ || "7773".equals(s) || "7774".equals(s) || "7786".equals(s) || "7775".equals(s)|| "7754".equals(s)
|
|
|
+ ||"0000".equals(s)) {
|
|
|
Hawk.put("logo", s);
|
|
|
Hawk.get("logo", "7777");
|
|
|
}
|