no message

models/tables/admin/admin.go

@@ -241,3 +241,10 @@ func GetSysUserByAdminName(adminName string) (item *Admin, err error) {
 	err = o.Raw(sql, adminName).QueryRow(&item)
 	return
 }
+
+func GetSysAdminByRealName(adminName string) (item *Admin, err error) {
+	sql := `SELECT * FROM admin WHERE real_name=? `
+	o := orm.NewOrm()
+	err = o.Raw(sql, adminName).QueryRow(&item)
+	return
+}

models/tables/company_product/company_product.go

@@ -38,6 +38,8 @@ type CompanyProduct struct {
 	IsFormal         int       `description:"是否已经转正式，0是没有转正式，1是已经转过正式"`
 	ShareSeller      string    `description:"共享销售员"`
 	ShareSellerId    int       `description:"共享销售员id"`
+	IsShare          int       `description:"0:非共享用户,1:共享客户"`
+	ShareGroupId     int       `description:"共享销售员所属分组ID"`
 }
 
 func GetCompanyProductByCompanyIdAndProductId(companyId, productId int) (item *CompanyProduct, err error) {

services/company_approval_message.go

@@ -8,6 +8,7 @@ import (
 	"hongze/hongze_mobile_admin/models/tables/company_approval_message"
 	"hongze/hongze_mobile_admin/models/tables/company_contract"
 	"hongze/hongze_mobile_admin/models/tables/company_product"
+	"hongze/hongze_mobile_admin/models/tables/company_report_permission"
 	"hongze/hongze_mobile_admin/models/tables/cygx_config"
 	"hongze/hongze_mobile_admin/services/alarm_msg"
 	"hongze/hongze_mobile_admin/utils"
@@ -231,7 +232,6 @@ func AddCompanyApprovalMessageWangYang(companyId, companyContractId int, applyRe
 		return
 	}
 
-
 	list, e := company_contract.GetCompanyContractPermissionByCompanyContractId(companyContractId)
 	if e != nil && e.Error() != utils.ErrNoRow() {
 		err = errors.New("GetCompanyContractPermissionByCompanyContractId, Err: " + e.Error())
@@ -271,3 +271,106 @@ func AddCompanyApprovalMessageWangYang(companyId, companyContractId int, applyRe
 
 	return
 }
+
+// AddCompanyApprovalMessageLiangChunYue 权益客户转正审批通过后（除了海外调研），自动共享给服务组账号梁春悦6（已共享的不用），并增加共享记录。同时发送模板消息提醒梁春悦。
+func AddCompanyApprovalMessageLiangChunYue(companyId, companyContractId int, companyName string) (err error) {
+	defer func() {
+		if err != nil {
+			go alarm_msg.SendAlarmMsg("权益客户转正审批通过后，自动共享给服务组账号梁春悦6失败，Err："+err.Error()+fmt.Sprint("companyId:", companyId, "companyContractId:", companyContractId, "companyName:", companyName), 3)
+		}
+	}()
+
+	//权益客户信息
+	companyProductItem, e := company_product.GetCompanyProductByCompanyIdAndProductId(companyId, utils.COMPANY_PRODUCT_RAI_ID)
+	if e != nil {
+		err = errors.New("GetCompanyProductByCompanyIdAndProductId, Err: " + e.Error())
+		return
+	}
+	if companyProductItem.IsShare == 1 {
+		return
+	}
+
+	list, e := company_report_permission.GetCompanyContractPermissionByCompanyContractId(companyContractId)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetCompanyContractPermissionByCompanyContractId, Err: " + e.Error())
+		return
+	}
+
+	if len(list) == 0 {
+		return
+	}
+	var haveSend bool
+
+	for _, v := range list {
+		if v.ChartPermissionId != 54 { //海外调研权限ID
+			haveSend = true
+		}
+	}
+	if !haveSend {
+		return
+	}
+
+	//新增操作记录
+	{
+		var remark string
+		var operation string
+		remark = "设置共享"
+		operation = "set_share"
+		AddCompanyOperationRecord(companyId, companyProductItem.SellerId, 0, 2, 0, companyProductItem.CompanyName,
+			companyProductItem.ProductName, "超级管理员", remark, operation, "", "超级管理员", "", companyProductItem.Status)
+	}
+
+	//新增操作记录
+	{
+		time.Sleep(500 * time.Millisecond)
+		seller, e := admin.GetSysAdminByRealName("梁春悦6")
+		if e != nil {
+			err = errors.New("GetSysAdminByRealName, Err: " + e.Error())
+			return
+		}
+		var remark string
+		var operation string
+		remark = "分配给" + seller.RealName
+		operation = "set_share_seller"
+		AddCompanyOperationRecord(companyId, seller.AdminId, 0, 2, 0, companyProductItem.CompanyName,
+			companyProductItem.ProductName, "超级管理员", remark, operation, "", "超级管理员", "", companyProductItem.Status)
+
+		//待更新字段
+		updateCol := make([]string, 0)
+		companyProductItem.ShareSeller = seller.RealName
+		companyProductItem.ShareSellerId = seller.AdminId
+		companyProductItem.ShareGroupId = seller.GroupId
+		updateCol = append(updateCol, "ShareSeller", "ShareSellerId", "ShareGroupId")
+
+		e = companyProductItem.Update(updateCol)
+		if e != nil {
+			err = errors.New("companyProductItem,Update Err: " + e.Error())
+			return
+		}
+	}
+
+	var mobiles []string
+	cnf, e := cygx_config.GetConfigByCode(utils.TPL_MSG_CYLIANG_APPROVAL)
+	if e != nil {
+		err = errors.New("GetConfigByCode, Err: " + e.Error())
+		return
+	}
+	mobiles = strings.Split(cnf.ConfigValue, ",")
+	openIdList, e := models.GetUserRecordListByMobileArr(mobiles)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetUserRecordListByMobileArr, Err: " + e.Error())
+		return
+	}
+	if len(openIdList) == 0 {
+		return
+	}
+
+	var keyword1, keyword2 string
+
+	keyword1 = companyName + "已共享"
+	keyword2 = "请及时分配服务销售"
+	fmt.Println(keyword1)
+	go SendWxMsgWithApprovalLiangChunYue(keyword1, keyword2, openIdList)
+
+	return
+}

services/wechat_send_msg.go

@@ -679,3 +679,29 @@ func SendWxMsgWithRoadshowSellerActivity(keyword1, keyword2, keyword3, keyword4
 	err = SendTemplateMsg(sendInfo)
 	return
 }
+
+// SendWxMsgWithApprovalLiangChunYue  权益非共享客户审批通过给梁春悦发模版消息
+func SendWxMsgWithApprovalLiangChunYue(keyword1, keyword2 string, openIdList []*models.OpenIdList) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("err：", err)
+			go alarm_msg.SendAlarmMsg("权益非共享客户审批通过给梁春悦发模版消息失败，SendWxMsgWithApprovalLiangChunYue："+err.Error(), 3)
+		}
+	}()
+
+	openIdArr := make([]string, len(openIdList))
+	for i, v := range openIdList {
+		openIdArr[i] = v.OpenId
+	}
+	sendInfo := new(SendWxTemplate)
+	sendInfo.Keyword1 = keyword1
+	sendInfo.Keyword2 = keyword2
+	sendInfo.Remark = ""
+	sendInfo.TemplateId = utils.WxMsgTemplateIdActivityChangeApply
+	sendInfo.RedirectUrl = ""
+	sendInfo.RedirectTarget = 3
+	sendInfo.SendType = utils.TEMPLATE_MSG_APPLY
+	sendInfo.OpenIdArr = openIdArr
+	err = SendTemplateMsg(sendInfo)
+	return
+}

utils/constants.go

@@ -177,6 +177,7 @@ const (
 	CHART_PERMISSION_ID_45W                 = 2002                       // 权益45w大套餐表示的权限ID(自定义)
 	TPL_MSG_WANG_YANG                       = "tpl_msg_wang_yang"        //汪洋手机号地址参数
 	TPL_MSG_YANXAUN_APPROVAL                = "tpl_msg_yanxaun_approval" // 【研选订阅】和【研选扣点包】转正/续约审批通过后，给冯柯然和汪洋和沈涛发送模板消息
+	TPL_MSG_CYLIANG_APPROVAL                = "tpl_msg_cyliang_approval" // 非共享客户转正之后，给梁春悦给发送模板消息
 )
 
 const (