Task.php 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use think\Db;
  5. /**
  6. * 任务接口
  7. */
  8. class Task extends Api
  9. {
  10. protected $noNeedLogin = [''];
  11. protected $noNeedRight = '*';
  12. public function _initialize()
  13. {
  14. parent::_initialize();
  15. $this->taskModel = new \app\common\model\Task();
  16. $this->tasklogModel = new \app\common\model\TaskLog();
  17. }
  18. /**
  19. * 获取任务列表
  20. */
  21. public function getTaskList() {
  22. $type_id = $this->request->request("type_id",1); // 任务类型:1=实时任务,2=每日任务
  23. $plat = $this->request->request("plat",1); // 平台:1=安卓,2=ios
  24. $urlArr = ["1"=>"android_url","2"=>"ios_url"];
  25. $jump_url = $urlArr[$plat];
  26. if($type_id == 2) {
  27. // 获取所有基础任务
  28. $where = [];
  29. $where["type_id"] = 2;
  30. $where["is_show"] = 1;
  31. $taskList = Db::name('task')
  32. ->field("id,type_id,image,name,exp,number,".$jump_url." as jump_url,url_type")
  33. ->where($where)
  34. ->autopage()
  35. ->select();
  36. $taskList = list_domain_image($taskList,['image']);
  37. $today = strtotime(date("Y-m-d 00:00:00"));
  38. //今日开始的任务
  39. $where = [];
  40. $where["user_id"] = $this->auth->id;
  41. $where["createtime"] = ["gt",$today];
  42. $finishInfo = \app\common\model\TaskLog::where($where)->select();
  43. $finishIds = [];
  44. if($finishInfo) foreach($finishInfo as $k => $v) {
  45. $finishIds[$v["task_id"]] = $v;
  46. }
  47. if($taskList) {
  48. foreach($taskList as $k => $v) {
  49. $finishInfo = isset($finishIds[$v["id"]])?$finishIds[$v["id"]]:[];
  50. if($finishInfo) {
  51. $taskList[$k]["pace"] = $finishInfo->pace;
  52. $taskList[$k]["is_finish"] = $finishInfo->is_finish;
  53. $taskList[$k]["finish_number"] = $finishInfo->finish_number;
  54. $taskList[$k]["is_reward"] = $finishInfo->is_reward;
  55. if($finishInfo->is_finish != 1 && $finishInfo->pace != 0) {
  56. $taskList[$k]["pace_txt"] = $finishInfo->finish_number."/".$v["number"];
  57. }
  58. } else {
  59. $taskList[$k]["pace"] = 0;
  60. $taskList[$k]["is_finish"] = 0;
  61. $taskList[$k]["finish_number"] = 0;
  62. $taskList[$k]["is_reward"] = 0;
  63. $taskList[$k]["pace_txt"] = "0/".$v["number"];
  64. }
  65. }
  66. }
  67. } else {
  68. // 获取基本信息
  69. $where = [];
  70. $where["a.type_id"] = 1;
  71. $where["a.is_show"] = 1;
  72. $taskList = Db::name('task')->alias("a")
  73. ->field("a.id,a.type_id,a.image,a.name,a.exp,a.number,a.".$jump_url." as jump_url,a.url_type,l.pace,l.is_reward,l.is_finish,l.finish_number")
  74. ->join("task_log l", "l.task_id = a.id and l.user_id = ".$this->auth->id, "left")
  75. ->where($where)
  76. ->autopage()
  77. ->order("a.id","asc")
  78. ->select();
  79. $taskList = list_domain_image($taskList,['image']);
  80. $comment_for_gold_switch = config('site.comment_for_gold_switch');//好评有礼开关
  81. if($taskList) {
  82. foreach($taskList as $k => $v) {
  83. $v["pace"] || $taskList[$k]["pace"] = 0;
  84. $v["is_finish"] || $taskList[$k]["is_finish"] = 0;
  85. $v["finish_number"] || $taskList[$k]["finish_number"] = 0;
  86. $v["is_reward"] || $taskList[$k]["is_reward"] = 0;
  87. if($v["is_finish"] != 1 && $v["pace"] != 0) {
  88. $taskList[$k]["pace_txt"] = $v["finish_number"]."/".$v["number"];
  89. }
  90. //好评有礼开关
  91. if($v['id'] == 17 && $comment_for_gold_switch == 0){
  92. unset($taskList[$k]);
  93. }
  94. }
  95. }
  96. }
  97. $this->success("获取成功!",$taskList);
  98. }
  99. /**
  100. * 领取奖励
  101. */
  102. public function getReward() {
  103. $task_id = $this->request->request("task_id"); // 任务ID
  104. if (!$task_id) {
  105. $this->error(__('Invalid parameters'));
  106. }
  107. // 查询任务信息
  108. $taskInfo = $this->taskModel->where(["id"=>$task_id])->find();
  109. if(!$taskInfo) {
  110. $this->error("任务信息未找到!");
  111. }
  112. // 查询用户完成情况
  113. $where = [];
  114. $where["user_id"] = $this->auth->id;
  115. $where["task_id"] = $task_id;
  116. $where["is_finish"] = 1;
  117. if($taskInfo["type_id"] == 2){
  118. $where["finish_date"] = date("Ymd");
  119. }
  120. $tasklogInfo = $this->tasklogModel->where($where)->find();
  121. if(!$tasklogInfo) {
  122. $this->error("任务还未完成哦!");
  123. }
  124. if($tasklogInfo["is_reward"] == 1) {
  125. $this->error("任务奖励已领取,请勿重复领取!");
  126. }
  127. Db::startTrans();
  128. try{
  129. // 增加用户金币
  130. $res1 = model('wallet')->lockChangeAccountRemain($this->auth->id,'gold',$taskInfo["exp"],61,$taskInfo['name'],'task_log',$tasklogInfo['id']);
  131. if($res1['status'] === false){
  132. Db::rollback();
  133. $this->error($res1['msg']);
  134. }
  135. // 更新奖励领取状态
  136. $res2 = $this->tasklogModel->update(["is_reward"=>1],["task_id"=>$task_id,"user_id"=>$this->auth->id]);
  137. if($res1['status'] === true && $res2) {
  138. Db::commit();
  139. $this->success("领取成功!");
  140. } else {
  141. Db::rollback();
  142. $this->error("领取失败!");
  143. }
  144. }catch (ValidateException $e) {
  145. Db::rollback();
  146. $this->error($e->getMessage());
  147. } catch (PDOException $e) {
  148. Db::rollback();
  149. $this->error($e->getMessage());
  150. } catch (Exception $e) {
  151. Db::rollback();
  152. $this->error($e->getMessage());
  153. }
  154. }
  155. /**
  156. * 完成任务
  157. */
  158. public function finishTask() {
  159. $task_id = $this->request->request("task_id"); // 任务编码
  160. $number = $this->request->request("number",1); // 完成次数
  161. if (!$task_id) {
  162. $this->error(__('Invalid parameters'));
  163. }
  164. \app\common\model\TaskLog::tofinish($this->auth->id,$task_id,$number);
  165. $this->success("成功!");
  166. }
  167. }