1

app/Controller/TestController.php

@@ -435,32 +435,16 @@ class TestController extends AbstractController
     }
 
     public function test_10(){
-        $ImService = new ImService();
-
-        // 获取订单医生数据
-        $params = array();
-        $params['doctor_id'] = "494429911331946496";
-        $user_doctor = UserDoctor::getOne($params);
-
-
-        // 自定义消息
-        $cloud_custom_data = array();
-        $cloud_custom_data['order_inquiry_id'] = "498932680833085441";
-        $cloud_custom_data['is_system'] = 1;
-        $cloud_custom_data['inquiry_type'] = 1;
-        $cloud_custom_data['message_rounds'] = 0;
-
-        // 消息内容
-        $message_content_data = array();
-        $message_content_data['message_type'] = 1;
-        $message_content_data['content'] = "--等待医生接诊--";
-        $message_content_data['desc'] = "温馨提示：您可继续补充问诊内容，便于更快确认病情，医生均在临床一线工作，还请耐心等待，医生接诊会第一时间短信通知您。";
-        $message_content = [
-            'Data' => json_encode($message_content_data,JSON_UNESCAPED_UNICODE),
-        ];
-
-        $ImService->sendMessage("494429911046733824", "498932257254518784", $message_content, "TIMCustomElem", $cloud_custom_data);
-
+        $data = array();
+        $data['order_inquiry_id'] = "499163900703698944";
+        $message = new CancelUnpayOrdersDelayDirectProducer($data);
+        $message->setDelayMs(1000 * 5);
+        $producer = $this->container->get(Producer::class);
+        $res = $producer->produce($message);
+        if (!$res) {
+            Db::rollBack();
+            return fail(HttpEnumCode::SERVER_ERROR, "订单创建失败");
+        }
 
     }