SysRen.php 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. <?php
  2. namespace app\subscribe;
  3. use app\common\model\Worker;
  4. use app\common\service\RensheService;
  5. use think\Event;
  6. use think\facade\Log;
  7. class SysRen
  8. {
  9. /**
  10. * 岗位撮合结果信息提交
  11. */
  12. public function onJobMatch($param)
  13. {
  14. //线上环境才同步
  15. if (env('APP_DEBUG')) {
  16. return true;
  17. }
  18. if ($param['status'] == 3) {
  19. if (empty($param['comjobs']['comjobsCate']['code'])) {
  20. Log::error('岗位撮合同步失败,工种编号不存在,撮合id:' . $param['id']);
  21. }
  22. //数据初始化
  23. $data = [];
  24. $data['aca111'] = $param['comjobs']['comjobsCate']['code'];
  25. $data['aca112'] = $param['comjobs']['title'];
  26. $data['baz367'] = $param['comjobs']['id'];
  27. $data['aae036'] = date('Y-m-d H:i:s');
  28. $data['baz370'] = $param['id'];
  29. if (empty($param['worker']['third_id'])) {
  30. $data['aae136'] = $param['worker']['card_no'];
  31. $data['aab069'] = $param['worker']['title'];
  32. $data['aae004'] = $param['worker']['realname'];
  33. } else {
  34. $data['aae136'] = $param['worker']['third']['card_no'];
  35. $data['aab069'] = $param['worker']['third']['name'];
  36. $data['aae004'] = $param['worker']['third']['contact'];
  37. }
  38. $data['aae006'] = $param['worker']['province'] . $param['worker']['city'] . $param['worker']['district'] . $param['worker']['address'];
  39. $data['aae005'] = $param['worker']['mobile'];
  40. $data['aac002'] = $param['user']['idcard'];
  41. $data['aac003'] = $param['user']['nickname'];
  42. $data['bec001'] = $param['user']['address'];
  43. $data['bae025'] = $param['user']['mobile'];
  44. //发送请求
  45. $service = new RensheService($data);
  46. $service->MatchSubmit();
  47. }
  48. }
  49. /**
  50. * 自定义订阅列表
  51. */
  52. public function subscribe(Event $event)
  53. {
  54. $event->listen('JobMatch', [$this, 'onJobMatch']);
  55. }
  56. }