Commit 908a134d authored by 技术部-任文超's avatar 技术部-任文超

Merge branch 'master' into 20180330-wechat-binding

# Conflicts:
#	src/main/java/cn/quantgroup/xyqb/controller/external/queryLog/UserQueryLogController.java
parents 17db9b60 54c6b427
...@@ -155,8 +155,8 @@ public class UserQueryLogController { ...@@ -155,8 +155,8 @@ public class UserQueryLogController {
} }
String[] values=keyValues.split("\\n"); String[] values=keyValues.split("\\n");
List<String> queryV= Arrays.asList(values); List<String> queryV= Arrays.asList(values);
if(queryV!=null&&queryV.size()>50000){ if(queryV!=null&&queryV.size()>3000){
return JsonResult.buildErrorStateResult("查询记录数是"+queryV.size()+",超过50000条限制",null); return JsonResult.buildErrorStateResult("查询记录数是"+queryV.size()+",超过3000条限制",null);
} }
List<UserQueryInfo> userQueryInfos=new ArrayList<UserQueryInfo>(); List<UserQueryInfo> userQueryInfos=new ArrayList<UserQueryInfo>();
List<UserDetail> userDetails=new ArrayList<UserDetail>(); List<UserDetail> userDetails=new ArrayList<UserDetail>();
...@@ -366,8 +366,8 @@ public class UserQueryLogController { ...@@ -366,8 +366,8 @@ public class UserQueryLogController {
List<String> queryV= Arrays.asList(values); List<String> queryV= Arrays.asList(values);
if(queryV!=null&&queryV.size()>50000){ if(queryV!=null&&queryV.size()>3000){
return JsonResult.buildErrorStateResult("查询记录数是"+queryV.size()+",超过50000条限制",null); return JsonResult.buildErrorStateResult("查询记录数是"+queryV.size()+",超过3000条限制",null);
} }
......
...@@ -12,8 +12,6 @@ import org.springframework.beans.factory.annotation.Qualifier; ...@@ -12,8 +12,6 @@ import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
;
/** /**
* Created by xuran on 2017/6/21. * Created by xuran on 2017/6/21.
* 用户统计信息 * 用户统计信息
...@@ -30,13 +28,6 @@ public class LoanVestMQServiceImpl implements IVestService { ...@@ -30,13 +28,6 @@ public class LoanVestMQServiceImpl implements IVestService {
@Qualifier(value = "loanVestQueue") @Qualifier(value = "loanVestQueue")
Queue loanVestQueue; Queue loanVestQueue;
/** /**
* 发送用登陆统计信息 * 发送用登陆统计信息
* @param message 订单信息 * @param message 订单信息
...@@ -44,17 +35,12 @@ public class LoanVestMQServiceImpl implements IVestService { ...@@ -44,17 +35,12 @@ public class LoanVestMQServiceImpl implements IVestService {
@Async @Async
public void send(UserStatistics message){ public void send(UserStatistics message){
if(null==message){ if(null==message){
LOGGER.error("用登陆统计消息不能为空"); LOGGER.error("用登陆统计消息不能为空");
} }
LOGGER.info("用户登陆统计发送,message={}",message);
LOGGER.info("用登陆统计发送,message={}",message);
String msg = JSONObject.toJSONString(message); String msg = JSONObject.toJSONString(message);
loanVestRabbitTemplate.convertAndSend("statistics-user", msg); loanVestRabbitTemplate.convertAndSend("statistics-user", msg);
LOGGER.info("用户登陆统计成功,message={}",msg);
LOGGER.info("用登陆统计成功,message={}",msg);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment