|
|
@@ -31,7 +31,7 @@ public class ReleaseUserTask {
|
|
|
* 每天凌晨一点将客户和业务转为待释放
|
|
|
*/
|
|
|
|
|
|
- @Scheduled(cron = "0 30 14 * * ?")
|
|
|
+ @Scheduled(cron = "0 10 15 * * ?")
|
|
|
// @RequestMapping(value = "/open/updateUser", method = RequestMethod.GET)
|
|
|
public void updateUser(){
|
|
|
try {
|
|
|
@@ -49,22 +49,26 @@ public class ReleaseUserTask {
|
|
|
lockBusinessList.addAll(businessTmpList);
|
|
|
}
|
|
|
List<LockingReleaseBo> newList=new ArrayList<LockingReleaseBo>();
|
|
|
- for(int i=0;i<userTmpList.size();i++){
|
|
|
- newList.add(userTmpList.get(i));
|
|
|
- if(pointsDataLimit == newList.size()||i == userTmpList.size()-1){
|
|
|
- if(newList.size()>0) customerServiceImpl.updatePendingReleaseLock(newList);
|
|
|
- newList.clear();
|
|
|
- Thread.sleep(2000);
|
|
|
- }
|
|
|
- }
|
|
|
- for(int i=0;i<businessTmpList.size();i++){
|
|
|
- newList.add(businessTmpList.get(i));
|
|
|
- if(pointsDataLimit == newList.size()||i == businessTmpList.size()-1){
|
|
|
- if(newList.size()>0) customerServiceImpl.updatePendingReleaseLock(newList);
|
|
|
- newList.clear();
|
|
|
- Thread.sleep(2000);
|
|
|
- }
|
|
|
- }
|
|
|
+ if (lockUserList.size()>0) {
|
|
|
+ for(int i=0;i<lockUserList.size();i++){
|
|
|
+ newList.add(lockUserList.get(i));
|
|
|
+ if(pointsDataLimit == newList.size()||i == lockUserList.size()-1){
|
|
|
+ if(newList.size()>0) customerServiceImpl.updatePendingReleaseLock(newList);
|
|
|
+ newList.clear();
|
|
|
+ Thread.sleep(2000);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (lockBusinessList.size()>0) {
|
|
|
+ for(int i=0;i<lockBusinessList.size();i++){
|
|
|
+ newList.add(lockBusinessList.get(i));
|
|
|
+ if(pointsDataLimit == newList.size()||i == lockBusinessList.size()-1){
|
|
|
+ if(newList.size()>0) customerServiceImpl.updatePendingReleaseLock(newList);
|
|
|
+ newList.clear();
|
|
|
+ Thread.sleep(2000);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
/*if(lockUserList.size()>0) customerServiceImpl.updateReleaseLock(lockUserList,releaseTime);
|
|
|
if(lockBusinessList.size()>0) customerServiceImpl.updateReleaseLock(lockBusinessList,releaseTime);
|
|
|
if(lockUserList.size()>0) userServiceImpl.updateReleaseLock(lockUserList);*/
|
|
|
@@ -79,7 +83,7 @@ public class ReleaseUserTask {
|
|
|
* 将待释放的代码释放出去
|
|
|
*/
|
|
|
|
|
|
- @Scheduled(cron = "0 50 14 * * ?")
|
|
|
+ @Scheduled(cron = "0 20 15 * * ?")
|
|
|
// @RequestMapping(value = "/open/releaseUser", method = RequestMethod.GET)
|
|
|
public void releaseUser(){
|
|
|
try {
|