完成上线

cmd/queue/update_user_sale/main.go

@@ -94,10 +94,20 @@ func handle(userId,saleId int)(result bool)  {
 			return false
 			return false
 		}
 		}
 	}
 	}
+
+	var salesUserId int
+	_ = dao.GetDb().QueryRowx("select user_id from lie_salesman where user_id = ?",crmUserId).Scan(&salesUserId)
 	var timeNow = time.Now().Unix()
 	var timeNow = time.Now().Unix()
-	_,err := dao.GetDb().Exec("update lie_salesman set assign_time = ?,update_time = ?,sale_id= ? where user_id = ?",timeNow,timeNow,saleId,crmUserId)
-	fmt.Println(err)
-	_,err = dao.GetDb().Exec("insert into lie_action_log(`user_id`,`operator_id`,`create_time`,`remark`,`admin`,`event`)value(?,?,?,'转为已下单用户','admin','用户下单')",crmUserId,saleId,timeNow)
+
+	fmt.Println(salesUserId)
+	if salesUserId == 0 {
+		_,err := dao.GetDb().Exec("INSERT INTO `lie_salesman` ( `user_id`, `sale_id`, `assign_time`, `update_time`)VALUES(?,?,?,?)",crmUserId,saleId,timeNow,timeNow)
+		fmt.Println(err)
+	}else{
+		_,err := dao.GetDb().Exec("update lie_salesman set assign_time = ?,update_time = ?,sale_id= ? where user_id = ?",timeNow,timeNow,saleId,crmUserId)
+		fmt.Println(err)
+	}
+	_,err := dao.GetDb().Exec("insert into lie_action_log(`user_id`,`operator_id`,`create_time`,`remark`,`admin`,`event`)value(?,?,?,'转为已下单用户','admin','用户下单')",crmUserId,saleId,timeNow)
 	fmt.Println(err)
 	fmt.Println(err)
 	return true
 	return true
 }
 }

internal/logic/crm_user.go

@@ -55,12 +55,23 @@ func InsertMemberUser(memberInfo model.MemberAddUserData)bool  {
 		return false
 		return false
 	}
 	}
 
 
-	//插入跟进销售
-	insertResult, err = dbTran.Exec(INSERTSALES,lastInsertId,memberInfo.Sale_Id,memberInfo.Create_Time)
-	if err != nil {
-		service.WriteErrDetail("插入用户数据错误：插入跟进销售"+err.Error())
-		err = dbTran.Rollback()
-		return false
+	if memberInfo.Sale_Id != 0 {
+
+		//插入跟进销售
+		insertResult, err = dbTran.Exec(INSERTSALES,lastInsertId,memberInfo.Sale_Id,memberInfo.Create_Time)
+		if err != nil {
+			service.WriteErrDetail("插入用户数据错误：插入跟进销售"+err.Error())
+			err = dbTran.Rollback()
+			return false
+		}
+
+		//插入跟进记录
+		insertResult, err = dbTran.Exec("INSERT INTO `lie_assign_active` (`user_id`, `turn_in_id`,`is_success`,`change_time`,`create_time`)VALUES(？, ？, 1,？, ？);",lastInsertId,memberInfo.Sale_Id,memberInfo.Create_Time,memberInfo.Create_Time)
+		if err != nil {
+			service.WriteErrDetail("插入用户数据错误：插入跟进销售"+err.Error())
+			err = dbTran.Rollback()
+			return false
+		}
 	}
 	}
 
 
 
 

internal/service/err_service.go

 package service
 package service
 
 
-import "fmt"
+import (
+	"fmt"
+)
 
 
 //错误日志
 //错误日志
 
 
@@ -28,5 +30,6 @@ func WriteErrDetail(errString string)  {
 	}
 	}
 	//屏幕打印，加上发送钉钉消息
 	//屏幕打印，加上发送钉钉消息
 	fmt.Println(errString)
 	fmt.Println(errString)
-	//SendMessage(ADMINTEL,ProGramErrType+errString)
+	SendMessage(ADMINTEL,ProGramErrType+errString)
+	//dao.GetDb().Exec("insert into lie_action_log(`user_id`,`operator_id`,`create_time`,`remark`,`admin`,`event`)value(?,?,?,?,'0','cs错误日志')",0,0,time.Now().Unix(),errString)
 }
 }
\ No newline at end of file