parent
d1526b291b
commit
aca391e3a8
@ -0,0 +1,53 @@ |
||||
package com.bweb.config.msg; |
||||
|
||||
import com.hai.msg.entity.MsgTopic; |
||||
import com.hai.service.HighMerchantStoreAccountService; |
||||
import com.hai.service.HighOrderService; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.data.redis.core.RedisTemplate; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import javax.annotation.PostConstruct; |
||||
import javax.annotation.Resource; |
||||
|
||||
@Component |
||||
public class MerStoreAccountChgHandler { |
||||
|
||||
private static Logger logger = LoggerFactory.getLogger(MerStoreAccountChgHandler.class); |
||||
|
||||
@Autowired |
||||
private RedisTemplate<String, Object> redisTemplate; |
||||
|
||||
@Resource |
||||
private HighMerchantStoreAccountService merchantStoreAccountService; |
||||
|
||||
@Resource |
||||
private HighOrderService orderService; |
||||
|
||||
@PostConstruct |
||||
public void init() { |
||||
new Thread(() -> { |
||||
{ |
||||
//消息处理
|
||||
while (true){ |
||||
try { |
||||
//构建的队列为左进右出
|
||||
Object o = redisTemplate.opsForList().rightPop(MsgTopic.MerStoreAccount.getName()); |
||||
if (o != null) { |
||||
//处理消息
|
||||
logger.info("消息通道："+o); |
||||
|
||||
|
||||
} else { |
||||
Thread.sleep(1000); |
||||
} |
||||
}catch (Exception e){ |
||||
logger.error("监听订单状态变更错误",e); |
||||
} |
||||
} |
||||
} |
||||
}).start(); |
||||
} |
||||
} |
||||
@ -0,0 +1,156 @@ |
||||
package com.hai.model; |
||||
|
||||
import java.math.BigDecimal; |
||||
import java.util.Date; |
||||
|
||||
/** |
||||
* 加油站订单 |
||||
* @author hurui |
||||
*/ |
||||
public class GasOrderModel { |
||||
|
||||
private String orderNo; |
||||
private String gasOrderNo; |
||||
private Integer payType; |
||||
private BigDecimal totalPrice; |
||||
private BigDecimal deductionPrice; |
||||
private BigDecimal payRealPrice; |
||||
private Integer status; |
||||
private String gasName; |
||||
private String gasAddress; |
||||
private String gasOilNo; |
||||
private String gasGunNo; |
||||
private String gasOilLiters; |
||||
private String gasPriceGun; |
||||
private Date createTime; |
||||
private Date payTime; |
||||
private Date refundTime; |
||||
|
||||
public String getOrderNo() { |
||||
return orderNo; |
||||
} |
||||
|
||||
public void setOrderNo(String orderNo) { |
||||
this.orderNo = orderNo; |
||||
} |
||||
|
||||
public String getGasOrderNo() { |
||||
return gasOrderNo; |
||||
} |
||||
|
||||
public void setGasOrderNo(String gasOrderNo) { |
||||
this.gasOrderNo = gasOrderNo; |
||||
} |
||||
|
||||
public Integer getPayType() { |
||||
return payType; |
||||
} |
||||
|
||||
public void setPayType(Integer payType) { |
||||
this.payType = payType; |
||||
} |
||||
|
||||
public BigDecimal getTotalPrice() { |
||||
return totalPrice; |
||||
} |
||||
|
||||
public void setTotalPrice(BigDecimal totalPrice) { |
||||
this.totalPrice = totalPrice; |
||||
} |
||||
|
||||
public BigDecimal getDeductionPrice() { |
||||
return deductionPrice; |
||||
} |
||||
|
||||
public void setDeductionPrice(BigDecimal deductionPrice) { |
||||
this.deductionPrice = deductionPrice; |
||||
} |
||||
|
||||
public BigDecimal getPayRealPrice() { |
||||
return payRealPrice; |
||||
} |
||||
|
||||
public void setPayRealPrice(BigDecimal payRealPrice) { |
||||
this.payRealPrice = payRealPrice; |
||||
} |
||||
|
||||
public Integer getStatus() { |
||||
return status; |
||||
} |
||||
|
||||
public void setStatus(Integer status) { |
||||
this.status = status; |
||||
} |
||||
|
||||
public String getGasName() { |
||||
return gasName; |
||||
} |
||||
|
||||
public void setGasName(String gasName) { |
||||
this.gasName = gasName; |
||||
} |
||||
|
||||
public String getGasAddress() { |
||||
return gasAddress; |
||||
} |
||||
|
||||
public void setGasAddress(String gasAddress) { |
||||
this.gasAddress = gasAddress; |
||||
} |
||||
|
||||
public String getGasOilNo() { |
||||
return gasOilNo; |
||||
} |
||||
|
||||
public void setGasOilNo(String gasOilNo) { |
||||
this.gasOilNo = gasOilNo; |
||||
} |
||||
|
||||
public String getGasGunNo() { |
||||
return gasGunNo; |
||||
} |
||||
|
||||
public void setGasGunNo(String gasGunNo) { |
||||
this.gasGunNo = gasGunNo; |
||||
} |
||||
|
||||
public String getGasOilLiters() { |
||||
return gasOilLiters; |
||||
} |
||||
|
||||
public void setGasOilLiters(String gasOilLiters) { |
||||
this.gasOilLiters = gasOilLiters; |
||||
} |
||||
|
||||
public String getGasPriceGun() { |
||||
return gasPriceGun; |
||||
} |
||||
|
||||
public void setGasPriceGun(String gasPriceGun) { |
||||
this.gasPriceGun = gasPriceGun; |
||||
} |
||||
|
||||
public Date getCreateTime() { |
||||
return createTime; |
||||
} |
||||
|
||||
public void setCreateTime(Date createTime) { |
||||
this.createTime = createTime; |
||||
} |
||||
|
||||
public Date getPayTime() { |
||||
return payTime; |
||||
} |
||||
|
||||
public void setPayTime(Date payTime) { |
||||
this.payTime = payTime; |
||||
} |
||||
|
||||
public Date getRefundTime() { |
||||
return refundTime; |
||||
} |
||||
|
||||
public void setRefundTime(Date refundTime) { |
||||
this.refundTime = refundTime; |
||||
} |
||||
} |
||||
@ -0,0 +1,17 @@ |
||||
package com.hai.msg.entity; |
||||
|
||||
public enum MsgTopic { |
||||
|
||||
// 门店账户业务员
|
||||
MerStoreAccount("mer-store-account"); |
||||
|
||||
private String name; |
||||
|
||||
MsgTopic(String name){ |
||||
this.name = name; |
||||
} |
||||
|
||||
public String getName(){ |
||||
return name; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue