传信息

app/admin/controller/Comjobs.php

@@ -17,6 +17,7 @@ use app\common\model\Broker as BrokerModel;
 use app\common\model\ComjobsShare as ComjobsShareModel;
 
 use app\common\model\WorkerThird;
+use app\common\service\FulianService;
 use app\common\service\RensheService;
 use app\common\validate\Comjobs as ComjobsValidate;
 use think\exception\ValidateException;
@@ -221,7 +222,7 @@ class Comjobs extends BaseController
         }
         if (empty($id)) {
             $data['video'] = input('new_video/s', "");
-            ComjobsModel::create($data);
+            $comjobs = ComjobsModel::create($data);
         } else {
 
             $old_video = input('old_video/s', '');
@@ -238,6 +239,12 @@ class Comjobs extends BaseController
             ComjobsLogModel::update(['workerid' => input('workerid/d', 0)], ['comjobsid' => $comjobs->id]);
             $comjobs->save($data);
         }
+
+        if ($comjobs['status'] == 3) {
+            $comjobs->append(['worker']);
+            $service = new FulianService($comjobs);
+            $service->jobInfo();
+        }
         exit(json_encode([
             'code' => 0,
         ]));

app/admin/controller/Test.php

@@ -3,6 +3,7 @@ namespace app\admin\controller;
 
 use app\admin\BaseController;
 use app\common\model\UserPart;
+use app\common\service\FulianService;
 use app\common\service\IntegralService;
 use think\facade\Db;
 
@@ -12,6 +13,15 @@ class Test extends BaseController
         $integralService = new IntegralService();
         $integralService->add(6,IntegralService::REGISTER);
     }
+
+    public function t2() {
+        $service = new FulianService();
+        \app\common\model\Comjobs::with('worker')->where('sex','<>',1)->chunk(10, function($list) use($service) {
+            $service->setData($list);
+            $service->jobInfos();
+        });
+        return 'success';
+    }
 /*
     public function t2()
     {

app/common/service/FulianService.php

@@ -0,0 +1,86 @@
+<?php
+
+namespace app\common\service;
+
+use think\facade\Log;
+
+class FulianService
+{
+    //网址
+    const BASE_URL = 'https://woman_odd_job.jucai.gov.cn/linggong';
+//    const BASE_URL = 'http://bd.woman_odd_job.com/linggong';
+
+    //要发送的数据
+    private $_data = [];
+
+    //日志名
+    private $_log_name = '';
+
+    /**
+     * 构造函数
+     * @param array $data 要发送的数据
+     */
+    public function __construct($data = [])
+    {
+        $this->_data = $data;
+    }
+
+    /**
+     * 设置参数
+     * @param $data
+     */
+    public function setData($data)
+    {
+        foreach ($data as $k => $v) {
+            $this->_data[$k] = $v;
+        }
+    }
+
+    /**
+     * 岗位信息库提交
+     */
+    public function jobInfo()
+    {
+        $this->_log_name = '同步岗位给妇联';
+        $url             = self::BASE_URL . '/getJob.html';
+        $res             = $this->_send($url);
+
+        return $res;
+    }
+
+    /**
+     * 岗位信息库提交
+     */
+    public function jobInfos()
+    {
+        $this->_log_name = '同步岗位列表给妇联';
+        $url             = self::BASE_URL . '/getJobs.html';
+        $res             = $this->_send($url);
+
+        return $res;
+    }
+
+    /**
+     * 发送数据
+     * @param $url
+     * @return mixed
+     */
+    private function _send($url)
+    {
+        Log::info($this->_log_name . '：' . json_encode($this->_data));
+
+        //请求头
+        $header = [
+            'Content-Type: application/json',
+        ];
+        //发送数据
+        $response = http_request($url, 'POST', json_encode($this->_data), $header);
+        Log::info($this->_log_name . '返回数据：' . $response);
+
+        //重置默认值，方便下一次使用
+        $this->_data = [];
+        $this->_log_name = '';
+
+        return json_decode($response,true);
+    }
+}