同步过程测试完成，异步过程未测试

wuxw7

2018-05-24 ac70082e183ae551ccdcda57304c7a669e28d5ee

 UserService/src/main/java/com/java110/user/rest/UserServiceRest.java

@@ -18,7 +18,7 @@
 * 用户服务提供类
 * Created by wuxw on 2017/4/5.
 */
@RestController
//@RestController
public class UserServiceRest extends BaseController implements IUserService {

    @Autowired
@@ -55,12 +55,62 @@

    /**
     * 根据购物车信息查询
     *
     * 这里返回data信息
     * @param busiOrder
     * @return
     */
    @Override
    public String queryUserInfoByOlId(String busiOrder) {
        return null;
    @RequestMapping("/userService/queryCustInfoByOlId")
    public String queryCustInfoByOlId(@RequestParam("busiOrder") String busiOrder) {


        LoggerEngine.debug("queryUserInfo入参：" + busiOrder);


        String resultUserInfo = null;

        try {
             this.simpleValidateJSON(busiOrder);
            resultUserInfo = iUserServiceSMO.queryCustInfoByOlId(busiOrder);

        } catch (Exception e) {
            LoggerEngine.error("服务处理出现异常：", e);
            resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"服务处理出现异常"+e,null);
        } finally {
            LoggerEngine.debug("用户服务操作客户出参：" + resultUserInfo);
            return resultUserInfo;
        }
    }

    /**
     * 根据购物车信息查询 需要作废的发起的报文
     *
     * 这里返回data信息
     * @param busiOrder
     * @return
     */
    @Override
    @RequestMapping("/userService/queryNeedDeleteCustInfoByOlId")
    public String queryNeedDeleteCustInfoByOlId(@RequestParam("busiOrder")  String busiOrder) {


        LoggerEngine.debug("queryUserInfo入参：" + busiOrder);


        String resultUserInfo = null;

        try {
            this.simpleValidateJSON(busiOrder);
            resultUserInfo = iUserServiceSMO.queryNeedDeleteCustInfoByOlId(busiOrder);

        } catch (Exception e) {
            LoggerEngine.error("服务处理出现异常：", e);
            resultUserInfo = ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_ERROR,"服务处理出现异常"+e,null);
        } finally {
            LoggerEngine.debug("用户服务操作客户出参：" + resultUserInfo);
            return resultUserInfo;
        }
    }


@@ -86,10 +136,8 @@
            reqUserJSON = this.simpleValidateJSON(data);
            //1.0规则校验，报文是否合法


            //2.0 受理客户信息
            resultUserInfo = iUserServiceSMO.soUserService(reqUserJSON);


        } catch (Exception e) {
            LoggerEngine.error("服务处理出现异常：", e);
@@ -99,6 +147,7 @@
            return resultUserInfo;
        }
    }


    /**
     * 这个接口专门用于订单服务受理用，入参为 JSONObject
@@ -296,7 +345,7 @@
        try{
            reqParam = this.simpleValidateJSON(data);

            Assert.isNull(reqParam,"data","传入报文错误，没有包含data节点"+reqParam);
            Assert.isNotNull(reqParam,"data","传入报文错误，没有包含data节点"+reqParam);

            resultUserInfo = iUserServiceSMO.soDeleteCustInfo(reqParam.getJSONArray("data"));