提交代码

internal/logic/crm_user.go

@@ -20,6 +20,9 @@ const INSERTISCREATEORDER  = "INSERT INTO `lie_user_extend` (`user_id`, `no_crea
 const INSERTSALES  = "INSERT INTO `lie_salesman` (`user_id`, `sale_id`,`assign_time`, `update_time`)VALUES(?,?,?,?)"
 const INSERTSALES  = "INSERT INTO `lie_salesman` (`user_id`, `sale_id`,`assign_time`, `update_time`)VALUES(?,?,?,?)"
 
 
 
 
+const INSERTINVOICECOMUSER = "INSERT INTO `lie_invoice_com_user` (`com_id`, `user_id`, `sale_id`, `sale_type`, `create_time`)VALUES( ?, ?, ?,  ?, ?)"
+
+
 //检测会员用户是否存在
 //检测会员用户是否存在
 func CheckMemberIdIsHave(memberId int)(returnUserId int){
 func CheckMemberIdIsHave(memberId int)(returnUserId int){
 
 
@@ -78,6 +81,13 @@ func InsertMemberUser(memberInfo model.MemberAddUserData)bool  {
 		}
 		}
 	}
 	}
 
 
+	//插入用户关联关系 20200406新增
+	insertResult, err = dbTran.Exec(INSERTINVOICECOMUSER,memberInfo.Com_Id,memberInfo.User_Id,memberInfo.Sale_Id,memberInfo.Channel_type,memberInfo.Create_Time)
+	if err != nil {
+		service.WriteErrDetail("插入用户数据错误：插入用户关联关系"+err.Error())
+		err = dbTran.Rollback()
+		return false
+	}
 
 
 	//插入公司
 	//插入公司
 	insertResult, err = dbTran.Exec(INSERTCOMPANY,lastInsertId,memberInfo.Com_Name,memberInfo.Com_Full_addr,memberInfo.Com_Telphone,memberInfo.Com_Fax,"",memberInfo.Com_Desc, memberInfo.Create_Time)
 	insertResult, err = dbTran.Exec(INSERTCOMPANY,lastInsertId,memberInfo.Com_Name,memberInfo.Com_Full_addr,memberInfo.Com_Telphone,memberInfo.Com_Fax,"",memberInfo.Com_Desc, memberInfo.Create_Time)