rdluck 4 tahun lalu
induk
melakukan
6212719a57
3 mengubah file dengan 20 tambahan dan 17 penghapusan
  1. 12 8
      models/company_product.go
  2. 2 2
      services/company.go
  3. 6 7
      services/task.go

+ 12 - 8
models/company_product.go

@@ -35,13 +35,14 @@ func CompanyFreeze(companyId, productId int) (err error) {
 	o := orm.NewOrm()
 	freezeStartDate := time.Now().Format(utils.FormatDate)
 	freezeEndDate := time.Now().AddDate(0, 3, 0).Format(utils.FormatDate)
-	sql := `UPDATE company_product SET status='冻结',freeze_time=NOW(),modify_time=NOW(),freeze_start_date=?,freeze_end_date=? WHERE company_id=? AND product_id=? `
-	_, err = o.Raw(sql, freezeStartDate, freezeEndDate, companyId, productId).Exec()
+
+	sql := `UPDATE company_product SET status='冻结',freeze_time=NOW(),modify_time=NOW(),start_date=?,end_date=?,freeze_start_date=?,freeze_end_date=? WHERE company_id=? AND product_id=? `
+	_, err = o.Raw(sql,freezeStartDate,freezeEndDate, freezeStartDate, freezeEndDate, companyId, productId).Exec()
 	if err != nil {
 		return err
 	}
-	sql = `UPDATE company SET type=3,last_updated_time=NOW() WHERE company_id=? `
-	_, err = o.Raw(sql, companyId).Exec()
+	sql = `UPDATE company SET type=3,last_updated_time=NOW(),start_date=?,end_date=? WHERE company_id=? `
+	_, err = o.Raw(sql,freezeStartDate,freezeEndDate, companyId).Exec()
 	if err != nil {
 		return err
 	}
@@ -65,13 +66,16 @@ func CompanyLoss(companyId, productId int) (err error) {
 
 func CompanyTryOut(companyId, productId int) (err error) {
 	o := orm.NewOrm()
-	sql := `UPDATE company_product SET status='试用',modify_time=NOW() WHERE company_id=? AND product_id=? `
-	_, err = o.Raw(sql, companyId, productId).Exec()
+	startDate:=time.Now().Format(utils.FormatDate)
+	endDate:=time.Now().AddDate(0,2,0).Format(utils.FormatDate)
+
+	sql := `UPDATE company_product SET status='试用',start_date=?,end_date=?,modify_time=NOW() WHERE company_id=? AND product_id=? `
+	_, err = o.Raw(sql,startDate,endDate, companyId, productId).Exec()
 	if err != nil {
 		return err
 	}
-	sql = `UPDATE company SET type=2,last_updated_time=NOW() WHERE company_id=? `
-	_, err = o.Raw(sql, companyId).Exec()
+	sql = `UPDATE company SET type=2,last_updated_time=NOW(),start_date=?,end_date=? WHERE company_id=? `
+	_, err = o.Raw(sql,startDate,endDate, companyId).Exec()
 	if err != nil {
 		return err
 	}

+ 2 - 2
services/company.go

@@ -151,7 +151,7 @@ func ImportCompanyUsers() {
 			fmt.Println("err:", err.Error())
 		}
 	}()
-	fileName := "./company_user_102202.xlsx"
+	fileName := "./company_user_1127.xlsx"
 	xlFile, err := xlsx.OpenFile(fileName)
 	if err != nil {
 		fmt.Printf("open failed: %s\n", err)
@@ -177,7 +177,7 @@ func ImportCompanyUsers() {
 				email = strings.Replace(email, " ", "", -1)
 				fmt.Println(mobile)
 				var companyId int
-				companyId = 225
+				companyId = 5140
 				if companyId > 0 {
 					wxUser, err := models.GetWxUserByMobile(mobile)
 					if err != nil && err.Error() != utils.ErrNoRow() {

+ 6 - 7
services/task.go

@@ -52,13 +52,12 @@ func Task() {
 	//GetLzProductList()GetLzProductDetail
 	fmt.Println("task end")
 }
-
-func Task123() {
-	fmt.Println("start")
-	//0 42 4 1 * *                         毎月1日的 4:42 分 执行
-	DeleteReportSaveLog()
-	fmt.Println("end")
-}
+//
+//func Task() {
+//	fmt.Println("start")
+//	ImportCompanyUsers()
+//	fmt.Println("end")
+//}
 
 func SendEmail() (err error) {
 	//报告历史访问次数