AuditPathsServiceImpl.java 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270
  1. package com.ruoyi.approvalFlow.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
  5. import com.ruoyi.approvalFlow.domain.*;
  6. import com.ruoyi.approvalFlow.domain.dto.AppAuditItemDTO;
  7. import com.ruoyi.approvalFlow.domain.enums.AuditStateEnum;
  8. import com.ruoyi.approvalFlow.domain.vo.AppAuditItemVO;
  9. import com.ruoyi.approvalFlow.mapper.*;
  10. import com.ruoyi.approvalFlow.service.IAuditPathsService;
  11. import com.ruoyi.basicData.domain.TFees;
  12. import com.ruoyi.basicData.mapper.TFeesMapper;
  13. import com.ruoyi.common.core.domain.AjaxResult;
  14. import com.ruoyi.common.core.domain.model.LoginUser;
  15. import com.ruoyi.common.exception.WarehouseException;
  16. import com.ruoyi.common.utils.DateUtils;
  17. import com.ruoyi.common.utils.DictUtils;
  18. import com.ruoyi.common.utils.StringUtils;
  19. import com.ruoyi.finance.domain.TFee;
  20. import com.ruoyi.finance.mapper.TFeeMapper;
  21. import com.ruoyi.finance.service.impl.TFeeServiceImpl;
  22. import com.ruoyi.reportManagement.domain.TWhgenleg;
  23. import com.ruoyi.reportManagement.mapper.TWhgenlegMapper;
  24. import com.ruoyi.warehouseBusiness.component.CalculationWarehouseService;
  25. import com.ruoyi.warehouseBusiness.domain.TWarehouseAgreement;
  26. import com.ruoyi.warehouseBusiness.domain.TWarehouseBills;
  27. import com.ruoyi.warehouseBusiness.domain.TWarehousebillsfees;
  28. import com.ruoyi.warehouseBusiness.domain.TWarehousebillsitems;
  29. import com.ruoyi.warehouseBusiness.domain.enums.WarehouseActIdEnum;
  30. import com.ruoyi.warehouseBusiness.domain.enums.WarehouseTypeEnum;
  31. import com.ruoyi.warehouseBusiness.mapper.TWarehouseAgreementMapper;
  32. import com.ruoyi.warehouseBusiness.mapper.TWarehouseBillsMapper;
  33. import com.ruoyi.warehouseBusiness.mapper.TWarehousebillsfeesMapper;
  34. import com.ruoyi.warehouseBusiness.mapper.TWarehousebillsitemsMapper;
  35. import com.ruoyi.warehouseBusiness.service.impl.TWarehouseAgreementServiceImpl;
  36. import com.ruoyi.warehouseBusiness.service.impl.TWarehouseBillsServiceImpl;
  37. import com.ruoyi.warehouseBusiness.service.impl.TWarehousebillsModifyServiceImpl;
  38. import com.sun.scenario.effect.impl.sw.java.JSWEffectPeer;
  39. import org.apache.commons.compress.utils.Lists;
  40. import org.springframework.beans.factory.annotation.Autowired;
  41. import org.springframework.stereotype.Service;
  42. import org.springframework.transaction.annotation.Transactional;
  43. import org.springframework.transaction.interceptor.TransactionAspectSupport;
  44. import java.util.*;
  45. import static java.util.stream.Collectors.toList;
  46. /**
  47. * 审批流配置主Service业务层处理
  48. *
  49. * @author ruoyi
  50. * @date 2021-01-21
  51. */
  52. @Service
  53. public class AuditPathsServiceImpl implements IAuditPathsService {
  54. @Autowired
  55. private AuditPathsMapper auditPathsMapper;
  56. @Autowired
  57. private AuditItemsMapper auditItemsMapper;
  58. @Autowired
  59. private TWhgenlegMapper tWhgenlegMapper;
  60. @Autowired
  61. private AuditItemsUsersMapper auditItemsUsersMapper;
  62. @Autowired
  63. private AuditPathsActsMapper auditPathsActsMapper;
  64. @Autowired
  65. private AuditPathsLevelsMapper auditPathsLevelsMapper;
  66. @Autowired
  67. private TWarehouseBillsMapper tWarehouseBillsMapper;
  68. @Autowired
  69. private TWarehouseBillsServiceImpl tWarehouseBillsService;
  70. @Autowired
  71. private TWarehousebillsfeesMapper tWarehousebillsfeesMapper;
  72. @Autowired
  73. private TWarehousebillsitemsMapper tWarehousebillsitemsMapper;
  74. @Autowired
  75. private TFeeServiceImpl tFeeServiceImpl;
  76. @Autowired
  77. private TWarehouseAgreementServiceImpl tWarehouseAgreementService;
  78. @Autowired
  79. private TWarehousebillsModifyServiceImpl warehousebillsModifyService;
  80. @Autowired
  81. private TFeeMapper tFeeMapper;
  82. @Autowired
  83. private TFeesMapper feesMapper;
  84. @Autowired
  85. private TWarehouseAgreementMapper tWarehouseAgreementMapper;
  86. @Autowired
  87. private AuditItemsDoMapper auditItemsDoMapper;
  88. @Autowired
  89. private CalculationWarehouseService calculationWarehouseService;
  90. /**
  91. * 查询审批流配置主
  92. *
  93. * @param id 审批流配置主ID
  94. * @return 审批流配置主
  95. */
  96. @Override
  97. public AjaxResult selectAuditPathsById(Long id) {
  98. Map<String, Object> map = new HashMap<>();
  99. AuditPaths auditPaths = auditPathsMapper.selectAuditPathsById(id);
  100. if (StringUtils.isNull(auditPaths)) {
  101. return AjaxResult.error("该审批流不存在,请确认");
  102. }
  103. map.put("auditPaths", auditPaths);
  104. AuditPathsLevels auditPathsLevels = new AuditPathsLevels();
  105. auditPathsLevels.setPathId(id);
  106. List<AuditPathsLevels> pathsLevelsList = auditPathsLevelsMapper.selectAuditPathsLevelsList(auditPathsLevels);
  107. if (StringUtils.isNotNull(pathsLevelsList)) {
  108. List<List<Long>> longs = new ArrayList<>();
  109. for (AuditPathsLevels ap : pathsLevelsList) {
  110. List<Long> longList = new ArrayList<>();
  111. if (ap.getAuditUserId() != null) {
  112. JSONArray jsonArray = JSONArray.parseArray(ap.getAuditUserId());
  113. longList = JSONObject.parseArray(jsonArray.toJSONString(), Long.class);
  114. }
  115. longs.add(longList);
  116. }
  117. map.put("auditUserIds", longs);
  118. map.put("auditPathsLevels", pathsLevelsList);
  119. }
  120. return AjaxResult.success(map);
  121. }
  122. /**
  123. * 查询审批流配置主列表
  124. *
  125. * @param auditPaths 审批流配置主
  126. * @return 审批流配置主
  127. */
  128. @Override
  129. public List<AuditPaths> selectAuditPathsList(AuditPaths auditPaths) {
  130. return auditPathsMapper.selectAuditPathsList(auditPaths);
  131. }
  132. /**
  133. * 新增审批流配置主
  134. *
  135. * @param auditPaths 审批流配置主
  136. * @return 结果
  137. */
  138. @Override
  139. @Transactional
  140. public AjaxResult insertAuditPaths(String auditPaths, String auditPathsLevels, LoginUser loginUser) {
  141. AuditPaths apath = JSONArray.parseObject(auditPaths, AuditPaths.class);
  142. if ("A".equals(apath.getStatus()) && (StringUtils.isNull(auditPathsLevels) || "[]".equals(auditPathsLevels))) {
  143. return AjaxResult.error("未找到级次信息无法提交,请确认");
  144. }
  145. long fPid = 0L;
  146. if (StringUtils.isNotNull(apath.getId())) {
  147. if ("S".equals(apath.getStatus())) {
  148. AuditPathsActs auditPathsActs = new AuditPathsActs();
  149. auditPathsActs.setPathId(apath.getId());
  150. int sum = auditPathsActsMapper.selectCountAuditPathsActs(auditPathsActs);
  151. if (sum > 0) {
  152. return AjaxResult.error("该审批配置已被使用,请取消使用后提交");
  153. }
  154. }
  155. auditPathsLevelsMapper.deleteAuditPathsLevelsBypathId(apath.getId());
  156. auditPathsMapper.updateAuditPaths(apath);
  157. fPid = apath.getId();
  158. } else {
  159. AuditPaths paths = new AuditPaths();
  160. paths.setPathName(apath.getPathName());
  161. List<AuditPaths> audiList = auditPathsMapper.selectAuditPathsList(paths);
  162. if (audiList.size() > 0) {
  163. return AjaxResult.error("审核路径名已存在,请确认");
  164. }
  165. apath.setOpUserId(loginUser.getUser().getUserId());
  166. apath.setOpDate(new Date());
  167. apath.setOpUserName(loginUser.getUsername());
  168. auditPathsMapper.insertAuditPaths(apath);
  169. fPid = apath.getId();
  170. }
  171. if (StringUtils.isNotNull(auditPathsLevels) && !"[]".equals(auditPathsLevels)) {
  172. JSONArray warehouseJSON = JSONArray.parseArray(auditPathsLevels);
  173. List<AuditPathsLevels> auditPathsLevelsList = JSONObject.parseArray(warehouseJSON.toJSONString(), AuditPathsLevels.class);
  174. if ("F".equals(auditPathsLevelsList.get(auditPathsLevelsList.size() - 1).getIffinalItem())) {
  175. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  176. return AjaxResult.error("操作失败:最后一级状态有误,请确认");
  177. }
  178. Long level = 0L;
  179. boolean last = false;
  180. for (AuditPathsLevels lev : auditPathsLevelsList) {
  181. if (StringUtils.isNull(lev.getAuditUserId())) {
  182. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  183. return AjaxResult.error("操作失败:请维护审核人");
  184. }
  185. if ("T".equals(lev.getIffinalItem()) && !last) {
  186. last = true;
  187. } else if ("T".equals(lev.getIffinalItem()) && last) {
  188. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  189. return AjaxResult.error("操作失败:最后一级只能存在一个");
  190. }
  191. level++;
  192. lev.setPathId(fPid);
  193. lev.setLevelId(level);
  194. auditPathsLevelsMapper.insertAuditPathsLevels(lev);
  195. }
  196. }
  197. return AjaxResult.success();
  198. }
  199. /**
  200. * 修改审批流配置主
  201. *
  202. * @param auditPaths 审批流配置主
  203. * @return 结果
  204. */
  205. @Override
  206. public int updateAuditPaths(AuditPaths auditPaths) {
  207. return auditPathsMapper.updateAuditPaths(auditPaths);
  208. }
  209. /**
  210. * 批量删除审批流配置主
  211. *
  212. * @param ids 需要删除的审批流配置主ID
  213. * @return 结果
  214. */
  215. @Override
  216. @Transactional
  217. public AjaxResult deleteAuditPathsByIds(Long[] ids) {
  218. int line = 0;
  219. for (Long lo : ids) {
  220. line++;
  221. AuditPathsActs auditPathsActs = new AuditPathsActs();
  222. auditPathsActs.setPathId(lo);
  223. int sum = auditPathsActsMapper.selectCountAuditPathsActs(auditPathsActs);
  224. if (sum > 0) {
  225. return AjaxResult.error("第" + line + "行,审批已被使用无法删除");
  226. }
  227. }
  228. auditPathsMapper.deleteAuditPathsByIds(ids);
  229. return AjaxResult.success();
  230. }
  231. /**
  232. * 删除审批流配置主信息
  233. *
  234. * @param id 审批流配置主ID
  235. * @return 结果
  236. */
  237. @Override
  238. public int deleteAuditPathsById(Long id) {
  239. return auditPathsMapper.deleteAuditPathsById(id);
  240. }
  241. /**
  242. * 单据点击查看审批流
  243. *
  244. * @param auditItems 条件
  245. * @return 结果
  246. */
  247. @Override
  248. public AjaxResult projectEndQueryPendingVal(AuditItems auditItems) {
  249. List<Map<String, Object>> mapList = auditItemsMapper.selectWarehouseApprover(auditItems);
  250. return AjaxResult.success(mapList);
  251. }
  252. /**
  253. * 首页点击查看审批流 获取对应数据
  254. *
  255. * @param auditItems 查询条件
  256. * @return 结果
  257. */
  258. @Override
  259. public List<Map<String, Object>> selectAllAuditItems(AuditItems auditItems) {
  260. List<Map<String,Object>> list = new ArrayList<>();
  261. for (Map<String,Object> map : auditItemsMapper.selectAuditItems(auditItems)) {
  262. // 根据审批明细详情主表 id 获取审批明细从表数据
  263. List<Map<String,Object>> auditItemsDoList = auditItemsDoMapper.selectByFPid(Long.valueOf(map.get("id").toString()));
  264. StringBuilder stringBuilder = new StringBuilder();
  265. for (Map<String,Object> auditItemsDo : auditItemsDoList) {
  266. if (StringUtils.isNotNull(auditItemsDo)) { // 有数据
  267. stringBuilder.append(auditItemsDo.get("fBsno")).append(",");
  268. }
  269. }
  270. map.put("fBsno",StringUtils.removeTheLastComma(stringBuilder));
  271. // 将 map 数据重新放入 list 中
  272. list.add(map);
  273. }
  274. return list;
  275. }
  276. /**
  277. * 查询审批流配置主信息条数
  278. *
  279. * @return 结果
  280. */
  281. @Override
  282. public int selectCountAuditItems() {
  283. return auditItemsMapper.selectCountAuditItems();
  284. }
  285. /**
  286. * 审批通过
  287. *
  288. * @param auditItems 审核人、单据信息
  289. * @return 结果
  290. */
  291. @Override
  292. @Transactional
  293. public AjaxResult approved(AuditItems auditItems) {
  294. // 审核通过时间
  295. Date auditItemtem = auditItems.getAuditItem();
  296. long fettle = 0L;
  297. int number = 0;
  298. AuditItems item = new AuditItems();
  299. item.setBillId(auditItems.getId());
  300. item.setActId(auditItems.getActId());
  301. item.setFidStatus(auditItems.getFidStatus());
  302. List<AuditItems> auditItemsList = auditItemsMapper.selectAuditItemsList(item);
  303. if (CollectionUtils.isEmpty(auditItemsList)) {
  304. return AjaxResult.error("未找到审批信息,请确认");
  305. }
  306. for (AuditItems at : auditItemsList) {
  307. if (!"S".equals(at.getAuditStatus())) {
  308. continue;
  309. }
  310. AuditItemsUsers itemsUsers = new AuditItemsUsers();
  311. itemsUsers.setPid(at.getId());
  312. List<AuditItemsUsers> auditItemsUsers = auditItemsUsersMapper.selectAuditItemsUsersList(itemsUsers);
  313. for (AuditItemsUsers au : auditItemsUsers) {
  314. if (au.getUserId().equals(auditItems.getSendUserId()) && "S".equals(au.getAuditStatus())) {
  315. number++;
  316. if (StringUtils.isEmpty(auditItems.getAuditMsg())) {
  317. at.setAuditMsg("同意");
  318. } else {
  319. at.setAuditMsg(auditItems.getAuditMsg());
  320. }
  321. at.setAuditStatus("A");
  322. //at.setAuditItem(new Date());
  323. at.setAuditOpTime(new Date());
  324. at.setAuditUserId(au.getUserId());
  325. at.setAuditItem(auditItemtem);
  326. int updateAuditItems = auditItemsMapper.updateAuditItems(at);
  327. if (updateAuditItems <= 0) {
  328. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  329. return AjaxResult.error("审批通过失败: 更新审批状态失败");
  330. }
  331. au.setAuditStatus("A");
  332. int updateAuditItemsUsers = auditItemsUsersMapper.updateAuditItemsUsers(au);
  333. if (updateAuditItemsUsers <= 0) {
  334. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  335. return AjaxResult.error("审批通过失败: 更新审批状态失败");
  336. }
  337. if (auditItems.getActId() >= 110 && auditItems.getActId() <= 160) {
  338. if ("T".equals(at.getIffinalItem())) {
  339. fettle = 6L;
  340. } else if ("F".equals(at.getIffinalItem())) {
  341. fettle = 5L;
  342. }
  343. // 仓库模块
  344. if ("warehouse_status".equals(auditItems.getFidStatus())) {
  345. tWarehouseBillsMapper.warehouseApprovalUpdate(auditItems, fettle);
  346. } else {
  347. tWarehouseBillsMapper.warehouseFollowUpdate(auditItems.getBillId(), fettle, at.getAuditItem());
  348. }
  349. getfBillStatus(auditItems,at);
  350. if (Objects.equals(fettle, 6L)) {
  351. if (Objects.equals(auditItems.getActId(), 120L)) {
  352. List<TWarehousebillsfees> feesList = tWarehousebillsfeesMapper.selectWarehousebillsfeesByPId(auditItems.getBillId());
  353. // 过滤出明细信息查询是否存在已计算仓储费
  354. List<Long> ids = feesList.stream().filter(li -> !li.getfBilltype().equals(WarehouseTypeEnum.KCZZ.getType()))
  355. .map(TWarehousebillsfees::getSrcId).distinct().collect(toList());
  356. if (CollectionUtils.isNotEmpty(ids) && tWarehousebillsitemsMapper.selectIsCalculateStorageFeesByIds(ids) > 0) {
  357. throw new WarehouseException("计算费用中存在已计算仓储费信息");
  358. }
  359. // 获取仓储费,并判断费用中是否存在仓储费
  360. TFees ccf = feesMapper.seletFeesByCCF();
  361. if (Objects.isNull(ccf)) {
  362. throw new WarehouseException("未找到仓储费费用信息");
  363. }
  364. // 过滤出费用类型等于仓储费并且有商机id,并取出来进行更新仓储费计费日期
  365. long count = feesList.stream().filter(li -> Objects.equals(li.getfFeeid(), ccf.getfId()) && Objects.nonNull(li.getSrcId()))
  366. .count();
  367. if (count > 0) {
  368. TWarehousebillsfees warehousebillsfees = feesList.stream().findFirst().orElseThrow(() -> new WarehouseException("未找到费用明细"));
  369. // 更新子表仓储费截止日期
  370. tWarehousebillsitemsMapper.updateItemStorageFeeDeadlineByPId(warehousebillsfees.getfPid(), warehousebillsfees.getfBillingDeadline());
  371. }
  372. } else if (Objects.equals(auditItems.getActId(), 150L)) {
  373. tWarehouseBillsService.approvedStorageFee(auditItems.getBillId(), fettle, at.getAuditItem());
  374. }
  375. }
  376. } else if (auditItems.getActId() >= 210 && auditItems.getActId() <= 230) {
  377. // 财务模块
  378. if ("T".equals(at.getIffinalItem())) {
  379. fettle = 6L;
  380. // 更新费用明细
  381. /*AjaxResult ajaxResult = tFeeServiceImpl.billsfeesFollow(auditItems.getBillId());
  382. String code = ajaxResult.get("code").toString();
  383. if ("500".equals(code)) {
  384. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  385. return ajaxResult;
  386. }*/
  387. } else if ("F".equals(at.getIffinalItem())) {
  388. fettle = 5L;
  389. }
  390. // 变更财务状态
  391. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  392. String code = ajaxResult.get("code").toString();
  393. if ("500".equals(code)) {
  394. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  395. return ajaxResult;
  396. }
  397. } else if (auditItems.getActId() >= 310 && auditItems.getActId() <= 320) {
  398. // 协议模块
  399. if ("T".equals(at.getIffinalItem())) {
  400. fettle = 6L;
  401. } else if ("F".equals(at.getIffinalItem())) {
  402. fettle = 5L;
  403. }
  404. // 变更财务状态
  405. AjaxResult ajaxResult = tWarehouseAgreementService.agreementFollow(auditItems.getBillId(), fettle);
  406. String code = ajaxResult.get("code").toString();
  407. if ("500".equals(code)) {
  408. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  409. return ajaxResult;
  410. }
  411. } else if (auditItems.getActId() == 410) {
  412. if (StringUtils.isEmpty(auditItems.getRefno3())) {
  413. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  414. return AjaxResult.error("提单号不能为空");
  415. }
  416. if ("T".equals(at.getIffinalItem())) {
  417. fettle = 6L;
  418. } else if ("F".equals(at.getIffinalItem())) {
  419. fettle = 5L;
  420. }
  421. //变更凯和订单状态
  422. AjaxResult ajaxResult = tWarehouseBillsService.updateKaHeOrder(auditItems.getBillId(), fettle, at.getAuditItem());
  423. String code = ajaxResult.get("code").toString();
  424. if ("500".equals(code)) {
  425. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  426. return ajaxResult;
  427. }
  428. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  429. tWarehouseBills.setfId(auditItems.getBillId());
  430. tWarehouseBills.setfMblno(auditItems.getRefno3());
  431. AjaxResult orderMessage = tWarehouseBillsService.updateOrderMessage(tWarehouseBills);
  432. String orderMessageCode = orderMessage.get("code").toString();
  433. if ("500".equals(orderMessageCode)) {
  434. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  435. return orderMessage;
  436. }
  437. } else if (auditItems.getActId() == 420) {
  438. if ("T".equals(at.getIffinalItem())) {
  439. fettle = 11L;
  440. } else if ("F".equals(at.getIffinalItem())) {
  441. fettle = 10L;
  442. }
  443. //变更凯和订单状态
  444. AjaxResult ajaxResult = tWarehouseBillsService.updateKaHeOrder(auditItems.getBillId(), fettle, at.getAuditItem());
  445. String code = ajaxResult.get("code").toString();
  446. if ("500".equals(code)) {
  447. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  448. return ajaxResult;
  449. }
  450. } else if (auditItems.getActId() >= 430 && auditItems.getActId() <= 450) {
  451. // 财务模块
  452. if ("T".equals(at.getIffinalItem())) {
  453. fettle = 6L;
  454. // 更新费用明细
  455. /*AjaxResult ajaxResult = tFeeServiceImpl.billsfeesFollow(auditItems.getBillId());
  456. String code = ajaxResult.get("code").toString();
  457. if ("500".equals(code)) {
  458. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  459. return ajaxResult;
  460. }*/
  461. } else if ("F".equals(at.getIffinalItem())) {
  462. fettle = 5L;
  463. }
  464. //修改主订单费用信息
  465. if (auditItems.getActId() >= 440 && auditItems.getActId() <= 450) {
  466. tWarehouseBillsService.updateMessage(auditItems.getBillId());
  467. }
  468. // 变更财务状态
  469. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  470. String code = ajaxResult.get("code").toString();
  471. if ("500".equals(code)) {
  472. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  473. return ajaxResult;
  474. }
  475. } else if (auditItems.getActId() == 470) {
  476. // 财务模块
  477. if ("T".equals(at.getIffinalItem())) {
  478. fettle = 6L;
  479. // 更新费用明细
  480. AjaxResult ajaxResult = tFeeServiceImpl.billsfeesFollow(auditItems.getBillId());
  481. String code = ajaxResult.get("code").toString();
  482. if ("500".equals(code)) {
  483. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  484. return ajaxResult;
  485. }
  486. } else if ("F".equals(at.getIffinalItem())) {
  487. fettle = 5L;
  488. }
  489. // 变更财务状态
  490. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  491. String code = ajaxResult.get("code").toString();
  492. if ("500".equals(code)) {
  493. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  494. return ajaxResult;
  495. }
  496. //生成销项发票
  497. AjaxResult invoiceFp = tFeeServiceImpl.copyInvoiceFp(auditItems.getBillId(), "INV");
  498. String string = invoiceFp.get("code").toString();
  499. if ("500".equals(string)) {
  500. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  501. return invoiceFp;
  502. }
  503. } else if (auditItems.getActId() == 460) {
  504. if ("T".equals(at.getIffinalItem())) {
  505. fettle = 6L;
  506. } else if ("F".equals(at.getIffinalItem())) {
  507. fettle = 5L;
  508. }
  509. //变更凯和订单状态
  510. Integer i = tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(auditItems.getBillId(), fettle, at.getAuditItem());
  511. if (i != null && i > 0) {
  512. } else {
  513. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  514. return AjaxResult.error("审核失败,更新费用状态失败");
  515. }
  516. } else if (auditItems.getActId() == 170) {
  517. //入库明细审核
  518. if ("T".equals(at.getIffinalItem())) {
  519. fettle = 6L;
  520. } else if ("F".equals(at.getIffinalItem())) {
  521. fettle = 5L;
  522. }
  523. //变更仓库入库明细审核状态
  524. Integer i = null;
  525. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  526. tWarehouseBills.setfId(auditItems.getBillId());
  527. tWarehouseBills.setfItemstatus(fettle);
  528. i = tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  529. i = tWarehousebillsitemsMapper.warehouseItemfItemstatus(auditItems.getBillId(), fettle);
  530. if (i != null && i > 0) {
  531. } else {
  532. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  533. return AjaxResult.error("审核失败,更新费用状态失败");
  534. }
  535. } else if (auditItems.getActId() == 180) {
  536. //入库明细审核
  537. if ("T".equals(at.getIffinalItem())) {
  538. fettle = 6L;
  539. } else if ("F".equals(at.getIffinalItem())) {
  540. fettle = 5L;
  541. }
  542. //变更仓库入库明细审核状态
  543. Integer i = null;
  544. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  545. tWarehouseBills.setfId(auditItems.getBillId());
  546. tWarehouseBills.setfItemstatus(fettle);
  547. i = tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  548. i = tWarehousebillsitemsMapper.warehouseItemfItemstatus(auditItems.getBillId(), fettle);
  549. if (i != null && i > 0) {
  550. } else {
  551. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  552. return AjaxResult.error("审核失败,更新费用状态失败");
  553. }
  554. } else if (auditItems.getActId() == 471) {
  555. if ("T".equals(at.getIffinalItem())) {
  556. fettle = 6L;
  557. AjaxResult orderMessage = tWarehouseBillsService.copyKhOrderMessage(auditItems.getBillId());
  558. String string = orderMessage.get("code").toString();
  559. if ("500".equals(string)) {
  560. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  561. return orderMessage;
  562. }
  563. } else if ("F".equals(at.getIffinalItem())) {
  564. fettle = 5L;
  565. }
  566. // 变更凯和申请修改订单状态
  567. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  568. tWarehouseBills.setfId(auditItems.getBillId());
  569. tWarehouseBills.setfUpdeteStatus(fettle);
  570. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  571. } else if (auditItems.getActId() == 472) {
  572. if ("T".equals(at.getIffinalItem())) {
  573. fettle = 6L;
  574. } else if ("F".equals(at.getIffinalItem())) {
  575. fettle = 5L;
  576. }
  577. // 变更凯和申请修改订单状态
  578. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  579. tWarehouseBills.setfId(auditItems.getBillId());
  580. tWarehouseBills.setfSubmitUpdate(fettle);
  581. if (fettle == 6L) {
  582. tWarehouseBills.setfUpdeteStatus(2L);
  583. tWarehouseBills.setfSubmitUpdate(2L);
  584. }
  585. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  586. } else if (auditItems.getActId() == 473) {
  587. if ("T".equals(at.getIffinalItem())) {
  588. fettle = 6L;
  589. // 删除申请审核通过修改订单的状态
  590. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  591. tWarehouseBills.setfId(auditItems.getBillId());
  592. tWarehouseBills.setDelFlag("1");
  593. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  594. } else if ("F".equals(at.getIffinalItem())) {
  595. fettle = 5L;
  596. }
  597. // 变更凯和申请修改订单状态
  598. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  599. tWarehouseBills.setfId(auditItems.getBillId());
  600. tWarehouseBills.setfDeleteStatus(fettle);
  601. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  602. } else if (auditItems.getActId() == 474) {
  603. if ("F".equals(at.getIffinalItem())) {
  604. fettle = 5L;
  605. } else if ("T".equals(at.getIffinalItem())) {
  606. fettle = 6L;
  607. //修改原订单信息
  608. AjaxResult ajaxResult = tWarehouseBillsService.approveDismount(auditItems.getBillId());
  609. String string = ajaxResult.get("code").toString();
  610. if ("500".equals(string)) {
  611. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  612. return ajaxResult;
  613. }
  614. }
  615. //变更凯和订单状态
  616. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  617. tWarehouseBills.setfId(auditItems.getBillId());
  618. tWarehouseBills.setfDismountStatus(fettle);
  619. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  620. } else if (auditItems.getActId() == 181) {
  621. if ("T".equals(at.getIffinalItem())) {
  622. fettle = 6L;
  623. } else if ("F".equals(at.getIffinalItem())) {
  624. fettle = 5L;
  625. }
  626. //业务处理
  627. } else if (auditItems.getActId() == 190) {
  628. if ("T".equals(at.getIffinalItem())) {
  629. fettle = 6L;
  630. } else if ("F".equals(at.getIffinalItem())) {
  631. fettle = 5L;
  632. }
  633. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  634. tWarehouseBills.setfId(auditItems.getBillId());
  635. tWarehouseBills.setfBillstatus(fettle);
  636. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  637. getfBillStatus(auditItems,at);
  638. } else if (Objects.equals(auditItems.getActId(), WarehouseActIdEnum.FEE_CHANGES.getActId().longValue())) {
  639. // 费用变更审核通过处理
  640. if ("T".equals(at.getIffinalItem())) {
  641. fettle = 6L;
  642. warehousebillsModifyService.additionalFeeInformation(auditItems.getBillId(), WarehouseTypeEnum.APPROVE);
  643. } else if ("F".equals(at.getIffinalItem())) {
  644. fettle = 5L;
  645. warehousebillsModifyService.additionalFeeInformation(auditItems.getBillId(), WarehouseTypeEnum.UNDER_REVIEW);
  646. }
  647. }
  648. if ("F".equals(at.getIffinalItem())) {
  649. at.setLevelId(at.getLevelId() + 1);
  650. int updateNum = auditItemsMapper.updateAuditStatus(at);
  651. if (updateNum <= 0) {
  652. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  653. return AjaxResult.error("审批通过失败: 更新审批状态失败");
  654. }
  655. }
  656. break;
  657. }
  658. }
  659. }
  660. TWarehouseBills warehouseBills = new TWarehouseBills();
  661. warehouseBills.setfId(auditItems.getBillId());
  662. calculationWarehouseService.calculationFeeStatus(warehouseBills);
  663. tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
  664. if (number <= 0) {
  665. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  666. return AjaxResult.error("该审批已被操作");
  667. }
  668. return AjaxResult.success();
  669. }
  670. /**
  671. * 获取费用明细数据,并保持费用明细请核状态不改动
  672. * @param auditItems 审批流
  673. * @param at 审批流
  674. */
  675. public void getfBillStatus(AuditItems auditItems,AuditItems at) {
  676. List<TWarehousebillsfees> tWarehousebillsfees = tWarehousebillsfeesMapper.selectWarehousebillsfeesByPId(auditItems.getBillId());
  677. for (TWarehousebillsfees result : tWarehousebillsfees) {
  678. if (StringUtils.isNotNull(at.getAuditItem())) {
  679. result.setfReviewDate(at.getAuditItem());
  680. }
  681. if (result.getfBillstatus() != 6) { // 判断状态
  682. tWarehousebillsfeesMapper.updateTWarehousebillsfees(result);
  683. }
  684. }
  685. }
  686. /**
  687. * 审批驳回
  688. *
  689. * @param auditItems 审核人、单据信息
  690. * @return 结果
  691. */
  692. @Override
  693. @Transactional
  694. public AjaxResult approvalRejected(AuditItems auditItems) {
  695. long fettle = 0L;
  696. if (auditItems.getActId() >= 110 && auditItems.getActId() <= 160) {
  697. fettle = 3L;
  698. if ("f_billstatus".equals(auditItems.getFidStatus())) {
  699. tWarehouseBillsMapper.warehouseFollowUpdate(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  700. } else {
  701. tWarehouseBillsMapper.warehouseApprovalUpdate(auditItems, fettle);
  702. }
  703. getfBillStatus(auditItems,auditItems);
  704. if (Objects.equals(auditItems.getActId(), 150L)) {
  705. List<TWarehousebillsfees> feesList = tWarehousebillsfeesMapper.selectWarehousebillsfeesByPId(auditItems.getBillId());
  706. for (TWarehousebillsfees wareItem : feesList) {
  707. if (StringUtils.isNull(wareItem.getSrcId())) {
  708. continue;
  709. }
  710. if ("KCZZ".equals(wareItem.getfBilltype())) {
  711. TWhgenleg whgenleg = new TWhgenleg();
  712. whgenleg.setfId(wareItem.getSrcId());
  713. whgenleg.setfChargedate(wareItem.getfChargedate());
  714. tWhgenlegMapper.updateTWhgenleg(whgenleg);
  715. } else {
  716. TWarehousebillsitems billsItem = new TWarehousebillsitems();
  717. billsItem.setfId(wareItem.getSrcId());
  718. billsItem.setfBilltype(wareItem.getfBilltype());
  719. if (!"SJCK".equals(wareItem.getfBilltype())) {
  720. billsItem.setfChargedate(wareItem.getfBillingDeadline());
  721. tWarehousebillsitemsMapper.updateTWarehousebillsitems(billsItem);
  722. } else {
  723. billsItem.setIsCalculateStorageFees(WarehouseTypeEnum.NOT_CALCULATE.getType());
  724. billsItem.setfChargedate(wareItem.getfChargedate());
  725. }
  726. tWarehousebillsitemsMapper.agreementApprovalRejected(billsItem);
  727. }
  728. }
  729. }
  730. } else if (auditItems.getActId() >= 210 && auditItems.getActId() <= 230) {
  731. fettle = 3L;
  732. String fBillType = null;
  733. if (auditItems.getActId() == 210) { // 对账
  734. fBillType = "DZRevoke";
  735. } else if (auditItems.getActId() == 220 || auditItems.getActId() == 230) {
  736. fBillType = "DCRevoke";
  737. }
  738. // 财务模块
  739. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  740. String code = ajaxResult.get("code").toString();
  741. if ("500".equals(code)) {
  742. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  743. return ajaxResult;
  744. }
  745. // 更新费用明细
  746. AjaxResult result = tFeeServiceImpl.updateDSFMoney(auditItems.getBillId(),fBillType);
  747. String message = result.get("code").toString();
  748. if ("500".equals(message)) {
  749. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  750. return result;
  751. }
  752. } else if (auditItems.getActId() >= 310 && auditItems.getActId() <= 320) {
  753. fettle = 3L;
  754. // 协议模块
  755. AjaxResult ajaxResult = tWarehouseAgreementService.agreementFollow(auditItems.getBillId(), fettle);
  756. String code = ajaxResult.get("code").toString();
  757. if ("500".equals(code)) {
  758. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  759. return ajaxResult;
  760. }
  761. } else if (auditItems.getActId() == 410) {
  762. fettle = 3L;
  763. AjaxResult ajaxResult = tWarehouseBillsService.updateKaHeOrder(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  764. String code = ajaxResult.get("code").toString();
  765. if ("500".equals(code)) {
  766. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  767. return ajaxResult;
  768. }
  769. } else if (auditItems.getActId() == 420) {
  770. fettle = 8L;
  771. AjaxResult ajaxResult = tWarehouseBillsService.updateKaHeOrder(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  772. String code = ajaxResult.get("code").toString();
  773. if ("500".equals(code)) {
  774. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  775. return ajaxResult;
  776. }
  777. } else if (auditItems.getActId() >= 430 && auditItems.getActId() <= 450) {
  778. fettle = 3L;
  779. String fBillType = null;
  780. if (auditItems.getActId() == 450 || auditItems.getActId() == 440){
  781. fBillType = "DCRevoke";
  782. }else if (auditItems.getActId() == 430){
  783. fBillType = "KHDZRevoke";
  784. }
  785. // 财务模块
  786. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  787. String code = ajaxResult.get("code").toString();
  788. if ("500".equals(code)) {
  789. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  790. return ajaxResult;
  791. }
  792. // 更新费用明细
  793. AjaxResult result = tFeeServiceImpl.updateMoney(auditItems.getBillId(),fBillType);
  794. String message = result.get("code").toString();
  795. if ("500".equals(message)) {
  796. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  797. return result;
  798. }
  799. } else if (auditItems.getActId() == 460) {
  800. fettle = 3L;
  801. Integer i = tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  802. if (i != null && i > 0) {
  803. } else {
  804. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  805. return AjaxResult.error("审批驳回失败,更新费用状态失败");
  806. }
  807. } else if (auditItems.getActId() == 470) {
  808. fettle = 3L;
  809. // 财务模块
  810. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  811. String code = ajaxResult.get("code").toString();
  812. if ("500".equals(code)) {
  813. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  814. return ajaxResult;
  815. }
  816. } else if (auditItems.getActId() == 170) {
  817. //入库明细审核
  818. fettle = 3L;
  819. //变更仓库入库明细审核状态
  820. Integer i = null;
  821. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  822. tWarehouseBills.setfId(auditItems.getBillId());
  823. tWarehouseBills.setfItemstatus(fettle);
  824. i = tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  825. i = tWarehousebillsitemsMapper.warehouseItemfItemstatus(auditItems.getBillId(), fettle);
  826. if (i != null && i > 0) {
  827. } else {
  828. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  829. return AjaxResult.error("审核失败,更新费用状态失败");
  830. }
  831. } else if (auditItems.getActId() == 180) {
  832. //入库明细审核
  833. fettle = 3L;
  834. //变更仓库入库明细审核状态
  835. Integer i = null;
  836. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  837. tWarehouseBills.setfId(auditItems.getBillId());
  838. tWarehouseBills.setfItemstatus(fettle);
  839. i = tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  840. i = tWarehousebillsitemsMapper.warehouseItemfItemstatus(auditItems.getBillId(), fettle);
  841. if (i != null && i > 0) {
  842. } else {
  843. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  844. return AjaxResult.error("审核失败,更新费用状态失败");
  845. }
  846. } else if (auditItems.getActId() == 471) {
  847. fettle = 3L;
  848. // 变更凯和申请修改订单状态
  849. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  850. tWarehouseBills.setfId(auditItems.getBillId());
  851. tWarehouseBills.setfUpdeteStatus(fettle);
  852. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  853. } else if (auditItems.getActId() == 472) {
  854. fettle = 3L;
  855. // 变更凯和申请修改订单状态
  856. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  857. tWarehouseBills.setfId(auditItems.getBillId());
  858. tWarehouseBills.setfSubmitUpdate(fettle);
  859. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  860. } else if (auditItems.getActId() == 473) {
  861. fettle = 3L;
  862. // 变更凯和申请修改订单状态
  863. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  864. tWarehouseBills.setfId(auditItems.getBillId());
  865. tWarehouseBills.setfDeleteStatus(fettle);
  866. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  867. } else if (auditItems.getActId() == 474) {
  868. fettle = 3L;
  869. //变更凯和拆单单状态
  870. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  871. tWarehouseBills.setfId(auditItems.getBillId());
  872. tWarehouseBills.setfDismountStatus(fettle);
  873. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  874. } else if (auditItems.getActId() == 181) {
  875. fettle = 3L;
  876. //业务处理
  877. } else if (auditItems.getActId() == 190) {
  878. fettle = 3L;
  879. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  880. tWarehouseBills.setfId(auditItems.getBillId());
  881. tWarehouseBills.setfBillstatus(fettle);
  882. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  883. getfBillStatus(auditItems,auditItems);
  884. } else if (Objects.equals(auditItems.getActId(), WarehouseActIdEnum.FEE_CHANGES.getActId().longValue())) {
  885. warehousebillsModifyService.additionalFeeInformation(auditItems.getBillId(), WarehouseTypeEnum.DISMISS);
  886. }
  887. AuditItems item = new AuditItems();
  888. item.setBillId(auditItems.getId());
  889. item.setActId(auditItems.getActId());
  890. item.setFidStatus(auditItems.getFidStatus());
  891. List<AuditItems> auditItem = auditItemsMapper.selectAuditItemsList(item);
  892. int number = 0;
  893. for (AuditItems at : auditItem) {
  894. if (!"S".equals(at.getAuditStatus())) {
  895. continue;
  896. }
  897. AuditItemsUsers itemsUsers = new AuditItemsUsers();
  898. itemsUsers.setPid(at.getId());
  899. List<AuditItemsUsers> auditItemsUsersList = auditItemsUsersMapper.selectAuditItemsUsersList(itemsUsers);
  900. for (AuditItemsUsers au : auditItemsUsersList) {
  901. if (Objects.equals(au.getUserId(), auditItems.getSendUserId())) {
  902. number++;
  903. at.setAuditStatus("B");
  904. if (auditItems.getAuditMsg() == null || "".equals(auditItems.getAuditMsg())) {
  905. at.setAuditMsg("不同意");
  906. } else {
  907. at.setAuditMsg(auditItems.getAuditMsg());
  908. }
  909. //at.setAuditItem(new Date());
  910. at.setAuditOpTime(new Date());
  911. at.setAuditUserId(au.getUserId());
  912. int updateAuditItems = auditItemsMapper.updateAuditItems(at);
  913. if (updateAuditItems <= 0) {
  914. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  915. return AjaxResult.error("审批驳回失败: 更新审批状态失败");
  916. }
  917. au.setAuditStatus("B");
  918. int updateAuditItemUser = auditItemsUsersMapper.updateAuditItemsUsers(au);
  919. if (updateAuditItemUser <= 0) {
  920. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  921. return AjaxResult.error("审批驳回失败: 更新审批状态失败");
  922. }
  923. if ("F".equals(at.getIffinalItem())) {
  924. int deleteNum = auditItemsMapper.deleteUpLevelId(at);
  925. if (deleteNum <= 0) {
  926. return AjaxResult.error("未找到后续除审批信息");
  927. }
  928. }
  929. }
  930. }
  931. }
  932. TWarehouseBills warehouseBills = new TWarehouseBills();
  933. warehouseBills.setfId(auditItems.getBillId());
  934. calculationWarehouseService.calculationFeeStatus(warehouseBills);
  935. tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
  936. if (number <= 0) {
  937. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  938. return AjaxResult.error("该审批已被操作");
  939. }
  940. return AjaxResult.success();
  941. }
  942. /**
  943. * 审批撤销(我提交的 没人审核)
  944. *
  945. * @param auditItems 审核人、单据信息
  946. * @return
  947. */
  948. @Override
  949. @Transactional
  950. public AjaxResult revoke(AuditItems auditItems) {
  951. long fettle = 0L;
  952. if (auditItems.getActId() >= 110 && auditItems.getActId() <= 160) {
  953. fettle = 2L;
  954. // 查询仓库状态
  955. TWarehouseBills tWarehouseBills = tWarehouseBillsMapper.selectTWarehousebillsById(auditItems.getBillId());
  956. if ("f_billstatus".equals(auditItems.getFidStatus())) {
  957. if (!tWarehouseBills.getfBillstatus().equals(4L)) {
  958. return AjaxResult.error("审批撤销失败: 已经过审批");
  959. }
  960. } else {
  961. if (!tWarehouseBills.getWarehouseStatus().equals(4L)) {
  962. return AjaxResult.error("审批撤销失败: 已经过审批");
  963. }
  964. }
  965. tWarehouseBillsMapper.warehouseApprovalUpdate(auditItems, fettle);
  966. getfBillStatus(auditItems,auditItems);
  967. // 撤销审批时删除审批流任务明细从表对应数据
  968. AuditItemsAbout.revokeDeleteAID(auditItems.getActId(),auditItems.getBillId());
  969. } else if (auditItems.getActId() >= 210 && auditItems.getActId() <= 230) {
  970. fettle = 2L;
  971. String fBillType = null;
  972. if (auditItems.getActId() == 210) {
  973. fBillType = "DZRevoke";
  974. } else if (auditItems.getActId() == 220 || auditItems.getActId() == 230) {
  975. fBillType = "DCRevoke";
  976. }
  977. // 查询财务状态
  978. TFee tFee = tFeeMapper.selectTFeeById(auditItems.getBillId());
  979. if (!"4".equals(tFee.getfBillstatus())) {
  980. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  981. return AjaxResult.error("审批撤销失败: 已经过审批");
  982. }
  983. // 财务模块
  984. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  985. String code = ajaxResult.get("code").toString();
  986. if ("500".equals(code)) {
  987. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  988. return AjaxResult.error("审批撤销失败: 更新审批状态失败");
  989. }
  990. // 更新费用明细
  991. AjaxResult result = tFeeServiceImpl.updateDSFMoney(auditItems.getBillId(),fBillType);
  992. String message = result.get("code").toString();
  993. if ("500".equals(message)) {
  994. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  995. return result;
  996. }
  997. // 撤销审批时删除审批流任务明细从表对应数据
  998. AuditItemsAbout.revokeDeleteAID(auditItems.getActId(),auditItems.getBillId());
  999. } else if (auditItems.getActId() >= 310 && auditItems.getActId() <= 320) {
  1000. fettle = 2L;
  1001. // 查询协议状态
  1002. TWarehouseAgreement tWarehouseAgreement = tWarehouseAgreementMapper.selectTWarehouseAgreementById(auditItems.getBillId());
  1003. if (!"4".equals(tWarehouseAgreement.getfBillstatus())) {
  1004. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1005. return AjaxResult.error("审批撤销失败: 已经过审批");
  1006. }
  1007. // 协议模块
  1008. AjaxResult ajaxResult = tWarehouseAgreementService.agreementFollow(auditItems.getBillId(), fettle);
  1009. String code = ajaxResult.get("code").toString();
  1010. if ("500".equals(code)) {
  1011. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1012. return AjaxResult.error("审批撤销失败: 更新审批状态失败");
  1013. }
  1014. } else if (auditItems.getActId() == 410) {
  1015. fettle = 2L;
  1016. TWarehouseBills tWarehouseBills = tWarehouseBillsService.selectKaHeById(auditItems.getBillId());
  1017. if (tWarehouseBills.getfBillstatus() != 4L) {
  1018. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1019. return AjaxResult.error("审批撤销失败: 已经过审批");
  1020. }
  1021. AjaxResult ajaxResult = tWarehouseBillsService.updateKaHeOrder(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  1022. String code = ajaxResult.get("code").toString();
  1023. if ("500".equals(code)) {
  1024. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1025. return ajaxResult;
  1026. }
  1027. } else if (auditItems.getActId() == 420) {
  1028. fettle = 7L;
  1029. TWarehouseBills tWarehouseBills = tWarehouseBillsService.selectKaHeById(auditItems.getBillId());
  1030. if (tWarehouseBills.getfBillstatus() != 9L) {
  1031. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1032. return AjaxResult.error("审批撤销失败: 已经过审批");
  1033. }
  1034. AjaxResult ajaxResult = tWarehouseBillsService.updateKaHeOrder(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  1035. String code = ajaxResult.get("code").toString();
  1036. if ("500".equals(code)) {
  1037. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1038. return ajaxResult;
  1039. }
  1040. } else if (auditItems.getActId() >= 430 && auditItems.getActId() <= 450) {
  1041. fettle = 2L;
  1042. String fBillType = null;
  1043. if (auditItems.getActId() == 450 || auditItems.getActId() == 440){
  1044. fBillType = "DCRevoke";
  1045. }else if (auditItems.getActId() == 430){
  1046. fBillType = "KHDZRevoke";
  1047. }
  1048. // 查询财务状态
  1049. TFee tFee = tFeeMapper.selectTFeeById(auditItems.getBillId());
  1050. if (!"4".equals(tFee.getfBillstatus())) {
  1051. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1052. return AjaxResult.error("审批撤销失败: 已经过审批");
  1053. }
  1054. // 财务模块
  1055. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  1056. String code = ajaxResult.get("code").toString();
  1057. if ("500".equals(code)) {
  1058. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1059. return AjaxResult.error("审批撤销失败: 更新审批状态失败");
  1060. }
  1061. // 更新费用明细
  1062. AjaxResult result = tFeeServiceImpl.updateMoney(auditItems.getBillId(),fBillType);
  1063. String message = result.get("code").toString();
  1064. if ("500".equals(message)) {
  1065. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1066. return result;
  1067. }
  1068. /*//修改主订单费用信息
  1069. if (auditItems.getActId() >= 440 && auditItems.getActId() <= 450) {
  1070. tWarehouseBillsService.updateMessage(auditItems.getBillId());
  1071. }*/
  1072. } else if (auditItems.getActId() == 460) {
  1073. fettle = 2L;
  1074. TWarehousebillsfees warehousebillsfees = new TWarehousebillsfees();
  1075. warehousebillsfees.setfPid(auditItems.getBillId());
  1076. List<TWarehousebillsfees> tWarehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(warehousebillsfees);
  1077. if (CollectionUtils.isNotEmpty(tWarehousebillsfees) && tWarehousebillsfees.get(0).getfBillstatus() != 4L) {
  1078. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1079. return AjaxResult.error("审批撤销失败: 已经过审批");
  1080. }
  1081. Integer i = tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(auditItems.getBillId(), fettle, auditItems.getAuditItem());
  1082. if (i != null && i > 0) {
  1083. } else {
  1084. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1085. return AjaxResult.error("审核失败,更新费用状态失败");
  1086. }
  1087. } else if (auditItems.getActId() == 470) {
  1088. fettle = 2L;
  1089. // 查询财务状态
  1090. TFee tFee = tFeeMapper.selectTFeeById(auditItems.getBillId());
  1091. if (!"4".equals(tFee.getfBillstatus())) {
  1092. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1093. return AjaxResult.error("审批撤销失败: 已经过审批");
  1094. }
  1095. // 财务模块
  1096. AjaxResult ajaxResult = tFeeServiceImpl.tfeeFollow(auditItems.getBillId(), fettle);
  1097. String code = ajaxResult.get("code").toString();
  1098. if ("500".equals(code)) {
  1099. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1100. return AjaxResult.error("审批撤销失败: 更新审批状态失败");
  1101. }
  1102. } else if (auditItems.getActId() == 170) {
  1103. //入库明细审核
  1104. fettle = 2L;
  1105. //变更仓库入库明细审核状态
  1106. Integer i = null;
  1107. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1108. tWarehouseBills.setfId(auditItems.getBillId());
  1109. tWarehouseBills.setfItemstatus(fettle);
  1110. i = tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  1111. i = tWarehousebillsitemsMapper.warehouseItemfItemstatus(auditItems.getBillId(), fettle);
  1112. if (i != null && i > 0) {
  1113. } else {
  1114. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1115. return AjaxResult.error("审核失败,更新费用状态失败");
  1116. }
  1117. } else if (auditItems.getActId() == 180) {
  1118. //入库明细审核
  1119. fettle = 2L;
  1120. //变更仓库入库明细审核状态
  1121. Integer i = null;
  1122. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1123. tWarehouseBills.setfId(auditItems.getBillId());
  1124. tWarehouseBills.setfItemstatus(fettle);
  1125. i = tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  1126. i = tWarehousebillsitemsMapper.warehouseItemfItemstatus(auditItems.getBillId(), fettle);
  1127. if (i != null && i > 0) {
  1128. } else {
  1129. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1130. return AjaxResult.error("审核失败,更新费用状态失败");
  1131. }
  1132. } else if (auditItems.getActId() == 471) {
  1133. fettle = 2L;
  1134. // 变更凯和申请修改订单状态
  1135. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1136. tWarehouseBills.setfId(auditItems.getBillId());
  1137. tWarehouseBills.setfUpdeteStatus(fettle);
  1138. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  1139. } else if (auditItems.getActId() == 472) {
  1140. fettle = 2L;
  1141. // 变更凯和申请修改订单状态
  1142. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1143. tWarehouseBills.setfId(auditItems.getBillId());
  1144. tWarehouseBills.setfSubmitUpdate(fettle);
  1145. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  1146. } else if (auditItems.getActId() == 473) {
  1147. fettle = 2L;
  1148. // 变更凯和申请修改订单状态
  1149. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1150. tWarehouseBills.setfId(auditItems.getBillId());
  1151. tWarehouseBills.setfDeleteStatus(fettle);
  1152. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  1153. } else if (auditItems.getActId() == 474) {
  1154. fettle = 2L;
  1155. //变更凯和拆单单状态
  1156. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1157. tWarehouseBills.setfId(auditItems.getBillId());
  1158. tWarehouseBills.setfDismountStatus(fettle);
  1159. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  1160. } else if (auditItems.getActId() == 181) {
  1161. fettle = 2L;
  1162. //业务处理
  1163. } else if (auditItems.getActId() == 190) {
  1164. fettle = 2L;
  1165. TWarehouseBills tWarehouseBills = new TWarehouseBills();
  1166. tWarehouseBills.setfId(auditItems.getBillId());
  1167. tWarehouseBills.setfBillstatus(fettle);
  1168. tWarehouseBillsMapper.updateKaHeOrder(tWarehouseBills);
  1169. getfBillStatus(auditItems,auditItems);
  1170. // 撤销审批时删除审批流任务明细从表对应数据
  1171. AuditItemsAbout.revokeDeleteAID(auditItems.getActId(),auditItems.getBillId());
  1172. } else if (Objects.equals(auditItems.getActId(), WarehouseActIdEnum.FEE_CHANGES.getActId().longValue())) {
  1173. warehousebillsModifyService.withdrawalApprovalById(auditItems.getBillId());
  1174. }
  1175. auditItemsMapper.deletePurchaseApproval(auditItems);
  1176. TWarehouseBills warehouseBills = new TWarehouseBills();
  1177. warehouseBills.setfId(auditItems.getBillId());
  1178. calculationWarehouseService.calculationFeeStatus(warehouseBills);
  1179. tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
  1180. return AjaxResult.success();
  1181. }
  1182. /**
  1183. * 仓库APP查看订单审批流
  1184. *
  1185. * @param auditItems 条件
  1186. * @return 结果
  1187. */
  1188. @Override
  1189. public List<AppAuditItemVO> selectOrderAuditItems(AppAuditItemDTO auditItems) {
  1190. // 如果没有指定类型信息,则默认 赋值仓库类型
  1191. if (StringUtils.isEmpty(auditItems.getBillType())) {
  1192. auditItems.setBillTypeList(WarehouseTypeEnum.getWarehousingType());
  1193. } else {
  1194. List<String> strings = new ArrayList<>();
  1195. strings.add(auditItems.getBillType());
  1196. auditItems.setBillTypeList(strings);
  1197. }
  1198. if (StringUtils.isNotEmpty(auditItems.getSendTimeInterval())) {
  1199. String[] split = auditItems.getSendTimeInterval().split(",");
  1200. List<String> list = Lists.newArrayList();
  1201. list.add(split[0] + " 00:00:00");
  1202. list.add(split[1] + " 23:59:59");
  1203. auditItems.setSendList(list);
  1204. }
  1205. auditItems.setActIdList(WarehouseActIdEnum.isWarehousingActList());
  1206. // 查询
  1207. List<AppAuditItemVO> appAuditItemVOList = auditItemsMapper.selectOrderAuditItems(auditItems);
  1208. // 贸易方式
  1209. String type = "data_trademodes";
  1210. if (CollectionUtils.isNotEmpty(appAuditItemVOList)) {
  1211. appAuditItemVOList.forEach(vo -> {
  1212. if (StringUtils.isNotNull(vo.getFTrademodeid())) {
  1213. // 转换贸易方式
  1214. String dictLabel = DictUtils.getDictLabel(type, vo.getFTrademodeid().toString());
  1215. if (StringUtils.isNotEmpty(dictLabel)) {
  1216. vo.setFTrademodeName(dictLabel);
  1217. }
  1218. }
  1219. // 转换状态
  1220. vo.setAudit(AuditStateEnum.fromType(vo.getAuditState()).getName());
  1221. // 转换活动号
  1222. vo.setActName(WarehouseActIdEnum.fromActId(vo.getActId().intValue()).getName());
  1223. });
  1224. }
  1225. return appAuditItemVOList;
  1226. }
  1227. }