xhArticleService.php 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. <?php
  2. namespace common\services;
  3. use Yii;
  4. use common\models\xhArticle;
  5. use common\models\xhArticleCategory;
  6. use common\components\dict;
  7. class xhArticleService {
  8. /**
  9. * 管理员添加文章
  10. */
  11. public static function addByAdmin($data)
  12. {
  13. $article = xhArticle::add($data);
  14. $id = $article['id'];
  15. $idstring = $data['categoryId'];
  16. $ids = explode(',',$idstring);
  17. $ids = array_filter($ids);//删除空元素
  18. $catData = [];
  19. $sjId = $data['sjId'];
  20. foreach($ids as $cId){
  21. $catData[] = array('sjId' => $sjId,'aId' => $id,'cId' => $cId);
  22. }
  23. xhArticleCategory::batchAdd($catData);
  24. }
  25. /**
  26. * 管理员更新文章
  27. */
  28. public static function updateAllById($id,$data,$sjId)
  29. {
  30. xhArticle::updateById($id, $data);
  31. //删除原有的分类
  32. xhArticleCategory::deleteByCondition(['aId' => $id,'sjId' => $sjId]);
  33. $idstring = $data['categoryId'];
  34. $ids = explode(',',$idstring);
  35. $ids = array_filter($ids);//删除空元素
  36. $catData = array();
  37. foreach($ids as $cId){
  38. $catData[] = array('sjId' => $sjId,'aId' => $id,'cId' => $cId);
  39. }
  40. xhArticleCategory::batchAdd($catData);
  41. }
  42. public static function getById($id)
  43. {
  44. $cacheKey = dict::getCacheKey('article').$id;
  45. $article = Yii::$app->redis->executeCommand('HGETALL', [$cacheKey]);
  46. if(!empty($article)){
  47. $arr = [];
  48. $i = 0;
  49. $x = 0;
  50. foreach($article as $key => $val){
  51. $i++;
  52. if($i%2 == 0){
  53. $arr[$x]['value'] = $val;
  54. $x++;
  55. }else{
  56. $arr[$x]['key'] = $val;
  57. }
  58. }
  59. $articleArr = [];
  60. foreach($arr as $key => $val){
  61. $articleArr[$val['key']] = $val['value'];
  62. }
  63. unset($articleArr['info_already_get_by_sql']);
  64. return $articleArr;
  65. }
  66. $article = xhArticle::find()->where(['id' => $id])->asArray()->one();
  67. $params = [$cacheKey];
  68. $params[] = 'info_already_get_by_sql';
  69. $params[] = 'ok';//redis没有办法设置带空值的键,加此可以数据空时表示取过
  70. if(!empty($article)){
  71. foreach($article as $key => $val){
  72. $params[] = $key;
  73. $params[] = $val;
  74. }
  75. }
  76. Yii::$app->redis->executeCommand('HMSET',$params);
  77. return $article;
  78. }
  79. public static function updateById($id,$data)
  80. {
  81. xhArticle::updateById($id, $data);
  82. self::getById($id);
  83. $cacheKey = dict::getCacheKey('article').$id;
  84. $articleParams = [$cacheKey];
  85. foreach($data as $key => $val){
  86. $articleParams[] = $key;
  87. $articleParams[] = $val;
  88. }
  89. Yii::$app->redis->executeCommand('HMSET',$articleParams);//更新缓存信息
  90. }
  91. }