Message.php 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  1. <?php
  2. namespace app\service\controller;
  3. class Message extends Base
  4. {
  5. public function index()
  6. {
  7. // 留言信息(默认查询前七天的留言)
  8. $start = time()-604800;
  9. $end = time();
  10. if(request()->isPost()){
  11. $start_time = input("param.start_time/s");
  12. $end_time = input("param.end_time/s");
  13. $limit = input("param.pageSize/s");
  14. $offset = (input("param.pageNumber/s") - 1) * $limit;
  15. if(!empty($start_time)){
  16. $start = strtotime($start_time);
  17. }
  18. if(!empty($end_time)){
  19. $end = strtotime($end_time . ' 23:59:59');
  20. }
  21. }
  22. $message = db('accountsmessage')->whereBetween('add_time', [$start, $end])->limit($offset, $limit)->order('add_time', 'desc')->select();
  23. foreach($message as $key=>$vo){
  24. //转为日期时间格式
  25. $message[$key]['add_time'] = date('Y-m-d H:i:s',$vo['add_time']);
  26. if(!empty($vo['dealWith_time'])){
  27. $message[$key]['dealWith_time'] = date('Y-m-d H:i:s',$vo['dealWith_time']);
  28. }
  29. }
  30. $data = [
  31. 'status'=>1,
  32. 'msg'=>'成功',
  33. 'data'=>$message
  34. ];
  35. return json_encode($data,JSON_UNESCAPED_UNICODE);
  36. }
  37. // 处理留言
  38. public function dealmessage()
  39. {
  40. if(request()->isPost()){
  41. //客服id
  42. //$user_id = 2;
  43. $user_id = input("param.user_id/s");
  44. //留言id
  45. //$message_id = 14;
  46. $message_id = input("param.message_id/s");
  47. //回复内容
  48. $reply_content = input("param.reply_content/s");
  49. //回复图片
  50. $images = input("param.images/s");
  51. $user = db('users')->where('id', $user_id)->find();
  52. if(empty($user)){
  53. return json(['code' => -1, 'data' => '', 'msg' => '客服不存在']);
  54. }
  55. $message = db('accountsmessage')->where('message_id', $message_id)->find();
  56. if(empty($message)){
  57. return json(['code' => -1, 'data' => '', 'msg' => '留言不存在']);
  58. }
  59. // 更新留言状态
  60. $param = [
  61. 'user_id' => $user_id,
  62. 'message_status' => 1,
  63. 'reply_content' => $reply_content,
  64. 'images' => $images,
  65. 'dealWith_time' => time()
  66. ];
  67. try{
  68. db('accountsmessage')->where('message_id', $message_id)->update($param);
  69. }catch(\Exception $e){
  70. return json(['code' => -1, 'data' => '', 'msg' => $e->getMessage()]);
  71. }
  72. return json(['code' => 1, 'data' => '', 'msg' => '留言处理成功']);
  73. }
  74. }
  75. }