1

business/jxstore/cms/store.go

@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"git.rosy.net.cn/baseapi/platformapi/tiktok_shop/tiktok_api"
 	"git.rosy.net.cn/jx-callback/business/jxstore/common"
 	"git.rosy.net.cn/jx-callback/business/jxstore/event"
 	"io"
@@ -5856,3 +5857,33 @@ func GetHomePageByLocation(ctx *jxcontext.Context, lng, lat float64, needWalkDis
 	}
 	return homePages, "", nil
 }
+
+// 抖店定时任务 主动拉取门店审核状态信息并更新
+func UpdateStorePoiStatus(ctx *jxcontext.Context) error {
+	var (
+		db = dao.GetDB()
+	)
+	storeList, _ := dao.GetStoresMapList(db, []int{model.VendorIDDD}, nil, []int{model.StoreStatusOpened, model.StoreStatusHaveRest}, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "")
+	task := tasksch.NewParallelTask("UpdateDDStorePoiAuditInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			storeMap := batchItemList[0].(*model.StoreMap)
+			if handler := CurVendorSync.GetStoreHandler(storeMap.VendorID); handler != nil {
+				if storePoiStatus, err := handler.GetStoreStatus(ctx, storeMap.VendorOrgCode, storeMap.StoreID, storeMap.VendorStoreID); err != nil {
+					return nil, err
+				} else {
+					if storePoiStatus == tiktok_api.PoiAuditStateSuccessBind {
+						storeMap.AuditStatus = model.StoreAuditStatusCreated
+					} else if storePoiStatus == tiktok_api.PoiAuditStateReject {
+						storeMap.AuditStatus = model.StoreAuditStatusRejected
+					}
+					dao.UpdateEntity(db, storeMap, "AuditStatus")
+					store := fmt.Sprintf("门店ID:%d,门店名称:%s,抖店平台审核状态:%d,抖店平台门店ID:%s", storeMap.StoreID, storeMap.StoreName, storeMap.AuditStatus, storeMap.VendorStoreID)
+					event.AddOperateEvent(ctx, ctx.GetTrackInfo(), store, "", "", 10, "UpdateStore")
+				}
+			}
+			return retVal, err
+		}, storeList)
+	tasksch.HandleTask(task, nil, true).Run()
+	task.GetID()
+	return nil
+}