修改同步脚本

@@ -142,9 +142,23 @@ class StakeholderIncomeSyncCommand extends Command
      */
     private function consumeTask($http_res, $redis, $key, $id)
     {
-
-
+        if (empty($http_res)) {
             return $redis->xdel($key, [$id]);
+        } else {
+            switch (intval($http_res['code'])) {
+                case 0:  //同步成功
+                case 501://入账类型不支持，请查阅入账类型字典10016
+                case 502://该用户或机构在分贝平台不存在，入账失败
+                case 503://入账金额计算有误，总金额=可提现金额+税费
+                case 504://请勿重复入账
+                case 506://子账单汇总金额与一级账单总金额不一致
+                case 507://子账单付款公司与一级账单付款公司不一致
+                    $redis->xdel($key, [$id]);
+                    break;
+                case 500: //无访问权限
+                    break;
+            }
+        }
     }
 
     /**