97 lines
3.8 KiB
Go
97 lines
3.8 KiB
Go
package model
|
|
|
|
import (
|
|
"SciencesServer/app/common/model"
|
|
"SciencesServer/serve/orm"
|
|
"fmt"
|
|
)
|
|
|
|
type ManageExpert struct {
|
|
*model.ManageExpert
|
|
}
|
|
|
|
type ManageExpertInfo struct {
|
|
*model.ManageExpert
|
|
PatentTitle string `json:"-"`
|
|
ResearchName string `json:"research_name"`
|
|
Research string `json:"-"`
|
|
Introduce string `json:"introduce"`
|
|
}
|
|
|
|
// Expert 专家信息
|
|
func (m *ManageExpert) Expert(limit int, where ...*model.ModelWhere) ([]*ManageExpertInfo, error) {
|
|
// 专利信息
|
|
mSysPatent := model.NewSysPatent()
|
|
// 用户专利信息
|
|
mUserPatent := model.NewUserPatent()
|
|
|
|
db := orm.GetDB().Table(m.TableName()+" AS e").
|
|
Select("e.id", "e.name", "e.industry", "e.image", "e.school", "e.major", "e.keyword",
|
|
"p.title AS patent_title", "r.name AS research_name").
|
|
Joins(fmt.Sprintf("LEFT JOIN %s AS e_u ON e.id = e_u.expert_id AND e_u.invalid_status = %d AND e_u.is_deleted = %d",
|
|
model.NewUserExpert().TableName(), model.InvalidStatusForNot, model.DeleteStatusForNot)).
|
|
Joins(fmt.Sprintf(`LEFT JOIN (SELECT u.uid, SUBSTRING_INDEX(GROUP_CONCAT(p.kind, '$$', p.title ORDER BY p.id DESC SEPARATOR '&&'), '&&', %d) AS title
|
|
FROM %s AS u LEFT JOIN %s AS p ON u.patent_id = p.id WHERE u.is_deleted = %d AND p.shelf_status = %d GROUP BY u.uid) AS p ON e_u.uid = p.uid`,
|
|
limit, mUserPatent.TableName(), mSysPatent.TableName(), model.DeleteStatusForNot, model.ShelfStatusForUp)).
|
|
Joins(fmt.Sprintf("LEFT JOIN %s AS r ON e.research_id = r.id", model.NewManageResearch().TableName())).
|
|
Where("e.examine_status = ?", model.ExamineStatusForAgree).
|
|
Where("e.is_deleted = ?", model.DeleteStatusForNot)
|
|
|
|
if len(where) > 0 {
|
|
for _, v := range where {
|
|
db = db.Where(v.Condition, v.Value)
|
|
}
|
|
}
|
|
out := make([]*ManageExpertInfo, 0)
|
|
|
|
if err := db.Order("e.id " + model.OrderModeToDesc).Scan(&out).Error; err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// Detail 专家信息
|
|
func (m *ManageExpert) Detail(limit int, id uint64) (*ManageExpertInfo, error) {
|
|
// 专利信息
|
|
mSysPatent := model.NewSysPatent()
|
|
// 用户专利信息
|
|
mUserPatent := model.NewUserPatent()
|
|
|
|
db := orm.GetDB().Table(m.TableName()+" AS e").
|
|
Select("e.id", "e.name", "e.industry", "e.image", "e.school", "e.major", "e.keyword", "e.research",
|
|
"e.introduce", "p.title AS patent_title", "r.name AS research_name").
|
|
Joins(fmt.Sprintf("LEFT JOIN %s AS e_u ON e.id = e_u.expert_id AND e_u.invalid_status = %d AND e_u.is_deleted = %d",
|
|
model.NewUserExpert().TableName(), model.InvalidStatusForNot, model.DeleteStatusForNot)).
|
|
Joins(fmt.Sprintf(`LEFT JOIN (SELECT u.uid, SUBSTRING_INDEX(GROUP_CONCAT(p.kind, '$$', p.title ORDER BY p.id DESC SEPARATOR '&&'), '&&', %d) AS title
|
|
FROM %s AS u LEFT JOIN %s AS p ON u.patent_id = p.id WHERE u.is_deleted = %d AND p.shelf_status = %d GROUP BY u.uid) AS p ON e_u.uid = p.uid`,
|
|
limit, mUserPatent.TableName(), mSysPatent.TableName(), model.DeleteStatusForNot, model.ShelfStatusForUp)).
|
|
Joins(fmt.Sprintf("LEFT JOIN %s AS r ON e.research_id = r.id", model.NewManageResearch().TableName())).
|
|
Where("e.id = ?", id)
|
|
|
|
out := new(ManageExpertInfo)
|
|
|
|
if err := db.Scan(&out).Error; err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// Distribution 分布信息
|
|
func (m *ManageExpert) Distribution(province, city string) ([]*DataAreaDistributionInfo, error) {
|
|
out := make([]*DataAreaDistributionInfo, 0)
|
|
|
|
db := orm.GetDB().Table(m.TableName()).
|
|
Select("province", "city", "district", "GROUP_CONCAT(industry SEPARATOR '&') AS industry").
|
|
Group("province").Group("city").Group("district")
|
|
|
|
err := db.Order("province "+model.OrderModeToAsc).Order("city "+model.OrderModeToAsc).Order("district "+model.OrderModeToAsc).
|
|
Where("examine_status = ?", model.ExamineStatusForAgree).
|
|
Scan(&out).Error
|
|
|
|
return out, err
|
|
}
|
|
|
|
func NewManageExpert() *ManageExpert {
|
|
return &ManageExpert{model.NewManageExpert()}
|
|
}
|