Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
C
cloud-platform
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
youjj
cloud-platform
Commits
601df947
Commit
601df947
authored
Nov 07, 2019
by
jiaorz
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'master-bacground-im' into base-modify
parents
4ec960be
35e4382b
Changes
14
Hide whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
223 additions
and
37 deletions
+223
-37
AppUserPositionTempBiz.java
...ub/wxiaoqi/security/admin/biz/AppUserPositionTempBiz.java
+36
-0
AppPermissionService.java
...aoqi/security/admin/rpc/service/AppPermissionService.java
+7
-0
AddMsgParam.java
...src/main/java/com/xxfc/platform/im/model/AddMsgParam.java
+19
-3
Msg.java
...-im-api/src/main/java/com/xxfc/platform/im/model/Msg.java
+22
-7
MusicInfo.java
...i/src/main/java/com/xxfc/platform/im/model/MusicInfo.java
+21
-0
MsgBiz.java
...server/src/main/java/com/xxfc/platform/im/biz/MsgBiz.java
+57
-7
MsgController.java
...rc/main/java/com/xxfc/platform/im/rest/MsgController.java
+8
-4
OrderStatisticsBiz.java
.../java/com/xxfc/platform/order/biz/OrderStatisticsBiz.java
+4
-2
OrderStatisticsController.java
...form/order/rest/background/OrderStatisticsController.java
+2
-2
VehicleModel.java
...n/java/com/xxfc/platform/vehicle/entity/VehicleModel.java
+4
-0
VehicleActiveService.java
...a/com/xxfc/platform/vehicle/biz/VehicleActiveService.java
+9
-2
VehicleBookRecordBiz.java
...a/com/xxfc/platform/vehicle/biz/VehicleBookRecordBiz.java
+9
-5
VehicleController.java
...ava/com/xxfc/platform/vehicle/rest/VehicleController.java
+10
-4
VehicleModelController.java
...om/xxfc/platform/vehicle/rest/VehicleModelController.java
+15
-1
No files found.
ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserPositionTempBiz.java
View file @
601df947
...
@@ -16,6 +16,7 @@ import com.github.wxiaoqi.security.common.vo.PageDataVO;
...
@@ -16,6 +16,7 @@ import com.github.wxiaoqi.security.common.vo.PageDataVO;
import
com.google.common.collect.Lists
;
import
com.google.common.collect.Lists
;
import
com.xxfc.platform.vehicle.entity.BranchCompany
;
import
com.xxfc.platform.vehicle.entity.BranchCompany
;
import
com.xxfc.platform.vehicle.feign.VehicleFeign
;
import
com.xxfc.platform.vehicle.feign.VehicleFeign
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.collections.CollectionUtils
;
import
org.apache.commons.collections.CollectionUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.BeanUtils
;
...
@@ -41,6 +42,7 @@ import java.util.stream.Collectors;
...
@@ -41,6 +42,7 @@ import java.util.stream.Collectors;
@Transactional
@Transactional
@DependsOn
(
"appUserPositionBiz"
)
@DependsOn
(
"appUserPositionBiz"
)
@Service
@Service
@Slf4j
public
class
AppUserPositionTempBiz
extends
BaseBiz
<
AppUserPositionTempMapper
,
AppUserPositionTemp
>
implements
InitializingBean
{
public
class
AppUserPositionTempBiz
extends
BaseBiz
<
AppUserPositionTempMapper
,
AppUserPositionTemp
>
implements
InitializingBean
{
@Autowired
@Autowired
...
@@ -299,4 +301,38 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
...
@@ -299,4 +301,38 @@ public class AppUserPositionTempBiz extends BaseBiz<AppUserPositionTempMapper, A
}
}
public
void
setPostionIdByPhone
(
String
phone
){
try
{
Example
example
=
new
Example
(
AppUserPositionTemp
.
class
);
example
.
createCriteria
().
andEqualTo
(
"phone"
,
phone
).
andEqualTo
(
"isDel"
,
0
);
List
<
AppUserPositionTemp
>
list
=
selectByExample
(
example
);
if
(
CollectionUtils
.
isEmpty
(
list
)){
log
.
info
(
"----用户无身份----phone==="
+
phone
);
return
;
}
AppUserPositionTemp
positionTemp
=
list
.
get
(
0
);
if
(
positionTemp
.
getUserId
()>
0
){
log
.
info
(
"----用户已存在身份----phone==="
+
phone
);
return
;
}
//根据手机号查询userId
AppUserLogin
userLogin
=
loginBiz
.
checkeUserLogin
(
phone
);
if
(
userLogin
==
null
)
{
log
.
info
(
"----用户不存在----phone==="
+
phone
);
return
;
}
Integer
userId
=
userLogin
.
getId
();
positionTemp
.
setUserId
(
userId
);
int
num
=
updateSelectiveByIdRe
(
positionTemp
);
if
(
num
>
0
){
Integer
postionId
=
positionTemp
.
getPositionId
();
log
.
info
(
"----用户---postionId===="
+
postionId
+
"----phone==="
+
phone
);
detailBiz
.
updateUserPositionByUserId
(
userId
,
postionId
);
}
}
catch
(
Exception
e
){
e
.
printStackTrace
();
}
}
}
}
ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rpc/service/AppPermissionService.java
View file @
601df947
...
@@ -111,6 +111,9 @@ public class AppPermissionService {
...
@@ -111,6 +111,9 @@ public class AppPermissionService {
@Autowired
@Autowired
private
AppUserPhoneNotesBiz
notesBiz
;
private
AppUserPhoneNotesBiz
notesBiz
;
@Autowired
private
AppUserPositionTempBiz
positionTempBiz
;
public
AppUserInfo
validate
(
String
username
,
String
password
)
{
public
AppUserInfo
validate
(
String
username
,
String
password
)
{
AppUserInfo
info
=
new
AppUserInfo
();
AppUserInfo
info
=
new
AppUserInfo
();
...
@@ -331,6 +334,8 @@ public class AppPermissionService {
...
@@ -331,6 +334,8 @@ public class AppPermissionService {
//创建钱包
//创建钱包
walletBiz
.
createWalletByUserId
(
appUserLogin
.
getId
());
walletBiz
.
createWalletByUserId
(
appUserLogin
.
getId
());
log
.
info
(
"注册:创建钱包: "
+
userid
+
"---time===="
+
System
.
currentTimeMillis
()/
1000L
);
log
.
info
(
"注册:创建钱包: "
+
userid
+
"---time===="
+
System
.
currentTimeMillis
()/
1000L
);
//临时身份绑定
positionTempBiz
.
setPostionIdByPhone
(
username
);
// 登录结果要做做统一处理
// 登录结果要做做统一处理
JSONObject
data
=
autoLogin
(
userid
,
username
,
headimgurl
,
nickname
,
code
,
activityCode
,
1
);
JSONObject
data
=
autoLogin
(
userid
,
username
,
headimgurl
,
nickname
,
code
,
activityCode
,
1
);
...
@@ -967,6 +972,8 @@ public class AppPermissionService {
...
@@ -967,6 +972,8 @@ public class AppPermissionService {
log
.
error
(
"注册:新增用户详情: "
+
userid
);
log
.
error
(
"注册:新增用户详情: "
+
userid
);
//创建钱包
//创建钱包
walletBiz
.
createWalletByUserId
(
appUserLogin
.
getId
());
walletBiz
.
createWalletByUserId
(
appUserLogin
.
getId
());
//临时身份绑定
positionTempBiz
.
setPostionIdByPhone
(
username
);
//临时会员绑定
//临时会员绑定
insertUserMemberByUserIdAndPhone
(
userid
,
username
);
insertUserMemberByUserIdAndPhone
(
userid
,
username
);
//上线绑定
//上线绑定
...
...
xx-im/xx-im-api/src/main/java/com/xxfc/platform/im/model/AddMsgParam.java
View file @
601df947
...
@@ -19,16 +19,24 @@ public class AddMsgParam extends BaseExample {
...
@@ -19,16 +19,24 @@ public class AddMsgParam extends BaseExample {
private
int
visible
=
1
;
// 默认 1 公开 2 私密 3 部分好友可见 4 不给谁看
private
int
visible
=
1
;
// 默认 1 公开 2 私密 3 部分好友可见 4 不给谁看
private
String
lable
;
// 标签(目前用于短视频标签)
private
String
lable
;
// 标签(目前用于短视频标签)
private
String
musicId
;
// 短视频的音乐Id
private
String
musicId
;
// 短视频的音乐Id
private
String
nickname
;
private
String
sdkUrl
;
// sdk分享url
private
String
sdkUrl
;
// sdk分享url
private
String
sdkIcon
;
// sdk分享icon
private
String
sdkIcon
;
// sdk分享icon
private
String
sdkTitle
;
// sdk分享title
private
String
sdkTitle
;
// sdk分享title
private
Integer
userId
;
private
List
<
Integer
>
userLook
;
//谁可以看的玩家id
private
List
<
Integer
>
userLook
;
//谁可以看的玩家id
private
List
<
Integer
>
userNotLook
;
//谁不能看的玩家id
private
List
<
Integer
>
userNotLook
;
//谁不能看的玩家id
private
List
<
Integer
>
userRemindLook
;
//提醒谁看的玩家id
private
List
<
Integer
>
userRemindLook
;
//提醒谁看的玩家id
private
int
isAllowComment
;
// 是否允许评论 0:允许 1:禁止评论
private
int
isAllowComment
;
// 是否允许评论 0:允许 1:禁止评论
public
String
getNickname
()
{
return
nickname
;
}
public
void
setNickname
(
String
nickname
)
{
this
.
nickname
=
nickname
;
}
public
String
getAddress
()
{
public
String
getAddress
()
{
return
address
;
return
address
;
...
@@ -202,6 +210,14 @@ public class AddMsgParam extends BaseExample {
...
@@ -202,6 +210,14 @@ public class AddMsgParam extends BaseExample {
return
musicId
;
return
musicId
;
}
}
public
Integer
getUserId
()
{
return
userId
;
}
public
void
setUserId
(
Integer
userId
)
{
this
.
userId
=
userId
;
}
public
void
setMusicId
(
String
musicId
)
{
public
void
setMusicId
(
String
musicId
)
{
this
.
musicId
=
musicId
;
this
.
musicId
=
musicId
;
}
}
...
...
xx-im/xx-im-api/src/main/java/com/xxfc/platform/im/model/Msg.java
View file @
601df947
...
@@ -41,7 +41,7 @@ public class Msg {
...
@@ -41,7 +41,7 @@ public class Msg {
private
List
<
Integer
>
userLook
;
//选中可见的朋友列表
private
List
<
Integer
>
userLook
;
//选中可见的朋友列表
private
List
<
Integer
>
userNotLook
;
//选中不可见的朋友列表
private
List
<
Integer
>
userNotLook
;
//选中不可见的朋友列表
private
List
<
Integer
>
userRemindLook
;
//@提醒朋友列表
private
List
<
Integer
>
userRemindLook
;
//@提醒朋友列表
private
Integer
source
;
//来源,1、后台创建, 2、APP用户上传
private
@Reference
List
<
CommentVo
>
comments
;
// 评论列表
private
@Reference
List
<
CommentVo
>
comments
;
// 评论列表
private
@Reference
List
<
Givegift
>
gifts
;
// 礼物列表
private
@Reference
List
<
Givegift
>
gifts
;
// 礼物列表
private
@Reference
List
<
PraiseVo
>
praises
;
// 赞列表
private
@Reference
List
<
PraiseVo
>
praises
;
// 赞列表
...
@@ -53,8 +53,23 @@ public class Msg {
...
@@ -53,8 +53,23 @@ public class Msg {
private
Integer
userStatus
;
// 该用户 状态:1=正常, -1=禁用
private
Integer
userStatus
;
// 该用户 状态:1=正常, -1=禁用
private
String
fileName
;
// 原文件名称
private
String
fileName
;
// 原文件名称
public
String
getPic
()
{
return
pic
;
}
public
void
setPic
(
String
pic
)
{
this
.
pic
=
pic
;
}
public
Integer
getSource
()
{
return
source
;
}
public
void
setSource
(
Integer
source
)
{
this
.
source
=
source
;
}
public
int
getIsCollect
()
{
public
int
getIsCollect
()
{
return
isCollect
;
return
isCollect
;
}
}
...
@@ -530,7 +545,7 @@ public class Msg {
...
@@ -530,7 +545,7 @@ public class Msg {
}
}
public
static
Msg
build
(
User
user
,
AddMsgParam
param
)
{
public
static
Msg
build
(
Integer
userId
,
String
nickname
,
AddMsgParam
param
)
{
Body
body
=
new
Body
();
Body
body
=
new
Body
();
body
.
title
=
param
.
getTitle
();
// 标题
body
.
title
=
param
.
getTitle
();
// 标题
body
.
text
=
param
.
getText
();
// 文字内容
body
.
text
=
param
.
getText
();
// 文字内容
...
@@ -568,11 +583,11 @@ public class Msg {
...
@@ -568,11 +583,11 @@ public class Msg {
Msg
entity
=
new
Msg
();
Msg
entity
=
new
Msg
();
entity
.
id
=
ObjectId
.
get
();
entity
.
id
=
ObjectId
.
get
();
entity
.
userId
=
user
.
getId
()
;
entity
.
userId
=
user
Id
;
if
(
"10000"
==
user
.
getId
()
.
toString
())
if
(
"10000"
==
user
Id
.
toString
())
entity
.
nickname
=
"客服公众号"
;
entity
.
nickname
=
"客服公众号"
;
else
else
entity
.
nickname
=
user
.
getNickname
()
;
entity
.
nickname
=
nickname
;
entity
.
flag
=
param
.
getFlag
();
// 1=求职消息、2=招聘消息、3=普通消息
entity
.
flag
=
param
.
getFlag
();
// 1=求职消息、2=招聘消息、3=普通消息
if
(
0
==
param
.
getVisible
())
if
(
0
==
param
.
getVisible
())
param
.
setVisible
(
1
);
param
.
setVisible
(
1
);
...
...
xx-im/xx-im-api/src/main/java/com/xxfc/platform/im/model/MusicInfo.java
0 → 100644
View file @
601df947
package
com
.
xxfc
.
platform
.
im
.
model
;
import
lombok.Data
;
import
org.bson.types.ObjectId
;
import
org.mongodb.morphia.annotations.Entity
;
import
org.mongodb.morphia.annotations.Id
;
@Data
@Entity
(
value
=
"musicInfo"
,
noClassnameStored
=
true
)
public
class
MusicInfo
{
@Id
private
ObjectId
id
;
public
String
cover
;
// 封面图地址
public
long
length
;
// 音乐长度
public
String
name
;
// 音乐名称
public
String
nikeName
;
// 创作人
public
String
path
;
// 音乐地址
private
int
useCount
;
//使用 数量
}
xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/biz/MsgBiz.java
View file @
601df947
...
@@ -3,6 +3,7 @@ package com.xxfc.platform.im.biz;
...
@@ -3,6 +3,7 @@ package com.xxfc.platform.im.biz;
import
cn.hutool.core.bean.BeanUtil
;
import
cn.hutool.core.bean.BeanUtil
;
import
cn.hutool.core.bean.copier.CopyOptions
;
import
cn.hutool.core.bean.copier.CopyOptions
;
import
com.alibaba.fastjson.JSONObject
;
import
com.github.pagehelper.PageInfo
;
import
com.github.pagehelper.PageInfo
;
import
com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO
;
import
com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO
;
import
com.github.wxiaoqi.security.admin.vo.ImiVo
;
import
com.github.wxiaoqi.security.admin.vo.ImiVo
;
...
@@ -10,19 +11,16 @@ import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
...
@@ -10,19 +11,16 @@ import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import
com.github.wxiaoqi.security.common.util.process.ResultCode
;
import
com.github.wxiaoqi.security.common.util.process.ResultCode
;
import
com.github.wxiaoqi.security.common.vo.PageDataVO
;
import
com.github.wxiaoqi.security.common.vo.PageDataVO
;
import
com.mongodb.client.result.DeleteResult
;
import
com.mongodb.client.result.DeleteResult
;
import
com.mongodb.client.result.UpdateResult
;
import
com.xxfc.platform.im.dto.CommentVo
;
import
com.xxfc.platform.im.dto.CommentVo
;
import
com.xxfc.platform.im.dto.PraiseVo
;
import
com.xxfc.platform.im.dto.PraiseVo
;
import
com.xxfc.platform.im.dto.QuestionParamDto
;
import
com.xxfc.platform.im.dto.QuestionParamDto
;
import
com.xxfc.platform.im.model.Comment
;
import
com.xxfc.platform.im.model.*
;
import
com.xxfc.platform.im.model.Msg
;
import
com.xxfc.platform.im.model.Praise
;
import
com.xxfc.platform.im.vo.MsgVo
;
import
com.xxfc.platform.im.vo.MsgVo
;
import
com.xxfc.platform.universal.constant.DictionaryKey
;
import
com.xxfc.platform.universal.constant.DictionaryKey
;
import
com.xxfc.platform.universal.constant.ResCode
;
import
com.xxfc.platform.universal.entity.Dictionary
;
import
com.xxfc.platform.universal.entity.Dictionary
;
import
com.xxfc.platform.universal.feign.ThirdFeign
;
import
com.xxfc.platform.universal.feign.ThirdFeign
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.collections.MapUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.bson.types.ObjectId
;
import
org.bson.types.ObjectId
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
@@ -32,12 +30,12 @@ import org.springframework.data.domain.Sort;
...
@@ -32,12 +30,12 @@ import org.springframework.data.domain.Sort;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Query
;
import
org.springframework.data.mongodb.core.query.Query
;
import
org.springframework.data.mongodb.core.query.Update
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.math.BigDecimal
;
import
java.util.*
;
import
java.util.*
;
import
java.util.stream.Collectors
;
import
static
com
.
xxfc
.
platform
.
universal
.
constant
.
DictionaryKey
.
APP_ORDER
;
import
static
com
.
xxfc
.
platform
.
universal
.
constant
.
DictionaryKey
.
IM_TYPE
;
import
static
com
.
xxfc
.
platform
.
universal
.
constant
.
DictionaryKey
.
IM_TYPE
;
@Service
@Service
...
@@ -280,6 +278,9 @@ public class MsgBiz {
...
@@ -280,6 +278,9 @@ public class MsgBiz {
//String address = AddressUtils.getMapaddress(msg.getLatitude().toString(), msg.getLongitude().toString());
//String address = AddressUtils.getMapaddress(msg.getLatitude().toString(), msg.getLongitude().toString());
msgVo
.
setAddress
(
msg
.
getLocation
());
msgVo
.
setAddress
(
msg
.
getLocation
());
msgVo
.
setMsgId
(
msg
.
getId
().
toString
());
msgVo
.
setMsgId
(
msg
.
getId
().
toString
());
if
(
msg
.
getSource
()
==
null
)
{
//默认是2 兼容以前数据
msgVo
.
setSource
(
2
);
}
}
}
msgVoList
.
add
(
msgVo
);
msgVoList
.
add
(
msgVo
);
}
}
...
@@ -333,4 +334,53 @@ public class MsgBiz {
...
@@ -333,4 +334,53 @@ public class MsgBiz {
return
number
;
return
number
;
}
}
/**
* 后台管理接口
*/
/**
* 新增消息接口
* @param param
* @return
*/
public
Msg
add
(
AddMsgParam
param
)
{
//去redis根据userId是否有数据
//设置一些列参数
Msg
entity
=
Msg
.
build
(
param
.
getUserId
(),
param
.
getNickname
(),
param
);
// 保存商务圈消息
mongoTemplate
.
save
(
entity
);
// 如果musicId不为空维护音乐使用次数
if
(!
StringUtils
.
isEmpty
(
param
.
getMusicId
())){
updateUseCount
(
new
ObjectId
(
param
.
getMusicId
()));
}
if
(
null
!=
param
.
getUserRemindLook
()){
if
(
null
!=
param
.
getUserNotLook
()){
List
<
Integer
>
collect
=
param
.
getUserRemindLook
().
stream
().
filter
(
item
->
param
.
getUserNotLook
().
contains
(
item
)).
collect
(
Collectors
.
toList
());
log
.
info
(
"朋友圈提醒朋友列表:{}, 不给看列表:{}, 交集列表:{}"
,
param
.
getUserRemindLook
(),
param
.
getUserNotLook
(),
JSONObject
.
toJSONString
(
collect
));
param
.
getUserRemindLook
().
removeAll
(
collect
);
if
(
null
==
param
.
getUserRemindLook
()){
return
entity
;
}
}
}
return
entity
;
}
//修改音乐使用次数
public
void
updateUseCount
(
ObjectId
id
){
Query
query
=
new
Query
(
Criteria
.
where
(
"_id"
).
is
(
id
));
MusicInfo
musicInfo
=
mongoTemplate
.
findOne
(
query
,
MusicInfo
.
class
,
"musicInfo"
);
if
(
musicInfo
!=
null
)
{
Update
update
=
new
Update
();
update
.
push
(
"useCount"
,
musicInfo
.
getUseCount
()
+
1
);
UpdateResult
updateResult
=
mongoTemplate
.
updateFirst
(
query
,
update
,
MusicInfo
.
class
,
"musicInfo"
);
log
.
info
(
"修改音乐使用次数: updateResult = {}"
,
updateResult
);
}
}
}
}
xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/rest/MsgController.java
View file @
601df947
...
@@ -2,11 +2,9 @@ package com.xxfc.platform.im.rest;
...
@@ -2,11 +2,9 @@ package com.xxfc.platform.im.rest;
import
com.github.wxiaoqi.security.common.msg.ObjectRestResponse
;
import
com.github.wxiaoqi.security.common.msg.ObjectRestResponse
;
import
com.xxfc.platform.im.biz.MsgBiz
;
import
com.xxfc.platform.im.biz.MsgBiz
;
import
com.xxfc.platform.im.model.AddMsgParam
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
@RestController
@RestController
@RequestMapping
(
"msg"
)
@RequestMapping
(
"msg"
)
...
@@ -40,4 +38,10 @@ public class MsgController {
...
@@ -40,4 +38,10 @@ public class MsgController {
public
ObjectRestResponse
deleteByIds
(
String
ids
)
{
public
ObjectRestResponse
deleteByIds
(
String
ids
)
{
return
msgBiz
.
deleteByList
(
ids
);
return
msgBiz
.
deleteByList
(
ids
);
}
}
@PostMapping
(
value
=
"/bg/app/unauth/addMsg"
)
public
ObjectRestResponse
addMsg
(
@RequestBody
AddMsgParam
param
)
{
return
ObjectRestResponse
.
succ
(
msgBiz
.
add
(
param
));
}
}
}
xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/OrderStatisticsBiz.java
View file @
601df947
...
@@ -46,12 +46,14 @@ public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper, OrderStat
...
@@ -46,12 +46,14 @@ public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper, OrderStat
@Autowired
@Autowired
private
DailyMembersOrderStatisticsBiz
membersStatisticsBiz
;
private
DailyMembersOrderStatisticsBiz
membersStatisticsBiz
;
public
HomePageOrderData
getTotalOrder
(
List
<
Integer
>
companyIds
)
{
public
HomePageOrderData
getTotalOrder
(
List
<
Integer
>
companyIds
,
Integer
dataAll
)
{
HomePageOrderData
result
=
new
HomePageOrderData
();
HomePageOrderData
result
=
new
HomePageOrderData
();
ArrayList
<
HomePageOrderData
>
list
=
new
ArrayList
<>();
ArrayList
<
HomePageOrderData
>
list
=
new
ArrayList
<>();
list
.
add
(
getVehicleHomePageOrderData
(
companyIds
));
list
.
add
(
getVehicleHomePageOrderData
(
companyIds
));
list
.
add
(
getTourHomePageOrderData
(
companyIds
));
list
.
add
(
getTourHomePageOrderData
(
companyIds
));
list
.
add
(
getMemberHomePageOrderData
(
companyIds
));
if
(
1
==
dataAll
)
{
list
.
add
(
getMemberHomePageOrderData
(
companyIds
));
}
result
.
setTotalOrders
(
list
.
stream
().
map
(
HomePageOrderData:
:
getTotalOrders
).
reduce
(
BigDecimal
.
ZERO
,
BigDecimal:
:
add
));
result
.
setTotalOrders
(
list
.
stream
().
map
(
HomePageOrderData:
:
getTotalOrders
).
reduce
(
BigDecimal
.
ZERO
,
BigDecimal:
:
add
));
result
.
setTotalOutstandingDeposit
(
list
.
stream
().
map
(
HomePageOrderData:
:
getTotalOutstandingDeposit
).
reduce
(
BigDecimal
.
ZERO
,
BigDecimal:
:
add
));
result
.
setTotalOutstandingDeposit
(
list
.
stream
().
map
(
HomePageOrderData:
:
getTotalOutstandingDeposit
).
reduce
(
BigDecimal
.
ZERO
,
BigDecimal:
:
add
));
result
.
setAdditionalIndemnity
(
list
.
stream
().
map
(
HomePageOrderData:
:
getAdditionalIndemnity
).
reduce
(
BigDecimal
.
ZERO
,
BigDecimal:
:
add
));
result
.
setAdditionalIndemnity
(
list
.
stream
().
map
(
HomePageOrderData:
:
getAdditionalIndemnity
).
reduce
(
BigDecimal
.
ZERO
,
BigDecimal:
:
add
));
...
...
xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/rest/background/OrderStatisticsController.java
View file @
601df947
...
@@ -111,12 +111,12 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
...
@@ -111,12 +111,12 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
return
ObjectRestResponse
.
succ
(
baseBiz
.
getTourHomePageOrderData
(
companyIds
));
return
ObjectRestResponse
.
succ
(
baseBiz
.
getTourHomePageOrderData
(
companyIds
));
}
}
//只统计会员订单
//只统计会员订单
if
(
TYPE_MEMBER
.
equals
(
type
))
{
if
(
TYPE_MEMBER
.
equals
(
type
)
||
DATA_AUTHORITY
.
equals
(
user
.
getDataAll
())
)
{
return
ObjectRestResponse
.
succ
(
baseBiz
.
getMemberHomePageOrderData
(
companyIds
));
return
ObjectRestResponse
.
succ
(
baseBiz
.
getMemberHomePageOrderData
(
companyIds
));
}
}
//所有订单
//所有订单
if
(
TYPE_TOTAL
.
equals
(
type
))
{
if
(
TYPE_TOTAL
.
equals
(
type
))
{
return
ObjectRestResponse
.
succ
(
baseBiz
.
getTotalOrder
(
companyIds
));
return
ObjectRestResponse
.
succ
(
baseBiz
.
getTotalOrder
(
companyIds
,
user
.
getDataAll
()
));
}
}
return
ObjectRestResponse
.
createFailedResult
(
ResultCode
.
FAILED_CODE
,
"参数错误!"
);
return
ObjectRestResponse
.
createFailedResult
(
ResultCode
.
FAILED_CODE
,
"参数错误!"
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
...
...
xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/entity/VehicleModel.java
View file @
601df947
...
@@ -182,4 +182,8 @@ public class VehicleModel implements Serializable {
...
@@ -182,4 +182,8 @@ public class VehicleModel implements Serializable {
@Column
(
name
=
"img_desc"
)
@Column
(
name
=
"img_desc"
)
@ApiModelProperty
(
"seo*html标签优化"
)
@ApiModelProperty
(
"seo*html标签优化"
)
private
String
imgDesc
;
private
String
imgDesc
;
@Column
(
name
=
"app_show"
)
@ApiModelProperty
(
"是否在App展示"
)
private
Integer
appShow
;
}
}
xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleActiveService.java
View file @
601df947
...
@@ -62,10 +62,12 @@ public class VehicleActiveService {
...
@@ -62,10 +62,12 @@ public class VehicleActiveService {
log
.
info
(
"出车参数: departureVo = {}"
,
departureVo
.
toString
());
log
.
info
(
"出车参数: departureVo = {}"
,
departureVo
.
toString
());
Vehicle
vehicle
=
vehicleBiz
.
selectById
(
departureVo
.
getVehicleId
());
Vehicle
vehicle
=
vehicleBiz
.
selectById
(
departureVo
.
getVehicleId
());
if
(
vehicle
==
null
)
{
if
(
vehicle
==
null
)
{
log
.
info
(
"出车异常,车辆不存在!"
);
throw
new
BaseException
(
ResCode
.
VEHICLE_DEPARTURE_VEHICLE_UNEXIST
.
getDesc
(),
throw
new
BaseException
(
ResCode
.
VEHICLE_DEPARTURE_VEHICLE_UNEXIST
.
getDesc
(),
ResCode
.
VEHICLE_DEPARTURE_VEHICLE_UNEXIST
.
getCode
());
ResCode
.
VEHICLE_DEPARTURE_VEHICLE_UNEXIST
.
getCode
());
}
}
if
(
StringUtils
.
isBlank
(
departureVo
.
getCheckMan
())
||
StringUtils
.
isBlank
(
departureVo
.
getCheckManTel
()))
{
if
(
StringUtils
.
isBlank
(
departureVo
.
getCheckMan
())
||
StringUtils
.
isBlank
(
departureVo
.
getCheckManTel
()))
{
log
.
error
(
"出车 核销人姓名不能为空!"
);
throw
new
BaseException
(
ResCode
.
CHECKUSER_AND_PHONE_NOT_NULL
.
getDesc
(),
throw
new
BaseException
(
ResCode
.
CHECKUSER_AND_PHONE_NOT_NULL
.
getDesc
(),
ResCode
.
CHECKUSER_AND_PHONE_NOT_NULL
.
getCode
());
ResCode
.
CHECKUSER_AND_PHONE_NOT_NULL
.
getCode
());
}
}
...
@@ -74,7 +76,11 @@ public class VehicleActiveService {
...
@@ -74,7 +76,11 @@ public class VehicleActiveService {
ResCode
.
VEHICLE_STATUS_IS_NOT_NORMAL
.
getCode
());
ResCode
.
VEHICLE_STATUS_IS_NOT_NORMAL
.
getCode
());
}
}
//添加出车时间过滤 再出车开始时间前一天至结束时间内可以出车,并且预定记录为已审核状态
//添加出车时间过滤 再出车开始时间前一天至结束时间内可以出车,并且预定记录为已审核状态
checkDateInvalid
(
departureVo
);
try
{
checkDateInvalid
(
departureVo
);
}
catch
(
BaseException
b
)
{
throw
new
BaseException
(
b
.
getMessage
(),
b
.
getStatus
());
}
Integer
MileageLift
=
vehicle
.
getMileageLastUpdate
();
Integer
MileageLift
=
vehicle
.
getMileageLastUpdate
();
Integer
MileageLift1
=
departureVo
.
getMileage
();
Integer
MileageLift1
=
departureVo
.
getMileage
();
if
(
MileageLift1
==
null
)
{
if
(
MileageLift1
==
null
)
{
...
@@ -259,7 +265,7 @@ public class VehicleActiveService {
...
@@ -259,7 +265,7 @@ public class VehicleActiveService {
throw
new
BaseException
(
ResCode
.
VEHICLE_UNBOOK_FAIL
.
getDesc
(),
ResCode
.
VEHICLE_UNBOOK_FAIL
.
getCode
());
throw
new
BaseException
(
ResCode
.
VEHICLE_UNBOOK_FAIL
.
getDesc
(),
ResCode
.
VEHICLE_UNBOOK_FAIL
.
getCode
());
}
}
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
info
(
"提前还车失败,bookVehicleVo = {}"
,
bookVehicleVo
.
toString
());
log
.
error
(
"提前还车失败,bookVehicleVo = {}"
,
bookVehicleVo
.
toString
());
e
.
printStackTrace
();
e
.
printStackTrace
();
}
}
}
else
if
(
actualArrivalDate
.
compareTo
(
arrivalDate
)
>
0
)
{
//实际还车时间大于预计还车时间
}
else
if
(
actualArrivalDate
.
compareTo
(
arrivalDate
)
>
0
)
{
//实际还车时间大于预计还车时间
...
@@ -339,6 +345,7 @@ public class VehicleActiveService {
...
@@ -339,6 +345,7 @@ public class VehicleActiveService {
}
}
}
}
if
(!(
startDate
.
minusDays
(
1
).
compareTo
(
DateTime
.
now
())
<=
0
&&
DateTime
.
now
().
compareTo
(
endDate
)
<=
0
&&
vehicleBookRecord
.
getStatus
()
==
VehicleBookRecordStatus
.
APPROVE
.
getCode
()
&&
(
list
==
null
||
list
.
size
()
<=
0
)))
{
if
(!(
startDate
.
minusDays
(
1
).
compareTo
(
DateTime
.
now
())
<=
0
&&
DateTime
.
now
().
compareTo
(
endDate
)
<=
0
&&
vehicleBookRecord
.
getStatus
()
==
VehicleBookRecordStatus
.
APPROVE
.
getCode
()
&&
(
list
==
null
||
list
.
size
()
<=
0
)))
{
log
.
error
(
"出车过滤,有正常未还车记录,请按照预定的日期出车"
);
throw
new
BaseException
(
ResCode
.
VEHICLE_DEPARTURE_DATE_IS_NOT_ABLED
.
getDesc
(),
throw
new
BaseException
(
ResCode
.
VEHICLE_DEPARTURE_DATE_IS_NOT_ABLED
.
getDesc
(),
ResCode
.
VEHICLE_DEPARTURE_DATE_IS_NOT_ABLED
.
getCode
());
ResCode
.
VEHICLE_DEPARTURE_DATE_IS_NOT_ABLED
.
getCode
());
}
}
...
...
xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBookRecordBiz.java
View file @
601df947
...
@@ -251,14 +251,18 @@ public class VehicleBookRecordBiz extends BaseBiz<VehicleBookRecordMapper, Vehic
...
@@ -251,14 +251,18 @@ public class VehicleBookRecordBiz extends BaseBiz<VehicleBookRecordMapper, Vehic
if
(
vehicleBookRecord
!=
null
)
{
if
(
vehicleBookRecord
!=
null
)
{
vehicleBookRecord
.
setRetCompany
(
bookRecordUpdateLog
.
getNewRetCompanyId
());
vehicleBookRecord
.
setRetCompany
(
bookRecordUpdateLog
.
getNewRetCompanyId
());
int
a
=
updateSelectiveByIdRe
(
vehicleBookRecord
);
int
a
=
updateSelectiveByIdRe
(
vehicleBookRecord
);
log
.
info
(
"修改停靠分公司后预定记录: {}"
+
vehicleBookRecord
.
toString
());
log
.
info
(
vehicleBookRecord
.
toString
());
if
(
a
<=
0
)
{
if
(
a
<=
0
)
{
return
ObjectRestResponse
.
createDefaultFail
();
return
ObjectRestResponse
.
createDefaultFail
();
}
}
Vehicle
vehicle
=
vehicleBiz
.
selectById
(
vehicleBookRecord
.
getVehicleId
());
//出行中才修改车辆停靠分公司
if
(
vehicle
!=
null
)
{
VehicleDepartureLogVo
vehicleDepartureLogVo
=
vehicleDepartureService
.
getByRecordId
(
vehicleBookRecord
.
getId
());
vehicle
.
setParkBranchCompanyId
(
vehicleBookRecord
.
getRetCompany
());
if
(
vehicleDepartureLogVo
!=
null
&&
vehicleDepartureLogVo
.
getState
()
==
0
)
{
vehicleBiz
.
updateSelectiveByIdRe
(
vehicle
);
Vehicle
vehicle
=
vehicleBiz
.
selectById
(
vehicleBookRecord
.
getVehicleId
());
if
(
vehicle
!=
null
)
{
vehicle
.
setParkBranchCompanyId
(
vehicleBookRecord
.
getRetCompany
());
vehicleBiz
.
updateSelectiveByIdRe
(
vehicle
);
}
}
}
return
bookRecordUpdateLogBiz
.
save
(
bookRecordUpdateLog
);
return
bookRecordUpdateLogBiz
.
save
(
bookRecordUpdateLog
);
}
else
{
}
else
{
...
...
xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/VehicleController.java
View file @
601df947
...
@@ -78,6 +78,9 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use
...
@@ -78,6 +78,9 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use
@Autowired
@Autowired
BookRecordUpdateLogBiz
bookRecordUpdateLogBiz
;
BookRecordUpdateLogBiz
bookRecordUpdateLogBiz
;
@Autowired
VehicleDepartureService
vehicleDepartureService
;
public
UserFeign
getUserFeign
()
{
public
UserFeign
getUserFeign
()
{
return
userFeign
;
return
userFeign
;
...
@@ -335,10 +338,13 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use
...
@@ -335,10 +338,13 @@ public class VehicleController extends BaseController<VehicleBiz> implements Use
bookRecordUpdateLog
.
setOperaterId
(
userDTO
.
getId
());
bookRecordUpdateLog
.
setOperaterId
(
userDTO
.
getId
());
bookRecordUpdateLog
.
setOperaterName
(
userDTO
.
getName
());
bookRecordUpdateLog
.
setOperaterName
(
userDTO
.
getName
());
bookRecordUpdateLog
.
setCreateTime
(
new
Date
());
bookRecordUpdateLog
.
setCreateTime
(
new
Date
());
Vehicle
vehicle
=
vehicleBiz
.
selectById
(
oldValue
.
getVehicleId
());
VehicleDepartureLogVo
vehicleDepartureLogVo
=
vehicleDepartureService
.
getByRecordId
(
oldValue
.
getId
());
if
(
vehicle
!=
null
)
{
if
(
vehicleDepartureLogVo
!=
null
&&
vehicleDepartureLogVo
.
getState
()
==
0
)
{
vehicle
.
setParkBranchCompanyId
(
oldValue
.
getRetCompany
());
Vehicle
vehicle
=
vehicleBiz
.
selectById
(
oldValue
.
getVehicleId
());
vehicleBiz
.
updateSelectiveByIdRe
(
vehicle
);
if
(
vehicle
!=
null
)
{
vehicle
.
setParkBranchCompanyId
(
oldValue
.
getRetCompany
());
vehicleBiz
.
updateSelectiveByIdRe
(
vehicle
);
}
}
}
vehicleBookRecordBiz
.
updateSelectiveByIdRe
(
vehicleBookRecord
);
vehicleBookRecordBiz
.
updateSelectiveByIdRe
(
vehicleBookRecord
);
return
bookRecordUpdateLogBiz
.
save
(
bookRecordUpdateLog
);
return
bookRecordUpdateLogBiz
.
save
(
bookRecordUpdateLog
);
...
...
xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/VehicleModelController.java
View file @
601df947
...
@@ -18,6 +18,7 @@ import com.xxfc.platform.vehicle.biz.VehicleCataBiz;
...
@@ -18,6 +18,7 @@ import com.xxfc.platform.vehicle.biz.VehicleCataBiz;
import
com.xxfc.platform.vehicle.biz.VehicleModelBiz
;
import
com.xxfc.platform.vehicle.biz.VehicleModelBiz
;
import
com.xxfc.platform.vehicle.biz.VehiclePlatCataBiz
;
import
com.xxfc.platform.vehicle.biz.VehiclePlatCataBiz
;
import
com.xxfc.platform.vehicle.common.RestResponse
;
import
com.xxfc.platform.vehicle.common.RestResponse
;
import
com.xxfc.platform.vehicle.constant.ResCode.ResCode
;
import
com.xxfc.platform.vehicle.entity.VehicleCata
;
import
com.xxfc.platform.vehicle.entity.VehicleCata
;
import
com.xxfc.platform.vehicle.entity.VehicleModel
;
import
com.xxfc.platform.vehicle.entity.VehicleModel
;
import
com.xxfc.platform.vehicle.pojo.VModelDetailVO
;
import
com.xxfc.platform.vehicle.pojo.VModelDetailVO
;
...
@@ -292,7 +293,20 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
...
@@ -292,7 +293,20 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
}
}
}
}
@ApiOperation
(
"是否在App展示"
)
@PostMapping
(
value
=
"/bg/updateAppShow"
)
public
ObjectRestResponse
<
VehicleModel
>
updateAppShow
(
@RequestBody
VehicleModel
vehicleModel
)
{
if
(
vehicleModel
==
null
||
vehicleModel
.
getId
()
==
null
)
{
return
ObjectRestResponse
.
paramIsEmpty
();
}
VehicleModel
oldValue
=
vehicleModelBiz
.
selectById
(
vehicleModel
.
getId
());
if
(
oldValue
==
null
)
{
return
ObjectRestResponse
.
createFailedResult
(
ResCode
.
FIND_DATA_NOT_EXIST
.
getCode
(),
ResCode
.
FIND_DATA_NOT_EXIST
.
getDesc
());
}
oldValue
.
setAppShow
(
vehicleModel
.
getAppShow
());
vehicleModelBiz
.
updateByPrimaryKeySelective
(
oldValue
);
return
ObjectRestResponse
.
succ
();
}
@ApiOperation
(
"删除"
)
@ApiOperation
(
"删除"
)
@DeleteMapping
(
value
=
"/app/{id}"
)
@DeleteMapping
(
value
=
"/app/{id}"
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment