From e6b789324372c91a0ba9c1cfcabade2efdf92434 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Fri, 19 Mar 2021 09:51:49 +0800 Subject: [PATCH] aa --- business/jxstore/tempop/tempop.go | 159 +++++++++++++++--------------- 1 file changed, 82 insertions(+), 77 deletions(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 514cfa1eb..0ec2f055c 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1753,86 +1753,91 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { ) 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 = 667431 ` 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") - // var ( - // url2 string - // idCode string - // startTime 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) - // } else { - // data2, _, _ := jxutils.DownloadFileByURL("http://image.jxc4.com/image/a9bfc170a950ab9a4c76bd10b48b222b.tem.jpg") - // fileName := "a9bfc170a950ab9a4c76bd10b48b222b.tem.jpg" - // url2, _ = api.JdShop2API.UploadImageNew(data2, fileName) - // } - // if storeDetail.IDCode == "" { - // idCode = "610126198012230014" - // } else { - // idCode = storeDetail.IDCode - // } - // if storeDetail.IDValid == "" { - // startTime = "2013-01-25 00:00:00" - // } else { - // startTime = utils.Time2Str(utils.Str2Time(storeDetail.IDValid)) - // } - // 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" - // } - 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: detail.AddName, - 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, - QualificationBusType: 2, - QualificationBusName: storeDetail.LicenceCorpName, - StartTime: detail.QualificationInfoTOList[0].StartTime, - EndingTime: utils.Time2Str(utils.Str2Time(detail.QualificationInfoTOList[0].StartTime).AddDate(10, 0, 0)), - Time: []string{detail.QualificationInfoTOList[0].StartTime, detail.QualificationInfoTOList[0].EndingTime}, + // for _, v := range storeMaps { + task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx, + func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + v := batchItemList[0].(*model.StoreMap) + detail, _ := api.JdShop2API.ShopDetail(utils.Str2Int(v.VendorStoreID)) + storeDetail, _ := dao.GetStoreDetail(db, v.StoreID, model.VendorIDJDShop, "2") + // var ( + // url2 string + // idCode string + // startTime 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) + // } else { + // data2, _, _ := jxutils.DownloadFileByURL("http://image.jxc4.com/image/a9bfc170a950ab9a4c76bd10b48b222b.tem.jpg") + // fileName := "a9bfc170a950ab9a4c76bd10b48b222b.tem.jpg" + // url2, _ = api.JdShop2API.UploadImageNew(data2, fileName) + // } + // if storeDetail.IDCode == "" { + // idCode = "610126198012230014" + // } else { + // idCode = storeDetail.IDCode + // } + // if storeDetail.IDValid == "" { + // startTime = "2013-01-25 00:00:00" + // } else { + // startTime = utils.Time2Str(utils.Str2Time(storeDetail.IDValid)) + // } + // 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" + // } + 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: detail.AddName, + 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, + QualificationBusType: 2, + QualificationBusName: storeDetail.LicenceCorpName, + StartTime: detail.QualificationInfoTOList[0].StartTime, + EndingTime: utils.Time2Str(utils.Str2Time(detail.QualificationInfoTOList[0].StartTime).AddDate(10, 0, 0)), + Time: []string{detail.QualificationInfoTOList[0].StartTime, detail.QualificationInfoTOList[0].EndingTime}, + }, + &jdshopapi.QualificationRequests{ + QualificationID: 42, + QualificationName: "身份证件", + QualificationNo: detail.QualificationInfoTOList[1].QualificationNo, + QualificationURL: detail.QualificationInfoTOList[1].QualificationURL, + StartTime: detail.QualificationInfoTOList[1].StartTime, + EndingTime: detail.QualificationInfoTOList[1].EndingTime, + Time: []string{detail.QualificationInfoTOList[1].StartTime, detail.QualificationInfoTOList[1].EndingTime}, + // QualificationNo: idCode, + // QualificationURL: url2, + // StartTime: startTime, + // EndingTime: ex, + // Time: []string{startTime, ex}, + }, }, - &jdshopapi.QualificationRequests{ - QualificationID: 42, - QualificationName: "身份证件", - QualificationNo: detail.QualificationInfoTOList[1].QualificationNo, - QualificationURL: detail.QualificationInfoTOList[1].QualificationURL, - StartTime: detail.QualificationInfoTOList[1].StartTime, - EndingTime: detail.QualificationInfoTOList[1].EndingTime, - Time: []string{detail.QualificationInfoTOList[1].StartTime, detail.QualificationInfoTOList[1].EndingTime}, - // QualificationNo: idCode, - // QualificationURL: url2, - // StartTime: startTime, - // EndingTime: ex, - // Time: []string{startTime, ex}, - }, - }, - }) - } + }) + return retVal, err + }, storeMaps) + tasksch.HandleTask(task, nil, true).Run() + task.GetID() // var ( // db = dao.GetDB() // vendorThingIDs []int64