Merge branch 'develop' of 192.168.3.17:zhanghongbo/qfw into develop

core/src/qfw/active/activemanage.go

@@ -223,9 +223,9 @@ func (a *Activemanage) Addredis() error {
 
 //进入抽奖页面
 func (a *Activemanage) Luckdraw(activecode, id string) error {
-	nowdate := time.Now().Unix()
+	nowdate := time.Now()
 	enddate := LuckDraw.EndDate
-	if nowdate > enddate {
+	if nowdate.Unix() > enddate {
 		a.T["flog"] = "G"
 		a.T["msg"] = "　　抱歉，来晚了，活动已经结束了！敬请期待下一次活动吧，注意看预告呦……"
 		return a.Render("/active/luckdraw.html", &a.T)
@@ -264,11 +264,14 @@ func (a *Activemanage) Luckdraw(activecode, id string) error {
 				Tm := time.Now().AddDate(0, 0, 1)
 				if ret := redis.Get("other", "cj_"+openid+"_"+Tm.Format("2006_01_02")); ret == nil {
 					a.T["msg"] = "　　小主，分享给好友参加明天的抽奖吧！千万不要再忘记了，大奖可能就在明天~"
-				} else {
-					a.T["msg"] = "　　小主已获得明天的抽奖资格！明天记得要来啊~"
 				}
-				return a.Render("/active/luckdraw.html", &a.T)
+			} else {
+				a.T["msg"] = "　　小主已获得明天的抽奖资格！明天记得要来啊~"
 			}
+			if nowdate.Day() == 15 {
+				a.T["msg"] = "　　小主，明天抽奖活动就结束了，请期待企明星的下一次活动吧！"
+			}
+			return a.Render("/active/luckdraw.html", &a.T)
 		}
 
 		return a.Render("/active/luckdraw.html", &a.T)
@@ -295,7 +298,11 @@ func (a *Activemanage) Getluckdraw() error {
 			if ret := redis.Get("other", "cj_"+openid+"_"+time.Now().Format("2006_01_02")); ret == nil {
 				//a.T = *u
 				a.T["flog"] = "A"
-				a.T["msg"] = "　　小主，分享给好友参加明天的抽奖吧！千万不要再忘记了，大奖可能就在明天~"
+				if today.Day() == 15 {
+					a.T["msg"] = "　　小主，明天抽奖活动就结束了，请期待企明星的下一次活动吧！"
+				} else {
+					a.T["msg"] = "　　小主，分享给好友参加明天的抽奖吧！千万不要再忘记了，大奖可能就在明天~"
+				}
 				return a.Write(`{"flog":"` + flog + `","msg":"` + msg + `"}`)
 			}
 			redis.Del("other", "cj_"+openid+"_"+time.Now().Format("2006_01_02"))
@@ -368,9 +375,12 @@ func (a *Activemanage) Getluckdraw() error {
 			redpackage_fail["i_amount"] = amount
 			redpackage_fail["l_createdate"] = today.Unix()
 			Save("redpackage_fail", redpackage_fail)
-
 		}
-		msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中。红包将由系统自动发放到您的微信，请注意查收。<br/><br/>　　分享给好友参加明天抽奖呦！乖，快去分享吧！大奖可能就在明天~~"
+		if today.Day() == 15 {
+			msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中。红包将由系统自动发放到您的微信，请注意查收。<br/><br/>　　明天抽奖活动就结束了，请期待企明星的下一次活动吧！"
+		} else {
+			msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中。红包将由系统自动发放到您的微信，请注意查收。<br/><br/>　　分享给好友参加明天抽奖呦！乖，快去分享吧！大奖可能就在明天~~"
+		}
 	} else if (i > 279 && i < 311) || (i > 94 && i < 121) {
 		//时间判断，提醒不同
 		//now := time.Now()
@@ -379,7 +389,12 @@ func (a *Activemanage) Getluckdraw() error {
 		//
 		//	msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中！<br/>　　请在微信留下您的联系方式（手机号或qq号），企明星客服会在下一个工作日9:00-17:00给小主回复哦!<br/>　　小主翻个牌子，动动小手分享活动，么么哒……（分享点击页面右上方···分享到朋友圈）"
 		//} else { //在工作时间
-		msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中。请将您的姓名+联系方式+邮寄地址留言给企明星。我们会在活动截止后尽快为您发出。<br/><br/>　　分享给好友参加明天抽奖呦！乖，快去分享吧！大奖可能就在明天~~"
+
+		if today.Day() == 15 {
+			msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中。红包将由系统自动发放到您的微信，请注意查收。<br/><br/>　　明天抽奖活动就结束了，请期待企明星的下一次活动吧！"
+		} else {
+			msg = "　　小主是真真的好运气，" + s_prize + "落入您囊中。请将您的姓名+联系方式+邮寄地址留言给企明星。我们会在活动截止后尽快为您发出。<br/><br/>　　分享给好友参加明天抽奖呦！乖，快去分享吧！大奖可能就在明天~~"
+		}
 		//}
 	} else if i > 139 && i < 176 {
 		obid := a.GetSession("userId").(string)
@@ -389,8 +404,15 @@ func (a *Activemanage) Getluckdraw() error {
 		} else {
 			msg = "　　抽奖出错！小主不要桑心，联系企明星管理员，200积分还是您的！"
 		}
+		if today.Day() == 15 {
+			msg = "　　小主是真真的好运气，200积分落入您囊中。积分将由系统自动发放到您的企明星账户，请登录www.qmx.top查看。<br/><br/>　　明天抽奖活动就结束了，请期待企明星的下一次活动吧！"
+		}
 	} else { //不中奖
-		msg = "　　小主不要桑心，这次没有中奖哦，明天记得要来拼运气啊！<br/><br/>　　分享给好友参加明天抽奖呦！乖，快去分享吧！大奖可能就在明天~~"
+		if today.Day() == 15 {
+			msg = "　　小主不要桑心，这次没有中奖哦，明天抽奖活动就结束了，请期待企明星的下一次活动吧！"
+		} else {
+			msg = "　　小主不要桑心，这次没有中奖哦，明天记得要来拼运气啊！<br/><br/>　　分享给好友参加明天抽奖呦！乖，快去分享吧！大奖可能就在明天~~"
+		}
 	}
 	return a.Write(`{"flog":"` + flog + `","msg":"` + msg + `","rotate":` + strconv.Itoa(int(i)) + `}`)
 

core/src/timetask.json

@@ -1 +1 @@
-{"comment":{"c_rate":720,"commentrate":900},"market":{"demand":{"attr":["i_hits","i_bids","i_status"],"timepoint":"2016-02-03 11:05:05"},"service":{"attr":["i_hits","i_sales","i_comments","i_score","i_appcounts"],"timepoint":"2016-02-03 11:05:05"}},"marketisstart":true,"marketrate":300}
+{"comment":{"c_rate":720,"commentrate":900},"market":{"demand":{"attr":["i_hits","i_bids","i_status"],"timepoint":"2016-02-03 14:20:18"},"service":{"attr":["i_hits","i_sales","i_comments","i_score","i_appcounts"],"timepoint":"2016-02-03 14:20:18"}},"marketisstart":true,"marketrate":300}

core/src/web/templates/swordfish/rssset.html

@@ -36,7 +36,7 @@
 				{{if .T.msgset}}
 					{{if .T.msgset.tender}}
 						{{if .T.msgset.tender.day}}
-							{{if gt 6 .T.msgset.tender.day}}
+							{{if and (gt 6 .T.msgset.tender.day) (gt .T.msgset.tender.day 0)}}
 							本栏目推送服务期还剩<span style="color:red"> {{.T.msgset.tender.day}} </span>天。想要服务不间断，请确保积分充足。 <a href="/member/credit/myCredit">去做任务赚积分</a>
 							{{end}}
 						{{end}}
@@ -72,7 +72,7 @@
 				{{if .T.msgset}}
 					{{if .T.msgset.bid}}
 						{{if .T.msgset.bid.day}}
-							{{if gt 6 .T.msgset.bid.day}}
+							{{if and (gt 6 .T.msgset.bid.day) (gt .T.msgset.bid.day 0)}}
 							本栏目推送服务期还剩<span style="color:red"> {{.T.msgset.bid.day}} </span>天。想要服务不间断，请确保积分充足。 <a href="/member/credit/myCredit">去做任务赚积分</a>
 							{{end}}
 						{{end}}

weixin/src/config.json

@@ -19,8 +19,8 @@
 	"entAuthTip":"，请按向导进行操作。第1步(共2步)：请输入完整的企业名称。\n（认证过程只涉及您所在企业的公开信息。除非事先获得您的授权，企明星不会将您的个人隐私信息公开或透露给第三方机构。输入q或Q,退出认证操作。）",
 	"perAuthTip":"，请按向导进行操作。第1步(共2步)：请输入商家名称。\n（除非事先获得您的授权，企明星不会将您的个人隐私信息公开或透露给第三方机构。输入q或Q,退出认证操作。）",
 	"othAuthTip":"，请按向导进行操作。第1步(共2步)：请输入完整的组织机构名称。\n（认证过程只涉及您所在机构的公开信息。除非事先获得您的授权，企明星不会将您的个人隐私信息公开或透露给第三方机构。输入q或Q,退出认证操作。）",
-	"welcomeTip":"您已成功注册企明星！企明星是一个为全国企业提供专业化服务的互联网平台。企明星提供企业服务交易、剑鱼招标订阅、免费企业查询等多项服务。\n新春到，剑鱼送祝福，企明星幸运抽奖活动火热举行中，回复抽奖，即可参与活动。",
-	"oWelcomeTip":"您已成功注册企明星！企明星是一个为全国企业提供专业化服务的互联网平台。企明星提供企业服务交易、剑鱼招标订阅、免费企业查询等多项服务。\n新春到，剑鱼送祝福，企明星幸运抽奖活动火热举行中，回复抽奖，即可参与活动。",
+	"welcomeTip":"您已注册企明星！企明星是一个为全国企业提供专业化服务的互联网平台。企明星提供企业服务交易、剑鱼招标订阅、全国企业信息查询等多项服务。\n新春到，企明星多种活动火爆举行中。回复抽奖，即可参加“剑鱼抽奖”；回复福牌，即可参加“猴年翻福牌活动”。",
+	"oWelcomeTip":"您已注册企明星！企明星是一个为全国企业提供专业化服务的互联网平台。企明星提供企业服务交易、剑鱼招标订阅、全国企业信息查询等多项服务。\n新春到，企明星多种活动火爆举行中。回复抽奖，即可参加“剑鱼抽奖”；回复福牌，即可参加“猴年翻福牌活动”。",
 	"loginTip":"您已经成功登录企明星。",
 	"freezeTip":"您的帐号已经冻结，请联系管理员。",
 	"messagetpl":{
@@ -33,7 +33,7 @@
 		"activitycode":"topcj",
 		"title":"企明星新年抽奖活动进行中",
 		"picurl":"http://www.qimingxing.info/images/choujiang2.png",
-		"tuenCards":"小主，来抢新年福牌了！\n剑鱼君派送神秘福牌！\n<a href='%s'>小主快快点这里翻福牌!</a>",
+		"tuenCards":"小主，来抢新年福牌了~~\n/:handclap/:handclap/:handclap\n剑鱼君派送神秘福牌！\n/:gift<a href='%s'>小主快快点这里翻福牌!</a>/:gift",
 	},"weixinautorpl":"小主的吩咐我们已经收到了，请留下您的联系方式（手机号或qq号），企明星客服会在下一个工作日9:00-17:00给小主回复哦！",
 	"creditRpc":"127.0.0.1:8765",
 	"subscribemonitorcyc":3,

weixin/src/qfw/weixin/msgtxtchandler.go

@@ -45,16 +45,15 @@ func MsgTxtHandler(w ResponseWriter, r *Request) {
 		w.ReplyText("您已进入微信管理，请输入指令操作:\n1.查看抽奖模式（指令:f0）\n2.切换抽奖模式（指令:c*,*为数字。如c0(自动模式),c1(手动模式1),c2(手动模式2),c3(手动模式3)）\n3.统计抽奖结果（tjr*,tjr120(最近两分钟),tjr120-1200(最近两分钟至最近20分钟之间的)）\n4.统计新用户数（tju*）\n5.服务器情况监测（ser0）\n6服务管理(man*,man1重启主程序(man11关闭),man3重启积分(man33关闭),man4重启微信认证(man44关闭))。\n输入q或Q离开。")
 		return
 	} else if r.Content == "抽奖" { //进入抽奖环节
-		if time.Now().Unix() > 1455465600 { //活动过期 ，过期后，这段代码要删除
+		if time.Now().Unix() > 1455552000 { //活动过期 ，过期后，这段代码要删除
 			//TODO
 			w.ReplyText("抱歉，活动已结束！敬请期待下一次抽奖活动，注意看预告哟……")
 		} else {
 			targeturl := fmt.Sprintf("http://%s/activity/%s/%s", wf.SysConfig.Domain, wf.SysConfig.Activity["activitycode"], se.EncodeString(r.FromUserName))
 			w.ReplyNews([]Article{Article{PicUrl: wf.SysConfig.Activity["picurl"], Title: wf.SysConfig.Activity["title"], Url: targeturl}})
 		}
-	} else if r.Content == "翻牌" { //进入抽奖环节
+	} else if r.Content == "福牌" { //进入抽奖环节
 		targeturl := fmt.Sprintf("https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&redirect_uri=http://%s/weixinoauth/action/%s&response_type=code&scope=snsapi_base&state=1#wechat_redirect", wf.SysConfig.Appid, wf.SysConfig.Domain, "turncards")
-		//w.ReplyNews([]Article{Article{Title: wf.SysConfig.Activity["tuenCards"], Url: targeturl,Description:}})
 		w.ReplyText(fmt.Sprintf(wf.SysConfig.Activity["tuenCards"], targeturl))
 	} else if strings.HasPrefix(r.Content, "内部报名") { //绑定拓普员工姓名
 		tmp := strings.Fields(r.Content)

weixin/src/qfw/weixin/subscribehandler.go

@@ -21,8 +21,8 @@ func SubscribeHandler(w ResponseWriter, r *Request) {
 	l1 := time.Now().Unix()
 	wxutil.SubscribeInc()
 	openid := r.FromUserName
-	log.Println("user data", w.GetUserData())
-	ret,_ := w.GetUserData().(map[string]interface{})
+	//log.Println("user data", w.GetUserData())
+	ret, _ := w.GetUserData().(map[string]interface{})
 	var unionid, bindweixin, userphoto string
 	if ret != nil {
 		unionid = ""
@@ -146,12 +146,14 @@ func SubscribeHandlerBak(w ResponseWriter, r *Request) {
 
 //取消关注事件处理
 func UnSubscribeHandler(w ResponseWriter, r *Request) {
-	w.ReplyText(WELCOME_MSG) // 有新人关注，返回欢迎消息
+	//w.ReplyText(WELCOME_MSG) // 有新人关注，返回欢迎消息
+	w.ReplyOK()
 	openid := r.FromUserName
 	//取UnionID
-	ret, err := w.GetUserBaseInfo(openid)
+	//ret, err := w.GetUserBaseInfo(openid)
+	ret := w.GetUserData().(map[string]interface{})
 	var unionid, bindweixin string
-	if err != nil {
+	if ret != nil {
 		unionid = ""
 		bindweixin = ""
 	} else {
@@ -185,11 +187,11 @@ func DoLogin(key string, openid string) {
 //下载微信用户头像
 func downloadUserFace(url string) string {
 	var filename string
-	
-		tn := time.Now()
-		filename = fmt.Sprintf("/upload/%s/%s/%s/%s%d.jpg", tn.Format("2006"), tn.Format("01"), tn.Format("02"), tn.Format("20060102150405"), rand.Intn(9999)+1000)
-		go func() {
-			util.Try(func() {
+
+	tn := time.Now()
+	filename = fmt.Sprintf("/upload/%s/%s/%s/%s%d.jpg", tn.Format("2006"), tn.Format("01"), tn.Format("02"), tn.Format("20060102150405"), rand.Intn(9999)+1000)
+	go func() {
+		util.Try(func() {
 			fi, _ := os.OpenFile(weixinconfig.SysConfig.Imgpath+filename, os.O_CREATE|os.O_TRUNC|os.O_SYNC|os.O_RDWR, 0x666)
 			defer fi.Close()
 			resp, err := http.Get(url)
@@ -199,7 +201,7 @@ func downloadUserFace(url string) string {
 			} else {
 				log.Println("download userface err:", err.Error())
 			}
-			}, func(e interface{}) {})
-		}()
+		}, func(e interface{}) {})
+	}()
 	return filename
 }

weixin/src/qfw/weixin/weixin.go

@@ -5,6 +5,7 @@ import (
 	"qfw/weixin/util"
 	wf "qfw/weixinconfig"
 	"regexp"
+	"time"
 )
 
 var Mux *Weixin
@@ -70,4 +71,16 @@ func InitWeixinSdk() {
 	//执行其他一些初始化的动作
 	InitSSLClient()
 	util.StartSubscribeFilter(wf.SysConfig.SubscribeMonitorCyc, wf.SysConfig.SubscribeMonitorTimes)
+
+	go changeMsg()
+}
+
+func changeMsg() {
+	now := time.Now().Unix()
+	if now > 1455552000 {
+		WELCOME_MSG = "您已注册企明星！企明星是一个为全国企业提供专业化服务的互联网平台。企明星提供企业服务交易、剑鱼招标订阅、全国企业信息查询等多项服务。"
+		OWELCOME_MSG = WELCOME_MSG
+	} else {
+		time.AfterFunc(5*time.Minute, changeMsg)
+	}
 }