|
|
@@ -46,6 +46,12 @@ public class SckwBusSumConsumer {
|
|
|
@Autowired
|
|
|
private MongoTemplate mongoTemplate;
|
|
|
|
|
|
+ private String TRADE_ORDER = "tradeOrder";
|
|
|
+
|
|
|
+ private String LOGISTICS_ORDER = "logisticsOrder";
|
|
|
+
|
|
|
+ private String WAYBILL_ORDER = "waybillOrder";
|
|
|
+
|
|
|
/**
|
|
|
* @desc 消息订阅
|
|
|
* @author zk
|
|
|
@@ -77,7 +83,7 @@ public class SckwBusSumConsumer {
|
|
|
|
|
|
/**业务存储**/
|
|
|
/**贸易订单**/
|
|
|
- if (busSum.getBusSumType().equals("tradeOrder")) {
|
|
|
+ if (busSum.getBusSumType().equals(TRADE_ORDER)) {
|
|
|
SckwTradeOrder order = JSONObject.parseObject(JSON.toJSONString(busSum.getObject()), SckwTradeOrder.class);
|
|
|
order.set_id(order.getTOrderId());
|
|
|
if (busSum.getMethod() == 1) {
|
|
|
@@ -100,7 +106,7 @@ public class SckwBusSumConsumer {
|
|
|
}
|
|
|
|
|
|
/**物流订单**/
|
|
|
- if (busSum.getBusSumType().equals("logisticsOrder")) {
|
|
|
+ if (busSum.getBusSumType().equals(LOGISTICS_ORDER)) {
|
|
|
SckwLogisticsOrder order = JSONObject.parseObject(JSON.toJSONString(busSum.getObject()), SckwLogisticsOrder.class);
|
|
|
if (busSum.getMethod() == 1) {
|
|
|
/**新增**/
|
|
|
@@ -117,7 +123,7 @@ public class SckwBusSumConsumer {
|
|
|
}
|
|
|
|
|
|
/**车辆运单**/
|
|
|
- if (busSum.getBusSumType().equals("waybillOrder")) {
|
|
|
+ if (busSum.getBusSumType().equals(WAYBILL_ORDER)) {
|
|
|
SckwWaybillOrder order = JSONObject.parseObject(JSON.toJSONString(busSum.getObject()), SckwWaybillOrder.class);
|
|
|
if (busSum.getMethod() == 1) {
|
|
|
/**新增**/
|