package com.huimv.receive.service.impl;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.Header;
import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.huimv.receive.common.token.TokenSign;
import com.huimv.receive.common.utils.*;
import com.huimv.receive.entity.*;
import com.huimv.receive.entity.dto.PcrDto;
import com.huimv.receive.entity.vo.PcrVo;
import com.huimv.receive.entity.vo.PcrVo1;
import com.huimv.receive.mapper.*;
import com.huimv.receive.service.IBillPcrService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
*
* pcr 表 服务实现类
*
*
* @author author
* @since 2023-07-21
*/
@Service
public class BillPcrServiceImpl extends ServiceImpl implements IBillPcrService {
@Resource
private BillPcrMapper billPcrMapper;
@Override
public Result listPersonalPcr(HttpServletRequest httpServletRequest, Map paramsMap) {
String pageNo = paramsMap.get("pageNum");
String pageSize = paramsMap.get("pageSize");
String vistitType = paramsMap.get("vistitType");
Page page = new Page<>(Integer.parseInt(pageNo), Integer.parseInt(pageSize));
Page billPcrPage = billPcrMapper.selectPage(page, new QueryWrapper().eq(StringUtils.isNotBlank(vistitType), "vistit_type", vistitType).eq("admission_user_id", TokenSign.getMemberIdByJwtToken(httpServletRequest)).orderByDesc("sub_date"));
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq(StringUtils.isNotBlank(vistitType), "vistit_type", vistitType).eq("admission_user_id", TokenSign.getMemberIdByJwtToken(httpServletRequest)).orderByDesc("sub_date");
return new Result(ResultCode.SUCCESS, billPcrPage, billPcrMapper.selectCount(queryWrapper));
}
@Override
public Result pcrWhole(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
Date timesmorning = DataUill.getTimesmorning();
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("farm_id", farmId).eq("bill_status", 1).ge("sub_date", timesmorning);//今日合格
Integer count = billPcrMapper.selectCount(queryWrapper);
QueryWrapper queryWrapper1 = new QueryWrapper<>();
queryWrapper1.eq("farm_id", farmId).eq("bill_status", 2).ge("sub_date", timesmorning);//今日异常
Integer count1 = billPcrMapper.selectCount(queryWrapper1);
QueryWrapper queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("farm_id", farmId).eq("bill_status", 3).ge("sub_date", timesmorning);//今日失效
Integer count2 = billPcrMapper.selectCount(queryWrapper2);
PcrDto dto = new PcrDto();
dto.setWholeCount(count + count1);
dto.setPassCount(count);
dto.setRefuseCount(count1);
dto.setLoseCount(count2);
return new Result(ResultCode.SUCCESS, dto);
}
@Override
public Result listType(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
String type = paramsMap.get("type");
if ("".equals(type) || null == type) {
type = "1";
}
List pcrVos = null;
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("farm_id", farmId).in("bill_status", 1, 2);
if ("1".equals(type)) {
Date timesmorning = DataUill.getTimesmorning();
queryWrapper.ge("sub_date", timesmorning);
} else if ("2".equals(type)) {
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) - 7);
queryWrapper.ge("sub_date", calendar.getTime());
} else if ("3".equals(type)) {
Date monthmorning = DataUill.getTimesMonthmorning();
queryWrapper.ge("sub_date", monthmorning);
}
pcrVos = billPcrMapper.listPcr(queryWrapper);
for (PcrVo pcrVo : pcrVos) {
if (pcrVo.getType().equals("0")) {
pcrVo.setType("人员");
} else if (pcrVo.getType().equals("1")) {
pcrVo.setType("环保车");
} else if (pcrVo.getType().equals("2")) {
pcrVo.setType("拉猪车");
} else if (pcrVo.getType().equals("3")) {
pcrVo.setType("饲料车");
} else if (pcrVo.getType().equals("4")) {
pcrVo.setType("送猪车");
} else if (pcrVo.getType().equals("5")) {
pcrVo.setType("物资车");
}
}
return new Result(ResultCode.SUCCESS, pcrVos);
}
@Override
public Result listLocation(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
String type = paramsMap.get("type");
if ("".equals(type) || null == type) {
type = "1";
}
List pcrVos = null;
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("farm_id", farmId).in("bill_status", 1, 2);
if ("1".equals(type)) {
Date timesmorning = DataUill.getTimesmorning();
queryWrapper.ge("sub_date", timesmorning);
} else if ("2".equals(type)) {
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) - 7);
queryWrapper.ge("sub_date", calendar.getTime());
} else if ("3".equals(type)) {
Date monthmorning = DataUill.getTimesMonthmorning();
queryWrapper.ge("sub_date", monthmorning);
}
pcrVos = billPcrMapper.listLocation(queryWrapper);
return new Result(ResultCode.SUCCESS, pcrVos);
}
@Override
public Result listAll(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
String personType = paramsMap.get("personType");
String type = paramsMap.get("type");
if ("".equals(type) || null == type) {
type = "1";
}
List pcrVos = null;
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("farm_id", farmId).in("bill_status", 1, 2);
if ("".equals(personType) || null == personType) {
} else {
queryWrapper.eq("vistit_type", personType);
}
if ("1".equals(type)) {
Date timesmorning = DataUill.getTimesmorning();
queryWrapper.ge("sub_date", timesmorning);
} else if ("2".equals(type)) {
Calendar calendar = Calendar.getInstance();
calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) - 7);
queryWrapper.ge("sub_date", calendar.getTime());
} else if ("3".equals(type)) {
Date monthmorning = DataUill.getTimesMonthmorning();
queryWrapper.ge("sub_date", monthmorning);
}
pcrVos = billPcrMapper.listAll(queryWrapper);
for (PcrVo1 pcrVo : pcrVos) {
pcrVo.setAllCount(pcrVo.getPassCount() + pcrVo.getRefuseCount());
}
return new Result(ResultCode.SUCCESS, pcrVos);
}
@Override
public Result selectList(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
String type = paramsMap.get("type");//来访类型
String destId = paramsMap.get("destId");//目的地
String startTime = paramsMap.get("startTime");
String endTime = paramsMap.get("endTime");
String pageNum = paramsMap.get("pageNum");
String pageSize = paramsMap.get("pageSize");
if ("".equals(pageNum) || null == pageNum) {
pageNum = "1";
}
if ("".equals(pageSize) || null == pageSize) {
pageSize = "10";
}
QueryWrapper queryWrapper = new QueryWrapper<>();
if (ObjectUtil.isNotEmpty(startTime)) {
startTime = startTime + " 00:00:00";
endTime = endTime + " 23:59:59";
queryWrapper.between("check_date", startTime, endTime);
}
queryWrapper.in("bill_status", 1, 2);
queryWrapper.lambda().orderByDesc(BillPcr::getId);
queryWrapper.eq("farm_id", farmId).eq(StringUtils.isNotBlank(destId), "dest_id", destId).eq(StringUtils.isNotBlank(type), "vistit_type", type);
Page page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
return new Result(ResultCode.SUCCESS, billPcrMapper.selectPage(page, queryWrapper));
}
@Override
public void printPcr(HttpServletResponse httpServletRequest, Map paramsMap) throws Exception {
String ids = paramsMap.get("ids");
String[] split = ids.split(",");
List list = new ArrayList<>();
for (String s : split) {
BillPcr admission = billPcrMapper.selectById(s);
list.add(admission);
}
Print.printPcr(list);
}
@Override
public Result PcrList(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("farm_id", farmId);
Integer integer = pcrMapper.selectCount(queryWrapper);//检测总数
queryWrapper.in("bill_status", 1, 3);
Integer integer1 = pcrMapper.selectCount(queryWrapper);//合格总数
queryWrapper.orderByDesc("sub_date").last(" limit 10");
DecimalFormat def = new DecimalFormat("0.00");
String rank;
if (integer == 0 || integer == null) {
Double ranks = Double.valueOf("0.00");
rank = ranks.toString();
} else {
Double ranks = (Double.valueOf(integer1.toString()) / Double.valueOf(integer.toString())) * 100;
rank = def.format(ranks);
}
JSONObject jsonObject = new JSONObject();
jsonObject.put("allCount", integer);
jsonObject.put("passCount", integer1);
jsonObject.put("rank", rank);
jsonObject.put("pcrList", pcrMapper.selectList(queryWrapper));
return new Result(ResultCode.SUCCESS, jsonObject);
}
@Autowired
private BillPcrMapper pcrMapper;
@Autowired
private BaseProcessMapper processMapper;
@Autowired
private BaseLocationMapper locationMapper;
@Autowired
private BillCleanMapper cleanMapper;
@Autowired
private BillGoodsInventoryMapper goodsInventoryMapper;
@Autowired
private ConfigurationMapper configurationMapper;
@Autowired
private UploadImage uploadImage;
@Autowired
private ExistMapper existMapper;
@Autowired
private DeviceListMapper deviceListMapper;
@Autowired
private PeopleListMapper peopleListMapper;
@Autowired
private BillPersonnelAdmissionMapper personnelAdmissionMapper;
@Autowired
private BaseWashoutPointMapper washoutPointMapper;
@Autowired
private BillDryMapper dryMapper;
@Autowired
private BillIsolateMapper isolateMapper;
@Autowired
private BillSamplingMapper samplingMapper;
@Autowired
private BillCleanBeforeMapper beforeMapper;
@Override
public Result list(HttpServletRequest httpServletRequest, Map paramsMap) {
String farmId = paramsMap.get("farmId");
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 page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("farm_id", farmId).eq("test_location_id", TokenSign.getWorkIdByJwtToken(httpServletRequest)).orderByDesc("sub_date");
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);
}
if ("3".equals(type)) {
queryWrapper.in("bill_status", 2, 3);
}
QueryWrapper queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("farm_id", farmId).eq("test_location_id", TokenSign.getWorkIdByJwtToken(httpServletRequest)).orderByDesc("sub_date");
queryWrapper2.eq("bill_status", 0);
return new Result(ResultCode.SUCCESS, pcrMapper.selectPage(page, queryWrapper), pcrMapper.selectCount(queryWrapper2));
}
@Override
public Result listById(HttpServletRequest httpServletRequest, Map paramsMap) {
String id = paramsMap.get("id");
BillPcr billPcr = pcrMapper.selectById(id);
return new Result(ResultCode.SUCCESS, billPcr);
}
@Override
public Result edit(HttpServletRequest httpServletRequest, String farmId, String id, String date, String result,
MultipartFile img1, MultipartFile img2, MultipartFile img3) throws ParseException, IOException {
//1为合格2为异常
String s1 = "";
String s2 = "";
String s3 = "";
if (ObjectUtil.isNotEmpty(img1)) {
if (uploadImage.getImageCom(img1).equals("上传失败")) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return new Result(10001, "图片1上传失败", false);
}
s1 = uploadImage.uploadImg(img1);
}
if (ObjectUtil.isNotEmpty(img2)) {
if (uploadImage.getImageCom(img2).equals("上传失败")) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return new Result(10001, "图片2上传失败", false);
}
s2 = "," + uploadImage.uploadImg(img2);
}
if (ObjectUtil.isNotEmpty(img3)) {
if (uploadImage.getImageCom(img3).equals("上传失败")) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return new Result(10001, "图片3上传失败", false);
}
s3 = "," + uploadImage.uploadImg(img3);
}
String s = s1 + s2 + s3;
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
if (StringUtils.isBlank(date)) {
date = sdf.format(new Date());
}
BillPcr billPcr = pcrMapper.selectById(id);
billPcr.setImgUrl(s);
billPcr.setImgStatus(1);
QueryWrapper processQueryWrapper = new QueryWrapper<>();
processQueryWrapper.eq("farm_id", farmId).eq("id", billPcr.getProcessId());
BaseProcess baseProcess = processMapper.selectOne(processQueryWrapper);//进程
QueryWrapper locationQueryWrapper = new QueryWrapper<>();
locationQueryWrapper.eq("id", billPcr.getTestLocationId());
BaseLocation baseLocation = locationMapper.selectOne(locationQueryWrapper);//当前pcr检测所在的位置
String allLocationId = baseProcess.getAllLocationId();//所有的位置id
String allFlowId = baseProcess.getAllFlowId();//所有的流程id
String currentFlowId = baseProcess.getCurrentFlowId();//当前已经完成的流程id
String substring1 = allFlowId.substring(currentFlowId.length() + 1, allFlowId.length());
String[] split = substring1.split(",");
Integer nextId = Integer.parseInt(split[0]);
if (billPcr.getBillStatus() != 0) {
return new Result(10001, "该订单已通过,无需再次提交!", false);
}
if (baseProcess.getProcessType() == 2 || baseProcess.getProcessType() == 1) {
return new Result(10001, "修改失败!该申请已提前结束或者被拒绝", false);
} else {
if ("1".equals(result)) {
Integer pcrTime = washoutPointMapper.selectOne(new QueryWrapper().eq("farm_ids", farmId)
.eq("visiting_type", billPcr.getVistitType()).eq("location_id", baseLocation.getId())).getPcrTime();
billPcr.setBillStatus(1);
billPcr.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
billPcr.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
billPcr.setTestLocation(baseLocation.getLocationName());
billPcr.setTestLocationId(baseLocation.getId());
billPcr.setCheckDate(sdf.parse(date));
billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
billPcr.setQualifiedDate(pcrTime);
Object newObject = getNewObject(nextId, billPcr.getDestName(), billPcr.getDestId(), billPcr.getAdmissionUserName(),
billPcr.getAdmissionUserId(), billPcr.getVistitDate(), billPcr.getSubDate(),
billPcr.getProcessId(), billPcr.getFarmId(), billPcr.getTestLocation(), billPcr.getTestLocationId(),
billPcr.getVistitType(),billPcr.getPhone(),billPcr.getDepartureName(),billPcr.getDepartureId());
System.out.println("这里是pcr通过的下一个流程id:" + nextId);
if (nextId == 0) {
int index = allLocationId.indexOf(baseLocation.getId());
StringBuilder status = new StringBuilder(baseProcess.getAllLocationId());
status.setCharAt(index, '1');
status.setCharAt(index + 2, '1');
baseProcess.setAllLocationStatus(status.toString());
} else if (nextId == 1) {
//新增采样
BillSampling billSampling = (BillSampling) newObject;
samplingMapper.insert(billSampling);
}else if (nextId == 2) {
//新增pcr
BillPcr billClean = (BillPcr) newObject;
pcrMapper.insert(billClean);
}else if (nextId == 3) {
//新增洗澡
BillClean billClean = (BillClean) newObject;
cleanMapper.insert(billClean);
}else if (nextId == 4) {
//新增隔离
BillIsolate pcr = (BillIsolate) newObject;
isolateMapper.insert(pcr);
}else if (nextId == 5) {
BillDry billClean = (BillDry) newObject;
dryMapper.insert(billClean);
//新增烘干
}else if (nextId == 6) {
//新增洗澡前拍照
BillCleanBefore before = (BillCleanBefore) newObject;
beforeMapper.insert(before);
}
// //通过生成门禁白名单
// QueryWrapper deviceListQueryWrapper = new QueryWrapper<>();
// deviceListQueryWrapper.eq("farm_id", billPcr.getFarmId()).eq("location_id", baseLocation.getId());
// List deviceLists = deviceListMapper.selectList(deviceListQueryWrapper);
// //找到对应的入场申请表
// QueryWrapper queryWrapper1 = new QueryWrapper<>();
// queryWrapper1.eq("farm_id", billPcr.getFarmId()).eq("process_id", baseProcess.getId());
// BillPersonnelAdmission billPersonnelAdmission = personnelAdmissionMapper.selectOne(queryWrapper1);
// if (deviceLists.size() > 0) {
// for (DeviceList deviceList : deviceLists) {
// //通过生成门禁白名单
// PeopleList peopleList = new PeopleList();
// peopleList.setFarmId(billPcr.getFarmId().toString());
// peopleList.setDeviceCode(deviceList.getDeviceCode());
// peopleList.setUserId(billPcr.getAdmissionUserId());
// peopleList.setUserName(billPcr.getAdmissionUserName());
// peopleList.setPassword("123456");
// peopleList.setType(0);
// peopleList.setCreateTime(new Date());
// Date date2 = new Date();
// Calendar calendar = Calendar.getInstance();
// calendar.setTime(date2);
// calendar.add(Calendar.HOUR_OF_DAY, 2);
// Date date1 = calendar.getTime();
// peopleList.setOutTime(date1);
// peopleListMapper.insert(peopleList);
//
// HashMap jsonObject = new HashMap<>();
// jsonObject.put("seq", deviceList.getDeviceCode());
//// String savePath = "D:\\works\\pig_projects\\甜妹.jpg";
// String savePath = "/opt/huatong/test.jpg";
// URL url = new URL(billPersonnelAdmission.getUserImgUrl());
// HttpURLConnection connection = (HttpURLConnection) url.openConnection();
// connection.setRequestMethod("GET");
// int resCode = connection.getResponseCode();
// if (resCode == HttpURLConnection.HTTP_OK) {
// InputStream inputStream = connection.getInputStream();
// byte[] buffer = new byte[4096];
// int length;
// //读取数据并写入到文件中
// try (FileOutputStream outStream = new FileOutputStream(savePath)) {
// while ((length = inputStream.read(buffer)) != -1) {
// outStream.write(buffer, 0, length);
// }
// outStream.flush();
// } finally {
// inputStream.close();
// }
// } else {
// System.out.println("文件下载错误码为" + resCode);
// }
//
//// jsonObject.put("face", FileUtil.file("D:\\works\\pig_projects\\甜妹.jpg"));
// jsonObject.put("face", FileUtil.file(savePath));
// jsonObject.put("name", billPersonnelAdmission.getAdmissionUserName());
// jsonObject.put("password", "123456");
// jsonObject.put("timestamp", date1.getTime());
// jsonObject.put("uid", billPersonnelAdmission.getAdmissionUserId());
// String post = HttpRequest.post("http://39.173.90.137:8040/addDeviceUser")
// .header(Header.CONTENT_TYPE, "multipart/form-data")
// .form(jsonObject)
// .timeout(30 * 1000).execute().body();
// System.out.println(post);
// }
// }
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getLocationName());
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getId());
String status = baseProcess.getCurrentStatus();
String substring = status.substring(0, status.length() - 1);
baseProcess.setCurrentStatus(substring + "1," + 0);
baseProcess.setCurrentFlowId(baseProcess.getCurrentFlowId() + "," + nextId);
processMapper.updateById(baseProcess);
pcrMapper.updateById(billPcr);
return new Result(10000, "修改成功!", true);
} else {
billPcr.setBillStatus(2);
billPcr.setPcrType(1);
billPcr.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
billPcr.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
billPcr.setTestLocation(baseLocation.getLocationName());
billPcr.setTestLocationId(baseLocation.getId());
billPcr.setCheckDate(sdf.parse(date));
billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
String status = baseProcess.getCurrentStatus();
String substring = status.substring(0, status.length() - 1);
baseProcess.setCurrentStatus(substring + "2," + 0);
processMapper.updateById(baseProcess);
pcrMapper.updateById(billPcr);
return new Result(10000, "修改成功!", true);
}
}
}
public static void main(String[] args) {
String s = "0,1,0,2,0,3,0";
StringBuilder sb = new StringBuilder(s);
Integer a = s.length() - 3;
sb.setCharAt(a,'0');
System.out.println(sb.toString());
// String s1 = "1,1,1,0,0,0";
// System.out.println(s.indexOf("2"));
// StringBuilder sb = new StringBuilder(s1);
// sb.setCharAt(6, '1');
// sb.setCharAt(8, '1');
// System.out.println(sb.toString());
}
private void xiugaiPro(BaseProcess baseProcess, BillPcr billPcr) {
baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + new Date());
baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + billPcr.getTestLocation());
baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + billPcr.getTestLocationId());
baseProcess.setCurrentStatus(baseProcess.getCurrentStatus() + "," + 2);
}
public String add() {
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(10);
Runnable task = new Runnable() {
@Override
public void run() {
//这里写业务
System.out.println();
}
};
// 设定延迟时间(两小时后执行,单位为秒)
long delay = 3;
// 执行定时任务
scheduler.schedule(task, delay, TimeUnit.SECONDS);
System.out.println("完结");
return "成功";
}
public static Object getNewObject(Integer id, String destName, Integer destId, String admissionUserName, Integer admissionUserId
, LocalDateTime vistitDate, LocalDateTime subDate, Integer processId, Integer farmId, String testLocation
, Integer testLocationId,Integer vistitType,String phone,String departureName,Integer departureId) {
if (id == 1) {
//采样
BillSampling billSampling = new BillSampling();
billSampling.setVistitType(vistitType);
billSampling.setDestName(destName);
billSampling.setDestId(destId);
billSampling.setAdmissionUserName(admissionUserName);
billSampling.setAdmissionUserId(admissionUserId);
billSampling.setVistitDate(vistitDate);
billSampling.setSubDate(LocalDateTime.now());
billSampling.setPhone(phone);
billSampling.setTestLocation(testLocation);
billSampling.setTestLocationId(testLocationId);
billSampling.setProcessId(processId);
billSampling.setFarmId(String.valueOf(farmId));
billSampling.setDepartureName(departureName);
billSampling.setDepartureId(departureId);
return billSampling;
}
if (id == 2) {
//pcr
BillPcr billPcr = new BillPcr();
billPcr.setDestName(destName);
billPcr.setDestId(destId);
billPcr.setAdmissionUserId(admissionUserId);
billPcr.setAdmissionUserName(admissionUserName);
billPcr.setVistitDate(vistitDate);
billPcr.setSubDate(subDate);
billPcr.setBillStatus(0);
billPcr.setProcessId(processId);
billPcr.setFarmId(farmId);
billPcr.setTestLocationId(testLocationId);
billPcr.setTestLocation(testLocation);
billPcr.setDepartureName(departureName);
billPcr.setDepartureId(departureId);
return billPcr;
}
if (id == 3) {
//洗消
BillClean billPcr = new BillClean();
billPcr.setDestName(destName);
billPcr.setDestId(destId);
billPcr.setAdmissionUserId(admissionUserId);
billPcr.setAdmissionUserName(admissionUserName);
billPcr.setVistitDate(vistitDate);
billPcr.setSubDate(subDate);
billPcr.setBillStatus(0);
billPcr.setProcessId(processId);
billPcr.setFarmId(farmId);
billPcr.setTestLocationId(testLocationId);
billPcr.setTestLocation(testLocation);
billPcr.setDepartureName(departureName);
billPcr.setDepartureId(departureId);
return billPcr;
}
if (id == 4) {
//隔离
BillIsolate billPcr = new BillIsolate();
billPcr.setDestName(destName);
billPcr.setDestId(destId);
billPcr.setAdmissionUserId(admissionUserId);
billPcr.setAdmissionUserName(admissionUserName);
billPcr.setVistitDate(vistitDate);
billPcr.setSubDate(subDate);
billPcr.setBillStatus(0);
billPcr.setProcessId(processId);
billPcr.setFarmId(farmId);
billPcr.setIsolateLocation(testLocation);
billPcr.setIsolateLocationId(testLocationId);
billPcr.setDepartureName(departureName);
billPcr.setDepartureId(departureId);
return billPcr;
}
if (id == 5) {
//烘干
BillDry billPcr = new BillDry();
billPcr.setDestName(destName);
billPcr.setDestId(destId);
billPcr.setAdmissionUserId(admissionUserId);
billPcr.setAdmissionUserName(admissionUserName);
billPcr.setVistitDate(vistitDate);
billPcr.setSubDate(subDate);
billPcr.setBillStatus(0);
billPcr.setProcessId(processId);
billPcr.setFarmId(farmId);
billPcr.setTestLocationId(testLocationId);
billPcr.setTestLocation(testLocation);
billPcr.setDepartureName(departureName);
billPcr.setDepartureId(departureId);
return billPcr;
}
if (id == 6) {
//洗澡前拍照
BillCleanBefore billCleanBefore = new BillCleanBefore();
billCleanBefore.setVistitType(vistitType);
billCleanBefore.setDestName(destName);
billCleanBefore.setDestId(destId);
billCleanBefore.setAdmissionUserName(admissionUserName);
billCleanBefore.setAdmissionUserId(admissionUserId);
billCleanBefore.setVistitDate(vistitDate);
billCleanBefore.setSubDate(LocalDateTime.now());
billCleanBefore.setPhone(phone);
billCleanBefore.setTestLocation(testLocation);
billCleanBefore.setTestLocationId(testLocationId);
billCleanBefore.setProcessId(processId);
billCleanBefore.setFarmId(String.valueOf(farmId));
billCleanBefore.setDepartureName(departureName);
billCleanBefore.setDepartureId(departureId);
return billCleanBefore;
}
return null;
}
}