基于C++、MySQL的图书销售管理系统

create database bsms character set=utf8; /* bsm for book sales management */
use bsms;

create table books (
bno varchar(16) NOT NULL,
bname varchar(64) NOT NULL,
bauthor varchar(64),
bamount int NOT NULL,
bsaled int NOT NULL,
bprice int NOT NULL,
bsupplier varchar(64),
boffer int,
primary key(bno),
index (bno)
) engine=innodb default charset=utf8;

/* test insert */
insert into books(bno,bname,bauthor,bamount,bsaled,bprice,bsupplier,boffer)
value("testnum","testname","testauth",99,9,9999,"testpbls",1);

create table purchase (
pno varchar(16) NOT NULL,
bno varchar(16) NOT NULL,
pnum int NOT NULL,
bsupplier varchar(64),
boffer int,
primary key(pno),
foreign key(bno) references books(bno)
) engine=innodb default charset=utf8;

/* test insert */
insert into purchase(pno,bno,pnum,bsupplier,boffer)
value("testpurchase","testnum",123,"testsupplier",99);

create table sale (
sno varchar(16) NOT NULL,
bno varchar(16) NOT NULL,
snum int NOT NULL,
primary key(sno),
foreign key(bno) references books(bno)
) engine=innodb default charset=utf8;

/* test insert */
insert into sale(sno,bno,snum)
value("testsale","testnum",2);

create table refund (
rno varchar(16) NOT NULL,
bno varchar(16) NOT NULL,
rnum int NOT NULL,
primary key(rno),
foreign key(bno) references books(bno)
)  engine=innodb default charset=utf8;

/* test insert */
insert into refund(rno,bno,rnum)
value("testrefund","testnum",1);

/* delimiter // */
/* don't have to and can't user delimiter in C API */
create trigger purchase_update
after insert on purchase
for each row
    begin http://www.biyezuopin.vip
        update books set bamount=bamount+new.pnum where bno=new.bno;
        update books set bsupplier=new.bsupplier where bno=new.bno;
        update books set boffer=new.boffer where bno=new.bno;
    end
/* //
delimiter ; */

create trigger sale_update
after insert on sale
for each row
    begin
        update books set bamount=bamount-new.snum where bno=new.bno;
        update books set bsaled=bsaled+new.snum where bno=new.bno;
    end

create trigger refund_update
after insert on refund
for each row
    begin http://www.biyezuopin.vip
        update books set bamount=bamount+new.rnum where bno=new.bno;
        update books set bsaled=bsaled-new.rnum where bno=new.bno;
        update sale set snum=snum-new.rnum where bno=new.bno;
    end

select *
from books
order by bno asc;

select p.pno,b.bno,b.bname,p.pnum,b.bsupplier,b.boffer
from purchase p
join books b
    on b.bno=p.bno
order by pno desc;

select s.sno,s.snum,b.bno,b.bname,b.bauthor,b.bamount,b.bsaled,b.bprice
from books b
join sale s
    on s.bno=b.bno
order by sno desc;

select b.bno,b.bname,b.bauthor,b.bamount,b.bsaled,b.bprice
from books b
order by bsaled desc;

int main() {
    sm_welcome(); // 欢迎页面打印 系统起始界面
    // 数据库连接 运行时需要先行手动在MySQL上创建数据库 bsms
    mysql_init(&mysql);
    if (NULL == mysql_real_connect(&mysql, "localhost", username, password, database, 3306, 0, 0)) {
        sm_error(mysql_error(&mysql));
        return -1;
    }
    // 数据库初始化：创建表格、触发器约束
    init();http://www.biyezuopin.vip
    // 循环获取用户操作，各对应操作用函数进行封装处理
    bool infinite = true;
    while (infinite) {
        sm_menu(); // 菜单打印
        string tcmd = sm_get_cmd(); // 指令获取和处理
        int cmd = tcmd[0] - '0';
        switch (cmd) {
            case 0:sm_bye();return 0;break;
            case 1:book();break;
            case 2:stock();break;
            case 3:purchase();break;
            case 4:sale()；break;
            case 5:refund();break;
            case 6:sale_time();break;
            case 7:sale_ppl();break;
            default:sm_error("Invalid command input detected");break;
        }
        sleep(1); // 每次都挂起一秒
                  // 提示用户注意操作后的系统信息以免直接被菜单覆盖
                  // 防止生成的年月日时分秒时间戳重复
    }
    mysql_close(&mysql);
    return 0;
}

#ifndef Global_h
#define Global_h

#include <iomanip>
#include <iostream>
#include <mysql.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

using namespace std;

MYSQL mysql;
char username[16] = "root";
char password[16] = "database2019";
char database[16] = "bsms";

#endif /* Global_h */

// 系统界面打印辅助函数，以 decorator 作为左右占位符号将 msg 内容在屏幕上居中输出
void sm_center(char decorator, string msg)；

// 系统消息提示统一模板，将提示信息 msg 在命令行界面以统一格式输出，用于输出正常操作后的提示信息
void sm_alert(const char * msg)；

// 系统消息提示统一模板，将错误信息 msg 在命令行界面以统一格式输出，用于输出异常操作后的错误提示
void sm_error(const char * msg)；

// 系统表格打印辅助函数，模仿 MySQL 命令行终端的表格打印方法打印表格中的横向分隔符
void sm_display_table_line(vector<int> widths, int col)；

// 系统表格打印辅助函数，打印整个表格信息
void sm_display_table_func(vector<vector<string>> ele, vector<int> widths, int col, unsigned long long row)；

// 系统表格打印函数，将 mysql 查询得到的结果进行解析保存，调用辅助函数完成打印
// 获取每个数据属性信息并保存在二维vector中，获取每列数据最大长度并保存作为底层表格打印函数参数
void sm_display_table(MYSQL_RES * res)；

// 系统获取用户指令统一模板，显示获取指令提示信息并接收用户输入
string sm_get_cmd()；

// 系统获取字符串类型数据信息统一模板，显示提示输入 msg 和属性关键字 key 并接受用户录入的数据
string sm_get_info(const char * msg, const char * key)；

// 系统获取整数类型数据信息统一模板，显示提示输入 msg 和属性关键字 key 并接受用户录入的数据
int sm_get_amount(const char * msg, const char * key)；

// 系统欢迎界面打印函数，会输出 ascii 字符拼接海报体的 BOOK SALE 字样
void sm_welcome()；

// 系统菜单打印函数，会输出系统功能列表以及对应的代表关键字方便用户操作
void sm_menu()；

// 系统关闭退出信息打印函数，模仿 MySQL 命令行终端输出海报体 Bye
void sm_bye()；

// 以其中一个函数为例，初始化查询字符串并将接收到的参数利用 sprintf 整合其中
// 进行查询并完成错误处理和结果返回，更详细有针对性的错误信息会在上层调用中进行打印
bool insert_book(string bno, string bname, string bauthor, int bamount, int bsaled, int bprice, string bsupplier, int boffer) {
    char querys[256];
    sprintf(querys, "insert into books(bno,\
                                       bname,\
                                       bauthor,\
                                       bamount,\
                                       bsaled,\
                                       bprice,\
                                       bsupplier,\
                                       boffer) value\
                                       (\"%s\",\"%s\",\"%s\",%d,%d,%d,\"%s\",%d);\
                                       ", bno.c_str(), bname.c_str(), 
                                       bauthor.c_str(), bamount, bsaled,
                                       bprice, bsupplier.c_str(), boffer);
    if (0 == mysql_query(&mysql, querys)) {
        return true;
    }
    sm_error(mysql_error(&mysql));
    return false;
}

bool insert_purchase(string pno, string bno, int pnum, string bsupplier, int boffer);

bool insert_sale(string sno, string bno, int snum);

bool insert_refund(string rno, string bno, int rnum);

// 根据前述数据库物理结构设计中的表格、触发器创建语句完成表格和触发器创建
void init();

// 获取年月日时分秒14位时间戳作为唯一的订单、进货单、退货单标识
// 因为每次功能执行都会挂起一秒，所以不会出现重复情况
string get_time_stamp()；

// 打印图书列表，查询所有图书，按照编号升序排列并调用功能函数完成打印
void book()；

// 进货列表打印，查询进货列表并对图书列表进行join拼接，打印详细进货信息
void stock() ；

// 完成进货操作
// 要求用户输入要进货的书编号、数量、选择供应商和对应报价
// 如果书不存在，即说明是新书进货，要求用户录入完整书籍信息完成插入再进行下一步
// 如果书已经存在，或者已经完成插入，则按照编号和数量对书库、进货单两个表格进行更新
void purchase()；

// 完成销售操作
// 要求用户输入要售卖的书编号、数量
// 判断书库中是否有该书，如果有数量是否足够
// 根据实际情况完成正常销售或是打印错误信息建议管理员进货
void sale()；

// 完成退货操作
// 要求用户输入客户要退货的书编号、数量
// 判断该书是否在书库中，如果有是否售卖出该数量以上的书
// 根据实际情况完成退货或是打印错误信息提醒该书可能不是本店售出
void refund()；


// 根据订单完成时间（即订单号）从新到旧打印销售单
void sale_time()；

// 根据图书热度、受欢迎程度（总销售量）从高到低打印图书销售情况
void sale_ppl()；