ccdd6e7306
现象
----
采购管理新建采购申请时粘贴电商商品链接报错。实测该链接 **516 字符**，而
purchase_request.supplier_link 是 varchar(500) —— 超出 16 个字符，
PostgreSQL 直接拒绝（value too long for type character varying(500)）。
★ 为什么用 text 而不是把 500 调大
电商外链（淘宝/1688）普遍带很长的跟踪参数，长度没有稳定上界：本例已 516，
再叠加一轮营销参数就可能破千。任何有限的 varchar(N) 都只是把报错往后推，
而且**截断是静默的** —— 用户只会觉得「链接打不开」。
同 material_base.purchase_link 的处理（那边一开始就用 text）。
附带确认（全部扫描，无需改动）
从数据库层面扫了所有「有长度上限、且列名像 link/url/photo/image/
signature/path」的列：
· purchase_request.supplier_link(500) ← 本次唯一真正有问题的
· sys_menu.path(200)、sys_warehouse_location.full_path(500) 内部生成数据
· stock_adjustment.linked_sku(100)/linked_outbound_no(50) SKU 与单号
用户粘贴外链的列仅此一处。
迁移用 DO 块先判断当前类型，可重复执行；含核对段与回滚段。
验证：把那条 516 字符的真实链接写入再读回，长度一致、内容未截断。
109 lines
5.2 KiB
Python
109 lines
5.2 KiB
Python
import json
|
|
from app.extensions import db, beijing_time
|
|
from datetime import datetime
|
|
|
|
|
|
class PurchaseRequest(db.Model):
|
|
"""
|
|
采购申请表
|
|
"""
|
|
__tablename__ = 'purchase_request'
|
|
|
|
id = db.Column(db.Integer, primary_key=True)
|
|
request_no = db.Column(db.String(100), unique=True, nullable=False, index=True)
|
|
# [新增] 硬关联基础物料表，打通"按单入库"链路
|
|
base_id = db.Column(db.Integer, db.ForeignKey('material_base.id'), index=True, comment='关联基础物料ID')
|
|
name = db.Column(db.String(255), nullable=False, comment='采购名称')
|
|
spec_model = db.Column(db.String(255), comment='规格型号')
|
|
quantity = db.Column(db.Numeric(19, 4), nullable=False, comment='采购数量')
|
|
purchase_date = db.Column(db.Date, nullable=False, comment='采购时间')
|
|
# ★ 用 Text 而非 String(N)：电商外链常带很长的跟踪参数，长度没有稳定上界
|
|
# （实测一条淘宝链接已 516 字符，超过原先的 varchar(500) 直接报错）。
|
|
# 任何有限的 varchar(N) 都只是把报错往后推，且**截断是静默的** ——
|
|
# 用户只会觉得「链接打不开」。同 material_base.purchase_link 的处理。
|
|
# DDL 见 db_migrations/phase10_purchase_supplier_link_text.sql
|
|
supplier_link = db.Column(db.Text, comment='商家地址链接')
|
|
remark = db.Column(db.Text, comment='备注信息')
|
|
images = db.Column(db.Text, comment='图片列表JSON')
|
|
unit_price = db.Column(db.Numeric(19, 4), default=0, comment='不含税单价')
|
|
total_price = db.Column(db.Numeric(19, 4), default=0, comment='不含税总价')
|
|
tax_rate = db.Column(db.Numeric(5, 2), default=0, comment='税率')
|
|
status = db.Column(db.Integer, default=0, nullable=False)
|
|
requester_id = db.Column(db.Integer, nullable=False, index=True)
|
|
approver_id = db.Column(db.Integer, index=True)
|
|
# [新增] 反向关联：该采购申请对应的入库记录
|
|
stock_buys = db.relationship('StockBuy', back_populates='purchase_request', lazy='dynamic')
|
|
approved_at = db.Column(db.DateTime)
|
|
reject_reason = db.Column(db.Text)
|
|
created_at = db.Column(db.DateTime, default=beijing_time, nullable=False)
|
|
updated_at = db.Column(db.DateTime, default=beijing_time, onupdate=beijing_time, nullable=False)
|
|
|
|
def _safe_parse_json(self, value):
|
|
if value is None:
|
|
return []
|
|
if isinstance(value, (list, dict)):
|
|
return value
|
|
if isinstance(value, str):
|
|
val = value.strip()
|
|
if not val:
|
|
return []
|
|
try:
|
|
parsed = json.loads(val)
|
|
return parsed if isinstance(parsed, list) else []
|
|
except Exception:
|
|
return []
|
|
return []
|
|
|
|
def get_images(self):
|
|
return self._safe_parse_json(self.images)
|
|
|
|
def set_images(self, image_list):
|
|
self.images = json.dumps(image_list, ensure_ascii=False) if image_list else '[]'
|
|
|
|
def _get_user_name(self, user_id):
|
|
if not user_id:
|
|
return ""
|
|
from app.models.system import SysUser
|
|
try:
|
|
user = db.session.get(SysUser, user_id)
|
|
return user.username if user else f"未知用户({user_id})"
|
|
except Exception:
|
|
return f"用户({user_id})"
|
|
|
|
def _get_user_email(self, user_id):
|
|
if not user_id:
|
|
return ""
|
|
from app.models.system import SysUser
|
|
try:
|
|
user = db.session.get(SysUser, user_id)
|
|
return user.email or "" if user else ""
|
|
except Exception:
|
|
return ""
|
|
|
|
def to_dict(self):
|
|
return {
|
|
'id': self.id,
|
|
'request_no': self.request_no,
|
|
'base_id': self.base_id,
|
|
'name': self.name,
|
|
'spec_model': self.spec_model or '',
|
|
'quantity': float(self.quantity) if self.quantity else 0,
|
|
'purchase_date': self.purchase_date.strftime('%Y-%m-%d') if self.purchase_date else None,
|
|
'supplier_link': self.supplier_link or '',
|
|
'remark': self.remark or '',
|
|
'images': self.get_images(),
|
|
'unit_price': float(self.unit_price) if self.unit_price else 0,
|
|
'total_price': float(self.total_price) if self.total_price else 0,
|
|
'tax_rate': float(self.tax_rate) if self.tax_rate else 0,
|
|
'status': self.status,
|
|
'status_text': ['待审批', '已通过', '已驳回', '已完成', '已完结'][self.status] if self.status in [0, 1, 2, 3, 4] else '未知',
|
|
'requester_id': self.requester_id,
|
|
'requester_name': self._get_user_name(self.requester_id),
|
|
'requester_email': self._get_user_email(self.requester_id),
|
|
'approver_id': self.approver_id,
|
|
'approver_name': self._get_user_name(self.approver_id) if self.approver_id else None,
|
|
'approved_at': self.approved_at.strftime('%Y-%m-%d %H:%M:%S') if self.approved_at else None,
|
|
'reject_reason': self.reject_reason or '',
|
|
'created_at': self.created_at.strftime('%Y-%m-%d %H:%M:%S') if self.created_at else None,
|
|
'updated_at': self.updated_at.strftime('%Y-%m-%d %H:%M:%S') if self.updated_at else None,
|
|
} |