- tempop.RetrieveEbaiShopLicence

business/jxstore/tempop/tempop.go

@@ -914,3 +914,45 @@ func UpdateAllWeiXinRemark(ctx *jxcontext.Context, isAsync, isContinueWhenError
 	}
 	return hint, err
 }
+
+// 从饿百得到执照信息
+func RetrieveEbaiShopLicence(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint string, err error) {
+	var ebaiStoreList []*model.StoreMap
+	db := dao.GetDB()
+	if err = dao.GetRows(db, &ebaiStoreList, `
+	SELECT *
+	FROM store_map
+	WHERE vendor_id = ? AND deleted_at = ?
+	`, model.VendorIDEBAI, utils.DefaultTimeValue); err == nil {
+		globals.SugarLogger.Debugf("RetrieveEbaiShopLicence, count:%d", len(ebaiStoreList))
+		rootTask := tasksch.NewParallelTask("XXXX", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
+			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+				ebaiStore := batchItemList[0].(*model.StoreMap)
+				xxList, err := api.EbaiAPI.ShopAptitudeGet("", utils.Str2Int64(ebaiStore.VendorStoreID))
+				if err == nil && ebaiStore != nil {
+					if len(xxList) > 1 {
+						ebaiStore2, err2 := api.EbaiAPI.ShopGet("", utils.Str2Int64(ebaiStore.VendorStoreID))
+						if err = err2; err == nil {
+							shop := &legacymodel.EbaiShopLicence{
+								ShopName:    utils.Interface2String(ebaiStore2["name"]),
+								Licence:     utils.Interface2String(xxList[1]["license_number"]),
+								Address:     utils.Interface2String(ebaiStore2["address"]),
+								Owner:       utils.Interface2String(xxList[1]["legal_representative_name"]),
+								Tel:         utils.Interface2String(ebaiStore2["service_phone"]),
+								LicenceName: utils.Interface2String(xxList[1]["license_name"]),
+							}
+							err = dao.CreateEntity(db, shop)
+						}
+					}
+				}
+				return nil, err
+			}, ebaiStoreList)
+		tasksch.ManageTask(rootTask).Run()
+		if !isAsync {
+			_, err = rootTask.GetResult(0)
+		} else {
+			hint = rootTask.ID
+		}
+	}
+	return hint, err
+}