企业官网建设流程全解析

步骤一

电脑安装Python，下载链接：下载Python |Python.org

步骤二

安装依赖环境

cmd下，执行以下命令

pip install flask

出现以下结果，代表安装成功

步骤三

创建回调脚本 agv_recv.py

CMD 输入：notepad agv_recv.py，弹出记事本后粘贴下面代码

from flask import Flask, request app = Flask(__name__) # 完全匹配WCS原回调路径：/wcs/services/rest/cms/agvCallback @app.route("/wcs/services/rest/cms/agvCallback", methods=["POST","GET"]) def agv_callback(): print("========== 收到WCS回调数据 ==========") print("请求头：", dict(request.headers)) # 解析JSON报文 if request.is_json: req_data = request.get_json() print("回调JSON报文：", req_data) else: print("表单参数：", request.form) # 返回WCS需要的成功应答 return {"code":0,"msg":"success"} if __name__ == '__main__': # 端口使用23600，和WCS服务同端口 app.run(host="0.0.0.0", port=23600, debug=False)

Ctrl+S 保存，关闭记事本。

步骤四

CMD 直接执行启动命令：

python agv_recv.py

步骤五

执行 curl 命令模拟推送消息：

curl -X POST "http://127.0.0.1:23600/wcs/services/rest/cms/agvCallback" -H "Content-Type:application/json" -d "{\"agvCode\":\"AGV001\",\"taskNo\":\"T2026060301\"}"

执行后回到运行服务的 CMD，即可打印出收到的回调 JSON 数据。

补充说明

1. 将打印数据保存至文件中

from flask import Flask, request import datetime app = Flask(__name__) @app.route("/wcs/services/rest/cms/agvCallback", methods=["POST","GET"]) def agv_callback(): print("========== 收到WCS回调数据 ==========") headers = dict(request.headers) print("请求头：", headers) if request.is_json: req_data = request.get_json() print("回调JSON报文：", req_data) # ==========新增：落地文件========== with open("agv_data.log","a",encoding="utf-8") as f: time_str = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") f.write(f"【{time_str}】报文：{req_data}\n") else: print("表单参数：", request.form) return {"code":0,"msg":"success"} if __name__ == '__main__': app.run(host="0.0.0.0", port=23600, debug=False)

2. 按日期自动生成日志文件

from flask import Flask, request import datetime, os app = Flask(__name__) # 日志存放文件夹 LOG_DIR = "agv_logs" # 文件夹不存在自动创建 if not os.path.exists(LOG_DIR): os.mkdir(LOG_DIR) @app.route("/wcs/services/rest/cms/agvCallback", methods=["POST","GET"]) def agv_callback(): now = datetime.datetime.now() time_full = now.strftime("%Y-%m-%d %H:%M:%S") date_str = now.strftime("%Y%m%d") # 日期作为日志文件名 print(f"==========【{time_full}】收到WCS回调数据 ==========") headers = dict(request.headers) print("请求头：", headers) # 拼接当日日志完整路径 log_file = os.path.join(LOG_DIR, f"agv_{date_str}.log") if request.is_json: req_data = request.get_json() print("回调JSON报文：", req_data) # 写入当天的日志文件 with open(log_file,"a",encoding="utf-8") as f: f.write(f"【{time_full}】请求头：{headers}\n【报文内容】：{req_data}\n-------------------------\n") else: form_data = request.form print("表单参数：", form_data) with open(log_file,"a",encoding="utf-8") as f: f.write(f"【{time_full}】请求头：{headers}\n【表单内容】：{form_data}\n-------------------------\n") return {"code":0,"msg":"success"} if __name__ == '__main__': app.run(host="0.0.0.0", port=23600, debug=False)