Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Z
zhny
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
王夏晖
zhny
Commits
69e2b614
Commit
69e2b614
authored
May 30, 2018
by
王夏晖
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
系统管理bug修改
parent
77a148fb
Changes
17
Hide whitespace changes
Inline
Side-by-side
Showing
17 changed files
with
29 additions
and
24 deletions
+29
-24
BusDeviceMeterController.java
.../business/manage/controller/BusDeviceMeterController.java
+1
-1
BusDeviceParamController.java
.../business/manage/controller/BusDeviceParamController.java
+1
-1
BusDeviceTpController.java
...oft/business/manage/controller/BusDeviceTpController.java
+1
-1
BusFactoryController.java
...soft/business/manage/controller/BusFactoryController.java
+1
-1
BusLibraryParamController.java
...business/manage/controller/BusLibraryParamController.java
+1
-1
BusParamReferController.java
...t/business/manage/controller/BusParamReferController.java
+1
-1
BusProjectAreaController.java
.../business/manage/controller/BusProjectAreaController.java
+1
-1
BusProjectController.java
...soft/business/manage/controller/BusProjectController.java
+6
-6
BusProjectZoneController.java
.../business/manage/controller/BusProjectZoneController.java
+1
-1
BusSavingController.java
...isoft/business/manage/controller/BusSavingController.java
+2
-1
BusTeamController.java
...rcisoft/business/manage/controller/BusTeamController.java
+1
-1
EnergyPriceController.java
...oft/business/manage/controller/EnergyPriceController.java
+1
-1
BusProjectZoneServiceImpl.java
...siness/manage/service/impl/BusProjectZoneServiceImpl.java
+1
-1
UserController.java
...isoft/business/system/user/controller/UserController.java
+3
-0
UserRepository.java
.../org/rcisoft/business/system/user/dao/UserRepository.java
+1
-1
UserServiceImpl.java
...ft/business/system/user/service/impl/UserServiceImpl.java
+1
-1
MqttClient.java
src/main/java/org/rcisoft/mqttclient/MqttClient.java
+5
-4
No files found.
src/main/java/org/rcisoft/business/manage/controller/BusDeviceMeterController.java
View file @
69e2b614
...
@@ -35,7 +35,7 @@ public class BusDeviceMeterController extends PaginationController<BusDeviceMete
...
@@ -35,7 +35,7 @@ public class BusDeviceMeterController extends PaginationController<BusDeviceMete
@ApiOperation
(
value
=
"修改表具"
,
notes
=
"修改表具"
)
@ApiOperation
(
value
=
"修改表具"
,
notes
=
"修改表具"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusDeviceMeter
busDeviceMeter
)
{
public
Result
update
(
@Valid
BusDeviceMeter
busDeviceMeter
)
{
PersistModel
data
=
busDeviceMeterServiceImpl
.
merge
(
busDeviceMeter
);
PersistModel
data
=
busDeviceMeterServiceImpl
.
merge
(
busDeviceMeter
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/controller/BusDeviceParamController.java
View file @
69e2b614
...
@@ -40,7 +40,7 @@ public class BusDeviceParamController extends PaginationController<BusDevicePara
...
@@ -40,7 +40,7 @@ public class BusDeviceParamController extends PaginationController<BusDevicePara
@ApiOperation
(
value
=
"修改设备参数模板"
,
notes
=
"修改设备参数模板"
)
@ApiOperation
(
value
=
"修改设备参数模板"
,
notes
=
"修改设备参数模板"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@RequestBody
BusDeviceParamList
busDeviceParamList
)
{
public
Result
update
(
@RequestBody
BusDeviceParamList
busDeviceParamList
)
{
PersistModel
data
=
busDeviceParamServiceImpl
.
merge
(
busDeviceParamList
);
PersistModel
data
=
busDeviceParamServiceImpl
.
merge
(
busDeviceParamList
);
return
Result
.
builder
(
data
,
return
Result
.
builder
(
data
,
...
...
src/main/java/org/rcisoft/business/manage/controller/BusDeviceTpController.java
View file @
69e2b614
...
@@ -43,7 +43,7 @@ public class BusDeviceTpController extends PaginationController<BusDeviceTp> {
...
@@ -43,7 +43,7 @@ public class BusDeviceTpController extends PaginationController<BusDeviceTp> {
@ApiOperation
(
value
=
"修改设备类型"
,
notes
=
"修改设备类型"
)
@ApiOperation
(
value
=
"修改设备类型"
,
notes
=
"修改设备类型"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusDeviceTp
busDeviceTp
)
{
public
Result
update
(
@Valid
BusDeviceTp
busDeviceTp
)
{
PersistModel
data
=
busDeviceTpServiceImpl
.
merge
(
busDeviceTp
);
PersistModel
data
=
busDeviceTpServiceImpl
.
merge
(
busDeviceTp
);
return
Result
.
builder
(
data
,
return
Result
.
builder
(
data
,
...
...
src/main/java/org/rcisoft/business/manage/controller/BusFactoryController.java
View file @
69e2b614
...
@@ -44,7 +44,7 @@ public class BusFactoryController extends PaginationController<BusFactory> {
...
@@ -44,7 +44,7 @@ public class BusFactoryController extends PaginationController<BusFactory> {
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusFactory
busFactory
)
{
public
Result
update
(
@Valid
BusFactory
busFactory
)
{
PersistModel
data
=
busFactoryServiceImpl
.
merge
(
busFactory
);
PersistModel
data
=
busFactoryServiceImpl
.
merge
(
busFactory
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/controller/BusLibraryParamController.java
View file @
69e2b614
...
@@ -40,7 +40,7 @@ public class BusLibraryParamController extends PaginationController<BusLibraryPa
...
@@ -40,7 +40,7 @@ public class BusLibraryParamController extends PaginationController<BusLibraryPa
@ApiOperation
(
value
=
"修改设备参数库模板"
,
notes
=
"修改设备参数库模板"
)
@ApiOperation
(
value
=
"修改设备参数库模板"
,
notes
=
"修改设备参数库模板"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@RequestBody
BusLibraryParamList
busLibraryParamList
)
{
public
Result
update
(
@RequestBody
BusLibraryParamList
busLibraryParamList
)
{
PersistModel
data
=
busLibraryParamServiceImpl
.
merge
(
busLibraryParamList
);
PersistModel
data
=
busLibraryParamServiceImpl
.
merge
(
busLibraryParamList
);
return
Result
.
builder
(
data
,
return
Result
.
builder
(
data
,
...
...
src/main/java/org/rcisoft/business/manage/controller/BusParamReferController.java
View file @
69e2b614
...
@@ -29,7 +29,7 @@ public class BusParamReferController extends PaginationController<BusParamRefer>
...
@@ -29,7 +29,7 @@ public class BusParamReferController extends PaginationController<BusParamRefer>
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusParamRefer
busParamRefer
)
{
public
Result
update
(
@Valid
BusParamRefer
busParamRefer
)
{
PersistModel
data
=
busParamReferServiceImpl
.
merge
(
busParamRefer
);
PersistModel
data
=
busParamReferServiceImpl
.
merge
(
busParamRefer
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/controller/BusProjectAreaController.java
View file @
69e2b614
...
@@ -28,7 +28,7 @@ public class BusProjectAreaController extends PaginationController<BusProjectAre
...
@@ -28,7 +28,7 @@ public class BusProjectAreaController extends PaginationController<BusProjectAre
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@RequestBody
BusProjectAreaList
busProjectAreaList
)
{
public
Result
update
(
@RequestBody
BusProjectAreaList
busProjectAreaList
)
{
PersistModel
data
=
busProjectAreaServiceImpl
.
merge
(
busProjectAreaList
);
PersistModel
data
=
busProjectAreaServiceImpl
.
merge
(
busProjectAreaList
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/controller/BusProjectController.java
View file @
69e2b614
...
@@ -47,7 +47,7 @@ public class BusProjectController extends PaginationController<BusProject> {
...
@@ -47,7 +47,7 @@ public class BusProjectController extends PaginationController<BusProject> {
@ApiOperation
(
value
=
"添加项目"
,
notes
=
"添加项目"
)
@ApiOperation
(
value
=
"添加项目"
,
notes
=
"添加项目"
)
@
Po
stMapping
(
value
=
"/add"
)
@
Reque
stMapping
(
value
=
"/add"
)
public
Result
add
(
@Valid
BusProject
busProject
)
{
public
Result
add
(
@Valid
BusProject
busProject
)
{
PersistModel
data
=
busProjectServiceImpl
.
save
(
busProject
);
PersistModel
data
=
busProjectServiceImpl
.
save
(
busProject
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
@@ -55,14 +55,14 @@ public class BusProjectController extends PaginationController<BusProject> {
...
@@ -55,14 +55,14 @@ public class BusProjectController extends PaginationController<BusProject> {
@ApiOperation
(
value
=
"修改项目信息"
,
notes
=
"修改项目信息"
)
@ApiOperation
(
value
=
"修改项目信息"
,
notes
=
"修改项目信息"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusProject
busProject
)
{
public
Result
update
(
@Valid
BusProject
busProject
)
{
PersistModel
data
=
busProjectServiceImpl
.
merge
(
busProject
);
PersistModel
data
=
busProjectServiceImpl
.
merge
(
busProject
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
}
}
@ApiOperation
(
value
=
"删除项目"
,
notes
=
"删除项目"
)
@ApiOperation
(
value
=
"删除项目"
,
notes
=
"删除项目"
)
@
Delete
Mapping
(
"/delete"
)
@
Request
Mapping
(
"/delete"
)
public
Result
delete
(
@RequestParam
String
proId
)
{
public
Result
delete
(
@RequestParam
String
proId
)
{
BusProject
busProject
=
new
BusProject
();
BusProject
busProject
=
new
BusProject
();
busProject
.
setProId
(
proId
)
;
busProject
.
setProId
(
proId
)
;
...
@@ -71,7 +71,7 @@ public class BusProjectController extends PaginationController<BusProject> {
...
@@ -71,7 +71,7 @@ public class BusProjectController extends PaginationController<BusProject> {
}
}
@ApiOperation
(
value
=
"根据条件查询单个项目信息"
,
notes
=
"根据条件查询单个项目信息"
)
@ApiOperation
(
value
=
"根据条件查询单个项目信息"
,
notes
=
"根据条件查询单个项目信息"
)
@
Ge
tMapping
(
"/detail"
)
@
Reques
tMapping
(
"/detail"
)
public
Result
detail
(
@Valid
BusProject
busProject
)
{
public
Result
detail
(
@Valid
BusProject
busProject
)
{
return
Result
.
builder
(
new
PersistModel
(
1
),
return
Result
.
builder
(
new
PersistModel
(
1
),
MessageConstant
.
MESSAGE_ALERT_SUCCESS
,
MessageConstant
.
MESSAGE_ALERT_SUCCESS
,
...
@@ -80,14 +80,14 @@ public class BusProjectController extends PaginationController<BusProject> {
...
@@ -80,14 +80,14 @@ public class BusProjectController extends PaginationController<BusProject> {
}
}
@ApiOperation
(
value
=
"查看 集合"
,
notes
=
"查看 集合"
)
@ApiOperation
(
value
=
"查看 集合"
,
notes
=
"查看 集合"
)
@
Ge
tMapping
(
value
=
"/queryBusProjectByPagination"
)
@
Reques
tMapping
(
value
=
"/queryBusProjectByPagination"
)
public
GridModel
listByPagination
(
BusProject
busProject
)
{
public
GridModel
listByPagination
(
BusProject
busProject
)
{
busProjectServiceImpl
.
findAllByPagination
(
getPaginationUtility
(),
busProject
);
busProjectServiceImpl
.
findAllByPagination
(
getPaginationUtility
(),
busProject
);
return
getGridModelResponse
();
return
getGridModelResponse
();
}
}
@ApiOperation
(
value
=
"查询用户权限项目"
,
notes
=
"查询用户权限项目"
)
@ApiOperation
(
value
=
"查询用户权限项目"
,
notes
=
"查询用户权限项目"
)
@
Ge
tMapping
(
value
=
"/queryBusProjectByUser"
)
@
Reques
tMapping
(
value
=
"/queryBusProjectByUser"
)
public
Result
queryBusProjectByUser
()
{
public
Result
queryBusProjectByUser
()
{
String
userId
=
UserUtil
.
getUserInfoProp
(
getToken
(),
UserUtil
.
USER_ID
);
String
userId
=
UserUtil
.
getUserInfoProp
(
getToken
(),
UserUtil
.
USER_ID
);
Map
<
String
,
Object
>
map
=
new
HashMap
<>();
Map
<
String
,
Object
>
map
=
new
HashMap
<>();
...
...
src/main/java/org/rcisoft/business/manage/controller/BusProjectZoneController.java
View file @
69e2b614
...
@@ -36,7 +36,7 @@ public class BusProjectZoneController {
...
@@ -36,7 +36,7 @@ public class BusProjectZoneController {
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusProjectZone
busProjectZone
)
{
public
Result
update
(
@Valid
BusProjectZone
busProjectZone
)
{
PersistModel
data
=
busProjectZoneServiceImpl
.
merge
(
busProjectZone
);
PersistModel
data
=
busProjectZoneServiceImpl
.
merge
(
busProjectZone
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/controller/BusSavingController.java
View file @
69e2b614
...
@@ -13,6 +13,7 @@ import org.rcisoft.core.model.PersistModel;
...
@@ -13,6 +13,7 @@ import org.rcisoft.core.model.PersistModel;
import
org.rcisoft.core.result.Result
;
import
org.rcisoft.core.result.Result
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.PathVariable
;
import
org.springframework.web.bind.annotation.PathVariable
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.springframework.web.bind.annotation.RestController
;
...
@@ -49,7 +50,7 @@ public class BusSavingController extends PaginationController<BusSaving> {
...
@@ -49,7 +50,7 @@ public class BusSavingController extends PaginationController<BusSaving> {
@ApiImplicitParam
(
name
=
"tm"
,
value
=
"从业时间"
,
dataType
=
"字符串"
),
@ApiImplicitParam
(
name
=
"tm"
,
value
=
"从业时间"
,
dataType
=
"字符串"
),
@ApiImplicitParam
(
name
=
"performance"
,
value
=
"项目业绩"
,
dataType
=
"字符串"
)
@ApiImplicitParam
(
name
=
"performance"
,
value
=
"项目业绩"
,
dataType
=
"字符串"
)
})
})
@
Reque
stMapping
(
"/update"
)
@
Po
stMapping
(
"/update"
)
public
Result
update
(
@Valid
BusSaving
busSaving
)
{
public
Result
update
(
@Valid
BusSaving
busSaving
)
{
Integer
result
=
busSavingServiceImpl
.
update
(
busSaving
);
Integer
result
=
busSavingServiceImpl
.
update
(
busSaving
);
return
Result
.
builder
(
new
PersistModel
(
result
),
MessageConstant
.
MESSAGE_ALERT_SUCCESS
,
MessageConstant
.
MESSAGE_ALERT_ERROR
,
result
);
return
Result
.
builder
(
new
PersistModel
(
result
),
MessageConstant
.
MESSAGE_ALERT_SUCCESS
,
MessageConstant
.
MESSAGE_ALERT_ERROR
,
result
);
...
...
src/main/java/org/rcisoft/business/manage/controller/BusTeamController.java
View file @
69e2b614
...
@@ -44,7 +44,7 @@ public class BusTeamController extends PaginationController<BusTeam> {
...
@@ -44,7 +44,7 @@ public class BusTeamController extends PaginationController<BusTeam> {
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@Valid
BusTeam
busTeam
)
{
public
Result
update
(
@Valid
BusTeam
busTeam
)
{
PersistModel
data
=
busTeamServiceImpl
.
merge
(
busTeam
);
PersistModel
data
=
busTeamServiceImpl
.
merge
(
busTeam
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/controller/EnergyPriceController.java
View file @
69e2b614
...
@@ -29,7 +29,7 @@ public class EnergyPriceController extends PaginationController<EnergyPrice> {
...
@@ -29,7 +29,7 @@ public class EnergyPriceController extends PaginationController<EnergyPrice> {
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@ApiOperation
(
value
=
"修改"
,
notes
=
"修改"
)
@P
u
tMapping
(
"/update"
)
@P
os
tMapping
(
"/update"
)
public
Result
update
(
@RequestBody
EnergyPriceList
energyPriceList
)
{
public
Result
update
(
@RequestBody
EnergyPriceList
energyPriceList
)
{
PersistModel
data
=
energyPriceServiceImpl
.
merge
(
energyPriceList
);
PersistModel
data
=
energyPriceServiceImpl
.
merge
(
energyPriceList
);
return
Result
.
builder
(
data
);
return
Result
.
builder
(
data
);
...
...
src/main/java/org/rcisoft/business/manage/service/impl/BusProjectZoneServiceImpl.java
View file @
69e2b614
...
@@ -33,7 +33,7 @@ public class BusProjectZoneServiceImpl implements BusProjectZoneService {
...
@@ -33,7 +33,7 @@ public class BusProjectZoneServiceImpl implements BusProjectZoneService {
public
PersistModel
merge
(
BusProjectZone
busProjectZone
)
{
public
PersistModel
merge
(
BusProjectZone
busProjectZone
)
{
Integer
line
=
0
;
Integer
line
=
0
;
String
message
=
""
;
String
message
=
""
;
Example
example
=
new
Example
(
Bus
Factory
.
class
);
Example
example
=
new
Example
(
Bus
ProjectZone
.
class
);
Example
.
Criteria
criteria
=
example
.
createCriteria
();
Example
.
Criteria
criteria
=
example
.
createCriteria
();
criteria
.
andEqualTo
(
"bldZoneId"
,
busProjectZone
.
getBldZoneId
());
criteria
.
andEqualTo
(
"bldZoneId"
,
busProjectZone
.
getBldZoneId
());
if
(
busProjectZone
.
getBldZoneId
()!=
null
&&
!
busProjectZone
.
getBldZoneId
().
equals
(
""
)){
if
(
busProjectZone
.
getBldZoneId
()!=
null
&&
!
busProjectZone
.
getBldZoneId
().
equals
(
""
)){
...
...
src/main/java/org/rcisoft/business/system/user/controller/UserController.java
View file @
69e2b614
...
@@ -65,6 +65,9 @@ public class UserController extends PaginationController<SysUser> {
...
@@ -65,6 +65,9 @@ public class UserController extends PaginationController<SysUser> {
public
Result
updateUser
(
@RequestBody
UserDto
userDto
){
public
Result
updateUser
(
@RequestBody
UserDto
userDto
){
String
userId
=
UserUtil
.
getUserInfoProp
(
getToken
(),
UserUtil
.
USER_ID
);
String
userId
=
UserUtil
.
getUserInfoProp
(
getToken
(),
UserUtil
.
USER_ID
);
SysUser
sysUser
=
userDto
.
getSysUser
();
SysUser
sysUser
=
userDto
.
getSysUser
();
if
(
userDto
.
getSysUser
().
getUserId
()!=
null
){
userId
=
userDto
.
getSysUser
().
getUserId
();
}
sysUser
.
setUserId
(
userId
);
sysUser
.
setUserId
(
userId
);
SysAdmins
sysAdmins
=
userDto
.
getSysAdmins
();
SysAdmins
sysAdmins
=
userDto
.
getSysAdmins
();
SysOwner
sysOwner
=
userDto
.
getSysOwner
();
SysOwner
sysOwner
=
userDto
.
getSysOwner
();
...
...
src/main/java/org/rcisoft/business/system/user/dao/UserRepository.java
View file @
69e2b614
...
@@ -41,7 +41,7 @@ public interface UserRepository extends BaseMapper<SysUser>{
...
@@ -41,7 +41,7 @@ public interface UserRepository extends BaseMapper<SysUser>{
* 查询所有用户
* 查询所有用户
* @return
* @return
*/
*/
@Select
(
"<script>select a.USER_ID,a.USER_NM,a.USER_TP "
+
@Select
(
"<script>select a.USER_ID,a.USER_NM,a.USER_
NICK_NAME,a.USER_
TP "
+
"<if test=\"stable != null\">,b.*</if> "
+
"<if test=\"stable != null\">,b.*</if> "
+
"from sys_user a "
+
"from sys_user a "
+
"<if test=\"stable != null\">left join ${stable} b on a.USER_ID = b.USER_ID </if> "
+
"<if test=\"stable != null\">left join ${stable} b on a.USER_ID = b.USER_ID </if> "
+
...
...
src/main/java/org/rcisoft/business/system/user/service/impl/UserServiceImpl.java
View file @
69e2b614
...
@@ -151,7 +151,7 @@ public class UserServiceImpl implements UserService {
...
@@ -151,7 +151,7 @@ public class UserServiceImpl implements UserService {
String
userId
=
sysUser
.
getUserId
();
String
userId
=
sysUser
.
getUserId
();
String
userTp
=
sysUser
.
getUserTp
();
String
userTp
=
sysUser
.
getUserTp
();
try
{
try
{
if
(
UserTpConstant
.
TP_ADMIN
.
equals
(
userTp
))
{
if
(
UserTpConstant
.
TP_ADMIN
.
equals
(
userTp
)
||
UserTpConstant
.
TP_SUPER_ADMIN
.
equals
(
userTp
)
)
{
SysAdmins
sysAdminsByUserId
=
adminRepository
.
getSysAdminsByUserId
(
userId
);
SysAdmins
sysAdminsByUserId
=
adminRepository
.
getSysAdminsByUserId
(
userId
);
if
(
null
!=
sysAdminsByUserId
){
if
(
null
!=
sysAdminsByUserId
){
sysAdmins
.
setAdminId
(
sysAdminsByUserId
.
getAdminId
());
sysAdmins
.
setAdminId
(
sysAdminsByUserId
.
getAdminId
());
...
...
src/main/java/org/rcisoft/mqttclient/MqttClient.java
View file @
69e2b614
...
@@ -37,11 +37,7 @@ public class MqttClient {
...
@@ -37,11 +37,7 @@ public class MqttClient {
String
devStr
=
""
;
String
devStr
=
""
;
try
{
try
{
JSONObject
jb
=
JSONArray
.
parseObject
(
content
.
substring
(
1
,
content
.
length
()-
1
));
JSONObject
jb
=
JSONArray
.
parseObject
(
content
.
substring
(
1
,
content
.
length
()-
1
));
Map
<
String
,
Object
>
map
=
new
HashMap
<>();
String
jwnum
=
jb
.
getString
(
"PHONE"
);
//网关编号
String
jwnum
=
jb
.
getString
(
"PHONE"
);
//网关编号
map
.
put
(
"pro_id"
,
jwnum
);
referMap
=
totalService
.
queryBusParamRefer
(
map
);
devStr
=
totalService
.
queryDevByPro
(
jwnum
);
String
time
=
jb
.
getString
(
"TIME"
);
//时间
String
time
=
jb
.
getString
(
"TIME"
);
//时间
JSONObject
jbody
=
jb
.
getJSONObject
(
"body"
);
//数据体
JSONObject
jbody
=
jb
.
getJSONObject
(
"body"
);
//数据体
//String time = DateUtil.getSimepleDate("yyyyMMddHHmmss",new Date());
//String time = DateUtil.getSimepleDate("yyyyMMddHHmmss",new Date());
...
@@ -59,6 +55,11 @@ public class MqttClient {
...
@@ -59,6 +55,11 @@ public class MqttClient {
}
}
System
.
out
.
println
(
"++++++++++++++++++++++++++++++++++"
+
minute
+
"-----"
+
sec
);
System
.
out
.
println
(
"++++++++++++++++++++++++++++++++++"
+
minute
+
"-----"
+
sec
);
if
(
Integer
.
parseInt
(
minute
)%
10
==
0
&&
sec
.
equalsIgnoreCase
(
"00"
)){
//10分钟级的数据,进行存储
if
(
Integer
.
parseInt
(
minute
)%
10
==
0
&&
sec
.
equalsIgnoreCase
(
"00"
)){
//10分钟级的数据,进行存储
Map
<
String
,
Object
>
map
=
new
HashMap
<>();
map
.
put
(
"pro_id"
,
jwnum
);
referMap
=
totalService
.
queryBusParamRefer
(
map
);
devStr
=
totalService
.
queryDevByPro
(
jwnum
);
List
<
String
>
list
=
new
ArrayList
<
String
>();
List
<
String
>
list
=
new
ArrayList
<
String
>();
List
<
TotalOriginal
>
originalList
=
new
ArrayList
<>();
List
<
TotalOriginal
>
originalList
=
new
ArrayList
<>();
List
<
TotalSensor
>
sensorList
=
new
ArrayList
<>();
List
<
TotalSensor
>
sensorList
=
new
ArrayList
<>();
...
...
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