|
@@ -25,7 +25,6 @@ import com.iamberry.wechat.core.entity.order.OrderItem;
|
|
|
import com.iamberry.wechat.core.entity.order.ProbationOrder;
|
|
|
import com.iamberry.wechat.core.entity.product.ProductColor;
|
|
|
import com.iamberry.wechat.face.cart.CartService;
|
|
|
-import com.iamberry.wechat.face.giftCard.AgentMachineService;
|
|
|
import com.iamberry.wechat.face.mq.EfastOrderService;
|
|
|
import com.iamberry.wechat.face.order.AdminOrderService;
|
|
|
import com.iamberry.wechat.face.order.AdminProbationOrderService;
|
|
@@ -33,38 +32,36 @@ import com.iamberry.wechat.face.porduct.ProductColorService;
|
|
|
import com.iamberry.wechat.tools.DateTimeUtil;
|
|
|
import com.iamberry.wechat.tools.HttpClient431Util;
|
|
|
import com.iamberry.wechat.tools.NameUtils;
|
|
|
+import com.iamberry.wechat.core.entity.admin.ShopSystemRule;
|
|
|
|
|
|
@Service
|
|
|
public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
-
|
|
|
+
|
|
|
@Autowired
|
|
|
private AdminOrderService adminOrderService;
|
|
|
-
|
|
|
+
|
|
|
@Autowired
|
|
|
private AdminProbationOrderService adminProbationOrderService;
|
|
|
-
|
|
|
+
|
|
|
@Autowired
|
|
|
private RatFWLogger logger;
|
|
|
-
|
|
|
+
|
|
|
@Autowired
|
|
|
private CartService cartService;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private AgentMachineService agentMachineService;
|
|
|
-
|
|
|
+
|
|
|
@Autowired
|
|
|
private ProductColorService productColorService;
|
|
|
|
|
|
@Override
|
|
|
public boolean selectEfastSendOrderInfo(MQMessage message) {
|
|
|
// TODO Auto-generated method stub
|
|
|
-
|
|
|
+
|
|
|
// 组装数据
|
|
|
Map<String, String> requestData = new HashMap<String, String>();
|
|
|
requestData.put("app_nick", NameUtils.getConfig("app_nick"));
|
|
|
requestData.put("app_key", NameUtils.getConfig("app_key"));
|
|
|
requestData.put("app_secret", NameUtils.getConfig("app_secret"));
|
|
|
- requestData.put("timestamp",DateTimeUtil.format(new Date(),"yyyyMMddHHmmss"));
|
|
|
+ requestData.put("timestamp", DateTimeUtil.format(new Date(), "yyyyMMddHHmmss"));
|
|
|
requestData.put("app_act", message.getServiceOtherMessage());
|
|
|
requestData.put("oid", message.getServiceToMessage());
|
|
|
requestData.put("feilds", NameUtils.getConfig("order_field"));
|
|
@@ -79,7 +76,7 @@ public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
}
|
|
|
logger.info("get-订单号为:" + message.getServiceToMessage() + "的订单,百胜返回信息:" + resultJson);
|
|
|
JSONObject jsonObject = JSONObject.fromObject(resultJson);
|
|
|
-
|
|
|
+
|
|
|
// default HTTP SUCCESS
|
|
|
JSONObject respData = JSONObject.fromObject(jsonObject.get("resp_data"));
|
|
|
// 发货状态 : shipping_status
|
|
@@ -87,9 +84,9 @@ public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
if ("1".equals(shippingStatus)) {
|
|
|
// 更新数据:将订单从已支付、代发货状态修改为已发货状态
|
|
|
Order order = new Order();
|
|
|
- order.setOldStatus(2); // 已支付、待发货
|
|
|
- order.setSalesOrderid(message.getServiceToMessage()); // orderId
|
|
|
- order.setSalesStatus(5); // 已发货
|
|
|
+ order.setOldStatus(2); // 已支付、待发货
|
|
|
+ order.setSalesOrderid(message.getServiceToMessage()); // orderId
|
|
|
+ order.setSalesStatus(5); // 已发货
|
|
|
order.setSalesPostFirm(respData.getString("shipping_name"));
|
|
|
order.setSalesPostNum(respData.getString("invoice_no"));
|
|
|
adminOrderService.updateOrderDeliver(order);
|
|
@@ -103,71 +100,73 @@ public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
}
|
|
|
return false;
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
|
|
|
@Override
|
|
|
public JSONObject selectEfastSendOrderList() throws Exception {
|
|
|
// TODO Auto-generated method stub
|
|
|
java.util.Calendar rightNow = java.util.Calendar.getInstance();
|
|
|
- java.text.SimpleDateFormat sim = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
- //如果是后退几天,就写 -天数 例如:
|
|
|
- rightNow.add(java.util.Calendar.DAY_OF_MONTH, -60);
|
|
|
- //进行时间转换
|
|
|
- String date = sim.format(rightNow.getTime());
|
|
|
+ java.text.SimpleDateFormat sim = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ //如果是后退几天,就写 -天数 例如:
|
|
|
+ rightNow.add(java.util.Calendar.DAY_OF_MONTH, -60);
|
|
|
+ //进行时间转换
|
|
|
+ String date = sim.format(rightNow.getTime());
|
|
|
// 组装数据
|
|
|
- Map<String, String> requestData = new HashMap<String, String>();
|
|
|
- requestData.put("app_nick", NameUtils.getConfig("app_nick"));
|
|
|
- requestData.put("app_key", NameUtils.getConfig("app_key"));
|
|
|
- requestData.put("app_secret", NameUtils.getConfig("app_secret"));
|
|
|
- requestData.put("timestamp",DateTimeUtil.format(new Date(),"yyyyMMddHHmmss"));
|
|
|
- requestData.put("app_act", "efast.trade.list.get");
|
|
|
- requestData.put("shipping_status", "1");
|
|
|
- requestData.put("sd_id", NameUtils.getConfig("sd_id"));
|
|
|
- requestData.put("start_time", date);
|
|
|
- requestData.put("time_type", "add");
|
|
|
- requestData.put("order_status", "1");
|
|
|
- requestData.put("page_no", "1");
|
|
|
- requestData.put("page_size", "100");
|
|
|
- try {
|
|
|
- String resultJson = HttpClient431Util.doPost(requestData, NameUtils.getConfig("efast_base_url"));
|
|
|
- resultJson = StringEscapeUtils.unescapeJava(resultJson); // unicode
|
|
|
- logger.info("get-百胜订单列表,百胜返回信息:" + resultJson);
|
|
|
- JSONObject jsonObject = JSONObject.fromObject(resultJson);
|
|
|
-
|
|
|
- // default HTTP SUCCESS
|
|
|
- JSONObject respData = JSONObject.fromObject(jsonObject.get("resp_data"));
|
|
|
- // 发货状态 : shipping_status
|
|
|
- logger.error(this, "get-百胜订单列表,百胜返回信息:" + resultJson);
|
|
|
- return respData;
|
|
|
- } catch (Exception e) {
|
|
|
- // TODO Auto-generated catch block
|
|
|
- logger.error(this, "get-百胜订单列表,百胜返回信息,发生错误:" + e.getMessage());
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
+ Map<String, String> requestData = new HashMap<String, String>();
|
|
|
+ requestData.put("app_nick", NameUtils.getConfig("app_nick"));
|
|
|
+ requestData.put("app_key", NameUtils.getConfig("app_key"));
|
|
|
+ requestData.put("app_secret", NameUtils.getConfig("app_secret"));
|
|
|
+ requestData.put("timestamp", DateTimeUtil.format(new Date(), "yyyyMMddHHmmss"));
|
|
|
+ requestData.put("app_act", "efast.trade.list.get");
|
|
|
+ requestData.put("shipping_status", "1");
|
|
|
+ requestData.put("sd_id", NameUtils.getConfig("sd_id"));
|
|
|
+ requestData.put("start_time", date);
|
|
|
+ requestData.put("time_type", "add");
|
|
|
+ requestData.put("order_status", "1");
|
|
|
+ requestData.put("page_no", "1");
|
|
|
+ requestData.put("page_size", "100");
|
|
|
+ try {
|
|
|
+ String resultJson = HttpClient431Util.doPost(requestData, NameUtils.getConfig("efast_base_url"));
|
|
|
+ resultJson = StringEscapeUtils.unescapeJava(resultJson); // unicode
|
|
|
+ logger.info("get-百胜订单列表,百胜返回信息:" + resultJson);
|
|
|
+ JSONObject jsonObject = JSONObject.fromObject(resultJson);
|
|
|
|
|
|
+ // default HTTP SUCCESS
|
|
|
+ JSONObject respData = JSONObject.fromObject(jsonObject.get("resp_data"));
|
|
|
+ // 发货状态 : shipping_status
|
|
|
+ logger.error(this, "get-百胜订单列表,百胜返回信息:" + resultJson);
|
|
|
+ return respData;
|
|
|
+ } catch (Exception e) {
|
|
|
+ // TODO Auto-generated catch block
|
|
|
+ logger.error(this, "get-百胜订单列表,百胜返回信息,发生错误:" + e.getMessage());
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
|
|
|
@Override
|
|
|
public boolean addOrderInfoToEfast(MQMessage message) throws Exception {
|
|
|
-
|
|
|
+
|
|
|
// orderInfo
|
|
|
Order order = adminOrderService.getShopOrderByOrderId(message.getServiceToMessage());
|
|
|
if (order == null || order.getSalesOrderid() == null) {
|
|
|
return false;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
List<OrderItem> items = adminOrderService.getShopOrderItemByOrderId(order.getSalesOrderid());
|
|
|
-
|
|
|
+
|
|
|
+ //获取当前水机产品类型
|
|
|
+ ShopSystemRule rule = adminOrderService.getReluByRid(237);
|
|
|
+
|
|
|
// request url
|
|
|
String url = NameUtils.getConfig("efast_base_url");
|
|
|
-
|
|
|
+
|
|
|
// set Requeset Data
|
|
|
Map<String, String> requestData = new HashMap<String, String>();
|
|
|
-
|
|
|
+ Map<String, String> otherData = new HashMap<String, String>();
|
|
|
+
|
|
|
int money = order.getSalesYetAmount();
|
|
|
-
|
|
|
+
|
|
|
double couponMoney = 0;
|
|
|
double avgPercentage = 0.0; //均摊比例
|
|
|
//将优惠券抵消金额加入实付金额中
|
|
@@ -178,16 +177,16 @@ public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
CouponType couponType = cartService.getCouponReduceByItemId(couponItem);
|
|
|
if (null != couponType) {
|
|
|
switch (couponType.getCouponType()) {
|
|
|
- case 1:
|
|
|
- couponMoney = couponType.getCouponReduce();
|
|
|
- break;
|
|
|
- case 2:
|
|
|
- couponMoney = order.getSalesAmount() * couponType.getCouponReduce()/100;
|
|
|
- break;
|
|
|
+ case 1:
|
|
|
+ couponMoney = couponType.getCouponReduce();
|
|
|
+ break;
|
|
|
+ case 2:
|
|
|
+ couponMoney = order.getSalesAmount() * couponType.getCouponReduce() / 100;
|
|
|
+ break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
//只计算用户用微信支付的金额,不包含余额支付
|
|
|
if (order.getBalancePayAmount() != null && !"".equals(order.getBalancePayAmount().toString())) {
|
|
|
money = money - order.getBalancePayAmount().intValue();
|
|
@@ -200,35 +199,41 @@ public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
avgMoney += item.getItemNum().intValue() * item.getItemProductDiscount();
|
|
|
}
|
|
|
//计算均摊比例
|
|
|
- avgPercentage = 1 - couponMoney/avgMoney;
|
|
|
+ avgPercentage = 1 - couponMoney / avgMoney;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 系统级参数
|
|
|
*/
|
|
|
requestData.put("app_nick", NameUtils.getConfig("app_nick"));
|
|
|
requestData.put("app_key", NameUtils.getConfig("app_key"));
|
|
|
requestData.put("app_secret", NameUtils.getConfig("app_secret"));
|
|
|
- requestData.put("timestamp",DateTimeUtil.format(new Date(),"yyyyMMddHHmmss"));
|
|
|
+ requestData.put("timestamp", DateTimeUtil.format(new Date(), "yyyyMMddHHmmss"));
|
|
|
requestData.put("app_act", message.getServiceOtherMessage()); // "efast.trade.new.add"
|
|
|
-
|
|
|
+
|
|
|
+ otherData.put("app_nick", NameUtils.getConfig("app_nick"));
|
|
|
+ otherData.put("app_key", NameUtils.getConfig("app_key"));
|
|
|
+ otherData.put("app_secret", NameUtils.getConfig("app_secret"));
|
|
|
+ otherData.put("timestamp", DateTimeUtil.format(new Date(), "yyyyMMddHHmmss"));
|
|
|
+ otherData.put("app_act", message.getServiceOtherMessage()); // "efast.trade.new.add"
|
|
|
+
|
|
|
/**
|
|
|
* 订单基本信息
|
|
|
*/
|
|
|
- String [] addressDesc = order.getSalesAddressInfo().split("-");
|
|
|
-
|
|
|
+ String[] addressDesc = order.getSalesAddressInfo().split("-");
|
|
|
+
|
|
|
//判断收货地址从而选择仓库
|
|
|
String sd_id = NameUtils.getConfig("sd_id");
|
|
|
-
|
|
|
+
|
|
|
String address = addressDesc[3];
|
|
|
- if (addressDesc[3]!=null) {
|
|
|
- Pattern p = Pattern.compile("\\s*|\t|\r|\n");
|
|
|
- Matcher m = p.matcher(addressDesc[3]);
|
|
|
- if (m.find()) {
|
|
|
- address = m.replaceAll("");
|
|
|
+ if (addressDesc[3] != null) {
|
|
|
+ Pattern p = Pattern.compile("\\s*|\t|\r|\n");
|
|
|
+ Matcher m = p.matcher(addressDesc[3]);
|
|
|
+ if (m.find()) {
|
|
|
+ address = m.replaceAll("");
|
|
|
}
|
|
|
- }
|
|
|
-
|
|
|
+ }
|
|
|
+
|
|
|
String provinceName = addressDesc[0];
|
|
|
if (addressDesc[0].indexOf("北京") != -1) {
|
|
|
provinceName = "北京";
|
|
@@ -240,78 +245,149 @@ public class EfastOrderServiceImpl implements EfastOrderService {
|
|
|
provinceName = "重庆";
|
|
|
}
|
|
|
Map<String, Object> orderData = new HashMap<String, Object>();
|
|
|
- orderData.put("add_time", DateTimeUtil.format(order.getSalesCreateDate())); // 时间
|
|
|
- orderData.put("address", address); // 收货地址
|
|
|
- orderData.put("city_name", addressDesc[1]); // 城市
|
|
|
- orderData.put("consignee", order.getSalesAddressName()); // 收货人
|
|
|
- orderData.put("district_name", addressDesc[2]); // 区域
|
|
|
- orderData.put("email", ""); // email
|
|
|
- orderData.put("goods_amount", (order.getSalesAmount()/100.0)); // 商品总价
|
|
|
- orderData.put("goods_count", items.size()); // 产品数量
|
|
|
- orderData.put("mobile", order.getSalesAddressTel()); // 手机号码
|
|
|
- orderData.put("money_paid", (money/100.0)); // 已付款
|
|
|
- orderData.put("oid", order.getSalesOrderid()); // 订单号
|
|
|
- orderData.put("order_amount", (money/100.0)); // 应付款,应付款金额要与已付款金额相同
|
|
|
-
|
|
|
-
|
|
|
+ Map<String, Object> filterData = new HashMap<String, Object>();
|
|
|
+ orderData.put("add_time", DateTimeUtil.format(order.getSalesCreateDate())); // 时间
|
|
|
+ orderData.put("address", address); // 收货地址
|
|
|
+ orderData.put("city_name", addressDesc[1]); // 城市
|
|
|
+ orderData.put("consignee", order.getSalesAddressName()); // 收货人
|
|
|
+ orderData.put("district_name", addressDesc[2]); // 区域
|
|
|
+ orderData.put("email", ""); // email
|
|
|
+ orderData.put("goods_amount", (order.getSalesAmount() / 100.0)); // 商品总价
|
|
|
+ //orderData.put("goods_count", items.size()); // 产品数量
|
|
|
+ orderData.put("mobile", order.getSalesAddressTel()); // 手机号码
|
|
|
+ orderData.put("money_paid", (money / 100.0)); // 已付款
|
|
|
+ orderData.put("oid", order.getSalesOrderid()); // 订单号
|
|
|
+ orderData.put("order_amount", (money / 100.0)); // 应付款,应付款金额要与已付款金额相同
|
|
|
+
|
|
|
+ orderData.put("pay_name", "weixinpay"); // 支付方式
|
|
|
+ orderData.put("pay_time", DateTimeUtil.format(order.getSalesTransactionDate()));// 支付时间
|
|
|
+ orderData.put("postscript", order.getSalesUserRemark()); // 买家留言
|
|
|
+ orderData.put("province_name", provinceName); // 省份
|
|
|
+ orderData.put("sd_id", sd_id); // 对应 efast 店铺 id
|
|
|
+ orderData.put("shipping_fee", 0); // 快递费
|
|
|
+ orderData.put("shipping_name", "yto"); // 快递公司代码
|
|
|
+ orderData.put("tel", ""); // 我司电话
|
|
|
+ orderData.put("to_buyer", ""); // 商家备注
|
|
|
+ orderData.put("total_amount", (order.getSalesAmount() / 100.0)); // 订单总额
|
|
|
+ orderData.put("user_name", order.getSalesOpenid()); // 买家账户 百胜根据user_name来判断是否有重复,传openId是为了防止重复
|
|
|
+ orderData.put("zipcode", order.getSalesAddressPostnum()); // 邮编
|
|
|
+
|
|
|
+ filterData.putAll(orderData);
|
|
|
+
|
|
|
/**
|
|
|
* 产品信息
|
|
|
*/
|
|
|
+ String[] productType = null;
|
|
|
+ if (rule != null && rule.getRuleDesc() != null) {
|
|
|
+ String type = rule.getRuleDesc().split(":")[1];
|
|
|
+ productType = type.split(",");
|
|
|
+ }
|
|
|
List<Map<String, Object>> maps = new ArrayList<Map<String, Object>>();
|
|
|
+ List<Map<String, Object>> filterMap = new ArrayList<Map<String, Object>>();
|
|
|
+ boolean mapFlag = false; //标识是否推送百胜
|
|
|
+ boolean filterFlag = false; //标识是否推送百胜
|
|
|
+ int filterMoney = 0; //除水机外的金额
|
|
|
+ int orderItem = 0;
|
|
|
+ int filterItem = 0;
|
|
|
for (OrderItem item : items) {
|
|
|
Map<String, Object> orders1 = new HashMap<String, Object>();
|
|
|
- orders1.put("goods_name", item.getItemProductName()); // 产品名称
|
|
|
- orders1.put("goods_number", item.getItemNum()); // 产品数量
|
|
|
- orders1.put("goods_price", (item.getItemProductPrice()/100.0)); // 产品原价
|
|
|
- orders1.put("outer_sku", item.getProduectRemark()); // 产品SKU
|
|
|
- orders1.put("payment_ft", (item.getItemProductDiscount()/100.0*avgPercentage*item.getItemNum())); // 产品分摊价
|
|
|
- maps.add(orders1);
|
|
|
+ orders1.put("goods_name", item.getItemProductName()); // 产品名称
|
|
|
+ orders1.put("goods_number", item.getItemNum()); // 产品数量
|
|
|
+ orders1.put("goods_price", (item.getItemProductPrice() / 100.0)); // 产品原价
|
|
|
+ orders1.put("outer_sku", item.getProduectRemark()); // 产品SKU
|
|
|
+ orders1.put("payment_ft", (item.getItemProductDiscount() / 100.0 * avgPercentage * item.getItemNum())); // 产品分摊价
|
|
|
+ if (productType != null) {
|
|
|
+ boolean productFlag = false; //用来判断当前产品是否为水机
|
|
|
+ for (int i = 0; i < productType.length; i++) {
|
|
|
+ if (item.getItemProductType() == Integer.parseInt(productType[i])) {
|
|
|
+ mapFlag = true;
|
|
|
+ productFlag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (productFlag) {
|
|
|
+ maps.add(orders1);
|
|
|
+ orderItem++;
|
|
|
+ } else {
|
|
|
+ filterFlag = true;
|
|
|
+ filterMap.add(orders1);
|
|
|
+ filterItem++;
|
|
|
+ filterMoney += item.getItemProductDiscount() / 100 * item.getItemNum();
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ maps.add(orders1);
|
|
|
+ mapFlag = true;
|
|
|
+ }
|
|
|
}
|
|
|
-
|
|
|
- orderData.put("orders", maps); // 订单产品
|
|
|
- orderData.put("pay_name", "weixinpay"); // 支付方式
|
|
|
- orderData.put("pay_time", DateTimeUtil.format(order.getSalesTransactionDate()));// 支付时间
|
|
|
- orderData.put("postscript", order.getSalesUserRemark()); // 买家留言
|
|
|
- orderData.put("province_name", provinceName); // 省份
|
|
|
- orderData.put("sd_id", sd_id); // 对应 efast 店铺 id
|
|
|
- orderData.put("shipping_fee", 0); // 快递费
|
|
|
- orderData.put("shipping_name", "yto"); // 快递公司代码
|
|
|
- orderData.put("tel", ""); // 我司电话
|
|
|
- orderData.put("to_buyer", ""); // 商家备注
|
|
|
- orderData.put("total_amount", (order.getSalesAmount()/100.0)); // 订单总额
|
|
|
- orderData.put("user_name", order.getSalesOpenid()); // 买家账户 百胜根据user_name来判断是否有重复,传openId是为了防止重复
|
|
|
- orderData.put("zipcode", order.getSalesAddressPostnum()); // 邮编
|
|
|
-
|
|
|
-
|
|
|
+ orderData.put("goods_count", orderItem);
|
|
|
+ orderData.put("orders", maps); // 订单产品
|
|
|
+
|
|
|
+
|
|
|
com.fasterxml.jackson.databind.ObjectMapper mapper = new ObjectMapper();
|
|
|
- String orderDataStr = null;;
|
|
|
+ String orderDataStr = null;
|
|
|
+ String filterDataStr = null;
|
|
|
try {
|
|
|
- orderDataStr = mapper.writeValueAsString(orderData);
|
|
|
+ if (mapFlag) {
|
|
|
+ orderDataStr = mapper.writeValueAsString(orderData);
|
|
|
+ }
|
|
|
+ if (filterFlag) {
|
|
|
+ filterData.put("oid", "ZP" + order.getSalesOrderid());
|
|
|
+ filterData.put("user_name", "ZP" + order.getSalesOpenid());
|
|
|
+ filterData.put("goods_amount", filterMoney);
|
|
|
+ filterData.put("money_paid", filterMoney);
|
|
|
+ filterData.put("order_amount", filterMoney);
|
|
|
+ filterData.put("total_amount", filterMoney);
|
|
|
+ filterData.put("goods_count", filterItem);
|
|
|
+ filterData.put("orders", filterMap); //非水机等订单产品
|
|
|
+ filterDataStr = mapper.writeValueAsString(filterData);
|
|
|
+ }
|
|
|
} catch (JsonProcessingException e2) {
|
|
|
e2.printStackTrace();
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
requestData.put("info", orderDataStr);
|
|
|
-
|
|
|
+ otherData.put("info", filterDataStr);
|
|
|
+
|
|
|
try {
|
|
|
- String result = HttpClient431Util.doGet(requestData, url);
|
|
|
- result = StringEscapeUtils.unescapeJava(result); // unicode 编码
|
|
|
- logger.info("add-推送订单号为:" + order.getSalesOrderid() + "的订单,百胜返回信息:" + result);
|
|
|
- // parse JSON String to Object
|
|
|
- JSONObject jsonObject = JSONObject.fromObject(result);
|
|
|
- JSONObject respData = JSONObject.fromObject(jsonObject.get("resp_data"));
|
|
|
- String oderSn = respData.getString("oder_sn");
|
|
|
- if (oderSn != null) {
|
|
|
- String msg = respData.getString("msg");
|
|
|
- if ("success".equals(msg)) {
|
|
|
- return true;
|
|
|
+ if (mapFlag) {
|
|
|
+ String result = HttpClient431Util.doGet(requestData, url);
|
|
|
+ result = StringEscapeUtils.unescapeJava(result); // unicode 编码
|
|
|
+ logger.info("add-推送订单号为:" + order.getSalesOrderid() + "的订单,百胜返回信息:" + result);
|
|
|
+ // parse JSON String to Object
|
|
|
+ JSONObject jsonObject = JSONObject.fromObject(result);
|
|
|
+ JSONObject respData = JSONObject.fromObject(jsonObject.get("resp_data"));
|
|
|
+ String oderSn = respData.getString("oder_sn");
|
|
|
+ if (oderSn != null) {
|
|
|
+ String msg = respData.getString("msg");
|
|
|
+ if ("success".equals(msg)) {
|
|
|
+ //return true;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ logger.error(this, "add-推送订单号为:" + order.getSalesOrderid() + "的订单,百胜返回信息:" + result);
|
|
|
+ //throw new Exception(respData.getString("msg"));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (filterFlag) {
|
|
|
+ String result = HttpClient431Util.doGet(otherData, url);
|
|
|
+ result = StringEscapeUtils.unescapeJava(result); // unicode 编码
|
|
|
+ logger.info("add-推送订单号为:" + order.getSalesOrderid() + "的订单,百胜返回信息:" + result);
|
|
|
+ // parse JSON String to Object
|
|
|
+ JSONObject jsonObject = JSONObject.fromObject(result);
|
|
|
+ JSONObject respData = JSONObject.fromObject(jsonObject.get("resp_data"));
|
|
|
+ String oderSn = respData.getString("oder_sn");
|
|
|
+ if (oderSn != null) {
|
|
|
+ String msg = respData.getString("msg");
|
|
|
+ if ("success".equals(msg)) {
|
|
|
+ //return true;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ logger.error(this, "add-推送订单号为:" + order.getSalesOrderid() + "的订单,百胜返回信息:" + result);
|
|
|
+ //throw new Exception(respData.getString("msg"));
|
|
|
}
|
|
|
}
|
|
|
- logger.error(this, "add-推送订单号为:" + order.getSalesOrderid() + "的订单,百胜返回信息:" + result);
|
|
|
- throw new Exception(respData.getString("msg"));
|
|
|
} catch (Exception e) {
|
|
|
throw e;
|
|
|
}
|
|
|
+ return true;
|
|
|
}
|
|
|
|
|
|
|