|  |  |  | 
|---|
|  |  |  | package com.matrix.system.hive.action; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import cn.hutool.core.collection.CollUtil; | 
|---|
|  |  |  | import com.matrix.component.rabbitmq.RabiitMqTemplate; | 
|---|
|  |  |  | import com.matrix.core.constance.MatrixConstance; | 
|---|
|  |  |  | import com.matrix.core.exception.GlobleException; | 
|---|
|  |  |  | 
|---|
|  |  |  | import com.matrix.system.common.bean.SysUsers; | 
|---|
|  |  |  | import com.matrix.system.common.tools.ResponseHeadUtil; | 
|---|
|  |  |  | import com.matrix.system.constance.Dictionary; | 
|---|
|  |  |  | import com.matrix.system.constance.SystemConstance; | 
|---|
|  |  |  | import com.matrix.system.hive.bean.*; | 
|---|
|  |  |  | import com.matrix.system.hive.dao.*; | 
|---|
|  |  |  | import com.matrix.system.hive.plugin.util.CollectionUtils; | 
|---|
|  |  |  | import com.matrix.system.hive.pojo.ShoppingCarItem; | 
|---|
|  |  |  | import com.matrix.system.hive.pojo.ShoppingCarItemsVo; | 
|---|
|  |  |  | import com.matrix.system.hive.service.*; | 
|---|
|  |  |  | import com.matrix.system.shopXcx.mqTask.MQTaskRouting; | 
|---|
|  |  |  | import com.matrix.system.wechart.templateMsg.UniformMsgParam; | 
|---|
|  |  |  | 
|---|
|  |  |  | RabiitMqTemplate rabiitMqTemplate; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SysProjUseDao sysProjUseDao; | 
|---|
|  |  |  | private SysProjServicesDao sysProjServicesDao; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private SysProjServicesService projServicesService; | 
|---|
|  |  |  | @Value("${evn}") | 
|---|
|  |  |  | private String evn; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | total = total.add(new BigDecimal(item.getPrice() * item.getCount())); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | SysOrder sysOrderResult = new SysOrder(); | 
|---|
|  |  |  | sysOrderResult.setZkTotal(zkTotal.doubleValue()); | 
|---|
|  |  |  | sysOrderResult.setZkTotal(zkTotal.setScale(2,BigDecimal.ROUND_DOWN).doubleValue()); | 
|---|
|  |  |  | sysOrderResult.setTotal(total.doubleValue()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return AjaxResult.buildSuccessInstance(Arrays.asList(sysOrderResult)); | 
|---|
|  |  |  | 
|---|
|  |  |  | return AjaxResult.buildSuccessInstance(Arrays.asList(sysOrder), "订单保存成功"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 新建订单 | 
|---|
|  |  |  | * | 
|---|
|  |  |  | * @author jiangyouyao | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @RequestMapping(value = "/addOrder") | 
|---|
|  |  |  | public @ResponseBody | 
|---|
|  |  |  | AjaxResult addOrder(ShoppingCarItemsVo car) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<ShoppingCarItem> sessionCarItems = (List<ShoppingCarItem>) WebUtil.getSession().getAttribute( | 
|---|
|  |  |  | SystemConstance.SHOPPING_CAR); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<ShoppingCarItem> carItems = new ArrayList<>(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 设置购车中的具体类型信息,过滤没有被选中的商品 | 
|---|
|  |  |  | for (ShoppingCarItem carItem : car.getCarItems()) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (ShoppingCarItem sessionCar : sessionCarItems) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (carItem.getId().equals(sessionCar.getId())) { | 
|---|
|  |  |  | //已最后提交的数量为准 | 
|---|
|  |  |  | sessionCar.setCount(carItem.getCount()); | 
|---|
|  |  |  | carItems.add(sessionCar); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //设置过滤后的购物车条目 | 
|---|
|  |  |  | car.setCarItems(carItems); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | SysVipInfo info = (SysVipInfo) WebUtil.getSession().getAttribute(SystemConstance.CURRENT_CUSTOMER); | 
|---|
|  |  |  | car.setVipId(info.getId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 添加新订单 | 
|---|
|  |  |  | int i = orderService.createOrder(WebUtil.getSession(), car); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (i > 0) { | 
|---|
|  |  |  | WebUtil.getSession().removeAttribute(SystemConstance.SHOPPING_CAR); | 
|---|
|  |  |  | return new AjaxResult(AjaxResult.STATUS_SUCCESS, "下单成功"); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | return new AjaxResult(AjaxResult.STATUS_FAIL, "下单添加失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(orderVo.getId()!=null){ | 
|---|
|  |  |  | WebUtil.getRequest().setAttribute("orderParam", orderVo.getId()); | 
|---|
|  |  |  | WebUtil.getRequest().setAttribute("orderId", orderVo.getId()); | 
|---|
|  |  |  | }else if(StringUtils.isNotBlank(orderVo.getOrderNo())){ | 
|---|
|  |  |  | WebUtil.getRequest().setAttribute("orderParam", orderVo.getOrderNo()); | 
|---|
|  |  |  | WebUtil.getRequest().setAttribute("orderNo", orderVo.getOrderNo()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return "admin/hive/beautySalon/orderXq-form"; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | return new AjaxResult(AjaxResult.STATUS_FAIL, "订单不存在!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //        SysProjServices sysProjServices = new SysProjServices(); | 
|---|
|  |  |  | //        projServicesService.findByModel() | 
|---|
|  |  |  | List<SysOrderItem> items = orderItemDao.selectByOrderId(id); | 
|---|
|  |  |  | for (SysOrderItem item : items) { | 
|---|
|  |  |  | List<SysProjServices> sysProjServices = sysProjServicesDao.selectProjServicesByOrderItemId(item.getId()); | 
|---|
|  |  |  | if (CollUtil.isNotEmpty(sysProjServices)) { | 
|---|
|  |  |  | return new AjaxResult(AjaxResult.STATUS_FAIL, "订单存在进行中的服务单无法取消/删除"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | orderService.cancelOrder(id); | 
|---|
|  |  |  | //        if (del > 0) { | 
|---|
|  |  |  | //            orderService.removeById(id); | 
|---|