273 lines
9.5 KiB
Go
273 lines
9.5 KiB
Go
package mtwm
|
||
|
||
import (
|
||
"fmt"
|
||
"strings"
|
||
"time"
|
||
|
||
"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
|
||
|
||
"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
|
||
"git.rosy.net.cn/jx-callback/business/partner"
|
||
|
||
"git.rosy.net.cn/baseapi/utils"
|
||
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
|
||
"git.rosy.net.cn/jx-callback/business/model"
|
||
"git.rosy.net.cn/jx-callback/business/model/dao"
|
||
"git.rosy.net.cn/jx-callback/globals"
|
||
)
|
||
|
||
const (
|
||
RefreshCommentTime = 7 * 24 * time.Hour // 此值必须大于24小时
|
||
RefreshCommentTimeInterval = 60 * time.Minute
|
||
BAD_COMMENTS_MAX_MODIFY_TIME = 24 * 6 // 小时
|
||
)
|
||
|
||
func (c *PurchaseHandler) StartRefreshComment() {
|
||
utils.AfterFuncWithRecover(5*time.Second, func() {
|
||
c.refreshCommentOnce()
|
||
})
|
||
}
|
||
|
||
func (c *PurchaseHandler) refreshCommentOnce() {
|
||
c.RefreshComment(time.Now().Add(-RefreshCommentTime), time.Now())
|
||
utils.AfterFuncWithRecover(RefreshCommentTimeInterval, func() {
|
||
c.refreshCommentOnce()
|
||
})
|
||
}
|
||
|
||
func formalizeTagList(mtwmTagList string) (outTagList string) {
|
||
if mtwmTagList != "" {
|
||
outTagList = string(utils.Format4Output(strings.Split(mtwmTagList, ","), true))
|
||
}
|
||
return outTagList
|
||
}
|
||
|
||
func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) {
|
||
globals.SugarLogger.Debugf("--------------------------------------------------------------")
|
||
startTime := time.Now().Add(-24 * time.Hour)
|
||
//endTime := time.Now().Add(-RefreshCommentTime)
|
||
endDateStr := startTime.Format("20060102")
|
||
startDateStr := time.Now().Add(-RefreshCommentTime).Format("20060102")
|
||
storeIDs, _ := dao.GetOrderStoreIDs(dao.GetDB(), fromTime, toTime, model.VendorIDMTWM)
|
||
storeIDs = append(storeIDs, 804697)
|
||
globals.SugarLogger.Debugf("------storeIDs := %s", utils.Format4Output(storeIDs, false))
|
||
task := tasksch.NewParallelTask("mtwm RefreshComment", nil, jxcontext.AdminCtx,
|
||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||
storeID := batchItemList[0].(int)
|
||
|
||
storeDetail, _ := dao.GetStoreDetail(dao.GetDB(), storeID, model.VendorIDMTWM, "")
|
||
if storeDetail.VendorStoreID == "" {
|
||
return nil, nil
|
||
}
|
||
// 查询门店差评
|
||
commentList, err := getAPI(storeDetail.VendorOrgCode, storeID, storeDetail.VendorStoreID).CommentQuery(storeDetail.VendorStoreID, startDateStr, endDateStr, 0, 0, mtwmapi.CommentReplyStatusNotReplied)
|
||
globals.SugarLogger.Debugf("commentList lenght --------------- :=%d,%s,%s", storeID, storeDetail.VendorStoreID, utils.Format4Output(len(commentList), false))
|
||
if err != nil {
|
||
globals.SugarLogger.Debugf("=========err := %v", err)
|
||
}
|
||
var orderCommentList []*model.OrderComment
|
||
if len(commentList) == model.NO || commentList == nil {
|
||
return nil, nil
|
||
}
|
||
for _, mtwmComment := range commentList {
|
||
createdTime, err := utils.TryStr2Time(mtwmComment.CommentTime)
|
||
if err == nil {
|
||
orderComment := &model.OrderComment{
|
||
VendorOrderID: utils.Int64ToStr(mtwmComment.CommentID), // 美团评价不能得到订单号，以评价ID代替
|
||
VendorID: model.VendorIDMTWM,
|
||
UserCommentID: utils.Int64ToStr(mtwmComment.CommentID),
|
||
VendorStoreID: storeDetail.VendorStoreID,
|
||
TagList: formalizeTagList(mtwmComment.CommentLables),
|
||
Score: int8(mtwmComment.FoodCommentScore),
|
||
ModifyDuration: BAD_COMMENTS_MAX_MODIFY_TIME,
|
||
OriginalMsg: string(utils.MustMarshal(mtwmComment)),
|
||
IsReplied: int8(mtwmComment.ReplyStatus),
|
||
StoreID: storeDetail.ID,
|
||
}
|
||
if orderComment.IsReplied == 0 {
|
||
orderComment.Content = mtwmComment.CommentContent
|
||
orderComment.CommentCreatedAt = createdTime
|
||
} else {
|
||
orderComment.Content = mtwmComment.AddComment
|
||
if updatedTime, err := utils.TryStr2Time(mtwmComment.CommentTime); err == nil {
|
||
orderComment.CommentCreatedAt = updatedTime
|
||
}
|
||
}
|
||
|
||
foodNameList := make(map[string]int, 0)
|
||
for _, fn := range mtwmComment.PraiseRetailList {
|
||
foodNameList[fn.Name] = 1
|
||
}
|
||
for _, fn := range mtwmComment.CriticRetailList {
|
||
foodNameList[fn.Name] = 1
|
||
}
|
||
|
||
for _, fn := range mtwmComment.CommentOrderDetail {
|
||
if len(fn.FoodName)-strings.LastIndex(fn.FoodName, "）") > 3 {
|
||
foodNameList[fn.FoodName] = 1
|
||
} else {
|
||
foodNameList[fn.FoodName[0:strings.LastIndex(fn.FoodName, "（")]] = 1
|
||
}
|
||
}
|
||
nameList := make([]string, 0, 0)
|
||
for k, _ := range foodNameList {
|
||
nameList = append(nameList, k)
|
||
}
|
||
|
||
if len(foodNameList) > 0 {
|
||
vendorOrderID, _ := dao.GetBadCommentOrderId(storeDetail.ID, time.Now().Add(-RefreshCommentTime), startTime, nameList)
|
||
if vendorOrderID != "" {
|
||
orderComment.VendorOrderID2 = vendorOrderID
|
||
}
|
||
}
|
||
orderCommentList = append(orderCommentList, orderComment)
|
||
}
|
||
}
|
||
return orderCommentList, nil
|
||
}, storeIDs)
|
||
task.Run()
|
||
resultList, err2 := task.GetResult(0)
|
||
if err = err2; err != nil {
|
||
return err
|
||
}
|
||
var orderCommentList []*model.OrderComment
|
||
for _, result := range resultList {
|
||
orderComment := result.(*model.OrderComment)
|
||
orderCommentList = append(orderCommentList, orderComment)
|
||
}
|
||
if len(orderCommentList) > 0 {
|
||
err = partner.CurOrderManager.OnOrderComments(orderCommentList)
|
||
}
|
||
return err
|
||
}
|
||
|
||
func (c *PurchaseHandler) ReplyOrderComment(ctx *jxcontext.Context, vendorOrgCode string, orderComment *model.OrderComment, replyComment string) (err error) {
|
||
if globals.EnableMtwmStoreWrite {
|
||
err = getAPI(vendorOrgCode, orderComment.StoreID, orderComment.VendorStoreID).CommentAddReply(orderComment.VendorStoreID, utils.Str2Int64(orderComment.UserCommentID), replyComment)
|
||
}
|
||
return err
|
||
}
|
||
|
||
func GetMtwmCommentList4ShanGou(key string, appOrgCode string, startTime, endTime string) error {
|
||
var (
|
||
db = dao.GetDB()
|
||
now = time.Now()
|
||
)
|
||
end, _ := utils.TryStr2Time(endTime)
|
||
if end.Year() == now.Year() && end.Month() == now.Month() && end.Day() == now.Day() {
|
||
return fmt.Errorf("结束时间不能是当前时间")
|
||
}
|
||
configList, err := dao.QueryConfigs(db, key, "Cookie", "")
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if len(configList) != model.YES {
|
||
return fmt.Errorf("查询异常,请输入正确的key或者添加此key")
|
||
}
|
||
|
||
param := map[string]interface{}{
|
||
"wmPoiId": -1,
|
||
"appType": 3,
|
||
"pageNum": 1,
|
||
"rate": 0,
|
||
"reply": -1,
|
||
"context": -1,
|
||
"startDate": startTime,
|
||
"endDate": endTime,
|
||
"timeType": 4,
|
||
}
|
||
|
||
commentList, err := getAPI(appOrgCode, 0, "").GetComment4ShanGou(param, true, configList[0].Value)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if len(commentList) == model.NO {
|
||
return fmt.Errorf("查询参数暂未获取到数据")
|
||
}
|
||
// 差评订单数据
|
||
orderCommentList := CommentListData(db, commentList, startTime, endTime)
|
||
if len(orderCommentList) > 0 {
|
||
return partner.CurOrderManager.OnOrderComments(orderCommentList)
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func CommentListData(db *dao.DaoDB, skuList []*mtwmapi.CommentsList, startTime, endTime string) []*model.OrderComment {
|
||
st, _ := utils.TryStr2Time(startTime)
|
||
et, _ := utils.TryStr2Time(endTime)
|
||
orderCommentList := make([]*model.OrderComment, 0, len(skuList))
|
||
|
||
for _, mtwmComment := range skuList {
|
||
createdTime, _ := utils.TryStr2Time(mtwmComment.CreateTime)
|
||
orderComment := &model.OrderComment{
|
||
VendorOrderID: utils.Int64ToStr(mtwmComment.Id), // 美团评价不能得到订单号，以评价ID代替
|
||
VendorID: model.VendorIDMTWM,
|
||
UserCommentID: utils.Int64ToStr(mtwmComment.UserId),
|
||
VendorStoreID: utils.Int2Str(mtwmComment.WmPoiId),
|
||
TagList: "",
|
||
Score: int8(mtwmComment.FoodCommentScore),
|
||
ModifyDuration: BAD_COMMENTS_MAX_MODIFY_TIME,
|
||
OriginalMsg: string(utils.MustMarshal(mtwmComment)),
|
||
IsReplied: 0,
|
||
StoreID: 0,
|
||
}
|
||
if len(mtwmComment.ECommentList) != 0 {
|
||
orderComment.IsReplied = 1
|
||
}
|
||
|
||
if orderComment.IsReplied == 0 {
|
||
orderComment.Content = mtwmComment.MasterCleanComment
|
||
orderComment.CommentCreatedAt = createdTime
|
||
} else {
|
||
orderComment.Content = mtwmComment.Comment
|
||
orderComment.CommentCreatedAt = utils.Timestamp2Time(int64(mtwmComment.Utime))
|
||
}
|
||
|
||
// 商品的名称集合
|
||
foodNameList := make(map[string]int, 0)
|
||
// 好评商品
|
||
for _, fn := range mtwmComment.PraiseFoodList {
|
||
foodNameList[fn] = 1
|
||
}
|
||
// 差评商品
|
||
for _, fn := range mtwmComment.CriticFoodList {
|
||
foodNameList[fn] = 1
|
||
}
|
||
// 列表商品
|
||
for _, fn := range mtwmComment.SpuCommentList {
|
||
foodNameList[fn.SpuName] = 1
|
||
}
|
||
// 包含（）中文括号的商品
|
||
for _, fn := range mtwmComment.OrderStatus.Details {
|
||
if len(fn.FoodName)-strings.LastIndex(fn.FoodName, "）") > 3 {
|
||
foodNameList[strings.TrimSuffix(fn.FoodName, " ")] = 1
|
||
} else {
|
||
foodNameList[strings.TrimSuffix(fn.FoodName[0:strings.LastIndex(fn.FoodName, "（")], " ")] = 1
|
||
}
|
||
}
|
||
store, err := dao.GetStoreDetailByVendorStoreID(db, orderComment.VendorStoreID, orderComment.VendorID, "")
|
||
if err == nil {
|
||
orderComment.StoreID = store.ID
|
||
if len(foodNameList) > 0 {
|
||
foodName := make([]string, 0, len(foodNameList))
|
||
for fnl, _ := range foodNameList {
|
||
foodName = append(foodName, fnl)
|
||
}
|
||
vendorOrderID, _ := dao.GetBadCommentOrderId(store.ID, st.AddDate(0, 0, -7), et.AddDate(0, 0, 7), foodName)
|
||
if vendorOrderID != "" {
|
||
orderComment.VendorOrderID2 = vendorOrderID
|
||
}
|
||
}
|
||
orderCommentList = append(orderCommentList, orderComment)
|
||
} else {
|
||
orderComment.StoreID = 999999
|
||
orderComment.VendorOrderID2 = orderComment.VendorOrderID
|
||
orderCommentList = append(orderCommentList, orderComment)
|
||
globals.SugarLogger.Debugf("获取美团外卖差评列表,失败:%s,%v", orderComment.VendorStoreID, err)
|
||
}
|
||
}
|
||
|
||
return orderCommentList
|
||
}
|