TWarehouseBillsServiceImpl.java 98 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035
  1. package com.ruoyi.warehouseBusiness.service.impl;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.ruoyi.approvalFlow.domain.AuditItems;
  5. import com.ruoyi.approvalFlow.mapper.AuditItemsMapper;
  6. import com.ruoyi.approvalFlow.service.impl.AuditItemsServiceImpl;
  7. import com.ruoyi.basicData.domain.*;
  8. import com.ruoyi.basicData.mapper.*;
  9. import com.ruoyi.common.core.domain.AjaxResult;
  10. import com.ruoyi.common.core.domain.entity.SysDept;
  11. import com.ruoyi.common.core.domain.entity.SysDictData;
  12. import com.ruoyi.common.core.domain.entity.SysUser;
  13. import com.ruoyi.common.core.domain.model.LoginUser;
  14. import com.ruoyi.common.utils.DateUtils;
  15. import com.ruoyi.common.utils.StringUtils;
  16. import com.ruoyi.reportManagement.domain.TWhgenleg;
  17. import com.ruoyi.reportManagement.mapper.TWhgenlegMapper;
  18. import com.ruoyi.system.domain.SysConfig;
  19. import com.ruoyi.system.mapper.SysConfigMapper;
  20. import com.ruoyi.system.mapper.SysDeptMapper;
  21. import com.ruoyi.system.mapper.SysDictDataMapper;
  22. import com.ruoyi.system.mapper.SysUserMapper;
  23. import com.ruoyi.warehouseBusiness.domain.*;
  24. import com.ruoyi.warehouseBusiness.mapper.*;
  25. import com.ruoyi.warehouseBusiness.service.ITWarehouseBillsService;
  26. import org.springframework.beans.factory.annotation.Autowired;
  27. import org.springframework.stereotype.Service;
  28. import org.springframework.transaction.annotation.Transactional;
  29. import org.springframework.transaction.interceptor.TransactionAspectSupport;
  30. import com.ruoyi.common.core.domain.entity.TWarehouse;
  31. import java.math.BigDecimal;
  32. import java.util.*;
  33. import static java.util.stream.Collectors.toList;
  34. /**
  35. * 详情主表Service业务层处理
  36. *
  37. * @author ruoyi
  38. * @date 2020-12-11
  39. */
  40. @Service
  41. public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
  42. @Autowired
  43. private TWhgenlegMapper tWhgenlegMapper;
  44. @Autowired
  45. private TGoodsMapper tGoodsMapper;
  46. @Autowired
  47. private SysConfigMapper sysConfigMapper;
  48. @Autowired
  49. private AuditItemsServiceImpl auditItemsService;
  50. @Autowired
  51. private AuditItemsMapper auditItemsMapper;
  52. @Autowired
  53. private SysDeptMapper sysDeptMapper;
  54. @Autowired
  55. private SysUserMapper sysUserMapper;
  56. @Autowired
  57. private TCorpsMapper tCorpsMapper;
  58. @Autowired
  59. private TFeesMapper tFeesMapper;
  60. @Autowired
  61. private TWarehouseMapper tWarehouseMapper;
  62. @Autowired
  63. private SysDictDataMapper sysDictDataMapper;
  64. @Autowired
  65. private TWarehouseAreaMapper tWarehouseAreaMapper;
  66. @Autowired
  67. private TEnclosureMapper tEnclosureMapper;
  68. @Autowired
  69. private TWarehouseBillsMapper tWarehouseBillsMapper;
  70. @Autowired
  71. private TWarehousebillsfeesMapper tWarehousebillsfeesMapper;
  72. @Autowired
  73. private TWarehousebillsitemsMapper tWarehousebillsitemsMapper;
  74. @Autowired
  75. private BillnoSerialServiceImpl billnoSerialServiceImpl;
  76. @Autowired
  77. private BillnoDelMapper billnoDelMapper;
  78. @Autowired
  79. private TWarehousebillsLogMapper tWarehousebillsLogMapper;
  80. @Autowired
  81. private TWarehouseAgreementServiceImpl tWarehouseAgreementService;
  82. /**
  83. * 查询详情主表
  84. *
  85. * @param fId 详情主表ID
  86. * @return 详情主表
  87. */
  88. @Override
  89. public Map<String, Object> selectTWarehousebillsById(Long fId) {
  90. Map<String, Object> map = new HashMap<>();
  91. // 查询仓库主表数据
  92. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  93. // 客户表
  94. List<Long> corpsId = new ArrayList<>();
  95. // 用户表
  96. List<SysUser> sysUserList = new ArrayList<>();
  97. // 仓库表
  98. List<TWarehouse> warehouseList = new ArrayList<>();
  99. // 商品
  100. List<Long> goodsId = new ArrayList<>();
  101. // 费用
  102. List<Long> feesId = new ArrayList<>();
  103. // 库区
  104. List<Long> warehouseAreaId = new ArrayList<>();
  105. if (!StringUtils.isNull(tWarehousebills)) {
  106. if (StringUtils.isNotNull(tWarehousebills.getfTocorpid())) {
  107. corpsId.add(tWarehousebills.getfTocorpid());
  108. }
  109. corpsId.add(tWarehousebills.getfCorpid());
  110. // 查询制单人
  111. SysUser logUser = sysUserMapper.selectUserByUserName(tWarehousebills.getCreateBy());
  112. if (StringUtils.isNotNull(logUser)) {
  113. SysDept sysDept = sysDeptMapper.selectDeptById(logUser.getDeptId());
  114. sysUserList.add(logUser);
  115. map.put("dept", sysDept);
  116. }
  117. SysUser sysUser = sysUserMapper.selectUserByUserName(tWarehousebills.getfStorekeeper());
  118. if (StringUtils.isNotNull(sysUser)) {
  119. sysUserList.add(sysUser);
  120. }
  121. // 查询仓库
  122. TWarehouse tWarehouse = tWarehouseMapper.selectTWarehouseById(tWarehousebills.getfWarehouseid());
  123. if (StringUtils.isNotNull(tWarehouse)) {
  124. warehouseList.add(tWarehouse);
  125. }
  126. // 查询经营单位
  127. corpsId.add(tWarehousebills.getfSbu());
  128. map.put("warehousebills", tWarehousebills);
  129. }
  130. // 查询仓库明细从表数据
  131. TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
  132. tWarehousebillsitems.setfPid(fId);
  133. List<Map<String, Object>> mapList = tWarehousebillsitemsMapper.selectGoodsTransferitemsList(tWarehousebillsitems);
  134. if (StringUtils.isNotEmpty(mapList)) {
  135. for (Map<String, Object> wb : mapList) {
  136. /*TWhgenleg tWhgenleg = new TWhgenleg();
  137. tWhgenleg.setfCorpid(tWarehousebills.getfCorpid());
  138. if (StringUtils.isNotNull(wb.get("fGoodsid"))) {
  139. tWhgenleg.setfGoodsid(((Integer) wb.get("fGoodsid")).longValue());
  140. }
  141. if (StringUtils.isNotNull(wb.get("fWarehouselocid"))) {
  142. tWhgenleg.setfWarehouseLocationid(((Integer) wb.get("fWarehouselocid")).longValue());
  143. }
  144. tWhgenleg.setfTrademodeid(tWarehousebills.getfTrademodeid());
  145. tWhgenleg.setfMblno(tWarehousebills.getfMblno());
  146. TWhgenleg whgenleg = tWhgenlegMapper.selectTWhgenleg(tWhgenleg);
  147. if (StringUtils.isNotNull(whgenleg)) {
  148. wb.put("fQtyblc", whgenleg.getfQtyblc());
  149. }*/
  150. if (StringUtils.isNotNull(wb.get("fGoodsid"))) {
  151. Integer fGoodsid = (Integer) wb.get("fGoodsid");
  152. goodsId.add(fGoodsid.longValue());
  153. }
  154. if (StringUtils.isNotNull(wb.get("fWarehouselocid"))) {
  155. Long fWarehouselocid = Long.valueOf(String.valueOf(wb.get("fWarehouselocid")));
  156. if (wb.get("fTransferWarehouselocid") != null) {
  157. Long fTransferWarehouselocid = Long.valueOf(String.valueOf(wb.get("fTransferWarehouselocid")));
  158. warehouseAreaId.add(fTransferWarehouselocid);
  159. }
  160. warehouseAreaId.add(fWarehouselocid);
  161. }
  162. }
  163. map.put("warehouseBillsItem", mapList);
  164. }
  165. // 查询仓库费用明细表数据
  166. TWarehousebillsfees tWarehousebillsfees = new TWarehousebillsfees();
  167. tWarehousebillsfees.setfPid(fId);
  168. List<TWarehousebillsfees> warehousebillsfeesDr = new ArrayList<>();
  169. List<TWarehousebillsfees> warehousebillsfeesCr = new ArrayList<>();
  170. List<TWarehousebillsfees> warehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(tWarehousebillsfees);
  171. if (StringUtils.isNotEmpty(warehousebillsfees)) {
  172. for (TWarehousebillsfees fees : warehousebillsfees) {
  173. if ("C".equals(fees.getfDc())) {
  174. warehousebillsfeesCr.add(fees);
  175. } else {
  176. warehousebillsfeesDr.add(fees);
  177. }
  178. corpsId.add(fees.getfCorpid());
  179. feesId.add(fees.getfFeeid());
  180. }
  181. }
  182. // 查询附件表数据
  183. TEnclosure enclosure = new TEnclosure();
  184. enclosure.setfPid(fId);
  185. List<TEnclosure> enclosures = tEnclosureMapper.selectTEnclosureList(enclosure);
  186. if (StringUtils.isNotEmpty(enclosures)) {
  187. map.put("enclosures", enclosures);
  188. }
  189. List<TCorps> corpsList = new ArrayList<>();
  190. List<Long> corpsIdList = StringUtils.integerDeduplication(corpsId);
  191. for (Long corpId : corpsIdList) {
  192. TCorps corps = tCorpsMapper.selectTCorpsById(corpId);
  193. if (StringUtils.isNotNull(corps)) {
  194. corpsList.add(corps);
  195. }
  196. }
  197. List<TWarehouseArea> warehouseAreaList = new ArrayList<>();
  198. List<Long> warehouseAreaIdList = StringUtils.integerDeduplication(warehouseAreaId);
  199. for (Long warehouseArea : warehouseAreaIdList) {
  200. TWarehouseArea tWarehouseArea = tWarehouseAreaMapper.selectTWarehouseAreaById(warehouseArea);
  201. if (StringUtils.isNotNull(tWarehouseArea)) {
  202. warehouseAreaList.add(tWarehouseArea);
  203. }
  204. }
  205. List<TGoods> goodsList = new ArrayList<>();
  206. List<Long> goodsIdList = StringUtils.integerDeduplication(goodsId);
  207. for (Long goods : goodsIdList) {
  208. TGoods tGoods = tGoodsMapper.selectTGoodsById(goods);
  209. if (StringUtils.isNotNull(tGoods)) {
  210. goodsList.add(tGoods);
  211. }
  212. }
  213. List<TFees> feesList = new ArrayList<>();
  214. List<Long> longList = StringUtils.integerDeduplication(feesId);
  215. for (Long fees : longList) {
  216. TFees tFees = tFeesMapper.selectTFeesById(fees);
  217. if (StringUtils.isNotNull(tFees)) {
  218. feesList.add(tFees);
  219. }
  220. }
  221. map.put("corps", corpsList);
  222. map.put("goodsList", goodsList);
  223. map.put("feesList", feesList);
  224. map.put("sysUser", sysUserList);
  225. map.put("warehouse", warehouseList);
  226. map.put("warehouseAreas", warehouseAreaList);
  227. map.put("warehousebillsfeesDr", warehousebillsfeesDr);
  228. map.put("warehousebillsfeesCr", warehousebillsfeesCr);
  229. map.put("dept", sysDeptMapper.selectDeptById(tWarehousebills.getfDeptid()));
  230. return map;
  231. }
  232. /**
  233. * 查询详情主表列表
  234. *
  235. * @param tWarehousebills 详情主表
  236. * @return 详情主表
  237. */
  238. @Override
  239. public List<Map<String, Object>> selectWarehouseBusinessList(TWarehouseBills tWarehousebills) {
  240. return tWarehouseBillsMapper.selectWarehouseBusinessList(tWarehousebills);
  241. }
  242. /**
  243. * 查询导出所需主表列表
  244. *
  245. * @param tWarehousebills 详情主表
  246. * @return 详情主表
  247. */
  248. @Override
  249. public List<TWarehouseBills> selectTWarehousebillsList(TWarehouseBills tWarehousebills) {
  250. return tWarehouseBillsMapper.selectTWarehousebillsList(tWarehousebills);
  251. }
  252. /**
  253. * 根据条件查询总账是否存在
  254. *
  255. * @param warehouseBills 仓库主表
  256. * @param warehousebillsitems 仓库明细表
  257. * @return 库存总账
  258. */
  259. public TWhgenleg queryTWhgenleg(TWarehouseBills warehouseBills, TWarehousebillsitems warehousebillsitems) {
  260. TWhgenleg tWhgenleg = new TWhgenleg();
  261. // 客户
  262. tWhgenleg.setfCorpid(warehouseBills.getfCorpid());
  263. // 提单号
  264. if ("HQZY".equals(warehouseBills.getfBilltype())) {
  265. tWhgenleg.setfMblno(warehousebillsitems.getfMblno());
  266. } else {
  267. tWhgenleg.setfMblno(warehouseBills.getfMblno());
  268. }
  269. // 库区
  270. tWhgenleg.setfWarehouseLocationid(warehousebillsitems.getfWarehouselocid());
  271. // 货物品名
  272. tWhgenleg.setfGoodsid(warehousebillsitems.getfGoodsid());
  273. // 贸易方式
  274. tWhgenleg.setfTrademodeid(warehouseBills.getfTrademodeid());
  275. return tWhgenlegMapper.selectTWhgenleg(tWhgenleg);
  276. }
  277. /**
  278. * 新增库存总账
  279. *
  280. * @param warehouseBills 仓库主表
  281. * @param warehousebillsitems 仓库明细表
  282. * @return 结果
  283. */
  284. @Transactional
  285. public int instalTWhgenleg(TWarehouseBills warehouseBills, TWarehousebillsitems warehousebillsitems, SysUser user) {
  286. TWhgenleg tWhgenleg = new TWhgenleg();
  287. if ("SJRK".equals(warehouseBills.getfBilltype())) {
  288. tWhgenleg.setfOriginalbilldate(warehousebillsitems.getfBsdate());
  289. }
  290. if ("HQZY".equals(warehouseBills.getfBilltype()) || "CKDB".equals(warehouseBills.getfBilltype())) {
  291. tWhgenleg.setfOriginalbilldate(warehousebillsitems.getfOriginalbilldate());
  292. if ("CKDB".equals(warehouseBills.getfBilltype())) {
  293. tWhgenleg.setfCorpid(warehouseBills.getfCorpid());
  294. } else {
  295. // 客户
  296. tWhgenleg.setfCorpid(warehouseBills.getfTocorpid());
  297. }
  298. // 提单号
  299. tWhgenleg.setfMblno(warehousebillsitems.getfMblno());
  300. // 原始单号
  301. tWhgenleg.setfOriginalbillno(warehousebillsitems.getfMblno());
  302. } else {
  303. // 客户
  304. tWhgenleg.setfCorpid(warehouseBills.getfCorpid());
  305. // 提单号
  306. tWhgenleg.setfMblno(warehouseBills.getfMblno());
  307. // 原始单号
  308. tWhgenleg.setfOriginalbillno(warehouseBills.getfMblno());
  309. }
  310. // 明细类型
  311. tWhgenleg.setfBusinessType(warehousebillsitems.getfBusinessType());
  312. // 仓库
  313. tWhgenleg.setfWarehouseid(warehouseBills.getfWarehouseid());
  314. // 库区
  315. tWhgenleg.setfWarehouseLocationid(warehousebillsitems.getfWarehouselocid());
  316. // 货物品名
  317. tWhgenleg.setfGoodsid(warehousebillsitems.getfGoodsid());
  318. // 计费方式
  319. tWhgenleg.setfBillingway(warehousebillsitems.getfBillingway());
  320. // 仓储计费日期
  321. tWhgenleg.setfChargedate(warehousebillsitems.getfChargedate());
  322. // 贸易方式
  323. tWhgenleg.setfTrademodeid(warehouseBills.getfTrademodeid());
  324. // 入库数
  325. tWhgenleg.setfQtyd(warehousebillsitems.getfQty());
  326. // 入库尺码
  327. tWhgenleg.setfVolumnd(warehousebillsitems.getfVolumn());
  328. // 唛头
  329. tWhgenleg.setfMarks(warehousebillsitems.getfMarks());
  330. // 入库毛重
  331. tWhgenleg.setfGrossweightd(warehousebillsitems.getfGrossweight());
  332. // 入库净重
  333. tWhgenleg.setfNetweightd(warehousebillsitems.getfNetweight());
  334. // 入库箱号
  335. tWhgenleg.setfCntrno(warehousebillsitems.getfCntrno());
  336. // 创建人
  337. tWhgenleg.setCreateBy(user.getUserName());
  338. // 创建人
  339. tWhgenleg.setCreateTime(new Date());
  340. // 状态
  341. tWhgenleg.setfStatus("T");
  342. // 结余件数
  343. tWhgenleg.setfQtyblc(warehousebillsitems.getfQty());
  344. return tWhgenlegMapper.insertTWhgenleg(tWhgenleg);
  345. }
  346. @Transactional
  347. public int updateTWhgenlegData(TWarehousebillsitems warehousebillsitems, long whgenlegId, String billtype) {
  348. Map<String, Object> map = new HashMap<>();
  349. map.put("whgenlegId", whgenlegId);
  350. map.put("billType", billtype);
  351. map.put("warehousebillsitems", warehousebillsitems);
  352. return tWhgenlegMapper.updateTWhgenlegData(map);
  353. }
  354. /**
  355. * 仓库暂存接口
  356. *
  357. * @param tWarehouseBills 仓库主表
  358. * @param tWarehousebillsfeesCr 仓库费付款用明细表
  359. * @param tWarehousebillsfeesDr 仓库费收
  360. * 款用明细表
  361. * @param tWarehousebillsitems 仓库货物明细表
  362. * @param loginUser 当前登陆人
  363. * @param billsType 判断标识
  364. * @return 结果
  365. */
  366. @Override
  367. @Transactional
  368. public AjaxResult insertTWarehousebills(String tWarehouseBills, String tWarehousebillsfeesCr, String tWarehousebillsfeesDr
  369. , String tWarehousebillsitems, String tEnclosure, LoginUser loginUser, String billsType) {
  370. Long fPid = null;
  371. Map<String, Object> map = new HashMap<>();
  372. TWarehouseBills warehouseBills = JSONArray.parseObject(tWarehouseBills, TWarehouseBills.class);
  373. if (StringUtils.isNull(warehouseBills.getfId())) {
  374. // 如果是新数据
  375. warehouseBills.setfBillstatus(2L);
  376. warehouseBills.setCreateBy(loginUser.getUser().getUserName());
  377. warehouseBills.setfChargedate(warehouseBills.getfBsdate());
  378. warehouseBills.setfBilltype(billsType);
  379. warehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
  380. // 业务编码
  381. String billNo = billnoSerialServiceImpl.getBillNo(billsType, warehouseBills.getfBsdate());
  382. warehouseBills.setfBillno(billNo);
  383. if ("SJRK".equals(billsType)) {
  384. // 存货编码
  385. Date time = new Date();
  386. String bscorpno = billnoSerialServiceImpl.getCorpNo(warehouseBills.getfCorpid(), time);
  387. warehouseBills.setfBscorpno(bscorpno);
  388. }
  389. tWarehouseBillsMapper.insertTWarehousebills(warehouseBills);
  390. fPid = warehouseBills.getfId();
  391. } else {
  392. fPid = warehouseBills.getfId();
  393. warehouseBills.setfChargedate(warehouseBills.getfBsdate());
  394. warehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  395. warehouseBills.setUpdateTime(new Date());
  396. tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
  397. tWarehousebillsfeesMapper.deleteByFPid(fPid);
  398. tEnclosureMapper.deleteByFPid(fPid);
  399. // 删除 从表中 未打印账单的数据
  400. deleteBillsitems(fPid, tWarehousebillsitems);
  401. }
  402. // 库存明细添加
  403. if (StringUtils.isNotNull(tWarehousebillsitems) && !"[]".equals(tWarehousebillsitems)) {
  404. JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
  405. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  406. for (TWarehousebillsitems wbItem : warehousebillsitemsList) {
  407. boolean warehouseStatus = "SJRK".equals(billsType) || "SJCK".equals(billsType) || "CKDB".equals(billsType);
  408. // 仓储计费日期
  409. wbItem.setfBilltype(billsType);
  410. if ("SJRK".equals(billsType)) {
  411. wbItem.setfChargedate(warehouseBills.getfChargedate());
  412. wbItem.setfBillingway(warehouseBills.getfBillingway());
  413. }
  414. if (null != wbItem.getfId()) {
  415. wbItem.setUpdateTime(new Date());
  416. wbItem.setUpdateBy(loginUser.getUser().getUserName());
  417. tWarehousebillsitemsMapper.updateTWarehousebillsitems(wbItem);
  418. } else {
  419. // 添加主表 业务单号
  420. wbItem.setfBillno(warehouseBills.getfBillno());
  421. if (!warehouseStatus) {
  422. // wbItem.setfMblno(warehouseBills.getfMblno());
  423. wbItem.setfBillstatus(1L);
  424. } else {
  425. wbItem.setfBillstatus(10L);
  426. }
  427. wbItem.setfPid(fPid);
  428. wbItem.setCreateBy(loginUser.getUser().getUserName());
  429. wbItem.setCreateTime(new Date());
  430. tWarehousebillsitemsMapper.insertTWarehousebillsitems(wbItem);
  431. if (!warehouseStatus) {
  432. // 添加状态log
  433. insertTWarehousebillsLog(wbItem, 10L, loginUser);
  434. }
  435. }
  436. }
  437. }
  438. // 附件添加
  439. if (StringUtils.isNotNull(tEnclosure) && !"[]".equals(tEnclosure)) {
  440. JSONArray jsonDrArray = JSONArray.parseArray(tEnclosure);
  441. List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
  442. for (TEnclosure enclosure : tEnclosureList) {
  443. enclosure.setfPid(fPid);
  444. enclosure.setCreateBy(loginUser.getUser().getUserName());
  445. enclosure.setCreateTime(new Date());
  446. tEnclosureMapper.insertTEnclosure(enclosure);
  447. }
  448. }
  449. // 收款明细添加
  450. if (StringUtils.isNotNull(tWarehousebillsfeesDr) && !"[]".equals(tWarehousebillsfeesDr)) {
  451. JSONArray jsonDrArray = JSONArray.parseArray(tWarehousebillsfeesDr);
  452. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
  453. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  454. // 检验 数量*单价=金额
  455. wbDr.setfPid(fPid);
  456. wbDr.setfDc("D");
  457. wbDr.setfBilltype(billsType);
  458. wbDr.setCreateTime(new Date());
  459. wbDr.setSrcBillNo(warehouseBills.getfBillno());
  460. wbDr.setfChargedate(warehouseBills.getfChargedate());
  461. wbDr.setfBillingDeadline(warehouseBills.getfChargedate());
  462. wbDr.setCreateBy(loginUser.getUser().getUserName());
  463. if(warehouseBills.getfBsdate()!=null&& !warehouseBills.getfBsdate().equals("")){
  464. wbDr.setfBsdate(warehouseBills.getfBsdate());
  465. }
  466. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  467. }
  468. }
  469. // 付款明细添加
  470. if (StringUtils.isNotNull(tWarehousebillsfeesCr) && !"[]".equals(tWarehousebillsfeesCr)) {
  471. JSONArray jsonCrArray = JSONArray.parseArray(tWarehousebillsfeesCr);
  472. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  473. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  474. wbCr.setfPid(fPid);
  475. wbCr.setfDc("C");
  476. wbCr.setfBilltype(billsType);
  477. wbCr.setCreateTime(new Date());
  478. wbCr.setSrcBillNo(warehouseBills.getfBillno());
  479. wbCr.setCreateBy(loginUser.getUser().getUserName());
  480. wbCr.setfChargedate(warehouseBills.getfChargedate());
  481. wbCr.setfBillingDeadline(warehouseBills.getfChargedate());
  482. if(warehouseBills.getfBsdate()!=null&& !warehouseBills.getfBsdate().equals("")){
  483. wbCr.setfBsdate(warehouseBills.getfBsdate());
  484. }
  485. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  486. }
  487. }
  488. TWarehousebillsitems warehousebillsitems = new TWarehousebillsitems();
  489. warehousebillsitems.setfPid(fPid);
  490. map.put("warehouseBills", warehouseBills);
  491. map.put("warehousebillsitems", tWarehousebillsitemsMapper.selectGoodsTransferitemsList(warehousebillsitems));
  492. return AjaxResult.success("成功", map);
  493. }
  494. /**
  495. * 仓库模块提交接口
  496. *
  497. * @param tWarehouseBills 仓库主表
  498. * @param tWarehousebillsfeesCr 仓库费用付款明细表
  499. * @param tWarehousebillsfeesDr 仓库费用收款明细表
  500. * @param tWarehousebillsitems 仓库货物明细表
  501. * @param tEnclosure
  502. * @param loginUser 当前登陆人
  503. * @param billsType 操作状态
  504. * @return
  505. */
  506. @Override
  507. @Transactional
  508. public AjaxResult warehouseSubmission(String tWarehouseBills, String tWarehousebillsfeesCr, String tWarehousebillsfeesDr,
  509. String tWarehousebillsitems, String tEnclosure, LoginUser loginUser, String billsType) {
  510. Long fPid = null;
  511. boolean isApprove = false;
  512. String key = "";
  513. long actId = 0L;
  514. if ("SJRK".equals(billsType)) {
  515. actId = 110L;
  516. key = "warehouse.inStock.ApprovalFlow";
  517. } else if ("SJCK".equals(billsType)) {
  518. actId = 120L;
  519. key = "warehouse.outStock.ApprovalFlow";
  520. } else if ("CKDB".equals(billsType)) {
  521. actId = 140L;
  522. key = "warehouse.stockTransfer.ApprovalFlow";
  523. } else if ("HQZY".equals(billsType)) {
  524. actId = 130L;
  525. key = "warehouse.transfer.ApprovalFlow";
  526. }
  527. SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key);
  528. if (StringUtils.isNull(sysConfig)) {
  529. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  530. return AjaxResult.error("系统参数异常,未找到开启审批流参数");
  531. }
  532. if ("0".equals(sysConfig.getConfigValue())) {
  533. isApprove = true;
  534. }
  535. TWarehouseBills warehouseBills = JSONArray.parseObject(tWarehouseBills, TWarehouseBills.class);
  536. warehouseBills.setfItemsStatus(4L);
  537. if (StringUtils.isNull(warehouseBills.getfId())) {
  538. if (isApprove) {
  539. warehouseBills.setfBillstatus(4L);
  540. } else {
  541. warehouseBills.setfBillstatus(6L);
  542. warehouseBills.setfReviewDate(new Date());
  543. }
  544. warehouseBills.setfBilltype(billsType);
  545. warehouseBills.setfChargedate(warehouseBills.getfBsdate());
  546. warehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
  547. warehouseBills.setCreateBy(loginUser.getUser().getUserName());
  548. String billNo = billnoSerialServiceImpl.getBillNo(billsType, warehouseBills.getfBsdate());
  549. warehouseBills.setfBillno(billNo);
  550. Date time = new Date();
  551. String bscorpno = billnoSerialServiceImpl.getCorpNo(warehouseBills.getfCorpid(), time);
  552. warehouseBills.setfBscorpno(bscorpno);
  553. tWarehouseBillsMapper.insertTWarehousebills(warehouseBills);
  554. fPid = warehouseBills.getfId();
  555. } else {
  556. fPid = warehouseBills.getfId();
  557. if (isApprove) {
  558. warehouseBills.setfBillstatus(4L);
  559. } else {
  560. warehouseBills.setfBillstatus(6L);
  561. warehouseBills.setfReviewDate(new Date());
  562. }
  563. warehouseBills.setUpdateTime(new Date());
  564. warehouseBills.setfChargedate(warehouseBills.getfBsdate());
  565. warehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  566. tEnclosureMapper.deleteByFPid(fPid);
  567. tWarehousebillsfeesMapper.deleteByFPid(fPid);
  568. tWarehousebillsitemsMapper.deleteByFPid(fPid);
  569. tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
  570. }
  571. JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
  572. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  573. int line = 0;
  574. for (TWarehousebillsitems wbItem : warehousebillsitemsList) {
  575. line++;
  576. if ("SJRK".equals(billsType) || "SJCK".equals(billsType) || "CKDB".equals(billsType)) {
  577. // 除了入库其他模块不需要更新主表的 仓储费计费日期到明细表,其他模块 应从库存总账把仓储费计费日期 赋给明细表
  578. if ("SJRK".equals(billsType)) {
  579. wbItem.setfMblno(warehouseBills.getfMblno());
  580. wbItem.setfBillingway(warehouseBills.getfBillingway());
  581. wbItem.setfChargedate(warehouseBills.getfChargedate());
  582. wbItem.setfOriginalbilldate(warehouseBills.getfBsdate());
  583. }
  584. if (!wbItem.getfBillstatus().equals(40L)) {
  585. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  586. return AjaxResult.error("库存明细第" + line + "行状态异常,请确认");
  587. }
  588. } else {
  589. if (!wbItem.getfBillstatus().equals(6L)) {
  590. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  591. return AjaxResult.error("库存明细第" + line + "行状态异常,请确认");
  592. }
  593. }
  594. if (StringUtils.isNull(wbItem.getfChargedate())) {
  595. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  596. return AjaxResult.error("库存明细第" + line + "行未找到仓储费计费日期,请确认");
  597. }
  598. if (StringUtils.isNull(wbItem.getfBillingway())) {
  599. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  600. return AjaxResult.error("库存明细第" + line + "行未找到计费方式,请确认");
  601. }
  602. if (StringUtils.isNull(wbItem.getfOriginalbilldate())) {
  603. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  604. return AjaxResult.error("库存明细第" + line + "行未找到入库日期,请确认");
  605. }
  606. wbItem.setfPid(fPid);
  607. wbItem.setfBilltype(billsType);
  608. wbItem.setCreateTime(new Date());
  609. wbItem.setfBillno(warehouseBills.getfBillno());
  610. wbItem.setCreateBy(loginUser.getUser().getUserName());
  611. tWarehousebillsitemsMapper.insertTWarehousebillsitems(wbItem);
  612. }
  613. if (StringUtils.isNotNull(tWarehousebillsfeesCr) && !"[]".equals(tWarehousebillsfeesCr)) {
  614. JSONArray jsonCrArray = JSONArray.parseArray(tWarehousebillsfeesCr);
  615. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  616. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  617. wbCr.setfPid(fPid);
  618. wbCr.setfDc("C");
  619. wbCr.setfBilltype(billsType);
  620. wbCr.setCreateTime(new Date());
  621. wbCr.setSrcBillNo(warehouseBills.getfBillno());
  622. wbCr.setCreateBy(loginUser.getUser().getUserName());
  623. wbCr.setfChargedate(warehouseBills.getfChargedate());
  624. wbCr.setfBillingDeadline(warehouseBills.getfChargedate());
  625. if(warehouseBills.getfBsdate()!=null&& !warehouseBills.getfBsdate().equals("")){
  626. wbCr.setfBsdate(warehouseBills.getfBsdate());
  627. }
  628. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  629. }
  630. }
  631. if (StringUtils.isNotNull(tWarehousebillsfeesDr) && !"[]".equals(tWarehousebillsfeesDr)) {
  632. JSONArray jsonCrArray = JSONArray.parseArray(tWarehousebillsfeesDr);
  633. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  634. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  635. wbDr.setfPid(fPid);
  636. wbDr.setfDc("D");
  637. wbDr.setfBillstatus(4L);
  638. wbDr.setfBilltype(billsType);
  639. wbDr.setCreateTime(new Date());
  640. wbDr.setSrcBillNo(warehouseBills.getfBillno());
  641. wbDr.setCreateBy(loginUser.getUser().getUserName());
  642. wbDr.setfChargedate(warehouseBills.getfChargedate());
  643. wbDr.setfBillingDeadline(warehouseBills.getfChargedate());
  644. if(warehouseBills.getfBsdate()!=null&& !warehouseBills.getfBsdate().equals("")){
  645. wbDr.setfBsdate(warehouseBills.getfBsdate());
  646. }
  647. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  648. }
  649. }
  650. if (StringUtils.isNotNull(tEnclosure) && !"[]".equals(tEnclosure)) {
  651. JSONArray jsonEnclosureArray = JSONArray.parseArray(tEnclosure);
  652. List<TEnclosure> enclosuresList = JSONObject.parseArray(jsonEnclosureArray.toJSONString(), TEnclosure.class);
  653. long lineNo = 0L;
  654. for (TEnclosure enclosure : enclosuresList) {
  655. lineNo++;
  656. enclosure.setfPid(fPid);
  657. enclosure.setfLineno(lineNo);
  658. enclosure.setCreateTime(new Date());
  659. enclosure.setCreateBy(loginUser.getUser().getUserName());
  660. tEnclosureMapper.insertTEnclosure(enclosure);
  661. }
  662. }
  663. // 这里加个判断取系统参数来确定是否需要启用审批流
  664. if (isApprove) {
  665. AuditItems auditItems = new AuditItems();
  666. auditItems.setLevelId(0L);
  667. auditItems.setBillId(fPid);
  668. auditItems.setActId(actId);
  669. auditItems.setIffinalItem("F");
  670. auditItems.setBillNo(warehouseBills.getfBillno());
  671. // 存储委托方(货权方)
  672. auditItems.setRefno1(warehouseBills.getfCorpid() + "");
  673. // 存储业务类型(业务类型)
  674. auditItems.setRefno2(warehouseBills.getfBilltype());
  675. // 存储提单号(提单号)
  676. auditItems.setRefno3(warehouseBills.getfMblno());
  677. auditItems.setSendUserId(loginUser.getUser().getUserId());
  678. auditItems.setSendName(loginUser.getUsername());
  679. auditItems.setSendTime(new Date());
  680. auditItems.setAuditUserId(loginUser.getUser().getUserId());
  681. auditItems.setAuditItem(new Date());
  682. auditItems.setAuditOpTime(new Date());
  683. auditItems.setAuditMsg("提交");
  684. auditItems.setAuditStatus("O");
  685. AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems);
  686. // Long code = Long.valueOf(String.valueOf(approvalFlow.get("code"))).longValue();
  687. String code = approvalFlow.get("code").toString();
  688. // Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue();
  689. if ("500".equals(code)) {
  690. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  691. }
  692. return approvalFlow;
  693. } else {
  694. AjaxResult ajaxResult = warehouseFollow(fPid, 6L);
  695. String code = ajaxResult.get("code").toString();
  696. // Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue();
  697. if ("500".equals(code)) {
  698. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  699. }
  700. return ajaxResult;
  701. }
  702. }
  703. @Override
  704. public List<TWareHouseExcelItems> selectTWarehousebillsItemsList(Long fId) {
  705. return tWarehouseBillsMapper.selectTWarehousebillsItemsList(fId);
  706. }
  707. @Override
  708. public List<Map<String, Object>> selectInventoryList(TWarehouseBills tWarehouseBills) {
  709. return tWarehouseBillsMapper.selectInventoryList(tWarehouseBills);
  710. }
  711. /**
  712. * 根据仓库主表id 更新对应明细表状态
  713. *
  714. * @param fPid 仓库主表id
  715. * @return 结果
  716. */
  717. @Transactional
  718. public AjaxResult warehouseFollow(Long fPid, long fettle) {
  719. if (StringUtils.isNull(fPid)) {
  720. return AjaxResult.error("仓库更新状态未找到主表信息,请与管理员联系");
  721. }
  722. try {
  723. tWarehouseBillsMapper.warehouseFollowUpdate(fPid, fettle, new Date());
  724. tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(fPid, fettle, new Date());
  725. TWarehouseBills tWarehouseBills = tWarehouseBillsMapper.selectTWarehousebillsById(fPid);
  726. if ("SJRK".equals(tWarehouseBills.getfBilltype()) || "SJCK".equals(tWarehouseBills.getfBilltype())) {
  727. fettle = 40L;
  728. }
  729. tWarehousebillsitemsMapper.warehouseItemFollowUpdate(fPid, fettle);
  730. } catch (Exception e) {
  731. return AjaxResult.error("更新库存费用状态失败,请联系管理员");
  732. }
  733. return AjaxResult.success();
  734. }
  735. /**
  736. * 根据仓库主表id 更新对应明细表状态
  737. *
  738. * @param fPid 仓库主表id
  739. * @return 结果
  740. */
  741. @Transactional
  742. public AjaxResult storageFeeFollow(Long fPid, long fettle) {
  743. if (StringUtils.isNull(fPid)) {
  744. return AjaxResult.error("仓库更新状态未找到主表信息,请与管理员联系");
  745. }
  746. int warehouseUpdateResult = tWarehouseBillsMapper.warehouseFollowUpdate(fPid, fettle, new Date());
  747. if (warehouseUpdateResult <= 0) {
  748. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  749. return AjaxResult.error("更新库存明细状态失败,请联系管理员");
  750. }
  751. TWarehousebillsfees warehousebillsfees = new TWarehousebillsfees();
  752. warehousebillsfees.setfPid(fPid);
  753. List<TWarehousebillsfees> warehousebillsfeesList = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(warehousebillsfees);
  754. for (TWarehousebillsfees wareItem : warehousebillsfeesList) {
  755. if (StringUtils.isNull(wareItem.getSrcId())) {
  756. continue;
  757. }
  758. if ("KCZZ".equals(wareItem.getfBilltype())) {
  759. TWhgenleg tWhgenleg = tWhgenlegMapper.selectTWhgenlegById(wareItem.getSrcId());
  760. System.out.println(tWhgenleg.getfChargedate());
  761. tWhgenleg.setfChargedate(wareItem.getfBillingDeadline());
  762. System.out.println(tWhgenleg.getfChargedate());
  763. int i = tWhgenlegMapper.updateTWhgenleg(tWhgenleg);
  764. if (i <= 0) {
  765. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  766. return AjaxResult.error("更新库存费用状态失败,请联系管理员");
  767. }
  768. } else {
  769. TWarehousebillsitems tWarehousebillsitems = tWarehousebillsitemsMapper.selectTWarehousebillsitemsById(wareItem.getSrcId());
  770. tWarehousebillsitems.setfAmt(wareItem.getfAmt());
  771. tWarehousebillsitems.setfBillingQty(wareItem.getfBillingQty());
  772. tWarehousebillsitems.setfBillingDays(wareItem.getfBillingDays());
  773. tWarehousebillsitems.setfChargedate(wareItem.getfBillingDeadline());
  774. tWarehousebillsitems.setfInventoryDays(wareItem.getfInventoryDays());
  775. tWarehousebillsitems.setfBillingDeadline(wareItem.getfBillingDeadline());
  776. tWarehousebillsitemsMapper.updateTWarehousebillsitems(tWarehousebillsitems);
  777. }
  778. }
  779. int feesUpdateResult = tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(fPid, fettle, new Date());
  780. if (feesUpdateResult <= 0) {
  781. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  782. return AjaxResult.error("更新库存费用状态失败,请联系管理员");
  783. }
  784. return AjaxResult.success();
  785. }
  786. /**
  787. * 入库详情入账
  788. *
  789. * @param warehouseBills 主表
  790. * @param warehousebillsitems 明细
  791. * @param loginUser 当前登录人
  792. * @param billsType 状态
  793. * @return 结果
  794. */
  795. @Override
  796. @Transactional
  797. public AjaxResult addCredit(String warehouseBills, String warehousebillsitems, String tEnclosure, String warehousebillsfeesCr,
  798. String warehousebillsfeesDr, LoginUser loginUser, String billsType) {
  799. Map<String, Object> map = new HashMap<>();
  800. if (StringUtils.isNull(warehouseBills) || "[]".equals(warehouseBills)) {
  801. return AjaxResult.error("未找到主表信息");
  802. }
  803. if (StringUtils.isNull(warehousebillsitems) || "[]".equals(warehousebillsitems)) {
  804. return AjaxResult.error("未找到入账信息");
  805. }
  806. TWarehouseBills tWarehouseBills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  807. tWarehouseBills.setfItemsStatus(4L);
  808. tWarehouseBills.setfBilltype(billsType);
  809. if (StringUtils.isNotNull(tWarehouseBills.getfId())) {
  810. tWarehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  811. tWarehouseBills.setUpdateTime(new Date());
  812. tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  813. }
  814. tEnclosureMapper.deleteByFPid(tWarehouseBills.getfId());
  815. tWarehousebillsfeesMapper.deleteByFPid(tWarehouseBills.getfId());
  816. boolean businessStatus = "场地直装".equals(tWarehouseBills.getfBusinessType());
  817. JSONArray warehouseJSON = JSONArray.parseArray(warehousebillsitems);
  818. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  819. for (TWarehousebillsitems item : warehousebillsitemsList) {
  820. if (!businessStatus) {
  821. // 查询库容量 是否可入库
  822. int m = calculation(tWarehouseBills.getfWarehouseid(), item.getfGrossweight());
  823. if (m == 0) {
  824. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  825. return AjaxResult.error("更新库存总账失败-->入库毛重大于库容");
  826. }
  827. item.setfBillingway(tWarehouseBills.getfBillingway());
  828. item.setfChargedate(tWarehouseBills.getfChargedate());
  829. TWhgenleg tWhgenle = queryTWhgenleg(tWarehouseBills, item);
  830. if (StringUtils.isNotNull(tWhgenle)) {
  831. int i = updateTWhgenlegData(item, tWhgenle.getfId(), billsType);
  832. if (i <= 0) {
  833. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  834. return AjaxResult.error("更新库存总账失败");
  835. }
  836. } else {
  837. if (instalTWhgenleg(tWarehouseBills, item, loginUser.getUser()) <= 0) {
  838. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  839. return AjaxResult.error("新增库存总账失败");
  840. }
  841. }
  842. item.setfIsInventory(0L);
  843. } else {
  844. item.setfIsInventory(1L);
  845. }
  846. int num = 0;
  847. if (StringUtils.isNotNull(item.getfId())) {
  848. item.setfBillstatus(40L);
  849. item.setUpdateBy(loginUser.getUser().getUserName());
  850. item.setUpdateTime(new Date());
  851. num = tWarehousebillsitemsMapper.updateTWarehousebillsitems(item);
  852. // 添加状态log
  853. insertTWarehousebillsLog(item, 40L, loginUser);
  854. }
  855. if (num <= 0) {
  856. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  857. return AjaxResult.error("新增库存明细失败");
  858. }
  859. }
  860. // 附件添加
  861. if (StringUtils.isNotEmpty(tEnclosure) && !"[]".equals(tEnclosure)) {
  862. JSONArray jsonDrArray = JSONArray.parseArray(tEnclosure);
  863. List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
  864. for (TEnclosure enclosure : tEnclosureList) {
  865. enclosure.setfPid(tWarehouseBills.getfId());
  866. enclosure.setCreateBy(loginUser.getUser().getUserName());
  867. enclosure.setCreateTime(new Date());
  868. tEnclosureMapper.insertTEnclosure(enclosure);
  869. }
  870. }
  871. // 收款明细添加
  872. if (StringUtils.isNotEmpty(warehousebillsfeesDr) && !"[]".equals(warehousebillsfeesDr)) {
  873. JSONArray jsonDrArray = JSONArray.parseArray(warehousebillsfeesDr);
  874. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
  875. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  876. wbDr.setfPid(tWarehouseBills.getfId());
  877. wbDr.setfDc("D");
  878. wbDr.setCreateBy(loginUser.getUser().getUserName());
  879. wbDr.setCreateTime(new Date());
  880. if(tWarehouseBills.getfBsdate()!=null&& !tWarehouseBills.getfBsdate().equals("")){
  881. wbDr.setfBsdate(tWarehouseBills.getfBsdate());
  882. }
  883. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  884. }
  885. }
  886. // 付款明细添加
  887. if (StringUtils.isNotNull(warehousebillsfeesCr) && !"[]".equals(warehousebillsfeesCr)) {
  888. JSONArray jsonCrArray = JSONArray.parseArray(warehousebillsfeesCr);
  889. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  890. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  891. wbCr.setfPid(tWarehouseBills.getfId());
  892. wbCr.setfDc("C");
  893. wbCr.setCreateBy(loginUser.getUser().getUserName());
  894. wbCr.setCreateTime(new Date());
  895. if(tWarehouseBills.getfBsdate()!=null&& !tWarehouseBills.getfBsdate().equals("")){
  896. wbCr.setfBsdate(tWarehouseBills.getfBsdate());
  897. }
  898. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  899. }
  900. }
  901. map.put("warehousebillsitems", warehousebillsitemsList);
  902. return AjaxResult.success("成功", map);
  903. }
  904. /**
  905. * 出库、调拨、货转 确认
  906. *
  907. * @param warehouseBills
  908. * @param warehousebillsitems
  909. * @param loginUser
  910. * @param billsType
  911. * @return
  912. */
  913. @Override
  914. @Transactional
  915. public AjaxResult updateCredit(String warehouseBills, String warehousebillsitems, String tEnclosure, String warehousebillsfeesCr,
  916. String warehousebillsfeesDr, LoginUser loginUser, String billsType) {
  917. Long fPid = null;
  918. Map<String, Object> map = new HashMap<>();
  919. TWarehouseBills tWarehouseBills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  920. if ("SJCK".equals(billsType)) {
  921. tWarehouseBills.setfItemsStatus(4L);
  922. } else {
  923. tWarehouseBills.setfItemsStatus(6L);
  924. }
  925. tWarehouseBills.setfBilltype(billsType);
  926. if (StringUtils.isNotNull(tWarehouseBills.getfId())) {
  927. tWarehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  928. tWarehouseBills.setUpdateTime(new Date());
  929. tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  930. fPid = tWarehouseBills.getfId();
  931. } else {
  932. tWarehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
  933. tWarehouseBills.setCreateBy(loginUser.getUser().getUserName());
  934. tWarehouseBills.setCreateTime(new Date());
  935. String billNo = billnoSerialServiceImpl.getBillNo(billsType, tWarehouseBills.getfBsdate());
  936. tWarehouseBills.setfBillno(billNo);
  937. tWarehouseBillsMapper.insertTWarehousebills(tWarehouseBills);
  938. fPid = tWarehouseBills.getfId();
  939. }
  940. tEnclosureMapper.deleteByFPid(fPid);
  941. tWarehousebillsfeesMapper.deleteByFPid(fPid);
  942. JSONArray warehouseJSON = JSONArray.parseArray(warehousebillsitems);
  943. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  944. int i = 1;
  945. List<TFees> feesList = new ArrayList<>();
  946. List<TWarehousebillsfees> warehousebillsfees = new ArrayList<>();
  947. for (TWarehousebillsitems wbItem : warehousebillsitemsList) {
  948. long warehouselocId = 0L;
  949. long transferWarehouselocid = 0L;
  950. if ("CKDB".equals(billsType)) {
  951. warehouselocId = wbItem.getfWarehouselocid();
  952. transferWarehouselocid = wbItem.getfTransferWarehouselocid();
  953. // wbItem.setfWarehouselocid(transferWarehouselocid);
  954. }
  955. // 查询总账是否存在
  956. TWhgenleg tWhgenle = queryTWhgenleg(tWarehouseBills, wbItem);
  957. // 入库数特殊不判断入账
  958. if ("SJCK".equals(billsType)) { // 出库 查询
  959. if (StringUtils.isNull(tWhgenle)) { // 为空 提示没有库存
  960. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  961. return AjaxResult.error("库存明细第" + i + "行库存为空");
  962. } else { // 非空修改库存总账
  963. // 库存 < 出库件数
  964. if (tWhgenle.getfQtyblc() < wbItem.getfQty()) {
  965. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  966. return AjaxResult.error("库存明细第" + i + "行库存不足");
  967. }
  968. // 更新库存总账
  969. updateTWhgenlegData(wbItem, tWhgenle.getfId(), billsType);
  970. if (StringUtils.isNull(tWarehouseBills.getfBsdate()) || StringUtils.isNull(wbItem.getfChargedate())) {
  971. return AjaxResult.error("库存明细第" + i + "行请检查日期,操作终止");
  972. }
  973. long dateDay = DateUtils.getDateDay(tWarehouseBills.getfBsdate(), wbItem.getfChargedate());
  974. if (StringUtils.isNull(tWarehouseBills.getfCorpid())) {
  975. return AjaxResult.error("库存明细第" + i + "行请检查客户信息,操作终止");
  976. }
  977. /*long fCorpid = tWarehouseBills.getfCorpid();
  978. TGoods tGoods = tGoodsMapper.selectTGoodsById(wbItem.getfGoodsid());
  979. long fGoodsid = tGoods.getfTypeid();
  980. long fBillingway = wbItem.getfBillingway();
  981. long fQty = wbItem.getfQty();
  982. // 计算仓储费明细
  983. Map<String, Object> objectMap = tWarehouseAgreementService.getCarryingCost(fCorpid, fGoodsid, dateDay, fBillingway, fQty , 0L);
  984. if (StringUtils.isNull(objectMap)) {
  985. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  986. return AjaxResult.error("库存明细第" + i + "行没有维护出库明细的仓储协议,操作终止");
  987. }
  988. Long feeId = (Long) objectMap.get("feeId");
  989. BigDecimal amt = (BigDecimal) objectMap.get("amt");
  990. TFees tFees = tFeesMapper.selectTFeesById(feeId);
  991. if (StringUtils.isNotNull(tFees)) {
  992. feesList.add(tFees);
  993. }
  994. TWarehousebillsfees fees = new TWarehousebillsfees();
  995. fees.setfPid(fPid);
  996. fees.setfFeeid(feeId);
  997. fees.setfCorpid(tWarehouseBills.getfCorpid());
  998. fees.setfFeeUnitid(fBillingway);
  999. fees.setfQty(new BigDecimal(1));
  1000. fees.setfUnitprice(amt);
  1001. fees.setfAmount(amt);
  1002. fees.setfExrate(new BigDecimal(1));
  1003. fees.setfCurrency("RMB");
  1004. fees.setRemark(dateDay + "天" + tFees.getfName());
  1005. warehousebillsfees.add(fees);*/
  1006. }
  1007. wbItem.setfBillstatus(40L);
  1008. } else if ("CKDB".equals(billsType)) { // 调拨查询
  1009. if (StringUtils.isNull(tWhgenle)) { // 为空 提示没有库存
  1010. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1011. return AjaxResult.error("库存明细第" + i + "行库存为空");
  1012. } else { // 非空修改库存总账
  1013. if (tWhgenle.getfQtyblc() < wbItem.getfQty()) { // 1、 库存 < 调拨件数 提示库存不足
  1014. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1015. return AjaxResult.error("库存明细第" + i + "行库存不足");
  1016. } else { // 2、 库存足够 先 进行出库操作
  1017. wbItem.setfWarehouselocid(warehouselocId);
  1018. updateTWhgenlegData(wbItem, tWhgenle.getfId(), "SJCK");
  1019. }
  1020. // 3、 进行入库操作 查询是否存在库存
  1021. wbItem.setfWarehouselocid(transferWarehouselocid); // 新库区
  1022. TWhgenleg tWhgenle1 = queryTWhgenleg(tWarehouseBills, wbItem);
  1023. if (StringUtils.isNull(tWhgenle1)) { // 5、 不存在 进行新增库存
  1024. instalTWhgenleg(tWarehouseBills, wbItem, loginUser.getUser());
  1025. } else { // 4、 存在 进行跟新库存
  1026. updateTWhgenlegData(wbItem, tWhgenle1.getfId(), "SJRK");
  1027. }
  1028. }
  1029. wbItem.setfWarehouselocid(warehouselocId);
  1030. wbItem.setfBillstatus(40L);
  1031. } else if ("HQZY".equals(billsType)) { // 货转
  1032. wbItem.setfBillstatus(6L);
  1033. wbItem.setfChargedate(tWarehouseBills.getfChargedate());
  1034. wbItem.setfBillingway(tWarehouseBills.getfBillingway());
  1035. if (StringUtils.isNull(tWhgenle)) { // 为空 提示没有库存
  1036. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1037. return AjaxResult.error("库存明细第" + i + "行库存为空");
  1038. } else { // 非空修改库存总账
  1039. if (tWhgenle.getfQtyblc() < wbItem.getfQty()) { // 1、 库存 < 调拨件数 提示库存不足
  1040. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1041. return AjaxResult.error("库存明细第" + i + "行库存不足");
  1042. } else { // 2、 库存足够 先 进行出库操作
  1043. updateTWhgenlegData(wbItem, tWhgenle.getfId(), "SJCK");
  1044. }
  1045. long corpId = tWarehouseBills.getfCorpid();
  1046. tWarehouseBills.setfCorpid(tWarehouseBills.getfTocorpid());
  1047. // 3、 进行入库操作 查询是否存在库存
  1048. TWhgenleg tWhgenle1 = queryTWhgenleg(tWarehouseBills, wbItem);
  1049. if (StringUtils.isNull(tWhgenle1)) { // 5、 不存在 进行新增库存
  1050. instalTWhgenleg(tWarehouseBills, wbItem, loginUser.getUser());
  1051. } else { // 4、 存在 进行跟新库存
  1052. updateTWhgenlegData(wbItem, tWhgenle1.getfId(), "SJRK");
  1053. }
  1054. tWarehouseBills.setfCorpid(corpId);
  1055. }
  1056. }
  1057. i++;
  1058. int num = 0;
  1059. wbItem.setfPid(fPid);
  1060. wbItem.setfBilltype(billsType);
  1061. wbItem.setfBillno(tWarehouseBills.getfBillno());
  1062. wbItem.setfBsdate(tWarehouseBills.getfBsdate());
  1063. if (StringUtils.isNotNull(wbItem.getfId())) {
  1064. wbItem.setUpdateBy(loginUser.getUser().getUserName());
  1065. wbItem.setUpdateTime(new Date());
  1066. num = tWarehousebillsitemsMapper.updateTWarehousebillsitems(wbItem);
  1067. if ("SJCK".equals(billsType)) {
  1068. // 添加状态log
  1069. insertTWarehousebillsLog(wbItem, 40L, loginUser);
  1070. }
  1071. } else {
  1072. wbItem.setCreateTime(new Date());
  1073. wbItem.setCreateBy(loginUser.getUsername());
  1074. num = tWarehousebillsitemsMapper.insertTWarehousebillsitems(wbItem);
  1075. }
  1076. if (num <= 0) {
  1077. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1078. return AjaxResult.error("库存明细更新失败");
  1079. }
  1080. }
  1081. // 附件添加
  1082. if (StringUtils.isNotEmpty(tEnclosure) && !"[]".equals(tEnclosure)) {
  1083. JSONArray jsonDrArray = JSONArray.parseArray(tEnclosure);
  1084. List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
  1085. for (TEnclosure enclosure : tEnclosureList) {
  1086. enclosure.setfPid(tWarehouseBills.getfId());
  1087. enclosure.setCreateBy(loginUser.getUser().getUserName());
  1088. enclosure.setCreateTime(new Date());
  1089. tEnclosureMapper.insertTEnclosure(enclosure);
  1090. }
  1091. }
  1092. // 收款明细添加
  1093. if (StringUtils.isNotEmpty(warehousebillsfeesDr) && !"[]".equals(warehousebillsfeesDr)) {
  1094. JSONArray jsonDrArray = JSONArray.parseArray(warehousebillsfeesDr);
  1095. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
  1096. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  1097. wbDr.setfPid(tWarehouseBills.getfId());
  1098. wbDr.setfDc("D");
  1099. wbDr.setCreateBy(loginUser.getUser().getUserName());
  1100. wbDr.setCreateTime(new Date());
  1101. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  1102. }
  1103. }
  1104. // 付款明细添加
  1105. if (StringUtils.isNotNull(warehousebillsfeesCr) && !"[]".equals(warehousebillsfeesCr)) {
  1106. JSONArray jsonCrArray = JSONArray.parseArray(warehousebillsfeesCr);
  1107. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  1108. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  1109. wbCr.setfPid(tWarehouseBills.getfId());
  1110. wbCr.setfDc("C");
  1111. wbCr.setCreateBy(loginUser.getUser().getUserName());
  1112. wbCr.setCreateTime(new Date());
  1113. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  1114. }
  1115. }
  1116. map.put("fPid", fPid);
  1117. map.put("warehouse", tWarehouseBills);
  1118. map.put("warehouseItem", warehousebillsitemsList);
  1119. map.put("fees", feesList);
  1120. map.put("warehousebillsfees", warehousebillsfees);
  1121. // 添加成功 主键返回 前台
  1122. return AjaxResult.success("成功", map);
  1123. }
  1124. /**
  1125. * 打印作业单
  1126. *
  1127. * @param warehouseBills
  1128. * @param warehousebillsitems
  1129. * @param tEnclosure
  1130. * @param tWarehousebillsfeesCr
  1131. * @param tWarehousebillsfeesDr
  1132. * @param loginUser
  1133. * @param status
  1134. * @param billtystatus
  1135. * @return
  1136. */
  1137. @Override
  1138. public AjaxResult waitWarehousing(String warehouseBills, String warehousebillsitems,
  1139. String tEnclosure, String tWarehousebillsfeesCr, String tWarehousebillsfeesDr,
  1140. LoginUser loginUser, Long status, String billtystatus) {
  1141. Map<String, Object> map = new HashMap<>();
  1142. if (StringUtils.isNull(warehouseBills) || "[]".equals(warehouseBills)) {
  1143. return AjaxResult.error("未找到主表信息");
  1144. }
  1145. if (StringUtils.isNull(warehousebillsitems) || "[]".equals(warehousebillsitems)) {
  1146. return AjaxResult.error("未找到入账信息");
  1147. }
  1148. TWarehouseBills tWarehouseBills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  1149. if (status.equals(20L)) {
  1150. tWarehouseBills.setfItemsStatus(2L);
  1151. } else {
  1152. tWarehouseBills.setfItemsStatus(3L);
  1153. }
  1154. if (StringUtils.isNotNull(tWarehouseBills.getfId())) {
  1155. tWarehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  1156. tWarehouseBills.setUpdateTime(new Date());
  1157. tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  1158. }
  1159. tEnclosureMapper.deleteByFPid(tWarehouseBills.getfId());
  1160. tWarehousebillsfeesMapper.deleteByFPid(tWarehouseBills.getfId());
  1161. JSONArray warehouseJSON = JSONArray.parseArray(warehousebillsitems);
  1162. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  1163. for (TWarehousebillsitems item : warehousebillsitemsList) {
  1164. // 生成流水号
  1165. Date time = new Date();
  1166. String serialNumber;
  1167. if (item.getfBillstatus() < 30L) {
  1168. if ("RK".equals(billtystatus)) { // 生成 入库 流水号
  1169. serialNumber = billnoSerialServiceImpl.getSerialNumber("RK", time);
  1170. item.setfSerialNumber(serialNumber);
  1171. } else if ("CK".equals(billtystatus)) { //生成 出库 流水号
  1172. serialNumber = billnoSerialServiceImpl.getSerialNumber("CK", time);
  1173. item.setfSerialNumber(serialNumber);
  1174. } else if ("DB".equals(billtystatus)) { //生成 出库 流水号
  1175. serialNumber = billnoSerialServiceImpl.getSerialNumber("DB", time);
  1176. item.setfSerialNumber(serialNumber);
  1177. }
  1178. item.setfBillstatus(status);
  1179. item.setUpdateTime(new Date());
  1180. item.setUpdateBy(loginUser.getUser().getUserName());
  1181. int num = tWarehousebillsitemsMapper.updateTWarehousebillsitems(item);
  1182. // 添加状态log
  1183. insertTWarehousebillsLog(item, status, loginUser);
  1184. if (num <= 0) {
  1185. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1186. return AjaxResult.error("更新库存明细失败");
  1187. }
  1188. }
  1189. }
  1190. // 附件添加
  1191. if (StringUtils.isNotEmpty(tEnclosure) && !"[]".equals(tEnclosure)) {
  1192. JSONArray jsonDrArray = JSONArray.parseArray(tEnclosure);
  1193. List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
  1194. for (TEnclosure enclosure : tEnclosureList) {
  1195. enclosure.setfPid(tWarehouseBills.getfId());
  1196. enclosure.setCreateBy(loginUser.getUser().getUserName());
  1197. enclosure.setCreateTime(new Date());
  1198. tEnclosureMapper.insertTEnclosure(enclosure);
  1199. }
  1200. }
  1201. // 收款明细添加
  1202. if (StringUtils.isNotEmpty(tWarehousebillsfeesDr) && !"[]".equals(tWarehousebillsfeesDr)) {
  1203. JSONArray jsonDrArray = JSONArray.parseArray(tWarehousebillsfeesDr);
  1204. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
  1205. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  1206. wbDr.setfPid(tWarehouseBills.getfId());
  1207. wbDr.setfDc("D");
  1208. wbDr.setCreateBy(loginUser.getUser().getUserName());
  1209. wbDr.setCreateTime(new Date());
  1210. if(tWarehouseBills.getfBsdate()!=null&& !tWarehouseBills.getfBsdate().equals("")){
  1211. wbDr.setfBsdate(tWarehouseBills.getfBsdate());
  1212. }
  1213. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  1214. }
  1215. }
  1216. // 付款明细添加
  1217. if (StringUtils.isNotNull(tWarehousebillsfeesCr) && !"[]".equals(tWarehousebillsfeesCr)) {
  1218. JSONArray jsonCrArray = JSONArray.parseArray(tWarehousebillsfeesCr);
  1219. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  1220. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  1221. wbCr.setfPid(tWarehouseBills.getfId());
  1222. wbCr.setfDc("C");
  1223. wbCr.setCreateBy(loginUser.getUser().getUserName());
  1224. wbCr.setCreateTime(new Date());
  1225. if(tWarehouseBills.getfBsdate()!=null&& !tWarehouseBills.getfBsdate().equals("")){
  1226. wbCr.setfBsdate(tWarehouseBills.getfBsdate());
  1227. }
  1228. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  1229. }
  1230. }
  1231. // 添加成功 返回 前台
  1232. TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
  1233. tWarehousebillsitems.setfPid(tWarehouseBills.getfId());
  1234. List<TWarehousebillsitems> mapList = tWarehousebillsitemsMapper.selectTWarehousebillsitemsList(tWarehousebillsitems);
  1235. map.put("warehousebillsitems", mapList);
  1236. return AjaxResult.success("成功", map);
  1237. }
  1238. /**
  1239. * 生成计算仓储费信息
  1240. * @param warehouseBills
  1241. * @param mapItem
  1242. * @param loginUser
  1243. * @return
  1244. */
  1245. public Map<String, Object> getWarehouseItems(TWarehouseBills warehouseBills, List<Map<String, Object>> mapItem, LoginUser loginUser) {
  1246. Map<String, Object> map = new HashMap<>();
  1247. long feeId = 0L;
  1248. BigDecimal sumAmt = new BigDecimal(0);
  1249. List<TWarehousebillsfees> itemsList = new ArrayList<>();
  1250. List<SysDictData> taxRate = sysDictDataMapper.selectDictDataByType("tax_rate");
  1251. for (Map<String, Object> item : mapItem) {
  1252. if (StringUtils.isNull(item.get("fBillingway"))) {
  1253. map.put("error", "单号:" + item.get("fBillno") + ",业务日期:" + item.get("fBsdate") + "未找到库存总账的计费单位,请确认");
  1254. return map;
  1255. }
  1256. long fCorpid = warehouseBills.getfCorpid();
  1257. String fBilltype = (String) item.get("fBilltype");
  1258. long fGoodsid = Long.parseLong((String) item.get("fTypeid"));
  1259. long fId = Long.valueOf(String.valueOf(item.get("fId"))).longValue();
  1260. // 累计计费天数
  1261. long accumulatedDays = DateUtils.getDateDay((Date) item.get("fChargedate"), (Date) item.get("fOriginalbilldate"));
  1262. // 库存天数
  1263. long fInventoryDays = 0L;
  1264. // 要计费天数
  1265. long fBillingDays = DateUtils.getDateDay(warehouseBills.getfBillingDeadline(), (Date) item.get("fOriginalbilldate"));
  1266. if ("SJCK".equals(fBilltype)) {
  1267. fInventoryDays = DateUtils.getDateDay((Date) item.get("fBsdate"), (Date) item.get("fOriginalbilldate"));
  1268. fBillingDays = DateUtils.getDateDay((Date) item.get("fChargedate"), (Date) item.get("fChargedate"));
  1269. } else if ("HQZY".equals(fBilltype)) {
  1270. fInventoryDays = DateUtils.getDateDay(warehouseBills.getfBillingDeadline(), (Date) item.get("fBsdate"));
  1271. } else {
  1272. fBillingDays = DateUtils.getDateDay(warehouseBills.getfBillingDeadline(), (Date) item.get("fChargedate"));
  1273. fInventoryDays = DateUtils.getDateDay(warehouseBills.getfBillingDeadline(), (Date) item.get("fOriginalbilldate"));
  1274. }
  1275. /*if ("KCZZ".equals(fBilltype)) {
  1276. } else {
  1277. fInventoryDays = Long.valueOf(String.valueOf(item.get("fBillingDays")));
  1278. }*/
  1279. Long dictLabel = Long.valueOf(String.valueOf(item.get("fBillingway")));
  1280. BigDecimal fQty = acquiredQuantity(item, dictLabel);
  1281. if (fQty.equals(BigDecimal.ZERO)) {
  1282. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1283. return AjaxResult.error("单号:" + item.get("fBillno") + ",业务日期:" + item.get("fBsdate") + "未找到计费单位,请确认");
  1284. }
  1285. // 计算仓储费明细
  1286. Map<String, Object> objectMap = tWarehouseAgreementService.getCarryingCost(fCorpid, fGoodsid, fBillingDays, dictLabel, fQty, accumulatedDays);
  1287. if (StringUtils.isNull(objectMap)) {
  1288. map.put("error", "单号:" + item.get("fBillno") + ",业务日期:" + item.get("fBsdate") + "未找到仓储费协议,请确认");
  1289. return map;
  1290. }
  1291. String mblno = "";
  1292. if (StringUtils.isNotNull(item.get("fMblno"))) {
  1293. mblno = item.get("fMblno").toString();
  1294. }
  1295. String remark = objectMap.get("remark").toString();
  1296. feeId = Long.valueOf(String.valueOf(objectMap.get("feeId"))).longValue();
  1297. BigDecimal amt = (BigDecimal) objectMap.get("amt");
  1298. map.put("feeId", feeId);
  1299. map.put("itemFeeId", objectMap.get("feeId"));
  1300. sumAmt = sumAmt.add(amt).setScale(2, BigDecimal.ROUND_HALF_UP);
  1301. TWarehousebillsfees fees = new TWarehousebillsfees();
  1302. fees.setfFeeid(feeId);
  1303. fees.setfDc("D");
  1304. fees.setfAmt(amt);
  1305. fees.setSrcId(fId);
  1306. fees.setfMblno(mblno);
  1307. fees.setRemark(remark);
  1308. fees.setfFeeunitid(2L);
  1309. fees.setfAmount(sumAmt);
  1310. fees.setfBillstatus(2L);
  1311. fees.setfCurrency("RMB");
  1312. fees.setfBillingQty(fQty);
  1313. fees.setfUnitprice(sumAmt);
  1314. fees.setfBilltype(fBilltype);
  1315. fees.setfBillingDays(fBillingDays);
  1316. fees.setCreateTime(new Date());
  1317. fees.setfQty(new BigDecimal(1));
  1318. fees.setfPid(warehouseBills.getfId());
  1319. fees.setfInventoryDays(fInventoryDays);
  1320. fees.setfExrate(new BigDecimal(1));
  1321. fees.setfBsdate((Date) item.get("fBsdate"));
  1322. fees.setfCorpid(warehouseBills.getfCorpid());
  1323. fees.setfMarks(item.get("fMarks").toString());
  1324. fees.setSrcBillNo((String) item.get("fBillno"));
  1325. fees.setfChargedate((Date) item.get("fChargedate"));
  1326. fees.setCreateBy(loginUser.getUser().getUserName());
  1327. fees.setfProductName(item.get("fGoodsids").toString());
  1328. fees.setfBillingDeadline(warehouseBills.getfBillingDeadline());
  1329. fees.setfTaxrate(new BigDecimal(taxRate.get(0).getDictValue()));
  1330. fees.setfOriginalbilldate((Date) item.get("fOriginalbilldate"));
  1331. fees.setfBillingway(Long.valueOf(String.valueOf(item.get("fBillingway"))).longValue());
  1332. tWarehousebillsfeesMapper.insertTWarehousebillsfees(fees);
  1333. itemsList.add(fees);
  1334. }
  1335. map.put("sumAmt", sumAmt);
  1336. map.put("itemsList", itemsList);
  1337. return map;
  1338. }
  1339. /**
  1340. * 新增库存费计算
  1341. *
  1342. * @param tWarehouseBills 主表的查询条件
  1343. * @param loginUser 登录用户
  1344. * @param billsType 状态
  1345. * @return 结果
  1346. */
  1347. @Override
  1348. @Transactional
  1349. public AjaxResult calculateStorageFees(TWarehouseBills tWarehouseBills, LoginUser loginUser, String billsType) {
  1350. if (StringUtils.isNull(tWarehouseBills.getfCorpid())) {
  1351. return AjaxResult.error("请选择客户信息");
  1352. }
  1353. long fPid = 0L;
  1354. if (StringUtils.isNull(tWarehouseBills.getfId())) {
  1355. // 生成流水号
  1356. Date time = new Date();
  1357. String billNo = billnoSerialServiceImpl.getSerialNumber("JSCCF", time);
  1358. tWarehouseBills.setfBillno(billNo);
  1359. if (StringUtils.isNull(tWarehouseBills.getfBillstatus())) {
  1360. tWarehouseBills.setfBillstatus(2L);
  1361. }
  1362. tWarehouseBills.setfBilltype(billsType);
  1363. tWarehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
  1364. tWarehouseBills.setCreateBy(loginUser.getUser().getUserName());
  1365. tWarehouseBills.setCreateTime(new Date());
  1366. tWarehouseBillsMapper.insertTWarehousebills(tWarehouseBills);
  1367. fPid = tWarehouseBills.getfId();
  1368. } else {
  1369. tWarehousebillsfeesMapper.deleteByFPid(tWarehouseBills.getfId());
  1370. tWarehousebillsitemsMapper.deleteByFPid(tWarehouseBills.getfId());
  1371. tWarehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  1372. tWarehouseBills.setUpdateTime(new Date());
  1373. tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  1374. fPid = tWarehouseBills.getfId();
  1375. }
  1376. // 计划物资明细
  1377. List<TWarehousebillsfees> itemsList = new ArrayList<>();
  1378. BigDecimal bigDecimal = new BigDecimal(0);
  1379. Map<String, Object> map = new HashMap<>();
  1380. // 库存总账id
  1381. long whgenlegFeeId = 0;
  1382. // 计费单位
  1383. long feeUnitid = 1;
  1384. // 查询 出库 货转的库存明细
  1385. List<Map<String, Object>> warehousebillsitemsList = tWarehousebillsitemsMapper.selectStorageFeeItemList(tWarehouseBills);
  1386. if (warehousebillsitemsList.size() != 0) {
  1387. Map<String, Object> mapItem = getWarehouseItems(tWarehouseBills, warehousebillsitemsList, loginUser);
  1388. if (mapItem.containsKey("error")) {
  1389. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1390. return AjaxResult.error((String) mapItem.get("error"));
  1391. }
  1392. itemsList = (List<TWarehousebillsfees>) mapItem.get("itemsList");
  1393. }
  1394. List<Map<String, Object>> tWhgenlegs = tWhgenlegMapper.selectStorageFeeItemList(tWarehouseBills);
  1395. if (tWhgenlegs.size() != 0) {
  1396. Map<String, Object> mapItem = getWarehouseItems(tWarehouseBills, tWhgenlegs, loginUser);
  1397. if (mapItem.containsKey("error")) {
  1398. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1399. return AjaxResult.error((String) mapItem.get("error"));
  1400. }
  1401. List<TWarehousebillsfees> itemList = (List<TWarehousebillsfees>) mapItem.get("itemsList");
  1402. if (itemList.size() != 0) {
  1403. for (TWarehousebillsfees ite : itemList) {
  1404. itemsList.add(ite);
  1405. }
  1406. }
  1407. }
  1408. TFees tFees = new TFees();
  1409. tFees.setfStatus("2");
  1410. tFees.setDelFlag("0");
  1411. List<TFees> feesList = tFeesMapper.selectTFeesList(tFees);
  1412. if (itemsList.size() <= 0) {
  1413. return AjaxResult.error("未找到合适的库存明细");
  1414. }
  1415. map.put("feesList", feesList);
  1416. map.put("warehouseBills", tWarehouseBills);
  1417. map.put("warehouseItemList", itemsList);
  1418. return AjaxResult.success(map);
  1419. }
  1420. /**
  1421. * 仓储费计算提交以及暂存
  1422. *
  1423. * @param warehouseBills
  1424. * @param warehouseItems
  1425. * @param warehouseFees
  1426. * @param loginUser
  1427. * @param billsType
  1428. * @return
  1429. */
  1430. @Override
  1431. @Transactional
  1432. public AjaxResult insertStorageFee(String warehouseBills, String warehouseItems, String warehouseFees, LoginUser loginUser, String billsType) {
  1433. TWarehouseBills tWarehousebills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  1434. long fPid = 0L;
  1435. boolean billstatus = tWarehousebills.getfBillstatus().equals(4L);
  1436. if (billstatus && (StringUtils.isNull(warehouseItems) || "[]".equals(warehouseItems))) {
  1437. return AjaxResult.error("未找到计费物资明细无法提交");
  1438. }
  1439. /*if (billstatus && (StringUtils.isNull(warehouseFees) || "[]".equals(warehouseFees))) {
  1440. return AjaxResult.error("未找到应收款明细无法提交");
  1441. }*/
  1442. if (StringUtils.isNotNull(tWarehousebills.getfId())) {
  1443. fPid = tWarehousebills.getfId();
  1444. tWarehousebills.setUpdateTime(new Date());
  1445. tWarehousebills.setUpdateBy(loginUser.getUser().getUserName());
  1446. tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1447. tWarehousebillsfeesMapper.deleteByFPid(fPid);
  1448. tWarehousebillsitemsMapper.deleteByFPid(fPid);
  1449. } else {
  1450. // 生成流水号
  1451. Date time = new Date();
  1452. String billNo = billnoSerialServiceImpl.getSerialNumber("JSCCF", time);
  1453. tWarehousebills.setfBillno(billNo);
  1454. tWarehousebills.setfDeptid(loginUser.getUser().getDeptId());
  1455. tWarehousebills.setfBsdeptid(loginUser.getUser().getDeptId());
  1456. tWarehousebills.setCreateBy(loginUser.getUser().getUserName());
  1457. tWarehousebills.setCreateTime(new Date());
  1458. tWarehousebills.setfBilltype(billsType);
  1459. tWarehouseBillsMapper.insertTWarehousebills(tWarehousebills);
  1460. fPid = tWarehousebills.getfId();
  1461. }
  1462. JSONArray warehouseJSON = JSONArray.parseArray(warehouseItems);
  1463. List<TWarehousebillsfees> itemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsfees.class);
  1464. for (TWarehousebillsfees item : itemsList) {
  1465. item.setfId(null);
  1466. item.setSrcBillNo(tWarehousebills.getfBillno());
  1467. item.setfPid(fPid);
  1468. item.setfBillstatus(tWarehousebills.getfBillstatus());
  1469. tWarehousebillsfeesMapper.insertTWarehousebillsfees(item);
  1470. }
  1471. if (StringUtils.isNotNull(warehouseFees) && !"[]".equals(warehouseFees)) {
  1472. JSONArray feesJSON = JSONArray.parseArray(warehouseFees);
  1473. List<TWarehousebillsfees> warehousebillsfeesList = JSONObject.parseArray(feesJSON.toJSONString(), TWarehousebillsfees.class);
  1474. for (TWarehousebillsfees fees : warehousebillsfeesList) {
  1475. fees.setfId(null);
  1476. fees.setfPid(fPid);
  1477. fees.setfDc("D");
  1478. fees.setfBilltype("JSCCF");
  1479. fees.setSrcBillNo(tWarehousebills.getfBillno());
  1480. fees.setfBillstatus(tWarehousebills.getfBillstatus());
  1481. tWarehousebillsfeesMapper.insertTWarehousebillsfees(fees);
  1482. }
  1483. }
  1484. if (billstatus) {
  1485. String key = "warehouse.storageFeeCalculation.ApprovalFlow";
  1486. SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key);
  1487. if (StringUtils.isNull(sysConfig)) {
  1488. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1489. return AjaxResult.error("系统参数异常,未找到开启审批流参数");
  1490. }
  1491. if ("0".equals(sysConfig.getConfigValue())) {
  1492. AuditItems auditItems = new AuditItems();
  1493. auditItems.setLevelId(0L);
  1494. auditItems.setBillId(fPid);
  1495. auditItems.setActId(150L);
  1496. auditItems.setIffinalItem("F");
  1497. auditItems.setBillNo(tWarehousebills.getfBillno());
  1498. // 存储委托方(货权方)
  1499. auditItems.setRefno1(tWarehousebills.getfCorpid() + "");
  1500. // 存储业务类型(业务类型)
  1501. auditItems.setRefno2(tWarehousebills.getfBilltype());
  1502. // 存储提单号(提单号)
  1503. auditItems.setRefno3(tWarehousebills.getfMblno());
  1504. auditItems.setSendUserId(loginUser.getUser().getUserId());
  1505. auditItems.setSendName(loginUser.getUsername());
  1506. auditItems.setSendTime(new Date());
  1507. auditItems.setAuditUserId(loginUser.getUser().getUserId());
  1508. auditItems.setAuditItem(new Date());
  1509. auditItems.setAuditOpTime(new Date());
  1510. auditItems.setAuditMsg("提交");
  1511. auditItems.setAuditStatus("O");
  1512. AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems);
  1513. String code = approvalFlow.get("code").toString();
  1514. // Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue();
  1515. if ("500".equals(code)) {
  1516. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1517. }
  1518. return approvalFlow;
  1519. } else {
  1520. AjaxResult ajaxResult = storageFeeFollow(fPid, 6L);
  1521. String code = ajaxResult.get("code").toString();
  1522. // Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue();
  1523. if ("500".equals(code)) {
  1524. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1525. }
  1526. return ajaxResult;
  1527. }
  1528. }
  1529. return AjaxResult.success(tWarehousebills);
  1530. }
  1531. /**
  1532. * 根据id查询仓储费计算信息
  1533. *
  1534. * @param fId
  1535. * @return
  1536. */
  1537. @Override
  1538. public AjaxResult selectStorageFeeById(Long fId) {
  1539. TWarehouseBills tWarehouseBills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  1540. if (StringUtils.isNull(tWarehouseBills)) {
  1541. return AjaxResult.error("未找到信息,请刷新页面重试");
  1542. }
  1543. Map<String, Object> map = new HashMap<>();
  1544. List<TWarehousebillsfees> feesList = new ArrayList<>();
  1545. List<TWarehousebillsfees> itemsList = new ArrayList<>();
  1546. TWarehousebillsfees warehousebillsfees = new TWarehousebillsfees();
  1547. warehousebillsfees.setfPid(fId);
  1548. List<TWarehousebillsfees> warehouseFeesList = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(warehousebillsfees);
  1549. for (TWarehousebillsfees fees : warehouseFeesList) {
  1550. if (StringUtils.isNotNull(fees.getSrcId())) {
  1551. itemsList.add(fees);
  1552. } else {
  1553. feesList.add(fees);
  1554. }
  1555. }
  1556. TGoods tGoods = new TGoods();
  1557. tGoods.setfStatus("0");
  1558. tGoods.setDelFlag("0");
  1559. List<TGoods> goods = tGoodsMapper.selectTGoodsList(tGoods);
  1560. TFees tFees = new TFees();
  1561. tFees.setfStatus("2");
  1562. tFees.setDelFlag("0");
  1563. List<TFees> feesLists = tFeesMapper.selectTFeesList(tFees);
  1564. // 查询联系人
  1565. List<SysUser> sysUserList = new ArrayList<>();
  1566. SysUser sysUser = sysUserMapper.selectUserByUserName(tWarehouseBills.getCreateBy());
  1567. if (StringUtils.isNotNull(sysUser)) {
  1568. sysUserList.add(sysUser);
  1569. }
  1570. TCorps corps = tCorpsMapper.selectTCorpsById(tWarehouseBills.getfCorpid());
  1571. map.put("corps", corps);
  1572. map.put("goodsList", goods);
  1573. map.put("feesList", feesLists);
  1574. map.put("sysUser", sysUserList);
  1575. map.put("warehouse", tWarehouseBills);
  1576. map.put("warehouseFeesList", feesList);
  1577. map.put("warehouseItemsList", itemsList);
  1578. return AjaxResult.success(map);
  1579. }
  1580. /**
  1581. * 根据不同计费单位获取不同 计算库存明细数量
  1582. *
  1583. * @param item 库存明细
  1584. * @param dictLabel 计费单位
  1585. * @return 结果
  1586. */
  1587. public BigDecimal acquiredQuantity(Map<String, Object> item, Long dictLabel) {
  1588. BigDecimal fQty = new BigDecimal(0);
  1589. // 件数
  1590. long boxNum = 1;
  1591. // 毛重
  1592. long grossWeight = 2;
  1593. // 净重
  1594. long netWeight = 3;
  1595. // 尺码
  1596. long size = 4;
  1597. // 统一
  1598. long fixed = 5;
  1599. if (dictLabel.equals(boxNum)) {
  1600. fQty = new BigDecimal(((Number) item.get("fQty")).doubleValue());
  1601. return fQty.setScale(2, BigDecimal.ROUND_HALF_UP);
  1602. } else if (dictLabel.equals(grossWeight)) {
  1603. fQty = new BigDecimal(((Number) item.get("fGrossweight")).doubleValue());
  1604. } else if (dictLabel.equals(netWeight)) {
  1605. fQty = new BigDecimal(((Number) item.get("fNetweight")).doubleValue());
  1606. } else if (dictLabel.equals(size)) {
  1607. fQty = new BigDecimal(((Number) item.get("fVolumn")).doubleValue());
  1608. } else if (dictLabel.equals(fixed)) {
  1609. fQty = new BigDecimal(1);
  1610. }
  1611. //return fQty.setScale(2, BigDecimal.ROUND_HALF_UP);
  1612. // 结果值除以1000 保留两位
  1613. BigDecimal divisor = new BigDecimal("1000");
  1614. BigDecimal result = fQty.divide(divisor,2,BigDecimal.ROUND_HALF_UP);
  1615. return result;
  1616. }
  1617. // 入库 收费明细 校验
  1618. public Long check(BigDecimal number, BigDecimal unitPrice) {
  1619. BigDecimal result1 = number.multiply(unitPrice);
  1620. // 保留两位小数且四舍五入
  1621. result1 = result1.setScale(2, BigDecimal.ROUND_HALF_UP);
  1622. // 转换去掉小数点
  1623. String result = result1.toString().replace(".", "");
  1624. return Long.valueOf(result);
  1625. }
  1626. /**
  1627. * 修改详情主表
  1628. *
  1629. * @param tWarehousebills 详情主表
  1630. * @return 结果
  1631. */
  1632. @Override
  1633. public int updateTWarehousebills(TWarehouseBills tWarehousebills) {
  1634. tWarehousebills.setUpdateTime(DateUtils.getNowDate());
  1635. return tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1636. }
  1637. /**
  1638. * 批量删除详情主表
  1639. *
  1640. * @param fIds 需要删除的详情主表ID
  1641. * @return 结果
  1642. */
  1643. @Override
  1644. public int deleteTWarehousebillsByIds(Long[] fIds) {
  1645. // 取出业务编号、 放入 billno_del
  1646. for (Long id : fIds) {
  1647. // 1、查询主表信息
  1648. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(id);
  1649. // 2、业务编号、客存编号 放入 billno_del
  1650. BillnoDel billnoDel = new BillnoDel();
  1651. billnoDel.setBillType(tWarehousebills.getfBilltype());
  1652. billnoDel.setBillNo(tWarehousebills.getfBillno());
  1653. billnoDelMapper.insertBillnoDel(billnoDel);
  1654. }
  1655. return tWarehouseBillsMapper.deleteTWarehousebillsByIds(fIds);
  1656. }
  1657. @Override
  1658. public AjaxResult queryRemove(Long fId) {
  1659. // 查询主表明细
  1660. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  1661. // 查询仓库明细从表数据
  1662. TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
  1663. tWarehousebillsitems.setfPid(tWarehousebills.getfId());
  1664. List<Map<String, Object>> mapList = tWarehousebillsitemsMapper.selectGoodsTransferitemsList(tWarehousebillsitems);
  1665. // 查询仓库费用明细表数据
  1666. TWarehousebillsfees tWarehousebillsfees = new TWarehousebillsfees();
  1667. tWarehousebillsfees.setfPid(tWarehousebills.getfId());
  1668. List<TWarehousebillsfees> warehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(tWarehousebillsfees);
  1669. // 查询附件表数据
  1670. TEnclosure enclosure = new TEnclosure();
  1671. enclosure.setfPid(tWarehousebills.getfId());
  1672. List<TEnclosure> enclosures = tEnclosureMapper.selectTEnclosureList(enclosure);
  1673. if (StringUtils.isNull(tWarehousebills)) {
  1674. return AjaxResult.success("0");
  1675. } else if (StringUtils.isNotNull(tWarehousebills)
  1676. && StringUtils.isEmpty(warehousebillsfees)
  1677. && StringUtils.isEmpty(enclosures)
  1678. && StringUtils.isEmpty(mapList)) {
  1679. return AjaxResult.success("1");
  1680. } else {
  1681. return AjaxResult.success("2");
  1682. }
  1683. }
  1684. /**
  1685. * 删除详情主表信息
  1686. *
  1687. * @param fId 详情主表ID
  1688. * @return 结果
  1689. */
  1690. @Override
  1691. public int deleteTWarehousebillsById(Long fId) {
  1692. return tWarehouseBillsMapper.deleteTWarehousebillsById(fId);
  1693. }
  1694. @Override
  1695. public String getWarehouseInStockBillsNo(TWarehouseBills tWarehouseBills) {
  1696. return null;
  1697. }
  1698. @Override
  1699. public String getWarehouseOutStockBillsNo(TWarehouseBills tWarehouseBills) {
  1700. return null;
  1701. }
  1702. /**
  1703. * 撤销入库
  1704. *
  1705. * @param fId
  1706. * @param loginUser
  1707. * @param billsType
  1708. * @return
  1709. */
  1710. @Override
  1711. @Transactional
  1712. public AjaxResult revokeTWarehousebillsById(Long fId, LoginUser loginUser, String billsType) {
  1713. // 查询 仓库主表信息、库存明细信息
  1714. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  1715. // 修改主表信息
  1716. tWarehousebills.setUpdateBy(loginUser.getUser().getUserName());
  1717. tWarehousebills.setUpdateTime(new Date());
  1718. tWarehousebills.setfBillstatus(2L); //撤销状态
  1719. tWarehousebills.setfReviewDate(null);// 审核通过时间清空
  1720. tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1721. tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(tWarehousebills.getfId(), 2L,new Date());
  1722. return AjaxResult.success();
  1723. }
  1724. /**
  1725. * 撤销入账
  1726. *
  1727. * @param warehouseBills 主表
  1728. * @param warehousebillsitems 明细
  1729. * @param loginUser 当前登录人
  1730. * @param billsType 状态
  1731. * @return 结果
  1732. */
  1733. @Override
  1734. @Transactional
  1735. public AjaxResult revokeTWarehousebillsById1(String warehouseBills, String warehousebillsitems, String tEnclosure,
  1736. String warehousebillsfeesCr, String warehousebillsfeesDr, LoginUser loginUser, String billsType) {
  1737. if (StringUtils.isNull(warehouseBills) || "[]".equals(warehouseBills)) {
  1738. return AjaxResult.error("未找到主表信息");
  1739. }
  1740. if (StringUtils.isNull(warehousebillsitems) || "[]".equals(warehousebillsitems)) {
  1741. return AjaxResult.error("未找到入账信息");
  1742. }
  1743. TWarehouseBills tWarehousebills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  1744. tWarehousebills.setfItemsStatus(2L);
  1745. tWarehousebills.setfItemsStatus(1L); //撤销状态
  1746. tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1747. tEnclosureMapper.deleteByFPid(tWarehousebills.getfId());
  1748. tWarehousebillsfeesMapper.deleteByFPid(tWarehousebills.getfId());
  1749. JSONArray warehouseJSON = JSONArray.parseArray(warehousebillsitems);
  1750. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  1751. if (StringUtils.isNotEmpty(warehousebillsitemsList)) {
  1752. int i = 1;
  1753. for (TWarehousebillsitems wb : warehousebillsitemsList) {
  1754. // 查询库存总账
  1755. TWhgenleg tWhgenle = queryTWhgenleg(tWarehousebills, wb);
  1756. if ("SJRKRevoke".equals(billsType)) { // 撤销 入库
  1757. if (wb.getfIsInventory().equals(0L)) {
  1758. if (StringUtils.isNotNull(tWhgenle) && (wb.getfQty() <= tWhgenle.getfQtyblc())) { // 非空 且 撤销数 <= 结余数
  1759. updateTWhgenlegData(wb, tWhgenle.getfId(), billsType);
  1760. } else { // 撤销数>结余数
  1761. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1762. return AjaxResult.error("第" + i + "行撤销数大于库存结余数");
  1763. }
  1764. }
  1765. wb.setfBillstatus(10L);
  1766. } else if ("SJCKRevoke".equals(billsType)) { // 撤销出库
  1767. if (StringUtils.isNotNull(tWhgenle)) { // 非空
  1768. updateTWhgenlegData(wb, tWhgenle.getfId(), billsType);
  1769. } else {
  1770. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1771. return AjaxResult.error("第" + i + "行未查询到库存信息");
  1772. }
  1773. wb.setfBillstatus(10L);
  1774. } else if ("CKDBRevoke".equals(billsType)) { // 调拨 撤销
  1775. Long warehouselocid = wb.getfWarehouselocid();// 原货仓库
  1776. Long transferWarehouselocid = wb.getfTransferWarehouselocid(); // 新仓库
  1777. // 1、新货权方撤销入库
  1778. // 查询库存总账
  1779. wb.setfWarehouselocid(transferWarehouselocid);
  1780. TWhgenleg tWhgenle1 = queryTWhgenleg(tWarehousebills, wb);
  1781. if (StringUtils.isNotNull(tWhgenle1) && (wb.getfQty() <= tWhgenle1.getfQtyblc())) {
  1782. updateTWhgenlegData(wb, tWhgenle1.getfId(), "SJRKRevoke");
  1783. } else {
  1784. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1785. return AjaxResult.error("第" + i + "行撤销数大于库存结余数");
  1786. }
  1787. // 2、原货权方撤销出库
  1788. // 查询库存总账
  1789. wb.setfWarehouselocid(warehouselocid);
  1790. TWhgenleg tWhgenle2 = queryTWhgenleg(tWarehousebills, wb);
  1791. updateTWhgenlegData(wb, tWhgenle2.getfId(), "SJCKRevoke");
  1792. wb.setfBillstatus(10L);
  1793. } else if ("HQZYRevoke".equals(billsType)) { // 货转撤销
  1794. Long fCorpid = tWarehousebills.getfCorpid();// 原货权方
  1795. Long fTocorpid = tWarehousebills.getfTocorpid(); // 新货权方
  1796. // 1、新货权方撤销入库
  1797. // 查询库存总账
  1798. tWarehousebills.setfCorpid(fTocorpid);
  1799. TWhgenleg tWhgenle1 = queryTWhgenleg(tWarehousebills, wb);
  1800. if (StringUtils.isNotNull(tWhgenle1) && (wb.getfQty() <= tWhgenle1.getfQtyblc())) {
  1801. updateTWhgenlegData(wb, tWhgenle1.getfId(), "SJRKRevoke");
  1802. } else {
  1803. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1804. return AjaxResult.error("第" + i + "行撤销数大于库存结余数");
  1805. }
  1806. // 2、原货权方撤销出库
  1807. // 查询库存总账
  1808. tWarehousebills.setfCorpid(fCorpid);
  1809. TWhgenleg tWhgenle2 = queryTWhgenleg(tWarehousebills, wb);
  1810. updateTWhgenlegData(wb, tWhgenle2.getfId(), "SJCKRevoke");
  1811. wb.setfBillstatus(1L);
  1812. }
  1813. i++;
  1814. wb.setUpdateBy(loginUser.getUser().getUserName());
  1815. wb.setUpdateTime(new Date());
  1816. if (tWarehousebillsitemsMapper.updateTWarehousebillsitems(wb) <= 0) {
  1817. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1818. return AjaxResult.error("新增库存明细失败");
  1819. }
  1820. }
  1821. }
  1822. // 附件添加
  1823. if (StringUtils.isNotEmpty(tEnclosure) && !"[]".equals(tEnclosure)) {
  1824. JSONArray jsonDrArray = JSONArray.parseArray(tEnclosure);
  1825. List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
  1826. for (TEnclosure enclosure : tEnclosureList) {
  1827. enclosure.setfPid(tWarehousebills.getfId());
  1828. enclosure.setCreateBy(loginUser.getUser().getUserName());
  1829. enclosure.setCreateTime(new Date());
  1830. tEnclosureMapper.insertTEnclosure(enclosure);
  1831. }
  1832. }
  1833. // 收款明细添加
  1834. if (StringUtils.isNotEmpty(warehousebillsfeesDr) && !"[]".equals(warehousebillsfeesDr)) {
  1835. JSONArray jsonDrArray = JSONArray.parseArray(warehousebillsfeesDr);
  1836. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
  1837. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  1838. wbDr.setfPid(tWarehousebills.getfId());
  1839. wbDr.setfDc("D");
  1840. wbDr.setCreateBy(loginUser.getUser().getUserName());
  1841. wbDr.setCreateTime(new Date());
  1842. if(tWarehousebills.getfBsdate()!=null&& !tWarehousebills.getfBsdate().equals("")){
  1843. wbDr.setfBsdate(tWarehousebills.getfBsdate());
  1844. }
  1845. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  1846. }
  1847. }
  1848. // 付款明细添加
  1849. if (StringUtils.isNotNull(warehousebillsfeesCr) && !"[]".equals(warehousebillsfeesCr)) {
  1850. JSONArray jsonCrArray = JSONArray.parseArray(warehousebillsfeesCr);
  1851. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  1852. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  1853. wbCr.setfPid(tWarehousebills.getfId());
  1854. wbCr.setfDc("C");
  1855. wbCr.setCreateBy(loginUser.getUser().getUserName());
  1856. wbCr.setCreateTime(new Date());
  1857. if(tWarehousebills.getfBsdate()!=null&& !tWarehousebills.getfBsdate().equals("")){
  1858. wbCr.setfBsdate(tWarehousebills.getfBsdate());
  1859. }
  1860. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  1861. }
  1862. }
  1863. return AjaxResult.success();
  1864. }
  1865. /**
  1866. * 添加 库存明细状态
  1867. *
  1868. * @param wbItem
  1869. * @param status
  1870. * @param loginUser
  1871. */
  1872. public void insertTWarehousebillsLog(TWarehousebillsitems wbItem, Long status, LoginUser loginUser) {
  1873. // 添加状态log
  1874. TWarehousebillsLog tWarehousebillsLog = new TWarehousebillsLog();
  1875. tWarehousebillsLog.setfPid(wbItem.getfPid());
  1876. tWarehousebillsLog.setfItmeid(wbItem.getfId());
  1877. tWarehousebillsLog.setfItmestatus(status);
  1878. tWarehousebillsLog.setCreateTime(new Date());
  1879. tWarehousebillsLog.setCreateBy(loginUser.getUser().getUserName());
  1880. tWarehousebillsLogMapper.insertTWarehousebillsLog(tWarehousebillsLog);
  1881. }
  1882. /**
  1883. * 删除 库存明细
  1884. *
  1885. * @param fid
  1886. * @param tWarehousebillsitems
  1887. */
  1888. public void deleteBillsitems(Long fid, String tWarehousebillsitems) {
  1889. List<Long> oldList = new ArrayList<Long>();
  1890. List<Long> newList = new ArrayList<Long>();
  1891. // 查询所有从表数据
  1892. TWarehousebillsitems tWarehousebillsitem = new TWarehousebillsitems();
  1893. tWarehousebillsitem.setfPid(fid);
  1894. List<TWarehousebillsitems> warehousebillsitemsList = tWarehousebillsitemsMapper.selectTWarehousebillsitemsList(tWarehousebillsitem);
  1895. warehousebillsitemsList.forEach(wb ->
  1896. oldList.add(wb.getfId())
  1897. );
  1898. // 获取提交从表数据ID
  1899. if (tWarehousebillsitems != null) {
  1900. JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
  1901. List<TWarehousebillsitems> warehousebillsitemsLists = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  1902. warehousebillsitemsLists.forEach(wb ->
  1903. newList.add(wb.getfId())
  1904. );
  1905. }
  1906. // 删除多余的ID
  1907. List<Long> reduce1 = oldList.stream().filter(item -> !newList.contains(item)).collect(toList());
  1908. reduce1.forEach(id ->
  1909. tWarehousebillsitemsMapper.deleteTWarehousebillsitemsById(id)
  1910. );
  1911. }
  1912. /**
  1913. * 库容-结余毛重
  1914. *
  1915. * @param fTotalgross
  1916. * @param fGrossweightblc
  1917. * @return
  1918. */
  1919. public static BigDecimal calculation1(String fTotalgross, String fGrossweightblc) {
  1920. BigDecimal num1 = new BigDecimal(fTotalgross);
  1921. BigDecimal num2 = new BigDecimal(fGrossweightblc);
  1922. BigDecimal result = num1.subtract(num2);
  1923. return result.setScale(2, BigDecimal.ROUND_HALF_UP);
  1924. }
  1925. /**
  1926. * 判断 是否允许 入库
  1927. *
  1928. * @param fId
  1929. */
  1930. public int calculation(Long fId, BigDecimal fGrossweight) {
  1931. // 仓库库容
  1932. TWarehouse tWarehouse = tWarehouseMapper.selectTWarehouseById(fId);
  1933. // 毛重公斤转化为吨
  1934. fGrossweight = fGrossweight.divide(new BigDecimal(1000), 0, BigDecimal.ROUND_HALF_UP);
  1935. // 总账使用
  1936. List<Map<String, Object>> whouseList = tWhgenlegMapper.selectWareHouseListWhouse(fId);
  1937. if (whouseList != null && whouseList.size() > 0) {
  1938. String fTotalgross = null;
  1939. String fGrossweightblc = null;
  1940. for (Map<String, Object> m : whouseList) {
  1941. for (String k : m.keySet()) {
  1942. // 获取毛重库容
  1943. if (k.equals("fTotalgross")) {
  1944. fTotalgross = m.get(k).toString();
  1945. }
  1946. if (k.equals("fGrossweightD")) {
  1947. fGrossweightblc = m.get(k).toString();
  1948. }
  1949. }
  1950. }
  1951. BigDecimal result = calculation1(fTotalgross, fGrossweightblc);
  1952. if (result.compareTo(fGrossweight) == -1) {
  1953. return 0;// 结余库容小于入库数
  1954. } else {
  1955. return 1;
  1956. }
  1957. } else {
  1958. if (tWarehouse.getfTotalgross().compareTo(fGrossweight) == -1) {
  1959. return 0;// 库容小于入库数
  1960. } else {
  1961. return 1;
  1962. }
  1963. }
  1964. }
  1965. }