duxingchen/KCGL
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

成品图像上传初实现，支持多图，检测报告的图片以及链接上传

Browse Source
This commit is contained in:
dxc
2026-02-03 13:20:17 +08:00
parent d084bd29dd
commit 3257973820
3 changed files with 516 additions and 420 deletions
Download Patch File Download Diff File Expand all files Collapse all files

77
inventory-backend/app/services/inbound/product_service.py
View File

@ -1,10 +1,10 @@
# app/services/inbound/product_service.py
from app.extensions import db
from app.models.base import MaterialBase
from app.models.inbound.product import StockProduct
from datetime import datetime
from sqlalchemy import or_, func, text
import traceback
import json
class ProductInboundService:
@ -12,7 +12,6 @@ class ProductInboundService:
def search_base_material(keyword):
try:
if not keyword:
# 如果没有关键词，返回最新的20条
query = MaterialBase.query.filter(MaterialBase.is_enabled == True).order_by(
MaterialBase.id.desc()).limit(20)
else:
@ -34,6 +33,8 @@ class ProductInboundService:
@staticmethod
def handle_inbound(data):
from app.models.inbound.product import StockProduct
try:
base_id = data.get('base_id')
if not base_id: raise ValueError("必须选择基础物料")
@ -43,45 +44,39 @@ class ProductInboundService:
in_date_val = datetime.utcnow().date()
if data.get('in_date'):
try:
# 兼容字符串格式日期处理
date_str = str(data['in_date'])
if len(date_str) > 10:
date_str = date_str[:10]
if len(date_str) > 10: date_str = date_str[:10]
in_date_val = datetime.strptime(date_str, '%Y-%m-%d').date()
except:
pass
in_qty = float(data.get('in_quantity') or 0)
# 处理生产时间范围
p_start = data.get('production_start_time', '')
p_end = data.get('production_end_time', '')
time_range = f"{p_start} ~ {p_end}" if p_start or p_end else None
# ------------------------------------------------------------------
# 1. 获取全局打印流水号 (跨表唯一，用于打印逻辑)
# ------------------------------------------------------------------
# 全局流水号
seq_sql = text("SELECT nextval('global_print_seq')")
result = db.session.execute(seq_sql)
next_global_id = result.scalar()
# ------------------------------------------------------------------
# 2. 自动生成 SKU (格式: 10位数字，补零)
# ------------------------------------------------------------------
generated_sku = str(next_global_id).zfill(10)
final_barcode = data.get('barcode') or generated_sku
# ------------------------------------------------------------------
# 3. 条码逻辑处理
# 如果前端没传条码，则默认使用 SKU 作为条码
# ------------------------------------------------------------------
final_barcode = data.get('barcode')
if not final_barcode:
final_barcode = generated_sku
# [核心修改] 处理三个图片/链接列表
photo_list = data.get('product_photo', [])
quality_list = data.get('quality_report_link', [])
inspection_list = data.get('inspection_report_link', [])
if not isinstance(photo_list, list): photo_list = []
if not isinstance(quality_list, list): quality_list = []
if not isinstance(inspection_list, list): inspection_list = []
new_stock = StockProduct(
base_id=material.id,
global_print_id=next_global_id, # 新增全局打印ID
sku=generated_sku, # 使用自动生成的SKU
global_print_id=next_global_id,
sku=generated_sku,
production_date=in_date_val,
barcode=final_barcode,
serial_number=data.get('serial_number'),
@ -103,18 +98,21 @@ class ProductInboundService:
manual_cost=float(data.get('manual_cost') or 0),
quality_status=data.get('quality_status', '合格'),
quality_report_link=data.get('quality_report_link'),
# 存为 JSON
product_photo=json.dumps(photo_list),
quality_report_link=json.dumps(quality_list),
inspection_report_link=json.dumps(inspection_list),
detail_link=data.get('detail_link'),
remark=data.get('remark'),
sale_price=float(data.get('sale_price') or 0),
inspection_report_link=data.get('inspection_report_link'),
order_id=data.get('order_id')
)
db.session.add(new_stock)
db.session.commit()
# 返回对象实例以便上层调用 to_dict()
return new_stock
except Exception as e:
db.session.rollback()
@ -122,26 +120,38 @@ class ProductInboundService:
@staticmethod
def update_inbound(stock_id, data):
from app.models.inbound.product import StockProduct
try:
stock = StockProduct.query.get(stock_id)
if not stock: raise ValueError("记录不存在")
# 允许更新的字段列表
fields = [
'barcode', 'serial_number', 'warehouse_location',
'status', 'quality_status', 'bom_code', 'bom_version',
'work_order_code', 'production_manager', 'quality_report_link',
'detail_link', 'inspection_report_link', 'order_id'
'work_order_code', 'production_manager',
'detail_link', 'order_id', 'remark'
]
for f in fields:
if f in data: setattr(stock, f, data[f])
# 数值类型处理
# [核心修改] 更新 JSON 字段
if 'product_photo' in data:
imgs = data['product_photo']
if isinstance(imgs, list): stock.product_photo = json.dumps(imgs)
if 'quality_report_link' in data:
imgs = data['quality_report_link']
if isinstance(imgs, list): stock.quality_report_link = json.dumps(imgs)
if 'inspection_report_link' in data:
imgs = data['inspection_report_link']
if isinstance(imgs, list): stock.inspection_report_link = json.dumps(imgs)
if 'sale_price' in data: stock.sale_price = float(data['sale_price'])
if 'raw_material_cost' in data: stock.raw_material_cost = float(data['raw_material_cost'])
if 'manual_cost' in data: stock.manual_cost = float(data['manual_cost'])
# 数量更新逻辑 (同步更新库存和可用量)
if 'in_quantity' in data:
new_qty = float(data['in_quantity'])
old_qty = float(stock.in_quantity)
@ -151,14 +161,11 @@ class ProductInboundService:
stock.stock_quantity = float(stock.stock_quantity) + diff
stock.available_quantity = float(stock.available_quantity) + diff
# 时间范围处理
if 'production_start_time' in data or 'production_end_time' in data:
old_range = stock.production_time_range or " ~ "
parts = old_range.split(' ~ ')
# 获取原值防止越界
old_start = parts[0] if len(parts) > 0 else ''
old_end = parts[1] if len(parts) > 1 else ''
start = data.get('production_start_time', old_start)
end = data.get('production_end_time', old_end)
stock.production_time_range = f"{start} ~ {end}"
@ -171,6 +178,7 @@ class ProductInboundService:
@staticmethod
def delete_inbound(stock_id):
from app.models.inbound.product import StockProduct
try:
stock = StockProduct.query.get(stock_id)
if stock:
@ -183,8 +191,8 @@ class ProductInboundService:
@staticmethod
def get_list(page, limit, keyword=None):
from app.models.inbound.product import StockProduct
try:
# 联表查询
query = db.session.query(StockProduct).outerjoin(MaterialBase, StockProduct.base_id == MaterialBase.id)
if keyword:
@ -199,7 +207,6 @@ class ProductInboundService:
pagination = query.order_by(StockProduct.id.desc()).paginate(page=page, per_page=limit, error_out=False)
# 计算聚合库存
current_items = pagination.items
base_ids = list(set([i.base_id for i in current_items]))
stock_map = {}