docs(architecture): allow internal raw evidence screenshots

merge: T-103 observed price prefix
fix(client): bind T-103 observed price prefix
2026-08-04 15:47:47 +08:00 · 2026-08-04 15:23:10 +08:00 · 2026-08-04 15:23:02 +08:00 · 2026-08-04 15:16:44 +08:00 · 2026-08-04 15:16:30 +08:00
20 changed files with 221 additions and 1198 deletions
@@ -8,7 +8,6 @@
 | `CMBUYER_ADMIN_PASSWORD_BCRYPT` | 非空 bcrypt 密码哈希，不接受明文密码。 |
 | `CMBUYER_SESSION_SECRET` | 至少 32 字节的会话签名密钥。 |
 | `CMBUYER_COOKIE_SECURE` | 可选；存在时只能精确为 `true` 或 `false`。HTTPS 部署应设为 `true`。 |
-| `CMBUYER_DATABASE_SOURCE` | 已迁移 SQLite 的显式 data source。 |

 示例仅展示变量名，不提供可运行凭据：

@@ -17,8 +16,6 @@ $env:CMBUYER_ADMIN_USERNAME = '<管理员账号>'
 $env:CMBUYER_ADMIN_PASSWORD_BCRYPT = '<bcrypt 密码哈希>'
 $env:CMBUYER_SESSION_SECRET = '<至少 32 字节的随机密钥>'
 $env:CMBUYER_COOKIE_SECURE = 'true'
-$env:CMBUYER_DATABASE_SOURCE = '<SQLite data source>'
-go run ./cmd/migrate -database $env:CMBUYER_DATABASE_SOURCE up
 go run ./cmd/server
 ```

@@ -8,8 +8,6 @@ import (
 	"cmbuyer/admin/internal/auth"
 	"cmbuyer/admin/internal/config"
 	"cmbuyer/admin/internal/server"
-	"cmbuyer/admin/internal/storage/sqlite"
-	"cmbuyer/admin/internal/tasks"
 )

 const listenAddress = ":8080"
@@ -25,21 +23,11 @@ func run() error {
 	if err != nil {
 		return err
 	}
-	database, err := sqlite.Open(configuration.DatabaseSource)
-	if err != nil {
-		return err
-	}
-	defer database.Close()
-	taskStore, err := tasks.NewSQLiteStore(database)
-	if err != nil {
-		return err
-	}

 	router, err := server.NewRouter(server.Options{
 		AdminUsername:       configuration.AdminUsername,
 		AdminPasswordBcrypt: configuration.AdminPasswordBcrypt,
 		Sessions:            auth.NewManager(configuration.SessionSecret, configuration.CookieSecure),
-		Tasks:               taskStore,
 	})
 	if err != nil {
 		return err
@@ -15,7 +15,6 @@ const (
 	adminPasswordBcryptEnv = "CMBUYER_ADMIN_PASSWORD_BCRYPT"
 	sessionSecretEnv       = "CMBUYER_SESSION_SECRET"
 	cookieSecureEnv        = "CMBUYER_COOKIE_SECURE"
-	databaseSourceEnv      = "CMBUYER_DATABASE_SOURCE"
 	minimumSecretLength    = 32
 )

@@ -25,7 +24,6 @@ type Config struct {
 	AdminPasswordBcrypt string
 	SessionSecret       []byte
 	CookieSecure        bool
-	DatabaseSource      string
 }

 // LoadFromEnv 从进程环境读取配置。错误只指出缺失或非法的变量名，绝不回显秘密。
@@ -67,17 +65,12 @@ func Load(lookup func(string) (string, bool)) (Config, error) {
 			return Config{}, fmt.Errorf("%s must be exactly true or false", cookieSecureEnv)
 		}
 	}
-	databaseSource, err := required(lookup, databaseSourceEnv)
-	if err != nil {
-		return Config{}, err
-	}

 	return Config{
 		AdminUsername:       username,
 		AdminPasswordBcrypt: passwordHash,
 		SessionSecret:       []byte(secret),
 		CookieSecure:        cookieSecure,
-		DatabaseSource:      databaseSource,
 	}, nil
 }

@@ -20,7 +20,6 @@ func TestLoad(t *testing.T) {
 		"CMBUYER_ADMIN_PASSWORD_BCRYPT": string(hash),
 		"CMBUYER_SESSION_SECRET":        strings.Repeat("s", 32),
 		"CMBUYER_COOKIE_SECURE":         "true",
-		"CMBUYER_DATABASE_SOURCE":       ":memory:",
 	}

 	got, err := config.Load(lookup(values))
@@ -42,7 +41,6 @@ func TestLoadRejectsMissingOrInvalidConfiguration(t *testing.T) {
 		"CMBUYER_ADMIN_USERNAME":        "admin",
 		"CMBUYER_ADMIN_PASSWORD_BCRYPT": string(hash),
 		"CMBUYER_SESSION_SECRET":        strings.Repeat("s", 32),
-		"CMBUYER_DATABASE_SOURCE":       ":memory:",
 	}

 	tests := []struct {
@@ -54,7 +52,6 @@ func TestLoadRejectsMissingOrInvalidConfiguration(t *testing.T) {
 		{"invalid bcrypt", func(values map[string]string) { values["CMBUYER_ADMIN_PASSWORD_BCRYPT"] = "not-a-bcrypt-hash" }, "CMBUYER_ADMIN_PASSWORD_BCRYPT"},
 		{"short secret", func(values map[string]string) { values["CMBUYER_SESSION_SECRET"] = "short" }, "CMBUYER_SESSION_SECRET"},
 		{"invalid secure flag", func(values map[string]string) { values["CMBUYER_COOKIE_SECURE"] = "1" }, "CMBUYER_COOKIE_SECURE"},
-		{"missing database", func(values map[string]string) { delete(values, "CMBUYER_DATABASE_SOURCE") }, "CMBUYER_DATABASE_SOURCE"},
 	}

 	for _, test := range tests {
@@ -9,7 +9,6 @@ import (
 	"strings"

 	"cmbuyer/admin/internal/auth"
-	"cmbuyer/admin/internal/tasks"
 	"cmbuyer/admin/internal/transport/webui"

 	"github.com/gin-gonic/gin"
@@ -23,12 +22,11 @@ type Options struct {
 	AdminUsername       string
 	AdminPasswordBcrypt string
 	Sessions            *auth.Manager
-	Tasks               tasks.Store
 }

 // NewRouter 返回当前服务范围内的完整 HTTP 路由。
 func NewRouter(options Options) (*gin.Engine, error) {
-	if options.AdminUsername == "" || options.AdminPasswordBcrypt == "" || options.Sessions == nil || options.Tasks == nil {
+	if options.AdminUsername == "" || options.AdminPasswordBcrypt == "" || options.Sessions == nil {
 		return nil, errors.New("server authentication options are incomplete")
 	}

@@ -40,8 +38,6 @@ func NewRouter(options Options) (*gin.Engine, error) {
 	router.POST("/login", login(options))
 	router.POST("/logout", logout(options))
 	router.GET("/tasks", tasksPage(options))
-	router.GET("/tasks/new", newTaskPage(options))
-	router.POST("/tasks", createTask(options))

 	return router, nil
 }
@@ -74,14 +70,11 @@ func loginPage(options Options) gin.HandlerFunc {

 func login(options Options) gin.HandlerFunc {
 	return func(context *gin.Context) {
-		if !parseForm(context) {
-			return
-		}
-		form := context.Request.PostForm
-		csrfToken := form.Get("csrf_token")
-		returnPath := returnTo(form.Get("return_to"))
-		username := form.Get("username")
-		password := form.Get("password")
+		limitFormBody(context)
+		csrfToken := context.PostForm("csrf_token")
+		returnPath := returnTo(context.PostForm("return_to"))
+		username := context.PostForm("username")
+		password := context.PostForm("password")

 		if _, ok := options.Sessions.VerifyCSRF(context.Request, csrfToken); !ok {
 			newCSRF, _ := options.Sessions.Ensure(context.Writer, context.Request)
@@ -104,10 +97,8 @@ func login(options Options) gin.HandlerFunc {

 func logout(options Options) gin.HandlerFunc {
 	return func(context *gin.Context) {
-		if !parseForm(context) {
-			return
-		}
-		authenticated, ok := options.Sessions.VerifyCSRF(context.Request, context.Request.PostForm.Get("csrf_token"))
+		limitFormBody(context)
+		authenticated, ok := options.Sessions.VerifyCSRF(context.Request, context.PostForm("csrf_token"))
 		if !ok || !authenticated {
 			context.Status(http.StatusForbidden)
 			return
@@ -126,113 +117,12 @@ func tasksPage(options Options) gin.HandlerFunc {
 			return
 		}

-		drafts, err := options.Tasks.ListDrafts(context.Request.Context())
-		if err != nil {
-			context.Status(http.StatusInternalServerError)
-			return
-		}
-		data := webui.TasksData{CSRFToken: csrfToken, Drafts: drafts}
-		for _, draft := range drafts {
-			if draft.ID == context.Query("created") {
-				data.Success = true
-				break
-			}
-		}
-		if context.Query("create") == "1" {
-			form, err := newTaskForm()
-			if err != nil {
-				context.Status(http.StatusInternalServerError)
-				return
-			}
-			data.OpenForm = true
-			data.Form = form
-			data.FocusField = "title"
-		}
-		renderTasks(context, http.StatusOK, data)
-	}
-}
-
-func newTaskPage(options Options) gin.HandlerFunc {
-	return func(context *gin.Context) {
-		csrf, authenticated := options.Sessions.Ensure(context.Writer, context.Request)
-		if !authenticated {
-			context.Redirect(http.StatusSeeOther, "/login?return_to=%2Ftasks%2Fnew")
-			return
-		}
-		form, err := newTaskForm()
-		if err != nil {
-			context.Status(http.StatusInternalServerError)
-			return
-		}
-		renderTasks(context, http.StatusOK, webui.TasksData{CSRFToken: csrf, Form: form, FullPage: true, FocusField: "title"})
-	}
-}
-func createTask(options Options) gin.HandlerFunc {
-	return func(context *gin.Context) {
-		if !parseForm(context) {
-			return
-		}
-		requestForm := context.Request.PostForm
-		authenticated, csrfOK := options.Sessions.VerifyCSRF(context.Request, requestForm.Get("csrf_token"))
-		if !csrfOK || !authenticated {
-			context.Status(http.StatusForbidden)
-			return
-		}
-		form := taskForm(requestForm)
-		draft, validation := tasks.Validate(form)
-		if draft.GoodsID != "" {
-			form.ProductURL = tasks.CanonicalURL(draft.GoodsID)
-		}
-		fullPage := requestForm.Get("form_mode") == "full"
-		if !validation.Valid() {
-			drafts, err := options.Tasks.ListDrafts(context.Request.Context())
-			if err != nil {
-				context.Status(http.StatusInternalServerError)
-				return
-			}
-			renderTasks(context, http.StatusBadRequest, webui.TasksData{CSRFToken: csrfFor(context, options), Drafts: drafts, Form: form, Errors: validation, OpenForm: !fullPage, FullPage: fullPage, FocusField: firstError(validation)})
-			return
-		}
-		created, err := options.Tasks.CreateDraft(context.Request.Context(), draft)
-		if err != nil {
-			if errors.Is(err, tasks.ErrCreateKeyConflict) {
-				validation["create_key"] = "该创建请求已用于另一条任务，请重新打开表单。"
-				drafts, listErr := options.Tasks.ListDrafts(context.Request.Context())
-				if listErr != nil {
-					context.Status(http.StatusInternalServerError)
-					return
-				}
-				renderTasks(context, http.StatusConflict, webui.TasksData{CSRFToken: csrfFor(context, options), Drafts: drafts, Form: form, Errors: validation, OpenForm: !fullPage, FullPage: fullPage, FocusField: firstError(validation)})
-				return
-			}
-			context.Status(http.StatusInternalServerError)
-			return
-		}
-		context.Redirect(http.StatusSeeOther, "/tasks?created="+url.QueryEscape(created.ID))
-	}
-}
-
-func newTaskForm() (tasks.Form, error) {
-	key, err := tasks.NewCreateKey()
-	if err != nil {
-		return tasks.Form{}, err
-	}
-	return tasks.Form{CreateKey: key}, nil
-}
-func taskForm(form url.Values) tasks.Form {
-	return tasks.Form{CreateKey: form.Get("create_key"), Title: form.Get("title"), ProductURL: form.Get("product_url"), SKUColor: form.Get("sku_color"), SKUSize: form.Get("sku_size"), Quantity: form.Get("quantity"), MaxTotalPrice: form.Get("max_total_price")}
-}
-func csrfFor(context *gin.Context, options Options) string {
-	csrf, _ := options.Sessions.Ensure(context.Writer, context.Request)
-	return csrf
-}
-func renderTasks(context *gin.Context, status int, data webui.TasksData) {
 		context.Header("Content-Type", "text/html; charset=utf-8")
-	context.Status(status)
-	if err := webui.RenderTasks(context.Writer, data); err != nil {
+		if err := webui.RenderTasks(context.Writer, webui.TasksData{CSRFToken: csrfToken}); err != nil {
 			_ = context.Error(err)
 		}
 	}
+}

 func renderLogin(context *gin.Context, status int, csrfToken, returnPath, username, message string) {
 	context.Header("Content-Type", "text/html; charset=utf-8")
@@ -247,27 +137,8 @@ func renderLogin(context *gin.Context, status int, csrfToken, returnPath, userna
 	}
 }

-func parseForm(context *gin.Context) bool {
+func limitFormBody(context *gin.Context) {
 	context.Request.Body = http.MaxBytesReader(context.Writer, context.Request.Body, maxFormBytes)
-	if err := context.Request.ParseForm(); err != nil {
-		var tooLarge *http.MaxBytesError
-		if errors.As(err, &tooLarge) {
-			context.Status(http.StatusRequestEntityTooLarge)
-		} else {
-			context.Status(http.StatusBadRequest)
-		}
-		return false
-	}
-	return true
-}
-
-func firstError(validation tasks.Errors) string {
-	for _, field := range []string{"title", "product_url", "sku_color", "sku_size", "quantity", "max_total_price"} {
-		if _, ok := validation[field]; ok {
-			return field
-		}
-	}
-	return "title"
 }

 func returnTo(value string) string {
@@ -1,7 +1,6 @@
 package server_test

 import (
-	"context"
 	"net/http"
 	"net/http/httptest"
 	"net/url"
@@ -11,14 +10,12 @@ import (

 	"cmbuyer/admin/internal/auth"
 	"cmbuyer/admin/internal/server"
-	"cmbuyer/admin/internal/tasks"

 	"github.com/gin-gonic/gin"
 	"golang.org/x/crypto/bcrypt"
 )

 var csrfPattern = regexp.MustCompile(`name="csrf_token" value="([^"]+)"`)
-var createKeyPattern = regexp.MustCompile(`name="create_key" value="([^"]+)"`)

 func TestHealthzIsPublic(t *testing.T) {
 	router, _ := newRouter(t)
@@ -178,149 +175,6 @@ func TestTamperedCookieCannotAccessTasks(t *testing.T) {

 }

-func TestTaskCreationRendersSharedFormsAndPersistsOnlyDraft(t *testing.T) {
-	router, _ := newRouter(t)
-	cookie := authenticate(t, router)
-
-	modal := serve(router, http.MethodGet, "/tasks?create=1", nil, cookie)
-	if modal.Code != http.StatusOK {
-		t.Fatalf("GET dialog form status = %d, want 200", modal.Code)
-	}
-	fullPage := serve(router, http.MethodGet, "/tasks/new", nil, cookie)
-	if fullPage.Code != http.StatusOK {
-		t.Fatalf("GET full form status = %d, want 200", fullPage.Code)
-	}
-	for _, want := range []string{`<div class="modal-scrim"`, `<dialog open`, `aria-modal="true"`, `name="title"`, `name="product_url"`, `name="sku_color"`, `name="sku_size"`, `name="quantity"`, `name="max_total_price"`, `type="url" inputmode="url" maxlength="2048"`, `type="number" inputmode="numeric" min="1" step="1"`, `inputmode="decimal" pattern="[0-9]+(\.[0-9]{1,2})?"`, `maxlength="120"`, `maxlength="80"`, `required`, `autofocus`, `导入</button><a class="button primary"`, `type="search" disabled`, `disabled>筛选</button>`, `disabled>清除</button>`, `min-height:44px`, `overflow-x:auto`, `prefers-reduced-motion`} {
-		if !strings.Contains(modal.Body.String(), want) {
-			t.Fatalf("dialog form is missing %q", want)
-		}
-	}
-	for _, want := range []string{`name="title"`, `name="product_url"`, `name="sku_color"`, `name="sku_size"`, `name="quantity"`, `name="max_total_price"`, `name="form_mode" value="full"`} {
-		if !strings.Contains(fullPage.Body.String(), want) {
-			t.Fatalf("full-page form is missing %q", want)
-		}
-	}
-
-	invalid := serve(router, http.MethodPost, "/tasks", url.Values{
-		"csrf_token":      {csrfToken(t, modal.Body.String())},
-		"create_key":      {createKey(t, modal.Body.String())},
-		"title":           {`<script>alert(1)</script>`},
-		"product_url":     {"https://mobile.yangkeduo.com/goods.html?goods_id=937122477375&uin=discard"},
-		"sku_color":       {"black"},
-		"sku_size":        {"M"},
-		"quantity":        {"0"},
-		"max_total_price": {"12.80"},
-		"form_mode":       {"dialog"},
-	}, cookie)
-	if invalid.Code != http.StatusBadRequest || !strings.Contains(invalid.Body.String(), `<dialog open`) || !strings.Contains(invalid.Body.String(), "数量必须是正整数") || !strings.Contains(invalid.Body.String(), `role="alert"`) || !strings.Contains(invalid.Body.String(), `href="#quantity"`) || !strings.Contains(invalid.Body.String(), `aria-describedby="quantity-error"`) || !strings.Contains(invalid.Body.String(), `autofocus`) {
-		t.Fatalf("invalid create = (%d, %q), want dialog validation response", invalid.Code, invalid.Body.String())
-	}
-	if strings.Contains(invalid.Body.String(), `<script>alert(1)</script>`) || !strings.Contains(invalid.Body.String(), `&lt;script&gt;alert(1)&lt;/script&gt;`) {
-		t.Fatalf("invalid create did not safely preserve title: %q", invalid.Body.String())
-	}
-	if strings.Contains(invalid.Body.String(), "uin=discard") || !strings.Contains(invalid.Body.String(), `value="https://mobile.yangkeduo.com/goods.html?goods_id=937122477375"`) {
-		t.Fatalf("invalid create did not canonicalize product URL: %q", invalid.Body.String())
-	}
-
-	createPage := serve(router, http.MethodGet, "/tasks?create=1", nil, cookie)
-	key := createKey(t, createPage.Body.String())
-	created := serve(router, http.MethodPost, "/tasks", url.Values{
-		"csrf_token":      {csrfToken(t, createPage.Body.String())},
-		"create_key":      {key},
-		"title":           {"<b>夏季上衣</b>"},
-		"product_url":     {"https://mobile.yangkeduo.com/goods.html?goods_id=937122477375&utm_source=discard"},
-		"sku_color":       {"black"},
-		"sku_size":        {"M"},
-		"quantity":        {"2"},
-		"max_total_price": {"12.8"},
-		"form_mode":       {"dialog"},
-	}, cookie)
-	if created.Code != http.StatusSeeOther || !strings.HasPrefix(created.Header().Get("Location"), "/tasks?created=") {
-		t.Fatalf("valid create = (%d, %q), want 303 to a created-task acknowledgement", created.Code, created.Header().Get("Location"))
-	}
-	replay := serve(router, http.MethodPost, "/tasks", url.Values{
-		"csrf_token":      {csrfToken(t, createPage.Body.String())},
-		"create_key":      {key},
-		"title":           {"<b>夏季上衣</b>"},
-		"product_url":     {"https://mobile.yangkeduo.com/goods.html?goods_id=937122477375&utm_source=discard"},
-		"sku_color":       {"black"},
-		"sku_size":        {"M"},
-		"quantity":        {"2"},
-		"max_total_price": {"12.8"},
-		"form_mode":       {"dialog"},
-	}, cookie)
-	if replay.Code != http.StatusSeeOther {
-		t.Fatalf("idempotent replay status = %d, want 303", replay.Code)
-	}
-	conflict := serve(router, http.MethodPost, "/tasks", url.Values{
-		"csrf_token":      {csrfToken(t, createPage.Body.String())},
-		"create_key":      {key},
-		"title":           {"different task"},
-		"product_url":     {"https://mobile.yangkeduo.com/goods.html?goods_id=937122477375"},
-		"sku_color":       {"black"},
-		"sku_size":        {"M"},
-		"quantity":        {"2"},
-		"max_total_price": {"12.80"},
-		"form_mode":       {"dialog"},
-	}, cookie)
-	if conflict.Code != http.StatusConflict || !strings.Contains(conflict.Body.String(), "该创建请求已用于另一条任务") {
-		t.Fatalf("conflicting create = (%d, %q), want a 409 form error", conflict.Code, conflict.Body.String())
-	}
-
-	list := serve(router, http.MethodGet, created.Header().Get("Location"), nil, cookie)
-	if list.Code != http.StatusOK {
-		t.Fatalf("GET /tasks status = %d, want 200", list.Code)
-	}
-	body := list.Body.String()
-	for _, want := range []string{`任务已创建，已显示在列表首行。`, `&lt;b&gt;夏季上衣&lt;/b&gt;`, `https://mobile.yangkeduo.com/goods.html?goods_id=937122477375`, `target="_blank"`, `rel="noopener noreferrer"`, `¥12.80`, `待开始`, `选择全部任务`, `选择任务`} {
-		if !strings.Contains(body, want) {
-			t.Fatalf("task list is missing %q", want)
-		}
-	}
-	for _, forbidden := range []string{"utm_source", "试选", "PENDING", "支付", "订单确认", "真机", "提交订单"} {
-		if strings.Contains(body, forbidden) {
-			t.Fatalf("task list exposed deferred scope %q", forbidden)
-		}
-	}
-}
-
-func TestTaskCreationRequiresAuthenticationAndCSRF(t *testing.T) {
-	router, _ := newRouter(t)
-	if response := serve(router, http.MethodPost, "/tasks", url.Values{}, nil); response.Code != http.StatusForbidden {
-		t.Fatalf("anonymous POST /tasks = %d, want 403", response.Code)
-	}
-	cookie := authenticate(t, router)
-	if response := serve(router, http.MethodPost, "/tasks", url.Values{}, cookie); response.Code != http.StatusForbidden {
-		t.Fatalf("POST /tasks without CSRF = %d, want 403", response.Code)
-	}
-}
-
-func TestTaskCreationFailsClosedForMalformedOrOversizedForms(t *testing.T) {
-	router, _ := newRouter(t)
-	cookie := authenticate(t, router)
-	page := serve(router, http.MethodGet, "/tasks?create=1", nil, cookie)
-	base := url.Values{
-		"csrf_token":      {csrfToken(t, page.Body.String())},
-		"create_key":      {createKey(t, page.Body.String())},
-		"title":           {"title"},
-		"product_url":     {"https://mobile.yangkeduo.com/goods.html?goods_id=1;uin=malformed"},
-		"sku_color":       {"black"},
-		"sku_size":        {"M"},
-		"quantity":        {"1"},
-		"max_total_price": {"1.00"},
-		"form_mode":       {"dialog"},
-	}
-	malformed := serve(router, http.MethodPost, "/tasks", base, cookie)
-	if malformed.Code != http.StatusBadRequest || !strings.Contains(malformed.Body.String(), "canonical 商品链接") {
-		t.Fatalf("malformed URL create = (%d, %q), want validation failure", malformed.Code, malformed.Body.String())
-	}
-
-	oversized := url.Values{"csrf_token": {csrfToken(t, page.Body.String())}, "title": {strings.Repeat("x", 9<<10)}}
-	if response := serve(router, http.MethodPost, "/tasks", oversized, cookie); response.Code != http.StatusRequestEntityTooLarge {
-		t.Fatalf("oversized form status = %d, want 413", response.Code)
-	}
-}
-
 func assertSecurityHeaders(t *testing.T, response *httptest.ResponseRecorder) {
 	t.Helper()
 	want := map[string]string{
@@ -392,7 +246,6 @@ func newRouter(t *testing.T) (*gin.Engine, *auth.Manager) {
 		AdminUsername:       "admin",
 		AdminPasswordBcrypt: string(hash),
 		Sessions:            manager,
-		Tasks:               &memoryStore{},
 	})
 	if err != nil {
 		t.Fatalf("NewRouter: %v", err)
@@ -400,24 +253,6 @@ func newRouter(t *testing.T) (*gin.Engine, *auth.Manager) {
 	return router, manager
 }

-type memoryStore struct{ drafts []tasks.Draft }
-
-func (store *memoryStore) CreateDraft(_ context.Context, draft tasks.Draft) (tasks.Draft, error) {
-	for _, existing := range store.drafts {
-		if existing.ID == draft.ID {
-			if existing.Title != draft.Title || existing.GoodsID != draft.GoodsID || existing.SKUColor != draft.SKUColor || existing.SKUSize != draft.SKUSize || existing.Quantity != draft.Quantity || existing.MaxTotalPrice != draft.MaxTotalPrice {
-				return tasks.Draft{}, tasks.ErrCreateKeyConflict
-			}
-			return existing, nil
-		}
-	}
-	store.drafts = append(store.drafts, draft)
-	return draft, nil
-}
-func (store *memoryStore) ListDrafts(_ context.Context) ([]tasks.Draft, error) {
-	return append([]tasks.Draft(nil), store.drafts...), nil
-}
-
 func serve(router http.Handler, method, target string, form url.Values, cookie *http.Cookie) *httptest.ResponseRecorder {
 	var body *strings.Reader
 	if form == nil {
@@ -456,26 +291,3 @@ func csrfToken(t *testing.T, body string) string {
 	}
 	return matches[1]
 }
-
-func createKey(t *testing.T, body string) string {
-	t.Helper()
-	matches := createKeyPattern.FindStringSubmatch(body)
-	if len(matches) != 2 || matches[1] == "" {
-		t.Fatalf("no create key in response body: %q", body)
-	}
-	return matches[1]
-}
-
-func authenticate(t *testing.T, router http.Handler) *http.Cookie {
-	t.Helper()
-	page := serve(router, http.MethodGet, "/login", nil, nil)
-	login := serve(router, http.MethodPost, "/login", url.Values{
-		"csrf_token": {csrfToken(t, page.Body.String())},
-		"username":   {"admin"},
-		"password":   {"test-password"},
-	}, sessionCookie(t, page))
-	if login.Code != http.StatusSeeOther {
-		t.Fatalf("authenticate status = %d, want 303", login.Code)
-	}
-	return sessionCookie(t, login)
-}
@@ -1,129 +0,0 @@
-package tasks
-
-import (
-	"context"
-	"database/sql"
-	"errors"
-	"fmt"
-	"time"
-)
-
-const sqliteWriteTimeout = 2 * time.Second
-
-type Store interface {
-	CreateDraft(context.Context, Draft) (Draft, error)
-	ListDrafts(context.Context) ([]Draft, error)
-}
-type SQLiteStore struct {
-	database   *sql.DB
-	now        func() time.Time
-	createGate chan struct{}
-}
-
-func NewSQLiteStore(database *sql.DB) (*SQLiteStore, error) {
-	if database == nil {
-		return nil, errors.New("database is required")
-	}
-	if _, err := database.Exec("SELECT 1 FROM tasks LIMIT 1"); err != nil {
-		return nil, fmt.Errorf("tasks migration is not available: %w", err)
-	}
-	return &SQLiteStore{database: database, now: time.Now, createGate: make(chan struct{}, 1)}, nil
-}
-
-func (store *SQLiteStore) CreateDraft(ctx context.Context, draft Draft) (Draft, error) {
-	writeContext, cancel := context.WithTimeout(ctx, sqliteWriteTimeout)
-	defer cancel()
-	// SQLite permits one writer at a time. Serializing this store's short create
-	// transaction prevents concurrent retries of one create key from surfacing as busy.
-	select {
-	case store.createGate <- struct{}{}:
-		defer func() { <-store.createGate }()
-	case <-writeContext.Done():
-		return Draft{}, writeContext.Err()
-	}
-	draft.CreatedAt = store.now().UTC()
-	transaction, err := store.database.BeginTx(writeContext, nil)
-	if err != nil {
-		return Draft{}, err
-	}
-	defer transaction.Rollback()
-	_, err = transaction.ExecContext(writeContext, `INSERT INTO tasks (id, source, title, goods_id, sku_color, sku_size, quantity, max_total_price, status, version, created_at, updated_at) VALUES (?, 'MANUAL', ?, ?, ?, ?, ?, ?, 'DRAFT', 1, ?, ?)`, draft.ID, draft.Title, draft.GoodsID, draft.SKUColor, draft.SKUSize, draft.Quantity, draft.MaxTotalPrice, draft.CreatedAt.Format(time.RFC3339Nano), draft.CreatedAt.Format(time.RFC3339Nano))
-	if err == nil {
-		if err := transaction.Commit(); err != nil {
-			return Draft{}, err
-		}
-		return draft, nil
-	}
-	existing, found, currentPhase, lookupErr := findDraft(writeContext, transaction, draft.ID)
-	if lookupErr != nil {
-		return Draft{}, lookupErr
-	}
-	if found && currentPhase && samePayload(existing, draft) {
-		if err := transaction.Commit(); err != nil {
-			return Draft{}, err
-		}
-		return existing, nil
-	}
-	if found {
-		return Draft{}, ErrCreateKeyConflict
-	}
-	return Draft{}, err
-}
-
-func (store *SQLiteStore) ListDrafts(ctx context.Context) ([]Draft, error) {
-	// rowid makes equal timestamps deterministic: SQLite assigns it in insertion order,
-	// whereas UUID v4 is deliberately not time-sortable.
-	rows, err := store.database.QueryContext(ctx, `SELECT id, title, goods_id, sku_color, sku_size, quantity, max_total_price, created_at FROM tasks WHERE source = 'MANUAL' AND status = 'DRAFT' ORDER BY created_at DESC, rowid DESC`)
-	if err != nil {
-		return nil, err
-	}
-	defer rows.Close()
-	result := []Draft{}
-	for rows.Next() {
-		draft, err := scanDraft(rows)
-		if err != nil {
-			return nil, err
-		}
-		result = append(result, draft)
-	}
-	return result, rows.Err()
-}
-
-func findDraft(ctx context.Context, transaction *sql.Tx, id string) (Draft, bool, bool, error) {
-	row := transaction.QueryRowContext(ctx, `SELECT id, title, goods_id, sku_color, sku_size, quantity, max_total_price, created_at, source, status, version FROM tasks WHERE id = ?`, id)
-	var draft Draft
-	var created, source, status string
-	var version int
-	err := row.Scan(&draft.ID, &draft.Title, &draft.GoodsID, &draft.SKUColor, &draft.SKUSize, &draft.Quantity, &draft.MaxTotalPrice, &created, &source, &status, &version)
-	if errors.Is(err, sql.ErrNoRows) {
-		return Draft{}, false, false, nil
-	}
-	if err != nil {
-		return Draft{}, false, false, err
-	}
-	parsed, err := time.Parse(time.RFC3339Nano, created)
-	if err != nil {
-		return Draft{}, false, false, err
-	}
-	draft.CreatedAt = parsed
-	return draft, true, source == "MANUAL" && status == "DRAFT" && version == 1, nil
-}
-
-type scanner interface{ Scan(...any) error }
-
-func scanDraft(row scanner) (Draft, error) {
-	var draft Draft
-	var created string
-	if err := row.Scan(&draft.ID, &draft.Title, &draft.GoodsID, &draft.SKUColor, &draft.SKUSize, &draft.Quantity, &draft.MaxTotalPrice, &created); err != nil {
-		return Draft{}, err
-	}
-	parsed, err := time.Parse(time.RFC3339Nano, created)
-	if err != nil {
-		return Draft{}, err
-	}
-	draft.CreatedAt = parsed
-	return draft, nil
-}
-func samePayload(left, right Draft) bool {
-	return left.ID == right.ID && left.Title == right.Title && left.GoodsID == right.GoodsID && left.SKUColor == right.SKUColor && left.SKUSize == right.SKUSize && left.Quantity == right.Quantity && left.MaxTotalPrice == right.MaxTotalPrice
-}
@@ -1,159 +0,0 @@
-// Package tasks 定义手工 DRAFT 任务的校验与窄仓储边界。
-package tasks
-
-import (
-	"crypto/rand"
-	"encoding/hex"
-	"errors"
-	"net/url"
-	"strconv"
-	"strings"
-	"time"
-)
-
-const (
-	maxTitleLength = 120
-	maxSKUText     = 80
-)
-
-var ErrCreateKeyConflict = errors.New("create key conflicts with a different task")
-
-type Draft struct {
-	ID            string
-	Title         string
-	GoodsID       string
-	SKUColor      string
-	SKUSize       string
-	Quantity      int
-	MaxTotalPrice string
-	CreatedAt     time.Time
-}
-
-type Form struct{ CreateKey, Title, ProductURL, SKUColor, SKUSize, Quantity, MaxTotalPrice string }
-type Errors map[string]string
-
-func (errors Errors) Valid() bool { return len(errors) == 0 }
-
-// Validate trims and normalizes a user form. It never reads a product page or derives price data.
-func Validate(form Form) (Draft, Errors) {
-	draft := Draft{ID: strings.TrimSpace(form.CreateKey), Title: strings.TrimSpace(form.Title), SKUColor: strings.TrimSpace(form.SKUColor), SKUSize: strings.TrimSpace(form.SKUSize)}
-	errors := Errors{}
-	if !validUUID(draft.ID) {
-		errors["create_key"] = "创建请求已过期，请重新打开表单。"
-	}
-	if draft.Title == "" || len([]rune(draft.Title)) > maxTitleLength {
-		errors["title"] = "任务名称不能为空，且不能超过 120 个字符。"
-	}
-	if draft.SKUColor == "" || len([]rune(draft.SKUColor)) > maxSKUText {
-		errors["sku_color"] = "颜色分类不能为空，且不能超过 80 个字符。"
-	}
-	if draft.SKUSize == "" || len([]rune(draft.SKUSize)) > maxSKUText {
-		errors["sku_size"] = "尺码不能为空，且不能超过 80 个字符。"
-	}
-	goodsID, ok := CanonicalGoodsID(strings.TrimSpace(form.ProductURL))
-	if !ok {
-		errors["product_url"] = "请输入唯一的 canonical 商品链接。"
-	} else {
-		draft.GoodsID = goodsID
-	}
-	quantity, err := strconv.ParseInt(strings.TrimSpace(form.Quantity), 10, 0)
-	if err != nil || quantity < 1 {
-		errors["quantity"] = "数量必须是正整数。"
-	} else {
-		draft.Quantity = int(quantity)
-	}
-	money, ok := normalizeMoney(strings.TrimSpace(form.MaxTotalPrice))
-	if !ok {
-		errors["max_total_price"] = "价格上限必须大于零，且最多两位小数。"
-	} else {
-		draft.MaxTotalPrice = money
-	}
-	return draft, errors
-}
-
-// CanonicalGoodsID only accepts the one verified manual-entry URL shape; untrusted query data is discarded.
-func CanonicalGoodsID(value string) (string, bool) {
-	if value == "" || strings.Contains(value, "\\") || strings.Contains(value, "%") {
-		return "", false
-	}
-	parsed, err := url.ParseRequestURI(value)
-	if err != nil || parsed.Scheme != "https" || parsed.Host != "mobile.yangkeduo.com" || parsed.User != nil || parsed.Port() != "" || parsed.Path != "/goods.html" || parsed.Fragment != "" {
-		return "", false
-	}
-	values, err := url.ParseQuery(parsed.RawQuery)
-	if err != nil {
-		return "", false
-	}
-	goodsIDs := values["goods_id"]
-	if len(goodsIDs) != 1 || goodsIDs[0] == "" {
-		return "", false
-	}
-	for _, character := range goodsIDs[0] {
-		if character < '0' || character > '9' {
-			return "", false
-		}
-	}
-	return goodsIDs[0], true
-}
-
-func CanonicalURL(goodsID string) string {
-	return "https://mobile.yangkeduo.com/goods.html?goods_id=" + goodsID
-}
-
-func NewCreateKey() (string, error) {
-	bytes := make([]byte, 16)
-	if _, err := rand.Read(bytes); err != nil {
-		return "", err
-	}
-	bytes[6] = (bytes[6] & 0x0f) | 0x40
-	bytes[8] = (bytes[8] & 0x3f) | 0x80
-	hexValue := hex.EncodeToString(bytes)
-	return hexValue[0:8] + "-" + hexValue[8:12] + "-" + hexValue[12:16] + "-" + hexValue[16:20] + "-" + hexValue[20:32], nil
-}
-
-func validUUID(value string) bool {
-	if len(value) != 36 {
-		return false
-	}
-	for index, character := range value {
-		if index == 8 || index == 13 || index == 18 || index == 23 {
-			if character != '-' {
-				return false
-			}
-			continue
-		}
-		if !(character >= '0' && character <= '9' || character >= 'a' && character <= 'f') {
-			return false
-		}
-	}
-	return value[14] == '4' && (value[19] == '8' || value[19] == '9' || value[19] == 'a' || value[19] == 'b')
-}
-
-func normalizeMoney(value string) (string, bool) {
-	parts := strings.Split(value, ".")
-	if len(parts) > 2 || parts[0] == "" || len(parts) == 2 && (len(parts[1]) == 0 || len(parts[1]) > 2) {
-		return "", false
-	}
-	for _, character := range parts[0] {
-		if character < '0' || character > '9' {
-			return "", false
-		}
-	}
-	fraction := ""
-	if len(parts) == 2 {
-		fraction = parts[1]
-		for _, character := range fraction {
-			if character < '0' || character > '9' {
-				return "", false
-			}
-		}
-	}
-	whole := strings.TrimLeft(parts[0], "0")
-	if whole == "" {
-		whole = "0"
-	}
-	if whole == "0" && strings.Trim(fraction, "0") == "" {
-		return "", false
-	}
-	return whole + "." + (fraction + "00")[:2], true
-}
@@ -1,300 +0,0 @@
-package tasks
-
-import (
-	"context"
-	"database/sql"
-	"errors"
-	"path/filepath"
-	"regexp"
-	"runtime"
-	"sync"
-	"testing"
-	"time"
-
-	"cmbuyer/admin/internal/migrations"
-	"cmbuyer/admin/internal/storage/sqlite"
-)
-
-const testKey = "a3c9f507-7473-4fa6-8d71-8786c34c6301"
-
-func TestValidateNormalizesManualDraft(t *testing.T) {
-	draft, validation := Validate(Form{
-		CreateKey:     " " + testKey + " ",
-		Title:         "  夏季上衣  ",
-		ProductURL:    "https://mobile.yangkeduo.com/goods.html?goods_id=937122477375&utm_source=untrusted",
-		SKUColor:      " 黑色CHA(纯棉) ",
-		SKUSize:       " M(建议100-115) ",
-		Quantity:      "2",
-		MaxTotalPrice: "00012.8",
-	})
-	if !validation.Valid() {
-		t.Fatalf("Validate errors = %#v", validation)
-	}
-	if draft.ID != testKey || draft.GoodsID != "937122477375" || draft.Title != "夏季上衣" || draft.SKUColor != "黑色CHA(纯棉)" || draft.SKUSize != "M(建议100-115)" || draft.Quantity != 2 || draft.MaxTotalPrice != "12.80" {
-		t.Fatalf("normalized draft = %#v", draft)
-	}
-}
-
-func TestValidateRejectsInvalidFieldsAndURLs(t *testing.T) {
-	base := Form{CreateKey: testKey, Title: "title", ProductURL: "https://mobile.yangkeduo.com/goods.html?goods_id=1", SKUColor: "black", SKUSize: "M", Quantity: "1", MaxTotalPrice: "1"}
-	for name, update := range map[string]func(*Form){
-		"empty title":       func(form *Form) { form.Title = "  " },
-		"long color":        func(form *Form) { form.SKUColor = string(make([]rune, maxSKUText+1)) },
-		"fraction quantity": func(form *Form) { form.Quantity = "1.5" },
-		"zero quantity":     func(form *Form) { form.Quantity = "0" },
-		"too many decimals": func(form *Form) { form.MaxTotalPrice = "1.234" },
-		"trailing decimal":  func(form *Form) { form.MaxTotalPrice = "1." },
-		"zero money":        func(form *Form) { form.MaxTotalPrice = "0.00" },
-	} {
-		t.Run(name, func(t *testing.T) {
-			form := base
-			update(&form)
-			if _, validation := Validate(form); validation.Valid() {
-				t.Fatal("invalid form was accepted")
-			}
-		})
-	}
-
-	for _, value := range []string{
-		"http://mobile.yangkeduo.com/goods.html?goods_id=1",
-		"https://yangkeduo.com/goods.html?goods_id=1",
-		"https://mobile.yangkeduo.com:443/goods.html?goods_id=1",
-		"https://user@mobile.yangkeduo.com/goods.html?goods_id=1",
-		"https://mobile.yangkeduo.com/goods.html?goods_id=1#fragment",
-		"https://mobile.yangkeduo.com/goods.html?goods_id=1&goods_id=2",
-		"https://mobile.yangkeduo.com/goods.html?goods_id=one",
-		"https://mobile.yangkeduo.com/goods.html?goods_id=%31",
-		"https://mobile.yangkeduo.com/goods.html?goods_id=1%26goods_id%3D2",
-		"https://mobile.yangkeduo.com/goods.html?goods_id=1;uin=bad",
-		"https://mobile.yangkeduo.com/other.html?goods_id=1",
-	} {
-		if _, ok := CanonicalGoodsID(value); ok {
-			t.Fatalf("CanonicalGoodsID accepted %q", value)
-		}
-	}
-}
-
-func TestNormalizeMoneyBoundaries(t *testing.T) {
-	for value, want := range map[string]string{"1": "1.00", "1.2": "1.20", "000.01": "0.01", "999999999999999999": "999999999999999999.00"} {
-		got, ok := normalizeMoney(value)
-		if !ok || got != want {
-			t.Fatalf("normalizeMoney(%q) = (%q, %t), want (%q, true)", value, got, ok, want)
-		}
-	}
-	for _, value := range []string{"0", "0.0", "0.00", "1.", ".1", "1.000", "-1", "1e2", " 1"} {
-		if got, ok := normalizeMoney(value); ok {
-			t.Fatalf("normalizeMoney(%q) = %q, want rejection", value, got)
-		}
-	}
-}
-
-func TestNewCreateKeyIsUUIDv4(t *testing.T) {
-	key, err := NewCreateKey()
-	if err != nil {
-		t.Fatalf("NewCreateKey: %v", err)
-	}
-	if !regexp.MustCompile(`^[0-9a-f]{8}-[0-9a-f]{4}-4[0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$`).MatchString(key) {
-		t.Fatalf("create key %q is not UUID v4", key)
-	}
-}
-
-func TestSQLiteStoreRequiresMigratedDatabase(t *testing.T) {
-	database := openDatabase(t)
-	if _, err := NewSQLiteStore(database); err == nil {
-		t.Fatal("NewSQLiteStore accepted an unmigrated database")
-	}
-}
-
-func TestSQLiteStoreCreatesListsAndHandlesIdempotency(t *testing.T) {
-	database := migratedDatabase(t)
-	store, err := NewSQLiteStore(database)
-	if err != nil {
-		t.Fatalf("NewSQLiteStore: %v", err)
-	}
-	baseTime := time.Date(2026, 8, 4, 9, 0, 0, 0, time.UTC)
-	call := 0
-	store.now = func() time.Time {
-		result := baseTime.Add(time.Duration(call) * time.Minute)
-		call++
-		return result
-	}
-	first := testDraft(testKey, "first")
-	created, err := store.CreateDraft(context.Background(), first)
-	if err != nil {
-		t.Fatalf("create first draft: %v", err)
-	}
-	replayed, err := store.CreateDraft(context.Background(), first)
-	if err != nil {
-		t.Fatalf("replay first draft: %v", err)
-	}
-	if replayed.CreatedAt != created.CreatedAt {
-		t.Fatalf("replayed CreatedAt = %s, want original %s", replayed.CreatedAt, created.CreatedAt)
-	}
-	second := testDraft("b3c9f507-7473-4fa6-8d71-8786c34c6301", "second")
-	if _, err := store.CreateDraft(context.Background(), second); err != nil {
-		t.Fatalf("create second draft: %v", err)
-	}
-	drafts, err := store.ListDrafts(context.Background())
-	if err != nil {
-		t.Fatalf("list drafts: %v", err)
-	}
-	if len(drafts) != 2 || drafts[0].ID != second.ID || drafts[1].ID != first.ID {
-		t.Fatalf("draft order = %#v, want second then first", drafts)
-	}
-	var source, status string
-	var version int
-	if err := database.QueryRow(`SELECT source, status, version FROM tasks WHERE id = ?`, first.ID).Scan(&source, &status, &version); err != nil {
-		t.Fatalf("read stored task: %v", err)
-	}
-	if source != "MANUAL" || status != "DRAFT" || version != 1 {
-		t.Fatalf("stored metadata = (%q, %q, %d)", source, status, version)
-	}
-
-	conflicting := first
-	conflicting.Title = "different"
-	if _, err := store.CreateDraft(context.Background(), conflicting); !errors.Is(err, ErrCreateKeyConflict) {
-		t.Fatalf("conflicting create error = %v, want ErrCreateKeyConflict", err)
-	}
-}
-
-func TestSQLiteStoreRollsBackFailedCreate(t *testing.T) {
-	database := migratedDatabase(t)
-	store, err := NewSQLiteStore(database)
-	if err != nil {
-		t.Fatalf("NewSQLiteStore: %v", err)
-	}
-	if _, err := database.Exec(`CREATE TRIGGER reject_task BEFORE INSERT ON tasks BEGIN SELECT RAISE(ABORT, 'reject test insert'); END`); err != nil {
-		t.Fatalf("create trigger: %v", err)
-	}
-	if _, err := store.CreateDraft(context.Background(), testDraft(testKey, "blocked")); err == nil {
-		t.Fatal("CreateDraft succeeded despite rejecting trigger")
-	}
-	drafts, err := store.ListDrafts(context.Background())
-	if err != nil {
-		t.Fatalf("list after failed create: %v", err)
-	}
-	if len(drafts) != 0 {
-		t.Fatalf("failed create persisted drafts: %#v", drafts)
-	}
-}
-
-func TestSQLiteStoreUsesInsertionOrderForEqualTimesAndFiltersPhase(t *testing.T) {
-	database := migratedDatabase(t)
-	store, err := NewSQLiteStore(database)
-	if err != nil {
-		t.Fatalf("NewSQLiteStore: %v", err)
-	}
-	store.now = func() time.Time { return time.Date(2026, 8, 4, 9, 0, 0, 0, time.UTC) }
-	first := testDraft(testKey, "first")
-	second := testDraft("b3c9f507-7473-4fa6-8d71-8786c34c6301", "second")
-	for _, draft := range []Draft{first, second} {
-		if _, err := store.CreateDraft(context.Background(), draft); err != nil {
-			t.Fatalf("create %s: %v", draft.Title, err)
-		}
-	}
-	if _, err := database.Exec(`INSERT INTO tasks (id, source, title, goods_id, sku_color, sku_size, quantity, max_total_price, status, version, created_at, updated_at) VALUES ('excel-draft', 'EXCEL', 'other', '1', 'black', 'M', 1, '1.00', 'DRAFT', 1, '2026-08-04T10:00:00Z', '2026-08-04T10:00:00Z'), ('manual-pending', 'MANUAL', 'other', '2', 'black', 'M', 1, '1.00', 'PENDING', 1, '2026-08-04T10:00:00Z', '2026-08-04T10:00:00Z')`); err != nil {
-		t.Fatalf("insert out-of-scope tasks: %v", err)
-	}
-	drafts, err := store.ListDrafts(context.Background())
-	if err != nil {
-		t.Fatalf("list drafts: %v", err)
-	}
-	if len(drafts) != 2 || drafts[0].ID != second.ID || drafts[1].ID != first.ID {
-		t.Fatalf("equal-time draft order/filter = %#v, want second then first only", drafts)
-	}
-	if _, err := database.Exec(`UPDATE tasks SET status = 'PENDING' WHERE id = ?`, first.ID); err != nil {
-		t.Fatalf("move draft outside current phase: %v", err)
-	}
-	if _, err := store.CreateDraft(context.Background(), first); !errors.Is(err, ErrCreateKeyConflict) {
-		t.Fatalf("replay of non-DRAFT record error = %v, want conflict", err)
-	}
-	third := testDraft("c3c9f507-7473-4fa6-8d71-8786c34c6301", "third")
-	if _, err := database.Exec(`INSERT INTO tasks (id, source, title, goods_id, sku_color, sku_size, quantity, max_total_price, status, version, created_at, updated_at) VALUES (?, 'EXCEL', ?, ?, ?, ?, ?, ?, 'DRAFT', 1, '2026-08-04T09:00:00Z', '2026-08-04T09:00:00Z')`, third.ID, third.Title, third.GoodsID, third.SKUColor, third.SKUSize, third.Quantity, third.MaxTotalPrice); err != nil {
-		t.Fatalf("insert same-payload EXCEL record: %v", err)
-	}
-	if _, err := store.CreateDraft(context.Background(), third); !errors.Is(err, ErrCreateKeyConflict) {
-		t.Fatalf("replay of non-MANUAL record error = %v, want conflict", err)
-	}
-	if _, err := database.Exec(`UPDATE tasks SET version = 2, source = 'MANUAL' WHERE id = ?`, third.ID); err != nil {
-		t.Fatalf("change replay record version: %v", err)
-	}
-	if _, err := store.CreateDraft(context.Background(), third); !errors.Is(err, ErrCreateKeyConflict) {
-		t.Fatalf("replay of non-v1 record error = %v, want conflict", err)
-	}
-}
-
-func TestSQLiteStoreConcurrentIdenticalCreateIsOneDraft(t *testing.T) {
-	store, err := NewSQLiteStore(migratedDatabase(t))
-	if err != nil {
-		t.Fatalf("NewSQLiteStore: %v", err)
-	}
-	const callers = 20
-	start := make(chan struct{})
-	errors := make(chan error, callers)
-	results := make(chan Draft, callers)
-	var group sync.WaitGroup
-	for range callers {
-		group.Add(1)
-		go func() {
-			defer group.Done()
-			<-start
-			draft, err := store.CreateDraft(context.Background(), testDraft(testKey, "same"))
-			if err != nil {
-				errors <- err
-				return
-			}
-			results <- draft
-		}()
-	}
-	close(start)
-	group.Wait()
-	close(errors)
-	close(results)
-	for err := range errors {
-		t.Fatalf("concurrent create: %v", err)
-	}
-	for result := range results {
-		if result.ID != testKey {
-			t.Fatalf("concurrent result = %#v", result)
-		}
-	}
-	drafts, err := store.ListDrafts(context.Background())
-	if err != nil {
-		t.Fatalf("list after concurrent create: %v", err)
-	}
-	if len(drafts) != 1 || drafts[0].ID != testKey {
-		t.Fatalf("concurrent creates persisted %#v, want exactly one", drafts)
-	}
-}
-
-func testDraft(id, title string) Draft {
-	return Draft{ID: id, Title: title, GoodsID: "937122477375", SKUColor: "black", SKUSize: "M", Quantity: 2, MaxTotalPrice: "12.80"}
-}
-
-func openDatabase(t *testing.T) *sql.DB {
-	t.Helper()
-	database, err := sqlite.Open(filepath.Join(t.TempDir(), "tasks.db"))
-	if err != nil {
-		t.Fatalf("open database: %v", err)
-	}
-	t.Cleanup(func() { _ = database.Close() })
-	return database
-}
-
-func migratedDatabase(t *testing.T) *sql.DB {
-	t.Helper()
-	database := openDatabase(t)
-	if err := migrations.Up(context.Background(), database, migrationDirectory(t)); err != nil {
-		t.Fatalf("migrate database: %v", err)
-	}
-	return database
-}
-
-func migrationDirectory(t *testing.T) string {
-	t.Helper()
-	_, file, _, ok := runtime.Caller(0)
-	if !ok {
-		t.Fatal("locate test source")
-	}
-	return filepath.Join(filepath.Dir(file), "..", "..", "migrations")
-}
@@ -6,14 +6,22 @@
  <meta name="viewport" content="width=device-width, initial-scale=1">
  <title>采购任务 · 采购服务</title>
  <style>
-    :root{--bg:#f4f7fb;--surface:#fff;--text:#172033;--muted:#526079;--border:#cfd8e6;--primary:#155eef;--danger:#b42318;--success:#067647;--focus:#ffbf47;font-family:"Segoe UI","Microsoft YaHei UI",system-ui,sans-serif}*{box-sizing:border-box}html{min-width:320px;background:var(--bg)}body{min-height:100dvh;margin:0;color:var(--text);background:var(--bg);font-size:16px;line-height:1.55}button,input{font:inherit}:focus-visible{outline:3px solid var(--focus);outline-offset:3px}.skip{position:fixed;z-index:100;top:8px;left:8px;padding:10px;color:#fff;background:#172033;transform:translateY(-160%)}.skip:focus{transform:translateY(0)}header{display:flex;align-items:center;justify-content:space-between;gap:16px;min-height:64px;padding:10px clamp(16px,4vw,40px);border-bottom:1px solid var(--border);background:var(--surface)}.brand{font-weight:700}.brand b{display:inline-grid;place-items:center;width:32px;height:32px;margin-right:8px;border-radius:8px;background:var(--primary);color:#fff;font-size:.82rem}.logout,.button{display:inline-flex;align-items:center;justify-content:center;min-height:44px;padding:9px 14px;border:1px solid var(--border);border-radius:8px;color:var(--text);background:#fff;font-weight:700;text-decoration:none;cursor:pointer}.button.primary{border-color:var(--primary);background:var(--primary);color:#fff}.button:disabled,.filter input:disabled{opacity:.5;cursor:not-allowed}main{width:min(100% - 32px,1200px);margin:32px auto}.toolbar{display:flex;align-items:center;justify-content:space-between;gap:16px;margin-bottom:16px}.toolbar-actions,.filters,.actions{display:flex;flex-wrap:wrap;gap:10px}.muted,.placeholder{color:var(--muted)}.filters{align-items:end;margin:0 0 16px}.filters label{display:grid;gap:4px;font-weight:700}.filters input{min-height:44px;min-width:180px;padding:8px 10px;border:1px solid var(--border);border-radius:8px;background:#fff}.table-wrap{overflow-x:auto;border:1px solid var(--border);border-radius:12px;background:var(--surface)}table{width:100%;min-width:880px;border-collapse:collapse}th,td{padding:12px 14px;border-bottom:1px solid var(--border);text-align:left;vertical-align:top}th{background:#f8fafc;font-size:.88rem}td a{color:#124cc5;font-weight:700;text-underline-offset:3px}.status{display:inline-block;padding:3px 8px;border-radius:999px;background:#eaf1ff;color:#173d8f;font-size:.85rem;font-weight:700}.empty,.success{padding:20px;border:1px solid var(--border);border-radius:12px;background:var(--surface)}.success{margin:0 0 16px;border-color:#9dd9b8;background:#ecfdf3;color:var(--success)}.modal-scrim{position:fixed;z-index:20;inset:0;background:rgba(23,32,51,.52)}dialog[open]{position:fixed;z-index:30;top:50%;left:50%;width:min(calc(100% - 24px),640px);max-height:calc(100dvh - 24px);margin:0;padding:28px;overflow-y:auto;border:1px solid var(--border);border-radius:14px;box-shadow:0 18px 48px rgba(23,32,51,.24);transform:translate(-50%,-50%);background:var(--surface)}.form-page{width:min(100% - 32px,640px);margin:32px auto;padding:28px;border:1px solid var(--border);border-radius:14px;background:var(--surface)}.form-grid{display:grid;gap:16px}.field label{display:block;margin-bottom:6px;font-weight:700}.required{color:var(--danger)}.field input{width:100%;min-height:44px;padding:10px 12px;border:1px solid #9ba9bc;border-radius:8px}.field input[aria-invalid=true]{border-color:var(--danger)}.error{margin:5px 0 0;color:var(--danger);font-size:.9rem}.summary{margin:0 0 16px;padding:12px;border-left:4px solid var(--danger);background:#fef3f2;color:var(--danger)}.summary p{margin:0}.summary ul{margin:8px 0 0;padding-left:20px}.summary a{color:inherit}.sr-only{position:absolute;width:1px;height:1px;padding:0;margin:-1px;overflow:hidden;clip:rect(0,0,0,0);white-space:nowrap;border:0}@media(max-width:420px){main,.form-page{width:calc(100% - 24px);margin:24px auto}.toolbar{align-items:stretch;flex-direction:column}.toolbar-actions,.toolbar .button{width:100%}.toolbar-actions .button{flex:1}.filters{align-items:stretch;flex-direction:column}.filters input,.filters .button{width:100%}}@media(prefers-reduced-motion:reduce){*,*::before,*::after{transition-duration:.01ms!important;animation-duration:.01ms!important}}</style>
+    :root { color-scheme:light; --bg:#f4f7fb; --surface:#fff; --text:#172033; --muted:#526079; --border:#cfd8e6; --primary:#155eef; --focus:#ffbf47; font-family:"Segoe UI","Microsoft YaHei UI",system-ui,sans-serif; }
+    * { box-sizing:border-box; } body { min-height:100dvh; margin:0; color:var(--text); background:var(--bg); font-size:16px; line-height:1.55; } button { font:inherit; } :focus-visible { outline:3px solid var(--focus); outline-offset:3px; }
+    .skip-link { position:fixed; z-index:10; top:8px; left:8px; padding:10px 14px; color:#fff; background:var(--text); transform:translateY(-160%); } .skip-link:focus { transform:translateY(0); }
+    header { display:flex; min-height:64px; align-items:center; justify-content:space-between; gap:16px; padding:10px clamp(16px,4vw,40px); border-bottom:1px solid var(--border); background:var(--surface); }
+    .brand { display:flex; align-items:center; gap:10px; font-weight:700; } .brand-mark { display:grid; width:32px; height:32px; place-items:center; border-radius:8px; color:#fff; background:var(--primary); font-size:.82rem; }
+    .logout { min-height:44px; padding:8px 14px; border:1px solid var(--border); border-radius:8px; color:var(--text); background:var(--surface); font-weight:700; cursor:pointer; }
+    main { width:min(100% - 32px,760px); margin:48px auto; padding:32px; border:1px solid var(--border); border-radius:14px; background:var(--surface); }
+    h1 { margin:0; font-size:clamp(1.5rem,5vw,2rem); } p { color:var(--muted); } .notice { margin-top:24px; padding:14px; border-left:4px solid var(--primary); border-radius:6px; background:#eaf1ff; color:#29466f; }
+    @media (max-width:420px) { main { width:calc(100% - 24px); margin:24px auto; padding:24px 16px; } }
+    @media (prefers-reduced-motion:reduce) { *,*::before,*::after { transition-duration:.01ms !important; animation-duration:.01ms !important; } }
+  </style>
 </head>
 <body>
-  <a class="skip" href="#main">跳到主要内容</a>
-  <header><div class="brand"><b aria-hidden="true">采</b>采购服务</div><form method="post" action="/logout"><input type="hidden" name="csrf_token" value="{{.CSRFToken}}"><button class="logout" type="submit">退出登录</button></form></header>
-  {{if .FullPage}}<main class="form-page" id="main">{{template "form" .}}</main>{{else}}<main id="main"><div class="toolbar"><div><h1>采购任务</h1><p class="muted">只显示待开始的手工任务。</p></div><div class="toolbar-actions"><button class="button" type="button" disabled>导入</button><a class="button primary" href="/tasks?create=1">创建任务</a></div></div><div class="filters" aria-label="暂不可用的列表条件"><label>关键词<input type="search" disabled></label><button class="button" type="button" disabled>筛选</button><button class="button" type="button" disabled>清除</button></div>{{if .Success}}<p class="success" role="status">任务已创建，已显示在列表首行。</p>{{end}}{{if .Drafts}}<div class="table-wrap"><table><thead><tr><th scope="col"><input type="checkbox" disabled aria-label="选择全部任务"></th><th scope="col">标题</th><th scope="col">颜色分类</th><th scope="col">尺码</th><th scope="col">价格上限</th><th scope="col">数量</th><th scope="col">采购结果</th><th scope="col">状态</th><th scope="col">创建时间</th></tr></thead><tbody>{{range .Drafts}}<tr><td><input type="checkbox" disabled aria-label="选择任务 {{.Title}}"></td><td><a href="https://mobile.yangkeduo.com/goods.html?goods_id={{.GoodsID}}" target="_blank" rel="noopener noreferrer">{{.Title}}</a></td><td>{{.SKUColor}}</td><td>{{.SKUSize}}</td><td>¥{{.MaxTotalPrice}}</td><td>{{.Quantity}}</td><td>—</td><td><span class="status">待开始</span></td><td><time datetime="{{.CreatedAt.Format "2006-01-02T15:04:05Z07:00"}}">{{.CreatedAt.Format "2006-01-02 15:04 UTC"}}</time></td></tr>{{end}}</tbody></table></div>{{else}}<section class="empty"><h2>还没有待开始任务</h2><p>创建一条手工任务后会显示在这里。</p></section>{{end}}</main>{{if .OpenForm}}<div class="modal-scrim" aria-hidden="true"></div><dialog open aria-modal="true" aria-labelledby="form-title">{{template "form" .}}</dialog>{{end}}{{end}}
+  <a class="skip-link" href="#main">跳到主要内容</a>
+  <header><div class="brand"><span class="brand-mark" aria-hidden="true">采</span><span>采购服务</span></div><form method="post" action="/logout"><input type="hidden" name="csrf_token" value="{{.CSRFToken}}"><button class="logout" type="submit">退出登录</button></form></header>
+  <main id="main"><h1>采购任务</h1><p>任务功能正在准备中。</p><p class="notice">当前页面仅用于验证管理员会话。</p></main>
 </body>
 </html>
 {{end}}
-{{define "form"}}<h1 id="form-title">创建采购任务</h1><p class="muted">保存后仅生成待开始任务，不会执行其他动作。</p>{{if .Errors}}<div class="summary" role="alert" aria-live="assertive"><p>请修正下列字段后再保存。</p><ul>{{with index .Errors "title"}}<li><a href="#title">任务名称：{{.}}</a></li>{{end}}{{with index .Errors "product_url"}}<li><a href="#product_url">商品链接：{{.}}</a></li>{{end}}{{with index .Errors "sku_color"}}<li><a href="#sku_color">颜色分类：{{.}}</a></li>{{end}}{{with index .Errors "sku_size"}}<li><a href="#sku_size">尺码：{{.}}</a></li>{{end}}{{with index .Errors "quantity"}}<li><a href="#quantity">数量：{{.}}</a></li>{{end}}{{with index .Errors "max_total_price"}}<li><a href="#max_total_price">价格上限：{{.}}</a></li>{{end}}{{with index .Errors "create_key"}}<li>{{.}}</li>{{end}}</ul></div>{{end}}<form method="post" action="/tasks" class="form-grid"><input type="hidden" name="csrf_token" value="{{.CSRFToken}}"><input type="hidden" name="create_key" value="{{.Form.CreateKey}}"><input type="hidden" name="form_mode" value="{{if .FullPage}}full{{else}}dialog{{end}}">{{template "field" (list "title" "任务名称" .Form.Title .Errors .FocusField)}}{{template "field" (list "product_url" "商品链接" .Form.ProductURL .Errors .FocusField)}}{{template "field" (list "sku_color" "颜色分类" .Form.SKUColor .Errors .FocusField)}}{{template "field" (list "sku_size" "尺码" .Form.SKUSize .Errors .FocusField)}}{{template "field" (list "quantity" "数量" .Form.Quantity .Errors .FocusField)}}{{template "field" (list "max_total_price" "价格上限" .Form.MaxTotalPrice .Errors .FocusField)}}<div class="actions"><button class="button primary" type="submit">保存任务</button><a class="button" href="/tasks">取消</a></div></form>{{end}}
-{{define "field"}}{{$name:=index . 0}}{{$label:=index . 1}}{{$value:=index . 2}}{{$errors:=index . 3}}{{$focus:=index . 4}}<div class="field"><label for="{{$name}}">{{$label}} <span class="required" aria-hidden="true">*</span><span class="sr-only">（必填）</span></label><input id="{{$name}}" name="{{$name}}" value="{{$value}}" required {{if eq $focus $name}}autofocus{{end}} aria-invalid="{{if index $errors $name}}true{{else}}false{{end}}"{{with index $errors $name}} aria-describedby="{{$name}}-error"{{end}} {{if eq $name "product_url"}}type="url" inputmode="url" maxlength="2048"{{else if eq $name "quantity"}}type="number" inputmode="numeric" min="1" step="1"{{else if eq $name "max_total_price"}}type="text" inputmode="decimal" pattern="[0-9]+(\.[0-9]{1,2})?" maxlength="64"{{else if eq $name "title"}}type="text" maxlength="120"{{else}}type="text" maxlength="80"{{end}}>{{with index $errors $name}}<p class="error" id="{{$name}}-error">{{.}}</p>{{end}}</div>{{end}}
@@ -5,14 +5,12 @@ import (
 	"embed"
 	"html/template"
 	"io"
-
-	"cmbuyer/admin/internal/tasks"
 )

 //go:embed templates/*.html
 var templateFiles embed.FS

-var templates = template.Must(template.New("webui").Funcs(template.FuncMap{"list": func(values ...any) []any { return values }}).ParseFS(templateFiles, "templates/*.html"))
+var templates = template.Must(template.New("webui").ParseFS(templateFiles, "templates/*.html"))

 // LoginData 是登录页面所需的非敏感展示数据。
 type LoginData struct {
@@ -22,16 +20,9 @@ type LoginData struct {
 	Error     string
 }

-// TasksData 是受保护的 DRAFT 建单与列表页面所需数据。
+// TasksData 是当前受保护任务空壳所需的数据。任务字段将在后续任务实现。
 type TasksData struct {
 	CSRFToken string
-	Drafts     []tasks.Draft
-	Form       tasks.Form
-	Errors     tasks.Errors
-	OpenForm   bool
-	FullPage   bool
-	FocusField string
-	Success    bool
 }

 // RenderLogin 写入登录页。
@@ -39,7 +30,7 @@ func RenderLogin(writer io.Writer, data LoginData) error {
 	return templates.ExecuteTemplate(writer, "login.html", data)
 }

-// RenderTasks 写入登录后的受保护任务页。
+// RenderTasks 写入登录后的受保护空壳。
 func RenderTasks(writer io.Writer, data TasksData) error {
 	return templates.ExecuteTemplate(writer, "tasks.html", data)
 }
@@ -22,7 +22,7 @@ from ..pdd.product_url import ProductUrl, ProductUrlError, parse_product_url
 from ..pdd.sku_panel_state import HUMAN_DECLARED_STATES


-SANITIZER_VERSION = "t103-privacy-v4"
+SANITIZER_VERSION = "t103-privacy-v5"
 EXPECTED_GOODS_ID = "937122477375"
 EXPECTED_PDD_VERSION = "8.17.0"
 EXPECTED_DEVICE_MODEL = "PKG110"
@@ -56,9 +56,11 @@ _PRICE_PROJECTION_ATTRIBUTES = (
 )
 # 仅接受普通 ASCII 空格，且每个可分隔位置最多一个；禁止换行、折扣、支付/提交文案和
 # 任何其它字符。前缀捕获组用于区分当前价与至多一个划线/原价候选。
-_CROSSING_PRICE_TEXT_RE = re.compile(r" {0,1}(?:(快卖光) {0,1})?[¥￥] {0,1}[1-9]\d*\.\d{2} {0,1}\Z")
-_CROSSING_PRICE_PREFIX_RE = re.compile(r" {0,1}(?:快卖光 {0,1})?[¥￥] {0,1}[1-9]\d*\.\d{2} {0,1}")
-_CROSSING_PRICE_ALLOWED_CHARACTERS = frozenset(" 快卖光¥￥0123456789.")
+# T-103 人工在 live 规格面板确认当前价槽的完整非敏感前缀仅为“快卖完”；不得兼容
+# 未取证的“快卖光”或其它相近文案。
+_CROSSING_PRICE_TEXT_RE = re.compile(r" {0,1}(?:(快卖完) {0,1})?[¥￥] {0,1}[1-9]\d*\.\d{2} {0,1}\Z")
+_CROSSING_PRICE_PREFIX_RE = re.compile(r" {0,1}(?:快卖完 {0,1})?[¥￥] {0,1}[1-9]\d*\.\d{2} {0,1}")
+_CROSSING_PRICE_ALLOWED_CHARACTERS = frozenset(" 快卖完¥￥0123456789.")


 class SkuEvidenceSanitizationError(RuntimeError):
@@ -423,8 +425,10 @@ def _crossing_price_text_mismatch_reason(text: str) -> str:
        return "non_ascii_whitespace"
    if any(marker in text for marker in ("提交订单", "支付", "下单", "优惠")):
        return "extra_or_order"
-    without_leading_space = text.lstrip(" ")
-    if without_leading_space.startswith("快") and not without_leading_space.startswith("快卖光"):
+    without_one_leading_space = text[1:] if text.startswith(" ") else text
+    if without_one_leading_space.startswith("快要抢光"):
+        return "observed_prefix_kuaiyaoqiangguang"
+    if without_one_leading_space.startswith("快") and not without_one_leading_space.startswith("快卖完"):
        return "known_prefix_missing"
    if "¥" not in text and "￥" not in text:
        return "currency_missing"
@@ -34,7 +34,7 @@ TEST_ADDRESS = "SYNTHETIC_ADDRESS_NEVER_PUBLISH"
 FULL_PHONE = "13800138000"
 MASKED_PHONE = "138****0000"
 SAFE_TEXT = "synthetic-safe-lower-content"
-CURRENT_PRICE = "快卖光 ¥12.88"
+CURRENT_PRICE = "快卖完 ¥12.88"
 ORIGINAL_PRICE = "¥29.00"
 PRICE_CURRENT_BOUNDS = "[396,503][712,570]"
 PRICE_ORIGINAL_BOUNDS = "[730,503][895,570]"
@@ -166,7 +166,7 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):
                self.assertNotIn(MASKED_PHONE, derived_xml)
                self.assertIn(f'"human_declared_state": "{state}"', manifest)
                self.assertIn('"privacy_tier": "SANITIZED"', manifest)
-                self.assertIn('"sanitizer_version": "t103-privacy-v4"', manifest)
+                self.assertIn('"sanitizer_version": "t103-privacy-v5"', manifest)
                self.assertIn('"screenshot_space": {', manifest)
                self.assertIn('"xml_coordinate_space": {', manifest)
                self.assertIn('"height": 2376', manifest)
@@ -256,16 +256,16 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):

    def test_crossing_price_window_rejects_text_and_structure_drift(self) -> None:
        bad_texts = (
-            f"快卖光 ¥12.88 {TEST_ADDRESS}",
-            f"快卖光 ¥12.88 {FULL_PHONE}",
-            "快卖光 ¥12.88 使用微信支付",
-            "快卖光 ¥12.88 提交订单",
-            "快卖光 ¥12.88 优惠-11元",
+            f"快卖完 ¥12.88 {TEST_ADDRESS}",
+            f"快卖完 ¥12.88 {FULL_PHONE}",
+            "快卖完 ¥12.88 使用微信支付",
+            "快卖完 ¥12.88 提交订单",
+            "快卖完 ¥12.88 优惠-11元",
            "快要抢光 ¥12.88",
-            "快卖光 ¥0.00",
-            "快卖光 ¥12.8",
-            "快卖光 ¥12.880",
-            "快卖光　¥12.88",
+            "快卖完 ¥0.00",
+            "快卖完 ¥12.8",
+            "快卖完 ¥12.880",
+            "快卖完　¥12.88",
        )
        for text in bad_texts:
            with self.subTest(text=text), TemporaryDirectory() as temporary:
@@ -276,31 +276,37 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):

    def test_crossing_price_text_mismatch_reports_only_fixed_slot_and_reason(self) -> None:
        newline_node = _price_node(CURRENT_PRICE, PRICE_CURRENT_BOUNDS).replace(
-            "快卖光 ¥12.88", "快卖光&#10;¥12.88"
+            "快卖完 ¥12.88", "快卖完&#10;¥12.88"
        )
        cases = (
            ("newline", _xml_with_prices(current_node=newline_node), "newline", PRICE_CURRENT_BOUNDS),
            (
                "non-ascii-whitespace",
-                _xml_with_prices(current="快卖光　¥12.88"),
+                _xml_with_prices(current="快卖完　¥12.88"),
                "non_ascii_whitespace",
                PRICE_CURRENT_BOUNDS,
            ),
            (
                "known-prefix-missing",
                _xml_with_prices(current="快要抢光 ¥12.88"),
+                "observed_prefix_kuaiyaoqiangguang",
+                PRICE_CURRENT_BOUNDS,
+            ),
+            (
+                "other-kuai-prefix-remains-generic",
+                _xml_with_prices(current="快递地址 ¥12.88"),
                "known_prefix_missing",
                PRICE_CURRENT_BOUNDS,
            ),
            (
                "currency-missing",
-                _xml_with_prices(current="快卖光 12.88"),
+                _xml_with_prices(current="快卖完 12.88"),
                "currency_missing",
                PRICE_CURRENT_BOUNDS,
            ),
            (
                "amount-shape",
-                _xml_with_prices(current="快卖光 ¥12.8"),
+                _xml_with_prices(current="快卖完 ¥12.8"),
                "amount_shape",
                PRICE_CURRENT_BOUNDS,
            ),
@@ -337,10 +343,10 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):

    def test_crossing_price_text_mismatch_never_echoes_sensitive_or_order_text(self) -> None:
        cases = (
-            f"快卖光 ¥12.88 {TEST_ADDRESS}",
-            f"快卖光 ¥12.88 {FULL_PHONE}",
-            "快卖光 ¥12.88 使用微信支付",
-            "快卖光 ¥12.88 提交订单",
+            f"快卖完 ¥12.88 {TEST_ADDRESS}",
+            f"快卖完 ¥12.88 {FULL_PHONE}",
+            "快卖完 ¥12.88 使用微信支付",
+            "快卖完 ¥12.88 提交订单",
        )
        for text in cases:
            with self.subTest(text=text), TemporaryDirectory() as temporary:
@@ -354,14 +360,44 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):
                for raw_fragment in (TEST_ADDRESS, FULL_PHONE, "使用微信支付", "提交订单", "¥12.88"):
                    self.assertNotIn(raw_fragment, message)

+    def test_observed_prefix_diagnostic_does_not_echo_its_suffix(self) -> None:
+        suffix = "地址和金额都不得回显"
+        text = f"快要抢光 ¥12.88 {suffix}"
+        with TemporaryDirectory() as temporary:
+            raw = _write_raw(Path(temporary), xml=_xml_with_prices(current=text))
+            with self.assertRaises(SkuEvidenceSanitizationError) as raised:
+                sanitize_sku_panel_evidence(raw, raw.parent / "derived")
+
+            message = str(raised.exception)
+            self.assertEqual(
+                message,
+                "跨界价格节点文本不匹配：slot=[396,503][712,570]；"
+                "reason=observed_prefix_kuaiyaoqiangguang。",
+            )
+            self.assertNotIn(suffix, message)
+            self.assertNotIn("¥12.88", message)
+
    def test_crossing_price_projection_allows_only_limited_ascii_spaces_and_yen_variants(self) -> None:
-        for current in ("快卖光 ¥12.88", " 快卖光 ¥ 12.88 ", "快卖光 ￥12.88"):
+        for current in ("快卖完 ¥12.88", " 快卖完 ¥ 12.88 ", "快卖完 ￥12.88"):
            with self.subTest(current=current), TemporaryDirectory() as temporary:
                raw = _write_raw(Path(temporary), xml=_xml_with_prices(current=current))
                result = sanitize_sku_panel_evidence(raw, raw.parent / "derived")
                hierarchy = result.hierarchy_path.read_text(encoding="utf-8")
                self.assertIn(current, hierarchy)

+    def test_unverified_or_missing_current_price_prefixes_fail_closed(self) -> None:
+        cases = (
+            ("old-prefix", "快卖光 ¥12.88"),
+            ("bottom-button-prefix", "快要抢光 ¥12.88"),
+            ("missing-prefix", "¥12.88"),
+        )
+        for name, current in cases:
+            with self.subTest(name=name), TemporaryDirectory() as temporary:
+                raw = _write_raw(Path(temporary), xml=_xml_with_prices(current=current))
+                with self.assertRaises(SkuEvidenceSanitizationError):
+                    sanitize_sku_panel_evidence(raw, raw.parent / "derived")
+                self.assertFalse((raw.parent / "derived").exists())
+
    def test_unique_current_price_without_original_price_is_published(self) -> None:
        with TemporaryDirectory() as temporary:
            raw = _write_raw(Path(temporary), xml=_xml_with_prices(include_original=False))
@@ -375,7 +411,7 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):

    def test_crossing_price_projection_rejects_newline_and_structure_drift(self) -> None:
        encoded_newline = _price_node(CURRENT_PRICE, PRICE_CURRENT_BOUNDS).replace(
-            "快卖光 ¥12.88", "快卖光&#10;¥12.88"
+            "快卖完 ¥12.88", "快卖完&#10;¥12.88"
        )
        with TemporaryDirectory() as temporary:
            raw = _write_raw(Path(temporary), xml=_xml_with_prices(current_node=encoded_newline))
@@ -409,7 +445,7 @@ class SkuEvidenceSanitizerTests(unittest.TestCase):
            ),
            (
                "duplicate-current",
-                _xml_with_prices(current=CURRENT_PRICE, original=f"快卖光 {ORIGINAL_PRICE}"),
+                _xml_with_prices(current=CURRENT_PRICE, original=f"快卖完 {ORIGINAL_PRICE}"),
            ),
            (
                "multiple-original",
@@ -149,41 +149,23 @@ T-103 已证明当前衣服商品没有独立「规格/已选」入口。T-110
 .\client\.venv\Scripts\python.exe client\scripts\capture_sku_panel_spike.py --serial <SERIAL> --url "https://mobile.yangkeduo.com/goods.html?goods_id=<GOODS_ID>" --state target-selection-restored --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-target-restored-<GOODS_ID>-v2\raw" --timeout 10 --adb D:\Portable\adb\adb.exe
 ```

-PDD 规格面板不可避免显示收货区域和掩码手机号。原始截图/XML 只能留在
-`%LOCALAPPDATA%\cmbuyer\artifacts\...\raw` 隔离目录，不供 agent、fixture、业务或 HTTP 上传读取；
-T-103 已在 `client/src/cmbuyer_client/device/sku_evidence_sanitizer.py` 实现本机确定性脱敏器，并由
-`client/scripts/sanitize_sku_panel_evidence.py` 提供离线 CLI。第一组新 raw 的 PNG 头部由人确认实际为
-1080×2376，推翻了 v1 将截图和 XML 坐标空间都写成 1080×2400 的假设；v1 正确拒绝且原始证据未重采。
-随后 v2 在同一份 raw 上安全报告 XML `observed 1080x2376` 并拒绝发布，证明其独立配置的
-1080×2400 假设同样不成立。v3 用同一 raw 成功发布后，人已确认截图隐私带完整遮挡、派生 XML
-不含地址或手机号且目标颜色和尺码仍为预选；但顶部当前价节点横跨隐私带边界，v3 只留下断片，
-而下方完整的“提交订单 ¥12.88”属于第一趟硬拒绝区，不能作为 SKU 单价证据。
+PDD 规格面板不可避免显示收货区域和手机号。项目所有者确认 cmbuyer 是内部系统，正式流程允许把
+页面原始截图上传采购服务供已登录管理员查看，不做遮罩或裁剪。完整 XML 仍只留在
+`%LOCALAPPDATA%\cmbuyer\artifacts\...\raw`；采购工具运行时在内存中读取当前页面树，但只返回规格、
+选中态、价格和页面状态摘要，不把地址或手机号解析为业务字段，也不写入日志、Git 或 Vikunja。

-当前 `t103-privacy-v4` 继续精确绑定 PKG110 / Android 16 / 拼多多 8.17.0 / goods_id
-`937122477375`；screenshot space 与 XML coordinate space 仍分别建模、分别校验，当前都精确为
-1080×2376，且都把
-`[0,0,1080,540)` 作为整宽隐私带。截图覆盖该区域；XML 递归移除区域内节点，跨界容器只清空自身
-敏感属性并保留下方子节点。v4 **不改变或缩小截图遮罩**，只允许交界带两个已取证精确 bounds 中，
-属于拼多多包、不可点击、可见且启用的 `TextView` 叶节点投影最小价格属性；当前价必须唯一匹配
-可选“快卖光”前缀加人民币符号和两位小数，原价同格式且最多一个。包外、可点击、结构漂移、重复、
-零值、混杂文本或坐标变化一律拒绝。地址依靠已确认的整块几何隔离而不是易漏的关键词表；完整、
-掩码、带分隔符或跨节点手机号残留会被自动复检拒绝。v4 离线实现已通过合成测试，仍须由人用同一
-第一态 raw 重跑并确认派生结果，才构成真实价格证据。
+T-103 已完成 `t103-privacy-v5` 的一次真实派生：人确认 XML 无实际地址/手机号、目标颜色
+“黑色CHA(纯棉)”与尺码“M(建议100-115)”保留；安全节点显示顶部当前价“快卖完 ¥12.88”与原价
+“¥29.88”，底部“提交订单 ¥12.88”明确属于第一趟硬拒绝区。派生截图的整宽黑色隐私带遮住了顶部
+价格文字的一半，这只说明该截图不适合上传展示，不否定 XML 中已经确认的规格面板价格事实。

-```powershell
-.\client\.venv\Scripts\python.exe client\scripts\sanitize_sku_panel_evidence.py --raw-dir "<证据目录>\raw" --output-dir "<证据目录>\derived"
-```
+为加快 MVP，T-103 从此不再修改或调用截图遮罩器。现有 v5 派生 XML 只用于提取不含页面个人信息的
+最小 fixture；正式 `TrialSkuFlow` 在本机实时页面树上按拼多多 8.17.0 与面板结构读取允许字段，完整
+页面树不落日志、不上传。T-204 直接接入原始截图上传，资产标记 `privacy_tier=INTERNAL_RAW`，只允许
+已认证设备写入、已登录管理员读取；不上传 XML，不允许外部支付页或支付凭据。

-脱敏器校验源 manifest 与文件哈希、设备/App/商品/人工状态、截图分辨率和 XML 隐私结构；XML 所有
-节点观察到的最大 right/bottom 必须精确为 1080×2376，否则只报告非敏感 observed 尺寸并拒绝。它只允许发布到
-同级且尚不存在的 `derived`；失败或发布竞态不覆盖已有目录、不留下 staging。派生 manifest 记录
-`privacy_tier=SANITIZED`、sanitizer 版本、两个坐标空间、清理计数及本机 source/derived 哈希，不记录
-原始路径、serial 或页面正文；v4 另记录 `preserved_crossing_price_nodes`，用于核对严格价格投影
-数量。只有自动复检通过并经人确认状态对应性的派生物，agent 才能读取并提取最小 fixture、编写判据。
-
-2026-08-04 的首轮旧证据只用于确认上述入口事实；其中旧 `initial` 不是规格面板，另两张原始截图含隐私
-区域，因此 XML 未读取、fixture 与选择器未生成。T-110 完成受控入口与脱敏契约后，T-103 重新取证；
-该边界调整不授权第一趟调整数量、进入确认页、点击“提交订单”或触碰任何支付控件。
+这个范围调整不授权第一趟调整数量、进入确认页、点击“提交订单”或触碰支付控件。最终仍由人把两个
+维度改成明确的非目标值，再运行受控入口、精确选择、读价和安全退出脚本完成真机验收。

 Windows 的标准入口是仓库根 `./init.ps1`。它要求 Go、两端目录及其哨兵文件存在；已有合规
 `client/.venv` 时，所有采购工具检查与 validator 都使用该解释器。只有 venv 不存在时，才从 `py -0p`
@@ -150,7 +150,8 @@ T-103 的真机证据推翻了“商品详情页存在独立规格入口”的
 1. 打开 canonical 商品链接。
 2. 点击与证据哈希、拼多多版本和页面状态绑定的精确唯一 `快要抢光` 入口。
 3. 在已确认的维度容器中精确选择规格并读回选中态。
-4. 从规格面板读取单价、生成脱敏派生证据、关闭面板并退出商品页。
+4. 从规格面板读取单价、保存原始截图、关闭面板并退出商品页。T-103 真机 spike 先在本机验证；
+   T-204 再把原始截图接入采购服务供管理员查看。

 第一趟 capability **不得包含**通用 `click`、数量增减、进入订单确认页、提交订单或付款能力。
 “免拼购买 / 单独购买 / 直接拼成”等其他文案即使人工认为行为相同，也必须各自重新取证后才能评审；
@@ -194,10 +195,10 @@ V2 实现时仍遵守：**图搜的唯一产出是 goods_id**，不在搜索结
 | 提交订单控件唯一 | 文本精确等于「提交订单」且可点击祖先唯一，否则停 | 点到未知控件 |
 | 数量必须复核 | 设置后读回确认精确等于要求值，否则停 | 买错数量 |
 | 价格三道闸门 | 见第三节。任一道读不到或不通过即停，**不用其他位置的数字凑合** | 超预算采购 |
-| 第一趟不下单 | 只允许点击证据/版本绑定的精确唯一受控入口打开规格面板，当前仅为 `快要抢光`；随后只选规格、读价、脱敏取证和返回。数量、确认页、`提交订单`、付款与通用点击能力均不可达 | 无授权下单 |
+| 第一趟不下单 | 只允许点击证据/版本绑定的精确唯一受控入口打开规格面板，当前仅为 `快要抢光`；随后只选规格、读价、截图和返回。数量、确认页、`提交订单`、付款与通用点击能力均不可达 | 无授权下单 |
 | 外部支付页 | 检测到微信等外部支付交接立即停止、转人工、保留证据 | 凭据泄露 |
 | 安全校验 | 检测到验证码、风控、人脸、短信校验立即停止，不尝试绕过 | 封号 / 违规 |
-| 敏感信息 | 只读非敏感摘要，不提取收货地址原文、手机号、支付凭据 | 隐私泄露 |
+| 页面个人信息 | 内部原始截图可包含并上传页面已显示的地址、手机号，供已登录管理员查看；不得把这些内容解析成业务字段或写入普通日志、Git、Vikunja。支付凭据仍不得读取或上传 | 非必要扩散 / 凭据泄露 |
 | 授权一次性 | 一笔授权只能产生一笔订单，重复提交幂等 | 重复采购 |
 | 服务端提交围栏 | 真机点击前必须由采购服务原子冻结授权并创建唯一提交记录；失败或响应不明不得点击 | 并发 / 断网导致重复下单 |
 | App 版本失配即停 | 运行版本与本项目已取证版本不一致时停止领取真机任务，先重新取证 | 旧判据误点新页面 |
@@ -387,18 +388,23 @@ PENDING_RETRIAL ─────────────┴─claim→ CLAIMED

 | 数据 | 位置 | 理由 |
 | --- | --- | --- |
-| 原始商品页 / 规格页 screenshot/XML | **仅采购工具本机隔离目录** | PDD 页面不可避免包含收货区域和掩码手机号；只允许确定性脱敏器读取，不供业务、agent、fixture 或上传消费 |
-| 脱敏派生商品页 / 规格页截图 | 上传采购服务 | 管理员做授权决策必须看；服务端只接收派生哈希和 sanitizer 版本，原始/派生哈希映射仅留本机 manifest |
+| 原始商品页 / 规格页 screenshot | 采购工具本机 + 采购服务内部证据存储（T-204） | 内部系统允许保留页面中已显示的地址和手机号；设备鉴权后上传，只有已登录管理员可查看，不做遮罩或裁剪 |
+| 原始商品页 / 规格页完整 XML | **仅采购工具本机隔离目录** | 自动化运行时在内存中读取规格/价格，完整 XML 不上传、不进入日志、Git、Vikunja 或 fixture |
+| T-103 真机 spike 证据 | 先在采购工具本机；T-204 接入上传 | T-103 只验证选择与读价，不实现 HTTP 证据链；这是一项任务拆分，不是禁止原始截图上传 |
 | 最小脱敏 XML fixture | 采购工具测试 / 可提交 Git | 只保留页面判据所需结构；自动复检无地址、手机号、支付凭据后才可发布 |
-| 脱敏派生订单确认页截图 | 上传采购服务 | 授权后核对与审计必须留；原始物仍只在本机隔离目录 |
-| 脱敏派生订单核对截图 | 上传采购服务 | 资金核对证据；原始物仍只在本机隔离目录 |
+| 原始订单确认页截图 | 采购服务内部证据存储 | 授权后核对与审计必须留；允许页面已显示的地址/手机号，禁止外部支付凭据 |
+| 原始订单核对截图 | 采购服务内部证据存储 | 资金核对证据；只有已认证设备上传、已登录管理员查看 |
 | AI 调用记录（P1） | **仅采购工具本地** | 含 prompt / 响应全文，脱敏成本高 |
 | 失败现场快照 | 原始物仅采购工具本机；只能手工导出脱敏派生物 | 同上 |

-原始目录不得被 HTTP sink、Vikunja 导出、日志或 fixture 构建器读取。脱敏器必须先验证设备分辨率、
-页面/App 版本和预期隐私区域，再同时生成派生 screenshot/XML；派生 XML 仍命中手机号模式、截图隐私
-区域无法确定、sanitizer 异常或任一哈希不一致时，不发布派生目录。上传端只接受 manifest 明确标记
-`privacy_tier=SANITIZED` 的派生截图，**不上传含收货地址、手机号、支付凭据的区域或文本。**
+截图上传器只能接收调用方显式传入的截图文件，不能枚举整个原始目录，也不能上传 XML、manifest 中的
+本机路径或其他文件。采购工具可以在真机流程内存中读取当前页面树，但只返回规格、选中态、价格和页面
+状态摘要；不得把地址或手机号解析成结构化业务字段。原始 XML 不进入 HTTP、日志、Vikunja、Git 或
+fixture；仓库只允许进入与页面判据有关的最小 XML fixture。
+
+T-204 负责原始截图上传、SHA-256 校验、内部访问控制和保留策略，不再实现遮罩或裁剪。证据响应使用
+`Cache-Control: no-store`，不得暴露为无需登录的静态目录。外部支付页及任何支付凭据不属于“内部原图
+可上传”的范围，遇到支付交接仍立即停止。

 ## 六、关键技术难点

@@ -420,7 +426,7 @@ PENDING_RETRIAL ─────────────┴─claim→ CLAIMED

 1. **Phase 0 地基**：两端骨架、测试命令、`init` 脚本可运行。
 2. **Phase 1 真机取证**：WiFi ADB 连通；先验证第一趟的打开商品 → 受控打开规格面板 → 按维度
-   精确勾选颜色分类和尺码 → **读到该 SKU 单价** → 脱敏取证 → 退出；再以独立的第二趟 spike
+   精确勾选颜色分类和尺码 → **读到该 SKU 单价** → 原始截图取证 → 退出；再以独立的第二趟 spike
   验证设数量 → 进订单确认页 → 读「实付款」。第一趟 capability 不含后三项。
   **结论写入文档，判据带拼多多 App 版本。**
 3. **Phase 2 采购服务核心**：数据模型与状态机、手工建单、任务查询、试选结果接收、
@@ -435,7 +441,8 @@ PENDING_RETRIAL ─────────────┴─claim→ CLAIMED

 > 2026-08-04：Phase 1 证明已验证衣服商品没有独立规格入口。项目所有者随后批准 T-110 的受控入口
 > 方案：当前只允许证据绑定的精确唯一 `快要抢光` 打开规格面板，并以 capability 隔离保证数量、确认页、
-> 提交订单和付款在第一趟不可达。T-103 仍须先实现自动脱敏与新证据门禁，完成前 Phase 2 保持冻结。
+> 提交订单和付款在第一趟不可达。项目所有者随后决定加速 MVP：停止截图遮罩器开发，T-103 使用现有
+> 安全最小 XML 继续实现选择与读价；T-204 直接把内部原始截图上传采购服务，不遮罩地址或手机号。

 ## 八、项目结构

@@ -54,12 +54,13 @@

 - 检测到验证码、风控、人脸、短信校验时立即停止，**不尝试绕过**。
 - 检测到外部支付交接立即停止，**不读取、不保存、不输入任何凭据**。
- 只读非敏感摘要，**不提取收货地址原文、手机号、支付凭据**。
- 上传服务端的证据必须先脱敏。
- PDD 页面不可避免显示地址/掩码手机号时，原始 screenshot/XML 只允许写入采购工具本机隔离目录，
-  只由确定性脱敏器消费；业务代码、agent、fixture、日志和 HTTP sink 只能读取自动复检通过且 manifest
-  标记 `privacy_tier=SANITIZED` 的派生物。脱敏失败、分辨率/版本不符或派生 XML 仍命中手机号模式时
-  必须拒绝发布，不得用人工口头确认绕过。
+- 页面已显示的地址和手机号允许随**内部原始截图**上传采购服务，供已登录管理员核对；不做遮罩或裁剪。
+- 地址和手机号不得被解析为结构化业务字段，也不得写入普通日志、Git、Vikunja、fixture 或错误消息。
+  原始完整 XML 只留采购工具本机；真机流程可在内存中读取，但只能返回规格、选中态、价格和页面状态摘要。
+- 截图上传器只能接收显式文件，不得枚举原始目录或顺带上传 XML/manifest/其他文件；服务端必须校验
+  设备身份和 SHA-256，证据只允许已登录管理员访问，不得提供公开静态目录。
+- **支付凭据仍不得读取、保存或上传。** 外部支付交接不在“内部原图允许上传”的例外范围内。
+- T-103 停止遮罩器开发并专注真机选择/读价；生产原始截图上传由 T-204 实现。

 ### 1.5 页面判据

@@ -168,26 +168,29 @@
 - 无可领任务返回 `200` 且 `task` 为 `null`，**不是 404**。
 - 后续所有该任务的调用必须携带 `X-Claim-Token` 与匹配的 `claim_generation`。

-### `POST /api/v1/tasks/{id}/evidence`（只接收脱敏派生物）
+### `POST /api/v1/tasks/{id}/evidence`（内部原始截图）

-规格面板和订单确认页可能固定展示地址与掩码手机号。采购工具必须先在本机隔离目录保存原始证据，
-再由确定性脱敏器生成派生 screenshot/XML；本接口只接受派生截图及如下审计元数据：
+> 本接口属于生产第一趟证据链，由 T-204 实现。T-103 只做本机真机可行性验证，不调用本接口，
+> 也不为上传目的继续扩展截图遮罩器。正式流程直接上传原始截图；T-103 与 T-204 的区分只是任务拆分。
+
+这是内部系统。规格面板和订单确认页固定展示的地址与手机号允许保留在原始截图中。本接口只接受截图
+文件及如下审计元数据；完整 XML、manifest、本机路径和目录中的其他文件一律不接收：

 ```json
 {
  "kind": "SKU_PANEL_SCREENSHOT",
-  "privacy_tier": "SANITIZED",
-  "artifact_sha256": "<派生截图 SHA-256>",
-  "sanitizer_version": "sku-panel-pdd-8.17.0-v1"
+  "privacy_tier": "INTERNAL_RAW",
+  "artifact_sha256": "<原始截图 SHA-256>",
+  "pdd_version": "8.17.0"
 }
 ```

- `privacy_tier` 必须精确为 `SANITIZED`；缺失、其他值或 sanitizer 元数据不完整均拒绝。
- 上传内容的 SHA-256 必须等于 `artifact_sha256`。服务端不接收原始文件、原始哈希、原始路径、
-  原始 XML、地址、手机号或支付凭据；原始/派生哈希映射只存在于采购工具本机 manifest。
- 原始目录不得被 `HttpResultSink` 或证据上传器枚举；调用方必须显式传入已原子发布的派生目录。
- 完整 XML 永不上传。经自动复检的最小脱敏 XML 只用于采购工具离线 fixture；仍命中手机号模式或
-  脱敏结果不确定时，客户端调用 `/needs-manual`，不得上传截图或继续试选。
+- `privacy_tier` 必须精确为 `INTERNAL_RAW`，明确告知服务端该资产可能包含页面个人信息。
+- 上传截图的 SHA-256 必须等于 `artifact_sha256`。服务端不接收截图以外的原始文件、完整 XML、
+  本机路径、源 manifest 或地址/手机号的结构化字段。支付凭据和外部支付页截图始终拒绝。
+- 原始目录不得被 `HttpResultSink` 或证据上传器枚举；调用方必须显式传入单个截图文件。
+- 完整 XML 永不上传。最小 XML 只用于采购工具离线 fixture；fixture 不得包含地址、手机号或支付凭据。
+- 资产不得放在公开静态目录；读取要求管理会话，响应使用 `Cache-Control: no-store`。

 ### `POST /api/v1/tasks/{id}/spec-trial`（第一趟回传）

@@ -208,7 +211,7 @@
 - `unit_price` 来自闸门一（规格面板）。**读不到时不要发这个接口**，改发
  `/needs-manual` 并带原因码 `UNIT_PRICE_UNREADABLE`。
 - `total_price` = `unit_price` × 任务数量，服务端会重算校验。
- 证据须先经 `/evidence` 上传，且对应资产必须为 `privacy_tier=SANITIZED`。
+- 原始截图须先经 `/evidence` 上传，且对应资产必须为 `privacy_tier=INTERNAL_RAW`。
 - 服务端接收后创建 `spec_trials` 记录，任务转 `WAITING_CONFIRMATION`。

 ### dry-run 与真实提交协议
@@ -310,8 +313,8 @@ class ResultSink(ABC):
 | `open_product(url)` | TRIAL / ORDER | 商品 URL | 页面快照路径 | 只打开页面，不点击控件 |
 | `open_trial_sku_panel(evidence_key)` | **仅 TRIAL** | 版本与证据绑定键 | 面板快照 | 只点击精确唯一、已取证的受控入口；当前仅 `快要抢光`，无通用 click |
 | `select_sku_options(items)` | TRIAL / ORDER | `{维度: 值}` | 选中证据 | 按维度精确匹配，找不到抛错 |
-| `sanitize_evidence(raw_manifest)` | TRIAL / ORDER | 本机隔离目录 manifest | 派生 manifest | 原子发布脱敏派生物；失败不发布，原始内容不进入日志/上传 |
-| `read_sku_unit_price(xml)` | TRIAL / ORDER | 脱敏规格面板 XML | 单价或 `None` | **闸门一 / 二**；读不到返回 `None`，不猜 |
+| `capture_evidence(screenshot)` | TRIAL / ORDER | 单个原始截图路径 | 截图 SHA-256 | 只处理显式截图文件；不得枚举目录或读取/上传 XML，T-204 接入内部证据 API |
+| `read_sku_unit_price(xml)` | TRIAL / ORDER | 当前规格面板 XML 或安全最小 fixture | 单价或 `None` | **闸门一 / 二**；只返回金额摘要，读不到返回 `None`，不猜、不返回页面其他正文 |
 | `leave_product()` | TRIAL / ORDER | - | - | 第一趟结束时退出并释放手机 |
 | `set_quantity(n)` | **仅 ORDER** | 数量 | 读回值 | 必须复核等于 n；TRIAL capability 不暴露 |
 | `go_to_order_confirm()` | **仅 ORDER** | - | 确认页摘要 | 需显式授权；TRIAL capability 不暴露 |
@@ -21,7 +21,7 @@
  `client/` 已有 Python 包、PySide6 最小入口、运行目录与日志脱敏策略，以及显式 serial 的 ADB
  连接边界、本地基线取证 CLI、受限商品链接打开取证 CLI、人工声明规格面板状态的只读取证 CLI，
  以及绑定 PKG110 / Android 16 / 拼多多 8.17.0 的规格证据确定性脱敏 CLI；尚无规格选择、价格读取或下单流程
- 测试：采购服务已覆盖健康检查、核心模型、迁移与状态机等离线包级测试；采购工具 78 项离线单元测试
+- 测试：采购服务已覆盖健康检查、核心模型、迁移与状态机等离线包级测试；采购工具 80 项离线单元测试
  （全部 mock，不连接真机）
 - 数据：SQLite 核心表与迁移已落成；无业务实例数据
 - 标准启动路径：Windows PowerShell 运行 `./init.ps1`，Unix shell 运行 `./init.sh`。Windows 入口
@@ -31,13 +31,11 @@
  editable install / 包导入 / unittest / compileall，以及仓库上下文校验。可单独运行两端命令诊断。
 - 当前设备门禁：人工已确认拼多多 8.17.0、goods_id `937122477375` 的衣服商品只能通过“快要抢光”
  打开规格面板；T-110 已获项目所有者批准，只把该证据/版本绑定的精确唯一入口作为第一趟可逆导航，
-  数量、确认页、提交订单、付款与通用点击能力仍不可达。T-103 的原始证据本机隔离与确定性脱敏器
-  已完成离线实现；第一态 v3 derived 已由人确认隐私安全，并证明目标颜色和尺码自动预选，派生哈希
-  复算一致。顶部规格价格横跨隐私遮罩边界，当前只保留了不可读断片；唯一完整金额位于禁触的
-  “提交订单 ¥12.88”区域，不能作为第一趟价格证据。v4 已在保持截图遮罩不变的前提下，只允许顶部
-  交界带中满足精确坐标、拼多多包、非点击叶节点和严格金额格式的文本投影到派生 XML，离线门禁已通过；
-  下一步由人保留已验收 v3 derived，并用同一 raw 重跑 v4。价格证据通过后才采集“两个维度改为非目标 /
-  两个维度恢复目标”两态。T-010 已允许不依赖真机字段的 T-201 和只创建 `DRAFT` 的 T-202 并行；
+  数量、确认页、提交订单、付款与通用点击能力仍不可达。T-103 的 v5 派生 XML 已由人确认无实际地址/
+  手机号，并保留目标预选规格、顶部当前价“快卖完 ¥12.88”和原价“¥29.88”；底部“提交订单 ¥12.88”
+  继续属于硬拒绝区。派生截图虽然把顶部价格遮住一半，但项目已停止遮罩器开发，视觉完整性不再阻塞
+  规格选择与读价；T-204 将直接上传内部原始截图供管理员查看。T-010 已允许不依赖真机字段的 T-201 和只创建
+  `DRAFT` 的 T-202 并行；
  T-203 及后续会启动试选或依赖真机字段的 Phase 2 功能继续等待 T-103。

 ## 当前目录要点
@@ -65,7 +63,8 @@
 - 已完成 T-010（安全并行门禁）；T-201（管理员登录与会话）已在独立写路径并行开发。T-202 可在
  T-201 完成后继续，但只能创建和展示 `DRAFT`，不得启动试选或引入未经 T-103 证实的真机字段。
 - 已完成 T-110（第一趟受控规格入口与隐私脱敏边界）。T-103 是当前最高优先级和 MVP 生死线，
-  已补充 T-110 依赖并恢复 `DOING`；v4 脱敏器离线实现已完成，三态派生证据和新真机验收完成前不开发
+  已补充 T-110 依赖并保持 `DOING`；现有安全派生 XML 足以开始最小 fixture、规格选择与读价实现，
+  内部原始截图上传与展示交给 T-204；T-103 最终真机验收完成前不开发
  T-203 及后续依赖真机可读字段或会启动试选的 Phase 2 生产页面。
 - 已确认原型继续只作信息架构依据；原型假数据不调用真实接口、不驱动真机。真机结论改变
  可读字段时必须先回修原型与交互清单。
@@ -146,35 +145,16 @@ D:\Portable\adb\adb.exe devices -l
 不得提交 Git。T-102 已由人确认 goods_id `958756616606` 的目标商品及截图/XML 隐私，并完成验收。

 T-103 已确认当前衣服商品只能从精确文案“快要抢光”进入规格面板；T-110 只批准该证据/版本绑定入口，
-不授权“免拼购买 / 单独购买 / 直接拼成”等其他文案。现有只读取证脚本本身仍不打开面板、不点击或选择
-规格，也不读取价格；`--state` 只是人工声明，不能作为自动判据。面板刚打开时目标颜色
-“黑色CHA(纯棉)”与尺码“M(建议100-115)”已经自动选中，不强行取消。人依次准备刚打开目标预选、
-颜色和尺码均为非目标值、再恢复目标值三个状态，并分别采集到全新 `raw` 目录：
+不授权“免拼购买 / 单独购买 / 直接拼成”等其他文案。面板刚打开时目标颜色“黑色CHA(纯棉)”与尺码
+“M(建议100-115)”已经自动选中。v5 派生 XML 与人工观察已证明顶部当前价为“快卖完 ¥12.88”、
+并列原价为“¥29.88”；促销前缀会变化，正式读价不能把该文案作为主判据，必须以面板结构、价格角色、
+严格金额格式和唯一性组合判断，冲突时返回 unreadable。

-```powershell
-# 仓库根目录；三次采集使用三个全新的 output-dir
-.\client\.venv\Scripts\python.exe client\scripts\capture_sku_panel_spike.py --serial <SERIAL> --url "https://mobile.yangkeduo.com/goods.html?goods_id=<GOODS_ID>" --state panel-opened-target-preselected --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-opened-target-<GOODS_ID>-v2\raw" --timeout 10 --adb D:\Portable\adb\adb.exe
-.\client\.venv\Scripts\python.exe client\scripts\capture_sku_panel_spike.py --serial <SERIAL> --url "https://mobile.yangkeduo.com/goods.html?goods_id=<GOODS_ID>" --state alternate-all-dimensions-selected --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-alternate-<GOODS_ID>-v2\raw" --timeout 10 --adb D:\Portable\adb\adb.exe
-.\client\.venv\Scripts\python.exe client\scripts\capture_sku_panel_spike.py --serial <SERIAL> --url "https://mobile.yangkeduo.com/goods.html?goods_id=<GOODS_ID>" --state target-selection-restored --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-target-restored-<GOODS_ID>-v2\raw" --timeout 10 --adb D:\Portable\adb\adb.exe
-```
-
-每组 raw 采集成功后分别运行离线脱敏器；`derived` 必须尚不存在：
-
-```powershell
-.\client\.venv\Scripts\python.exe client\scripts\sanitize_sku_panel_evidence.py --raw-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-opened-target-<GOODS_ID>-v2\raw" --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-opened-target-<GOODS_ID>-v2\derived"
-.\client\.venv\Scripts\python.exe client\scripts\sanitize_sku_panel_evidence.py --raw-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-alternate-<GOODS_ID>-v2\raw" --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-alternate-<GOODS_ID>-v2\derived"
-.\client\.venv\Scripts\python.exe client\scripts\sanitize_sku_panel_evidence.py --raw-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-target-restored-<GOODS_ID>-v2\raw" --output-dir "$env:LOCALAPPDATA\cmbuyer\artifacts\T-103\sku-panel-target-restored-<GOODS_ID>-v2\derived"
-```
-
-PDD 现场显示地址和掩码手机号不阻塞真机流程；但原始 screenshot/XML 只能留在本机 `raw` 隔离目录，
-不能由 agent、fixture、业务或上传端消费。`t103-privacy-v4` 把截图与 XML 保持为两个独立坐标空间，
-并根据同一第一态 raw 的两次 fail-closed 安全观测将二者分别精确固定为 1080×2376；截图隐私带沿用
-v3，不扩大、不缩小。v4 只从两个精确交界 bounds 投影属于拼多多包、不可点击且格式严格唯一的价格
-叶节点，任何点击节点、包外节点、坐标/结构/文本漂移、重复或零值都 fail closed。它校验源哈希、
-设备/App/商品/人工状态与隐私结构，在 sibling `derived` 目录原子发布 screenshot/XML 与 manifest；
-任何不匹配、手机号残留或已有目标均拒绝发布。
-自动复检通过且人确认三态对应性后，agent 才能读取派生物并提取最小 fixture、编写判据。
-人工确认中还必须记录中间态实际选择的非目标颜色和尺码，不能只写“已切换”。
+本轮不再运行或修改截图遮罩器。T-103 先用本机证据验证真机能力；T-204 再把原始规格页截图上传采购
+服务，允许页面中已显示的地址和手机号，完整 XML 不上传。代码从已确认的派生 XML 提取最小 fixture，
+并在真机运行时只返回获准摘要。下一步实现 `TrialSkuFlow` 的受控入口、
+按维度精确选择、选中态读回、SKU 单价读取与安全退出；完成离线主审后，由人先把两个维度改成明确
+记录的非目标值，再执行真机脚本确认恢复目标规格与 `12.88` 单价。生产原始截图展示/上传由 T-204 处理。

 ## 关键背景

@@ -25,38 +25,39 @@ write_paths:
  - docs/current-state.md
 ---

-<!-- BEGIN VIKUNJA EXPORT id=23 synced=2026-08-04T06:56:08Z sha256=1f5f8b30076531a859c0cada576c91206cbe20471694a53690231fbb031e816e -->
+<!-- BEGIN VIKUNJA EXPORT id=23 synced=2026-08-04T07:46:08Z sha256=48f9e0a02fd330550ae8d749b142a05cb9d92b16c8ee795c6289ccaedde6bca9 -->
 ## 问题 / 背景

-T-102 已证明 canonical 链接可进入目标商品。T-103 随后在 PKG110 / Android 16 / 拼多多 8.17.0、衣服商品 goods_id `937122477375` 上确认：规格面板只能从详情页右下角精确文案“快要抢光”进入，面板固定显示收货区域和掩码手机号。T-110 经项目所有者批准，将该已取证点击定义为可逆、能力受限的规格面板导航；这不是通用购买入口豁免，不授权其他文案、数量、确认页、提交订单或支付。 项目所有者随后确认，面板刚打开时已自动选中目标颜色“黑色CHA(纯棉)”和尺码“M(建议100-115)”；因此本任务不再假设存在“未选择”或“只选择一个维度”的初始状态。
+T-102 已证明 canonical 链接可进入目标商品。T-103 在 PKG110 / Android 16 / 拼多多 8.17.0、goods_id `937122477375` 上确认：规格面板只能由详情页精确唯一的“快要抢光”打开；T-110 已把该入口批准为可逆、能力受限的第一趟导航。面板刚打开时目标颜色“黑色CHA(纯棉)”和尺码“M(建议100-115)”自动选中。
+
+真实 `t103-privacy-v5` 派生曾成功用于安全分析：顶部价格节点为“快卖完 ¥12.88”，并列原价为“¥29.88”；派生截图的整宽遮罩把顶部价格文字遮住一半。项目所有者确认 cmbuyer 是内部系统，要求停止遮罩返工：正式流程可以把包含页面地址/手机号的原始截图上传采购服务供已登录管理员查看。完整 XML 不上传，地址/手机号不解析为业务字段，支付凭据仍禁止处理。

 ## 关联需求与交互

- 功能：F-006 第一趟试选；覆盖自动脱敏、`open_trial_sku_panel()`、`select_sku_options()`、`read_sku_unit_price()` 的真机 spike。
- 用户故事：US-003、US-004、US-008；本任务无生产 GUI。
- 架构 / API：`docs/04-architecture.md` 第三、四、5.4、六节；`docs/api.md` 证据上传和 `TrialSkuFlow`；T-104、T-105 与 Phase 2 的前置。
+- 功能：F-006 第一趟试选；覆盖 `open_trial_sku_panel()`、`select_sku_options()`、`read_sku_unit_price()` 和安全退出的真机 spike。
+- 用户故事：US-003、US-004、US-008；本任务无生产 GUI。T-103 先验证本机真机能力，T-204 接入原始截图 HTTP 上传与管理员查看。
+- 架构 / API：`docs/04-architecture.md` 第三、四、5.4、六节；`docs/api.md` 的 `TrialSkuFlow`；T-104、T-105 与 Phase 2 的前置。

 ## 方案

-1. 先实现本机确定性脱敏器，不先写页面判据。原始 screenshot/XML 只保存到 `%LOCALAPPDATA%\cmbuyer\artifacts\T-103\...\raw`，只允许脱敏器消费；agent、fixture、业务、日志、HTTP sink、Vikunja 与 Git 均不得读取/上传原始内容。
-2. 脱敏器绑定 PKG110 分辨率、拼多多 8.17.0、goods_id、人工声明状态和本项目证据配置，同时从 screenshot/XML 移除收货区域、地址与手机号内容，在 sibling `derived` 目录原子发布派生物。派生 XML 仍命中手机号模式、隐私区域无法确认、结构/分辨率/版本失配、哈希不一致或目标目录存在时 fail closed，不发布半成品。服务端只接收派生截图哈希和 sanitizer 版本，不接收原始文件/哈希/路径/XML。
-3. 由人运行脱敏器并本地确认派生 screenshot/XML 的三种真实状态：panel-opened-target-preselected（刚打开且目标规格已自动选中）、alternate-all-dimensions-selected（人工把颜色和尺码都改成非目标值）、target-selection-restored（再把两个维度恢复为目标值）。主 agent 只在派生 manifest、每态实际选中值与人工确认齐全后读取派生证据，提取最小 fixture。首轮旧证据不得复用为 fixture。
-4. 实现 `TrialSkuFlow` 窄 capability。`open_trial_sku_panel()` 只允许拼多多 8.17.0、goods_id `937122477375` 上证据绑定、精确唯一的 `快要抢光`；缺失、重复、版本失配或打开后面板判据不唯一时零后续点击。`免拼购买 / 单独购买 / 直接拼成` 等其他文案必须分别取证，不能包含、前缀、同义、OCR 或坐标兜底。
-5. 第一趟 capability 只含打开商品、受控打开面板、在维度容器内精确选择、读面板单价、脱敏取证和返回。接口不得暴露通用 `click`、`set_quantity()`、`go_to_order_confirm()`、`submit_order()` 或支付能力；规格面板中的“提交订单”、微信支付、先用后付和 0 元下单只作为硬拒绝判据，静态调用链测试证明不可达。
-6. 在脱敏派生 XML 上按维度容器隔离候选，文本等值匹配并读回选中态；缺失、重复、禁用、维度不明或选中态不唯一均停止。纯函数测试覆盖 `红`/`粉红`、`1`/`10` 等前缀碰撞。
-7. 单价只从规格面板证据确定的唯一节点读取，以十进制字符串返回，禁止浮点。记录真实文本是否含优惠前缀、货币符号是否拆节点、是否并列原价/区间价；语义不唯一、节点缺失、候选冲突或只能从详情页读取时返回 unreadable。
-8. 人最终在真机先把两个维度改成一组明确记录的非目标值，再执行受控入口、精确选择和读价脚本恢复目标规格，确认实际选择颜色分类=黑色 CHA（纯棉）、尺码=M（建议100-115）（以派生 XML 精确文本为准）、面板单价语义、派生证据隐私与退出行为；agent 保持 DOING 直到人工验收。
+1. 停止修改或调用截图遮罩器。T-103 的截图先保存在 `%LOCALAPPDATA%\cmbuyer\artifacts\T-103\...` 完成本机验收；T-204 正式接入原始截图上传，资产标记 `privacy_tier=INTERNAL_RAW`，允许包含页面已显示的地址和手机号。
+2. 完整 XML 只留采购工具本机，不上传、不进日志、Vikunja 或 Git。以已确认的 v5 派生 XML 提取只含页面判据节点的最小 fixture；fixture 不含地址、手机号或支付凭据。
+3. 实现 `TrialSkuFlow` 窄 capability。`open_trial_sku_panel()` 只允许拼多多 8.17.0、goods_id `937122477375` 上证据绑定、精确唯一的 `快要抢光`；缺失、重复、版本失配或面板判据不唯一时零后续点击。其他购买文案不得复用。
+4. 第一趟只含打开商品、受控打开面板、在维度容器内精确选择、读回选中态、读取 SKU 单价、原始截图和退出。不得暴露通用 `click`、数量、确认页、提交订单或支付能力；“提交订单”、微信支付、先用后付和 0 元下单只作为硬拒绝判据。
+5. 规格选项按维度容器隔离后文本精确唯一匹配，防 `红`/`粉红`、`1`/`10` 前缀碰撞；缺失、重复、禁用、维度不明或选中态不唯一均停止。
+6. 单价只从已取证规格面板结构中的当前价角色读取，严格解析人民币两位小数字符串。促销前缀会变化，不能把“快卖完”作为主判据；必须限定 PDD package、面板结构/相对位置、非点击价格叶节点、唯一当前价，并排除原价及“提交订单/支付/优惠/预估”等语义。任一歧义返回 unreadable，不从详情页或底部提交区补值。
+7. 真机运行时在内存中读取当前页面树，只返回规格、选中态、价格和页面状态摘要；地址/手机号不解析为结构化字段。原始截图可由 T-204 显式上传，但截图上传器不得枚举目录或顺带上传 XML/manifest。
+8. 离线主审通过后，由人先把颜色和尺码改成明确记录的非目标值，再运行脚本恢复目标规格、读取 `12.88`、保存原始截图并安全退出。`needs_device=true`，agent 保持 DOING，等待人工验收。

 ## 验收要点

- 三组原始证据分别对应 panel-opened-target-preselected、alternate-all-dimensions-selected、target-selection-restored，且仅在本机 raw 目录；脱敏器离线测试覆盖地址/手机号移除、截图与 XML 同步处理、状态/版本/分辨率/结构失配、手机号残留、原子性、异常脱敏和已有目录不覆盖。
- 派生 manifest 记录 source/derived 本机哈希、sanitizer 版本、设备/App/goods_id/人工状态；原始页面正文、serial、地址和手机号不进入 manifest、日志、错误或上传。
- 只从人工验收通过的派生证据编写页面判据与最小 fixture；判据绑定拼多多 8.17.0 和证据哈希。
- `快要抢光` 精确唯一时才打开面板；其他文案、入口缺失/重复、面板不唯一、规格缺失/碰撞/禁用、价格不唯一均 fail closed。
- 静态 API/导入测试证明 T-103 第一趟无通用点击、数量、确认页、提交订单或支付能力，“提交订单”及资金控件不可达。
- 从规格面板可靠读取选中 SKU 单价为十进制字符串；无法唯一解释优惠价/原价/区间价时返回 unreadable。
+- 最小 fixture 只来自本项目拼多多 8.17.0、goods_id `937122477375` 的已验收 v5 派生 XML，不含地址、手机号或支付凭据。
+- `快要抢光` 精确唯一时才打开面板；其他入口、版本失配、面板不唯一、规格碰撞/禁用、选中态或价格不唯一均 fail closed。
+- 价格读取不依赖可变促销文案，能区分当前价 `12.88`、原价 `29.88` 和硬拒绝区“提交订单 ¥12.88”；金额只用十进制字符串。
+- 静态 API/导入测试证明第一趟无通用点击、数量、确认页、提交订单或支付能力。
+- T-103 不再开发遮罩；T-204 原始截图上传必须限制为显式截图文件、设备鉴权、SHA-256 校验和管理员会话读取，不上传完整 XML 或支付凭据。
 - client 全部单测、compileall、wheel metadata、上下文校验、完整 `init.ps1` 与 diff-check 通过。
- `needs_device=true`：只有人完成受控入口、精确选择、单价读取、派生证据对应性/隐私和安全退出验收后才能 DONE。
+- 只有人完成受控入口、精确规格选择、单价读取、页面对应性、原始截图与安全退出验收后才能 DONE。

 ## 执行记录

@@ -147,14 +148,29 @@ T-103 sanitizer v2 坐标修正与主审：提交 44c027a 将 screenshot space
 ### 2026-08-04T06:55:52Z · ila

 2026-08-04 项目所有者用同一第一态 raw 运行 v4，脱敏器按设计 fail closed：跨界价格节点文本不匹配，未发布 derived；raw 与已保留的 derived-v3-reviewed 未受损。提交 ef1ac60 增加最小安全诊断：失败只输出两个固定价格槽位和受控 reason 枚举，不回显原文、金额、数字串、字符码点、长度或原始属性，v4 成功白名单与原子不发布语义不变。主 agent 独立复跑 78 项 client 单测、compileall、CLI help 与 diff-check，全部通过。等待项目所有者用同一 raw 重跑并反馈 slot/reason；T-103 保持 DOING。
+
+### 2026-08-04T07:17:10Z · ila
+
+2026-08-04 项目所有者重跑安全诊断，固定当前价槽 [396,503][712,570] 返回 reason=known_prefix_missing，证明 raw 文本以“快”开头但不是 v4 假设的精确“快卖光”；该原因不足以证明具体前缀，成功白名单未放宽。提交 6e001b2 仅细分一个已人工观察过的安全枚举：若该槽精确以“快要抢光”开头则返回 observed_prefix_kuaiyaoqiangguang，其余“快”开头仍为 generic；不回显后缀、金额、长度、码点或 raw 属性。主 agent 独立复跑 79 项 client 单测、compileall 与 diff-check 通过。等待项目所有者用同一 raw 再次重跑；T-103 保持 DOING。
+
+### 2026-08-04T07:19:42Z · ila
+
+2026-08-04 项目所有者在手机 live 规格面板人工确认：固定顶部当前价槽的完整非敏感文字为“快卖完 ¥12.88”；底部购买按钮“快要抢光”是另一控件。主 agent 未读取 raw。该事实解释了 v4 对未经验证“快卖光”假设的两次安全拒绝。下一步升级 v5：删除“快卖光”成功假设，只允许证据绑定的精确“快卖完”当前价；坐标、遮罩、结构、PDD package、非点击叶节点、唯一性与原价限制全部不变。T-103 保持 DOING。
+
+### 2026-08-04T07:42:53Z · ila
+
+2026-08-04 范围调整：`t103-privacy-v5` 已在真实第一态成功生成，人工确认派生 XML 无实际地址/手机号、目标规格保留；顶部当前价为“快卖完 ¥12.88”、原价为“¥29.88”，底部“提交订单 ¥12.88”继续属于第一趟硬拒绝区。派生截图的整宽遮罩把顶部价格遮住一半。项目所有者要求停止遮罩返工并加速 MVP：T-103 不上传规格页截图，以安全最小 XML fixture 继续选择/读价；正式管理员证据截图归 T-204，上传端仍不得接收地址、手机号或支付凭据。未完成真机选择/读价验收，T-103 保持 Doing。
+
+### 2026-08-04T07:45:57Z · ila
+
+2026-08-04 最终范围澄清：上一条“正式截图仍需脱敏/裁剪”的记录已被项目所有者新决定取代。cmbuyer 是内部系统，正式第一趟允许把包含页面已显示地址/手机号的原始截图上传采购服务，不做遮罩或裁剪；T-204 负责设备鉴权上传、SHA-256 校验与管理员会话访问。完整 XML、普通日志、Git、Vikunja 和支付凭据仍不接收。T-103 立即停止遮罩开发，继续受控规格选择与 SKU 读价，任务保持 Doing。
 <!-- END VIKUNJA EXPORT -->

 ## 边界

- 任何规格面板入口、维度容器、选项、选中态和价格判据都必须来自本项目新采集、自动复检通过的
-  拼多多 8.17.0 **脱敏派生** screenshot/XML；T-102 详情页证据只能证明已到目标商品，不能证明
-  规格面板结构。派生证据路径、SHA-256、goods_id、设备、Android、App 与 sanitizer 版本写入
-  执行记录之前，不得提交页面判据代码。
+- 任何规格面板入口、维度容器、选项、选中态和价格判据都必须来自本项目拼多多 8.17.0 真机证据；
+  T-102 详情页证据只能证明已到目标商品，不能证明规格面板结构。T-103 只使用已由人确认无实际地址/
+  手机号的 v5 派生 XML 提取最小 fixture；派生截图的上传适用性不再是本任务的代码门禁。
 - 第一趟只允许 T-110 批准的 `open_trial_sku_panel()` 窄能力点击证据/版本绑定、精确唯一的
  `快要抢光`；当前事实仅覆盖 goods_id `937122477375`、拼多多 `8.17.0`。不得把“免拼购买 /
  单独购买 / 直接拼成”等其他文案加入包含、前缀、同义或坐标兜底，分别取证前一律拒绝。
@@ -169,11 +185,11 @@ T-103 sanitizer v2 坐标修正与主审：提交 44c027a 将 screenshot space
  规格面板中的“提交订单”、微信支付、先用后付、0 元下单只可作为硬拒绝判据，不能返回可点击对象。
 - 不把 `/mnt/d/chengma/cmroubao`、`/mnt/d/chengma/cmpdd` 或任何旧版本的节点、Activity、选择器、
  坐标、文本形态和页面结论当作事实；前序项目只可用于理解为什么必须 fail closed。
- 原始 screenshot/XML 只保存在 `%LOCALAPPDATA%\cmbuyer\artifacts\T-103\...\raw`，只允许本机
-  确定性脱敏器消费，不得由 agent、业务、fixture、HTTP sink、Vikunja 或 Git 读取/上传。脱敏器必须
-  校验设备分辨率、页面/App 版本和预期隐私区域，同时移除 screenshot/XML 中的地址与手机号内容；
-  派生 XML 仍命中手机号模式、结构/版本/分辨率失配或哈希不一致时不得发布 `derived`。
- 只有自动复检通过的最小脱敏 fixture、派生路径/哈希、sanitizer 版本与非敏感结论可入库；服务端
-  不接收原始文件、原始路径或原始哈希。
+- 原始完整 XML 只保存在 `%LOCALAPPDATA%\cmbuyer\artifacts\T-103\...\raw`，不得由 HTTP sink、
+  Vikunja 或 Git 读取/上传。真机流程可在内存中读取当前页面树，但只返回规格、选中态、价格和页面
+  状态摘要；不得把地址、手机号或支付凭据解析成业务字段或写入日志。
+- T-103 不再扩展截图遮罩器；本任务先以本机原始截图完成真机验收。生产第一趟原始截图上传由 T-204
+  接入，允许截图包含页面已显示的地址和手机号，但只允许已认证设备上传、已登录管理员查看；完整 XML、
+  外部支付页和支付凭据不得上传。
 - `needs_device: true`：agent 只能完成离线实现并保持 `DOING`；只有人完成安全入口、精确规格选择、
-  SKU 单价语义、页面对应性与派生证据验收后才能标 `DONE`。
+  SKU 单价语义、页面对应性与安全退出验收后才能标 `DONE`。HTTP 截图上传实现不属于 T-103 验收。
@@ -1,75 +0,0 @@
---
-id: T-202
-title: 手工建单与 DRAFT 基础列表
-phase: 2
-deps: [T-201, T-004, T-005]
-status: DONE
-created: 2026-08-04
-vikunja_task_id: 27
-context_ref: 1c35155
-work_branch: task/t-202-admin-draft
-needs_device: false
-needs_human_review: false
-write_paths:
-  - docs/tasks/T-202.md
-  - admin/cmd/server/main.go
-  - admin/internal/config/**
-  - admin/internal/server/**
-  - admin/internal/tasks/**
-  - admin/internal/storage/sqlite/**
-  - admin/internal/transport/webui/**
-  - admin/README.md
---
-
-<!-- BEGIN VIKUNJA EXPORT id=27 synced=2026-08-04T08:32:16Z sha256=39e3b06bab4ca86e97b961a4eb6bb0a4f1e88b29dae4d50f916779f7e761424c -->
-## 问题 / 背景
-
-T-201 已提供管理员会话；T-004 已提供 tasks 表。根据 T-010 加速门禁，T-103 尚未完成时只允许实现不启动试选的 DRAFT 手工建单与基础列表。
-
-## 关联需求与交互
-
-F-001、US-001、IX-002；GET /tasks、GET /tasks/new、POST /tasks；沿用已确认的传统表格与创建弹窗/直达页。
-
-## 方案
-
-1. 显式数据库配置并打开已迁移 SQLite；以仓储接口隔离 HTTP 和 SQL，创建事务只写 MANUAL、DRAFT、version=1。
-2. 表单校验任务名称、canonical 拼多多链接、颜色分类、尺码、正整数数量和正十进制总额上限；金额只用字符串并规范为两位小数。链接只接受 HTTPS mobile.yangkeduo.com/goods.html 且 goods_id 为唯一纯数字参数，额外查询参数不进入数据库。
-3. 以服务端生成的 create_key 同时作为任务 ID；重复相同 key 和相同内容返回原结果，不创建第二条，内容不同则冲突。
-4. GET /tasks 默认 created_at DESC 显示 DRAFT 基础表格；创建入口用服务端渲染的 modal 状态，/tasks/new 复用同一表单作为无脚本兜底；失败保留非密码输入并显示字段错误，成功 303 回列表且新任务第一行。
-5. 页面只显示需求字段、采购结果占位、DRAFT 状态与创建时间；不读取或伪造规格面板价格/证据，不提供勾选开始试选、状态推进、详情或设备接口。
-
-## 验收要点
-
- 覆盖创建成功、倒序第一行、严格链接/goods_id、数量、金额、空白/长度、CSRF/未登录、幂等重放与冲突、SQL 错误 fail closed。
- 弹窗与 /tasks/new 共享校验；错误保留输入并可访问；标题只链接到由 goods_id 重建的 canonical PDD URL并使用安全新标签属性。
- go test ./...、go test -race ./...、go vet ./...、go build ./...、完整 init.ps1、上下文校验和 diff-check 通过。
-
-## 执行记录
-
-### 2026-08-04T08:30:47Z · ila
-
-已完成：DRAFT 手工建单与基础列表；已验证链接、金额、CSRF、幂等、SQLite 并发和 SSR 无障碍，Go 与上下文门禁均通过。
-<!-- END VIKUNJA EXPORT -->
-
-## 边界
-
- 本任务只创建 `source=MANUAL`、`status=DRAFT`、`version=1` 的任务并显示 DRAFT 基础列表；不得
-  实现勾选、批量开始试选、`DRAFT → PENDING` 或任何其他状态流转，也不得新增设备领取接口。
- 不增加或修改数据库 schema，不读写 `spec_trials`、`order_authorizations`、`order_submissions`，
-  不生成或展示机器实际规格、规格面板单价、截图、证据哈希或 PDD 页面判据。
- 启动服务必须从显式 `CMBUYER_DATABASE_SOURCE` 读取 SQLite data source；缺失时明确失败，不提供
-  隐式内存库或仓库内默认数据库。服务不自动猜迁移目录；README 必须先给出显式迁移命令。
- 商品链接只接受 `https://mobile.yangkeduo.com/goods.html`，且必须恰有一个纯数字 `goods_id`；
-  拒绝 userinfo、端口、fragment、重复参数、其他 host/scheme/path 和编码绕过。数据库只保存 goods_id，
-  展示链接由 goods_id 重建 canonical URL；`uin` 等额外查询参数既不保存也不回显。
- 标题、颜色分类、尺码必须去除首尾空白后非空并受明确长度上限约束；数量必须是可表示的正整数；
-  总额上限必须是大于零、最多两位小数的十进制字符串并规范为两位小数。金额校验、保存与展示均不得
-  使用浮点数或从其他数字推测。
- `create_key` 由服务端用 `crypto/rand` 生成并验证格式，同时作为任务 ID；相同 key 与相同规范化内容
-  重放只能返回原任务，不得二次 INSERT，相同 key 携带不同内容必须冲突。SQL 必须参数化，创建失败
-  不得留下半条或未知状态记录。
- `GET /tasks`、`GET /tasks/new`、`POST /tasks` 都必须复用 T-201 管理会话；POST 必须验证 CSRF。
-  校验失败保留非敏感输入并逐字段提示，数据库内部错误只给通用响应，不泄露 SQL、路径或凭据。
- 页面只使用服务端模板转义；标题商品链接在新标签打开时必须带 `noopener noreferrer`。导入按钮只作
-  禁用占位；不得加载外部资源或把原型假数据、真机数据、地址、手机号带进生产页面。
- 不实现或引用试选、数量设置、订单确认、提交围栏、提交订单、付款、免密支付或先用后付能力。
Author	SHA1	Message	Date
QiuSW	efeb2d958a	docs(architecture): allow internal raw evidence screenshots	2026-08-04 15:47:47 +08:00
QiuSW	549099ad24	merge: T-103 observed price prefix	2026-08-04 15:23:10 +08:00
QiuSW	76a522f13f	fix(client): bind T-103 observed price prefix	2026-08-04 15:23:02 +08:00
QiuSW	5088d544f2	merge: T-103 refined prefix diagnostics	2026-08-04 15:16:44 +08:00
QiuSW	6e001b2729	fix(client): refine T-103 prefix diagnostics	2026-08-04 15:16:30 +08:00