diff --git a/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcTimingChargingModelMapper.xml b/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcTimingChargingModelMapper.xml index aeb4fbf8..7e235dd5 100644 --- a/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcTimingChargingModelMapper.xml +++ b/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcTimingChargingModelMapper.xml @@ -110,7 +110,7 @@ and tcm.tenant_id =#{tenantId} - order by tcm.status desc, tcm.create_time desc + order by tcm.status asc, tcm.create_time desc diff --git a/xhpc-modules/xhpc-invoice/src/main/java/com/xhpc/invoice/api/XhpcInvoiceApiController.java b/xhpc-modules/xhpc-invoice/src/main/java/com/xhpc/invoice/api/XhpcInvoiceApiController.java index ce7d452e..01555a4e 100644 --- a/xhpc-modules/xhpc-invoice/src/main/java/com/xhpc/invoice/api/XhpcInvoiceApiController.java +++ b/xhpc-modules/xhpc-invoice/src/main/java/com/xhpc/invoice/api/XhpcInvoiceApiController.java @@ -4,9 +4,13 @@ import com.xhpc.common.core.web.controller.BaseController; import com.xhpc.common.core.web.domain.AjaxResult; import com.xhpc.common.log.annotation.Log; import com.xhpc.common.log.enums.BusinessType; +import com.xhpc.common.redis.service.RedisService; +import com.xhpc.common.security.service.TokenService; import com.xhpc.common.util.DateUtil; +import com.xhpc.common.util.UserTypeUtil; import com.xhpc.invoice.domain.*; import com.xhpc.invoice.service.XhpcInvoiceService; +import com.xhpc.system.api.model.LoginUser; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @@ -24,6 +28,10 @@ public class XhpcInvoiceApiController extends BaseController { @Resource XhpcInvoiceService xhpcInvoiceService; + @Resource + TokenService tokenService; + @Resource + RedisService redisService; /** * 查询用户显示小红点,即查询用户有几个未读的已开发票 @@ -35,7 +43,23 @@ public class XhpcInvoiceApiController extends BaseController { @GetMapping("/user/no-read") public AjaxResult findNotReadCount(@RequestParam Long creatorId, @RequestParam Integer creatorType) { + LoginUser loginUser = tokenService.getLoginUser(); + Long userid = loginUser.getUserid(); + String tenantId = loginUser.getTenantId(); + Integer userType = loginUser.getUserType(); + String globalInvoice="global:invoice:"+ tenantId +":"; + String invoice =""; + if(UserTypeUtil.USER_TYPE.equals(userType)){ + invoice =globalInvoice + UserTypeUtil.USER + userid; + }else if(UserTypeUtil.INTERNET_TYPE.equals(userType)){ + invoice =globalInvoice + UserTypeUtil.INTERNET + userid; + }else if(UserTypeUtil.COMMUNIT_TYPE.equals(userType)){ + invoice =globalInvoice + UserTypeUtil.COMMUNIT + userid; + }else{ + invoice =globalInvoice + UserTypeUtil.CUSTOMERS + userid; + } Long notRead = xhpcInvoiceService.findNotReadCount(creatorId, creatorType); + redisService.setCacheObject(invoice,notRead); return AjaxResult.success(notRead); } diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java index be45eb08..8feb8300 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java @@ -516,26 +516,34 @@ public class XhpcPileOrderController extends BaseController { @Transactional @PostMapping("/chargeOrder/abnormalOrder") public R abnormalOrder(@RequestParam(value = "orderNo") String orderNo) { - //获取实时订单 XhpcChargeOrder xhpcChargeOrder = xhpcChargeOrderService.getSerialNumberMessage(orderNo); if(xhpcChargeOrder==null|| xhpcChargeOrder.getUserId()==null){ logger.info("订单异常回调接口--无效订单号>>>>>orderNo:" + orderNo); return R.fail(500,"无效订单号"); } + if(xhpcChargeOrder.getStatus()==1 || xhpcChargeOrder.getStatus()==3){ + logger.info("订单异常回调接口--已结算订单>>>>>orderNo:" + orderNo); + return R.ok(); + } Integer source = xhpcChargeOrder.getSource(); String tenantId = xhpcChargeOrder.getTenantId(); - if(!UserTypeUtil.INTERNET_TYPE.equals(source)){ - R user = userTypeService.getUser(null, xhpcChargeOrder.getUserId(), source, null, tenantId); - if(user !=null && user.getData() !=null){ - Map userMessage = (Map)user.getData(); - if (userMessage != null && userMessage.get("balance") != null) { - xhpcHistoryOrderService.addXhpcChargeOrder(userMessage,orderNo,1); - } - } - }else{ - xhpcHistoryOrderService.addXhpcChargeOrder(null,orderNo,1); - } +// if(!UserTypeUtil.INTERNET_TYPE.equals(source)){ +// R user = userTypeService.getUser(null, xhpcChargeOrder.getUserId(), source, null, tenantId); +// if(user !=null && user.getData() !=null){ +// Map userMessage = (Map)user.getData(); +// if (userMessage != null && userMessage.get("balance") != null) { +// xhpcHistoryOrderService.addXhpcChargeOrder(userMessage,orderNo,1); +// } +// } +// }else{ +// xhpcHistoryOrderService.addXhpcChargeOrder(null,orderNo,1); +// } + Date date = new Date(); + xhpcChargeOrder.setStatus(2); + xhpcChargeOrder.setEndTime(date); + xhpcChargeOrderService.updateXhpcChargeOrder(xhpcChargeOrder); + Long userId = xhpcChargeOrder.getUserId(); Map map = new HashMap<>(); map.put("code", 500); diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/controller/XhpcRealTimeOrderController.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/controller/XhpcRealTimeOrderController.java index a3fe89db..fef95ca0 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/controller/XhpcRealTimeOrderController.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/controller/XhpcRealTimeOrderController.java @@ -58,9 +58,9 @@ public class XhpcRealTimeOrderController extends BaseController { * 实时/异常订单详情(PC) */ @GetMapping("/getMessage") - public AjaxResult getMessage(@RequestParam Long realTimeOrderId) + public AjaxResult getMessage(@RequestParam Long realTimeOrderId,@RequestParam Long chargeOrderId) { - return AjaxResult.success(xhpcRealTimeOrderService.getMessage(realTimeOrderId)); + return AjaxResult.success(xhpcRealTimeOrderService.getMessage(realTimeOrderId,chargeOrderId)); } @@ -92,8 +92,8 @@ public class XhpcRealTimeOrderController extends BaseController { *异常订单审核详情 */ @GetMapping("/getExamineMessage") - public AjaxResult getExamineMessage(@RequestParam Long realTimeOrderId){ - return xhpcRealTimeOrderService.getExamineMessage(realTimeOrderId); + public AjaxResult getExamineMessage(@RequestParam Long realTimeOrderId,@RequestParam Long chargeOrderId){ + return xhpcRealTimeOrderService.getExamineMessage(realTimeOrderId,chargeOrderId); } /** diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcRealTimeOrderMapper.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcRealTimeOrderMapper.java index 4904b8df..af188f31 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcRealTimeOrderMapper.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/mapper/XhpcRealTimeOrderMapper.java @@ -69,6 +69,13 @@ public interface XhpcRealTimeOrderMapper { */ Map getMessage(@Param("realTimeOrderId")Long realTimeOrderId); + /** + * 异常订单详情接口(PC端) + * @param chargeOrderId + * @return + */ + Map getMessageChargeOrderId(@Param("chargeOrderId")Long chargeOrderId); + /** * 实时订单详情数据列表(PC) diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/IXhpcRealTimeOrderService.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/IXhpcRealTimeOrderService.java index 5849f419..109cad6b 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/IXhpcRealTimeOrderService.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/IXhpcRealTimeOrderService.java @@ -38,7 +38,7 @@ public interface IXhpcRealTimeOrderService { * @param realTimeOrderId * @return */ - Map getMessage(Long realTimeOrderId); + Map getMessage(Long realTimeOrderId,Long chargeOrderId); /** * 实时订单详情数据列表(PC) @@ -93,7 +93,7 @@ public interface IXhpcRealTimeOrderService { * @param realTimeOrderId * @return */ - AjaxResult getExamineMessage(Long realTimeOrderId); + AjaxResult getExamineMessage(Long realTimeOrderId,Long chargeOrderId); /** * 审核 diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcHistoryOrderServiceImpl.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcHistoryOrderServiceImpl.java index a7892964..a397ab62 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcHistoryOrderServiceImpl.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcHistoryOrderServiceImpl.java @@ -446,7 +446,6 @@ public class XhpcHistoryOrderServiceImpl extends BaseService implements IXhpcHis xhpcChargeOrder.setAmountCharged(new BigDecimal(cacheRealtimeData.getAmountCharged()).divide(decimal, 2, BigDecimal.ROUND_HALF_UP)); xhpcChargeOrder.setChargingTimeNumber(Long.valueOf(cacheRealtimeData.getChargingTime())); - if (checking) { BigDecimal money = xhpcChargeOrder.getAmountCharged(); //结算 diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java index acb5ebe2..98aa5697 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java @@ -119,7 +119,10 @@ public class XhpcRealTimeOrderServiceImpl extends BaseService implements IXhpcRe } @Override - public Map getMessage(Long realTimeOrderId) { + public Map getMessage(Long realTimeOrderId,Long chargeOrderId) { + if(realTimeOrderId ==null){ + return xhpcRealTimeOrderMapper.getMessageChargeOrderId(chargeOrderId); + } return xhpcRealTimeOrderMapper.getMessage(realTimeOrderId); } @@ -159,7 +162,16 @@ public class XhpcRealTimeOrderServiceImpl extends BaseService implements IXhpcRe @Transactional @Override - public AjaxResult getExamineMessage(Long realTimeOrderId) { + public AjaxResult getExamineMessage(Long realTimeOrderId,Long chargeOrderId) { + + if(realTimeOrderId==null){ + Map message = xhpcRealTimeOrderMapper.getMessageChargeOrderId(chargeOrderId); + message.put("powerPriceTotal",0); + message.put("servicePriceTotal",0); + return AjaxResult.success(message); + } + + //基本信息 Map message = xhpcRealTimeOrderMapper.getMessage(realTimeOrderId); try{ diff --git a/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcRealTimeOrderMapper.xml b/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcRealTimeOrderMapper.xml index 5a030d5f..01b15652 100644 --- a/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcRealTimeOrderMapper.xml +++ b/xhpc-modules/xhpc-order/src/main/resources/mapper/XhpcRealTimeOrderMapper.xml @@ -535,7 +535,47 @@ left join xhpc_charging_pile as cp on cp.charging_pile_id = ter.charging_pile_id where ro.real_time_order_id=#{realTimeOrderId} - + + + + + +