BookLimit.php 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: licc
  5. * Date: 2018/10/16
  6. * Time: 上午10:33
  7. */
  8. namespace app\common\model;
  9. use app\common\library\Redis;
  10. use think\Cookie;
  11. use think\Model;
  12. class BookLimit extends Model
  13. {
  14. // 表名
  15. protected $table = 'book_limit';
  16. // 自动写入时间戳字段
  17. protected $autoWriteTimestamp = 'int';
  18. // 定义时间戳字段名
  19. protected $updateTime = 'updatetime';
  20. // 追加属性
  21. protected $append = [
  22. ];
  23. public function hasLimit($agentId,$channelId,$bookID,$userId){
  24. $bookinfo = model('Book')->BookInfo($bookID);
  25. if(empty($bookinfo)){
  26. return true;
  27. }
  28. $rk = 0;
  29. $rknosee = 0;
  30. if($bookinfo['state'] == '-1'){ //入库书籍
  31. $rk = 1;
  32. }
  33. if($bookinfo['state'] == '-1' && isset($bookinfo['cansee']) && $bookinfo['cansee'] == '0'){ //入库不可见
  34. $rknosee = 1;
  35. }
  36. $redis = Redis::instance();
  37. //通用规则屏蔽 开始
  38. $redisKeyTy = 'BL:*';
  39. if ($redis->exists($redisKeyTy)) {
  40. //存在通用规则
  41. $endUserId = $redis->hget($redisKeyTy, $bookID);
  42. if (!empty($endUserId) && $endUserId < $userId) {
  43. return true;
  44. }
  45. }
  46. //通用规则屏蔽 结束
  47. if(empty($agentId) && empty($channelId)){
  48. //如果渠道商和代理商都为空,则从cookie里取代理商和渠道商id
  49. if(Cookie::has('agent_id')){
  50. $agentId = Cookie::get('agent_id');
  51. }
  52. if(Cookie::has('channel_id')){
  53. $channelId = Cookie::get('channel_id');
  54. }
  55. }
  56. if($agentId == $channelId){
  57. $agentId = 0;
  58. }
  59. if(empty($agentId)){
  60. //渠道商用户
  61. $groupId = model('AuthGroupAccess')->getGroupId($channelId);
  62. $redisKey = 'BL:'.$channelId;
  63. if($groupId == 3){
  64. $keyChannel = 'BL:'.$channelId.'*';
  65. }else{
  66. $adminExtend = model('AdminExtend')->getInfo($channelId);
  67. $keyChannel = 'BL:'.$adminExtend['create_by'].'*';
  68. }
  69. if($redis->exists($redisKey)){
  70. //判断存在不存在
  71. $endUserId = $redis->hget($redisKey,$bookID);
  72. if(!empty($endUserId) && $endUserId < $userId){
  73. return true;
  74. }
  75. if($rk){ //判断所有入库
  76. $rkUserId = $redis->hget($redisKey,'-1');
  77. if(!empty($rkUserId) && $rkUserId < $userId){
  78. return true;
  79. }
  80. }
  81. if($rknosee){ //判断入库并不可见
  82. $rknoseeUserId = $redis->hget($redisKey,'-2');
  83. if(!empty($rknoseeUserId) && $rknoseeUserId<$userId){
  84. return true;
  85. }
  86. }
  87. }
  88. if($redis->exists($keyChannel)){
  89. //用渠道商的
  90. $endUserId = $redis->hget($keyChannel, $bookID);
  91. if (!empty($endUserId) && $endUserId < $userId) {
  92. return true;
  93. }
  94. if ($rk) { //判断入库
  95. $rkUserId = $redis->hget($keyChannel, '-1');
  96. if (!empty($rkUserId) && $rkUserId < $userId) {
  97. return true;
  98. }
  99. }
  100. if ($rknosee) {
  101. $rknoseeUserId = $redis->hget($keyChannel, '-2');
  102. if (!empty($rknoseeUserId) && $rknoseeUserId < $userId) {
  103. return true;
  104. }
  105. }
  106. }
  107. return false;
  108. }else{
  109. //代理商用户
  110. $redisKey = 'BL:'.$agentId;
  111. $keyChannel = 'BL:'.$channelId.'*';
  112. if($redis->exists($redisKey)){
  113. //判断存在不存在
  114. $endUserId = $redis->hget($redisKey,$bookID);
  115. if(!empty($endUserId) && $endUserId < $userId){
  116. return true;
  117. }
  118. if($rk){ //判断入库
  119. $rkUserId = $redis->hget($redisKey,'-1');
  120. if(!empty($rkUserId) && $rkUserId < $userId){
  121. return true;
  122. }
  123. }
  124. if($rknosee){
  125. $rknoseeUserId = $redis->hget($redisKey,'-2');
  126. if(!empty($rknoseeUserId) && $rknoseeUserId<$userId){
  127. return true;
  128. }
  129. }
  130. return false;
  131. }
  132. if($redis->exists($keyChannel)) {
  133. //用渠道商的
  134. $endUserId = $redis->hget($keyChannel, $bookID);
  135. if (!empty($endUserId) && $endUserId < $userId) {
  136. return true;
  137. }
  138. if ($rk) { //判断入库
  139. $rkUserId = $redis->hget($keyChannel, '-1');
  140. if (!empty($rkUserId) && $rkUserId < $userId) {
  141. return true;
  142. }
  143. }
  144. if ($rknosee) {
  145. $rknoseeUserId = $redis->hget($keyChannel, '-2');
  146. if (!empty($rknoseeUserId) && $rknoseeUserId < $userId) {
  147. return true;
  148. }
  149. }
  150. }
  151. return false;
  152. }
  153. return false;
  154. }
  155. /**
  156. * 后台限制书籍
  157. * @param $agentId
  158. * @param $channelId
  159. * @param $bookID
  160. * @return bool
  161. */
  162. public function backendHasLimit($agentId,$channelId,$bookID){
  163. $bookinfo = model('Book')->BookInfo($bookID);
  164. if (!$bookinfo) {
  165. return true;
  166. }
  167. $rk = 0;
  168. $rknosee = 0;
  169. if($bookinfo['state'] == '-1'){ //入库书籍
  170. $rk = 1;
  171. }
  172. if($bookinfo['state'] == '-1' && isset($bookinfo['cansee']) && $bookinfo['cansee'] == '0'){ //入库不可见
  173. $rknosee = 1;
  174. }
  175. $redis = Redis::instance();
  176. if(empty($agentId)){
  177. //渠道商用户
  178. $redisKey = 'BL:'.$channelId;
  179. $keyChannel = 'BL:'.$channelId.'*';
  180. if($redis->exists($redisKey)){
  181. //判断存在不存在
  182. $endUserId = $redis->hget($redisKey,$bookID);
  183. if(!empty($endUserId)){
  184. return true;
  185. }
  186. if($rk){ //判断入库
  187. $rkUserId = $redis->hget($redisKey,'-1');
  188. if(!empty($rkUserId)){
  189. return true;
  190. }
  191. }
  192. if($rknosee){
  193. $rknoseeUserId = $redis->hget($redisKey,'-2');
  194. if(!empty($rknoseeUserId)){
  195. return true;
  196. }
  197. }
  198. return false;
  199. }else {
  200. if ($redis->exists($keyChannel)) {
  201. //用渠道商的
  202. $endUserId = $redis->hget($keyChannel, $bookID);
  203. if (!empty($endUserId)) {
  204. return true;
  205. }
  206. if ($rk) { //判断入库
  207. $rkUserId = $redis->hget($keyChannel, '-1');
  208. if (!empty($rkUserId)) {
  209. return true;
  210. }
  211. }
  212. if ($rknosee) {
  213. $rknoseeUserId = $redis->hget($keyChannel, '-2');
  214. if (!empty($rknoseeUserId)) {
  215. return true;
  216. }
  217. }
  218. }
  219. }
  220. return false;
  221. }else{
  222. //代理商用户
  223. $redisKey = 'BL:'.$agentId;
  224. $keyChannel = 'BL:'.$channelId.'*';
  225. if($redis->exists($redisKey)){
  226. //判断存在不存在
  227. $endUserId = $redis->hget($redisKey,$bookID);
  228. if(!empty($endUserId)){
  229. return true;
  230. }
  231. if($rk){ //判断入库
  232. $rkUserId = $redis->hget($redisKey,'-1');
  233. if(!empty($rkUserId)){
  234. return true;
  235. }
  236. }
  237. if($rknosee){
  238. $rknoseeUserId = $redis->hget($redisKey,'-2');
  239. if(!empty($rknoseeUserId)){
  240. return true;
  241. }
  242. }
  243. return false;
  244. }else{
  245. if($redis->exists($keyChannel)) {
  246. //用渠道商的
  247. $endUserId = $redis->hget($keyChannel, $bookID);
  248. if (!empty($endUserId)) {
  249. return true;
  250. }
  251. if ($rk) { //判断入库
  252. $rkUserId = $redis->hget($keyChannel, '-1');
  253. if (!empty($rkUserId)) {
  254. return true;
  255. }
  256. }
  257. if ($rknosee) {
  258. $rknoseeUserId = $redis->hget($keyChannel, '-2');
  259. if (!empty($rknoseeUserId)) {
  260. return true;
  261. }
  262. }
  263. }
  264. }
  265. return false;
  266. }
  267. return false;
  268. }
  269. }