123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430 |
- package services
- import (
- "archive/zip"
- "bytes"
- "fmt"
- "strings"
- "xugu_license/internal/api"
- "xugu_license/internal/global"
- "xugu_license/internal/models"
- "xugu_license/internal/module/email"
- "xugu_license/internal/module/license"
- "xugu_license/internal/utils"
- "github.com/pkg/errors"
- )
- func DistributeOALicenseServices(OperatorUniqueID, OaRequestId string, UserUniqueIDs, UserAccounts, UserNames, EmailArray []string) (error, []string) {
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- return nil, nil
- }
- func DistributeLicenseToUserServices(OperatorUniqueID string, OaRequestId int64, UserUniqueIDs, UserAccounts, UserNames []string) (error, []string) {
-
- existUsers, err := checkDistributeToUser(OaRequestId, UserUniqueIDs, UserNames)
- if err != nil {
- global.Logger.Errorln("license分发请求检测是否已发放给用户失败 %s", err.Error())
- return err, nil
- }
-
- if len(existUsers) != 0 {
- return nil, existUsers
- }
- fmt.Println("DistributeOALicenseServices : ")
-
- LicInfos, _, err := models.GetOALicenseInfo(1, 1, "", "", "", OaRequestId)
- if err != nil {
- return err, nil
- }
-
- for _, licInfo := range *LicInfos {
- for userIdx, userUID := range UserUniqueIDs {
-
- if licInfo.GenrateInfo.Lic1.String == "" {
- global.Logger.Errorln("DistributeOALicenseServices : license生成信息为空 ")
- return errors.New("license生成信息为空"), nil
- }
- err = models.InsertlicenseRecordByUserRow(OaRequestId, licInfo.LicInfo.UniqueID.String, userUID, UserAccounts[userIdx], OperatorUniqueID)
- if err != nil {
- global.Logger.Errorln("DistributeOALicenseServices: 数据库插入失败: ", err.Error())
- return err, nil
- }
- }
- }
- return nil, nil
- }
- func DistributeLicenseToEmailServices(OperatorUniqueID string, OaRequestId int64, UserUniqueIDs, UserAccounts, UserNames, EmailArray []string) (error, []string) {
-
-
-
- if len(EmailArray) == 0 {
- return nil, nil
- }
-
- LicInfos, _, err := models.GetOALicenseInfo(1, 1, "", "", "", OaRequestId)
- if err != nil {
- return err, nil
- }
-
-
- var buffer bytes.Buffer
- zipWriter := zip.NewWriter(&buffer)
- for i, lic := range *LicInfos {
- ii := i + 1
- num := 1
- filetestName := fmt.Sprintf("%d_%s_license_jdCount%d_%d", ii, lic.LicInfo.OAGLXMName.String, lic.LicInfo.OANodeCount.Int64, num)
- num++
-
- file1, err := zipWriter.Create(fmt.Sprintf(filetestName+"_%s", lic.LicInfo.OAMainMAC.String))
- if err != nil {
- global.Logger.Errorln(err)
- }
- if lic.GenrateInfo.Lic1.Valid {
- _, err = file1.Write([]byte(lic.GenrateInfo.Lic1.String))
- if err != nil {
- global.Logger.Errorln(err)
- }
- }
- file2, err := zipWriter.Create(fmt.Sprintf(filetestName+"_%s", lic.LicInfo.OASecondMAC.String))
- if lic.GenrateInfo.Lic2.Valid {
- if err != nil {
- global.Logger.Errorln(err)
- }
- _, err = file2.Write([]byte(lic.GenrateInfo.Lic2.String))
- if err != nil {
- global.Logger.Errorln(err)
- }
- }
- }
-
- if err := zipWriter.Close(); err != nil {
- global.Logger.Errorln(err)
- }
-
- zipBytes := buffer.Bytes()
- fmt.Println("EmailArray : ", EmailArray)
- emails := strings.Join(EmailArray, ",")
- if !strings.Contains(emails, "@") {
- return nil, nil
- }
-
-
-
-
- lic := &(*LicInfos)[0]
-
- em, err := email.BuildEmail(lic, EmailArray, zipBytes, "")
- if err != nil {
- global.Logger.Errorln("邮件生成失败", err.Error())
- return err, nil
- }
-
- err = email.SendEmail(em)
- if err != nil {
- global.Logger.Errorln("邮件发送失败", err.Error())
- return err, nil
- }
- for _, lic := range *LicInfos {
-
- err = models.InsertlicenseRecordByEmailRow(OaRequestId, lic.LicInfo.UniqueID.String, emails, OperatorUniqueID)
- if err != nil {
- global.Logger.Errorln("数据库插入失败: ", err.Error())
- return err, nil
- }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- return nil, nil
- }
- func GenerateOALicenseStrServices(request api.GenerateLicenseStrRequest) (error, bool) {
- if request.OARequestId != 0 {
-
- OALics, _, err := models.GetOALicenseInfo(0, 0, "", "", "", request.OARequestId)
- if err != nil || OALics == nil {
- global.Logger.Errorln("LicenseInfo数据查询失败: ", err.Error())
- return errors.Errorf("LicenseInfo数据查询失败 : %v", err.Error()), false
- }
-
- var isCheck bool
- for _, license := range *OALics {
-
- isCheckTmp, err := models.CheckLicenseInfoInOADB(&license.LicInfo)
- if err != nil {
- global.Logger.Errorln("LicenseInfo数据对比oa库 校验失败: ", err.Error())
- return errors.Errorf("LicenseInfo数据对比oa库 校验失败 %v", err.Error()), false
- }
- if isCheckTmp {
- global.Logger.Errorf("\nLicenseInfo数据对比oa库 不一致: %v\n", license.LicInfo.UniqueID)
- isCheck = isCheckTmp
- err = models.UpdatelicenseInfoRow(license)
- if err != nil {
- return err, false
- }
- }
- }
-
- if isCheck {
- return nil, true
- }
-
- for _, v := range *OALics {
- if v.GenrateInfo.LicenseFlage.String == "未生成" {
- err := generateLicenseStrSub(utils.ToString(v.LicInfo.UniqueID))
- if err != nil {
- global.Logger.Errorf("请联系管理员, LicenseInfo%v生成失败: %v\n", v.LicInfo.UniqueID, err.Error())
- return errors.Errorf("请联系管理员, LicenseInfo%v生成失败: %v\n", v.LicInfo.UniqueID, err.Error()), false
- }
- }
- }
- return nil, false
- }
- return errors.Errorf("License申请单为空"), false
- }
- func generateLicenseStrSub(UniqueID string) error {
- var applications *[]models.OALicenseInfo
- var err error
- if UniqueID != "" {
- applications, _, err = models.GetOALicenseInfo(0, 1, "", UniqueID, "", 0)
- if err != nil {
- global.Logger.Errorln("LicenseInfo数据查询失败: ", err.Error())
-
- return errors.Errorf("LicenseInfo数据查询失败: %v", err.Error())
- }
- }
- fmt.Printf("applications%#v\n", applications)
-
- if applications == nil {
- global.Logger.Errorln("LicenseInfo数据生成失败 ,数据查询为空 ")
-
- return errors.Errorf("LicenseInfo数据生成失败 ,数据查询为空 ")
- }
- pj := license.ProjectInfo{
- ProjectName: utils.ToString((*applications)[0].LicInfo.OAProductName),
- UserName: utils.ToString((*applications)[0].LicInfo.OAProductVersion),
- UserAddr: "未填写",
- SerialNumber: "未填写",
- }
- ei := license.EnvironmentInfo{
- CpuSN: "未填写",
- BaseboardSN: "未填写",
- MacAddr: utils.ToString((*applications)[0].LicInfo.OAMainMAC),
- DiskID: "未填写",
- IPAddr: "未填写",
- }
- LicType := utils.SwitchLicenseType(utils.ToString((*applications)[0].LicInfo.OAProductVersion))
- lI := license.LicenseInfo{
- GenDate: "2024-07-15",
- ExpireDate: "9999-12-31",
- LicenseType: LicType,
- LicenseVersion: 1,
- HardType: 3,
- }
-
- res := false
- if res {
- if (*applications)[0].LicInfo.OASecondMAC.String != "" {
-
-
-
- err = models.UpdateOALicenseStr(utils.ToString((*applications)[0].LicInfo.UniqueID), []byte("b4j6z4rE2IfG1av0wIPT7YnvyGZFHxwIBikMGjgCLQILR0xsT1NHiuzoi+Dqq+bmiNDEiuPyitDVgdvlRmYbFAk+MAAGASlPTkdMbE9"), []byte("b4j6z4rE2IfG1av0wIPT7YnvyGZFHxwIBikMGjgCLQILR0xsT1NHiuzoi+Dqq+bmiNDEiuPyitDVgdvlRmYbFAk+MAAGASlPTkdMbE9"))
- if err != nil {
- global.Logger.Errorln("LicenseInfo生成插入失败: ", err.Error())
-
- return errors.Errorf("LicenseInfo生成插入失败:: ", err.Error())
- }
- } else {
-
-
- err = models.UpdateOALicenseStr(utils.ToString((*applications)[0].LicInfo.UniqueID), []byte("b4j6z4rE2IfG1av0wIPT7YnvyGZFHxwIBikMGjgCLQILR0xsT1NHiuzoi+Dqq+bmiNDEiuPyitDVgdvlRmYbFAk+MAAGASlPTkdMbE9"), nil)
- if err != nil {
- global.Logger.Errorln("LicenseInfo2生成插入失败: ", err.Error())
-
- return errors.Errorf("LicenseInfo2生成插入失败:: ", err.Error())
- }
- }
- } else {
- licStr := license.GenerateLicense(pj, ei, lI)
-
- if (*applications)[0].LicInfo.OASecondMAC.String != "" {
- var licStr2 []byte
- ei.MacAddr = (*applications)[0].LicInfo.OASecondMAC.String
- licStr2 = license.GenerateLicense(pj, ei, lI)
- err = models.UpdateOALicenseStr(utils.ToString((*applications)[0].LicInfo.UniqueID), licStr, licStr2)
- if err != nil {
- global.Logger.Errorln("LicenseInfo2生成插入失败: ", err.Error())
-
- return errors.Errorf("LicenseInfo2生成插入失败:: ", err.Error())
- }
- } else {
-
- err = models.UpdateOALicenseStr(utils.ToString((*applications)[0].LicInfo.UniqueID), licStr, nil)
- if err != nil {
- global.Logger.Errorln("LicenseInfo生成插入失败: ", err.Error())
-
- return errors.Errorf("LicenseInfo生成插入失败:: ", err.Error())
- }
- }
- }
-
- return nil
- }
|