Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
C
clx-performance
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
姜武杰
clx-performance
Commits
fd991f28
提交
fd991f28
authored
12月 20, 2023
作者:
liuhaiquan
浏览文件
操作
浏览文件
下载
差异文件
Merge remote-tracking branch 'origin/test' into test
上级
d8d2ff21
157c665e
隐藏空白字符变更
内嵌
并排
正在显示
38 个修改的文件
包含
1122 行增加
和
33 行删除
+1122
-33
PageNetworkAccountInfoListParam.java
...performance/param/pc/PageNetworkAccountInfoListParam.java
+24
-0
PageNetworkAccountListParam.java
...clx/performance/param/pc/PageNetworkAccountListParam.java
+24
-0
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
+56
-0
NetworkDriverRunningWaterRecordVO.java
.../performance/vo/pc/NetworkDriverRunningWaterRecordVO.java
+79
-0
OwnerAccountVO.java
...c/main/java/com/clx/performance/vo/pc/OwnerAccountVO.java
+1
-0
NetworkSyncComponent.java
...a/com/clx/performance/component/NetworkSyncComponent.java
+44
-0
CarrierSettlementOwnerController.java
...ntroller/pc/carrier/CarrierSettlementOwnerController.java
+0
-1
NetworkDriverAccountController.java
.../controller/pc/driver/NetworkDriverAccountController.java
+71
-0
TransportSyncController.java
...ance/controller/pc/transport/TransportSyncController.java
+0
-1
NetworkCaseOutRecordDaoImpl.java
...formance/dao/impl/settle/NetworkCaseOutRecordDaoImpl.java
+17
-0
NetworkDriverAccountDaoImpl.java
...formance/dao/impl/settle/NetworkDriverAccountDaoImpl.java
+27
-0
NetworkDriverRunningWaterRecordDaoImpl.java
...o/impl/settle/NetworkDriverRunningWaterRecordDaoImpl.java
+29
-0
SettlementOwnerDetailDaoImpl.java
...ormance/dao/impl/settle/SettlementOwnerDetailDaoImpl.java
+1
-1
NetworkCaseOutRecordDao.java
...m/clx/performance/dao/settle/NetworkCaseOutRecordDao.java
+14
-0
NetworkDriverAccountDao.java
...m/clx/performance/dao/settle/NetworkDriverAccountDao.java
+20
-0
NetworkDriverRunningWaterRecordDao.java
...rmance/dao/settle/NetworkDriverRunningWaterRecordDao.java
+19
-0
FeignInterceptor.java
...main/java/com/clx/performance/feign/FeignInterceptor.java
+1
-0
NetworkCaseOutRecordMapper.java
...performance/mapper/settle/NetworkCaseOutRecordMapper.java
+12
-0
NetworkDriverAccountMapper.java
...performance/mapper/settle/NetworkDriverAccountMapper.java
+21
-0
NetworkDriverRunningWaterRecordMapper.java
.../mapper/settle/NetworkDriverRunningWaterRecordMapper.java
+21
-0
NetworkCaseOutRecord.java
...om/clx/performance/model/settle/NetworkCaseOutRecord.java
+128
-0
NetworkDriverAccount.java
...om/clx/performance/model/settle/NetworkDriverAccount.java
+76
-0
NetworkDriverRunningWaterRecord.java
...ormance/model/settle/NetworkDriverRunningWaterRecord.java
+112
-0
NetworkCaseOutRecordServiceImpl.java
.../service/impl/settle/NetworkCaseOutRecordServiceImpl.java
+20
-0
NetworkDriverAccountServiceImpl.java
.../service/impl/settle/NetworkDriverAccountServiceImpl.java
+27
-0
NetworkDriverRunningWaterRecordServiceImpl.java
...pl/settle/NetworkDriverRunningWaterRecordServiceImpl.java
+28
-0
SettlementMqHandlerServiceImpl.java
...e/service/impl/settle/SettlementMqHandlerServiceImpl.java
+4
-1
SettlementOwnerDetailServiceImpl.java
...service/impl/settle/SettlementOwnerDetailServiceImpl.java
+0
-1
SettlementOwnerServiceImpl.java
...mance/service/impl/settle/SettlementOwnerServiceImpl.java
+15
-26
SettlementServiceImpl.java
...erformance/service/impl/settle/SettlementServiceImpl.java
+1
-1
NetworkCaseOutRecordService.java
...rformance/service/settle/NetworkCaseOutRecordService.java
+16
-0
NetworkDriverAccountService.java
...rformance/service/settle/NetworkDriverAccountService.java
+15
-0
NetworkDriverRunningWaterRecordService.java
...ervice/settle/NetworkDriverRunningWaterRecordService.java
+15
-0
OwnerAccountSqlProvider.java
.../clx/performance/sqlProvider/OwnerAccountSqlProvider.java
+1
-1
NetworkDriverAccountProvider.java
...ance/sqlProvider/settle/NetworkDriverAccountProvider.java
+33
-0
NetworkDriverRunningWaterRecordProvider.java
...vider/settle/NetworkDriverRunningWaterRecordProvider.java
+34
-0
没有找到文件。
performance-api/src/main/java/com/clx/performance/param/pc/PageNetworkAccountInfoListParam.java
0 → 100644
浏览文件 @
fd991f28
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
0 → 100644
浏览文件 @
fd991f28
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
PageNetworkAccountListParam
extends
PageParam
{
@ApiModelProperty
(
value
=
"手机号"
,
example
=
"13966554477"
)
private
String
mobile
;
@ApiModelProperty
(
value
=
"车主名称"
)
private
String
driverUserName
;
@ApiModelProperty
(
value
=
"司机编码"
)
private
String
driverUserNo
;
}
performance-api/src/main/java/com/clx/performance/param/pc/PageNetworkCaseOutRecordListParam.java
0 → 100644
浏览文件 @
fd991f28
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
浏览文件 @
fd991f28
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
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
vo
.
pc
;
import
com.msl.common.convertor.type.MoneyOutConvert
;
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
NetworkDriverAccountVO
{
private
Integer
id
;
@ApiModelProperty
(
"司机编码"
)
private
String
driverUserNo
;
@ApiModelProperty
(
"司机名称"
)
private
String
driverUserName
;
@ApiModelProperty
(
"联系电话"
)
private
String
mobile
;
@ApiModelProperty
(
"账户余额"
)
@MoneyOutConvert
private
BigDecimal
accountBalance
;
@ApiModelProperty
(
"可用余额"
)
@MoneyOutConvert
private
BigDecimal
usableBalance
;
@ApiModelProperty
(
"冻结余额"
)
@MoneyOutConvert
private
BigDecimal
frozenBalance
;
@ApiModelProperty
(
"钱包code"
)
private
String
walletCode
;
@ApiModelProperty
(
"创建人"
)
private
String
createBy
;
@ApiModelProperty
(
"创建时间"
)
private
String
createTime
;
@ApiModelProperty
(
"修改时间"
)
private
String
modifiedTime
;
}
performance-api/src/main/java/com/clx/performance/vo/pc/NetworkDriverRunningWaterRecordVO.java
0 → 100644
浏览文件 @
fd991f28
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-api/src/main/java/com/clx/performance/vo/pc/OwnerAccountVO.java
浏览文件 @
fd991f28
...
...
@@ -56,6 +56,7 @@ public class OwnerAccountVO {
@ApiModelProperty
(
value
=
"冻结金额"
)
@MoneyOutConvert
private
BigDecimal
frozenBalance
;
/**
* 创建人
*/
...
...
performance-web/src/main/java/com/clx/performance/component/NetworkSyncComponent.java
0 → 100644
浏览文件 @
fd991f28
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/carrier/CarrierSettlementOwnerController.java
浏览文件 @
fd991f28
...
...
@@ -111,7 +111,6 @@ public class CarrierSettlementOwnerController {
@ApiOperation
(
value
=
"编辑结算单状态"
,
notes
=
"<br>By:姜文业"
)
@PostMapping
(
"/updateStatusByOrderNo"
)
public
Result
updateStatusByOrderNo
(
@RequestBody
@Validated
UpdateStatusParam
param
)
{
log
.
info
(
"履约服务进行结算单状态更改,参数{}"
,
JSONUtil
.
parse
(
param
));
settlementOwnerService
.
updateStatusByOrderNo
(
param
.
getOrderNo
(),
param
.
getSettlementPeriodType
(),
param
.
getFromStatus
(),
param
.
getToStatus
());
return
Result
.
ok
();
}
...
...
performance-web/src/main/java/com/clx/performance/controller/pc/driver/NetworkDriverAccountController.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
controller
.
pc
.
driver
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.model.OwnerTransferInfo
;
import
com.clx.performance.param.pc.*
;
import
com.clx.performance.param.pc.owner.CreteAccountParam
;
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.NetworkDriverRunningWaterRecordService
;
import
com.clx.performance.vo.pc.*
;
import
com.clx.user.vo.pc.owner.OwnerBindCardVO
;
import
com.msl.common.base.PageData
;
import
com.msl.common.convertor.aspect.UnitCovert
;
import
com.msl.common.result.Result
;
import
com.msl.user.data.UserSessionData
;
import
com.msl.user.utils.TokenUtil
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.poi.xssf.streaming.SXSSFWorkbook
;
import
org.springframework.http.HttpHeaders
;
import
org.springframework.http.MediaType
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.*
;
import
javax.servlet.http.HttpServletResponse
;
import
javax.validation.constraints.NotNull
;
@Slf4j
@RestController
@RequestMapping
(
"/pc/driver"
)
@Validated
@AllArgsConstructor
@Api
(
tags
=
"PC-车主网络货运"
)
public
class
NetworkDriverAccountController
{
private
final
NetworkDriverAccountService
networkDriverAccountService
;
private
final
NetworkDriverRunningWaterRecordService
networkDriverRunningWaterRecordService
;
private
final
NetworkCaseOutRecordService
networkCaseOutRecordService
;
@ApiOperation
(
value
=
"网络货运账户列表"
,
notes
=
"<br>By:胡宇帆"
)
@PostMapping
(
"/networkAccountList"
)
@UnitCovert
(
param
=
false
)
public
Result
<
PageData
<
NetworkDriverAccountVO
>>
networkAccountList
(
@RequestBody
PageNetworkAccountListParam
param
)
{
IPage
<
NetworkDriverAccountVO
>
page
=
networkDriverAccountService
.
networkAccountList
(
param
);
return
Result
.
page
(
page
.
getRecords
(),
page
.
getTotal
(),
page
.
getPages
());
}
@ApiOperation
(
value
=
"网络货运账户详情"
,
notes
=
"<br>By:胡宇帆"
)
@PostMapping
(
"/networkAccountInfoList"
)
@UnitCovert
(
param
=
false
)
public
Result
<
PageData
<
NetworkDriverRunningWaterRecordVO
>>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
)
{
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/controller/pc/transport/TransportSyncController.java
浏览文件 @
fd991f28
...
...
@@ -28,7 +28,6 @@ import io.swagger.annotations.Api;
import
io.swagger.annotations.ApiOperation
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.*
;
...
...
performance-web/src/main/java/com/clx/performance/dao/impl/settle/NetworkCaseOutRecordDaoImpl.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
dao
.
impl
.
settle
;
import
com.clx.performance.dao.settle.NetworkCaseOutRecordDao
;
import
com.clx.performance.mapper.settle.NetworkCaseOutRecordMapper
;
import
com.clx.performance.model.settle.NetworkCaseOutRecord
;
import
com.msl.common.dao.impl.BaseDaoImpl
;
import
org.springframework.stereotype.Repository
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Repository
public
class
NetworkCaseOutRecordDaoImpl
extends
BaseDaoImpl
<
NetworkCaseOutRecordMapper
,
NetworkCaseOutRecord
,
Integer
>
implements
NetworkCaseOutRecordDao
{
}
performance-web/src/main/java/com/clx/performance/dao/impl/settle/NetworkDriverAccountDaoImpl.java
0 → 100644
浏览文件 @
fd991f28
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.NetworkDriverAccountDao
;
import
com.clx.performance.mapper.settle.NetworkDriverAccountMapper
;
import
com.clx.performance.model.settle.NetworkDriverAccount
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
com.clx.performance.vo.pc.NetworkDriverAccountVO
;
import
com.msl.common.dao.impl.BaseDaoImpl
;
import
org.springframework.stereotype.Repository
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Repository
public
class
NetworkDriverAccountDaoImpl
extends
BaseDaoImpl
<
NetworkDriverAccountMapper
,
NetworkDriverAccount
,
Integer
>
implements
NetworkDriverAccountDao
{
@Override
public
IPage
<
NetworkDriverAccountVO
>
networkAccountList
(
PageNetworkAccountListParam
param
)
{
Page
<
NetworkDriverAccountVO
>
page
=
Page
.
of
(
param
.
getPage
(),
param
.
getPageSize
());
return
baseMapper
.
networkAccountList
(
page
,
param
);
}
}
performance-web/src/main/java/com/clx/performance/dao/impl/settle/NetworkDriverRunningWaterRecordDaoImpl.java
0 → 100644
浏览文件 @
fd991f28
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.mapper.settle.NetworkDriverRunningWaterRecordMapper
;
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
org.springframework.stereotype.Repository
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Repository
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/impl/settle/SettlementOwnerDetailDaoImpl.java
浏览文件 @
fd991f28
...
...
@@ -114,7 +114,7 @@ public class SettlementOwnerDetailDaoImpl extends BaseDaoImpl<SettlementOwnerDet
public
void
updateSettlementByChildNoList
(
List
<
String
>
childNoList
)
{
update
(
lUdWrapper
()
.
in
(
SettlementOwnerDetail:
:
getChildNo
,
childNoList
)
.
set
(
SettlementOwnerDetail:
:
getInvoiceStatus
,
SettlementOwner
Enum
.
InvoiceStatus
.
INVOICED
.
getCode
())
.
set
(
SettlementOwnerDetail:
:
getInvoiceStatus
,
SettlementOwner
DetailEnum
.
InvoiceStatus
.
YES
.
getCode
())
);
}
...
...
performance-web/src/main/java/com/clx/performance/dao/settle/NetworkCaseOutRecordDao.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
dao
.
settle
;
import
com.clx.performance.mapper.settle.NetworkCaseOutRecordMapper
;
import
com.clx.performance.model.settle.NetworkCaseOutRecord
;
import
com.msl.common.dao.BaseDao
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkCaseOutRecordDao
extends
BaseDao
<
NetworkCaseOutRecordMapper
,
NetworkCaseOutRecord
,
Integer
>
{
}
performance-web/src/main/java/com/clx/performance/dao/settle/NetworkDriverAccountDao.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
dao
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.mapper.settle.NetworkDriverAccountMapper
;
import
com.clx.performance.model.settle.NetworkDriverAccount
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
com.clx.performance.vo.pc.NetworkDriverAccountVO
;
import
com.msl.common.dao.BaseDao
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkDriverAccountDao
extends
BaseDao
<
NetworkDriverAccountMapper
,
NetworkDriverAccount
,
Integer
>
{
IPage
<
NetworkDriverAccountVO
>
networkAccountList
(
PageNetworkAccountListParam
param
);
}
performance-web/src/main/java/com/clx/performance/dao/settle/NetworkDriverRunningWaterRecordDao.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
dao
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.mapper.settle.NetworkDriverRunningWaterRecordMapper
;
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
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkDriverRunningWaterRecordDao
extends
BaseDao
<
NetworkDriverRunningWaterRecordMapper
,
NetworkDriverRunningWaterRecord
,
Integer
>
{
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
);
}
performance-web/src/main/java/com/clx/performance/feign/FeignInterceptor.java
浏览文件 @
fd991f28
...
...
@@ -17,6 +17,7 @@ public class FeignInterceptor implements RequestInterceptor {
public
void
apply
(
RequestTemplate
template
){
// 通过template获取到请求体(已经被转成json)
String
jsonBody
=
template
.
requestBody
().
asString
();
log
.
info
(
"请求参数:{}"
,
jsonBody
);
try
{
//调用网络货运请求需要加密处理
log
.
info
(
"加密开始"
);
...
...
performance-web/src/main/java/com/clx/performance/mapper/settle/NetworkCaseOutRecordMapper.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
mapper
.
settle
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.clx.performance.model.settle.NetworkCaseOutRecord
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkCaseOutRecordMapper
extends
BaseMapper
<
NetworkCaseOutRecord
>
{
}
performance-web/src/main/java/com/clx/performance/mapper/settle/NetworkDriverAccountMapper.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
mapper
.
settle
;
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.NetworkDriverAccount
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
com.clx.performance.sqlProvider.settle.NetworkDriverAccountProvider
;
import
com.clx.performance.vo.pc.NetworkDriverAccountVO
;
import
org.apache.ibatis.annotations.SelectProvider
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkDriverAccountMapper
extends
BaseMapper
<
NetworkDriverAccount
>
{
@SelectProvider
(
type
=
NetworkDriverAccountProvider
.
class
,
method
=
"networkAccountList"
)
IPage
<
NetworkDriverAccountVO
>
networkAccountList
(
Page
<
NetworkDriverAccountVO
>
page
,
PageNetworkAccountListParam
param
);
}
performance-web/src/main/java/com/clx/performance/mapper/settle/NetworkDriverRunningWaterRecordMapper.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
mapper
.
settle
;
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.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
* Date 2023-12-19
* Time 11:34
*/
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/model/settle/NetworkCaseOutRecord.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
model
.
settle
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
import
com.msl.common.config.KeyColumn
;
import
com.msl.common.model.HasKey
;
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
)
@TableName
(
"network_case_out_record"
)
public
class
NetworkCaseOutRecord
implements
HasKey
<
Integer
>
{
@TableId
(
value
=
"id"
,
type
=
IdType
.
AUTO
)
private
Integer
id
;
@TableField
(
"case_out_no"
)
@ApiModelProperty
(
"提现单号"
)
private
Long
caseOutNo
;
@TableField
(
"driver_user_no"
)
@ApiModelProperty
(
"司机编码"
)
private
String
driverUserNo
;
@TableField
(
"driver_user_name"
)
@ApiModelProperty
(
"司机名称"
)
private
String
driverUserName
;
@TableField
(
"mobile"
)
@ApiModelProperty
(
"联系电话"
)
private
String
mobile
;
@TableField
(
"payee"
)
@ApiModelProperty
(
"收款人"
)
private
String
payee
;
@TableField
(
"bank"
)
@ApiModelProperty
(
"开户行"
)
private
String
bank
;
@TableField
(
"collection_bank_code"
)
@ApiModelProperty
(
"收款银行账户"
)
private
String
collectionBankCode
;
@TableField
(
"status"
)
@ApiModelProperty
(
"状态 10:待平台付款 20:已付款"
)
private
Integer
status
;
@TableField
(
"platform"
)
@ApiModelProperty
(
"平台"
)
private
String
platform
;
@TableField
(
"relation_id"
)
@ApiModelProperty
(
""
)
private
Long
relationId
;
@TableField
(
"order_id"
)
@ApiModelProperty
(
"订单ID"
)
private
Integer
orderId
;
@TableField
(
"order_no"
)
@ApiModelProperty
(
"订单编号"
)
private
String
orderNo
;
@TableField
(
"order_child_id"
)
@ApiModelProperty
(
"运单ID"
)
private
Integer
orderChildId
;
@TableField
(
"order_child_no"
)
@ApiModelProperty
(
"运单编号"
)
private
String
orderChildNo
;
@TableField
(
"alteration_balance"
)
@ApiModelProperty
(
"变动金额"
)
private
BigDecimal
alterationBalance
;
@TableField
(
"frozen_balance"
)
@ApiModelProperty
(
"冻结金额"
)
private
BigDecimal
frozenBalance
;
@TableField
(
"usable_balance"
)
@ApiModelProperty
(
"可用余额"
)
private
BigDecimal
usableBalance
;
@TableField
(
"account_balance"
)
@ApiModelProperty
(
"账户余额"
)
private
BigDecimal
accountBalance
;
@TableField
(
"take_out_balance"
)
@ApiModelProperty
(
"扣除金额"
)
private
BigDecimal
takeOutBalance
;
@TableField
(
"create_by"
)
@ApiModelProperty
(
"操作人"
)
private
String
createBy
;
@TableField
(
"create_time"
)
@ApiModelProperty
(
"创建时间"
)
private
LocalDateTime
createTime
;
@TableField
(
"finish_time"
)
@ApiModelProperty
(
"提现完成时间"
)
private
LocalDateTime
finishTime
;
@TableField
(
"modified_time"
)
@ApiModelProperty
(
"修改时间"
)
private
LocalDateTime
modifiedTime
;
@Override
@KeyColumn
(
"id"
)
public
Integer
gainKey
()
{
return
this
.
id
;
}
}
performance-web/src/main/java/com/clx/performance/model/settle/NetworkDriverAccount.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
model
.
settle
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
import
com.msl.common.config.KeyColumn
;
import
com.msl.common.model.HasKey
;
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
)
@TableName
(
"network_driver_account"
)
public
class
NetworkDriverAccount
implements
HasKey
<
Integer
>
{
@TableId
(
value
=
"id"
,
type
=
IdType
.
AUTO
)
private
Integer
id
;
@TableField
(
"driver_user_no"
)
@ApiModelProperty
(
"司机编码"
)
private
String
driverUserNo
;
@TableField
(
"driver_user_name"
)
@ApiModelProperty
(
"司机名称"
)
private
String
driverUserName
;
@TableField
(
"mobile"
)
@ApiModelProperty
(
"联系电话"
)
private
String
mobile
;
@TableField
(
"account_balance"
)
@ApiModelProperty
(
"账户余额"
)
private
BigDecimal
accountBalance
;
@TableField
(
"usable_balance"
)
@ApiModelProperty
(
"可用余额"
)
private
BigDecimal
usableBalance
;
@TableField
(
"frozen_balance"
)
@ApiModelProperty
(
"冻结余额"
)
private
BigDecimal
frozenBalance
;
@TableField
(
"wallet_code"
)
@ApiModelProperty
(
"钱包code"
)
private
String
walletCode
;
@TableField
(
"create_by"
)
@ApiModelProperty
(
"创建人"
)
private
String
createBy
;
@TableField
(
"create_time"
)
@ApiModelProperty
(
"创建时间"
)
private
LocalDateTime
createTime
;
@TableField
(
"modified_time"
)
@ApiModelProperty
(
"修改时间"
)
private
LocalDateTime
modifiedTime
;
@Override
@KeyColumn
(
"id"
)
public
Integer
gainKey
()
{
return
this
.
id
;
}
}
performance-web/src/main/java/com/clx/performance/model/settle/NetworkDriverRunningWaterRecord.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
model
.
settle
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableField
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
com.baomidou.mybatisplus.annotation.TableName
;
import
com.msl.common.config.KeyColumn
;
import
com.msl.common.model.HasKey
;
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
)
@TableName
(
"network_driver_running_water_record"
)
public
class
NetworkDriverRunningWaterRecord
implements
HasKey
<
Integer
>
{
@TableId
(
value
=
"id"
,
type
=
IdType
.
AUTO
)
private
Integer
id
;
@TableField
(
"running_water_no"
)
@ApiModelProperty
(
"流水号"
)
private
Long
runningWaterNo
;
@TableField
(
"driver_user_no"
)
@ApiModelProperty
(
"司机编码"
)
private
String
driverUserNo
;
@TableField
(
"driver_user_name"
)
@ApiModelProperty
(
"司机名称"
)
private
String
driverUserName
;
@TableField
(
"mobile"
)
@ApiModelProperty
(
"联系电话"
)
private
String
mobile
;
@TableField
(
"running_water_type"
)
@ApiModelProperty
(
"流水类型 10:运单结算 20:提现冻结 30:提现成功"
)
private
Integer
runningWaterType
;
@TableField
(
"fund_type"
)
@ApiModelProperty
(
"资金类型 10:收入 20:冻结 30:支出"
)
private
Integer
fundType
;
@TableField
(
"relation_id"
)
@ApiModelProperty
(
""
)
private
Long
relationId
;
@TableField
(
"order_id"
)
@ApiModelProperty
(
"订单ID"
)
private
Integer
orderId
;
@TableField
(
"order_no"
)
@ApiModelProperty
(
"订单编号"
)
private
String
orderNo
;
@TableField
(
"order_child_id"
)
@ApiModelProperty
(
"运单ID"
)
private
Integer
orderChildId
;
@TableField
(
"order_child_no"
)
@ApiModelProperty
(
"运单编号"
)
private
String
orderChildNo
;
@TableField
(
"alteration_balance"
)
@ApiModelProperty
(
"变动金额"
)
private
BigDecimal
alterationBalance
;
@TableField
(
"frozen_balance"
)
@ApiModelProperty
(
"冻结金额"
)
private
BigDecimal
frozenBalance
;
@TableField
(
"usable_balance"
)
@ApiModelProperty
(
"可用余额"
)
private
BigDecimal
usableBalance
;
@TableField
(
"account_balance"
)
@ApiModelProperty
(
"账户余额"
)
private
BigDecimal
accountBalance
;
@TableField
(
"take_out_balance"
)
@ApiModelProperty
(
"扣除金额"
)
private
BigDecimal
takeOutBalance
;
@TableField
(
"create_by"
)
@ApiModelProperty
(
"操作人"
)
private
String
createBy
;
@TableField
(
"create_time"
)
@ApiModelProperty
(
"创建时间"
)
private
LocalDateTime
createTime
;
@TableField
(
"modified_time"
)
@ApiModelProperty
(
"修改时间"
)
private
LocalDateTime
modifiedTime
;
@Override
@KeyColumn
(
"id"
)
public
Integer
gainKey
()
{
return
this
.
id
;
}
}
performance-web/src/main/java/com/clx/performance/service/impl/settle/NetworkCaseOutRecordServiceImpl.java
0 → 100644
浏览文件 @
fd991f28
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.vo.pc.NetworkCaseOutRecordVO
;
import
org.springframework.stereotype.Service
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Service
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/NetworkDriverAccountServiceImpl.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
service
.
impl
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.dao.settle.NetworkDriverAccountDao
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
com.clx.performance.service.settle.NetworkDriverAccountService
;
import
com.clx.performance.vo.pc.NetworkDriverAccountVO
;
import
lombok.AllArgsConstructor
;
import
org.springframework.stereotype.Service
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Service
@AllArgsConstructor
public
class
NetworkDriverAccountServiceImpl
implements
NetworkDriverAccountService
{
private
final
NetworkDriverAccountDao
networkDriverAccountDao
;
@Override
public
IPage
<
NetworkDriverAccountVO
>
networkAccountList
(
PageNetworkAccountListParam
param
)
{
return
networkDriverAccountDao
.
networkAccountList
(
param
);
}
}
performance-web/src/main/java/com/clx/performance/service/impl/settle/NetworkDriverRunningWaterRecordServiceImpl.java
0 → 100644
浏览文件 @
fd991f28
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.vo.pc.NetworkDriverRunningWaterRecordVO
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.stereotype.Service
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
@Service
@AllArgsConstructor
@Slf4j
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/SettlementMqHandlerServiceImpl.java
浏览文件 @
fd991f28
...
...
@@ -121,7 +121,7 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
OrderGoods
orderGoods
=
orderGoodsDao
.
getByOrderGoodsNo
(
settlementOwnerDetail
.
getOrderGoodsNo
()).
get
();
if
(
Objects
.
equals
(
orderGoods
.
getSettlementAccountPeriod
(),
2
)){
//月结
log
.
info
(
"月结初始化货主结算单"
);
LocalDateTime
settlementPeriodTime
=
LocalDateTimeUtils
.
getBeginMonthDate
();
settlementOwner
=
settlementOwnerDao
.
selectUnlockOfSettlementPeriodMonth
(
settlementOwnerDetail
.
getOrderNo
(),
settlementPeriodTime
,
settlementOwnerDetail
.
getInvoiceType
()).
orNull
();
if
(
settlementOwner
==
null
){
// 月结初始化
...
...
@@ -133,6 +133,8 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
}
}
else
{
log
.
info
(
"月结初始化货主结算单"
);
settlementOwner
=
settlementOwnerDao
.
selectUnlockOfSettlementPeriodImmediate
(
settlementOwnerDetail
.
getOrderNo
(),
settlementOwnerDetail
.
getInvoiceType
()).
orNull
();
if
(
settlementOwner
==
null
){
// 拉运完成初始化
settlementNo
=
settlementPeriodImmediateInit
(
settlementOwnerDetail
,
ownerInfo
);
...
...
@@ -407,6 +409,7 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
settlementOwner
.
setCompanyContactMobile
(
ownerInfo
.
getContactsTelephone
());
settlementOwner
.
setCompanyContactAddress
(
ownerInfo
.
getContactsAddress
());
settlementOwner
.
setSettlementWay
(
settlementOwnerDetail
.
getSettlementWay
());
settlementOwner
.
setInvoiceStatus
(
SettlementOwnerEnum
.
InvoiceStatus
.
NOT_INVOICE
.
getCode
());
settlementOwnerDao
.
saveEntity
(
settlementOwner
);
...
...
performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerDetailServiceImpl.java
浏览文件 @
fd991f28
...
...
@@ -144,7 +144,6 @@ public class SettlementOwnerDetailServiceImpl implements SettlementOwnerDetailS
//
settlementOwnerDetail
.
setFinalPaymentStatus
(
SettlementOwnerDetailEnum
.
FinalPaymentStatus
.
NO
.
getCode
());
settlementOwnerDetailDao
.
saveEntity
(
settlementOwnerDetail
);
return
settlementOwnerDetail
.
getId
();
...
...
performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerServiceImpl.java
浏览文件 @
fd991f28
...
...
@@ -3,7 +3,7 @@ package com.clx.performance.service.impl.settle;
import
cn.hutool.core.collection.CollectionUtil
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
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.SettlementOwnerDao
;
import
com.clx.performance.dao.settle.SettlementOwnerDetailDao
;
...
...
@@ -12,12 +12,10 @@ import com.clx.performance.dto.InvoicingStatusNotifyDTO;
import
com.clx.performance.enums.OrderChildLogEnum
;
import
com.clx.performance.enums.PerformanceResultEnum
;
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.SettlementOwner
;
import
com.clx.performance.model.settle.SettlementOwnerDetail
;
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.service.OwnerAccountService
;
import
com.clx.performance.service.settle.SettlementLogService
;
...
...
@@ -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.owner.settle.OwnerPageSettlementOwnerVO
;
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.msl.common.dto.HttpDTO
;
import
com.msl.common.exception.ServiceSystemException
;
import
com.msl.user.data.UserSessionData
;
import
com.msl.user.utils.TokenUtil
;
...
...
@@ -45,7 +41,6 @@ import org.springframework.transaction.annotation.Transactional;
import
java.math.BigDecimal
;
import
java.util.ArrayList
;
import
java.util.LinkedList
;
import
java.util.List
;
import
java.util.Objects
;
...
...
@@ -75,9 +70,7 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
private
final
OwnerAccountService
ownerAccountService
;
private
final
OwnerFeign
ownerFeign
;
private
final
TransportFeignService
transportFeignService
;
private
final
NetworkSyncComponent
networkSyncComponent
;
@Override
public
CarrierSettlementOwnerDetailVO
getCarrierSettlementOwnerDetail
(
Integer
id
)
{
...
...
@@ -136,6 +129,16 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
if
(
settlementOwner
.
getSettlementFreight
().
compareTo
(
BigDecimal
.
ZERO
)
==
0
){
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 {
}
else
{
if
(
Objects
.
equals
(
settlementOwner
.
getInvoiceType
(),
SettlementOwnerEnum
.
InvoiceType
.
ONLINE
.
getCode
()))
{
settlementOwnerDao
.
updateStatusBySettlementNo
(
settlementNo
,
SettlementOwnerEnum
.
Status
.
COMPLETED
.
getCode
());
String
mobile
=
ownerFeign
.
getOwnerInfo
(
settlementOwner
.
getOwnerUserNo
()).
getData
().
getMobile
();
//TODO 通知网络货运做货主计费开票标识通知
OwnerSettlementSyncParam
param
=
new
OwnerSettlementSyncParam
();
param
.
setOwnerMobile
(
mobile
);
List
<
OwnerSettlementSyncParam
.
SettlementItem
>
settlementList
=
new
LinkedList
<>();
param
.
setSettlementList
(
settlementList
);
List
<
SettlementOwnerDetail
>
settlementOwnerDetailList
=
settlementOwnerDetailDao
.
getBySettlementNoAndInvoiceType
(
settlementNo
,
SettlementDriverEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwnerEnum
.
InvoiceStatus
.
NOT_INVOICE
.
getCode
());
for
(
SettlementOwnerDetail
settlementOwnerDetail
:
settlementOwnerDetailList
)
{
String
childNo
=
settlementOwnerDetail
.
getChildNo
();
OwnerSettlementSyncParam
.
SettlementItem
item
=
new
OwnerSettlementSyncParam
.
SettlementItem
();
item
.
setChildNo
(
childNo
);
item
.
setSettlementNo
(
settlementOwnerDetail
.
getSettlementNo
());
settlementList
.
add
(
item
);
}
HttpDTO
httpDTO
=
transportFeignService
.
ownerSettlementSync
(
param
);
String
decrypt
=
ThirdComponent
.
decrypt
(
httpDTO
.
getData
());
log
.
info
(
"通知网络货运做货主计费开票标识通知请求解密后:{}"
,
decrypt
);
SettlementDriverEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwnerDetailEnum
.
InvoiceStatus
.
NO
.
getCode
());
networkSyncComponent
.
ownerSettlementSync
(
settlementOwner
,
settlementOwnerDetailList
);
}
else
{
settlementOwnerDao
.
updateStatusBySettlementNo
(
settlementNo
,
SettlementOwnerEnum
.
Status
.
INVOICE_TO_BE_MAILED
.
getCode
());
...
...
@@ -531,7 +520,7 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService {
SettlementOwnerDetail
settlementOwnerDetail
=
settlementOwnerDetailDao
.
getByChildNo
(
childNoList
.
get
(
0
)).
get
();
String
settlementNo
=
settlementOwnerDetail
.
getSettlementNo
();
List
<
SettlementOwnerDetail
>
list
=
settlementOwnerDetailDao
.
getBySettlementNoAndInvoiceType
(
settlementNo
,
SettlementOwnerEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwner
Enum
.
InvoiceStatus
.
NOT_INVOICE
.
getCode
());
SettlementOwnerEnum
.
InvoiceType
.
ONLINE
.
getCode
(),
SettlementOwner
DetailEnum
.
InvoiceStatus
.
NO
.
getCode
());
if
(
CollectionUtil
.
isEmpty
(
list
))
{
log
.
info
(
"开票结果回调查询当前结算单均已开完票,结算单信息为{}"
,
settlementNo
);
return
;
...
...
performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementServiceImpl.java
浏览文件 @
fd991f28
...
...
@@ -234,7 +234,7 @@ public class SettlementServiceImpl implements SettlementService {
return
BigDecimal
.
ZERO
;
}
}
else
{
if
(
accountFrozenPrefreght
.
compareTo
(
settlementOwnerDetail
.
getFreight
())
=
=
0
)
{
if
(
accountFrozenPrefreght
.
compareTo
(
settlementOwnerDetail
.
getFreight
())
>
=
0
)
{
return
settlementOwnerDetail
.
getFreight
();
}
else
{
return
BigDecimal
.
ZERO
;
...
...
performance-web/src/main/java/com/clx/performance/service/settle/NetworkCaseOutRecordService.java
0 → 100644
浏览文件 @
fd991f28
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
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkCaseOutRecordService
{
IPage
<
NetworkCaseOutRecordVO
>
networkCaseOutRecord
(
PageNetworkCaseOutRecordListParam
param
);
}
performance-web/src/main/java/com/clx/performance/service/settle/NetworkDriverAccountService.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
service
.
settle
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.clx.performance.param.pc.PageNetworkAccountListParam
;
import
com.clx.performance.vo.pc.NetworkDriverAccountVO
;
/**
* @author kavin
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkDriverAccountService
{
IPage
<
NetworkDriverAccountVO
>
networkAccountList
(
PageNetworkAccountListParam
param
);
}
performance-web/src/main/java/com/clx/performance/service/settle/NetworkDriverRunningWaterRecordService.java
0 → 100644
浏览文件 @
fd991f28
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
* Date 2023-12-19
* Time 11:34
*/
public
interface
NetworkDriverRunningWaterRecordService
{
IPage
<
NetworkDriverRunningWaterRecordVO
>
networkAccountInfoList
(
PageNetworkAccountInfoListParam
param
);
}
performance-web/src/main/java/com/clx/performance/sqlProvider/OwnerAccountSqlProvider.java
浏览文件 @
fd991f28
...
...
@@ -20,7 +20,7 @@ public class OwnerAccountSqlProvider {
String
sql
=
new
SQL
()
{{
SELECT
(
"a.id, a.owner_user_no,"
+
" a.owner_user_name, a.mobile, a.account_type, "
+
" a.account_balance,a.usable_balance,
a.frozen_balance,a.create_by,date_format(a.create_time, '%Y-%m-%d %H:%i:%s') as create_time"
);
" a.account_balance,a.usable_balance,a.frozen_balance,a.create_by,date_format(a.create_time, '%Y-%m-%d %H:%i:%s') as create_time"
);
FROM
(
"owner_account a"
);
...
...
performance-web/src/main/java/com/clx/performance/sqlProvider/settle/NetworkDriverAccountProvider.java
0 → 100644
浏览文件 @
fd991f28
package
com
.
clx
.
performance
.
sqlProvider
.
settle
;
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
NetworkDriverAccountProvider
{
public
String
networkAccountList
(
@Param
(
"param"
)
PageNetworkAccountListParam
param
)
{
String
sql
=
new
SQL
()
{{
SELECT
(
"a.id, a.driver_user_no,"
+
" a.driver_user_name, a.mobile, a.account_balance, "
+
" a.usable_balance,a.frozen_balance,a.wallet_code,a.create_by,date_format(a.create_time, '%Y-%m-%d %H:%i:%s') as create_time"
);
FROM
(
"network_driver_account a"
);
if
(
StringUtils
.
isNotBlank
(
param
.
getDriverUserNo
()))
{
WHERE
(
"a.driver_user_no = #{param.driverUserNo}"
);
}
if
(
StringUtils
.
isNotBlank
(
param
.
getMobile
()))
{
WHERE
(
"a.mobile = #{param.mobile}"
);
}
if
(
StringUtils
.
isNotBlank
(
param
.
getDriverUserName
()))
{
WHERE
(
"a.driver_user_name like CONCAT('%',#{param.driverUserName},'%')"
);
}
ORDER_BY
(
"a.create_time desc"
);
}}.
toString
();
return
sql
;
}
}
performance-web/src/main/java/com/clx/performance/sqlProvider/settle/NetworkDriverRunningWaterRecordProvider.java
0 → 100644
浏览文件 @
fd991f28
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
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论