import json
from django.shortcuts import render
from django.http import HttpResponse
from .models import Purchase_info,Commodity_info,Goods,Tea_info,Sale_info,Sale_tea,Tea_addition,Finance,Goods_inout,Users
from collections import Counter
from django.db.models import Q
from django.forms.models import model_to_dict
# Create your views here.
# 显示首页
from django.views.decorators.csrf import csrf_exempt
def index(request):
return render(request, 'teamanagement/index.html')
# 显示采购单创建页面
def purchase_create(request):
return render(request, 'teamanagement/purchase_create.html')
# 提交采购单信息
@csrf_exempt
def purchase_input(request):
if request.method == 'POST':
# 订单信息
purchase_data = request.POST.get("purchase_data")
# 表格内信息
table_data = request.POST.get("table_data")
# 将两个进行json序列化
purchase_data = json.loads(purchase_data)
table_data = json.loads(table_data)
# 存入数据库
# 第一种存入方式
# 存入purchase_info数据表
pur = Purchase_info(staff_name=purchase_data['staff_name'],
merchant_name=purchase_data['merchant_name'],
merchant_phone=purchase_data['merchant_phone'],
today=purchase_data['today'],
estimated_time=purchase_data['estimated_time'],
purchase_status='unfinished',
total_price=0.0)
pur.save(force_insert=True)
fin = Finance(time=purchase_data['today'],
staff_name=purchase_data['staff_name'],
mode='purchase',
option_id=pur.id)
fin.save(force_insert=True)
# 第二种存入方式
# uq = {'userquestion': user_question, 'question_time': Time}
#
# Purchase_info.objects.create(**uq)
# 这两者等价
# 存入commodity数据表
# 总价
total_price = 0.0
for data in table_data['data']:
# 存入commodity的采购详情表中
commod = Commodity_info(commodity_name=data[0].strip(),
commodity_specification=data[1].strip(),
commodity_num=data[2].strip(),
commodity_price=data[3].strip(),
purchase=Purchase_info.objects.get(id=pur.id), # 返回新建记录的id
goods=Goods.objects.get(commodity_name=data[0].strip())) # 外键，这个外键需要传入一个对象，而不是一个id
commod.save(force_insert=True)
total_price = total_price + float(data[3].strip()) * int(data[2].strip())
# print(total_price)
# 在这之后存入总额
Purchase_info.objects.filter(id=pur.id).update(total_price=total_price)
# uq = {'commodity_id': table_data['data'][i][0].strip(),
# 'commodity_name': table_data['data'][i][1].strip(),
# 'commodity_specification': table_data['data'][i][2].strip(),
# 'commodity_num': table_data['data'][i][3].strip(),
# 'purchase': pur.id}
#
# Commodity_info.objects.create(**uq)
result = {'result': '存入数据库成功！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 显示采购单信息页面
def purchase_show(request):
# 在显示页面时，请求数据库
purchase_info = Purchase_info.objects.all() # 返回所有的对象
# 因为本次没有使用json传值，而是使用django自己的内置标签，这个东西和jsp与PHP类似，比较方便
return render(request, 'teamanagement/purchase_show.html', {'purchase_info': purchase_info})
# 显示订单详情
def purchase_detail(request, purchase_id):
# 根据purchase_id请求数据库
purchase_detail = Commodity_info.objects.filter(purchase=purchase_id) # 返回该id采购单下面的详细内容
return render(request, 'teamanagement/purchase_detail.html',{'purchase_detail': purchase_detail})
# 删除订单
@csrf_exempt
def purchase_del(request):
if request.method == 'POST':
# 订单信息
purchase_id = request.POST.get("purchase_id")
# print(purchase_id)
# 根据purchase_id删除这一条订单
# 这里可以留一下，只有未确认的订单可以被删除
Purchase_info.objects.get(id=purchase_id).delete() # 删除订单
# Finance 表中的数据也需要删除
# Q对象复杂查询
fin = Finance.objects.filter(Q(id=purchase_id) & Q(mode='purchase')).delete()
print(fin)
result = {'result': '删除采购单成功！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 显示仓库确认收货页面
def warehouse_confirm(request):
# 在显示页面时，请求数据库
purchase_info = Purchase_info.objects.all() # 返回所有的对象
# 因为本次没有使用json传值，而是使用django自己的内置标签，这个东西和jsp与PHP类似，比较方便
return render(request, 'teamanagement/warehouse_confirm.html', {'purchase_info': purchase_info})
@csrf_exempt
# 确认收货
def purchase_confirm(request):
if request.method == 'POST':
# 订单信息
comfirm_id = request.POST.get("comfirm_id")
# print(comfirm_id)
time = Purchase_info.objects.filter(id=comfirm_id).values('today')[0]['today']
staff_name = Purchase_info.objects.filter(id=comfirm_id).values('staff_name')[0]['staff_name']
# 确认进货后在inout表单记录
purchase = Commodity_info.objects.filter(purchase=comfirm_id)
for pur in purchase:
pur_dict = model_to_dict(pur)
# 在仓库确认到货之后才能在仓库增加数额
# 在仓库表中添加数额
num = Goods.objects.filter(id=pur_dict['goods']).values('commodity_num')[0]['commodity_num']
# print(num)
Goods.objects.filter(id=pur_dict['goods']).update(commodity_num=num + pur.commodity_num)
# 货物进出表
inout = Goods_inout(time=time,
staff_name=staff_name,
num=pur.commodity_num,
mode='purchase',
goods=Goods.objects.get(id=pur_dict['goods']))
inout.save(force_insert=True)
# 确认订单
Purchase_info.objects.filter(id=comfirm_id).update(purchase_status='finished')
result = {'result': '仓库确认收货成功！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
@csrf_exempt
# 订单有误
def purchase_wrong(request):
if request.method == 'POST':
# 订单信息
wrong_id = request.POST.get("wrong_id")
Purchase_info.objects.filter(id=wrong_id).update(purchase_status='error')
result = {'result': '确认订单有误！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 仓库进货查看
def warehouse_goodscheck(request):
goods_info = Goods.objects.all() # 返回所有的对象
return render(request, 'teamanagement/warehouse_goodscheck.html', {'goods_info': goods_info})
# 采购品进出记录查询
def warehouse_goodsdetail(request, goods_id):
# 根据goods_id 查询 采购单和销售单
inout_info = Goods_inout.objects.filter(goods=goods_id)
return render(request, 'teamanagement/warehouse_goodsdetail.html', {'inout_info': inout_info})
# 显示销售单创建页面
def sales_create(request):
tea_info = Tea_info.objects.all()
addition_info = Tea_addition.objects.all()
return render(request, 'teamanagement/sales_create.html', {'tea_info': tea_info, 'addition_info': addition_info})
# 买一杯奶茶时的检查程序
@csrf_exempt
def tea_buy(request):
if request.method == 'POST':
'''
这边不仅仅需要处理刚刚添加的这个奶茶
而是要考虑到和之前的奶茶加在一起的用料会不会超过仓库
'''
# 奶茶信息
tea = request.POST.get("tea_info")
tea = json.loads(tea)
# 原先已有的奶茶
table_data = request.POST.get("table_data")
table_data = json.loads(table_data)
'''
这边需要处理几个逻辑
1.获取了奶茶的名字，数量，添加的料。
2.就是要计算仓库内的物品是否够用。（奶茶的名字可以获取到用料 + 加料） * 数量 = 用的材料总数
看看仓库够不够，如果不够报出提示，仓库缺货，无法添加奶茶
3.就是计算总价了，根据奶茶的名字+加料 * 杯数，算出这一次的单价
4.表单尾的总价也要更新
{'tea_name': '椰果奶茶', 'tea_addition': ['椰果', '红豆'], 'tea_num': '1'}
'''
# 获取该奶茶的用料
compos = Tea_info.objects.filter(tea_name=tea['tea_name']).values('tea_composition')[0]['tea_composition']
# 在数据库中，这段是使用.来分割的
composition = compos.split('.')
# 获取辅料
addition = []
for add in tea['tea_addition']:
addition.append(Tea_addition.objects.filter(name=add).values('goods')[0]['goods'])
# 计算之前的表格中的数据
old_composition = []
old_addition = []
old_sum = []
for data in table_data['data']:
# 获取组成原料
old_com = Tea_info.objects.filter(tea_name=data[0].strip()).values('tea_composition')[0]['tea_composition']
old_coms = old_com.split('.')
old_composition = old_composition + old_coms
# 加料
if data[2] != '':
old_adds = data[2].strip().split(',')
for old_add in old_adds:
old_addition.append(Tea_addition.objects.filter(name=old_add).values('goods')[0]['goods'])
old_composition = list(map(int, old_composition))
# 乘上奶茶的数量
old_sum = (old_composition + old_addition) * int(data[1])
#print('原有的'+str(old_sum))
# 计算总价
sum_price = 0
tea_price = Tea_info.objects.filter(tea_name=tea['tea_name']).values('tea_price')[0]['tea_price']
for add in tea['tea_addition']:
adddition_price = Tea_addition.objects.filter(name=add).values('price')[0]['price']
sum_price = sum_price + adddition_price
sum_price = (sum_price + tea_price) * int(tea['tea_num'])
# com 中的字符串转换成数字
composition = list(map(int, composition))
# 将两个数组合并，方便统计
# 算上数量
new_sum = (composition + addition) * int(tea['tea_num'])
#print('新的'+str(new_sum))
sum = new_sum + old_sum
#print('全部的'+str(sum))
# 统计list中元素出现的次数，结果为dict{1: 3, 2: 2, 3: 1}
goods_sum = Counter(sum)
# for i in goods_sum.keys():
# # 还要乘以数量
# goods_sum[i] = goods_sum[i] * int(tea['tea_num'])
#print(goods_sum)
# 使用统计好的用料去仓库中进行对比
# 使用key去对比
# 判断状态的 flag，只有全部的循环结束了，才能进行操作
flag = False
for key in goods_sum.keys():
# 原来的数量
origin_num = Goods.objects.filter(id=key).values('commodity_num')[0]['commodity_num']
# 本次需要的数量
need_num = goods_sum[key]
# 剩余的数量
remain_num = origin_num - need_num
# print(remain_num)
if remain_num >= 0:
flag = True
else:
flag = False
break
# print(flag)
if flag:
result = {'flag': 'true', 'sum_price': sum_price, 'result': '确认订单正确！'}
result_json = json.dumps(result)
else:
result = {'flag': 'false', 'sum_price': sum_price, 'result': '材料不足，已提醒进行采购！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 提交销售单信息
@csrf_exempt
def sales_input(request):
if request.method == 'POST':
# 订单信息
sales_data = request.POST.get("sales_data")
# 表格内信息
table_data = request.POST.get("table_data")
# 将两个进行json序列化
sales_data = json.loads(sales_data)
table_data = json.loads(table_data)
# 数据库操作
sale = Sale_info(today=sales_data['today'],
staff_name=sales_data['staff_name'],
ismember=sales_data['ismember'],
discount=sales_data['discount'],
original_price=float(sales_data['origin_price']),
discount_price=float(sales_data['discount_price'])
)
sale.save(force_insert=True)
fin = Finance(time=sales_data['today'],
staff_name=sales_data['staff_name'],
mode='sales',
option_id=sale.id)
fin.save(force_insert=True)
composition = []
addition = []
for data in table_data['data']:
'''
先获取全部的数据，将数据存入数据表中
在去仓库表中去减去相应的数字
'''
# 存入数据库
tea = Sale_tea(tea=Tea_info.objects.get(tea_name=data[0].strip()),
tea_name=data[0].strip(),
tea_num=data[1].strip(),
tea_temperature=data[2].strip(),
tea_sugar=data[3].strip(),
tea_additional=data[4].strip(),
total_price=float(data[5].strip()),
sale=Sale_info.objects.get(id=sale.id)
)
tea.save(force_insert=True)
# 去仓库中减去对应的数量
# 获取组成原料
com = Tea_info.objects.filter(tea_name=data[0].strip()).values('tea_composition')[0]['tea_composition']
coms = com.split('.')
composition = composition + coms
# 加料
if data[4] != '':
adds = data[4].strip().split(',')
for add in adds:
addition.append(Tea_addition.objects.filter(name=add).values('goods')[0]['goods'])
composition = list(map(int, composition))
# 乘上奶茶的数量
sum = (composition + addition) * int(data[1])
goods_sum = Counter(sum)
for key in goods_sum.keys():
# 原来的数量
origin_num = Goods.objects.filter(id=key).values('commodity_num')[0]['commodity_num']
# 本次需要的数量
need_num = goods_sum[key]
# 剩余的数量
remain_num = origin_num - need_num
# print(remain_num)
# 可以进行实际操作
Goods.objects.filter(id=key).update(commodity_num=remain_num)
# 对物品进出表进行插入
inout = Goods_inout(time=sales_data['today'],
staff_name=sales_data['staff_name'],
mode='sales',
num=need_num,
goods=Goods.objects.get(id=key)
)
inout.save(force_insert=True)
result = {'result': '提交订单正确！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 显示销售单页面
def sales_show(request):
sales_info = Sale_info.objects.all()
return render(request, 'teamanagement/sales_show.html', {'sales_info': sales_info})
# 采购单详细信息
def sales_detail(request, sales_id):
# 根据goods_id 查询 采购单和销售单
sales_info = Sale_tea.objects.filter(sale=sales_id)
return render(request, 'teamanagement/sales_detail.html', {'sales_info': sales_info})
# 销售部的显示
def finance_show(request):
finance_info = Finance.objects.all()
return render(request, 'teamanagement/finance_show.html', {'finance_info': finance_info})
# 登录页面显示
def login_show(request):
return render(request, 'teamanagement/login.html')
# 登陆
@csrf_exempt
def login(request):
if request.method == 'POST':
# 用户名
username = request.POST.get("username")
# 密码
password = request.POST.get("password")
user = Users.objects.get(username=username)
if user.password == password:
result = {'result': '登陆成功！'}
request.session['username'] = user.username
request.session['identity'] = user.identity
else:
result = {'result': '账户或密码错误！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 登出
@csrf_exempt
def logout(request):
if request.method == 'POST':
del request.session['username']
del request.session['identity']
result = {'result': '登出成功！'}
result_json = json.dumps(result)
return HttpResponse(result_json)
# 销售部详细信息
# def finance_detail(request, sales_id):
# # 根据goods_id 查询 采购单和销售单
# sales_info = Sale_tea.objects.filter(sale=sales_id)
#
# return render(request, 'teamanagement/sales_detail.html', {'sales_info': sales_info})
