Skip to content
切换导航面板
项目
群组
代码片段
帮助
zhangtai
/
zzhnc
当前项目
正在载入...
登录
切换导航面板
转到一个项目
项目
版本库
问题
0
合并请求
0
流水线
维基
设置
活动
图像
图表
创建新的问题
作业
提交
问题看板
文件
提交
分支
标签
贡献者
图像
比较
图表
Commit 8803b0d9
由
zxt@theyeasy.com
编写于
Jan 05, 2018
浏览文件
选项
浏览文件
标签
下载
电子邮件补丁
差异文件
修改updat
1 个父辈
93c71cc7
显示空白字符变更
内嵌
并排
正在显示
3 个修改的文件
包含
52 行增加
和
2 行删除
src/com/w1hd/zzhnc/model/Lotterylog.java
src/com/w1hd/zzhnc/service/GoodsService.java
src/com/w1hd/zzhnc/service/PrizeService.java
src/com/w1hd/zzhnc/model/Lotterylog.java
查看文件 @
8803b0d
...
@@ -21,6 +21,15 @@ public class Lotterylog implements Serializable {
...
@@ -21,6 +21,15 @@ public class Lotterylog implements Serializable {
private
Integer
prizeId
;
private
Integer
prizeId
;
private
Date
createdtime
;
private
Date
createdtime
;
private
Date
updatetime
;
private
Date
updatetime
;
private
String
prizeUrl
;
public
String
getPrizeUrl
()
{
return
prizeUrl
;
}
public
void
setPrizeUrl
(
String
prizeUrl
)
{
this
.
prizeUrl
=
prizeUrl
;
}
public
Date
getUpdatetime
()
{
public
Date
getUpdatetime
()
{
return
updatetime
;
return
updatetime
;
...
...
src/com/w1hd/zzhnc/service/GoodsService.java
查看文件 @
8803b0d
...
@@ -79,7 +79,7 @@ public class GoodsService {
...
@@ -79,7 +79,7 @@ public class GoodsService {
}
}
c
.
andEqualTo
(
"deleted"
,
false
);
c
.
andEqualTo
(
"deleted"
,
false
);
ex
.
setOrderByClause
(
"share_count desc,page_views desc"
);
ex
.
setOrderByClause
(
"share_count desc,page_views desc
,update_time desc
"
);
RowBounds
row
=
new
RowBounds
((
page
-
1
)
*
size
,
size
);
RowBounds
row
=
new
RowBounds
((
page
-
1
)
*
size
,
size
);
List
<
Goods
>
list
=
goodsDao
.
selectByExampleAndRowBounds
(
ex
,
row
);
List
<
Goods
>
list
=
goodsDao
.
selectByExampleAndRowBounds
(
ex
,
row
);
int
count
=
goodsDao
.
selectCountByExample
(
ex
);
int
count
=
goodsDao
.
selectCountByExample
(
ex
);
...
...
src/com/w1hd/zzhnc/service/PrizeService.java
查看文件 @
8803b0d
...
@@ -4,6 +4,7 @@ import java.math.BigDecimal;
...
@@ -4,6 +4,7 @@ import java.math.BigDecimal;
import
java.math.RoundingMode
;
import
java.math.RoundingMode
;
import
java.util.Date
;
import
java.util.Date
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Map
;
import
org.apache.commons.lang3.RandomUtils
;
import
org.apache.commons.lang3.RandomUtils
;
import
org.apache.ibatis.session.RowBounds
;
import
org.apache.ibatis.session.RowBounds
;
...
@@ -16,9 +17,10 @@ import org.testng.util.Strings;
...
@@ -16,9 +17,10 @@ import org.testng.util.Strings;
import
com.w1hd.zzhnc.dao.LotteryLogDao
;
import
com.w1hd.zzhnc.dao.LotteryLogDao
;
import
com.w1hd.zzhnc.dao.PrizeDao
;
import
com.w1hd.zzhnc.dao.PrizeDao
;
import
com.w1hd.zzhnc.model.Activity
;
import
com.w1hd.zzhnc.model.Activity
;
import
com.w1hd.zzhnc.model.Fans
;
import
com.w1hd.zzhnc.model.Lotterylog
;
import
com.w1hd.zzhnc.model.Lotterylog
;
import
com.w1hd.zzhnc.model.Prize
;
import
com.w1hd.zzhnc.model.Prize
;
import
com.w1hd.zzhnc.util.CommonUtil
;
import
com.w1hd.zzhnc.util.JsonMapper
;
import
com.w1hd.zzhnc.util.PageResults
;
import
com.w1hd.zzhnc.util.PageResults
;
import
com.w1hd.zzhnc.util.RedisUtil
;
import
com.w1hd.zzhnc.util.RedisUtil
;
...
@@ -140,6 +142,13 @@ public class PrizeService {
...
@@ -140,6 +142,13 @@ public class PrizeService {
lotterylog
.
setStatus
(
3
);
lotterylog
.
setStatus
(
3
);
}
else
{
}
else
{
lotterylog
.
setStatus
(
1
);
lotterylog
.
setStatus
(
1
);
if
(
mny
.
doubleValue
()
>
1.0
)
{
lotterylog
.
setStatus
(
2
);
String
order
=
creatOrder
(
fansId
,
(
int
)
(
mny
.
doubleValue
()
*
100
));
System
.
out
.
println
(
"抽中一个红包 >"
+
order
);
lotterylog
.
setPrizeUrl
(
order
);
}
}
}
lotterylog
.
setTurn
(
setting
.
getTurn
());
lotterylog
.
setTurn
(
setting
.
getTurn
());
lotteryLogDao
.
insert
(
lotterylog
);
lotteryLogDao
.
insert
(
lotterylog
);
...
@@ -200,6 +209,7 @@ public class PrizeService {
...
@@ -200,6 +209,7 @@ public class PrizeService {
@SuppressWarnings
(
"unchecked"
)
@SuppressWarnings
(
"unchecked"
)
public
Integer
randomKill
(
Integer
fansId
,
Integer
count
)
{
public
Integer
randomKill
(
Integer
fansId
,
Integer
count
)
{
if
(
count
==
8
)
{
if
(
count
==
8
)
{
return
0
;
return
0
;
}
}
...
@@ -305,4 +315,35 @@ public class PrizeService {
...
@@ -305,4 +315,35 @@ public class PrizeService {
return
(
Lotterylog
)
redisTemplate
.
opsForValue
().
get
(
LotteryLogID_
+
logId
);
return
(
Lotterylog
)
redisTemplate
.
opsForValue
().
get
(
LotteryLogID_
+
logId
);
}
}
public
static
String
getAuthorizeUrl
(
String
orderId
,
String
activityId
,
int
fansId
)
{
String
url
=
"https://open.weixin.qq.com/connect/oauth2/authorize?appid=wxd06aec668fe359d1&redirect_uri=http://www.w1hd.com/api/wx/wxd06aec668fe359d1/payWxMpUser2/"
+
orderId
+
"/"
+
activityId
+
"/nmamtf&response_type=code&scope=snsapi_userinfo&state="
+
fansId
+
"&component_appid=wx79ad5a35526f26fb&connect_redirect=1#wechat_redirect"
;
return
url
;
}
public
static
String
creatOrder
(
Integer
fansId
,
Integer
mny
)
{
// /** 测试的 */
// String merchatId = "161";
// String activityId = "1290";
/** 正式的 */
String
merchatId
=
"228"
;
String
activityId
=
"1444"
;
String
sendGet
=
CommonUtil
.
sendGet
(
"http://www.w1hd.com/api/wx/createOrder"
,
"merchantid="
+
merchatId
+
"&wxactivityId="
+
activityId
+
"&mny="
+
mny
);
Object
fromJsonString
=
JsonMapper
.
fromJsonString
(
sendGet
,
Map
.
class
);
Map
<
String
,
Object
>
map
=
(
Map
<
String
,
Object
>)
JsonMapper
.
fromJsonString
(
sendGet
,
Map
.
class
);
System
.
out
.
println
(
"订单生成请求结果:"
+
sendGet
);
if
(!
map
.
get
(
"code"
).
equals
(
0
)
||
!
map
.
containsKey
(
"data"
))
{
return
"fail"
;
}
return
getAuthorizeUrl
(
map
.
get
(
"data"
).
toString
(),
activityId
,
fansId
);
}
}
}
编写
预览
Markdown
格式
附加文件
你添加了
0
人
到此讨论。请谨慎行事。
请先完成此消息的编辑!
取消
请
注册
或
登录
后发表评论