From ccc6fbb0e27a37d162b4cf2a7eed70f5397dc30e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Fri, 12 Jun 2020 17:35:40 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E4=BA=8F=E6=8D=9F=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E7=BB=99=E9=97=A8=E5=BA=97=E8=B4=9F=E8=B4=A3=E4=BA=BA?=
 =?UTF-8?q?=E7=BB=84=E5=8F=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/business/jxcallback/scheduler/defsch/defsch.go b/business/jxcallback/scheduler/defsch/defsch.go
index 05a191a65..ab88ab3eb 100644
--- a/business/jxcallback/scheduler/defsch/defsch.go
+++ b/business/jxcallback/scheduler/defsch/defsch.go
@@ -6,6 +6,10 @@ import (
 	"sync"
 	"time"
 
+	"git.rosy.net.cn/jx-callback/business/jxstore/cms"
+
+	"git.rosy.net.cn/jx-callback/business/authz"
+	"git.rosy.net.cn/jx-callback/business/authz/autils"
 	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	"git.rosy.net.cn/jx-callback/business/partner/purchase/jdshop"
 
@@ -1449,11 +1453,34 @@ func OrderProfitWarning(order *model.GoodsOrder) {
 		}
 		if profit < 0 {
 			operatorPhone, operatorName := getOrderOperatorInfo(order, storeDetail)
+			operatorRole := getOrderOperatorRoleInfo(order, storeDetail)
 			if operatorPhone != "" {
+				var (
+					roleList []*authz.RoleInfo
+					userIDs  []string
+					flag     = false
+				)
+				roleList = append(roleList, autils.NewRole(operatorRole, 0))
+				userIDMap, err := cms.GetRolesUserList(jxcontext.AdminCtx, roleList)
 				noticeMsg := fmt.Sprintf("利润 ：[%v]，运营负责人：[%v]，门店ID：[%v]，平台门店ID[%v]，门店名：[%v]，订单序号：[%v]，订单号(点击进入详情)：%v", profit, operatorName, order.StoreID, order.VendorStoreID, order.StoreName, order.OrderSeq, globals.BackstageHost+"/#/ordermanager/"+order.VendorOrderID)
 				user, err := dao.GetUserByID(db, "mobile", operatorPhone)
 				if user != nil && err == nil {
-					ddmsg.SendUserMessage(dingdingapi.MsgTyeText, user.UserID, "警告！此订单利润低于0", noticeMsg)
+					for _, v := range userIDMap {
+						for _, vv := range v {
+							userIDs = append(userIDs, vv)
+						}
+					}
+					for _, v := range userIDs {
+						if v == user.UserID {
+							flag = true
+						}
+					}
+					if !flag {
+						userIDs = append(userIDs, user.UserID)
+					}
+					for _, v := range userIDs {
+						ddmsg.SendUserMessage(dingdingapi.MsgTyeText, v, "警告！此订单利润低于0", noticeMsg)
+					}
 				}
 			}
 		}
@@ -1502,3 +1529,15 @@ func getOrderOperatorInfo(order *model.GoodsOrder, storeDetail *dao.StoreDetail)
 	}
 	return operatorPhone, operatorName
 }
+
+func getOrderOperatorRoleInfo(order *model.GoodsOrder, storeDetail *dao.StoreDetail) (roleName string) {
+	switch order.VendorID {
+	case model.VendorIDJD:
+		roleName = storeDetail.OperatorRole
+	case model.VendorIDMTWM:
+		roleName = storeDetail.OperatorRole2
+	case model.VendorIDEBAI:
+		roleName = storeDetail.OperatorRole3
+	}
+	return roleName
+}