Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
amos-boot-zx-biz
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
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
Jobs
Commits
Open sidebar
项目统一框架
一体化_户用光伏项目代码
amos-boot-zx-biz
Commits
4b44b2ae
Commit
4b44b2ae
authored
Oct 31, 2024
by
chenzhao
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/developer_bw' into developer_bw
parents
50319641
f05fe12e
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
240 additions
and
222 deletions
+240
-222
TestController.java
.../amos/boot/module/hygf/biz/controller/TestController.java
+240
-222
No files found.
amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/TestController.java
View file @
4b44b2ae
package
com
.
yeejoin
.
amos
.
boot
.
module
.
hygf
.
biz
.
controller
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.concurrent.ExecutorService
;
import
java.util.concurrent.Executors
;
import
com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper
;
import
com.qiyuesuo.sdk.v2.bean.Contract
;
import
com.yeejoin.amos.boot.biz.common.controller.BaseController
;
import
com.yeejoin.amos.boot.biz.common.utils.DateUtils
;
import
com.yeejoin.amos.boot.module.hygf.api.entity.*
;
import
com.yeejoin.amos.boot.module.hygf.api.mapper.*
;
import
com.yeejoin.amos.boot.module.hygf.api.util.CommonResponseNewUtil
;
import
com.yeejoin.amos.boot.module.hygf.biz.service.impl.QiyuesuoServiceImpl
;
import
com.yeejoin.amos.boot.module.standard.api.entity.PublicAgencyUser
;
import
com.yeejoin.amos.boot.module.standard.api.mapper.PublicAgencyUserMapper
;
import
com.yeejoin.amos.component.feign.model.FeignClientResult
;
import
com.yeejoin.amos.feign.privilege.Privilege
;
import
com.yeejoin.amos.feign.privilege.model.AgencyUserModel
;
import
com.yeejoin.amos.feign.privilege.util.AesUtil
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
...
...
@@ -20,17 +26,11 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
import
org.typroject.tyboot.core.restful.doc.TycloudOperation
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
com.yeejoin.amos.boot.biz.common.controller.BaseController
;
import
com.yeejoin.amos.boot.module.hygf.api.util.CommonResponseNewUtil
;
import
com.yeejoin.amos.boot.module.standard.api.entity.PublicAgencyUser
;
import
com.yeejoin.amos.boot.module.standard.api.mapper.PublicAgencyUserMapper
;
import
com.yeejoin.amos.component.feign.model.FeignClientResult
;
import
com.yeejoin.amos.feign.privilege.Privilege
;
import
com.yeejoin.amos.feign.privilege.model.AgencyUserModel
;
import
com.yeejoin.amos.feign.privilege.util.AesUtil
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
java.time.LocalDateTime
;
import
java.time.ZoneId
;
import
java.util.*
;
import
java.util.concurrent.ExecutorService
;
import
java.util.concurrent.Executors
;
/**
* 农户信息
...
...
@@ -44,210 +44,227 @@ import io.swagger.annotations.ApiOperation;
@Slf4j
public
class
TestController
extends
BaseController
{
private
static
final
String
regionRedis
=
"app_region_redis"
;
@Autowired
UnitInfoMapper
unitInfoMapper
;
@Autowired
PublicAgencyUserMapper
publicAgencyUserMapper
;
@Autowired
PowerStationMapper
powerStationMapper
;
@Autowired
QiyuesuoServiceImpl
qiyuesuoService
;
@Autowired
HouseholdContractMapper
householdContractMapper
;
@Autowired
WorkOrderPowerStationMapper
workOrderPowerStationMapper
;
@Autowired
BasicGridRecordMapper
basicGridRecordMapper
;
@Autowired
AcceptanceCheckMapper
acceptanceCheckMapper
;
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@GetMapping
(
value
=
"/initTime"
)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"初始时间"
,
notes
=
"初始时间"
)
public
ResponseModel
<
Object
>
initTime
()
{
// 创建线程池
ExecutorService
executorService
=
Executors
.
newFixedThreadPool
(
5
);
// 提交不同的方法
executorService
.
submit
(
this
::
dealKcTime
);
executorService
.
submit
(
this
::
dealDzhtqyTime
);
executorService
.
submit
(
this
::
dealSgTime
);
executorService
.
submit
(
this
::
dealBwTime
);
executorService
.
submit
(
this
::
dealYsTime
);
// 关闭线程池
executorService
.
shutdown
();
return
CommonResponseNewUtil
.
success
();
}
private
void
dealYsTime
()
{
log
.
info
(
"================开始初始验收时间========================="
);
List
<
Map
<
String
,
Object
>>
ysCreateTime
=
acceptanceCheckMapper
.
getYsCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
ysCreateTime
)
{
LambdaUpdateWrapper
<
AcceptanceCheck
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
AcceptanceCheck:
:
getYsCreateTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
AcceptanceCheck:
:
getInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
acceptanceCheckMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
ysEndTime
=
acceptanceCheckMapper
.
getYsEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
ysEndTime
)
{
LambdaUpdateWrapper
<
AcceptanceCheck
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
AcceptanceCheck:
:
getYsEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
AcceptanceCheck:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
acceptanceCheckMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================验收时间更新完成========================="
);
}
private
void
dealBwTime
()
{
log
.
info
(
"================开始初始并网时间========================="
);
List
<
Map
<
String
,
Object
>>
bwCreateTime
=
basicGridRecordMapper
.
getBwCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
bwCreateTime
)
{
LambdaUpdateWrapper
<
BasicGridRecord
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
BasicGridRecord:
:
getBwCreateTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
BasicGridRecord:
:
getInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
basicGridRecordMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
bwEndTime
=
basicGridRecordMapper
.
getBwEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
bwEndTime
)
{
LambdaUpdateWrapper
<
BasicGridRecord
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
BasicGridRecord:
:
getBwEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
BasicGridRecord:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
basicGridRecordMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================并网时间更新完成========================="
);
}
private
void
dealSgTime
()
{
log
.
info
(
"================开始初始施工时间========================="
);
List
<
Map
<
String
,
Object
>>
sgCreateTime
=
workOrderPowerStationMapper
.
getSgCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sgCreateTime
)
{
LambdaUpdateWrapper
<
WorkOrderPowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
WorkOrderPowerStation:
:
getSgCreateTime
,
DateUtils
.
dateParse
(
String
.
valueOf
(
stringObjectMap
.
get
(
"time"
))))
.
eq
(
WorkOrderPowerStation:
:
getWorkOrderId
,
stringObjectMap
.
get
(
"workOrderId"
));
workOrderPowerStationMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
sgEndTime
=
workOrderPowerStationMapper
.
getSgEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sgEndTime
)
{
LambdaUpdateWrapper
<
WorkOrderPowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
WorkOrderPowerStation:
:
getSgEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
WorkOrderPowerStation:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
workOrderPowerStationMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================施工时间更新完成========================="
);
}
private
void
dealSjTime
()
{
log
.
info
(
"================开始初始设计时间========================="
);
List
<
Map
<
String
,
Object
>>
sjCreateTime
=
powerStationMapper
.
getSjCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sjCreateTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getSjCreateTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
sjEndTime
=
powerStationMapper
.
getSjEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sjEndTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getSjEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================设计时间更新完成========================="
);
}
private
void
dealDzhtqyTime
()
{
log
.
info
(
"================开始初始电子合同时间========================="
);
Map
<
Long
,
Contract
>
contractMap
=
qiyuesuoService
.
getContractMap
();
contractMap
.
forEach
((
k
,
v
)->{
LambdaUpdateWrapper
<
HouseholdContract
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
HouseholdContract:
:
getDzhtqyCreateTime
,
DateUtils
.
dateParse
(
v
.
getPublishTime
()))
.
eq
(
HouseholdContract:
:
getContractLockId
,
k
);
householdContractMapper
.
update
(
null
,
wrapper
);
});
List
<
Map
<
String
,
Object
>>
dzhtqyEndTime
=
householdContractMapper
.
getDzhtqyEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
dzhtqyEndTime
)
{
LambdaUpdateWrapper
<
HouseholdContract
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
HouseholdContract:
:
getSigningTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
HouseholdContract:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
householdContractMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================电子合同时间更新完成========================="
);
}
private
void
dealKcTime
()
{
log
.
info
(
"================开始初始勘察时间========================="
);
List
<
Map
<
String
,
Object
>>
kcCreateTime
=
powerStationMapper
.
getKcCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
kcCreateTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getKcCreateTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
kcEndTime
=
powerStationMapper
.
getKcEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
kcEndTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getKcEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================勘察时间更新完成========================="
);
dealSjTime
();
}
/**
* 新增农户信息
*
* @return
*/
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@GetMapping
(
value
=
"/initpw"
)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"新增农户信息"
,
notes
=
"新增农户信息"
)
public
ResponseModel
<
Object
>
initpw
()
{
// 经销商管理员
List
<
UnitInfo
>
list
=
unitInfoMapper
.
selectList
(
null
);
for
(
UnitInfo
unitInfo
:
list
)
{
try
{
int
ph
=
unitInfo
.
getAdminPhone
().
length
();
String
npwd
=
"Zxnk_"
+
unitInfo
.
getAdminPhone
().
substring
(
ph
-
4
,
ph
);
String
npwdm
=
AesUtil
.
encode
(
npwd
,
"qaz"
);
unitInfo
.
setAdminLoginPwd
(
npwdm
);
FeignClientResult
<
AgencyUserModel
>
re
=
Privilege
.
agencyUserClient
.
queryByUserId
(
unitInfo
.
getAdminUserId
());
AgencyUserModel
ag
=
re
.
getResult
();
ag
.
setPassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
ag
.
setRePassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
Privilege
.
agencyUserClient
.
restorePassword
(
unitInfo
.
getAdminUserId
());
ag
.
setOriginalPassword
(
AesUtil
.
encode
(
"Z2%Op9.q"
,
"qaz"
));
Privilege
.
agencyUserClient
.
modifyPassword
(
unitInfo
.
getAdminUserId
(),
ag
);
unitInfoMapper
.
updateById
(
unitInfo
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
// 经销商子人员
List
<
PublicAgencyUser
>
list2
=
publicAgencyUserMapper
.
selectList
(
null
);
for
(
PublicAgencyUser
unitInfo
:
list2
)
{
try
{
int
ph
=
unitInfo
.
getEmergencyTelephone
().
length
();
String
npwd
=
"Zxnk_"
+
unitInfo
.
getEmergencyTelephone
().
substring
(
ph
-
4
,
ph
);
String
npwdm
=
AesUtil
.
encode
(
npwd
,
"qaz"
);
unitInfo
.
setPassword
(
npwdm
);
FeignClientResult
<
AgencyUserModel
>
re
=
Privilege
.
agencyUserClient
.
queryByUserId
(
unitInfo
.
getAmosUserId
());
AgencyUserModel
ag
=
re
.
getResult
();
ag
.
setPassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
ag
.
setRePassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
Privilege
.
agencyUserClient
.
restorePassword
(
unitInfo
.
getAmosUserId
());
ag
.
setOriginalPassword
(
AesUtil
.
encode
(
"Z2%Op9.q"
,
"qaz"
));
Privilege
.
agencyUserClient
.
modifyPassword
(
unitInfo
.
getAmosUserId
(),
ag
);
publicAgencyUserMapper
.
updateById
(
unitInfo
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
return
CommonResponseNewUtil
.
success
();
}
private
static
final
String
regionRedis
=
"app_region_redis"
;
@Autowired
UnitInfoMapper
unitInfoMapper
;
@Autowired
PublicAgencyUserMapper
publicAgencyUserMapper
;
@Autowired
PowerStationMapper
powerStationMapper
;
@Autowired
QiyuesuoServiceImpl
qiyuesuoService
;
@Autowired
HouseholdContractMapper
householdContractMapper
;
@Autowired
WorkOrderPowerStationMapper
workOrderPowerStationMapper
;
@Autowired
BasicGridRecordMapper
basicGridRecordMapper
;
@Autowired
AcceptanceCheckMapper
acceptanceCheckMapper
;
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@GetMapping
(
value
=
"/initTime"
)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"初始时间"
,
notes
=
"初始时间"
)
public
ResponseModel
<
Object
>
initTime
()
{
// 创建线程池
ExecutorService
executorService
=
Executors
.
newFixedThreadPool
(
5
);
// 提交不同的方法
executorService
.
submit
(
this
::
dealKcTime
);
executorService
.
submit
(
this
::
dealDzhtqyTime
);
executorService
.
submit
(
this
::
dealSgTime
);
executorService
.
submit
(
this
::
dealBwTime
);
executorService
.
submit
(
this
::
dealYsTime
);
// 关闭线程池
executorService
.
shutdown
();
return
CommonResponseNewUtil
.
success
();
}
private
void
dealYsTime
()
{
log
.
info
(
"================开始初始验收时间========================="
);
List
<
Map
<
String
,
Object
>>
ysCreateTime
=
acceptanceCheckMapper
.
getYsCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
ysCreateTime
)
{
LambdaUpdateWrapper
<
AcceptanceCheck
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
AcceptanceCheck:
:
getYsCreateTime
,
dealHour
(
stringObjectMap
.
get
(
"time"
)))
.
eq
(
AcceptanceCheck:
:
getInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
acceptanceCheckMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
ysEndTime
=
acceptanceCheckMapper
.
getYsEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
ysEndTime
)
{
LambdaUpdateWrapper
<
AcceptanceCheck
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
AcceptanceCheck:
:
getYsEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
AcceptanceCheck:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
acceptanceCheckMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================验收时间更新完成========================="
);
}
private
void
dealBwTime
()
{
log
.
info
(
"================开始初始并网时间========================="
);
List
<
Map
<
String
,
Object
>>
bwCreateTime
=
basicGridRecordMapper
.
getBwCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
bwCreateTime
)
{
LambdaUpdateWrapper
<
BasicGridRecord
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
BasicGridRecord:
:
getBwCreateTime
,
dealHour
(
stringObjectMap
.
get
(
"time"
)))
.
eq
(
BasicGridRecord:
:
getInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
basicGridRecordMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
bwEndTime
=
basicGridRecordMapper
.
getBwEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
bwEndTime
)
{
LambdaUpdateWrapper
<
BasicGridRecord
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
BasicGridRecord:
:
getBwEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
BasicGridRecord:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
basicGridRecordMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================并网时间更新完成========================="
);
}
private
void
dealSgTime
()
{
log
.
info
(
"================开始初始施工时间========================="
);
List
<
Map
<
String
,
Object
>>
sgCreateTime
=
workOrderPowerStationMapper
.
getSgCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sgCreateTime
)
{
LambdaUpdateWrapper
<
WorkOrderPowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
WorkOrderPowerStation:
:
getSgCreateTime
,
DateUtils
.
dateParse
(
String
.
valueOf
(
stringObjectMap
.
get
(
"time"
))))
.
eq
(
WorkOrderPowerStation:
:
getWorkOrderId
,
stringObjectMap
.
get
(
"workOrderId"
));
workOrderPowerStationMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
sgEndTime
=
workOrderPowerStationMapper
.
getSgEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sgEndTime
)
{
LambdaUpdateWrapper
<
WorkOrderPowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
WorkOrderPowerStation:
:
getSgEndTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
WorkOrderPowerStation:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
workOrderPowerStationMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================施工时间更新完成========================="
);
}
private
void
dealSjTime
()
{
log
.
info
(
"================开始初始设计时间========================="
);
List
<
Map
<
String
,
Object
>>
sjCreateTime
=
powerStationMapper
.
getSjCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sjCreateTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getSjCreateTime
,
dealHour
(
stringObjectMap
.
get
(
"time"
)))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
sjEndTime
=
powerStationMapper
.
getSjEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
sjEndTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getSjEndTime
,
dealHour
(
stringObjectMap
.
get
(
"time"
)))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================设计时间更新完成========================="
);
}
private
void
dealDzhtqyTime
()
{
log
.
info
(
"================开始初始电子合同时间========================="
);
Map
<
Long
,
Contract
>
contractMap
=
qiyuesuoService
.
getContractMap
();
contractMap
.
forEach
((
k
,
v
)
->
{
LambdaUpdateWrapper
<
HouseholdContract
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
HouseholdContract:
:
getDzhtqyCreateTime
,
DateUtils
.
dateParse
(
v
.
getPublishTime
()))
.
eq
(
HouseholdContract:
:
getContractLockId
,
k
);
householdContractMapper
.
update
(
null
,
wrapper
);
});
List
<
Map
<
String
,
Object
>>
dzhtqyEndTime
=
householdContractMapper
.
getDzhtqyEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
dzhtqyEndTime
)
{
LambdaUpdateWrapper
<
HouseholdContract
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
HouseholdContract:
:
getSigningTime
,
stringObjectMap
.
get
(
"time"
))
.
eq
(
HouseholdContract:
:
getSequenceNbr
,
stringObjectMap
.
get
(
"sequenceNbr"
));
householdContractMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================电子合同时间更新完成========================="
);
}
private
Date
dealHour
(
Object
dateString
)
{
if
(
Objects
.
isNull
(
dateString
)){
return
null
;
}
// 转换为 LocalDateTime
LocalDateTime
localDateTime
=
LocalDateTime
.
parse
(
String
.
valueOf
(
dateString
));
// 转换为 Date
Date
date
=
Date
.
from
(
localDateTime
.
atZone
(
ZoneId
.
systemDefault
()).
toInstant
());
Calendar
calendar
=
Calendar
.
getInstance
();
calendar
.
setTime
(
date
);
// 加8小时
calendar
.
add
(
Calendar
.
HOUR_OF_DAY
,
8
);
return
calendar
.
getTime
();
}
private
void
dealKcTime
()
{
log
.
info
(
"================开始初始勘察时间========================="
);
List
<
Map
<
String
,
Object
>>
kcCreateTime
=
powerStationMapper
.
getKcCreateTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
kcCreateTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getKcCreateTime
,
dealHour
(
stringObjectMap
.
get
(
"time"
)))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
List
<
Map
<
String
,
Object
>>
kcEndTime
=
powerStationMapper
.
getKcEndTime
();
for
(
Map
<
String
,
Object
>
stringObjectMap
:
kcEndTime
)
{
LambdaUpdateWrapper
<
PowerStation
>
wrapper
=
new
LambdaUpdateWrapper
<>();
wrapper
.
set
(
PowerStation:
:
getKcEndTime
,
dealHour
(
stringObjectMap
.
get
(
"time"
)))
.
eq
(
PowerStation:
:
getProcessInstanceId
,
stringObjectMap
.
get
(
"processInstanceId"
));
powerStationMapper
.
update
(
null
,
wrapper
);
}
log
.
info
(
"================勘察时间更新完成========================="
);
dealSjTime
();
}
/**
* 新增农户信息
*
* @return
*/
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@GetMapping
(
value
=
"/initpw"
)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"新增农户信息"
,
notes
=
"新增农户信息"
)
public
ResponseModel
<
Object
>
initpw
()
{
// 经销商管理员
List
<
UnitInfo
>
list
=
unitInfoMapper
.
selectList
(
null
);
for
(
UnitInfo
unitInfo
:
list
)
{
try
{
int
ph
=
unitInfo
.
getAdminPhone
().
length
();
String
npwd
=
"Zxnk_"
+
unitInfo
.
getAdminPhone
().
substring
(
ph
-
4
,
ph
);
String
npwdm
=
AesUtil
.
encode
(
npwd
,
"qaz"
);
unitInfo
.
setAdminLoginPwd
(
npwdm
);
FeignClientResult
<
AgencyUserModel
>
re
=
Privilege
.
agencyUserClient
.
queryByUserId
(
unitInfo
.
getAdminUserId
());
AgencyUserModel
ag
=
re
.
getResult
();
ag
.
setPassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
ag
.
setRePassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
Privilege
.
agencyUserClient
.
restorePassword
(
unitInfo
.
getAdminUserId
());
ag
.
setOriginalPassword
(
AesUtil
.
encode
(
"Z2%Op9.q"
,
"qaz"
));
Privilege
.
agencyUserClient
.
modifyPassword
(
unitInfo
.
getAdminUserId
(),
ag
);
unitInfoMapper
.
updateById
(
unitInfo
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
// 经销商子人员
List
<
PublicAgencyUser
>
list2
=
publicAgencyUserMapper
.
selectList
(
null
);
for
(
PublicAgencyUser
unitInfo
:
list2
)
{
try
{
int
ph
=
unitInfo
.
getEmergencyTelephone
().
length
();
String
npwd
=
"Zxnk_"
+
unitInfo
.
getEmergencyTelephone
().
substring
(
ph
-
4
,
ph
);
String
npwdm
=
AesUtil
.
encode
(
npwd
,
"qaz"
);
unitInfo
.
setPassword
(
npwdm
);
FeignClientResult
<
AgencyUserModel
>
re
=
Privilege
.
agencyUserClient
.
queryByUserId
(
unitInfo
.
getAmosUserId
());
AgencyUserModel
ag
=
re
.
getResult
();
ag
.
setPassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
ag
.
setRePassword
(
AesUtil
.
encode
(
npwd
,
"qaz"
));
Privilege
.
agencyUserClient
.
restorePassword
(
unitInfo
.
getAmosUserId
());
ag
.
setOriginalPassword
(
AesUtil
.
encode
(
"Z2%Op9.q"
,
"qaz"
));
Privilege
.
agencyUserClient
.
modifyPassword
(
unitInfo
.
getAmosUserId
(),
ag
);
publicAgencyUserMapper
.
updateById
(
unitInfo
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
return
CommonResponseNewUtil
.
success
();
}
}
\ No newline at end of file
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