FinancialStat.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: tandunzhao
  5. * Date: 2017/11/17
  6. * Time: 下午5:44
  7. */
  8. namespace App\Modules\Finance\Models;
  9. use App\Modules\Channel\Models\Channel;
  10. use Illuminate\Database\Eloquent\Model;
  11. use DB;
  12. /**
  13. * Class FinancialStat 渠道提现信息(可提现,总提现...)
  14. * @package App\Modules\Finance\Models
  15. */
  16. class FinancialStat extends Model
  17. {
  18. protected $table = 'financial_stats';
  19. protected $fillable = ['distribution_channel_id', 'accumulative_withdrawal_amount','enable_withdrawal_amount', 'latest_withdrawal_amount', 'latest_withdraw_time','withdraw_pending_amount', 'commission_rate'];
  20. /**
  21. * 根据渠道ID获取FinancialStat
  22. * @param $distribution_channel_id
  23. * @return mixed
  24. */
  25. static function getByDistributionChannel($distribution_channel_id)
  26. {
  27. $result = self::where('distribution_channel_id', $distribution_channel_id)->first();
  28. return $result;
  29. }
  30. /**
  31. * 获取可提现金额总额
  32. * @param string $distribution_channel_id 不传获取所有渠道可提现金额总额
  33. * @return mixed
  34. */
  35. static function getEnableWithdrawalAmount($distribution_channel_id = '') {
  36. if($distribution_channel_id) {
  37. return FinancialStat::where('distribution_channel_id', $distribution_channel_id)->sum('enable_withdrawal_amount');
  38. } else {
  39. return FinancialStat::sum('enable_withdrawal_amount');
  40. }
  41. }
  42. /**
  43. * 获取账号信息列表
  44. * @param $params[]
  45. * channel_id:渠道ID 可选
  46. * channel_name:渠道名称 可选
  47. * person_in_charge_name: 渠道负责人姓名 可选
  48. * search_name: 搜索名称 可选
  49. * ac_start_time:开始时间 可选
  50. * ac_end_time:结束时间 可选
  51. * is_frozen:冻结 0; -1:冻结账户 可选
  52. * frozen_start_time:冻结开始时间 可选
  53. * frozen_end_time:冻结结束时间 可选
  54. * is_company 0:对私, 1:对公司 可选
  55. * @return mixed
  56. */
  57. public static function getFrozenFinancialStatListParam($params=[]) {
  58. $search_object = Channel::select([
  59. 'distribution_channels.id',
  60. 'distribution_channels.phone',
  61. 'distribution_channels.name',
  62. 'distribution_channels.pay_merchant_id',
  63. 'distribution_channels.nickname',
  64. 'distribution_channels.remark as channel_remark',
  65. 'distribution_channels.person_in_charge_name',
  66. 'distribution_channels.created_at as channel_created_at',
  67. 'financial_stats.accumulative_withdrawal_amount',
  68. 'financial_stats.enable_withdrawal_amount',
  69. 'financial_stats.latest_withdrawal_amount',
  70. 'financial_stats.latest_withdraw_time',
  71. 'financial_stats.withdraw_pending_amount',
  72. 'financial_stats.commission_rate',
  73. 'cash_accounts.is_company',
  74. DB::raw('IFNULL(financial_configs.is_frozen, 0) as is_frozen'),
  75. DB::raw('IFNULL(financial_configs.remark , "") as fc_remark'),
  76. DB::raw('IFNULL(financial_configs.updated_at , "") as frozen_time'),
  77. ])
  78. ->leftjoin('financial_stats','financial_stats.distribution_channel_id','=','distribution_channels.id')
  79. ->leftjoin('financial_configs','financial_configs.distribution_channel_id','=','distribution_channels.id')
  80. ->leftjoin('cash_accounts','cash_accounts.distribution_channel_id','=','distribution_channels.id')
  81. ->orderBy('distribution_channels.id','asc');
  82. if(isset($params['channel_id']) && $params['channel_id']) $search_object->where('distribution_channels.id', $params['channel_id']);
  83. if(isset($params['channel_name']) && $params['channel_name']) $search_object->where('distribution_channels.name','like', "%".$params['channel_name']."%");
  84. if(isset($params['person_in_charge_name']) && $params['person_in_charge_name']) $search_object->where('distribution_channels.person_in_charge_name', 'like', "%".$params['person_in_charge_name']."%");
  85. if(isset($params['search_name']) && $params['search_name']) {
  86. $search_object->where(function ($query) use($params) {
  87. $query->where('distribution_channels.name','like', "%".$params['search_name']."%")
  88. ->orWhere('distribution_channels.person_in_charge_name', 'like', "%".$params['search_name']."%");
  89. });
  90. }
  91. if(isset($params['is_frozen']) && is_numeric($params['is_frozen'])) {
  92. if($params['is_frozen'] == 0) {
  93. $search_object->where(function ($query) use($params) {
  94. $query->where('financial_configs.is_frozen', 0)
  95. ->orWhereNull('financial_configs.is_frozen');
  96. });
  97. } else {
  98. $search_object->where('financial_configs.is_frozen', $params['is_frozen']);
  99. }
  100. }
  101. if(isset($params['ac_start_time']) && $params['ac_start_time']) $search_object->where('distribution_channels.created_at','>=', $params['ac_start_time']);
  102. if(isset($params['ac_end_time']) && $params['ac_end_time']) $search_object->where('distribution_channels.created_at','<=', $params['ac_end_time']);
  103. if(isset($params['frozen_start_time']) && $params['frozen_start_time']) $search_object->where('financial_configs.updated_at','>=', $params['frozen_start_time']);
  104. if(isset($params['frozen_end_time']) && $params['frozen_end_time']) $search_object->where('financial_configs.updated_at','<=', $params['frozen_end_time']);
  105. if(isset($params['is_company']) && is_numeric($params['is_company'])) {
  106. if($params['is_company'] == 0) {
  107. $search_object->where(function ($query) use($params) {
  108. $query->where('cash_accounts.is_company', 0)
  109. ->orWhereNull('cash_accounts.is_company');
  110. });
  111. } else {
  112. $search_object->where('cash_accounts.is_company', $params['is_company']);
  113. }
  114. }
  115. return $search_object->paginate();
  116. }
  117. /**
  118. * 结算明细
  119. * @param $params[]
  120. * channel_id:渠道ID 可选
  121. * channel_name:渠道名称 可选
  122. * person_in_charge_name: 渠道负责人姓名 可选
  123. * search_name: 搜索名称 可选
  124. * ac_start_time:开始时间 可选
  125. * ac_end_time:结束时间 可选
  126. * is_frozen:冻结 0; -1:冻结账户 可选
  127. * frozen_start_time:冻结开始时间 可选
  128. * frozen_end_time:冻结结束时间 可选
  129. * @return mixed
  130. */
  131. static function getFrozenFinancialStatPriceListDetail($params=[]) {
  132. $search_object = Channel::select([
  133. 'distribution_channels.id',
  134. 'distribution_channels.phone',
  135. 'distribution_channels.name',
  136. 'distribution_channels.pay_merchant_id',
  137. 'distribution_channels.nickname',
  138. 'distribution_channels.remark as channel_remark',
  139. 'distribution_channels.person_in_charge_name',
  140. 'distribution_channels.created_at as channel_created_at',
  141. 'financial_stats.accumulative_withdrawal_amount',
  142. 'financial_stats.enable_withdrawal_amount',
  143. 'financial_stats.latest_withdrawal_amount',
  144. 'financial_stats.latest_withdraw_time',
  145. 'financial_stats.withdraw_pending_amount',
  146. 'financial_stats.commission_rate',
  147. 'cash_accounts.is_company',
  148. DB::raw('IFNULL(financial_configs.is_frozen, 0) as is_frozen'),
  149. DB::raw('IFNULL(financial_configs.remark , "") as fc_remark'),
  150. DB::raw('IFNULL(financial_configs.updated_at , "") as frozen_time'),
  151. DB::raw('(SELECT sum(withdraw_cashes.tallage) from withdraw_cashes where withdraw_cashes.distribution_channel_id = distribution_channels.id) as tallage'),
  152. DB::raw('(SELECT sum(bills.recharge_amount) from bills where bills.distribution_channel_id = distribution_channels.id) as recharge_amount_count'),
  153. DB::raw('(SELECT sum(bills.settlement_price) from bills where bills.distribution_channel_id = distribution_channels.id) as settlement_price_count')
  154. ])
  155. ->leftjoin('financial_stats','financial_stats.distribution_channel_id','=','distribution_channels.id')
  156. ->leftjoin('financial_configs','financial_configs.distribution_channel_id','=','distribution_channels.id')
  157. ->leftjoin('bills','bills.distribution_channel_id','=','distribution_channels.id')
  158. ->leftjoin('cash_accounts','cash_accounts.distribution_channel_id','=','distribution_channels.id')
  159. ->groupBy('distribution_channels.id')
  160. ->orderBy('distribution_channels.id','asc');
  161. if(isset($params['channel_id']) && $params['channel_id']) $search_object->where('distribution_channels.id', $params['channel_id']);
  162. if(isset($params['channel_name']) && $params['channel_name']) $search_object->where('distribution_channels.name','like', "%".$params['channel_name']."%");
  163. if(isset($params['person_in_charge_name']) && $params['person_in_charge_name']) $search_object->where('distribution_channels.person_in_charge_name', 'like', "%".$params['person_in_charge_name']."%");
  164. if(isset($params['search_name']) && $params['search_name']) {
  165. $search_object->where(function ($query) use($params) {
  166. $query->where('distribution_channels.name','like', "%".$params['search_name']."%")
  167. ->orWhere('distribution_channels.person_in_charge_name', 'like', "%".$params['search_name']."%");
  168. });
  169. }
  170. if(isset($params['is_frozen']) && is_numeric($params['is_frozen'])) {
  171. if($params['is_frozen'] == 0) {
  172. $search_object->where(function ($query) use($params) {
  173. $query->where('financial_configs.is_frozen', 0)
  174. ->orWhereNull('financial_configs.is_frozen');
  175. });
  176. } else {
  177. $search_object->where('financial_configs.is_frozen', $params['is_frozen']);
  178. }
  179. }
  180. if(isset($params['ac_start_time']) && $params['ac_start_time']) $search_object->where('distribution_channels.created_at','>=', $params['ac_start_time']);
  181. if(isset($params['ac_end_time']) && $params['ac_end_time']) $search_object->where('distribution_channels.created_at','<=', $params['ac_end_time']);
  182. if(isset($params['frozen_start_time']) && $params['frozen_start_time']) $search_object->where('financial_configs.updated_at','>=', $params['frozen_start_time']);
  183. if(isset($params['frozen_end_time']) && $params['frozen_end_time']) $search_object->where('financial_configs.updated_at','<=', $params['frozen_end_time']);
  184. if(isset($params['is_company']) && is_numeric($params['is_company'])) {
  185. if($params['is_company'] == 0) {
  186. $search_object->where(function ($query) use($params) {
  187. $query->where('cash_accounts.is_company', 0)
  188. ->orWhereNull('cash_accounts.is_company');
  189. });
  190. } else {
  191. $search_object->where('cash_accounts.is_company', $params['is_company']);
  192. }
  193. }
  194. return $search_object->paginate();
  195. }
  196. }