优化统计,优化订单结算
This commit is contained in:
parent
f531afb503
commit
23a4f56d86
@ -496,6 +496,8 @@ public class XhpcRealTimeOrderServiceImpl extends BaseService implements IXhpcRe
|
|||||||
|
|
||||||
Map<String, Double> params1 =new HashMap<>();
|
Map<String, Double> params1 =new HashMap<>();
|
||||||
if("1".equals(judgeActivity.get("status").toString())){
|
if("1".equals(judgeActivity.get("status").toString())){
|
||||||
|
judge =true;
|
||||||
|
logger.info("<<<<<<<<<<<<<<<价格、时间、公式都相同>>>>>>>>>>>>>>>>>");
|
||||||
params1.put("T",money.doubleValue());
|
params1.put("T",money.doubleValue());
|
||||||
params1.put("P",powerPrice.doubleValue());
|
params1.put("P",powerPrice.doubleValue());
|
||||||
params1.put("S",servicePrice.doubleValue());
|
params1.put("S",servicePrice.doubleValue());
|
||||||
@ -528,7 +530,8 @@ public class XhpcRealTimeOrderServiceImpl extends BaseService implements IXhpcRe
|
|||||||
promotionDiscount = money.subtract(activityTotalPriceTotal);
|
promotionDiscount = money.subtract(activityTotalPriceTotal);
|
||||||
xhpcHistoryOrder.setActivityId(judgeActivity.get("activityId").toString());
|
xhpcHistoryOrder.setActivityId(judgeActivity.get("activityId").toString());
|
||||||
}else if("2".equals(judgeActivity.get("status").toString())){
|
}else if("2".equals(judgeActivity.get("status").toString())){
|
||||||
|
judge =true;
|
||||||
|
logger.info("<<<<<<<<<<<<<<<价格、时间都相同>>>>>>>>>>>>>>>>>");
|
||||||
String computeFormula = judgeActivity.get("computeFormula").toString();
|
String computeFormula = judgeActivity.get("computeFormula").toString();
|
||||||
BigDecimal powerPrice1 = new BigDecimal(judgeActivity.get("powerPrice").toString());
|
BigDecimal powerPrice1 = new BigDecimal(judgeActivity.get("powerPrice").toString());
|
||||||
BigDecimal servicePrice1 = new BigDecimal(judgeActivity.get("servicePrice").toString());
|
BigDecimal servicePrice1 = new BigDecimal(judgeActivity.get("servicePrice").toString());
|
||||||
|
|||||||
@ -44,9 +44,7 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<Map<String, Object>> getTimeIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
public List<Map<String, Object>> getTimeIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
return new ArrayList<>();
|
|
||||||
}
|
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
@ -164,9 +162,7 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
}
|
}
|
||||||
@Override
|
@Override
|
||||||
public List<Map<String, Object>> getDateIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
public List<Map<String, Object>> getDateIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
return new ArrayList<>();
|
|
||||||
}
|
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
@ -197,9 +193,7 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<Map<String, Object>> getStationIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String chargingStationIds, String operatorIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
public List<Map<String, Object>> getStationIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String chargingStationIds, String operatorIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
return new ArrayList<>();
|
|
||||||
}
|
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
@ -233,9 +227,7 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<Map<String, Object>> getOperatorIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String operatorIds, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
public List<Map<String, Object>> getOperatorIntervalPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId,String operatorIds, Long operatorId, String startTime, String endTime, Long userId, Integer type) {
|
||||||
if(getJudge(null,operatorId,type)){
|
|
||||||
return new ArrayList<>();
|
|
||||||
}
|
|
||||||
List<String> operatorUserId =new ArrayList<>();
|
List<String> operatorUserId =new ArrayList<>();
|
||||||
if(!"".equals(operatorIds) && operatorIds !=null){
|
if(!"".equals(operatorIds) && operatorIds !=null){
|
||||||
operatorUserId= Arrays.asList(operatorIds.split(","));
|
operatorUserId= Arrays.asList(operatorIds.split(","));
|
||||||
@ -264,9 +256,6 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<Map<String, Object>> getInternetUserIntervalPage(HttpServletRequest request,String internetUserIds, Long internetUserId, String startTime, String endTime, Long userId, Integer type) {
|
public List<Map<String, Object>> getInternetUserIntervalPage(HttpServletRequest request,String internetUserIds, Long internetUserId, String startTime, String endTime, Long userId, Integer type) {
|
||||||
if(getJudge(internetUserId,null,type)){
|
|
||||||
return new ArrayList<>();
|
|
||||||
}
|
|
||||||
List<String> internetIds =new ArrayList<>();
|
List<String> internetIds =new ArrayList<>();
|
||||||
if(!"".equals(internetUserIds) && internetUserIds !=null){
|
if(!"".equals(internetUserIds) && internetUserIds !=null){
|
||||||
internetIds= Arrays.asList(internetUserIds.split(","));
|
internetIds= Arrays.asList(internetUserIds.split(","));
|
||||||
@ -514,9 +503,6 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
@Override
|
@Override
|
||||||
public List<Map<String, Object>> getMechanismPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type,Integer source) {
|
public List<Map<String, Object>> getMechanismPage(HttpServletRequest request,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type,Integer source) {
|
||||||
|
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
return new ArrayList<>();
|
|
||||||
}
|
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
@ -566,7 +552,6 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
}
|
}
|
||||||
|
|
||||||
private boolean getJudge(Long internetUserId, Long operatorId, Integer type) {
|
private boolean getJudge(Long internetUserId, Long operatorId, Integer type) {
|
||||||
|
|
||||||
if (type == null) {
|
if (type == null) {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@ -674,32 +659,30 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
@Override
|
@Override
|
||||||
public void dateIntervalExport(HttpServletRequest request,HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) throws IOException {
|
public void dateIntervalExport(HttpServletRequest request,HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) throws IOException {
|
||||||
List<Map<String, Object>> list =new ArrayList<>();
|
List<Map<String, Object>> list =new ArrayList<>();
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
|
|
||||||
}else{
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
|
||||||
}
|
|
||||||
//获取登陆用户
|
|
||||||
LoginUser loginUser = tokenService.getLoginUser(request);
|
|
||||||
SysUser sysUser = loginUser.getSysUser();
|
|
||||||
Long sysUserId = sysUser.getUserId();
|
|
||||||
//获取登陆用户
|
|
||||||
|
|
||||||
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
|
||||||
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
|
||||||
Long logOperatorId = sysUser.getOperatorId();
|
|
||||||
//运营商看自己的场站
|
|
||||||
list = xhpcStatisticsServiceMapper.getDateIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 1,logOperatorId,tenantId);
|
|
||||||
}else{
|
|
||||||
//查询赋值的场站
|
|
||||||
list = xhpcStatisticsServiceMapper.getDateIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 2,sysUserId,tenantId);
|
|
||||||
}
|
|
||||||
}else{
|
|
||||||
list =xhpcStatisticsServiceMapper.getDateIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 0,sysUserId,tenantId);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
//获取登陆用户
|
||||||
|
LoginUser loginUser = tokenService.getLoginUser(request);
|
||||||
|
SysUser sysUser = loginUser.getSysUser();
|
||||||
|
Long sysUserId = sysUser.getUserId();
|
||||||
|
//获取登陆用户
|
||||||
|
|
||||||
|
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
||||||
|
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
||||||
|
Long logOperatorId = sysUser.getOperatorId();
|
||||||
|
//运营商看自己的场站
|
||||||
|
list = xhpcStatisticsServiceMapper.getDateIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 1,logOperatorId,tenantId);
|
||||||
|
}else{
|
||||||
|
//查询赋值的场站
|
||||||
|
list = xhpcStatisticsServiceMapper.getDateIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 2,sysUserId,tenantId);
|
||||||
|
}
|
||||||
|
}else{
|
||||||
|
list =xhpcStatisticsServiceMapper.getDateIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 0,sysUserId,tenantId);
|
||||||
|
}
|
||||||
|
|
||||||
// 通过工具类创建writer,默认创建xls格式
|
// 通过工具类创建writer,默认创建xls格式
|
||||||
BigExcelWriter writer = ExcelUtil.getBigWriter("temp_" + System.currentTimeMillis() + ".xlsx");
|
BigExcelWriter writer = ExcelUtil.getBigWriter("temp_" + System.currentTimeMillis() + ".xlsx");
|
||||||
writer.addHeaderAlias("createTime", "日期");
|
writer.addHeaderAlias("createTime", "日期");
|
||||||
@ -744,33 +727,30 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
@Override
|
@Override
|
||||||
public void stationIntervalExport(HttpServletRequest request,HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds,String operatorIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) throws IOException {
|
public void stationIntervalExport(HttpServletRequest request,HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds,String operatorIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type) throws IOException {
|
||||||
List<Map<String, Object>> list =new ArrayList<>();
|
List<Map<String, Object>> list =new ArrayList<>();
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
|
|
||||||
}else{
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
}
|
||||||
}
|
List<String> operatorUserId =new ArrayList<>();
|
||||||
List<String> operatorUserId =new ArrayList<>();
|
if(!"".equals(operatorIds) && operatorIds !=null){
|
||||||
if(!"".equals(operatorIds) && operatorIds !=null){
|
operatorUserId= Arrays.asList(operatorIds.split(","));
|
||||||
operatorUserId= Arrays.asList(operatorIds.split(","));
|
}
|
||||||
}
|
LoginUser loginUser = tokenService.getLoginUser(request);
|
||||||
LoginUser loginUser = tokenService.getLoginUser(request);
|
SysUser sysUser = loginUser.getSysUser();
|
||||||
SysUser sysUser = loginUser.getSysUser();
|
Long sysUserId = sysUser.getUserId();
|
||||||
Long sysUserId = sysUser.getUserId();
|
|
||||||
|
|
||||||
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
||||||
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
||||||
Long logOperatorId = sysUser.getOperatorId();
|
Long logOperatorId = sysUser.getOperatorId();
|
||||||
//运营商看自己的场站
|
//运营商看自己的场站
|
||||||
list = xhpcStatisticsServiceMapper.getStationIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList,operatorUserId,internetUserId,operatorId,startTime,endTime,1,logOperatorId,tenantId);
|
list = xhpcStatisticsServiceMapper.getStationIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList,operatorUserId,internetUserId,operatorId,startTime,endTime,1,logOperatorId,tenantId);
|
||||||
}else{
|
|
||||||
//查询赋值的场站
|
|
||||||
list = xhpcStatisticsServiceMapper.getStationIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList,operatorUserId,internetUserId,operatorId,startTime,endTime,2,sysUserId,tenantId);
|
|
||||||
}
|
|
||||||
}else{
|
}else{
|
||||||
list =xhpcStatisticsServiceMapper.getStationIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList,operatorUserId,internetUserId,operatorId,startTime,endTime,0,sysUserId,tenantId);
|
//查询赋值的场站
|
||||||
|
list = xhpcStatisticsServiceMapper.getStationIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList,operatorUserId,internetUserId,operatorId,startTime,endTime,2,sysUserId,tenantId);
|
||||||
}
|
}
|
||||||
|
}else{
|
||||||
|
list =xhpcStatisticsServiceMapper.getStationIntervalPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList,operatorUserId,internetUserId,operatorId,startTime,endTime,0,sysUserId,tenantId);
|
||||||
}
|
}
|
||||||
|
|
||||||
// 通过工具类创建writer,默认创建xls格式
|
// 通过工具类创建writer,默认创建xls格式
|
||||||
@ -819,29 +799,26 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
@Override
|
@Override
|
||||||
public void operatorIntervalExport(HttpServletRequest request,HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String operatorIds,Long operatorId, String startTime, String endTime, Long userId, Integer type) throws IOException {
|
public void operatorIntervalExport(HttpServletRequest request,HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String operatorIds,Long operatorId, String startTime, String endTime, Long userId, Integer type) throws IOException {
|
||||||
List<Map<String, Object>> list =new ArrayList<>();
|
List<Map<String, Object>> list =new ArrayList<>();
|
||||||
if(getJudge(null,operatorId,type)){
|
|
||||||
|
|
||||||
}else{
|
List<String> operatorUserId =new ArrayList<>();
|
||||||
List<String> operatorUserId =new ArrayList<>();
|
if(!"".equals(operatorIds) && operatorIds !=null){
|
||||||
if(!"".equals(operatorIds) && operatorIds !=null){
|
operatorUserId= Arrays.asList(operatorIds.split(","));
|
||||||
operatorUserId= Arrays.asList(operatorIds.split(","));
|
}
|
||||||
}
|
LoginUser loginUser = tokenService.getLoginUser(request);
|
||||||
LoginUser loginUser = tokenService.getLoginUser(request);
|
SysUser sysUser = loginUser.getSysUser();
|
||||||
SysUser sysUser = loginUser.getSysUser();
|
Long sysUserId = sysUser.getUserId();
|
||||||
Long sysUserId = sysUser.getUserId();
|
|
||||||
|
|
||||||
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
||||||
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
||||||
Long logOperatorId = sysUser.getOperatorId();
|
Long logOperatorId = sysUser.getOperatorId();
|
||||||
//运营商看自己的场站
|
//运营商看自己的场站
|
||||||
list = xhpcStatisticsServiceMapper.getOperatorIntervalPage(chargingStationId,chargingPileId,terminalId,operatorUserId, operatorId, startTime, endTime, 1,logOperatorId,tenantId);
|
list = xhpcStatisticsServiceMapper.getOperatorIntervalPage(chargingStationId,chargingPileId,terminalId,operatorUserId, operatorId, startTime, endTime, 1,logOperatorId,tenantId);
|
||||||
}else{
|
|
||||||
//查询赋值的场站
|
|
||||||
list = xhpcStatisticsServiceMapper.getOperatorIntervalPage(chargingStationId,chargingPileId,terminalId,operatorUserId, operatorId, startTime, endTime, 2,sysUserId,tenantId);
|
|
||||||
}
|
|
||||||
}else{
|
}else{
|
||||||
list =xhpcStatisticsServiceMapper.getOperatorIntervalPage(chargingStationId,chargingPileId,terminalId,operatorUserId, operatorId, startTime, endTime, 0,sysUserId,tenantId);
|
//查询赋值的场站
|
||||||
|
list = xhpcStatisticsServiceMapper.getOperatorIntervalPage(chargingStationId,chargingPileId,terminalId,operatorUserId, operatorId, startTime, endTime, 2,sysUserId,tenantId);
|
||||||
}
|
}
|
||||||
|
}else{
|
||||||
|
list =xhpcStatisticsServiceMapper.getOperatorIntervalPage(chargingStationId,chargingPileId,terminalId,operatorUserId, operatorId, startTime, endTime, 0,sysUserId,tenantId);
|
||||||
}
|
}
|
||||||
// 通过工具类创建writer,默认创建xls格式
|
// 通过工具类创建writer,默认创建xls格式
|
||||||
BigExcelWriter writer = ExcelUtil.getBigWriter("temp_" + System.currentTimeMillis() + ".xlsx");
|
BigExcelWriter writer = ExcelUtil.getBigWriter("temp_" + System.currentTimeMillis() + ".xlsx");
|
||||||
@ -1004,30 +981,27 @@ public class XhpcStatisticsServiceImpl extends BaseService implements IXhpcStati
|
|||||||
@Override
|
@Override
|
||||||
public void getMechanismExport(HttpServletRequest request, HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type, Integer source) throws IOException {
|
public void getMechanismExport(HttpServletRequest request, HttpServletResponse response,String tenantId,Long chargingStationId,Long chargingPileId,Long terminalId, String chargingStationIds, Long internetUserId, Long operatorId, String startTime, String endTime, Long userId, Integer type, Integer source) throws IOException {
|
||||||
List<Map<String, Object>> list =new ArrayList<>();
|
List<Map<String, Object>> list =new ArrayList<>();
|
||||||
if (getJudge(internetUserId, operatorId, type)){
|
|
||||||
|
|
||||||
}else{
|
List<String> chargingStationIdList =new ArrayList<>();
|
||||||
List<String> chargingStationIdList =new ArrayList<>();
|
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
||||||
if(!"".equals(chargingStationIds) && chargingStationIds !=null){
|
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
||||||
chargingStationIdList= Arrays.asList(chargingStationIds.split(","));
|
}
|
||||||
}
|
//获取登陆用户
|
||||||
//获取登陆用户
|
LoginUser loginUser = tokenService.getLoginUser(request);
|
||||||
LoginUser loginUser = tokenService.getLoginUser(request);
|
SysUser sysUser = loginUser.getSysUser();
|
||||||
SysUser sysUser = loginUser.getSysUser();
|
Long sysUserId = sysUser.getUserId();
|
||||||
Long sysUserId = sysUser.getUserId();
|
//获取登陆用户
|
||||||
//获取登陆用户
|
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
||||||
if(!UserTypeUtil.SYS_USER_TYPE_ADMIN.equals(sysUser.getUserId())){
|
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
||||||
if(UserTypeUtil.SYS_USER_TYPE_ONE.equals(sysUser.getUserType())){
|
Long logOperatorId = sysUser.getOperatorId();
|
||||||
Long logOperatorId = sysUser.getOperatorId();
|
//运营商看自己的场站
|
||||||
//运营商看自己的场站
|
list = xhpcStatisticsServiceMapper.getMechanismPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 1,logOperatorId,tenantId,source);
|
||||||
list = xhpcStatisticsServiceMapper.getMechanismPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 1,logOperatorId,tenantId,source);
|
|
||||||
}else{
|
|
||||||
//查询赋值的场站
|
|
||||||
list = xhpcStatisticsServiceMapper.getMechanismPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 2,sysUserId,tenantId,source);
|
|
||||||
}
|
|
||||||
}else{
|
}else{
|
||||||
list =xhpcStatisticsServiceMapper.getMechanismPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 0,sysUserId,tenantId,source);
|
//查询赋值的场站
|
||||||
|
list = xhpcStatisticsServiceMapper.getMechanismPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 2,sysUserId,tenantId,source);
|
||||||
}
|
}
|
||||||
|
}else{
|
||||||
|
list =xhpcStatisticsServiceMapper.getMechanismPage(chargingStationId,chargingPileId,terminalId,chargingStationIdList, internetUserId, operatorId, startTime, endTime, 0,sysUserId,tenantId,source);
|
||||||
}
|
}
|
||||||
// 通过工具类创建writer,默认创建xls格式
|
// 通过工具类创建writer,默认创建xls格式
|
||||||
BigExcelWriter writer = ExcelUtil.getBigWriter("temp_" + System.currentTimeMillis() + ".xlsx");
|
BigExcelWriter writer = ExcelUtil.getBigWriter("temp_" + System.currentTimeMillis() + ".xlsx");
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user