|
|
@ -12,6 +12,7 @@ import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.nl.common.utils.CodeUtil; |
|
|
|
import org.nl.common.websocket.SendHomeWebSocketServer; |
|
|
|
import org.nl.config.IdUtil; |
|
|
|
import org.nl.system.service.user.dao.SysUser; |
|
|
|
import org.nl.wms.database.eas.dao.EasOutInBillDetail; |
|
|
|
import org.nl.wms.database.eas.dao.HomeBillCounts; |
|
|
|
import org.nl.wms.database.eas.dao.mapper.EasOutInBillDetailMapper; |
|
|
@ -28,7 +29,9 @@ import org.springframework.stereotype.Component; |
|
|
|
import javax.annotation.PostConstruct; |
|
|
|
import javax.annotation.Resource; |
|
|
|
import java.math.BigDecimal; |
|
|
|
import java.text.ParseException; |
|
|
|
import java.time.LocalDate; |
|
|
|
import java.time.LocalDateTime; |
|
|
|
import java.time.format.DateTimeFormatter; |
|
|
|
import java.util.*; |
|
|
|
import java.util.concurrent.CompletableFuture; |
|
|
@ -77,7 +80,24 @@ public class EasBillSchedule { |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Async("taskExecutor") |
|
|
|
//@Scheduled(cron = "0/120 * * * * *")
|
|
|
|
public void insertUsers(List<SysUser> existingUsers, List<SysUser> newUsers) { |
|
|
|
Set<String> ids = existingUsers.stream().map(SysUser::getUsername).collect(Collectors.toSet()); |
|
|
|
// 过滤出需要插入的新用户,并设置默认属性
|
|
|
|
List<SysUser> insertUsers = newUsers.stream() |
|
|
|
.filter(user -> !ids.contains(user.getUsername())) |
|
|
|
.peek(user -> { |
|
|
|
user.setIs_used(true); // 设置默认启用
|
|
|
|
user.setCreate_time(new Date()); // 设置创建时间
|
|
|
|
}) |
|
|
|
.collect(Collectors.toList()); |
|
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(insertUsers)) { |
|
|
|
// 批量插入新用户
|
|
|
|
//this.saveBatch(insertUsers);
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 定时清空单据 |
|
|
@ -113,7 +133,7 @@ public class EasBillSchedule { |
|
|
|
SendHomeWebSocketServer.getWebSocketSet(); |
|
|
|
if (webSocketSet.size() > 0) { |
|
|
|
webSocketSet.forEach(c -> { |
|
|
|
c.sendDataToClient(easOutInBillService.getBillsCount()); |
|
|
|
// c.sendDataToClient(easOutInBillService.getBillsCount());
|
|
|
|
}); |
|
|
|
} |
|
|
|
//stopWatch.stop();
|
|
|
|