biService/service/material.go

package service

import (
	"app.yhyue.com/moapp/jybase/date"
	entity "bp.jydev.jianyu360.cn/BaseService/biService/entity"
	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/pb"
	"errors"
	"fmt"
	"github.com/gogf/gf/v2/util/gconv"
	"log"
	"strings"
	"time"
)

func MaterialSave(in *pb.MaterialSaveReq, title, content string) (msgId, mId int64, err error) {
	if len(strings.Split(in.ReceiveUserId, ",")) < 1 {
		return 0, 0, errors.New("物料发送人员为空")
	}
	//先插入message_log
	saveMsg := map[string]interface{}{
		"msg_type":    "14",
		"title":       title,
		"content":     content,
		"send_mode":   2,
		"send_time":   time.Now().Format(date.Date_Full_Layout),
		"send_status": 4,
		"update_time": time.Now().Format(date.Date_Full_Layout),
		"link":        "",
		"isdel":       1,
		"update_user": in.CreateUser,
		"Sign":        1,
		"group_id":    11,
		"createtime":  time.Now().Format(date.Date_Full_Layout),
	}
	msgId = entity.JyMysql.Insert("message_send_log", saveMsg)
	if msgId < 0 {
		return 0, 0, errors.New("插入消息表message_send_log出错")
	}
	saveMap := map[string]interface{}{
		"task_name":           in.TaskName,
		"task_description":    in.TaskDescription,
		"material_content":    in.MaterialContent,
		"qrcode_url":          in.QrcodeUrl,
		"receive_user_name":   in.ReceiveUserName,
		"receive_position_id": in.ReceiveUserId,
		"file_url":            in.FileUrl,
		"createtime":          time.Now().Format(date.Date_Full_Layout),
		"create_user":         in.CreateUser,
		"msg_id":              msgId,
		"img_webpage":         in.ImgWebpage,
	}
	mId = entity.BiService.Insert("operating_materials", saveMap)
	if mId < 0 {
		return 0, 0, errors.New("插入物料表operating_materials出错")
	}
	return msgId, mId, nil
}

func GetSendUserId(positionIds string, entId int64) []string {
	//拿职位id找mgoid
	userIdArr := []string{}
	query := fmt.Sprintf("SELECT userid FROM `dwd_f_userbase_id_mapping` WHERE position_id in (%s) AND ent_id = %d", positionIds, entId)
	log.Println("查找分发人的sql", query)
	useridMap := entity.JyBiTidb.SelectBySql(query)
	if useridMap != nil && len(*useridMap) > 0 {
		for _, val := range *useridMap {
			userIdArr = append(userIdArr, gconv.String(val["userid"]))
		}
	}
	return userIdArr
}