天气同步

public class WeatherSyncTask extends DeviceSyncTask {
    private final String tag = getClass().getSimpleName();
    private final SyncTaskManager syncTaskManager;

    public WeatherSyncTask(SyncTaskManager manager, SyncTaskFinishListener finishListener) {
        super(finishListener);
        this.syncTaskManager = manager;
    }

    @Override
    public int getType() {
        return TASK_TYPE_SYNC_DEVICE_WEATHER;
    }

@Override
public void start() {
    if (mWatchManager.isFirmwareOTA()) {
        JL_Log.w(tag, "start", "device's ota is in progress.");
        if (finishListener != null) finishListener.onFinish();
        return;
    }
    if (checkEnv()) {
        refreshCity(HealthApplication.getAppViewModel().getApplication());
    } else {
        onFinish(false);
    }
}

private boolean checkEnv() {
    if (!mWatchManager.isConnected()) return false;
    NetWorkStateModel netWorkStateModel = NetworkStateHelper.getInstance().getNetWorkStateModel();
    //网络状态
    return netWorkStateModel != null && netWorkStateModel.isAvailable();
}

private void refreshCity(Context context) {
    AMapLocationClient locationClient = null;
    try {
        locationClient = new AMapLocationClient(context);
        locationClient.setLocationListener(mAMapLocationListener);
        AMapLocationClientOption option = new AMapLocationClientOption();
        option.setOnceLocation(true);
        option.setOnceLocationLatest(true);
        option.setHttpTimeOut(20000);
        option.setLocationMode(AMapLocationClientOption.AMapLocationMode.Hight_Accuracy);
        locationClient.setLocationOption(option);
        //设置场景模式后最好调用一次stop，再调用start以保证场景模式生效
        locationClient.stopLocation();
        locationClient.startLocation();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

private final AMapLocationListener mAMapLocationListener = aMapLocation -> {
    if (aMapLocation != null) {
        if (aMapLocation.getErrorCode() == 0) {
            refreshWeather(aMapLocation.getCity());
        } else {
            if (aMapLocation.getErrorCode() == AMapLocation.ERROR_CODE_FAILURE_LOCATION_PERMISSION) {
                refreshCityByIP();
            } else {
                onFinish(false);
            }
            JL_Log.d(tag, "onLocationChanged", "location Error, ErrCode:"
                    + aMapLocation.getErrorCode() + ", errInfo:"
                    + aMapLocation.getErrorInfo());
        }
    }
};

private void refreshCityByIP() {
    String url = "http://restapi.amap.com/v3/ip?key=2824c5044e6cd020c3af5e5d923cb883";
    OkHttpClient okHttpClient = new OkHttpClient();
    final Request request = new Request.Builder()
            .url(url)
            .get()
            .build();
    Call call = okHttpClient.newCall(request);
    call.enqueue(new Callback() {
        @Override
        public void onFailure(@NotNull Call call, @NotNull IOException e) {
            JL_Log.w(tag, "refreshCityByIP", "onFailure: " + e);
            refreshWeather("北京市");
        }

        @Override
        public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
            if (!response.isSuccessful() || null == response.body()) return;
            String res = response.body().string();
            String city = null;
            try {
                Gson gson = new GsonBuilder().create();
                City cityObj = gson.fromJson(res, City.class);
                if (cityObj != null) {
                    city = cityObj.getCity();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
            refreshWeather(city != null ? city : "北京市");
        }
    });
}

private void refreshWeather(String city) {
    try {
        WeatherSearchQuery query = new WeatherSearchQuery(city, WeatherSearchQuery.WEATHER_TYPE_LIVE);
        WeatherSearch search = new WeatherSearch(HealthApplication.getAppViewModel().getApplication());
        search.setQuery(query);
        search.setOnWeatherSearchListener(new WeatherSearch.OnWeatherSearchListener() {
            @Override
            public void onWeatherLiveSearched(LocalWeatherLiveResult localWeatherLiveResult, int code) {
                if (code != 1000) {
                    JL_Log.w(tag, "refreshWeather", "获取天气失败");
                    onFinish(false);
                    return;
                }
                if (localWeatherLiveResult == null || localWeatherLiveResult.getLiveResult() == null) {
                    JL_Log.w(tag, "refreshWeather", "没有天气数据");
                    onFinish(false);
                    return;
                }
                LocalWeatherLive result = localWeatherLiveResult.getLiveResult();
                String sb = "实时天气数据:" + "\n" +
                        "省份:" + result.getProvince() + "\t\t" +
                        "城市:" + result.getCity() + "\t\t" +
                        "城市编码:" + result.getAdCode() + "\n" +
                        "天气:" + result.getWeather() + "\t\t" +
                        "温度:" + result.getTemperature() + "\t\t" +
                        "湿度:" + result.getHumidity() + "\n" +
                        "方向:" + result.getWindDirection() + "\t\t" +
                        "风力:" + result.getWindPower() + "\n" +
                        "时间:" + result.getReportTime() + "\n\n";
                JL_Log.d(tag, "refreshWeather", sb);
                syncWeatherToDevice(result);
            }

            @Override
            public void onWeatherForecastSearched(LocalWeatherForecastResult localWeatherForecastResult, int code) {
                onFinish(false);
            }
        });
        search.searchWeatherAsyn();
    } catch (AMapException e) {
        e.printStackTrace();
    }
}

private void syncWeatherToDevice(LocalWeatherLive result) {
    byte weatherCode = getWeatherCode(result.getWeather());
    byte windDirectionCode = getWindDirectionCode(result.getWindDirection());
    byte temperature = Byte.parseByte(result.getTemperature());
    byte humidity = Byte.parseByte(result.getHumidity());
    byte windPower = (result.getWindPower().equals("≤3")) ? 3 : Byte.parseByte(result.getWindPower());
    @SuppressLint("SimpleDateFormat")
    SimpleDateFormat format = CustomTimeFormatUtil.dateFormat("yyyy-MM-dd hh:mm:ss");
    long time = 0;
    try {
        Date date = format.parse(result.getReportTime());
        if (date != null) {
            time = date.getTime();
        }
    } catch (ParseException e) {
        e.printStackTrace();
    }

    PushInfoDataToDeviceCmd.Weather weather = new PushInfoDataToDeviceCmd.Weather(
            result.getProvince(), result.getCity(),
            weatherCode, temperature,
            humidity, windPower, windDirectionCode,
            time
    );
    mWatchManager.syncWeatherInfo(weather, new OnWatchOpCallback<Boolean>() {
        @Override
        public void onSuccess(Boolean result) {
            onFinish(true);
        }

        @Override
        public void onFailed(BaseError error) {
            JL_Log.w(tag, "syncWeatherToDevice", "天气同步失败, " + error);
            onFinish(false);
        }
    });
}

private void onFinish(boolean success) {
    int min = 1000 * 60;
    syncTaskManager.addWeatherTask(success ? 15 * min : 2 * min);//同步成功，间隔15分钟，同步失败，间隔2分钟
    finishListener.onFinish();
}

private void startTestSyncWeather() {
    if (!isTestRunning) return;
    PushInfoDataToDeviceCmd.Weather weather = getRandomWeather();
    if (null == weather) {
        callbackError(TestError.ERR_INVALID_PARAM);
        return;
    }
    onTestLog("开始同步天气:" + weather + ",\n 测试次数: " + (count + 1));
    mWatchOp.syncWeatherInfo(weather, new OnWatchOpCallback<Boolean>() {
        @Override
        public void onSuccess(Boolean result) {
            count++;
            if (count >= mTestCount) {
                callbackError(TestError.ERR_SUCCESS);
            } else {
                mUIHandler.postDelayed(() -> startTestSyncWeather(), DELAY_TIME);
            }
        }

        @Override
        public void onFailed(BaseError error) {
            String text = String.format(Locale.getDefault(), "code:%d, %s", error.getCode(), error.getMessage());
            callbackError(TestError.ERR_FAILED, text);
        }
    });
}

@Test
public void syncWeatherInformation() {
    //WatchManager是WatchOpImpl的子类，须在1.3配置好sdk
    WatchManager watchManager = WatchManager.getInstance();
    String province = "省份";
    String city = "城市";
    byte weatherCode = 0;//天气编码，参考天气编码表
    byte temperature = 0;//温度
    byte humidity = 0; //湿度
    byte windPower = 0;//风力等级
    byte windDirectionCode = 0; //方向编码，参考方向编码表
    long time = System.currentTimeMillis(); //时间
    //构建天气信息
    PushInfoDataToDeviceCmd.Weather weather = new PushInfoDataToDeviceCmd.Weather(province, city,
            weatherCode, temperature,
            humidity, windPower, windDirectionCode,
            time
    );
    //执行同步天气信息功能并等待结果回调
    watchManager.syncWeatherInfo(weather, new OnWatchOpCallback<Boolean>() {
        @Override
        public void onSuccess(Boolean result) {
            //天气同步成功
        }

        @Override
        public void onFailed(BaseError error) {
            //天气同步失败
            //error - 错误信息
        }
    });
}

public SyncWeatherTask(WatchOpImpl watchOp, int testCount, PushInfoDataToDeviceCmd.Weather... weatherList) {
    mWatchOp = watchOp;
    if (testCount < 1) testCount = 1;
    mTestCount = testCount;
    mWeatherList = weatherList;
}

@Nullable
private PushInfoDataToDeviceCmd.Weather getRandomWeather() {
    if (null == mWeatherList || mWeatherList.length == 0) return null;
    if (mWeatherList.length == 1) return mWeatherList[0];
    int random = getRandom(mWeatherList.length);
    while (random == lastIndex) {
        random = getRandom(mWeatherList.length);
    }
    lastIndex = random;
    return mWeatherList[random];
}

Weather(String province, String city,
        byte weatherCode, byte temperature,
        byte humidity, byte windPower, byte windDirectionCode,
        long time)