@ -1,5 +1,6 @@
package com.bellmann.service.impl ;
package com.bellmann.service.impl ;
import cn.hutool.core.map.MapUtil ;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper ;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper ;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper ;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper ;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper ;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper ;
@ -18,6 +19,7 @@ import com.bellmann.model.entity.DeviceStatic;
import com.bellmann.model.entity.OrderInfo ;
import com.bellmann.model.entity.OrderInfo ;
import com.bellmann.model.entity.OrderService ;
import com.bellmann.model.entity.OrderService ;
import com.bellmann.model.form.ModifyOrderForm ;
import com.bellmann.model.form.ModifyOrderForm ;
import com.bellmann.model.query.DeviceOrderQuery ;
import com.bellmann.model.query.SelectQuery ;
import com.bellmann.model.query.SelectQuery ;
import com.bellmann.model.vo.OrderInfoTableVO ;
import com.bellmann.model.vo.OrderInfoTableVO ;
import com.bellmann.model.vo.OrderInfoVO ;
import com.bellmann.model.vo.OrderInfoVO ;
@ -33,6 +35,7 @@ import org.springframework.stereotype.Service;
import java.util.Date ;
import java.util.Date ;
import java.util.List ;
import java.util.List ;
import java.util.Map ;
/ * *
/ * *
* < p >
* < p >
@ -68,32 +71,7 @@ public class OrderInfoServiceImpl implements OrderInfoService {
Page < OrderInfoTableVO > page = new Page < > ( pageNum , pageSize ) ;
Page < OrderInfoTableVO > page = new Page < > ( pageNum , pageSize ) ;
Long domain = SecurityUtils . getGroupId ( ) ;
Long domain = SecurityUtils . getGroupId ( ) ;
List < OrderInfoTableVO > list = orderInfoMapper . tablePage ( page , column , value , domain ) ;
List < OrderInfoTableVO > list = orderInfoMapper . tablePage ( page , column , value , domain ) ;
list . forEach ( obj - > {
return getOrderInfoTableVOPage ( page , list ) ;
Long systemDomain = obj . getSystemDomain ( ) ;
String orderServiceType = obj . getOrderServiceType ( ) ;
String orderStatus = obj . getOrderStatus ( ) ;
String orderRemark = obj . getOrderRemark ( ) ;
String dummyFlag = obj . getDummyFlag ( ) ;
if ( systemDomain ! = null ) {
obj . setDomain ( ( String ) redisTemplate . opsForHash ( ) . get ( SecurityConstants . DOMAIN_PREFIX , systemDomain . toString ( ) ) ) ;
}
if ( orderServiceType ! = null ) {
obj . setOrderServiceType ( IBaseEnum . getLabelByValue ( orderServiceType , OrderServiceTypeEnum . class ) ) ;
}
if ( orderStatus ! = null ) {
obj . setOrderStatus ( IBaseEnum . getLabelByValue ( orderStatus , OrderStatusEnum . class ) ) ;
}
if ( orderRemark ! = null ) {
obj . setOrderRemark ( IBaseEnum . getLabelByValue ( orderRemark , OrderOperateEnum . class ) ) ;
}
//如果是虚拟工单 不显示 pppoe帐户 和 电话号码 反之则显示 0虚拟单 1是非虚拟单
if ( "0" . equals ( dummyFlag ) ) {
obj . setTelNum ( "" ) ;
obj . setPppoeAccount ( "" ) ;
}
obj . setDevOnLineStatus ( devOnlineStatus ( obj . getDevSnoOui ( ) , obj . getPppoeAccount ( ) ) ) ;
} ) ;
return page . setRecords ( list ) ;
}
}
private String devOnlineStatus ( String devSnoOui , String pppoe ) {
private String devOnlineStatus ( String devSnoOui , String pppoe ) {
@ -101,9 +79,18 @@ public class OrderInfoServiceImpl implements OrderInfoService {
String devSno = "" ;
String devSno = "" ;
String status = "无设备上线记录" ;
String status = "无设备上线记录" ;
if ( devSnoOui = = null | | devSnoOui . isEmpty ( ) ) {
if ( devSnoOui = = null | | devSnoOui . isEmpty ( ) ) {
return status ;
if ( pppoe = = null | | pppoe . isEmpty ( ) ) {
return status ;
}
}
if ( ! devSnoOui . contains ( "-" ) ) {
devSno = devSnoOui . trim ( ) ;
} else {
String [ ] devOS = devSnoOui . trim ( ) . split ( "-" ) ;
devOui = devOS [ 0 ] ;
devSno = devOS [ 1 ] ;
}
}
return null ;
return "无设备上线记录" ;
}
}
@Override
@Override
@ -394,4 +381,69 @@ public class OrderInfoServiceImpl implements OrderInfoService {
throw new BusinessException ( ResultCode . LOGICID_ALREADY_DEVICE ) ;
throw new BusinessException ( ResultCode . LOGICID_ALREADY_DEVICE ) ;
}
}
}
}
@Override
public Page < OrderInfoTableVO > deviceOrderPage ( DeviceOrderQuery query ) {
int pageNum = query . getPageNum ( ) ;
int pageSize = query . getPageSize ( ) ;
Page < OrderInfoTableVO > page = new Page < > ( pageNum , pageSize ) ;
Long domain = SecurityUtils . getGroupId ( ) ;
String devSnoOui = query . getDevOui ( ) + "-" + query . getDevSno ( ) ;
String pppoeAccount = query . getPppoeAccount ( ) ;
List < OrderInfoTableVO > list = orderInfoMapper . deviceOrderPage ( page , devSnoOui , pppoeAccount , domain ) ;
return getOrderInfoTableVOPage ( page , list ) ;
}
private Page < OrderInfoTableVO > getOrderInfoTableVOPage ( Page < OrderInfoTableVO > page , List < OrderInfoTableVO > list ) {
list . forEach ( obj - > {
Long systemDomain = obj . getSystemDomain ( ) ;
String orderServiceType = obj . getOrderServiceType ( ) ;
String orderStatus = obj . getOrderStatus ( ) ;
String orderRemark = obj . getOrderRemark ( ) ;
String dummyFlag = obj . getDummyFlag ( ) ;
if ( systemDomain ! = null ) {
obj . setDomain ( ( String ) redisTemplate . opsForHash ( ) . get ( SecurityConstants . DOMAIN_PREFIX , systemDomain . toString ( ) ) ) ;
}
if ( orderServiceType ! = null ) {
obj . setOrderServiceType ( IBaseEnum . getLabelByValue ( orderServiceType , OrderServiceTypeEnum . class ) ) ;
}
if ( orderStatus ! = null ) {
obj . setOrderStatus ( IBaseEnum . getLabelByValue ( orderStatus , OrderStatusEnum . class ) ) ;
}
if ( orderRemark ! = null ) {
obj . setOrderRemark ( IBaseEnum . getLabelByValue ( orderRemark , OrderOperateEnum . class ) ) ;
}
//如果是虚拟工单 不显示 pppoe帐户 和 电话号码 反之则显示 0虚拟单 1是非虚拟单
if ( "0" . equals ( dummyFlag ) ) {
obj . setTelNum ( "" ) ;
obj . setPppoeAccount ( "" ) ;
}
obj . setDevOnLineStatus ( devOnlineStatus ( obj . getDevSnoOui ( ) , obj . getPppoeAccount ( ) ) ) ;
} ) ;
return page . setRecords ( list ) ;
}
@Override
public Result < Map < Object , Object > > checkDev ( String devSnoOui ) {
if ( devSnoOui = = null | | ! devSnoOui . contains ( "-" ) ) {
return Result . failed ( ResultCode . NOT_GET_DEVICE ) ;
}
String [ ] split = devSnoOui . split ( "-" ) ;
DeviceStatic deviceStatic = deviceStaticMapper . selectOne ( new QueryWrapper < DeviceStatic > ( )
. eq ( "dev_sno" , split [ 1 ] )
. eq ( "dev_remark3" , split [ 0 ] )
. select ( "dev_id" , "type_and_ver_id" )
) ;
if ( deviceStatic ! = null ) {
Map < Object , Object > map = MapUtil
. builder ( )
. put ( "devId" , deviceStatic . getDevId ( ) )
. put ( "typeAndVerId" , deviceStatic . getTypeAndVerId ( ) )
. build ( ) ;
return Result . success ( map ) ;
}
return Result . failed ( ResultCode . NOT_GET_DEVICE ) ;
}
}
}