liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2021-02-22 17:31:45 +08:00
parent cc8c1a5a30
commit 2ed0f94f2f
1 changed files with 127 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

254
business/jxstore/cms/job.go
View File

@@ -1760,8 +1760,8 @@ type Store struct {
func TempJob() (err error) { func TempJob() (err error) {
var ( var (
db = dao.GetDB() db = dao.GetDB()
// ctx = jxcontext.AdminCtx ctx = jxcontext.AdminCtx
storesJD []*Store storesJD []*Store
// storesMT []*Store // storesMT []*Store
) )
@@ -1772,13 +1772,13 @@ func TempJob() (err error) {
JOIN store_map b ON a.id = b.store_id AND b.vendor_id = 0 AND b.deleted_at = ? AND b.vendor_store_id <> '' JOIN store_map b ON a.id = b.store_id AND b.vendor_id = 0 AND b.deleted_at = ? AND b.vendor_store_id <> ''
WHERE a.deleted_at = ? WHERE a.deleted_at = ?
AND a.id <> 667281 AND a.id <> 667281
AND a.id = 667278
AND a.status IN (1,0) AND a.status IN (1,0)
` `
sqlParams := []interface{}{utils.DefaultTimeValue, utils.DefaultTimeValue} sqlParams := []interface{}{utils.DefaultTimeValue, utils.DefaultTimeValue}
if err = dao.GetRows(db, &storesJD, sql, sqlParams); err != nil { if err = dao.GetRows(db, &storesJD, sql, sqlParams); err != nil {
return err return err
} }
fmt.Println(utils.Format4Output(storesJD, false))
// sql2 := ` // sql2 := `
// SELECT a.*, b.vendor_store_id // SELECT a.*, b.vendor_store_id
// FROM store a // FROM store a
@@ -1791,129 +1791,129 @@ func TempJob() (err error) {
// if err = dao.GetRows(db, &storesMT, sql2, sqlParams2); err != nil { // if err = dao.GetRows(db, &storesMT, sql2, sqlParams2); err != nil {
// return err // return err
// } // }
// db.Db.Using("default") db.Db.Using("default")
// task := tasksch.NewParallelTask("TempJob", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("TempJob", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
// func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// step := batchItemList[0].(int) step := batchItemList[0].(int)
// switch step { switch step {
// case 0: case 0:
// task := tasksch.NewParallelTask("TempJob1", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("TempJob1", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// store := batchItemList[0].(*Store) store := batchItemList[0].(*Store)
// job := &model.Job{ job := &model.Job{
// UserID: "906380C7390E11EB8831525400C36BDA", UserID: "906380C7390E11EB8831525400C36BDA",
// JobCategoryID: 3, JobCategoryID: 3,
// Title: "京东(" + store.Name + ")", Title: "京东(" + store.Name + ")",
// Content: "领取任务后，需要尽快去完成，并提交截图。如超时未完成，任务会被取消", Content: "领取任务后，需要尽快去完成，并提交截图。如超时未完成，任务会被取消",
// Count: 1000, Count: 1000,
// AvgPrice: 300, AvgPrice: 300,
// TotalPrice: 300000, TotalPrice: 300000,
// Status: 0, Status: 0,
// Address: store.Address, Address: store.Address,
// StoreURL: store.VendorStoreID, StoreURL: store.VendorStoreID,
// SurplusCount: 1000, SurplusCount: 1000,
// JobLimitAt: 72, JobLimitAt: 72,
// AuditLimitAt: 168, AuditLimitAt: 168,
// LimitCountType: 3, LimitCountType: 3,
// VendorID: 0, VendorID: 0,
// CashbackType: 1, CashbackType: 1,
// JobLat: jxutils.IntCoordinate2Standard(store.Lat), JobLat: jxutils.IntCoordinate2Standard(store.Lat),
// JobLng: jxutils.IntCoordinate2Standard(store.Lng), JobLng: jxutils.IntCoordinate2Standard(store.Lng),
// JobCityCode: store.CityCode, JobCityCode: store.CityCode,
// } }
// finishAt := utils.Str2Time("2021-12-30 00:00:00") finishAt := utils.Str2Time("2021-12-30 00:00:00")
// job.FinishedAt = &finishAt job.FinishedAt = &finishAt
// lng, lat, _ := api.AutonaviAPI.GetCoordinateFromAddressByPage(job.Address, store.CityCode) lng, lat, _ := api.AutonaviAPI.GetCoordinateFromAddressByPage(job.Address, store.CityCode)
// job.Lng = jxutils.StandardCoordinate2Int(lng) job.Lng = jxutils.StandardCoordinate2Int(lng)
// job.Lat = jxutils.StandardCoordinate2Int(lat) job.Lat = jxutils.StandardCoordinate2Int(lat)
// if err = dao.CreateEntity(db, job); err == nil { if err = dao.CreateEntity(db, job); err == nil {
// jobsteps, _ := dao.GetJobSteps(db, 171) jobsteps, _ := dao.GetJobSteps(db, 171)
// for _, v := range jobsteps { for _, v := range jobsteps {
// jobStep := &model.JobStep{ jobStep := &model.JobStep{
// JobID: job.ID, JobID: job.ID,
// StepCount: v.StepCount, StepCount: v.StepCount,
// Content: v.Content, Content: v.Content,
// Img: v.Img, Img: v.Img,
// Type: v.Type, Type: v.Type,
// } }
// dao.WrapAddIDCULEntity(jobStep, ctx.GetUserName()) dao.WrapAddIDCULEntity(jobStep, ctx.GetUserName())
// err = dao.CreateEntity(db, jobStep) err = dao.CreateEntity(db, jobStep)
// } }
// jobImgs, _ := dao.GetJobImgs(db, 171) jobImgs, _ := dao.GetJobImgs(db, 171)
// for _, v := range jobImgs { for _, v := range jobImgs {
// jobImg := &model.JobImg{ jobImg := &model.JobImg{
// JobID: job.ID, JobID: job.ID,
// Img: v.Img, Img: v.Img,
// } }
// dao.WrapAddIDCULEntity(jobImg, ctx.GetUserName()) dao.WrapAddIDCULEntity(jobImg, ctx.GetUserName())
// err = dao.CreateEntity(db, jobImg) err = dao.CreateEntity(db, jobImg)
// } }
// } }
// return retVal, err return retVal, err
// }, storesJD) }, storesJD)
// tasksch.HandleTask(task, task2, true).Run() tasksch.HandleTask(task, task2, true).Run()
// task.GetResult(0) task.GetResult(0)
// case 1: case 1:
// task := tasksch.NewParallelTask("TempJob2", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, // task := tasksch.NewParallelTask("TempJob2", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { // func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// store := batchItemList[0].(*Store) // store := batchItemList[0].(*Store)
// job := &model.Job{ // job := &model.Job{
// UserID: "906380C7390E11EB8831525400C36BDA", // UserID: "906380C7390E11EB8831525400C36BDA",
// JobCategoryID: 3, // JobCategoryID: 3,
// Title: "美团(" + store.Name + ")", // Title: "美团(" + store.Name + ")",
// Content: "领取任务后，需要尽快去完成，并提交截图。如超时未完成，任务会被取消", // Content: "领取任务后，需要尽快去完成，并提交截图。如超时未完成，任务会被取消",
// Count: 1000, // Count: 1000,
// AvgPrice: 300, // AvgPrice: 300,
// TotalPrice: 300000, // TotalPrice: 300000,
// Status: 0, // Status: 0,
// Address: store.Address, // Address: store.Address,
// StoreURL: store.VendorStoreID, // StoreURL: store.VendorStoreID,
// SurplusCount: 1000, // SurplusCount: 1000,
// JobLimitAt: 72, // JobLimitAt: 72,
// AuditLimitAt: 168, // AuditLimitAt: 168,
// LimitCountType: 3, // LimitCountType: 3,
// VendorID: 1, // VendorID: 1,
// CashbackType: 1, // CashbackType: 1,
// JobLat: jxutils.IntCoordinate2Standard(store.Lat), // JobLat: jxutils.IntCoordinate2Standard(store.Lat),
// JobLng: jxutils.IntCoordinate2Standard(store.Lng), // JobLng: jxutils.IntCoordinate2Standard(store.Lng),
// JobCityCode: store.CityCode, // JobCityCode: store.CityCode,
// } // }
// finishAt := utils.Str2Time("2021-12-31 00:00:00") // finishAt := utils.Str2Time("2021-12-31 00:00:00")
// job.FinishedAt = &finishAt // job.FinishedAt = &finishAt
// lng, lat, _ := api.AutonaviAPI.GetCoordinateFromAddressByPage(job.Address, store.CityCode) // lng, lat, _ := api.AutonaviAPI.GetCoordinateFromAddressByPage(job.Address, store.CityCode)
// job.Lng = jxutils.StandardCoordinate2Int(lng) // job.Lng = jxutils.StandardCoordinate2Int(lng)
// job.Lat = jxutils.StandardCoordinate2Int(lat) // job.Lat = jxutils.StandardCoordinate2Int(lat)
// if err = dao.CreateEntity(db, job); err == nil { // if err = dao.CreateEntity(db, job); err == nil {
// jobsteps, _ := dao.GetJobSteps(db, 171) // jobsteps, _ := dao.GetJobSteps(db, 171)
// for _, v := range jobsteps { // for _, v := range jobsteps {
// jobStep := &model.JobStep{ // jobStep := &model.JobStep{
// JobID: job.ID, // JobID: job.ID,
// StepCount: v.StepCount, // StepCount: v.StepCount,
// Content: v.Content, // Content: v.Content,
// Img: v.Img, // Img: v.Img,
// Type: v.Type, // Type: v.Type,
// } // }
// dao.WrapAddIDCULEntity(jobStep, ctx.GetUserName()) // dao.WrapAddIDCULEntity(jobStep, ctx.GetUserName())
// err = dao.CreateEntity(db, jobStep) // err = dao.CreateEntity(db, jobStep)
// } // }
// jobImgs, _ := dao.GetJobImgs(db, 171) // jobImgs, _ := dao.GetJobImgs(db, 171)
// for _, v := range jobImgs { // for _, v := range jobImgs {
// jobImg := &model.JobImg{ // jobImg := &model.JobImg{
// JobID: job.ID, // JobID: job.ID,
// Img: v.Img, // Img: v.Img,
// } // }
// dao.WrapAddIDCULEntity(jobImg, ctx.GetUserName()) // dao.WrapAddIDCULEntity(jobImg, ctx.GetUserName())
// err = dao.CreateEntity(db, jobImg) // err = dao.CreateEntity(db, jobImg)
// } // }
// } // }
// return retVal, err // return retVal, err
// }, storesMT) // }, storesMT)
// tasksch.HandleTask(task, task2, true).Run() // tasksch.HandleTask(task, task2, true).Run()
// task.GetResult(0) // task.GetResult(0)
// } }
// return retVal, err return retVal, err
// }, []int{0, 1}) }, []int{0, 1})
// tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
// task.GetID() task.GetID()
return err return err
} }