[提交人]：王雪伟

[提交简述] ：幸福农场
[实现方案] ：加入广告

app/src/main/java/com/ym/game/GameActivity.kt

@@ -49,7 +49,7 @@ class GameActivity : UnityPlayerActivity() {
         )
         mLoading?.dismiss()
         TurntableDialog.initTurntableAnim()
-
+        ToponManager.initRewardAd(this, AdID.mPlacementId_Reward_video_luck_farm)
     }
 
     /**
@@ -57,29 +57,6 @@ class GameActivity : UnityPlayerActivity() {
      */
     fun gotoWithdrawPage() {
         Log.d("wxw", "跳转提现页")
-        ToponManager.loadReward(this, object : ToponRewardListener {
-            override fun onRewardedVideoAdPlayClicked(entity: ATAdInfo) {
-                Log.d("wxw", "onRewardedVideoAdPlayClicked")
-            }
-
-            override fun onRewardedVideoAdClosed(entity: ATAdInfo) {
-                Log.d("wxw", "onRewardedVideoAdClosed")
-            }
-
-            override fun onRewardedVideoAdFailed(errorCode: AdError) {
-                Log.d("wxw", "onRewardedVideoAdFailed")
-
-            }
-
-            override fun onRewardedVideoAdPlayEnd(entity: ATAdInfo) {
-                Log.d("wxw", "onRewardedVideoAdPlayEnd")
-            }
-
-            override fun onRewardedVideoAdPlayStart(entity: ATAdInfo) {
-                Log.d("wxw", "onRewardedVideoAdPlayStart")
-            }
-
-        }, AdID.mPlacementId_Reward_video_luck_farm)
     }
 
     /**
@@ -186,6 +163,16 @@ class GameActivity : UnityPlayerActivity() {
      * */
     fun getCloudSpeed(callback: IUnitySendMessageCallback?) {
         Log.d("wxw", "云朵加速")
+        ToponManager.loadReward(this, object : ToponRewardListener {
+            override fun onRewardedVideoAdPlayClicked(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayClicked")
+            }
+
+            override fun onRewardedVideoAdClosed(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdClosed")
+                //看视频上报
+                getVideoAcceleratorsReceive();
+                //
                 GameApiClient.gameApi.getCloudSpeed().compose(RxSchedulers.observableIO2Main())
                     .subscribe(object : BaseObserver<StatusEntity>() {
                         override fun onSuccess(result: StatusEntity?) {
@@ -200,6 +187,35 @@ class GameActivity : UnityPlayerActivity() {
                     })
             }
 
+            override fun onRewardedVideoAdFailed(errorCode: AdError) {
+                Log.d("wxw", "onRewardedVideoAdFailed")
+                callback?.onIncrVideoAcceleratorsSuccess(false,"广告失败")
+            }
+
+            override fun onRewardedVideoAdPlayEnd(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayEnd")
+            }
+
+            override fun onRewardedVideoAdPlayStart(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayStart")
+            }
+        }, AdID.mPlacementId_Reward_video_luck_farm)
+
+
+//        GameApiClient.gameApi.getCloudSpeed().compose(RxSchedulers.observableIO2Main())
+//            .subscribe(object : BaseObserver<StatusEntity>() {
+//                override fun onSuccess(result: StatusEntity?) {
+//                    Log.d("wxw", "云朵加速" + Utils.obj2Str(result))
+//                    callback?.onCloudSpeedSuccess(true, Utils.obj2Str(result))
+//                }
+//
+//                override fun onFailure(e: Throwable?, code: String?, errorMsg: String?) {
+//                    Log.d("wxw", "云朵加速 error")
+//                    callback?.onCloudSpeedSuccess(false, errorMsg + "")
+//                }
+//            })
+    }
+
     //解锁地块
     fun getUnlockLand(callback: IUnitySendMessageCallback?, id: Int, type: Int) {
         Log.d("wxw", "解锁地块 id" + id + "type" + type)
@@ -305,6 +321,16 @@ class GameActivity : UnityPlayerActivity() {
 
     //看视频领取种子
     fun getVideoSeedReceive(callback: IUnitySendMessageCallback?, id: Int) {
+        ToponManager.loadReward(this, object : ToponRewardListener {
+            override fun onRewardedVideoAdPlayClicked(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayClicked")
+            }
+
+            override fun onRewardedVideoAdClosed(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdClosed")
+                //看视频上报
+                getVideoAcceleratorsReceive();
+                //
                 GameApiClient.gameApi.getVideoSeedReceive(id).compose(RxSchedulers.observableIO2Main())
                     .subscribe(object : BaseObserver<StatusEntity>() {
                         override fun onSuccess(result: StatusEntity?) {
@@ -320,8 +346,49 @@ class GameActivity : UnityPlayerActivity() {
                     })
             }
 
+            override fun onRewardedVideoAdFailed(errorCode: AdError) {
+                Log.d("wxw", "onRewardedVideoAdFailed")
+                callback?.onIncrVideoAcceleratorsSuccess(false,"广告失败")
+            }
+
+            override fun onRewardedVideoAdPlayEnd(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayEnd")
+            }
+
+            override fun onRewardedVideoAdPlayStart(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayStart")
+            }
+        }, AdID.mPlacementId_Reward_video_luck_farm)
+
+
+
+//        GameApiClient.gameApi.getVideoSeedReceive(id).compose(RxSchedulers.observableIO2Main())
+//            .subscribe(object : BaseObserver<StatusEntity>() {
+//                override fun onSuccess(result: StatusEntity?) {
+//                    result?.id = id
+//                    Log.d("wxw", "看视频领取种子" + Utils.obj2Str(result))
+//                    callback?.onIncrVideoSeedSuccess(true, Utils.obj2Str(result))
+//                }
+//
+//                override fun onFailure(e: Throwable?, code: String?, errorMsg: String?) {
+//                    Log.d("wxw", "看视频领取种子 error")
+//                    callback?.onIncrVideoSeedSuccess(false, errorMsg + "")
+//                }
+//            })
+    }
+
     //看视频领取加速剂
     fun getVideoAcceleratorsReceive(callback: IUnitySendMessageCallback?, id: Int) {
+        ToponManager.loadReward(this, object : ToponRewardListener {
+            override fun onRewardedVideoAdPlayClicked(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayClicked")
+            }
+
+            override fun onRewardedVideoAdClosed(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdClosed")
+                //看视频上报
+                getVideoAcceleratorsReceive();
+                //
                 GameApiClient.gameApi.getVideoAcceleratorsReceive(id)
                     .compose(RxSchedulers.observableIO2Main())
                     .subscribe(object : BaseObserver<StatusEntity>() {
@@ -335,7 +402,43 @@ class GameActivity : UnityPlayerActivity() {
                             callback?.onIncrVideoAcceleratorsSuccess(false, errorMsg + "")
                         }
                     })
+
+
+            }
+
+            override fun onRewardedVideoAdFailed(errorCode: AdError) {
+                Log.d("wxw", "onRewardedVideoAdFailed")
+                callback?.onIncrVideoAcceleratorsSuccess(false,"广告失败")
+            }
+
+            override fun onRewardedVideoAdPlayEnd(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayEnd")
+            }
+
+            override fun onRewardedVideoAdPlayStart(entity: ATAdInfo) {
+                Log.d("wxw", "onRewardedVideoAdPlayStart")
+            }
+        }, AdID.mPlacementId_Reward_video_luck_farm)
+
+
+
+    }
+
+    //看视频领上报
+    fun getVideoAcceleratorsReceive() {
+        GameApiClient.gameApi.adVideoReport()
+            .compose(RxSchedulers.observableIO2Main())
+            .subscribe(object : BaseObserver<StatusEntity>() {
+                override fun onSuccess(result: StatusEntity?) {
+                    Log.d("wxw", "看视频上报 Success")
+                }
+
+                override fun onFailure(e: Throwable?, code: String?, errorMsg: String?) {
+                    Log.d("wxw", "看视频上报 error")
+                }
+            })
     }
 
 
+
 }
\ No newline at end of file

app/src/main/java/com/ym/game/net/IGameApi.kt

@@ -124,7 +124,6 @@ interface IGameApi {
      */
     @POST(NetConfig.Game.URL_GAME_INCR_SEED)
     fun getVideoSeedReceive(@Query("id") id: Int): Observable<Response<StatusEntity>>
-
     /**
      * 看视频获得加速剂
      * @param
@@ -132,15 +131,25 @@ interface IGameApi {
      * @return
      */
     @POST(NetConfig.Game.URL_GAME_INCR_ACCELERATORS)
-    fun getVideoAcceleratorsReceive(): Observable<Response<StatusEntity>>
+    fun getVideoAcceleratorsReceive(@Query("id") id: Int): Observable<Response<StatusEntity>>
 
     /**
-     * 看视频获得加速剂
+     * 开宝箱
      * @param
      * @paramq
      * @return
      */
     @POST(NetConfig.Game.URL_GAME_OPEN_BOX)
     fun getopenBox(): Observable<Response<StatusEntity>>
-    fun getVideoAcceleratorsReceive(@Query("id") id: Int): Observable<Response<StatusEntity>>
+
+   /**
+     * 看视频上报
+     * @param
+     * @paramq
+     * @return
+     */
+    @POST(NetConfig.Game.URL_GAME_AD_VIDEO_REPORT)
+    fun adVideoReport(): Observable<Response<StatusEntity>>
+
+
 }
\ No newline at end of file

library/src/main/java/com/ym/library/net/NetConfig.java

@@ -234,6 +234,7 @@ public class NetConfig {
 
     public static class Game{
         public static final String URL_GAME_AD_VIDEO_REPORT="app/v1/game/report";//看视频上报
+
         public static final String URL_GAME_BUY_SEED="app/v1/game/farm/buy_seed";//金币购买种子
         public static final String URL_GAME_CLOUD_SPEED="app/v1/game/farm/cloud_speed";//云朵加速
         public static final String URL_GAME_DO_WD="app/v1/game/farm/do_wd";//发起提现

library/src/main/java/com/ym/library/net/PermissionsActivity.java

@@ -79,28 +79,6 @@ public class PermissionsActivity extends Activity {
         isRequireCheck = true;
     }
 
-    private void createDialog() {
-        alertBuilder = new AlertDialog.Builder(this)
-                .setTitle(R.string.permission_help)
-                .setNegativeButton(R.string.permission_quit, (dialog, which) -> {
-                    setResult(PERMISSIONS_DENIED);
-                    isAlertDialogShow = false;
-                    finish();
-                })
-                .setPositiveButton(R.string.permission_setting, (dialog, which) -> {
-                    isAlertDialogShow = false;
-                    dialog.dismiss();
-                    startAppSettings();
-                })
-                .setOnKeyListener((dialog, keyCode, event) -> {
-                    if (keyCode == KeyEvent.KEYCODE_BACK) {
-                        return true;
-                    }
-                    return false;
-                })
-                .setCancelable(false);
-    }
-
     // 启动应用的设置
     private void startAppSettings() {
         Intent intent = new Intent(Settings.ACTION_APPLICATION_DETAILS_SETTINGS);

toponad/src/main/java/com/ym/module/toponad/ToponManager.kt

@@ -213,7 +213,6 @@ object ToponManager {
             override fun onRewardedVideoAdPlayEnd(entity: ATAdInfo) {
                 listener.onRewardedVideoAdPlayEnd(entity)
                 //移除本次并预加载
-                mRewardVideoAd?.show(activity)
                 AdMap.aTRewardVideoAdMap.remove(placementId)
                 AdMap.aTRewardVideoAdMap[placementId] =
                     preloadingLoadReward(activity, placementId)
@@ -256,6 +255,7 @@ object ToponManager {
                             Toast.makeText(activity, "看完视频即可获得奖励", Toast.LENGTH_SHORT).show()
                             isShowToast = false
                         }
+                        mRewardVideoAd?.show(activity)
                         Log.i(TAG, "isAdReady =  true")
                         removeCallbacksAndMessages(null)
                     } else {