fix bug

models/data_source_longzhong.go

@@ -211,7 +211,7 @@ type LongzhonginfoList struct {
 func GetLongzhonginfoList() (items []*LongzhonginfoList, err error) {
 	o := orm.NewOrm()
 	o.Using("edb")
-	sql := ` SELECT * FROM longzhonginfo `
+	sql := ` SELECT * FROM longzhonginfo WHERE trade_code='L000580' `
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }

models/users.go

@@ -42,10 +42,8 @@ func GetWxUserByMobile(mobile string) (item *WxUser, err error) {
 	return
 }
 
-func AddWxUser(companyId int64,mobile,realName string) (err error) {
-	sql:=`INSERT INTO wx_user(company_id,real_name,mobile,first_login,enabled,is_note,from_type,apply_method) VALUES (?,?,?,1,1,1,'report',0);`
-	orm.NewOrm().Raw(sql,companyId,realName,mobile).Exec()
+func AddWxUser(companyId int64,mobile,realName,email string) (err error) {
+	sql:=`INSERT INTO wx_user(company_id,real_name,mobile,first_login,enabled,is_note,from_type,apply_method,email) VALUES (?,?,?,1,1,1,'report',0,?);`
+	orm.NewOrm().Raw(sql,companyId,realName,mobile,email).Exec()
 	return
-}
-
-
+}

services/company.go

@@ -125,8 +125,9 @@ func ImportCompany() {
 					if wxUser == nil {
 						//用户不存在，新增
 						fmt.Println("AddWxUser")
+						email:=""
 						fmt.Println(company.CompanyId, mobile, realName)
-						err = models.AddWxUser(company.CompanyId, mobile, realName)
+						err = models.AddWxUser(company.CompanyId, mobile, realName,email)
 						if err != nil {
 							fmt.Println("AddWxUser Err:" + err.Error())
 							return
@@ -156,7 +157,7 @@ func ImportCompanyUsers() {
 			fmt.Println("err:", err.Error())
 		}
 	}()
-	fileName := "./company_user_0819.xlsx"
+	fileName := "./company_user_0914.xlsx"
 	xlFile, err := xlsx.OpenFile(fileName)
 	if err != nil {
 		fmt.Printf("open failed: %s\n", err)
@@ -172,16 +173,21 @@ func ImportCompanyUsers() {
 					return
 				}
 
-				realName := row.GetCell(1).String()
+				realName := row.GetCell(0).String()
 				realName = strings.Trim(realName, " ")
 				realName = strings.Replace(realName, " ", "", -1)
 
-				mobile := row.GetCell(2).String()
+				mobile := row.GetCell(1).String()
 				mobile = strings.Trim(mobile, " ")
 				mobile = strings.Replace(mobile, " ", "", -1)
+
+				email := row.GetCell(2).String()
+				email = strings.Trim(email, " ")
+				email = strings.Replace(email, " ", "", -1)
+
 				fmt.Println(mobile)
 				var companyId int64
-				companyId=794
+				companyId=98
 				if companyId > 0 {
 					wxUser, err := models.GetWxUserByMobile(mobile)
 					if err != nil && err.Error() != utils.ErrNoRow() {
@@ -191,7 +197,7 @@ func ImportCompanyUsers() {
 					if wxUser == nil {
 						//用户不存在，新增
 						fmt.Println("AddWxUser")
-						err = models.AddWxUser(companyId, mobile, realName)
+						err = models.AddWxUser(companyId, mobile, realName,email)
 						if err != nil {
 							fmt.Println("AddWxUser Err:" + err.Error())
 							return

services/task.go

@@ -5,7 +5,7 @@ import (
 	"github.com/astaxie/beego/toolbox"
 )
 
-func Task() {
+func Task123() {
 	fmt.Println("task start")
 	//发送邮件
 	sendEmail := toolbox.NewTask("sendEmail", "0 0 12 * * 0 ", SendEmail)
@@ -38,11 +38,11 @@ func Task() {
 }
 
 
-//func Task() {
-//	fmt.Println("start")
-//	GetLzProductPriceData()
-//	fmt.Println("end")
-//}
+func Task() {
+	fmt.Println("start")
+	GetHistoryLzProductDetail()
+	fmt.Println("end")
+}
 
 func SendEmail() (err error) {
 	//报告历史访问次数