StarJob.php 2.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. <?php
  2. namespace app\controller\jiandao;
  3. use app\extra\basic\Base;
  4. use app\model\blue\BlueExpertPlatform;
  5. use LinFly\Annotation\Route\Controller;
  6. use LinFly\Annotation\Route\Route;
  7. use support\Request;
  8. use support\Response;
  9. use yzh52521\EasyHttp\Http;
  10. #[Controller(prefix: "/v2")]
  11. class StarJob extends Base
  12. {
  13. #[Route(path: "task/push",methods: "get")]
  14. public function pushJobList(Request $request): Response
  15. {
  16. try {
  17. $resp = Http::asJson()->post("https://api.jiandaoyun.com/api/v1/automation/tenant/69dc899f71c9656940c3db33/hooks/69e07cb9d9016a508ad1dfad0bb32ba47135e0453631e9e6",[
  18. "time" => time()
  19. ])->array();
  20. return success("ok",$resp);
  21. } catch (\Throwable $throwable) {
  22. return error($throwable->getMessage());
  23. }
  24. }
  25. /**
  26. * 获取已添加的任务
  27. * @param Request $request
  28. * @return Response
  29. */
  30. #[Route(path: "task/param",methods: "post")]
  31. public function getJobList(Request $request): Response
  32. {
  33. try {
  34. $param = $request->all();
  35. print_r($param);
  36. return success("ok");
  37. } catch (\Throwable $throwable) {
  38. return error($throwable->getMessage());
  39. }
  40. }
  41. /**
  42. * 检查达人数据是否存在
  43. * @param Request $request
  44. * @return Response
  45. */
  46. #[Route(path: "task/star",methods: "post")]
  47. public function checkStarId(Request $request): Response
  48. {
  49. try {
  50. $param = $this->_valid([
  51. "total.require" => trans("empty.require"),
  52. "uid.require" => trans("empty.require"),
  53. "platform.require" => trans("empty.require"),
  54. ],$request->method());
  55. if (!is_array($param)) return error($param);
  56. $star = (new BlueExpertPlatform)->where(['unique_id' => $param['uid'],'source' => $param['platform']])->findOrEmpty();
  57. if ($star->isEmpty()) return error("数据不存在");
  58. if ($param['total'] == 0) return success("ok");
  59. $star->jd_exist = 1;
  60. $state = $star->save();
  61. if (!$state) return errorTrans("error.data");
  62. return success("ok");
  63. } catch (\Throwable $throwable) {
  64. return error($throwable->getMessage());
  65. }
  66. }
  67. }