BillPersonnelAdmissionServiceImpl.java 59 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088
  1. package com.huimv.admin.service.impl;
  2. import cn.hutool.core.util.ObjectUtil;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.baomidou.mybatisplus.core.metadata.IPage;
  5. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  6. import com.huimv.admin.common.token.TokenSign;
  7. import com.huimv.admin.common.utils.DataUill;
  8. import com.huimv.admin.common.utils.Result;
  9. import com.huimv.admin.common.utils.ResultCode;
  10. import com.huimv.admin.entity.*;
  11. import com.huimv.admin.mapper.*;
  12. import cn.hutool.core.date.DateTime;
  13. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  14. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  15. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  16. import com.huimv.admin.common.token.TokenSign;
  17. import com.huimv.admin.common.utils.*;
  18. import com.huimv.admin.entity.*;
  19. import com.huimv.admin.entity.vo.FactoryDirectorVo;
  20. import com.huimv.admin.mapper.*;
  21. import com.huimv.admin.service.IBillPersonnelAdmissionService;
  22. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  23. import org.springframework.beans.factory.annotation.Autowired;
  24. import org.springframework.stereotype.Service;
  25. import org.springframework.transaction.annotation.Transactional;
  26. import org.springframework.transaction.interceptor.TransactionAspectSupport;
  27. import org.springframework.web.bind.annotation.PostMapping;
  28. import org.springframework.web.multipart.MultipartFile;
  29. import javax.annotation.Resource;
  30. import javax.servlet.http.HttpServletRequest;
  31. import java.io.IOException;
  32. import java.time.LocalDateTime;
  33. import java.time.format.DateTimeFormatter;
  34. import java.util.*;
  35. import javax.servlet.http.HttpServletRequest;
  36. import java.text.DateFormat;
  37. import java.text.ParseException;
  38. import java.text.SimpleDateFormat;
  39. import java.time.LocalDate;
  40. import java.time.LocalDateTime;
  41. import java.util.List;
  42. import java.util.Map;
  43. import java.util.concurrent.Executors;
  44. import java.util.concurrent.ScheduledExecutorService;
  45. import java.util.concurrent.TimeUnit;
  46. /**
  47. * <p>
  48. * 入场申请 服务实现类
  49. * </p>
  50. *
  51. * @author author
  52. * @since 2023-07-21
  53. */
  54. @Service
  55. public class BillPersonnelAdmissionServiceImpl extends ServiceImpl<BillPersonnelAdmissionMapper, BillPersonnelAdmission> implements IBillPersonnelAdmissionService {
  56. @Resource
  57. private BillPersonnelAdmissionMapper billPersonnelAdmissionMapper;
  58. @Resource
  59. private BaseProcessMapper baseProcessMapper;
  60. @Resource
  61. private BillPcrMapper billPcrMapper;
  62. @Resource
  63. private BaseLocationMapper baseLocationMapper;
  64. @Resource
  65. private BillIsolateMapper billIsolateMapper;
  66. @Resource
  67. private BillCleanMapper billCleanMapper;
  68. @Resource
  69. private SysAccountMultilevelMapper sysAccountMultilevelMapper;
  70. @Autowired
  71. private UploadImage uploadImage;
  72. @Autowired
  73. private BillDryMapper dryMapper;
  74. @Override
  75. @Transactional(rollbackFor = Exception.class)
  76. public Result addAdmission(HttpServletRequest httpServletRequest, String admissionType, String vistitType, String userName, String phone, String workName, String papersType, String papersCode, MultipartFile imgUrl, String img, String vistitDate, String vistitReson, String destId, String destName, String farmId,String carNum,String source) throws IOException {
  77. Integer userId = TokenSign.getMemberIdByJwtToken(httpServletRequest);
  78. if (!PhoneNumberValidator.isValidPhoneNumber(phone)) {
  79. return new Result(10001, "手机号格式错误!", false);
  80. }
  81. if (papersType.equals("0")) {
  82. if (!IDCardValidator.isValidIDCard(papersCode)) {
  83. return new Result(10001, "身份证号格式错误!", false);
  84. }
  85. }
  86. DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
  87. BillPersonnelAdmission billPersonnelAdmission = new BillPersonnelAdmission();
  88. billPersonnelAdmission.setAdmissionType(Integer.parseInt(admissionType));
  89. billPersonnelAdmission.setVistitType(Integer.parseInt(vistitType));
  90. billPersonnelAdmission.setDestId(Integer.parseInt(destId));
  91. billPersonnelAdmission.setDestName(destName);
  92. billPersonnelAdmission.setAdmissionUserId(userId);
  93. billPersonnelAdmission.setAdmissionUserName(userName);
  94. billPersonnelAdmission.setVistitDate(LocalDateTime.parse(vistitDate, dateTimeFormatter));
  95. billPersonnelAdmission.setSubDate(LocalDateTime.now());
  96. billPersonnelAdmission.setPhone(phone);
  97. billPersonnelAdmission.setWorkName(workName);
  98. billPersonnelAdmission.setPapersType(Integer.parseInt(papersType));
  99. billPersonnelAdmission.setPapersCode(papersCode);
  100. if (ObjectUtil.isNotEmpty(carNum)){
  101. billPersonnelAdmission.setCarNum(carNum);
  102. }
  103. if (ObjectUtil.isNotEmpty(imgUrl)) {
  104. if (uploadImage.getImageCom(imgUrl).equals("上传失败")) {
  105. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  106. return new Result(10001, "图片上传失败", false);
  107. }
  108. billPersonnelAdmission.setImgUrl(uploadImage.getImageCom(imgUrl));
  109. }
  110. if (ObjectUtil.isNotEmpty(img)) {
  111. billPersonnelAdmission.setImgUrl(img);
  112. }
  113. if (ObjectUtil.isNotEmpty(source)){
  114. billPersonnelAdmission.setSource(source);
  115. }
  116. billPersonnelAdmission.setVistitReson(vistitReson);
  117. billPersonnelAdmission.setFarmId(Integer.parseInt(farmId));
  118. BaseProcess baseProcess = new BaseProcess();
  119. baseProcess.setDestName(destName);
  120. baseProcess.setDestId(Integer.parseInt(destId));
  121. baseProcess.setAdmissionUserId(userId);
  122. baseProcess.setAdmissionUserName(userName);
  123. baseProcess.setSubDate(DateTime.now());
  124. baseProcess.setUpdateDate(LocalDateTime.now().format(dateTimeFormatter));
  125. baseProcess.setCurrentStatus("0");
  126. //获取位置
  127. BaseLocation baseLocation = baseLocationMapper.selectOne(new QueryWrapper<BaseLocation>().eq("farm_id", farmId).eq("vistit_type", vistitType).eq("parent_id", 0));
  128. if (ObjectUtil.isEmpty(baseLocation)) {
  129. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  130. return new Result(10001, "该来访类型位置不存在", false);
  131. }
  132. baseProcess.setCurrentLocation(baseLocation.getLocationName());
  133. baseProcess.setCurrentLocationId(baseLocation.getId().toString());
  134. baseProcess.setFarmId(Integer.parseInt(farmId));
  135. baseProcessMapper.insert(baseProcess);
  136. billPersonnelAdmission.setProcessId(baseProcess.getId());
  137. billPersonnelAdmissionMapper.insert(billPersonnelAdmission);
  138. return Result.SUCCESS();
  139. }
  140. @Override
  141. public Result listPersonalAdmission(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  142. String pageNo = paramsMap.get("pageNum");
  143. String pageSize = paramsMap.get("pageSize");
  144. Page<BillPersonnelAdmission> page = new Page<>(Integer.parseInt(pageNo), Integer.parseInt(pageSize));
  145. Page<BillPersonnelAdmission> billPersonnelAdmissionPage = billPersonnelAdmissionMapper.selectPage(page, new QueryWrapper<BillPersonnelAdmission>().eq("admission_user_id", TokenSign.getMemberIdByJwtToken(httpServletRequest)).orderByDesc("sub_date"));
  146. return new Result(ResultCode.SUCCESS, billPersonnelAdmissionPage);
  147. }
  148. @Override
  149. public Result listAdmission(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  150. String pageNo = paramsMap.get("pageNum");
  151. String pageSize = paramsMap.get("pageSize");
  152. String type = paramsMap.get("type");
  153. String farmId = paramsMap.get("farmId");
  154. QueryWrapper<BillPersonnelAdmission> queryWrapper = new QueryWrapper<>();
  155. Integer userType = TokenSign.getUserTypeByJwtToken(httpServletRequest);
  156. if (userType == 3) {
  157. //生物安全负责人
  158. queryWrapper.eq("admission_type", 0);
  159. } else if (userType == 2) {
  160. //紧急入场
  161. queryWrapper.ne("admission_type", 0);
  162. }
  163. switch (type) {
  164. case "1":
  165. queryWrapper.eq("bill_status", 0);
  166. break;
  167. case "2":
  168. queryWrapper.eq("bill_status", 1);
  169. break;
  170. case "3":
  171. queryWrapper.eq("bill_status", 2);
  172. break;
  173. default:
  174. break;
  175. }
  176. queryWrapper.orderByDesc("sub_date").eq("farm_id", farmId);
  177. // List<BaseLocation> baseLocations = baseLocationMapper.selectList(new QueryWrapper<BaseLocation>().eq("serial_number", 0));
  178. // List<Integer> locationIds = new ArrayList<>();
  179. // for (BaseLocation baseLocation : baseLocations) {
  180. // locationIds.add(baseLocation.getId());
  181. // }
  182. // if (!locationIds.contains(Integer.parseInt(TokenSign.getWorkIdByJwtToken(httpServletRequest)))){
  183. // queryWrapper.eq("id",0);
  184. // }
  185. Page<BillPersonnelAdmission> page = new Page<>(Integer.parseInt(pageNo), Integer.parseInt(pageSize));
  186. Page<BillPersonnelAdmission> billPersonnelAdmissionPage = billPersonnelAdmissionMapper.selectPage(page, queryWrapper);
  187. return new Result(ResultCode.SUCCESS, billPersonnelAdmissionPage);
  188. }
  189. @Override
  190. @Transactional
  191. public Result handleAdmission(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  192. String type = paramsMap.get("type");
  193. String id = paramsMap.get("id");
  194. DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
  195. BillPersonnelAdmission billPersonnelAdmission = billPersonnelAdmissionMapper.selectById(id);
  196. Integer userType = TokenSign.getUserTypeByJwtToken(httpServletRequest);
  197. billPersonnelAdmission.setPassDate(LocalDateTime.now());
  198. billPersonnelAdmission.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  199. billPersonnelAdmission.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  200. BaseProcess baseProcess = baseProcessMapper.selectById(billPersonnelAdmission.getProcessId());
  201. List<BaseLocation> baseLocations = baseLocationMapper.selectList(new QueryWrapper<BaseLocation>().eq("serial_number", 0));
  202. List<Integer> locationIds = new ArrayList<>();
  203. for (BaseLocation baseLocation : baseLocations) {
  204. locationIds.add(baseLocation.getId());
  205. }
  206. if (StringUtils.isBlank(baseProcess.getUpdateDate())) {
  207. baseProcess.setUpdateDate(LocalDateTime.now().format(dateTimeFormatter));
  208. } else {
  209. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + LocalDateTime.now().format(dateTimeFormatter));
  210. }
  211. if (type.equals("0")) {
  212. //拒绝
  213. billPersonnelAdmission.setBillStatus(2);
  214. baseProcess.setProcessType(2);
  215. } else {
  216. //通过
  217. billPersonnelAdmission.setBillStatus(1);
  218. //获取pcr位置
  219. String laseLocationId = baseProcess.getCurrentLocationId();
  220. BaseLocation laseLocation = baseLocationMapper.selectById(laseLocationId);
  221. BaseLocation baseLocation = baseLocationMapper.selectById(laseLocation.getNextId());
  222. if (userType == 3) {
  223. if (locationIds.contains(billPersonnelAdmission.getDestId())) {
  224. baseProcess.setCurrentStatus("1");
  225. baseProcess.setProcessType(1);
  226. } else {
  227. baseProcess.setCurrentStatus("1,0");
  228. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getLocationName());
  229. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getId());
  230. BillPcr billPcr = new BillPcr();
  231. billPcr.setVistitType(billPersonnelAdmission.getVistitType());
  232. billPcr.setDestName(billPersonnelAdmission.getDestName());
  233. billPcr.setDestId(billPersonnelAdmission.getDestId());
  234. billPcr.setPhone(billPersonnelAdmission.getPhone());
  235. billPcr.setAdmissionUserId(billPersonnelAdmission.getAdmissionUserId());
  236. billPcr.setAdmissionUserName(billPersonnelAdmission.getAdmissionUserName());
  237. billPcr.setSubDate(LocalDateTime.now());
  238. billPcr.setVistitDate(billPersonnelAdmission.getVistitDate());
  239. billPcr.setFarmId(billPersonnelAdmission.getFarmId());
  240. billPcr.setProcessId(billPersonnelAdmission.getProcessId());
  241. billPcr.setAdmissionId(Integer.parseInt(id));
  242. if (ObjectUtil.isNotEmpty(billPersonnelAdmission.getCarNum())){
  243. billPcr.setCarNum(billPersonnelAdmission.getCarNum());
  244. }
  245. billPcr.setTestLocation(baseLocation.getLocationName());
  246. billPcr.setTestLocationId(baseLocation.getId());
  247. billPcrMapper.insert(billPcr);
  248. }
  249. } else {
  250. baseProcess.setCurrentStatus("1");
  251. // baseProcess.setCurrentLocation(baseProcess.getCurrentLocation()+","+baseLocation.getLocationName());
  252. // baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() +","+baseLocation.getId());
  253. //TODO 紧急入场通过先不处理
  254. }
  255. }
  256. baseProcessMapper.updateById(baseProcess);
  257. billPersonnelAdmissionMapper.updateById(billPersonnelAdmission);
  258. return Result.SUCCESS();
  259. }
  260. @Override
  261. public Result listAll(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  262. String type = paramsMap.get("type");
  263. String farmId = paramsMap.get("farmId");
  264. String pageNo = paramsMap.get("pageNum");
  265. String pageSize = paramsMap.get("pageSize");
  266. Page<FactoryDirectorVo> page = new Page<>(Integer.parseInt(pageNo), Integer.parseInt(pageSize));
  267. IPage<FactoryDirectorVo> factoryDirectorList;
  268. if (type.equals("0")){
  269. factoryDirectorList = billPersonnelAdmissionMapper.listAll(type, farmId, page);
  270. }else {
  271. factoryDirectorList = billPersonnelAdmissionMapper.listCarAll(type, farmId, page);
  272. }
  273. return new Result(ResultCode.SUCCESS, factoryDirectorList);
  274. }
  275. @Override
  276. public Result getDetail(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  277. String type = paramsMap.get("type");
  278. String id = paramsMap.get("id");
  279. if (type.equals("0")) {
  280. return new Result(ResultCode.SUCCESS, billPersonnelAdmissionMapper.selectById(id));
  281. } else if (type.equals("1")) {
  282. return new Result(ResultCode.SUCCESS, billPcrMapper.selectById(id));
  283. } else if (type.equals("2")) {
  284. return new Result(ResultCode.SUCCESS, billCleanMapper.selectById(id));
  285. } else {
  286. return new Result(ResultCode.SUCCESS, billIsolateMapper.selectById(id));
  287. }
  288. }
  289. @Autowired
  290. private BillPcrMapper pcrMapper;
  291. @Autowired
  292. private BaseProcessMapper processMapper;
  293. @Autowired
  294. private BaseLocationMapper locationMapper;
  295. @Autowired
  296. private BillCleanMapper cleanMapper;
  297. @Autowired
  298. private BillIsolateMapper isolateMapper;
  299. @Override
  300. public Result listPrc(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  301. String type = paramsMap.get("type");//类型
  302. String pageNum = paramsMap.get("pageNum");
  303. String pageSize = paramsMap.get("pageSize");
  304. if ("".equals(pageNum) || null == pageNum) {
  305. pageNum = "1";
  306. }
  307. if ("".equals(pageSize) || null == pageSize) {
  308. pageSize = "20";
  309. }
  310. Page<BillPcr> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
  311. if ("".equals(type) || null == type) {
  312. type = "0";
  313. }
  314. String farmId = paramsMap.get("farmId");
  315. QueryWrapper<BillPcr> queryWrapper = new QueryWrapper<>();
  316. queryWrapper.eq("farm_id", farmId).orderByDesc("sub_date");
  317. if ("0".equals(type)) {
  318. queryWrapper.in("pcr_type", 1, 2, 3);
  319. }
  320. if ("1".equals(type)) {
  321. queryWrapper.eq("pcr_type", 1);
  322. }
  323. if ("2".equals(type)) {
  324. queryWrapper.eq("pcr_type", 2);
  325. }
  326. if ("3".equals(type)) {
  327. queryWrapper.eq("pcr_type", 3);
  328. }
  329. return new Result(ResultCode.SUCCESS, pcrMapper.selectPage(page, queryWrapper));
  330. }
  331. @Override
  332. public Result listById(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  333. String id = paramsMap.get("id");
  334. return new Result(ResultCode.SUCCESS, pcrMapper.selectById(id));
  335. }
  336. @Override
  337. public Result editStatus(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) throws ParseException {
  338. String farmId = paramsMap.get("farmId");
  339. String type = paramsMap.get("type");
  340. String id = paramsMap.get("id");
  341. String data = paramsMap.get("data");
  342. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
  343. if (StringUtils.isBlank(data)) {
  344. data = sdf.format(new Date());
  345. }
  346. BillPcr billPcr = pcrMapper.selectById(id);
  347. QueryWrapper<BaseProcess> processQueryWrapper = new QueryWrapper<>();
  348. processQueryWrapper.eq("farm_id", farmId).eq("id", billPcr.getProcessId());
  349. BaseProcess baseProcess = processMapper.selectOne(processQueryWrapper);//进程
  350. QueryWrapper<BaseLocation> locationQueryWrapper = new QueryWrapper<>();
  351. locationQueryWrapper.eq("farm_id", farmId).eq("id", billPcr.getTestLocationId());
  352. BaseLocation baseLocation = locationMapper.selectOne(locationQueryWrapper);//当前pcr检测所在的位置
  353. if (baseProcess.getProcessType() == 2 || baseProcess.getProcessType() == 1) {
  354. return new Result(10001, "修改失败!该申请已提前结束或者被拒绝", false);
  355. } else {
  356. if (billPcr.getDestId() > billPcr.getTestLocationId()) { //说明当前不是目的地
  357. if ("1".equals(type)) {
  358. billPcr.setBillStatus(1);
  359. billPcr.setPcrType(2);
  360. billPcr.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  361. billPcr.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  362. billPcr.setTestLocation(baseLocation.getLocationName());
  363. billPcr.setTestLocationId(baseLocation.getId());
  364. billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
  365. billPcr.setCheckDate(sdf.parse(data));
  366. //通过生成洗消记录
  367. BillClean billClean = new BillClean();
  368. billClean.setPhone(billPcr.getPhone());
  369. billClean.setVistitType(billPcr.getVistitType());
  370. billClean.setDestName(billPcr.getDestName());
  371. billClean.setDestId(billPcr.getDestId());
  372. billClean.setAdmissionUserName(billPcr.getAdmissionUserName());
  373. billClean.setAdmissionUserId(billPcr.getAdmissionUserId());
  374. billClean.setVistitDate(billPcr.getVistitDate());
  375. billClean.setSubDate(billPcr.getSubDate());
  376. billClean.setFarmId(billPcr.getFarmId());
  377. billClean.setPassUserName(billPcr.getPassUserName());
  378. billClean.setPassDate(billPcr.getPassDate());
  379. billClean.setPassUserId(billPcr.getPassUserId());
  380. billClean.setProcessId(billPcr.getProcessId());
  381. billClean.setTestLocation(baseLocation.getNextLocation());
  382. billClean.setTestLocationId(baseLocation.getNextId());
  383. billClean.setImgStatus(0);
  384. billClean.setCarNum(billPcr.getCarNum());
  385. cleanMapper.insert(billClean);
  386. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  387. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
  388. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
  389. String status = baseProcess.getCurrentStatus();
  390. String substring = status.substring(0, status.length() - 1);
  391. baseProcess.setCurrentStatus(substring + "1," + 0);
  392. processMapper.updateById(baseProcess);
  393. pcrMapper.updateById(billPcr);
  394. return new Result(10000, "修改成功!", true);
  395. } else {
  396. billPcr.setBillStatus(2);
  397. billPcr.setPcrType(3);
  398. billPcr.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  399. billPcr.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  400. billPcr.setTestLocation(baseLocation.getLocationName());
  401. billPcr.setTestLocationId(baseLocation.getId());
  402. billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
  403. billPcr.setCheckDate(sdf.parse(data));
  404. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  405. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  406. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  407. String status = baseProcess.getCurrentStatus();
  408. String substring = status.substring(0, status.length() - 1);
  409. baseProcess.setCurrentStatus(substring + "2");
  410. baseProcess.setProcessType(2);
  411. processMapper.updateById(baseProcess);
  412. pcrMapper.updateById(billPcr);
  413. return new Result(10000, "修改成功!", true);
  414. }
  415. } else {
  416. if ("1".equals(type)) {
  417. billPcr.setBillStatus(1);
  418. billPcr.setPcrType(2);
  419. billPcr.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  420. billPcr.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  421. billPcr.setTestLocation(baseLocation.getLocationName());
  422. billPcr.setTestLocationId(baseLocation.getId());
  423. billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
  424. billPcr.setCheckDate(sdf.parse(data));
  425. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  426. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  427. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  428. String status = baseProcess.getCurrentStatus();
  429. String substring = status.substring(0, status.length() - 1);
  430. baseProcess.setCurrentStatus(substring + "1");
  431. baseProcess.setProcessType(1);
  432. processMapper.updateById(baseProcess);
  433. pcrMapper.updateById(billPcr);
  434. return new Result(10000, "修改成功!", true);
  435. } else {
  436. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  437. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  438. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  439. String status = baseProcess.getCurrentStatus();
  440. String substring = status.substring(0, status.length() - 1);
  441. baseProcess.setCurrentStatus(substring + "2");
  442. baseProcess.setProcessType(2);
  443. billPcr.setBillStatus(2);
  444. billPcr.setPcrType(3);
  445. billPcr.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  446. billPcr.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  447. billPcr.setTestLocation(baseLocation.getLocationName());
  448. billPcr.setTestLocationId(baseLocation.getId());
  449. billPcr.setPassDate(sdf.parse(sdf.format(new Date())));
  450. billPcr.setCheckDate(sdf.parse(data));
  451. processMapper.updateById(baseProcess);
  452. pcrMapper.updateById(billPcr);
  453. return new Result(10000, "修改成功!", true);
  454. }
  455. }
  456. }
  457. }
  458. @Override
  459. public Result listIsolate(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  460. String type = paramsMap.get("type");//类型
  461. String pageNum = paramsMap.get("pageNum");
  462. String pageSize = paramsMap.get("pageSize");
  463. if ("".equals(pageNum) || null == pageNum) {
  464. pageNum = "1";
  465. }
  466. if ("".equals(pageSize) || null == pageSize) {
  467. pageSize = "20";
  468. }
  469. Page<BillIsolate> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
  470. if ("".equals(type) || null == type) {
  471. type = "0";
  472. }
  473. String farmId = paramsMap.get("farmId");
  474. QueryWrapper<BillIsolate> queryWrapper = new QueryWrapper<>();
  475. queryWrapper.eq("farm_id", farmId).orderByDesc("sub_date");
  476. if ("0".equals(type)) {
  477. queryWrapper.in("bill_status", 0, 1, 2, 3);
  478. }
  479. if ("1".equals(type)) {
  480. queryWrapper.eq("bill_status", 0);
  481. }
  482. if ("2".equals(type)) {
  483. queryWrapper.in("bill_status", 1, 2);
  484. }
  485. if ("3".equals(type)) {
  486. queryWrapper.eq("bill_status", 3);
  487. }
  488. return new Result(ResultCode.SUCCESS, isolateMapper.selectPage(page, queryWrapper));
  489. }
  490. @Override
  491. public Result isolateById(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  492. String id = paramsMap.get("id");
  493. return new Result(ResultCode.SUCCESS, isolateMapper.selectById(id));
  494. }
  495. @Override
  496. public Result commitIsolate(HttpServletRequest httpServletRequest, BillIsolate billIsolate) {
  497. BillIsolate isolate = isolateMapper.selectById(billIsolate.getId());
  498. Date startDate = billIsolate.getIsolateStartDate();
  499. Integer dayNum = billIsolate.getIsolateDayNum();//隔离天数
  500. Date endDate = DataUill.getNextDay(startDate, dayNum);
  501. isolate.setIsolateStartDate(startDate);
  502. isolate.setIsolateEndDate(endDate);
  503. isolate.setIsolateDayNum(dayNum);
  504. isolate.setBillStatus(1);
  505. isolateMapper.updateById(isolate);
  506. ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(10);
  507. Runnable task = new Runnable() {
  508. @Override
  509. public void run() {
  510. //这里写业务
  511. BillIsolate isolate = isolateMapper.selectById(billIsolate.getId());
  512. QueryWrapper<BaseLocation> locationQueryWrapper = new QueryWrapper<>();
  513. locationQueryWrapper.eq("farm_id", isolate.getFarmId()).eq("id", isolate.getIsolateLocationId());
  514. BaseLocation baseLocation = locationMapper.selectOne(locationQueryWrapper);//当前所在的位置
  515. QueryWrapper<BaseProcess> processQueryWrapper = new QueryWrapper<>();
  516. processQueryWrapper.eq("farm_id", isolate.getFarmId()).eq("id", isolate.getProcessId());
  517. BaseProcess baseProcess = processMapper.selectOne(processQueryWrapper);//进程
  518. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
  519. if (isolate.getBillStatus() == 1) {
  520. isolate.setBillStatus(2);
  521. if (isolate.getDestId() > isolate.getIsolateLocationId()) { //当前不是目的地
  522. if (isolate.getIsolateLocationId() == 8) {
  523. //通过生成洗消记录
  524. BillClean billClean = new BillClean();
  525. billClean.setPhone(isolate.getPhone());
  526. billClean.setVistitType(isolate.getVistitType());
  527. billClean.setDestName(isolate.getDestName());
  528. billClean.setDestId(isolate.getDestId());
  529. billClean.setAdmissionUserName(isolate.getAdmissionUserName());
  530. billClean.setAdmissionUserId(isolate.getAdmissionUserId());
  531. billClean.setVistitDate(isolate.getVistitDate());
  532. billClean.setSubDate(isolate.getSubDate());
  533. billClean.setFarmId(isolate.getFarmId());
  534. billClean.setPassUserName(isolate.getPassUserName());
  535. billClean.setPassDate(isolate.getPassDate());
  536. billClean.setPassUserId(isolate.getPassUserId());
  537. billClean.setProcessId(isolate.getProcessId());
  538. billClean.setTestLocation(baseLocation.getNextLocation());
  539. billClean.setTestLocationId(baseLocation.getNextId());
  540. cleanMapper.insert(billClean);
  541. }
  542. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  543. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
  544. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
  545. String status = baseProcess.getCurrentStatus();
  546. String substring = status.substring(0, status.length() - 1);
  547. baseProcess.setCurrentStatus(substring + "1," + 0);
  548. processMapper.updateById(baseProcess);
  549. } else {
  550. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  551. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  552. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  553. String status = baseProcess.getCurrentStatus();
  554. String substring = status.substring(0, status.length() - 1);
  555. baseProcess.setCurrentStatus(substring + "2");
  556. baseProcess.setProcessType(1);
  557. processMapper.updateById(baseProcess);
  558. }
  559. isolateMapper.updateById(isolate);
  560. }
  561. }
  562. };
  563. // 设定延迟时间(两小时后执行,单位为秒)
  564. long delay = (endDate.getTime() - startDate.getTime()) / 1000;
  565. // 执行定时任务
  566. scheduler.schedule(task, delay, TimeUnit.SECONDS);
  567. return new Result(10000, "提交成功!", true);
  568. }
  569. @Override
  570. public Result editIsolate(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) throws ParseException {
  571. String id = paramsMap.get("id");
  572. String farmId = paramsMap.get("farmId");
  573. String remark = paramsMap.get("remark");//是否提前结束隔离的标识
  574. BillIsolate billIsolate = isolateMapper.selectById(id);
  575. BaseProcess baseProcess = processMapper.selectById(billIsolate.getProcessId());
  576. QueryWrapper<BaseLocation> locationQueryWrapper = new QueryWrapper<>();
  577. locationQueryWrapper.eq(StringUtils.isNotBlank(farmId), "farm_id", farmId).eq("id", billIsolate.getIsolateLocationId());
  578. BaseLocation baseLocation = locationMapper.selectOne(locationQueryWrapper);//当前隔离所在的位置
  579. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  580. String end = sdf.format(billIsolate.getIsolateEndDate());
  581. String start = sdf.format(billIsolate.getIsolateStartDate());
  582. String now = sdf.format(new Date());
  583. int res = now.compareTo(end);
  584. if (res > 0) {//当前时间晚于隔离结束时间
  585. if (baseProcess.getDestId().equals(billIsolate.getIsolateLocationId()) || baseProcess.getDestId() >= 13) {
  586. //目的地就是当前隔离地点
  587. baseProcess.setProcessType(1);
  588. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  589. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  590. } else {
  591. baseProcess.setProcessType(0);
  592. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
  593. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
  594. }
  595. if (billIsolate.getIsolateLocationId() == 8 && baseProcess.getDestId() >= 10) {
  596. //通过生成洗消记录
  597. BillClean billClean = new BillClean();
  598. billClean.setVistitType(billIsolate.getVistitType());
  599. billClean.setDestName(billIsolate.getDestName());
  600. billClean.setDestId(billIsolate.getDestId());
  601. billClean.setAdmissionUserName(billIsolate.getAdmissionUserName());
  602. billClean.setAdmissionUserId(billIsolate.getAdmissionUserId());
  603. billClean.setVistitDate(billIsolate.getVistitDate());
  604. billClean.setSubDate(billIsolate.getSubDate());
  605. billClean.setFarmId(billIsolate.getFarmId());
  606. billClean.setPassUserName(billIsolate.getPassUserName());
  607. billClean.setPassDate(billIsolate.getPassDate());
  608. billClean.setPassUserId(billIsolate.getPassUserId());
  609. billClean.setProcessId(billIsolate.getProcessId());
  610. billClean.setTestLocation("场内洗澡间1");
  611. billClean.setTestLocationId(10);
  612. billClean.setPhone(billIsolate.getPhone());
  613. cleanMapper.insert(billClean);
  614. }
  615. billIsolate.setIsolateRealEndDate(new Date());
  616. SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
  617. Calendar cal1 = Calendar.getInstance();
  618. Calendar cal2 = Calendar.getInstance();
  619. Date startDate = sdf1.parse(start);
  620. Date endDate = sdf1.parse(now);
  621. cal1.setTime(startDate);
  622. cal2.setTime(endDate);
  623. long days = (cal2.getTimeInMillis() - cal1.getTimeInMillis()) / (1000 * 3600 * 24);
  624. billIsolate.setIsolateRealDayNum((int) days);
  625. billIsolate.setBillStatus(2);
  626. billIsolate.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  627. billIsolate.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  628. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + now);
  629. String status = baseProcess.getCurrentStatus();
  630. String substring = status.substring(0, status.length() - 1);
  631. baseProcess.setCurrentStatus(substring + "1," + 0);
  632. isolateMapper.updateById(billIsolate);
  633. processMapper.updateById(baseProcess);
  634. return new Result(10000, "正常解除隔离成功!", true);
  635. } else {
  636. //提前结束隔离
  637. if (baseProcess.getDestId().equals(billIsolate.getIsolateLocationId())) {
  638. //目的地就是当前隔离地点
  639. baseProcess.setProcessType(1);
  640. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  641. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  642. } else {
  643. baseProcess.setProcessType(0);
  644. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
  645. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
  646. }
  647. if (billIsolate.getIsolateLocationId() == 8 && baseProcess.getDestId() >= 10) {
  648. //通过生成洗消记录
  649. BillClean billClean = new BillClean();
  650. billClean.setVistitType(billIsolate.getVistitType());
  651. billClean.setDestName(billIsolate.getDestName());
  652. billClean.setDestId(billIsolate.getDestId());
  653. billClean.setAdmissionUserName(billIsolate.getAdmissionUserName());
  654. billClean.setAdmissionUserId(billIsolate.getAdmissionUserId());
  655. billClean.setVistitDate(billIsolate.getVistitDate());
  656. billClean.setSubDate(billIsolate.getSubDate());
  657. billClean.setFarmId(billIsolate.getFarmId());
  658. billClean.setPassUserName(billIsolate.getPassUserName());
  659. billClean.setPassDate(billIsolate.getPassDate());
  660. billClean.setPassUserId(billIsolate.getPassUserId());
  661. billClean.setProcessId(billIsolate.getProcessId());
  662. billClean.setTestLocation("场内洗澡间1");
  663. billClean.setTestLocationId(10);
  664. billClean.setPhone(billIsolate.getPhone());
  665. cleanMapper.insert(billClean);
  666. }
  667. billIsolate.setIsolateRealEndDate(new Date());
  668. SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
  669. Calendar cal1 = Calendar.getInstance();
  670. Calendar cal2 = Calendar.getInstance();
  671. Date startDate = sdf1.parse(start);
  672. Date endDate = sdf1.parse(now);
  673. cal1.setTime(startDate);
  674. cal2.setTime(endDate);
  675. long days = (cal2.getTimeInMillis() - cal1.getTimeInMillis()) / (1000 * 3600 * 24);
  676. billIsolate.setIsolateRealDayNum((int) days);
  677. billIsolate.setBillStatus(3);
  678. billIsolate.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  679. billIsolate.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  680. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + now);
  681. String status = baseProcess.getCurrentStatus();
  682. String substring = status.substring(0, status.length() - 1);
  683. baseProcess.setCurrentStatus(substring + "1," + 0);
  684. isolateMapper.updateById(billIsolate);
  685. processMapper.updateById(baseProcess);
  686. return new Result(10000, "提前解除隔离成功!", true);
  687. }
  688. }
  689. @Override
  690. public Result listClean(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  691. String type = paramsMap.get("type");//类型
  692. String pageNum = paramsMap.get("pageNum");
  693. String pageSize = paramsMap.get("pageSize");
  694. if ("".equals(pageNum) || null == pageNum) {
  695. pageNum = "1";
  696. }
  697. if ("".equals(pageSize) || null == pageSize) {
  698. pageSize = "20";
  699. }
  700. Page<BillClean> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
  701. if ("".equals(type) || null == type) {
  702. type = "0";
  703. }
  704. String farmId = paramsMap.get("farmId");
  705. QueryWrapper<BillClean> queryWrapper = new QueryWrapper<>();
  706. queryWrapper.eq("farm_id", farmId).orderByDesc("sub_date");
  707. if ("0".equals(type)) {
  708. queryWrapper.in("bill_status", 0, 1, 2);
  709. }
  710. if ("1".equals(type)) {
  711. queryWrapper.eq("bill_status", 0);
  712. }
  713. if ("2".equals(type)) {
  714. queryWrapper.eq("bill_status", 1);
  715. }
  716. if ("3".equals(type)) {
  717. queryWrapper.eq("bill_status", 2);
  718. }
  719. return new Result(ResultCode.SUCCESS, cleanMapper.selectPage(page, queryWrapper));
  720. }
  721. @Override
  722. public Result listByIdClean(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  723. String id = paramsMap.get("id");
  724. return new Result(ResultCode.SUCCESS, cleanMapper.selectById(id));
  725. }
  726. //清洗和洗消的检测
  727. @Override
  728. public Result editClean(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) throws ParseException {
  729. String result = paramsMap.get("result");
  730. String id = paramsMap.get("id");
  731. String farmId = paramsMap.get("farmId");
  732. BillClean billClean = cleanMapper.selectById(id);
  733. QueryWrapper<BaseProcess> processQueryWrapper = new QueryWrapper<>();
  734. processQueryWrapper.eq("farm_id", farmId).eq("id", billClean.getProcessId());
  735. BaseProcess baseProcess = processMapper.selectOne(processQueryWrapper);//进程
  736. QueryWrapper<BaseLocation> locationQueryWrapper = new QueryWrapper<>();
  737. locationQueryWrapper.eq("farm_id", farmId).eq("id", billClean.getTestLocationId());
  738. BaseLocation baseLocation = locationMapper.selectOne(locationQueryWrapper);//当前洗消检测所在的位置
  739. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
  740. if (baseProcess.getProcessType() == 2 || baseProcess.getProcessType() == 1) {
  741. return new Result(10001, "修改失败!该申请已提前结束或者被拒绝", false);
  742. } else {
  743. if (billClean.getDestId() > billClean.getTestLocationId()) { //说明当前不是目的地
  744. if ("1".equals(result)) {
  745. billClean.setBillStatus(1);
  746. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  747. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  748. billClean.setTestLocation(baseLocation.getLocationName());
  749. billClean.setTestLocationId(baseLocation.getId());
  750. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  751. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  752. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  753. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
  754. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
  755. String status = baseProcess.getCurrentStatus();
  756. String substring = status.substring(0, status.length() - 1);
  757. baseProcess.setCurrentStatus(substring + "1," + 0);
  758. //环保车洗消合格生成烘干申请
  759. if (billClean.getDestId() == 18 || billClean.getDestId() == 21) {
  760. BillDry billDry = new BillDry();
  761. billDry.setVistitType(billClean.getVistitType());
  762. billDry.setDestName(billClean.getDestName());
  763. billDry.setDestId(billClean.getDestId());
  764. billDry.setAdmissionUserName(billClean.getAdmissionUserName());
  765. billDry.setAdmissionUserId(billClean.getAdmissionUserId());
  766. billDry.setVistitDate(billClean.getVistitDate());
  767. billDry.setSubDate(billClean.getSubDate());
  768. billDry.setFarmId(billClean.getFarmId());
  769. billDry.setBillStatus(0);
  770. billDry.setProcessId(billClean.getProcessId());
  771. billDry.setTestLocation(baseLocation.getNextLocation());
  772. billDry.setTestLocationId(baseLocation.getNextId());
  773. billDry.setPhone(billClean.getPhone());
  774. billDry.setCarNum(billClean.getCarNum());
  775. billDry.setImgStatus(0);
  776. dryMapper.insert(billDry);
  777. }
  778. //拉猪车洗消合格生成烘干申请
  779. if (billClean.getDestId() == 27 ) {
  780. BillDry billDry = new BillDry();
  781. billDry.setVistitType(billClean.getVistitType());
  782. billDry.setDestName(billClean.getDestName());
  783. billDry.setDestId(billClean.getDestId());
  784. billDry.setAdmissionUserName(billClean.getAdmissionUserName());
  785. billDry.setAdmissionUserId(billClean.getAdmissionUserId());
  786. billDry.setVistitDate(billClean.getVistitDate());
  787. billDry.setSubDate(billClean.getSubDate());
  788. billDry.setFarmId(billClean.getFarmId());
  789. billDry.setBillStatus(0);
  790. billDry.setProcessId(billClean.getProcessId());
  791. billDry.setTestLocation(baseLocation.getNextLocation());
  792. billDry.setTestLocationId(baseLocation.getNextId());
  793. billDry.setPhone(billClean.getPhone());
  794. billDry.setCarNum(billClean.getCarNum());
  795. billDry.setImgStatus(0);
  796. dryMapper.insert(billDry);
  797. }
  798. //送猪车洗消合格生成烘干申请
  799. if (billClean.getDestId() == 42 ) {
  800. BillDry billDry = new BillDry();
  801. billDry.setVistitType(billClean.getVistitType());
  802. billDry.setDestName(billClean.getDestName());
  803. billDry.setDestId(billClean.getDestId());
  804. billDry.setAdmissionUserName(billClean.getAdmissionUserName());
  805. billDry.setAdmissionUserId(billClean.getAdmissionUserId());
  806. billDry.setVistitDate(billClean.getVistitDate());
  807. billDry.setSubDate(billClean.getSubDate());
  808. billDry.setFarmId(billClean.getFarmId());
  809. billDry.setBillStatus(0);
  810. billDry.setProcessId(billClean.getProcessId());
  811. billDry.setTestLocation(baseLocation.getNextLocation());
  812. billDry.setTestLocationId(baseLocation.getNextId());
  813. billDry.setPhone(billClean.getPhone());
  814. billDry.setCarNum(billClean.getCarNum());
  815. billDry.setImgStatus(0);
  816. dryMapper.insert(billDry);
  817. }
  818. processMapper.updateById(baseProcess);
  819. cleanMapper.updateById(billClean);
  820. return new Result(10000, "修改成功!", true);
  821. } else {
  822. billClean.setBillStatus(2);
  823. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  824. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  825. billClean.setTestLocation(baseLocation.getLocationName());
  826. billClean.setTestLocationId(baseLocation.getId());
  827. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  828. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  829. billClean.setImgStatus(0);
  830. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  831. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  832. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  833. String status = baseProcess.getCurrentStatus();
  834. String substring = status.substring(0, status.length() - 1);
  835. baseProcess.setCurrentStatus(substring + "2");
  836. baseProcess.setProcessType(2);
  837. processMapper.updateById(baseProcess);
  838. cleanMapper.updateById(billClean);
  839. return new Result(10000, "修改成功!", true);
  840. }
  841. } else {
  842. if ("1".equals(result)) {
  843. billClean.setBillStatus(1);
  844. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  845. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  846. billClean.setTestLocation(baseLocation.getLocationName());
  847. billClean.setTestLocationId(baseLocation.getId());
  848. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  849. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  850. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  851. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  852. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  853. String status = baseProcess.getCurrentStatus();
  854. String substring = status.substring(0, status.length() - 1);
  855. baseProcess.setCurrentStatus(substring + "1");
  856. baseProcess.setProcessType(1);
  857. processMapper.updateById(baseProcess);
  858. cleanMapper.updateById(billClean);
  859. return new Result(10000, "修改成功!", true);
  860. } else {
  861. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  862. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  863. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  864. String status = baseProcess.getCurrentStatus();
  865. String substring = status.substring(0, status.length() - 1);
  866. baseProcess.setCurrentStatus(substring + "2");
  867. baseProcess.setProcessType(2);
  868. billClean.setBillStatus(2);
  869. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  870. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  871. billClean.setTestLocation(baseLocation.getLocationName());
  872. billClean.setTestLocationId(baseLocation.getId());
  873. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  874. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  875. billClean.setImgStatus(0);
  876. processMapper.updateById(baseProcess);
  877. cleanMapper.updateById(billClean);
  878. return new Result(10000, "修改成功!", true);
  879. }
  880. }
  881. }
  882. }
  883. //烘干检测
  884. @Override
  885. public Result editDry(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) throws ParseException {
  886. String result = paramsMap.get("result");
  887. String id = paramsMap.get("id");
  888. String farmId = paramsMap.get("farmId");
  889. BillDry billClean = dryMapper.selectById(id);
  890. QueryWrapper<BaseProcess> processQueryWrapper = new QueryWrapper<>();
  891. processQueryWrapper.eq("farm_id", farmId).eq("id", billClean.getProcessId());
  892. BaseProcess baseProcess = processMapper.selectOne(processQueryWrapper);//进程
  893. QueryWrapper<BaseLocation> locationQueryWrapper = new QueryWrapper<>();
  894. locationQueryWrapper.eq("farm_id", farmId).eq("id", billClean.getTestLocationId());
  895. BaseLocation baseLocation = locationMapper.selectOne(locationQueryWrapper);//当前洗消检测所在的位置
  896. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
  897. if (baseProcess.getProcessType() == 2 || baseProcess.getProcessType() == 1) {
  898. return new Result(10001, "修改失败!该申请已提前结束或者被拒绝", false);
  899. } else {
  900. if (billClean.getDestId() > billClean.getTestLocationId()) { //说明当前不是目的地
  901. if ("1".equals(result)) {
  902. billClean.setBillStatus(1);
  903. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  904. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  905. billClean.setTestLocation(baseLocation.getLocationName());
  906. billClean.setTestLocationId(baseLocation.getId());
  907. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  908. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  909. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  910. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation() + "," + baseLocation.getNextLocation());
  911. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId() + "," + baseLocation.getNextId());
  912. String status = baseProcess.getCurrentStatus();
  913. String substring = status.substring(0, status.length() - 1);
  914. baseProcess.setCurrentStatus(substring + "1," + 0);
  915. //环保车烘干合格生成洗消申请
  916. if (billClean.getDestId() == 19) {
  917. BillClean clean = new BillClean();
  918. clean.setVistitType(billClean.getVistitType());
  919. clean.setDestName(billClean.getDestName());
  920. clean.setDestId(billClean.getDestId());
  921. clean.setAdmissionUserName(billClean.getAdmissionUserName());
  922. clean.setAdmissionUserId(billClean.getAdmissionUserId());
  923. clean.setVistitDate(billClean.getVistitDate());
  924. clean.setSubDate(billClean.getSubDate());
  925. clean.setFarmId(billClean.getFarmId());
  926. clean.setBillStatus(0);
  927. clean.setProcessId(billClean.getProcessId());
  928. clean.setTestLocationId(baseLocation.getNextId());
  929. clean.setTestLocation(baseLocation.getNextLocation());
  930. clean.setPhone(billClean.getPhone());
  931. clean.setCarNum(billClean.getCarNum());
  932. clean.setImgStatus(0);
  933. cleanMapper.insert(clean);
  934. }
  935. //拉猪车烘干合格生成洗消申请
  936. if (billClean.getDestId() == 28) {
  937. BillClean clean = new BillClean();
  938. clean.setVistitType(billClean.getVistitType());
  939. clean.setDestName(billClean.getDestName());
  940. clean.setDestId(billClean.getDestId());
  941. clean.setAdmissionUserName(billClean.getAdmissionUserName());
  942. clean.setAdmissionUserId(billClean.getAdmissionUserId());
  943. clean.setVistitDate(billClean.getVistitDate());
  944. clean.setSubDate(billClean.getSubDate());
  945. clean.setFarmId(billClean.getFarmId());
  946. clean.setBillStatus(0);
  947. clean.setProcessId(billClean.getProcessId());
  948. clean.setTestLocationId(baseLocation.getNextId());
  949. clean.setTestLocation(baseLocation.getNextLocation());
  950. clean.setPhone(billClean.getPhone());
  951. clean.setCarNum(billClean.getCarNum());
  952. clean.setImgStatus(0);
  953. cleanMapper.insert(clean);
  954. }
  955. processMapper.updateById(baseProcess);
  956. dryMapper.updateById(billClean);
  957. return new Result(10000, "修改成功!", true);
  958. } else {
  959. billClean.setBillStatus(2);
  960. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  961. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  962. billClean.setTestLocation(baseLocation.getLocationName());
  963. billClean.setTestLocationId(baseLocation.getId());
  964. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  965. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  966. billClean.setImgStatus(0);
  967. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  968. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  969. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  970. String status = baseProcess.getCurrentStatus();
  971. String substring = status.substring(0, status.length() - 1);
  972. baseProcess.setCurrentStatus(substring + "2");
  973. baseProcess.setProcessType(2);
  974. processMapper.updateById(baseProcess);
  975. dryMapper.updateById(billClean);
  976. return new Result(10000, "修改成功!", true);
  977. }
  978. } else {
  979. if ("1".equals(result)) {
  980. billClean.setBillStatus(1);
  981. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  982. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  983. billClean.setTestLocation(baseLocation.getLocationName());
  984. billClean.setTestLocationId(baseLocation.getId());
  985. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  986. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  987. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  988. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  989. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  990. String status = baseProcess.getCurrentStatus();
  991. String substring = status.substring(0, status.length() - 1);
  992. baseProcess.setCurrentStatus(substring + "1");
  993. baseProcess.setProcessType(1);
  994. processMapper.updateById(baseProcess);
  995. dryMapper.updateById(billClean);
  996. return new Result(10000, "修改成功!", true);
  997. } else {
  998. baseProcess.setUpdateDate(baseProcess.getUpdateDate() + "," + sdf.format(new Date()));
  999. baseProcess.setCurrentLocation(baseProcess.getCurrentLocation());
  1000. baseProcess.setCurrentLocationId(baseProcess.getCurrentLocationId());
  1001. String status = baseProcess.getCurrentStatus();
  1002. String substring = status.substring(0, status.length() - 1);
  1003. baseProcess.setCurrentStatus(substring + "2");
  1004. baseProcess.setProcessType(2);
  1005. billClean.setBillStatus(2);
  1006. billClean.setPassUserName(TokenSign.getUserNameByJwtToken(httpServletRequest));
  1007. billClean.setPassUserId(TokenSign.getMemberIdByJwtToken(httpServletRequest));
  1008. billClean.setTestLocation(baseLocation.getLocationName());
  1009. billClean.setTestLocationId(baseLocation.getId());
  1010. billClean.setPassDate(sdf.parse(sdf.format(new Date())));
  1011. billClean.setCheckDate(sdf.parse(sdf.format(new Date())));
  1012. billClean.setImgStatus(0);
  1013. processMapper.updateById(baseProcess);
  1014. dryMapper.updateById(billClean);
  1015. return new Result(10000, "修改成功!", true);
  1016. }
  1017. }
  1018. }
  1019. }
  1020. }