From 90860121bd5e2b49cfc8181d7a6e3519b275a423 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 17 Mar 2021 10:44:38 +0800
Subject: [PATCH] aa

---
 business/jxstore/report/report.go | 23 ++++++++++++++++++-----
 1 file changed, 18 insertions(+), 5 deletions(-)

diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go
index df8d630f6..535b8bd5f 100644
--- a/business/jxstore/report/report.go
+++ b/business/jxstore/report/report.go
@@ -400,7 +400,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
 		db                       = dao.GetDB()
 		vendorIDs                = []int{model.VendorIDJD, model.VendorIDMTWM, model.VendorIDEBAI}
 		dayTimeBegin, dayTimeEnd = utils.Str2Time(utils.Time2Str(utils.Time2Date(time.Now())) + "00:00:00"), utils.Str2Time(utils.Time2Str(utils.Time2Date(time.Now())) + "23:59:59")
-		// coverAreaFlag            = time.Now().Hour() == 9 && time.Now().Minute() > 50 && time.Now().Minute() < 59
+		coverAreaFlag            = time.Now().Hour() == 10 && time.Now().Minute() > 0 && time.Now().Minute() < 12
 	)
 	task := tasksch.NewParallelTask("RefreshStoreManageState", tasksch.NewParallelConfig().SetParallelCount(3).SetIsContinueWhenError(true), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
@@ -431,10 +431,23 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
 					//营业状态
 					storeManage.VendorStatus = store.Status
 					//不一致发消息
-					if storeDetail.Status != store.Status {
-						content := "您的门店 [" + storeDetail.Name + "]，ID:[" + utils.Int2Str(storeDetail.ID) + "]，在[" + model.VendorChineseNames[vendorID] + "] 平台上营业状态和京西不一致！平台状态：[" + model.StoreStatusName[store.Status] + "]，京西状态：[" + model.StoreStatusName[storeDetail.Status] + "]"
-						if user, err := dao.GetUserByID(db, "mobile", storeDetail.MarketManPhone); err == nil {
-							ddmsg.SendUserMessage(dingdingapi.MsgTyeText, user.UserID, "平台门店状态变化", content)
+					if coverAreaFlag {
+						vendorStatus, status := -1, -1
+						if store.Status == model.StoreStatusOpened {
+							vendorStatus = 1
+						}
+						if storeDetail.Status == model.StoreStatusOpened {
+							status = 1
+						}
+						statusMap := map[int]string{
+							1:  "营业",
+							-1: "休息",
+						}
+						if vendorStatus != status {
+							content := "您的门店 [" + storeDetail.Name + "]，ID:[" + utils.Int2Str(storeDetail.ID) + "]，在[" + model.VendorChineseNames[vendorID] + "] 平台上营业状态和京西不一致！平台状态：【" + statusMap[vendorStatus] + "】，京西状态：【" + statusMap[status] + "】"
+							if user, err := dao.GetUserByID(db, "mobile", storeDetail.MarketManPhone); err == nil {
+								ddmsg.SendUserMessage(dingdingapi.MsgTyeText, user.UserID, "平台门店状态变化", content)
+							}
 						}
 					}
 					//营业时长