xugu_license/internal/models/license_oa_models.go

package models

import (
	"database/sql"
	"fmt"
	"log"
	"strings"
	"time"
	"xugu_license/internal/api"
	"xugu_license/internal/global"
)

// LicenseRecord 包含 LicenseRecordToUser 和 LicenseRecordToEmails 两个结构体
type LicenseRecord struct {
	LicenseRecordToUser   []LicenseRecordToUser   `json:"license_record_to_user"`
	LicenseRecordToEmails []LicenseRecordToEmails `json:"license_record_to_emails"`
}

type LicenseRecordToUser struct {
	ID               int       `json:"id"`
	OARequestId      int       `json:"oa_request_id"`
	LicenseUniqueID  string    `json:"license_unique_id"`
	UserUniqueID     string    `json:"user_unique_id"`
	UserAccount      string    `json:"user_account"`
	OperatorUniqueID string    `json:"operator_unique_id"`
	UpTime           time.Time `json:"up_time"`
	DelTime          time.Time `json:"del_time"` // 删除或失效的时间
}

type LicenseRecordToEmails struct {
	ID               int       `json:"id"`
	OARequestId      int       `json:"oa_request_id"`
	LicenseUniqueID  string    `json:"license_unique_id"`
	Emails           string    `json:"emails"`
	OperatorUniqueID string    `json:"operator_unique_id"`
	UpTime           time.Time `json:"up_time"`
	DelTime          time.Time `json:"del_time"` // 删除或失效的时间
}

// 插入分发记录用户表
func InsertlicenseRecordByUserRow(oaRequestID int64, LicenseUniqueID string, userUniqueID string, UserAccount string, operatorUniqueID string) error {

	tx, err := global.XuguDB.Begin()
	if err != nil {
		global.Logger.Errorln("begin transaction失败：  ", err.Error())
		return fmt.Errorf("begin transaction: %v", err)
	}

	defer func() {
		if err != nil {
			tx.Rollback()
		} else {
			err = tx.Commit()
		}
	}()
	_, err = tx.Exec(`
	Insert into  licenseRecordToUser(OA_REQUESTID,License_UniqueID ,user_UniqueID,User_Account,up_Time,operator_UniqueID) values(?,?,?,?,?,?)`,
		oaRequestID, LicenseUniqueID, userUniqueID, UserAccount, time.Now(), operatorUniqueID)
	if err != nil {
		global.Logger.Errorln("插入分发记录用户表失败： ", err.Error())
		return err
	}
	return nil

}

// 插入分发记录邮箱表
func InsertlicenseRecordByEmailRow(oaRequestID int64, LicenseUniqueID string, emails string, operatorUniqueID string) error {

	tx, err := global.XuguDB.Begin()
	if err != nil {
		global.Logger.Errorln("begin transaction失败：  ", err.Error())
		return fmt.Errorf("begin transaction: %v", err)
	}

	defer func() {
		if err != nil {
			tx.Rollback()
		} else {
			err = tx.Commit()
		}
	}()
	_, err = tx.Exec(`
	Insert into  licenseRecordToEmails(OA_REQUESTID,License_UniqueID ,emails,operator_UniqueID,up_Time) values(?,?,?,?,?)`,
		oaRequestID, LicenseUniqueID, emails, operatorUniqueID, time.Now())
	if err != nil {

		global.Logger.Errorln("插入分发记录邮箱表失败： ", err.Error())
		return err
	}
	return nil

}

// 获取分发记录用户表
func GetlicenseRecordByUser(OA_REQUESTID int, License_UniqueID string) ([]LicenseRecordToUser, error) {
	fmt.Println("搜索分发记录表 OA_REQUESTID", OA_REQUESTID)

	if License_UniqueID == "" {
		return nil, fmt.Errorf("uniqueID is empty")

	}
	if OA_REQUESTID <= 0 {
		return nil, fmt.Errorf("OA_REQUESTID is empty or error")
	}
	sqlLicUser := `select OA_REQUESTID,License_UniqueID,user_UNIQUEID,User_Account,operator_UniqueID,up_Time from licenseRecordToUser where License_UniqueID  = ? AND  del_time IS NULL`
	rows, err := global.XuguDB.Query(sqlLicUser, License_UniqueID)
	if err != nil {
		global.Logger.Errorln("query data: ", err.Error())
		return nil, fmt.Errorf("query error: %v", err)
	}
	defer rows.Close()

	var results []LicenseRecordToUser
	for rows.Next() {
		var lRU LicenseRecordToUser

		err = rows.Scan(
			&lRU.OARequestId,
			&lRU.LicenseUniqueID,
			&lRU.UserUniqueID,
			&lRU.UserAccount,
			&lRU.OperatorUniqueID,
			&lRU.UpTime,
		)

		if err != nil {

			global.Logger.Errorln("scan row: ", err.Error())

			return nil, fmt.Errorf("scan row error: %v", err)
		}

		results = append(results, lRU)
	}
	fmt.Println("LicenseRecordToUser ", results)
	return results, nil
}

// 获取分发记录邮箱表
func GetlicenseRecordByEmail(OA_REQUESTID int, License_UniqueID string) ([]LicenseRecordToEmails, error) {

	if License_UniqueID == "" {
		return nil, fmt.Errorf("uniqueID is empty")

	}
	if OA_REQUESTID <= 0 {
		return nil, fmt.Errorf("OA_REQUESTID is empty or error")
	}

	sqlLicEmail := `select OA_REQUESTID, License_UniqueID,emails,operator_UniqueID ,up_Time from licenseRecordToEmails  where License_UniqueID  = ? AND  del_time IS NULL;`
	rows, err := global.XuguDB.Query(sqlLicEmail, License_UniqueID)
	if err != nil {
		global.Logger.Errorln("query data: ", err.Error())
		return nil, fmt.Errorf("query error: %v", err)
	}

	var results []LicenseRecordToEmails
	for rows.Next() {
		var lRU LicenseRecordToEmails

		err = rows.Scan(
			&lRU.OARequestId,
			&lRU.LicenseUniqueID,
			&lRU.Emails,
			&lRU.OperatorUniqueID,
			&lRU.UpTime,
		)

		if err != nil {

			global.Logger.Errorln("scan row: ", err.Error())

			return nil, fmt.Errorf("scan row error: %v", err)
		}

		results = append(results, lRU)
	}

	if err = rows.Err(); err != nil {
		global.Logger.Errorln("rows error: ", err.Error())
		return nil, fmt.Errorf("rows error: %v", err)
	}

	return results, nil
}

type SQLResult struct {
	OARequestName          sql.NullString `json:"oa_request_name"`           // 请求名称 (wr.REQUESTNAME)
	OARequestNameNew       sql.NullString `json:"oa_request_name_new"`       // 新请求名称 (wr.REQUESTNAMENEW)
	OARequestNameHTMLNew   sql.NullString `json:"oa_request_name_html_new"`  // 新请求名称（HTML格式） (wr.REQUESTNAMEHTMLNEW)
	OAGLXMID               sql.NullInt64  `json:"oa_glxm_id"`                // 关联项目ID (fm.glxm)
	OAGLXMName             sql.NullString `json:"oa_glxm_name"`              // 关联项目 (PP.NAME)
	OASQSJ                 sql.NullString `json:"oa_sqsj"`                   // 申请时间 (fm.SQSJ)
	OASalespersonName      sql.NullString `json:"oa_salesperson_name"`       // 销售人员名称 (hrm1.LASTNAME)
	OAOperationsPersonName sql.NullString `json:"oa_operations_person_name"` // 运维人员名称 (hrm2.LASTNAME)
	OAXSJSYX               sql.NullString `json:"oa_xsjsyx"`                 // 销售邮箱 (fm.XSJSYX)
	OAJFJSYX               sql.NullString `json:"oa_jfjsyx"`                 // 运维邮箱 (fm.JFJSYX)
	OASYDW                 sql.NullString `json:"oa_sydw"`                   // 使用单位 (fm.SYDW)
	OAXMXXMS               sql.NullString `json:"oa_xmxxms"`                 // 项目详细描述 (fm.XMXXMS)
	OAJDS                  sql.NullInt64  `json:"oa_jds"`                    // 节点数 (fm.JDS)
	OANodeCount            sql.NullInt64  `json:"oa_node_count"`             // 总节点数 (fmd.JDS)
	OAProductName          sql.NullString `json:"oa_product_name"`           // 产品编号 (ws1.SELECTNAME)
	OAProductVersion       sql.NullString `json:"oa_product_version"`        // 产品版本 (ws2.SELECTNAME)
	CLQ                    sql.NullString `json:"clq"`                       // cpu
	CZXT                   sql.NullString `json:"czxt"`                      // 操作系统 (fmd.CZXT)
	IP                     sql.NullString `json:"ip"`                        // IP 地址 (fmd.IP)
	MAC                    sql.NullString `json:"mac"`                       // MAC 地址 (fmd.MAC)
	OACreationDate         sql.NullString `json:"oa_creation_date"`          // 创建日期 (wr.CREATEDATE)
	OACreationTime         sql.NullString `json:"oa_creation_time"`          // 创建时间 (wr.CREATETIME)
	OALastOperateDate      sql.NullString `json:"oa_last_operate_date"`      // 最后操作日期 (wr.LASTOPERATEDATE)
	OALastOperateTime      sql.NullString `json:"oa_last_operate_time"`      // 最后操作时间 (wr.LASTOPERATETIME)
}

// 检验与oa库数据是否一致
func CheckLicenseInfoInOADB(licInfo *TargetOALicenseInfo) (bool, error) {
	//fmt.Println("该死的id", licInfo.ID)
	if !licInfo.OAId.Valid {
		return false, fmt.Errorf("uniqueID is empty")

	}

	sql := `	
		SELECT
		wr.REQUESTNAME, wr.REQUESTNAMENEW, wr.REQUESTNAMEHTMLNEW, 
		fm.glxm,PP.NAME,fm.SQSJ, hrm1.LASTNAME, 
		hrm2.LASTNAME, fm.XSJSYX, fm.JFJSYX, 
		fm.SYDW, fm.XMXXMS, fm.JDS, 
		fmd.JDS,  ws1.SELECTNAME, 
		ws2.SELECTNAME, fmd.CLQ, fmd.CZXT, 
		fmd.IP, fmd.MAC,wr.CREATEDATE, wr.CREATETIME, 
		wr.LASTOPERATEDATE, wr.LASTOPERATETIME 
	FROM XUGU.formtable_main_146 fm
	LEFT JOIN XUGU.HRMRESOURCE hrm1 ON TO_NUMBER(fm.XSRY) = hrm1.id 
	LEFT JOIN XUGU.HRMRESOURCE hrm2 ON TO_NUMBER(fm.jfry) = hrm2.id
	LEFT JOIN XUGU.FORMTABLE_MAIN_146_dt1 fmd ON fmd.mainid = fm.id 
	LEFT JOIN XUGU.WORKFLOW_SELECTITEM ws1 ON fmd.cpmc = ws1.SELECTVALUE AND ws1.FIELDID = 14627
	LEFT JOIN XUGU.WORKFLOW_SELECTITEM ws2 ON fmd.BB = ws2.SELECTVALUE AND ws2.FIELDID = 14628
	LEFT JOIN XUGU.WORKFLOW_REQUESTBASE WR ON fm.REQUESTID = WR.REQUESTID 
	LEFT JOIN XUGU.PRJ_PROJECTINFO PP ON fm.glxm = PP.ID 
where fmd.id  = ?
	PARALLEL 8;
`
	var record SQLResult
	//Wvar sqsj string
	err := global.OaDB.QueryRow(sql, licInfo.OAId.Int64).Scan(
		&record.OARequestName,
		&record.OARequestNameNew,
		&record.OARequestNameHTMLNew,
		&record.OAGLXMID,
		&record.OAGLXMName,
		&record.OASQSJ,
		&record.OASalespersonName,
		&record.OAOperationsPersonName,
		&record.OAXSJSYX,
		&record.OAJFJSYX,
		&record.OASYDW,
		&record.OAXMXXMS,
		&record.OAJDS,
		&record.OANodeCount,
		&record.OAProductName,
		&record.OAProductVersion,
		&record.CLQ,
		&record.CZXT,
		&record.IP,
		&record.MAC,
		&record.OACreationDate,
		&record.OACreationTime,
		&record.OALastOperateDate,
		&record.OALastOperateTime,
	)
	if err != nil {
		//global.Logger.Errorln("query data: ", err.Error())
		return false, fmt.Errorf("CheckLicenseInfoInOADB query error: %v", err)
	}

	// 将字符串转换为 time.Time 对象
	//record.OASQSJ.Time, err = time.Parse("2006-01-02", sqsj)

	// if err != nil {
	// 	//fmt.Println("Error parsing date:", err)
	// 	return false, fmt.Errorf("CheckLicenseInfoInOADB  将字符串转换为 time.Time  Error : %v", err)
	// }

	if isEqual := compareAndCopy(record, licInfo); !isEqual {

		return true, nil
	}

	return false, nil
}

func SearchLicInfoToDb(userInput string) ([]TargetOALicenseInfo, error) {
	query := fmt.Sprintf(`
		SELECT 
			ID, UNIQUE_ID, OA_REQUESTID, OA_REQUESTNAME, OA_REQUESTNAMENEW, OA_REQUESTNAMEHTMLNEW,
			OA_GLXMID, OA_GLXMNAME, OA_SQSJ, OA_SALESPERSONNAME, OA_XSJSYX, OA_OPERATIONSPERSONNAME,
			OA_JFJSYX, OA_SYDW, OA_XMXXMS, OA_JDS, OA_NODECOUNT, OA_PRODUCTCODE, OA_PRODUCTNAME,
			OA_PRODUCTVERSION, OA_CPU, OA_OPERATINGSYSTEM, OA_MAINMAC, OA_SECONDMAC, 
			OA_CREATIONDATE, OA_CREATIONTIME, OA_LASTOPERATEDATE, OA_LASTOPERATETIME
		FROM SYSDBA.TARGET_OA_LICENSE
		WHERE 
			UNIQUE_ID LIKE '%%%s%%' OR
			OA_REQUESTNAME LIKE '%%%s%%' OR
			OA_REQUESTNAMENEW LIKE '%%%s%%' OR
			OA_REQUESTNAMEHTMLNEW LIKE '%%%s%%' OR
			OA_GLXMNAME LIKE '%%%s%%' OR
			OA_SQSJ LIKE '%%%s%%' OR
			OA_SALESPERSONNAME LIKE '%%%s%%' OR
			OA_XSJSYX LIKE '%%%s%%' OR
			OA_OPERATIONSPERSONNAME LIKE '%%%s%%' OR
			OA_JFJSYX LIKE '%%%s%%' OR
			OA_SYDW LIKE '%%%s%%' OR
			OA_XMXXMS LIKE '%%%s%%' OR
			OA_PRODUCTCODE LIKE '%%%s%%' OR
			OA_PRODUCTNAME LIKE '%%%s%%' OR
			OA_PRODUCTVERSION LIKE '%%%s%%' OR
			OA_CPU LIKE '%%%s%%' OR
			OA_OPERATINGSYSTEM LIKE '%%%s%%' OR
			OA_MAINMAC LIKE '%%%s%%' OR
			OA_SECONDMAC LIKE '%%%s%%' OR
			OA_CREATIONDATE LIKE '%%%s%%' OR
			OA_CREATIONTIME LIKE '%%%s%%' OR
			OA_LASTOPERATEDATE LIKE '%%%s%%' OR
			OA_LASTOPERATETIME LIKE '%%%s%%';
	`, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput, userInput)

	rows, err := global.XuguDB.Query(query)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	// 处理查询结果
	var licenses []TargetOALicenseInfo
	for rows.Next() {
		var license TargetOALicenseInfo
		err := rows.Scan(
			&license.ID, &license.UniqueID, &license.OARequestID, &license.OARequestName,
			&license.OARequestNameNew, &license.OARequestNameHTMLNew, &license.OAGLXMID,
			&license.OAGLXMName, &license.OASQSJ, &license.OASalespersonName, &license.OAXSJSYX,
			&license.OAOperationsPersonName, &license.OAJFJSYX, &license.OASYDW, &license.OAXMXXMS,
			&license.OAJDS, &license.OANodeCount, &license.OAProductCode, &license.OAProductName,
			&license.OAProductVersion, &license.OACPU, &license.OAOperatingSystem, &license.OAMainMAC,
			&license.OASecondMAC, &license.OACreationDate, &license.OACreationTime, &license.OALastOperateDate,
			&license.OALastOperateTime,
		)
		if err != nil {
			log.Fatal(err)
		}
		licenses = append(licenses, license)
	}
	if err != nil {
		log.Fatal(err)
	}

	// 检查错误
	if err := rows.Err(); err != nil {
		log.Fatal(err)
	}
	return licenses, nil
}

// 检测该单个license是否分配给用户
func CheckLicenseToUser(LicenseUniqueID string, userUNIQUEID string) (bool, error) {
	if LicenseUniqueID == "" || userUNIQUEID == "" {
		global.Logger.Errorln("LicenseUniqueID 或 userUNIQUEID 为空")
		return false, fmt.Errorf("LicenseUniqueID 或 userUNIQUEID 为空")
	}

	type checkLicens struct {
		check int
	}

	sql := `SELECT ID FROM licenseRecordToUser WHERE  License_UniqueID = ? AND user_UNIQUEID = ?`

	rows, err := global.XuguDB.Query(sql, LicenseUniqueID, userUNIQUEID)
	if err != nil {
		global.Logger.Errorln("query data: ", err.Error())
		return false, fmt.Errorf("query error: %v", err)
	}

	var cl checkLicens
	for rows.Next() {

		err = rows.Scan(
			&cl.check,
		)

		if err != nil {

			global.Logger.Errorln("scan row: ", err.Error())

			return false, fmt.Errorf("scan row error: %v", err)
		}

	}

	if err = rows.Err(); err != nil {
		global.Logger.Errorln("rows error: ", err.Error())
		return false, fmt.Errorf("rows error: %v", err)
	}

	fmt.Println("check: ", cl)
	if cl.check == 0 {
		return false, nil
	}
	return true, nil
}

// 按oa的申请单号来检测是否分发给用户
func CheckOaLicRequest(oaRequestID int64, userUNIQUEID string) (bool, error) {
	if oaRequestID == 0 || userUNIQUEID == "" {
		global.Logger.Errorln("CheckOaLicRequest : LicenseUniqueID 或 userUNIQUEID 为空")
		return false, fmt.Errorf("oaRequestID 或 userUNIQUEID 为空")
	}

	type checkLicens struct {
		check int
	}

	sql := `SELECT ID FROM licenseRecordToUser WHERE  OA_REQUESTID = ? AND user_UNIQUEID = ?`

	rows, err := global.XuguDB.Query(sql, oaRequestID, userUNIQUEID)
	if err != nil {
		global.Logger.Errorln("CheckOaLicRequest : query data: ", err.Error())
		return false, fmt.Errorf("CheckOaLicRequest : query error: %v", err)
	}

	var cl checkLicens
	for rows.Next() {

		err = rows.Scan(
			&cl.check,
		)

		if err != nil {

			global.Logger.Errorln("CheckOaLicRequest : scan row: ", err.Error())

			return false, fmt.Errorf("CheckOaLicRequest : scan row error: %v", err)
		}

	}

	if err = rows.Err(); err != nil {
		global.Logger.Errorln("CheckOaLicRequest : rows error: ", err.Error())
		return false, fmt.Errorf("CheckOaLicRequest : rows error: %v", err)
	}

	if cl.check == 0 {
		return false, nil
	}

	return true, nil
}

// ------------------按搜索条件查询license表--------------------
/*生成sql
flag : 1 是全部
		2 是用户拥有的license
*/
func buildConditionalSearchAllSQL(params api.ConditionalSearchRequest, flag int, user string) (string, []interface{}) {
	// 基础SQL查询
	var baseSQL string

	switch flag {
	case 1:
		baseSQL = `SELECT 
		la.ID, la.Unique_ID, la.OA_ID, la.OA_REQUESTID, la.OA_REQUESTNAME, la.OA_REQUESTNAMENEW,
		la.OA_REQUESTNAMEHTMLNEW, la.OA_GLXMID ,la.OA_GLXMNAME ,la.OA_SQSJ, la.OA_SALESPERSONNAME, la.OA_XSJSYX,
		la.OA_OPERATIONSPERSONNAME, la.OA_JFJSYX, la.OA_SYDW, la.OA_XMXXMS, la.OA_JDS,
		la.OA_NODECOUNT, la.OA_PRODUCTCODE, la.OA_PRODUCTNAME, la.OA_PRODUCTVERSION,
		la.OA_CPU, la.OA_OPERATINGSYSTEM, la.OA_MAINMAC, la.OA_SECONDMAC, la.OA_CREATIONDATE,
		la.OA_CREATIONTIME, la.OA_LASTOPERATEDATE, la.OA_LASTOPERATETIME, la.capture_Time,
		la.del_Time, la.LAST_OPERATE_TIME,
		li.ID AS License_ID, li.OA_ID, li.License_UniqueID, li.License_Flage, li.lic1, li.lic2, li.Creator_generate
	FROM 
		target_OA_license la
	INNER JOIN 
		License_generate_Info li
		ON 
		la.Unique_ID = li.License_UniqueID
	WHERE 
		OA_REQUESTID  IN (
			SELECT OA_REQUESTID 
			FROM (
				SELECT OA_REQUESTID, rownum AS a 
				FROM (
					SELECT DISTINCT OA_REQUESTID FROM TARGET_OA_LICENSE
				) a
			) s
			WHERE a BETWEEN 1 AND 1000
		)
		AND la.del_Time IS NULL
	AND 1=1`
	case 2:
		baseSQL = fmt.Sprintf(`SELECT 
    la.ID, la.Unique_ID, la.OA_ID, la.OA_REQUESTID, la.OA_REQUESTNAME, la.OA_REQUESTNAMENEW,
    la.OA_REQUESTNAMEHTMLNEW, la.OA_GLXMID ,la.OA_GLXMNAME ,la.OA_SQSJ, la.OA_SALESPERSONNAME, la.OA_XSJSYX,
    la.OA_OPERATIONSPERSONNAME, la.OA_JFJSYX, la.OA_SYDW, la.OA_XMXXMS, la.OA_JDS,
    la.OA_NODECOUNT, la.OA_PRODUCTCODE, la.OA_PRODUCTNAME, la.OA_PRODUCTVERSION,
    la.OA_CPU, la.OA_OPERATINGSYSTEM, la.OA_MAINMAC, la.OA_SECONDMAC, la.OA_CREATIONDATE,
    la.OA_CREATIONTIME, la.OA_LASTOPERATEDATE, la.OA_LASTOPERATETIME, la.capture_Time,
    la.del_Time, la.LAST_OPERATE_TIME,
    li.ID AS License_ID, li.OA_ID, li.License_UniqueID, li.License_Flage, li.lic1, li.lic2, li.Creator_generate
FROM 
    target_OA_license la
INNER JOIN 
    License_generate_Info li
    ON 
    la.Unique_ID = li.License_UniqueID
INNER JOIN 
    LICENSERECORDTOUSER ltr
  	ON 
    la.OA_REQUESTID = ltr.OA_REQUESTID AND ltr.USER_ACCOUNT = '%s'
WHERE 
    OA_REQUESTID  IN (
        SELECT OA_REQUESTID 
        FROM (
            SELECT OA_REQUESTID, rownum AS a 
            FROM (
                SELECT DISTINCT OA_REQUESTID FROM TARGET_OA_LICENSE
            ) a
        ) s
        WHERE a BETWEEN 1 AND 1000
    )
	AND la.del_Time IS NULL
AND 1=1`, user)
	}

	// 动态条件部分
	var conditions []string
	var args []interface{}

	// 根据 LicenseFlag 生成条件
	if params.LicenseFlag != "" {
		conditions = append(conditions, "li.License_Flage = ?")
		args = append(args, params.LicenseFlag)
	}

	// 根据 StartingDate 生成条件，将字符串转换为日期
	if params.StartingDate != "" {
		conditions = append(conditions, "TO_DATE(la.OA_CREATIONDATE, 'YYYY-MM-DD') >= ?")
		args = append(args, params.StartingDate)
	}

	// 根据 EndDate 生成条件，将字符串转换为日期
	if params.EndDate != "" {
		conditions = append(conditions, "TO_DATE(la.OA_CREATIONDATE, 'YYYY-MM-DD') <= ?")
		args = append(args, params.EndDate)
	}

	// 如果有条件，将条件加入SQL语句中
	if len(conditions) > 0 {
		baseSQL += " AND " + strings.Join(conditions, " AND ")
	}

	return baseSQL, args
}

func GetConditionalSearchAll(params api.ConditionalSearchRequest) (*[]OALicenseInfo, int, error) {
	total := 0
	err := global.XuguDB.QueryRow(`
		SELECT COUNT(*) from (SELECT OA_REQUESTID AS RequestCount
		FROM TARGET_OA_LICENSE
		where  Del_Time IS NULL
		GROUP BY OA_REQUESTID 
		)
		HAVING COUNT(*) > 1;`).Scan(&total)
	if err != nil {
		return nil, 0, fmt.Errorf("count query error: %v", err)
	}

	// 构建SQL语句和参数
	query, args := buildConditionalSearchAllSQL(params, 1, "")
	// 输出SQL语句和参数
	fmt.Println("Query:", query)
	fmt.Println("Args:", args)
	rows, err := global.XuguDB.Query(query, args...)
	if err != nil {
		global.Logger.Errorln("getLicInfoByOAUniqueID 数据查询失败： ", err.Error())
		return nil, 0, fmt.Errorf("getLicInfoByOAUniqueID 数据查询失败: %v", err)
	}
	defer rows.Close()
	var rest []OALicenseInfo
	for rows.Next() {
		var info OALicenseInfo
		err = rows.Scan(
			&info.LicInfo.ID, &info.LicInfo.UniqueID, &info.LicInfo.OAId, &info.LicInfo.OARequestID,
			&info.LicInfo.OARequestName, &info.LicInfo.OARequestNameNew, &info.LicInfo.OARequestNameHTMLNew,
			&info.LicInfo.OAGLXMID, &info.LicInfo.OAGLXMName,
			&info.LicInfo.OASQSJ, &info.LicInfo.OASalespersonName, &info.LicInfo.OAXSJSYX,
			&info.LicInfo.OAOperationsPersonName, &info.LicInfo.OAJFJSYX, &info.LicInfo.OASYDW,
			&info.LicInfo.OAXMXXMS, &info.LicInfo.OAJDS, &info.LicInfo.OANodeCount,
			&info.LicInfo.OAProductCode, &info.LicInfo.OAProductName, &info.LicInfo.OAProductVersion,
			&info.LicInfo.OACPU, &info.LicInfo.OAOperatingSystem, &info.LicInfo.OAMainMAC,
			&info.LicInfo.OASecondMAC, &info.LicInfo.OACreationDate, &info.LicInfo.OACreationTime,
			&info.LicInfo.OALastOperateDate, &info.LicInfo.OALastOperateTime, &info.LicInfo.CaptureTime,
			&info.LicInfo.DelTime, &info.LicInfo.LastOperateTime,
			&info.GenrateInfo.ID, &info.GenrateInfo.OAId, &info.GenrateInfo.LicenseUniqueID, &info.GenrateInfo.LicenseFlage,
			&info.GenrateInfo.Lic1, &info.GenrateInfo.Lic2, &info.GenrateInfo.CreatorGenerate,
		)
		if err != nil {
			log.Fatal(err)
		}
		rest = append(rest, info)

		fmt.Println("info", info)
	}

	return &rest, total, nil
}

func GetConditionalSearchUser(params api.ConditionalSearchRequest, user string) (*[]OALicenseInfo, int, error) {
	total := 0
	err := global.XuguDB.QueryRow(`
		SELECT COUNT(*) from (SELECT OA_REQUESTID AS RequestCount
		FROM TARGET_OA_LICENSE
		where  Del_Time IS NULL
		GROUP BY OA_REQUESTID 
		)
		HAVING COUNT(*) > 1;`).Scan(&total)
	if err != nil {
		return nil, 0, fmt.Errorf("count query error: %v", err)
	}

	// 构建SQL语句和参数
	query, args := buildConditionalSearchAllSQL(params, 2, user)
	// 输出SQL语句和参数
	fmt.Println("Query:", query)
	fmt.Println("Args:", args)
	rows, err := global.XuguDB.Query(query, args...)
	if err != nil {
		global.Logger.Errorln("getLicInfoByOAUniqueID 数据查询失败： ", err.Error())
		return nil, 0, fmt.Errorf("getLicInfoByOAUniqueID 数据查询失败: %v", err)
	}
	defer rows.Close()
	var rest []OALicenseInfo
	for rows.Next() {
		var info OALicenseInfo
		err = rows.Scan(
			&info.LicInfo.ID, &info.LicInfo.UniqueID, &info.LicInfo.OAId, &info.LicInfo.OARequestID,
			&info.LicInfo.OARequestName, &info.LicInfo.OARequestNameNew, &info.LicInfo.OARequestNameHTMLNew,
			&info.LicInfo.OAGLXMID, &info.LicInfo.OAGLXMName,
			&info.LicInfo.OASQSJ, &info.LicInfo.OASalespersonName, &info.LicInfo.OAXSJSYX,
			&info.LicInfo.OAOperationsPersonName, &info.LicInfo.OAJFJSYX, &info.LicInfo.OASYDW,
			&info.LicInfo.OAXMXXMS, &info.LicInfo.OAJDS, &info.LicInfo.OANodeCount,
			&info.LicInfo.OAProductCode, &info.LicInfo.OAProductName, &info.LicInfo.OAProductVersion,
			&info.LicInfo.OACPU, &info.LicInfo.OAOperatingSystem, &info.LicInfo.OAMainMAC,
			&info.LicInfo.OASecondMAC, &info.LicInfo.OACreationDate, &info.LicInfo.OACreationTime,
			&info.LicInfo.OALastOperateDate, &info.LicInfo.OALastOperateTime, &info.LicInfo.CaptureTime,
			&info.LicInfo.DelTime, &info.LicInfo.LastOperateTime,
			&info.GenrateInfo.ID, &info.GenrateInfo.OAId, &info.GenrateInfo.LicenseUniqueID, &info.GenrateInfo.LicenseFlage,
			&info.GenrateInfo.Lic1, &info.GenrateInfo.Lic2, &info.GenrateInfo.CreatorGenerate,
		)
		if err != nil {
			log.Fatal(err)
		}
		rest = append(rest, info)

		fmt.Println("info", info)
	}

	return &rest, total, nil
}