diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index e4d1b17bd..3c9fe7c84 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -8,6 +8,8 @@ import ( "strings" "time" + "git.rosy.net.cn/baseapi/platformapi/jdshopapi" + "git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin" "git.rosy.net.cn/jx-callback/business/partner/delivery" "github.com/360EntSecGroup-Skylar/excelize" @@ -1745,59 +1747,67 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { // } // } // } - //门店建商品 var ( - db = dao.GetDB() storeMaps []*model.StoreMap + db = dao.GetDB() ) sql := ` - SELECT * - FROM store_map - WHERE vendor_id = 5 - AND deleted_at = '1970-01-01 00:00:00' - AND vendor_org_code = 2 - AND store_id <> 667281 - AND store_id <> 100000 - AND store_id <> 102919 - AND store_id <> 103075 - ` - err = dao.GetRows(db, &storeMaps, sql, nil) - storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID2}, nil) - task := tasksch.NewParallelTask("京东商城门店建商品1", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, - func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - v := batchItemList[0].(*model.StoreSkuBind) - if v.JdsID != 0 && v.SubStoreID == 0 { - if err = api.JdShop2API.StoreSkuBindStore(true, []string{utils.Int64ToStr(v.JdsID)}, nil); err == nil { - // task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetParallelCount(2).SetIsContinueWhenError(true), ctx, - // func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - // storeMap := batchItemList[0].(*model.StoreMap) - // storeSkus2, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{v.SkuID}) - // if len(storeSkus2) > 0 { - // status := storeSkus2[0].Status - // stock := storeSkus2[0].Stock - // price := storeSkus2[0].Price - // if status == model.StoreSkuBindStatusNormal { - // api.JdShop2API.StoreWareDoUpdate(status, v.JdsID, storeMap.VendorStoreID) - // } - // if stock != 0 { - // api.JdShop2API.StoreUpdateStock(stock, v.JdsID, storeMap.VendorStoreID) - // } - // api.JdShop2API.StoreUpdatePrice(utils.Float64ToStr(jxutils.IntPrice2Standard(int64(price))), v.JdsID, storeMap.VendorStoreID) - // } else { - // return retVal, err - // } - // return retVal, err - // }, storeMaps) - // tasksch.HandleTask(task, task2, true).Run() - // _, err = task.GetResult(0) - } - } - v.SubStoreID = 1 - dao.UpdateEntity(db, v, "SubStoreID") - return retVal, err - }, storeSkus) - tasksch.HandleTask(task, nil, true).Run() - _, err = task.GetResult(0) + SELECT * from store_map where vendor_id = 5 and deleted_at = '1970-01-01 00:00:00' and vendor_org_code = 2 + and store_id = 102808 + ` + dao.GetRows(db, &storeMaps, sql, nil) + for _, v := range storeMaps { + detail, _ := api.JdShop2API.ShopDetail(utils.Str2Int(v.VendorStoreID)) + storeDetail, _ := dao.GetStoreDetail(db, v.StoreID, model.VendorIDJDShop, "2") + ex := storeDetail.IDExpire + if ex == "" { + ex = utils.Time2Str(utils.Str2Time(storeDetail.IDValid).AddDate(10, 0, 0)) + } + if !strings.Contains(ex, "00:00:00") { + ex += " 00:00:00" + } + var url2 string + if storeDetail.IDCardFront != "" { + data2, _, _ := jxutils.DownloadFileByURL(storeDetail.IDCardFront) + fileName := storeDetail.IDCardFront[strings.LastIndex(storeDetail.IDCardFront, "/")+1 : len(storeDetail.IDCardFront)] + url2, _ = api.JdShop2API.UploadImageNew(data2, fileName) + } + api.JdShop2API.UpdateBasic(&jdshopapi.UpdateBasicParam{ + StoreID: detail.StoreID, + StoreName: detail.StoreName, + CategoryID2: detail.CategoryID2, + Coordinate: detail.Coordinate, + BussinessBeginTime: detail.BussinessBeginTime, + BussinessEndTime: detail.BussinessEndTime, + ImgURL: detail.ImgURL, + StorePhone: detail.StorePhone, + AddName: utils.LimitUTF8StringLen(detail.AddName, 100), + AddCode1: detail.AddCode1, + AddCode2: detail.AddCode2, + AddCode3: detail.AddCode3, + CategoryID1: detail.CategoryID1, + QualificationRequests: []*jdshopapi.QualificationRequests{ + &jdshopapi.QualificationRequests{ + QualificationID: 41, + QualificationName: "营业执照", + QualificationNo: detail.QualificationInfoTOList[0].QualificationNo, + QualificationURL: detail.QualificationInfoTOList[0].QualificationURL, + StartTime: detail.QualificationInfoTOList[0].StartTime, + EndingTime: detail.QualificationInfoTOList[0].EndingTime, + Time: []string{detail.QualificationInfoTOList[0].StartTime, detail.QualificationInfoTOList[0].EndingTime}, + }, + &jdshopapi.QualificationRequests{ + QualificationID: 42, + QualificationName: "身份证件", + QualificationNo: storeDetail.IDCode, + QualificationURL: url2, + StartTime: utils.Time2Str(utils.Str2Time(storeDetail.IDValid)), + EndingTime: ex, + Time: []string{utils.Time2Str(utils.Str2Time(storeDetail.IDValid)), ex}, + }, + }, + }) + } return err }