fangTang code review

wugian
1 parent 10041a18
Showing 1 changed file with 1 additions and 358 deletions
gimiCinema/src/main/java/com/xgimi/gimicinema/service/AskService.java
--- a/gimiCinema/src/main/java/com/xgimi/gimicinema/service/AskService.java
View file @7687088
+++ b/gimiCinema/src/main/java/com/xgimi/gimicinema/service/AskService.java
View file @7687088
 package com.xgimi.gimicinema.service;
 import android.app.Service;
-import android.content.BroadcastReceiver;
 import android.content.ComponentName;
 import android.content.Context;
 import android.content.Intent;
-import android.content.IntentFilter;
 import android.content.ServiceConnection;
 import android.content.SharedPreferences;
 import android.os.Handler;
@@ -15,59 +13,37 @@ import android.os.RemoteException;
 import android.text.TextUtils;
 import android.util.Log;
 import android.widget.Toast;
-
-import com.android.volley.DefaultRetryPolicy;
-import com.android.volley.RequestQueue;
-import com.android.volley.Response;
-import com.android.volley.VolleyError;
-import com.android.volley.toolbox.StringRequest;
-import com.android.volley.toolbox.Volley;
 import com.gimi.common.cinema.db.NewDBManager;
 import com.gimi.common.cinema.model.BaseData;
 import com.gimi.common.cinema.model.Constant;
 import com.gimi.common.cinema.model.ControlMessage;
 import com.gimi.common.cinema.model.GimiMessage;
-import com.gimi.common.cinema.model.GimiSysData;
 import com.gimi.common.cinema.model.GimiSysMsg;
-import com.gimi.common.cinema.model.MessageEvent;
 import com.gimi.common.cinema.model.PlayStatus;
 import com.gimi.common.cinema.model.PlayStatusMessage;
 import com.gimi.common.cinema.model.SambaMsg;
 import com.gimi.common.cinema.model.UdpModel;
 import com.gimi.common.cinema.utils.AuthUtils;
-import com.gimi.common.cinema.utils.CToast;
 import com.gimi.common.cinema.utils.FolderUtils;
 import com.gimi.common.cinema.utils.LocalDataUtils;
 import com.gimi.common.cinema.utils.MovieMessageUtils;
-import com.gimi.common.cinema.utils.NetStatusUtils;
 import com.gimi.common.cinema.utils.OpenMMUtils;
 import com.gimi.common.cinema.utils.SambaFileCharge;
 import com.gimi.common.cinema.utils.SystemUtils;
 import com.gimi.common.cinema.utils.T;
-import com.gimi.common.cinema.utils.TimeoutCharge;
 import com.gimi.common.cinema.utils.Utils;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
-import com.google.gson.JsonSyntaxException;
-import com.umeng.analytics.MobclickAgent;
 import com.xgimi.gimicinema.BuildConfig;
 import com.xgimi.gimicinema.ICinemaControl;
-import com.xgimi.gimicinema.R;
 import com.xgimi.gimicinema.activity.CinemaConfig;
 import com.xgimi.gimicinema.deserializer.GimiMessageDeserializer;
 import com.xgimi.gimicinema.deserializer.GimiSysMsgDeserializer;
 import com.xgimi.gimicinema.mview.IAskView;
 import com.xgimi.gimicinema.presenter.AskPresenter;
-import org.greenrobot.eventbus.EventBus;
-
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.TimerTask;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
 /**
@@ -75,27 +51,10 @@ import java.util.concurrent.TimeUnit;
  */
 public class AskService extends Service implements IAskView {
     public static final String TAG = "AskService";
-
-    public static final String ASK_SERVICE_ACTION = "com.qnbar.ask.service";
-    private static String ROOT_URL = "http://fbs.qnbar.com/";
-    private static String ROOT_URL_FOR_TEST = "http://fbs.t.qnbar.com/";
-    private static final String STATUS_URL = "apis/rest/Server/getStatus?imei=";
-    private static final String MESSAGE_URL = "apis/rest/Server/getMessage?imei=";
-
-    private static final int CUR_PERIOD = 15;
-
     private Handler handler = new Handler();
-    private int unSupport = 0;
-
-    private int statusCount = 0;
-    private int messageCount = 0;
     private Context context;
     private SystemUtils systemUtils;
-    private StringRequest reqGetStatus;
-    private StringRequest reqGetMessage;
-    private RequestQueue mQueueSts;
-    private RequestQueue mQueueMsg;
     private SharedPreferences sharedPreferences;
     private NewDBManager dbManager;
     private LocalDataUtils localDataUtils;
@@ -103,16 +62,9 @@ public class AskService extends Service implements IAskView {
     private String ip = "";
     private String folder = "";
-    private int offlinePromoteCount = 0;
-
-    private int delay = 15;
     private SambaMsg sambaMsg;
     private Gson gson;
     private UdpPostSender sender;
-    //    private Type typeStatus;
-//    private Type typeMessage;
-
-    // 是否需要完善UDP通信机制，提高通信稳定性
     @Override
     public void onCreate() {
         super.onCreate();
@@ -120,11 +72,6 @@ public class AskService extends Service implements IAskView {
         if (!mBound) {
             attemptToBindService();
         }
-        initBroadcast();
-//        typeStatus = new TypeToken<QnResult<StatusData>>() {
-//        }.getType();
-//        typeMessage = new TypeToken<QnResult<List<MessageData>>>() {
-//        }.getType();
         gson = new GsonBuilder()
                 .registerTypeAdapter(GimiSysMsg.class, new GimiSysMsgDeserializer())
                 .registerTypeAdapter(GimiMessage.class, new GimiMessageDeserializer())
@@ -136,87 +83,11 @@ public class AskService extends Service implements IAskView {
         localDataUtils = new LocalDataUtils(context);
         dbManager = new NewDBManager(this);
         systemUtils = new SystemUtils();
-        mQueueSts = Volley.newRequestQueue(context);
-        mQueueMsg = Volley.newRequestQueue(context);
         sharedPreferences = Utils.getSp(context);
-
-        boolean test = sharedPreferences.getBoolean("test", false);
         agentType = Utils.getInt(sharedPreferences, "agent-type", 0);
-        if (test) {
-            ROOT_URL = ROOT_URL_FOR_TEST;
-        }
         Log.d(TAG, "onCreate: " + BuildConfig.MACHINE_TYPE);
-        String pid = SystemUtils.getPid(context, BuildConfig.MACHINE_TYPE);
         updateMsg();
-        reqGetMessage = new StringRequest(ROOT_URL + MESSAGE_URL + pid,
-                new Response.Listener<String>() {
-                    @Override
-                    public void onResponse(String response) {
-                        AskService.this.handlerMessage(response);
-                    }
-                }, new Response.ErrorListener() {
-            @Override
-            public void onErrorResponse(VolleyError error) {
-                Log.d(TAG, " msg error" + error.toString());
-            }
-        });
-
-        reqGetStatus = new StringRequest(ROOT_URL + STATUS_URL + pid,
-                new Response.Listener<String>() {
-                    @Override
-                    public void onResponse(String response) {
-                        offlinePromoteCount = 0;
-                        promoteCount = 0;
-                        if (!AuthUtils.checkOfflineAuthTime(context)) {
-                            if (!AuthUtils.isFinish(context)) {
-                                CToast.makeText(context, "店铺服务已到期，请联系相关工作人员为您续费，否则可能影响后续使用及营业", 8 * 1000).show();
-                            } else {
-                                showMsg("由于你长期没有续费，系统已暂停你的相关功能使用");
-                            }
-                        }
-                        AskService.this.handleStatus(response);
-                    }
-                }, new Response.ErrorListener() {
-            @Override
-            public void onErrorResponse(VolleyError error) {
-                Log.d(TAG, "status error:" + error.toString());
-                boolean pingIp = NetStatusUtils.isAvailableByPing("114.55.207.168");//qnbar ip 通
-                boolean pingUrl = TimeoutCharge.ping("fbs.qnbar.com");//qnbar addr 通
-                boolean pingLocal = NetStatusUtils.isAvailableByPing(sambaMsg.getIp());//qnbar addr 通
-
-                if (AuthUtils.checkOfflineAuthTime(context)) {
-                    if (!pingIp || !pingUrl) {
-                        openLed();
-                    }
-                }
-
-                if (offlinePromoteCount++ >= 3) {
-                    return;
-                }
-                String append = pingLocal ? "电影服务器正常，不影响正常观影" : "电影服务器异常请检查相应配置，否则不能正常观影";
-                if ((!pingIp || !pingUrl)) {
-                    if (promoteCount++ < 3) {
-                        showMsg("机器不能访问远程控制数据,为不影响正常营业，已为您开机，" + append);
-                    } else {
-                        Log.d(TAG, "onErrorResponse: already promote 3 times do nothing " + promoteCount);
-                    }
-                } else {
-                    if (!pingLocal) {
-                        showMsg(append);
-                    }
-                }
-            }
-        }
-
-        );
-        DefaultRetryPolicy retryPolicy = new DefaultRetryPolicy(50 * 1000,
-                DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
-                DefaultRetryPolicy.DEFAULT_BACKOFF_MULT);
-
-        reqGetMessage.setRetryPolicy(retryPolicy);
-        reqGetStatus.setRetryPolicy(retryPolicy);
-
         sender = new UdpPostSender("", 53301, 53301, _handler);
         askPresenter.load(context);
@@ -224,100 +95,6 @@ public class AskService extends Service implements IAskView {
 //        PollingUtils.startPollingService(context, 60, ProguardService.class, ProguardService.STATUS_ACTION);
     }
-    int promoteCount = 0;
-
-    private void handlerMessage(String response) {
-        MessageEvent messageEvent = new MessageEvent();
-        messageEvent.setEventId(1);
-        messageEvent.setMessage("handle message");
-        EventBus.getDefault().post(messageEvent);
-        GimiSysMsg msg = null;
-        ProguardService.lastHandlerServerMsg = System.currentTimeMillis();
-        try {
-            msg = gson.fromJson(response, GimiSysMsg.class);
-        } catch (JsonSyntaxException e) {
-            uploadCrashMsg("getMessage", response, e.getMessage());
-            e.printStackTrace();
-        }
-        if (msg == null) {
-            return;
-        }
-        StringBuilder buffer = new StringBuilder();
-        if (msg.getCode() == 200) {
-            for (GimiSysData gimiSysData : msg.getData()) {
-                buffer.append(gimiSysData.getMessages().getMsg_content().trim()).append("\n");
-            }
-            if (!TextUtils.isEmpty(buffer.toString())) {
-                if (systemUtils.getYbProp() != 3) {
-                    CToast.makeText(context, buffer.toString().trim(), 45 * 1000).show();
-                }
-            }
-            saveGimiAuth(true);
-            System.out.println(msg.toString());
-            System.out.println(buffer.toString());
-        } else if (msg.getCode() == 602) {
-            setUnAuthAndToast(msg.getMessage());
-            unSupport++;
-        }
-    }
-
-    private void handleStatus(String response) {
-        MessageEvent messageEvent = new MessageEvent();
-        messageEvent.setEventId(0);
-        messageEvent.setMessage("handle status");
-        EventBus.getDefault().post(messageEvent);
-
-        GimiMessage gimiMessage = null;
-        ProguardService.lastHandlerServerMsg = System.currentTimeMillis();
-        try {
-            gimiMessage = gson.fromJson(response, GimiMessage.class);
-        } catch (JsonSyntaxException e) {
-            uploadCrashMsg("getStatus", response, e.getMessage());
-            e.printStackTrace();
-        }
-        if (gimiMessage == null) {
-            return;
-        }
-        System.out.println(gimiMessage.toString());
-        if (gimiMessage.getCode() == 200) {
-            saveGimiAuth(true);
-            if (gimiMessage.getData().getStatus().equals("on")) {
-                openLed();
-                Constant.messageRun = true;
-            } else {
-                CToast.makeText(context, "您的观影时间已到，如有需要请到前台续费", 10 * 1000).show();
-                new Handler().postDelayed(serviceRunnable, 10 * 1000);
-            }
-            int delayA = gimiMessage.getData().getDelay();
-            Log.d(TAG, "delay time is :" + delayA);
-            if (delayA != delay) {
-                delay = delayA;
-                Log.d(TAG, "delay time change reset");
-                statusPool.shutdown();
-                statusPool = null;
-                startStatusLoop();
-            }
-        } else if (gimiMessage.getCode() == 602) {
-            setUnAuthAndToast(gimiMessage.getMessage());
-            unSupport++;
-        }
-    }
-
-    private void uploadCrashMsg(String type, String msg, String error) {
-        HashMap<String, String> map = new HashMap<>();
-        map.put("imei", SystemUtils.getPid(context, BuildConfig.MACHINE_TYPE));
-        map.put("type", type);
-        map.put("msg", msg);
-        map.put("error", error);
-        MobclickAgent.onEvent(this, "handler_msg_crash", map);
-    }
-
-    private void openLed() {
-        if (!BuildConfig.MACHINE_TYPE.equals("himedia")) {
-            systemUtils.openLed(context);
-        }
-    }
-
     private void updateMsg() {
         sambaMsg = Utils.getSambaMsg(sharedPreferences);
         ip = sambaMsg.getIp();
@@ -326,19 +103,6 @@ public class AskService extends Service implements IAskView {
     int agentType;
-    private void setUnAuthAndToast(String msg) {
-        saveGimiAuth(false);
-        if (agentType == 5 && AuthUtils.checkOfflineAuthTime(this)) {
-            return;
-        }
-        if (unSupport < 3) {
-            if (systemUtils.getYbProp() != 3)
-                CToast.makeText(context.getApplicationContext(),
-                        TextUtils.isEmpty(msg) ? getString(R.string.no_auth) : msg,
-                        10 * 1000).show();
-        }
-    }
-
     private Handler _handler = new Handler() {
         @Override
         public void dispatchMessage(Message msg) {
@@ -348,12 +112,6 @@ public class AskService extends Service implements IAskView {
                     return;
                 }
                 String obj = (String) msg.obj;
-//                UdpModel udpModel = new Gson().fromJson(obj, UdpModel.class);
-//                if (!udpModel.isMulti()) {
-//                    playPath(getPlayUrl(udpModel.getMovie_url()));
-//                } else {
-                //get All list
-
                 ControlMessage controlMessage = gson.fromJson(obj, ControlMessage.class);
                 UdpModel udpModel1 = controlMessage.getUdpModel();
                 switch (controlMessage.getAction()) {
@@ -379,7 +137,6 @@ public class AskService extends Service implements IAskView {
             }
             super.dispatchMessage(msg);
         }
-//        }
     };
     private void returnCurrentStatus() throws RemoteException {
@@ -473,13 +230,6 @@ public class AskService extends Service implements IAskView {
         systemUtils.stopMediaPlayer(context.getApplicationContext());
     }
-    private void saveGimiAuth(boolean b) {
-        Constant.gimiAuth = b;
-        SharedPreferences.Editor edit = sharedPreferences.edit();
-        edit.putBoolean(Constant.GIMI_AUTHENTICATION, b);
-        edit.apply();
-    }
-
     private Runnable updateRunnable = new Runnable() {
         @Override
         public void run() {
@@ -490,39 +240,8 @@ public class AskService extends Service implements IAskView {
         }
     };
-    private Runnable serviceRunnable = new Runnable() {
-        @Override
-        public void run() {
-            //停止播放视频　纯后台时不走onResume，还需要启动广告视频
-            Intent intent = new Intent(Constant.ACTION_GET_MESSAGE_CLOSE_LED);
-            sendBroadcast(intent);
-            Constant.messageRun = false;
-            if (!BuildConfig.MACHINE_TYPE.equals("himedia")) {
-                systemUtils.setLedStatus(false);
-            }
-            stopMediaPlayer();
-            Intent intentHome = new Intent(Intent.ACTION_MAIN);
-            intentHome.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK); //如果是服务里调用，必须加入new task标识
-            intentHome.addCategory(Intent.CATEGORY_HOME);
-            startActivity(intentHome);
-        }
-    };
-
-    private Runnable closeSystem = new Runnable() {
-        @Override
-        public void run() {
-            systemUtils.shutdown(context);
-        }
-    };
-
     @Override
     public int onStartCommand(Intent intent, int flags, int startId) {
-//        if (systemUtils.getYbProp() != 3) {
-//            if (agentType != 5) {
-//                startMessageLoop();
-//                startStatusLoop();
-//            }
-//        }
         return START_STICKY;
     }
@@ -538,7 +257,6 @@ public class AskService extends Service implements IAskView {
             unbindService(mServiceConnection);
             mBound = false;
         }
-//        unregisterReceiver(myReceiver);
         super.onDestroy();
     }
@@ -556,51 +274,7 @@ public class AskService extends Service implements IAskView {
     public void showMsg(String msg) {
         Toast.makeText(context, msg, Toast.LENGTH_SHORT).show();
     }
-
-    ScheduledExecutorService pool = Executors.newScheduledThreadPool(4);
-    ScheduledExecutorService statusPool = Executors.newScheduledThreadPool(4);
-
-    void startStatusLoop() {
-        if (statusPool == null) {
-            statusPool = Executors.newScheduledThreadPool(4);
-        }
-        TimerTask task = new TimerTask() {
-            @Override
-            public void run() {
-                mQueueSts.add(reqGetStatus);
-                statusCount++;
-                Log.d(TAG, "run: " + "statusCount = " + statusCount + ",delay = " + delay);
-            }
-        };
-//        statusTimer.schedule(task, 0, delay * 1000);
-        statusPool.scheduleAtFixedRate(task, 0, delay * 1000, TimeUnit.MILLISECONDS);
-//        pool.
-    }
-
-    void startMessageLoop() {
-        if (pool == null) {
-            pool = Executors.newScheduledThreadPool(4);
-        }
-        TimerTask himedia = new TimerTask() {
-            @Override
-            public void run() {
-                double v = ((double) (System.currentTimeMillis() / 1000 % 86400)) / 3600;
-                if ((v > 18 && v < 24) && !Constant.messageRun && !BuildConfig.MACHINE_TYPE.equals("himedia")) {
-                    handler.postDelayed(closeSystem, 5 * 1000);
-                }
-                if (Constant.messageRun) {
-                    // getMessage from server
-                    mQueueMsg.add(reqGetMessage);
-                    messageCount++;
-                }
-
-                Log.d(TAG, "run: " + "messageCount = " + messageCount + ",delay = " + delay);
-            }
-        };
-        pool.scheduleAtFixedRate(himedia, 0, CUR_PERIOD * 1000, TimeUnit.MILLISECONDS);
-    }
-
-    //由AIDL文件生成的Java类
+        //由AIDL文件生成的Java类
     private ICinemaControl cinemaControl = null;
     //标志当前与服务端连接状况的布尔值，false为未连接，true为连接中
@@ -631,35 +305,4 @@ public class AskService extends Service implements IAskView {
     }
     public static final String ACTION = "cn.etzmico.broadcastreceiverregister.SENDBROADCAST";
-    private BroadcastReceiver myReceiver = new BroadcastReceiver() {
-
-        @Override
-        public void onReceive(Context context, Intent intent) {
-//            Toast.makeText(context, "myReceiver receive", Toast.LENGTH_SHORT)
-//                    .show();
-            Log.d(TAG, "delay time change reset");
-            boolean reset = intent.getBooleanExtra("reset", false);
-            if (statusPool != null) {
-                statusPool.shutdown();
-                statusPool = null;
-            }
-            if (pool != null) {
-                pool.shutdown();
-                pool = null;
-            }
-            if (reset) {
-                statusCount = 0;
-                messageCount = 0;
-                startStatusLoop();
-                startMessageLoop();
-            }
-        }
-    };
-
-    private void initBroadcast() {
-        IntentFilter filter = new IntentFilter();
-        filter.addAction(ACTION);
-        filter.setPriority(Integer.MAX_VALUE);
-        registerReceiver(myReceiver, filter);
-    }
 }