From 846442f478df9385304f9e08b46f694cb20bde0a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Mon, 23 Dec 2019 10:29:35 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=88=A9=E6=B6=A6=E6=8A=A5?=
 =?UTF-8?q?=E8=AD=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../jxcallback/scheduler/defsch/defsch.go     | 43 +++++++++++++++++++
 1 file changed, 43 insertions(+)

diff --git a/business/jxcallback/scheduler/defsch/defsch.go b/business/jxcallback/scheduler/defsch/defsch.go
index 4f1c53477..6207f0a97 100644
--- a/business/jxcallback/scheduler/defsch/defsch.go
+++ b/business/jxcallback/scheduler/defsch/defsch.go
@@ -6,11 +6,14 @@ import (
 	"sync"
 	"time"
 
+	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
+
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 	"git.rosy.net.cn/jx-callback/business/jxutils/netprinter"
 	"git.rosy.net.cn/jx-callback/business/jxutils/smsmsg"
 	"git.rosy.net.cn/jx-callback/business/msghub"
 
+	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxcallback/scheduler"
 	"git.rosy.net.cn/jx-callback/business/jxcallback/scheduler/basesch"
@@ -1277,6 +1280,7 @@ func (s *DefScheduler) notifyNewOrder(order *model.GoodsOrder) {
 			netprinter.PrintOrderByOrder(jxcontext.AdminCtx, order)
 			weixinmsg.NotifyNewOrder(order)
 			smsmsg.NotifyNewOrder(order)
+			OrderProfitWarning(order)
 		})
 	}
 }
@@ -1313,3 +1317,42 @@ func isOrderCanSwitch2SelfDeliver(order *model.GoodsOrder) (isCan bool) {
 	}
 	return isCan
 }
+
+func OrderProfitWarning(order *model.GoodsOrder) {
+	var (
+		operatorName string
+		noticeMsg    string
+		profit       float64
+		storeID      int
+	)
+	db := dao.GetDB()
+	if order == nil {
+		return
+	}
+	if order.JxStoreID == 0 {
+		storeID = order.StoreID
+	} else {
+		storeID = order.JxStoreID
+	}
+	storeDetail, err := dao.GetStoreDetail(db, storeID, order.VendorID)
+	if storeDetail != nil && err == nil {
+		payPercentage := storeDetail.PayPercentage
+		if payPercentage >= 50 {
+			profit = utils.Str2Float64(utils.Int64ToStr(order.TotalShopMoney-order.EarningPrice-order.DistanceFreightMoney-order.WaybillTipMoney)) / 100
+		} else {
+			profit = utils.Str2Float64(utils.Int64ToStr(order.TotalShopMoney*int64(payPercentage)/200)) / 100
+		}
+		if profit < 0 {
+			if storeDetail.OperatorName != "" {
+				operatorName = storeDetail.OperatorName
+			} else if storeDetail.OperatorName2 != "" {
+				operatorName = storeDetail.OperatorName2
+			}
+			noticeMsg = fmt.Sprintf("订单号：[%v]，利润 ：[%v]，运营负责人：[%v]", order.VendorOrderID, profit, operatorName)
+			user, err := dao.GetUserByID(db, "name", operatorName)
+			if user != nil && err == nil {
+				ddmsg.SendUserMessage(dingdingapi.MsgTyeText, user.UserID, "警告！此订单利润低于0", noticeMsg)
+			}
+		}
+	}
+}