From 18e16853eb51575561909a225e61a5618f33af3d Mon Sep 17 00:00:00 2001
From: root <root@localhost.localdomain>
Date: Mon, 9 Oct 2023 01:27:24 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 __pycache__/app.cpython-36.pyc       | Bin 0 -> 3100 bytes
 __pycache__/readQueue.cpython-36.pyc | Bin 0 -> 1146 bytes
 __pycache__/settings.cpython-36.pyc  | Bin 0 -> 287 bytes
 app.py                               |  84 ++++++++++++++++++++++-----
 readQueue.py                         |  31 ----------
 settings.py                          |  11 ++++
 templates/index.html                 |  78 ++++++++++++++++++++++++-
 templates/readQueue.html             |  73 +++++++++++++++++++++++
 8 files changed, 230 insertions(+), 47 deletions(-)
 create mode 100644 __pycache__/app.cpython-36.pyc
 create mode 100644 __pycache__/readQueue.cpython-36.pyc
 create mode 100644 __pycache__/settings.cpython-36.pyc
 delete mode 100644 readQueue.py
 create mode 100644 settings.py
 create mode 100644 templates/readQueue.html

diff --git a/__pycache__/app.cpython-36.pyc b/__pycache__/app.cpython-36.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..d16709c7cf8943beaaf1568c513838700185a30b
GIT binary patch
literal 3100
zcmb7G%Z?nk6)o1gpYxJrNpYNx5<63hJR|uPA#wyql9dPG$=Fh0ppc+b)8zD2O;=Tm
zWKU)W-J6U6ON#;W5!vJyvdAind;_-u0%)I=S3Z|LF9qJXtLqkvWRbjw=bp>=JDuiR
z|Ggpp*KwTxI2V3C%Aep?|AgTVXCtR%DJ$L7Expt${nTev?~Z~pOha4tMo}7}&Kt#P
zY@dy^VV}*kX`ijMC75U*v9!Z|9z1u_ZtiR|9`fipOBZ;|8>m|ponnbMd5gD)F7F(>
zyvrA!JNRnZwk%#~S>nsKWkt04%C0N_fgYFmC4QM-Id-us?}?MV@d`dTiEo0(qfG6Z
z1t}^nWM7MNJj%2%krdA+LTM9!A=J38lt>slXS+gf4Cq_>xwr$|4{@sxU^GzS?lGG=
znicMmQ+QLS@Q)nWz}nE-=*SuRIh(O5!&<xz6CCdJA8ufVa8wVnkw{`0VmRYZCOJ0&
z*$<4jBleA7Wu-9wpKHm}V0@5Q+C&-WQYe+UslSZ{8ei?y<G(v{5kq`^eO=bIUYFU{
zR<6ru?`k-;o{h(A;{(&8j(wR`ye=E$15N6%ruz<)%P0*Pz2oQMK6CW9c+pP5aJ$+o
zeB8m2dt}`y;NZ-ix<!QAn6qQX9K1C+^^B(g|JXwfE1E|R5d`l0<aYqDC&B=XG#2}V
zova#)v?c3_&Z}X6R~#6BtL6tu%lPAbH#5r*0Mstp9@bSQ20E`RbLqUinMuH;g;XY1
zLen71gr9x>>l!<X=VmQ|8%<M*k?GjU`&<l0nH1E%fv?lfR;Kbne>~Y5<!Z+SgHa6@
zc*f_M&P;P~HnV&ah*-4eW(lvRslced9eDxoste<=D=hZ9UdVhFyYdEV&bUO;MYrYB
zCJNsQF)@iC26JA6`1H*Mz^>hZM$w!R`&tC_lsHd7%N30LG;!@SjmDW$`JPDH@(SwZ
z8)UAMxklzXneUOY4t}3XZ^4)l*zVNabV|@J8;bs*o>W@?0Bwmce|Y*u+MENMSKGDx
zG1U?yFJdG`c7hQNKF7$NW3<R(T=H$yf6dm7_p48z8h`V5Po9D;(R_aO8hFHA3*KK)
zAn-Ut@b3*B1S6PQcpMz%-mWKap1)Tv_h(G|Q%3yVe@_QgdgT1^otdi%XirBvE*evh
z2RuB+2msS5np2NT&p!Fm(JdZ<*YUCY#FmFA<)pD8SFsXFyDu-n81~^~EWRx&HIbs9
zsX?9}Hgo9C{@RW%M-&D*1V~{!hzasX^pOwjO5+WMHXcQLfN&iO8=jUx#xE4eAMi;z
z2FDTE;GOjFY2v2=1-LR^H7O0tWsgSvzdZ=-0)C1XMT>OYCdk<X^j#LRW!N^8AEEv*
zSf|~34RVqMno0c)=DYB9=)82ka=v2QE(c?u#{e6A<vup-uPC*OHV=-N{L^_E8x_7}
zy7L0tgJ+jVC_&8;2MbnOT*?$D;<8Ab*GqQ$mN_=-g~MCN6a($k7#I-3^dsG)n*u}q
z8^-zpx@Z^D<`w}&%$xaB-^N`q4T^|}gqf*iX<$n})#-TZ6^$e0B@(z<xc|{K1ew<U
z;Lf61Z2JY%Xd3hIngbhI8(Z7B=4?YoL8>plbY38Cr=gw2FWNSOgQ8=fPSGWwd6T5|
z1>@0O=Ox241a|)dHLdSfSX&z;Ry!nl{zM6BVhVT49EU$2U@x`kk&;2>L@(d&RkiMk
z{ak6)Bi8h|*v=*+-GfR>XlU=oL~q}{aqqB!v22ffhkGZ(V35(bjj@{Z-d-kYgw;E@
zZzs2Ul)cWX-lLjfU32w%)mY{O3|Hw}y_3{-*8bt`B)NCEnj;@eO<n5wV)wEUvi0iQ
z>ehvSa!*nMdu0vf>Q^=_5Q1EcAbawlud`vYWTNpwd7z$+kP_yiZuKt>A3dOiLC@b~
zzO?!1!R85qX*ifjRZA0zeKDBez~Bq4!GuU6H4YNDFq?cI1|93N%;(~mHs&cM8|=zo
zP-9nVBw$RcCM9xI(lG8|$Hsly9LstPCv&0XW%M;Zt<89t*RWmVQBDl3+fef!bztQM
zX^nA=7;RyqU!qBoYC9f;l{M|Ph`7Fq5=m^=+QTap-D@A)^M|^>cKW&1ur%OA33<~_
zbLVm5&GW}fUG>jWz{z}RoK1Ay$IORa8uD{W>~no{(}q28K#i0|C|UVVdFNae<-1sk
zTqCniYYIS_N}p!zIi4b2P&$+P9A2ADPNeZXOG!G<oTsM~H05uo)@E{_+_;O^IgIoC
z#C*5A(qwO1NMq(&5JM(Eqvgc?ewpP}zke9rUbELL%IFySXVmPEar{Uwr@=OzJtZ;I
zu4?Wdi7J}tq-hU<@(#7z{7gC}?~|eYOw&+2_4~$y?4PFu>n9QgPEW#W_k2~JoKzRo
o-{t}9VEl1e^T|lur$AAZ|F1&zuaZkHuCU#WyVpC{e-g8A0AD%sQvd(}

literal 0
HcmV?d00001

diff --git a/__pycache__/readQueue.cpython-36.pyc b/__pycache__/readQueue.cpython-36.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..dbb06ed78b3bbcfcee9f87f6635c6345b79db6e5
GIT binary patch
literal 1146
zcmZuwOK;pZ5GEz+we~tekV}dlgdi>~z|9jug188Rq{z`|l0$(-3xg|;ceN{tGD$h!
zh4!Re^AGw5`j?0v0_5aluQ_!n=T*RxW;E0c=lf=;c`zQ2{(YaqYevXN^4;a5{R~Av
zM<s}$C7E2j>4XAVcqqQ`dfL+o1GWfyG6^79gu)l>J*7m%A{5a(I*9~*L$c%?^N>TE
zlrrb#Txw&-6==<8aCFi_3mLV+V4MdSm^<aJ5lW2m0!4p7WypdGD!c*5-vnK-@OrWd
zyAb&VJt7ZQ_|=M>b=Dcy`Hp2zkz<TH>dCL<&*>lDCfdZqo}`PqSd4BE)LVnzzCn&z
z?@?mn%X~dUPqG+Y<`d(;m_t4}{GA}jt)2|bwug5jwjPm9(j^^Rdg`B!EXMA;AlRv$
zL*-$emMJOCdizzu>z7c^p543uAoDF7TE|)q%Ek@X`mI!A{Ulew4Wxn_KIIzH;yA6P
zN#U%}MyGl%n^eFtZ%dQrbFMU)^k!?0AKyG!Czxx9I9S8yG?=8kEXQ8WD@aedayj<y
z-_7>ZnUq5R|5Kxi9Cz1dKjlIwJmjzbhj+8=z%oa3y<5~+gmHoLg5fDIThM#EdjHFl
z9Vm*uI3JYjO2#a6BqoWg>1Z&6O4hKl%z<S)HfmPYN}rTA%4J<cZYE*gDlL_b;0*HC
zfMtMCHWZLc0oI>^u|Z*=(l$WywNdV`vmtL9s0D79RaIa}UP=viM;k=O+`6rbdX|l>
zm(OijftgETM~#vVmQ{eZY%0ad(%Le|#QI3X(xs)R-+ujEwzc`2s9Om5DZS&4{Ep(&
zX<@39pABeS0T-{_fZT3YHpba0r#xS7VZ8nk74fdpn2y}-r8K2K&|A31+l#6C3H=#W
zZkDpxvZh#abp;pp+H)MkC9;2U(V{}u_WC#bH?FY929&lVM;)8!A|gC?T$FY^4C)c~
iujC2_n4yC2)UJbxf2pKsOL*$ePY<I^V;>3o+unZ+3rO++

literal 0
HcmV?d00001

diff --git a/__pycache__/settings.cpython-36.pyc b/__pycache__/settings.cpython-36.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..45f35b8c6a262e9c7ea8517612bd7339b0f8aa7e
GIT binary patch
literal 287
zcmX|+&q~8U5XLuuTZ8fFRS*yMP=n?wQbG_fEe+yjFJ<cvF_2{K&IZvp@*RAVy_UX&
zCugm7mhb!RGBfN<o~B8@JBKgE*p~Dk9^GanydaZ|GwE@U<V&9iGT<RGk|B>}#78oI
zWRnq3J3tgQtTqD-V552fH1?=f&!T-%XqwAY#%!pSG9SlPBl>&j>)G{9zL<<{Jg*j_
z15SKG&^(z}OM&>Nv~;-#>UUf!O)QK3yDVI-P0Hd>`^j`d6aU)xS?2!Av{<hj(`}}P
g=E)F@Y5E$kUf=Ebwo`Iw;m&ufo{)v!-w7Ol04%akdjJ3c

literal 0
HcmV?d00001

diff --git a/app.py b/app.py
index 55edcb9..8bfaaf8 100644
--- a/app.py
+++ b/app.py
@@ -1,40 +1,96 @@
-from flask import Flask,render_template, request, Response
+from flask import Flask, render_template, request, Response
 from faker import Faker
-import json, pika
+import json, pika, uuid
+import pymysql
+import settings
 
 app = Flask(__name__)
 
-def shop_random(n):
+def shop_random():
     fake = Faker(locale='zh_CN')
     # 随机生成姓名、商品、价格、地址,并返回一个字典
-    shop = {"response": "下单成功", "data": {fake.name(): [fake.word(), fake.pyint(), fake.address()] for i in range(n)}}
+    shop = {uuid.uuid4().hex: [fake.name(), fake.word(), fake.pyint(), fake.address()]}
     return shop
 
 def send_queue(data={}):
-    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost, settings.MQPort))
     channel = connection.channel()
 
     # 声明一个名为 'message_queue' 的队列
-    channel.queue_declare(queue='message_queue')
+    channel.queue_declare(queue=settings.MQName)
 
     # 将消息发送到队列中
     channel.basic_publish(exchange='',
-                          routing_key='message_queue',
+                          routing_key=settings.MQName,
                           body=data)
     # 关闭连接
     connection.close()
 
+def read_queue():
+    # 建立与RabbitMQ服务器的连接
+    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost, settings.MQPort))
+    channel = connection.channel()
+
+    # 声明一个队列
+    channel.queue_declare(queue=settings.MQName)
 
+    # 获取队列中的消息数量
+    queue_info = channel.queue_declare(queue=settings.MQName, passive=True)
+    message_count = queue_info.method.message_count
+    connection.close()
+    return message_count
 
 @app.route('/', methods=["GET", "POST"])
 def index():
     if request.method == 'POST':
-        num = int(request.form.get('shop', 100))
-        data = shop_random(num)
-        json_data = json.dumps(data, ensure_ascii=False)  # 设置 ensure_ascii 为 False
-        send_queue(json_data)
-        return Response(json_data, content_type='application/json; charset=utf-8')
-    return render_template("index.html")
+        shops = []
+        num = request.form.get('shop') if request.form.get('shop') != "" else '5'
+        num = int(num)
+        for i in range(num):
+            data = shop_random()
+            send_queue(json.dumps(data, ensure_ascii=False))
+            shops.append(data)
+        return render_template("index.html", items=shops)
+    return render_template("index.html", items=[])
+
+@app.route('/read', methods=["GET","POST"])
+def read():
+    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost,settings.MQPort))
+    channel = connection.channel()
+
+    # 声明一个名为 'message_queue' 的队列
+    channel.queue_declare(queue=settings.MQName)
+    data = []
+
+    def callback(ch, method, properties, body):
+        nonlocal m
+        # 这里处理从队列中获取到的消息
+        conn = pymysql.connect(host=settings.DBHost, user=settings.DBUser, password=settings.DBPassword)
+        cur = conn.cursor()
+        cur.execute('create database if not exists shop default charset "utf8";')
+        cur.execute('use shop;')
+        cur.execute('create table if not exists shop(id varchar(100), name varchar(20), goods varchar(20), price int, address varchar(50));')
+        k = eval(body.decode()).items()
+        for key, value in k:
+            cur.execute('insert into shop values(%s,%s,%s,%s,%s);', (key, value[0], value[1], value[2], value[3]))
+        data.append(k)
+        conn.commit()
+        cur.close()
+        ch.basic_ack(delivery_tag=method.delivery_tag)
+        m -= 1
+        if m == 0:
+            ch.stop_consuming()
+
+    if request.method == 'POST':
+        m = request.form.get('dshop') if request.form.get('dshop') else '5'
+        m = int(m)
+        print('1', m)
+        channel.basic_consume(queue=settings.MQName,
+                              on_message_callback=callback,
+                              auto_ack=False)  # 将 auto_ack 设置为 False
+        channel.start_consuming()
+    message_count = read_queue()
+    return render_template("readQueue.html", shop_nums=message_count, items=data)
 
 if __name__ == '__main__':
-    app.run(host="0.0.0.0",port=80)
\ No newline at end of file
+    app.run(host="0.0.0.0", port=80)
diff --git a/readQueue.py b/readQueue.py
deleted file mode 100644
index 1cf4429..0000000
--- a/readQueue.py
+++ /dev/null
@@ -1,31 +0,0 @@
-import pika
-import pymysql
-
-# 建立到 RabbitMQ 的连接
-connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
-channel = connection.channel()
-
-# 声明一个名为 'message_queue' 的队列
-channel.queue_declare(queue='message_queue')
-
-def callback(ch, method, properties, body):
-    # 这里处理从队列中获取到的消息
-    conn = pymysql.connect(host='localhost', user='root', password='123456')
-    cur = conn.cursor()
-    cur.execute('create database if not exists shop default charset "utf8";')
-    cur.execute('use shop;')
-    cur.execute('create table if not exists shop(name varchar(20), goods varchar(20), price int, address varchar(50));')
-
-    for k,v in eval(body.decode()).get('data').items():
-        cur.execute('insert into shop values(%s,%s,%s,%s);', (k, v[0], v[1], v[2]))
-        print(k, v[0], v[1], v[2])
-    conn.commit()
-    cur.close()
-
-# 从 'message_queue' 队列中获取消息
-channel.basic_consume(queue='message_queue',
-                      on_message_callback=callback,
-                      auto_ack=True)
-
-print('Waiting for messages. To exit press CTRL+C')
-channel.start_consuming()
diff --git a/settings.py b/settings.py
new file mode 100644
index 0000000..314d93e
--- /dev/null
+++ b/settings.py
@@ -0,0 +1,11 @@
+# rabbitmq 配置
+MQName="message_queue"
+MQUser="guest"
+MQPassword="guest"
+MQHost="localhost"
+MQPort=5672
+
+# mysql数据库配置
+DBHost="localhost"
+DBUser="root"
+DBPassword="QianFeng@123"
\ No newline at end of file
diff --git a/templates/index.html b/templates/index.html
index 09712d7..ed46443 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -4,14 +4,88 @@
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
     <title>商城主页</title>
+    <style>
+        body {
+            text-align: center;
+            margin-top: 20px;
+        }
+        
+        h1 {
+            font-size: 24px;
+            color: #333;
+        }
+        
+        form {
+            margin-top: 20px;
+        }
+        
+        input[type="number"] {
+            padding: 10px;
+        }
+        
+        button[type="submit"] {
+            padding: 10px 20px;
+            background-color: #007bff;
+            color: #fff;
+            border: none;
+            cursor: pointer;
+        }
+        
+        button[type="submit"]:hover {
+            background-color: #0056b3;
+        }
+        
+        table {
+            width: 80%;
+            margin: 0 auto;
+            border-collapse: collapse;
+            border: 2px solid #000;
+        }
+        
+        th, td {
+            border: 1px solid #000;
+            padding: 10px;
+        }
+        
+        th {
+            background-color: #f2f2f2;
+        }
+    </style>
 </head>
 <body>
     <center>
         <h1>祝您购物愉快</h1>
         <form action="/" method="post">
             请输入采购的商品数量：<input type="number" name="shop">
-            <button type="submit">提交</button>
+            <button type="submit">点击下单</button>
         </form>
     </center>
+    <br>
+    <table>
+        <thead>
+            <tr>
+                <th>用户编号</th>
+                <th>用户名称</th>
+                <th>商品名称</th>
+                <th>商品金额</th>
+                <th>收货地址</th>
+            </tr>
+        </thead>
+        <tbody>
+            {% if items %}
+            {% for item in items %}
+                <tr>
+                    {% for k in item %}
+                    <td>{{ k }}</td>
+                    <td>{{ item[k][0] }}</td>
+                    <td>{{ item[k][1] }}</td>
+                    <td>{{ item[k][2] }}</td>
+                    <td>{{ item[k][3] }}</td>
+                    {% endfor %}
+                </tr>
+            {% endfor %}
+            {% endif %}
+        </tbody>
+    </table>
 </body>
-</html>
\ No newline at end of file
+</html>
diff --git a/templates/readQueue.html b/templates/readQueue.html
new file mode 100644
index 0000000..acbbe57
--- /dev/null
+++ b/templates/readQueue.html
@@ -0,0 +1,73 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>发货</title>
+    <style>
+        body {
+            text-align: center;
+            margin-top: 20px; /* 添加顶部边距 */
+        }
+        
+        table {
+            width: 80%;
+            margin: 0 auto;
+            border-collapse: collapse;
+            border: 2px solid #000;
+        }
+        
+        th, td {
+            border: 1px solid #000;
+            padding: 10px;
+        }
+        
+        th {
+            background-color: #f2f2f2;
+        }
+        
+        button {
+            padding: 10px 20px;
+            background-color: #007bff;
+            color: #fff;
+            border: none;
+            cursor: pointer;
+        }
+        
+        button:hover {
+            background-color: #0056b3;
+        }
+    </style>
+</head>
+<body>
+    <form action="/read" method="post">
+        请输入批量发货的商品数量：<input type="number" name="dshop">
+        <button type="submit">点击发货</button>
+    </form>
+    <p>当前未处理货物: {{ shop_nums }}</p>
+    <table>
+        <thead>
+            <tr>
+                <th>用户编号</th>
+                <th>用户名称</th>
+                <th>商品名称</th>
+                <th>商品金额</th>
+                <th>收货地址</th>
+            </tr>
+        </thead>
+        <tbody>
+            {% for item in items %}
+                <tr>
+                    {% for item_key,item_value in item %}
+                    <td>{{ item_key }}</td>
+                    <td>{{ item_value[0] }}</td>
+                    <td>{{ item_value[1] }}</td>
+                    <td>{{ item_value[2] }}</td>
+                    <td>{{ item_value[3] }}</td>
+                    {% endfor %}
+                </tr>
+            {% endfor %}
+        </tbody>
+    </table>
+</body>
+</html>