CustomerServiceImpl.java 61 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319
  1. package com.iamberry.rst.service.cm;
  2. import com.github.pagehelper.PageHelper;
  3. import com.iamberry.rst.core.cm.*;
  4. import com.iamberry.rst.core.fm.AwaitingSignclosedProductInfo;
  5. import com.iamberry.rst.core.fm.ComplaintDetectInfo;
  6. import com.iamberry.rst.core.fm.ComplaintSignclosedInfo;
  7. import com.iamberry.rst.core.order.*;
  8. import com.iamberry.rst.core.page.PagedResult;
  9. import com.iamberry.rst.faces.cm.*;
  10. import com.iamberry.rst.faces.order.EfastOrderService;
  11. import com.iamberry.rst.service.address.mapper.AddressMapper;
  12. import com.iamberry.rst.service.cm.mapper.*;
  13. import com.iamberry.rst.service.fm.mapper.ComplaintDetectInfoMapper;
  14. import com.iamberry.rst.service.fm.mapper.ComplaintSignclosedInfoMapper;
  15. import com.iamberry.rst.service.fm.mapper.ComplaintSignclosedProductInfoMapper;
  16. import com.iamberry.rst.service.product.mapper.ProductMapper;
  17. import com.iamberry.rst.util.CustomerCommonUtil;
  18. import com.iamberry.rst.util.PageUtil;
  19. import net.sf.json.JSONObject;
  20. import org.slf4j.Logger;
  21. import org.slf4j.LoggerFactory;
  22. import org.springframework.beans.factory.annotation.Autowired;
  23. import org.springframework.stereotype.Service;
  24. import org.springframework.transaction.annotation.Transactional;
  25. import java.util.*;
  26. @Service
  27. public class CustomerServiceImpl implements CustomerService {
  28. private static Logger logger = LoggerFactory.getLogger(CustomerServiceImpl.class);
  29. @Autowired
  30. private CustomerInfoMapper customerInfoMapper;
  31. @Autowired
  32. private RepairMapper repairMapper;
  33. @Autowired
  34. private BackGoodsMapper backGoodsMapper;
  35. @Autowired
  36. private NoreasonBackMapper noreasonBackMapper;
  37. @Autowired
  38. private ReissueMapper reissueMapper;
  39. @Autowired
  40. private RenewedMapper renewedMapper;
  41. @Autowired
  42. private ClosedFittingMapper closedFittingMapper;
  43. @Autowired
  44. private ClosedProdcueMapper closedProdcueMapper;
  45. @Autowired
  46. private SendProdcueMapper sendProdcueMapper;
  47. @Autowired
  48. private SendFittingMapper sendFittingMapper;
  49. @Autowired
  50. private SalesOrderMapper salesOrderMapper;
  51. @Autowired
  52. private CustomerService customerService;
  53. @Autowired
  54. private VisitMapper visitMapper; //回访
  55. @Autowired
  56. private ComplaintSignclosedInfoMapper complaintSignclosedInfoMapper; //仓储
  57. @Autowired
  58. private ComplaintDetectInfoMapper complaintDetectInfoMapper; //品检
  59. @Autowired
  60. private QuestionDescribeMapper questionDescribeMapper; //客诉问题
  61. @Autowired
  62. private AddressMapper addressMapper; //地址
  63. @Autowired
  64. private ProductMapper productMapper; //产品
  65. @Autowired
  66. private ComplaintSignclosedProductInfoMapper complaintSignclosedProductInfoMapper;
  67. @Autowired
  68. private FittingsInfoMapper fittingsInfoMapper;
  69. @Autowired
  70. private EfastOrderService efastOrderService;
  71. @Autowired
  72. private StoreInfoMapper storeInfoMapper;
  73. @Autowired
  74. private CustomerCommonService customerCommonService;
  75. @Autowired
  76. private RelationOrderService relationOrderService;
  77. @Autowired
  78. private ProcMethodService procMethodService;
  79. @Autowired
  80. private CmRelationMapper cmRelationMapper;
  81. @Override
  82. public CustomerInfo getCustomerInfo(Integer customerId) {
  83. return customerInfoMapper.getCustomerInfo(customerId);
  84. }
  85. @Override
  86. @Transactional
  87. public Integer saveCustomerInfo(CustomerInfo customerInfo,SalesOrder salesOrder){
  88. Integer isNeedSelectOrder = customerInfo.getIsNeedSelectOrder();
  89. List<SalesOrder> orderList = new ArrayList<>();
  90. //添加客诉基本信息
  91. Integer flag = 0;
  92. flag = customerInfoMapper.insert(customerInfo);
  93. if(flag < 1){
  94. throw new RuntimeException("添加客诉失败");
  95. }
  96. logger.info("-----------添加客诉-添加客诉基本信息---------------");
  97. QuestionDescribe questionDescribe = new QuestionDescribe();
  98. questionDescribe.setCustomerId(customerInfo.getCustomerId());
  99. questionDescribe.setDescribeTitle(customerInfo.getDescribeTitle()); //客诉问题标题
  100. questionDescribe.setDescribeContent(customerInfo.getDescribeContent()); //客诉问题描述
  101. questionDescribe.setDescribeHandleDesc(customerInfo.getDescribeHandleDesc()); //处理描述
  102. flag = questionDescribeMapper.insert(questionDescribe);
  103. if(flag < 1){
  104. throw new RuntimeException("添加客诉问题失败");
  105. }
  106. logger.info("-----------添加客诉-添加客诉问题---------------");
  107. if ("2".equals(customerInfo.getCustomerIsVisit())) {
  108. Visit visit = new Visit();
  109. visit.setCustomerId(customerInfo.getCustomerId());
  110. visit.setAdminId(customerInfo.getAdminId());
  111. visit.setDesignatedAdminId(customerInfo.getVisitAdminId());
  112. visit.setVisitName(customerInfo.getVisitName());
  113. visit.setVisitTel(customerInfo.getVisitTel());
  114. visit.setVisitDate(customerInfo.getVisitDate());
  115. visit.setVisitTimeSelect(customerInfo.getVisitTimeSelect());
  116. visit.setVisitStatus(1); //回访状态
  117. flag = visitMapper.addVisitInfo(visit);
  118. if(flag < 1){
  119. throw new RuntimeException("添加客诉回访信息失败");
  120. }
  121. logger.info("-----------添加客诉-添加客诉回访信息---------------");
  122. }
  123. ProcMethod procMethod = procMethodService.getProcMethodById(customerInfo.getProcMethodId());
  124. if (2 == customerInfo.getCustomerCounselType() && (procMethod.getProcMethodIsBack()==1||procMethod.getProcMethodIsSend()==1)){
  125. if(isNeedSelectOrder == 1){
  126. SalesOrder so = new SalesOrder();
  127. if(salesOrder.getIds()!= null && salesOrder.getIds().indexOf("_") > -1){
  128. String[] salesIds = salesOrder.getIds().split("_");
  129. so.setSalesIds(salesIds);
  130. orderList = salesOrderMapper.listSalesOrder(so);
  131. if(orderList == null || orderList.size() < 1){
  132. throw new RuntimeException("添加客诉-订单为空-请重新添加订单");
  133. }
  134. }else{
  135. throw new RuntimeException("添加客诉-订单为空-请重新添加订单");
  136. }
  137. }
  138. logger.info("-----------添加客诉-添加订单校验 --------------");
  139. }
  140. CmRelation cmRelation = customerInfo.getCmRelation();
  141. cmRelation.setCustomerId(customerInfo.getCustomerId());
  142. cmRelation.setRelationBackStatus(1); //寄回状态 1:未寄回
  143. cmRelation.setRelationSendStatus(1); //寄送状态 1:未寄送
  144. cmRelation.setRelationState(1); //状态 默认使用中
  145. //cmRelation.setTransactionNumber(customerInfo.getTransactionNumber()); //外部交易号
  146. // TODO: 2018/3/27 是否转账邮费,默认为不需要转账 : 0
  147. cmRelation.setRelationIsTransfer(0); //是否已转账邮费
  148. cmRelation.setRelationBackPostage(0); //邮费默认为0
  149. cmRelation.setRelationBackName(cmRelation.getRelationSendName()); //姓名
  150. cmRelation.setRelationBackTel(cmRelation.getRelationSendTel()); //电话号码
  151. /* 初始化产品类型,名称,配件名称 */
  152. customerService.setName(cmRelation);
  153. logger.info("-----------添加客诉-初始化产品,配件信息--------------");
  154. /*添加处理方式*/
  155. flag = cmRelationMapper.save(cmRelation);
  156. if (flag < 1) {
  157. throw new RuntimeException("添加客诉处理结果失败");
  158. }
  159. logger.info("-----------添加客诉-添加客诉处理成功--------------");
  160. /*添加客诉-添加处理与订单关联表*/
  161. List<RelationOrder> relationOrderList = new ArrayList<>();
  162. for (SalesOrder sor : orderList) {
  163. RelationOrder ro = new RelationOrder();
  164. ro.setRelationId(cmRelation.getRelationId());
  165. ro.setSalesId(sor.getSalesId());
  166. ro.setRelationCustomerId(customerInfo.getCustomerId());
  167. relationOrderList.add(ro);
  168. }
  169. if(relationOrderList != null && relationOrderList.size() > 0){
  170. flag = relationOrderService.saveList(relationOrderList);
  171. if(flag < 1){
  172. throw new RuntimeException("添加客诉,关联订单失败");
  173. }
  174. }
  175. logger.info("-----------添加客诉-添加处理与订单关联表--------------");
  176. for (SalesOrder sor : orderList) {
  177. SalesOrder newOrder = new SalesOrder(); //salesOrderStatus
  178. newOrder.setSalesId(sor.getSalesId());
  179. newOrder.setSalesOrderStatus(procMethod.getProcTypeId());
  180. flag = salesOrderMapper.updateSalesOrder(newOrder);
  181. if(flag < 1){
  182. throw new RuntimeException("添加客诉,修改订单失败");
  183. }
  184. }
  185. logger.info("-----------添加客诉-修改订单--------------");
  186. CustomerCommonUtil.setProduce(cmRelation);
  187. if(cmRelation.getClosedProdcues() != null && cmRelation.getClosedProdcues().size()>0){
  188. closedProdcueMapper.insert(cmRelation.getClosedProdcues());
  189. }
  190. if(cmRelation.getSendProdcues() != null && cmRelation.getSendProdcues().size() > 0){
  191. sendProdcueMapper.insert(cmRelation.getSendProdcues());
  192. }
  193. logger.info("-----------添加客诉-寄回寄出产品配件成功--------------");
  194. return flag;
  195. }
  196. @Override
  197. @Transactional
  198. public Integer updateCustomerInfo(CustomerInfo customerInfo,SalesOrder salesOrder){
  199. Integer isNeedSelectOrder = customerInfo.getIsNeedSelectOrder();
  200. //当前处理信息
  201. CmRelation cr = customerInfo.getCmRelation();
  202. //删除旧的售后数据
  203. customerService.deleteCustomerAfterSales(customerInfo,cr);
  204. List<SalesOrder> orderList = new ArrayList<SalesOrder>();
  205. //修改客诉基本信息
  206. Integer flag = 0;
  207. flag = customerInfoMapper.updateCustomerInfo(customerInfo);
  208. if(flag < 1){
  209. throw new RuntimeException("修改客诉失败-修改客诉基本信息失败");
  210. }
  211. logger.info("-----------修改客诉-修改客诉基本信息---------------");
  212. QuestionDescribe questionDescribe = new QuestionDescribe();
  213. // questionDescribe.setCustomerId(customerInfo.getCustomerId());
  214. questionDescribe.setDescribeId(customerInfo.getDescribeId());//客诉问题主键
  215. questionDescribe.setDescribeTitle(customerInfo.getDescribeTitle()); //客诉问题标题
  216. questionDescribe.setDescribeContent(customerInfo.getDescribeContent()); //客诉问题描述
  217. questionDescribe.setDescribeHandleDesc(customerInfo.getDescribeHandleDesc()); //处理描述
  218. flag = questionDescribeMapper.updateByPrimaryKeySelective(questionDescribe);
  219. if(flag < 1){
  220. throw new RuntimeException("修改客诉失败-修改客诉问题信息失败");
  221. }
  222. logger.info("-----------修改客诉-修改客诉问题---------------");
  223. if ("2".equals(customerInfo.getCustomerIsVisit())) {
  224. Visit visit = new Visit();
  225. visit.setCustomerId(customerInfo.getCustomerId());
  226. visit.setAdminId(customerInfo.getAdminId());
  227. visit.setDesignatedAdminId(customerInfo.getVisitAdminId());
  228. visit.setVisitName(customerInfo.getVisitName());
  229. visit.setVisitTel(customerInfo.getVisitTel());
  230. visit.setVisitDate(customerInfo.getVisitDate());
  231. visit.setVisitTimeSelect(customerInfo.getVisitTimeSelect());
  232. visit.setVisitStatus(1); //回访状态
  233. flag = visitMapper.addVisitInfo(visit);
  234. if(flag < 1){
  235. throw new RuntimeException("修改客诉失败-修改客诉回访失败");
  236. }
  237. logger.info("-----------修改客诉-修改客诉回访信息---------------");
  238. }
  239. ProcMethod procMethod = procMethodService.getProcMethodById(customerInfo.getProcMethodId());
  240. if (2 == customerInfo.getCustomerCounselType() && (procMethod.getProcMethodIsBack()==1||procMethod.getProcMethodIsSend()==1)){
  241. if(isNeedSelectOrder == 1){
  242. SalesOrder so = new SalesOrder();
  243. if(salesOrder.getIds()!= null && salesOrder.getIds().indexOf("_") > -1){
  244. String[] salesIds = salesOrder.getIds().split("_");
  245. so.setSalesIds(salesIds);
  246. orderList = salesOrderMapper.listSalesOrder(so);
  247. if(orderList == null || orderList.size() < 1){
  248. throw new RuntimeException("添加客诉-订单为空-请重新添加订单");
  249. }
  250. }else{
  251. throw new RuntimeException("添加客诉-订单查询出错-请重新添加订单");
  252. }
  253. }
  254. logger.info("-----------添加客诉-添加订单 --------------");
  255. }
  256. if (procMethod.getProcMethodIsBack()==2) {
  257. cr.setRelationBackStatus(1); //寄回状态 1:未寄回
  258. cr.setRelationIsTransfer(0); //是否已转账邮费
  259. cr.setRelationBackPostage(0); //邮费
  260. cr.setRelationBackLogisticsCompany("");//寄回物流公司
  261. cr.setRelationBackLogisticsNo("");//寄回物流单号
  262. cr.setRelationAlipay("");//转账账户
  263. cr.setRelationAlipayName("");//转账账户 (账户姓名)
  264. }
  265. if (procMethod.getProcMethodIsSend()==2) {
  266. cr.setRelationSendStatus(1); //寄送状态 1:未寄送
  267. cr.setRelationSendLogisticsCompany("");//寄送物流公司
  268. cr.setRelationSendLogisticsNo("");//寄送物流单号
  269. }
  270. /* 初始化产品类型,名称,配件名称 */
  271. customerService.setName(cr);
  272. logger.info("-----------修改客诉-初始化产品,配件信息--------------");
  273. ComplaintDetectInfo complaintDetectInfo = new ComplaintDetectInfo(); //品质检测
  274. ComplaintSignclosedInfo complaintSignclosedInfo = new ComplaintSignclosedInfo(); //客诉-签收表
  275. Map<String,Object> map;
  276. boolean isReturn = false;
  277. logger.info("-----------修改客诉-创建仓储/品检成功--------------");
  278. flag = cmRelationMapper.update(cr);
  279. if(flag < 1){
  280. throw new RuntimeException("修改客诉-修改处理信息失败");
  281. }
  282. logger.info("-----------修改客诉-修改处理信息失败--------------");
  283. /*添加客诉-添加处理与订单关联表*/
  284. List<RelationOrder> relationOrderList = new ArrayList<>();
  285. for (SalesOrder sor : orderList) {
  286. RelationOrder ro = new RelationOrder();
  287. ro.setRelationId(cr.getRelationId());
  288. ro.setSalesId(sor.getSalesId());
  289. ro.setRelationCustomerId(customerInfo.getCustomerId());
  290. relationOrderList.add(ro);
  291. }
  292. if(relationOrderList != null && relationOrderList.size() > 0){
  293. flag = relationOrderService.saveList(relationOrderList);
  294. if(flag < 1){
  295. throw new RuntimeException("添加客诉,关联订单失败");
  296. }
  297. }
  298. for (SalesOrder sor : orderList) {
  299. SalesOrder newOrder = new SalesOrder(); //salesOrderStatus
  300. newOrder.setSalesId(sor.getSalesId());
  301. newOrder.setSalesOrderStatus(procMethod.getProcTypeId());
  302. flag = salesOrderMapper.updateSalesOrder(newOrder);
  303. if(flag < 1){
  304. throw new RuntimeException("添加客诉,修改订单状态失败");
  305. }
  306. }
  307. logger.info("-----------添加客诉-添加处理与订单关联表--------------");
  308. logger.info("-----------添加客诉-修改订单--------------");
  309. CustomerCommonUtil.setProduce(cr);
  310. if(cr.getClosedProdcues() != null && cr.getClosedProdcues().size()>0){
  311. closedProdcueMapper.insert(cr.getClosedProdcues());
  312. }
  313. if(cr.getSendProdcues() != null && cr.getSendProdcues().size() > 0){
  314. sendProdcueMapper.insert(cr.getSendProdcues());
  315. }
  316. logger.info("-----------添加客诉-寄回寄出产品配件成功--------------");
  317. return flag;
  318. }
  319. /**
  320. * 删除旧的售后数据
  321. * @param customer
  322. */
  323. @Override
  324. @Transactional
  325. public void deleteCustomerAfterSales(CustomerInfo customer,CmRelation cmRelation){
  326. Integer flag = 0;
  327. CustomerInfo customerInfo = customerInfoMapper.getCustomerInfo(customer.getCustomerId());
  328. //删除回访信息
  329. if ("2".equals(customerInfo.getCustomerIsVisit())){
  330. flag = visitMapper.deleteByPrimaryKey(customer.getCustomerId());
  331. if(flag < 1){
  332. throw new RuntimeException("修改客诉-删除回访,删除回访失败");
  333. }
  334. }
  335. //删除寄出寄回产品
  336. ClosedProdcue closedrecord = new ClosedProdcue();
  337. SendProdcue sendProdcue = new SendProdcue();
  338. closedrecord.setRelationId(cmRelation.getRelationId());
  339. closedProdcueMapper.deleteByPrimaryKey(closedrecord);
  340. sendProdcue.setRelationId(cmRelation.getRelationId());
  341. sendProdcueMapper.deleteByPrimaryKey(sendProdcue);
  342. /*恢复订单状态*/
  343. RelationOrder relationOrder = new RelationOrder();
  344. relationOrder.setRelationId(cmRelation.getRelationId());
  345. List<RelationOrder> relationOrderList = relationOrderService.getRelationOrderList(relationOrder);
  346. for (int k=0; k<relationOrderList.size();k++){
  347. SalesOrder newOrder = new SalesOrder(); //salesOrderStatus
  348. newOrder.setSalesId(relationOrderList.get(k).getSalesId());
  349. newOrder.setSalesOrderStatus(1); //恢复订单到之前的状态
  350. salesOrderMapper.updateSalesOrder(newOrder);
  351. }
  352. /* 删除掉订单与处理的关联表 */
  353. relationOrderService.deleteByRelationId(cmRelation.getRelationId());
  354. }
  355. @Override
  356. public Integer selectNotSolvedCustomer(CustomerInfo customerInfo) {
  357. List<CustomerInfo> listCustomer = customerInfoMapper.listCustomer(customerInfo);
  358. return listCustomer.size();
  359. }
  360. @Override
  361. public List<CustomerInfo> listOnCustomer(CustomerInfo customerInfo) {
  362. List<CustomerInfo> customerList = customerInfoMapper.listOnCustomer(customerInfo);
  363. //查询售后维修集合
  364. // Repair repairInfo = new Repair();
  365. // repairInfo.setRepairState(1);
  366. // List<Repair> repairList = repairMapper.listRepair(repairInfo);
  367. // //查询售后退货集合
  368. // BackGoods backGoodsInfo = new BackGoods();
  369. // backGoodsInfo.setBackGoodsState(1);
  370. // List<BackGoods> backGoodsList = backGoodsMapper.listBackGoods(backGoodsInfo);
  371. // //查询售后无理由退货集合
  372. // NoreasonBack noreasonBackInfo = new NoreasonBack();
  373. // noreasonBackInfo.setNoreasonBackState(1);
  374. // List<NoreasonBack> noreasonBackList = noreasonBackMapper.listNoreasonBack(noreasonBackInfo);
  375. // //查询售后补发集合
  376. // Reissue reissueInfo = new Reissue();
  377. // reissueInfo.setReissueState(1);
  378. // List<Reissue> reissueList = reissueMapper.listReissue(reissueInfo);
  379. // //查询售后换新集合
  380. // Renewed renewedInfo = new Renewed();
  381. // renewedInfo.setRenewedState(1);
  382. // List<Renewed> renewedList = renewedMapper.listRenewed(renewedInfo);
  383. //
  384. // if (customerList != null && customerList.size() > 0) {
  385. // for (CustomerInfo customer : customerList) {
  386. // switch (customer.getCustomerIsSolve().intValue()) {
  387. // case 3: //换新
  388. // for (Renewed renewed : renewedList) {
  389. // if (renewed.getCustomerId().intValue() == customer.getCustomerId()) {
  390. // customer.setBackStatus(renewed.getRenewedBackStatus());
  391. // customer.setSendStatus(renewed.getRenewedSendStatus());
  392. // customer.setSalesTime(renewed.getSalesPayTime());
  393. // customer.setSendLogisticsNo(renewed.getRenewedSendLogisticsNo());
  394. // customer.setSendLogisticsCompany(renewed.getRenewedSendLogisticsCompany());
  395. // customer.setBackLogisticsNo(renewed.getRenewedBackLogisticsNo());
  396. // customer.setBackLogisticsCompany(renewed.getRenewedBackLogisticsCompany());
  397. // break;
  398. // }
  399. // }
  400. // break;
  401. // case 4: //维修
  402. // for (Repair repair : repairList) {
  403. // if (repair.getCustomerId().intValue() == customer.getCustomerId()) {
  404. // customer.setBackStatus(repair.getRepairBackStatus());
  405. // customer.setSendStatus(repair.getRepairSendStatus());
  406. // customer.setSalesTime(repair.getSalesPayTime());
  407. // customer.setSendLogisticsNo(repair.getRepairSendLogisticsNo());
  408. // customer.setSendLogisticsCompany(repair.getRepairSendLogisticsCompany());
  409. // customer.setBackLogisticsNo(repair.getRepairBackLogisticsNo());
  410. // customer.setBackLogisticsCompany(repair.getRepairBackLogisticsCompany());
  411. // break;
  412. // }
  413. // }
  414. // break;
  415. // case 5: //补发
  416. // for (Reissue reissue : reissueList) {
  417. // if (reissue.getCustomerId().intValue() == customer.getCustomerId()) {
  418. // customer.setSendStatus(reissue.getReissueSendStatus());
  419. // customer.setSalesTime(reissue.getSalesPayTime());
  420. // customer.setBackLogisticsNo(reissue.getReissueSendLogisticsNo());
  421. // customer.setBackLogisticsCompany(reissue.getReissueSendLogisticsCompany());
  422. // break;
  423. // }
  424. // }
  425. // break;
  426. // case 6: //退货
  427. // for (BackGoods backGoods : backGoodsList) {
  428. // if (backGoods.getCustomerId().intValue() == customer.getCustomerId()) {
  429. // customer.setBackStatus(backGoods.getBackGoodsBackStatus());
  430. // customer.setSalesTime(backGoods.getSalesPayTime());
  431. // customer.setSendLogisticsNo(backGoods.getBackGoodsBackLogisticsNo());
  432. // break;
  433. // }
  434. // }
  435. // break;
  436. // case 7: //无理由退货
  437. // for (NoreasonBack noreasonBack : noreasonBackList) {
  438. // if (noreasonBack.getCustomerId().intValue() == customer.getCustomerId()) {
  439. // customer.setBackStatus(noreasonBack.getNoreasonBackBackStatus());
  440. // customer.setSalesTime(noreasonBack.getSalesPayTime());
  441. // customer.setSendLogisticsNo(noreasonBack.getNoreasonBackBackLogisticsNo());
  442. // customer.setSendLogisticsCompany(noreasonBack.getNoreasonBackBackLogisticsCompany());
  443. // break;
  444. // }
  445. // }
  446. // break;
  447. // }
  448. // }
  449. // }
  450. return customerList;
  451. }
  452. /**
  453. * 产品配件初始化
  454. * @param cr
  455. */
  456. @Override
  457. @Transactional
  458. public void setName(CmRelation cr) {
  459. for (int i=0;i<cr.getSendProdcues().size();i++) {
  460. ProductColor productColor = productMapper.getProductBySku(cr.getSendProdcues().get(i).getColorBar());
  461. cr.getSendProdcues().get(i).setProductColor(productColor);
  462. cr.getSendProdcues().get(i).setColorId(productColor.getColorId());
  463. Product product = productMapper.getProduce(productColor.getColorProductId());
  464. cr.getSendProdcues().get(i).setProductId(product.getProductId());
  465. cr.getSendProdcues().get(i).setSendProduceName(product.getProductName());
  466. cr.getSendProdcues().get(i).setProductType(product.getProductType());
  467. cr.getSendProdcues().get(i).setProductNumber(product.getProductNumber());
  468. }
  469. for (int i=0;i<cr.getClosedProdcues().size();i++) {
  470. ProductColor productColor = productMapper.getProductBySku(cr.getClosedProdcues().get(i).getColorBar());
  471. cr.getClosedProdcues().get(i).setProductColor(productColor);
  472. cr.getClosedProdcues().get(i).setColorId(productColor.getColorId());
  473. Product product = productMapper.getProduce(productColor.getColorProductId());
  474. cr.getClosedProdcues().get(i).setProductId(product.getProductId());
  475. cr.getClosedProdcues().get(i).setClosedProductName(product.getProductName());
  476. cr.getClosedProdcues().get(i).setProductType(product.getProductType());
  477. cr.getClosedProdcues().get(i).setProductNumber(product.getProductNumber());
  478. }
  479. }
  480. /**
  481. * 产品配件初始化
  482. * @param cc
  483. */
  484. @Override
  485. @Transactional
  486. public void setName(CustomerCommon cc){
  487. }
  488. /**
  489. * 添加品检
  490. * @param complaintDetectInfo
  491. * @param customerCommon
  492. * @return
  493. */
  494. @Transactional
  495. public void saveComplaintDetectInfo(ComplaintDetectInfo complaintDetectInfo,CustomerCommon customerCommon){
  496. if(customerCommon.getIsNeedSelectOrder() == 2){
  497. return;
  498. }
  499. /*Integer flag = 0;
  500. List<ComplaintDetectInfo> complaintDetectInfoList = new ArrayList<ComplaintDetectInfo>();
  501. for(int i=0 ;i< customerCommon.getClosedProdcues().size();i++){
  502. ClosedProdcue closedProdcue = customerCommon.getClosedProdcues().get(i);
  503. for(int j=0; j<closedProdcue.getClosedProdcueNumber();j++){
  504. ComplaintDetectInfo cd = new ComplaintDetectInfo();
  505. cd.setSignclosedId(complaintDetectInfo.getSignclosedId());
  506. cd.setCustomerId(customerCommon.getCustomerId()); //添加客诉
  507. cd.setDetectState(1); //状态 1待仓库转入
  508. cd.setDetectRevolutionProduced(1); //是否转入生产部门 1待转入
  509. cd.setDetectIsMaintenance(1); //是否需要维修,1 需要 2不需要
  510. cd.setProductId(closedProdcue.getProductId());
  511. cd.setDetectProductType(closedProdcue.getProductType());
  512. if(closedProdcue.getProductNumber() == null || "".equals(closedProdcue.getProductNumber())){
  513. cd.setDetectProductNumber("0");
  514. }else{
  515. cd.setDetectProductNumber(closedProdcue.getProductNumber());
  516. }
  517. complaintDetectInfoList.add(cd);
  518. }
  519. }
  520. if(complaintDetectInfoList.size() > 0){
  521. flag = complaintDetectInfoMapper.insertList(complaintDetectInfoList);
  522. }
  523. if(flag < 1){
  524. throw new RuntimeException("添加品检失败");
  525. }*/
  526. }
  527. /**
  528. * 添加仓储
  529. * @param customerCommon
  530. * @return
  531. */
  532. @Override
  533. @Transactional
  534. public void saveComplaintSignclosedInfo(ComplaintSignclosedInfo complaintSignclosedInfo,CustomerCommon customerCommon){
  535. if(customerCommon.getIsNeedSelectOrder() == 2){
  536. return;
  537. }
  538. Integer flag;
  539. complaintSignclosedInfo.setSignclosedType(1); //客诉寄回
  540. complaintSignclosedInfo.setSignclosedCustomerId(customerCommon.getCustomerId()); //客诉id
  541. complaintSignclosedInfo.setSignclosedSendName(customerCommon.getRelationBackName()); //签收姓名
  542. complaintSignclosedInfo.setSignclosedSendTel(customerCommon.getRelationBackTel()); //签收手机
  543. flag = complaintSignclosedInfoMapper.insert(complaintSignclosedInfo);
  544. if(flag < 1){
  545. throw new RuntimeException("添加签收失败");
  546. }
  547. //添加代签收表
  548. List<AwaitingSignclosedProductInfo> awaitingSignclosedProductInfoArrayList = new ArrayList<>();
  549. for(int i=0 ;i< customerCommon.getClosedProdcues().size();i++){
  550. ClosedProdcue closedProdcue = customerCommon.getClosedProdcues().get(i);
  551. for(int k=0;k<closedProdcue.getClosedProdcueNumber();k++){
  552. AwaitingSignclosedProductInfo awaitingSignclosedProductInfo = new AwaitingSignclosedProductInfo();
  553. awaitingSignclosedProductInfo.setSignclosedId(complaintSignclosedInfo.getSignclosedId()); //仓储id
  554. awaitingSignclosedProductInfo.setSignclosedProductType(1); //类型为产品
  555. awaitingSignclosedProductInfo.setProductNum(1);
  556. awaitingSignclosedProductInfo.setSignclosedProductId(closedProdcue.getProductId()); //产品id
  557. awaitingSignclosedProductInfo.setSignclosedProductColor(closedProdcue.getColorId()); //颜色id
  558. awaitingSignclosedProductInfo.setProductName(closedProdcue.getClosedProductName()); //产品名称
  559. awaitingSignclosedProductInfoArrayList.add(awaitingSignclosedProductInfo);
  560. }
  561. }
  562. for(int i=0 ;i< customerCommon.getClosedFittings().size();i++){
  563. ClosedFitting closedFitting = customerCommon.getClosedFittings().get(i);
  564. for(int k=0;k<closedFitting.getClosedFittingNumber();k++){
  565. AwaitingSignclosedProductInfo awaitingSignclosedProductInfo = new AwaitingSignclosedProductInfo();
  566. awaitingSignclosedProductInfo.setSignclosedId(complaintSignclosedInfo.getSignclosedId()); //仓储id
  567. awaitingSignclosedProductInfo.setSignclosedProductType(2); //类型为配件
  568. awaitingSignclosedProductInfo.setProductNum(1);
  569. awaitingSignclosedProductInfo.setSignclosedProductId(closedFitting.getFittingsId()); //配件id
  570. awaitingSignclosedProductInfo.setSignclosedProductColor(null);
  571. awaitingSignclosedProductInfo.setProductName(closedFitting.getClosedFittingsName()); //配件名称
  572. awaitingSignclosedProductInfoArrayList.add(awaitingSignclosedProductInfo);
  573. }
  574. }
  575. flag = complaintSignclosedProductInfoMapper.insertList(awaitingSignclosedProductInfoArrayList);
  576. if(flag < 1){
  577. throw new RuntimeException("添加签收产品失败");
  578. }
  579. }
  580. /**
  581. * 向Efast推送订单 仅换新,维修 ,补发
  582. * @return
  583. */
  584. @Transactional
  585. public Map<String,Object> sendEfastOrder(CustomerCommon customerCommon,SalesOrder salesOrder){
  586. Map<String,Object> map = new HashMap<String,Object>();
  587. List<EfastOrder> orderList = new ArrayList<EfastOrder>();
  588. List<OrderItem> itemList = new ArrayList<OrderItem>();
  589. Integer num = 0; //产品数量
  590. Integer amout = 0; //商品总价
  591. String orderProductBarCode = ""; //产品sku
  592. String productName = ""; //产品名称
  593. for(int i=0;i<customerCommon.getSendProdcues().size();i++){
  594. SendProdcue sendProdcue = customerCommon.getSendProdcues().get(i);
  595. OrderItem orderItem = new OrderItem();
  596. orderItem.setItemProductName(sendProdcue.getSendProduceName());
  597. orderItem.setItemProductNum(sendProdcue.getSendProdcueNumber());
  598. orderItem.setItemProductPrice(sendProdcue.getProductColor().getColorPrice());
  599. orderItem.setItemColorBar(sendProdcue.getProductColor().getColorBar());
  600. itemList.add(orderItem);
  601. orderProductBarCode = sendProdcue.getProductColor().getColorBar();
  602. productName = sendProdcue.getSendProduceName();
  603. num += sendProdcue.getSendProdcueNumber();
  604. amout += sendProdcue.getProductColor().getColorPrice();
  605. }
  606. EfastOrder efastOrder = new EfastOrder();
  607. efastOrder.setOrderAddressName(customerCommon.getRelationSendName());//收货人姓名
  608. efastOrder.setOrderAddressTel(customerCommon.getRelationSendTel());//收货人电话
  609. efastOrder.setOrderOpenId("1");//身份证
  610. String[] address = customerCommon.getRelationSendMergeAddress().split("-");
  611. efastOrder.setOrderProvince(address[0]);
  612. efastOrder.setOrderCity(address[1]);
  613. efastOrder.setOrderArea(address[2]);
  614. efastOrder.setOrderAddress(customerCommon.getRelationSendAddress());
  615. efastOrder.setOrderStatus(2);
  616. efastOrder.setOrderStoreId(salesOrder.getStoreEfast()); //设置efast店铺id
  617. efastOrder.setOrderNum(num); //产品数量
  618. efastOrder.setOrderAmount(amout); //商品总价
  619. efastOrder.setOrderPayMoney(amout); //已付款
  620. //支付方式
  621. switch (salesOrder.getSalesPayType()){
  622. case 1: //微信支付
  623. efastOrder.setOrderPayType(1);
  624. break;
  625. case 2: //现金支付
  626. efastOrder.setOrderPayType(2);
  627. break;
  628. case 3:
  629. break;
  630. case 4: //刷卡支付
  631. efastOrder.setOrderPayType(4);
  632. break;
  633. case 5: //支付宝支付
  634. efastOrder.setOrderPayType(5);
  635. break;
  636. default:
  637. efastOrder.setOrderPayType(2); //默认现金
  638. break;
  639. }
  640. efastOrder.setOrderProductBarCode(orderProductBarCode); //产品sku
  641. efastOrder.setOrderProductName(productName); //产品名称
  642. efastOrder.setOrderId(customerCommon.getTransactionNumber()); //外部交易号
  643. efastOrder.setOid(1);
  644. orderList.add(efastOrder);
  645. Integer status = 1;
  646. Map<String,Object> orderMap = new HashMap<String,Object>();
  647. try {
  648. orderMap = efastOrderService.sendOrder(orderList,itemList);
  649. } catch (Exception e) {
  650. status = 0;
  651. }
  652. List<EfastOrder> oList = (List<EfastOrder>) orderMap.get("efastOrderList");
  653. if(oList == null || oList.size() < 1){
  654. status = 0;
  655. }
  656. map.put("status",status);
  657. if(oList != null && oList.size() > 0){
  658. map.put("EfastOrderId",oList.get(0).getOrderId());
  659. logger.info("换新,维修 ,补发向Efast 推送订单成功,订单号为:" + oList.get(0).getOrderId());
  660. }else{
  661. logger.info("换新,维修 ,补发向Efast 推送订单,推送失败,交易号为:" + customerCommon.getTransactionNumber());
  662. }
  663. return map;
  664. }
  665. @Override
  666. public Integer getQuestionNumber(CustomerInfo customerInfo) {
  667. return customerInfoMapper.getQuestionNumber(customerInfo);
  668. }
  669. /**
  670. * 添加订单
  671. * @return
  672. */
  673. @Transactional
  674. public Integer addOrder(SalesOrder salesOrder) {
  675. //添加订单数据
  676. int orderNum = salesOrderMapper.addSalesOrder(salesOrder);
  677. if (orderNum <= 0) {
  678. throw new RuntimeException("系统添加订单失败");
  679. }
  680. for (SalesOrderItem item : salesOrder.getSalesOrderItemList()) {
  681. item.setItemOrderId(salesOrder.getSalesId());
  682. }
  683. //批量添加订单项数据
  684. int itemNum = salesOrderMapper.addOrderItemList(salesOrder.getSalesOrderItemList());
  685. if (itemNum <= 0) {
  686. throw new RuntimeException("系统添加订单项失败");
  687. }
  688. return orderNum;
  689. }
  690. @Override
  691. public List<CustomerStatisticalInfo> listStatisticalCustomer() {
  692. return customerInfoMapper.listStatisticalCustomer();
  693. }
  694. @Override
  695. public List<ReturnStatisticsInfo> salesTotalSales(SalesOrder salesOrder) {
  696. return customerInfoMapper.salesTotalSales(salesOrder);
  697. }
  698. @Override
  699. public List<ReturnStatisticsInfo> salesTotalExchange(SalesOrder salesOrder) {
  700. return customerInfoMapper.salesTotalExchange(salesOrder);
  701. }
  702. @Override
  703. public List<ReturnStatisticsInfo> salesTotalReturn(SalesOrder salesOrder) {
  704. return customerInfoMapper.salesTotalReturn(salesOrder);
  705. }
  706. @Override
  707. public List<ReturnStatisticsInfo> salesSecondaryChangeNew(SalesOrder salesOrder) {
  708. return customerInfoMapper.salesSecondaryChangeNew(salesOrder);
  709. }
  710. @Override
  711. public List<ReturnStatisticsInfo> salesReturnForSecond(SalesOrder salesOrder) {
  712. return customerInfoMapper.salesReturnForSecond(salesOrder);
  713. }
  714. @Override
  715. public List<ProcType> listProcType() {
  716. return customerInfoMapper.listProcType();
  717. }
  718. @Override
  719. public List<ProcMethod> listProcMethod(Integer procTypeId) {
  720. return customerInfoMapper.listProcMethod(procTypeId);
  721. }
  722. @Override
  723. public ProcMethod getProcMethod(Integer procMethodId) {
  724. return customerInfoMapper.getProcMethod(procMethodId);
  725. }
  726. @Override
  727. public Integer updateCmRelation(CmRelation cmRelation) {
  728. return customerInfoMapper.updateCmRelation(cmRelation);
  729. }
  730. @Override
  731. public CmRelation getCmRelationInfo(CmRelation cmRelation) {
  732. return customerInfoMapper.getCmRelationInfo(cmRelation);
  733. }
  734. /**
  735. * 向Efast推送订单--添加订单
  736. * @return
  737. */
  738. @Transactional
  739. public Map<String,Object> sendEfastOrder(SalesOrder salesOrder){
  740. //添加订单数据
  741. int orderNum = salesOrderMapper.addSalesOrder(salesOrder);
  742. if (orderNum <= 0) {
  743. throw new RuntimeException("系统添加订单失败");
  744. }
  745. for (SalesOrderItem item : salesOrder.getSalesOrderItemList()) {
  746. item.setItemOrderId(salesOrder.getSalesId());
  747. }
  748. //批量添加订单项数据
  749. int itemNum = salesOrderMapper.addOrderItemList(salesOrder.getSalesOrderItemList());
  750. if (itemNum <= 0) {
  751. throw new RuntimeException("系统添加订单项失败");
  752. }
  753. Map<String,Object> map = new HashMap<String,Object>();
  754. List<EfastOrder> orderList = new ArrayList<EfastOrder>();
  755. List<OrderItem> itemList = new ArrayList<OrderItem>();
  756. Integer num = 0; //产品数量
  757. Integer amout = 0; //商品总价
  758. String orderProductBarCode = ""; //产品sku
  759. String productName = ""; //产品名称
  760. for(int i=0;i<salesOrder.getSalesOrderItemList().size();i++){
  761. SalesOrderItem salesOrderItem = salesOrder.getSalesOrderItemList().get(i);
  762. OrderItem orderItem = new OrderItem();
  763. orderItem.setItemProductName(salesOrderItem.getItemProductName());
  764. orderItem.setItemProductNum(salesOrderItem.getItemNum());
  765. orderItem.setItemProductPrice(salesOrderItem.getItemProductPrice());
  766. orderItem.setItemColorBar(salesOrderItem.getItemColorBar());
  767. itemList.add(orderItem);
  768. orderProductBarCode = salesOrderItem.getItemColorBar();
  769. productName = salesOrderItem.getItemProductName();
  770. num += salesOrderItem.getItemNum();
  771. amout += salesOrderItem.getItemProductPrice();
  772. }
  773. EfastOrder efastOrder = new EfastOrder();
  774. efastOrder.setOrderAddressName(salesOrder.getSalesAddressName());//收货人姓名
  775. efastOrder.setOrderAddressTel(salesOrder.getSalesAddressTel());//收货人电话
  776. efastOrder.setOrderOpenId("1");//身份证
  777. efastOrder.setOrderRemark(salesOrder.getOrderNoteRemark()); //订单备注
  778. efastOrder.setOrderBuyerRemark(salesOrder.getSalesUserRemark()); //买家备注
  779. efastOrder.setOrderSellerRemark(salesOrder.getSalesAdminRemark()); //卖家备注
  780. String[] address = salesOrder.getSalesAddressInfo().split("-");
  781. efastOrder.setOrderProvince(address[0]);
  782. efastOrder.setOrderCity(address[1]);
  783. efastOrder.setOrderArea(address[2]);
  784. String myAddress = "";
  785. if(address.length > 4){
  786. myAddress = address[3] + address[4];
  787. }else{
  788. myAddress = address[3];
  789. }
  790. efastOrder.setOrderAddress(myAddress);
  791. efastOrder.setOrderStatus(1);
  792. efastOrder.setOrderNum(num); //产品数量
  793. efastOrder.setOrderAmount(amout); //商品总价
  794. efastOrder.setOrderPayMoney(amout); //已付款
  795. //支付方式
  796. switch (salesOrder.getSalesPayType()){
  797. case 1: //微信支付
  798. efastOrder.setOrderPayType(1);
  799. break;
  800. case 2: //现金支付
  801. efastOrder.setOrderPayType(2);
  802. break;
  803. case 3:
  804. break;
  805. case 4: //刷卡支付
  806. efastOrder.setOrderPayType(4);
  807. break;
  808. case 5: //支付宝支付
  809. efastOrder.setOrderPayType(5);
  810. break;
  811. default:
  812. efastOrder.setOrderPayType(2); //默认现金
  813. break;
  814. }
  815. efastOrder.setOrderProductBarCode(orderProductBarCode); //产品sku
  816. efastOrder.setOrderProductName(productName); //产品名称
  817. efastOrder.setOrderId(salesOrder.getSalesDealCode()); //外部交易号
  818. StoreInfo storeInfo = new StoreInfo();
  819. storeInfo = storeInfoMapper.getStoreInfoById(salesOrder.getSalesStoreId());
  820. efastOrder.setOrderStoreId(storeInfo.getStoreEfast());
  821. efastOrder.setOid(1);
  822. orderList.add(efastOrder);
  823. Integer status = 1;
  824. Map<String,Object> orderMap = new HashMap<String,Object>();
  825. try {
  826. orderMap = efastOrderService.sendOrder(orderList,itemList);
  827. } catch (Exception e) {
  828. status = 0;
  829. }
  830. List<EfastOrder> oList = (List<EfastOrder>) orderMap.get("efastOrderList");
  831. if(oList == null || oList.size() < 1){
  832. status = 0;
  833. }
  834. if(oList != null && oList.size() > 0){
  835. map.put("EfastOrderId",oList.get(0).getOrderId());
  836. SalesOrder sa = new SalesOrder();
  837. sa.setSalesId(salesOrder.getSalesId());
  838. sa.setSalesOrderId(oList.get(0).getOrderId());
  839. orderNum = salesOrderMapper.updateSalesOrder(sa);
  840. if (orderNum <= 0) {
  841. throw new RuntimeException("系统修改订单失败,订单回滚,Efast交易号:"+salesOrder.getSalesDealCode());
  842. }
  843. }else{
  844. throw new RuntimeException("添加Efast订单失败");
  845. }
  846. map.put("status",status);
  847. return map;
  848. }
  849. /**
  850. * 将原订单生成退货单
  851. * @param customerCommon
  852. * @param salesOrder
  853. * @return
  854. * @throws RuntimeException
  855. */
  856. @Transactional
  857. public void chargebackEfastOrder(CustomerCommon customerCommon, SalesOrder salesOrder,Integer status,Integer returnType){
  858. SalesOrder order = new SalesOrder();
  859. order.setSalesId(salesOrder.getSalesId());
  860. order.setSalesOrderStatus(status); //换货状态
  861. Integer flag = salesOrderMapper.updateSalesOrder(order);
  862. if(flag < 0){
  863. throw new RuntimeException("系统生成退单失败");
  864. }
  865. EfastOrder efastOrder = new EfastOrder();
  866. List<EfastOrderItem> itemList = new ArrayList<>();
  867. /*for(int i=0;i<customerCommon.getSendProdcues().size();i++){
  868. SendProdcue sendProdcue = customerCommon.getSendProdcues().get(i);
  869. EfastOrderItem efastOrderItem = new EfastOrderItem();
  870. efastOrderItem.setItemColorBar(sendProdcue.getProductColor().getColorBar());
  871. efastOrderItem.setItemNum(sendProdcue.getSendProdcueNumber());
  872. efastOrderItem.setItemDiscount(sendProdcue.getProductColor().getColorPrice());
  873. itemList.add(efastOrderItem);
  874. }*/
  875. SalesOrderItem salesOrderItem = new SalesOrderItem();
  876. salesOrderItem.setItemOrderId(salesOrder.getSalesId());
  877. List<SalesOrderItem> salesOrderItemList = salesOrderMapper.listSalesOrderItem(salesOrderItem);
  878. for(SalesOrderItem item : salesOrderItemList){
  879. EfastOrderItem efastOrderItem = new EfastOrderItem();
  880. efastOrderItem.setItemColorBar(item.getItemColorBar());
  881. efastOrderItem.setItemNum(item.getItemNum());
  882. efastOrderItem.setItemDiscount(item.getItemProductPrice());
  883. itemList.add(efastOrderItem);
  884. }
  885. efastOrder.setOrderDealCode(salesOrder.getSalesDealCode()); //交易号
  886. efastOrder.setOrderPostFirm(salesOrder.getSalesPostFirm()); //物流代码
  887. efastOrder.setOrderPostNum(salesOrder.getSalesPostNum()); //物流单号
  888. efastOrder.setOrderId(salesOrder.getSalesOrderId()); //订单编号
  889. efastOrder.setItemList(itemList);
  890. efastOrder.setReturnOrderType(returnType);//退单类型
  891. JSONObject jsonObject = new JSONObject();
  892. try{
  893. jsonObject = efastOrderService.returnOrderFormEfast(efastOrder);
  894. logger.info("------将原订单生成退货订单返回数据:" + jsonObject + "------");
  895. /*if(jsonObject != null){
  896. Object obj;
  897. obj = jsonObject.get("return_sn");
  898. if(obj != null && !"".equals(obj)){
  899. fg = true;
  900. }else{
  901. obj = jsonObject.get("msg");
  902. if("系统订单 已作废".equals(obj)){
  903. fg = true;
  904. }
  905. }
  906. }*/
  907. }catch (Exception e){
  908. logger.info("------将原订单生成退货订单报错------");
  909. }
  910. }
  911. @Override
  912. public Integer updateCustomerInfo(CustomerInfo record) {
  913. return customerInfoMapper.updateCustomerInfo(record);
  914. }
  915. @Override
  916. public PagedResult<CustomerInfo> listCustomer(int pageNO, int pageSize, CustomerInfo customerInfo, boolean isTotalNum) {
  917. PageHelper.startPage(pageNO, pageSize, isTotalNum);
  918. //查询客诉列表
  919. List<CustomerInfo> customerList = customerInfoMapper.listCustomer(customerInfo);
  920. return PageUtil.getPage(customerList);
  921. }
  922. @Override
  923. public Map<String,Object> getCustomerInfo(CustomerInfo customerInfo) {
  924. Map<String,Object> map = new HashMap<String,Object>();
  925. CustomerCommon customerCommon = new CustomerCommon();
  926. //查询客诉列表
  927. List<CustomerInfo> customerList = customerInfoMapper.listCustomer(customerInfo);
  928. if (customerList == null || customerList.size() == 0) {
  929. return null;
  930. }
  931. CustomerInfo customer = customerList.get(0);
  932. map.put("customer",customer);
  933. CmRelation cmRelation = new CmRelation();
  934. cmRelation.setCustomerId(customer.getCustomerId());
  935. cmRelation = customerInfoMapper.getCmRelationInfo(cmRelation);
  936. RelationOrder relationOrder = new RelationOrder();
  937. relationOrder.setRelationId(cmRelation.getRelationId());
  938. relationOrder.setRelationCustomerId(customer.getCustomerId());
  939. List<RelationOrder> relationOrderList = relationOrderService.getRelationOrderList(relationOrder);
  940. if(relationOrderList != null && relationOrderList.size() > 0){
  941. String[] salesIds = new String[relationOrderList.size()];
  942. for (int k=0; k<relationOrderList.size();k++){
  943. salesIds[k] = String.valueOf(relationOrderList.get(k).getSalesId());
  944. }
  945. SalesOrder so = new SalesOrder();
  946. so.setSalesIds(salesIds);
  947. List<SalesOrder> orderList = salesOrderMapper.listSalesOrder(so);
  948. if (orderList != null && orderList.size() > 0) {
  949. SalesOrder order = orderList.get(0);
  950. SalesOrderItem salesOrderItem = new SalesOrderItem();
  951. salesOrderItem.setItemOrderId(order.getSalesId());
  952. order.setSalesOrderItemList(salesOrderMapper.listSalesOrderItem(salesOrderItem));
  953. } else {
  954. map.put("orderList",null);
  955. }
  956. map.put("orderList",orderList);
  957. }
  958. //查询寄回寄出产品
  959. ClosedProdcue record = new ClosedProdcue();
  960. record.setRelationId(cmRelation.getRelationId());
  961. customerCommon.setClosedProdcues(closedProdcueMapper.listclosedProdcue(record));
  962. SendProdcue sendrecord = new SendProdcue();
  963. sendrecord.setRelationId(cmRelation.getRelationId());
  964. customerCommon.setSendProdcues(sendProdcueMapper.listSendProdcue(sendrecord));
  965. map.put("customerCommon",customerCommon);
  966. return map;
  967. }
  968. @Override
  969. public CustomerCommon selectProdcueAndFitting(CustomerCommon customerCommon, int isSolve) {
  970. if (customerCommon == null || customerCommon.getRelationId() == null) {
  971. return customerCommon;
  972. }
  973. List<SendProdcue> sendProdcues = null;
  974. List<SendFitting> sendFittings = null;
  975. List<ClosedFitting> closedfittings = null;
  976. List<ClosedProdcue> closedProdcues = null;
  977. SendProdcue sendProdcue = new SendProdcue();
  978. SendFitting sendFitting = new SendFitting();
  979. ClosedFitting fitting = new ClosedFitting();
  980. ClosedProdcue closedProdcue = new ClosedProdcue();
  981. // switch (isSolve) {
  982. // case 3://换新
  983. // sendProdcue.setRelationId(customerCommon.getRelationId());
  984. // sendProdcue.setSendProduceType(3);
  985. // //查询寄出产品集合
  986. // sendProdcues = sendProdcueMapper.listSendProdcue(sendProdcue);
  987. // sendFitting.setRelationId(customerCommon.getRelationId());
  988. // sendFitting.setSendFittingType(3);
  989. // //查询寄出配件集合
  990. // sendFittings = sendFittingMapper.listSendFitting(sendFitting);
  991. // fitting.setRelationId(customerCommon.getRelationId());
  992. // fitting.setClosedFittingType(3);
  993. // //查询寄回配件集合
  994. // closedfittings = closedFittingMapper.listClosedFitting(fitting);
  995. // closedProdcue.setRelationId(customerCommon.getRelationId());
  996. // closedProdcue.setClosedProdcueType(3);
  997. // //查询寄回产品集合
  998. // closedProdcues = closedProdcueMapper.listclosedProdcue(closedProdcue);
  999. // break;
  1000. // case 4://维修
  1001. // sendProdcue.setRelationId(customerCommon.getRelationId());
  1002. // sendProdcue.setSendProduceType(4);
  1003. // //查询寄出产品集合
  1004. // sendProdcues = sendProdcueMapper.listSendProdcue(sendProdcue);
  1005. // sendFitting.setRelationId(customerCommon.getRelationId());
  1006. // sendFitting.setSendFittingType(4);
  1007. // //查询寄出配件集合
  1008. // sendFittings = sendFittingMapper.listSendFitting(sendFitting);
  1009. // fitting.setRelationId(customerCommon.getRelationId());
  1010. // fitting.setClosedFittingType(4);
  1011. // //查询寄回配件集合
  1012. // closedfittings = closedFittingMapper.listClosedFitting(fitting);
  1013. // closedProdcue.setRelationId(customerCommon.getRelationId());
  1014. // closedProdcue.setClosedProdcueType(4);
  1015. // //查询寄回产品集合
  1016. // closedProdcues = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1017. // break;
  1018. // case 5://补发
  1019. // sendProdcue.setRelationId(customerCommon.getRelationId());
  1020. // sendProdcue.setSendProduceType(5);
  1021. // //查询寄出产品集合
  1022. // sendProdcues = sendProdcueMapper.listSendProdcue(sendProdcue);
  1023. // sendFitting.setRelationId(customerCommon.getRelationId());
  1024. // sendFitting.setSendFittingType(5);
  1025. // //查询寄出配件集合
  1026. // sendFittings = sendFittingMapper.listSendFitting(sendFitting);
  1027. // break;
  1028. // case 6://退货
  1029. // fitting.setRelationId(customerCommon.getRelationId());
  1030. // fitting.setClosedFittingType(6);
  1031. // //查询寄回配件集合
  1032. // closedfittings = closedFittingMapper.listClosedFitting(fitting);
  1033. // closedProdcue.setRelationId(customerCommon.getRelationId());
  1034. // closedProdcue.setClosedProdcueType(6);
  1035. // //查询寄回产品集合
  1036. // closedProdcues = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1037. // break;
  1038. // case 7://无理由退货
  1039. // fitting.setRelationId(customerCommon.getRelationId());
  1040. // fitting.setClosedFittingType(7);
  1041. // //查询寄回配件集合
  1042. // closedfittings = closedFittingMapper.listClosedFitting(fitting);
  1043. // closedProdcue.setRelationId(customerCommon.getRelationId());
  1044. // closedProdcue.setClosedProdcueType(7);
  1045. // //查询寄回产品集合
  1046. // closedProdcues = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1047. // break;
  1048. // }
  1049. customerCommon.setClosedFittings(closedfittings);
  1050. customerCommon.setClosedProdcues(closedProdcues);
  1051. customerCommon.setSendProdcues(sendProdcues);
  1052. customerCommon.setSendFittings(sendFittings);
  1053. return customerCommon;
  1054. }
  1055. @Override
  1056. public ProductType getcompanyAffiliation(Integer customerId) {
  1057. return customerInfoMapper.getcompanyAffiliation(customerId);
  1058. }
  1059. @Override
  1060. public BackGoods getBackGoods(BackGoods backGoods) {
  1061. //获取退货集合
  1062. // List<BackGoods> backList = backGoodsMapper.listBackGoods(backGoods);
  1063. // if (backList == null || backList.size() == 0) {
  1064. // return null;
  1065. // }
  1066. // BackGoods goods = backList.get(0);
  1067. // ClosedProdcue closedProdcue = new ClosedProdcue();
  1068. // closedProdcue.setRelationId(goods.getBackGoodsId());
  1069. // closedProdcue.setClosedProdcueType(6);
  1070. // //查询寄回产品集合
  1071. // List<ClosedProdcue> prodcueList = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1072. // ClosedFitting fitting = new ClosedFitting();
  1073. // fitting.setRelationId(goods.getBackGoodsId());
  1074. // fitting.setClosedFittingType(6);
  1075. // //查询寄回配件集合
  1076. // List<ClosedFitting> fittingList = closedFittingMapper.listClosedFitting(fitting);
  1077. // if (prodcueList != null && prodcueList.size() > 0) {
  1078. // goods.setClosedProdcues(prodcueList);
  1079. // }
  1080. // if (fittingList != null && fittingList.size() > 0) {
  1081. // goods.setClosedFittings(fittingList);
  1082. // }
  1083. // return goods;
  1084. return null;
  1085. }
  1086. @Override
  1087. public NoreasonBack getNoreasonBack(NoreasonBack noreasonBack) {
  1088. //获取无理由退货
  1089. List<NoreasonBack> backList = noreasonBackMapper.listNoreasonBack(noreasonBack);
  1090. if (backList == null || backList.size() == 0) {
  1091. return null;
  1092. }
  1093. NoreasonBack noreasonBackInfo = backList.get(0);
  1094. ClosedProdcue closedProdcue = new ClosedProdcue();
  1095. closedProdcue.setRelationId(noreasonBackInfo.getNoreasonBackId());
  1096. closedProdcue.setClosedProdcueType(7);
  1097. //查询寄回产品集合
  1098. List<ClosedProdcue> prodcueList = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1099. ClosedFitting fitting = new ClosedFitting();
  1100. fitting.setRelationId(noreasonBackInfo.getNoreasonBackId());
  1101. fitting.setClosedFittingType(7);
  1102. //查询寄回配件集合
  1103. if (prodcueList != null && prodcueList.size() > 0) {
  1104. noreasonBackInfo.setClosedProdcues(prodcueList);
  1105. }
  1106. return noreasonBackInfo;
  1107. }
  1108. @Override
  1109. public Reissue getReissue(Reissue reissue) {
  1110. //查询售后补发信息
  1111. // List<Reissue> reissueList = reissueMapper.listReissue(reissue);
  1112. // if (reissueList == null || reissueList.size() == 0) {
  1113. // return null;
  1114. // }
  1115. // Reissue reissueInfo = reissueList.get(0);
  1116. // SendProdcue sendProdcue = new SendProdcue();
  1117. // sendProdcue.setRelationId(reissueInfo.getReissueId());
  1118. // sendProdcue.setSendProduceType(5);
  1119. // //查询寄送产品集合
  1120. // List<SendProdcue> sendProdcueList = sendProdcueMapper.listSendProdcue(sendProdcue);
  1121. // SendFitting sendFitting = new SendFitting();
  1122. // sendFitting.setRelationId(reissueInfo.getReissueId());
  1123. // sendFitting.setSendFittingType(5);
  1124. // //查询寄送配件集合
  1125. // List<SendFitting> sendFittingList = sendFittingMapper.listSendFitting(sendFitting);
  1126. //
  1127. // if (sendProdcueList != null && sendProdcueList.size() > 0) {
  1128. // reissueInfo.setSendProdcues(sendProdcueList);
  1129. // }
  1130. // if (sendFittingList != null && sendFittingList.size() > 0) {
  1131. // reissueInfo.setSendFittings(sendFittingList);
  1132. // }
  1133. // return reissueInfo;
  1134. return null;
  1135. }
  1136. @Override
  1137. public Renewed getRenewedInfo(Renewed renewed) {
  1138. // renewed = renewedMapper.getRenewedInfo(renewed);
  1139. // if (renewed == null){
  1140. // return null;
  1141. // }
  1142. // ClosedProdcue closedProdcue = new ClosedProdcue();
  1143. // closedProdcue.setRelationId(renewed.getRenewedId());
  1144. // closedProdcue.setClosedProdcueType(3);
  1145. // //查询寄回产品集合
  1146. // List<ClosedProdcue> prodcueList = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1147. // ClosedFitting fitting = new ClosedFitting();
  1148. // fitting.setRelationId(renewed.getRenewedId());
  1149. // fitting.setClosedFittingType(3);
  1150. // //查询寄回配件集合
  1151. // List<ClosedFitting> fittingList = closedFittingMapper.listClosedFitting(fitting);
  1152. // SendProdcue sendProdcue = new SendProdcue();
  1153. // sendProdcue.setRelationId(renewed.getRenewedId());
  1154. // sendProdcue.setSendProduceType(3);
  1155. // //查询寄送产品集合
  1156. // List<SendProdcue> sendProdcueList = sendProdcueMapper.listSendProdcue(sendProdcue);
  1157. // SendFitting sendFitting = new SendFitting();
  1158. // sendFitting.setRelationId(renewed.getRenewedId());
  1159. // sendFitting.setSendFittingType(3);
  1160. // //查询寄送配件集合
  1161. // List<SendFitting> sendFittingList = sendFittingMapper.listSendFitting(sendFitting);
  1162. //
  1163. // if (prodcueList != null && prodcueList.size() > 0) {
  1164. // renewed.setClosedProdcues(prodcueList);
  1165. // }
  1166. // if (fittingList != null && fittingList.size() > 0) {
  1167. // renewed.setClosedFittings(fittingList);
  1168. // }
  1169. // if (sendProdcueList != null && sendProdcueList.size() > 0) {
  1170. // renewed.setSendProdcues(sendProdcueList);
  1171. // }
  1172. // if (sendFittingList != null && sendFittingList.size() > 0) {
  1173. // renewed.setSendFittings(sendFittingList);
  1174. // }
  1175. return null;
  1176. }
  1177. @Override
  1178. public Repair getRepairInfo(Repair repair) {
  1179. // repair = repairMapper.getRepairInfo(repair);
  1180. // if (repair == null) {
  1181. // return null;
  1182. // }
  1183. // ClosedProdcue closedProdcue = new ClosedProdcue();
  1184. // closedProdcue.setRelationId(repair.getRepairId());
  1185. // closedProdcue.setClosedProdcueType(4);
  1186. // //查询寄回产品集合
  1187. // List<ClosedProdcue> prodcueList = closedProdcueMapper.listclosedProdcue(closedProdcue);
  1188. // ClosedFitting fitting = new ClosedFitting();
  1189. // fitting.setRelationId(repair.getRepairId());
  1190. // fitting.setClosedFittingType(4);
  1191. // //查询寄回配件集合
  1192. // List<ClosedFitting> fittingList = closedFittingMapper.listClosedFitting(fitting);
  1193. // SendProdcue sendProdcue = new SendProdcue();
  1194. // sendProdcue.setRelationId(repair.getRepairId());
  1195. // sendProdcue.setSendProduceType(4);
  1196. // //查询寄送产品集合
  1197. // List<SendProdcue> sendProdcueList = sendProdcueMapper.listSendProdcue(sendProdcue);
  1198. // SendFitting sendFitting = new SendFitting();
  1199. // sendFitting.setRelationId(repair.getRepairId());
  1200. // sendFitting.setSendFittingType(4);
  1201. // //查询寄送配件集合
  1202. // List<SendFitting> sendFittingList = sendFittingMapper.listSendFitting(sendFitting);
  1203. //
  1204. // if (prodcueList != null && prodcueList.size() > 0) {
  1205. // repair.setClosedProdcues(prodcueList);
  1206. // }
  1207. // if (fittingList != null && fittingList.size() > 0) {
  1208. // repair.setClosedFittings(fittingList);
  1209. // }
  1210. // if (sendProdcueList != null && sendProdcueList.size() > 0) {
  1211. // repair.setSendProdcues(sendProdcueList);
  1212. // }
  1213. // if (sendFittingList != null && sendFittingList.size() > 0) {
  1214. // repair.setSendFittings(sendFittingList);
  1215. // }
  1216. // return repair;
  1217. return null;
  1218. }
  1219. }