package com.java110.order.rest;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.common.log.LoggerEngine;
|
import com.java110.common.util.ProtocolUtil;
|
import com.java110.core.base.controller.BaseController;
|
import com.java110.entity.order.OrderList;
|
import com.java110.order.smo.IOrderServiceSMO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.util.Assert;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
/**
|
* 订单服务 提供类
|
*
|
* 主要提供订单相关服务
|
* Created by wuxw on 2017/4/11.
|
*/
|
@RestController
|
public class OrderServiceRest extends BaseController {
|
|
|
@Autowired
|
IOrderServiceSMO iOrderServiceSMO;
|
|
|
/**
|
* 查询订单信息
|
* 接口协议：
|
* 请求报文
|
* {'olId':'71234567','extSystemId':'','custId':'','channelId':''}
|
*
|
* 可以根据 购物车ID 或者 外部系统ID 或者 custId 或者 channelId
|
*
|
* 返回报文:
|
* {
|
"RESULT_CODE": "0000",
|
"RESULT_MSG": "成功",
|
"RESULT_INFO": {
|
"orderLists": [
|
{
|
"channelId": "700212896",
|
"remarks": "",
|
"olId": "123456",
|
"custId": "701008023904",
|
"statusCd": "S",
|
"reqTime": "20170411163709",
|
"extSystemId": "310013698777",
|
"olTypeCd": "15",
|
"orderListAttrs": [
|
{
|
"olId": "123456",
|
"attrCd": "712345",
|
"value": "XXX",
|
"name": "系统来源"
|
}
|
],
|
"busiOrders": [
|
{
|
"boId": "123456",
|
"olId": "123456",
|
"actionTypeCd": "C1",
|
"status_cd": "0",
|
"create_dt": "2017-04-16 22:58:03",
|
"start_dt": "2017-04-16 22:58:03",
|
"end_dt": "2017-04-16 22:58:03",
|
"remark": "",
|
"busiOrders": [
|
{
|
"boId": "123456",
|
"attrCd": "712345",
|
"value": "XXX",
|
"name": "系统来源"
|
}
|
]
|
}
|
]
|
}
|
]
|
}
|
}
|
*
|
* @param orderInfo
|
* @return
|
*/
|
@RequestMapping("/orderService/queryOrder")
|
public String queryOrder(@RequestParam("orderInfo") String orderInfo) {
|
|
LoggerEngine.debug("soOrderService入参：" + orderInfo);
|
String resultUserInfo = null;
|
|
JSONObject reqOrderJSON = null;
|
|
try{
|
|
reqOrderJSON = this.simpleValidateJSON(orderInfo);
|
|
//校验 购物车ID 或者 外部系统ID 或者 custId 或者 channelId 中的一个是
|
Assert.notNull(reqOrderJSON);
|
|
if(!reqOrderJSON.containsKey("olId") && !reqOrderJSON.containsKey("extSystemId")
|
&& !reqOrderJSON.containsKey("custId") && !reqOrderJSON.containsKey("channelId")){
|
throw new IllegalArgumentException("此接口只支持用olId，extSystemId，custId，channelId 来查询订单，当前请求报文为："+orderInfo);
|
}
|
//转化为 对象
|
OrderList orderListTmp = JSONObject.toJavaObject(reqOrderJSON, OrderList.class);
|
|
resultUserInfo = iOrderServiceSMO.queryOrderInfo(orderListTmp);
|
|
}catch (Exception e){
|
LoggerEngine.error("查询失败，orderInfo = "+orderInfo,e);
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"查询失败，orderInfo = "+orderInfo+"失败原因："+e,null);
|
}finally {
|
return resultUserInfo;
|
}
|
}
|
|
/**
|
* 订单统一处理接口
|
*
|
* orderListInfo 中字段 asyn 如果为 A 表示 异步处理订单，其他表同步处理订单
|
* 接口协议
|
* {
|
"orderList": {
|
"orderListAttrs": [
|
{
|
"attrCd": "40010026",
|
"name": "购物车流水号",
|
"value": "31201704110009114961"
|
}
|
],"busiOrder": [
|
{
|
|
"data": {
|
"boCust": [
|
{
|
"custId": "-1",
|
"name": "S",
|
"email": "-52",
|
"cellphone": "17797173942",
|
"realName": "wuxw",
|
"sex": "1",
|
"password": "123456",
|
"lanId": "863010",
|
"custAdress": "青海省西宁市城中区格兰小镇",
|
"custType": "1",
|
"openId": "",
|
"state": "ADD"
|
},
|
{
|
"custId": "123",
|
"name": "S",
|
"email": "-52",
|
"cellphone": "17797173942",
|
"realName": "wuxw",
|
"sex": "1",
|
"password": "123456",
|
"lanId": "863010",
|
"custAdress": "青海省西宁市城中区格兰小镇",
|
"custType": "1",
|
"openId": "",
|
"state": "DEL"
|
}
|
],
|
"boCustAttr": [
|
{
|
"custId": "123",
|
"prodId": "-1",
|
"attrCd": "123344",
|
"value": "1",
|
"state": "ADD"
|
},
|
{
|
"custId": "123",
|
"prodId": "-1",
|
"attrCd": "123345",
|
"value": "1",
|
"state": "DEL"
|
}
|
]
|
},
|
"busiObj": {
|
"name": "新建客户",
|
"actionTypeCd": "C1",
|
"actionClassCd": "1",
|
"status_cd": "S",
|
"start_dt": "2017-04-11",
|
"end_dt": "2017-04-12",
|
"remark": ""
|
},
|
"busiOrderAttrs": [
|
{
|
"attrCd": "40010026",
|
"name": "购物车流水号",
|
"value": "31201704110009114961"
|
}
|
]
|
}
|
|
],
|
"orderListInfo": {
|
"transactionId": "1000000200201704113137002690",
|
"channelId": "700212896",
|
"remarks": "",
|
"olId": "-1",
|
"custId": "701008023904",
|
"statusCd": "S",
|
"reqTime": "20170411163709",
|
"extSystemId": "310013698777",
|
"olTypeCd": "15",
|
"asyn":"A"
|
}
|
}
|
}
|
* @param orderInfo
|
* @return
|
*/
|
@RequestMapping("/orderService/soOrderService")
|
public String soOrderService(@RequestParam("orderInfo") String orderInfo){
|
|
LoggerEngine.debug("soOrderService入参：" + orderInfo);
|
String resultUserInfo = null;
|
|
JSONObject reqOrderJSON = null;
|
|
try{
|
|
reqOrderJSON = this.simpleValidateJSON(orderInfo);
|
|
if(reqOrderJSON == null || !reqOrderJSON.containsKey("orderList")){
|
throw new IllegalArgumentException("请求参数为空 reqOrderJSON ："+reqOrderJSON);
|
}
|
|
resultUserInfo = iOrderServiceSMO.orderDispatch(reqOrderJSON.getJSONObject("orderList"));
|
|
}catch (Exception e){
|
LoggerEngine.error("订单受理出现异常：", e);
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"订单受理出现异常，"+e,null);
|
}finally {
|
return resultUserInfo;
|
}
|
|
|
}
|
|
/**
|
* 作废订单时，order_list busi_order 和bo_开头数据不影响，只是作废实例数据，如作废客户信息，只作废 cust 和cust_attr 表中的数据
|
* 作废订单依然会创建order_list 和busi_order 数据
|
* 作废指定动作的信息
|
* 请求协议：
|
* {
|
* "orderList":{
|
* "transactionId": "1000000200201704113137002690",
|
"channelId": "700212896",
|
"remarks": "",
|
"custId": "701008023904",
|
"statusCd": "S",
|
"reqTime": "20170411163709",
|
"extSystemId": "310013698777",
|
"olTypeCd": "15",
|
* "oldOlId":"123456789",
|
* "asyn":"S"
|
* },
|
* "busiOrder":[{
|
* "actionTypeCd":"ALL"
|
* }]
|
* }
|
*
|
* 说明
|
* oldOlId 购物车ID，对应表order_list
|
* asyn 处理方式，S 同步 A 异步
|
*
|
* 注意这里busiOrder 的{} 只能有一个，有多个，只能会处理第一个
|
*
|
* actionTypeCd All标识 作废所有订单订单 C2 作废客户信息，。。。
|
*
|
* transactionId 交易流水
|
*
|
* channelId 渠道ID，对应channel表，可以自定义一个
|
*
|
* remarks 备注，不能超过200个，如果超过200个会截取200个字
|
*
|
* custId 操作者ID，可能客户本身，很有很可能商家，或管理员
|
*
|
* statusCd S表示这个购物车有效，
|
*
|
* reqTime 请求时间
|
*
|
* extSystemId 外部系统关联ID
|
*
|
* olTypeCd 购物车类型，如 微信创建的购物车 1 APP创建的2 PC网站创建 3
|
*
|
* asyn 处理方式，S 同步 A 异步
|
*
|
* 作废指定订单项的信息
|
* 请求协议：
|
* {
|
* "orderList":{
|
* "transactionId": "1000000200201704113137002690",
|
"channelId": "700212896",
|
"remarks": "",
|
"custId": "701008023904",
|
"statusCd": "S",
|
"reqTime": "20170411163709",
|
"extSystemId": "310013698777",
|
"olTypeCd": "15",
|
"asyn":"A"
|
* },
|
* "busiOrder":[{
|
* "oldBoId":"123456789"
|
* },
|
* {
|
* "oldBoId":"123456799"
|
* }]
|
* }
|
* oldBoId 为作废单个 要作废的订单项 对应busi_order 的 boId
|
*
|
* transactionId 交易流水
|
*
|
* channelId 渠道ID，对应channel表，可以自定义一个
|
*
|
* remarks 备注，不能超过200个，如果超过200个会截取200个字
|
*
|
* custId 操作者ID，可能客户本身，很有很可能商家，或管理员
|
*
|
* statusCd S表示这个购物车有效，
|
*
|
* reqTime 请求时间
|
*
|
* extSystemId 外部系统关联ID
|
*
|
* olTypeCd 购物车类型，如 微信创建的购物车 1 APP创建的2 PC网站创建 3
|
*
|
* asyn 处理方式，S 同步 A 异步
|
*
|
*
|
* 统一返回协议：
|
* {
|
"RESULT_CODE": "0000",
|
"RESULT_MSG": "成功",
|
"RESULT_INFO": {"oldOrder":"1234567","oldBoId":"7000123,718881991"}
|
}
|
* RESULT_CODE 0000 成功，1999 失败， 失败原因为 RESULT_MSG
|
*
|
* RESULT_INFO 成功时返回作废 的购物车 olId 和 boId
|
* @param orderInfo
|
* @return
|
*/
|
@RequestMapping("/orderService/deleteOrderInfo")
|
public String deleteOrderInfo(@RequestParam("orderInfo") String orderInfo){
|
|
LoggerEngine.debug("deleteOrderInfo入参：" + orderInfo);
|
String resultUserInfo = null;
|
|
JSONObject reqOrderJSON = null;
|
|
try{
|
|
reqOrderJSON = this.simpleValidateJSON(orderInfo);
|
|
if(reqOrderJSON == null || !reqOrderJSON.containsKey("orderList")){
|
throw new IllegalArgumentException("请求参数为空 reqOrderJSON ："+reqOrderJSON);
|
}
|
|
// 删除订单对应实例数据
|
resultUserInfo = iOrderServiceSMO.deleteOrder(reqOrderJSON.getJSONObject("orderList"));
|
|
}catch (Exception e){
|
LoggerEngine.error("订单受理出现异常：", e);
|
resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"订单受理出现异常，"+e,null);
|
}finally {
|
return resultUserInfo;
|
}
|
|
}
|
|
|
public IOrderServiceSMO getiOrderServiceSMO() {
|
return iOrderServiceSMO;
|
}
|
|
public void setiOrderServiceSMO(IOrderServiceSMO iOrderServiceSMO) {
|
this.iOrderServiceSMO = iOrderServiceSMO;
|
}
|
}
|
