添加销售部门

internal/logic/crm_user.go

@@ -19,7 +19,7 @@ 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 INSERTINVOICECOMUSER = "INSERT INTO `lie_invoice_com_user` (`com_id`, `user_id`, `sale_id`, `sale_type`, `create_time`)VALUES( ?, ?, ?,  ?, ?)"
+const INSERTINVOICECOMUSER = "INSERT INTO `lie_invoice_com_user` (`com_id`, `user_id`, `sale_id`, `department_id`, `sale_type`, `create_time`)VALUES( ?, ?, ?, ?, ?, ?)"
 
 const INSERTFOLLOWTASK = "INSERT INTO `lie_task_info` (user_id, task_id, task_type, task_display_degree, sale_id, end_time, create_time, update_time) VALUES (?,?,?,?,?,?,?,?)"
 
@@ -63,7 +63,12 @@ func InsertMemberUser(memberInfo model.MemberAddUserData)bool  {
 		return false
 	}
 
+	var department_id = 0
 	if memberInfo.Sale_Id != 0 {
+		err := dao.GetCmsDb().QueryRowx("select department_id from user_info where userId = ?",memberInfo.Sale_Id).Scan(&department_id)
+		if err != nil {
+			service.WriteErr(err)
+		}
 
 		//插入跟进销售
 		insertResult, err = dbTran.Exec(INSERTSALES,lastInsertId,memberInfo.Sale_Id,memberInfo.Create_Time,memberInfo.Create_Time)
@@ -83,7 +88,7 @@ func InsertMemberUser(memberInfo model.MemberAddUserData)bool  {
 	}
 
 	//插入用户关联关系 20200406新增
-	insertResult, err = dbTran.Exec(INSERTINVOICECOMUSER,0,memberInfo.User_Id,memberInfo.Sale_Id,memberInfo.Channel_type,memberInfo.Create_Time)
+	insertResult, err = dbTran.Exec(INSERTINVOICECOMUSER,0,memberInfo.User_Id,memberInfo.Sale_Id,department_id,memberInfo.Channel_type,memberInfo.Create_Time)
 	if err != nil {
 		service.WriteErrDetail("插入用户数据错误：插入用户关联关系"+err.Error())
 		err = dbTran.Rollback()