Message.php 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  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. if(!empty($start_time)){
  14. $start = strtotime($start_time);
  15. }
  16. if(!empty($end_time)){
  17. $end = strtotime($end_time . ' 23:59:59');
  18. }
  19. }
  20. $message = db('accountsmessage')->whereBetween('add_time', [$start, $end])->select();
  21. //print_r($message);
  22. return $message;
  23. }
  24. // 处理留言
  25. public function dealmessage()
  26. {
  27. if(request()->isPost()){
  28. //客服id
  29. //$user_id = 2;
  30. $user_id = input("param.user_id/s");
  31. //留言id
  32. //$message_id = 14;
  33. $message_id = input("param.message_id/s");
  34. $user = db('users')->where('id', $user_id)->find();
  35. if(empty($user)){
  36. return json(['code' => -1, 'data' => '', 'msg' => '客服不存在']);
  37. }
  38. $message = db('accountsmessage')->where('message_id', $message_id)->find();
  39. if(empty($message)){
  40. return json(['code' => -1, 'data' => '', 'msg' => '留言不存在']);
  41. }
  42. // 更新留言状态
  43. $param = [
  44. 'user_id' => $user_id,
  45. 'message_status' => 1,
  46. 'dealWith_time' => time()
  47. ];
  48. try{
  49. db('accountsmessage')->where('message_id', $message_id)->update($param);
  50. }catch(\Exception $e){
  51. return json(['code' => -1, 'data' => '', 'msg' => $e->getMessage()]);
  52. }
  53. return json(['code' => 1, 'data' => url('message/index'), 'msg' => '留言处理成功']);
  54. }
  55. }
  56. }