|
|
@@ -65,7 +65,7 @@ public class ReleaseUserTask {
|
|
|
* 客户释放
|
|
|
*
|
|
|
*/
|
|
|
- @Scheduled(cron = "0 30 16 * * ?")
|
|
|
+ @Scheduled(cron = "0 10 17 * * ?")
|
|
|
// @RequestMapping("/open/test")
|
|
|
// @Scheduled(cron = "0 0 1 * * ?")
|
|
|
public void startTask() {
|
|
|
@@ -247,11 +247,12 @@ public class ReleaseUserTask {
|
|
|
}
|
|
|
//获取需要释放的签单客户
|
|
|
List<LockingReleaseBo> users1 = userService.selectSignReleaseUser(u.getId());
|
|
|
+ customerService.pushReleaseLog(users1);
|
|
|
+ addUserNotice(users1);
|
|
|
if (!users1.isEmpty()){
|
|
|
users.addAll(users1);
|
|
|
}
|
|
|
- customerService.pushReleaseLog(users);
|
|
|
- addUserNotice(users);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -275,7 +276,7 @@ public class ReleaseUserTask {
|
|
|
for (int i = 0; i < users.size(); i++) {
|
|
|
releaseList.add(users.get(i));
|
|
|
if (pointsDataLimit == releaseList.size() || i == users.size() - 1) {
|
|
|
- userService.updateUserShareType(newList);
|
|
|
+ userService.updateUserShareType(releaseList);
|
|
|
newList.clear();
|
|
|
Thread.sleep(2000);
|
|
|
}
|