增加删除pushOrder:订单号
This commit is contained in:
parent
87cefdd0c4
commit
945c1097aa
@ -30,6 +30,8 @@ import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
|
||||
|
||||
@RestController
|
||||
public class XhpcPileOrderController extends BaseController {
|
||||
|
||||
@ -248,6 +250,7 @@ public class XhpcPileOrderController extends BaseController {
|
||||
//费率计费模型
|
||||
List<XhpcRate> rateModelList = xhpcChargeOrderService.getRateModelId(xhpcChargeOrder.getRateModelId());
|
||||
for (XhpcRate xhpcRate:rateModelList) {
|
||||
System.out.println(">>>>>>"+xhpcRate.getRateValue());
|
||||
if("00".equals(xhpcRate.getRateValue())){
|
||||
t1powerFee = xhpcRate.getPowerFee();
|
||||
}
|
||||
@ -373,6 +376,8 @@ public class XhpcPileOrderController extends BaseController {
|
||||
map.put("userId", userId);
|
||||
JSONObject json = new JSONObject(map);
|
||||
webSocketService.getMessage(userId+"",json.toString());
|
||||
|
||||
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
return R.fail(500,"添加订单回调失败");
|
||||
|
||||
@ -26,6 +26,8 @@ import java.util.*;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
|
||||
|
||||
/**
|
||||
* @author yuyang
|
||||
* @date 2021/8/7 15:07
|
||||
@ -440,6 +442,8 @@ public class XhpcRealTimeOrderServiceImpl implements IXhpcRealTimeOrderService {
|
||||
xhpcHistoryOrderService.insert(xhpcHistoryOrder);
|
||||
|
||||
xhpcChargeOrderService.updateXhpcChargeOrder(xhpcChargeOrder);
|
||||
|
||||
redisService.deleteObject("pushOrder:"+xhpcChargeOrder.getSerialNumber());
|
||||
}
|
||||
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user