From 478720790a6c7adfad82cf6829ef9471a00daab2 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 18 八月 2023 15:50:41 +0800 Subject: [PATCH] 增加workorder,完善 --- /dev/null | 52 -------------------------- service/task.go | 8 ++-- nsq/msg_handler.go | 12 +++-- .gitignore | 3 + model/procedures.go | 9 ++-- model/request/schedule_task.go | 8 +++- model/work_order.go | 9 ++-- api/v1/task.go | 8 ++-- 8 files changed, 33 insertions(+), 76 deletions(-) diff --git a/.gitignore b/.gitignore index ca9b9ad..f7f7161 100644 --- a/.gitignore +++ b/.gitignore @@ -23,4 +23,5 @@ *.test apsClient aps.db -.idea \ No newline at end of file +.idea +logs \ No newline at end of file diff --git a/api/v1/task.go b/api/v1/task.go index 2e01370..c2e6b8c 100644 --- a/api/v1/task.go +++ b/api/v1/task.go @@ -58,18 +58,18 @@ ctx.Fail(code) return } - order, err := service.NewTaskService().GetOrderByOrderId(procedure.OrderID) + order, err := service.NewTaskService().GetOrderByWorkOrderId(procedure.WorkOrderID) if err != nil { ctx.Fail(ecode.UnknownErr) return } params := service.GetProcessModelParams{ - WorkOrder: "", + WorkOrder: procedure.WorkOrderID, OrderId: procedure.OrderID, Product: order.ProductName, Procedure: procedure.ProceduresInfo.ProcedureName, - Device: procedure.ProceduresInfo.DeviceID, + Device: procedure.ProceduresInfo.DeviceName, } resp, err := service.ProcessModel{}.GetProcessModel(params) @@ -138,7 +138,7 @@ ctx.Fail(code) return } - order, err := service.NewTaskService().GetOrderByOrderId(procedure.OrderID) + order, err := service.NewTaskService().GetOrderByWorkOrderId(procedure.WorkOrderID) if err != nil { ctx.Fail(ecode.UnknownErr) return diff --git a/logs/apsClient.err.log b/logs/apsClient.err.log deleted file mode 100644 index 2e890e6..0000000 --- a/logs/apsClient.err.log +++ /dev/null @@ -1,71 +0,0 @@ -[2023-08-14 20:07:30] [error] [apsClient/model.Init:10] failed to initialize database, got error Error 1049 (42000): Unknown database 'apsClient' -[2023-08-14 20:07:30] [error] [main.main:22] model Init err:Error 1049 (42000): Unknown database 'apsClient' -[2023-08-14 20:09:18] [error] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:281] trace {"error": "Error 1067 (42000): Invalid default value for 'nick_name'", "elapsed": 0.0020053, "rows": 0, "sql": "CREATE TABLE `user` (`id` varchar(255) COMMENT '鐢ㄦ埛ID',`username` varchar(255) COMMENT '鐢ㄦ埛鐧诲綍鍚�',`user_type` int(11) COMMENT '鐢ㄦ埛绫诲瀷 1瓒呯骇绠$悊鍛� 2涓昏处鎴� 3瀛愯处鎴�',`password` varchar(255) COMMENT '鐢ㄦ埛鐧诲綍瀵嗙爜',`nick_name` varchar(255) DEFAULT '绯荤粺鐢ㄦ埛' COMMENT '鐢ㄦ埛鏄电О',`header_image` mediumtext COMMENT '鐢ㄦ埛澶村儚',`phone` varchar(255) COMMENT '鐢ㄦ埛鎵嬫満鍙�',`enable` tinyint(1) COMMENT '鐢ㄦ埛鏄惁琚喕缁�',`parent_id` varchar(255) COMMENT '鐖剁敤鎴稩D',`parent_name` varchar(255) COMMENT '鐖剁敤鎴峰悕绉�',`company_name` varchar(255) COMMENT '鍏徃鍚嶇О',`company_email` varchar(255) COMMENT '鍏徃閭',`company_contact` varchar(255) COMMENT '鍏徃鑱旂郴浜哄鍚�',`company_province` varchar(255) COMMENT '鍏徃鎵�鍦ㄧ渷',`company_city` varchar(255) COMMENT '鍏徃鎵�鍦ㄥ競',`company_trade` varchar(255) COMMENT '鍏徃琛屼笟',`pos` varchar(255) COMMENT '宀椾綅',`modified_pwd` tinyint(1) COMMENT '鏄惁鏀硅繃瀵嗙爜',`create_time` bigint(20) COMMENT '鍒涘缓鏃堕棿',`update_time` bigint(20) COMMENT '鏇存柊鏃堕棿',`ip` varchar(255) COMMENT '闆嗙兢Ip',`port` varchar(255) COMMENT '绔彛鍙�',`status` int(11) COMMENT '鐢ㄦ埛瀹℃牳鐘舵�� 0:绂佺敤',`company_logo` mediumtext COMMENT '鍏徃logo',`system_name` varchar(255) COMMENT '绯荤粺鍚嶇О',PRIMARY KEY (`id`),INDEX `idx_user_username` (`username`))"} -[2023-08-14 20:09:18] [error] [main.main:22] model Init err:Error 1067 (42000): Invalid default value for 'nick_name' -[2023-08-14 20:10:31] [error] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:281] trace {"error": "Error 1067 (42000): Invalid default value for 'nick_name'", "elapsed": 0.001014, "rows": 0, "sql": "CREATE TABLE `user` (`id` varchar(255) COMMENT '鐢ㄦ埛ID',`username` varchar(255) COMMENT '鐢ㄦ埛鐧诲綍鍚�',`user_type` int(11) COMMENT '鐢ㄦ埛绫诲瀷 1瓒呯骇绠$悊鍛� 2涓昏处鎴� 3瀛愯处鎴�',`password` varchar(255) COMMENT '鐢ㄦ埛鐧诲綍瀵嗙爜',`nick_name` varchar(255) DEFAULT '绯荤粺鐢ㄦ埛' COMMENT '鐢ㄦ埛鏄电О',`header_image` mediumtext COMMENT '鐢ㄦ埛澶村儚',`phone` varchar(255) COMMENT '鐢ㄦ埛鎵嬫満鍙�',`enable` tinyint(1) COMMENT '鐢ㄦ埛鏄惁琚喕缁�',`parent_id` varchar(255) COMMENT '鐖剁敤鎴稩D',`parent_name` varchar(255) COMMENT '鐖剁敤鎴峰悕绉�',`company_name` varchar(255) COMMENT '鍏徃鍚嶇О',`company_email` varchar(255) COMMENT '鍏徃閭',`company_contact` varchar(255) COMMENT '鍏徃鑱旂郴浜哄鍚�',`company_province` varchar(255) COMMENT '鍏徃鎵�鍦ㄧ渷',`company_city` varchar(255) COMMENT '鍏徃鎵�鍦ㄥ競',`company_trade` varchar(255) COMMENT '鍏徃琛屼笟',`pos` varchar(255) COMMENT '宀椾綅',`modified_pwd` tinyint(1) COMMENT '鏄惁鏀硅繃瀵嗙爜',`create_time` bigint(20) COMMENT '鍒涘缓鏃堕棿',`update_time` bigint(20) COMMENT '鏇存柊鏃堕棿',`ip` varchar(255) COMMENT '闆嗙兢Ip',`port` varchar(255) COMMENT '绔彛鍙�',`status` int(11) COMMENT '鐢ㄦ埛瀹℃牳鐘舵�� 0:绂佺敤',`company_logo` mediumtext COMMENT '鍏徃logo',`system_name` varchar(255) COMMENT '绯荤粺鍚嶇О',PRIMARY KEY (`id`),INDEX `idx_user_username` (`username`))"} -[2023-08-14 20:10:31] [error] [main.main:22] model Init err:Error 1067 (42000): Invalid default value for 'nick_name' -[2023-08-14 20:10:43] [error] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:281] trace {"error": "Error 1067 (42000): Invalid default value for 'nick_name'", "elapsed": 0.0010015, "rows": 0, "sql": "CREATE TABLE `user` (`id` varchar(255) COMMENT '鐢ㄦ埛ID',`username` varchar(255) COMMENT '鐢ㄦ埛鐧诲綍鍚�',`user_type` int(11) COMMENT '鐢ㄦ埛绫诲瀷 1瓒呯骇绠$悊鍛� 2涓昏处鎴� 3瀛愯处鎴�',`password` varchar(255) COMMENT '鐢ㄦ埛鐧诲綍瀵嗙爜',`nick_name` varchar(255) DEFAULT '绯荤粺鐢ㄦ埛' COMMENT '鐢ㄦ埛鏄电О',`header_image` mediumtext COMMENT '鐢ㄦ埛澶村儚',`phone` varchar(255) COMMENT '鐢ㄦ埛鎵嬫満鍙�',`enable` tinyint(1) COMMENT '鐢ㄦ埛鏄惁琚喕缁�',`parent_id` varchar(255) COMMENT '鐖剁敤鎴稩D',`parent_name` varchar(255) COMMENT '鐖剁敤鎴峰悕绉�',`company_name` varchar(255) COMMENT '鍏徃鍚嶇О',`company_email` varchar(255) COMMENT '鍏徃閭',`company_contact` varchar(255) COMMENT '鍏徃鑱旂郴浜哄鍚�',`company_province` varchar(255) COMMENT '鍏徃鎵�鍦ㄧ渷',`company_city` varchar(255) COMMENT '鍏徃鎵�鍦ㄥ競',`company_trade` varchar(255) COMMENT '鍏徃琛屼笟',`pos` varchar(255) COMMENT '宀椾綅',`modified_pwd` tinyint(1) COMMENT '鏄惁鏀硅繃瀵嗙爜',`create_time` bigint(20) COMMENT '鍒涘缓鏃堕棿',`update_time` bigint(20) COMMENT '鏇存柊鏃堕棿',`ip` varchar(255) COMMENT '闆嗙兢Ip',`port` varchar(255) COMMENT '绔彛鍙�',`status` int(11) COMMENT '鐢ㄦ埛瀹℃牳鐘舵�� 0:绂佺敤',`company_logo` mediumtext COMMENT '鍏徃logo',`system_name` varchar(255) COMMENT '绯荤粺鍚嶇О',PRIMARY KEY (`id`),INDEX `idx_user_username` (`username`))"} -[2023-08-14 20:10:43] [error] [main.main:22] model Init err:Error 1067 (42000): Invalid default value for 'nick_name' -[2023-08-15 10:34:05] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: Post "/api-s/v1/processParams/info": unsupported protocol scheme "" -[2023-08-15 10:38:12] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: Post "/api-s/v1/processParams/info": unsupported protocol scheme "" -[2023-08-15 10:38:23] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: Post "/api-s/v1/processParams/info": unsupported protocol scheme "" -[2023-08-15 10:38:28] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: Post "/api-s/v1/processParams/info": unsupported protocol scheme "" -[2023-08-15 10:38:55] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: parse "127.0.0.1:9081/api-s/v1/processParams/info": first path segment in URL cannot contain colon -[2023-08-15 10:40:21] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: parse "127.0.0.1:9081/api-s/v1/processParams/info": first path segment in URL cannot contain colon -[2023-08-15 10:42:38] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: invalid character 'p' after top-level value -[2023-08-15 10:43:02] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: Post "http://127.0.0.1:9081/api-s/v1/processParams/info": EOF -[2023-08-15 10:48:32] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: json: cannot unmarshal number into Go struct field GetProcessModelResponse.Code of type string -[2023-08-15 10:49:36] [error] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:37] TaskStart Notice GetProcessModel error: json: cannot unmarshal number into Go struct field GetProcessModelResponse.Code of type string -[2023-08-15 15:25:28] [error] [apsClient/pkg/safe.RecoverPanic:17] panic: runtime error: invalid memory address or nil pointer dereference, stack trace: goroutine 36 [running]: -runtime/debug.Stack() - C:/Program Files/Go/src/runtime/debug/stack.go:24 +0x65 -apsClient/pkg/safe.RecoverPanic() - C:/code/apsClient/pkg/safe/safe.go:17 +0x39 -panic({0x1182d20, 0x203d620}) - C:/Program Files/Go/src/runtime/panic.go:884 +0x213 -apsClient/nsq.Consume({0xc0005800c0, 0x1a}, {0x1251b90?, 0x1?}) - C:/code/apsClient/nsq/consumer.go:23 +0x1dc -apsClient/nsq.Init.func1() - C:/code/apsClient/nsq/nsq.go:20 +0x6d -apsClient/pkg/safe.Go.func1() - C:/code/apsClient/pkg/safe/safe.go:11 +0x3f -created by apsClient/pkg/safe.Go - C:/code/apsClient/pkg/safe/safe.go:9 +0x56 - -[2023-08-15 15:34:30] [error] [apsClient/model.Init:11] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 15:34:30] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 15:35:48] [error] [apsClient/model.Init:11] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 15:35:48] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 15:41:52] [error] [apsClient/model.(*ScheduleTaskSearch).Create:83] trace {"error": "no such table: user_menu", "elapsed": 0.0010028, "rows": 0, "sql": "INSERT INTO `user_menu` (`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id`) VALUES (\"2023-08-15 15:41:52.976\",\"2023-08-15 15:41:52.976\",NULL,1,\"userId\") RETURNING `id`"} -[2023-08-15 15:41:52] [error] [apsClient/model.(*ScheduleTaskSearch).First:151] trace {"error": "no such table: user_menu", "elapsed": 0.0010025, "rows": 0, "sql": "SELECT * FROM `user_menu` WHERE menu_id = 1 AND `user_menu`.`deleted_at` IS NULL ORDER BY `user_menu`.`id` LIMIT 1"} -[2023-08-15 18:09:46] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 18:09:46] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 19:36:01] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 19:36:01] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-15 19:36:44] [error] [apsClient/nsq.(*ScheduleTask).HandleMessage:61] ScheduleTask HandleMessage task structx.AssignTo taskRecord err: json: cannot unmarshal number into Go struct field Procedures.Procedures.startTime of type string, old: &nsq.DeliverScheduleTask{Order:nsq.Order{OrderID:"0100000", ProductID:"PE500A01D/F", ProductName:"鍓嶇汉姣涘竷", Parameter:"", Customer:"1200", DeliverDate:"2023-08-16", OrderAttr:"浜у搧绫诲埆:娑ょ憾", Amount:decimal.Decimal{value:(*big.Int)(0xc0005202a0), exp:0}, Unit:"", StartTime:1692328320, EndTime:1692946800}, Procedures:[]*nsq.ProductProcedure{(*nsq.ProductProcedure)(0xc0004741e0)}}, new: &model.ScheduleTask{Model:gorm.Model{ID:0x0, CreatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), UpdatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), DeletedAt:gorm.DeletedAt{Time:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), Valid:false}}, Id:0, OrderId:"", ProductId:"", ProductName:"", Parameter:"", Customer:"", DeliverDate:"", OrderAttr:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0, Data:"", Procedures:[]*model.Procedures{(*model.Procedures)(0xc0005742a0)}} -[2023-08-15 19:38:15] [error] [apsClient/nsq.(*ScheduleTask).HandleMessage:61] ScheduleTask HandleMessage task structx.AssignTo taskRecord err: json: cannot unmarshal number into Go struct field Procedures.Procedures.startTime of type string, old: &nsq.DeliverScheduleTask{Order:nsq.Order{OrderID:"0100000", ProductID:"PE500A01D/F", ProductName:"鍓嶇汉姣涘竷", Parameter:"", Customer:"1200", DeliverDate:"2023-08-16", OrderAttr:"浜у搧绫诲埆:娑ょ憾", Amount:decimal.Decimal{value:(*big.Int)(0xc0000464e0), exp:0}, Unit:"", StartTime:1692328320, EndTime:1692946800}, Procedures:[]*nsq.ProductProcedure{(*nsq.ProductProcedure)(0xc00007e000)}}, new: &model.ScheduleTask{Model:gorm.Model{ID:0x0, CreatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), UpdatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), DeletedAt:gorm.DeletedAt{Time:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), Valid:false}}, Id:0, OrderId:"", ProductId:"", ProductName:"", Parameter:"", Customer:"", DeliverDate:"", OrderAttr:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0, Data:"", Procedures:[]*model.Procedures{(*model.Procedures)(0xc0000d2000)}} -[2023-08-15 19:41:15] [error] [apsClient/nsq.(*ScheduleTask).HandleMessage:61] ScheduleTask HandleMessage task structx.AssignTo taskRecord err: json: cannot unmarshal number into Go struct field Procedures.Procedures.startTime of type string, old: &nsq.DeliverScheduleTask{Order:nsq.Order{OrderID:"0100000", ProductID:"PE500A01D/F", ProductName:"鍓嶇汉姣涘竷", Parameter:"", Customer:"1200", DeliverDate:"2023-08-16", OrderAttr:"浜у搧绫诲埆:娑ょ憾", Amount:decimal.Decimal{value:(*big.Int)(0xc00045a040), exp:0}, Unit:"", StartTime:1692328320, EndTime:1692946800}, Procedures:[]*nsq.ProductProcedure{(*nsq.ProductProcedure)(0xc00058c8c0)}}, new: &model.ScheduleTask{Model:gorm.Model{ID:0x0, CreatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), UpdatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), DeletedAt:gorm.DeletedAt{Time:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), Valid:false}}, Id:0, OrderId:"", ProductId:"", ProductName:"", Parameter:"", Customer:"", DeliverDate:"", OrderAttr:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0, Data:"", Procedures:[]*model.Procedures{(*model.Procedures)(0xc0004f4000)}} -[2023-08-15 19:48:02] [error] [apsClient/model.(*ScheduleTaskSearch).Find:199] trace {"error": "Procedures: unsupported relations for schema ScheduleTask", "elapsed": 0, "rows": 0, "sql": "SELECT * FROM `schedule_task` WHERE end_time < 1692100082 AND `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-15 19:48:37] [error] [apsClient/model.(*ScheduleTaskSearch).Find:199] trace {"error": "Procedures: unsupported relations for schema ScheduleTask", "elapsed": 0.0009641, "rows": 4, "sql": "SELECT * FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-15 19:48:44] [error] [apsClient/model.(*ScheduleTaskSearch).Find:199] trace {"error": "Procedures: unsupported relations for schema ScheduleTask", "elapsed": 0, "rows": 4, "sql": "SELECT * FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-15 19:53:30] [error] [gorm.io/gorm/migrator.Migrator.AutoMigrate:113] failed to parse value model.ScheduleTask{Model:gorm.Model{ID:0x0, CreatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), UpdatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), DeletedAt:gorm.DeletedAt{Time:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), Valid:false}}, Id:0, OrderId:"", ProductId:"", ProductName:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0, Data:"", TaskInfo:request.DeliverScheduleTask{Order:request.Order{OrderID:"", ProductID:"", ProductName:"", Parameter:"", Customer:"", DeliverDate:"", OrderAttr:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0}, Procedures:[]*request.ProductProcedure(nil)}}, got error invalid field found for struct apsClient/model/request.DeliverScheduleTask's field Order: define a valid foreign key for relations or implement the Valuer/Scanner interface -[2023-08-15 19:53:30] [error] [gorm.io/gorm/migrator.Migrator.CreateTable:207] failed to parse value model.ScheduleTask{Model:gorm.Model{ID:0x0, CreatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), UpdatedAt:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), DeletedAt:gorm.DeletedAt{Time:time.Date(1, time.January, 1, 0, 0, 0, 0, time.UTC), Valid:false}}, Id:0, OrderId:"", ProductId:"", ProductName:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0, Data:"", TaskInfo:request.DeliverScheduleTask{Order:request.Order{OrderID:"", ProductID:"", ProductName:"", Parameter:"", Customer:"", DeliverDate:"", OrderAttr:"", Amount:decimal.Decimal{value:(*big.Int)(nil), exp:0}, Unit:"", StartTime:0, EndTime:0}, Procedures:[]*request.ProductProcedure(nil)}}, got error invalid field found for struct apsClient/model/request.DeliverScheduleTask's field Order: define a valid foreign key for relations or implement the Valuer/Scanner interface -[2023-08-15 19:53:30] [error] [main.main:23] model Init err:invalid field found for struct apsClient/model/request.DeliverScheduleTask's field Order: define a valid foreign key for relations or implement the Valuer/Scanner interface -[2023-08-16 13:37:32] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 13:37:32] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 14:23:42] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 14:23:42] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 19:47:30] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 19:47:30] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 19:58:28] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-16 19:58:28] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-17 17:01:05] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-17 17:01:05] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-17 17:27:57] [error] [apsClient/model.(*OrderSearch).First:189] trace {"error": "record not found", "elapsed": 0, "rows": 0, "sql": "SELECT * FROM `Order` WHERE status = \"1\" AND start_time >= 1692264477 AND `Order`.`deleted_at` IS NULL ORDER BY created_at asc,`Order`.`id` LIMIT 1"} -[2023-08-17 17:29:01] [error] [apsClient/model.(*ProceduresSearch).First:197] trace {"error": "record not found", "elapsed": 0, "rows": 0, "sql": "SELECT * FROM `procedures` WHERE `procedures`.`deleted_at` IS NULL ORDER BY `procedures`.`id` LIMIT 1"} -[2023-08-18 11:10:56] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-18 11:10:56] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-18 11:12:50] [error] [apsClient/model.Init:10] failed to initialize database, got error Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-18 11:12:50] [error] [main.main:23] model Init err:Binary was compiled with 'CGO_ENABLED=0', go-sqlite3 requires cgo to work. This is a stub -[2023-08-18 11:13:42] [error] [apsClient/model.(*ProceduresSearch).First:197] trace {"error": "record not found", "elapsed": 0, "rows": 0, "sql": "SELECT * FROM `procedures` WHERE `procedures`.`deleted_at` IS NULL ORDER BY `procedures`.`id` LIMIT 1"} -[2023-08-18 11:14:18] [error] [apsClient/model.(*ProceduresSearch).First:197] trace {"error": "record not found", "elapsed": 0, "rows": 0, "sql": "SELECT * FROM `procedures` WHERE `procedures`.`deleted_at` IS NULL ORDER BY `procedures`.`id` LIMIT 1"} diff --git a/logs/apsClient.info.log b/logs/apsClient.info.log deleted file mode 100644 index c67594c..0000000 --- a/logs/apsClient.info.log +++ /dev/null @@ -1,402 +0,0 @@ -[2023-08-14 20:09:18] [debug] [gorm.io/gorm/migrator.Migrator.CurrentDatabase:827] trace {"elapsed": 0.0009714, "rows": -1, "sql": "SELECT DATABASE()"} -[2023-08-14 20:09:18] [debug] [gorm.io/gorm/migrator.Migrator.HasTable.func1:309] trace {"elapsed": 0.0020006, "rows": 1, "sql": "SELECT SCHEMA_NAME from Information_schema.SCHEMATA where SCHEMA_NAME LIKE 'aps_client%' ORDER BY SCHEMA_NAME='aps_client' DESC,SCHEMA_NAME limit 1"} -[2023-08-14 20:09:18] [debug] [gorm.io/gorm/migrator.Migrator.HasTable.func1:310] trace {"elapsed": 0.0010025, "rows": -1, "sql": "SELECT count(*) FROM information_schema.tables WHERE table_schema = 'aps_client' AND table_name = 'user' AND table_type = 'BASE TABLE'"} -[2023-08-14 20:10:31] [debug] [gorm.io/gorm/migrator.Migrator.CurrentDatabase:827] trace {"elapsed": 0, "rows": -1, "sql": "SELECT DATABASE()"} -[2023-08-14 20:10:31] [debug] [gorm.io/gorm/migrator.Migrator.HasTable.func1:309] trace {"elapsed": 0.0020057, "rows": 1, "sql": "SELECT SCHEMA_NAME from Information_schema.SCHEMATA where SCHEMA_NAME LIKE 'aps_client%' ORDER BY SCHEMA_NAME='aps_client' DESC,SCHEMA_NAME limit 1"} -[2023-08-14 20:10:31] [debug] [gorm.io/gorm/migrator.Migrator.HasTable.func1:310] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM information_schema.tables WHERE table_schema = 'aps_client' AND table_name = 'user' AND table_type = 'BASE TABLE'"} -[2023-08-14 20:10:43] [debug] [gorm.io/gorm/migrator.Migrator.CurrentDatabase:827] trace {"elapsed": 0.0010045, "rows": -1, "sql": "SELECT DATABASE()"} -[2023-08-14 20:10:43] [debug] [gorm.io/gorm/migrator.Migrator.HasTable.func1:309] trace {"elapsed": 0.0020024, "rows": 1, "sql": "SELECT SCHEMA_NAME from Information_schema.SCHEMATA where SCHEMA_NAME LIKE 'aps_client%' ORDER BY SCHEMA_NAME='aps_client' DESC,SCHEMA_NAME limit 1"} -[2023-08-14 20:10:43] [debug] [gorm.io/gorm/migrator.Migrator.HasTable.func1:310] trace {"elapsed": 0.0010035, "rows": -1, "sql": "SELECT count(*) FROM information_schema.tables WHERE table_schema = 'aps_client' AND table_name = 'user' AND table_type = 'BASE TABLE'"} -[2023-08-14 20:11:04] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:32:54] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:33:18] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:33:20] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:34:05] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:37:58] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:38:01] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:38:12] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:38:23] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:38:28] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:38:50] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:38:52] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:38:55] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:39:11] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:39:19] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:39:26] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:40:21] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:40:22] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:40:26] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:42:41] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:43:07] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:43:09] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:44:44] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:44:44] [info] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:40] TaskStart Notice GetProcessModel: &{Number: OrderId: Product: Procedure: WorkOrder: Device: ParamsMap:map[]} -[2023-08-15 10:45:37] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:45:39] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:45:42] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:48:20] [info] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:40] TaskStart Notice GetProcessModel: &{Number: OrderId: Product: Procedure: WorkOrder: Device: ParamsMap:map[]} -[2023-08-15 10:48:20] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:48:23] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:48:25] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:48:45] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:49:54] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 10:49:57] [info] [main.main:27] apsClient start serve... -[2023-08-15 10:49:59] [info] [apsClient/pkg/contextx.NewContext.func1:38] 192.168.20.120 | POST /v1/notice/task/start | uid: | &{OrderId:string Product:string Procedure:string WorkOrder:string Device:string} -[2023-08-15 10:49:59] [info] [apsClient/api/v1.(*NoticeApi).TaskStart.func1:40] TaskStart Notice GetProcessModel: {Number:宸ヨ壓妯″瀷缂栧彿 OrderId:璁㈠崟 Product:浜у搧 Procedure:宸ュ簭 WorkOrder:宸ュ崟 Device:璁惧 ParamsMap:map[鍘嬪己:100Mpa 鏃堕棿:100min 娓╁害:1000]} -[2023-08-15 15:24:23] [info] [main.shutdown:42] apsClient exited... -[2023-08-15 15:25:28] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:25:28] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.attendance -[2023-08-15 15:26:08] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 15:26:11] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:26:11] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 15:34:26] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 15:37:47] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:37:47] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 15:39:19] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 15:39:28] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:39:28] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 15:41:47] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 15:41:52] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:41:52] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 15:42:41] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 15:42:46] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 15:42:46] [debug] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:290] trace {"elapsed": 0.0050171, "rows": 0, "sql": "CREATE TABLE `schedule_task` (`id` integer,`created_at` datetime,`updated_at` datetime,`deleted_at` datetime,`menu_id` bigint(20),`user_id` varchar(255),PRIMARY KEY (`id`))"} -[2023-08-15 15:42:46] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0050369, "rows": 0, "sql": "CREATE INDEX `idx_schedule_task_user_id` ON `schedule_task`(`user_id`)"} -[2023-08-15 15:42:46] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0039837, "rows": 0, "sql": "CREATE INDEX `idx_schedule_task_deleted_at` ON `schedule_task`(`deleted_at`)"} -[2023-08-15 15:42:46] [debug] [apsClient/model.(*ScheduleTaskSearch).Create:83] trace {"elapsed": 0.0040376, "rows": 1, "sql": "INSERT INTO `schedule_task` (`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id`) VALUES (\"2023-08-15 15:42:46.557\",\"2023-08-15 15:42:46.557\",NULL,1,\"userId\") RETURNING `id`"} -[2023-08-15 15:42:46] [debug] [apsClient/model.(*ScheduleTaskSearch).First:151] trace {"elapsed": 0.0009762, "rows": 1, "sql": "SELECT * FROM `schedule_task` WHERE menu_id = 1 AND `schedule_task`.`deleted_at` IS NULL ORDER BY `schedule_task`.`id` LIMIT 1"} -[2023-08-15 15:42:46] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:42:46] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 15:44:43] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 15:44:48] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.AlterColumn:80] trace {"elapsed": 0, "rows": 1, "sql": "PRAGMA foreign_keys"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.getRawDDL:370] trace {"elapsed": 0, "rows": -1, "sql": "SELECT sql FROM sqlite_master WHERE type = \"table\" AND tbl_name = \"schedule_task\" AND name = \"schedule_task\""} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:414] trace {"elapsed": 0.0010022, "rows": 0, "sql": "CREATE TABLE `schedule_task__temp` (`id` integer,`created_at` datetime,`updated_at` datetime,`deleted_at` datetime,`menu_id` bigint(20),`user_id` varchar(255),PRIMARY KEY (`id`))"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:424] trace {"elapsed": 0, "rows": 1, "sql": "INSERT INTO `schedule_task__temp`(`id`,`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id`) SELECT `id`,`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id` FROM `schedule_task`"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:424] trace {"elapsed": 0.0010015, "rows": 1, "sql": "DROP TABLE `schedule_task`"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:424] trace {"elapsed": 0, "rows": 1, "sql": "ALTER TABLE `schedule_task__temp` RENAME TO `schedule_task`"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_user_id\""} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0040193, "rows": 1, "sql": "CREATE INDEX `idx_schedule_task_user_id` ON `schedule_task`(`user_id`)"} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 15:44:48] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0030108, "rows": 1, "sql": "CREATE INDEX `idx_schedule_task_deleted_at` ON `schedule_task`(`deleted_at`)"} -[2023-08-15 15:44:48] [debug] [apsClient/model.(*ScheduleTaskSearch).Create:83] trace {"elapsed": 0.0050514, "rows": 1, "sql": "INSERT INTO `schedule_task` (`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id`) VALUES (\"2023-08-15 15:44:48.543\",\"2023-08-15 15:44:48.543\",NULL,1,\"userId\") RETURNING `id`"} -[2023-08-15 15:44:48] [debug] [apsClient/model.(*ScheduleTaskSearch).First:151] trace {"elapsed": 0, "rows": 1, "sql": "SELECT * FROM `schedule_task` WHERE menu_id = 1 AND `schedule_task`.`deleted_at` IS NULL ORDER BY `schedule_task`.`id` LIMIT 1"} -[2023-08-15 15:44:48] [info] [main.main:33] apsClient start serve... -[2023-08-15 15:44:48] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 16:08:19] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 16:08:24] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.AlterColumn:80] trace {"elapsed": 0, "rows": 1, "sql": "PRAGMA foreign_keys"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.getRawDDL:370] trace {"elapsed": 0, "rows": -1, "sql": "SELECT sql FROM sqlite_master WHERE type = \"table\" AND tbl_name = \"schedule_task\" AND name = \"schedule_task\""} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:414] trace {"elapsed": 0.0020047, "rows": 0, "sql": "CREATE TABLE `schedule_task__temp` (`id` integer,`created_at` datetime,`updated_at` datetime,`deleted_at` datetime,`menu_id` bigint(20),`user_id` varchar(255),PRIMARY KEY (`id`))"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:424] trace {"elapsed": 0, "rows": 2, "sql": "INSERT INTO `schedule_task__temp`(`id`,`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id`) SELECT `id`,`created_at`,`updated_at`,`deleted_at`,`menu_id`,`user_id` FROM `schedule_task`"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:424] trace {"elapsed": 0, "rows": 2, "sql": "DROP TABLE `schedule_task`"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.recreateTable.func1.1:424] trace {"elapsed": 0.0010019, "rows": 2, "sql": "ALTER TABLE `schedule_task__temp` RENAME TO `schedule_task`"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0.0010022, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0230621, "rows": 2, "sql": "CREATE INDEX `idx_schedule_task_deleted_at` ON `schedule_task`(`deleted_at`)"} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_user_id\""} -[2023-08-15 16:08:24] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0050129, "rows": 2, "sql": "CREATE INDEX `idx_schedule_task_user_id` ON `schedule_task`(`user_id`)"} -[2023-08-15 16:08:24] [info] [main.main:33] apsClient start serve... -[2023-08-15 16:08:24] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 17:54:43] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0050116, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `order_id` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0040109, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `product_id` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0040373, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `product_name` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0049869, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `parameter` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0040065, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `customer` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0040113, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `deliver_date` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0040103, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `order_attr` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0060163, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `amount` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0050132, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `unit` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.004011, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `start_time` integer"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0040399, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `end_time` integer"} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0049836, "rows": 0, "sql": "ALTER TABLE `schedule_task` ADD `data` text"} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"materials\""} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:290] trace {"elapsed": 0.0040106, "rows": 0, "sql": "CREATE TABLE `materials` (`id` integer,`created_at` datetime,`updated_at` datetime,`deleted_at` datetime,`material_id` text,`material_name` text,`amount` text,`unit` text,PRIMARY KEY (`id`))"} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0030088, "rows": 0, "sql": "CREATE INDEX `idx_materials_deleted_at` ON `materials`(`deleted_at`)"} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:290] trace {"elapsed": 0.005018, "rows": 0, "sql": "CREATE TABLE `procedures` (`id` integer,`created_at` datetime,`updated_at` datetime,`deleted_at` datetime,`procedure_id` text,`procedure_name` text,`device_id` text,`start_time` text,`end_time` text,`work_hours` text,`input_materials_id` integer,`output_materials_id` integer,PRIMARY KEY (`id`))"} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0040126, "rows": 0, "sql": "CREATE INDEX `idx_procedures_deleted_at` ON `procedures`(`deleted_at`)"} -[2023-08-15 19:36:31] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task_procedures\""} -[2023-08-15 19:36:31] [debug] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:290] trace {"elapsed": 0.0040103, "rows": 0, "sql": "CREATE TABLE `schedule_task_procedures` (`schedule_task_id` integer,`procedures_id` integer,PRIMARY KEY (`schedule_task_id`,`procedures_id`))"} -[2023-08-15 19:36:31] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:36:31] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:45:18] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:45:24] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0.0010022, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:45:24] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:45:24] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:45:24] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:45:24] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:45:24] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:45:31] [debug] [apsClient/model.(*ScheduleTaskSearch).Create:111] trace {"elapsed": 0.006015, "rows": 1, "sql": "INSERT INTO `schedule_task` (`created_at`,`updated_at`,`deleted_at`,`order_id`,`product_id`,`product_name`,`amount`,`unit`,`start_time`,`end_time`,`data`) VALUES (\"2023-08-15 19:45:31.418\",\"2023-08-15 19:45:31.418\",NULL,\"0100000\",\"PE500A01D/F\",\"鍓嶇汉姣涘竷\",\"1200\",\"\",1692328320,1692946800,\"{\\\"order\\\":{\\\"orderId\\\":\\\"0100000\\\",\\\"productId\\\":\\\"PE500A01D/F\\\",\\\"productName\\\":\\\"鍓嶇汉姣涘竷\\\",\\\"parameter\\\":\\\"\\\",\\\"customer\\\":\\\"1200\\\",\\\"deliverDate\\\":\\\"2023-08-16\\\",\\\"orderAttr\\\":\\\"浜у搧绫诲埆:娑ょ憾\\\",\\\"amount\\\":\\\"1200\\\",\\\"unit\\\":\\\"\\\",\\\"startTime\\\":1692328320,\\\"endTime\\\":1692946800},\\\"procedures\\\":[{\\\"procedureId\\\":\\\"QF\\\",\\\"procedureName\\\":\\\"涓ョ墝鍓嶇汉\\\",\\\"deviceId\\\":\\\"08\\\",\\\"startTime\\\":1692328320,\\\"endTime\\\":1692946800,\\\"workHours\\\":\\\"171.8\\\",\\\"inputMaterials\\\":[{\\\"materialId\\\":\\\"PT\\\",\\\"materialName\\\":\\\"涓ョ墝PT\\\",\\\"amount\\\":\\\"10\\\",\\\"unit\\\":\\\"g/銕\\"}],\\\"outputMaterials\\\":[{\\\"materialId\\\":\\\"PS\\\",\\\"materialName\\\":\\\"涓ョ墝PS\\\",\\\"amount\\\":\\\"10\\\",\\\"unit\\\":\\\"g/銕\\"}],\\\"workers\\\":null}]}\") RETURNING `id`,`id`"} -[2023-08-15 19:45:45] [debug] [apsClient/model.(*ScheduleTaskSearch).Create:111] trace {"elapsed": 0.0040113, "rows": 1, "sql": "INSERT INTO `schedule_task` (`created_at`,`updated_at`,`deleted_at`,`order_id`,`product_id`,`product_name`,`amount`,`unit`,`start_time`,`end_time`,`data`) VALUES (\"2023-08-15 19:45:45.435\",\"2023-08-15 19:45:45.435\",NULL,\"0100000\",\"PE500A01D/F\",\"鍓嶇汉姣涘竷\",\"1200\",\"\",1692328320,1692946800,\"{\\\"order\\\":{\\\"orderId\\\":\\\"0100000\\\",\\\"productId\\\":\\\"PE500A01D/F\\\",\\\"productName\\\":\\\"鍓嶇汉姣涘竷\\\",\\\"parameter\\\":\\\"\\\",\\\"customer\\\":\\\"1200\\\",\\\"deliverDate\\\":\\\"2023-08-16\\\",\\\"orderAttr\\\":\\\"浜у搧绫诲埆:娑ょ憾\\\",\\\"amount\\\":\\\"1200\\\",\\\"unit\\\":\\\"\\\",\\\"startTime\\\":1692328320,\\\"endTime\\\":1692946800},\\\"procedures\\\":[{\\\"procedureId\\\":\\\"QF\\\",\\\"procedureName\\\":\\\"涓ョ墝鍓嶇汉\\\",\\\"deviceId\\\":\\\"08\\\",\\\"startTime\\\":1692328320,\\\"endTime\\\":1692946800,\\\"workHours\\\":\\\"171.8\\\",\\\"inputMaterials\\\":[{\\\"materialId\\\":\\\"PT\\\",\\\"materialName\\\":\\\"涓ョ墝PT\\\",\\\"amount\\\":\\\"10\\\",\\\"unit\\\":\\\"g/銕\\"}],\\\"outputMaterials\\\":[{\\\"materialId\\\":\\\"PS\\\",\\\"materialName\\\":\\\"涓ョ墝PS\\\",\\\"amount\\\":\\\"10\\\",\\\"unit\\\":\\\"g/銕\\"}],\\\"workers\\\":null}]}\") RETURNING `id`,`id`"} -[2023-08-15 19:47:49] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:47:55] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:47:55] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0010031, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:47:55] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:47:55] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0.0020095, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:47:55] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:47:55] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:48:02] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:48:02] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:193] trace {"elapsed": 0, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE end_time < 1692100082 AND `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:48:31] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:48:37] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:48:37] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:48:37] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:48:37] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:48:37] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:48:37] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:48:37] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:48:37] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:193] trace {"elapsed": 0, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:48:44] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:48:44] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:193] trace {"elapsed": 0, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:49:21] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:49:27] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:49:27] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:49:27] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:49:27] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:49:27] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:49:27] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:49:30] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:49:30] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:193] trace {"elapsed": 0, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:49:30] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:199] trace {"elapsed": 0, "rows": 4, "sql": "SELECT * FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-15 19:51:56] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:54:05] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:54:05] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:54:05] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:54:05] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:54:05] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:54:05] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:54:10] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:54:10] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:195] trace {"elapsed": 0, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:54:10] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:201] trace {"elapsed": 0, "rows": 4, "sql": "SELECT * FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-15 19:54:24] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:54:47] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0.0010028, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:54:47] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0010025, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:54:47] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:54:47] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:54:47] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:54:47] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:54:52] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:54:52] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:195] trace {"elapsed": 0.0010002, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:54:52] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:201] trace {"elapsed": 0.0009973, "rows": 4, "sql": "SELECT * FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-15 19:55:57] [info] [main.shutdown:48] apsClient exited... -[2023-08-15 19:56:02] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-15 19:56:02] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-15 19:56:02] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-15 19:56:02] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-15 19:56:02] [info] [main.main:33] apsClient start serve... -[2023-08-15 19:56:02] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-15 19:56:07] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/list?page=1&pageSize=20 | uid: | &{PageInfo:{Page:1 PageSize:20}} -[2023-08-15 19:56:07] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:195] trace {"elapsed": 0, "rows": 1, "sql": "SELECT count(*) FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL"} -[2023-08-15 19:56:07] [debug] [apsClient/model.(*ScheduleTaskSearch).Find:201] trace {"elapsed": 0, "rows": 4, "sql": "SELECT * FROM `schedule_task` WHERE `schedule_task`.`deleted_at` IS NULL LIMIT 20"} -[2023-08-16 13:37:29] [info] [main.shutdown:48] apsClient exited... -[2023-08-16 14:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0.0010137, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-16 14:24:28] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0009919, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-16 14:24:28] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-16 14:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-16 14:24:28] [info] [main.main:33] apsClient start serve... -[2023-08-16 14:24:28] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-16 14:24:52] [info] [main.shutdown:48] apsClient exited... -[2023-08-16 14:24:53] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-16 14:24:53] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-16 14:24:53] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-16 14:24:53] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-16 14:24:53] [info] [main.main:33] apsClient start serve... -[2023-08-16 14:24:53] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-16 14:25:21] [info] [main.shutdown:48] apsClient exited... -[2023-08-16 14:25:26] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-16 14:25:26] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-16 14:25:26] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-16 14:25:26] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-16 14:25:26] [info] [main.main:33] apsClient start serve... -[2023-08-16 14:25:26] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-16 19:47:26] [info] [main.shutdown:48] apsClient exited... -[2023-08-16 19:58:49] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"schedule_task\""} -[2023-08-16 19:58:49] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0010028, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"schedule_task\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-16 19:58:49] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `schedule_task` LIMIT 1"} -[2023-08-16 19:58:49] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"schedule_task\" AND name = \"idx_schedule_task_deleted_at\""} -[2023-08-16 19:58:49] [info] [main.main:33] apsClient start serve... -[2023-08-16 19:58:49] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:00:28] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:01:32] [debug] [gorm.io/gorm/migrator.Migrator.CreateTable.func1:290] trace {"elapsed": 0.0070474, "rows": 0, "sql": "CREATE TABLE `Order` (`id` integer,`created_at` datetime,`updated_at` datetime,`deleted_at` datetime,`order_id` varchar(191) NOT NULL,`product_id` varchar(191),`product_name` varchar(191),`parameter` varchar(1024),`customer` varchar(191),`deliver_date` varchar(100),`order_attr` text,`amount` decimal(35,18),`unit` varchar(100),`start_time` integer,`end_time` integer,`status` integer,PRIMARY KEY (`id`))"} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0040126, "rows": 0, "sql": "CREATE INDEX `idx_Order_order_id` ON `Order`(`order_id`)"} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0050064, "rows": 0, "sql": "CREATE INDEX `idx_Order_deleted_at` ON `Order`(`deleted_at`)"} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:01:32] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 2, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:01:32] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0060192, "rows": 0, "sql": "ALTER TABLE `procedures` ADD `order_id` varchar(191) NOT NULL"} -[2023-08-17 17:01:32] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.0050113, "rows": 0, "sql": "ALTER TABLE `procedures` ADD `status` integer"} -[2023-08-17 17:01:32] [debug] [gorm.io/gorm/migrator.Migrator.AddColumn.func1:363] trace {"elapsed": 0.004009, "rows": 0, "sql": "ALTER TABLE `procedures` ADD `procedure_data` text"} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:01:32] [debug] [gorm.io/driver/sqlite.Migrator.CreateIndex.func1:294] trace {"elapsed": 0.0050123, "rows": 0, "sql": "CREATE INDEX `idx_procedures_order_id` ON `procedures`(`order_id`)"} -[2023-08-17 17:01:32] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:01:32] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:18:25] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:18:30] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:18:30] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:18:30] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:18:30] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:18:30] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:23:05] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:23:10] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:23:10] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0009688, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:23:10] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:23:10] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:23:10] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:24:23] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:24:28] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:24:28] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:24:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:24:28] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:24:28] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:25:44] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:25:51] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:25:51] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:25:51] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:25:51] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:25:51] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:26:43] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:26:48] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:26:48] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:26:48] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:26:48] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:26:48] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:27:40] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:27:45] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:27:45] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:27:45] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:27:45] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:27:45] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:27:57] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/get | uid: | <nil> -[2023-08-17 17:28:54] [info] [main.shutdown:48] apsClient exited... -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0.0010009, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-17 17:29:00] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0010019, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0.0010051, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-17 17:29:00] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-17 17:29:00] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-17 17:29:00] [info] [main.main:33] apsClient start serve... -[2023-08-17 17:29:00] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-17 17:29:01] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | GET /v1/task/start/1 | uid: | <nil> -[2023-08-18 11:10:53] [info] [main.shutdown:48] apsClient exited... -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-18 11:13:28] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0.0010015, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-18 11:13:28] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-18 11:13:28] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-18 11:13:28] [info] [main.main:33] apsClient start serve... -[2023-08-18 11:13:28] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-18 11:13:42] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:14:03] [info] [main.shutdown:48] apsClient exited... -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-18 11:14:09] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0010028, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-18 11:14:09] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-18 11:14:09] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-18 11:14:09] [info] [main.main:33] apsClient start serve... -[2023-08-18 11:14:09] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-18 11:14:15] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:16:14] [info] [main.shutdown:48] apsClient exited... -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-18 11:16:19] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0009753, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-18 11:16:19] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0.0009785, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-18 11:16:19] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-18 11:16:19] [info] [main.main:33] apsClient start serve... -[2023-08-18 11:16:19] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-18 11:16:30] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:16:42] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:16:46] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:16:52] [info] [main.shutdown:48] apsClient exited... -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"Order\""} -[2023-08-18 11:16:59] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"Order\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `Order` LIMIT 1"} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0.0009941, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_deleted_at\""} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"Order\" AND name = \"idx_Order_order_id\""} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.HasTable.func1:33] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=\"procedures\""} -[2023-08-18 11:16:59] [debug] [gorm.io/gorm/migrator.Migrator.RunWithValue:71] trace {"elapsed": 0, "rows": 3, "sql": "SELECT sql FROM sqlite_master WHERE type IN (\"table\",\"index\") AND tbl_name = \"procedures\" AND sql IS NOT NULL order by type = \"table\" desc"} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.ColumnTypes.func1:119] trace {"elapsed": 0, "rows": -1, "sql": "SELECT * FROM `procedures` LIMIT 1"} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_deleted_at\""} -[2023-08-18 11:16:59] [debug] [gorm.io/driver/sqlite.Migrator.HasIndex.func1:313] trace {"elapsed": 0, "rows": -1, "sql": "SELECT count(*) FROM sqlite_master WHERE type = \"index\" AND tbl_name = \"procedures\" AND name = \"idx_procedures_order_id\""} -[2023-08-18 11:16:59] [info] [main.main:33] apsClient start serve... -[2023-08-18 11:16:59] [info] [apsClient/nsq.Consume:17] Consume NewNsqConsumer topic:aps.wangpengfei.scheduleTask -[2023-08-18 11:17:01] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:04] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:07] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:11] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:13] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:16] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:22] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:25] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> -[2023-08-18 11:17:28] [info] [apsClient/pkg/contextx.NewContext.func1:44] 192.168.20.120 | POST /v1/task/sendProcessParams/1 | uid: | <nil> diff --git a/model/procedures.go b/model/procedures.go index 5ac3185..4915825 100644 --- a/model/procedures.go +++ b/model/procedures.go @@ -13,6 +13,7 @@ Procedures struct { gorm.Model `json:"-"` ID int `gorm:"primarykey"` + WorkOrderID string `gorm:"index;type:varchar(191);not null;comment:宸ュ崟ID" json:"-"` OrderID string `gorm:"index;type:varchar(191);not null;comment:璁㈠崟ID" json:"-"` Status ProcedureStatus `json:"-"` ProcedureData string `json:"-"` //request.ProductProcedure json涓� @@ -72,8 +73,8 @@ return slf } -func (slf *ProceduresSearch) SetOrderId(orderId string) *ProceduresSearch { - slf.OrderID = orderId +func (slf *ProceduresSearch) SetWorkOrderId(orderId string) *ProceduresSearch { + slf.WorkOrderID = orderId return slf } func (slf *ProceduresSearch) SetStartTimeMax(ts int64) *ProceduresSearch { @@ -103,8 +104,8 @@ db = db.Order(slf.Order) } - if slf.OrderID != "" { - db = db.Where("order_id = ?", slf.OrderID) + if slf.WorkOrderID != "" { + db = db.Where("work_order_id = ?", slf.WorkOrderID) } if slf.Preload { diff --git a/model/request/schedule_task.go b/model/request/schedule_task.go index 43ca48c..dfe7a8e 100644 --- a/model/request/schedule_task.go +++ b/model/request/schedule_task.go @@ -4,7 +4,8 @@ // 鎺掔▼浠诲姟涓嬪彂 type ( - Order struct { + WorkOrder struct { + WorkOrderID string `json:"workOrderId"` OrderID string `gorm:"index;type:varchar(191);not null;comment:璁㈠崟ID" json:"orderId"` ProductID string `gorm:"type:varchar(191);comment:浜у搧ID" json:"productId"` ProductName string `gorm:"type:varchar(191);comment:浜у搧鍚嶇О" json:"productName"` @@ -29,12 +30,15 @@ WorkerID string `gorm:"type:varchar(2048);comment:浜哄憳ID" json:"workerId"` WorkerName string `gorm:"unique;type:varchar(191);not null;comment:浜哄憳濮撳悕" json:"workerName"` PhoneNum string `gorm:"type:varchar(191);comment:鎵嬫満鍙�" json:"phoneNum"` + StartTime int64 `gorm:"comment:寮�濮嬫椂闂�" json:"startTime"` + EndTime int64 `gorm:"comment:缁撴潫鏃堕棿" json:"endTime"` } ProductProcedure struct { ProcedureID string `gorm:"uniqueIndex:idx_product_procedure;type:varchar(191);comment:宸ュ簭ID" json:"procedureId"` ProcedureName string `gorm:"type:varchar(191);comment:宸ュ簭鍚嶇О锛屼粎鏌ヨ鐢�" json:"procedureName"` DeviceID string `gorm:"type:varchar(191);not null;comment:璁惧ID" json:"deviceId"` + DeviceName string `gorm:"type:varchar(191);not null;comment:璁惧鍚嶇О" json:"deviceName"` StartTime int64 `gorm:"comment:璁″垝寮�濮嬫椂闂�" json:"startTime"` EndTime int64 `gorm:"comment:璁″垝缁撴潫鏃堕棿" json:"endTime"` WorkHours decimal.Decimal `gorm:"type:decimal(35,18);comment:宸ユ椂" json:"workHours"` @@ -44,7 +48,7 @@ } DeliverScheduleTask struct { - Order Order `json:"order"` + WorkOrder WorkOrder `json:"workOrder"` Procedures []*ProductProcedure `json:"procedures"` // 宸ュ簭鍒楄〃 } ) diff --git a/model/order.go b/model/work_order.go similarity index 95% rename from model/order.go rename to model/work_order.go index 5f8022a..6848342 100644 --- a/model/order.go +++ b/model/work_order.go @@ -10,6 +10,7 @@ type ( Order struct { gorm.Model `json:"-"` + WorkOrderID string `gorm:"index;type:varchar(191);not null;comment:宸ュ崟ID" json:"workOrderId"` OrderID string `gorm:"index;type:varchar(191);not null;comment:璁㈠崟ID" json:"orderId"` ProductID string `gorm:"type:varchar(191);comment:浜у搧ID" json:"productId"` ProductName string `gorm:"type:varchar(191);comment:浜у搧鍚嶇О" json:"productName"` @@ -83,8 +84,8 @@ return slf } -func (slf *OrderSearch) SetOrderId(orderId string) *OrderSearch { - slf.OrderID = orderId +func (slf *OrderSearch) SetWorkOrderId(workOrderId string) *OrderSearch { + slf.WorkOrderID = workOrderId return slf } @@ -95,8 +96,8 @@ db = db.Order(slf.OrderBy) } - if slf.OrderID != "" { - db = db.Where("order_id = ?", slf.OrderID) + if slf.WorkOrderID != "" { + db = db.Where("work_order_id = ?", slf.OrderID) } if slf.Status != 0 { diff --git a/nsq/model.go b/nsq/model.go deleted file mode 100644 index 693dd18..0000000 --- a/nsq/model.go +++ /dev/null @@ -1,52 +0,0 @@ -package nsq - -import ( - "github.com/shopspring/decimal" -) - -// 鎺掔▼浠诲姟涓嬪彂 -type ( - Order struct { - OrderID string `gorm:"index;type:varchar(191);not null;comment:璁㈠崟ID" json:"orderId"` - ProductID string `gorm:"type:varchar(191);comment:浜у搧ID" json:"productId"` - ProductName string `gorm:"type:varchar(191);comment:浜у搧鍚嶇О" json:"productName"` - Parameter string `gorm:"type:varchar(1024);comment:鍙傛暟闇�姹�" json:"parameter"` - Customer string `gorm:"type:varchar(191);comment:瀹㈡埛缂栫爜" json:"customer"` - DeliverDate string `gorm:"type:varchar(100);comment:浜よ揣鏃ユ湡" json:"deliverDate"` - OrderAttr string `json:"orderAttr"` // 璁㈠崟灞炴�ф嫾鎺ョ殑瀛楃涓诧紝鍗宠揣鐗╂弿杩� - Amount decimal.Decimal `gorm:"type:decimal(35,18);comment:鏁伴噺" json:"amount"` - Unit string `gorm:"type:varchar(100);comment:鍗曚綅" json:"unit"` - StartTime int64 `gorm:"comment:璁″垝寮�濮嬫椂闂�" json:"startTime"` - EndTime int64 `gorm:"comment:璁″垝缁撴潫鏃堕棿" json:"endTime"` - } - - ProcedureMaterial struct { - MaterialID string `gorm:"type:varchar(191);comment:鐗╂枡缂栧彿" json:"materialId"` - MaterialName string `gorm:"unique;type:varchar(191);not null;comment:鐗╂枡鍚嶇О" json:"materialName"` - Amount decimal.Decimal `gorm:"type:decimal(35,18);comment:鏁伴噺" json:"amount"` - Unit string `gorm:"type:varchar(191);comment:鍗曚綅" json:"unit"` - } - - ProcedureWorker struct { - WorkerID string `gorm:"type:varchar(2048);comment:浜哄憳ID" json:"workerId"` - WorkerName string `gorm:"unique;type:varchar(191);not null;comment:浜哄憳濮撳悕" json:"workerName"` - PhoneNum string `gorm:"type:varchar(191);comment:鎵嬫満鍙�" json:"phoneNum"` - } - - ProductProcedure struct { - ProcedureID string `gorm:"uniqueIndex:idx_product_procedure;type:varchar(191);comment:宸ュ簭ID" json:"procedureId"` - ProcedureName string `gorm:"type:varchar(191);comment:宸ュ簭鍚嶇О锛屼粎鏌ヨ鐢�" json:"procedureName"` - DeviceID string `gorm:"type:varchar(191);not null;comment:璁惧ID" json:"deviceId"` - StartTime int64 `gorm:"comment:璁″垝寮�濮嬫椂闂�" json:"startTime"` - EndTime int64 `gorm:"comment:璁″垝缁撴潫鏃堕棿" json:"endTime"` - WorkHours decimal.Decimal `gorm:"type:decimal(35,18);comment:宸ユ椂" json:"workHours"` - InputMaterials []*ProcedureMaterial `json:"inputMaterials"` // 杈撳叆鐗╂枡鍒楄〃 - OutputMaterials []*ProcedureMaterial `json:"outputMaterials"` // 杈撳嚭鐗╂枡鍒楄〃 - Workers []*ProcedureWorker `json:"workers"` // 浜哄憳鍒楄〃 - } - - DeliverScheduleTask struct { - Order Order `json:"order"` - Procedures []*ProductProcedure `json:"procedures"` // 宸ュ簭鍒楄〃 - } -) diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go index fef9a83..dd692fe 100644 --- a/nsq/msg_handler.go +++ b/nsq/msg_handler.go @@ -3,6 +3,7 @@ import ( "apsClient/conf" "apsClient/model" + "apsClient/model/request" "apsClient/pkg/logx" "apsClient/pkg/structx" "encoding/json" @@ -20,7 +21,7 @@ func (slf *ScheduleTask) HandleMessage(data []byte) (err error) { fmt.Println(string(data)) - var tasks = make([]*DeliverScheduleTask, 0) + var tasks = make([]*request.DeliverScheduleTask, 0) err = json.Unmarshal(data, &tasks) if err != nil { @@ -31,10 +32,10 @@ for _, procedure := range task.Procedures { if procedure.DeviceID == conf.Conf.System.DeviceId { //鍙瓨鍌ㄦ湰璁惧鐨勫伐搴� err = model.WithTransaction(func(db *gorm.DB) error { - _, err := model.NewOrderSearch(db).SetOrderId(task.Order.OrderID).First() + _, err := model.NewOrderSearch(db).SetWorkOrderId(task.WorkOrder.WorkOrderID).First() if err == gorm.ErrRecordNotFound { var orderRecord model.Order - err = structx.AssignTo(task.Order, &orderRecord) + err = structx.AssignTo(task.WorkOrder, &orderRecord) orderRecord.Status = model.OrderStatusUnFinished if err != nil { logx.Errorf(" structx.Assign task.Order to orderRecord err: %v", err.Error()) @@ -45,8 +46,9 @@ } } procedureRecord := model.Procedures{ - OrderID: task.Order.OrderID, - Status: model.ProcedureStatusUnFinished, + WorkOrderID: task.WorkOrder.WorkOrderID, + OrderID: task.WorkOrder.OrderID, + Status: model.ProcedureStatusUnFinished, } procedureData, err := json.Marshal(procedure) procedureRecord.ProcedureData = string(procedureData) diff --git a/service/task.go b/service/task.go index 86ee38e..d2f5970 100644 --- a/service/task.go +++ b/service/task.go @@ -35,13 +35,13 @@ return nil, ecode.DBErr } procedure, err := model.NewProceduresSearch(nil). - SetOrderId(order.OrderID). + SetWorkOrderId(order.WorkOrderID). SetStartTimeMax(nowTs). SetStatus(model.ProcedureStatusUnFinished). First() if err == gorm.ErrRecordNotFound { //璇ヨ鍗曟湰璁惧鍏ㄩ儴宸ュ簭瀹屾垚锛屾妸璁㈠崟缃负瀹屾垚鐘舵�侊紙鍙槸瀵规湰璁惧瀹屾垚锛� err = nil - err = model.NewOrderSearch(nil).SetOrderId(order.OrderID).UpdateByMap(map[string]interface{}{ + err = model.NewOrderSearch(nil).SetWorkOrderId(order.WorkOrderID).UpdateByMap(map[string]interface{}{ "status": model.OrderStatusFinished, }) if err != nil { @@ -71,6 +71,6 @@ }) } -func (slf TaskService) GetOrderByOrderId(orderId string) (order *model.Order, err error) { - return model.NewOrderSearch(nil).SetOrderId(orderId).First() +func (slf TaskService) GetOrderByWorkOrderId(workOrderId string) (order *model.Order, err error) { + return model.NewOrderSearch(nil).SetWorkOrderId(workOrderId).First() } -- Gitblit v1.8.0