下单、新增用户分配客服添加操作日志

cmd/follow/handle/set_free.go

@@ -81,8 +81,8 @@ func CompareTime(user_id, limit_follow_time int) {
 			 return
 		 }
 
-		 // 限制跟进时间标为0
-		 dao.GetDb().Exec("update lie_salesman set limit_follow_time = ?, update_time = ? where user_id = ?", 0, curr_time, user_id)
+		 // 删除跟进记录
+		 dao.GetDb().Exec("delete from lie_salesman where user_id = ?", user_id)
 
 		 // 添加释放日志
 		 dao.GetDb().Exec("insert into lie_action_log (user_id, type, event, remark, create_time) values (?, ?, ?, ?, ?)", user_id, 2, "释放用户", "", curr_time)

cmd/queue/update_user_sale/main.go

@@ -107,7 +107,7 @@ func handle(userId,saleId int)(result bool)  {
 		_,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)
+	_,err := dao.GetDb().Exec("insert into lie_action_log (user_id, type, event, remark, create_time) values (?, ?, ?, ?, ?)", crmUserId, 2, "用户下单", "自动分配客服，客服ID："+ strconv.Itoa(saleId), timeNow)
 	fmt.Println(err)
 	return true
 }

internal/logic/crm_user.go

@@ -4,6 +4,8 @@ import (
 	"crm-server/internal/dao"
 	"crm-server/internal/model"
 	"crm-server/internal/service"
+	"strconv"
+	"time"
 )
 
 const INSERTCRMUSER  = "INSERT INTO `lie_user` (" +
@@ -83,6 +85,10 @@ func InsertMemberUser(memberInfo model.MemberAddUserData)bool  {
 		err = dbTran.Rollback()
 		return false
 	}
+
+	curr_time := time.Now().Unix()
+	dbTran.Exec("insert into lie_action_log (user_id, type, event, remark, create_time) values (?, ?, ?, ?, ?)", lastInsertId, 2, "新增用户", "自动分配客服，客服ID："+ strconv.Itoa(memberInfo.Sale_Id), curr_time)
+
 	dbTran.Commit()
 	return true
 }
\ No newline at end of file