Quellcode durchsuchen

Merge branch 'crm/need_1070' of http://8.136.199.33:3000/hongze/hz_crm_api into debug

zhangchuanxing vor 2 Tagen
Ursprung
Commit
9e2dbaee51

+ 1 - 0
services/company_apply/company_approval.go

@@ -419,6 +419,7 @@ func Approved(approvalRecord *contract.ContractApprovalRecord, opUser *system.Ad
 
 				//权益销售客户申请转正后,消息群发给所有销售
 				services.AddCompanyApprovalMessageRai(recordInfo.CompanyId, recordInfo.CompanyContractId, recordInfo.ApplyRealName, companyInfo.CompanyName, recordInfo.WxUserName)
+				services.AddCompanyApprovalMessageLiangChunYue(recordInfo.CompanyId, recordInfo.CompanyContractId, companyInfo.CompanyName) // 权益非共享客户审批通过给梁春悦发模版消息
 
 				//客户研选行业转正时(王芳审批通过),模板消息提醒汪洋
 				services.AddCompanyApprovalMessageWangYang(recordInfo.CompanyId, recordInfo.CompanyContractId, recordInfo.ApplyRealName, companyInfo.CompanyName)

+ 102 - 0
services/company_approval_message.go

@@ -308,3 +308,105 @@ 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.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.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)
+	}
+
+	//新增操作记录
+	{
+		seller, e := system.GetSysAdminByName("梁春悦6")
+		if e != nil {
+			err = errors.New("GetSysAdminByName, 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.GetCygxConfigDetailByCode(utils.TPL_MSG_CYLIANG_APPROVAL)
+	if e != nil {
+		err = errors.New("GetCygxConfigDetailByCode, Err: " + e.Error())
+		return
+	}
+	mobiles = strings.Split(cnf.ConfigValue, ",")
+	openIdList, e := cygx.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
+}

+ 26 - 0
services/wechat_send_msg.go

@@ -1950,3 +1950,29 @@ func SendWxMsgWithRoadshowSellerActivity(keyword1, keyword2, keyword3, keyword4
 	err = SendTemplateMsg(sendInfo)
 	return
 }
+
+// SendWxMsgWithApprovalLiangChunYue  权益非共享客户审批通过给梁春悦发模版消息
+func SendWxMsgWithApprovalLiangChunYue(keyword1, keyword2 string, openIdList []*cygx.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.WxMsgTemplateIdActivityChangeApplyXzs
+	sendInfo.RedirectUrl = ""
+	sendInfo.RedirectTarget = 3
+	sendInfo.SendType = utils.TEMPLATE_MSG_APPLY
+	sendInfo.OpenIdArr = openIdArr
+	err = SendTemplateMsg(sendInfo)
+	return
+}

+ 1 - 0
utils/constants.go

@@ -412,6 +412,7 @@ const (
 	CYGX_USER_KEY_LABEL                            = "CYGX_USER_KEY_LABEL"              //查研观向用户标签
 	TPL_MSG_WANG_YANG                              = "tpl_msg_wang_yang"                //汪洋手机号地址参数
 	TPL_MSG_YANXAUN_APPROVAL                       = "tpl_msg_yanxaun_approval"         //【研选订阅】和【研选扣点包】转正/续约审批通过后,给冯柯然和汪洋和沈涛发送模板消息
+	TPL_MSG_CYLIANG_APPROVAL                       = "tpl_msg_cyliang_approval"         // 非共享客户转正之后,给梁春悦给发送模板消息
 	MicroRoadshowDefaultImgKey                     = "micro_roadshow_default_img"       // 音视频封面图
 	TPL_MSG_NEI_RONG_ZU                            = "tpl_msg_nei_rong_zu"              //内容组四人
 	TPL_MSG_WANG_FANG_WANG_YANG                    = "tpl_msg_wang_fang_wang_yang"      //权限模板消息接收人,王芳,汪洋