|
@@ -55,10 +55,11 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
public Result listPersonalPcr(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
public Result listPersonalPcr(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
String pageNo = paramsMap.get("pageNum");
|
|
String pageNo = paramsMap.get("pageNum");
|
|
String pageSize = paramsMap.get("pageSize");
|
|
String pageSize = paramsMap.get("pageSize");
|
|
- Page<BillPcr> page = new Page<>(Integer.parseInt(pageNo),Integer.parseInt(pageSize));
|
|
|
|
|
|
+ Page<BillPcr> page = new Page<>(Integer.parseInt(pageNo), Integer.parseInt(pageSize));
|
|
Page<BillPcr> billPcrPage = billPcrMapper.selectPage(page, new QueryWrapper<BillPcr>().eq("admission_user_id", TokenSign.getMemberIdByJwtToken(httpServletRequest)).orderByDesc("sub_date"));
|
|
Page<BillPcr> billPcrPage = billPcrMapper.selectPage(page, new QueryWrapper<BillPcr>().eq("admission_user_id", TokenSign.getMemberIdByJwtToken(httpServletRequest)).orderByDesc("sub_date"));
|
|
- return new Result(ResultCode.SUCCESS,billPcrPage);
|
|
|
|
|
|
+ return new Result(ResultCode.SUCCESS, billPcrPage);
|
|
}
|
|
}
|
|
|
|
+
|
|
@Autowired
|
|
@Autowired
|
|
private BillPcrMapper pcrMapper;
|
|
private BillPcrMapper pcrMapper;
|
|
@Autowired
|
|
@Autowired
|
|
@@ -72,17 +73,30 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
public Result list(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
public Result list(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
String farmId = paramsMap.get("farmId");
|
|
String farmId = paramsMap.get("farmId");
|
|
String type = paramsMap.get("type");//展示类型
|
|
String type = paramsMap.get("type");//展示类型
|
|
|
|
+ String pageNum = paramsMap.get("pageNum");
|
|
|
|
+ String pageSize = paramsMap.get("pageSize");
|
|
|
|
+ if ("".equals(pageNum) || null == pageNum) {
|
|
|
|
+ pageNum = "1";
|
|
|
|
+ }
|
|
|
|
+ if ("".equals(pageSize) || null == pageSize) {
|
|
|
|
+ pageSize = "20";
|
|
|
|
+ }
|
|
|
|
+ Page<BillPcr> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
|
|
QueryWrapper<BillPcr> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<BillPcr> queryWrapper = new QueryWrapper<>();
|
|
- queryWrapper.eq("farm_id", farmId).eq("test_location_id",TokenSign.getWorkIdByJwtToken(httpServletRequest));
|
|
|
|
- if ("".equals(type) || null == type) {
|
|
|
|
- queryWrapper.eq("pcr_type", 0);
|
|
|
|
- } else if (type.equals("3")) {
|
|
|
|
- queryWrapper.eq("pcr_type", 0).in("bill_status", 2, 3);
|
|
|
|
- } else {
|
|
|
|
- queryWrapper.eq("pcr_type", 0).eq("bill_status", type);
|
|
|
|
|
|
+ queryWrapper.eq("farm_id", farmId).eq("test_location_id", TokenSign.getWorkIdByJwtToken(httpServletRequest));
|
|
|
|
+ if ("0".equals(type)) {
|
|
|
|
+ queryWrapper.in("bill_status", 0, 1, 2, 3);
|
|
|
|
+ }
|
|
|
|
+ if ("1".equals(type)) {
|
|
|
|
+ queryWrapper.eq("bill_status", 0);
|
|
|
|
+ }
|
|
|
|
+ if ("2".equals(type)) {
|
|
|
|
+ queryWrapper.eq("bill_status", 1);
|
|
}
|
|
}
|
|
- List<BillPcr> billPcrs = pcrMapper.selectList(queryWrapper);
|
|
|
|
- return new Result(ResultCode.SUCCESS, billPcrs);
|
|
|
|
|
|
+ if ("3".equals(type)) {
|
|
|
|
+ queryWrapper.in("bill_status", 2, 3);
|
|
|
|
+ }
|
|
|
|
+ return new Result(ResultCode.SUCCESS, pcrMapper.selectPage(page, queryWrapper));
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -99,7 +113,7 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
String farmId = paramsMap.get("farmId");
|
|
String farmId = paramsMap.get("farmId");
|
|
String date = paramsMap.get("date");
|
|
String date = paramsMap.get("date");
|
|
|
|
|
|
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
|
|
|
|
|
if (StringUtils.isBlank(date)) {
|
|
if (StringUtils.isBlank(date)) {
|
|
date = sdf.format(new Date());
|
|
date = sdf.format(new Date());
|
|
@@ -146,7 +160,7 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
billClean.setTestLocationId(baseLocation.getNextId());
|
|
billClean.setTestLocationId(baseLocation.getNextId());
|
|
cleanMapper.insert(billClean);
|
|
cleanMapper.insert(billClean);
|
|
|
|
|
|
- baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," +sdf.format(new Date()));
|
|
|
|
|
|
+ baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
|
|
baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
|
|
baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
|
|
String status = baseProcess.getCurrentStatus();
|
|
String status = baseProcess.getCurrentStatus();
|
|
@@ -166,7 +180,7 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
}
|
|
}
|
|
};
|
|
};
|
|
// 设定延迟时间(两小时后执行,单位为秒)
|
|
// 设定延迟时间(两小时后执行,单位为秒)
|
|
- long delay = 60*60*2;
|
|
|
|
|
|
+ long delay = 60 * 60 * 2;
|
|
// 执行定时任务
|
|
// 执行定时任务
|
|
scheduler.schedule(task, delay, TimeUnit.SECONDS);
|
|
scheduler.schedule(task, delay, TimeUnit.SECONDS);
|
|
return new Result(10000, "修改成功!", true);
|
|
return new Result(10000, "修改成功!", true);
|
|
@@ -216,7 +230,7 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
|
|
billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
|
|
|
|
|
|
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
|
|
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
|
|
- baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() );
|
|
|
|
|
|
+ baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
|
|
String status = baseProcess.getCurrentStatus();
|
|
String status = baseProcess.getCurrentStatus();
|
|
String substring = status.substring(0, status.length() - 1);
|
|
String substring = status.substring(0, status.length() - 1);
|
|
@@ -234,7 +248,7 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
}
|
|
}
|
|
};
|
|
};
|
|
// 设定延迟时间(两小时后执行,单位为秒)
|
|
// 设定延迟时间(两小时后执行,单位为秒)
|
|
- long delay = 60*60*2;
|
|
|
|
|
|
+ long delay = 60 * 60 * 2;
|
|
// 执行定时任务
|
|
// 执行定时任务
|
|
scheduler.schedule(task, delay, TimeUnit.SECONDS);
|
|
scheduler.schedule(task, delay, TimeUnit.SECONDS);
|
|
return new Result(10000, "修改成功!", true);
|
|
return new Result(10000, "修改成功!", true);
|
|
@@ -244,11 +258,11 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
billPcr.setPcrType(1);
|
|
billPcr.setPcrType(1);
|
|
baseProcess.setProcessType(2);
|
|
baseProcess.setProcessType(2);
|
|
} else {
|
|
} else {
|
|
- baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," +sdf.format(new Date()));
|
|
|
|
|
|
+ baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
|
|
baseProcess.setProcessType(2);
|
|
baseProcess.setProcessType(2);
|
|
}
|
|
}
|
|
- baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," +sdf.format(new Date()));
|
|
|
|
- baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() );
|
|
|
|
|
|
+ baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
|
|
|
|
+ baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
|
|
String status = baseProcess.getCurrentStatus();
|
|
String status = baseProcess.getCurrentStatus();
|
|
String substring = status.substring(0, status.length() - 1);
|
|
String substring = status.substring(0, status.length() - 1);
|
|
@@ -272,13 +286,14 @@ public class BillPcrServiceImpl extends ServiceImpl<BillPcrMapper, BillPcr> impl
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
- private void xiugaiPro(BaseProcess baseProcess,BillPcr billPcr) {
|
|
|
|
|
|
+ private void xiugaiPro(BaseProcess baseProcess, BillPcr billPcr) {
|
|
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + new Date());
|
|
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + new Date());
|
|
baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + billPcr.getTestLocation());
|
|
baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + billPcr.getTestLocation());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + billPcr.getTestLocationId());
|
|
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + billPcr.getTestLocationId());
|
|
baseProcess.setCurrentStatus(baseProcess.getCurrentStatus() + "," + 2);
|
|
baseProcess.setCurrentStatus(baseProcess.getCurrentStatus() + "," + 2);
|
|
}
|
|
}
|
|
- public String add() {
|
|
|
|
|
|
+
|
|
|
|
+ public String add() {
|
|
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(10);
|
|
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(10);
|
|
Runnable task = new Runnable() {
|
|
Runnable task = new Runnable() {
|
|
@Override
|
|
@Override
|