From 946810c1771531c6b02b542cc0c3f6a6fe642633 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Fri, 10 Jul 2020 09:06:24 +0800 Subject: [PATCH 1/7] =?UTF-8?q?SensitiveWord=E7=9B=B8=E5=85=B3=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sku.go | 2 +- business/model/dao/sensitive_words.go | 23 ++++++++++++++++++----- controllers/cms_sku.go | 7 ++++--- 3 files changed, 23 insertions(+), 9 deletions(-) diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index c0344b3eb..2eac14c28 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -727,7 +727,7 @@ func CheckHasSensitiveWord(word string) (bool, error) { } func IsSensitiveWordInList(str string) (bool, string) { - wordList, err := dao.GetSensitiveWordList() + wordList, err := dao.GetSensitiveWordList(2) if err == nil { for _, value := range wordList { keyWord := value.Word diff --git a/business/model/dao/sensitive_words.go b/business/model/dao/sensitive_words.go index 47055aa75..51bb85388 100644 --- a/business/model/dao/sensitive_words.go +++ b/business/model/dao/sensitive_words.go @@ -7,22 +7,32 @@ import ( "time" ) -func GetSensitiveWordList() (wordList []*model.SensitiveWord, err error) { - sql := `SELECT * FROM sensitive_word WHERE deleted_at = ?` - err = GetRows(nil, &wordList, sql, utils.DefaultTimeValue) +/*VendorID = 2 的时候是通用，保留之前的1，看后面会不会有扩展*/ +func GetSensitiveWordList(vendorID int) (wordList []*model.SensitiveWord, err error) { + if vendorID == 0 { + vendorID = 2 + } + sql := `SELECT * FROM sensitive_word WHERE deleted_at = ? AND vendor_id = ?` + err = GetRows(nil, &wordList, sql, utils.DefaultTimeValue, vendorID) return wordList, err } func InsertSensitiveWord(word string, vendorID int, userName string) error { + if vendorID == 0 { + vendorID = 2 + } sensitiveWord := &model.SensitiveWord{Word: word, VendorID: vendorID} WrapAddIDCULDEntity(sensitiveWord, userName) return CreateEntity(nil, sensitiveWord) } -func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string) (word *model.SensitiveWord, err error) { +func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string, vendorID int) (word *model.SensitiveWord, err error) { if id == 0 { return nil, errors.New("入参错误，找不到相应ID") } + if vendorID == 0 { + vendorID = 2 + } wordList.ID = id wordList.DeletedAt = time.Now() wordList.LastOperator = userName @@ -32,10 +42,13 @@ func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string) return wordList, nil } -func UpdateSensitiveWord(wordList *model.SensitiveWord, id int, userName string, params ...string) (word *model.SensitiveWord, err error) { +func UpdateSensitiveWord(wordList *model.SensitiveWord, vendorID int, id int, userName string, params ...string) (word *model.SensitiveWord, err error) { if id == 0 { return nil, errors.New("入参错误，找不到相应ID") } + if vendorID == 0 { + vendorID = 2 + } wordList.ID = id wordList.UpdatedAt = time.Now() wordList.LastOperator = userName diff --git a/controllers/cms_sku.go b/controllers/cms_sku.go index 8a4a5adca..0fe7d99dd 100644 --- a/controllers/cms_sku.go +++ b/controllers/cms_sku.go @@ -338,12 +338,13 @@ func (c *SkuController) SyncSku() { // @Title 获取敏感词列表 // @Description 获取敏感词列表 // @Param token header string true "认证token" +// @Param vendorID query int false "VendorID" // @Success 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult // @router /GetSensitiveWordList [get] func (c *SkuController) GetSensitiveWordList() { c.callGetSensitiveWordList(func(params *tSkuGetSensitiveWordListParams) (retVal interface{}, errCode string, err error) { - sensitiveWordList, err := dao.GetSensitiveWordList() + sensitiveWordList, err := dao.GetSensitiveWordList(2) var wordList []string for _, value := range sensitiveWordList { wordList = append(wordList, value.Word) @@ -388,9 +389,9 @@ func (c *SkuController) UpdateSensitiveWord() { }, } if params.Status == 1 { - retVal, err = dao.DeleteSensitiveWord(word, params.ID, params.Ctx.GetUserName()) + retVal, err = dao.DeleteSensitiveWord(word, params.ID, params.Ctx.GetUserName(), params.VendorID) } else { - retVal, err = dao.UpdateSensitiveWord(word, params.ID, params.Ctx.GetUserName(), "id", "word", "vendor_id", "last_operator") + retVal, err = dao.UpdateSensitiveWord(word, params.VendorID, params.ID, params.Ctx.GetUserName(), "id", "word", "vendor_id", "last_operator") } return retVal, "", err }) From 68adbed883616d5f26d0312f2cd54bd59bc8f14e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Fri, 10 Jul 2020 09:17:35 +0800 Subject: [PATCH 2/7] =?UTF-8?q?SensitiveWord=E7=9B=B8=E5=85=B3=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sku.go | 2 +- business/model/dao/sensitive_words.go | 13 ++++++++++--- controllers/cms_sku.go | 2 +- 3 files changed, 12 insertions(+), 5 deletions(-) diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 2eac14c28..98e356684 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -727,7 +727,7 @@ func CheckHasSensitiveWord(word string) (bool, error) { } func IsSensitiveWordInList(str string) (bool, string) { - wordList, err := dao.GetSensitiveWordList(2) + wordList, err := dao.GetSensitiveWordList(3) if err == nil { for _, value := range wordList { keyWord := value.Word diff --git a/business/model/dao/sensitive_words.go b/business/model/dao/sensitive_words.go index 51bb85388..fd7c2544e 100644 --- a/business/model/dao/sensitive_words.go +++ b/business/model/dao/sensitive_words.go @@ -7,13 +7,18 @@ import ( "time" ) -/*VendorID = 2 的时候是通用，保留之前的1，看后面会不会有扩展*/ +/*VendorID = 2 的时候是通用,3 查询所有，保留之前的1，看后面会不会有扩展*/ func GetSensitiveWordList(vendorID int) (wordList []*model.SensitiveWord, err error) { if vendorID == 0 { vendorID = 2 } - sql := `SELECT * FROM sensitive_word WHERE deleted_at = ? AND vendor_id = ?` - err = GetRows(nil, &wordList, sql, utils.DefaultTimeValue, vendorID) + if vendorID == 3 { + sql := `SELECT * FROM sensitive_word WHERE deleted_at = ?` + err = GetRows(nil, &wordList, sql, utils.DefaultTimeValue) + } else { + sql := `SELECT * FROM sensitive_word WHERE deleted_at = ? AND vendor_id = ?` + err = GetRows(nil, &wordList, sql, utils.DefaultTimeValue, vendorID) + } return wordList, err } @@ -34,6 +39,7 @@ func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string, vendorID = 2 } wordList.ID = id + wordList.VendorID = id wordList.DeletedAt = time.Now() wordList.LastOperator = userName if _, err := UpdateEntity(nil, wordList, "deleted_at", "id", "last_operator", "vendor_id"); err != nil { @@ -50,6 +56,7 @@ func UpdateSensitiveWord(wordList *model.SensitiveWord, vendorID int, id int, us vendorID = 2 } wordList.ID = id + wordList.VendorID = vendorID wordList.UpdatedAt = time.Now() wordList.LastOperator = userName if _, err := UpdateEntity(nil, wordList, params...); err != nil { diff --git a/controllers/cms_sku.go b/controllers/cms_sku.go index 0fe7d99dd..f8cf75f0d 100644 --- a/controllers/cms_sku.go +++ b/controllers/cms_sku.go @@ -344,7 +344,7 @@ func (c *SkuController) SyncSku() { // @router /GetSensitiveWordList [get] func (c *SkuController) GetSensitiveWordList() { c.callGetSensitiveWordList(func(params *tSkuGetSensitiveWordListParams) (retVal interface{}, errCode string, err error) { - sensitiveWordList, err := dao.GetSensitiveWordList(2) + sensitiveWordList, err := dao.GetSensitiveWordList(params.VendorID) var wordList []string for _, value := range sensitiveWordList { wordList = append(wordList, value.Word) From 87d05b2166ecea16d098fa832ee29df0fdaedad8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Mon, 13 Jul 2020 09:28:27 +0800 Subject: [PATCH 3/7] =?UTF-8?q?=E4=BF=AE=E6=94=B9sensitive=E5=85=A5?= =?UTF-8?q?=E5=8F=82-1=E6=89=80=E6=9C=89=EF=BC=8C-2=E9=BB=98=E8=AE=A4?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=96=B0=E6=A8=A1=E5=BC=8F=EF=BC=8C=E6=89=80?= =?UTF-8?q?=E4=BB=A5=E5=8F=AA=E6=9C=89=E4=B8=80=E6=9D=A1=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sku.go | 2 +- business/model/dao/sensitive_words.go | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 98e356684..f3b3b6e34 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -727,7 +727,7 @@ func CheckHasSensitiveWord(word string) (bool, error) { } func IsSensitiveWordInList(str string) (bool, string) { - wordList, err := dao.GetSensitiveWordList(3) + wordList, err := dao.GetSensitiveWordList(-1) if err == nil { for _, value := range wordList { keyWord := value.Word diff --git a/business/model/dao/sensitive_words.go b/business/model/dao/sensitive_words.go index fd7c2544e..344ee5c55 100644 --- a/business/model/dao/sensitive_words.go +++ b/business/model/dao/sensitive_words.go @@ -7,12 +7,12 @@ import ( "time" ) -/*VendorID = 2 的时候是通用,3 查询所有，保留之前的1，看后面会不会有扩展*/ +/*VendorID = -2 的时候是通用,-1 查询所有，保留之前的1，看后面会不会有扩展*/ func GetSensitiveWordList(vendorID int) (wordList []*model.SensitiveWord, err error) { if vendorID == 0 { - vendorID = 2 + vendorID = -2 } - if vendorID == 3 { + if vendorID == -1 { sql := `SELECT * FROM sensitive_word WHERE deleted_at = ?` err = GetRows(nil, &wordList, sql, utils.DefaultTimeValue) } else { @@ -24,7 +24,7 @@ func GetSensitiveWordList(vendorID int) (wordList []*model.SensitiveWord, err er func InsertSensitiveWord(word string, vendorID int, userName string) error { if vendorID == 0 { - vendorID = 2 + vendorID = -2 } sensitiveWord := &model.SensitiveWord{Word: word, VendorID: vendorID} WrapAddIDCULDEntity(sensitiveWord, userName) @@ -36,7 +36,7 @@ func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string, return nil, errors.New("入参错误，找不到相应ID") } if vendorID == 0 { - vendorID = 2 + vendorID = -2 } wordList.ID = id wordList.VendorID = id @@ -53,7 +53,7 @@ func UpdateSensitiveWord(wordList *model.SensitiveWord, vendorID int, id int, us return nil, errors.New("入参错误，找不到相应ID") } if vendorID == 0 { - vendorID = 2 + vendorID = -2 } wordList.ID = id wordList.VendorID = vendorID From 9a562a4f49211a2fe8d3f06a265cc27e3e67c289 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Mon, 13 Jul 2020 09:47:50 +0800 Subject: [PATCH 4/7] =?UTF-8?q?=E4=BF=AE=E6=94=B9UpdateSensitiveWord?= =?UTF-8?q?=E6=96=B9=E6=B3=95=E5=85=A5=E5=8F=82=EF=BC=8CID=E6=88=90?= =?UTF-8?q?=E9=9D=9E=E5=BF=85=E5=A1=AB=EF=BC=8C=E4=B8=8D=E9=80=89=E7=9A=84?= =?UTF-8?q?=E8=AF=9D=EF=BC=8C=E9=BB=98=E8=AE=A4=E5=8F=AA=E6=94=B9vendorid?= =?UTF-8?q?=3D-2=E7=9A=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/model/dao/sensitive_words.go | 15 ++++++--------- controllers/cms_sku.go | 2 +- 2 files changed, 7 insertions(+), 10 deletions(-) diff --git a/business/model/dao/sensitive_words.go b/business/model/dao/sensitive_words.go index 344ee5c55..e7e5f893f 100644 --- a/business/model/dao/sensitive_words.go +++ b/business/model/dao/sensitive_words.go @@ -1,7 +1,6 @@ package dao import ( - "errors" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/model" "time" @@ -32,13 +31,12 @@ func InsertSensitiveWord(word string, vendorID int, userName string) error { } func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string, vendorID int) (word *model.SensitiveWord, err error) { - if id == 0 { - return nil, errors.New("入参错误，找不到相应ID") - } if vendorID == 0 { vendorID = -2 } - wordList.ID = id + if id != 0 { + wordList.ID = id + } wordList.VendorID = id wordList.DeletedAt = time.Now() wordList.LastOperator = userName @@ -49,13 +47,12 @@ func DeleteSensitiveWord(wordList *model.SensitiveWord, id int, userName string, } func UpdateSensitiveWord(wordList *model.SensitiveWord, vendorID int, id int, userName string, params ...string) (word *model.SensitiveWord, err error) { - if id == 0 { - return nil, errors.New("入参错误，找不到相应ID") - } if vendorID == 0 { vendorID = -2 } - wordList.ID = id + if id != 0 { + wordList.ID = id + } wordList.VendorID = vendorID wordList.UpdatedAt = time.Now() wordList.LastOperator = userName diff --git a/controllers/cms_sku.go b/controllers/cms_sku.go index f8cf75f0d..d25127852 100644 --- a/controllers/cms_sku.go +++ b/controllers/cms_sku.go @@ -374,7 +374,7 @@ func (c *SkuController) InsertSensitiveWord() { // @Param token header string true "认证token" // @Param word query string true "关键词名字" // @Param vendorID query int false "VendorID" -// @Param ID query int true "关键词ID" +// @Param ID query int false "关键词ID" // @Param Status query int false "状态，0为修改默认，1为删除" // @Success 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult From c54ddb01e3ee93bfa3c2c439b408a98a23faeda3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Mon, 13 Jul 2020 11:22:05 +0800 Subject: [PATCH 5/7] =?UTF-8?q?=E4=BF=AE=E6=94=B9SetMTPSStatus=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E7=9A=84=E5=90=8D=E5=AD=97=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sync.go | 64 ++++++++++++++++++++++++++++++++++-- 1 file changed, 61 insertions(+), 3 deletions(-) diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index bfade8418..dcc4ceab3 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -4,6 +4,7 @@ import ( "errors" "fmt" "strconv" + "strings" "sync" "time" @@ -1285,16 +1286,73 @@ func SetMTPSStatus(ctx *jxcontext.Context, storeId, courierStatus int) { /*获取美团门店信息*/ //&& CourierStatus != 0 if storeId != 0 { + var ShopName string StoreLists, _ := dao.GetStoreList(nil, []int{storeId}, nil, nil, nil, "") - StoreInfoList, _ := api.MtpsAPI.GetStoreStatus(StoreLists[0].Name) - globals.SugarLogger.Debug("美团查询结果", StoreInfoList) - if StoreInfoList == nil || StoreInfoList.DataList == nil { + ShopName = StoreLists[0].Name + StoreInfoList := new(mtpsapi.GetStoreStatusResultAll) + StoreInfoList, _ = api.MtpsAPI.GetStoreStatus(ShopName) + /*通过名字找到了，正常情况*/ + if StoreInfoList != nil && StoreInfoList.DataList != nil { + goto ifExist + } else { + /*如果通过名字找不到，那就先通过ID去找名字*/ + ShopInfo, _ := api.MtpsAPI.ShopQuery(strconv.Itoa(storeId)) + if ShopInfo != nil { + ShopName = ShopInfo.ShopName + StoreInfoList, _ = api.MtpsAPI.GetStoreStatus(ShopName) + if StoreInfoList != nil && StoreInfoList.DataList != nil { + goto ifExist + } else { + /*如果通过API返回的名字也找不到*/ + goto ifNotExist + } + } else { + /*如果通过ID找不到，那就直接去判断名字*/ + goto NameProblem + } + NameProblem: + { + var NotOpen int + if strings.Contains(StoreLists[0].Name, "不做") || strings.Contains(StoreLists[0].Name, "不想做") { + NotOpen = strings.Index(StoreLists[0].Name, "-") + if strings.Index(StoreLists[0].Name, "-") > 0 { + StoreLists[0].Name = StoreLists[0].Name[:NotOpen-1] + } + NotOpen = strings.Index(StoreLists[0].Name, "不") + if strings.Index(StoreLists[0].Name, "不") > 0 { + StoreLists[0].Name = StoreLists[0].Name[:NotOpen-1] + } + NotOpen = strings.Index(StoreLists[0].Name, "（") + if strings.Index(StoreLists[0].Name, "（") > 0 { + StoreLists[0].Name = StoreLists[0].Name[:NotOpen-1] + } + NotOpen = strings.Index(StoreLists[0].Name, "(") + if strings.Index(StoreLists[0].Name, "(") > 0 { + StoreLists[0].Name = StoreLists[0].Name[:NotOpen-1] + } + NotOpen = strings.Index(StoreLists[0].Name, " ") + if NotOpen > 0 { + StoreLists[0].Name = StoreLists[0].Name[:NotOpen-1] + } + ShopName = StoreLists[0].Name + StoreInfoList, _ = api.MtpsAPI.GetStoreStatus(ShopName) + if StoreInfoList != nil && StoreInfoList.DataList != nil { + goto ifExist + } else { + goto ifNotExist + } + } + } + } + ifNotExist: + { sl := make(map[string]interface{}) sl["vendorStatus"] = 0 globals.SugarLogger.Debug("因为没找到被修改配送状态的VendorStoreID是", StoreLists[0].Name, storeId) UpdateStoreCourierMap(ctx, nil, storeId, model.VendorIDMTPS, sl, ctx.GetUserName()) return } + ifExist: if StoreInfoList.DataList[0].OuterPoiID != "" { //若存在且名字不为空，就是找到了 if StoreInfoList.DataList[0].OpenType != courierStatus { From bb059118588541d7e36d9344997d39c1521111a8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Mon, 13 Jul 2020 11:28:35 +0800 Subject: [PATCH 6/7] =?UTF-8?q?=E4=BF=AE=E6=94=B9SetMTPSStatus=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E7=9A=84=E5=90=8D=E5=AD=97=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sync.go | 22 ++++++++++++---------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index dcc4ceab3..4590460fd 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -1353,16 +1353,18 @@ func SetMTPSStatus(ctx *jxcontext.Context, storeId, courierStatus int) { return } ifExist: - if StoreInfoList.DataList[0].OuterPoiID != "" { - //若存在且名字不为空，就是找到了 - if StoreInfoList.DataList[0].OpenType != courierStatus { - sl := make(map[string]interface{}) - sl["vendorStoreID"] = StoreInfoList.DataList[0].OuterPoiID - sl["status"] = StoreInfoList.DataList[0].OpenType - sl["vendorStatus"] = StoreInfoList.DataList[0].OpenType - globals.SugarLogger.Debugf("被修改配送状态的VendorStoreID是:%s,名称是:%s,美团状态是:%s,本地状态是:%s", - StoreInfoList.DataList[0].OuterPoiID, StoreInfoList.DataList[0].PoiName, strconv.Itoa(StoreInfoList.DataList[0].OpenType), strconv.Itoa(StoreLists[0].Status)) - UpdateStoreCourierMap(ctx, nil, storeId, model.VendorIDMTPS, sl, ctx.GetUserName()) + { + if StoreInfoList.DataList[0].OuterPoiID != "" { + //若存在且名字不为空，就是找到了 + if StoreInfoList.DataList[0].OpenType != courierStatus { + sl := make(map[string]interface{}) + sl["vendorStoreID"] = StoreInfoList.DataList[0].OuterPoiID + sl["status"] = StoreInfoList.DataList[0].OpenType + sl["vendorStatus"] = StoreInfoList.DataList[0].OpenType + globals.SugarLogger.Debugf("被修改配送状态的VendorStoreID是:%s,名称是:%s,美团状态是:%s,本地状态是:%s", + StoreInfoList.DataList[0].OuterPoiID, StoreInfoList.DataList[0].PoiName, strconv.Itoa(StoreInfoList.DataList[0].OpenType), strconv.Itoa(StoreLists[0].Status)) + UpdateStoreCourierMap(ctx, nil, storeId, model.VendorIDMTPS, sl, ctx.GetUserName()) + } } } } else { From d35fe7d95a4eb7f092c0003173e8d4f252ee8355 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B9=B3=E5=87=A1=E6=A2=A6?= Date: Mon, 13 Jul 2020 11:35:27 +0800 Subject: [PATCH 7/7] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=9C=80=E5=A4=A7?= =?UTF-8?q?=E5=80=BC=E5=92=8C=E6=9C=80=E5=B0=8F=E5=80=BC=E7=9A=84=E5=88=A4?= =?UTF-8?q?=E6=96=AD=EF=BC=8C=E8=A6=81=E5=85=B3=E6=B3=A8=E4=BA=86=E6=89=8D?= =?UTF-8?q?=E5=8E=BB=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/store_sku.go | 22 ++++++++++++---------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go index 99f1b3f47..aa8ad151e 100644 --- a/business/jxstore/cms/store_sku.go +++ b/business/jxstore/cms/store_sku.go @@ -455,16 +455,18 @@ func getGetStoresSkusBaseSQL(db *dao.DaoDB, storeIDs, skuIDs []int, isFocus bool sql += ")" } } - /*前台传入的最大值和最小值设置*/ - if params["highestPrice"] != "" && params["highestPrice"] != nil { - //highestPrice := utils.Interface2Float64WithDefault(params["highestPrice"], 0) * 100 - sql += " AND t4.unit_price <= ? " - sqlParams = append(sqlParams, params["highestPrice"]) - } - if params["minimumPrice"] != "" && params["minimumPrice"] != nil { - //minimumPrice := utils.Interface2Float64WithDefault(params["minimumPrice"], 0) * 100 - sql += " AND t4.unit_price >= ? " - sqlParams = append(sqlParams, params["minimumPrice"]) + if isFocus { + /*前台传入的最大值和最小值设置*/ + if params["highestPrice"] != "" && params["highestPrice"] != nil { + //highestPrice := utils.Interface2Float64WithDefault(params["highestPrice"], 0) * 100 + sql += " AND t4.unit_price <= ? " + sqlParams = append(sqlParams, params["highestPrice"]) + } + if params["minimumPrice"] != "" && params["minimumPrice"] != nil { + //minimumPrice := utils.Interface2Float64WithDefault(params["minimumPrice"], 0) * 100 + sql += " AND t4.unit_price >= ? " + sqlParams = append(sqlParams, params["minimumPrice"]) + } } return sql, sqlParams, err }