jyMicroservices/jyBXCore/rpc/service/participate.go

package service

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

//我的参标项目|企业参标项目 列表
func ParticipateList(in *bxcore.ParticipateListReq) (*bxcore.ParticipateListRes, error) {
	defer MC.Catch()
	res := &bxcore.ParticipateListRes{Data: &bxcore.ParticipateData{}}
	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 {
			in.EntUserIds = ""
		}
	}
	if in.PageNum < 1 {
		in.PageNum = 1
	}
	if in.PageSize < 1 {
		in.PageSize = 10
	}
	switch in.Identity {
	case "mine": //员工|个人列表
		r, e := mysql.SingleParticipateList(in, mysql.ParticipateListSql(in))
		if e != nil {
			res.ErrCode = -1
			res.ErrMsg = e.Error()
			return res, nil
		}
		res.Data = r
	case "ent": //企业管理员
		r, e := mysql.AdminParticipateList(in, mysql.ParticipateListSql(in))
		if e != nil {
			res.ErrCode = -1
			res.ErrMsg = e.Error()
			return res, nil
		}
		res.Data = r
	}
	return res, nil
}

/*
已过投标截止日期项目
(1)	不显示终止投标倒计时
(2)	显示参标人信息
(3)	无终止参标操作入口
(4)	不能划转
(5)	不能参标
*/

//参标动作：参标、终止参标、划转:in:参标；out:终止参标；transfer:划转
func ParticipateDo(in *bxcore.ParticipateActionReq) error {
	defer MC.Catch()
	//企业版 判断是否是管理员
	//判断用户身份
	userInfo := IC.Middleground.PowerCheckCenter.Check(in.AppId, in.UserId, in.NewUserId, in.AccountId, in.EntId, in.PositionType, in.PositionId)
	switch in.ActionType {
	case "in": //参标针对单个招标信息 或者 项目
		if in.BidIds == "" && in.ProjectIds == "" {
			return fmt.Errorf("缺少参数")
		}
		if err := GetProjectInfoByES(in); err != nil {
			return err
		}
		//是否允许多人参标
		if isAllow := util.IsALLow(in.EntId); !isAllow {
			if ok := mysql.IsParticipatedByBidId(in); ok {
				return fmt.Errorf("当前项目不允许多人参标")
			}
		}
		//保存参标信息  更新当前企业参标项目记录
		if err := mysql.SaveParticipateInfo(in); err != nil {
			return err
		}
	case "out": //终止参标
		if in.BidIds == "" && in.ProjectIds == "" {
			return fmt.Errorf("缺少参数")
		}
		if err := GetProjectInfoByES(in); err != nil {
			return err
		}
		if err := mysql.CancelParticipateInfo(in, userInfo.Ent.EntRoleId); err != nil {
			return err
		}
	case "transfer":
		//PC端 多个项目-》一个人
		//移动端  一个项目-》多个人
		if in.ProjectIds == "" {
			return fmt.Errorf("项目信息有误")
		}
		//个人版
		if in.PositionType == 0 {
			return fmt.Errorf("当前企业身份有误")
		}
		//非管理员
		if userInfo.Ent.EntRoleId == 0 { //1:企业管理员；2：部门管理员
			return fmt.Errorf("当前企业身份无权限")
		}
		//判断划转人
		if in.ToEntUserId == "" {
			return fmt.Errorf("划转对象不能为空")
		}
		//是否保留原跟踪人？
		isAllow := util.IsALLow(in.EntId)
		if (in.IsRetain || len(strings.Split(in.ToEntUserId, ",")) > 1) && !isAllow {
			//不允许多人参标，但是前端参数又是保留原参标人 互相矛盾
			return fmt.Errorf("当前项目只允许一人参标")
		}
		//in.ProjectIds //项目id
		projectIds := strings.Split(in.ProjectIds, ",")
		projectNum := 0
		for _, v := range projectIds {
			projectId := encrypt.DecodeArticleId2ByCheck(v)[0]
			if projectId == "" {
				continue
			}
			if err := mysql.TransferParticipateInfo(projectId, in); err != nil {
				logx.Info(fmt.Sprintf("是否允许多人参标：%v, 项目id：%s，企业id：%d，划转对象entuserid：%s,划转异常：", isAllow, projectId, in.EntId, in.ToEntUserId))
				continue
			}
			projectNum += 1
		}
		if projectNum != len(projectIds) {
			return fmt.Errorf("划转失败")
		}
	}
	return nil
}

//参标设置更新及设置内容
func GetParticipateSetInfo(in *bxcore.ParticipateSetUpInfoReq) (*bxcore.ParticipateSetUpInfoRes, error) {
	defer MC.Catch()
	res := &bxcore.ParticipateSetUpInfoRes{Data: &bxcore.ParticipateSetUpInfo{
		IsAllow:    "0",
		BidType:    nil,
		RemindRule: nil,
	}}
	switch in.SetAction {
	case "U": //update 更新设置信息
		res.Data = nil
		if err := mysql.UpdateParticipateSetInfo(in); err != nil {
			res.ErrCode = -1
			res.ErrMsg = err.Error()
		}
	default: //默认查询对应设置信息
		//查询对应用户设置信息
		//未设置过 返回默认配置
		if info, err := mysql.GetParticipateSetInfo(in); err == nil {
			res.Data = info
		} else {
			res.ErrCode = -1
			res.ErrMsg = err.Error()
		}
	}
	return res, nil
}

//参标企业人员信息
func GetParticipatePersonInfo(in *bxcore.ParticipatePersonsReq) *bxcore.ParticipatePersonsRes {
	var (
		participateMap = map[int64]bool{}
	)
	if in.ProjectId != "" {
		participateInfos := mysql.ParticipateProjectEnt(in.EntId, strings.Split(in.ProjectId, ","))
		if participateInfos != nil && len(*participateInfos) > 0 {
			participateInfo := (*participateInfos)[0]
			personIds := MC.ObjToString(participateInfo["personIds"])
			if personIds != "" {
				for _, p := range strings.Split(personIds, ",") {
					personId, _ := strconv.ParseInt(p, 10, 64)
					participateMap[personId] = true
				}
			}
		}
	}
	//查询企业人员信息
	personInfos := mysql.GetPersonInfo(in.EntId, in.EntUserId, participateMap)
	return &bxcore.ParticipatePersonsRes{
		Data: personInfos,
	}
}

//获取项目信息
func GetProjectInfoByES(in *bxcore.ParticipateActionReq) error {
	//参标和终止参标 单个项目；不进行批量操作
	in.ProjectIds = MC.If(in.ProjectIds != "", in.ProjectIds, in.BidIds).(string)
	var (
		tip = "参标"
	)
	switch in.ActionType {
	case "out":
		tip = "终止参标"
		//case "transfer":
		//	tip = "划转"
	}
	in.ProjectIds = strings.Split(in.ProjectIds, ",")[0]
	in.ProjectIds = encrypt.DecodeArticleId2ByCheck(in.ProjectIds)[0]
	if in.ProjectIds == "" {
		return fmt.Errorf("当前招标信息有误")
	}
	//当前项目是否符合参标条件
	//根据项目id查询project
	projectInfos := es.GetBidInfoByPId(in.ProjectIds)
	if projectInfos == nil || len(*projectInfos) == 0 {
		//当前项目是否符合参标条件
		//根据招标信息id 查询bidding
		projectInfos = es.GetProjectByInfoId(strings.Split(in.ProjectIds, ","))
		if projectInfos == nil || len(*projectInfos) == 0 {
			return fmt.Errorf(fmt.Sprintf("当前项目信息不满足%s条件", tip))
		}
		//符合参标项目id
		projectInfo := (*projectInfos)[0]
		if projectInfo["_id"] != nil && MC.ObjToString(projectInfo["_id"]) != "" {
			//项目信息id
			in.ProjectIds = MC.ObjToString(projectInfo["_id"])
		} else {
			return fmt.Errorf("当前项目信息有误")
		}
	}
	return nil
}