|
@@ -32,6 +32,7 @@ import java.time.Instant;
|
|
|
import java.time.LocalDateTime;
|
|
|
import java.time.LocalTime;
|
|
|
import java.time.ZoneId;
|
|
|
+import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
import java.util.stream.Collectors;
|
|
@@ -70,6 +71,9 @@ public class WorkerManagerLogic {
|
|
|
@Autowired
|
|
|
CommonMapper commonMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ WorkerNumberCheckService workerNumberCheckService;
|
|
|
+
|
|
|
|
|
|
|
|
|
public void stop(String id) {
|
|
@@ -1015,7 +1019,36 @@ public class WorkerManagerLogic {
|
|
|
|
|
|
}
|
|
|
|
|
|
- public void importData(List<Object> objects) {
|
|
|
+ public void importData(List<Object> datas) {
|
|
|
+ AdminUserCom adminUser = commonLogic.getAdminUser();
|
|
|
+ int index = 0;
|
|
|
+ List<WorkerNumberCheck> workerNumberChecks =new ArrayList<>();
|
|
|
+ for (Object o : datas) {
|
|
|
+ index++;
|
|
|
+ String errPrefix = "第" + index + "行";
|
|
|
+ List<Object> row = (List<Object>) o;
|
|
|
+
|
|
|
+
|
|
|
+ WorkerNumberCheck workerNumberCheck = new WorkerNumberCheck();
|
|
|
+
|
|
|
+ workerNumberCheck.setCompanyWechatId(adminUser.getCompanyWechatId());
|
|
|
+ workerNumberCheck.setCompanyWechatName(adminUser.getCompanyName());
|
|
|
+ workerNumberCheck.setWebsitId((String)row.get(0));
|
|
|
+ workerNumberCheck.setWebsitName((String)row.get(1));
|
|
|
+ workerNumberCheck.setWorkerNumberYun((String)row.get(2));
|
|
|
+ workerNumberCheck.setWorkerName((String)row.get(3));
|
|
|
+ workerNumberCheck.setWorkerPhoneYun((String)row.get(4));
|
|
|
+
|
|
|
+ WorkerNumberCheck workerNumberCheckUp = workerNumberCheckService.lambdaQuery().eq(WorkerNumberCheck::getWorkerNumberYun, workerNumberCheck.getWorkerNumberYun())
|
|
|
+ .last("limit 1").one();
|
|
|
+
|
|
|
+ if (workerNumberCheckUp != null){
|
|
|
+ workerNumberCheck.setId(workerNumberCheckUp.getId());
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
|
|
|
+ workerNumberCheckService.saveOrUpdateBatch(workerNumberChecks);
|
|
|
}
|
|
|
}
|