Core.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511
  1. <?php
  2. namespace Score\Lib;
  3. use Dever;
  4. class Core
  5. {
  6. /**
  7. * 增加日志 Dever::load('score/lib/core')->log($uid, $key, $name);
  8. *
  9. * @return mixed
  10. */
  11. public function log($uid, $action_key, $action_name, $callback = '', $score = false, $num = false, $type = false, $type_id = false)
  12. {
  13. if (strstr($action_key, '.')) {
  14. $temp = explode('.', $action_key);
  15. $action_key = $temp[0];
  16. $type = $temp[1];
  17. $type_id = $temp[2];
  18. }
  19. $action = Dever::db('score/action')->one(array('key' => $action_key));
  20. if (!$action) {
  21. $action = array();
  22. $action['id'] = Dever::db('score/action')->insert(array('key' => $action_key, 'name' => $action_name));
  23. }
  24. if (isset($action['id']) && $action['id'] > 0) {
  25. $insert = array();
  26. $parent_uid = 0;
  27. if (strstr($uid, '_')) {
  28. $temp = explode('_', $uid);
  29. $uid = $temp[1];
  30. $parent_uid = $temp[0];
  31. }
  32. $insert['uid'] = $uid;
  33. $insert['action_id'] = $action['id'];
  34. $insert['callback'] = $callback;
  35. if ($score > 0) {
  36. $insert['mscore'] = $score;
  37. }
  38. if ($num > 0) {
  39. $insert['num'] = $num;
  40. }
  41. if ($parent_uid > 0) {
  42. $insert['parent_uid'] = $parent_uid;
  43. }
  44. if ($type) {
  45. $insert['type'] = $type;
  46. }
  47. if ($type_id) {
  48. $insert['type_id'] = $type_id;
  49. }
  50. $insert['cron_type'] = 1;
  51. $log_id = Dever::db('score/action_log')->insert($insert);
  52. Dever::load('score/lib/core.oper?log_id='.$log_id);
  53. return;
  54. $sync = Dever::config('base', 'project')->score['sync'];
  55. if ($sync) {
  56. Dever::daemon('lib/core.oper?log_id='.$log_id, 'score');
  57. }
  58. //Dever::daemon('lib/core.oper?log_id='.$log_id, 'score');
  59. //Dever::load('score/lib/core.oper?log_id='.$log_id);
  60. }
  61. }
  62. # 获取积分列表
  63. public function getScore()
  64. {
  65. $data = Dever::db('score/config')->state();
  66. return $data;
  67. }
  68. # 获取某一个用户的积分
  69. public function getUserScore($uid, $config_id = false, $type = false, $type_id = false)
  70. {
  71. if ($config_id && $type && $type_id) {
  72. $where['config_id'] = $config_id;
  73. $where['type'] = $type;
  74. $where['type_id'] = $type_id;
  75. $where['state'] = 1;
  76. $child = Dever::db('score/config_child')->one($where);
  77. if ($child) {
  78. $where = array();
  79. $where['uid'] = $uid;
  80. $where['config_child_id'] = $child['id'];
  81. $score = Dever::db('score/user_child')->one($where);
  82. return array('name' => $child['name'], 'score' => $score['score'] ? $score['score'] : 0);
  83. }
  84. } else {
  85. if (!$config_id) {
  86. $config = Dever::db('score/config')->one(array('type' => 1));
  87. } else {
  88. $config = Dever::db('score/config')->one($config_id);
  89. }
  90. if ($config) {
  91. $where = array();
  92. $where['uid'] = $uid;
  93. $where['config_id'] = $config['id'];
  94. $score = Dever::db('score/user')->one($where);
  95. return array('name' => $config['name'], 'score' => $score['score'] ? $score['score'] : 0);
  96. }
  97. }
  98. return false;
  99. }
  100. # 设置子积分
  101. public function setScoreChild($config_type, $config_id, $type, $type_id, $name)
  102. {
  103. $where['config_id'] = $config_id;
  104. $where['type'] = $type;
  105. $where['type_id'] = $type_id;
  106. $info = Dever::db('score/config_child')->one($where);
  107. if ($info && $config_type == 1) {
  108. $update['where_id'] = $info['id'];
  109. $update['state'] = 2;
  110. Dever::db('score/config_child')->update($update);
  111. } elseif ($config_type == 2) {
  112. if (!$name) {
  113. $config = Dever::db('score/config')->one($config_id);
  114. $name = $config['name'];
  115. }
  116. if ($info) {
  117. $update['where_id'] = $info['id'];
  118. $update['name'] = $name;
  119. $update['state'] = 1;
  120. Dever::db('score/config_child')->update($update);
  121. } else {
  122. $insert = $where;
  123. $insert['name'] = $name;
  124. Dever::db('score/config_child')->insert($insert);
  125. }
  126. }
  127. return true;
  128. }
  129. public function oper_api()
  130. {
  131. }
  132. /**
  133. * 根据用户行为,增加积分
  134. *
  135. * @return mixed
  136. */
  137. public function oper()
  138. {
  139. $log_id = Dever::input('log_id');
  140. $log = Dever::db('score/action_log')->one($log_id);
  141. $this->operAction($log);
  142. return $log;
  143. }
  144. private function rule($log, $info)
  145. {
  146. # 手动增加积分
  147. if (isset($log['mscore']) && $log['mscore'] > 0) {
  148. $info['num'] = $log['mscore'];
  149. }
  150. # 积分乘以倍数
  151. if (isset($log['num']) && $log['num'] > 0) {
  152. $info['num'] = $info['num'] * $log['num'];
  153. }
  154. if ($info['num'] == 0) {
  155. # 未加数据
  156. return $this->finish($log);
  157. }
  158. $uid = $log['uid'];
  159. $num = $info['num'];
  160. $this->user = 'score/user';
  161. $this->user_log = 'score/user_log';
  162. $info['config_child_id'] = false;
  163. # 验证是否有子积分设置
  164. if ($log['type'] && $log['type_id']) {
  165. $child = Dever::db('score/config_child')->one(array(
  166. 'config_id' => $info['config_id'], 'type' => $log['type'], 'type_id' => $log['type_id'], 'state' => 1));
  167. if ($child) {
  168. $this->user = 'score/user_child';
  169. $this->user_log = 'score/user_child_log';
  170. $info['config_child_id'] = $child['id'];
  171. }
  172. }
  173. if ($info['upper'] == 2 && $info['upper_limit'] >= 1) {
  174. $upper = $this->upper($uid, $info, $log);
  175. if (!$upper) {
  176. # 达到积分上限
  177. return $this->finish($log, 3, '0');
  178. }
  179. }
  180. # 完成
  181. $this->finish($log, 2, $num);
  182. $user_log_id = $this->add($uid, $num, $info, $log);
  183. if (!$user_log_id) {
  184. return;
  185. }
  186. # 增加返利
  187. if ($info['rebate_type'] > 1) {
  188. $this->rebate($uid, $num, $info, $log);
  189. }
  190. if ($log['callback']) {
  191. if (strstr($log['callback'], '?')) {
  192. Dever::load($log['callback'] . '&user_log_id=' . $user_log_id);
  193. } else {
  194. Dever::load($log['callback'], $user_log_id);
  195. }
  196. }
  197. }
  198. # 增加积分
  199. private function add($uid, $num, $info, $log, $rebate_uid = false)
  200. {
  201. $where = array();
  202. $where['uid'] = $uid;
  203. $where['config_id'] = $info['config_id'];
  204. if ($info['config_child_id']) {
  205. $where['config_child_id'] = $info['config_child_id'];
  206. }
  207. $user = Dever::db($this->user)->one($where);
  208. if (!$user) {
  209. $user = array();
  210. $user['id'] = Dever::db($this->user)->insert($where);
  211. $user['score'] = 0;
  212. }
  213. $update = array();
  214. $update['where_id'] = $user['id'];
  215. $update['score'] = $user['score'] + $num;
  216. $insert = $where;
  217. $insert['action_log_id'] = $log['id'];
  218. $insert['action_id'] = $info['action_id'];
  219. if ($rebate_uid) {
  220. $insert['rebate_uid'] = $rebate_uid;
  221. }
  222. $insert['status'] = 1;
  223. $insert['num'] = $num;
  224. $insert['total'] = $update['score'];
  225. $insert['cdate'] = time();
  226. $user_log_id = Dever::db($this->user_log)->insert($insert);
  227. if ($user_log_id) {
  228. Dever::db($this->user)->update($update);
  229. # 提升等级
  230. $level_type = Dever::db('score/level_type')->state();
  231. if ($level_type) {
  232. foreach ($level_type as $k => $v) {
  233. $this->setLevel($uid, $v);
  234. }
  235. }
  236. }
  237. return $user_log_id;
  238. }
  239. # 返利
  240. private function rebate($uid, $num, $info, $log)
  241. {
  242. if (!strstr($info['rebate_value'], ':')) {
  243. $info['rebate_value'] = '1:' . $info['rebate_value'];
  244. }
  245. $temp = explode(',', $info['rebate_value']);
  246. $invite = Dever::project('invite');
  247. $parent_uid = false;
  248. foreach ($temp as $k => $v) {
  249. $config = explode(':', $v);
  250. $value = $config[1];
  251. if ($info['rebate_type'] == 2) {
  252. # 百分比
  253. $value = round($num*($value/100), 2);
  254. }
  255. # 直属上级
  256. if ($config[0] == 1) {
  257. if ($log['parent_uid'] > 0) {
  258. $parent_uid = $log['parent_uid'];
  259. } elseif ($invite) {
  260. $parent_uid = Dever::load('invite/api')->getParent($uid, $config[0]);
  261. }
  262. if ($parent_uid > 0) {
  263. $this->add($parent_uid, $value, $info, $log, $uid);
  264. }
  265. } elseif ($invite) {
  266. # 上级的上级
  267. if ($parent_uid > 0) {
  268. $rebate_uid = $parent_uid;
  269. $level = $config[0]-1;
  270. } else {
  271. $rebate_uid = $uid;
  272. $level = $config[0];
  273. }
  274. $other_parent_uid = Dever::load('invite/api')->getParent($rebate_uid, $level);
  275. if ($other_parent_uid > 0) {
  276. $this->add($other_parent_uid, $value, $info, $log, $rebate_uid);
  277. }
  278. }
  279. }
  280. }
  281. # 迁移完成的数据
  282. private function finish($log, $score_type = 1, $score = 'no')
  283. {
  284. $id = $log['id'];
  285. if ($score_type == -1) {
  286. Dever::db('score/action_log')->update(array('where_id' => $id, 'cron_type' => 3));
  287. } else {
  288. unset($log['id']);
  289. $log['log_id'] = $id;
  290. $log['cron_type'] = 3;
  291. $log['score_type'] = $score_type;
  292. if ($score != 'no') {
  293. $log['score'] = $score;
  294. }
  295. Dever::db('score/action_log_finish')->insert($log);
  296. Dever::db('score/action_log')->delete($id);
  297. }
  298. return true;
  299. }
  300. # 设置上限限制
  301. private function upper($uid, $info, $log)
  302. {
  303. # 有上限限制
  304. $limit = $info['upper_limit'];
  305. # 获取用户最新一次积分变化日志
  306. $time = time();
  307. $where = array();
  308. if ($info['config_child_id']) {
  309. $where['config_child_id'] = $info['config_child_id'];
  310. }
  311. $where['config_id'] = $info['config_id'];
  312. $where['action_id'] = $info['action_id'];
  313. $where['uid'] = $uid;
  314. $where['status'] = 1;
  315. $user_log = Dever::db($this->user_log)->getNew($where);
  316. if ($user_log) {
  317. if ($info['upper_type'] == 1) {
  318. # 按天
  319. $where['start'] = Dever::maketime(date('Y-m-d 00:00:00', $time));
  320. //$where['end'] = $end;
  321. } elseif ($info['upper_type'] == 2) {
  322. # 按小时
  323. $where['start'] = $time - ($info['upper_time'] * 3600);
  324. //$where['end'] = $end;
  325. } elseif ($info['upper_type'] == 3) {
  326. # 永久
  327. } else {
  328. return true;
  329. }
  330. $user_log_num = Dever::db($this->user_log)->getNewTotal($where);
  331. if ($user_log_num >= $info['upper_limit']) {
  332. return false;
  333. }
  334. }
  335. return true;
  336. }
  337. private function operAction($log)
  338. {
  339. if ($log && $log['cron_type'] == 1) {
  340. Dever::db('score/action_log')->update(array('where_id' => $log['id'], 'cron_type' => 2));
  341. $where = array();
  342. $where['state'] = 1;
  343. $where['id'] = $log['action_id'];
  344. $action = Dever::db('score/action')->one($where);
  345. if ($action) {
  346. $rule = Dever::db('score/rule')->state(array('action_id' => $action['id']));
  347. if ($rule) {
  348. foreach ($rule as $k => $v) {
  349. $this->rule($log, $v);
  350. }
  351. }
  352. }
  353. }
  354. }
  355. /**
  356. * 根据积分日志和规则,增加积分,这是一个定时任务,可以设置每天凌晨启动
  357. *
  358. * @return mixed
  359. */
  360. public function cron()
  361. {
  362. $where['cron_type'] = 1;
  363. $log = Dever::db('score/action_log')->all($where);
  364. if ($log) {
  365. foreach ($log as $k => $v) {
  366. $this->operAction($v);
  367. }
  368. }
  369. }
  370. /**
  371. * 根据积分算等级,如果是自动升级,则直接升级,如果是手动升级,则将其标识置为可以升级状态。
  372. *
  373. * @return mixed
  374. */
  375. public function setLevel($uid, $level_type)
  376. {
  377. # 获取当前用户的等级
  378. $where['uid'] = $uid;
  379. $where['level_type_id'] = $level_type['id'];
  380. $user_level = Dever::db('score/user_level')->one($where);
  381. /*
  382. if ($user_level && $user_level['type'] == 2) {
  383. return;
  384. } else
  385. */
  386. $update = array();
  387. if ($user_level) {
  388. $config = Dever::db('score/level')->one($user_level['level_id']);
  389. $level = $config['level'] + 1;
  390. $method = 'update';
  391. $update['where_id'] = $user_level['id'];
  392. } else {
  393. $level = 1;
  394. $method = 'insert';
  395. }
  396. $config = Dever::db('score/level')->one(array('level' => $level, 'level_type_id' => $level_type['id'], 'state' => 1));
  397. if ($config) {
  398. # 是否能升级
  399. $yes = false;
  400. if ($config['total_type'] == 1 && $config['total'] > 0) {
  401. # 查看是否超过总数
  402. $total = Dever::db('score/user_level')->total(array('level_id' => $config['id']));
  403. if ($total >= $config['total']) {
  404. return $yes;
  405. }
  406. }
  407. $rule = Dever::array_decode($config['score']);
  408. if ($rule) {
  409. $user_score = Dever::db($this->user)->getScoreByConfig($where);
  410. if ($user_score) {
  411. foreach ($rule as $k => $v) {
  412. $score = $v['config'];
  413. $num = $v['num'];
  414. if (isset($user_score[$score]) && $user_score[$score]['score'] && $user_score[$score]['score'] >= $num) {
  415. $yes = $config['id'];
  416. # 是否清空积分 当type为自动并且score为2时
  417. if ($level_type['score'] == 2 && $level_type['type'] == 1) {
  418. $user_score_update['where_id'] = $user_score[$score]['id'];
  419. $user_score_update['score'] = $user_score[$score]['score'] - $num;
  420. Dever::db($this->user)->update($user_score_update);
  421. }
  422. } else {
  423. $yes = false;
  424. }
  425. }
  426. }
  427. }
  428. # 可以升级
  429. if ($yes) {
  430. if ($level_type['type'] == 2) {
  431. $update['next_level_id'] = $yes;
  432. $update['level_status'] = 1;
  433. } else {
  434. $update['level_id'] = $update['next_level_id'] = $yes;
  435. $update['level_status'] = 2;
  436. }
  437. $update['uid'] = $uid;
  438. $update['level_type_id'] = $level_type['id'];
  439. Dever::db('score/user_level')->$method($update);
  440. }
  441. }
  442. }
  443. }