liujiandao
2024-01-11 eaa4218d45fade3a9ac2cfb7ff81cbfceeb650cd
问题修改
3个文件已修改
32 ■■■■■ 已修改文件
controllers/operation.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
controllers/warehouse.go 29 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
main.go 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
controllers/operation.go
@@ -1090,7 +1090,7 @@
        return
    }
    if err := db.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize).Find(&records).Error; err != nil {
    if err := db.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize).Order("wms_operation.created_at desc").Find(&records).Error; err != nil {
        util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error())
        return
    }
controllers/warehouse.go
@@ -122,7 +122,34 @@
        util.ResponseFormat(c, code.RequestParamError, err.Error())
        return
    }
    err := models.NewWarehouseSearch().SetID(params.Id).Update(&params)
    warehouse, err := models.NewWarehouseSearch().SetID(params.Id).First()
    if err != nil {
        util.ResponseFormat(c, code.RequestParamError, "仓库不存在")
        return
    }
    err = models.WithTransaction(func(db *gorm.DB) error {
        //更新作业类型名称
        if params.Name != warehouse.Name {
            m := make(map[string]interface{})
            m["name"] = params.Name + "-入库"
            err := models.NewOperationTypeSearch().SetOrm(db).SetBaseOperationType(constvar.BaseOperationTypeIncoming).SetWarehouseId(params.Id).UpdateByMap(m)
            if err != nil {
                return err
            }
            m["name"] = params.Name + "-出库"
            err = models.NewOperationTypeSearch().SetOrm(db).SetBaseOperationType(constvar.BaseOperationTypeOutgoing).SetWarehouseId(params.Id).UpdateByMap(m)
            if err != nil {
                return err
            }
            m["name"] = params.Name + "-内部调拨"
            err = models.NewOperationTypeSearch().SetOrm(db).SetBaseOperationType(constvar.BaseOperationTypeInternal).SetWarehouseId(params.Id).UpdateByMap(m)
            if err != nil {
                return err
            }
        }
        err = models.NewWarehouseSearch().SetID(params.Id).Update(&params)
        return err
    })
    if err != nil {
        util.ResponseFormat(c, code.RequestParamError, "修改失败")
main.go
@@ -60,7 +60,6 @@
            logx.Errorf("grpc server init error: %v", err.Error())
            panic(fmt.Sprintf("grpc server init error: %v", err.Error()))
        }
        fmt.Println("-----------监听端口: ", conf.WebConf.GrpcPort)
        s := grpc.NewServer()
        //todo 添加具体服务
        product_inventory.RegisterProductInventoryServiceServer(s, &product_inventory.Server{})