no message

services/order.go

@@ -76,14 +76,14 @@ func GetQueryOrderByOutTradeNoTask(cont context.Context) (err error) {
 	for _, v := range orderList {
 		tradeState, statusCode, itemResp := GetQueryOrderByOutTradeNo(v.OutTradeNo)
 		if tradeState == "SUCCESS" && statusCode == 200 {
-			go HandleOrderHandle(itemResp)
+			go HandleOrderByWechatPay(itemResp)
 		}
 	}
 	return
 }
 
 // 手动处理支付订单回调
-func HandleOrderHandle(itemCallback *Transaction) {
+func HandleOrderByWechatPay(itemCallback *Transaction) {
 	var err error
 	defer func() {
 		if err != nil {
@@ -206,12 +206,12 @@ func AddCygxOrderPayment(itemCallback *Transaction) {
 }
 
 // 定时任务处理退款回调
-func HandleOrderRefundHandleask(cont context.Context) (err error) {
-	//func HandleOrderRefundHandleask() (err error) {
+func HandleOrderRefundTask(cont context.Context) (err error) {
+	//func HandleOrderRefundTask() (err error) {
 	defer func() {
 		if err != nil {
 			fmt.Println(err)
-			go utils.SendAlarmMsg(fmt.Sprint("自动取消十分钟之内没有付款的的订单 CancelCygxOrder ，err：", err.Error()), 2)
+			go utils.SendAlarmMsg(fmt.Sprint("定时任务处理退款回调 HandleOrderRefundTask ，err：", err.Error()), 2)
 		}
 	}()
 	var condition string
@@ -232,19 +232,19 @@ func HandleOrderRefundHandleask(cont context.Context) (err error) {
 	for _, v := range orderList {
 		tradeState, statusCode, itemResp := GetQueryOrderByOutTradeNo(v.OutTradeNo)
 		if tradeState == "REFUND" && statusCode == 200 {
-			go HandleOrderRefundHandle(itemResp)
+			go HandleOrderRefundByWechatPay(itemResp)
 		}
 	}
 	return
 }
 
 // 处理退款订单回调
-func HandleOrderRefundHandle(itemCallback *Transaction) {
+func HandleOrderRefundByWechatPay(itemCallback *Transaction) {
 	var err error
 	defer func() {
 		if err != nil {
 			fmt.Println(err)
-			go utils.SendAlarmMsg(fmt.Sprint("处理退款订单回调信息失败 HandleOrderRefundHandle, err：", err.Error()), 2)
+			go utils.SendAlarmMsg(fmt.Sprint("处理退款订单回调信息失败 HandleOrderRefundByWechatPay, err：", err.Error()), 2)
 		}
 	}()
 	outTradeNo := itemCallback.OutTradeNo

services/task.go

@@ -143,14 +143,14 @@ func Task() {
 		sendMfyxActivityBeginMsg := task.NewTask("sendMfyxActivityBeginMsg", "0 */5 6-23 * * *", SendMfyxActivityBeginMsg) //会议前60分钟的提醒
 		task.AddTask("sendMfyxActivityBeginMsg", sendMfyxActivityBeginMsg)
 
-		//cancelCygxOrder := task.NewTask("CancelCygxOrder", "0 */1 * * * *", CancelCygxOrder)
-		//task.AddTask("十分钟内未付款的订单自动取消", cancelCygxOrder) //十分钟内未付款的订单自动取消
-		//
-		//getQueryOrderByOutTradeNoTask := task.NewTask("getQueryOrderByOutTradeNoTask", "0 */1 * * * *", GetQueryOrderByOutTradeNoTask)
-		//task.AddTask("定时任务主动获取订单支付状态", getQueryOrderByOutTradeNoTask) //定时任务主动获取订单支付状态
-		//
-		//handleOrderRefundHandleask := task.NewTask("HandleOrderRefundHandleask", "0 */1 * * * *", HandleOrderRefundHandleask)
-		//task.AddTask("定时任务处理退款回调", handleOrderRefundHandleask) //定时任务处理退款回调
+		cancelCygxOrder := task.NewTask("CancelCygxOrder", "0 */1 * * * *", CancelCygxOrder)
+		task.AddTask("十分钟内未付款的订单自动取消", cancelCygxOrder) //十分钟内未付款的订单自动取消
+
+		getQueryOrderByOutTradeNoTask := task.NewTask("getQueryOrderByOutTradeNoTask", "0 */1 * * * *", GetQueryOrderByOutTradeNoTask)
+		task.AddTask("定时任务主动获取订单支付状态", getQueryOrderByOutTradeNoTask) //定时任务主动获取订单支付状态
+
+		handleOrderRefundTask := task.NewTask("handleOrderRefundTask", "0 */1 * * * *", HandleOrderRefundTask)
+		task.AddTask("定时任务处理退款回调", handleOrderRefundTask) //定时任务处理退款回调
 	}
 
 	//if utils.RunMode != "release" {