Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
C
clx-performance
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
姜武杰
clx-performance
Commits
157c665e
提交
157c665e
authored
12月 20, 2023
作者:
huyufan
浏览文件
操作
浏览文件
下载
差异文件
Merge remote-tracking branch 'origin/v6.5_transport_open_20231115' into test
上级
c4d6badf
9072e08d
隐藏空白字符变更
内嵌
并排
正在显示
18 个修改的文件
包含
407 行增加
和
45 行删除
+407
-45
PageNetworkAccountInfoListParam.java
...performance/param/pc/PageNetworkAccountInfoListParam.java
+24
-0
PageNetworkAccountListParam.java
...clx/performance/param/pc/PageNetworkAccountListParam.java
+1
-1
PageNetworkCaseOutRecordListParam.java
...rformance/param/pc/PageNetworkCaseOutRecordListParam.java
+24
-0
NetworkCaseOutRecordVO.java
...ava/com/clx/performance/vo/pc/NetworkCaseOutRecordVO.java
+92
-0
NetworkDriverAccountVO.java
...ava/com/clx/performance/vo/pc/NetworkDriverAccountVO.java
+4
-0
NetworkDriverRunningWaterRecordVO.java
.../performance/vo/pc/NetworkDriverRunningWaterRecordVO.java
+79
-0
NetworkSyncComponent.java
...a/com/clx/performance/component/NetworkSyncComponent.java
+44
-0
NetworkDriverAccountController.java
.../controller/pc/driver/NetworkDriverAccountController.java
+20
-5
NetworkDriverRunningWaterRecordDaoImpl.java
...o/impl/settle/NetworkDriverRunningWaterRecordDaoImpl.java
+12
-0
NetworkDriverRunningWaterRecordDao.java
...rmance/dao/settle/NetworkDriverRunningWaterRecordDao.java
+5
-0
NetworkDriverRunningWaterRecordMapper.java
.../mapper/settle/NetworkDriverRunningWaterRecordMapper.java
+9
-0
NetworkCaseOutRecordServiceImpl.java
.../service/impl/settle/NetworkCaseOutRecordServiceImpl.java
+7
-0
NetworkDriverRunningWaterRecordServiceImpl.java
...pl/settle/NetworkDriverRunningWaterRecordServiceImpl.java
+15
-0
SettlementOwnerServiceImpl.java
...mance/service/impl/settle/SettlementOwnerServiceImpl.java
+13
-24
NetworkCaseOutRecordService.java
...rformance/service/settle/NetworkCaseOutRecordService.java
+7
-0
NetworkDriverRunningWaterRecordService.java
...ervice/settle/NetworkDriverRunningWaterRecordService.java
+6
-0
NetworkDriverAccountProvider.java
...ance/sqlProvider/settle/NetworkDriverAccountProvider.java
+11
-15
NetworkDriverRunningWaterRecordProvider.java
...vider/settle/NetworkDriverRunningWaterRecordProvider.java
+34
-0
没有找到文件。
performance-api/src/main/java/com/clx/performance/param/pc/PageNetworkAccountInfoListParam.java
0 → 100644
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
param
.
pc
;
import
com.msl.common.base.PageParam
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.AllArgsConstructor
;
import
lombok.Getter
;
import
lombok.NoArgsConstructor
;
import
lombok.Setter
;
@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
public
class
PageNetworkAccountInfoListParam
extends
PageParam
{
@ApiModelProperty
(
value
=
"手机号"
,
example
=
"13966554477"
)
private
String
mobile
;
@ApiModelProperty
(
value
=
"网络货运流水类型"
)
private
Integer
runningWaterType
;
@ApiModelProperty
(
value
=
"司机编码"
)
private
String
driverUserNo
;
}
performance-api/src/main/java/com/clx/performance/param/pc/PageNetworkAccountListParam.java
浏览文件 @
157c665e
...
@@ -20,5 +20,5 @@ public class PageNetworkAccountListParam extends PageParam {
...
@@ -20,5 +20,5 @@ public class PageNetworkAccountListParam extends PageParam {
private
String
driverUserName
;
private
String
driverUserName
;
@ApiModelProperty
(
value
=
"司机编码"
)
@ApiModelProperty
(
value
=
"司机编码"
)
private
Lo
ng
driverUserNo
;
private
Stri
ng
driverUserNo
;
}
}
performance-api/src/main/java/com/clx/performance/param/pc/PageNetworkCaseOutRecordListParam.java
0 → 100644
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
param
.
pc
;
import
com.msl.common.base.PageParam
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.AllArgsConstructor
;
import
lombok.Getter
;
import
lombok.NoArgsConstructor
;
import
lombok.Setter
;
@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
public
class
PageNetworkCaseOutRecordListParam
extends
PageParam
{
@ApiModelProperty
(
value
=
"手机号"
,
example
=
"13966554477"
)
private
String
mobile
;
@ApiModelProperty
(
value
=
"运单编号"
)
private
String
childNo
;
@ApiModelProperty
(
value
=
"车主编码"
)
private
String
driverUserNo
;
}
performance-api/src/main/java/com/clx/performance/vo/pc/NetworkCaseOutRecordVO.java
0 → 100644
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
vo
.
pc
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Getter
;
import
lombok.Setter
;
import
lombok.experimental.Accessors
;
import
java.math.BigDecimal
;
import
java.time.LocalDateTime
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Getter
@Setter
@Accessors
(
chain
=
true
)
public
class
NetworkCaseOutRecordVO
{
private
Integer
id
;
@ApiModelProperty
(
"提现单号"
)
private
Long
caseOutNo
;
@ApiModelProperty
(
"司机编码"
)
private
String
driverUserNo
;
@ApiModelProperty
(
"司机名称"
)
private
String
driverUserName
;
@ApiModelProperty
(
"联系电话"
)
private
String
mobile
;
@ApiModelProperty
(
"收款人"
)
private
String
payee
;
@ApiModelProperty
(
"开户行"
)
private
String
bank
;
@ApiModelProperty
(
"收款银行账户"
)
private
String
collectionBankCode
;
@ApiModelProperty
(
"状态 10:待平台付款 20:已付款"
)
private
Integer
status
;
@ApiModelProperty
(
"平台"
)
private
String
platform
;
@ApiModelProperty
(
""
)
private
Long
relationId
;
@ApiModelProperty
(
"订单ID"
)
private
Integer
orderId
;
@ApiModelProperty
(
"订单编号"
)
private
String
orderNo
;
@ApiModelProperty
(
"运单ID"
)
private
Integer
orderChildId
;
@ApiModelProperty
(
"运单编号"
)
private
String
orderChildNo
;
@ApiModelProperty
(
"变动金额"
)
private
BigDecimal
alterationBalance
;
@ApiModelProperty
(
"冻结金额"
)
private
BigDecimal
frozenBalance
;
@ApiModelProperty
(
"可用余额"
)
private
BigDecimal
usableBalance
;
@ApiModelProperty
(
"账户余额"
)
private
BigDecimal
accountBalance
;
@ApiModelProperty
(
"扣除金额"
)
private
BigDecimal
takeOutBalance
;
@ApiModelProperty
(
"操作人"
)
private
String
createBy
;
@ApiModelProperty
(
"创建时间"
)
private
String
createTime
;
@ApiModelProperty
(
"提现完成时间"
)
private
String
finishTime
;
@ApiModelProperty
(
"修改时间"
)
private
String
modifiedTime
;
}
performance-api/src/main/java/com/clx/performance/vo/pc/NetworkDriverAccountVO.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
vo
.
pc
;
package
com
.
clx
.
performance
.
vo
.
pc
;
import
com.msl.common.convertor.type.MoneyOutConvert
;
import
io.swagger.annotations.ApiModelProperty
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Getter
;
import
lombok.Getter
;
import
lombok.Setter
;
import
lombok.Setter
;
...
@@ -29,12 +30,15 @@ public class NetworkDriverAccountVO {
...
@@ -29,12 +30,15 @@ public class NetworkDriverAccountVO {
private
String
mobile
;
private
String
mobile
;
@ApiModelProperty
(
"账户余额"
)
@ApiModelProperty
(
"账户余额"
)
@MoneyOutConvert
private
BigDecimal
accountBalance
;
private
BigDecimal
accountBalance
;
@ApiModelProperty
(
"可用余额"
)
@ApiModelProperty
(
"可用余额"
)
@MoneyOutConvert
private
BigDecimal
usableBalance
;
private
BigDecimal
usableBalance
;
@ApiModelProperty
(
"冻结余额"
)
@ApiModelProperty
(
"冻结余额"
)
@MoneyOutConvert
private
BigDecimal
frozenBalance
;
private
BigDecimal
frozenBalance
;
@ApiModelProperty
(
"钱包code"
)
@ApiModelProperty
(
"钱包code"
)
...
...
performance-api/src/main/java/com/clx/performance/vo/pc/NetworkDriverRunningWaterRecordVO.java
0 → 100644
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
vo
.
pc
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Getter
;
import
lombok.Setter
;
import
lombok.experimental.Accessors
;
import
java.math.BigDecimal
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Getter
@Setter
@Accessors
(
chain
=
true
)
public
class
NetworkDriverRunningWaterRecordVO
{
private
Integer
id
;
@ApiModelProperty
(
"流水号"
)
private
Long
runningWaterNo
;
@ApiModelProperty
(
"司机编码"
)
private
String
driverUserNo
;
@ApiModelProperty
(
"司机名称"
)
private
String
driverUserName
;
@ApiModelProperty
(
"联系电话"
)
private
String
mobile
;
@ApiModelProperty
(
"流水类型 10:运单结算 20:提现冻结 30:提现成功"
)
private
Integer
runningWaterType
;
@ApiModelProperty
(
"资金类型 10:收入 20:冻结 30:支出"
)
private
Integer
fundType
;
@ApiModelProperty
(
""
)
private
Long
relationId
;
@ApiModelProperty
(
"订单ID"
)
private
Integer
orderId
;
@ApiModelProperty
(
"订单编号"
)
private
String
orderNo
;
@ApiModelProperty
(
"运单ID"
)
private
Integer
orderChildId
;
@ApiModelProperty
(
"运单编号"
)
private
String
orderChildNo
;
@ApiModelProperty
(
"变动金额"
)
private
BigDecimal
alterationBalance
;
@ApiModelProperty
(
"冻结金额"
)
private
BigDecimal
frozenBalance
;
@ApiModelProperty
(
"可用余额"
)
private
BigDecimal
usableBalance
;
@ApiModelProperty
(
"账户余额"
)
private
BigDecimal
accountBalance
;
@ApiModelProperty
(
"扣除金额"
)
private
BigDecimal
takeOutBalance
;
@ApiModelProperty
(
"操作人"
)
private
String
createBy
;
@ApiModelProperty
(
"创建时间"
)
private
String
createTime
;
@ApiModelProperty
(
"修改时间"
)
private
String
modifiedTime
;
}
performance-web/src/main/java/com/clx/performance/component/NetworkSyncComponent.java
0 → 100644
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
component
;
import
com.clx.performance.feign.TransportFeignService
;
import
com.clx.performance.model.settle.SettlementOwner
;
import
com.clx.performance.model.settle.SettlementOwnerDetail
;
import
com.clx.performance.param.feign.transport.OwnerSettlementSyncParam
;
import
com.clx.user.feign.OwnerFeign
;
import
com.msl.common.dto.HttpDTO
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.stereotype.Component
;
import
java.util.LinkedList
;
import
java.util.List
;
@Component
@Slf4j
@AllArgsConstructor
public
class
NetworkSyncComponent
{
private
final
TransportFeignService
transportFeignService
;
private
final
OwnerFeign
ownerFeign
;
public
void
ownerSettlementSync
(
SettlementOwner
settlementOwner
,
List
<
SettlementOwnerDetail
>
settlementOwnerDetailList
){
//TODO 通知网络货运做货主计费开票标识通知
OwnerSettlementSyncParam
param
=
new
OwnerSettlementSyncParam
();
String
mobile
=
ownerFeign
.
getOwnerInfo
(
settlementOwner
.
getOwnerUserNo
()).
getData
().
getMobile
();
param
.
setOwnerMobile
(
mobile
);
List
<
OwnerSettlementSyncParam
.
SettlementItem
>
settlementList
=
new
LinkedList
<>();
for
(
SettlementOwnerDetail
settlementOwnerDetail
:
settlementOwnerDetailList
)
{
String
childNo
=
settlementOwnerDetail
.
getChildNo
();
OwnerSettlementSyncParam
.
SettlementItem
item
=
new
OwnerSettlementSyncParam
.
SettlementItem
();
item
.
setChildNo
(
childNo
);
item
.
setSettlementNo
(
settlementOwnerDetail
.
getSettlementNo
());
settlementList
.
add
(
item
);
}
param
.
setSettlementList
(
settlementList
);
HttpDTO
httpDTO
=
transportFeignService
.
ownerSettlementSync
(
param
);
String
decrypt
=
ThirdComponent
.
decrypt
(
httpDTO
.
getData
());
log
.
info
(
"通知网络货运做货主计费开票标识通知请求解密后:{}"
,
decrypt
);
}
}
performance-web/src/main/java/com/clx/performance/controller/pc/driver/NetworkDriverAccountController.java
浏览文件 @
157c665e
...
@@ -5,7 +5,9 @@ import com.clx.performance.model.OwnerTransferInfo;
...
@@ -5,7 +5,9 @@ import com.clx.performance.model.OwnerTransferInfo;
import
com.clx.performance.param.pc.*
;
import
com.clx.performance.param.pc.*
;
import
com.clx.performance.param.pc.owner.CreteAccountParam
;
import
com.clx.performance.param.pc.owner.CreteAccountParam
;
import
com.clx.performance.service.*
;
import
com.clx.performance.service.*
;
import
com.clx.performance.service.settle.NetworkCaseOutRecordService
;
import
com.clx.performance.service.settle.NetworkDriverAccountService
;
import
com.clx.performance.service.settle.NetworkDriverAccountService
;
import
com.clx.performance.service.settle.NetworkDriverRunningWaterRecordService
;
import
com.clx.performance.vo.pc.*
;
import
com.clx.performance.vo.pc.*
;
import
com.clx.user.vo.pc.owner.OwnerBindCardVO
;
import
com.clx.user.vo.pc.owner.OwnerBindCardVO
;
import
com.msl.common.base.PageData
;
import
com.msl.common.base.PageData
;
...
@@ -36,6 +38,10 @@ public class NetworkDriverAccountController {
...
@@ -36,6 +38,10 @@ public class NetworkDriverAccountController {
private
final
NetworkDriverAccountService
networkDriverAccountService
;
private
final
NetworkDriverAccountService
networkDriverAccountService
;
private
final
NetworkDriverRunningWaterRecordService
networkDriverRunningWaterRecordService
;
private
final
NetworkCaseOutRecordService
networkCaseOutRecordService
;
@ApiOperation
(
value
=
"网络货运账户列表"
,
notes
=
"<br>By:胡宇帆"
)
@ApiOperation
(
value
=
"网络货运账户列表"
,
notes
=
"<br>By:胡宇帆"
)
...
@@ -47,10 +53,19 @@ public class NetworkDriverAccountController {
...
@@ -47,10 +53,19 @@ public class NetworkDriverAccountController {
}
}
@ApiOperation
(
value
=
"创建账户"
,
notes
=
"<br>By:胡宇帆"
)
@ApiOperation
(
value
=
"网络货运账户详情"
,
notes
=
"<br>By:胡宇帆"
)
@PostMapping
(
"/createAccount"
)
@PostMapping
(
"/networkAccountInfoList"
)
public
Result
<
Object
>
createAccount
(
CreteAccountParam
param
)
{
@UnitCovert
(
param
=
false
)
//ownerAccountService.createAccount(param);
public
Result
<
PageData
<
NetworkDriverRunningWaterRecordVO
>>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
)
{
return
Result
.
ok
();
IPage
<
NetworkDriverRunningWaterRecordVO
>
page
=
networkDriverRunningWaterRecordService
.
networkAccountInfoList
(
param
);
return
Result
.
page
(
page
.
getRecords
(),
page
.
getTotal
(),
page
.
getPages
());
}
@ApiOperation
(
value
=
"车主提现"
,
notes
=
"<br>By:胡宇帆"
)
@PostMapping
(
"/networkCaseOutRecord"
)
@UnitCovert
(
param
=
false
)
public
Result
<
PageData
<
NetworkCaseOutRecordVO
>>
networkCaseOutRecord
(
PageNetworkCaseOutRecordListParam
param
)
{
IPage
<
NetworkCaseOutRecordVO
>
page
=
networkCaseOutRecordService
.
networkCaseOutRecord
(
param
);
return
Result
.
page
(
page
.
getRecords
(),
page
.
getTotal
(),
page
.
getPages
());
}
}
}
}
performance-web/src/main/java/com/clx/performance/dao/impl/settle/NetworkDriverRunningWaterRecordDaoImpl.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
dao
.
impl
.
settle
;
package
com
.
clx
.
performance
.
dao
.
impl
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.clx.performance.dao.settle.NetworkDriverRunningWaterRecordDao
;
import
com.clx.performance.dao.settle.NetworkDriverRunningWaterRecordDao
;
import
com.clx.performance.mapper.settle.NetworkDriverRunningWaterRecordMapper
;
import
com.clx.performance.mapper.settle.NetworkDriverRunningWaterRecordMapper
;
import
com.clx.performance.model.settle.NetworkDriverRunningWaterRecord
;
import
com.clx.performance.model.settle.NetworkDriverRunningWaterRecord
;
import
com.clx.performance.param.pc.PageNetworkAccountInfoListParam
;
import
com.clx.performance.vo.pc.NetworkDriverAccountVO
;
import
com.clx.performance.vo.pc.NetworkDriverRunningWaterRecordVO
;
import
com.msl.common.dao.impl.BaseDaoImpl
;
import
com.msl.common.dao.impl.BaseDaoImpl
;
import
org.springframework.stereotype.Repository
;
import
org.springframework.stereotype.Repository
;
...
@@ -14,4 +19,11 @@ import org.springframework.stereotype.Repository;
...
@@ -14,4 +19,11 @@ import org.springframework.stereotype.Repository;
*/
*/
@Repository
@Repository
public
class
NetworkDriverRunningWaterRecordDaoImpl
extends
BaseDaoImpl
<
NetworkDriverRunningWaterRecordMapper
,
NetworkDriverRunningWaterRecord
,
Integer
>
implements
NetworkDriverRunningWaterRecordDao
{
public
class
NetworkDriverRunningWaterRecordDaoImpl
extends
BaseDaoImpl
<
NetworkDriverRunningWaterRecordMapper
,
NetworkDriverRunningWaterRecord
,
Integer
>
implements
NetworkDriverRunningWaterRecordDao
{
@Override
public
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
)
{
Page
<
NetworkDriverRunningWaterRecordVO
>
page
=
Page
.
of
(
param
.
getPage
(),
param
.
getPageSize
());
return
baseMapper
.
networkAccountInfoList
(
page
,
param
);
}
}
}
performance-web/src/main/java/com/clx/performance/dao/settle/NetworkDriverRunningWaterRecordDao.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
dao
.
settle
;
package
com
.
clx
.
performance
.
dao
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.mapper.settle.NetworkDriverRunningWaterRecordMapper
;
import
com.clx.performance.mapper.settle.NetworkDriverRunningWaterRecordMapper
;
import
com.clx.performance.model.settle.NetworkDriverRunningWaterRecord
;
import
com.clx.performance.model.settle.NetworkDriverRunningWaterRecord
;
import
com.clx.performance.param.pc.PageNetworkAccountInfoListParam
;
import
com.clx.performance.vo.pc.NetworkDriverRunningWaterRecordVO
;
import
com.msl.common.dao.BaseDao
;
import
com.msl.common.dao.BaseDao
;
/**
/**
...
@@ -11,4 +14,6 @@ import com.msl.common.dao.BaseDao;
...
@@ -11,4 +14,6 @@ import com.msl.common.dao.BaseDao;
* Time 11:34
* Time 11:34
*/
*/
public
interface
NetworkDriverRunningWaterRecordDao
extends
BaseDao
<
NetworkDriverRunningWaterRecordMapper
,
NetworkDriverRunningWaterRecord
,
Integer
>
{
public
interface
NetworkDriverRunningWaterRecordDao
extends
BaseDao
<
NetworkDriverRunningWaterRecordMapper
,
NetworkDriverRunningWaterRecord
,
Integer
>
{
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
);
}
}
performance-web/src/main/java/com/clx/performance/mapper/settle/NetworkDriverRunningWaterRecordMapper.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
mapper
.
settle
;
package
com
.
clx
.
performance
.
mapper
.
settle
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.clx.performance.model.settle.NetworkDriverRunningWaterRecord
;
import
com.clx.performance.model.settle.NetworkDriverRunningWaterRecord
;
import
com.clx.performance.param.pc.PageNetworkAccountInfoListParam
;
import
com.clx.performance.sqlProvider.settle.NetworkDriverRunningWaterRecordProvider
;
import
com.clx.performance.vo.pc.NetworkDriverRunningWaterRecordVO
;
import
org.apache.ibatis.annotations.SelectProvider
;
/**
/**
* @author kavin
* @author kavin
...
@@ -9,4 +15,7 @@ import com.clx.performance.model.settle.NetworkDriverRunningWaterRecord;
...
@@ -9,4 +15,7 @@ import com.clx.performance.model.settle.NetworkDriverRunningWaterRecord;
* Time 11:34
* Time 11:34
*/
*/
public
interface
NetworkDriverRunningWaterRecordMapper
extends
BaseMapper
<
NetworkDriverRunningWaterRecord
>
{
public
interface
NetworkDriverRunningWaterRecordMapper
extends
BaseMapper
<
NetworkDriverRunningWaterRecord
>
{
@SelectProvider
(
type
=
NetworkDriverRunningWaterRecordProvider
.
class
,
method
=
"networkAccountInfoList"
)
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
Page
<
NetworkDriverRunningWaterRecordVO
>
page
,
PageNetworkAccountInfoListParam
param
);
}
}
performance-web/src/main/java/com/clx/performance/service/impl/settle/NetworkCaseOutRecordServiceImpl.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
service
.
impl
.
settle
;
package
com
.
clx
.
performance
.
service
.
impl
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.param.pc.PageNetworkCaseOutRecordListParam
;
import
com.clx.performance.service.settle.NetworkCaseOutRecordService
;
import
com.clx.performance.service.settle.NetworkCaseOutRecordService
;
import
com.clx.performance.vo.pc.NetworkCaseOutRecordVO
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
/**
/**
...
@@ -10,4 +13,8 @@ import org.springframework.stereotype.Service;
...
@@ -10,4 +13,8 @@ import org.springframework.stereotype.Service;
*/
*/
@Service
@Service
public
class
NetworkCaseOutRecordServiceImpl
implements
NetworkCaseOutRecordService
{
public
class
NetworkCaseOutRecordServiceImpl
implements
NetworkCaseOutRecordService
{
@Override
public
IPage
<
NetworkCaseOutRecordVO
>
networkCaseOutRecord
(
PageNetworkCaseOutRecordListParam
param
)
{
return
null
;
}
}
}
performance-web/src/main/java/com/clx/performance/service/impl/settle/NetworkDriverRunningWaterRecordServiceImpl.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
service
.
impl
.
settle
;
package
com
.
clx
.
performance
.
service
.
impl
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.dao.settle.NetworkDriverRunningWaterRecordDao
;
import
com.clx.performance.param.pc.PageNetworkAccountInfoListParam
;
import
com.clx.performance.service.settle.NetworkDriverRunningWaterRecordService
;
import
com.clx.performance.service.settle.NetworkDriverRunningWaterRecordService
;
import
com.clx.performance.vo.pc.NetworkDriverRunningWaterRecordVO
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
/**
/**
...
@@ -9,5 +15,14 @@ import org.springframework.stereotype.Service;
...
@@ -9,5 +15,14 @@ import org.springframework.stereotype.Service;
* Time 11:34
* Time 11:34
*/
*/
@Service
@Service
@AllArgsConstructor
@Slf4j
public
class
NetworkDriverRunningWaterRecordServiceImpl
implements
NetworkDriverRunningWaterRecordService
{
public
class
NetworkDriverRunningWaterRecordServiceImpl
implements
NetworkDriverRunningWaterRecordService
{
private
final
NetworkDriverRunningWaterRecordDao
networkDriverRunningWaterRecordDao
;
@Override
public
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
)
{
return
networkDriverRunningWaterRecordDao
.
networkAccountInfoList
(
param
);
}
}
}
performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerServiceImpl.java
浏览文件 @
157c665e
...
@@ -3,7 +3,7 @@ package com.clx.performance.service.impl.settle;
...
@@ -3,7 +3,7 @@ package com.clx.performance.service.impl.settle;
import
cn.hutool.core.collection.CollectionUtil
;
import
cn.hutool.core.collection.CollectionUtil
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.clx.performance.component.
Third
Component
;
import
com.clx.performance.component.
NetworkSync
Component
;
import
com.clx.performance.dao.settle.SettlementLogDao
;
import
com.clx.performance.dao.settle.SettlementLogDao
;
import
com.clx.performance.dao.settle.SettlementOwnerDao
;
import
com.clx.performance.dao.settle.SettlementOwnerDao
;
import
com.clx.performance.dao.settle.SettlementOwnerDetailDao
;
import
com.clx.performance.dao.settle.SettlementOwnerDetailDao
;
...
@@ -12,12 +12,10 @@ import com.clx.performance.dto.InvoicingStatusNotifyDTO;
...
@@ -12,12 +12,10 @@ import com.clx.performance.dto.InvoicingStatusNotifyDTO;
import
com.clx.performance.enums.OrderChildLogEnum
;
import
com.clx.performance.enums.OrderChildLogEnum
;
import
com.clx.performance.enums.PerformanceResultEnum
;
import
com.clx.performance.enums.PerformanceResultEnum
;
import
com.clx.performance.enums.settle.*
;
import
com.clx.performance.enums.settle.*
;
import
com.clx.performance.feign.TransportFeignService
;
import
com.clx.performance.model.settle.SettlementLog
;
import
com.clx.performance.model.settle.SettlementLog
;
import
com.clx.performance.model.settle.SettlementOwner
;
import
com.clx.performance.model.settle.SettlementOwner
;
import
com.clx.performance.model.settle.SettlementOwnerDetail
;
import
com.clx.performance.model.settle.SettlementOwnerDetail
;
import
com.clx.performance.model.settle.SettlementPlatformAccount
;
import
com.clx.performance.model.settle.SettlementPlatformAccount
;
import
com.clx.performance.param.feign.transport.OwnerSettlementSyncParam
;
import
com.clx.performance.param.pc.owner.*
;
import
com.clx.performance.param.pc.owner.*
;
import
com.clx.performance.service.OwnerAccountService
;
import
com.clx.performance.service.OwnerAccountService
;
import
com.clx.performance.service.settle.SettlementLogService
;
import
com.clx.performance.service.settle.SettlementLogService
;
...
@@ -31,9 +29,7 @@ import com.clx.performance.utils.excel.ExcelUtil;
...
@@ -31,9 +29,7 @@ import com.clx.performance.utils.excel.ExcelUtil;
import
com.clx.performance.vo.pc.carrier.settle.*
;
import
com.clx.performance.vo.pc.carrier.settle.*
;
import
com.clx.performance.vo.pc.owner.settle.OwnerPageSettlementOwnerVO
;
import
com.clx.performance.vo.pc.owner.settle.OwnerPageSettlementOwnerVO
;
import
com.clx.performance.vo.pc.owner.settle.SettlementPlatformAccountVO
;
import
com.clx.performance.vo.pc.owner.settle.SettlementPlatformAccountVO
;
import
com.clx.user.feign.OwnerFeign
;
import
com.clx.user.vo.pc.owner.OwnerBindCardVO
;
import
com.clx.user.vo.pc.owner.OwnerBindCardVO
;
import
com.msl.common.dto.HttpDTO
;
import
com.msl.common.exception.ServiceSystemException
;
import
com.msl.common.exception.ServiceSystemException
;
import
com.msl.user.data.UserSessionData
;
import
com.msl.user.data.UserSessionData
;
import
com.msl.user.utils.TokenUtil
;
import
com.msl.user.utils.TokenUtil
;
...
@@ -45,7 +41,6 @@ import org.springframework.transaction.annotation.Transactional;
...
@@ -45,7 +41,6 @@ import org.springframework.transaction.annotation.Transactional;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.LinkedList
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Objects
;
import
java.util.Objects
;
...
@@ -75,9 +70,7 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
...
@@ -75,9 +70,7 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
private
final
OwnerAccountService
ownerAccountService
;
private
final
OwnerAccountService
ownerAccountService
;
private
final
OwnerFeign
ownerFeign
;
private
final
NetworkSyncComponent
networkSyncComponent
;
private
final
TransportFeignService
transportFeignService
;
@Override
@Override
public
CarrierSettlementOwnerDetailVO
getCarrierSettlementOwnerDetail
(
Integer
id
)
{
public
CarrierSettlementOwnerDetailVO
getCarrierSettlementOwnerDetail
(
Integer
id
)
{
...
@@ -136,6 +129,16 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
...
@@ -136,6 +129,16 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
if
(
settlementOwner
.
getSettlementFreight
().
compareTo
(
BigDecimal
.
ZERO
)
==
0
){
if
(
settlementOwner
.
getSettlementFreight
().
compareTo
(
BigDecimal
.
ZERO
)
==
0
){
settlementOwnerDetailDao
.
updateFinalPaymentStatusBySettlementNo
(
settlementNo
,
SettlementOwnerDetailEnum
.
FinalPaymentStatus
.
NO_REQUIRE
.
getCode
());
settlementOwnerDetailDao
.
updateFinalPaymentStatusBySettlementNo
(
settlementNo
,
SettlementOwnerDetailEnum
.
FinalPaymentStatus
.
NO_REQUIRE
.
getCode
());
}
}
}
else
{
if
(
settlementOwner
.
getSettlementFreight
().
compareTo
(
BigDecimal
.
ZERO
)
==
0
&&
settlementOwner
.
getInvoiceFreight
().
compareTo
(
BigDecimal
.
ZERO
)
>=
0
)
{
//TODO 通知网络货运做货主计费开票标识通知
List
<
SettlementOwnerDetail
>
settlementOwnerDetailList
=
settlementOwnerDetailDao
.
getBySettlementNoAndInvoiceType
(
settlementNo
,
SettlementDriverEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwnerDetailEnum
.
InvoiceStatus
.
NO
.
getCode
());
networkSyncComponent
.
ownerSettlementSync
(
settlementOwner
,
settlementOwnerDetailList
);
}
}
}
//更新状态
//更新状态
...
@@ -483,24 +486,10 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
...
@@ -483,24 +486,10 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
}
else
{
}
else
{
if
(
Objects
.
equals
(
settlementOwner
.
getInvoiceType
(),
SettlementOwnerEnum
.
InvoiceType
.
ONLINE
.
getCode
()))
{
if
(
Objects
.
equals
(
settlementOwner
.
getInvoiceType
(),
SettlementOwnerEnum
.
InvoiceType
.
ONLINE
.
getCode
()))
{
settlementOwnerDao
.
updateStatusBySettlementNo
(
settlementNo
,
SettlementOwnerEnum
.
Status
.
COMPLETED
.
getCode
());
settlementOwnerDao
.
updateStatusBySettlementNo
(
settlementNo
,
SettlementOwnerEnum
.
Status
.
COMPLETED
.
getCode
());
String
mobile
=
ownerFeign
.
getOwnerInfo
(
settlementOwner
.
getOwnerUserNo
()).
getData
().
getMobile
();
//TODO 通知网络货运做货主计费开票标识通知
//TODO 通知网络货运做货主计费开票标识通知
OwnerSettlementSyncParam
param
=
new
OwnerSettlementSyncParam
();
param
.
setOwnerMobile
(
mobile
);
List
<
OwnerSettlementSyncParam
.
SettlementItem
>
settlementList
=
new
LinkedList
<>();
List
<
SettlementOwnerDetail
>
settlementOwnerDetailList
=
settlementOwnerDetailDao
.
getBySettlementNoAndInvoiceType
(
settlementNo
,
List
<
SettlementOwnerDetail
>
settlementOwnerDetailList
=
settlementOwnerDetailDao
.
getBySettlementNoAndInvoiceType
(
settlementNo
,
SettlementDriverEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwnerDetailEnum
.
InvoiceStatus
.
NO
.
getCode
());
SettlementDriverEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwnerDetailEnum
.
InvoiceStatus
.
NO
.
getCode
());
for
(
SettlementOwnerDetail
settlementOwnerDetail
:
settlementOwnerDetailList
)
{
networkSyncComponent
.
ownerSettlementSync
(
settlementOwner
,
settlementOwnerDetailList
);
String
childNo
=
settlementOwnerDetail
.
getChildNo
();
OwnerSettlementSyncParam
.
SettlementItem
item
=
new
OwnerSettlementSyncParam
.
SettlementItem
();
item
.
setChildNo
(
childNo
);
item
.
setSettlementNo
(
settlementOwnerDetail
.
getSettlementNo
());
settlementList
.
add
(
item
);
}
param
.
setSettlementList
(
settlementList
);
HttpDTO
httpDTO
=
transportFeignService
.
ownerSettlementSync
(
param
);
String
decrypt
=
ThirdComponent
.
decrypt
(
httpDTO
.
getData
());
log
.
info
(
"通知网络货运做货主计费开票标识通知请求解密后:{}"
,
decrypt
);
}
else
{
}
else
{
settlementOwnerDao
.
updateStatusBySettlementNo
(
settlementNo
,
SettlementOwnerEnum
.
Status
.
INVOICE_TO_BE_MAILED
.
getCode
());
settlementOwnerDao
.
updateStatusBySettlementNo
(
settlementNo
,
SettlementOwnerEnum
.
Status
.
INVOICE_TO_BE_MAILED
.
getCode
());
...
...
performance-web/src/main/java/com/clx/performance/service/settle/NetworkCaseOutRecordService.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
service
.
settle
;
package
com
.
clx
.
performance
.
service
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.param.pc.PageNetworkCaseOutRecordListParam
;
import
com.clx.performance.vo.pc.NetworkCaseOutRecordVO
;
/**
/**
* @author kavin
* @author kavin
* Date 2023-12-19
* Date 2023-12-19
* Time 11:34
* Time 11:34
*/
*/
public
interface
NetworkCaseOutRecordService
{
public
interface
NetworkCaseOutRecordService
{
IPage
<
NetworkCaseOutRecordVO
>
networkCaseOutRecord
(
PageNetworkCaseOutRecordListParam
param
);
}
}
performance-web/src/main/java/com/clx/performance/service/settle/NetworkDriverRunningWaterRecordService.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
service
.
settle
;
package
com
.
clx
.
performance
.
service
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.param.pc.PageNetworkAccountInfoListParam
;
import
com.clx.performance.vo.pc.NetworkDriverRunningWaterRecordVO
;
/**
/**
* @author kavin
* @author kavin
* Date 2023-12-19
* Date 2023-12-19
* Time 11:34
* Time 11:34
*/
*/
public
interface
NetworkDriverRunningWaterRecordService
{
public
interface
NetworkDriverRunningWaterRecordService
{
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
);
}
}
performance-web/src/main/java/com/clx/performance/sqlProvider/settle/NetworkDriverAccountProvider.java
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
sqlProvider
.
settle
;
package
com
.
clx
.
performance
.
sqlProvider
.
settle
;
import
cn.hutool.core.util.ObjectUtil
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
com.clx.performance.param.pc.PageOwnerAccountListParam
;
import
com.clx.performance.param.pc.PageOwnerCaseOutListParam
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.ibatis.annotations.Param
;
import
org.apache.ibatis.annotations.Param
;
import
org.apache.ibatis.jdbc.SQL
;
import
org.apache.ibatis.jdbc.SQL
;
public
class
NetworkDriverAccountProvider
{
public
class
NetworkDriverAccountProvider
{
public
String
networkAccountList
(
@Param
(
"param"
)
Page
Owner
AccountListParam
param
)
{
public
String
networkAccountList
(
@Param
(
"param"
)
Page
Network
AccountListParam
param
)
{
String
sql
=
new
SQL
()
{{
String
sql
=
new
SQL
()
{{
SELECT
(
"a.id, a.
own
er_user_no,"
+
SELECT
(
"a.id, a.
driv
er_user_no,"
+
" a.
owner_user_name, a.mobile, a.account_typ
e, "
+
" a.
driver_user_name, a.mobile, a.account_balanc
e, "
+
" a.
account_balance,a.usable_balance, a.frozen_balanc
e,a.create_by,date_format(a.create_time, '%Y-%m-%d %H:%i:%s') as create_time"
);
" a.
usable_balance,a.frozen_balance,a.wallet_cod
e,a.create_by,date_format(a.create_time, '%Y-%m-%d %H:%i:%s') as create_time"
);
FROM
(
"
own
er_account a"
);
FROM
(
"
network_driv
er_account a"
);
if
(
StringUtils
.
isNotBlank
(
param
.
get
Own
erUserNo
()))
{
if
(
StringUtils
.
isNotBlank
(
param
.
get
Driv
erUserNo
()))
{
WHERE
(
"a.
owner_user_no = #{param.own
erUserNo}"
);
WHERE
(
"a.
driver_user_no = #{param.driv
erUserNo}"
);
}
}
if
(
StringUtils
.
isNotBlank
(
param
.
getMobile
()))
{
if
(
StringUtils
.
isNotBlank
(
param
.
getMobile
()))
{
WHERE
(
"a.mobile = #{param.mobile}"
);
WHERE
(
"a.mobile = #{param.mobile}"
);
}
}
if
(
ObjectUtil
.
isNotNull
(
param
.
getAccountType
()))
{
WHERE
(
"a.account_type = #{param.accountType}"
);
if
(
StringUtils
.
isNotBlank
(
param
.
getDriverUserName
()))
{
}
WHERE
(
"a.driver_user_name like CONCAT('%',#{param.driverUserName},'%')"
);
if
(
StringUtils
.
isNotBlank
(
param
.
getOwnerUserName
()))
{
WHERE
(
"a.owner_user_name like CONCAT('%',#{param.ownerUserName},'%')"
);
}
}
ORDER_BY
(
"a.create_time desc"
);
ORDER_BY
(
"a.create_time desc"
);
}}.
toString
();
}}.
toString
();
...
...
performance-web/src/main/java/com/clx/performance/sqlProvider/settle/NetworkDriverRunningWaterRecordProvider.java
0 → 100644
浏览文件 @
157c665e
package
com
.
clx
.
performance
.
sqlProvider
.
settle
;
import
cn.hutool.core.util.ObjectUtil
;
import
com.clx.performance.param.pc.PageNetworkAccountInfoListParam
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.ibatis.annotations.Param
;
import
org.apache.ibatis.jdbc.SQL
;
public
class
NetworkDriverRunningWaterRecordProvider
{
public
String
networkAccountInfoList
(
@Param
(
"param"
)
PageNetworkAccountInfoListParam
param
)
{
String
sql
=
new
SQL
()
{{
SELECT
(
"a.id, a.running_water_no,"
+
" a.driver_user_no,a.driver_user_name, a.mobile,a.running_water_type, a.account_balance, "
+
" a.fund_type,a.relation_id,a.order_id,a.order_no,a.order_child_id,a.order_child_no,a.alteration_balance"
+
"a.usable_balance,a.frozen_balance,a.take_out_balance,a.create_by,date_format(a.create_time, '%Y-%m-%d %H:%i:%s') as create_time"
);
FROM
(
"network_driver_running_water_record a"
);
if
(
StringUtils
.
isNotBlank
(
param
.
getDriverUserNo
()))
{
WHERE
(
"a.driver_user_no = #{param.driverUserNo}"
);
}
if
(
StringUtils
.
isNotBlank
(
param
.
getMobile
()))
{
WHERE
(
"a.mobile = #{param.mobile}"
);
}
if
(
ObjectUtil
.
isNotNull
(
param
.
getRunningWaterType
()))
{
WHERE
(
"a.running_water_type = #{param.runningWaterType}"
);
}
ORDER_BY
(
"a.create_time desc"
);
}}.
toString
();
return
sql
;
}
}
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论