Merge remote-tracking branch 'origin/master'

svc/routes/order_mail.go

@@ -9,11 +9,16 @@ import (
 	"net/http"
 	"strings"
 
+	"bssapp-backend/auth"
 	"bssapp-backend/internal/mailer"
 )
 
 type sendOrderMarketMailPayload struct {
-	OrderHeaderID string `json:"orderHeaderID"`
+	OrderHeaderID string   `json:"orderHeaderID"`
+	Operation     string   `json:"operation"`
+	DeletedItems  []string `json:"deletedItems"`
+	UpdatedItems  []string `json:"updatedItems"`
+	AddedItems    []string `json:"addedItems"`
 }
 
 func SendOrderMarketMailHandler(pg *sql.DB, mssql *sql.DB, ml *mailer.GraphMailer) http.HandlerFunc {
@@ -28,6 +33,11 @@ func SendOrderMarketMailHandler(pg *sql.DB, mssql *sql.DB, ml *mailer.GraphMaile
 			http.Error(w, "database not initialized", http.StatusInternalServerError)
 			return
 		}
+		claims, ok := auth.GetClaimsFromContext(r.Context())
+		if !ok || claims == nil {
+			http.Error(w, "unauthorized", http.StatusUnauthorized)
+			return
+		}
 
 		var payload sendOrderMarketMailPayload
 		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
@@ -80,14 +90,52 @@ func SendOrderMarketMailHandler(pg *sql.DB, mssql *sql.DB, ml *mailer.GraphMaile
 			marketLabel = strings.TrimSpace(marketCode)
 		}
 
-		subject := fmt.Sprintf("Sipariş %s - %s", number, marketLabel)
-		bodyHTML := fmt.Sprintf(
-			`<p>Sipariş kaydı oluşturuldu/güncellendi.</p><p><b>Sipariş No:</b> %s<br/><b>Cari:</b> %s<br/><b>Piyasa:</b> %s</p><p>PDF ektedir.</p>`,
-			htmlEsc(number),
-			htmlEsc(currAccCode),
-			htmlEsc(marketLabel),
+		actor := strings.TrimSpace(claims.Username)
+		if actor == "" {
+			actor = strings.TrimSpace(claims.V3Username)
+		}
+		if actor == "" {
+			actor = "Bilinmeyen Kullanici"
+		}
+
+		op := strings.ToLower(strings.TrimSpace(payload.Operation))
+		isUpdate := op == "update"
+
+		subjectAction := "SİPARİŞ KAYDI OLUŞTURULDU"
+		if isUpdate {
+			subjectAction = "SİPARİŞ GÜNCELLENDİ."
+		}
+		subject := fmt.Sprintf("%s kullanıcısı tarafından %s %s", actor, number, subjectAction)
+
+		cariDetail := ""
+		customerRep := ""
+		if header != nil {
+			cariDetail = strings.TrimSpace(header.CurrAccName)
+			customerRep = strings.TrimSpace(header.CustomerRep)
+		}
+
+		body := make([]string, 0, 12)
+		body = append(body,
+			`<p>`,
+			fmt.Sprintf(`<b>Cari Kodu:</b> %s<br/>`, htmlEsc(currAccCode)),
+			fmt.Sprintf(`<b>Cari Detay:</b> %s<br/>`, htmlEsc(cariDetail)),
+			fmt.Sprintf(`<b>Müşteri Temsilcisi:</b> %s<br/>`, htmlEsc(customerRep)),
+			fmt.Sprintf(`<b>Piyasa:</b> %s`, htmlEsc(marketLabel)),
+			`</p>`,
 		)
 
+		if isUpdate {
+			body = append(body,
+				renderItemListHTML("Silinen Ürün Kodları", payload.DeletedItems),
+				renderItemListHTML("Güncellenen Ürün Kodları", payload.UpdatedItems),
+				renderItemListHTML("Eklenen Ürün Kodları", payload.AddedItems),
+			)
+		}
+
+		body = append(body, `<p><i>Bu sipariş BaggiSS App Uygulamasından oluşturulmuştur.</i></p>`)
+		body = append(body, `<p>PDF ektedir.</p>`)
+		bodyHTML := strings.Join(body, "\n")
+
 		fileNo := sanitizeFileName(number)
 		if fileNo == "" {
 			fileNo = orderID
@@ -256,3 +304,31 @@ func htmlEsc(s string) string {
 	)
 	return r.Replace(s)
 }
+
+func renderItemListHTML(title string, items []string) string {
+	clean := make([]string, 0, len(items))
+	seen := make(map[string]struct{}, len(items))
+	for _, raw := range items {
+		v := strings.TrimSpace(raw)
+		if v == "" {
+			continue
+		}
+		if _, ok := seen[v]; ok {
+			continue
+		}
+		seen[v] = struct{}{}
+		clean = append(clean, v)
+	}
+
+	if len(clean) == 0 {
+		return fmt.Sprintf(`<p><b>%s:</b> Yok</p>`, htmlEsc(title))
+	}
+
+	b := make([]string, 0, len(clean)+3)
+	b = append(b, fmt.Sprintf(`<p><b>%s:</b><br/>`, htmlEsc(title)))
+	for _, item := range clean {
+		b = append(b, "- "+htmlEsc(item)+"<br/>")
+	}
+	b = append(b, `</p>`)
+	return strings.Join(b, "\n")
+}