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:54:14 +08:00
parent 60f61435bb
commit 37afeaaa04
1 changed files with 75 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1760,25 +1760,25 @@ 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
) )
db.Db.Using("c4") db.Db.Using("c4")
// sql := ` sql := `
// SELECT a.*, b.vendor_store_id SELECT a.*, b.vendor_store_id
// FROM store a FROM store a
// 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.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
// } }
sql2 := ` sql2 := `
SELECT a.*, b.vendor_store_id SELECT a.*, b.vendor_store_id
FROM store a FROM store a
@@ -1798,62 +1798,62 @@ func TempJob() (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),
// Lng: store.Lng, Lng: store.Lng,
// Lat: store.Lat, Lat: store.Lat,
// 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
// dao.WrapAddIDCULDEntity(job, ctx.GetUserName()) dao.WrapAddIDCULDEntity(job, ctx.GetUserName())
// 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.WrapAddIDCULDEntity(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) {
@@ -1885,7 +1885,7 @@ func TempJob() (err error) {
job.FinishedAt = &finishAt job.FinishedAt = &finishAt
dao.WrapAddIDCULDEntity(job, ctx.GetUserName()) dao.WrapAddIDCULDEntity(job, ctx.GetUserName())
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, 173)
for _, v := range jobsteps { for _, v := range jobsteps {
jobStep := &model.JobStep{ jobStep := &model.JobStep{
JobID: job.ID, JobID: job.ID,
@@ -1894,10 +1894,10 @@ func TempJob() (err error) {
Img: v.Img, Img: v.Img,
Type: v.Type, Type: v.Type,
} }
dao.WrapAddIDCULEntity(jobStep, ctx.GetUserName()) dao.WrapAddIDCULDEntity(jobStep, ctx.GetUserName())
err = dao.CreateEntity(db, jobStep) err = dao.CreateEntity(db, jobStep)
} }
jobImgs, _ := dao.GetJobImgs(db, 171) jobImgs, _ := dao.GetJobImgs(db, 173)
for _, v := range jobImgs { for _, v := range jobImgs {
jobImg := &model.JobImg{ jobImg := &model.JobImg{
JobID: job.ID, JobID: job.ID,