From 4636ea7fd5beda177cbe1f094c042fddfbf1f33e Mon Sep 17 00:00:00 2001 From: Rosy-zhudan Date: Fri, 16 Aug 2019 14:26:22 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E6=95=8F=E6=84=9F=E8=AF=8D=E8=BF=87?= =?UTF-8?q?=E6=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sku.go | 20 +++++++++++- business/jxstore/cms/sync_store_sku.go | 20 +++++++++++- business/model/dao/sensitive_words.go | 32 ++++++++++++++++++++ business/model/sensitive_words.go | 6 ++++ business/partner/partner_store_sku.go | 4 ++- business/partner/purchase/ebai/store_sku2.go | 6 +++- business/partner/purchase/mtwm/store_sku2.go | 5 +++ globals/beegodb/beegodb.go | 1 + 8 files changed, 90 insertions(+), 4 deletions(-) create mode 100644 business/model/dao/sensitive_words.go create mode 100644 business/model/sensitive_words.go diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index ba33c7d9d..af9381e35 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -508,6 +508,14 @@ func GetSkuNames(ctx *jxcontext.Context, keyword string, isBySku bool, params ma return skuNamesInfo, err } +func CheckHasSensitiveWord(word string) (bool, error) { + if hasSensitiveWord, sensitiveWord := dao.CheckHasSensitiveWord(word); hasSensitiveWord { + return true, errors.New(fmt.Sprintf("不能包含敏感词:[%s]", sensitiveWord)) + } + + return false, nil +} + func AddSkuName(ctx *jxcontext.Context, skuNameExt *model.SkuNameExt, userName string) (outSkuNameExt *model.SkuNameExt, err error) { if skuNameExt.CategoryID == 0 { return nil, errors.New("CategoryID不能为空") @@ -520,6 +528,10 @@ func AddSkuName(ctx *jxcontext.Context, skuNameExt *model.SkuNameExt, userName s } } + if hasSensitiveWord, err := CheckHasSensitiveWord(skuNameExt.Name); hasSensitiveWord { + return nil, err + } + db := dao.GetDB() dao.Begin(db) defer func() { @@ -615,13 +627,19 @@ func AddSkuName(ctx *jxcontext.Context, skuNameExt *model.SkuNameExt, userName s return outSkuNameExt, err } -func UpdateSkuName(ctx *jxcontext.Context, nameID int, payload map[string]interface{}, userName string) (num int64, err error) { +func UpdateSkuName(ctx *jxcontext.Context, nameID int, payload map[string]interface{}, userName string) (num int64, err error) { skuName := &model.SkuName{} skuName.ID = nameID db := dao.GetDB() if err = dao.GetEntity(db, skuName); err != nil { return 0, err } + + newSkuName := utils.Interface2String(payload["name"]) + if hasSensitiveWord, err := CheckHasSensitiveWord(newSkuName); hasSensitiveWord { + return 0, err + } + delete(payload, "isSpu") delete(payload, "ImgHashCode") delete(payload, "ImgWeimob") diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 72c4466ba..aab061fc4 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -3,7 +3,8 @@ package cms import ( "fmt" "time" - + "regexp" + "strings" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" @@ -403,6 +404,11 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, isFull bo } if err == nil { successList = batchedStoreSkuList + } else { + //handle error for sensitive words, if find, then insert to table sensitive_words + if sensitiveWords := GetSensitiveWords(singleStoreHandler, err.Error()); sensitiveWords != "" { + dao.InsertSensitiveWord(sensitiveWords) + } } if len(successList) > 0 { updateStoreSku(dao.GetDB(), vendorID, successList, model.SyncFlagNewMask) @@ -569,3 +575,15 @@ func ClearRemoteStoreStuffAndSetNew(ctx *jxcontext.Context, parentTask tasksch.I } return rootTask.ID, err } + +func GetSensitiveWords(singleStoreHandler partner.ISingleStoreStoreSkuHandler, str string) string { + var regFindKeyWords = singleStoreHandler.GetRegexp() + var subRegFindKeyWords = regexp.MustCompile(`[^\[\]\"\}]`) + findResult := regFindKeyWords.FindStringSubmatch(str) + if findResult != nil && len(findResult) > 1 { + findSubResult := subRegFindKeyWords.FindAllString(findResult[1], -1) + return strings.Join(findSubResult, "") + } + + return "" +} \ No newline at end of file diff --git a/business/model/dao/sensitive_words.go b/business/model/dao/sensitive_words.go new file mode 100644 index 000000000..28db794f5 --- /dev/null +++ b/business/model/dao/sensitive_words.go @@ -0,0 +1,32 @@ +package dao + +import ( + "strings" + + "git.rosy.net.cn/jx-callback/business/model" +) + +func GetSensitiveWordList() (wordList []*model.SensitiveWords, err error) { + sql := `SELECT * FROM sensitive_words` + err = GetRows(nil, &wordList, sql) + return wordList, err +} + +func InsertSensitiveWord(word string) error { + return CreateEntity(nil, &model.SensitiveWords{Words: word}) +} + +func CheckHasSensitiveWord(str string) (bool, string) { + wordList, err := GetSensitiveWordList() + if err == nil { + for _, value := range wordList { + keyWord := value.Words + checkHas := strings.Contains(str, keyWord) + if checkHas { + return true, keyWord + } + } + } + + return false, "" +} diff --git a/business/model/sensitive_words.go b/business/model/sensitive_words.go new file mode 100644 index 000000000..5e62cfa23 --- /dev/null +++ b/business/model/sensitive_words.go @@ -0,0 +1,6 @@ +package model + +type SensitiveWords struct { + ID int `orm:"column(id)" json:"id"` + Words string `orm:"size(30);column(words);unique" json:"words"` +} diff --git a/business/partner/partner_store_sku.go b/business/partner/partner_store_sku.go index 98a5a4b0f..1d1e0f0a5 100644 --- a/business/partner/partner_store_sku.go +++ b/business/partner/partner_store_sku.go @@ -3,7 +3,7 @@ package partner import ( "math" "time" - + "regexp" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "git.rosy.net.cn/jx-callback/business/jxutils/tasksch" @@ -137,6 +137,8 @@ type ISingleStoreStoreSkuHandler interface { IsErrCategoryExist(err error) (isExist bool) IsErrCategoryNotExist(err error) (isNotExist bool) + + GetRegexp() *regexp.Regexp } func BuildSkuName(skuID int, vendorSkuID string) (skuName *SkuNameInfo) { diff --git a/business/partner/purchase/ebai/store_sku2.go b/business/partner/purchase/ebai/store_sku2.go index 0eb5fdc2f..61ca77803 100644 --- a/business/partner/purchase/ebai/store_sku2.go +++ b/business/partner/purchase/ebai/store_sku2.go @@ -2,7 +2,7 @@ package ebai import ( "time" - + "regexp" "git.rosy.net.cn/baseapi/platformapi/ebaiapi" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" @@ -387,3 +387,7 @@ func vendorSkuList2Jx(vendorSkuList []*ebaiapi.SkuInfo) (skuNameList []*partner. } return skuNameList } + +func (p *PurchaseHandler) GetRegexp() *regexp.Regexp { + return regexp.MustCompile(`商品名称中含有敏感词(\[.*\])`) +} \ No newline at end of file diff --git a/business/partner/purchase/mtwm/store_sku2.go b/business/partner/purchase/mtwm/store_sku2.go index ada0a7537..a979e4baf 100644 --- a/business/partner/purchase/mtwm/store_sku2.go +++ b/business/partner/purchase/mtwm/store_sku2.go @@ -1,6 +1,7 @@ package mtwm import ( + "regexp" "git.rosy.net.cn/baseapi/platformapi/mtwmapi" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" @@ -365,3 +366,7 @@ func vendorSkuList2Jx(appFoodList []*mtwmapi.AppFood) (skuNameList []*partner.Sk } return skuNameList } + +func (p *PurchaseHandler) GetRegexp() *regexp.Regexp { + return regexp.MustCompile(`包含敏感词：(\[.*\])`) +} \ No newline at end of file diff --git a/globals/beegodb/beegodb.go b/globals/beegodb/beegodb.go index 66eeb6f52..9a678e440 100644 --- a/globals/beegodb/beegodb.go +++ b/globals/beegodb/beegodb.go @@ -53,6 +53,7 @@ func Init() { orm.RegisterModel(&model.NewConfig{}) orm.RegisterModel(&model.CasbinRule{}) + orm.RegisterModel(&model.SensitiveWords{}) // create table orm.RunSyncdb("default", false, true) } From 353b187edb2825855acafe1a4309a49e7aabf074 Mon Sep 17 00:00:00 2001 From: Rosy-zhudan Date: Fri, 16 Aug 2019 18:34:21 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E4=BA=AC=E8=A5=BF=E5=92=8C=E5=B9=B3?= =?UTF-8?q?=E5=8F=B0=E5=95=86=E5=93=81=E5=AF=B9=E6=AF=94-=E5=8A=A0?= =?UTF-8?q?=E5=85=A5=E6=95=B0=E6=8D=AE=E5=88=86=E6=9E=90Sheet?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/store_sku_check.go | 95 ++++++++++++++++++++++++- 1 file changed, 92 insertions(+), 3 deletions(-) diff --git a/business/jxstore/cms/store_sku_check.go b/business/jxstore/cms/store_sku_check.go index 6c7002adf..a9971f23b 100644 --- a/business/jxstore/cms/store_sku_check.go +++ b/business/jxstore/cms/store_sku_check.go @@ -5,7 +5,6 @@ import ( "strings" "sync" "time" - "git.rosy.net.cn/baseapi" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" @@ -19,8 +18,9 @@ import ( ) const ( - canWriteTolocal = false - isFilterToBeCreateAndNotSale = !false + canWriteTolocal = !false + needStatistic = true + isFilterToBeCreateAndNotSale = true parallelCount = 5 fileExt = ".xlsx" ) @@ -48,7 +48,26 @@ var ( "京西可售状态", "平台可售状态", } + statisticTitleList = []string{ + "京西和平台商品状态", + "待创建", + "京西可售状态", + "数量", + "占比", + } + statisticDataList = [][]string{ + {"京西有，平台无", "是", "下架"}, + {"京西有，平台无", "是", "上架"}, + {"京西有，平台无", "否", "下架"}, + {"京西有，平台无", "否", "上架"}, + {"京西无，平台有", "N/A", "N/A"}, + + {"京西有，平台有", "是", "下架"}, + {"京西有，平台有", "是", "上架"}, + {"京西有，平台有", "否", "下架"}, + {"京西有，平台有", "否", "上架"}, + } diffData DiffDataLock multiStoreAllSkuInfoMap map[int]map[int]*partner.SkuNameInfo @@ -74,6 +93,14 @@ type DiffData struct { VendorStatus string `json:"平台可售状态"` } +type StatisticData struct { + JxVendorStatus string `json:"京西和平台商品状态"` + ToBeCreate string `json:"待创建"` + JxSaleStatus string `json:"京西可售状态"` + Count string `json:"数量"` + Percent string `json:"占比"` +} + func (d *DiffDataLock) AppendData(vendorID int, diffData DiffData) { d.locker.Lock() defer d.locker.Unlock() @@ -365,6 +392,63 @@ func IsJXCS() bool { return globals.IsMainProductEnv() } +func AddStatisticSheet(sheetName string, data []DiffData) (sheet *excel.Obj2ExcelSheetConfig) { + statisticData := make([]StatisticData, 9) + var count [9]int + var percent [9]float32 + totalCount := len(data) + for _, rowData := range data { + if rowData.JxSkuName != "" && rowData.VendorSkuName == "" { + if rowData.ToBeCreate == "是" { + if rowData.JxStatus == "下架" { + count[0]++ + } else if rowData.JxStatus == "上架" { + count[1]++ + } + } else if rowData.ToBeCreate == "否" { + if rowData.JxStatus == "下架" { + count[2]++ + } else if rowData.JxStatus == "上架" { + count[3]++ + } + } + } else if rowData.JxSkuName == "" && rowData.VendorSkuName != "" { + if rowData.ToBeCreate == "" && rowData.JxStatus == "" { + count[4]++ + } + } else if rowData.JxSkuName != "" && rowData.VendorSkuName != "" { + if rowData.ToBeCreate == "是" { + if rowData.JxStatus == "下架" { + count[5]++ + } else if rowData.JxStatus == "上架" { + count[6]++ + } + } else if rowData.ToBeCreate == "否" { + if rowData.JxStatus == "下架" { + count[7]++ + } else if rowData.JxStatus == "上架" { + count[8]++ + } + } + } + } + for index, value := range count { + percent[index] = float32(value * 100) / float32(totalCount) + countStr := utils.Int2Str(value) + percentStr := fmt.Sprintf("%.2f%%", percent[index]) + subStatisticData := statisticDataList[index] + statisticData[index] = StatisticData{subStatisticData[0], subStatisticData[1], subStatisticData[2], countStr, percentStr} + } + sheetName = sheetName + "统计" + sheet = &excel.Obj2ExcelSheetConfig { + Title: sheetName, + Data: statisticData, + CaptionList: statisticTitleList, + } + + return sheet +} + func WriteToExcel(task *tasksch.SeqTask, data map[int][]DiffData) { var sheetList []*excel.Obj2ExcelSheetConfig for key, value := range data { @@ -375,8 +459,13 @@ func WriteToExcel(task *tasksch.SeqTask, data map[int][]DiffData) { CaptionList: titleList, } sheetList = append(sheetList, excelConf) + if needStatistic { + statisticSheet := AddStatisticSheet(sheetName, value) + sheetList = append(sheetList, statisticSheet) + } baseapi.SugarLogger.Debugf("WriteToExcel:append:%s count:%d", sheetName, len(value)) } + if len(sheetList) > 0 { excelBin := excel.Obj2Excel(sheetList) timeStr := utils.Int64ToStr(time.Now().Unix()) From dee9eea64a4afc49963da2ea35c922541a63a23a Mon Sep 17 00:00:00 2001 From: Rosy-zhudan Date: Mon, 19 Aug 2019 10:27:04 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=95=8F=E6=84=9F?= =?UTF-8?q?=E8=AF=8D=E8=BF=87=E6=BB=A4=E4=BB=A3=E7=A0=81=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sku.go | 19 ++++++++++++-- business/jxstore/cms/store_sku_check.go | 2 +- business/jxstore/cms/sync_store_sku.go | 14 +++++----- business/model/dao/sensitive_words.go | 27 +++++--------------- business/model/sensitive_words.go | 7 ++--- business/partner/partner_store_sku.go | 2 +- business/partner/purchase/ebai/store_sku2.go | 2 +- business/partner/purchase/mtwm/store_sku2.go | 2 +- globals/beegodb/beegodb.go | 2 +- 9 files changed, 39 insertions(+), 38 deletions(-) diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index a86046753..481df5dc4 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -509,13 +509,28 @@ func GetSkuNames(ctx *jxcontext.Context, keyword string, isBySku bool, params ma } func CheckHasSensitiveWord(word string) (bool, error) { - if hasSensitiveWord, sensitiveWord := dao.CheckHasSensitiveWord(word); hasSensitiveWord { + if hasSensitiveWord, sensitiveWord := IsSensitiveWordInList(word); hasSensitiveWord { return true, errors.New(fmt.Sprintf("不能包含敏感词:[%s]", sensitiveWord)) } return false, nil } +func IsSensitiveWordInList(str string) (bool, string) { + wordList, err := dao.GetSensitiveWordList() + if err == nil { + for _, value := range wordList { + keyWord := value.Word + checkHas := strings.Contains(str, keyWord) + if checkHas { + return true, keyWord + } + } + } + + return false, "" +} + func AddSkuName(ctx *jxcontext.Context, skuNameExt *model.SkuNameExt, userName string) (outSkuNameExt *model.SkuNameExt, err error) { if skuNameExt.CategoryID == 0 { return nil, errors.New("CategoryID不能为空") @@ -1027,4 +1042,4 @@ func UploadImg2Platforms(ctx *jxcontext.Context, parentTask tasksch.ITask, imgUR } } return imgHintMap, err -} +} \ No newline at end of file diff --git a/business/jxstore/cms/store_sku_check.go b/business/jxstore/cms/store_sku_check.go index a9971f23b..9714f4491 100644 --- a/business/jxstore/cms/store_sku_check.go +++ b/business/jxstore/cms/store_sku_check.go @@ -18,7 +18,7 @@ import ( ) const ( - canWriteTolocal = !false + canWriteTolocal = false needStatistic = true isFilterToBeCreateAndNotSale = true parallelCount = 5 diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 8a5fcf990..70eeb2f2c 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -416,8 +416,8 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, isFull bo successList = batchedStoreSkuList } else { //handle error for sensitive words, if find, then insert to table sensitive_words - if sensitiveWords := GetSensitiveWords(singleStoreHandler, err.Error()); sensitiveWords != "" { - dao.InsertSensitiveWord(sensitiveWords) + if sensitiveWord := GetSensitiveWord(singleStoreHandler, err.Error()); sensitiveWord != "" { + dao.InsertSensitiveWord(sensitiveWord, vendorID, ctx.GetUserName()) } } if len(successList) > 0 { @@ -586,12 +586,12 @@ func ClearRemoteStoreStuffAndSetNew(ctx *jxcontext.Context, parentTask tasksch.I return rootTask.ID, err } -func GetSensitiveWords(singleStoreHandler partner.ISingleStoreStoreSkuHandler, str string) string { - var regFindKeyWords = singleStoreHandler.GetRegexp() - var subRegFindKeyWords = regexp.MustCompile(`[^\[\]\"\}]`) - findResult := regFindKeyWords.FindStringSubmatch(str) +func GetSensitiveWord(singleStoreHandler partner.ISingleStoreStoreSkuHandler, str string) string { + var regFindKeyWord = singleStoreHandler.GetSensitiveWordRegexp() + var subRegFindKeyWord = regexp.MustCompile(`[^\[\]\"\}]`) + findResult := regFindKeyWord.FindStringSubmatch(str) if findResult != nil && len(findResult) > 1 { - findSubResult := subRegFindKeyWords.FindAllString(findResult[1], -1) + findSubResult := subRegFindKeyWord.FindAllString(findResult[1], -1) return strings.Join(findSubResult, "") } diff --git a/business/model/dao/sensitive_words.go b/business/model/dao/sensitive_words.go index 28db794f5..540801d41 100644 --- a/business/model/dao/sensitive_words.go +++ b/business/model/dao/sensitive_words.go @@ -1,32 +1,17 @@ package dao import ( - "strings" - "git.rosy.net.cn/jx-callback/business/model" ) -func GetSensitiveWordList() (wordList []*model.SensitiveWords, err error) { - sql := `SELECT * FROM sensitive_words` +func GetSensitiveWordList() (wordList []*model.SensitiveWord, err error) { + sql := `SELECT * FROM sensitive_word` err = GetRows(nil, &wordList, sql) return wordList, err } -func InsertSensitiveWord(word string) error { - return CreateEntity(nil, &model.SensitiveWords{Words: word}) -} - -func CheckHasSensitiveWord(str string) (bool, string) { - wordList, err := GetSensitiveWordList() - if err == nil { - for _, value := range wordList { - keyWord := value.Words - checkHas := strings.Contains(str, keyWord) - if checkHas { - return true, keyWord - } - } - } - - return false, "" +func InsertSensitiveWord(word string, vendorID int, userName string) error { + sensitiveWord := &model.SensitiveWord{Word: word, VendorID: vendorID} + WrapAddIDCULDEntity(sensitiveWord, userName) + return CreateEntity(nil, sensitiveWord) } diff --git a/business/model/sensitive_words.go b/business/model/sensitive_words.go index 5e62cfa23..5c791b3cb 100644 --- a/business/model/sensitive_words.go +++ b/business/model/sensitive_words.go @@ -1,6 +1,7 @@ package model -type SensitiveWords struct { - ID int `orm:"column(id)" json:"id"` - Words string `orm:"size(30);column(words);unique" json:"words"` +type SensitiveWord struct { + ModelIDCULD + VendorID int `orm:"column(vendor_id)" json:"vendorID"` + Word string `orm:"size(30);unique" json:"word"` } diff --git a/business/partner/partner_store_sku.go b/business/partner/partner_store_sku.go index 1d1e0f0a5..0a9f33b02 100644 --- a/business/partner/partner_store_sku.go +++ b/business/partner/partner_store_sku.go @@ -138,7 +138,7 @@ type ISingleStoreStoreSkuHandler interface { IsErrCategoryExist(err error) (isExist bool) IsErrCategoryNotExist(err error) (isNotExist bool) - GetRegexp() *regexp.Regexp + GetSensitiveWordRegexp() *regexp.Regexp } func BuildSkuName(skuID int, vendorSkuID string) (skuName *SkuNameInfo) { diff --git a/business/partner/purchase/ebai/store_sku2.go b/business/partner/purchase/ebai/store_sku2.go index 61ca77803..99ed7b6ec 100644 --- a/business/partner/purchase/ebai/store_sku2.go +++ b/business/partner/purchase/ebai/store_sku2.go @@ -388,6 +388,6 @@ func vendorSkuList2Jx(vendorSkuList []*ebaiapi.SkuInfo) (skuNameList []*partner. return skuNameList } -func (p *PurchaseHandler) GetRegexp() *regexp.Regexp { +func (p *PurchaseHandler) GetSensitiveWordRegexp() *regexp.Regexp { return regexp.MustCompile(`商品名称中含有敏感词(\[.*\])`) } \ No newline at end of file diff --git a/business/partner/purchase/mtwm/store_sku2.go b/business/partner/purchase/mtwm/store_sku2.go index a979e4baf..2cb5ddc50 100644 --- a/business/partner/purchase/mtwm/store_sku2.go +++ b/business/partner/purchase/mtwm/store_sku2.go @@ -367,6 +367,6 @@ func vendorSkuList2Jx(appFoodList []*mtwmapi.AppFood) (skuNameList []*partner.Sk return skuNameList } -func (p *PurchaseHandler) GetRegexp() *regexp.Regexp { +func (p *PurchaseHandler) GetSensitiveWordRegexp() *regexp.Regexp { return regexp.MustCompile(`包含敏感词：(\[.*\])`) } \ No newline at end of file diff --git a/globals/beegodb/beegodb.go b/globals/beegodb/beegodb.go index 9a678e440..d34c0a8c4 100644 --- a/globals/beegodb/beegodb.go +++ b/globals/beegodb/beegodb.go @@ -53,7 +53,7 @@ func Init() { orm.RegisterModel(&model.NewConfig{}) orm.RegisterModel(&model.CasbinRule{}) - orm.RegisterModel(&model.SensitiveWords{}) + orm.RegisterModel(&model.SensitiveWord{}) // create table orm.RunSyncdb("default", false, true) } From 9773900d340669df019f3f67e934a5ee5a99f289 Mon Sep 17 00:00:00 2001 From: Rosy-zhudan Date: Mon, 19 Aug 2019 11:22:30 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E6=95=8F=E6=84=9F=E8=AF=8D=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=E4=BB=A3=E7=A0=81=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sync_store_sku.go | 11 +++++++---- business/partner/purchase/ebai/store_sku2.go | 3 ++- business/partner/purchase/mtwm/store_sku2.go | 6 +++++- 3 files changed, 14 insertions(+), 6 deletions(-) diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index 70eeb2f2c..021de1b2f 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -19,6 +19,10 @@ import ( "git.rosy.net.cn/jx-callback/business/partner" ) +var ( + subSensitiveWordRegexp = regexp.MustCompile(`[^\[\]\"\}]`) +) + func CreateStoreCategoryByStoreSku(ctx *jxcontext.Context, vendorID, storeID int, vendorStoreID string, nameIDs, skuIDs []int) (err error) { db := dao.GetDB() dao.Begin(db) @@ -587,11 +591,10 @@ func ClearRemoteStoreStuffAndSetNew(ctx *jxcontext.Context, parentTask tasksch.I } func GetSensitiveWord(singleStoreHandler partner.ISingleStoreStoreSkuHandler, str string) string { - var regFindKeyWord = singleStoreHandler.GetSensitiveWordRegexp() - var subRegFindKeyWord = regexp.MustCompile(`[^\[\]\"\}]`) - findResult := regFindKeyWord.FindStringSubmatch(str) + sensitiveWordRegexp := singleStoreHandler.GetSensitiveWordRegexp() + findResult := sensitiveWordRegexp.FindStringSubmatch(str) if findResult != nil && len(findResult) > 1 { - findSubResult := subRegFindKeyWord.FindAllString(findResult[1], -1) + findSubResult := subSensitiveWordRegexp.FindAllString(findResult[1], -1) return strings.Join(findSubResult, "") } diff --git a/business/partner/purchase/ebai/store_sku2.go b/business/partner/purchase/ebai/store_sku2.go index 99ed7b6ec..6a8f4bf1f 100644 --- a/business/partner/purchase/ebai/store_sku2.go +++ b/business/partner/purchase/ebai/store_sku2.go @@ -22,6 +22,7 @@ var ( 2: 15347484581335, // 蔬菜类 3: 15347484581339, // 其他蔬菜类休闲食品 } + sensitiveWordRegexp = regexp.MustCompile(`商品名称中含有敏感词(\[.*\])`) ) func (p *PurchaseHandler) GetStoreSkusBatchSize(funcID int) (batchSize int) { @@ -389,5 +390,5 @@ func vendorSkuList2Jx(vendorSkuList []*ebaiapi.SkuInfo) (skuNameList []*partner. } func (p *PurchaseHandler) GetSensitiveWordRegexp() *regexp.Regexp { - return regexp.MustCompile(`商品名称中含有敏感词(\[.*\])`) + return sensitiveWordRegexp } \ No newline at end of file diff --git a/business/partner/purchase/mtwm/store_sku2.go b/business/partner/purchase/mtwm/store_sku2.go index 2cb5ddc50..706cd19d6 100644 --- a/business/partner/purchase/mtwm/store_sku2.go +++ b/business/partner/purchase/mtwm/store_sku2.go @@ -25,6 +25,10 @@ const ( defVendorCatID = 200001903 // 生菜 ) +var ( + sensitiveWordRegexp = regexp.MustCompile(`包含敏感词：(\[.*\])`) +) + func (p *PurchaseHandler) GetStoreSkusBatchSize(funcID int) (batchSize int) { switch funcID { case partner.FuncUpdateStoreSkusStock, partner.FuncUpdateStoreSkusStatus, partner.FuncUpdateStoreSkusPrice: @@ -368,5 +372,5 @@ func vendorSkuList2Jx(appFoodList []*mtwmapi.AppFood) (skuNameList []*partner.Sk } func (p *PurchaseHandler) GetSensitiveWordRegexp() *regexp.Regexp { - return regexp.MustCompile(`包含敏感词：(\[.*\])`) + return sensitiveWordRegexp } \ No newline at end of file