ServeLog.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612
  1. <?php
  2. namespace common\models;
  3. use common\helpers\snowflake\SnowFake;
  4. use Exception;
  5. use Yii;
  6. /**
  7. * This is the model class for table "{{%SERVE_LOG}}".
  8. *
  9. * @property string $ID
  10. * @property string $PERIOD_NUM 业绩期
  11. * @property string $LOG_DESCRIBE 日志信息
  12. * @property string $CREATE_AT 创建时间
  13. * @property string $CALC_MONTH 结算年月
  14. */
  15. class ServeLog extends \common\components\ActiveRecord
  16. {
  17. /**
  18. * {@inheritdoc}
  19. */
  20. public static function tableName()
  21. {
  22. return '{{%SERVE_LOG}}';
  23. }
  24. /**
  25. * {@inheritdoc}
  26. */
  27. public function rules()
  28. {
  29. return [
  30. [['PERIOD_NUM', 'CALC_MONTH', 'CREATE_AT'], 'required'],
  31. [['ID'], 'unique'],
  32. ];
  33. }
  34. /**
  35. * {@inheritdoc}
  36. */
  37. public function attributeLabels()
  38. {
  39. return [
  40. 'ID' => 'ID',
  41. 'PERIOD_NUM' => '业绩期',
  42. 'LOG_DESCRIBE' => '描述信息',
  43. 'CALC_MONTH' => '总人数',
  44. 'CREATE_AT' => '总业绩',
  45. ];
  46. }
  47. // =============================业绩相关日志==========================================================================
  48. /**
  49. * 无逻辑日志,直接传文案
  50. * @param int $periodNum
  51. * @param int $calcMonth 业绩期
  52. */
  53. public static function noParamsLog($periodNum, $calcMonth, $desc) {
  54. $logData[] = [
  55. 'PERIOD_NUM' => $periodNum,
  56. 'CALC_MONTH' => $calcMonth,
  57. 'LOG_DESCRIBE' => $desc,
  58. 'CREATE_AT' => time()
  59. ];
  60. ServeLog::batchInsert($logData);
  61. return true;
  62. }
  63. // 第一步,记录期数结算年月
  64. /**
  65. * 记录业绩期,结算年月
  66. * @param int $periodNum
  67. * @param int $calcMonth 业绩期
  68. */
  69. public static function periodMonth($periodNum, $calcMonth) {
  70. $logData[] = [
  71. 'PERIOD_NUM' => $periodNum,
  72. 'CALC_MONTH' => $calcMonth,
  73. 'LOG_DESCRIBE' => "期数:$periodNum,结算年月:$calcMonth,开始计算业绩",
  74. 'CREATE_AT' => time()
  75. ];
  76. ServeLog::batchInsert($logData);
  77. return true;
  78. }
  79. /**
  80. * 记录推送过来的基础数据
  81. * @param int $periodNum
  82. * @param int $calcMonth 业绩期
  83. */
  84. public static function basicData($periodNum, $calcMonth) {
  85. $userCount = User::find()->where('1=1')->count('ID');
  86. $infoCount = UserInfo::find()->where('1=1')->count('ID');
  87. $networkConut = UserNetwork::find()->where('1=1')->count('ID');
  88. $userPerfConut = UserPerf::find()->where('1=1')->count('ID');
  89. $calcBonusQyConut = CalcBonusQY::find()->where('1=1')->count('ID');
  90. $perfPeriodCount = PerfPeriod::find()->where('1=1')->count('ID');
  91. $perfOrderCount = PerfOrder::find()->where('1=1')->count('ID');
  92. $relationCount = UserRelation::find()->where('1=1')->count('ID');
  93. $periodCount = Period::find()->where('1=1')->count('ID');
  94. $perfMonthCount = PerfMonth::find()->where('1=1')->count('ID');
  95. $desc = "记录推送基础数据信息:AR_USER-推送用户总条数:$userCount;AR_USER_INFO-推送用户信息总条数:$infoCount;
  96. AR_USER_NETWORK_NEW-推送安置网络总条数:$networkConut;AR_USER_PERF-推送用户结余业绩总条数:$userPerfConut;
  97. AR_CALC_BONUS_QY-推送团队奖总条数:$calcBonusQyConut;AR_PERF_PERIOD-推送期业绩总条数:$perfPeriodCount;
  98. AR_PERIOD-推送业绩期总条数:$periodCount;AR_USER_RELATION_NEW-推送开拓网络总条数:$relationCount;
  99. AR_PERF_MONTH-推送月业绩表总条数:$perfMonthCount;AR_PERF_ORDER-推送业绩单总条数:$perfOrderCount";
  100. $logData[] = [
  101. 'PERIOD_NUM' => $periodNum,
  102. 'CALC_MONTH' => $calcMonth,
  103. 'LOG_DESCRIBE' => $desc,
  104. 'CREATE_AT' => time()
  105. ];
  106. ServeLog::batchInsert($logData);
  107. return true;
  108. }
  109. /**
  110. * 记录清除的期业绩和月业绩
  111. * @param int $periodNum
  112. * @param int $calcMonth 业绩期
  113. */
  114. public static function clearPerf($periodNum, $calcMonth) {
  115. $perfPeriodCount = PerfPeriod::find()
  116. ->where('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM'=>$periodNum])
  117. ->count('ID');
  118. $perfMonthCount = PerfMonth::find()
  119. ->where('CALC_MONTH=:CALC_MONTH', [':CALC_MONTH'=>$calcMonth])
  120. ->count('ID');
  121. $desc = "清除业绩数据:AR_PERF_PERIOD-清除期业绩表总条数:$perfPeriodCount;AR_PERF_MONTH-清除月业绩表总条数:$perfMonthCount";
  122. $logData[] = [
  123. 'PERIOD_NUM' => $periodNum,
  124. 'CALC_MONTH' => $calcMonth,
  125. 'LOG_DESCRIBE' => $desc,
  126. 'CREATE_AT' => time()
  127. ];
  128. ServeLog::batchInsert($logData);
  129. return true;
  130. }
  131. /**
  132. * 记录缓存用户数据
  133. * @param int $periodNum
  134. * @param int $calcMonth 业绩期
  135. */
  136. public static function cacheUserTotal($periodNum, $calcMonth) {
  137. $allUserCount = UserInfo::findUseDbCalc()
  138. ->from(UserInfo::tableName(). 'AS UI')
  139. ->select('UI.USER_ID,U.STATUS')
  140. ->leftJoin(User::tableName() . 'AS U', 'U.ID=UI.USER_ID')
  141. ->where('1=1')
  142. ->count('UI.USER_ID');
  143. $activeUserCount = UserInfo::findUseDbCalc()
  144. ->from(UserInfo::tableName(). 'AS UI')
  145. ->select('UI.USER_ID,U.STATUS')
  146. ->leftJoin(User::tableName() . 'AS U', 'U.ID=UI.USER_ID')
  147. ->where('U.STATUS=1')
  148. ->count('UI.USER_ID');
  149. $total = $allUserCount+$activeUserCount;
  150. $desc = "缓存用户信息-结束,缓存数量:$total";
  151. $logData[] = [
  152. 'PERIOD_NUM' => $periodNum,
  153. 'CALC_MONTH' => $calcMonth,
  154. 'LOG_DESCRIBE' => $desc,
  155. 'CREATE_AT' => time()
  156. ];
  157. ServeLog::batchInsert($logData);
  158. return true;
  159. }
  160. /**
  161. * 记录期业绩数据
  162. * @param int $periodNum
  163. * @param int $calcMonth 业绩期
  164. */
  165. public static function perfPeriodInfo($periodNum, $calcMonth) {
  166. $data = PerfPeriod::findUseSlaves()
  167. ->select('SUM(PV_PCS) AS TOTAL_PV_PCS, COUNT(ID) AS TOTAL_NUM')
  168. ->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])
  169. ->asArray()
  170. ->one();
  171. $num = $data['TOTAL_NUM'];
  172. $total_pvpcs = $data['TOTAL_PV_PCS'];
  173. $desc = "期业绩计算完成:AR_PERF_PERIOD-期业绩总条数:$num,期业绩个人消费PV总数:$total_pvpcs";
  174. $logData[] = [
  175. 'PERIOD_NUM' => $periodNum,
  176. 'CALC_MONTH' => $calcMonth,
  177. 'LOG_DESCRIBE' => $desc,
  178. 'CREATE_AT' => time()
  179. ];
  180. ServeLog::batchInsert($logData);
  181. return true;
  182. }
  183. /**
  184. * 记录月业绩数据
  185. * @param int $periodNum
  186. * @param int $calcMonth 业绩期
  187. */
  188. public static function perfMonthInfo($periodNum, $calcMonth) {
  189. $data = PerfMonth::findUseSlaves()
  190. ->select('SUM(PV_PCS) AS TOTAL_PV_PCS, COUNT(ID) AS TOTAL_NUM')
  191. ->where('CALC_MONTH=:CALC_MONTH', ['CALC_MONTH'=>$calcMonth])
  192. ->asArray()
  193. ->one();
  194. $num = $data['TOTAL_NUM'];
  195. $total_pvpcs = $data['TOTAL_PV_PCS'];
  196. $desc = "月业绩计算完成:AR_PERF_MONTH-月业绩表总条数:$num,月业绩个人消费总数:$total_pvpcs";
  197. $logData[] = [
  198. 'PERIOD_NUM' => $periodNum,
  199. 'CALC_MONTH' => $calcMonth,
  200. 'LOG_DESCRIBE' => $desc,
  201. 'CREATE_AT' => time()
  202. ];
  203. ServeLog::batchInsert($logData);
  204. return true;
  205. }
  206. /**
  207. * 记录期业绩活跃数据
  208. * @param int $periodNum
  209. * @param int $calcMonth 业绩期
  210. */
  211. public static function perfPeriodActive($periodNum, $calcMonth) {
  212. $data = PerfPeriod::findUseSlaves()
  213. ->select('COUNT(ID) AS TOTAL_NUM')
  214. ->where('PERIOD_NUM=:PERIOD_NUM AND IS_ACTIVE=1', ['PERIOD_NUM'=>$periodNum])
  215. ->asArray()
  216. ->one();
  217. $num = $data['TOTAL_NUM'];
  218. $desc = "期业绩更新活跃状态,活跃人数:$num";
  219. $logData[] = [
  220. 'PERIOD_NUM' => $periodNum,
  221. 'CALC_MONTH' => $calcMonth,
  222. 'LOG_DESCRIBE' => $desc,
  223. 'CREATE_AT' => time()
  224. ];
  225. ServeLog::batchInsert($logData);
  226. return true;
  227. }
  228. // =============================奖金相关日志=====================================================================================
  229. /**
  230. * 记录清除的奖金流水表数据
  231. * @param int $periodNum
  232. * @param int $calcMonth 业绩期
  233. * @param int $isCalcMonth 是否月节点
  234. */
  235. public static function clearTableBonus($periodNum, $calcMonth, $isCalcMonth) {
  236. $bonusCount = CalcBonus::find()->where('1=1')->count('ID');
  237. $bonusTgCount = CalcBonusTG::find()->where('1=1')->count('ID');
  238. $bonusBdCount = CalcBonusBD::find()->where('1=1')->count('ID');
  239. $bonusQyCount = CalcBonusQY::find()->where('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM'=>$periodNum])->count('ID');
  240. $bonusBsCount = $bonusQuarterCount = $bonusVillaCount = $bonusGarageCount = 0;
  241. if ($isCalcMonth) {
  242. $bonusBsCount = CalcBonusBS::find()->where('1=1')->count('ID');
  243. $bonusQuarterCount = CalcBonusQuarter::find()->where('1=1')->count('ID');
  244. $bonusVillaCount = CalcBonusVilla::find()->where('1=1')->count('ID');
  245. $bonusGarageCount = CalcBonusGarage::find()->where('1=1')->count('ID');
  246. }
  247. $desc = "清除奖金流水表数据:AR_CALC_BONUS-清除奖金汇总表总数:$bonusCount;AR_CALC_BONUS_TG-清除推广将流水表总条数:$bonusTgCount;
  248. AR_CALC_BONUS_BD-清除服务奖流水表总条数:$bonusBdCount;AR_CALC_BONUS_QY-清除团队奖流水表总条数:$bonusQyCount;
  249. AR_CALC_BONUS_BS-清除管理奖流水表总条数:$bonusBsCount;AR_CALC_BONUS_QUARTER-清除季度奖流水表总条数:$bonusQuarterCount;
  250. AR_CALC_BONUS_VILLA-清除房奖流水表总条数:$bonusVillaCount;AR_CALC_BONUS_GARAGE-清除车房奖流水表总条数:$bonusGarageCount";
  251. $logData[] = [
  252. 'PERIOD_NUM' => $periodNum,
  253. 'CALC_MONTH' => $calcMonth,
  254. 'LOG_DESCRIBE' => $desc,
  255. 'CREATE_AT' => time()
  256. ];
  257. ServeLog::batchInsert($logData);
  258. return true;
  259. }
  260. /**
  261. * 记录管理奖数据
  262. * @param int $periodNum
  263. * @param int $calcMonth 业绩期
  264. */
  265. public static function bonusBSData($periodNum, $calcMonth) {
  266. $data = CalcBonusBS::findUseSlaves()
  267. ->select('SUM(AMOUNT) AS ORI_AMOUNT,SUM(ORI_BONUS) AS REAL_BONUS,COUNT(ID) AS USER_NUM')
  268. ->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])
  269. ->asArray()
  270. ->one();
  271. $num = $data['USER_NUM'];
  272. $oriBonus = $data['ORI_AMOUNT'];
  273. $realBonus = $data['REAL_BONUS'];
  274. // 查询得将人数
  275. $hasBonus = CalcBonusBS::findUseSlaves()
  276. ->select('COUNT(ID) AS BONUS_USER_NUM')
  277. ->where('PERIOD_NUM=:PERIOD_NUM AND ORI_BONUS > 0', ['PERIOD_NUM'=>$periodNum])
  278. ->asArray()
  279. ->one();
  280. $hasBonusNum = $hasBonus['BONUS_USER_NUM'];
  281. $desc = "计算管理奖完成AR_CALC_BONUS_BS:人数:$num,得奖人数:$hasBonusNum,原金额:$oriBonus,实发金额:$realBonus";
  282. $logData[] = [
  283. 'PERIOD_NUM' => $periodNum,
  284. 'CALC_MONTH' => $calcMonth,
  285. 'LOG_DESCRIBE' => $desc,
  286. 'CREATE_AT' => time()
  287. ];
  288. ServeLog::batchInsert($logData);
  289. return true;
  290. }
  291. /**
  292. * 记录月业绩,小组业绩数据
  293. * @param int $periodNum
  294. * @param int $calcMonth 业绩期
  295. */
  296. public static function perfMonthPgs($periodNum, $calcMonth) {
  297. $data = PerfMonth::findUseSlaves()
  298. ->select('SUM(DIRECTOR_BONUS_PGS) AS SUM_PGS,COUNT(ID) AS USER_NUM')
  299. ->where('CALC_MONTH=:CALC_MONTH', ['CALC_MONTH'=>$calcMonth])
  300. ->asArray()
  301. ->one();
  302. $userNum = $data['USER_NUM'];
  303. $totalPgs = $data['SUM_PGS'];
  304. $desc = "月业绩表增加小组业绩完成AR_PERF_MONTH:小组业绩:$totalPgs,条数:$userNum";
  305. $logData[] = [
  306. 'PERIOD_NUM' => $periodNum,
  307. 'CALC_MONTH' => $calcMonth,
  308. 'LOG_DESCRIBE' => $desc,
  309. 'CREATE_AT' => time()
  310. ];
  311. ServeLog::batchInsert($logData);
  312. return true;
  313. }
  314. /**
  315. * 记录服务奖数据
  316. * @param int $periodNum
  317. * @param int $calcMonth 业绩期
  318. */
  319. public static function bonusBDData($periodNum, $calcMonth) {
  320. $data = CalcBonusBD::findUseSlaves()
  321. ->select('SUM(AMOUNT) AS SUM_AMOUNT,COUNT(ID) AS USER_NUM')
  322. ->where('PERIOD_NUM=:PERIOD_NUM AND AMOUNT>0', ['PERIOD_NUM'=>$periodNum])
  323. ->asArray()
  324. ->one();
  325. $userNum = $data['USER_NUM'];
  326. $totalAmount = $data['SUM_AMOUNT'];
  327. $desc = "计算服务奖完成AR_CALC_BONUS_BD:得奖人数:$userNum,金额:$totalAmount";
  328. $logData[] = [
  329. 'PERIOD_NUM' => $periodNum,
  330. 'CALC_MONTH' => $calcMonth,
  331. 'LOG_DESCRIBE' => $desc,
  332. 'CREATE_AT' => time()
  333. ];
  334. ServeLog::batchInsert($logData);
  335. return true;
  336. }
  337. /**
  338. * 记录推广奖数据
  339. * @param int $periodNum
  340. * @param int $calcMonth 业绩期
  341. */
  342. public static function bonusTGData($periodNum, $calcMonth) {
  343. $data = CalcBonusTG::findUseSlaves()
  344. ->select('SUM(AMOUNT) AS SUM_AMOUNT,COUNT(ID) AS USER_NUM')
  345. ->where('PERIOD_NUM=:PERIOD_NUM AND AMOUNT>0', ['PERIOD_NUM'=>$periodNum])
  346. ->asArray()
  347. ->one();
  348. $userNum = $data['USER_NUM'];
  349. $totalAmount = $data['SUM_AMOUNT'];
  350. $desc = "计算推广奖完成AR_CALC_BONUS_TG:得奖人数:$userNum,金额:$totalAmount";
  351. $logData[] = [
  352. 'PERIOD_NUM' => $periodNum,
  353. 'CALC_MONTH' => $calcMonth,
  354. 'LOG_DESCRIBE' => $desc,
  355. 'CREATE_AT' => time()
  356. ];
  357. ServeLog::batchInsert($logData);
  358. return true;
  359. }
  360. /**
  361. * 记录团队奖数据
  362. * @param int $periodNum
  363. * @param int $calcMonth 业绩期
  364. */
  365. public static function bonusQYData($periodNum, $calcMonth) {
  366. // 获取封顶人数
  367. $cappedNumData = CalcBonusQY::findUseSlaves()
  368. ->select('ID,USER_ID')
  369. ->where('PERIOD_NUM=:PERIOD_NUM AND ORI_CAPPED_BONUS_QY > 0', ['PERIOD_NUM'=>$periodNum])
  370. ->groupBy('USER_ID')
  371. ->asArray()
  372. ->all();
  373. $cappedNumData = array_column($cappedNumData, 'USER_ID');
  374. $cappedNum = count($cappedNumData);
  375. // 封顶金额
  376. $cappedBonusData = CalcBonusQY::findUseSlaves()
  377. ->select('SUM(ORI_CAPPED_BONUS_QY) AS CAPPED_AMOUNT')
  378. ->where('PERIOD_NUM=:PERIOD_NUM AND ORI_CAPPED_BONUS_QY > 0', ['PERIOD_NUM'=>$periodNum])
  379. ->asArray()
  380. ->one();
  381. $cappendBonus = $cappedBonusData['CAPPED_AMOUNT'];
  382. // 得奖人数
  383. $bonusNumData = CalcBonusQY::findUseSlaves()
  384. ->select('ID,USER_ID')
  385. ->where('PERIOD_NUM=:PERIOD_NUM AND AMOUNT > 0', ['PERIOD_NUM'=>$periodNum])
  386. ->groupBy('USER_ID')
  387. ->asArray()
  388. ->one();
  389. $bonusNumData = array_column($bonusNumData, 'USER_ID');
  390. $bonusNum = count($bonusNumData);
  391. // 实发金额
  392. $bonusData = CalcBonusQY::findUseSlaves()
  393. ->select('SUM(AMOUNT) AS BONUS_AMOUNT')
  394. ->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])
  395. ->asArray()
  396. ->one();
  397. $realBonus = $bonusData['BONUS_AMOUNT'];
  398. // 人数
  399. $allNumData = CalcBonusQY::findUseSlaves()
  400. ->select('ID,USER_ID')
  401. ->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])
  402. ->groupBy('USER_ID')
  403. ->asArray()
  404. ->one();
  405. $allNumData = array_column($allNumData, 'USER_ID');
  406. $allNum = count($allNumData);
  407. // 金额
  408. $allBonusData = CalcBonusQY::findUseSlaves()
  409. ->select('SUM(HOPE_BONUS) AS ALL_BONUS_AMOUNT')
  410. ->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])
  411. ->asArray()
  412. ->one();
  413. $oriBonus = $allBonusData['ALL_BONUS_AMOUNT'];
  414. $desc = "计算团队奖完成AR_CALC_BONUS_QY:人数:$allNum,得奖人数:$bonusNum,原金额:$oriBonus,实发金额:$realBonus,封顶人数:$cappedNum,封顶金额:$cappendBonus";
  415. $logData[] = [
  416. 'PERIOD_NUM' => $periodNum,
  417. 'CALC_MONTH' => $calcMonth,
  418. 'LOG_DESCRIBE' => $desc,
  419. 'CREATE_AT' => time()
  420. ];
  421. ServeLog::batchInsert($logData);
  422. return true;
  423. }
  424. /**
  425. * 记录房奖数据
  426. * @param int $periodNum
  427. * @param int $calcMonth 业绩期
  428. */
  429. public static function bonusVillaData($periodNum, $calcMonth) {
  430. // 得奖人数和实发金额
  431. $hasNumData = CalcBonusVilla::findUseSlaves()
  432. ->select('COUNT(ID) AS USER_NUM, SUM(AMOUNT) AS BONUS_AMOUNT')
  433. ->where('PERIOD_NUM=:PERIOD_NUM AND AMOUNT > 0', ['PERIOD_NUM'=>$periodNum])
  434. ->asArray()
  435. ->one();
  436. $hasNum = $hasNumData['USER_NUM'];
  437. $realBonus = $hasNumData['BONUS_AMOUNT'];
  438. // 封顶金额
  439. $cappedBonusData = CalcBonusVilla::findUseSlaves()
  440. ->select('SUM(CAP_AMOUNT) AS CAPPED_AMOUNT')
  441. ->where('PERIOD_NUM=:PERIOD_NUM AND CAP_AMOUNT > 0 AND CAP_AMOUNT > AMOUNT', ['PERIOD_NUM'=>$periodNum])
  442. ->asArray()
  443. ->one();
  444. $cappendBonus = $cappedBonusData['CAPPED_AMOUNT'];
  445. $desc = "计算房奖完成AR_CALC_BONUS_VILLA:得奖人数:$hasNum,金额:$realBonus,封顶金额:$cappendBonus";
  446. $logData[] = [
  447. 'PERIOD_NUM' => $periodNum,
  448. 'CALC_MONTH' => $calcMonth,
  449. 'LOG_DESCRIBE' => $desc,
  450. 'CREATE_AT' => time()
  451. ];
  452. ServeLog::batchInsert($logData);
  453. return true;
  454. }
  455. /**
  456. * 记录车奖数据
  457. * @param int $periodNum
  458. * @param int $calcMonth 业绩期
  459. */
  460. public static function bonusGarageData($periodNum, $calcMonth) {
  461. // 得奖人数和实发金额
  462. $hasNumData = CalcBonusGarage::findUseSlaves()
  463. ->select('COUNT(ID) AS USER_NUM, SUM(AMOUNT) AS BONUS_AMOUNT')
  464. ->where('PERIOD_NUM=:PERIOD_NUM AND AMOUNT > 0', ['PERIOD_NUM'=>$periodNum])
  465. ->asArray()
  466. ->one();
  467. $hasNum = $hasNumData['USER_NUM'];
  468. $realBonus = $hasNumData['BONUS_AMOUNT'];
  469. // 封顶金额
  470. $cappedBonusData = CalcBonusGarage::findUseSlaves()
  471. ->select('SUM(CAP_AMOUNT) AS CAPPED_AMOUNT')
  472. ->where('PERIOD_NUM=:PERIOD_NUM AND CAP_AMOUNT > 0 AND CAP_AMOUNT>AMOUNT', ['PERIOD_NUM'=>$periodNum])
  473. ->asArray()
  474. ->one();
  475. $cappendBonus = $cappedBonusData['CAPPED_AMOUNT'];
  476. $desc = "计算车奖完成AR_CALC_BONUS_GARAGE:得奖人数:$hasNum,金额:$realBonus,封顶金额:$cappendBonus";
  477. $logData[] = [
  478. 'PERIOD_NUM' => $periodNum,
  479. 'CALC_MONTH' => $calcMonth,
  480. 'LOG_DESCRIBE' => $desc,
  481. 'CREATE_AT' => time()
  482. ];
  483. ServeLog::batchInsert($logData);
  484. return true;
  485. }
  486. /**
  487. * 记录季度奖数据----季度奖有问题,记录不到实发金额,因为不符合得奖得人,没有更新流水表中的AMOUNT字段
  488. * @param int $periodNum
  489. * @param int $calcMonth 业绩期
  490. */
  491. public static function bonusQuarterData($periodNum, $calcMonth) {
  492. // 得奖人数和实发金额
  493. // $hasNumData = CalcBonusQuarter::findUseSlaves()
  494. // ->select('COUNT(ID) AS USER_NUM, SUM(AMOUNT) AS BONUS_AMOUNT')
  495. // ->where('PERIOD_NUM=:PERIOD_NUM AND AMOUNT > 0', ['PERIOD_NUM'=>$periodNum])
  496. // ->asArray()
  497. // ->one();
  498. // $hasNum = $hasNumData['USER_NUM'];
  499. // $realBonus = $hasNumData['BONUS_AMOUNT'];
  500. // // 封顶金额
  501. // $cappedBonusData = CalcBonusGarage::findUseSlaves()
  502. // ->select('SUM(CAP_AMOUNT) AS CAPPED_AMOUNT')
  503. // ->where('PERIOD_NUM=:PERIOD_NUM AND CAP_AMOUNT > 0 AND CAP_AMOUNT>AMOUNT', ['PERIOD_NUM'=>$periodNum])
  504. // ->asArray()
  505. // ->one();
  506. // $cappendBonus = $cappedBonusData['CAPPED_AMOUNT'];
  507. // $desc = "计算季度奖完成AR_CALC_BONUS_QUARTER:得奖人数:xx,原金额:xx,实发金额:xx";
  508. // $logData[] = [
  509. // 'PERIOD_NUM' => $periodNum,
  510. // 'CALC_MONTH' => $calcMonth,
  511. // 'LOG_DESCRIBE' => $desc,
  512. // 'CREATE_AT' => time()
  513. // ];
  514. // ServeLog::batchInsert($logData);
  515. return true;
  516. }
  517. /**
  518. * 记录奖金汇总表数据
  519. * @param int $periodNum
  520. * @param int $calcMonth 业绩期
  521. */
  522. public static function bonusData($periodNum, $calcMonth) {
  523. $bonusData = CalcBonus::findUseSlaves()
  524. ->select('SUM(BONUS_REAL) AS LOG_BONUS_REAL,SUM(BONUS_TOTAL) AS LOG_BONUS_TOTAL,SUM(ORI_BONUS_BS) AS LOG_BONUS_BS,
  525. SUM(ORI_BONUS_QY) AS LOG_BONUS_QY,SUM(ORI_BONUS_BD) AS LOG_BONUS_BD,SUM(ORI_BONUS_TG) AS LOG_BONUS_TG,
  526. SUM(ORI_BONUS_QUARTER) AS LOG_BONUS_QUARTER,SUM(ORI_BONUS_GARAGE) AS LOG_BONUS_GARAGE,SUM(ORI_BONUS_VILLA) AS LOG_BONUS_VILLA,
  527. SUM(MANAGE_TAX) AS LOG_MANAGE_TAX,SUM(RECONSUME_POINTS) AS LOG_RECONSUME_POINTS')
  528. ->where('PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM'=>$periodNum])
  529. ->asArray()
  530. ->one();
  531. $totalBonus = $bonusData['LOG_BONUS_TOTAL'];// 总金额
  532. $realBonus = $bonusData['LOG_BONUS_REAL'];// 实发总额
  533. $bsBonus = $bonusData['LOG_BONUS_BS'];// 管理奖总额
  534. $qyBonus = $bonusData['LOG_BONUS_QY'];// 团队奖
  535. $bdBonus = $bonusData['LOG_BONUS_BD'];// 服务奖
  536. $tgBonus = $bonusData['LOG_BONUS_TG'];// 推广奖
  537. $quarterBonus = $bonusData['LOG_BONUS_QUARTER'];// 季度奖
  538. $garageBonus = $bonusData['LOG_BONUS_GARAGE'];// 车奖
  539. $villaBonus = $bonusData['LOG_BONUS_VILLA'];// 房奖
  540. $manageTax = $bonusData['LOG_MANAGE_TAX'];// 管理费
  541. $reconsumePoints = $bonusData['LOG_RECONSUME_POINTS'];// 复消积分
  542. // 得奖人数
  543. $hasNum = CalcBonus::find()
  544. ->where('PERIOD_NUM=:PERIOD_NUM AND BONUS_REAL>0', [':PERIOD_NUM'=>$periodNum])
  545. ->count('ID');
  546. $desc = "奖金写入奖金汇总表完成AR_CALC_BONUS:得奖人数:$hasNum,实发金额:$realBonus,原金额:$totalBonus,管理奖金额:$bsBonus,
  547. 团队奖金额:$qyBonus,服务奖金额:$bdBonus,推广奖金额:$tgBonus,季度奖金额:$quarterBonus,车奖金额:$garageBonus,房奖金额:$villaBonus,
  548. 管理费:$manageTax,复消积分:$reconsumePoints";
  549. $logData[] = [
  550. 'PERIOD_NUM' => $periodNum,
  551. 'CALC_MONTH' => $calcMonth,
  552. 'LOG_DESCRIBE' => $desc,
  553. 'CREATE_AT' => time()
  554. ];
  555. ServeLog::batchInsert($logData);
  556. return true;
  557. }
  558. }