Skip to content

C
customer
Commit 277da64f by BANice
Options

添加消费者代码

parent 3901d5a3
Showing with 221 additions and 36 deletions
.idea/workspace.xml
...@@ -2,7 +2,6 @@ ...@@ -2,7 +2,6 @@
<project version="4"> <project version="4">
<component name="ChangeListManager"> <component name="ChangeListManager">
<list default="true" id="51473025-d333-486e-bf8a-0f5aa99abe65" name="Default" comment=""> <list default="true" id="51473025-d333-486e-bf8a-0f5aa99abe65" name="Default" comment="">
<change afterPath="$PROJECT_DIR$/Dockerfile" afterDir="false" />
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/vendor/illuminate/database" beforeDir="false" afterPath="$PROJECT_DIR$/vendor/illuminate/database" afterDir="false" /> <change beforePath="$PROJECT_DIR$/vendor/illuminate/database" beforeDir="false" afterPath="$PROJECT_DIR$/vendor/illuminate/database" afterDir="false" />
</list> </list>
...@@ -22,7 +21,7 @@ ...@@ -22,7 +21,7 @@
<entry file="file://$PROJECT_DIR$/start.php"> <entry file="file://$PROJECT_DIR$/start.php">
<provider selected="true" editor-type-id="text-editor"> <provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="121"> <state relative-caret-position="121">
<caret line="76" column="31" lean-forward="true" selection-start-line="76" selection-start-column="31" selection-end-line="76" selection-end-column="31" /> <caret line="76" column="31" selection-start-line="76" selection-start-column="31" selection-end-line="76" selection-end-column="31" />
<folding> <folding>
<element signature="e#139#168#0#PHP" expanded="true" /> <element signature="e#139#168#0#PHP" expanded="true" />
</folding> </folding>
...@@ -34,7 +33,23 @@ ...@@ -34,7 +33,23 @@
<entry file="file://$PROJECT_DIR$/Dockerfile"> <entry file="file://$PROJECT_DIR$/Dockerfile">
<provider selected="true" editor-type-id="text-editor"> <provider selected="true" editor-type-id="text-editor">
<state> <state>
<caret column="17" selection-start-column="17" selection-end-column="17" /> <caret column="46" selection-start-column="46" selection-end-column="46" />
</state>
</provider>
</entry>
</file>
<file leaf-file-name="autoload_real.php" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/vendor/composer/autoload_real.php">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="-433" />
</provider>
</entry>
</file>
<file leaf-file-name="composer.json" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/composer.json">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="15">
<caret line="1" selection-start-line="1" selection-end-line="1" />
</state> </state>
</provider> </provider>
</entry> </entry>
...@@ -102,20 +117,6 @@ ...@@ -102,20 +117,6 @@
</provider> </provider>
</entry> </entry>
</file> </file>
<file leaf-file-name="RedisKey.php" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/Lib/redis/RedisKey.php">
<provider selected="true" editor-type-id="text-editor" />
</entry>
</file>
<file leaf-file-name="Order.php" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/Lib/cdz_order/Order.php">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="529">
<caret line="120" column="43" selection-start-line="120" selection-start-column="43" selection-end-line="120" selection-end-column="43" />
</state>
</provider>
</entry>
</file>
</leaf> </leaf>
</component> </component>
<component name="FindInProjectRecents"> <component name="FindInProjectRecents">
...@@ -206,9 +207,9 @@ ...@@ -206,9 +207,9 @@
</component> </component>
<component name="ProjectFrameBounds" fullScreen="true"> <component name="ProjectFrameBounds" fullScreen="true">
<option name="x" value="1920" /> <option name="x" value="1920" />
<option name="y" value="-35" /> <option name="y" value="-58" />
<option name="width" value="1855" /> <option name="width" value="1920" />
<option name="height" value="1057" /> <option name="height" value="1080" />
</component> </component>
<component name="ProjectLevelVcsManager" settingsEditedManually="true"> <component name="ProjectLevelVcsManager" settingsEditedManually="true">
<ConfirmationsSetting value="2" id="Add" /> <ConfirmationsSetting value="2" id="Add" />
...@@ -292,12 +293,12 @@ ...@@ -292,12 +293,12 @@
<workItem from="1530780684621" duration="15711000" /> <workItem from="1530780684621" duration="15711000" />
<workItem from="1531129253744" duration="16149000" /> <workItem from="1531129253744" duration="16149000" />
<workItem from="1531278957683" duration="9558000" /> <workItem from="1531278957683" duration="9558000" />
<workItem from="1531467679116" duration="35341000" /> <workItem from="1531467679116" duration="36857000" />
</task> </task>
<servers /> <servers />
</component> </component>
<component name="TimeTrackingManager"> <component name="TimeTrackingManager">
<option name="totallyTimeSpent" value="136677000" /> <option name="totallyTimeSpent" value="138193000" />
</component> </component>
<component name="TodoView"> <component name="TodoView">
<todo-panel id="selected-file"> <todo-panel id="selected-file">
...@@ -318,8 +319,8 @@ ...@@ -318,8 +319,8 @@
<window_info anchor="bottom" id="File Transfer" order="7" weight="0.200611" /> <window_info anchor="bottom" id="File Transfer" order="7" weight="0.200611" />
<window_info anchor="bottom" id="Run" order="2" /> <window_info anchor="bottom" id="Run" order="2" />
<window_info anchor="bottom" id="Version Control" order="7" /> <window_info anchor="bottom" id="Version Control" order="7" />
<window_info active="true" anchor="bottom" id="Terminal" order="7" visible="true" weight="0.23217922" /> <window_info anchor="bottom" id="Terminal" order="7" visible="true" weight="0.23217922" />
<window_info content_ui="combo" id="Project" order="0" visible="true" weight="0.16400427" /> <window_info active="true" content_ui="combo" id="Project" order="0" visible="true" weight="0.16400427" />
<window_info anchor="bottom" id="Docker" order="7" show_stripe_button="false" /> <window_info anchor="bottom" id="Docker" order="7" show_stripe_button="false" />
<window_info anchor="right" id="Database" order="3" /> <window_info anchor="right" id="Database" order="3" />
<window_info anchor="bottom" id="Find" order="1" /> <window_info anchor="bottom" id="Find" order="1" />
...@@ -341,9 +342,6 @@ ...@@ -341,9 +342,6 @@
<option name="myLimit" value="2678400000" /> <option name="myLimit" value="2678400000" />
</component> </component>
<component name="editorHistoryManager"> <component name="editorHistoryManager">
<entry file="file://$PROJECT_DIR$/vendor/composer/autoload_psr4.php">
<provider selected="true" editor-type-id="text-editor" />
</entry>
<entry file="file://$PROJECT_DIR$/src/MyRabbitMq.php" /> <entry file="file://$PROJECT_DIR$/src/MyRabbitMq.php" />
<entry file="file://$PROJECT_DIR$/Lib/Hello.php" /> <entry file="file://$PROJECT_DIR$/Lib/Hello.php" />
<entry file="file://$PROJECT_DIR$/Lib/rabbit.php" /> <entry file="file://$PROJECT_DIR$/Lib/rabbit.php" />
...@@ -433,13 +431,6 @@ ...@@ -433,13 +431,6 @@
</state> </state>
</provider> </provider>
</entry> </entry>
<entry file="file://$PROJECT_DIR$/composer.json">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="165">
<caret line="11" column="31" selection-start-line="11" selection-start-column="31" selection-end-line="11" selection-end-column="31" />
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/vendor/monolog/monolog/src/Monolog/Logger.php"> <entry file="file://$PROJECT_DIR$/vendor/monolog/monolog/src/Monolog/Logger.php">
<provider selected="true" editor-type-id="text-editor"> <provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="240"> <state relative-caret-position="240">
...@@ -634,17 +625,29 @@ ...@@ -634,17 +625,29 @@
<entry file="file://$PROJECT_DIR$/start.php"> <entry file="file://$PROJECT_DIR$/start.php">
<provider selected="true" editor-type-id="text-editor"> <provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="121"> <state relative-caret-position="121">
<caret line="76" column="31" lean-forward="true" selection-start-line="76" selection-start-column="31" selection-end-line="76" selection-end-column="31" /> <caret line="76" column="31" selection-start-line="76" selection-start-column="31" selection-end-line="76" selection-end-column="31" />
<folding> <folding>
<element signature="e#139#168#0#PHP" expanded="true" /> <element signature="e#139#168#0#PHP" expanded="true" />
</folding> </folding>
</state> </state>
</provider> </provider>
</entry> </entry>
<entry file="file://$PROJECT_DIR$/vendor/composer/autoload_real.php">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="-433" />
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/composer.json">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="15">
<caret line="1" selection-start-line="1" selection-end-line="1" />
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/Dockerfile"> <entry file="file://$PROJECT_DIR$/Dockerfile">
<provider selected="true" editor-type-id="text-editor"> <provider selected="true" editor-type-id="text-editor">
<state> <state>
<caret column="17" selection-start-column="17" selection-end-column="17" /> <caret column="46" selection-start-column="46" selection-end-column="46" />
</state> </state>
</provider> </provider>
</entry> </entry>
......
src/MyRabbitMq.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: suhangyang
* Date: 2018/5/4
* Time: 上午9:36
*/
namespace src;
class MyRabbitMq
{
const CONNECTION = [
'host' => 'rabbitmq.default.svc.cluster.local',
'port' => '5672',
'login' => 'rabbitmq',
'password' => 'senthink123!',
'vhost' => 'cdz_gateway',
];
/**
* @var \AMQPConnection
*/
protected $connection;
/**
* @var \AMQPChannel
*/
protected $channel;
/**
* @var string
*/
protected $routeKey;
/**
* @var string
*/
protected $exchangeKey;
/**
* @var \AMQPExchange
*/
protected $exchange;
/**
* MyRabbitMq constructor.
* @throws \AMQPConnectionException
* @throws \AMQPExchangeException
*/
public function __construct()
{
$this->connection = new \AMQPConnection(self::CONNECTION);
if (!$this->connection->connect()) {
throw new \Exception('amqp connect fail');
} else {
$channel = new \AMQPChannel($this->connection);
$this->exchange = new \AMQPExchange($channel);
}
}
/**
* @throws \AMQPConnectionException
*/
public function getChannel()
{
$this->channel = new \AMQPChannel($this->connection);
}
/**
* @return \AMQPConnection
*/
public function getConnection(): \AMQPConnection
{
return $this->connection;
}
/**
* @param \AMQPConnection $connection
*/
public function setConnection(\AMQPConnection $connection)
{
$this->connection = $connection;
}
/**
* @return string
*/
public function getRouteKey(): string
{
return $this->routeKey;
}
/**
* @param string $routeKey
*/
public function setRouteKey(string $routeKey)
{
$this->routeKey = $routeKey;
}
/**
* @return string
*/
public function getExchangeKey(): string
{
return $this->exchangeKey;
}
/**
* @param string $exchangeKey
*/
public function setExchangeKey(string $exchangeKey)
{
$this->exchangeKey = $exchangeKey;
}
/**
* @return \AMQPExchange
*/
public function getExchange(): \AMQPExchange
{
return $this->exchange;
}
/**
* @param \AMQPExchange $exchange
*/
public function setExchange(\AMQPExchange $exchange)
{
$this->exchange = $exchange;
}
}
\ No newline at end of file
storage/log/customer-2018-07-09 0 → 100644
[2018-07-09 15:25:25] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 15:25:40] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 16:30:33] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 16:30:33] ./storage/log/customer.DEBUG: body {"order_id":198,"time":"2018-07-09 15:13:52","gateway_mac":"009569C4B81A"} []
[2018-07-09 16:32:19] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 16:43:24] ./storage/log/customer.DEBUG: body {"order_id":208,"time":"2018-07-09 16:33:24","gateway_mac":"009569C4B81A"} []
[2018-07-09 16:43:24] ./storage/log/customer.DEBUG: 发送结束充电命令208 [] []
[2018-07-09 16:56:49] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 17:07:31] ./storage/log/customer.DEBUG: body {"order_id":209,"time":"2018-07-09 16:57:25","gateway_mac":"009569C4B81A"} []
[2018-07-09 17:08:38] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 17:08:38] ./storage/log/customer.DEBUG: body {"order_id":209,"time":"2018-07-09 16:57:25","gateway_mac":"009569C4B81A"} []
[2018-07-09 17:09:02] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 17:09:02] ./storage/log/customer.DEBUG: body {"order_id":209,"time":"2018-07-09 16:57:25","gateway_mac":"009569C4B81A"} []
[2018-07-09 17:09:02] ./storage/log/customer.DEBUG: 发送结束充电命令209 [] []
[2018-07-09 17:09:48] ./storage/log/customer.INFO: 启动消费者 [] []
[2018-07-09 17:09:48] ./storage/log/customer.DEBUG: body {"order_id":209,"time":"2018-07-09 16:57:25","gateway_mac":"009569C4B81A"} []
[2018-07-09 17:20:55] ./storage/log/customer.DEBUG: body {"order_id":215,"time":"2018-07-09 17:10:55","gateway_mac":"009569C4B81A"} []
[2018-07-09 17:20:55] ./storage/log/customer.DEBUG: 发送结束充电命令215 [] []
storage/log/customer-2018-07-22 0 → 100644
[2018-07-22 17:50:59] ./storage/log/customer.DEBUG: 已更改过口子，次消息作废 [] []
[2018-07-22 17:50:59] ./storage/log/customer.DEBUG: receiver {"message":{"order_id":1172,"out_trade_no":"21532252879269576","total_fee":1,"user_id":1,"pay_type":2,"port_id":2,"logic_num":1,"gateway_mac":"009569C4B8D6","gateway_id":1,"station_id":1},"time":"17:50:59"} []
[2018-07-22 17:58:05] ./storage/log/customer.DEBUG: body {"order_id":1172,"time":"2018-07-22 17:48:05","gateway_mac":"009569C4B8D6","shed_time":1532252884} []
storage/log/customer-2018-07-24 0 → 100644
This source diff could not be displayed because it is too large. You can view the blob instead.
storage/log/customer-2018-08-01 0 → 100644
[2018-08-01 16:30:40] ./storage/log/customer.DEBUG: refund [] []
[2018-08-01 16:30:40] ./storage/log/customer.DEBUG: 发送结束充电命令1829 [] []
[2018-08-01 16:30:40] ./storage/log/customer.DEBUG: receiver {"message":{"order_id":1829,"out_trade_no":"215331120607548","total_fee":100,"user_id":6,"pay_type":2,"port_id":54,"logic_num":1,"gateway_mac":"009569C4B81A","gateway_id":8,"station_id":7},"time":"16:30:40"} []
[2018-08-01 16:32:52] ./storage/log/customer.DEBUG: refund [] []
[2018-08-01 16:32:52] ./storage/log/customer.DEBUG: 发送结束充电命令1830 [] []
[2018-08-01 16:32:52] ./storage/log/customer.DEBUG: receiver {"message":{"order_id":1830,"out_trade_no":"215331121925326","total_fee":1,"user_id":5,"pay_type":2,"port_id":32,"logic_num":0,"gateway_mac":"009569B467B2","gateway_id":6,"station_id":5},"time":"16:32:52"} []
[2018-08-01 16:32:58] ./storage/log/customer.DEBUG: 已更改过口子，次消息作废 [] []
[2018-08-01 16:32:58] ./storage/log/customer.DEBUG: receiver {"message":{"order_id":1831,"out_trade_no":"215331121985336","total_fee":1,"user_id":5,"pay_type":2,"port_id":33,"logic_num":1,"gateway_mac":"009569B467B2","gateway_id":6,"station_id":5},"time":"16:32:58"} []
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment