diff --git a/business/jxcallback/scheduler/defsch/defsch.go b/business/jxcallback/scheduler/defsch/defsch.go index edc08b798..ca06e95df 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" @@ -1275,6 +1278,7 @@ func (s *DefScheduler) notifyNewOrder(order *model.GoodsOrder) { netprinter.PrintOrderByOrder(jxcontext.AdminCtx, order) weixinmsg.NotifyNewOrder(order) smsmsg.NotifyNewOrder(order) + OrderProfitWarning(order) }) } } @@ -1311,3 +1315,42 @@ func isOrderCanSwitch2SelfDeliver(order *model.GoodsOrder) (isCan bool) { } return isCan } + +//订单预计利润若低于0,则向门店运营负责人发送钉钉消息 +func OrderProfitWarning(order *model.GoodsOrder) { + var ( + operatorName string + operatorPhone string + noticeMsg string + profit float64 + storeID int + ) + db := dao.GetDB() + if order == nil { + return + } + storeID = jxutils.GetShowStoreIDFromOrder(order) + 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.OperatorPhone != "" { + operatorName = storeDetail.OperatorName + operatorPhone = storeDetail.OperatorPhone + } else if storeDetail.OperatorPhone2 != "" { + operatorName = storeDetail.OperatorName2 + operatorPhone = storeDetail.OperatorPhone2 + } + noticeMsg = fmt.Sprintf("订单号:[%v],利润 :[%v],运营负责人:[%v]", order.VendorOrderID, profit, operatorName) + user, err := dao.GetUserByID(db, "mobile", operatorPhone) + if user != nil && err == nil { + ddmsg.SendUserMessage(dingdingapi.MsgTyeText, user.UserID, "警告!此订单利润低于0", noticeMsg) + } + } + } +}