订单利润报警

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)
+			}
+		}
+	}
+}