TWarehouseBillsServiceImpl.java 98 KB

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