同步数据

@@ -75,6 +75,11 @@ class StakeholderIncomeSyncJob implements ShouldQueue
                     'title'=>"{$bills->bill_section_start}-{$bills->bill_section_end}账单/{$channel}",
                 ];
 
+                if ($res = StakeholderIncomeByPayer::query()->where(['serial_no'=>$income_item['serial_no']])->first()) {
+
+                    if ($res['sync_status'] == 0) {
+
+                        //直接未同步的数据才请求api
                         $http_res = ApiService::walletAddIncome($http_data);
 
                         if (empty($http_res)) {
@@ -98,8 +103,12 @@ class StakeholderIncomeSyncJob implements ShouldQueue
                                 $redis->xdel($key, [$id]);
                             }
                         }
-            }
 
+                    } else {
+                        $redis->xdel($key, [$id]);
+                    }
+                }
+            }
         }
     }
 }