SystemUserTask.php 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461
  1. <?php
  2. namespace app\models\system;
  3. use app\models\store\StoreOrder;
  4. use app\models\user\User;
  5. use app\models\user\UserBill;
  6. use app\models\user\UserLevel;
  7. use app\models\user\UserTaskFinish;
  8. use crmeb\traits\ModelTrait;
  9. use crmeb\basic\BaseModel;
  10. /**
  11. * TODO 设置等级任务Model
  12. * Class SystemUserTask
  13. * @package app\models\system
  14. */
  15. class SystemUserTask extends BaseModel
  16. {
  17. /**
  18. * 数据表主键
  19. * @var string
  20. */
  21. protected $pk = 'id';
  22. /**
  23. * 模型名称
  24. * @var string
  25. */
  26. protected $name = 'system_user_task';
  27. use ModelTrait;
  28. /**
  29. * 任务类型
  30. * type 记录在数据库中用来区分任务
  31. * name 任务名 (任务名中的{$num}会自动替换成设置的数字 + 单位)
  32. * max_number 最大设定数值 0为不限定
  33. * min_number 最小设定数值
  34. * unit 单位
  35. * */
  36. protected static $TaskType = [
  37. [
  38. 'type' => 'SatisfactionIntegral',
  39. 'name' => '满足积分{$num}',
  40. 'real_name' => '积分数',
  41. 'max_number' => 0,
  42. 'min_number' => 0,
  43. 'unit' => '分'
  44. ],
  45. [
  46. 'type' => 'ConsumptionAmount',
  47. 'name' => '消费满{$num}',
  48. 'real_name' => '消费金额',
  49. 'max_number' => 0,
  50. 'min_number' => 0,
  51. 'unit' => '元'
  52. ],
  53. [
  54. 'type' => 'ConsumptionFrequency',
  55. 'name' => '消费{$num}',
  56. 'real_name' => '消费次数',
  57. 'max_number' => 0,
  58. 'min_number' => 0,
  59. 'unit' => '次'
  60. ],
  61. [
  62. 'type' => 'CumulativeAttendance',
  63. 'name' => '累计签到{$num}',
  64. 'real_name' => '累计签到',
  65. 'max_number' => 365,
  66. 'min_number' => 1,
  67. 'unit' => '天'
  68. ],
  69. [
  70. 'type' => 'SharingTimes',
  71. 'name' => '分享给朋友{$num}',
  72. 'real_name' => '分享给朋友',
  73. 'max_number' => 1000,
  74. 'min_number' => 1,
  75. 'unit' => '次'
  76. ],
  77. [
  78. 'type' => 'InviteGoodFriends',
  79. 'name' => '邀请好友{$num}成为下线',
  80. 'real_name' => '邀请好友成为下线',
  81. 'max_number' => 1000,
  82. 'min_number' => 1,
  83. 'unit' => '人'
  84. ],
  85. [
  86. 'type' => 'InviteGoodFriendsLevel',
  87. 'name' => '邀请好友{$num}成为会员',
  88. 'real_name' => '邀请好友成为会员',
  89. 'max_number' => 1000,
  90. 'min_number' => 1,
  91. 'unit' => '人'
  92. ],
  93. [
  94. 'type' => 'UserConsumptionAmount',
  95. 'name' => '自己业绩{$num}',
  96. 'real_name' => '自己业绩',
  97. 'max_number' => 0,
  98. 'min_number' => 0,
  99. 'unit' => '元'
  100. ],
  101. [
  102. 'type' => 'TremConsumptionAmount',
  103. 'name' => '团队业绩{$num}',
  104. 'real_name' => '团队业绩',
  105. 'max_number' => 0,
  106. 'min_number' => 0,
  107. 'unit' => '元'
  108. ],
  109. ];
  110. public function profile()
  111. {
  112. return $this->hasOne('SystemUserLevel', 'level_id', 'id')->field('name');
  113. }
  114. public static function getTaskTypeAll()
  115. {
  116. return self::$TaskType;
  117. }
  118. /**
  119. * 获取某个任务
  120. * @param string $type 任务类型
  121. * @return array
  122. * */
  123. public static function getTaskType($type)
  124. {
  125. foreach (self::$TaskType as $item) {
  126. if ($item['type'] == $type) return $item;
  127. }
  128. }
  129. /**
  130. * 设置任务名
  131. * @param string $type 任务类型
  132. * @param int $num 预设值
  133. * @return string
  134. * */
  135. public static function setTaskName($type, $num)
  136. {
  137. $systemType = self::getTaskType($type);
  138. return str_replace('{$num}', $num . $systemType['unit'], $systemType['name']);
  139. }
  140. /**
  141. * 累计消费金额
  142. * @param int $task_id 任务id
  143. * @param int $uid 用户id
  144. * @param int $start_time 开始时间
  145. * @param int $number 限定时间
  146. * @return boolean
  147. * */
  148. public static function ConsumptionAmount($task_id, $uid = 0, $start_time = 0, $number = 0)
  149. {
  150. $isComplete = false;
  151. $SumPayPrice = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->sum('pay_price');
  152. if ($SumPayPrice >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  153. return ['还需消费{$num}元', $SumPayPrice, $isComplete];
  154. }
  155. public static function UserConsumptionAmount($task_id, $uid = 0, $start_time = 0, $number = 0)
  156. {
  157. $isComplete = false;
  158. $SumPayPrice = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->sum('pay_price');
  159. if ($SumPayPrice >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  160. return ['还需消费{$num}元', $SumPayPrice, $isComplete];
  161. }
  162. public static function TremConsumptionAmount($task_id, $uid = 0, $start_time = 0, $number = 0)
  163. {
  164. $isComplete = false;
  165. $SumPayPrice = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->sum('pay_price');
  166. if ($SumPayPrice >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  167. return ['还需消费{$num}元', $SumPayPrice, $isComplete];
  168. }
  169. /**
  170. * 累计消费次数
  171. * @param int $task_id 任务id
  172. * @param int $uid 用户id
  173. * @param int $start_time 开始时间
  174. * @param int $number 限定时间
  175. * @return boolean
  176. * */
  177. public static function ConsumptionFrequency($task_id, $uid = 0, $start_time = 0, $number = 0)
  178. {
  179. $isComplete = false;
  180. $countPay = StoreOrder::where('paid', 1)->where('refund_status', 0)->where('is_del', 0)->where('uid', $uid)->where('add_time', '>', $start_time)->count();
  181. if ($countPay >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  182. return ['还需消费{$num}次', $countPay, $isComplete];
  183. }
  184. /**
  185. * 邀请好友成为会员
  186. * @param int $task_id 任务id
  187. * @param int $uid 用户id
  188. * @param int $start_time 开始时间
  189. * @param int $number 限定时间
  190. * @return boolean
  191. * */
  192. public static function InviteGoodFriendsLevel($task_id, $uid = 0, $start_time = 0, $number = 0)
  193. {
  194. $isComplete = false;
  195. $uids = User::where('spread_uid', $uid)->where('spread_time', '>', $start_time)->column('uid', 'uid');
  196. $levelCount = count($uids) ? UserLevel::setUserLevelCount($uids) : 0;
  197. if ($levelCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  198. return ['还需邀请{$num}人成为会员', $levelCount, $isComplete];
  199. }
  200. /**
  201. * 邀请好友成为下线
  202. * @param int $task_id 任务id
  203. * @param int $uid 用户id
  204. * @param int $start_time 查询开始时间
  205. * @param int $number 限定数量
  206. * */
  207. public static function InviteGoodFriends($task_id, $uid = 0, $start_time = 0, $number = 0)
  208. {
  209. $isComplete = false;
  210. $spreadCount = User::where('spread_uid', $uid)->where('spread_time', '>', $start_time)->count();
  211. if ($spreadCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  212. return ['还需邀请{$num}人成为下线', $spreadCount, $isComplete];
  213. }
  214. /**
  215. * 满足积分
  216. * @param int $task_id 任务id
  217. * @param int $uid 用户id
  218. * @param int $start_time 查询开始时间
  219. * @param int $number 限定数量
  220. * @return Boolean
  221. * */
  222. public static function SatisfactionIntegral($task_id, $uid = 0, $start_time = 0, $number = 0)
  223. {
  224. $isComplete = false;
  225. $sumNumber = UserBill::where('uid', $uid)->where('category', 'integral')->where('pm', 1)->where('add_time', '>', $start_time)->where('type', 'in', ['system_add', 'sign', 'gain'])->sum('number');
  226. if ($sumNumber >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  227. return ['还需要{$num}经验', $sumNumber, $isComplete];
  228. }
  229. /**
  230. * 分享给朋友次数完成情况
  231. * @param int $task_id 任务id
  232. * @param int $uid 用户id
  233. * @param int $start_time 查询开始时间
  234. * @param int $number 限定数量
  235. * @return Boolean
  236. * */
  237. public static function SharingTimes($task_id, $uid = 0, $start_time = 0, $number = 0)
  238. {
  239. $isComplete = false;
  240. $sumCount = UserBill::where('uid', $uid)->where('category', 'share')->where('pm', 1)->where('add_time', '>', $start_time)->where('type', 'share')->count();
  241. if ($sumCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  242. return ['还需分享{$num}次', $sumCount, $isComplete];
  243. }
  244. /**
  245. * 累计签到
  246. * @param int $task_id 任务id
  247. * @param int $uid 用户id
  248. * @param int $start_time 查询开始时间
  249. * @param int $number 限定数量
  250. * @return Boolean
  251. * */
  252. public static function CumulativeAttendance($task_id, $uid = 0, $start_time = 0, $number = 0)
  253. {
  254. $isComplete = false;
  255. $sumCount = UserBill::where('uid', $uid)->where('category', 'integral')->where('pm', 1)->where('add_time', '>', $start_time)->where('type', 'sign')->count();
  256. if ($sumCount >= $number) $isComplete = UserTaskFinish::setFinish($uid, $task_id) ? true : false;
  257. return ['还需签到{$num}天', $sumCount, $isComplete];
  258. }
  259. /**
  260. * 设置任务完成情况
  261. * @param int $task_id 任务id
  262. * @param int $uid 用户uid
  263. * @param int $start_time 查询开始时间
  264. * @return Boolean
  265. * */
  266. public static function setTaskFinish($task_id = 0, $uid = 0, $start_time = 0)
  267. {
  268. if (!$task_id) return self::setErrorInfo('缺少任务id参数');
  269. if (!$uid) return self::setErrorInfo('缺少用户uid');
  270. $task = self::where('id', $task_id)->where('is_show', 1)->find();
  271. if (!$task) return self::setErrorInfo('任务不存在');
  272. $task_type = $task->task_type;
  273. if ($task_type && method_exists(self::class, $task_type)) {
  274. try {
  275. $start_time = User::getCleanTime($uid);
  276. return self::$task_type($task_id, $uid, $start_time, $task->number);
  277. } catch (\Exception $e) {
  278. return self::setErrorInfo($e->getMessage());
  279. }
  280. }
  281. return self::setErrorInfo('没有此任务');
  282. }
  283. /**
  284. * 设置任务显示条件
  285. * @param string $alert 表别名
  286. * @param object $model 模型实例
  287. * @return object
  288. * */
  289. public static function visibleWhere($alert = '', $model = null)
  290. {
  291. $model = $model === null ? new self() : $model;
  292. if ($alert) $model = $model->alias($alert);
  293. $alert = $alert ? $alert . '.' : '';
  294. return $model->where("{$alert}is_show", 1);
  295. }
  296. /**
  297. * 获取等级会员任务列表
  298. * @param int $level_id 会员等级id
  299. * @param int $uid 用户id
  300. * @return array
  301. * */
  302. public static function getTashList($level_id, $uid = 0, $level = null, $expire = 1400)
  303. {
  304. $level_id = is_string($level_id) ? (int)$level_id : $level_id;
  305. $list = self::visibleWhere()->where('level_id', $level_id)->field('name,real_name,task_type,illustrate,number,id')->order('sort desc')->select();
  306. $list = count($list) ? $list->toArray() : [];
  307. if ($uid == 0) return $list;
  308. if ($level === null) $level = SystemUserLevel::getLevelInfo($uid);
  309. //获取下一个vip的id
  310. $LeveId = SystemUserLevel::getNextLevelId($level['id']);
  311. $is_clear = SystemUserLevel::getClear($level['id']);
  312. if ($is_clear == false && $LeveId == $level_id) $is_clear = true;
  313. $reach_count = self::getTaskComplete($level_id, $uid, true);
  314. return [
  315. 'list' => $list,
  316. 'reach_count' => $reach_count,
  317. 'task' => self::tidyTask($list, $uid, $is_clear, User::getCleanTime($uid)),
  318. ];
  319. }
  320. /**
  321. * 获取未完成任务的详细值
  322. * @param array $item 任务
  323. * @param int $uid 用户id
  324. * @param int $startTime 开始时间
  325. * @return array
  326. * */
  327. protected static function set_task_type($item, $uid, $startTime = 0)
  328. {
  329. $task = ['task_type_title' => '', 'new_number' => 0, 'speed' => 0, 'finish' => 0];
  330. $task_type = $item['task_type'];
  331. switch ($task_type) {
  332. case 'SatisfactionIntegral':
  333. case 'ConsumptionAmount':
  334. case 'ConsumptionFrequency':
  335. case 'CumulativeAttendance':
  336. case 'SharingTimes':
  337. case 'InviteGoodFriends':
  338. case 'UserConsumptionAmount':
  339. case 'TremConsumptionAmount':
  340. case 'InviteGoodFriendsLevel':
  341. try {
  342. list($task_type_title, $num, $isComplete) = self::$task_type($item['id'], $uid, $startTime, $item['number']);
  343. if ($isComplete) {
  344. $task['finish'] = 1;
  345. $task['speed'] = 100;
  346. $task['speed'] = $item['number'];
  347. $task['new_number'] = $item['number'];
  348. } else {
  349. $numdata = bcsub($item['number'], $num, 0);
  350. $task['task_type_title'] = str_replace('{$num}', $numdata, $task_type_title);
  351. $task['speed'] = bcdiv($num, $item['number'], 2);
  352. $task['speed'] = bcmul($task['speed'], 100, 0);
  353. $task['new_number'] = $num;
  354. }
  355. } catch (\Exception $e) {
  356. }
  357. break;
  358. }
  359. return [$task['new_number'], $task['speed'], $task['task_type_title'], $task['finish']];
  360. }
  361. /**
  362. * 设置任务完成状态,已被使用
  363. * @param int $level_id 会员id
  364. * @param int $uid 用户id
  365. * @return Boolean
  366. * */
  367. public static function setTarkStatus($level_id, $uid)
  368. {
  369. $taskIds = self::visibleWhere()->where('level_id', $level_id)->column('id', 'id');
  370. if (!count($taskIds)) return true;
  371. return UserTaskFinish::where('uid', $uid)->where('task_id', 'in', $taskIds)->update(['status' => 1]);
  372. }
  373. /**
  374. * 检查当前等级是否完成全部任务
  375. * @param int $level_id 会员id
  376. * @param int $uid 用户uid
  377. * @return boolean
  378. * */
  379. public static function getTaskComplete($level_id, $uid, $isCount = false)
  380. {
  381. $taskIds = self::visibleWhere()->where('level_id', $level_id)->column('id', 'id');
  382. $taskIdsCount = count($taskIds);
  383. //如果当前会员没有任务默认为直接升级为下一等级
  384. if ($taskIdsCount) {
  385. if ($isCount) {
  386. return UserTaskFinish::group('task_id')->where('uid', $uid)->where('task_id', 'in', $taskIds)->count();
  387. } else {
  388. $finishCount = UserTaskFinish::group('task_id')->where('status', $isCount ? 1 : 0)->where('uid', $uid)->where('task_id', 'in', implode(',', $taskIds))->count();
  389. }
  390. //如果当前任务有完成其一的,查询当前完成的任务数量,如果有任务完成则达成当前vip
  391. if (self::visibleWhere()->where('id', 'in', implode(',', $taskIds))->where('is_must', 0)->count() && $finishCount) {
  392. return true;
  393. }
  394. return $finishCount >= $taskIdsCount;
  395. }
  396. if ($isCount) return 0;
  397. //如果没有设置任务当前等级无需购买则返回false
  398. if (SystemUserLevel::be(['id' => $level_id, 'is_pay' => 0])) return false;
  399. return true;
  400. }
  401. /**
  402. * 设置任务内容完成情况
  403. * @param array $task 任务列表
  404. * @param int $uid 用户id
  405. * @热图图呢 array
  406. * */
  407. public static function tidyTask($task, $uid, $is_clear, $startTime)
  408. {
  409. if (!is_array($task)) return $task;
  410. foreach ($task as &$item) {
  411. //如果已完成该任务进度直接为100
  412. if (UserTaskFinish::where('uid', $uid)->where('task_id', $item['id'])->count()) {
  413. $item['new_number'] = $item['number'];
  414. $item['speed'] = 100;
  415. $item['finish'] = 1;
  416. $item['task_type_title'] = '';
  417. } else {
  418. // if($is_clear){
  419. list($new_number, $speed, $task_type_title, $finish) = self::set_task_type($item, $uid, $startTime);
  420. $item['new_number'] = $new_number;
  421. $item['speed'] = $speed;
  422. $item['task_type_title'] = $task_type_title;
  423. $item['finish'] = $finish;
  424. // }else {
  425. // list($new_number, $speed, $task_type_title, $finish) = self::set_task_type($item,-1,time()+86400);
  426. // $item['new_number'] = $new_number;
  427. // $item['speed'] = $speed;
  428. // $item['task_type_title'] = $task_type_title;
  429. // $item['finish'] = $finish;
  430. // }
  431. }
  432. }
  433. return $task;
  434. }
  435. }