Commit 2c052e2f authored by zhengjian's avatar zhengjian

6.6-2

parent 57754bd8
...@@ -63,7 +63,7 @@ public class FundModuleController { ...@@ -63,7 +63,7 @@ public class FundModuleController {
} }
@RequestMapping("/get_audit_infos") @RequestMapping("/get_audit_infos")
public GlobalResponse getAuditInfos(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget, String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize) { public GlobalResponse getAuditInfos(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget, String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize,Integer sortMode) {
log.info("资方模块接口, 获取审批列表开始, targetName : {}, auditStatus : {}, auditType : {}, auditTarget : {}, applyStartTime : {}, applyEndTime : {}, user : {}, pageNum : {}, pageSize : {}", targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize); log.info("资方模块接口, 获取审批列表开始, targetName : {}, auditStatus : {}, auditType : {}, auditTarget : {}, applyStartTime : {}, applyEndTime : {}, user : {}, pageNum : {}, pageSize : {}", targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize);
if (pageNum == null || pageSize == null) { if (pageNum == null || pageSize == null) {
return GlobalResponse.create(FundModuleResponse.PAGEING_CONDITIONS_IS_EMPTY); return GlobalResponse.create(FundModuleResponse.PAGEING_CONDITIONS_IS_EMPTY);
...@@ -72,7 +72,7 @@ public class FundModuleController { ...@@ -72,7 +72,7 @@ public class FundModuleController {
return GlobalResponse.create(FundModuleResponse.USER_IS_EMPTY); return GlobalResponse.create(FundModuleResponse.USER_IS_EMPTY);
} }
Stopwatch stopwatch = Stopwatch.createStarted(); Stopwatch stopwatch = Stopwatch.createStarted();
GlobalResponse response = fundModuleService.getAuditInfos(targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize); GlobalResponse response = fundModuleService.getAuditInfos(targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize,sortMode);
log.info("资方模块接口, 获取审批列表结束, targetName : {}, auditStatus : {}, auditType : {}, auditTarget : {}, applyStartTime : {}, applyEndTime : {}, user : {}, pageNum : {}, pageSize : {}, 耗时 : {}, response : {}", targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize, stopwatch.stop().elapsed(TimeUnit.MILLISECONDS), JSON.toJSONString(response)); log.info("资方模块接口, 获取审批列表结束, targetName : {}, auditStatus : {}, auditType : {}, auditTarget : {}, applyStartTime : {}, applyEndTime : {}, user : {}, pageNum : {}, pageSize : {}, 耗时 : {}, response : {}", targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize, stopwatch.stop().elapsed(TimeUnit.MILLISECONDS), JSON.toJSONString(response));
return response; return response;
} }
......
...@@ -40,11 +40,10 @@ public interface IApprovalLogService { ...@@ -40,11 +40,10 @@ public interface IApprovalLogService {
* @return * @return
*/ */
public Map<String, Object> getApprovalLogs(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget, public Map<String, Object> getApprovalLogs(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget,
String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize); String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize,Integer sortMode);
/** /**
* 审批接口 * 审批接口
* @param id 审批记录id
* @param auditStatus * @param auditStatus
*/ */
public void audit(ApprovalLog approvalLog, Integer auditStatus); public void audit(ApprovalLog approvalLog, Integer auditStatus);
......
...@@ -6,19 +6,17 @@ import java.util.HashMap; ...@@ -6,19 +6,17 @@ import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import javax.persistence.criteria.CriteriaBuilder; import javax.persistence.criteria.*;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Order;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import com.quantgroup.asset.distribution.service.funding.IFundModuleChannelFundConfigNewService; import com.quantgroup.asset.distribution.service.funding.IFundModuleChannelFundConfigNewService;
import com.quantgroup.asset.distribution.service.jpa.entity.FundModuleChannelFundConfigNew; import com.quantgroup.asset.distribution.service.jpa.entity.FundModuleChannelFundConfigNew;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.hibernate.jpa.criteria.predicate.InPredicate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page; import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -61,9 +59,15 @@ public class ApprovalLogServiceImpl implements IApprovalLogService{ ...@@ -61,9 +59,15 @@ public class ApprovalLogServiceImpl implements IApprovalLogService{
@Override @Override
public Map<String, Object> getApprovalLogs(String targetName, Integer auditStatus, Integer auditType, public Map<String, Object> getApprovalLogs(String targetName, Integer auditStatus, Integer auditType,
Integer auditTarget, String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer auditTarget, String applyStartTime, String applyEndTime, String user, Integer pageNum,
Integer pageSize) { Integer pageSize,Integer sortMode) {
// 分页条件 // 分页条件
Pageable pageable = new PageRequest(pageNum < 0 ? 0 : pageNum, pageSize); Pageable pageable;
if (sortMode == 1){
Sort sort = new Sort(Sort.Direction.ASC,"audit_status").and(new Sort(Sort.Direction.DESC,"audit_time"));
pageable = new PageRequest(pageNum < 0 ? 0 : pageNum, pageSize, sort);
}else {
pageable = new PageRequest(pageNum < 0 ? 0 : pageNum, pageSize);
}
Specification<ApprovalLog> specification = new Specification<ApprovalLog>() { Specification<ApprovalLog> specification = new Specification<ApprovalLog>() {
@Override @Override
public Predicate toPredicate(Root<ApprovalLog> root, CriteriaQuery<?> query, CriteriaBuilder cb) { public Predicate toPredicate(Root<ApprovalLog> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
...@@ -72,6 +76,10 @@ public class ApprovalLogServiceImpl implements IApprovalLogService{ ...@@ -72,6 +76,10 @@ public class ApprovalLogServiceImpl implements IApprovalLogService{
predicatesAnd.add(cb.equal(root.get("enable"), true)); predicatesAnd.add(cb.equal(root.get("enable"), true));
if(auditStatus != null){ if(auditStatus != null){
predicatesAnd.add(cb.equal(root.get("auditStatus"), auditStatus)); predicatesAnd.add(cb.equal(root.get("auditStatus"), auditStatus));
}else {
if (sortMode == 1){
predicatesAnd.add(cb.in(root.get("auditStatus")).value(0).value(1));
}
} }
if(auditType != null){ if(auditType != null){
predicatesAnd.add(cb.equal(root.get("auditType"), auditType)); predicatesAnd.add(cb.equal(root.get("auditType"), auditType));
......
...@@ -80,7 +80,7 @@ public interface IFundModuleService { ...@@ -80,7 +80,7 @@ public interface IFundModuleService {
* @param pageSize * @param pageSize
* @return * @return
*/ */
public GlobalResponse getAuditInfos(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget, String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize); public GlobalResponse getAuditInfos(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget, String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize,Integer sortMode);
/** /**
* 根据Id获取资方配置 * 根据Id获取资方配置
......
...@@ -149,8 +149,8 @@ public class FundModuleServiceImpl implements IFundModuleService{ ...@@ -149,8 +149,8 @@ public class FundModuleServiceImpl implements IFundModuleService{
@HandleException @HandleException
@Override @Override
public GlobalResponse getAuditInfos(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget, public GlobalResponse getAuditInfos(String targetName, Integer auditStatus, Integer auditType, Integer auditTarget,
String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize) { String applyStartTime, String applyEndTime, String user, Integer pageNum, Integer pageSize,Integer sortMode) {
Map<String, Object> result = approvalLogService.getApprovalLogs(targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize); Map<String, Object> result = approvalLogService.getApprovalLogs(targetName, auditStatus, auditType, auditTarget, applyStartTime, applyEndTime, user, pageNum, pageSize,sortMode);
if (result.size() == 0) { if (result.size() == 0) {
return GlobalResponse.create(FundModuleResponse.HAS_NO_DATA); return GlobalResponse.create(FundModuleResponse.HAS_NO_DATA);
} }
......
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