taskqueueworker: add support for mysql persistent

candihelper/const.go

@@ -54,6 +54,21 @@ const (
 	HeaderMIMEMultipartForm = "multipart/form-data"
 	// HeaderMIMEOctetStream const
 	HeaderMIMEOctetStream = "application/octet-stream"
+
+	// DateFormatMonday date format
+	DateFormatMonday = "Monday"
+	// DateFormatYYYYMM date format
+	DateFormatYYYYMM = "2006-01"
+	// DateFormatYYYYMMDD date format
+	DateFormatYYYYMMDD = "2006-01-02"
+	// DateFormatYYYYMMDDHHmmss date format
+	DateFormatYYYYMMDDHHmmss = "2006-01-02 15:04:05"
+	// DateFormatYYYYMMDDClean date format
+	DateFormatYYYYMMDDClean = "20060102"
+	// DateFormatHHmmss date format
+	DateFormatHHmm = "15:04"
+	// DateFormatDDMMYYYY date format
+	DateFormatDDMMYYYY = "02-01-2006"
 )
 
 var (

candihelper/helper.go

@@ -654,3 +654,11 @@ func StringToByte(s string) (b []byte) {
 	bh.Len = sh.Len
 	return b
 }
+
+// ParseTimeToString helper, return empty string if zero time
+func ParseTimeToString(date time.Time, format string) (res string) {
+	if !date.IsZero() {
+		res = date.Format(format)
+	}
+	return res
+}

cmd/candi/template_delivery_worker.go

@@ -198,9 +198,10 @@ func (h *TaskQueueHandler) handleTask{{upper (camel .ModuleName)}}(eventContext
 
 	// exec usecase
 	// h.uc.SomethingUsecase()
+	time.Sleep(1*time.Second) // just for example process
 
 	return &candishared.ErrorRetrier{
-		Delay:   2 * time.Second,
+		Delay:   1 * time.Second,
 		Message: "Error retry",
 	}
 }

codebase/app/task_queue_worker/helper.go

@@ -14,3 +14,10 @@ func convertIncrementMap(mp map[string]int) map[string]interface{} {
 	}
 	return res
 }
+
+func normalizeCount(count int) int {
+	if count < 0 {
+		return 0
+	}
+	return count
+}

codebase/app/task_queue_worker/persistent_model.go

@@ -106,16 +106,17 @@ func (f *Filter) ParseStartEndDate() (startDate, endDate time.Time) {
 
 // CountTotalJob method
 func (s *TaskSummary) CountTotalJob() int {
-	return s.Success + s.Queueing + s.Retrying + s.Failure + s.Stopped
+	return normalizeCount(s.Success) + normalizeCount(s.Queueing) + normalizeCount(s.Retrying) +
+		normalizeCount(s.Failure) + normalizeCount(s.Stopped)
 }
 
 // ToSummaryDetail method
 func (s *TaskSummary) ToSummaryDetail() (detail SummaryDetail) {
-	detail.Failure = s.Failure
-	detail.Retrying = s.Retrying
-	detail.Success = s.Success
-	detail.Queueing = s.Queueing
-	detail.Stopped = s.Stopped
+	detail.Failure = normalizeCount(s.Failure)
+	detail.Retrying = normalizeCount(s.Retrying)
+	detail.Success = normalizeCount(s.Success)
+	detail.Queueing = normalizeCount(s.Queueing)
+	detail.Stopped = normalizeCount(s.Stopped)
 	return
 }