TWarehouseBillsServiceImpl.java 98 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028
  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 remark = objectMap.get("remark").toString();
  1290. feeId = Long.valueOf(String.valueOf(objectMap.get("feeId"))).longValue();
  1291. BigDecimal amt = (BigDecimal) objectMap.get("amt");
  1292. map.put("feeId", feeId);
  1293. map.put("itemFeeId", objectMap.get("feeId"));
  1294. sumAmt = sumAmt.add(amt).setScale(2, BigDecimal.ROUND_HALF_UP);
  1295. TWarehousebillsfees fees = new TWarehousebillsfees();
  1296. fees.setfFeeid(feeId);
  1297. fees.setfDc("D");
  1298. fees.setfAmt(amt);
  1299. fees.setSrcId(fId);
  1300. fees.setRemark(remark);
  1301. fees.setfBillstatus(2L);
  1302. fees.setfFeeunitid(2L);
  1303. fees.setfAmount(sumAmt);
  1304. fees.setfCurrency("RMB");
  1305. fees.setfBillingQty(fQty);
  1306. fees.setfUnitprice(sumAmt);
  1307. fees.setfBilltype(fBilltype);
  1308. fees.setfBillingDays(fBillingDays);
  1309. fees.setCreateTime(new Date());
  1310. fees.setfQty(new BigDecimal(1));
  1311. fees.setfPid(warehouseBills.getfId());
  1312. fees.setfInventoryDays(fInventoryDays);
  1313. fees.setfExrate(new BigDecimal(1));
  1314. fees.setfBsdate((Date) item.get("fBsdate"));
  1315. fees.setfCorpid(warehouseBills.getfCorpid());
  1316. fees.setfMarks(item.get("fMarks").toString());
  1317. fees.setSrcBillNo((String) item.get("fBillno"));
  1318. fees.setfChargedate((Date) item.get("fChargedate"));
  1319. fees.setCreateBy(loginUser.getUser().getUserName());
  1320. fees.setfProductName(item.get("fGoodsids").toString());
  1321. fees.setfBillingDeadline(warehouseBills.getfBillingDeadline());
  1322. fees.setfTaxrate(new BigDecimal(taxRate.get(0).getDictValue()));
  1323. fees.setfOriginalbilldate((Date) item.get("fOriginalbilldate"));
  1324. fees.setfBillingway(Long.valueOf(String.valueOf(item.get("fBillingway"))).longValue());
  1325. tWarehousebillsfeesMapper.insertTWarehousebillsfees(fees);
  1326. itemsList.add(fees);
  1327. }
  1328. map.put("sumAmt", sumAmt);
  1329. map.put("itemsList", itemsList);
  1330. return map;
  1331. }
  1332. /**
  1333. * 新增库存费计算
  1334. *
  1335. * @param tWarehouseBills 主表的查询条件
  1336. * @param loginUser 登录用户
  1337. * @param billsType 状态
  1338. * @return 结果
  1339. */
  1340. @Override
  1341. @Transactional
  1342. public AjaxResult calculateStorageFees(TWarehouseBills tWarehouseBills, LoginUser loginUser, String billsType) {
  1343. if (StringUtils.isNull(tWarehouseBills.getfCorpid())) {
  1344. return AjaxResult.error("请选择客户信息");
  1345. }
  1346. long fPid = 0L;
  1347. if (StringUtils.isNull(tWarehouseBills.getfId())) {
  1348. // 生成流水号
  1349. Date time = new Date();
  1350. String billNo = billnoSerialServiceImpl.getSerialNumber("JSCCF", time);
  1351. tWarehouseBills.setfBillno(billNo);
  1352. if (StringUtils.isNull(tWarehouseBills.getfBillstatus())) {
  1353. tWarehouseBills.setfBillstatus(2L);
  1354. }
  1355. tWarehouseBills.setfBilltype(billsType);
  1356. tWarehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
  1357. tWarehouseBills.setCreateBy(loginUser.getUser().getUserName());
  1358. tWarehouseBills.setCreateTime(new Date());
  1359. tWarehouseBillsMapper.insertTWarehousebills(tWarehouseBills);
  1360. fPid = tWarehouseBills.getfId();
  1361. } else {
  1362. tWarehousebillsfeesMapper.deleteByFPid(tWarehouseBills.getfId());
  1363. tWarehousebillsitemsMapper.deleteByFPid(tWarehouseBills.getfId());
  1364. tWarehouseBills.setUpdateBy(loginUser.getUser().getUserName());
  1365. tWarehouseBills.setUpdateTime(new Date());
  1366. tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills);
  1367. fPid = tWarehouseBills.getfId();
  1368. }
  1369. // 计划物资明细
  1370. List<TWarehousebillsfees> itemsList = new ArrayList<>();
  1371. BigDecimal bigDecimal = new BigDecimal(0);
  1372. Map<String, Object> map = new HashMap<>();
  1373. // 库存总账id
  1374. long whgenlegFeeId = 0;
  1375. // 计费单位
  1376. long feeUnitid = 1;
  1377. // 查询 出库 货转的库存明细
  1378. List<Map<String, Object>> warehousebillsitemsList = tWarehousebillsitemsMapper.selectStorageFeeItemList(tWarehouseBills);
  1379. if (warehousebillsitemsList.size() != 0) {
  1380. Map<String, Object> mapItem = getWarehouseItems(tWarehouseBills, warehousebillsitemsList, loginUser);
  1381. if (mapItem.containsKey("error")) {
  1382. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1383. return AjaxResult.error((String) mapItem.get("error"));
  1384. }
  1385. itemsList = (List<TWarehousebillsfees>) mapItem.get("itemsList");
  1386. }
  1387. List<Map<String, Object>> tWhgenlegs = tWhgenlegMapper.selectStorageFeeItemList(tWarehouseBills);
  1388. if (tWhgenlegs.size() != 0) {
  1389. Map<String, Object> mapItem = getWarehouseItems(tWarehouseBills, tWhgenlegs, loginUser);
  1390. if (mapItem.containsKey("error")) {
  1391. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1392. return AjaxResult.error((String) mapItem.get("error"));
  1393. }
  1394. List<TWarehousebillsfees> itemList = (List<TWarehousebillsfees>) mapItem.get("itemsList");
  1395. if (itemList.size() != 0) {
  1396. for (TWarehousebillsfees ite : itemList) {
  1397. itemsList.add(ite);
  1398. }
  1399. }
  1400. }
  1401. TFees tFees = new TFees();
  1402. tFees.setfStatus("2");
  1403. tFees.setDelFlag("0");
  1404. List<TFees> feesList = tFeesMapper.selectTFeesList(tFees);
  1405. if (itemsList.size() <= 0) {
  1406. return AjaxResult.error("未找到合适的库存明细");
  1407. }
  1408. map.put("feesList", feesList);
  1409. map.put("warehouseBills", tWarehouseBills);
  1410. map.put("warehouseItemList", itemsList);
  1411. return AjaxResult.success(map);
  1412. }
  1413. /**
  1414. * 仓储费计算提交以及暂存
  1415. *
  1416. * @param warehouseBills
  1417. * @param warehouseItems
  1418. * @param warehouseFees
  1419. * @param loginUser
  1420. * @param billsType
  1421. * @return
  1422. */
  1423. @Override
  1424. @Transactional
  1425. public AjaxResult insertStorageFee(String warehouseBills, String warehouseItems, String warehouseFees, LoginUser loginUser, String billsType) {
  1426. TWarehouseBills tWarehousebills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  1427. long fPid = 0L;
  1428. boolean billstatus = tWarehousebills.getfBillstatus().equals(4L);
  1429. if (billstatus && (StringUtils.isNull(warehouseItems) || "[]".equals(warehouseItems))) {
  1430. return AjaxResult.error("未找到计费物资明细无法提交");
  1431. }
  1432. /*if (billstatus && (StringUtils.isNull(warehouseFees) || "[]".equals(warehouseFees))) {
  1433. return AjaxResult.error("未找到应收款明细无法提交");
  1434. }*/
  1435. if (StringUtils.isNotNull(tWarehousebills.getfId())) {
  1436. fPid = tWarehousebills.getfId();
  1437. tWarehousebills.setUpdateTime(new Date());
  1438. tWarehousebills.setUpdateBy(loginUser.getUser().getUserName());
  1439. tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1440. tWarehousebillsfeesMapper.deleteByFPid(fPid);
  1441. tWarehousebillsitemsMapper.deleteByFPid(fPid);
  1442. } else {
  1443. // 生成流水号
  1444. Date time = new Date();
  1445. String billNo = billnoSerialServiceImpl.getSerialNumber("JSCCF", time);
  1446. tWarehousebills.setfBillno(billNo);
  1447. tWarehousebills.setfDeptid(loginUser.getUser().getDeptId());
  1448. tWarehousebills.setfBsdeptid(loginUser.getUser().getDeptId());
  1449. tWarehousebills.setCreateBy(loginUser.getUser().getUserName());
  1450. tWarehousebills.setCreateTime(new Date());
  1451. tWarehousebills.setfBilltype(billsType);
  1452. tWarehouseBillsMapper.insertTWarehousebills(tWarehousebills);
  1453. fPid = tWarehousebills.getfId();
  1454. }
  1455. JSONArray warehouseJSON = JSONArray.parseArray(warehouseItems);
  1456. List<TWarehousebillsfees> itemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsfees.class);
  1457. for (TWarehousebillsfees item : itemsList) {
  1458. item.setfId(null);
  1459. item.setSrcBillNo(tWarehousebills.getfBillno());
  1460. item.setfPid(fPid);
  1461. item.setfBillstatus(tWarehousebills.getfBillstatus());
  1462. tWarehousebillsfeesMapper.insertTWarehousebillsfees(item);
  1463. }
  1464. if (StringUtils.isNotNull(warehouseFees) && !"[]".equals(warehouseFees)) {
  1465. JSONArray feesJSON = JSONArray.parseArray(warehouseFees);
  1466. List<TWarehousebillsfees> warehousebillsfeesList = JSONObject.parseArray(feesJSON.toJSONString(), TWarehousebillsfees.class);
  1467. for (TWarehousebillsfees fees : warehousebillsfeesList) {
  1468. fees.setfId(null);
  1469. fees.setfPid(fPid);
  1470. fees.setfDc("D");
  1471. fees.setfBilltype("JSCCF");
  1472. fees.setSrcBillNo(tWarehousebills.getfBillno());
  1473. fees.setfBillstatus(tWarehousebills.getfBillstatus());
  1474. tWarehousebillsfeesMapper.insertTWarehousebillsfees(fees);
  1475. }
  1476. }
  1477. if (billstatus) {
  1478. String key = "warehouse.storageFeeCalculation.ApprovalFlow";
  1479. SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key);
  1480. if (StringUtils.isNull(sysConfig)) {
  1481. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1482. return AjaxResult.error("系统参数异常,未找到开启审批流参数");
  1483. }
  1484. if ("0".equals(sysConfig.getConfigValue())) {
  1485. AuditItems auditItems = new AuditItems();
  1486. auditItems.setLevelId(0L);
  1487. auditItems.setBillId(fPid);
  1488. auditItems.setActId(150L);
  1489. auditItems.setIffinalItem("F");
  1490. auditItems.setBillNo(tWarehousebills.getfBillno());
  1491. // 存储委托方(货权方)
  1492. auditItems.setRefno1(tWarehousebills.getfCorpid() + "");
  1493. // 存储业务类型(业务类型)
  1494. auditItems.setRefno2(tWarehousebills.getfBilltype());
  1495. // 存储提单号(提单号)
  1496. auditItems.setRefno3(tWarehousebills.getfMblno());
  1497. auditItems.setSendUserId(loginUser.getUser().getUserId());
  1498. auditItems.setSendName(loginUser.getUsername());
  1499. auditItems.setSendTime(new Date());
  1500. auditItems.setAuditUserId(loginUser.getUser().getUserId());
  1501. auditItems.setAuditItem(new Date());
  1502. auditItems.setAuditOpTime(new Date());
  1503. auditItems.setAuditMsg("提交");
  1504. auditItems.setAuditStatus("O");
  1505. AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems);
  1506. String code = approvalFlow.get("code").toString();
  1507. // Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue();
  1508. if ("500".equals(code)) {
  1509. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1510. }
  1511. return approvalFlow;
  1512. } else {
  1513. AjaxResult ajaxResult = storageFeeFollow(fPid, 6L);
  1514. String code = ajaxResult.get("code").toString();
  1515. // Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue();
  1516. if ("500".equals(code)) {
  1517. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1518. }
  1519. return ajaxResult;
  1520. }
  1521. }
  1522. return AjaxResult.success(tWarehousebills);
  1523. }
  1524. /**
  1525. * 根据id查询仓储费计算信息
  1526. *
  1527. * @param fId
  1528. * @return
  1529. */
  1530. @Override
  1531. public AjaxResult selectStorageFeeById(Long fId) {
  1532. TWarehouseBills tWarehouseBills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  1533. if (StringUtils.isNull(tWarehouseBills)) {
  1534. return AjaxResult.error("未找到信息,请刷新页面重试");
  1535. }
  1536. Map<String, Object> map = new HashMap<>();
  1537. List<TWarehousebillsfees> feesList = new ArrayList<>();
  1538. List<TWarehousebillsfees> itemsList = new ArrayList<>();
  1539. TWarehousebillsfees warehousebillsfees = new TWarehousebillsfees();
  1540. warehousebillsfees.setfPid(fId);
  1541. List<TWarehousebillsfees> warehouseFeesList = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(warehousebillsfees);
  1542. for (TWarehousebillsfees fees : warehouseFeesList) {
  1543. if (StringUtils.isNotNull(fees.getSrcId())) {
  1544. itemsList.add(fees);
  1545. } else {
  1546. feesList.add(fees);
  1547. }
  1548. }
  1549. TGoods tGoods = new TGoods();
  1550. tGoods.setfStatus("0");
  1551. tGoods.setDelFlag("0");
  1552. List<TGoods> goods = tGoodsMapper.selectTGoodsList(tGoods);
  1553. TFees tFees = new TFees();
  1554. tFees.setfStatus("2");
  1555. tFees.setDelFlag("0");
  1556. List<TFees> feesLists = tFeesMapper.selectTFeesList(tFees);
  1557. // 查询联系人
  1558. List<SysUser> sysUserList = new ArrayList<>();
  1559. SysUser sysUser = sysUserMapper.selectUserByUserName(tWarehouseBills.getCreateBy());
  1560. if (StringUtils.isNotNull(sysUser)) {
  1561. sysUserList.add(sysUser);
  1562. }
  1563. TCorps corps = tCorpsMapper.selectTCorpsById(tWarehouseBills.getfCorpid());
  1564. map.put("corps", corps);
  1565. map.put("goodsList", goods);
  1566. map.put("feesList", feesLists);
  1567. map.put("sysUser", sysUserList);
  1568. map.put("warehouse", tWarehouseBills);
  1569. map.put("warehouseFeesList", feesList);
  1570. map.put("warehouseItemsList", itemsList);
  1571. return AjaxResult.success(map);
  1572. }
  1573. /**
  1574. * 根据不同计费单位获取不同 计算库存明细数量
  1575. *
  1576. * @param item 库存明细
  1577. * @param dictLabel 计费单位
  1578. * @return 结果
  1579. */
  1580. public BigDecimal acquiredQuantity(Map<String, Object> item, Long dictLabel) {
  1581. BigDecimal fQty = new BigDecimal(0);
  1582. // 件数
  1583. long boxNum = 1;
  1584. // 毛重
  1585. long grossWeight = 2;
  1586. // 净重
  1587. long netWeight = 3;
  1588. // 尺码
  1589. long size = 4;
  1590. // 统一
  1591. long fixed = 5;
  1592. if (dictLabel.equals(boxNum)) {
  1593. fQty = new BigDecimal(((Number) item.get("fQty")).doubleValue());
  1594. return fQty.setScale(2, BigDecimal.ROUND_HALF_UP);
  1595. } else if (dictLabel.equals(grossWeight)) {
  1596. fQty = new BigDecimal(((Number) item.get("fGrossweight")).doubleValue());
  1597. } else if (dictLabel.equals(netWeight)) {
  1598. fQty = new BigDecimal(((Number) item.get("fNetweight")).doubleValue());
  1599. } else if (dictLabel.equals(size)) {
  1600. fQty = new BigDecimal(((Number) item.get("fVolumn")).doubleValue());
  1601. } else if (dictLabel.equals(fixed)) {
  1602. fQty = new BigDecimal(1);
  1603. }
  1604. //return fQty.setScale(2, BigDecimal.ROUND_HALF_UP);
  1605. // 结果值除以1000 保留两位
  1606. BigDecimal divisor = new BigDecimal("1000");
  1607. BigDecimal result = fQty.divide(divisor,2,BigDecimal.ROUND_HALF_UP);
  1608. return result;
  1609. }
  1610. // 入库 收费明细 校验
  1611. public Long check(BigDecimal number, BigDecimal unitPrice) {
  1612. BigDecimal result1 = number.multiply(unitPrice);
  1613. // 保留两位小数且四舍五入
  1614. result1 = result1.setScale(2, BigDecimal.ROUND_HALF_UP);
  1615. // 转换去掉小数点
  1616. String result = result1.toString().replace(".", "");
  1617. return Long.valueOf(result);
  1618. }
  1619. /**
  1620. * 修改详情主表
  1621. *
  1622. * @param tWarehousebills 详情主表
  1623. * @return 结果
  1624. */
  1625. @Override
  1626. public int updateTWarehousebills(TWarehouseBills tWarehousebills) {
  1627. tWarehousebills.setUpdateTime(DateUtils.getNowDate());
  1628. return tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1629. }
  1630. /**
  1631. * 批量删除详情主表
  1632. *
  1633. * @param fIds 需要删除的详情主表ID
  1634. * @return 结果
  1635. */
  1636. @Override
  1637. public int deleteTWarehousebillsByIds(Long[] fIds) {
  1638. // 取出业务编号、 放入 billno_del
  1639. for (Long id : fIds) {
  1640. // 1、查询主表信息
  1641. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(id);
  1642. // 2、业务编号、客存编号 放入 billno_del
  1643. BillnoDel billnoDel = new BillnoDel();
  1644. billnoDel.setBillType(tWarehousebills.getfBilltype());
  1645. billnoDel.setBillNo(tWarehousebills.getfBillno());
  1646. billnoDelMapper.insertBillnoDel(billnoDel);
  1647. }
  1648. return tWarehouseBillsMapper.deleteTWarehousebillsByIds(fIds);
  1649. }
  1650. @Override
  1651. public AjaxResult queryRemove(Long fId) {
  1652. // 查询主表明细
  1653. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  1654. // 查询仓库明细从表数据
  1655. TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
  1656. tWarehousebillsitems.setfPid(tWarehousebills.getfId());
  1657. List<Map<String, Object>> mapList = tWarehousebillsitemsMapper.selectGoodsTransferitemsList(tWarehousebillsitems);
  1658. // 查询仓库费用明细表数据
  1659. TWarehousebillsfees tWarehousebillsfees = new TWarehousebillsfees();
  1660. tWarehousebillsfees.setfPid(tWarehousebills.getfId());
  1661. List<TWarehousebillsfees> warehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(tWarehousebillsfees);
  1662. // 查询附件表数据
  1663. TEnclosure enclosure = new TEnclosure();
  1664. enclosure.setfPid(tWarehousebills.getfId());
  1665. List<TEnclosure> enclosures = tEnclosureMapper.selectTEnclosureList(enclosure);
  1666. if (StringUtils.isNull(tWarehousebills)) {
  1667. return AjaxResult.success("0");
  1668. } else if (StringUtils.isNotNull(tWarehousebills)
  1669. && StringUtils.isEmpty(warehousebillsfees)
  1670. && StringUtils.isEmpty(enclosures)
  1671. && StringUtils.isEmpty(mapList)) {
  1672. return AjaxResult.success("1");
  1673. } else {
  1674. return AjaxResult.success("2");
  1675. }
  1676. }
  1677. /**
  1678. * 删除详情主表信息
  1679. *
  1680. * @param fId 详情主表ID
  1681. * @return 结果
  1682. */
  1683. @Override
  1684. public int deleteTWarehousebillsById(Long fId) {
  1685. return tWarehouseBillsMapper.deleteTWarehousebillsById(fId);
  1686. }
  1687. @Override
  1688. public String getWarehouseInStockBillsNo(TWarehouseBills tWarehouseBills) {
  1689. return null;
  1690. }
  1691. @Override
  1692. public String getWarehouseOutStockBillsNo(TWarehouseBills tWarehouseBills) {
  1693. return null;
  1694. }
  1695. /**
  1696. * 撤销入库
  1697. *
  1698. * @param fId
  1699. * @param loginUser
  1700. * @param billsType
  1701. * @return
  1702. */
  1703. @Override
  1704. @Transactional
  1705. public AjaxResult revokeTWarehousebillsById(Long fId, LoginUser loginUser, String billsType) {
  1706. // 查询 仓库主表信息、库存明细信息
  1707. TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
  1708. // 修改主表信息
  1709. tWarehousebills.setUpdateBy(loginUser.getUser().getUserName());
  1710. tWarehousebills.setUpdateTime(new Date());
  1711. tWarehousebills.setfBillstatus(2L); //撤销状态
  1712. tWarehousebills.setfReviewDate(null);// 审核通过时间清空
  1713. tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1714. tWarehousebillsfeesMapper.warehouseFeesFollowUpdate(tWarehousebills.getfId(), 2L,new Date());
  1715. return AjaxResult.success();
  1716. }
  1717. /**
  1718. * 撤销入账
  1719. *
  1720. * @param warehouseBills 主表
  1721. * @param warehousebillsitems 明细
  1722. * @param loginUser 当前登录人
  1723. * @param billsType 状态
  1724. * @return 结果
  1725. */
  1726. @Override
  1727. @Transactional
  1728. public AjaxResult revokeTWarehousebillsById1(String warehouseBills, String warehousebillsitems, String tEnclosure,
  1729. String warehousebillsfeesCr, String warehousebillsfeesDr, LoginUser loginUser, String billsType) {
  1730. if (StringUtils.isNull(warehouseBills) || "[]".equals(warehouseBills)) {
  1731. return AjaxResult.error("未找到主表信息");
  1732. }
  1733. if (StringUtils.isNull(warehousebillsitems) || "[]".equals(warehousebillsitems)) {
  1734. return AjaxResult.error("未找到入账信息");
  1735. }
  1736. TWarehouseBills tWarehousebills = JSONArray.parseObject(warehouseBills, TWarehouseBills.class);
  1737. tWarehousebills.setfItemsStatus(2L);
  1738. tWarehousebills.setfItemsStatus(1L); //撤销状态
  1739. tWarehouseBillsMapper.updateTWarehousebills(tWarehousebills);
  1740. tEnclosureMapper.deleteByFPid(tWarehousebills.getfId());
  1741. tWarehousebillsfeesMapper.deleteByFPid(tWarehousebills.getfId());
  1742. JSONArray warehouseJSON = JSONArray.parseArray(warehousebillsitems);
  1743. List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  1744. if (StringUtils.isNotEmpty(warehousebillsitemsList)) {
  1745. int i = 1;
  1746. for (TWarehousebillsitems wb : warehousebillsitemsList) {
  1747. // 查询库存总账
  1748. TWhgenleg tWhgenle = queryTWhgenleg(tWarehousebills, wb);
  1749. if ("SJRKRevoke".equals(billsType)) { // 撤销 入库
  1750. if (wb.getfIsInventory().equals(0L)) {
  1751. if (StringUtils.isNotNull(tWhgenle) && (wb.getfQty() <= tWhgenle.getfQtyblc())) { // 非空 且 撤销数 <= 结余数
  1752. updateTWhgenlegData(wb, tWhgenle.getfId(), billsType);
  1753. } else { // 撤销数>结余数
  1754. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1755. return AjaxResult.error("第" + i + "行撤销数大于库存结余数");
  1756. }
  1757. }
  1758. wb.setfBillstatus(10L);
  1759. } else if ("SJCKRevoke".equals(billsType)) { // 撤销出库
  1760. if (StringUtils.isNotNull(tWhgenle)) { // 非空
  1761. updateTWhgenlegData(wb, tWhgenle.getfId(), billsType);
  1762. } else {
  1763. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1764. return AjaxResult.error("第" + i + "行未查询到库存信息");
  1765. }
  1766. wb.setfBillstatus(10L);
  1767. } else if ("CKDBRevoke".equals(billsType)) { // 调拨 撤销
  1768. Long warehouselocid = wb.getfWarehouselocid();// 原货仓库
  1769. Long transferWarehouselocid = wb.getfTransferWarehouselocid(); // 新仓库
  1770. // 1、新货权方撤销入库
  1771. // 查询库存总账
  1772. wb.setfWarehouselocid(transferWarehouselocid);
  1773. TWhgenleg tWhgenle1 = queryTWhgenleg(tWarehousebills, wb);
  1774. if (StringUtils.isNotNull(tWhgenle1) && (wb.getfQty() <= tWhgenle1.getfQtyblc())) {
  1775. updateTWhgenlegData(wb, tWhgenle1.getfId(), "SJRKRevoke");
  1776. } else {
  1777. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1778. return AjaxResult.error("第" + i + "行撤销数大于库存结余数");
  1779. }
  1780. // 2、原货权方撤销出库
  1781. // 查询库存总账
  1782. wb.setfWarehouselocid(warehouselocid);
  1783. TWhgenleg tWhgenle2 = queryTWhgenleg(tWarehousebills, wb);
  1784. updateTWhgenlegData(wb, tWhgenle2.getfId(), "SJCKRevoke");
  1785. wb.setfBillstatus(10L);
  1786. } else if ("HQZYRevoke".equals(billsType)) { // 货转撤销
  1787. Long fCorpid = tWarehousebills.getfCorpid();// 原货权方
  1788. Long fTocorpid = tWarehousebills.getfTocorpid(); // 新货权方
  1789. // 1、新货权方撤销入库
  1790. // 查询库存总账
  1791. tWarehousebills.setfCorpid(fTocorpid);
  1792. TWhgenleg tWhgenle1 = queryTWhgenleg(tWarehousebills, wb);
  1793. if (StringUtils.isNotNull(tWhgenle1) && (wb.getfQty() <= tWhgenle1.getfQtyblc())) {
  1794. updateTWhgenlegData(wb, tWhgenle1.getfId(), "SJRKRevoke");
  1795. } else {
  1796. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1797. return AjaxResult.error("第" + i + "行撤销数大于库存结余数");
  1798. }
  1799. // 2、原货权方撤销出库
  1800. // 查询库存总账
  1801. tWarehousebills.setfCorpid(fCorpid);
  1802. TWhgenleg tWhgenle2 = queryTWhgenleg(tWarehousebills, wb);
  1803. updateTWhgenlegData(wb, tWhgenle2.getfId(), "SJCKRevoke");
  1804. wb.setfBillstatus(1L);
  1805. }
  1806. i++;
  1807. wb.setUpdateBy(loginUser.getUser().getUserName());
  1808. wb.setUpdateTime(new Date());
  1809. if (tWarehousebillsitemsMapper.updateTWarehousebillsitems(wb) <= 0) {
  1810. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  1811. return AjaxResult.error("新增库存明细失败");
  1812. }
  1813. }
  1814. }
  1815. // 附件添加
  1816. if (StringUtils.isNotEmpty(tEnclosure) && !"[]".equals(tEnclosure)) {
  1817. JSONArray jsonDrArray = JSONArray.parseArray(tEnclosure);
  1818. List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
  1819. for (TEnclosure enclosure : tEnclosureList) {
  1820. enclosure.setfPid(tWarehousebills.getfId());
  1821. enclosure.setCreateBy(loginUser.getUser().getUserName());
  1822. enclosure.setCreateTime(new Date());
  1823. tEnclosureMapper.insertTEnclosure(enclosure);
  1824. }
  1825. }
  1826. // 收款明细添加
  1827. if (StringUtils.isNotEmpty(warehousebillsfeesDr) && !"[]".equals(warehousebillsfeesDr)) {
  1828. JSONArray jsonDrArray = JSONArray.parseArray(warehousebillsfeesDr);
  1829. List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
  1830. for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
  1831. wbDr.setfPid(tWarehousebills.getfId());
  1832. wbDr.setfDc("D");
  1833. wbDr.setCreateBy(loginUser.getUser().getUserName());
  1834. wbDr.setCreateTime(new Date());
  1835. if(tWarehousebills.getfBsdate()!=null&& !tWarehousebills.getfBsdate().equals("")){
  1836. wbDr.setfBsdate(tWarehousebills.getfBsdate());
  1837. }
  1838. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbDr);
  1839. }
  1840. }
  1841. // 付款明细添加
  1842. if (StringUtils.isNotNull(warehousebillsfeesCr) && !"[]".equals(warehousebillsfeesCr)) {
  1843. JSONArray jsonCrArray = JSONArray.parseArray(warehousebillsfeesCr);
  1844. List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
  1845. for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
  1846. wbCr.setfPid(tWarehousebills.getfId());
  1847. wbCr.setfDc("C");
  1848. wbCr.setCreateBy(loginUser.getUser().getUserName());
  1849. wbCr.setCreateTime(new Date());
  1850. if(tWarehousebills.getfBsdate()!=null&& !tWarehousebills.getfBsdate().equals("")){
  1851. wbCr.setfBsdate(tWarehousebills.getfBsdate());
  1852. }
  1853. tWarehousebillsfeesMapper.insertTWarehousebillsfees(wbCr);
  1854. }
  1855. }
  1856. return AjaxResult.success();
  1857. }
  1858. /**
  1859. * 添加 库存明细状态
  1860. *
  1861. * @param wbItem
  1862. * @param status
  1863. * @param loginUser
  1864. */
  1865. public void insertTWarehousebillsLog(TWarehousebillsitems wbItem, Long status, LoginUser loginUser) {
  1866. // 添加状态log
  1867. TWarehousebillsLog tWarehousebillsLog = new TWarehousebillsLog();
  1868. tWarehousebillsLog.setfPid(wbItem.getfPid());
  1869. tWarehousebillsLog.setfItmeid(wbItem.getfId());
  1870. tWarehousebillsLog.setfItmestatus(status);
  1871. tWarehousebillsLog.setCreateTime(new Date());
  1872. tWarehousebillsLog.setCreateBy(loginUser.getUser().getUserName());
  1873. tWarehousebillsLogMapper.insertTWarehousebillsLog(tWarehousebillsLog);
  1874. }
  1875. /**
  1876. * 删除 库存明细
  1877. *
  1878. * @param fid
  1879. * @param tWarehousebillsitems
  1880. */
  1881. public void deleteBillsitems(Long fid, String tWarehousebillsitems) {
  1882. List<Long> oldList = new ArrayList<Long>();
  1883. List<Long> newList = new ArrayList<Long>();
  1884. // 查询所有从表数据
  1885. TWarehousebillsitems tWarehousebillsitem = new TWarehousebillsitems();
  1886. tWarehousebillsitem.setfPid(fid);
  1887. List<TWarehousebillsitems> warehousebillsitemsList = tWarehousebillsitemsMapper.selectTWarehousebillsitemsList(tWarehousebillsitem);
  1888. warehousebillsitemsList.forEach(wb ->
  1889. oldList.add(wb.getfId())
  1890. );
  1891. // 获取提交从表数据ID
  1892. if (tWarehousebillsitems != null) {
  1893. JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
  1894. List<TWarehousebillsitems> warehousebillsitemsLists = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
  1895. warehousebillsitemsLists.forEach(wb ->
  1896. newList.add(wb.getfId())
  1897. );
  1898. }
  1899. // 删除多余的ID
  1900. List<Long> reduce1 = oldList.stream().filter(item -> !newList.contains(item)).collect(toList());
  1901. reduce1.forEach(id ->
  1902. tWarehousebillsitemsMapper.deleteTWarehousebillsitemsById(id)
  1903. );
  1904. }
  1905. /**
  1906. * 库容-结余毛重
  1907. *
  1908. * @param fTotalgross
  1909. * @param fGrossweightblc
  1910. * @return
  1911. */
  1912. public static BigDecimal calculation1(String fTotalgross, String fGrossweightblc) {
  1913. BigDecimal num1 = new BigDecimal(fTotalgross);
  1914. BigDecimal num2 = new BigDecimal(fGrossweightblc);
  1915. BigDecimal result = num1.subtract(num2);
  1916. return result.setScale(2, BigDecimal.ROUND_HALF_UP);
  1917. }
  1918. /**
  1919. * 判断 是否允许 入库
  1920. *
  1921. * @param fId
  1922. */
  1923. public int calculation(Long fId, BigDecimal fGrossweight) {
  1924. // 仓库库容
  1925. TWarehouse tWarehouse = tWarehouseMapper.selectTWarehouseById(fId);
  1926. // 毛重公斤转化为吨
  1927. fGrossweight = fGrossweight.divide(new BigDecimal(1000), 0, BigDecimal.ROUND_HALF_UP);
  1928. // 总账使用
  1929. List<Map<String, Object>> whouseList = tWhgenlegMapper.selectWareHouseListWhouse(fId);
  1930. if (whouseList != null && whouseList.size() > 0) {
  1931. String fTotalgross = null;
  1932. String fGrossweightblc = null;
  1933. for (Map<String, Object> m : whouseList) {
  1934. for (String k : m.keySet()) {
  1935. // 获取毛重库容
  1936. if (k.equals("fTotalgross")) {
  1937. fTotalgross = m.get(k).toString();
  1938. }
  1939. if (k.equals("fGrossweightD")) {
  1940. fGrossweightblc = m.get(k).toString();
  1941. }
  1942. }
  1943. }
  1944. BigDecimal result = calculation1(fTotalgross, fGrossweightblc);
  1945. if (result.compareTo(fGrossweight) == -1) {
  1946. return 0;// 结余库容小于入库数
  1947. } else {
  1948. return 1;
  1949. }
  1950. } else {
  1951. if (tWarehouse.getfTotalgross().compareTo(fGrossweight) == -1) {
  1952. return 0;// 库容小于入库数
  1953. } else {
  1954. return 1;
  1955. }
  1956. }
  1957. }
  1958. }