package technology import ( "SciencesServer/app/api/enterprise/controller/sys" "SciencesServer/app/api/enterprise/model" "SciencesServer/app/api/manage/controller" model2 "SciencesServer/app/common/model" "SciencesServer/app/service" "SciencesServer/app/session" "SciencesServer/serve/orm" "errors" "gorm.io/gorm" "strings" "time" ) // Patent 专利管理 type Patent struct { *session.Enterprise local string } type PatentHandle func(session *session.Enterprise, local string) *Patent type ( // PatentInfo 专利信息 PatentInfo struct { *sys.PatentInfo ShelfStatus model2.ShelfStatusKind Status model2.SysParentStatus } // PatentMatchInfo 专利匹配信息 PatentMatchInfo struct { ID string `json:"id"` Kind model2.SysParentKind `json:"kind"` Title string `json:"title"` Description string `json:"description"` ApplyAt string `json:"apply_at"` } // PatentInstance 专利信息 PatentInstance struct { ID string `json:"id"` *model.SysPatentInfo } // PatentDetailInfo 专利详细信息 PatentDetailInfo struct { ID string `json:"id"` *model2.SysPatent } // PatentParams 专利参数信息 PatentParams struct { ID uint64 Kind int Title, FileUrl string ApplyCode, ApplyName, ApplyAddress, ApplyAt, OpenCode, OpenAt string Inventor, IPCCode, Description, PrincipalClaim string Status int } ) // add 新增专利信息 func (c *PatentParams) add(uid uint64, local string) error { mSysPatent := model.NewSysPatent() isExist, err := mSysPatent.IsExistParams(map[string]interface{}{ "apply_code": c.ApplyCode, "open_code": c.OpenCode, }) if err != nil { return err } else if isExist { return errors.New("操作错误,申请号或公开(公告)号已存在") } return orm.GetDB().Transaction(func(tx *gorm.DB) error { mSysPatent.Kind = model2.SysParentKind(c.Kind) mSysPatent.Title = c.Title mSysPatent.FileUrl = c.FileUrl mSysPatent.ApplyCode = c.ApplyCode mSysPatent.ApplyAt = c.ApplyAt mSysPatent.OpenCode = c.OpenCode mSysPatent.OpenAt = c.OpenAt mSysPatent.ApplyName = c.ApplyName mSysPatent.ApplyAddress = c.ApplyAddress mSysPatent.Inventor = c.Inventor mSysPatent.Description = c.Description mSysPatent.PrincipalClaim = c.PrincipalClaim mSysPatent.IPCCode = c.IPCCode mSysPatent.Status = model2.SysParentStatus(c.Status) if err = model2.Create(mSysPatent.SysPatent, tx); err != nil { return err } mUserPatent := model.NewUserPatent() mUserPatent.Local.Local = local mUserPatent.UID = uid mUserPatent.PatentID = mSysPatent.ID return model2.Create(mUserPatent.UserPatent, tx) }) } // edit 删除专利信息 func (c *PatentParams) edit(uid uint64) error { mUserPatent := model.NewUserPatent() mUserPatent.ID = c.ID isExist, err := model2.FirstField(mUserPatent.UserPatent, []string{"id", "uid", "patent_id"}) if err != nil { return err } else if !isExist { return errors.New("操作错误,用户专利信息不存在或已被删除") } else if mUserPatent.UID != uid { return errors.New("无权限操作") } mSysPatent := model.NewSysPatent() mSysPatent.ID = mUserPatent.PatentID if isExist, err = model2.FirstField(mSysPatent.SysPatent, []string{"id", "apply_code", "open_code"}); err != nil { return err } else if !isExist { return errors.New("操作错误,专利信息不存在或已被删除") } _condition := make(map[string]interface{}, 0) if mSysPatent.ApplyCode != c.ApplyCode { _condition["apply_code"] = c.ApplyCode } if mSysPatent.OpenCode != c.OpenCode { _condition["open_code"] = c.OpenCode } if len(_condition) > 0 { if isExist, err = mSysPatent.IsExistParams(_condition); err != nil { return err } else if !isExist { return errors.New("操作错误,申请号或公开(公告)号已存在") } } mSysPatent.Kind = model2.SysParentKind(c.Kind) mSysPatent.Title = c.Title mSysPatent.FileUrl = c.FileUrl mSysPatent.ApplyCode = c.ApplyCode mSysPatent.ApplyAt = c.ApplyAt mSysPatent.OpenCode = c.OpenCode mSysPatent.OpenAt = c.OpenAt mSysPatent.ApplyName = c.ApplyName mSysPatent.ApplyAddress = c.ApplyAddress mSysPatent.Inventor = c.Inventor mSysPatent.Description = c.Description mSysPatent.PrincipalClaim = c.PrincipalClaim mSysPatent.IPCCode = c.IPCCode mSysPatent.Status = model2.SysParentStatus(c.Status) return model2.Updates(mSysPatent.SysPatent, mSysPatent.SysPatent) } // List 列表信息 func (c *Patent) List(kind int, title, applyCode, openCode, ipcCode string, page, pageSize int) (*controller.ReturnPages, error) { mUserPatent := model.NewUserPatent() where := []*model2.ModelWhere{ model2.NewWhere("u.uid", c.UID), } if kind <= 0 { where = append(where, model2.NewWhere("p.kind", kind)) } if title != "" { where = append(where, model2.NewWhereLike("p.title", title)) } if applyCode != "" { where = append(where, model2.NewWhereLike("p.apply_code", applyCode)) } if openCode != "" { where = append(where, model2.NewWhereLike("p.open_code", openCode)) } if ipcCode != "" { where = append(where, model2.NewWhereLike("p.ipc_code", ipcCode)) } var count int64 out, err := mUserPatent.Patents(page, pageSize, &count, where...) if err != nil { return nil, err } list := make([]*PatentInfo, 0) for _, v := range out { list = append(list, &PatentInfo{ PatentInfo: &sys.PatentInfo{ ID: v.GetEncodeID(), Title: v.Title, ApplyCode: v.ApplyCode, ApplyName: v.ApplyName, ApplyAt: v.ApplyAt, Inventor: v.Inventor, }, ShelfStatus: v.ShelfStatus, Status: v.Status, }) } return &controller.ReturnPages{Data: list, Count: count}, nil } // Match 搜索信息 func (c *Patent) Match(title string, industrys, keywords []string) ([]*PatentMatchInfo, error) { params := strings.Join([]string{ title, strings.Join(industrys, ","), strings.Join(keywords, ","), }, ",") patent := service.NewESPatent( service.WithPatentTitle(params), service.WithPatentIndustry(params), ) out, err := patent.Search(0, 0) if err != nil { return nil, err } ids := make([]uint64, 0) for _, v := range out.([]interface{}) { val := v.(*service.ESAchievement) ids = append(ids, val.ID) } mSysPatent := model.NewSysPatent() patents := make([]*model2.SysPatent, 0) if err = model2.ScanFields(mSysPatent.SysPatent, &patents, []string{"id", "kind", "title", "description", "apply_at"}, &model2.ModelWhereOrder{ Where: model2.NewWhereIn("id", ids), Order: model2.NewOrder("id", model2.OrderModeToDesc), }); err != nil { return nil, err } list := make([]*PatentMatchInfo, 0) for _, v := range patents { list = append(list, &PatentMatchInfo{ ID: v.GetEncodeID(), Title: v.Title, Description: v.Description, ApplyAt: v.ApplyAt, }) } return list, nil } // Detail 详细信息 func (c *Patent) Detail(id uint64) (*PatentDetailInfo, error) { mUserPatent := model.NewUserPatent() mUserPatent.ID = id isExist, err := model2.FirstField(mUserPatent.UserPatent, []string{"id", "uid", "patent_id"}) if err != nil { return nil, err } else if !isExist { return nil, errors.New("操作错误,用户专利信息不存在或已被删除") } mSysPatent := model.NewSysPatent() mSysPatent.ID = mUserPatent.PatentID _, err = model2.First(mSysPatent.SysPatent) if err != nil { return nil, err } return &PatentDetailInfo{ID: mUserPatent.GetEncodeID(), SysPatent: mSysPatent.SysPatent}, nil } func (c *Patent) Form(params *PatentParams) error { if params.ID > 0 { return params.edit(c.UID) } return params.add(c.UID, c.local) } // Shelf 上下架操作 func (c *Patent) Shelf(id uint64, status int) error { mUserPatent := model.NewUserPatent() mUserPatent.ID = id isExist, err := model2.FirstField(mUserPatent.UserPatent, []string{"id", "uid", "patent_id"}) if err != nil { return err } else if !isExist { return errors.New("操作错误,用户专利信息不存在或已被删除") } else if mUserPatent.UID != c.UID { return errors.New("无权限操作") } mSysPatent := model.NewSysPatent() mSysPatent.ID = mUserPatent.PatentID return model2.Updates(mSysPatent.SysPatent, map[string]interface{}{ "shelf": status, "updated_at": time.Now(), }) } // Delete 删除操作 func (c *Patent) Delete(id uint64) error { mUserPatent := model.NewUserPatent() mUserPatent.ID = id isExist, err := model2.FirstField(mUserPatent.UserPatent, []string{"id", "uid", "patent_id"}) if err != nil { return err } else if !isExist { return errors.New("操作错误,用户专利信息不存在或已被删除") } else if mUserPatent.UID != c.UID { return errors.New("无权限操作") } return orm.GetDB().Transaction(func(tx *gorm.DB) error { if err = model2.Delete(mUserPatent.UserPatent); err != nil { return err } mSysPatent := model.NewSysPatent() mSysPatent.ID = mUserPatent.PatentID return model2.Delete(mSysPatent.SysPatent) }) } func NewPatent() PatentHandle { return func(session *session.Enterprise, local string) *Patent { return &Patent{Enterprise: session, local: local} } }