OrdersService.java 142 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903
  1. package com.behosoft.lis.wms.orders.service;
  2. import com.behosoft.edi.common.EdiConst;
  3. import com.behosoft.edi.dtomodel.common.FetchMailNoRequestDto;
  4. import com.behosoft.edi.dtomodel.common.FetchMailNoResponseDto;
  5. import com.behosoft.framework.component.TransactionHelper;
  6. import com.behosoft.framework.component.TransactionHelper.TxCallBack;
  7. import com.behosoft.framework.web.exception.AjaxException;
  8. import com.behosoft.framework.web.exception.CommonException;
  9. import com.behosoft.framework.web.service.ManagementService;
  10. import com.behosoft.lis.BusinessConstants;
  11. import com.behosoft.lis.bc.provinceCityCompare.service.ProvinceCityCompareService;
  12. import com.behosoft.lis.common.service.GlobalPostCodeSettingService;
  13. import com.behosoft.lis.context.BusinessSessionContext;
  14. import com.behosoft.lis.crm.customer.service.CustomerCachedService;
  15. import com.behosoft.lis.crm.customer.service.CustomerService;
  16. import com.behosoft.lis.crm.transceiver.service.TransceiverService;
  17. import com.behosoft.lis.crm.vender.service.VenderService;
  18. import com.behosoft.lis.data.packagingMaterial.service.PackagingMaterialService;
  19. import com.behosoft.lis.data.warehouse.service.WarehouseService;
  20. import com.behosoft.lis.edi.bigcustomer.service.BigCustomerService;
  21. import com.behosoft.lis.edi.ws.callediws.GetMailNoService;
  22. import com.behosoft.lis.model.bo.*;
  23. import com.behosoft.lis.model.vo.*;
  24. import com.behosoft.lis.oms.deliveryoutbound.service.DeliveryOutboundService;
  25. import com.behosoft.lis.oms.deliveryoutbounddetail.service.DeliveryOutboundDetailService;
  26. import com.behosoft.lis.oms.returnoutbounddetail.service.ReturnOutboundDetailService;
  27. import com.behosoft.lis.own.goodManage.service.OwnGoodManageService;
  28. import com.behosoft.lis.sys.item.service.ItemService;
  29. import com.behosoft.lis.sys.user.service.UserCustomerService;
  30. import com.behosoft.lis.sys.user.service.UserWarehouseService;
  31. import com.behosoft.lis.util.IdGenerator;
  32. import com.behosoft.lis.util.ListUtils;
  33. import com.behosoft.lis.wms.abnormaldeliverydocument.service.AbnormalDeliveryDocumentService;
  34. import com.behosoft.lis.wms.orderswave.service.OrdersWaveService;
  35. import com.behosoft.lis.wms.pickList.service.PickListService;
  36. import com.behosoft.lis.wms.pickListDetail.service.PickListDetailService;
  37. import com.behosoft.lis.wms.replenishmentDetail.service.ReplenishmentDetailService;
  38. import com.behosoft.util.DataUtils;
  39. import com.behosoft.util.DateUtils;
  40. import com.behosoft.util.HttpUtils;
  41. import com.wondersgroup.framework.util.CollectionUtils;
  42. import com.wondersgroup.saas.access.dao.impl.ExtendedJdbcDao;
  43. import com.wondersgroup.saas.access.mapper.QueryContext;
  44. import net.sf.json.JSONArray;
  45. import net.sf.json.JSONObject;
  46. import org.apache.commons.beanutils.BeanUtilsBean;
  47. import org.apache.commons.lang3.StringUtils;
  48. import org.apache.commons.logging.Log;
  49. import org.apache.commons.logging.LogFactory;
  50. import org.springframework.beans.factory.annotation.Autowired;
  51. import org.springframework.stereotype.Service;
  52. import org.springframework.transaction.annotation.Transactional;
  53. import java.text.SimpleDateFormat;
  54. import java.util.*;
  55. @Service
  56. public class OrdersService extends ManagementService {
  57. private final Log logger = LogFactory.getLog(getClass());
  58. public static final Integer WMS_ORDERS_STATUS_FORZEN = 5200;//出货单冻结
  59. public static final Integer WMS_ORDERS_STATUS_NEW = 5201;//出货单新记录
  60. public static final Integer WMS_ORDERS_STATUS_OUTING = 5202;//出货中
  61. public static final Integer WMS_ORDERS_STATUS_OUTTED = 5203;//已出货
  62. public static final Integer WMS_ORDERS_STATUS_CANCLED = 5204;//已经取消
  63. public static final Integer WMS_ORDERS_BACK_STATUS_START = 48001;//订单未追回
  64. /**
  65. * 未分配,未拣货,未包装,未发运
  66. */
  67. public static final int WMS_ORDERS_TASK_NEW = 0;
  68. /**
  69. * 部分未分配,部分拣货,未包装,部分发运
  70. */
  71. public static final int WMS_ORDERS_TASK_PART = 1;
  72. /**
  73. * 已分配,已拣货,已包装,已发运
  74. */
  75. public static final int WMS_ORDERS_TASK_ALL = 2;
  76. public static final Long ORDERS_OUT_TYPE_DELIVERYOUTBOUND = 2401L;// 出库类型,自提
  77. public static final Long ORDERS_OUT_TYPE_TRANSFER = 2402L;// 出库类型,送货上门
  78. @Autowired
  79. private VenderService venderService;
  80. @Autowired
  81. private CustomerService customerService;
  82. @Autowired
  83. private TransceiverService transceiverService;
  84. @Autowired
  85. private WarehouseService warehouseService;
  86. @Autowired
  87. private OrdersDetailService ordersDetailService;
  88. @Autowired
  89. private DeliveryOutboundDetailService deliveryOutboundDetailService;
  90. @Autowired
  91. private ReturnOutboundDetailService returnOutboundDetailService;
  92. @Autowired
  93. private AllocateInventoryService allocateInventoryService;
  94. @Autowired
  95. private UserCustomerService userCustomerService;
  96. @Autowired
  97. private UserWarehouseService userWarehouseService;
  98. @Autowired
  99. private OrdersWaveService ordersWaveService;
  100. @Autowired
  101. private GlobalPostCodeSettingService globalPostCodeSettingService;
  102. @Autowired
  103. private OwnGoodManageService ownGoodManageService;
  104. @Autowired
  105. private ItemService itemService;
  106. @Autowired
  107. private PackagingMaterialService packagingMaterialService;
  108. @Autowired
  109. private ReplenishmentDetailService replenishmentDetailService;
  110. @Autowired
  111. private BigCustomerService bigCustomerService;
  112. @Autowired
  113. private GetMailNoService getMailNoService;
  114. @Autowired
  115. private CustomerCachedService customerCachedService;
  116. @Autowired
  117. private DeliveryOutboundService deliveryOutboundService;
  118. @Autowired
  119. private AbnormalDeliveryDocumentService abnormalDeliveryDocumentService;
  120. @Autowired
  121. private ProvinceCityCompareService provinceCityCompareService;
  122. @Autowired
  123. private PickListDetailService pickListDetailService;
  124. @Autowired
  125. private PickListService pickListService;
  126. private void resetOrderInfo(Orders orders) {
  127. // 补充货主信息
  128. CustomerVO customer = customerService.getCustomerById(orders.getCustomerId());
  129. orders.setCustomerCode(customer.getCustomerCode());
  130. orders.setCustomerName(customer.getCustomerName());
  131. // 补充承运商信息
  132. VenderVO vender = venderService.getVenderById(orders.getCarrierId());
  133. orders.setCarrierCode(vender.getVenderCode());
  134. orders.setCarrierName(vender.getVenderName());
  135. // 补充收货人信息
  136. TransceiverVO receiver = transceiverService.getTransceiverVOById(orders.getReceiverId());
  137. orders.setReceiverName(receiver.getTransceiverName());
  138. orders.setReceiverCode(receiver.getTransceiverCode());
  139. // 补充仓库信息
  140. WarehouseVO warehouse = warehouseService.getEntity(orders.getWarehouseId());
  141. orders.setWarehouseName(warehouse.getWarehouseName());
  142. }
  143. @Transactional
  144. public void saveOrders(Orders orders) {
  145. // ORDER_STATUS ASSIGNED_STATUS PICK_STATUS PACKING_STATUS DELIVERY_STATUS
  146. orders.setOrderStatus(WMS_ORDERS_STATUS_NEW);
  147. orders.setAssignedStatus(OrdersService.WMS_ORDERS_TASK_NEW);
  148. orders.setPickStatus(OrdersService.WMS_ORDERS_TASK_NEW);
  149. orders.setPackingStatus(OrdersService.WMS_ORDERS_TASK_NEW);
  150. orders.setDeliveryStatus(OrdersService.WMS_ORDERS_TASK_NEW);
  151. orders.setTagId("T" + orders.getOrderId());
  152. orders.setDeleteFlag(0);
  153. orders.setBusinessLockFlag(0);
  154. resetOrderInfo(orders);
  155. this.saveEntity(orders);
  156. }
  157. @Transactional
  158. public void updateOrders(Orders orders) {
  159. resetOrderInfo(orders);
  160. this.updateEntity(orders);
  161. }
  162. /**
  163. * 订单暂挂
  164. *
  165. * @param idArray
  166. */
  167. @Transactional
  168. public int pauseOrders(JSONArray idArray, String loginName) {
  169. String sql =
  170. "update wms_orders set ORDER_STATUS=" + WMS_ORDERS_STATUS_FORZEN
  171. + ", UPDATE_TIME = :updateTime, UPDATED_BY = '" + loginName + "', UPDATE_METHOD = '"
  172. + BusinessConstants.PROCESS_MODE_WEB + "' where ORDER_ID in(:id) ";
  173. Map<String, Object> map = new HashMap<String, Object>();
  174. map.put("id", idArray);
  175. map.put("updateTime", new Date());
  176. return this.daoFactory.getJdbcDao().update(sql, map);
  177. }
  178. /**
  179. * 订单暂挂取消
  180. *
  181. * @param idArray
  182. */
  183. @Transactional
  184. public int canclePauseOrders(JSONArray idArray, String loginName) {
  185. String sql =
  186. "update wms_orders set ORDER_STATUS=" + WMS_ORDERS_STATUS_NEW
  187. + ", UPDATE_TIME = :updateTime, UPDATED_BY = '" + loginName + "', UPDATE_METHOD = '"
  188. + BusinessConstants.PROCESS_MODE_WEB + "' where ORDER_ID in(:id) ";
  189. Map<String, Object> map = new HashMap<String, Object>();
  190. map.put("id", idArray);
  191. map.put("updateTime", new Date());
  192. return this.daoFactory.getJdbcDao().update(sql, map);
  193. }
  194. @Transactional
  195. public void genOrdersFromDeliveryOutbound(List<DeliveryOutbound> deliveryOutbounds) {
  196. if (ListUtils.isBlank(deliveryOutbounds)) {
  197. return;
  198. }
  199. List<DeliveryOutboundDetail> allDetails = new ArrayList<DeliveryOutboundDetail>();
  200. for (DeliveryOutbound deliveryOutbound : deliveryOutbounds) {
  201. if (BusinessConstants.BOOLEAN_FALSE.equals(deliveryOutbound.getDeleteFlag())) {
  202. Orders orders = new Orders();
  203. String orderId = IdGenerator.getOrdersId();
  204. String accountId = deliveryOutbound.getAccountId();
  205. String warehouseId = deliveryOutbound.getWarehouseId();
  206. Double cube = deliveryOutbound.getCube();
  207. Double weight = deliveryOutbound.getWeight();
  208. String deliveryOutboundId = deliveryOutbound.getDeliveryOutboundId();
  209. orders.setOrderId(orderId);
  210. orders.setTagId("T" + orders.getOrderId());
  211. orders.setAccountId(accountId);// 账户编号
  212. orders.setCustomerId(deliveryOutbound.getCustomerId());// 货主编号
  213. orders.setCustomerName(deliveryOutbound.getCustomerName());// 货主名称
  214. orders.setCustomerCode(deliveryOutbound.getCustomerCode());// 货主代码
  215. orders.setWarehouseId(warehouseId);// 仓库编号
  216. orders.setWarehouseName(deliveryOutbound.getWarehouseName());// 仓库名称
  217. orders.setSalesPlatform(deliveryOutbound.getSalesPlatform());// 销售平台
  218. orders.setOrderInvilidTime(deliveryOutbound.getOrderInvilidTime());// 订单失效时间
  219. orders.setOutboundOrderId(deliveryOutboundId);// 出库订单ID
  220. orders.setOutboundKind(2301L);// 出库订单类型
  221. orders.setOutType(deliveryOutbound.getOutType());// 出库类型
  222. orders.setDeliveryType(deliveryOutbound.getDeliveryType());// 送货方式
  223. orders.setCustomerRefferenceId(deliveryOutbound.getCustomerRefferenceId());// 客户订单号
  224. orders.setOrderDealType(deliveryOutbound.getOrderDealType());// 订单处理类型
  225. orders.setOrderStatus(WMS_ORDERS_STATUS_NEW);// 订单状态
  226. orders.setDeliveryStatus(WMS_ORDERS_TASK_NEW);// 发运状态
  227. orders.setPackingStatus(WMS_ORDERS_TASK_NEW);// 包装状态
  228. orders.setPickStatus(WMS_ORDERS_TASK_NEW);// 拣货状态
  229. orders.setAssignedStatus(WMS_ORDERS_TASK_NEW);// 分配状态
  230. // 包装完成时间
  231. // 出货结案时间
  232. // 发货单提货时间
  233. // 计划发货时间
  234. // 实际发货时间
  235. // 预期到达时间
  236. // 实际到达时间
  237. // 签收时间
  238. // 回单时间
  239. orders.setDetailCount(deliveryOutbound.getDetailCount());// 明细数量
  240. orders.setExpectedSendQuantity(deliveryOutbound.getExpectedSendQuantity());// 预期发货数量
  241. orders.setAssignedQuantity(0d);// 已分配数量
  242. orders.setDeliveredQuantity(0d);// 发货数量
  243. orders.setPickedQuantity(0d);// 已拣货数量
  244. orders.setPackingQuantity(0d);// 已装箱量
  245. // 订单拣货序号
  246. // 是否拆单拣货
  247. orders.setTotalFee(deliveryOutbound.getTotalFee());// 价值
  248. orders.setLogisticsFee(deliveryOutbound.getLogisticsFee());// 物流费用
  249. orders.setCollectionFlag(deliveryOutbound.getCollectionFlag());// 代收货款
  250. orders.setWeight(weight);// 重量
  251. orders.setBulk(cube);// 体积
  252. // 件数
  253. // 拣货单号
  254. // 发货单号
  255. // 备注
  256. // 未分配成功标志
  257. orders.setDriver(deliveryOutbound.getDriver());// 司机
  258. orders.setTruckNumber(deliveryOutbound.getTruckNumber());// 车辆号码
  259. orders.setDeliveryScore(deliveryOutbound.getDeliveryScore());// 送货评分
  260. orders.setDrliverPhone(deliveryOutbound.getDrliverPhone());// 司机联系方式
  261. orders.setIndentityCard(deliveryOutbound.getIndentityCard());// 身份证
  262. orders.setCarrierTrackingNumber(deliveryOutbound.getCarrierTrackingNumber());// 承运单号
  263. orders.setCarrierId(deliveryOutbound.getCarrierId());// 承运商编号
  264. orders.setCarrierCode(deliveryOutbound.getCarrierCode());// 承运商代码
  265. orders.setCarrierName(deliveryOutbound.getCarrierName());// 承运商名称
  266. orders.setReceiverId(deliveryOutbound.getReceiverId());// 收货人编号
  267. orders.setReceiverCode(deliveryOutbound.getReceiverCode());// 收货人代码
  268. orders.setReceiverName(deliveryOutbound.getReceiverName());// 收货人名称
  269. orders.setToTransceiverAddressId(deliveryOutbound.getToTransceiverAddressId());// 收货地址编号
  270. orders.setReceiverCountry(deliveryOutbound.getReceiverCountry());// 收货国家
  271. orders.setReceiverProvince(deliveryOutbound.getReceiverProvince());// 收货省
  272. orders.setReceiverCity(deliveryOutbound.getReceiverCity());// 收货市
  273. orders.setReceiverDistrict(deliveryOutbound.getReceiverDistrict());// 收货县
  274. orders.setReceiverStreet(deliveryOutbound.getReceiverStreet());// 收货街道
  275. if(null == deliveryOutbound.getReceiverZipcode() || "".equals(deliveryOutbound.getReceiverZipcode())){
  276. orders.setReceiverZipcode(globalPostCodeSettingService.getPostCodeForPlace(deliveryOutbound.getReceiverProvince(), deliveryOutbound.getReceiverCity(), deliveryOutbound.getReceiverDistrict(), deliveryOutbound.getReceiverStreet()));// 收货邮编
  277. }
  278. else{
  279. orders.setReceiverZipcode(deliveryOutbound.getReceiverZipcode());
  280. }
  281. orders.setReceiverContactor(deliveryOutbound.getReceiverContactor());// 收货联系人
  282. orders.setReceiverContactorPhone(deliveryOutbound.getReceiverContactorPhone());// 收货联系人电话
  283. orders.setReceiverContactorMobile(deliveryOutbound.getReceiverContactorMobile());// 收货联系人手机
  284. orders.setOwnGoodFlag(deliveryOutbound.getOwnGoodFlag());// 自有货品标记
  285. orders.setOwnGoodInboundNo(deliveryOutbound.getOwnGoodInboundNo());// 自有货品入库单号
  286. if(BusinessConstants.BOOLEAN_TRUE.equals(deliveryOutbound.getOwnGoodFlag())) {
  287. OwnGoodManage ownGoodManage = ownGoodManageService.getEntityById(deliveryOutbound.getOwnGoodInboundNo(), OwnGoodManage.class);
  288. if(ownGoodManage != null) {
  289. orders.setOwnWeight(ownGoodManage.getWeight());// 自有重量
  290. orders.setOwnCube(ownGoodManage.getCube());// 自有体积
  291. }
  292. }
  293. if (BusinessConstants.BOOLEAN_TRUE.equals(deliveryOutbound.getDetailCount())) {// 单订单单件标示
  294. orders.setSingleFlag(BusinessConstants.BOOLEAN_TRUE);
  295. }
  296. else {
  297. orders.setSingleFlag(BusinessConstants.BOOLEAN_FALSE);
  298. }
  299. orders.setSystemFrom(deliveryOutbound.getSystemFrom());// 系统标示
  300. orders.setBusinessLockFlag(BusinessConstants.BOOLEAN_FALSE);// 系统锁定标记
  301. orders.setPickType(deliveryOutbound.getPickType());// 拣货方式
  302. // 收货公司
  303. orders.setOrderRoute(deliveryOutbound.getOrderRoute());// 路向
  304. // 补充的字段
  305. orders.setPayType(deliveryOutbound.getPayType());// 付款方式
  306. orders.setIndentDate(deliveryOutbound.getIndentDate());
  307. orders.setPayCash(deliveryOutbound.getPayCash());
  308. orders.setPreFund(deliveryOutbound.getPreFund());
  309. orders.setPreAdvance(deliveryOutbound.getPreAdvance());
  310. orders.setPayAdvance2(deliveryOutbound.getPayAdvance2());
  311. orders.setTransPay(deliveryOutbound.getTransPay());
  312. orders.setStaffName(deliveryOutbound.getStaffName());
  313. orders.setTotalCost(deliveryOutbound.getTotalCost());
  314. orders.setPay(deliveryOutbound.getPay());
  315. orders.setPoints(deliveryOutbound.getPoints());
  316. orders.setSalesCash(deliveryOutbound.getSalesCash());
  317. orders.setAllPrefund(deliveryOutbound.getAllPrefund());
  318. orders.setCuPreFund(deliveryOutbound.getCuPreFund());
  319. orders.setMedianamePrint(deliveryOutbound.getMedianamePrint());
  320. orders.setMedianame(deliveryOutbound.getMedianame());
  321. orders.setListPrint(deliveryOutbound.getListPrint());
  322. orders.setInvoicePrint(deliveryOutbound.getInvoicePrint());
  323. orders.setRolegrouptype(deliveryOutbound.getRolegrouptype());
  324. orders.setSpare1(deliveryOutbound.getSpare1());
  325. orders.setSpare2(deliveryOutbound.getSpare2());
  326. orders.setSpare3(deliveryOutbound.getSpare3());
  327. orders.setSpare4(deliveryOutbound.getSpare4());
  328. orders.setSpare5(deliveryOutbound.getSpare5());
  329. orders.setSpare6(deliveryOutbound.getSpare6());
  330. orders.setSpare7(deliveryOutbound.getSpare7());
  331. orders.setSpare8(deliveryOutbound.getSpare8());
  332. orders.setSpare9(deliveryOutbound.getSpare9());
  333. orders.setSpare10(deliveryOutbound.getSpare10());
  334. orders.setCustomerOrderId(deliveryOutbound.getCustomerOrderId());// 客户订单ID
  335. orders.setCustomerRefferenceGuid(deliveryOutbound.getCustomerRefferenceGuid());
  336. // 是否允许拆分
  337. //orders.setIsSplitePicking(deliveryOutbound.getLotsAllowed());
  338. orders.setLotsAllowed( deliveryOutbound.getLotsAllowed() );
  339. // 默认分配数量0
  340. orders.setAssignedQuantity(0D);
  341. orders.setInvoiceAmount(deliveryOutbound.getInvoiceAmount() );
  342. orders.setInvoiceProject(deliveryOutbound.getInvoiceProject());
  343. orders.setInvoiceTitle(deliveryOutbound.getInvoiceTitle());
  344. orders.setIsSpecialInvoice(deliveryOutbound.getIsSpecialInvoice());
  345. orders.setOrderMemo(deliveryOutbound.getDescription());//备注
  346. orders.setIsProhibited(deliveryOutbound.getIsProhibited());//是否禁航
  347. //设置COD信息
  348. orders.setCodVenderId(deliveryOutbound.getCodVenderId());
  349. orders.setCodVenderCode(deliveryOutbound.getCodVenderCode());
  350. orders.setCodVenderName(deliveryOutbound.getCodVenderName());
  351. //获取推荐包材信息
  352. PackagingMaterialVO recommendPackagingMaterial = packagingMaterialService.findRecommendPackagingMaterial(accountId, Long.getLong(warehouseId), cube, weight);
  353. if(recommendPackagingMaterial != null) {
  354. orders.setPackagingMaterialId(recommendPackagingMaterial.getId());
  355. orders.setPackagingMaterialCode(recommendPackagingMaterial.getPackagingMaterialCode());
  356. orders.setPackagingMaterialName(recommendPackagingMaterial.getPackagingMaterialName());
  357. }
  358. // 市移动需求,新增以下四个字段
  359. orders.setIsPrint(deliveryOutbound.getIsPrint());
  360. orders.setIsDelivery(deliveryOutbound.getIsDelivery());
  361. orders.setIsReturn(deliveryOutbound.getIsReturn());
  362. orders.setIsInProvince(deliveryOutbound.getIsInProvince());
  363. orders.setReturnNumber(deliveryOutbound.getReturnNumber());
  364. if (null != deliveryOutbound.getInvoiceAmount() && deliveryOutbound.getInvoiceAmount().intValue() > 0){
  365. orders.setPrintInvoiceFlag("是");
  366. }
  367. else{
  368. orders.setPrintInvoiceFlag("否");
  369. }
  370. orders.setReceiverCompany(deliveryOutbound.getReceiverCompany());
  371. orders.setOrderCategory(deliveryOutbound.getOrderCategory());
  372. this.saveEntity(orders);
  373. List<DeliveryOutboundDetail> deliveryOutboundDetails =
  374. deliveryOutboundDetailService.listBy(deliveryOutboundId, accountId);
  375. allDetails.addAll(deliveryOutboundDetails);
  376. long i = 1;
  377. for (DeliveryOutboundDetail deliveryOutboundDetail : deliveryOutboundDetails) {
  378. if (BusinessConstants.BOOLEAN_FALSE.equals(deliveryOutboundDetail.getDeleteFlag())) {
  379. OrdersDetail ordersDetail = new OrdersDetail();
  380. ordersDetail.setOrderLineNo(i++);
  381. ordersDetail.setOrderId(orderId);// 出货单ID
  382. ordersDetail.setCustomerOrderLineNo(deliveryOutboundDetail.getCustomerOrderLineNo());// 客户订单行号
  383. // 订单行号
  384. ordersDetail.setItemId(deliveryOutboundDetail.getItemId());// 产品ID
  385. ordersDetail.setItemCode(deliveryOutboundDetail.getItemCode());// 产品代码
  386. ordersDetail.setItemName(deliveryOutboundDetail.getItemName());// 产品名称
  387. ordersDetail.setUnits(deliveryOutboundDetail.getUnits());// 单位
  388. ordersDetail.setWeight(deliveryOutboundDetail.getWeight());// 重量
  389. ordersDetail.setAccountId(deliveryOutboundDetail.getAccountId());// 账户编号
  390. ordersDetail.setCustomerId(deliveryOutboundDetail.getCustomerId());// 客户编号
  391. ordersDetail.setCustomerName(deliveryOutboundDetail.getCustomerName());// 客户名称
  392. ordersDetail.setCustomerCode(deliveryOutboundDetail.getCustomerCode());// 客户代码
  393. ordersDetail.setWarehouseId(deliveryOutboundDetail.getWarehouseId());// 仓库编号
  394. ordersDetail.setWarehouseName(deliveryOutboundDetail.getWarehouseName());// 仓库名称
  395. ordersDetail.setRelationedCustomerId(deliveryOutboundDetail.getRelationedCustomerId());// 客户关系人编号
  396. ordersDetail.setRelationedCustomerCode(deliveryOutboundDetail.getRelationedCustomerCode());// 客户关系人代码
  397. ordersDetail.setRelationedCustomerName(deliveryOutboundDetail.getRelationedCustomerName());// 客户关系人名称
  398. ordersDetail.setCustomerRefferenceId(deliveryOutbound.getCustomerRefferenceId());// 客户订单号
  399. ordersDetail.setBulk(deliveryOutboundDetail.getCube());// 体积
  400. ordersDetail.setNormalFlag(deliveryOutboundDetail.getNormalFlag());// 产品形态
  401. ordersDetail.setExpectedItemQuantity(deliveryOutboundDetail.getExpectedSendQuantity());// 预计发货数量
  402. ordersDetail.setAssignedQuantity(0d);// 已分配数量
  403. ordersDetail.setDeliveredQuantity(0d);// 已发运数量
  404. ordersDetail.setPickedQuantity(0d);// 已拣货数量
  405. ordersDetail.setPackingQuantity(0d);// 已装箱数量
  406. ordersDetail.setLotNumber(deliveryOutboundDetail.getLotNumber());// 批次号
  407. ItemVO itemVO = itemService.getItemVOByItemId(deliveryOutboundDetail.getItemId());
  408. if(itemVO != null) {
  409. ordersDetail.setItemSupplierId(itemVO.getTransceiverId());// 供应商编号
  410. ordersDetail.setItemSupplierCode(itemVO.getTransceiverCode());// 供应商代码
  411. ordersDetail.setItemSupplierName(itemVO.getTransceiverName());// 供应商名称
  412. }
  413. // 备注
  414. ordersDetail.setOutboundOrderId(deliveryOutboundId);// 出库订单ID
  415. ordersDetail.setOutboundKind(2301L);// 出库订单类型
  416. ordersDetail.setOutboundOrderDetailId(deliveryOutboundDetail.getId());//出库订单明细编号
  417. ordersDetail.setPrice(deliveryOutboundDetail.getPrice());// 销售单价
  418. ordersDetail.setTotalFee(deliveryOutboundDetail.getTotalFee());// 价值
  419. ordersDetail.setItemGroupId(deliveryOutboundDetail.getItemGroupId());
  420. ordersDetail.setItemGroupCode(deliveryOutboundDetail.getItemGroupCode());
  421. ordersDetail.setItemGroupName(deliveryOutboundDetail.getItemGroupName());
  422. // 补充的字段
  423. ordersDetail.setSpare1(deliveryOutboundDetail.getSpare1());
  424. ordersDetail.setSpare2(deliveryOutboundDetail.getSpare2());
  425. ordersDetail.setSpare3(deliveryOutboundDetail.getSpare3());
  426. ordersDetail.setSpare4(deliveryOutboundDetail.getSpare4());
  427. ordersDetail.setSpare5(deliveryOutboundDetail.getSpare5());
  428. ordersDetail.setSpare6(deliveryOutboundDetail.getSpare6());
  429. ordersDetail.setSpare7(deliveryOutboundDetail.getSpare7());
  430. ordersDetail.setSpare8(deliveryOutboundDetail.getSpare8());
  431. ordersDetail.setSpare9(deliveryOutboundDetail.getSpare9());
  432. ordersDetail.setSpare10(deliveryOutboundDetail.getSpare10());
  433. ordersDetail.setSpecification(deliveryOutboundDetail.getSpecification());
  434. ordersDetail.setIsAssignSequence(deliveryOutboundDetail.getIsAssignSequence());
  435. ordersDetail.setSequenceId(deliveryOutboundDetail.getSequenceId());
  436. ordersDetail.setLocationId(deliveryOutboundDetail.getLocationId());
  437. ordersDetail.setLocationName(deliveryOutboundDetail.getLocationName());
  438. ordersDetail.setCoding(deliveryOutboundDetail.getCoding());
  439. ordersDetailService.saveEntity(ordersDetail);
  440. }
  441. }
  442. }
  443. }
  444. replenishmentDetailService.sendStockOutMessageBydeliveryOutBoundConfirm(allDetails);
  445. }
  446. @Transactional
  447. public void genOrdersFromReturnOutbound(List<ReturnOutbound> returnOutbounds) {
  448. if (returnOutbounds == null || returnOutbounds.isEmpty()) {
  449. return;
  450. }
  451. for (ReturnOutbound returnOutbound : returnOutbounds) {
  452. if (BusinessConstants.BOOLEAN_FALSE.equals(returnOutbound.getDeleteFlag())) {
  453. Orders orders = new Orders();
  454. String orderId = IdGenerator.getOrdersId();
  455. String accountId = returnOutbound.getAccountId();
  456. String warehouseId = returnOutbound.getWarehouseId();
  457. Double weight = returnOutbound.getWeight();
  458. Double cube = returnOutbound.getCube();
  459. String returnOutboundId = returnOutbound.getReturnOutboundId();
  460. orders.setOrderId(orderId);
  461. orders.setAccountId(accountId);// 账户编号
  462. orders.setCustomerId(returnOutbound.getCustomerId());// 货主编号
  463. orders.setCustomerName(returnOutbound.getCustomerName());// 货主名称
  464. orders.setCustomerCode(returnOutbound.getCustomerCode());// 货主代码
  465. orders.setWarehouseId(warehouseId);// 仓库编号
  466. orders.setWarehouseName(returnOutbound.getWarehouseName());// 仓库名称
  467. orders.setSalesPlatform(returnOutbound.getSalesPlatform());// 销售平台
  468. // 订单失效时间
  469. orders.setOutboundOrderId(returnOutboundId);// 出库订单ID
  470. orders.setOutboundKind(2303L);// 出库订单类型
  471. orders.setOutType("2401");// 出库类型????
  472. orders.setDeliveryType(returnOutbound.getDeliveryType());// 送货方式
  473. orders.setCustomerRefferenceId(returnOutbound.getCustomerRefferenceId());// 客户订单号
  474. orders.setOrderDealType(returnOutbound.getOrderDealType());// 订单处理类型
  475. orders.setOrderStatus(WMS_ORDERS_STATUS_NEW);// 订单状态
  476. orders.setDeliveryStatus(WMS_ORDERS_TASK_NEW);// 发运状态
  477. orders.setPackingStatus(WMS_ORDERS_TASK_NEW);// 包装状态
  478. orders.setPickStatus(WMS_ORDERS_TASK_NEW);// 拣货状态
  479. orders.setAssignedStatus(WMS_ORDERS_TASK_NEW);// 分配状态
  480. // 包装完成时间
  481. // 出货结案时间
  482. // 发货单提货时间
  483. // 计划发货时间
  484. // 实际发货时间
  485. // 预期到达时间
  486. // 实际到达时间
  487. // 签收时间
  488. // 回单时间
  489. Integer detailCount = returnOutbound.getDetailCount();
  490. orders.setDetailCount(detailCount);// 明细数量
  491. orders.setExpectedSendQuantity(returnOutbound.getExpectedSendQuantity());// 预期发货数量
  492. orders.setAssignedQuantity(0d);// 已分配数量
  493. orders.setDeliveredQuantity(0d);// 发货数量
  494. orders.setPickedQuantity(0d);// 已拣货数量
  495. orders.setPackingQuantity(0d);// 已装箱量
  496. // 订单拣货序号
  497. // 是否拆单拣货
  498. orders.setTotalFee(returnOutbound.getTotalFee());// 价值
  499. orders.setLogisticsFee(returnOutbound.getLogisticsFee());// 物流费用
  500. orders.setCollectionFlag(returnOutbound.getCollectionFlag());// 代收货款
  501. orders.setWeight(weight);// 重量
  502. orders.setBulk(cube);// 体积
  503. // 件数
  504. // 拣货单号
  505. // 发货单号
  506. // 备注
  507. // 未分配成功标志
  508. orders.setDriver(returnOutbound.getDriver());// 司机
  509. orders.setTruckNumber(returnOutbound.getTruckNumber());// 车辆号码
  510. orders.setDeliveryScore(returnOutbound.getDeliveryScore());// 送货评分
  511. orders.setDrliverPhone(returnOutbound.getDrliverPhone());// 司机联系方式
  512. orders.setIndentityCard(returnOutbound.getIndentityCard());// 身份证
  513. orders.setCarrierTrackingNumber(returnOutbound.getCarrierTrackingNumber());// 承运单号
  514. orders.setCarrierId(returnOutbound.getCarrierId());// 承运商编号
  515. orders.setCarrierCode(returnOutbound.getCarrierCode());// 承运商代码
  516. orders.setCarrierName(returnOutbound.getCarrierName());// 承运商名称
  517. orders.setReceiverId(returnOutbound.getReceiverId());// 收货人编号
  518. orders.setReceiverCode(returnOutbound.getReceiverCode());// 收货人代码
  519. orders.setReceiverName(returnOutbound.getReceiverName());// 收货人名称
  520. orders.setToTransceiverAddressId(returnOutbound.getToTransceiverAddressId());// 收货地址编号
  521. orders.setReceiverCountry(returnOutbound.getReceiverCountry());// 收货国家
  522. orders.setReceiverProvince(returnOutbound.getReceiverProvince());// 收货省
  523. orders.setReceiverCity(returnOutbound.getReceiverCity());// 收货市
  524. orders.setReceiverDistrict(returnOutbound.getReceiverDistrict());// 收货县
  525. orders.setReceiverStreet(returnOutbound.getReceiverStreet());// 收货街道
  526. orders.setReceiverZipcode(globalPostCodeSettingService.getPostCodeForPlace(returnOutbound.getReceiverProvince(), returnOutbound.getReceiverCity(), returnOutbound.getReceiverDistrict(), returnOutbound.getReceiverStreet()));// 收货邮编
  527. orders.setReceiverContactor(returnOutbound.getReceiverContactor());// 收货联系人
  528. orders.setReceiverContactorPhone(returnOutbound.getReceiverContactorPhone());// 收货联系人电话
  529. orders.setReceiverContactorMobile(returnOutbound.getReceiverContactorMobile());// 收货联系人手机
  530. // 自有货品标记
  531. // 自有货品入库单号
  532. // 自有重量
  533. // 自有体积
  534. if(BusinessConstants.BOOLEAN_TRUE.equals(detailCount)) {
  535. orders.setSingleFlag(BusinessConstants.BOOLEAN_TRUE);// 单订单单件标示
  536. } else {
  537. orders.setSingleFlag(BusinessConstants.BOOLEAN_FALSE);
  538. }
  539. orders.setSystemFrom(returnOutbound.getSystemFrom());// 系统标示
  540. // 付款方式
  541. orders.setBusinessLockFlag(BusinessConstants.BOOLEAN_FALSE);// 系统锁定标记
  542. orders.setPickType(returnOutbound.getPickType());// 拣货方式
  543. // 收货公司
  544. orders.setOrderRoute(returnOutbound.getOrderRoute());// 路向// 路向
  545. //获取推荐包材信息
  546. PackagingMaterialVO recommendPackagingMaterial = packagingMaterialService.findRecommendPackagingMaterial(accountId, Long.getLong(warehouseId), cube, weight);
  547. if(recommendPackagingMaterial != null) {
  548. orders.setPackagingMaterialId(recommendPackagingMaterial.getId());
  549. orders.setPackagingMaterialCode(recommendPackagingMaterial.getPackagingMaterialCode());
  550. orders.setPackagingMaterialName(recommendPackagingMaterial.getPackagingMaterialName());
  551. }
  552. this.saveEntity(orders);
  553. List<ReturnOutboundDetail> returnOutboundDetails =
  554. returnOutboundDetailService.listBy(returnOutboundId, accountId);
  555. long i = 1;
  556. for (ReturnOutboundDetail returnOutboundDetail : returnOutboundDetails) {
  557. if (BusinessConstants.BOOLEAN_FALSE.equals(returnOutboundDetail.getDeleteFlag())) {
  558. OrdersDetail ordersDetail = new OrdersDetail();
  559. ordersDetail.setOrderLineNo(i ++);
  560. ordersDetail.setOrderId(orderId);// 出货单ID
  561. ordersDetail.setCustomerOrderLineNo(returnOutboundDetail.getCustomerOrderLineNo());// 客户订单行号
  562. // 订单行号
  563. ordersDetail.setItemId(returnOutboundDetail.getItemId());// 产品ID
  564. ordersDetail.setItemCode(returnOutboundDetail.getItemCode());// 产品代码
  565. ordersDetail.setItemName(returnOutboundDetail.getItemName());// 产品名称
  566. ordersDetail.setUnits(returnOutboundDetail.getUnits());// 单位
  567. ordersDetail.setWeight(returnOutboundDetail.getWeight());// 重量
  568. ordersDetail.setAccountId(returnOutboundDetail.getAccountId());// 账户编号
  569. ordersDetail.setCustomerId(returnOutboundDetail.getCustomerId());// 客户编号
  570. ordersDetail.setCustomerName(returnOutboundDetail.getCustomerName());// 客户名称
  571. ordersDetail.setCustomerCode(returnOutboundDetail.getCustomerCode());// 客户代码
  572. ordersDetail.setWarehouseId(returnOutboundDetail.getWarehouseId());// 仓库编号
  573. ordersDetail.setWarehouseName(returnOutboundDetail.getWarehouseName());// 仓库名称
  574. ordersDetail.setRelationedCustomerId(returnOutboundDetail.getRelationedCustomerId());// 客户关系人编号
  575. ordersDetail.setRelationedCustomerCode(returnOutboundDetail.getRelationedCustomerCode());// 客户关系人代码
  576. ordersDetail.setRelationedCustomerName(returnOutboundDetail.getRelationedCustomerName());// 客户关系人名称
  577. ordersDetail.setCustomerRefferenceId(returnOutbound.getCustomerRefferenceId());// 客户订单号
  578. ordersDetail.setBulk(returnOutboundDetail.getCube());// 体积
  579. ordersDetail.setNormalFlag(returnOutboundDetail.getNormalFlag());// 产品形态
  580. ordersDetail.setExpectedItemQuantity(returnOutboundDetail.getExpectedSendQuantity());// 预计发货数量
  581. ordersDetail.setAssignedQuantity(0d);// 已分配数量
  582. ordersDetail.setDeliveredQuantity(0d);// 已发运数量
  583. ordersDetail.setPickedQuantity(0d);// 已拣货数量
  584. ordersDetail.setPackingQuantity(0d);// 已装箱数量
  585. ordersDetail.setLotNumber(returnOutboundDetail.getLotNumber());// 批次号
  586. ItemVO itemVO = itemService.getItemVOByItemId(returnOutboundDetail.getItemId());
  587. if(itemVO != null) {
  588. ordersDetail.setItemSupplierId(itemVO.getTransceiverId());// 供应商编号
  589. ordersDetail.setItemSupplierCode(itemVO.getTransceiverCode());// 供应商代码
  590. ordersDetail.setItemSupplierName(itemVO.getTransceiverName());// 供应商名称
  591. }
  592. // 备注
  593. ordersDetail.setOutboundOrderId(returnOutboundId);// 出库订单ID
  594. ordersDetail.setOutboundKind(2303L);// 出库订单类型
  595. ordersDetail.setOutboundOrderDetailId(returnOutboundDetail.getId());//出库订单明细编号
  596. ordersDetail.setPrice(returnOutboundDetail.getPrice());// 销售单价
  597. ordersDetail.setTotalFee(returnOutboundDetail.getTotalFee());// 价值
  598. ordersDetail.setIsAssignSequence(returnOutboundDetail.getIsAssignSequence());
  599. ordersDetail.setSequenceId(returnOutboundDetail.getSequenceId());
  600. ordersDetailService.saveEntity(ordersDetail);
  601. }
  602. }
  603. }
  604. }
  605. }
  606. public List<List<String>> checkForzeFilter(List<Object> ids) {
  607. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  608. List<String> legalList = new ArrayList<String>();
  609. Map<String, Object> param = new HashMap<String, Object>();
  610. param.put("ids", ids);
  611. List<Orders> checkList =
  612. this.daoFactory
  613. .getJdbcDao(qc)
  614. .query(
  615. "select ORDER_ID from wms_orders where DELETE_FLAG = 0 AND BUSINESS_LOCK_FLAG=0 and ORDER_STATUS=5201 and ORDER_ID in (:ids)",
  616. param);
  617. for (Orders mmm : checkList) {
  618. legalList.add(mmm.getOrderId());
  619. }
  620. List<String> illegealList = new ArrayList<String>();
  621. for (Object obj : ids) {
  622. if (!legalList.contains(obj.toString())) {
  623. illegealList.add(obj.toString());
  624. }
  625. }
  626. List<List<String>> resultList = new ArrayList<List<String>>();
  627. resultList.add(legalList);
  628. resultList.add(illegealList);
  629. return resultList;
  630. }
  631. public List<List<String>> checkActiveFilter(List<Object> ids) {
  632. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  633. List<String> legalList = new ArrayList<String>();
  634. Map<String, Object> param = new HashMap<String, Object>();
  635. param.put("ids", ids);
  636. List<Orders> checkList =
  637. this.daoFactory
  638. .getJdbcDao(qc)
  639. .query(
  640. "select ORDER_ID from wms_orders where DELETE_FLAG = 0 AND BUSINESS_LOCK_FLAG=0 and ORDER_STATUS=5200 and ORDER_ID in (:ids)",
  641. param);
  642. for (Orders mmm : checkList) {
  643. legalList.add(mmm.getOrderId());
  644. }
  645. List<String> illegealList = new ArrayList<String>();
  646. for (Object obj : ids) {
  647. if (!legalList.contains(obj.toString())) {
  648. illegealList.add(obj.toString());
  649. }
  650. }
  651. List<List<String>> resultList = new ArrayList<List<String>>();
  652. resultList.add(legalList);
  653. resultList.add(illegealList);
  654. return resultList;
  655. }
  656. /**
  657. * <p>
  658. * Description:[方法功能中文描述]
  659. * </p>
  660. *
  661. * @param sql 参数说明
  662. * @param args 参数说明
  663. * @return 返回值说明
  664. */
  665. public List<List<String>> checkAllocateFilter(List<Object> ids) {
  666. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  667. // 条件 如果有业务锁标示 则需要做对应的过滤,只需要查询出主键就可以了
  668. List<String> legalList = new ArrayList<String>();
  669. Map<String, Object> param = new HashMap<String, Object>();
  670. param.put("ids", ids);
  671. List<Orders> checkList =
  672. this.daoFactory
  673. .getJdbcDao(qc)
  674. .query(
  675. "select ORDER_ID from wms_orders where DELETE_FLAG = 0 AND BUSINESS_LOCK_FLAG=0 and ORDER_STATUS<>5204 and ORDER_STATUS<>5200 and (ASSIGNED_STATUS=0 OR ASSIGNED_STATUS =1 ) and ORDER_ID in (:ids)",
  676. param);
  677. for (Orders mmm : checkList) {
  678. legalList.add(mmm.getOrderId());
  679. }
  680. List<String> illegealList = new ArrayList<String>();
  681. for (Object obj : ids) {
  682. if (!legalList.contains(obj.toString())) {
  683. illegealList.add(obj.toString());
  684. }
  685. }
  686. List<List<String>> resultList = new ArrayList<List<String>>();
  687. resultList.add(legalList);
  688. resultList.add(illegealList);
  689. return resultList;
  690. }
  691. public Map<String, Object> doAllocate(List<String> orderIds) {
  692. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  693. Map<String, Object> param = new HashMap<String, Object>();
  694. Map<String, Object> result = new HashMap<String, Object>();
  695. param.put("ids", orderIds);
  696. List<Orders> ordersList =
  697. this.daoFactory.getJdbcDao(qc).query("select * from wms_orders where ORDER_ID in (:ids)", param);
  698. List<PickListDetail> allpkList = new ArrayList<PickListDetail>();
  699. List<OrdersDetail> stockOutOrdersDetails = new ArrayList<OrdersDetail>();
  700. for (Orders orders : ordersList) {
  701. List<Object> allocateResult = null;
  702. try{
  703. allocateResult =allocateInventoryService.allocate(orders);
  704. }catch(AllocateException ex){
  705. allocateResult = ex.getAllocateResult();
  706. }
  707. List<PickListDetail> pklist =(List<PickListDetail>) allocateResult.get(0);
  708. List<OrdersDetail> stockOutlist =(List<OrdersDetail>) allocateResult.get(1);
  709. if( pklist.size()>0 ){
  710. allpkList.addAll(pklist);
  711. }
  712. if( stockOutlist!=null &&stockOutlist.size()>0 ){
  713. stockOutOrdersDetails.addAll(stockOutlist);
  714. }
  715. }
  716. if(allpkList!=null && allpkList.size()>0 ){
  717. replenishmentDetailService.sendCheckReplenishmentMessage(allpkList);
  718. }
  719. if( stockOutOrdersDetails!=null && stockOutOrdersDetails.size()>0 ){
  720. replenishmentDetailService.sendStockOutMessage(stockOutOrdersDetails);
  721. }
  722. result.put("allpkList", allpkList);
  723. result.put("orders", ordersList);
  724. result.put("ordersDetails", stockOutOrdersDetails);
  725. return result;
  726. }
  727. public List<List<String>> checkWaveFilter(List<Object> ids) {
  728. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  729. // 条件 如果有业务锁标示 则需要做对应的过滤,只需要查询出主键就可以了
  730. List<String> legalList = new ArrayList<String>();
  731. Map<String, Object> param = new HashMap<String, Object>();
  732. param.put("ids", ids);
  733. param.put("frozenStatus", WMS_ORDERS_STATUS_FORZEN);
  734. param.put("cancledStatus", WMS_ORDERS_STATUS_CANCLED);
  735. //String sql = "select ORDER_ID from WMS_ORDERS where DELETE_FLAG = 0 and IS_CANCLE=0 and (ORDER_STATUS != :frozenStatus or ORDER_STATUS != :cancledStatus) and (ASSIGNED_STATUS=0 or ASSIGNED_STATUS =1 ) and ( WAVE_ID IS NULL ) and ORDER_ID in (:ids)";
  736. String sql = "select ORDER_ID from WMS_ORDERS where DELETE_FLAG = 0 and IS_CANCLE=0 and (ORDER_STATUS != :frozenStatus AND ORDER_STATUS != :cancledStatus) and ( PICK_STATUS=0 ) and ( WAVE_ID IS NULL ) and ORDER_ID in (:ids)";
  737. List<Orders> checkList = this.daoFactory.getJdbcDao(qc).query(sql, param);
  738. for (Orders mmm : checkList) {
  739. legalList.add(mmm.getOrderId());
  740. }
  741. List<String> illegealList = new ArrayList<String>();
  742. for (Object obj : ids) {
  743. if (!legalList.contains(obj.toString())) {
  744. illegealList.add(obj.toString());
  745. }
  746. }
  747. List<List<String>> resultList = new ArrayList<List<String>>();
  748. resultList.add(legalList);
  749. resultList.add(illegealList);
  750. return resultList;
  751. }
  752. public List<Orders> doJoinWave(List<String> orderIds,boolean needPrintInvoice) {
  753. List<Orders> ordersList = new ArrayList<Orders>();
  754. if(orderIds!=null && orderIds.size()>0 ){
  755. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  756. Map<String, Object> param = new HashMap<String, Object>();
  757. param.put("ids", orderIds);
  758. ordersList =this.daoFactory.getJdbcDao(qc).query("select * from wms_orders where ORDER_ID in (:ids)", param);
  759. ordersWaveService.generateOrdersWaveByOrdersList(ordersList,needPrintInvoice);
  760. }
  761. return ordersList;
  762. }
  763. public Object[] findBy(String idCode, String type, String mode, String userId) {
  764. String orderMemo = "";
  765. String packagingMaterialCode = "";
  766. List<CustomerVO> customerList = userCustomerService.readUserCustomerByUserId(userId);
  767. List<String> customerIds = new ArrayList<String>();
  768. if (CollectionUtils.isNotEmpty(customerList)) {
  769. for (CustomerVO customerVO : customerList) {
  770. customerIds.add(customerVO.getCustomerId());
  771. }
  772. }
  773. else {
  774. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  775. }
  776. List<String> warehouseIds = new ArrayList<String>();
  777. List<WarehouseVO> warehouseList = userWarehouseService.readUserWarehouseByUserId(userId);
  778. if (CollectionUtils.isNotEmpty(warehouseList)) {
  779. for (WarehouseVO warehouseVO : warehouseList) {
  780. warehouseIds.add(warehouseVO.getWarehouseId());
  781. }
  782. }
  783. else {
  784. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  785. }
  786. List<OrdersDetail> ordersDetails = new ArrayList<OrdersDetail>();
  787. if (type.equals("3801")) {// 订单号
  788. Map<String, Object> params = new HashMap<String, Object>();
  789. params.put("orderId", idCode);
  790. params.put("warehouseIds", warehouseIds);
  791. params.put("customerIds", customerIds);
  792. params.put("frozenStatus", WMS_ORDERS_STATUS_FORZEN);
  793. params.put("canceledStatus", WMS_ORDERS_STATUS_CANCLED);
  794. String sql =
  795. "select d.* from WMS_ORDERS_DETAIL d where d.ORDER_ID = :orderId and d.WAREHOUSE_ID in (:warehouseIds) and d.CUSTOMER_ID in (:customerIds) and d.DELETE_FLAG = 0 and d.PACKING_QUANTITY < d.PICKED_QUANTITY and exists (select 1 from WMS_ORDERS o where o.ORDER_ID = d.ORDER_ID and (o.ORDER_STATUS != :frozenStatus or o.ORDER_STATUS != :canceledStatus) and o.IS_CANCLE = 0 and o.DELETE_FLAG = 0)";
  796. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  797. Orders _orders = this.getEntityById(idCode, Orders.class);
  798. if(_orders != null) {
  799. if(StringUtils.isNotBlank(_orders.getOrderMemo())) {
  800. orderMemo = _orders.getOrderMemo();
  801. }
  802. // if(StringUtils.isNotBlank(_orders.getPackagingMaterialCode())) {
  803. // packagingMaterialCode = _orders.getPackagingMaterialCode();
  804. // }
  805. packagingMaterialCode = DataUtils.asString(_orders.getPackagingMaterialCode(), "B");
  806. }
  807. }
  808. else if (type.equals("3803")) {// 地址编号
  809. String sql =
  810. "select o.* from WMS_ORDERS o where o.DELETE_FLAG = 0 and o.IS_CANCLE = 0 and (o.ORDER_STATUS != :frozenStatus or o.ORDER_STATUS != :canceledStatus) and o.PACKING_STATUS != :packingStatus and exists (select 1 from CRM_TRANSCEIVER_ADDRESS c where c.ID = o.TO_TRANSCEIVER_ADDRESS_ID and c.ADDRESS_CODE = :addressCode and c.DELETE_FLAG = 0) order by o.CREATION_TIME desc";
  811. Map<String, Object> params = new HashMap<String, Object>();
  812. params.put("addressCode", idCode);
  813. params.put("frozenStatus", WMS_ORDERS_STATUS_FORZEN);
  814. params.put("canceledStatus", WMS_ORDERS_STATUS_CANCLED);
  815. params.put("packingStatus", WMS_ORDERS_TASK_ALL);
  816. List<Orders> ordersList = findRecordsByConditions(sql, params, Orders.class);
  817. if (CollectionUtils.isNotEmpty(ordersList)) {
  818. List<String> orderIds = new ArrayList<String>();
  819. for (Orders orders : ordersList) {
  820. orderIds.add(orders.getOrderId());
  821. }
  822. params.clear();
  823. params.put("orderIds", orderIds);
  824. params.put("warehouseIds", warehouseIds);
  825. params.put("customerIds", customerIds);
  826. sql =
  827. "select d.* from WMS_ORDERS_DETAIL d where d.ORDER_ID in (:orderIds) and d.WAREHOUSE_ID in (:warehouseIds) and d.CUSTOMER_ID in (:customerIds) and d.DELETE_FLAG = 0 and d.PACKING_QUANTITY < d.PICKED_QUANTITY ";
  828. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  829. }
  830. }
  831. else if (type.equals("3802")) { // 商品
  832. Map<String, Object> params = new HashMap<String, Object>();
  833. params.put("itemId", idCode);
  834. params.put("warehouseIds", warehouseIds);
  835. params.put("customerIds", customerIds);
  836. params.put("frozenStatus", WMS_ORDERS_STATUS_FORZEN);
  837. params.put("canceledStatus", WMS_ORDERS_STATUS_CANCLED);
  838. String sql =
  839. "select o.* from WMS_ORDERS_DETAIL o where o.WAREHOUSE_ID in (:warehouseIds) and o.CUSTOMER_ID in (:customerIds) and o.DELETE_FLAG = 0 and o.PACKING_QUANTITY < o.PICKED_QUANTITY and exists (select 1 from WMS_ORDERS w where w.SINGLE_FLAG = 1 and w.ORDER_ID = o.ORDER_ID and (w.ORDER_STATUS != :frozenStatus or w.ORDER_STATUS != :canceledStatus) and w.DELETE_FLAG = 0 and w.IS_CANCLE = 0) and exists (select 1 from DATA_ITEM d where d.BARCODE_NUMBER = :itemId and d.ITEM_ID = o.ITEM_ID) order by o.CREATION_TIME desc, o.ORDER_ID desc";
  840. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  841. /*if (CollectionUtils.isNotEmpty(ordersDetailList)) {
  842. params.clear();
  843. String _orderId = ordersDetailList.get(0).getOrderId();
  844. params.put("orderId", _orderId);
  845. params.put("warehouseIds", warehouseIds);
  846. params.put("customerIds", customerIds);
  847. sql =
  848. "select * from WMS_ORDERS_DETAIL where ORDER_ID = :orderId and WAREHOUSE_ID in (:warehouseIds) and CUSTOMER_ID in (:customerIds) and DELETE_FLAG = 0 and PACKING_QUANTITY < PICKED_QUANTITY";
  849. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  850. }*/
  851. }
  852. else if (type.equals("3804")) { //箱号
  853. String sql = "select * from WMS_PICKLIST_BOX where DELETE_FLAG = 0 and BOX_NO = :boxNo";
  854. Map<String, Object> map = new HashMap<String, Object>();
  855. map.put("boxNo", idCode);
  856. PicklistBox picklistBox = findUniqueRecordByConditions(sql, map, PicklistBox.class);
  857. if(picklistBox == null) {
  858. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  859. } else {
  860. Map<String, Object> params = new HashMap<String, Object>();
  861. String _orderId = picklistBox.getOrderId();
  862. params.put("orderId", _orderId);
  863. params.put("warehouseIds", warehouseIds);
  864. params.put("customerIds", customerIds);
  865. params.put("frozenStatus", WMS_ORDERS_STATUS_FORZEN);
  866. params.put("canceledStatus", WMS_ORDERS_STATUS_CANCLED);
  867. sql =
  868. "select d.* from WMS_ORDERS_DETAIL d where d.ORDER_ID = :orderId and d.WAREHOUSE_ID in (:warehouseIds) and d.CUSTOMER_ID in (:customerIds) and d.DELETE_FLAG = 0 and d.PACKING_QUANTITY < d.PICKED_QUANTITY and exists (select 1 from WMS_ORDERS o where o.ORDER_ID = d.ORDER_ID and (o.ORDER_STATUS != :frozenStatus or o.ORDER_STATUS != :canceledStatus) and o.IS_CANCLE = 0 and o.DELETE_FLAG = 0)";
  869. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  870. Orders _orders = this.getEntityById(_orderId, Orders.class);
  871. if(_orders != null) {
  872. if(StringUtils.isNotBlank(_orders.getOrderMemo())) {
  873. orderMemo = _orders.getOrderMemo();
  874. }
  875. // if(StringUtils.isNotBlank(_orders.getPackagingMaterialCode())) {
  876. // packagingMaterialCode = _orders.getPackagingMaterialCode();
  877. // }
  878. packagingMaterialCode = DataUtils.asString(_orders.getPackagingMaterialCode(), "B");
  879. }
  880. }
  881. }
  882. else if (type.equals("3805")){
  883. Map<String, Object> params = new HashMap<String, Object>();
  884. params.put("orderId", idCode);
  885. params.put("warehouseIds", warehouseIds);
  886. params.put("customerIds", customerIds);
  887. params.put("frozenStatus", WMS_ORDERS_STATUS_FORZEN);
  888. params.put("canceledStatus", WMS_ORDERS_STATUS_CANCLED);
  889. String sql =
  890. "select d.* from WMS_ORDERS_DETAIL d where d.CUSTOMER_REFFERENCE_ID = :orderId and d.WAREHOUSE_ID in (:warehouseIds) and d.CUSTOMER_ID in (:customerIds) and d.DELETE_FLAG = 0 and d.PACKING_QUANTITY < d.PICKED_QUANTITY and exists (select 1 from WMS_ORDERS o where o.ORDER_ID = d.ORDER_ID and (o.ORDER_STATUS != :frozenStatus or o.ORDER_STATUS != :canceledStatus) and o.IS_CANCLE = 0 and o.DELETE_FLAG = 0)";
  891. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  892. if(org.apache.commons.collections.CollectionUtils.isEmpty(ordersDetails)){
  893. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  894. }
  895. Orders _orders = this.getEntityById(ordersDetails.get(0).getOrderId(), Orders.class);
  896. if(_orders != null) {
  897. if(StringUtils.isNotBlank(_orders.getOrderMemo())) {
  898. orderMemo = _orders.getOrderMemo();
  899. }
  900. // if(StringUtils.isNotBlank(_orders.getPackagingMaterialCode())) {
  901. // packagingMaterialCode = _orders.getPackagingMaterialCode();
  902. // }
  903. packagingMaterialCode = DataUtils.asString(_orders.getPackagingMaterialCode(), "B");
  904. }
  905. }
  906. else if(type.equals("3806")){
  907. Map<String, Object> params = new HashMap<String, Object>();
  908. params.put("orderId", idCode);
  909. String sql = "select ORDER_DETAIL_ID from wms_pick_list_detail where PICK_LIST_ID = :orderId and DELETE_FLAG = 0";
  910. List<PickListDetail> pickListDetails = this.pickListService.findRecordsByConditions(sql, params, PickListDetail.class);
  911. List<String> orderIds = new ArrayList<String>();
  912. List<String> orderDetailIds = new ArrayList<String>();
  913. if(org.apache.commons.collections.CollectionUtils.isNotEmpty(pickListDetails)){
  914. for (PickListDetail pld : pickListDetails){
  915. orderDetailIds.add(pld.getOrderDetailId());
  916. }
  917. orderIds.add(pickListDetails.get(0).getOrderId());
  918. }
  919. if(org.apache.commons.collections.CollectionUtils.isEmpty(orderIds)){
  920. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  921. }
  922. params.clear();
  923. params.put("orderDetailIds", orderDetailIds);
  924. params.put("warehouseIds", warehouseIds);
  925. params.put("customerIds", customerIds);
  926. sql = "select * from WMS_ORDERS_DETAIL where ID in (:orderDetailIds) and WAREHOUSE_ID in (:warehouseIds) and CUSTOMER_ID in (:customerIds) and DELETE_FLAG = 0";
  927. ordersDetails = findRecordsByConditions(sql, params, OrdersDetail.class);
  928. if(org.apache.commons.collections.CollectionUtils.isEmpty(ordersDetails)){
  929. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  930. }
  931. Orders _orders = this.getEntityById(ordersDetails.get(0).getOrderId(), Orders.class);
  932. if(_orders != null) {
  933. if(StringUtils.isNotBlank(_orders.getOrderMemo())) {
  934. orderMemo = _orders.getOrderMemo();
  935. }
  936. // if(StringUtils.isNotBlank(_orders.getPackagingMaterialCode())) {
  937. // packagingMaterialCode = _orders.getPackagingMaterialCode();
  938. // }
  939. packagingMaterialCode = DataUtils.asString(_orders.getPackagingMaterialCode(), "B");
  940. }
  941. }
  942. if (CollectionUtils.isNotEmpty(ordersDetails)) {
  943. List<String> detailIds = new ArrayList<String>();
  944. List<String> idsArray = new ArrayList<String>();
  945. for (OrdersDetail ordersDetail : ordersDetails) {
  946. detailIds.add(ordersDetail.getId());
  947. if(!idsArray.contains(ordersDetail.getOrderId())){
  948. idsArray.add(ordersDetail.getOrderId());
  949. }
  950. }
  951. if(mode.equals("1")) {
  952. Map tempMap = new HashMap();
  953. tempMap.put("ids", idsArray);
  954. long expectedQuantity = this.daoFactory.getJdbcDao().queryForLong("SELECT SUM(EXPECTED_SEND_QUANTITY) FROM WMS_ORDERS WHERE ORDER_ID IN(:ids) ", tempMap);
  955. long assignedQuantity = this.daoFactory.getJdbcDao().queryForLong("SELECT SUM(ASSIGNED_QUANTITY) FROM WMS_ORDERS WHERE ORDER_ID IN(:ids) ", tempMap);
  956. long pickedQuantity = this.daoFactory.getJdbcDao().queryForLong("SELECT SUM(PICKED_QUANTITY) FROM WMS_ORDERS WHERE ORDER_ID IN(:ids) ", tempMap);
  957. if( expectedQuantity!=assignedQuantity || expectedQuantity!=pickedQuantity ){
  958. throw new CommonException("预计发货数量、已分配数量、已拣货数量不相等,请检查是否拣货完成");
  959. }
  960. }
  961. return new Object[] { ordersDetails, detailIds, orderMemo, packagingMaterialCode };
  962. }
  963. else {
  964. return new Object[] { new ArrayList<OrdersDetail>(), new ArrayList<Long>(), orderMemo, packagingMaterialCode };
  965. }
  966. }
  967. /**
  968. * 根据波次号查询订单
  969. * @param waveId
  970. * @return
  971. */
  972. public List<Orders> queryOrdersByWave(String waveId) {
  973. OrdersWave ordersWave = ordersWaveService.getEntityById(waveId, OrdersWave.class);
  974. String warehouseId = ordersWave.getWarehouseId();
  975. WarehouseVO warehouseVO = this.warehouseService.getEntity(warehouseId + "");
  976. String sql = "";
  977. if (warehouseVO.getWarePrintRule() == null || warehouseVO.getWarePrintRule().longValue() == 3501) {
  978. // 按订单顺序
  979. sql = "SELECT * FROM wms_orders WHERE WAVE_ID =? AND DELETE_FLAG =0 ORDER BY ORDER_ID ";
  980. }
  981. else if (warehouseVO.getWarePrintRule().longValue() == 3502) {
  982. // 按拣货单顺序
  983. sql =
  984. "SELECT * FROM wms_orders WHERE WAVE_ID =? AND DELETE_FLAG =0 ORDER BY COMBINED_ORDER_ID,PICK_SEQUENCE ";
  985. }
  986. else if (warehouseVO.getWarePrintRule().longValue() == 3503) {
  987. // 按路向
  988. sql = "SELECT * FROM wms_orders WHERE WAVE_ID =? AND DELETE_FLAG =0 ORDER BY ORDER_ROUTE ";
  989. }
  990. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(QueryContext.createQueryContext(Orders.class));
  991. return dao.query(sql, waveId);
  992. }
  993. /**
  994. * 根据拣货单号查询订单
  995. * @param pickListId
  996. * @return
  997. */
  998. public List<Orders> queryOrdersByPickList(String pickListId) {
  999. String sql="SELECT * FROM WMS_ORDERS WHERE DELETE_FLAG =0 AND ORDER_STATUS<>5204 AND COMBINED_ORDER_ID=? ORDER BY COMBINED_ORDER_ID,PICK_SEQUENCE ";
  1000. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(QueryContext.createQueryContext(Orders.class));
  1001. return dao.query(sql, pickListId);
  1002. }
  1003. public void updateInvoiceNo(JSONArray orderIds, JSONArray invoiceNos) {
  1004. for (int i = 0; i < orderIds.size(); i++) {
  1005. String orderId = orderIds.getString(i);
  1006. String invoiceNo = invoiceNos.getString(i);
  1007. this.daoFactory.getJdbcDao().update("update wms_orders set INVOICE_NO=? where ORDER_ID=?", invoiceNo,
  1008. orderId);
  1009. }
  1010. }
  1011. /**
  1012. * 更新订单数量信息
  1013. *
  1014. * @param orderId
  1015. * @param quantityMap
  1016. * @return
  1017. */
  1018. synchronized public boolean synchronizedOrders(String orderId, Map<String, Object> quantityMap) {
  1019. logger.info("update WMS_ORDERS quantity start");
  1020. long start = System.currentTimeMillis();
  1021. String[] quantityArray =
  1022. new String[] { "expectedSendQuantity", "assignedQuantity", "pickedQuantity", "packingQuantity",
  1023. "deliveredQuantity" };
  1024. for (int i = 0; i < quantityArray.length; i++) {
  1025. if (!quantityMap.containsKey(quantityArray[i])) {
  1026. quantityMap.put(quantityArray[i], 0);
  1027. }
  1028. }
  1029. quantityMap.put("orderId", orderId);
  1030. StringBuilder sql = new StringBuilder();
  1031. sql
  1032. .append("update WMS_ORDERS set EXPECTED_SEND_QUANTITY=(ifnull(EXPECTED_SEND_QUANTITY,0)+(:expectedSendQuantity)),"
  1033. + "ASSIGNED_QUANTITY=(ifnull(ASSIGNED_QUANTITY,0)+(:assignedQuantity)),"
  1034. + "PICKED_QUANTITY=(ifnull(PICKED_QUANTITY,0)+(:pickedQuantity)),"
  1035. + "PACKING_QUANTITY=(ifnull(PACKING_QUANTITY,0)+(:packingQuantity)),"
  1036. + "DELIVERED_QUANTITY=(ifnull(DELIVERED_QUANTITY,0)+(:deliveredQuantity))"
  1037. + " where ORDER_ID=(:orderId) ");
  1038. this.daoFactory.getJdbcDao().update(sql.toString(), quantityMap);
  1039. logger.info("update WMS_ORDERS quantity end.use time:" +(System.currentTimeMillis()-start)+"ms");
  1040. return true;
  1041. }
  1042. synchronized public boolean synchronizedBatchOrders(List<Map<String, Object>> batchValues) {
  1043. logger.info("update WMS_ORDERS quantity start");
  1044. long start = System.currentTimeMillis();
  1045. if (batchValues != null && batchValues.size() != 0) {
  1046. for (Map<String, Object> map : batchValues) {
  1047. String[] quantityArray =
  1048. new String[] { "expectedSendQuantity", "assignedQuantity", "pickedQuantity", "packingQuantity",
  1049. "deliveredQuantity" };
  1050. for (int i = 0; i < quantityArray.length; i++) {
  1051. if (!map.containsKey(quantityArray[i])) {
  1052. map.put(quantityArray[i], 0);
  1053. }
  1054. }
  1055. }
  1056. StringBuilder sql = new StringBuilder();
  1057. sql
  1058. .append("update WMS_ORDERS set EXPECTED_SEND_QUANTITY=(ifnull(EXPECTED_SEND_QUANTITY,0)+(:expectedSendQuantity)),"
  1059. + "ASSIGNED_QUANTITY=(ifnull(ASSIGNED_QUANTITY,0)+(:assignedQuantity)),"
  1060. + "PICKED_QUANTITY=(ifnull(PICKED_QUANTITY,0)+(:pickedQuantity)),"
  1061. + "PACKING_QUANTITY=(ifnull(PACKING_QUANTITY,0)+(:packingQuantity)),"
  1062. + "DELIVERED_QUANTITY=(ifnull(DELIVERED_QUANTITY,0)+(:deliveredQuantity))"
  1063. + " where ORDER_ID=(:orderId) ");
  1064. this.daoFactory.getJdbcDao().batchUpdate(sql.toString(), batchValues.toArray(new Map[] {}));
  1065. }
  1066. logger.info("update WMS_ORDERS quantity end.use time:"+(System.currentTimeMillis()-start)+"ms");
  1067. return true;
  1068. }
  1069. synchronized public boolean synchronizedOrdersDetail(String id, Map<String, Object> quantityMap) {
  1070. logger.info("update wms_orders_detail quantity start");
  1071. long start = System.currentTimeMillis();
  1072. String[] quantityArray =
  1073. new String[] { "expectedItemQuantity", "assignedQuantity", "pickedQuantity", "packingQuantity",
  1074. "deliveredQuantity" };
  1075. for (int i = 0; i < quantityArray.length; i++) {
  1076. if (!quantityMap.containsKey(quantityArray[i])) {
  1077. quantityMap.put(quantityArray[i], 0);
  1078. }
  1079. }
  1080. quantityMap.put("id", id);
  1081. StringBuilder sql = new StringBuilder();
  1082. sql
  1083. .append("update wms_orders_detail set EXPECTED_ITEM_QUANTITY=(ifnull(EXPECTED_ITEM_QUANTITY,0)+(:expectedItemQuantity)),"
  1084. + "ASSIGNED_QUANTITY=(ifnull(ASSIGNED_QUANTITY,0)+(:assignedQuantity)),"
  1085. + "PICKED_QUANTITY=(ifnull(PICKED_QUANTITY,0)+(:pickedQuantity)),"
  1086. + "PACKING_QUANTITY=(ifnull(PACKING_QUANTITY,0)+(:packingQuantity)),"
  1087. + "DELIVERED_QUANTITY=(ifnull(DELIVERED_QUANTITY,0)+(:deliveredQuantity))" + " where ID=(:id) ");
  1088. this.daoFactory.getJdbcDao().update(sql.toString(), quantityMap);
  1089. logger.info("update wms_orders_detail quantity end.use time:"+(System.currentTimeMillis()-start)+"ms");
  1090. return true;
  1091. }
  1092. synchronized public boolean synchronizedBatchOrdersDetail( List<Map<String, Object>> batchValues) {
  1093. logger.info("update wms_orders_detail quantity start");
  1094. long start = System.currentTimeMillis();
  1095. if (batchValues != null && batchValues.size() != 0) {
  1096. for (Map<String, Object> map : batchValues) {
  1097. String[] quantityArray =
  1098. new String[] { "expectedItemQuantity", "assignedQuantity", "pickedQuantity", "packingQuantity",
  1099. "deliveredQuantity" };
  1100. for (int i = 0; i < quantityArray.length; i++) {
  1101. if (!map.containsKey(quantityArray[i])) {
  1102. map.put(quantityArray[i], 0);
  1103. }
  1104. }
  1105. }
  1106. StringBuilder sql = new StringBuilder();
  1107. sql
  1108. .append("update wms_orders_detail set EXPECTED_ITEM_QUANTITY=(ifnull(EXPECTED_ITEM_QUANTITY,0)+(:expectedItemQuantity)),"
  1109. + "ASSIGNED_QUANTITY=(ifnull(ASSIGNED_QUANTITY,0)+(:assignedQuantity)),"
  1110. + "PICKED_QUANTITY=(ifnull(PICKED_QUANTITY,0)+(:pickedQuantity)),"
  1111. + "PACKING_QUANTITY=(ifnull(PACKING_QUANTITY,0)+(:packingQuantity)),"
  1112. + "DELIVERED_QUANTITY=(ifnull(DELIVERED_QUANTITY,0)+(:deliveredQuantity))" + " where ID=(:id) ");
  1113. this.daoFactory.getJdbcDao().batchUpdate(sql.toString(), batchValues.toArray(new Map[] {}));
  1114. }
  1115. logger.info("update wms_orders_detail quantity end.use time:" +(System.currentTimeMillis() - start) + "ms");
  1116. return true;
  1117. }
  1118. public List<List<String>> checkCloseFilter(List<Object> ids) {
  1119. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1120. //已经冻结,已经发货,已经取消的订单不能取消
  1121. List<String> legalList = new ArrayList<String>();
  1122. Map<String, Object> param = new HashMap<String, Object>();
  1123. param.put("ids", ids);
  1124. List<Orders> checkList = new ArrayList<Orders>();
  1125. List<Orders> orderList =
  1126. this.daoFactory.getJdbcDao(qc).query("select * from wms_orders " +" where ORDER_ID in (:ids) ",param);
  1127. for(Orders orders: orderList ){
  1128. int orderStatus = this.getOrderStatus(orders);
  1129. if(orderStatus !=-1 ){
  1130. checkList.add(orders);
  1131. }
  1132. }
  1133. for (Orders mmm : checkList) {
  1134. legalList.add(mmm.getOrderId());
  1135. }
  1136. List<String> illegealList = new ArrayList<String>();
  1137. for (Object obj : ids) {
  1138. if (!legalList.contains(obj.toString())) {
  1139. illegealList.add(obj.toString());
  1140. }
  1141. }
  1142. List<List<String>> resultList = new ArrayList<List<String>>();
  1143. resultList.add(legalList);
  1144. resultList.add(illegealList);
  1145. return resultList;
  1146. }
  1147. public List<Orders> doCloseOrders(List<String> orderIds){
  1148. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1149. Map<String, Object> param = new HashMap<String, Object>();
  1150. param.put("ids", orderIds);
  1151. List<Orders> ordersList =
  1152. this.daoFactory.getJdbcDao(qc).query("select * from wms_orders where ORDER_ID in (:ids)",
  1153. param);
  1154. for( Orders orders : ordersList ){
  1155. this.closeOrder(orders);
  1156. }
  1157. return ordersList;
  1158. }
  1159. private int getOrderStatus(Orders orders){
  1160. Orders order = this.getEntityById(orders.getOrderId(), Orders.class);
  1161. DeliveryOutbound outbound = this.deliveryOutboundService.getDeliveryOutBound(order.getOutboundOrderId());
  1162. int status = -1;
  1163. if( orders.getOrderStatus().longValue()== WMS_ORDERS_STATUS_CANCLED ){
  1164. status = -1;
  1165. return status;
  1166. }
  1167. if( orders.getOrderStatus()== OrdersService.WMS_ORDERS_STATUS_NEW){
  1168. //新订单
  1169. status = 1;
  1170. }else {
  1171. if( orders.getDeliveryStatus()==1
  1172. && orders.getAssignedQuantity().longValue()==orders.getPackingQuantity().longValue()
  1173. && orders.getAssignedQuantity().longValue()==orders.getDeliveredQuantity().longValue() ){
  1174. //发运状态为已部分发运并且分配量=拣货量=包装量=发运量
  1175. status = 6;
  1176. }else if(orders.getPickStatus()==2 &&( orders.getPackingStatus()==1 || orders.getPackingStatus()==2) && orders.getDeliveryStatus()!=2 ){
  1177. //已装箱未发运
  1178. status = 5;
  1179. }else if( orders.getPickStatus()==2 && orders.getPackingStatus()==0 ){
  1180. //已分配,已拣货完成,未装箱
  1181. status = 4;
  1182. }else if( orders.getPickStatus()==1 ){
  1183. //已分配,已部分拣货
  1184. status = 3;
  1185. }else if( orders.getPickStatus()==0 && ( orders.getAssignedStatus()==1 || orders.getAssignedStatus()==2) ){
  1186. //已分配,未开始拣货
  1187. status = 2;
  1188. }else if(orders.getAssignedStatus()==0){
  1189. //未分配
  1190. status = 7;
  1191. }else if((outbound.getDeliveryOutboundStatus()==4203) && (orders.getDeliveryStatus()==2)){
  1192. //订单已取消并且已发运
  1193. status = 8;
  1194. //添加
  1195. try {
  1196. DeliverDocument dd = this.deliveryOutboundService.getDeliverDocument(order.getOrderId());
  1197. AbnormalDeliveryDocument abnormalDeliveryDocument = new AbnormalDeliveryDocument();
  1198. BeanUtilsBean.getInstance().copyProperties(abnormalDeliveryDocument,order, new String[] { "id" });
  1199. abnormalDeliveryDocument.setId(null);
  1200. abnormalDeliveryDocument.setOrderStatus(String.valueOf(4204));
  1201. abnormalDeliveryDocument.setOrderCancelTime(new Date());
  1202. abnormalDeliveryDocument.setOrderDeliveryDocumentStatus(String.valueOf(dd.getDeliverDocumentStatus()));
  1203. abnormalDeliveryDocument.setOrderDeliveryDocumentTime(dd.getDeliverDocumentConfirmTime());
  1204. abnormalDeliveryDocument.setBackStatus(String.valueOf(WMS_ORDERS_BACK_STATUS_START));
  1205. abnormalDeliveryDocumentService.addAbnormalDeliveryDocument(abnormalDeliveryDocument);
  1206. } catch (Exception e) {
  1207. e.printStackTrace();
  1208. }
  1209. }
  1210. else{
  1211. status =-1;
  1212. }
  1213. }
  1214. return status;
  1215. }
  1216. private List<PickListDetail> getPickListDetails(Orders orders){
  1217. ExtendedJdbcDao<PickListDetail> dao = this.daoFactory.getJdbcDao(QueryContext.createQueryContext(PickListDetail.class));
  1218. String sql="select * from wms_pick_list_detail where DELETE_FLAG=0 AND ORDER_ID =? ";
  1219. return dao.query(sql, orders.getOrderId());
  1220. }
  1221. /**
  1222. * 关闭出库单
  1223. * @param outboundId 销售出库订单Id
  1224. * @return 0:关闭失败 ;1:关闭成功
  1225. */
  1226. public int closeOrderByOms(String outboundId){
  1227. int result = 0 ;
  1228. try{
  1229. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(QueryContext.createQueryContext(Orders.class));
  1230. String sql =" select * from wms_orders where OUTBOUND_ORDER_ID=? ";
  1231. List<Orders> list = dao.query(sql, outboundId);
  1232. if( list!=null && list.size() > 0 ){
  1233. final Orders orders = list.get(0);
  1234. if(orders.getOrderStatus()!=OrdersService.WMS_ORDERS_STATUS_CANCLED){
  1235. TransactionHelper.getService().executeInTransaction(new TxCallBack() {
  1236. @Override
  1237. public Object execute(Object... params) {
  1238. closeOrder(orders);
  1239. return null;
  1240. }
  1241. });
  1242. }
  1243. }
  1244. result = 1;
  1245. }catch(Exception ex){
  1246. logger.error(ex);
  1247. }
  1248. return result;
  1249. }
  1250. @Transactional
  1251. public void closeOrder(Orders orders){
  1252. int status = this.getOrderStatus(orders);
  1253. if( status ==-1){
  1254. return ;
  1255. }
  1256. if( status==1 || status==7 ){
  1257. //新记录
  1258. logger.info("关闭订单【"+orders.getOrderId()+"】,新订单");
  1259. String sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS ,IS_CANCLE=1 WHERE ORDER_ID =:ORDER_ID";
  1260. Map<String,Object> params = new HashMap<String,Object>();
  1261. params.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1262. params.put("ORDER_ID", orders.getOrderId());
  1263. this.daoFactory.getJdbcDao().update(sql, params);
  1264. }else if( status==2 ){
  1265. logger.info("关闭订单【"+orders.getOrderId()+"】,已加入拣货未开始拣货");
  1266. //获取拣货单明细
  1267. List<PickListDetail> picklistdetailList =this.getPickListDetails(orders);
  1268. if( picklistdetailList==null || picklistdetailList.size()==0 ){
  1269. logger.error("没有找到该订单的拣货单明细");
  1270. return;
  1271. }
  1272. //删除拣货单明细
  1273. List<String> ids = new ArrayList<String>();
  1274. for( PickListDetail detail : picklistdetailList ){
  1275. ids.add(detail.getId());
  1276. }
  1277. //根据拣货单明细还原库存和订单分配量
  1278. this.allocateInventoryService.rollbackAllocate(picklistdetailList, orders);
  1279. String sql ="update wms_pick_list_detail set DELETE_FLAG=1,PICK_LIST_ID=null,UPDATE_TIME=:updateTime where ID IN(:ids) ";
  1280. Map<String,Object> params = new HashMap<String,Object>();
  1281. params.put("ids", ids);
  1282. params.put("updateTime", new Date());
  1283. this.daoFactory.getJdbcDao().update(sql, params);
  1284. //如果拣货单下的拣货明细被删完则直接删除拣货单主表信息
  1285. Map<String, Object> param = new HashMap<String, Object>();
  1286. param.put("pickListId", orders.getCombinedOrderId());
  1287. List<PickListDetail> pickListDetailList =
  1288. this.daoFactory.getJdbcDao(QueryContext.createQueryContext(PickListDetail.class))
  1289. .query("select * from wms_pick_list_detail where pick_list_id =(:pickListId) and DELETE_FLAG=0 and pick_list_detail_status=0",
  1290. param);
  1291. if (pickListDetailList.isEmpty())
  1292. {
  1293. deleteEntity(orders.getCombinedOrderId(), PickList.class);
  1294. }
  1295. //更新订单状态,为取消,订单分配状态为0,订单拣货状态为0,订单拣货数量为0
  1296. sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS,IS_CANCLE=1,ASSIGNED_STATUS=0,PICK_STATUS=0,PICKED_QUANTITY=0 WHERE ORDER_ID =:ORDER_ID";
  1297. Map<String,Object> params2 = new HashMap<String,Object>();
  1298. params2.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1299. params2.put("ORDER_ID", orders.getOrderId());
  1300. this.daoFactory.getJdbcDao().update(sql, params2);
  1301. }else if( status ==3){
  1302. logger.info("关闭订单【"+orders.getOrderId()+"】,已开始拣货未拣货完成");
  1303. //订单的取消标记标记为已取消??
  1304. //订单的状态设置为已取消
  1305. PickList pickList = getEntityById(orders.getCombinedOrderId(), PickList.class);
  1306. int assingned = DataUtils.asInt(pickList.getAssignedBox(),0);
  1307. //如果拣货单 已派箱 则不对出货单拣货单做任何操作 让 DPS拣货完成 在包装环节去判断是否取消
  1308. if (1 == assingned)
  1309. {
  1310. String sql = "update wms_orders set IS_CANCLE=1 WHERE ORDER_ID =:ORDER_ID";
  1311. Map<String, Object> params2 = new HashMap<String, Object>();
  1312. params2.put("ORDER_ID", orders.getOrderId());
  1313. this.daoFactory.getJdbcDao().update(sql, params2);
  1314. }
  1315. else
  1316. {
  1317. String sql = "update wms_orders set ORDER_STATUS =:ORDER_STATUS,IS_CANCLE=1 WHERE ORDER_ID =:ORDER_ID";
  1318. Map<String, Object> params2 = new HashMap<String, Object>();
  1319. params2.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1320. params2.put("ORDER_ID", orders.getOrderId());
  1321. this.daoFactory.getJdbcDao().update(sql, params2);
  1322. }
  1323. //执行拣货完成??
  1324. }else if( status ==4){
  1325. logger.info("关闭订单【"+orders.getOrderId()+"】,拣货完成未包装");
  1326. //订单的取消标记标记为已取消??
  1327. //订单的状态设置为已取消
  1328. String sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS,IS_CANCLE=1 WHERE ORDER_ID =:ORDER_ID";
  1329. Map<String,Object> params2 = new HashMap<String,Object>();
  1330. params2.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1331. params2.put("ORDER_ID", orders.getOrderId());
  1332. this.daoFactory.getJdbcDao().update(sql, params2);
  1333. //执行拣货完成??
  1334. }else if( status ==5){
  1335. logger.info("关闭订单【"+orders.getOrderId()+"】,已包装未发运");
  1336. String sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS,IS_CANCLE=1 WHERE ORDER_ID =:ORDER_ID";
  1337. Map<String,Object> params = new HashMap<String,Object>();
  1338. params.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1339. params.put("ORDER_ID", orders.getOrderId());
  1340. this.daoFactory.getJdbcDao().update(sql, params);
  1341. }else if( status ==6){
  1342. logger.info("关闭订单【"+orders.getOrderId()+"】,发运状态为已部分发运并且分配量=拣货量=包装量=发运量");
  1343. String sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS,IS_CANCLE=1 WHERE ORDER_ID =:ORDER_ID";
  1344. Map<String,Object> params = new HashMap<String,Object>();
  1345. params.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1346. params.put("ORDER_ID", orders.getOrderId());
  1347. this.daoFactory.getJdbcDao().update(sql, params);
  1348. }else if(status == 8){
  1349. logger.info("关闭订单【"+orders.getOrderId()+"】,发运状态为已发运并且订单状态为已取消");
  1350. String sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS WHERE ORDER_ID =:ORDER_ID";
  1351. Map<String,Object> params = new HashMap<String,Object>();
  1352. params.put("ORDER_STATUS", OrdersService.WMS_ORDERS_STATUS_CANCLED);
  1353. params.put("ORDER_ID", orders.getOrderId());
  1354. this.daoFactory.getJdbcDao().update(sql, params);
  1355. }
  1356. }
  1357. public List<List<String>> checkPrintOrdersFilter(List<Object> ids) {
  1358. List<List<String>> resultList = new ArrayList<List<String>>();
  1359. List<String> legalList = new ArrayList<String>();
  1360. List<String> illegealList = new ArrayList<String>();
  1361. resultList.add(legalList);
  1362. resultList.add(illegealList);
  1363. if( CollectionUtils.isNotEmpty(ids)){
  1364. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1365. Map<String, Object> param = new HashMap<String, Object>();
  1366. param.put("ids", ids);
  1367. //只有取消的订单不能打印
  1368. List<Orders> checkList =
  1369. this.daoFactory.getJdbcDao(qc).query(
  1370. "select ORDER_ID from wms_orders " +
  1371. " where DELETE_FLAG = 0 " +
  1372. "AND BUSINESS_LOCK_FLAG=0 " +
  1373. "AND ORDER_STATUS <> 5204 " +
  1374. "AND ORDER_ID in (:ids) ",
  1375. param);
  1376. for (Orders mmm : checkList) {
  1377. legalList.add(mmm.getOrderId());
  1378. }
  1379. for (Object obj : ids) {
  1380. if (!legalList.contains(obj.toString())) {
  1381. illegealList.add(obj.toString());
  1382. }
  1383. }
  1384. }
  1385. return resultList;
  1386. }
  1387. public List<List<String>> checkPrintCodFilterByWaveId(List<Object> ids) {
  1388. List<List<String>> resultList = new ArrayList<List<String>>();
  1389. List<String> legalList = new ArrayList<String>();
  1390. List<String> illegealList = new ArrayList<String>();
  1391. resultList.add(legalList);
  1392. resultList.add(illegealList);
  1393. if( CollectionUtils.isNotEmpty(ids)){
  1394. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1395. Map<String, Object> param = new HashMap<String, Object>();
  1396. param.put("ids", ids);
  1397. //只有取消的订单不能打印
  1398. List<Orders> checkList =
  1399. this.daoFactory.getJdbcDao(qc).query(
  1400. "SELECT * FROM wms_orders WHERE WAVE_ID in (:ids) AND COD_VENDER_ID IS NOT NULL AND DELETE_FLAG =0",
  1401. param);
  1402. for (Orders mmm : checkList) {
  1403. legalList.add(mmm.getOrderId());
  1404. }
  1405. for (Object obj : ids) {
  1406. if (!legalList.contains(obj.toString())) {
  1407. illegealList.add(obj.toString());
  1408. }
  1409. }
  1410. }
  1411. return resultList;
  1412. }
  1413. public List<List<String>> checkPrintCodFilterByPickListId(List<Object> ids) {
  1414. List<List<String>> resultList = new ArrayList<List<String>>();
  1415. List<String> legalList = new ArrayList<String>();
  1416. List<String> illegealList = new ArrayList<String>();
  1417. resultList.add(legalList);
  1418. resultList.add(illegealList);
  1419. if( CollectionUtils.isNotEmpty(ids)){
  1420. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1421. Map<String, Object> param = new HashMap<String, Object>();
  1422. param.put("ids", ids);
  1423. //只有取消的订单不能打印
  1424. List<Orders> checkList =
  1425. this.daoFactory.getJdbcDao(qc).query(
  1426. "SELECT * FROM wms_orders WHERE ORDER_ID in (SELECT DISTINCT(ORDER_ID) FROM wms_pick_list where PICK_LIST_ID in (:ids) AND DELETE_FLAG =0) AND COD_VENDER_ID IS NOT NULL AND DELETE_FLAG =0",
  1427. param);
  1428. for (Orders mmm : checkList) {
  1429. legalList.add(mmm.getOrderId());
  1430. }
  1431. for (Object obj : ids) {
  1432. if (!legalList.contains(obj.toString())) {
  1433. illegealList.add(obj.toString());
  1434. }
  1435. }
  1436. }
  1437. return resultList;
  1438. }
  1439. public List<List<String>> checkPrintReturnFilterByPickListId(List<Object> ids) {
  1440. List<List<String>> resultList = new ArrayList<List<String>>();
  1441. List<String> legalList = new ArrayList<String>();
  1442. List<String> illegealList = new ArrayList<String>();
  1443. resultList.add(legalList);
  1444. resultList.add(illegealList);
  1445. if( CollectionUtils.isNotEmpty(ids)){
  1446. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1447. Map<String, Object> param = new HashMap<String, Object>();
  1448. param.put("ids", ids);
  1449. //只有取消的订单不能打印
  1450. List<Orders> checkList =
  1451. this.daoFactory.getJdbcDao(qc).query(
  1452. "SELECT * FROM wms_orders WHERE ORDER_ID in (SELECT DISTINCT(ORDER_ID) FROM wms_pick_list where PICK_LIST_ID in (:ids) AND DELETE_FLAG =0) AND DELETE_FLAG =0",
  1453. param);
  1454. for (Orders mmm : checkList) {
  1455. legalList.add(mmm.getOrderId());
  1456. }
  1457. for (Object obj : ids) {
  1458. if (!legalList.contains(obj.toString())) {
  1459. illegealList.add(obj.toString());
  1460. }
  1461. }
  1462. }
  1463. return resultList;
  1464. }
  1465. public List<List<String>> checkPrintCodFilter(List<Object> ids) {
  1466. List<List<String>> resultList = new ArrayList<List<String>>();
  1467. List<String> legalList = new ArrayList<String>();
  1468. List<String> illegealList = new ArrayList<String>();
  1469. resultList.add(legalList);
  1470. resultList.add(illegealList);
  1471. if( CollectionUtils.isNotEmpty(ids)){
  1472. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1473. Map<String, Object> param = new HashMap<String, Object>();
  1474. param.put("ids", ids);
  1475. //只有取消的订单不能打印
  1476. List<Orders> checkList =
  1477. this.daoFactory.getJdbcDao(qc).query(
  1478. "select ORDER_ID from wms_orders " +
  1479. " where DELETE_FLAG = 0 " +
  1480. "AND BUSINESS_LOCK_FLAG=0 " +
  1481. "AND COD_VENDER_ID IS NOT NULL " +
  1482. "AND ORDER_ID in (:ids) ",
  1483. param);
  1484. for (Orders mmm : checkList) {
  1485. legalList.add(mmm.getOrderId());
  1486. }
  1487. for (Object obj : ids) {
  1488. if (!legalList.contains(obj.toString())) {
  1489. illegealList.add(obj.toString());
  1490. }
  1491. }
  1492. }
  1493. return resultList;
  1494. }
  1495. private String getOrderByField(List<String> ids){
  1496. String orderId = ids.get(0);
  1497. String orderByField =" ORDER_ID ";
  1498. Orders orders = this.getEntityById(orderId, Orders.class);
  1499. String warehouseId = orders.getWarehouseId();
  1500. WarehouseVO warehouseVO = this.warehouseService.getEntity(warehouseId + "");
  1501. if (warehouseVO.getWarePrintRule() == null || warehouseVO.getWarePrintRule().longValue() == 3501) {
  1502. // 按订单顺序
  1503. orderByField =" ORDER_ID ";
  1504. }
  1505. else if (warehouseVO.getWarePrintRule().longValue() == 3502) {
  1506. // 按拣货单顺序
  1507. orderByField =" COMBINED_ORDER_ID,PICK_SEQUENCE ";
  1508. }
  1509. else if (warehouseVO.getWarePrintRule().longValue() == 3503) {
  1510. // 按路向
  1511. orderByField =" COMBINED_ORDER_ID,ORDER_ROUTE ";
  1512. }
  1513. return orderByField;
  1514. }
  1515. /**
  1516. * 出货单管理页面打印拣货单
  1517. * @param ids
  1518. * @return
  1519. */
  1520. public JSONArray doPrintOrders(List<String> ids){
  1521. JSONArray jsonArray = new JSONArray();
  1522. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1523. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  1524. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  1525. Map<String,Object> params = new HashMap<String,Object>();
  1526. params.put("ids", ids);
  1527. List<Orders> list = dao.query(sql, params);
  1528. if( list!=null && list.size()>0 ){
  1529. for(Orders orders : list ){
  1530. JSONObject jsonObject =generateOrdersPrint(orders,false);
  1531. jsonArray.add(jsonObject);
  1532. }
  1533. }
  1534. return jsonArray ;
  1535. }
  1536. /**
  1537. * 拣货单管理页面打印拣货单
  1538. * @param ids
  1539. * @return
  1540. */
  1541. public JSONArray doPrintOrdersAfterAssigned(List<String> ids){
  1542. JSONArray jsonArray = new JSONArray();
  1543. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1544. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  1545. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  1546. Map<String,Object> params = new HashMap<String,Object>();
  1547. params.put("ids", ids);
  1548. List<Orders> list = dao.query(sql, params);
  1549. if( list!=null && list.size()>0 ){
  1550. for(Orders orders : list ){
  1551. JSONObject jsonObject =generateOrdersPrint(orders,true);
  1552. jsonArray.add(jsonObject);
  1553. }
  1554. }
  1555. return jsonArray ;
  1556. }
  1557. /**
  1558. * 生成出货清单打印对象
  1559. * @param orders
  1560. * @param isAssigned
  1561. * @return
  1562. */
  1563. private JSONObject generateOrdersPrint(Orders orders,boolean isAssigned){
  1564. DeliveryOutbound dob = this.getEntityById(orders.getOutboundOrderId(), DeliveryOutbound.class);
  1565. JSONObject jsonObject = new JSONObject();
  1566. jsonObject.put("ORDER_ID",DataUtils.asString(orders.getOrderId(),""));
  1567. jsonObject.put("OUTBOUND_KIND",DataUtils.asDictionary(orders.getOutboundKind()+"") );
  1568. jsonObject.put("CUSTOMER_NAME", DataUtils.asString(orders.getCustomerName(),"") );
  1569. jsonObject.put("WAREHOUSE_NAME", DataUtils.asString(orders.getWarehouseName(),"") );
  1570. jsonObject.put("CUSTOMER_REFFERENCE_ID", DataUtils.asString(orders.getCustomerRefferenceId(),"") );
  1571. jsonObject.put("CARRIER_NAME",DataUtils.asString(orders.getCarrierName(),"") );
  1572. jsonObject.put("RECEIVER_NAME", DataUtils.asString(orders.getReceiverName(),"") );
  1573. jsonObject.put("RECEIVER_CONTACTOR",DataUtils.asString(orders.getReceiverContactor(),"") );
  1574. jsonObject.put("CREATION_TIME", dob.getCreationTime() == null ? "" : DateUtils.getTimeStr(dob.getCreationTime(),2));
  1575. jsonObject.put("PAY_TYPE", DataUtils.asString(orders.getPayType(),"") );
  1576. jsonObject.put("COMMENT", DataUtils.asString(orders.getOrderMemo(),"") );
  1577. jsonObject.put("TOTAL_COST", DataUtils.asDouble(orders.getTotalCost(),0));
  1578. jsonObject.put("PAY", DataUtils.asDouble(orders.getPay(),0));
  1579. jsonObject.put("PRE_FUND", DataUtils.asDouble(orders.getPreFund(),0));
  1580. jsonObject.put("POINTS", DataUtils.asDouble(orders.getPoints(),0));
  1581. jsonObject.put("PAY_ADVANCE2", DataUtils.asDouble(orders.getPayAdvance2(),0));
  1582. jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0));
  1583. jsonObject.put("PAY_CASH", DataUtils.asDouble(orders.getPayCash(),0));
  1584. jsonObject.put("INDENT_DATE", orders.getIndentDate()==null?"":DateUtils.getTimeStr( orders.getIndentDate(),2) );
  1585. jsonObject.put("PRE_ADVANCE", DataUtils.asDouble(orders.getPreAdvance(),0));
  1586. jsonObject.put("STAFF_NAME", DataUtils.asString(orders.getStaffName(),"") );
  1587. jsonObject.put("TOTAL_FEE", DataUtils.asStringExt(orders.getTotalFee(),"") );
  1588. jsonObject.put("COMBINED_ORDER_ID", DataUtils.asString(orders.getCombinedOrderId(),"") );
  1589. jsonObject.put("RECEIVER_PROVINCE", DataUtils.asString(orders.getReceiverProvince(),"") );
  1590. jsonObject.put("RECEIVER_STREET", DataUtils.asString(orders.getReceiverStreet(),"") );
  1591. jsonObject.put("RECEIVER_CONTACTOR_PHONE", DataUtils.asString(orders.getReceiverContactorPhone(),"") );
  1592. jsonObject.put("TOTAL_QUANTITY", DataUtils.asDouble(orders.getExpectedSendQuantity(),0) );
  1593. jsonObject.put("RECEIVER_CITY", DataUtils.asString(orders.getReceiverCity(),"") );
  1594. jsonObject.put("SALES_CASH", DataUtils.asString(orders.getSalesCash(),"") );
  1595. jsonObject.put("ALL_PREFUND", DataUtils.asStringExt(orders.getAllPrefund(),"") );
  1596. jsonObject.put("SPARE1", DataUtils.asString(orders.getSpare1(),""));
  1597. jsonObject.put("SPARE2", DataUtils.asString(orders.getSpare2(),""));
  1598. jsonObject.put("SPARE3", DataUtils.asString(orders.getSpare3(),""));
  1599. jsonObject.put("SPARE4", DataUtils.asString(orders.getSpare4(),""));
  1600. jsonObject.put("SPARE5", DataUtils.asString(orders.getSpare5(),""));
  1601. jsonObject.put("SPARE6", DataUtils.asString(orders.getSpare6(),""));
  1602. jsonObject.put("SPARE7", DataUtils.asString(orders.getSpare7(),""));
  1603. jsonObject.put("SPARE8", DataUtils.asString(orders.getSpare8(),""));
  1604. jsonObject.put("SPARE9", DataUtils.asString(orders.getSpare9(),""));
  1605. jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  1606. jsonObject.put("ORDER_NO", DataUtils.asString(orders.getOrderId(),""));
  1607. jsonObject.put("SEND_SYSTEM_ID", DataUtils.asString("",""));
  1608. jsonObject.put("DELIVERY_OUTBOUND_TYPE", DataUtils.asString(orders.getOutboundKind(),""));
  1609. jsonObject.put("OUTBOUND_DETAIL_TYPE", DataUtils.asString(orders.getOrderDealType(),""));
  1610. jsonObject.put("REQUIRED_PICKUP_TIME", DataUtils.asString(dob.getRequiredPickupTime(),""));
  1611. jsonObject.put("CARRIER_CODE", DataUtils.asString(orders.getCarrierCode(),""));
  1612. jsonObject.put("LOGISTICS_FEE", DataUtils.asString(orders.getLogisticsFee(),""));
  1613. jsonObject.put("COLLECTION_FLAG", DataUtils.asString(orders.getCollectionFlag(),""));
  1614. jsonObject.put("RECEIVER_CODE", DataUtils.asString(orders.getReceiverCode(),""));
  1615. jsonObject.put("LOTS_ALLOWED", DataUtils.asString(orders.getLotsAllowed(),""));
  1616. jsonObject.put("FLOW_ID", DataUtils.asString("",""));
  1617. jsonObject.put("OWN_GOOD_FLAG", DataUtils.asString(orders.getOwnGoodFlag(),""));
  1618. jsonObject.put("TOTAL_FEE", DataUtils.asString(orders.getTotalFee(),""));
  1619. jsonObject.put("RECEIVER_COUNTRY", DataUtils.asString(orders.getReceiverCountry(),""));
  1620. jsonObject.put("RECEIVER_DISTRICT", DataUtils.asString(orders.getReceiverDistrict(),""));
  1621. jsonObject.put("RECEIVER_CONTACTOR_MOBILE", DataUtils.asString(orders.getReceiverContactorMobile(),""));
  1622. jsonObject.put("RECEIVER_ZIPCODE", DataUtils.asString(orders.getReceiverZipcode(),""));
  1623. jsonObject.put("MEDIANAME_PRINT", DataUtils.asString(orders.getMedianamePrint(),""));
  1624. jsonObject.put("MEDIANAME", DataUtils.asString(orders.getMedianame(),""));
  1625. jsonObject.put("DEAL_STATUS", DataUtils.asString(orders.getOrderStatus(),""));
  1626. jsonObject.put("DEAL_RESPONSE", DataUtils.asString("",""));
  1627. jsonObject.put("DEAL_TIME", DataUtils.asString(orders.getCreationTime(),""));
  1628. jsonObject.put("CU_PRE_FUND", DataUtils.asString(orders.getCuPreFund(),""));
  1629. jsonObject.put("LIST_PRINT", DataUtils.asString(orders.getListPrint(),""));
  1630. jsonObject.put("INVOICE_PRINT", DataUtils.asString(orders.getInvoicePrint(),""));
  1631. jsonObject.put("ROLEGROUPTYPE", DataUtils.asString(orders.getRolegrouptype(),""));
  1632. jsonObject.put("ORDER_INVILID_TIME", DataUtils.asString(orders.getOrderInvilidTime(),""));
  1633. jsonObject.put("ORDER_SOURCE", DataUtils.asString(dob.getSalesPlatform(),""));
  1634. jsonObject.put("CUSTOMER_REFFERENCE_NO", DataUtils.asString(orders.getCustomerRefferenceId(),""));
  1635. JSONArray detailArray = new JSONArray();
  1636. List<OrdersDetail> details = this.ordersDetailService.listBy(orders.getOrderId()) ;
  1637. if(isAssigned){
  1638. details = this.ordersDetailService.listByAssigned(orders.getOrderId()) ;
  1639. }else{
  1640. details = this.ordersDetailService.listBy(orders.getOrderId()) ;
  1641. }
  1642. for(OrdersDetail detail :details ){
  1643. ItemVO itemVo= this.itemService.getItemVOByItemId(detail.getItemId());
  1644. List<PickListDetail> plds = this.pickListDetailService.findByOrderDetailId(detail.getId(), detail.getAccountId());
  1645. JSONObject detailJson = new JSONObject();
  1646. detailJson.put("ORDER_ID", DataUtils.asString(orders.getOrderId(),""));
  1647. detailJson.put("ITEM_CODE", DataUtils.asString(detail.getItemCode(),""));
  1648. detailJson.put("ITEM_NAME", DataUtils.asString(detail.getItemName(),""));
  1649. detailJson.put("UNITS", DataUtils.asDictionary(detail.getUnits()+""));
  1650. detailJson.put("LOT_NUMBER", DataUtils.asString(detail.getLotNumber(),"") );
  1651. detailJson.put("ITEM_GROUP_NAME", DataUtils.asString(detail.getItemGroupName(),"") );
  1652. detailJson.put("EXPECTED_ITEM_QUANTITY", DataUtils.asDouble(detail.getExpectedItemQuantity(),0) );
  1653. detailJson.put("NORMAL_FLAG", DataUtils.asString(detail.getNormalFlag(),"") );
  1654. detailJson.put("ITEM_SALE_TYPE", DataUtils.asString(itemVo.getItemSaleType(),"6101"));
  1655. //采购价
  1656. detailJson.put("PRICE", DataUtils.asDouble(itemVo.getPrice(),0) );
  1657. //销售价
  1658. detailJson.put("MARKETING_PRICE", DataUtils.asDouble(itemVo.getMarketingPrice(),0));
  1659. //市场价
  1660. detailJson.put("LISTPRICE", DataUtils.asDouble(itemVo.getListPrice(),0));
  1661. detailJson.put("ASSIGNED_QUANTITY", DataUtils.asDouble(detail.getAssignedQuantity(),0));
  1662. //detailJson.put("SPECIFICATION", DataUtils.asString(itemVo.getSpecification(),""));
  1663. if (org.apache.commons.collections.CollectionUtils.isNotEmpty(plds)){
  1664. StringBuffer sb = new StringBuffer();
  1665. for(int i = 0; i < plds.size(); i++){
  1666. if(i == (plds.size() -1)){
  1667. sb.append(plds.get(i).getLocationName()).append("*").append(plds.get(i).getShouldPickQty().intValue());
  1668. }
  1669. else{
  1670. sb.append(plds.get(i).getLocationName()).append("*").append(plds.get(i).getShouldPickQty().intValue()).append(",");
  1671. }
  1672. }
  1673. detailJson.put("SPECIFICATION", DataUtils.asString(sb.toString(),""));
  1674. }
  1675. else{
  1676. detailJson.put("SPECIFICATION", "");
  1677. }
  1678. detailArray.add(detailJson);
  1679. }
  1680. //添加自有货品
  1681. if(orders.getOwnGoodFlag()!=null&&orders.getOwnGoodFlag()==1&&orders.getOwnGoodInboundNo()!=null){
  1682. JSONObject detailJson = new JSONObject();
  1683. detailJson.put("ORDER_ID", DataUtils.asString(orders.getOrderId(),""));
  1684. detailJson.put("ITEM_CODE", "");
  1685. detailJson.put("ITEM_NAME", "自备物品");
  1686. detailJson.put("UNITS", "");
  1687. detailJson.put("LOT_NUMBER", "" );
  1688. detailJson.put("ITEM_GROUP_NAME", "");
  1689. detailJson.put("EXPECTED_ITEM_QUANTITY", 1);
  1690. detailJson.put("NORMAL_FLAG", "");
  1691. detailJson.put("ITEM_SALE_TYPE", 610);
  1692. //采购价
  1693. detailJson.put("PRICE", 0);
  1694. //销售价
  1695. detailJson.put("MARKETING_PRICE", 0);
  1696. //市场价
  1697. detailJson.put("LISTPRICE", 0);
  1698. detailJson.put("ASSIGNED_QUANTITY", 1);
  1699. detailJson.put("SPECIFICATION", "");
  1700. detailArray.add(detailJson);
  1701. }
  1702. jsonObject.put("ORDERDETAIL", detailArray);
  1703. return jsonObject;
  1704. }
  1705. public JSONArray doPrintFiveBill(List<String> ids,boolean isReming) {
  1706. JSONArray jsonArray = new JSONArray();
  1707. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1708. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  1709. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  1710. Map<String,Object> params = new HashMap<String,Object>();
  1711. params.put("ids", ids);
  1712. List<Orders> list = dao.query(sql, params);
  1713. if( list!=null && list.size()>0 ){
  1714. for(Orders orders : list ){
  1715. // 获取destCode
  1716. // if(StringUtil.isEmpty(orders.getDestCode())) {
  1717. // String descCode = getDestCodeByWmsOrders(orders);
  1718. // orders.setDestCode(descCode);
  1719. // this.updateOrders(orders);
  1720. // }
  1721. if (null != orders.getCarrierId() && isReming == true && StringUtils.isBlank(orders.getCarrierTrackingNumber())){
  1722. Map map = this.getcarrierTrackNumber(orders);
  1723. orders.setCarrierTrackingNumber((String)map.get("mailNo"));
  1724. orders.setOriginCode((String)map.get("originCode"));
  1725. orders.setDestCode((String)map.get("destCode"));
  1726. }
  1727. // else{
  1728. // //WarehouseVO warehousevo = this.warehouseService.getEntity(orders.getWarehouseId());
  1729. //
  1730. // //orders.setOriginCode(ProvinceCityUtil.getInstance().getCityCode(warehousevo.getProvince(), warehousevo.getCity()));
  1731. // orders.setDestCode(ProvinceCityUtil.getInstance().getCityCode(orders.getReceiverProvince(), orders.getReceiverCity()));
  1732. // }
  1733. }
  1734. for(Orders orders : list ){
  1735. DeliveryOutbound dob = this.getEntityById(orders.getOutboundOrderId(), DeliveryOutbound.class);
  1736. JSONObject jsonObject = new JSONObject();
  1737. BigCustomer bc =this.bigCustomerService.findBigCustomerByCustomerIdandCarrierId(orders.getCustomerId(),
  1738. orders.getCarrierId());
  1739. WarehouseVO warehousevo = this.warehouseService.getEntity(orders.getWarehouseId());
  1740. jsonObject.put("ORDER_ID",DataUtils.asString(orders.getOrderId(),""));
  1741. jsonObject.put("OUTBOUND_KIND",DataUtils.asDictionary(orders.getOutboundKind()+"") );
  1742. jsonObject.put("CUSTOMER_NAME", DataUtils.asString(orders.getCustomerName(),"") );
  1743. jsonObject.put("WAREHOUSE_NAME", DataUtils.asString(orders.getWarehouseName(),"") );
  1744. /*市移动需要字段————start*/
  1745. String accountId = BusinessSessionContext.getCurrentAccountId();
  1746. List<CustomerVO> customerVOs = customerCachedService
  1747. .readCustomerByAccountIdAndCustomerId(accountId,orders.getCustomerId());
  1748. String customerDetailAddress = customerVOs.get(0).getCountry() + customerVOs.get(0).getProvince()
  1749. +customerVOs.get(0).getCity()+customerVOs.get(0).getDistrict()+customerVOs.get(0).getStreet();
  1750. jsonObject.put("CUSTOMER_ADDRESS", DataUtils.asString(customerDetailAddress, ""));
  1751. jsonObject.put("CUSTOMER_PHONE", DataUtils.asString(customerVOs.get(0).getPersonalPhone(), ""));
  1752. jsonObject.put("CUSTOMER_TELEPHONE", DataUtils.asString(customerVOs.get(0).getPhone(), ""));
  1753. jsonObject.put("CUSTOMER_CODE", DataUtils.asString(orders.getCustomerCode(), ""));
  1754. jsonObject.put("CUSTOMER_COMPANY", DataUtils.asString(orders.getCustomerName(), ""));
  1755. jsonObject.put("CUSTOMER_ZIPCODE", DataUtils.asString(customerVOs.get(0).getZipcode(), ""));
  1756. //是否代收货款
  1757. jsonObject.put("IS_DELIVERY", DataUtils.asString(orders.getIsDelivery(),"") );
  1758. //是否返单
  1759. jsonObject.put("IS_RETURN", DataUtils.asString(orders.getIsReturn(),"") );
  1760. //是否省内
  1761. jsonObject.put("IS_INPROVINCE", DataUtils.asString(orders.getIsInProvince(),"") );
  1762. /*市移动需要字段————end*/
  1763. jsonObject.put("CUSTOMER_REFFERENCE_ID", DataUtils.asString(orders.getCustomerRefferenceId(),"") );
  1764. jsonObject.put("CARRIER_NAME",DataUtils.asString(orders.getCarrierName(),"") );
  1765. jsonObject.put("RECEIVER_NAME", DataUtils.asString(orders.getReceiverName(),"") );
  1766. jsonObject.put("RECEIVER_CONTACTOR",DataUtils.asString(orders.getReceiverContactor(),"") );
  1767. jsonObject.put("CREATION_TIME", orders.getCreationTime()==null?"":DateUtils.getTimeStr( orders.getCreationTime(),2) );
  1768. jsonObject.put("PAY_TYPE", DataUtils.asString(orders.getPayType(),"") );
  1769. jsonObject.put("COMMENT", DataUtils.asString(orders.getOrderMemo(),"") );
  1770. jsonObject.put("TOTALCOST", DataUtils.asDouble(orders.getTotalCost(),0));
  1771. jsonObject.put("PAY", DataUtils.asDouble(orders.getPay(),0));
  1772. jsonObject.put("PRE_FUND", DataUtils.asDouble(orders.getPreFund(),0));
  1773. jsonObject.put("POINTS", DataUtils.asDouble(orders.getPoints(),0));
  1774. jsonObject.put("PAY_ADVANCE2", DataUtils.asDouble(orders.getPayAdvance2(),0));
  1775. jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0));
  1776. jsonObject.put("PAY_CASH", DataUtils.asDouble(orders.getPayCash(),0));
  1777. jsonObject.put("INDENT_DATE", orders.getIndentDate()==null?"":DateUtils.getTimeStr( orders.getIndentDate(),2) );
  1778. jsonObject.put("PRE_ADVANCE", DataUtils.asDouble(orders.getPreAdvance(),0));
  1779. jsonObject.put("MEDIANAME_PRINT", DataUtils.asString(orders.getMedianamePrint(),"") );
  1780. jsonObject.put("MEDIANAME", DataUtils.asString(orders.getMedianame(),"") );
  1781. jsonObject.put("ROLEGROUPTYPE", DataUtils.asString(orders.getRolegrouptype(),"") );
  1782. jsonObject.put("RECEIVER_COUNTRY", DataUtils.asString(orders.getReceiverCountry(),"") );
  1783. jsonObject.put("RECEIVER_PROVINCE", DataUtils.asString(orders.getReceiverProvince(),"") );
  1784. jsonObject.put("RECEIVER_CITY", DataUtils.asString(orders.getReceiverCity(),"") );
  1785. jsonObject.put("RECEIVER_DISTRICT", DataUtils.asString(orders.getReceiverDistrict(),"") );
  1786. jsonObject.put("RECEIVER_STREET", DataUtils.asString(orders.getReceiverStreet(),"") );
  1787. jsonObject.put("RECEIVER_CONTACTOR_MOBILE", DataUtils.asString(orders.getReceiverContactorMobile(),"") );
  1788. jsonObject.put("RECEIVER_ZIPCODE", DataUtils.asString(orders.getReceiverZipcode(),"") );
  1789. jsonObject.put("RECEIVER_CONTACTOR_PHONE", DataUtils.asString(orders.getReceiverContactorPhone(),"") );
  1790. jsonObject.put("IS_PROHIBITED", DataUtils.asInt(orders.getIsProhibited(),0));
  1791. jsonObject.put("ROUTE_NAME", DataUtils.asString(orders.getOrderRoute(),""));
  1792. jsonObject.put("TOTAL_FEE", DataUtils.asDouble(orders.getTotalFee(),0) );
  1793. jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0) );
  1794. if(null == orders.getWeight()){
  1795. jsonObject.put("WEIGHT", 0);
  1796. }
  1797. else{
  1798. jsonObject.put("WEIGHT", DataUtils.asDouble(orders.getWeight()/1000,0));
  1799. }
  1800. String bigCustomerNo = bc == null ? "temp" : bc.getBigCustomerName();
  1801. String trackingNumber = orders.getCarrierTrackingNumber()==null ?"":orders.getCarrierTrackingNumber();
  1802. jsonObject.put("EXPRESS_NO", DataUtils.asString(trackingNumber,"") );
  1803. jsonObject.put("ORIGINATIONG_CODE", DataUtils.asString(orders.getOriginCode(),"") );
  1804. jsonObject.put("DESTINATION_CODE", DataUtils.asString(orders.getDestCode(),"") );
  1805. jsonObject.put("ITEM_DESCRIPTION", DataUtils.asString(orders.getOrderMemo(),"") );
  1806. jsonObject.put("ITEM_COUNT", DataUtils.asString(orders.getDetailCount(),"") );
  1807. jsonObject.put("BIG_CUSTOMER_NO", DataUtils.asString(bigCustomerNo,"") );
  1808. jsonObject.put("ACCOUNTS_MODE", "1");
  1809. jsonObject.put("IS_SECURE", "0");
  1810. jsonObject.put("SECURE_ACCOUNTS", DataUtils.asDouble(orders.getTotalCost(), 0));
  1811. jsonObject.put("VOLUME", DataUtils.asDouble(orders.getBulk(), 0));
  1812. jsonObject.put("LENGTH", 0);
  1813. jsonObject.put("WIDTH", 0);
  1814. jsonObject.put("HEIGHT", 0);
  1815. jsonObject.put("SENDER", DataUtils.asString(warehousevo.getContactor(), ""));
  1816. jsonObject.put("SENDER_COMPANY", DataUtils.asString(warehousevo.getWarehouseName(), ""));
  1817. jsonObject.put("SENDER_COUNTRY", DataUtils.asString(warehousevo.getCountry(), ""));
  1818. jsonObject.put("SENDER_PROVINCE", DataUtils.asString(warehousevo.getProvince(), ""));
  1819. jsonObject.put("SENDER_CITY", DataUtils.asString(warehousevo.getCity(), ""));
  1820. jsonObject.put("SENDER_COUNTY", DataUtils.asString(warehousevo.getDistrict(), ""));
  1821. jsonObject.put("SENDER_ADDR", DataUtils.asString(warehousevo.getStreet(), ""));
  1822. jsonObject.put("SENDER_CONTACTOR_MOBILE", DataUtils.asString(warehousevo.getPersonalPhone(), ""));
  1823. jsonObject.put("RECEIVER_CUSTOMER_CODE",DataUtils.asString(orders.getReceiverCode(),""));
  1824. jsonObject.put("SENDER_CUSTOMER_CODE",DataUtils.asString(orders.getCustomerCode(),""));
  1825. jsonObject.put("TOTAL_QUANTITY",DataUtils.asString(orders.getExpectedSendQuantity(),""));
  1826. if(null == orders.getWeight()){
  1827. jsonObject.put("ACTUAL_WEIGHT", "");
  1828. }
  1829. else{
  1830. jsonObject.put("ACTUAL_WEIGHT", DataUtils.asString(orders.getWeight()/1000,""));
  1831. }
  1832. jsonObject.put("ROLEGROUPTYPE",DataUtils.asString(orders.getRolegrouptype(),""));
  1833. jsonObject.put("SPARE1", DataUtils.asString(orders.getSpare1(),""));
  1834. jsonObject.put("SPARE2", DataUtils.asString(orders.getSpare2(),""));
  1835. jsonObject.put("SPARE3", DataUtils.asString(orders.getSpare3(),""));
  1836. jsonObject.put("SPARE4", DataUtils.asString(orders.getSpare4(),""));
  1837. jsonObject.put("SPARE5", DataUtils.asString(orders.getSpare5(),""));
  1838. jsonObject.put("SPARE6", DataUtils.asString(orders.getSpare6(),""));
  1839. jsonObject.put("SPARE7", DataUtils.asString(orders.getSpare7(),""));
  1840. jsonObject.put("SPARE8", DataUtils.asString(orders.getSpare8(),""));
  1841. jsonObject.put("SPARE9", DataUtils.asString(orders.getSpare9(),""));
  1842. jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  1843. jsonObject.put("ORDER_NO", DataUtils.asString(orders.getOrderId(),""));
  1844. jsonObject.put("SEND_SYSTEM_ID", DataUtils.asString("",""));
  1845. jsonObject.put("DELIVERY_OUTBOUND_TYPE", DataUtils.asString(orders.getOutboundKind(),""));
  1846. jsonObject.put("OUTBOUND_DETAIL_TYPE", DataUtils.asString(orders.getOrderDealType(),""));
  1847. jsonObject.put("REQUIRED_PICKUP_TIME", DataUtils.asString(dob.getRequiredPickupTime(),""));
  1848. jsonObject.put("CARRIER_CODE", DataUtils.asString(orders.getCarrierCode(),""));
  1849. jsonObject.put("LOGISTICS_FEE", DataUtils.asString(orders.getLogisticsFee(),""));
  1850. //jsonObject.put("COLLECTION_FLAG", DataUtils.asString(orders.getCollectionFlag(),"0"));
  1851. if ("2502".equals(orders.getPayType()) && null != orders.getTotalFee() && 0 != orders.getTotalFee()){
  1852. jsonObject.put("COLLECTION_FLAG", DataUtils.asString(orders.getTotalFee(),"0"));
  1853. }
  1854. else{
  1855. jsonObject.put("COLLECTION_FLAG", "0");
  1856. }
  1857. jsonObject.put("RECEIVER_CODE", DataUtils.asString(orders.getReceiverCode(),""));
  1858. jsonObject.put("LOTS_ALLOWED", DataUtils.asString(orders.getLotsAllowed(),""));
  1859. jsonObject.put("FLOW_ID", DataUtils.asString("",""));
  1860. jsonObject.put("OWN_GOOD_FLAG", DataUtils.asString(orders.getOwnGoodFlag(),""));
  1861. jsonObject.put("TOTAL_FEE", DataUtils.asString(orders.getTotalFee(),""));
  1862. jsonObject.put("RECEIVER_COUNTRY", DataUtils.asString(orders.getReceiverCountry(),""));
  1863. jsonObject.put("RECEIVER_DISTRICT", DataUtils.asString(orders.getReceiverDistrict(),""));
  1864. jsonObject.put("RECEIVER_CONTACTOR_MOBILE", DataUtils.asString(orders.getReceiverContactorMobile(),""));
  1865. jsonObject.put("RECEIVER_ZIPCODE", DataUtils.asString(orders.getReceiverZipcode(),""));
  1866. jsonObject.put("MEDIANAME_PRINT", DataUtils.asString(orders.getMedianamePrint(),""));
  1867. jsonObject.put("MEDIANAME", DataUtils.asString(orders.getMedianame(),""));
  1868. jsonObject.put("DEAL_STATUS", DataUtils.asString(orders.getOrderStatus(),""));
  1869. jsonObject.put("DEAL_RESPONSE", DataUtils.asString("",""));
  1870. jsonObject.put("DEAL_TIME", DataUtils.asString(orders.getCreationTime(),""));
  1871. jsonObject.put("CU_PRE_FUND", DataUtils.asString(orders.getCuPreFund(),""));
  1872. jsonObject.put("LIST_PRINT", DataUtils.asString(orders.getListPrint(),""));
  1873. jsonObject.put("INVOICE_PRINT", DataUtils.asString(orders.getInvoicePrint(),""));
  1874. jsonObject.put("ROLEGROUPTYPE", DataUtils.asString(orders.getRolegrouptype(),""));
  1875. jsonObject.put("ORDER_INVILID_TIME", DataUtils.asString(orders.getOrderInvilidTime(),""));
  1876. jsonObject.put("ORDER_SOURCE", DataUtils.asString(dob.getSalesPlatform(),""));
  1877. jsonObject.put("CUSTOMER_REFFERENCE_NO", DataUtils.asString(orders.getCustomerRefferenceId(),""));
  1878. jsonObject.put("SALES_CASH", DataUtils.asString(orders.getSalesCash(),"") );
  1879. jsonObject.put("STAFF_NAME", DataUtils.asString(orders.getStaffName(),"") );
  1880. jsonObject.put("TOTAL_COST", DataUtils.asString(orders.getTotalCost(),"") );
  1881. jsonObject.put("ALL_PREFUND", DataUtils.asString(orders.getSalesCash(),"") );
  1882. jsonArray.add(jsonObject);
  1883. }
  1884. }
  1885. return jsonArray ;
  1886. }
  1887. public JSONArray doPrintCod(List<String> ids){
  1888. JSONArray jsonArray = new JSONArray();
  1889. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1890. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  1891. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  1892. Map<String,Object> params = new HashMap<String,Object>();
  1893. params.put("ids", ids);
  1894. List<Orders> list = dao.query(sql, params);
  1895. if( list!=null && list.size()>0 ){
  1896. // for(Orders orders : list ){
  1897. // if (null != orders.getCarrierId() && isReming == true && StringUtils.isBlank(orders.getCarrierTrackingNumber())){
  1898. // Map map = this.getcarrierTrackNumber(orders);
  1899. //
  1900. // orders.setCarrierTrackingNumber((String)map.get("mailNo"));
  1901. // orders.setOriginCode((String)map.get("originCode"));
  1902. // orders.setDestCode((String)map.get("destCode"));
  1903. // }
  1904. // }
  1905. for(Orders orders : list ){
  1906. JSONObject jsonObject = new JSONObject();
  1907. BigCustomer bc =this.bigCustomerService.findBigCustomerByCustomerIdandCarrierId(orders.getCustomerId(),
  1908. orders.getCarrierId());
  1909. WarehouseVO warehousevo = this.warehouseService.getEntity(orders.getWarehouseId());
  1910. jsonObject.put("ORDER_ID",DataUtils.asString(orders.getOrderId(),""));
  1911. jsonObject.put("OUTBOUND_KIND",DataUtils.asDictionary(orders.getOutboundKind()+"") );
  1912. jsonObject.put("CUSTOMER_NAME", DataUtils.asString(orders.getCustomerName(),"") );
  1913. jsonObject.put("WAREHOUSE_NAME", DataUtils.asString(orders.getWarehouseName(),"") );
  1914. jsonObject.put("CUSTOMER_REFFERENCE_ID", DataUtils.asString(orders.getCustomerRefferenceId(),"") );
  1915. jsonObject.put("CARRIER_NAME",DataUtils.asString(orders.getCarrierName(),"") );
  1916. jsonObject.put("RECEIVER_NAME", DataUtils.asString(orders.getReceiverName(),"") );
  1917. jsonObject.put("RECEIVER_CONTACTOR",DataUtils.asString(orders.getReceiverContactor(),"") );
  1918. jsonObject.put("CREATION_TIME", orders.getCreationTime()==null?"":DateUtils.getTimeStr( orders.getCreationTime(),2) );
  1919. jsonObject.put("PAY_TYPE", DataUtils.asString(orders.getPayType(),"") );
  1920. jsonObject.put("COMMENT", DataUtils.asString(orders.getOrderMemo(),"") );
  1921. jsonObject.put("TOTALCOST", DataUtils.asDouble(orders.getTotalCost(),0));
  1922. jsonObject.put("PAY", DataUtils.asDouble(orders.getPay(),0));
  1923. jsonObject.put("PRE_FUND", DataUtils.asDouble(orders.getPreFund(),0));
  1924. jsonObject.put("POINTS", DataUtils.asDouble(orders.getPoints(),0));
  1925. jsonObject.put("PAY_ADVANCE2", DataUtils.asDouble(orders.getPayAdvance2(),0));
  1926. jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0));
  1927. jsonObject.put("PAY_CASH", DataUtils.asDouble(orders.getPayCash(),0));
  1928. jsonObject.put("INDENT_DATE", orders.getIndentDate()==null?"":DateUtils.getTimeStr( orders.getIndentDate(),2) );
  1929. jsonObject.put("PRE_ADVANCE", DataUtils.asDouble(orders.getPreAdvance(),0));
  1930. jsonObject.put("MEDIANAME_PRINT", DataUtils.asString(orders.getMedianamePrint(),"") );
  1931. jsonObject.put("MEDIANAME", DataUtils.asString(orders.getMedianame(),"") );
  1932. jsonObject.put("ROLEGROUPTYPE", DataUtils.asString(orders.getRolegrouptype(),"") );
  1933. jsonObject.put("RECEIVER_COUNTRY", DataUtils.asString(orders.getReceiverCountry(),"") );
  1934. jsonObject.put("RECEIVER_PROVINCE", DataUtils.asString(orders.getReceiverProvince(),"") );
  1935. jsonObject.put("RECEIVER_CITY", DataUtils.asString(orders.getReceiverCity(),"") );
  1936. jsonObject.put("RECEIVER_DISTRICT", DataUtils.asString(orders.getReceiverDistrict(),"") );
  1937. jsonObject.put("RECEIVER_STREET", DataUtils.asString(orders.getReceiverStreet(),"") );
  1938. jsonObject.put("RECEIVER_CONTACTOR_MOBILE", DataUtils.asString(orders.getReceiverContactorMobile(),"") );
  1939. jsonObject.put("RECEIVER_ZIPCODE", DataUtils.asString(orders.getReceiverZipcode(),"") );
  1940. jsonObject.put("RECEIVER_CONTACTOR_PHONE", DataUtils.asString(orders.getReceiverContactorPhone(),"") );
  1941. jsonObject.put("IS_PROHIBITED", DataUtils.asInt(orders.getIsProhibited(),0));
  1942. jsonObject.put("ROUTE_NAME", DataUtils.asString(orders.getOrderRoute(),""));
  1943. jsonObject.put("TOTAL_FEE", DataUtils.asDouble(orders.getTotalFee(),0) );
  1944. jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0) );
  1945. jsonObject.put("WEIGHT", DataUtils.asDouble(orders.getWeight(),0) );
  1946. String bigCustomerNo = bc == null ? "temp" : bc.getBigCustomerName();
  1947. String trackingNumber = orders.getCarrierTrackingNumber()==null ?"":orders.getCarrierTrackingNumber();
  1948. jsonObject.put("EXPRESS_NO", DataUtils.asString(trackingNumber,"") );
  1949. jsonObject.put("ORIGINATIONG_CODE", DataUtils.asString(orders.getOriginCode(),"") );
  1950. jsonObject.put("DESTINATION_CODE", DataUtils.asString(orders.getDestCode(),"") );
  1951. jsonObject.put("ITEM_DESCRIPTION", DataUtils.asString(orders.getOrderMemo(),"") );
  1952. jsonObject.put("ITEM_COUNT", DataUtils.asString(orders.getDetailCount(),"") );
  1953. jsonObject.put("BIG_CUSTOMER_NO", DataUtils.asString(bigCustomerNo,"") );
  1954. jsonObject.put("ACCOUNTS_MODE", "1");
  1955. jsonObject.put("IS_SECURE", "0");
  1956. jsonObject.put("SECURE_ACCOUNTS", DataUtils.asDouble(orders.getTotalCost(), 0));
  1957. jsonObject.put("VOLUME", DataUtils.asDouble(orders.getBulk(), 0));
  1958. jsonObject.put("LENGTH", 0);
  1959. jsonObject.put("WIDTH", 0);
  1960. jsonObject.put("HEIGHT", 0);
  1961. jsonObject.put("SENDER", DataUtils.asString(warehousevo.getContactor(), ""));
  1962. jsonObject.put("SENDER_COMPANY", DataUtils.asString(warehousevo.getWarehouseName(), ""));
  1963. jsonObject.put("SENDER_COUNTRY", DataUtils.asString(warehousevo.getCountry(), ""));
  1964. jsonObject.put("SENDER_PROVINCE", DataUtils.asString(warehousevo.getProvince(), ""));
  1965. jsonObject.put("SENDER_CITY", DataUtils.asString(warehousevo.getCity(), ""));
  1966. jsonObject.put("SENDER_COUNTY", DataUtils.asString(warehousevo.getDistrict(), ""));
  1967. jsonObject.put("SENDER_ADDR", DataUtils.asString(warehousevo.getStreet(), ""));
  1968. jsonObject.put("SENDER_CONTACTOR_MOBILE", DataUtils.asString(warehousevo.getPersonalPhone(), ""));
  1969. jsonObject.put("RECEIVER_CUSTOMER_CODE",DataUtils.asString(orders.getReceiverCode(),""));
  1970. jsonObject.put("SENDER_CUSTOMER_CODE",DataUtils.asString(orders.getCustomerCode(),""));
  1971. jsonObject.put("TOTAL_QUANTITY",DataUtils.asString(orders.getExpectedSendQuantity(),""));
  1972. jsonObject.put("ACTUAL_WEIGHT",DataUtils.asString(orders.getWeight(),""));
  1973. jsonObject.put("ROLEGROUPTYPE",DataUtils.asString(orders.getRolegrouptype(),""));
  1974. jsonObject.put("SPARE1", DataUtils.asString(orders.getSpare1(),""));
  1975. jsonObject.put("SPARE2", DataUtils.asString(orders.getSpare2(),""));
  1976. jsonObject.put("SPARE3", DataUtils.asString(orders.getSpare3(),""));
  1977. jsonObject.put("SPARE4", DataUtils.asString(orders.getSpare4(),""));
  1978. jsonObject.put("SPARE5", DataUtils.asString(orders.getSpare5(),""));
  1979. jsonObject.put("SPARE6", DataUtils.asString(orders.getSpare6(),""));
  1980. jsonObject.put("SPARE7", DataUtils.asString(orders.getSpare7(),""));
  1981. jsonObject.put("SPARE8", DataUtils.asString(orders.getSpare8(),""));
  1982. jsonObject.put("SPARE9", DataUtils.asString(orders.getSpare9(),""));
  1983. jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  1984. //jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  1985. //jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  1986. jsonArray.add(jsonObject);
  1987. }
  1988. }
  1989. return jsonArray ;
  1990. }
  1991. /*
  1992. *
  1993. * 封装打印五联返单的JSON
  1994. */
  1995. public JSONArray doPrintReturn(List<String> ids){
  1996. JSONArray jsonArray = new JSONArray();
  1997. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  1998. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  1999. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  2000. Map<String,Object> params = new HashMap<String,Object>();
  2001. params.put("ids", ids);
  2002. List<Orders> list = dao.query(sql, params);
  2003. if( list!=null && list.size()>0 ){
  2004. for(Orders orders : list ){
  2005. JSONObject jsonObject = new JSONObject();
  2006. // BigCustomer bc =this.bigCustomerService.findBigCustomerByCustomerIdandCarrierId(orders.getCustomerId(),
  2007. // orders.getCarrierId());
  2008. // WarehouseVO warehousevo = this.warehouseService.getEntity(orders.getWarehouseId());
  2009. //
  2010. // jsonObject.put("ORDER_ID",DataUtils.asString(orders.getOrderId(),""));
  2011. // jsonObject.put("OUTBOUND_KIND",DataUtils.asDictionary(orders.getOutboundKind()+"") );
  2012. // jsonObject.put("CUSTOMER_NAME", DataUtils.asString(orders.getCustomerName(),"") );
  2013. // jsonObject.put("WAREHOUSE_NAME", DataUtils.asString(orders.getWarehouseName(),"") );
  2014. // jsonObject.put("CUSTOMER_REFFERENCE_ID", DataUtils.asString(orders.getCustomerRefferenceId(),"") );
  2015. // jsonObject.put("CARRIER_NAME",DataUtils.asString(orders.getCarrierName(),"") );
  2016. // jsonObject.put("RECEIVER_NAME", DataUtils.asString(orders.getReceiverName(),"") );
  2017. // jsonObject.put("RECEIVER_CONTACTOR",DataUtils.asString(orders.getReceiverContactor(),"") );
  2018. // jsonObject.put("CREATION_TIME", orders.getCreationTime()==null?"":DateUtils.getTimeStr( orders.getCreationTime(),2) );
  2019. // jsonObject.put("PAY_TYPE", DataUtils.asString(orders.getPayType(),"") );
  2020. // jsonObject.put("COMMENT", DataUtils.asString(orders.getOrderMemo(),"") );
  2021. // jsonObject.put("TOTALCOST", DataUtils.asDouble(orders.getTotalCost(),0));
  2022. // jsonObject.put("PAY", DataUtils.asDouble(orders.getPay(),0));
  2023. // jsonObject.put("PRE_FUND", DataUtils.asDouble(orders.getPreFund(),0));
  2024. // jsonObject.put("POINTS", DataUtils.asDouble(orders.getPoints(),0));
  2025. // jsonObject.put("PAY_ADVANCE2", DataUtils.asDouble(orders.getPayAdvance2(),0));
  2026. // jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0));
  2027. // jsonObject.put("PAY_CASH", DataUtils.asDouble(orders.getPayCash(),0));
  2028. // jsonObject.put("INDENT_DATE", orders.getIndentDate()==null?"":DateUtils.getTimeStr( orders.getIndentDate(),2) );
  2029. // jsonObject.put("PRE_ADVANCE", DataUtils.asDouble(orders.getPreAdvance(),0));
  2030. //
  2031. // jsonObject.put("MEDIANAME_PRINT", DataUtils.asString(orders.getMedianamePrint(),"") );
  2032. // jsonObject.put("MEDIANAME", DataUtils.asString(orders.getMedianame(),"") );
  2033. // jsonObject.put("ROLEGROUPTYPE", DataUtils.asString(orders.getRolegrouptype(),"") );
  2034. // jsonObject.put("RECEIVER_COUNTRY", DataUtils.asString(orders.getReceiverCountry(),"") );
  2035. // jsonObject.put("RECEIVER_PROVINCE", DataUtils.asString(orders.getReceiverProvince(),"") );
  2036. // jsonObject.put("RECEIVER_CITY", DataUtils.asString(orders.getReceiverCity(),"") );
  2037. // jsonObject.put("RECEIVER_DISTRICT", DataUtils.asString(orders.getReceiverDistrict(),"") );
  2038. // jsonObject.put("RECEIVER_STREET", DataUtils.asString(orders.getReceiverStreet(),"") );
  2039. // jsonObject.put("RECEIVER_CONTACTOR_MOBILE", DataUtils.asString(orders.getReceiverContactorMobile(),"") );
  2040. // jsonObject.put("RECEIVER_ZIPCODE", DataUtils.asString(orders.getReceiverZipcode(),"") );
  2041. // jsonObject.put("RECEIVER_CONTACTOR_PHONE", DataUtils.asString(orders.getReceiverContactorPhone(),"") );
  2042. // jsonObject.put("IS_PROHIBITED", DataUtils.asInt(orders.getIsProhibited(),0));
  2043. //
  2044. // jsonObject.put("ROUTE_NAME", DataUtils.asString(orders.getOrderRoute(),""));
  2045. // jsonObject.put("TOTAL_FEE", DataUtils.asDouble(orders.getTotalFee(),0) );
  2046. // jsonObject.put("TRANS_PAY", DataUtils.asDouble(orders.getTransPay(),0) );
  2047. // jsonObject.put("WEIGHT", DataUtils.asDouble(orders.getWeight(),0) );
  2048. //
  2049. // String bigCustomerNo = bc == null ? "temp" : bc.getBigCustomerName();
  2050. // String trackingNumber = orders.getCarrierTrackingNumber()==null ?"":orders.getCarrierTrackingNumber();
  2051. //
  2052. // jsonObject.put("EXPRESS_NO", DataUtils.asString(trackingNumber,"") );
  2053. // jsonObject.put("ORIGINATIONG_CODE", DataUtils.asString(orders.getOriginCode(),"") );
  2054. // jsonObject.put("DESTINATION_CODE", DataUtils.asString(orders.getDestCode(),"") );
  2055. // jsonObject.put("ITEM_DESCRIPTION", DataUtils.asString(orders.getOrderMemo(),"") );
  2056. // jsonObject.put("ITEM_COUNT", DataUtils.asString(orders.getDetailCount(),"") );
  2057. //
  2058. // jsonObject.put("BIG_CUSTOMER_NO", DataUtils.asString(bigCustomerNo,"") );
  2059. // jsonObject.put("ACCOUNTS_MODE", "1");
  2060. // jsonObject.put("IS_SECURE", "0");
  2061. // jsonObject.put("SECURE_ACCOUNTS", DataUtils.asDouble(orders.getTotalCost(), 0));
  2062. // jsonObject.put("VOLUME", DataUtils.asDouble(orders.getBulk(), 0));
  2063. // jsonObject.put("LENGTH", 0);
  2064. // jsonObject.put("WIDTH", 0);
  2065. // jsonObject.put("HEIGHT", 0);
  2066. // jsonObject.put("SENDER", DataUtils.asString(warehousevo.getContactor(), ""));
  2067. // jsonObject.put("SENDER_COMPANY", DataUtils.asString(warehousevo.getWarehouseName(), ""));
  2068. // jsonObject.put("SENDER_COUNTRY", DataUtils.asString(warehousevo.getCountry(), ""));
  2069. // jsonObject.put("SENDER_PROVINCE", DataUtils.asString(warehousevo.getProvince(), ""));
  2070. // jsonObject.put("SENDER_CITY", DataUtils.asString(warehousevo.getCity(), ""));
  2071. // jsonObject.put("SENDER_COUNTY", DataUtils.asString(warehousevo.getDistrict(), ""));
  2072. // jsonObject.put("SENDER_ADDR", DataUtils.asString(warehousevo.getStreet(), ""));
  2073. // jsonObject.put("SENDER_CONTACTOR_MOBILE", DataUtils.asString(warehousevo.getPersonalPhone(), ""));
  2074. //
  2075. // jsonObject.put("RECEIVER_CUSTOMER_CODE",DataUtils.asString(orders.getReceiverCode(),""));
  2076. // jsonObject.put("SENDER_CUSTOMER_CODE",DataUtils.asString(orders.getCustomerCode(),""));
  2077. // jsonObject.put("TOTAL_QUANTITY",DataUtils.asString(orders.getExpectedSendQuantity(),""));
  2078. // jsonObject.put("ACTUAL_WEIGHT",DataUtils.asString(orders.getWeight(),""));
  2079. //
  2080. // jsonObject.put("ROLEGROUPTYPE",DataUtils.asString(orders.getRolegrouptype(),""));
  2081. //
  2082. // jsonObject.put("SPARE1", DataUtils.asString(orders.getSpare1(),""));
  2083. // jsonObject.put("SPARE2", DataUtils.asString(orders.getSpare2(),""));
  2084. // jsonObject.put("SPARE3", DataUtils.asString(orders.getSpare3(),""));
  2085. // jsonObject.put("SPARE4", DataUtils.asString(orders.getSpare4(),""));
  2086. // jsonObject.put("SPARE5", DataUtils.asString(orders.getSpare5(),""));
  2087. // jsonObject.put("SPARE6", DataUtils.asString(orders.getSpare6(),""));
  2088. // jsonObject.put("SPARE7", DataUtils.asString(orders.getSpare7(),""));
  2089. // jsonObject.put("SPARE8", DataUtils.asString(orders.getSpare8(),""));
  2090. // jsonObject.put("SPARE9", DataUtils.asString(orders.getSpare9(),""));
  2091. // jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  2092. // //jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  2093. // //jsonObject.put("SPARE10", DataUtils.asString(orders.getSpare10(),""));
  2094. jsonArray.add(jsonObject);
  2095. }
  2096. }
  2097. return jsonArray;
  2098. }
  2099. public JSONArray doPrintInvoice(List<String> ids){
  2100. JSONArray jsonArray = new JSONArray();
  2101. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  2102. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  2103. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  2104. Map<String,Object> params = new HashMap<String,Object>();
  2105. params.put("ids", ids);
  2106. List<Orders> list = dao.query(sql, params);
  2107. if( list!=null && list.size()>0 ){
  2108. for(Orders orders : list ){
  2109. JSONObject jsonObject = new JSONObject();
  2110. jsonObject.put("ORDER_ID",DataUtils.asString(orders.getOrderId(),""));
  2111. jsonObject.put("CUSTOMER_REFFERENCE_ID", DataUtils.asString(orders.getCustomerRefferenceId(),"") );
  2112. jsonObject.put("CARRIER_NAME",DataUtils.asString(orders.getCarrierName(),"") );
  2113. jsonObject.put("RECEIVER_NAME", DataUtils.asString(orders.getReceiverName(),"") );
  2114. jsonObject.put("RECEIVER_CONTACTOR",DataUtils.asString(orders.getReceiverContactor(),"") );
  2115. jsonObject.put("MEDIANAME_PRINT", DataUtils.asString(orders.getMedianamePrint(),"") );
  2116. jsonObject.put("MEDIANAME", DataUtils.asString(orders.getMedianame(),"") );
  2117. jsonObject.put("INVOICE_AMOUNT", DataUtils.asStringExt(orders.getInvoiceAmount(),"") );
  2118. jsonObject.put("ROLEGROUPTYPE", DataUtils.asString(orders.getRolegrouptype(),"") );
  2119. jsonObject.put("INVOICE_PROJECT", DataUtils.asString(orders.getInvoiceProject(),"") );
  2120. jsonObject.put("INVOICE_TITLE", DataUtils.asString(orders.getInvoiceTitle(),"") );
  2121. jsonObject.put("IS_SPECIAL_INVOICE", DataUtils.asString(orders.getIsSpecialInvoice(),"0") );
  2122. jsonArray.add(jsonObject);
  2123. }
  2124. }
  2125. return jsonArray ;
  2126. }
  2127. public JSONArray doExpressLabelPrint(List<String> ids){
  2128. JSONArray jsonArray = new JSONArray();
  2129. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  2130. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(qc);
  2131. String sql ="select * from wms_orders where ORDER_ID IN(:ids) ORDER BY "+ getOrderByField(ids);
  2132. Map<String,Object> params = new HashMap<String,Object>();
  2133. params.put("ids", ids);
  2134. List<Orders> list = dao.query(sql, params);
  2135. if( list!=null && list.size()>0 ){
  2136. for(Orders orders : list ){
  2137. JSONObject jsonObject = new JSONObject();
  2138. jsonObject.put("ORDER_ID",DataUtils.asString(orders.getOrderId(),""));
  2139. jsonObject.put("TAG_ID", DataUtils.asString(orders.getTagId(),"") );
  2140. jsonObject.put("CARRIER_NAME",DataUtils.asString(orders.getCarrierName(),"") );
  2141. jsonObject.put("COMBINED_ORDER_ID",DataUtils.asString(orders.getCombinedOrderId(),"") );
  2142. jsonObject.put("CUSTOMER_REFFERENCE_ID",DataUtils.asString(orders.getCustomerRefferenceId(),"") );
  2143. jsonArray.add(jsonObject);
  2144. }
  2145. }
  2146. return jsonArray ;
  2147. }
  2148. public Map getcarrierTrackNumber(Orders orders) {
  2149. Map map = new HashMap();
  2150. String mailNo ="";
  2151. String originCode ="";
  2152. String destCode ="";
  2153. try{
  2154. if (orders.getCarrierId() == null) {
  2155. throw new AjaxException("承运商为空,无法打印热敏");
  2156. }
  2157. BigCustomer bc =
  2158. this.bigCustomerService.findBigCustomerByCustomerIdandCarrierId(orders.getCustomerId(),
  2159. orders.getCarrierId());
  2160. if( bc==null){
  2161. throw new AjaxException("没有配置大客户,无法打印热敏");
  2162. }
  2163. VenderVO vender = this.venderService.getVenderById(orders.getCarrierId());
  2164. WarehouseVO warehouse = this.warehouseService.getEntity(orders.getWarehouseId());
  2165. CustomerVO customer = this.customerCachedService.get(orders.getCustomerId());
  2166. List<OrdersDetail> ordersList = this.ordersDetailService.listBy(orders.getOrderId());
  2167. StringBuffer cargo = new StringBuffer();
  2168. StringBuffer cargo_count = new StringBuffer();
  2169. StringBuffer cargo_unit = new StringBuffer();
  2170. StringBuffer cargo_weight = new StringBuffer();
  2171. StringBuffer cargo_amount = new StringBuffer();
  2172. if(CollectionUtils.isNotEmpty(ordersList)){
  2173. for(int i = 0; i < ordersList.size(); i++){
  2174. if(i == (ordersList.size() -1)){
  2175. if (null == ordersList.get(i).getItemName()){
  2176. cargo.append("保健品");
  2177. }
  2178. else{
  2179. cargo.append(ordersList.get(i).getItemName());
  2180. }
  2181. cargo_count.append(Integer.toString(ordersList.get(i).getExpectedItemQuantity().intValue()));
  2182. if (null == ordersList.get(i).getUnits()){
  2183. cargo_unit.append("盒");
  2184. }
  2185. else{
  2186. cargo_unit.append(ordersList.get(i).getUnits());
  2187. }
  2188. if (null == ordersList.get(i).getWeight()){
  2189. cargo_weight.append(0);
  2190. }
  2191. else{
  2192. cargo_weight.append(ordersList.get(i).getWeight()/1000);
  2193. }
  2194. if (null == ordersList.get(i).getPrice()){
  2195. cargo_amount.append(0);
  2196. }
  2197. else{
  2198. cargo_amount.append(ordersList.get(i).getPrice());
  2199. }
  2200. }
  2201. else{
  2202. if (null == ordersList.get(i).getItemName()){
  2203. cargo.append("保健品").append(",");
  2204. }
  2205. else{
  2206. cargo.append(ordersList.get(i).getItemName()).append(",");
  2207. }
  2208. cargo_count.append(Integer.toString(ordersList.get(i).getExpectedItemQuantity().intValue())).append(",");
  2209. if (null == ordersList.get(i).getUnits()){
  2210. cargo_unit.append("盒").append(",");
  2211. }
  2212. else{
  2213. cargo_unit.append(ordersList.get(i).getUnits()).append(",");
  2214. }
  2215. if (null == ordersList.get(i).getWeight()){
  2216. cargo_weight.append(0).append(",");
  2217. }
  2218. else{
  2219. cargo_weight.append(ordersList.get(i).getWeight()/1000).append(",");
  2220. }
  2221. if (null == ordersList.get(i).getPrice()){
  2222. cargo_amount.append(0).append(",");
  2223. }
  2224. else{
  2225. cargo_amount.append(ordersList.get(i).getPrice()).append(",");
  2226. }
  2227. }
  2228. }
  2229. }
  2230. String analyseType = vender.getObtainCarrierTrackingNumber();
  2231. FetchMailNoRequestDto dto = new FetchMailNoRequestDto();
  2232. FetchMailNoRequestDto.Header header = new FetchMailNoRequestDto.Header();
  2233. FetchMailNoRequestDto.Body body = new FetchMailNoRequestDto.Body();
  2234. header.setAnalyzeType(analyseType);
  2235. if ("S90003".equals(analyseType)){
  2236. header.setInvocationWay(EdiConst.REQUEST_INVOCATIONWAY_MIDDLEDB);
  2237. }
  2238. else{
  2239. header.setInvocationWay(EdiConst.REQUEST_INVOCATIONWAY_WS);
  2240. }
  2241. FetchMailNoRequestDto.Body.LogisticsFetchMailNo fetchMailno =
  2242. new FetchMailNoRequestDto.Body.LogisticsFetchMailNo();
  2243. FetchMailNoRequestDto.Body.LogisticsFetchMailNo.Content content =
  2244. new FetchMailNoRequestDto.Body.LogisticsFetchMailNo.Content();
  2245. content.setBigaccountid(bc.getBigCustomerName());
  2246. content.setPassword(bc.getBigCustomerPassword());
  2247. content.setWeight(orders.getWeight() == null ? "0" : String.valueOf(orders.getWeight()/1000));
  2248. content.setIsCod(orders.getCollectionFlag()==null?"0":orders.getCollectionFlag().toString());
  2249. content.setOrderno(orders.getOrderId());
  2250. content.setSenderProvince(customer.getProvince());
  2251. if ("R70004".equals(analyseType)){
  2252. ProvinceCityCompare jpcc = this.provinceCityCompareService.findByInner(transformProvince(warehouse.getProvince()), warehouse.getCity(), warehouse.getDistrict());
  2253. ProvinceCityCompare dpcc = this.provinceCityCompareService.findByInner(transformProvince(orders.getReceiverProvince()), orders.getReceiverCity(), orders.getReceiverDistrict());
  2254. if (null != jpcc){
  2255. content.setSenderCity(jpcc.getOuterCity());
  2256. }
  2257. else{
  2258. content.setSenderCity(customer.getCity());
  2259. }
  2260. if (null != dpcc){
  2261. content.setReceiverCity(dpcc.getOuterCity());
  2262. }
  2263. else{
  2264. content.setReceiverCity(orders.getReceiverCity());
  2265. }
  2266. }
  2267. else{
  2268. content.setSenderCity(customer.getCity());
  2269. content.setReceiverCity(orders.getReceiverCity());
  2270. }
  2271. content.setSenderContactor(customer.getContactor());
  2272. content.setSenderTel(customer.getPersonalPhone() == null ? customer.getPhone() : customer.getPersonalPhone());
  2273. content.setSenderCompany(customer.getCustomerName());
  2274. content.setSenderAddress(customer.getProvince()+customer.getCity()+customer.getStreet());
  2275. content.setReceiverProvince(orders.getReceiverProvince());
  2276. if(null != orders.getReceiverCompany()){
  2277. content.setReceiverCompany(orders.getReceiverCompany());
  2278. }
  2279. else{
  2280. content.setReceiverCompany(orders.getReceiverName());
  2281. }
  2282. content.setReceiverContactor(orders.getReceiverContactor()==null?orders.getReceiverName():orders.getReceiverContactor());
  2283. content.setReceiverTel(orders.getReceiverContactorPhone() == null ? orders.getReceiverContactorMobile() : orders.getReceiverContactorPhone());
  2284. content.setReceiverAddress(orders.getReceiverProvince()+orders.getReceiverCity()+orders.getReceiverStreet());
  2285. content.setGoodsDesc(cargo.toString());
  2286. content.setGoodsNum(cargo_count.toString());
  2287. content.setCodFee(orders.getTotalFee() == null ? "0.0" : orders.getTotalFee().toString());
  2288. content.setCube(cargo_unit.toString());
  2289. content.setInsuranceFee(orders.getTotalCost() == null ? "0.0" : orders.getTotalCost().toString());
  2290. if (null != warehouse.getZipcode()){
  2291. content.setScustPost(warehouse.getZipcode());
  2292. }
  2293. else{
  2294. content.setScustPost("210000");
  2295. }
  2296. if (null != orders.getReceiverZipcode()){
  2297. content.setTcustPost(orders.getReceiverZipcode());
  2298. }
  2299. else{
  2300. content.setTcustPost("210000");
  2301. }
  2302. content.setTcustCounty(orders.getReceiverDistrict());
  2303. content.setLength("0");
  2304. content.setProductCode("");
  2305. content.setCarrierId(orders.getCarrierId() == null ? "" : orders.getCarrierId());
  2306. content.setReceiverDistrict(orders.getReceiverDistrict() == null ? "" : orders.getReceiverDistrict());
  2307. fetchMailno.setContent(content);
  2308. body.setLogisticsFetchMailNo(fetchMailno);
  2309. dto.setBody(body);
  2310. dto.setHeader(header);
  2311. FetchMailNoResponseDto rDto = this.getMailNoService.fetchMailNo(dto);
  2312. if(rDto==null){
  2313. // 由于网路延迟等原因,没有获取到顺丰承运商单号的,需要请求一次订单查询接口
  2314. // if ("R70004".equals(analyseType)){
  2315. // header.setAnalyzeType("R70006");
  2316. // dto.setHeader(header);
  2317. // rDto = this.getMailNoService.fetchMailNo(dto);
  2318. // }
  2319. // else{
  2320. throw new CommonException("由于网路延迟等原因,无法获取物流单号。");
  2321. // }
  2322. }
  2323. mailNo = rDto.getBody().getLogisticsFetchMailNoResponese().getHeader().getMailno();
  2324. originCode = rDto.getBody().getLogisticsFetchMailNoResponese().getHeader().getOriginalCode();
  2325. destCode = rDto.getBody().getLogisticsFetchMailNoResponese().getHeader().getDestinationCode();
  2326. logger.info("mailNo: " + mailNo + " originCode: " + originCode + " destCode: " + destCode);
  2327. map.put("mailNo", mailNo);
  2328. if (null != originCode && !"".equals(originCode)){
  2329. map.put("originCode", originCode);
  2330. }
  2331. else{
  2332. map.put("originCode", "");
  2333. }
  2334. //获取新的分拣码
  2335. orders.setCarrierTrackingNumber(mailNo);
  2336. destCode = getDestCodeByWmsOrders(orders);
  2337. map.put("destCode", destCode);
  2338. String sql ="UPDATE wms_orders SET CARRIER_TRACKING_NUMBER=?,ORIGIN_CODE=?,DEST_CODE=? WHERE ORDER_ID=?";
  2339. this.daoFactory.getJdbcDao().update(sql, mailNo, originCode, destCode, orders.getOrderId());
  2340. }catch(Exception ex){
  2341. throw new AjaxException("无法获取物流面单号,无法打印热敏");
  2342. }
  2343. // TODO 根据配置去获取物流面单号
  2344. return map;
  2345. }
  2346. public List groupOrderByInvoice(List<String> ids) {
  2347. QueryContext<Orders> qc = QueryContext.createQueryContext(Orders.class);
  2348. List resultList = new ArrayList();
  2349. List<String> needPrintInvoiceOrders = new ArrayList<String>();
  2350. List<String> needlessPrintInvoiceOrders = new ArrayList<String>();
  2351. resultList.add(needPrintInvoiceOrders);
  2352. resultList.add(needlessPrintInvoiceOrders);
  2353. Map<String, Object> param = new HashMap<String, Object>();
  2354. param.put("ids", ids);
  2355. List<Orders> checkList =
  2356. this.daoFactory
  2357. .getJdbcDao(qc).query(
  2358. "select * from wms_orders where DELETE_FLAG = 0 AND BUSINESS_LOCK_FLAG=0 and ORDER_STATUS<>5204 and ( PICK_STATUS=0 ) AND ( WAVE_ID IS NULL ) AND ORDER_ID in (:ids)",
  2359. param);
  2360. if( checkList!=null && checkList.size()>0 ){
  2361. for(Orders order:checkList ){
  2362. if(( order.getInvoiceAmount()==null || order.getInvoiceAmount().longValue()<=0 )
  2363. || (order.getIsSpecialInvoice()!=null && order.getIsSpecialInvoice().intValue()==1 )){
  2364. needlessPrintInvoiceOrders.add(order.getOrderId());
  2365. }else{
  2366. needPrintInvoiceOrders.add(order.getOrderId());
  2367. }
  2368. }
  2369. }
  2370. return resultList;
  2371. }
  2372. public List<List<Orders>> groupOrderByInvoice2(List<Orders> allOrders) {
  2373. List<List<Orders>> resultList = new ArrayList<List<Orders>>();
  2374. List<Orders> needPrintInvoiceOrders = new ArrayList<Orders>();
  2375. List<Orders> needlessPrintInvoiceOrders = new ArrayList<Orders>();
  2376. resultList.add(needPrintInvoiceOrders);
  2377. resultList.add(needlessPrintInvoiceOrders);
  2378. if( allOrders!=null && allOrders.size()>0 ){
  2379. for(Orders order:allOrders ){
  2380. if( isneedPrintInvoice(order) ){
  2381. needPrintInvoiceOrders.add(order);
  2382. }else{
  2383. needlessPrintInvoiceOrders.add(order);
  2384. }
  2385. }
  2386. }
  2387. return resultList;
  2388. }
  2389. /**
  2390. * 判断订单是否要打印发票
  2391. * @param orders
  2392. * @return
  2393. */
  2394. public boolean isneedPrintInvoice(Orders orders){
  2395. if(( orders.getInvoiceAmount()==null || orders.getInvoiceAmount().longValue()<=0 )
  2396. || (orders.getIsSpecialInvoice()!=null && orders.getIsSpecialInvoice().intValue()==1 ) ){
  2397. return false;
  2398. }else{
  2399. return true;
  2400. }
  2401. }
  2402. /**
  2403. *
  2404. * 根据id修改字段carrierTackingNumber
  2405. */
  2406. public void updateCarrierTackingNumberById(String id, String carrierTrackingNumber) {
  2407. String sql = "update wms_orders set CARRIER_TRACKING_NUMBER=:carrierTrackingNumber WHERE ID=:id";
  2408. Map<String, Object> params = new HashMap<String, Object>();
  2409. params.put("id", id);
  2410. params.put("carrierTrackingNumber", carrierTrackingNumber);
  2411. this.daoFactory.getJdbcDao().update(sql, params);
  2412. }
  2413. /** <一句话功能简述>
  2414. * <功能详细描述>
  2415. * @param orderId
  2416. * @param wmsOrdersStatusCancled
  2417. * @see [类、类#方法、类#成员]
  2418. */
  2419. public void updateOrderStatus(String orderId, Integer wmsOrdersStatusCancled)
  2420. {
  2421. String sql="update wms_orders set ORDER_STATUS =:ORDER_STATUS WHERE ORDER_ID =:ORDER_ID";
  2422. Map<String,Object> params2 = new HashMap<String,Object>();
  2423. params2.put("ORDER_STATUS", wmsOrdersStatusCancled);
  2424. params2.put("ORDER_ID", orderId);
  2425. this.daoFactory.getJdbcDao().update(sql, params2);
  2426. }
  2427. /**
  2428. * 查询物流返单号是否存在
  2429. */
  2430. public boolean isExistReturnNumber(String orderId, String returnNumber) {
  2431. int count =
  2432. this.daoFactory.getJdbcDao().queryForInt("select count(*) from wms_orders where ORDER_ID=? and RETURN_NUMBER=?",
  2433. orderId, returnNumber);
  2434. return count != 0;
  2435. }
  2436. @SuppressWarnings("unchecked")
  2437. public Map<String, Object> loadToOrdersPortalData(String accountId) {
  2438. Map<String, Object> result = new HashMap<String, Object>();
  2439. // 新记录状态的销售出库订单总数
  2440. int count1 =
  2441. this.daoFactory.getJdbcDao().queryForInt("select count(t.DELIVERY_OUTBOUND_ID) from oms_delivery_outbound t where t.DELIVERY_OUTBOUND_STATUS='4200' and t.ACCOUNT_ID=?",
  2442. accountId);
  2443. result.put("count1", count1);
  2444. // 已完成分配但未派箱的出货单总量
  2445. int count2 =
  2446. this.daoFactory.getJdbcDao().queryForInt("select count(o.ORDER_ID) from wms_orders o,(select WAVE_ID from wms_orders_wave ow where ow.ACCOUNT_ID=? and ow.ASSIGNED_BOX='0' and ow.WAVE_STATUS='2' and ow.ORDER_COUNT > 0 and ow.DELETE_FLAG='0') t where o.ACCOUNT_ID=? and o.DISTRIBUTION_UNSUCCESS_FLAG='1' and o.WAVE_ID=t.WAVE_ID",
  2447. accountId, accountId);
  2448. result.put("count2", count2);
  2449. // 已派箱未绑箱数
  2450. int count3 =
  2451. this.daoFactory.getJdbcDao().queryForInt("select count(t1.ORDER_ID) from (select o.ORDER_ID from wms_orders o,(select WAVE_ID from wms_orders_wave ow where ow.ACCOUNT_ID=? and ow.ASSIGNED_BOX='1' and ow.WAVE_STATUS='2' and ow.ORDER_COUNT > 0 and ow.DELETE_FLAG='0') t where o.ACCOUNT_ID=? and o.DISTRIBUTION_UNSUCCESS_FLAG='1' and o.PACKING_STATUS='0' and o.WAVE_ID=t.WAVE_ID) t1 where t1.ORDER_ID not in (select pb.ORDER_ID from wms_picklist_box pb where pb.ACCOUNT_ID=?)",
  2452. accountId, accountId, accountId);
  2453. result.put("count3", count3);
  2454. // 已绑箱未拣货完成订单数
  2455. int count4 =
  2456. this.daoFactory.getJdbcDao().queryForInt("select count(*) from wms_orders o,(select ORDER_ID from wms_picklist_box pb where pb.ACCOUNT_ID=? and pb.ORDER_ID is not null) t where o.ACCOUNT_ID=? and o.PICK_STATUS='1' and o.PICKED_QUANTITY='0' and o.ORDER_ID=t.ORDER_ID",
  2457. accountId, accountId);
  2458. result.put("count4", count4);
  2459. // 已拣货未包装订单数
  2460. int count5 =
  2461. this.daoFactory.getJdbcDao().queryForInt("select count(o.ORDER_ID) from wms_orders o where o.ACCOUNT_ID=? and o.PICK_STATUS='2' and o.PACKING_STATUS='0'",
  2462. accountId);
  2463. result.put("count5", count5);
  2464. // 已包装未交接订单数
  2465. int count6 =
  2466. this.daoFactory.getJdbcDao().queryForInt("select count(o.ORDER_ID) from wms_orders o where o.ACCOUNT_ID=? and o.PACKING_STATUS='2' and o.DELIVERY_STATUS='0'",
  2467. accountId);
  2468. result.put("count6", count6);
  2469. // 缺货订单数
  2470. int count7 =
  2471. this.daoFactory.getJdbcDao().queryForInt("select count(*) from (select odo.CUSTOMER_REFFERENCE_ID from oms_delivery_outbound odo where odo.DELIVERY_OUTBOUND_STATUS='4200' and odo.ACCOUNT_ID=? and odo.OWN_GOOD_FLAG='1' union select o.CUSTOMER_REFFERENCE_ID from wms_orders o where o.DISTRIBUTION_UNSUCCESS_FLAG='0' and o.ACCOUNT_ID=? and o.OWN_GOOD_FLAG ='1') t",
  2472. accountId, accountId);
  2473. int count8 =
  2474. this.daoFactory.getJdbcDao().queryForInt("select count(ogm.ID) from wms_own_good_manage ogm,(select odo.CUSTOMER_REFFERENCE_ID from oms_delivery_outbound odo where odo.DELIVERY_OUTBOUND_STATUS='4200' and odo.ACCOUNT_ID=? and odo.OWN_GOOD_FLAG='1' union select o.CUSTOMER_REFFERENCE_ID from wms_orders o where o.DISTRIBUTION_UNSUCCESS_FLAG='0' and o.ACCOUNT_ID=? and o.OWN_GOOD_FLAG ='1') t where ogm.ID=t.CUSTOMER_REFFERENCE_ID and ogm.account_id=? and ogm.DELETE_FLAG='0' and ogm.`STATUS`='6501'",
  2475. accountId, accountId, accountId);
  2476. result.put("count7", count7 - count8);
  2477. // 待发订单总数
  2478. int total = count1 + count2 + count3 + count4 + count5 + count6 + count7 - count8;
  2479. result.put("total", total);
  2480. return result;
  2481. }
  2482. /**
  2483. * 省份转化
  2484. */
  2485. public String transformProvince(String province){
  2486. String changedProvince = "";
  2487. if (null != province && !"".equals(province)){
  2488. if (province.contains("广西")){
  2489. changedProvince = "广西省";
  2490. }
  2491. else if (province.contains("内蒙古")){
  2492. changedProvince = "内蒙古";
  2493. }
  2494. else if (province.contains("宁夏")){
  2495. changedProvince = "宁夏自治区";
  2496. }
  2497. else if (province.contains("西藏")){
  2498. changedProvince = "西藏";
  2499. }
  2500. else if (province.contains("新疆")){
  2501. changedProvince = "新疆";
  2502. }
  2503. else if (province.contains("天津")){
  2504. changedProvince = "天津市";
  2505. }
  2506. else if (province.contains("北京")){
  2507. changedProvince = "北京市";
  2508. }
  2509. else if (province.contains("上海")){
  2510. changedProvince = "上海市";
  2511. }
  2512. else if (province.contains("重庆")){
  2513. changedProvince = "重庆市";
  2514. }
  2515. else{
  2516. changedProvince = province;
  2517. }
  2518. }
  2519. return changedProvince;
  2520. }
  2521. /**
  2522. * 根据波次号查询订单
  2523. * @param waveId
  2524. * @return
  2525. */
  2526. public List<Orders> queryOrdersByWaveId(String waveId) {
  2527. String sql = "SELECT * FROM wms_orders WHERE WAVE_ID =? AND DELETE_FLAG =0 ORDER BY ORDER_ID ";
  2528. ExtendedJdbcDao<Orders> dao = this.daoFactory.getJdbcDao(QueryContext.createQueryContext(Orders.class));
  2529. return dao.query(sql, waveId);
  2530. }
  2531. public List<Orders> findByStatus(String accountId, String customerId, int status){
  2532. Map<String, Object> param = new HashMap<String, Object>();
  2533. param.put("accountId", accountId);
  2534. param.put("customerId", customerId);
  2535. param.put("status", status);
  2536. String sql =
  2537. "select * from wms_orders where account_id=:accountId and customer_id=:customerId and ASSIGNED_STATUS=:status and DELETE_FLAG = 0";
  2538. List<Orders> list = findRecordsByConditions(sql, param, Orders.class);
  2539. return list;
  2540. }
  2541. public List<Orders> findByOutboundOrderId(String outboundOrderId){
  2542. Map<String, Object> param = new HashMap<String, Object>();
  2543. param.put("outboundOrderId", outboundOrderId);
  2544. String sql = "select * from wms_orders where OUTBOUND_ORDER_ID=:outboundOrderId and DELETE_FLAG = 0";
  2545. return findRecordsByConditions(sql, param, Orders.class);
  2546. }
  2547. /**
  2548. * 通过发货单获取三段码(分拣码新加接口)
  2549. * @param orders
  2550. * @return
  2551. */
  2552. public String getDestCodeByWmsOrders(Orders orders) {
  2553. StringBuffer destCode = new StringBuffer();
  2554. try {
  2555. JSONObject json = new JSONObject();
  2556. JSONArray jsonArray = new JSONArray();
  2557. JSONObject jsonDetail = new JSONObject();
  2558. jsonDetail.put("id", "1");
  2559. // 面单号
  2560. jsonDetail.put("mailNum", orders.getCarrierTrackingNumber());
  2561. // 产品代码 0100000000:文件;0200000000:信函;0300000000:物品;默认物品
  2562. jsonDetail.put("prodCode", "0300000000");
  2563. // 寄件人邮编
  2564. jsonDetail.put("clctOrgCode", "210023");
  2565. // 收件人邮编
  2566. String receiverZipcode = orders.getReceiverZipcode();
  2567. if (com.behosoft.util.StringUtils.isEmpty(receiverZipcode)) {
  2568. receiverZipcode = this.globalPostCodeSettingService.getPostCodeForPlace(orders.getReceiverProvince(),
  2569. orders.getReceiverCity(), null, null);
  2570. }
  2571. jsonDetail.put("arriPostCode", receiverZipcode);
  2572. //运输方式 0:陆运;1:航空;2:陆转航;3:航转陆;4:其他;默认是0
  2573. jsonDetail.put("transMode", "0");
  2574. // 收寄行政区划代码 与寄件人邮编必填一项
  2575. jsonDetail.put("clctArea", "210023");
  2576. // 寄达行政区划代码
  2577. jsonDetail.put("arriArea", receiverZipcode);
  2578. // 是否集散邮件 1:是;0:否;默认否
  2579. jsonDetail.put("isNanji", "0");
  2580. jsonDetail.put("recerAddress", orders.getReceiverStreet() == null? "*" : orders.getReceiverStreet());
  2581. jsonDetail.put("recerOrg", orders.getReceiverName() == null? "*" : orders.getReceiverName());
  2582. jsonDetail.put("recerProvName", orders.getReceiverProvince() == null? "*" : orders.getReceiverProvince());
  2583. jsonDetail.put("recerCityName", orders.getReceiverCity() == null? "*" : orders.getReceiverCity());
  2584. jsonDetail.put("recerCountryName", orders.getReceiverDistrict() == null? "*" : orders.getReceiverDistrict());
  2585. jsonDetail.put("requestTime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  2586. // 邮件种类 邮件号码前两位 【11】标准快递 【51】经济快递 【96】快递包裹 默认标准快递
  2587. jsonDetail.put("mailClass", "11");
  2588. jsonDetail.put("mome2", "");
  2589. jsonDetail.put("mome3", "");
  2590. jsonArray.add(jsonDetail);
  2591. json.put("dataList", jsonArray);
  2592. logger.info("获取三段码请求报文:" + json.toString());
  2593. // String result = HttpUtils.post(
  2594. // "http://ebi.ems.com.cn/ext-web/a/chinapost/thermalforward?method=getEMSSortCode",
  2595. // "application/json",
  2596. // json.toString().getBytes());
  2597. HashMap<String, Object> objectObjectHashMap = new HashMap<String, Object>();
  2598. objectObjectHashMap.put("url","http://ebi.ems.com.cn/ext-web/a/chinapost/thermalforward?method=getEMSSortCode");
  2599. objectObjectHashMap.put("requestData",json.toString());
  2600. Map<String, String> stringStringMap = HttpUtils.httpPost(objectObjectHashMap);
  2601. logger.info("获取三段码返回报文:" + stringStringMap.toString());
  2602. JSONObject jsonResult = JSONObject.fromObject(stringStringMap);
  2603. String response = (String) jsonResult.get("response");
  2604. JSONObject jsonResponse = JSONObject.fromObject(response);
  2605. JSONObject jsonObj1 = jsonResponse.getJSONArray("dataList").getJSONObject(0);
  2606. String provSendOrg = jsonObj1.getString("provSendOrg");
  2607. String provInSendOrg = jsonObj1.getString("provInSendOrg");
  2608. String dlvOrg = jsonObj1.getString("dlvOrg");
  2609. destCode.append(provSendOrg);
  2610. destCode.append("-");
  2611. destCode.append(provInSendOrg);
  2612. destCode.append("-");
  2613. destCode.append(dlvOrg);
  2614. }catch (Exception e){
  2615. logger.info("获取三段码报错:"+e);
  2616. }
  2617. return destCode.toString();
  2618. }
  2619. }