Notes

package main

import (
"bufio"
"encoding/csv"
"os"
"fmt"
"io"
"strconv"
"strings"
"labix.org/v2/mgo/bson"
. "./service/worker"
"time"
)

var XuMapVoucher = map[int]int{}

var startDate int64 = 1515430800
var endDate int64 = 1515776399

type Voucher struct {
VoucherId int `json:"voucher_id" bson:"voucher_id"`
MinOrder int `json:"min_order" bson:"min_order"`
Code string `json:"code"`
Quantity int `json:"quantity"`
Remain int `json:"remain"`
Value int `json:"value"`
Xu int `json:"xu"`
ShopId int `json:"shop_id" bson:"shop_id"`
StartDate int64 `json:"start_date" bson:"start_date"`
EndDate int64 `json:"end_date" bson:"end_date"`
}

func main() {
var timeStart int64 = int64(time.Now().Unix())
var timeTotal int64 = 0
strStart := "cron started at " + time.Now().String() + "n"
fmt.Println(strStart)
// Load a TXT file.
f, err := os.Open("./public/files/voucher_sendo.csv")
if err != nil {
fmt.Println("Open files err: ", err)
return
}

// Create a new reader.
r := csv.NewReader(bufio.NewReader(f))

session, db, err1 := GetCollection("Mongo_Event")
if err1 != nil {
fmt.Println("can not connect to Mongo_Event, ", err1)
return
}
defer session.Close()

type voucher_config struct {
Key string
Value_voucher int
Total int
}

var voucherConfig []voucher_config

db.C("event_voucher_config").Find(bson.M{"key": "xu_voucher_sendo"}).All(&voucherConfig)

for _, voucher := range voucherConfig {
XuMapVoucher[voucher.Value_voucher] = voucher.Total
}

i := 0
for {
record, err2 := r.Read()
// Stop at EOF.
if err2 == io.EOF {
break
}

if (len(record) > 2 && len(record[0]) > 0) {
if i > 0 {
voucherId, _ := strconv.Atoi(record[0])
value, _ := strconv.Atoi(record[8])
quantity, _ := strconv.Atoi(record[9])
minOrder, _ := strconv.Atoi(record[7])
code := record[1]

voucher := Voucher{
VoucherId: voucherId,
Value: value,
Code: code,
Quantity: quantity,
Remain: quantity,
MinOrder: minOrder,
ShopId: 0,
Xu: XuMapVoucher[value],
StartDate: startDate,
EndDate: endDate,
}

fmt.Println("STT: ", i," voucherId: ", voucherId)
db.C("event_voucher_sendo_flat").Upsert(bson.M{"voucher_id": voucherId}, &voucher)
}
i ++
}
}

timeTotal = int64(time.Now().Unix()) - timeStart
fmt.Println("Total Time: ", timeTotal)
fmt.Println("cron done at " + time.Now().String() + "n")
}

func RemoveCHSA(text string) string {
s := strings.Replace(text, "CH", "PM", -1)
s = strings.Replace(s, "SA", "AM", -1)
return s
}