|
|
@@ -11,6 +11,7 @@
|
|
|
|
|
|
namespace App\Services;
|
|
|
|
|
|
+use App\Models\ArticleModel;
|
|
|
use App\Models\CollectModel;
|
|
|
use App\Models\DynamicCommentModel;
|
|
|
use App\Models\DynamicModel;
|
|
|
@@ -219,4 +220,44 @@ class DynamicService extends BaseService
|
|
|
return parent::edit($data); // TODO: Change the autogenerated stub
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 发布动态
|
|
|
+ * @param $userId
|
|
|
+ * @return array
|
|
|
+ */
|
|
|
+ public function publish($userId){
|
|
|
+ $params = request()->all();
|
|
|
+ $content = isset($params['content'])? htmlspecialchars($params['content']) : '';
|
|
|
+ $albums = isset($params['fileList'])? $params['fileList'] : [];
|
|
|
+ $sourceId = isset($params['source_id'])? intval($params['source_id']) : 0;
|
|
|
+ if($sourceId && !ArticleModel::where(['id'=> $sourceId, 'mark'=> 1,'status'=> 1])->value('id')){
|
|
|
+ return message('抱歉,当前文章状态不可分享到动态', false);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 验证用户
|
|
|
+ $memberInfo = MemberModel::where(['id'=> $userId, 'mark'=> 1,'status'=> 1])
|
|
|
+ ->select(['id','openid','nickname'])
|
|
|
+ ->first();
|
|
|
+ if(!$memberInfo){
|
|
|
+ return message('账户不可操作或已冻结,请联系客服', false);
|
|
|
+ }
|
|
|
+
|
|
|
+ $confirm = ConfigService::make()->getConfigByCode('dynamic_confirm');
|
|
|
+ $confirm = intval($confirm)? intval($confirm) : 2;
|
|
|
+ $data = [
|
|
|
+ 'user_id'=> $userId,
|
|
|
+ 'source_id'=> $sourceId,
|
|
|
+ 'comment_close'=> isset($params['comment_close']) && $params['comment_close']? 1 : 2,
|
|
|
+ 'content'=> $content,
|
|
|
+ 'albums'=> $albums? json_encode($albums, 256) : '',
|
|
|
+ 'create_time'=> time(),
|
|
|
+ 'status'=> $confirm,
|
|
|
+ ];
|
|
|
+
|
|
|
+ if($id = $this->model::insertGetId($data)){
|
|
|
+ return message('发布成功', true, ['id'=> $id]);
|
|
|
+ }
|
|
|
+
|
|
|
+ return message('发布失败', false);
|
|
|
+ }
|
|
|
}
|