jyMicroservices/jyBXCore/rpc/model/mysql/participateBid.go

package mysql

import (
	MC "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/date"
	"app.yhyue.com/moapp/jybase/encrypt"
	"database/sql"
	"encoding/json"
	"fmt"
	"github.com/zeromicro/go-zero/core/logx"
	IC "jyBXCore/rpc/init"
	"jyBXCore/rpc/model/es"
	"jyBXCore/rpc/type/bxcore"
	"strconv"
	"strings"
	"time"
)

var (
	PartTable = "participate"
)

//划转参标信息
func TransferParticipateInfo(projectId string, in *bxcore.ParticipateActionReq) error {
	defer MC.Catch()
	//保存或更新新跟踪人
	if !IC.BaseMysql.ExecTx("划转参标信息", func(tx *sql.Tx) bool {
		var (
			b1            = true
			b2, b3        bool
			now           = time.Now()
			content       = "%s划转给%s%s"
			lastNotes     = ",保留原参标人"
			fromUserNames []string
			ids           []int
		)
		partInfo := IC.BaseMysql.SelectBySqlByTx(tx, "SELECT id,position_id FROM `participate_user` WHERE  project_id = ?  AND ent_id = ? AND state > -1", projectId, in.EntId)
		if partInfo == nil || len(*partInfo) == 0 {
			logx.Info("当前项目不满足划转条件")
			return false
		} else {
			for _, v := range *partInfo {
				ids = append(ids, MC.IntAll(v["id"]))
				positionId := MC.Int64All(v["position_id"])
				userInfo := IC.Middleground.UserCenter.IdentityByPositionId(positionId)
				if userInfo.EntUserName != "" {
					fromUserNames = append(fromUserNames, userInfo.EntUserName)
				}
			}
		}
		if len(fromUserNames) == 0 {
			logx.Info("原参标人信息查询有误")
			return false
		}
		//是否保留原参标人
		if !in.IsRetain {
			lastNotes = ""
			//不保留 原参标人，获取把原参标人信息
			//当前项目有参标人 更新参标人状态
			b1 = IC.BaseMysql.UpdateByTx(tx, "participate_user", map[string]interface{}{
				"ent_id":     in.EntId,
				"project_id": projectId,
			}, map[string]interface{}{
				"state":       -1,
				"mark":        -2, //0：参标；1：被划入；-1：终止参标；-2：被划走
				"update_date": date.FormatDate(&now, date.Date_Full_Layout),
			})
		}
		//查询划转人信息
		entUserId, _ := strconv.ParseInt(in.ToEntUserId, 10, 64)
		userInfo := IC.Middleground.UserCenter.IdentityByEntUserId(entUserId)
		positionId := userInfo.PositionId
		content = fmt.Sprintf(content, strings.Join(fromUserNames, ","), userInfo.EntUserName, lastNotes)
		//划转记录
		b2 = IC.BaseMysql.InsertByTx(tx, "participate_bid_records", map[string]interface{}{
			"ent_id":         in.EntId,
			"ent_user_id":    entUserId,
			"position_id":    positionId,
			"project_id":     projectId,
			"record_content": content,
			"create_date":    date.FormatDate(&now, date.Date_Full_Layout),
		}) > 0
		//保存参标--participate_user
		//查看是否参标过当前项目
		if c := IC.BaseMysql.CountBySql("SELECT count(id) FROM `participate_user` WHERE position_id = ? AND project_id = ?  AND ent_id = ?", positionId, projectId, in.EntId); c > 0 {
			//更新
			b3 = IC.BaseMysql.UpdateByTx(tx, "participate_user", map[string]interface{}{
				"position_id": positionId,
				"project_id":  projectId,
				"ent_id":      in.EntId,
			}, map[string]interface{}{
				"state":       0,
				"mark":        1, //0：参标；1：被划入；-1：终止参标；-2：被划走
				"update_date": date.FormatDate(&now, date.Date_Full_Layout),
			})
		} else {
			//保存
			b3 = IC.BaseMysql.InsertByTx(tx, "participate_user", map[string]interface{}{
				"ent_id":      in.EntId,
				"ent_user_id": entUserId,
				"position_id": positionId,
				"project_id":  projectId,
				"state":       0,
				"mark":        1, //0：参标；1：被划入；-1：终止参标；-2：被划走
				"create_date": date.FormatDate(&now, date.Date_Full_Layout),
				"update_date": date.FormatDate(&now, date.Date_Full_Layout),
			}) > 0
		}
		return b1 && b2 && b3
	}) {
		logx.Info(in.PositionId, "---终止---", projectId)
		return fmt.Errorf("终止参标更新信息出错")
	}
	return nil
}

//终止参标
func CancelParticipateInfo(in *bxcore.ParticipateActionReq, roleId int64) error {
	defer MC.Catch()
	if !IC.BaseMysql.ExecTx("终止参标", func(tx *sql.Tx) bool {
		var (
			b1, b2 bool
			now    = time.Now()
			tip    = "终止参标（被）"
		)
		//管理员终止：当前项目 其他参标人也被终止
		query := map[string]interface{}{
			"project_id": in.ProjectIds,
			"ent_id":     in.EntId,
		}
		//个人终止：仅仅终止本人参标项目
		if roleId == 0 {
			query["position_id"] = in.PositionId
			tip = "终止参标"
		}
		insert := map[string]interface{}{
			"state":       -1,
			"mark":        -1, //0：参标；1：被划入；-1：终止参标；-2：被划走
			"update_date": date.FormatDate(&now, date.Date_Full_Layout),
		}
		//更新参标participate_user
		b1 = IC.BaseMysql.UpdateByTx(tx, "participate_user", query, insert)
		//保存参标记录--participate_bid_records
		b2 = IC.BaseMysql.InsertByTx(tx, "participate_bid_records", map[string]interface{}{
			"ent_id":         in.EntId,
			"ent_user_id":    in.EntUserId,
			"position_id":    in.PositionId,
			"project_id":     in.ProjectIds,
			"record_content": tip,
			"create_date":    date.FormatDate(&now, date.Date_Full_Layout),
		}) > 0
		return b1 && b2
	}) {
		logx.Info(in.PositionId, "---终止---", in.ProjectIds)
		return fmt.Errorf("终止参标更新信息出错")
	}
	return nil
}

//保存参标信息
func SaveParticipateInfo(in *bxcore.ParticipateActionReq) error {
	defer MC.Catch()
	if !IC.BaseMysql.ExecTx("保存|更新参标信息及保存参标记录", func(tx *sql.Tx) bool {
		var (
			b1, b2, b3 bool
			now        = time.Now()
		)
		//保存参标--participate_user
		//查看是否参标过当前项目
		if c := IC.BaseMysql.CountBySql("SELECT count(id) FROM `participate_user` WHERE position_id = ? AND project_id = ?  AND ent_id = ?", in.PositionId, in.ProjectIds, in.EntId); c > 0 {
			//更新
			b1 = IC.BaseMysql.UpdateByTx(tx, "participate_user", map[string]interface{}{
				"state":       0,
				"mark":        0,
				"update_date": date.FormatDate(&now, date.Date_Full_Layout),
			}, map[string]interface{}{
				"position_id": in.PositionId,
				"ent_id":      in.EntId,
				"project_id":  in.ProjectIds,
			})
		} else {
			//保存
			b1 = IC.BaseMysql.InsertByTx(tx, "participate_user", map[string]interface{}{
				"ent_id":      in.EntId,
				"ent_user_id": in.EntUserId,
				"position_id": in.PositionId,
				"project_id":  in.ProjectIds,
				"state":       0,
				"mark":        0,
				"create_date": date.FormatDate(&now, date.Date_Full_Layout),
				"update_date": date.FormatDate(&now, date.Date_Full_Layout),
			}) > 0
		}
		if !b1 {
			return false
		}
		//保存参标记录participate_bid_records
		b2 = IC.BaseMysql.InsertByTx(tx, "participate_bid_records", map[string]interface{}{
			"ent_id":         in.EntId,
			"ent_user_id":    in.EntUserId,
			"position_id":    in.PositionId,
			"project_id":     in.ProjectIds,
			"record_content": "参标",
			"create_date":    date.FormatDate(&now, date.Date_Full_Layout),
		}) > 0
		if !b2 {
			return false
		}
		//保存或更新项目信息
		//有问题 其他回滚，项目信息不用回滚
		b3 = UpdateProjectInfo(in.ProjectIds, es.GetProjectInfo(in.ProjectIds), es.GetBiddingInfo(in.BidIds)) == nil
		return b1 && b2 && b3
	}) {
		logx.Info(in.PositionId, "---保存---", in.BidIds)
		return fmt.Errorf("保存参标信息出错")
	}
	return nil
}

//查询当前招标信息是否已被参标
func IsParticipatedByBidId(in *bxcore.ParticipateActionReq) bool {
	defer MC.Catch()
	//如果不允许多人参标 当前项目是否已经有企业其他人员参标
	query := fmt.Sprintf(`SELECT count(id) FROM participate_user WHERE %s AND project_id = %s AND state >-1`, "%s", in.BidIds)
	if in.PositionType > 0 { //企业版
		query = fmt.Sprintf(query, fmt.Sprintf("ent_id = %d", in.EntId))
	} else { //个人版
		query = fmt.Sprintf(query, fmt.Sprintf("position_id = %d", in.PositionId))
	}
	return IC.BaseMysql.CountBySql(query) > 0
}

//获取参标权限
func GetParticipateIsAllow(query map[string]interface{}) (b bool) {
	defer MC.Catch()
	if info, ok := IC.Mgo.FindOne(PartTable, query); ok {
		if info != nil {
			if (*info)["i_isallow"] != nil {
				b = MC.IntAll((*info)["i_isallow"]) > 0
			}
		}
	}
	return
}

//更新设置信息
func UpdateParticipateSetInfo(in *bxcore.ParticipateSetUpInfoReq) error {
	defer MC.Catch()
	query := map[string]interface{}{
		"i_positionid": in.PositionId,
	}
	if in.PositionType > 0 {
		//企业版 判断是否是管理员
		//判断用户身份
		userInfo := IC.Middleground.PowerCheckCenter.Check(in.AppId, in.UserId, in.NewUserId, in.AccountId, in.EntId, in.PositionType, in.PositionId)
		if userInfo.Ent.EntRoleId == 0 {
			return fmt.Errorf("当前企业身份无权限")
		}
		query["i_entid"] = in.EntId
	}
	upsert := map[string]interface{}{
		"i_entid":      in.EntId,
		"i_entuserid":  in.EntUserId,
		"i_positionid": in.PositionId,
		"l_createtime": time.Now().Unix(),
	}
	if in.IsAllow != "" {
		isAllow, _ := strconv.Atoi(in.IsAllow)
		upsert["i_isallow"] = isAllow
	}
	if len(in.BidType) > 0 {
		upsert["o_bidtype"] = in.BidType
	}
	if len(in.RemindRule) > 0 {
		upsert["o_remindrule"] = in.RemindRule
	}
	if ok := IC.Mgo.Update(PartTable, query, map[string]interface{}{
		"$set": upsert,
	}, true, false); ok {
		return nil
	}
	return fmt.Errorf("更新失败")
}

//查询企业|个人参标设置信息
func GetParticipateSetInfo(in *bxcore.ParticipateSetUpInfoReq) (*bxcore.ParticipateSetUpInfo, error) {
	defer MC.Catch()
	query := map[string]interface{}{
		"i_positionid": in.PositionId,
	}
	if in.PositionType > 0 {
		query["i_entid"] = in.EntId
	}
	if setInfo, ok := IC.Mgo.FindOne(PartTable, query); ok {
		var (
			isAllow    = ""
			bidType    []*bxcore.BidTypeReq
			remindRule []*bxcore.RemindRuleReq
		)
		bidType = append(bidType, &bxcore.BidTypeReq{
			Name:    "直接投标",
			Content: []string{"未报名", "已报名", "投标决策", "编制投标文件", "递交投标文件", "中标公示", "签合同", "已结束"},
		}, &bxcore.BidTypeReq{
			Name:    "渠道投标",
			Content: []string{"已报名", "签合同", "已结束"},
		})
		remindRule = append(remindRule, &bxcore.RemindRuleReq{
			BidState:  "直接投标",
			Remainder: 72,
			Node:      "编制投标文件",
		})
		if setInfo != nil {
			if (*setInfo)["i_isallow"] != nil {
				isAllow = strconv.Itoa(MC.IntAll((*setInfo)["i_isallow"]))
			}
			if (*setInfo)["bidType"] != nil {
				if sbb, err := json.Marshal((*setInfo)["o_bidtype"]); err == nil {
					if err := json.Unmarshal(sbb, &bidType); err != nil {
						logx.Info("bidType json un err:", err.Error())
						return nil, err
					}
				} else {
					logx.Info("bidType json err:", err.Error())
					return nil, err
				}
			}
			if (*setInfo)["o_remindrule"] != nil {
				if sbr, err := json.Marshal((*setInfo)["o_remindrule"]); err == nil {
					if err := json.Unmarshal(sbr, &remindRule); err != nil {
						logx.Info("remindRule json un err:", err.Error())
						return nil, err
					}
				} else {
					logx.Info("remindRule json err:", err.Error())
					return nil, err
				}
			}
		}
		return &bxcore.ParticipateSetUpInfo{
			IsAllow:    isAllow,
			BidType:    bidType,
			RemindRule: remindRule,
		}, nil
	}
	return nil, nil
}

//保存或更新tidb 项目信息
func UpdateProjectInfo(id string, pInfo map[string]interface{}, bInfo map[string]interface{}) error {
	//id 项目id
	//name 项目名称
	//area  省份
	//city 城市
	//buyer 采购单位
	//budget 预算
	//bid_open_time  开标时间
	//bid_time 招标时间  bidding表
	//bid_end_time 开标结束时间  bidding表
	//pici 批次 轮询更新数据
	//
	projectInfo := map[string]interface{}{
		"id":     id,
		"name":   MC.ObjToString(pInfo["projectname"]),
		"area":   MC.ObjToString(pInfo["area"]),
		"city":   MC.ObjToString(pInfo["city"]),
		"buyer":  MC.ObjToString(pInfo["buyer"]),
		"budget": MC.Int64All(pInfo["budget"]),
	}
	if pInfo["bidopentime"] != nil {
		openTime := pInfo["bidopentime"]
		projectInfo["bid_open_time"] = date.FormatDateWithObj(&openTime, date.Date_Full_Layout)
	}
	if pInfo["pici"] != nil {
		pici := pInfo["pici"]
		projectInfo["pici"] = date.FormatDateWithObj(&pici, date.Date_Full_Layout)
	}
	// 项目表：zbtime 招标时间是 biding表：publishtime发布时间
	if pInfo["zbtime"] != nil {
		bidTime := pInfo["zbtime"]
		projectInfo["bid_time"] = date.FormatDateWithObj(&bidTime, date.Date_Full_Layout)
	}
	if bInfo["bidendtime"] != nil {
		bidEndTime := bInfo["bidendtime"]
		projectInfo["bid_end_time"] = date.FormatDateWithObj(&bidEndTime, date.Date_Full_Layout)
	}
	if c := IC.BaseMysql.CountBySql(`SELECT COUNT(id) FROM project WHERE id = ?`, id); c > 0 {
		if ok := IC.BaseMysql.Update("project", map[string]interface{}{
			"id": id,
		}, projectInfo); !ok {
			return fmt.Errorf("项目信息更新异常", id)
		}
	} else {
		if i := IC.BaseMysql.Insert("project", projectInfo); i < 0 {
			return fmt.Errorf("项目信息插入异常", id)
		}
	}
	return nil
}

//参标列表其他条件
func ParticipateListSql(in *bxcore.ParticipateListReq) string {
	//b  project表
	//a  participate_user表
	now := time.Now()
	nowDate := date.FormatDate(&now, date.Date_Full_Layout)
	//查询tidb  base_service.project
	sql := ` `
	//地区
	if in.Area != "" {
		sql += fmt.Sprintf(" AND pt.area IN ('%s') ", strings.ReplaceAll(in.Area, ",", "','"))
	}
	//城市
	if in.City != "" {
		sql += fmt.Sprintf(" AND pt.city IN ('%s') ", strings.ReplaceAll(in.City, ",", "','"))
	}
	//关键词
	if in.Keywords != "" {
		kSql := ` AND (`
		for kk, kv := range strings.Split(in.Keywords, " ") {
			if kk > 0 {
				kSql += " OR "
			}
			kSql += " pt.name like '%" + kv + "%'"
		}
		kSql += `)`
		sql += kSql
	}
	//招标日期
	if in.BidTime != "" && strings.Contains(in.BidTime, "-") {
		startTime := strings.Split(in.BidTime, "-")[0]
		entTime := strings.Split(in.BidTime, "-")[1]
		if startTime != "" {
			sql += ` AND pt.bid_time > ` + startTime
		}
		if entTime != "" {
			sql += ` AND pt.bid_time < ` + entTime
		}
	}
	//招标截止日期
	if in.BidEndTime != "" {
		startTime := strings.Split(in.BidEndTime, "-")[0]
		entTime := strings.Split(in.BidEndTime, "-")[1]
		if startTime != "" {
			sql += ` AND pt.bid_end_time > ` + startTime
		}
		if entTime != "" {
			sql += ` AND pt.bid_end_time < ` + entTime
		}
	}
	//开标时间
	if in.BidOpenTime != "" {
		startTime := strings.Split(in.BidOpenTime, "-")[0]
		entTime := strings.Split(in.BidOpenTime, "-")[1]
		if startTime != "" {
			sql += ` AND pt.bid_open_time > ` + startTime
		}
		if entTime != "" {
			sql += ` AND pt.bid_open_time < ` + entTime
		}
	}
	//投标截止状态1:未截止；2:已截止；3:终止参标
	if in.BidEndStatus > 0 {
		switch in.BidEndStatus {
		case 1:
			sql += ` AND pt.bid_end_time > ` + nowDate
		case 2:
			sql += ` AND pt.bid_end_time < ` + nowDate
		case 3:
			sql += ` AND pug.state < 0 `
		}
	}
	//开标状态1：未开标；2：已开标
	if in.BidOpenStatus > 0 {
		switch in.BidOpenStatus {
		case 1:
			sql += ` AND pt.bid_open_time > ` + nowDate
		case 2:
			sql += ` AND pt.bid_open_time < ` + nowDate
		}
	}
	//参标人  管理员权限
	if in.EntUserIds != "" && in.PositionType > 0 {
		sql += ` AND pug.ent_user_id in ('` + strings.ReplaceAll(in.EntUserIds, ",", "','") + `')`
	}
	//默认按照投标截止日期正序排列、1：开标时间正序、2：更新状态时间倒序
	switch in.OrderNum {
	case 1:
		sql += ` ORDER BY pug.update_date DESC`
	case 2:
		sql += ` ORDER BY pt.bid_time ASC`
	default:
		sql += ` ORDER BY pt.bid_end_time ASC`
	}
	logx.Info(sql)
	return sql
}

//个人或员工查询参标列表
func SingleParticipateList(in *bxcore.ParticipateListReq, otherSql string) (data *bxcore.ParticipateData, err error) {
	defer MC.Catch()
	data = &bxcore.ParticipateData{
		Count: 0,
		List:  []*bxcore.ParticipateList{},
	}
	//员工|个人列表
	singlePersonSql := `SELECT %s FROM participate_user pug LEFT JOIN project pt ON pug.project_id = pt.id WHERE pug.position_id = ? `
	singlePersonSql += otherSql
	countSql := fmt.Sprintf(singlePersonSql, " COUNT(pt.id) ")
	count := IC.BaseMysql.CountBySql(countSql, in.PositionId)
	if count > 0 {
		data.Count = count
		listSql := fmt.Sprintf(singlePersonSql, "  pug.update_date,pt.* ")
		//分页
		listSql += fmt.Sprintf(` LIMIT %d,%d`, in.PageNum, in.PageSize)
		list := IC.BaseMysql.SelectBySql(listSql, in.PositionId)
		if list != nil && len(*list) > 0 {
			for _, v := range *list {
				data.List = append(data.List, &bxcore.ParticipateList{
					Id:               encrypt.EncodeArticleId2ByCheck(MC.ObjToString(v["id"])),
					ProjectName:      MC.ObjToString(v["name"]),
					Buyer:            MC.ObjToString(v["buyer"]),
					Budget:           MC.ObjToString(v["budget"]),
					BidTime:          MC.ObjToString(v["bid_time"]),
					BidEndTime:       MC.ObjToString(v["bid_end_time"]),
					BidOpenTime:      MC.ObjToString(v["bid_open_time"]),
					UpdateStatusTime: MC.ObjToString(v["update_date"]),
					UpdateStatusCon:  GetParticipateContent(in.PositionId, MC.ObjToString(v["id"])), //查询最后一次 投标状态更新,
				})
			}
			return data, nil
		}
		return nil, fmt.Errorf("数据异常")
	}
	return data, nil
}

//管理员获取参标列表数据
func AdminParticipateList(in *bxcore.ParticipateListReq, otherSql string) (data *bxcore.ParticipateData, err error) {
	defer MC.Catch()
	data = &bxcore.ParticipateData{
		Count: 0,
		List:  []*bxcore.ParticipateList{},
	}
	adminSql := `SELECT %s FROM (SELECT pu.ent_id, pu.project_id, GROUP_CONCAT(pu.ent_user_id SEPARATOR ',') ent_user_id, MAX(pu.update_date) update_date FROM participate_user pu WHERE pu.ent_id = ? AND NOT EXISTS ( SELECT 1 FROM participate_user WHERE project_id = pu.project_id AND state > pu. state ) GROUP BY pu.project_id ) pug LEFT JOIN project pt ON pug.project_id = pt.id`
	adminSql += otherSql
	adminCountSql := fmt.Sprintf(adminSql, "COUNT(pt.id)")
	count := IC.BaseMysql.CountBySql(adminCountSql, in.EntId)
	if count > 0 {
		data.Count = count
		adminListSql := fmt.Sprintf(adminSql, "pt.*, pug.ent_user_id,pug.update_date")
		list := IC.BaseMysql.SelectBySql(adminListSql, in.EntId)
		if list != nil && len(*list) > 0 {
			for _, v := range *list {
				data.List = append(data.List, &bxcore.ParticipateList{
					Id:               encrypt.EncodeArticleId2ByCheck(MC.ObjToString(v["id"])),
					ProjectName:      MC.ObjToString(v["name"]),
					Buyer:            MC.ObjToString(v["buyer"]),
					Budget:           MC.ObjToString(v["budget"]),
					BidTime:          MC.ObjToString(v["bid_time"]),
					BidEndTime:       MC.ObjToString(v["bid_end_time"]),
					BidOpenTime:      MC.ObjToString(v["bid_open_time"]),
					UpdateStatusTime: MC.ObjToString(v["update_date"]),
					UpdateStatusCon:  GetParticipateContent(in.EntId, MC.ObjToString(v["id"])), //查询最后一次 投标状态更新
					Participants:     GetParticipateUserName(MC.ObjToString(v["ent_user_id"])), //参标人信息
				})
			}
			return data, nil
		}
		return nil, fmt.Errorf("数据异常")
	}
	return data, nil
}

//获取最新参标 更新内容
func GetParticipateContent(userId int64, projectId string) string {
	recordsSql := `SELECT record_content FROM participate_bid_records WHERE (ent_id = ? OR position_id = ?) AND project_id = ? ORDER BY create_date DESC LIMIT 1;`
	records := IC.BaseMysql.SelectBySql(recordsSql, userId, userId, projectId)
	if records != nil && len(*records) > 0 {
		rec := (*records)[0]
		return MC.ObjToString(rec["record_content"])
	}
	return ""
}

//根据ent_user_id 获取参标人昵称，企业管理员现在都是“我”
func GetParticipateUserName(entUserId string) string {
	if entUserId != "" {
		var userNames []string
		for _, v := range strings.Split(entUserId, ",") {
			entUserInfos := IC.MainMysql.SelectBySql(`SELECT * FROM entniche_user WHERE id = ?`, v)
			if entUserInfos != nil && len(*entUserInfos) > 0 {
				entUserInfo := (*entUserInfos)[0]
				if entUserInfo["name"] != nil {
					if userName := MC.ObjToString(entUserInfo["name"]); userName != "" {
						userNames = append(userNames, userName)
					}
				}
			}
		}
		return strings.Join(userNames, ",")
	}
	return ""
}