init

src/app/job/Cronexecute.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace app\job;
+
+use app\model\system\Cron;
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 事件通过队列异步调用
+ * Class Eventasync
+ * @package app\job
+ */
+class Cronexecute
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+
+            $res = event($data[ 'event' ], [ 'relate_id' => $data[ 'relate_id' ] ]);
+            $data_log = [
+                'name' => $data[ 'name' ],
+                'event' => $data[ 'event' ],
+                'relate_id' => $data[ 'relate_id' ],
+                'message' => json_encode($res)
+            ];
+
+            Log::write("计划任务:{$data[ 'event' ]} relate_id: {$data[ 'relate_id' ]}执行结果：" . json_encode($res, JSON_UNESCAPED_UNICODE));
+            $cron_model = new Cron();
+            //定义最新的执行时间或错误
+            $cron_model->addCronLog($data_log);
+
+
+        } catch (\Exception $e) {
+            Log::write($e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/MemberRegisterAfter.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace app\job;
+
+use app\model\member\Register;
+use think\facade\Log;
+use think\queue\Job;
+
+class MemberRegisterAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            (new Register())->memberRegisterAfter($data);
+        } catch (\Exception $e) {
+            Log::write($e->getMessage() . $e->getFile() . $e->getLine());
+        }
+    }
+
+}

src/app/job/Sendmessage.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace app\job;
+
+use think\facade\Log;
+use think\queue\Job;
+
+class Sendmessage
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            $res = event("SendMessageTemplate", $data, true);
+            Log::write("SendMessageTemplate" . json_encode($res));
+
+        } catch (\Exception $e) {
+            Log::write($e->getMessage() . $e->getFile() . $e->getLine());
+        }
+    }
+
+}

src/app/job/order/OrderCreateAfter.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace app\job\order;
+
+use app\model\order\OrderCreate;
+use app\model\system\Cron;
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 订单创建后事件
+ */
+class OrderCreateAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            $create_data = $data['create_data'];
+            $order_object = (new OrderCreate())->invokeClass($create_data);
+            //订单创建后事件
+            event('OrderCreateAfter', ['order_object' => $order_object,  'create_data' => $data['create_data']]);
+        } catch (\Exception $e) {
+            Log::write('OrderCreateAfter_error_'.$e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/order/OrderDeliveryAfter.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace app\job\order;
+
+use think\facade\Log;
+use think\queue\Job;
+
+class OrderDeliveryAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            event('OrderDeliveryAfter', [ 'order_id' => $data[ 'order_id' ], 'site_id' => $data[ 'site_id' ] ]);
+
+        } catch (\Exception $e) {
+            Log::write($e->getMessage() . $e->getFile() . $e->getLine());
+        }
+    }
+
+}

src/app/job/order/OrderPayAfter.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace app\job\order;
+
+use think\facade\Log;
+use think\queue\Job;
+
+class OrderPayAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            (new \app\model\order\event\OrderPay())->after($data);
+
+        } catch (\Exception $e) {
+            Log::write($e->getMessage() . $e->getFile() . $e->getLine());
+        }
+    }
+
+}

src/app/job/order/OrderTakeDeliveryAfter.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace app\job\order;
+
+use think\facade\Log;
+use think\queue\Job;
+
+class OrderTakeDeliveryAfter
+{
+    /**
+     * 订单收货后自动执行事件
+     * @param Job $job
+     * @param $data
+     */
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            event('OrderTakeDeliveryAfter', [ 'order_id' => $data[ 'order_id' ], 'site_id' => $data[ 'site_id' ] ]);
+
+        } catch (\Exception $e) {
+            Log::write($e->getMessage() . $e->getFile() . $e->getLine());
+        }
+    }
+
+}

src/app/job/order_refund/OrderRefundApplyAfter.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace app\job\order_refund;
+
+use app\model\order\OrderCreate;
+use app\model\order\orderrefund\Apply;
+use app\model\system\Cron;
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 订单申请退款后事件
+ */
+class OrderRefundApplyAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            //退款申请后事件
+            Apply::after($data);
+        } catch (\Exception $e) {
+            Log::write(__CLASS__.$e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/order_refund/OrderRefundCancelAfter.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace app\job\order_refund;
+
+use app\model\order\orderrefund\Apply;
+use app\model\order\orderrefund\Cancel;
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 订单取消退款后事件
+ */
+class OrderRefundCancelAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            //退款取消后事件
+            Cancel::after($data);
+        } catch (\Exception $e) {
+            Log::write(__CLASS__.$e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/order_refund/OrderRefundConfirmAfter.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace app\job\order_refund;
+
+use app\model\order\orderrefund\Cancel;
+use app\model\order\orderrefund\Confirm;
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 订单通过退款后事件
+ */
+class OrderRefundConfirmAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            //退款审核后事件
+            Confirm::after($data);
+        } catch (\Exception $e) {
+            Log::write(__CLASS__.$e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/order_refund/OrderRefundRefuseAfter.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace app\job\order_refund;
+
+use app\model\order\orderrefund\Apply;
+use app\model\order\orderrefund\Refuse;
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 订单拒绝退款后事件
+ */
+class OrderRefundRefuseAfter
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            //退款拒绝后事件
+            Refuse::after($data);
+        } catch (\Exception $e) {
+            Log::write(__CLASS__.$e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/system/CheckJob.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace app\job\system;
+
+use app\model\system\Cron;
+use think\facade\Log;
+use think\facade\Queue;
+use think\queue\Job;
+
+/**
+ * 校验任务
+ */
+class CheckJob
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            $file = $data['file'];
+            file_put_contents($file, time());
+            //todo 部署一个8秒后再校验一次删除这个文件
+            Queue::later(8, 'app\job\system\DeleteJob', $data);
+        } catch (\Exception $e) {
+            Log::write($e->getMessage());
+            $job->delete();
+        }
+    }
+
+}

src/app/job/system/DeleteJob.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace app\job\system;
+
+use think\facade\Log;
+use think\queue\Job;
+
+/**
+ * 任务删除事件
+ */
+class DeleteJob
+{
+    public function fire(Job $job, $data)
+    {
+        $job->delete();
+        try {
+            $file = $data['file'];
+            @unlink($file);
+            return true;
+        } catch (\Exception $e) {
+            Log::write($e->getMessage());
+            $job->delete();
+        }
+    }
+
+}