SystemUserTask.php 16 KB

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