eta_bridge/models/gn/mdm.go

package gn

import (
	"eta_gn/eta_bridge/global"
	"eta_gn/eta_bridge/utils"
	"fmt"
	"strings"
	"time"
)

// MDM_COMSTRU MDM组织机构
type MDM_COMSTRU struct {
	Id                                int       `gorm:"column:Id;primaryKey;autoIncrement" json:"-"`
	MainFieldComstruCode              string    `gorm:"column:Main_Field_Comstru_Code" json:"Main_Field_Comstru_Code"`
	MainFieldComstruCodeHR            string    `gorm:"column:Main_Field_Comstru_Code_HR" json:"Main_Field_Comstru_Code_HR"`
	MainFieldComstruTypeHR            string    `gorm:"column:Main_Field_Comstru_Type_HR" json:"Main_Field_Comstru_Type_HR"`
	ZDWLX                             string    `gorm:"column:ZDWLX" json:"ZDWLX"`
	MainFieldComstruNameHR            string    `gorm:"column:Main_Field_Comstru_Name_HR" json:"Main_Field_Comstru_Name_HR"`
	MainFieldComstruShortNameHR       string    `gorm:"column:Main_Field_Comstru_Short_Name_HR" json:"Main_Field_Comstru_Short_Name_HR"`
	MainFieldParentAdminComstruCodeHR string    `gorm:"column:Main_Field_ParentAdmin_Comstru_Code_HR" json:"Main_Field_ParentAdmin_Comstru_Code_HR"`
	MainFieldParentAdminComstruCode   string    `gorm:"column:Main_Field_ParentAdmin_Comstru_Code" json:"Main_Field_ParentAdmin_Comstru_Code"`
	MainFieldParentAdminComstruName   string    `gorm:"column:Main_Field_ParentAdmin_Comstru_Name" json:"Main_Field_ParentAdmin_Comstru_Name"`
	MainFieldCompanyLevel             string    `gorm:"column:Main_Field_Company_Level" json:"Main_Field_Company_Level"`
	MainFieldSecondcomstrucodehr      string    `gorm:"column:Main_Field_Secondcomstrucodehr" json:"Main_Field_Secondcomstrucodehr"`
	MainFieldShBusinessType           string    `gorm:"column:Main_Field_Sh_Business_Type" json:"Main_Field_Sh_Business_Type"`
	MainFieldYZGDWZCNDGX              string    `gorm:"column:Main_Field_YZGDWZCNDGX" json:"Main_Field_YZGDWZCNDGX"`
	MainFieldOrderHR                  string    `gorm:"column:Main_Field_Order_HR" json:"Main_Field_Order_HR"`
	MainFieldCompanyCode              string    `gorm:"column:Main_Field_Company_Code" json:"Main_Field_Company_Code"`
	MainFieldCompanyChain             string    `gorm:"column:Main_Field_Company_Chain" json:"Main_Field_Company_Chain"`
	MainFieldPARENTCOMPANYVIRTUAL     string    `gorm:"column:Main_Field_PARENTCOMPANYVIRTUAL" json:"Main_Field_PARENTCOMPANYVIRTUAL"`
	ZQYZT                             string    `gorm:"column:ZQYZT" json:"ZQYZT"`
	CreateTime                        time.Time `gorm:"column:create_time" json:"create_time"`
	ModifyTime                        time.Time `gorm:"column:modify_time" json:"modify_time"`
}

func (m *MDM_COMSTRU) TableName() string {
	return "MDM_COMSTRU"
}

func (m *MDM_COMSTRU) Create() (err error) {
	err = global.MYSQL["hz_eta"].Create(m).Error
	return
}

func (m *MDM_COMSTRU) Update(cols []string) (err error) {
	err = global.MYSQL["hz_eta"].Select(cols).Updates(m).Error
	return
}

func (m *MDM_COMSTRU) GetItemByCondition(condition string, pars []interface{}) (item *MDM_COMSTRU, err error) {
	sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s LIMIT 1`, m.TableName(), condition)
	err = global.MYSQL["hz_eta"].Raw(sql, pars...).First(&item).Error
	return
}

func (m *MDM_COMSTRU) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*MDM_COMSTRU, err error) {
	fields := strings.Join(fieldArr, ",")
	if len(fieldArr) == 0 {
		fields = `*`
	}
	order := ``
	if orderRule != "" {
		order = ` ORDER BY ` + orderRule
	}
	sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
	err = global.MYSQL["hz_eta"].Raw(sql, pars...).Find(&items).Error
	return
}

// MDM_EMPLOYEE MDM员工表
type MDM_EMPLOYEE struct {
	Id                           int       `gorm:"column:Id;primaryKey;autoIncrement" json:"-"`
	MainFieldEmployeeCode        string    `gorm:"column:Main_Field_Employee_Code" json:"Main_Field_Employee_Code"`
	MainFieldEmployeeFirstName   string    `gorm:"column:Main_Field_Employee_FirstName" json:"Main_Field_Employee_FirstName"`
	MainFieldEmployeeLastName    string    `gorm:"column:Main_Field_Employee_LastName" json:"Main_Field_Employee_LastName"`
	MainFieldGender              string    `gorm:"column:Main_Field_Gender" json:"Main_Field_Gender"`
	MainFieldEmpolyeeGroup       string    `gorm:"column:Main_Field_Empolyee_Group" json:"Main_Field_Empolyee_Group"`
	MainFieldOfficeTelephone     string    `gorm:"column:Main_Field_Office_Telephone" json:"Main_Field_Office_Telephone"`
	MainFieldDateType            string    `gorm:"column:Main_Field_Date_Type" json:"Main_Field_Date_Type"`
	MainFieldEmployeeStatus      string    `gorm:"column:Main_Field_Employee_Status" json:"Main_Field_Employee_Status"`
	MainFieldDeleteFlag          string    `gorm:"column:Main_Field_Delete_Flag" json:"Main_Field_Delete_Flag"`
	MainFieldEmail               string    `gorm:"column:Main_Field_Email" json:"Main_Field_Email"`
	MainFieldCompanyCode         string    `gorm:"column:Main_Field_Company_code" json:"Main_Field_Company_code"`
	MainFieldSecondcomstrucodehr string    `gorm:"column:Main_Field_Secondcomstrucodehr" json:"Main_Field_Secondcomstrucodehr"`
	MainFieldCompanyChain        string    `gorm:"column:Main_Field_Company_Chain" json:"Main_Field_Company_Chain"`
	CreateTime                   time.Time `gorm:"column:create_time" json:"create_time"`
	ModifyTime                   time.Time `gorm:"column:modify_time" json:"modify_time"`
}

func (m *MDM_EMPLOYEE) TableName() string {
	return "MDM_EMPLOYEE"
}

func (m *MDM_EMPLOYEE) Create() (err error) {
	err = global.MYSQL["hz_eta"].Create(m).Error
	return
}

func (m *MDM_EMPLOYEE) Update(cols []string) (err error) {
	err = global.MYSQL["hz_eta"].Select(cols).Updates(m).Error
	return
}

func (m *MDM_EMPLOYEE) GetItemByCondition(condition string, pars []interface{}) (item *MDM_EMPLOYEE, err error) {
	sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s LIMIT 1`, m.TableName(), condition)
	err = global.MYSQL["hz_eta"].Raw(sql, pars...).First(&item).Error
	return
}

func (m *MDM_EMPLOYEE) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*MDM_EMPLOYEE, err error) {
	fields := strings.Join(fieldArr, ",")
	if len(fieldArr) == 0 {
		fields = `*`
	}
	order := ``
	if orderRule != "" {
		order = ` ORDER BY ` + orderRule
	}
	sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
	err = global.MYSQL["hz_eta"].Raw(sql, pars...).Find(&items).Error
	return
}

// CreateEmployee 新增员工及组织关系
func (m *MDM_EMPLOYEE) CreateEmployee(employee *MDM_EMPLOYEE, employeeRelation []*MDM_RELA_COMSTRU_EMPLOYEE) (err error) {
	if employee == nil {
		err = fmt.Errorf("employee is nil")
		return
	}
	tx := global.MYSQL["hz_eta"].Begin()
	defer func() {
		if err != nil {
			_ = tx.Rollback()
			return
		}
		_ = tx.Commit()
	}()

	if e := tx.Create(employee).Error; e != nil {
		err = fmt.Errorf("create employee err, %v", e)
		return
	}
	if len(employeeRelation) == 0 {
		return
	}
	if e := tx.CreateInBatches(employeeRelation, utils.MultiAddNum).Error; e != nil {
		err = fmt.Errorf("create employee relations err, %v", e)
		return
	}
	return
}

// UpdateEmployee 更新员工及组织关系
func (m *MDM_EMPLOYEE) UpdateEmployee(employee *MDM_EMPLOYEE, updateCols []string, employeeRelation []*MDM_RELA_COMSTRU_EMPLOYEE) (err error) {
	if employee == nil {
		err = fmt.Errorf("employee is nil")
		return
	}
	tx := global.MYSQL["hz_eta"].Begin()
	defer func() {
		if err != nil {
			_ = tx.Rollback()
			return
		}
		_ = tx.Commit()
	}()

	if e := tx.Select(updateCols).Updates(employee).Error; e != nil {
		err = fmt.Errorf("update employee err, %v", e)
		return
	}
	sql := `DELETE FROM MDM_RELA_COMSTRU_EMPLOYEE WHERE Main_Field_Employee_Code = ?`
	if e := tx.Exec(sql, employee.MainFieldEmployeeCode); e != nil {
		err = fmt.Errorf("delete employee relations err, %v", e)
		return
	}
	if len(employeeRelation) == 0 {
		return
	}
	if e := tx.CreateInBatches(employeeRelation, utils.MultiAddNum).Error; e != nil {
		err = fmt.Errorf("create employee relations err, %v", e)
		return
	}
	return
}

// MDM_RELA_COMSTRU_EMPLOYEE MDM员工组织关系表
type MDM_RELA_COMSTRU_EMPLOYEE struct {
	Id                        int       `gorm:"column:Id;primaryKey;autoIncrement" json:"-"`
	Main_Field_Employee_Code  string    `gorm:"column:Main_Field_Employee_Code" json:"Main_Field_Employee_Code"`
	TuplesFieldCompanyCode    string    `gorm:"column:Tuples_Field_Company_Code" json:"Tuples_Field_Company_Code"`
	TuplesFieldCompanyName    string    `gorm:"column:Tuples_Field_Company_Name" json:"Tuples_Field_Company_Name"`
	TuplesFieldDepartmentCode string    `gorm:"column:Tuples_Field_Department_Code" json:"Tuples_Field_Department_Code"`
	TuplesFieldDepartmentName string    `gorm:"column:Tuples_Field_Department_Name" json:"Tuples_Field_Department_Name"`
	TuplesFieldPositionCode   string    `gorm:"column:Tuples_Field_Position_Code" json:"Tuples_Field_Position_Code"`
	TuplesFieldPositionName   string    `gorm:"column:Tuples_Field_Position_Name" json:"Tuples_Field_Position_Name"`
	TuplesFieldPostFlag       string    `gorm:"column:Tuples_Field_Post_Flag" json:"Tuples_Field_Post_Flag"`
	CreateTime                time.Time `gorm:"column:create_time" json:"create_time"`
	ModifyTime                time.Time `gorm:"column:modify_time" json:"modify_time"`
}

func (m *MDM_RELA_COMSTRU_EMPLOYEE) TableName() string {
	return "MDM_RELA_COMSTRU_EMPLOYEE"
}