| | |
| | | if !ok { |
| | | return |
| | | } |
| | | |
| | | if params.Page == 1 { |
| | | params.PageSize-- |
| | | procedure, code := service.NewTaskService().GetProcedureById(params.ProcedureId) |
| | | if code != ecode.OK { |
| | | ctx.Fail(code) |
| | | return |
| | | } |
| | | var oldProcessModel *model.ProcessModel |
| | | if procedure.ProcessModelNumber != "" { |
| | | oldProcessModel, _ = service.GetProcessModelByNumber(procedure.ProcessModelNumber) |
| | | } |
| | | |
| | | list, total, err := service.GetProcessModelList(params.Page, params.PageSize, params.Number) |
| | | offset, limit, unShift := GetOffsetAndLimit(oldProcessModel, params.Page, params.PageSize) |
| | | list, total, err := service.GetProcessModelList(offset, limit, procedure.ProcessModelNumber) |
| | | if err != nil { |
| | | ctx.Fail(ecode.DBErr) |
| | | return |
| | | } |
| | | oldProcessModel, _ := service.GetProcessModelByNumber(params.Number) |
| | | |
| | | var isUpdate bool |
| | | if unShift && oldProcessModel != nil { //粘在前面 |
| | | list = append([]*model.ProcessModel{oldProcessModel}, list...) |
| | | } |
| | | for _, processModel := range list { |
| | | if processModel.Procedure == oldProcessModel.Procedure && processModel.Product == oldProcessModel.Product { |
| | | processModel.IsUpdate = processModel.Number != params.Number |
| | | } |
| | | if processModel.IsUpdate { |
| | | isUpdate = true |
| | | if oldProcessModel != nil && processModel.Procedure == oldProcessModel.Procedure && processModel.Product == oldProcessModel.Product { |
| | | processModel.IsUpdate = processModel.Number != procedure.ProcessModelNumber |
| | | } |
| | | if processModel.IsUpdate { |
| | | processModel.NewNumber, processModel.NewParamsMap = processModel.Number, processModel.ParamsMap |
| | | processModel.Number, processModel.ParamsMap = oldProcessModel.Number, oldProcessModel.ParamsMap |
| | | } |
| | | } |
| | | if params.Page == 1 && !isUpdate { |
| | | list = append([]*model.ProcessModel{oldProcessModel}, list...) |
| | | } |
| | | ctx.ResultList(list, total) |
| | | } |
| | | |
| | | func GetOffsetAndLimit(current *model.ProcessModel, page, pageSize int) (offset, limit int, unShift bool) { |
| | | //isNew是要更新的 |
| | | unShift = current != nil && page == 1 |
| | | limit = pageSize |
| | | if unShift { |
| | | limit-- //如果是新的,第一页少查一个 |
| | | } |
| | | offset = (page - 1) * pageSize |
| | | if current != nil && offset > 0 { //如果是新的,第二页开始偏移量左移一个 |
| | | offset-- |
| | | } |
| | | |
| | | return offset, limit, unShift |
| | | } |