macservice/src/main/java/com/minpay/shouhuo/deliveryaction/DeliveryAction.java

package com.minpay.shouhuo.deliveryaction;

import com.min.base64.Base64;
import com.min.des.DesUtils;
import com.min.util.OffSetUtil;
import com.minpay.common.bean.DrawDto;
import com.minpay.common.bean.User;
import com.minpay.common.exception.BusinessCodeException;
import com.minpay.common.format.IFormatService;
import com.minpay.common.service.IPropertiesService;
import com.minpay.common.service.IPublicService;
import com.minpay.common.util.CommonUtil;
import com.minpay.common.util.DateUtil;
import com.minpay.common.util.HttpPostUtil;
import com.minpay.db.table.mapper.VmDeliveryInfMapper;
import com.minpay.db.table.mapper.VmOrderDetailsMapper;
import com.minpay.db.table.mapper.VmOrderInfMapper;
import com.minpay.db.table.mapper.VmProEquRelMapper;
import com.minpay.db.table.model.*;
import com.minpay.db.table.own.mapper.DeliveryMapper;
import com.startup.minpay.frame.business.IMINAction;
import com.startup.minpay.frame.business.res.MINActionResult;
import com.startup.minpay.frame.constant.IMINBusinessConstant;
import com.startup.minpay.frame.data.format.MINCopyFormat;
import com.startup.minpay.frame.exception.MINBusinessException;
import com.startup.minpay.frame.jdbc.MINRowBounds;
import com.startup.minpay.frame.service.base.IMINDataBaseService;
import com.startup.minpay.frame.service.base.Service;
import com.startup.minpay.frame.session.MINSession;
import com.startup.minpay.frame.target.MINAction;
import com.startup.minpay.frame.target.MINComponent;
import com.startup.minpay.frame.target.MINParam;
import com.startup.minpay.util.Log;
import net.sf.json.JSONObject;

import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 售货机提货相关接口
 * @author Zhumq
 *
 */
@MINComponent
public class DeliveryAction implements IMINAction{
	
	/**查询提货信息*/
	public static final String QUERY_DELIVERY_INFO = "queryDeliveryInfo";
	
	/**修改提货信息*/
	public static final String MODIFY_DELIVERY_INFO = "modifyDeliveryInfo";
	
	/**提货接口*/
	public static final String MAKE_DELIVERY_FOR_MACHINE = "makeDeliveryForMachine";
	
	
	/**提货回调*/
	public static final String BACK_DELIVERY_FOR_MACHINE = "backDeliveryForMachine";
	
	
	/**
	 * 查询提货信息
	 * @param equNo		售货机编号
	 * @param dates		创建时间
	 * @param userNo	商户编号
	 * @param status	提货状态
	 * @param orderNo	订单编号
	 * @param personNo	会员编号
	 * @param page
	 * @param limit
	 * @param session
	 * @return
	 * @throws MINBusinessException
	 */
	@MINAction(value = QUERY_DELIVERY_INFO)
	public MINActionResult queryDeliveryInfo(
			@MINParam(key = "equNo")String equNo,
			@MINParam(key = "dates")String dates,
			@MINParam(key = "userNo")String userNo,
			@MINParam(key = "status")String status,
			@MINParam(key = "orderNo")String orderNo,
			@MINParam(key = "personNo")String personNo,
			@MINParam(key = "page",defaultValue = "1")int page,
			@MINParam(key = "limit",defaultValue = "10")int limit,
			MINSession session) throws MINBusinessException{
		MINActionResult res = new MINActionResult();
		if(CommonUtil.isEmpty(equNo)){
			throw new BusinessCodeException("JINM1101");//售货机异常,请联系工作人员
		}
		//解密售货机编号
		String equNoNew = OffSetUtil.deScanCode(equNo);
		//获取操作员信息
		User user = session.getUser();
		//创建分页对象
		MINRowBounds row = new MINRowBounds(page, limit);
		//初始化查询条件
		Map<String,String> map = new HashMap<String,String>();
		map.put("orderNo", orderNo);//订单编号
		map.put("status", status);//提货状态
		map.put("userNo", userNo);//商户编号
		map.put("equNo", equNoNew);//售货机编号
		if(CommonUtil.isEmpty(personNo)){
			personNo = user.getId();
		}
		map.put("personNo", personNo);//会员编号
		map.put("dates", dates);//创建时间
		//传入渠道验证
		map.put("channel", user.getChannel());
		List<Map<String,String>> list = Service.lookup(IMINDataBaseService.class)
												.getMybatisMapper(DeliveryMapper.class)
												.queryDeliveryInfo(map,row);
		//格式花时间和状态
		list = Service.lookup(IFormatService.class).formatDateTime(list, "createTime");
		list = new MINCopyFormat("{status:'statusDesc',proType:'proTypeDesc'}").format(list);
		list = Service.lookup(IFormatService.class).formatEnum(list,"{statusDesc:'VM_DELIVERY_STATUS',proTypeDesc:'PRO_TYPE'}");
		//传递返回值
		res.set(IMINBusinessConstant.F_PAGING_LAY, list);
		res.set(IMINBusinessConstant.F_PAGING_COUNT, row.getMaxRows());
		return res;
	}

	
	/**
	 * 提货接口
	 * @param orderNo    	订单编号
	 * @param deliveryNo	提货单编号
	 * @param session
	 * @return
	 * @throws Exception 
	 */
	@MINAction(value = MAKE_DELIVERY_FOR_MACHINE)
	public MINActionResult makeDeliveryForMachine(
			@MINParam ( key = "orderNo")String orderNo,
			@MINParam ( key = "deliveryNo")String deliveryNo,
			MINSession session) throws Exception{
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		//获取售货机推送地址
		String url = Service.lookup(IPropertiesService.class)
				.getSystemProperties().get(user.getChannel() + "_GET_MACHINE_ADDRESS").getKey();
		String retUrl = Service.lookup(IPropertiesService.class)
				.getSystemProperties().get(user.getChannel() + "_RETURN_MACHINE_ADDRESS").getKey();
		//组装推送接口
		String sendUrl = url.concat("/VendingMachineAction/pushGoods").concat("?MINView=JSON");
		String returnUrl = retUrl.concat("/DeliveryAction/backDeliveryForMachine");
		
		//组装传送参数
		//初始化查询条件
		Map<String,String> map = new HashMap<String,String>();
		map.put("deliveryNo", deliveryNo);//提货编号
		map.put("orderNo", orderNo);//订单编号
		//传入渠道验证
		map.put("channel", user.getChannel());
		List<Map<String,String>> list = Service.lookup(IMINDataBaseService.class)
												.getMybatisMapper(DeliveryMapper.class)
												.queryDeliverys(map);
		if(CommonUtil.isEmpty(deliveryNo)){
		
			VmOrderInf orderInf = Service.lookup(IMINDataBaseService.class)
											.getMybatisMapper(VmOrderInfMapper.class)
											.selectByPrimaryKey(orderNo);
			//如果直接购买选择存入卡包则不进行推货
			if(orderInf.getProState().equals("01")){
				return res;
			}
		}
//		//未创建提货信息的执行新增
//		if(list == null || list.size() == 0){
//			MINActionResult result = createDeliveryInfoTwo(orderNo);
//			deliveryNo = result.get("dlId");
//			map.put("deliveryNo", deliveryNo);//提货编号
//			list = Service.lookup(IMINDataBaseService.class)
//							.getMybatisMapper(DeliveryMapper.class)
//							.queryDeliverys(map);
//		}
		
		if(list == null || list.size() == 0){
			throw new MINBusinessException("没有提货信息!");
		}
		
		if(CommonUtil.isEmpty(deliveryNo)){
			deliveryNo = list.get(0).get("deliveryNo");
		}
		
		VmDeliveryInf deliveryInf = Service.lookup(IMINDataBaseService.class)
											.getMybatisMapper(VmDeliveryInfMapper.class)
											.selectByPrimaryKey(deliveryNo);
		if(deliveryInf == null){
			throw new MINBusinessException("没有提货信息!");
		}
		
		if(deliveryInf.getProNums().equals(deliveryInf.getDeliveryNums())){
			throw new MINBusinessException("提货已完成!");
		}
		
		if(!deliveryInf.getStatus().equals("0") 
				&& !deliveryInf.getStatus().equals("1")){
			throw new MINBusinessException("提货处理中，请稍后!");
		}
		
		VmDeliveryInf  delInf = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(VmDeliveryInfMapper.class).selectByPrimaryKey(deliveryNo);

		//改变提货状态为5处理中....
		delInf.setStatus("5");
		//处理提货状态
		Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(VmDeliveryInfMapper.class)
				.updateByPrimaryKeySelective(delInf);
		Map<String,String> mapNew = new HashMap<String,String>();
		mapNew.put("imeiAddr", list.get(0).get("equIMEI"));
		mapNew.put("cargoNo", list.get(0).get("cargoWay"));
		mapNew.put("deliveryNo", deliveryNo);
		mapNew.put("channel", user.getChannel());
		mapNew.put("returnUrl", returnUrl);
		mapNew.put("orderNo", orderNo);
		mapNew.put("MINView", "JSON");
		JSONObject jsonOb = JSONObject.fromObject(mapNew);
		String str = jsonOb.toString();
		Log.info("通知售货机推货：".concat(str));
		String passwardKey = Service.lookup(IPropertiesService.class)
				.getSystemProperties().get(user.getChannel() +"_TO_MACHINE_PASSWORD_KEY").getKey();
		//数据加密
		String	desDe = Base64.encode(DesUtils.getInstance().encrypt(Base64.encode(str).getBytes(),passwardKey.getBytes(),null));

//		new Thread() {
//            public void run() {
//            	HttpPostUtil.sendPostFormachine(sendUrl, desDe);
//            }
//        }.start();

//		//获取转义后响应信息
//		JSONObject detail = JSONObject.fromObject(results);
//		String code = String.valueOf(detail.get("code"));
//
//		if(!"0".equals(code)){
//			Log.info("售货机退货失败：".concat(code));
//			//改变提货状态为3卡货(提货失败)....
//			delInf.setStatus("3");
//			//处理提货状态
//			Service.lookup(IMINDataBaseService.class)
//					.getMybatisMapper(VmDeliveryInfMapper.class)
//					.updateByPrimaryKeySelective(delInf);
//			throw new BusinessCodeException("JINM0011");//操作失败!
//		}
//
//		//获取处理状态
//		String state = String.valueOf(detail.get("returnData"));
//		JSONObject stateNew = JSONObject.fromObject(state);
//		if(stateNew != null
//				&& !"200".equals(String.valueOf(stateNew.get("code")))){
//			Log.info("售货机退货卡货：".concat(CommonUtil.objToString(stateNew.get("msg"))));
//			//改变提货状态为3卡货....
//			delInf.setStatus("3");
//			//处理提货状态
//			Service.lookup(IMINDataBaseService.class)
//					.getMybatisMapper(VmDeliveryInfMapper.class)
//					.updateByPrimaryKeySelective(delInf);
//			String msg = String.valueOf(stateNew.get("msg"));
//			throw new MINBusinessException(msg);//操作失败!
//		}

		String results = HttpPostUtil.sendPostFormachine(sendUrl, desDe);
		//		//获取转义后响应信息
		JSONObject detail = JSONObject.fromObject(results);
		String code = String.valueOf(detail.get("code"));

		if(!"0".equals(code)){
			Log.info("售货机退货失败：".concat(code));
			//改变提货状态为3卡货(提货失败)....
			delInf.setStatus("3");
			//处理提货状态
			Service.lookup(IMINDataBaseService.class)
					.getMybatisMapper(VmDeliveryInfMapper.class)
					.updateByPrimaryKeySelective(delInf);
			throw new BusinessCodeException("JINM0011");//操作失败!
		}

		//获取处理状态
		String state = String.valueOf(detail.get("returnData"));
		JSONObject stateNew = JSONObject.fromObject(state);
		if(stateNew != null
				&& !"200".equals(String.valueOf(stateNew.get("code")))){
			Log.info("售货机退货卡货：".concat(CommonUtil.objToString(stateNew.get("msg"))));
			//改变提货状态为3卡货....
			delInf.setStatus("3");
			//处理提货状态
			Service.lookup(IMINDataBaseService.class)
					.getMybatisMapper(VmDeliveryInfMapper.class)
					.updateByPrimaryKeySelective(delInf);
			String msg = String.valueOf(stateNew.get("msg"));
			throw new MINBusinessException(msg);//操作失败!
		}else if("200".equals(String.valueOf(stateNew.get("code")))){
			//改变提货状态为2成功....
			delInf.setStatus("2");
			//处理提货状态
			Service.lookup(IMINDataBaseService.class)
					.getMybatisMapper(VmDeliveryInfMapper.class)
					.updateByPrimaryKeySelective(delInf);
			//修改货道商品数量
			String proEquRelId = delInf.getProEquRelId();
			VmProEquRel vmProEquRel = Service.lookup(IMINDataBaseService.class)
											.getMybatisMapper(VmProEquRelMapper.class)
											.selectByPrimaryKey(proEquRelId);
			String nums = vmProEquRel.getProductNums();
			nums = CommonUtil.add(nums,delInf.getDeliveryNums());
			vmProEquRel.setProductNums(nums);
			Service.lookup(IMINDataBaseService.class)
					.getMybatisMapper(VmProEquRelMapper.class)
					.updateByPrimaryKeySelective(vmProEquRel);

			VmOrderDetails vmOrderDetails = new VmOrderDetails();
			vmOrderDetails.setDetailsId(delInf.getOrdDetId());
			vmOrderDetails.setIsDelivery("01");
			Service.lookup(IMINDataBaseService.class)
					.getMybatisMapper(VmOrderDetailsMapper.class)
					.updateByPrimaryKeySelective(vmOrderDetails);

			//查询订单是否都提货
			VmOrderDetailsExample  vmOrderDetailsExample = new VmOrderDetailsExample();
			vmOrderDetailsExample.createCriteria().andOrderIdEqualTo(orderNo).andDeliveryIdIsNotNull().andIsDeliveryEqualTo("00");
			List<VmOrderDetails> vmOrderDetailsList = Service.lookup(IMINDataBaseService.class)
											.getMybatisMapper(VmOrderDetailsMapper.class)
											.selectByExample(vmOrderDetailsExample);
			if(vmOrderDetailsList.size() == 0){
				VmOrderInf vmOrderInf = new VmOrderInf();
				vmOrderInf.setId(orderNo);
				vmOrderInf.setPickupStt("01");
				Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmOrderInfMapper.class)
						.updateByPrimaryKeySelective(vmOrderInf);

			}

		}
		return res;
	}
	
	/**
	 * 提货回调
	 * @param response
	 * @param deliveryNo	
	 * @param outNums
	 * @param status
	 * @param failReason
	 * @throws MINBusinessException
	 */
	@MINAction(value = BACK_DELIVERY_FOR_MACHINE,session = false)
	public void backDeliveryForMachine(HttpServletResponse response,
			String deliveryNo,
			String outNums,
			String status,
			String failReason) throws MINBusinessException {
		// 给第三方传递回调成功信息
		try {
			if(response != null) {
				response.getOutputStream().write("Success".getBytes());
				response.flushBuffer();
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
		// 出货后维护销量
		VmDeliveryInf  delInf = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(VmDeliveryInfMapper.class).selectByPrimaryKey(deliveryNo);
		//处理数量
		if(CommonUtil.isEmpty(outNums)){
			outNums = "0";
		}
		String newDelNUms = CommonUtil.add(delInf.getDeliveryNums(), outNums);
		int compare = CommonUtil.compare(delInf.getProNums(), newDelNUms);
		if(0 == compare ){
			delInf.setStatus("2");//已出货
		}else if(compare > 0){
			delInf.setStatus("1");//部分出货
		}
		delInf.setDeliveryNums(newDelNUms);
		//维护出货状态和数量
		Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(VmDeliveryInfMapper.class)
				.updateByPrimaryKeySelective(delInf);
	}
	
	/**
	 * 创建提货信息
	 * @return
	 * @throws BusinessCodeException
	 * @throws MINBusinessException
	 */
	//@MINAction(value = "createDeliveryInfo",session = false)
	public static void createDeliveryInfo(
			List<DrawDto> drawDtoList
			 ) throws BusinessCodeException, MINBusinessException{
		String nowTime = DateUtil.getCurrentDateTimeString();

		for (int i = 0; i < drawDtoList.size(); i++) {
			DrawDto drawDto = drawDtoList.get(i);

				String orderId = drawDto.getOrderId();
				String orderDetailsId = drawDto.getOrderDetailsId();
				//获取订单信息
				VmOrderInf ordInf = Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmOrderInfMapper.class)
						.selectByPrimaryKey(orderId);
				if(ordInf == null){
					throw new BusinessCodeException("JINM0114");//订单信息不存在
				}else{
					if(!"00".equals(ordInf.getState())){
						throw new BusinessCodeException("JINM1105");//当前商品未支付,请支付后才可以提货
					}
				}

				VmOrderDetails detInf = Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmOrderDetailsMapper.class)
						.selectByPrimaryKey(orderDetailsId);

			//中奖的
			if(drawDto.isDraw()){
				//创建提货对象
				VmDeliveryInf dlInf = new VmDeliveryInf();
				//获取提货表主键
				String dlId = Service.lookup(IPublicService.class).getSequence("VM_DELIVERY_INF_ID");
				dlInf.setDeliveryId(dlId);					//提货编号
				dlInf.setChannel(ordInf.getChannel());		//渠道
				dlInf.setEquipmentId(ordInf.getEquipmentId());//售货机编号
				dlInf.setPersonId(ordInf.getPersonId());		//会员编号
				dlInf.setOrdDetId(detInf.getDetailsId());	//订单详情编号
				dlInf.setProType(detInf.getProType());		//商品交易类别:00正常商品01抽奖商品
				dlInf.setProName(detInf.getProName());		//商品名称
				dlInf.setProPrice(detInf.getProPrice());	//单价
				dlInf.setProNums(detInf.getProNums());	//为空取订单中的数量
				dlInf.setAmount(detInf.getAmount());		//金额
				dlInf.setStatus("0");						//0未提货1部分提货2已提货3卡货4清零
				dlInf.setDeliveryNums("0");					//默认未提货/提货数量为0
				dlInf.setCargoWay(detInf.getCargoWay());	//商品所在货道
				dlInf.setRemarks("会员下单,售货机编号:"+ordInf.getEquipmentId());//备注
				dlInf.setCreateUser(ordInf.getPersonId());	//创建人
				dlInf.setCreateTime(nowTime);				//创建时间
				dlInf.setModifyUser(ordInf.getPersonId());	//修改人
				dlInf.setModifyTime(nowTime);				//修改时间
				dlInf.setBranchid(ordInf.getBranchid());
				dlInf.setProEquRelId(detInf.getProEquRelId());
				//执行新增提货信息
				Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmDeliveryInfMapper.class)
						.insertSelective(dlInf);

				//更新订单详情
				detInf.setDeliveryId(dlId);
				ordInf.setIsDraw("01");
				detInf.setIsWinning("01");
				Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmOrderDetailsMapper.class)
						.updateByPrimaryKeySelective(detInf);
				if(!ordInf.equals("01") && !ordInf.equals("02")){
					Service.lookup(IMINDataBaseService.class)
							.getMybatisMapper(VmOrderInfMapper.class)
							.updateByPrimaryKeySelective(ordInf);
				}
			/**没有中奖的*/
			}else{
				ordInf.setIsDraw("00");
				detInf.setIsWinning("02");
				Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmOrderDetailsMapper.class)
						.updateByPrimaryKeySelective(detInf);
			}


		}

	}
	
	/**
	 * 创建提货信息
	 * @param orderNo		订单编号
	 * @return
	 * @throws BusinessCodeException
	 * @throws MINBusinessException
	 */
	//@MINAction(value = "createDeliveryInfo",session = false)
	public MINActionResult createDeliveryInfoTwo(
			// @MINParam(key = "orderNo")
			String orderNo
			 ) throws BusinessCodeException, MINBusinessException{
		MINActionResult res = new MINActionResult();
		String nowTime = DateUtil.getCurrentDateTimeString();
		//获取订单信息
		VmOrderInf ordInf = Service.lookup(IMINDataBaseService.class)
									.getMybatisMapper(VmOrderInfMapper.class)
									.selectByPrimaryKey(orderNo);
		if(ordInf == null){
			throw new BusinessCodeException("JINM0114");//订单信息不存在
		}else{
			if(!"00".equals(ordInf.getState())){
				throw new BusinessCodeException("JINM1105");//当前商品未支付,请支付后才可以提货
			}
		}
		//获取已支付的,待提货的订单商品信息
		VmOrderDetailsExample examp = new VmOrderDetailsExample();
		examp.createCriteria().andChannelEqualTo(ordInf.getChannel()).andOrderIdEqualTo(orderNo);
		List<VmOrderDetails> ordetList = Service.lookup(IMINDataBaseService.class)
												.getMybatisMapper(VmOrderDetailsMapper.class)
												.selectByExample(examp);
		for (int i = 0; i < ordetList.size(); i++) {
			VmOrderDetails detInf = ordetList.get(i);
			if(detInf != null){
				//创建提货对象
				VmDeliveryInf dlInf = new VmDeliveryInf();
				//获取提货表主键
				String dlId = Service.lookup(IPublicService.class).getSequence("VM_DELIVERY_INF_ID");
				res.set("dlId", dlId);
				dlInf.setDeliveryId(dlId);					//提货编号
				dlInf.setChannel(ordInf.getChannel());		//渠道
				dlInf.setEquipmentId(ordInf.getEquipmentId());//售货机编号
				dlInf.setPersonId(ordInf.getPersonId());		//会员编号
				dlInf.setOrdDetId(detInf.getDetailsId());	//订单详情编号
				dlInf.setProType(detInf.getProType());		//商品交易类别:00正常商品01抽奖商品
				dlInf.setProName(detInf.getProName());		//商品名称
				dlInf.setProPrice(detInf.getProPrice());	//单价
				dlInf.setProNums(detInf.getProNums());		//数量
				dlInf.setAmount(detInf.getAmount());		//金额
				dlInf.setStatus("0");						//0未提货1部分提货2已提货3卡货4清零
				dlInf.setDeliveryNums("0");					//默认未提货/提货数量为0
				dlInf.setCargoWay(detInf.getCargoWay());	//商品所在货道
				dlInf.setRemarks("会员下单,售货机编号:"+ordInf.getEquipmentId());//备注
				dlInf.setCreateUser(ordInf.getPersonId());	//创建人
				dlInf.setCreateTime(nowTime);				//创建时间
				dlInf.setModifyUser(ordInf.getPersonId());	//修改人
				dlInf.setModifyTime(nowTime);				//修改时间
				//执行新增提货信息
				Service.lookup(IMINDataBaseService.class)
								.getMybatisMapper(VmDeliveryInfMapper.class)
								.insert(dlInf);
			}
		}
		return res;
	}
	/**
	 * 创建提货信息
	 * @param orderNo		订单编号
	 * @return
	 * @throws BusinessCodeException
	 * @throws MINBusinessException
	 */
	//@MINAction(value = "createDeliveryInfo",session = false)
	public static void purchaseCreateDeliveryInfo(
			String orderNo,String drawNumber
	) throws BusinessCodeException, MINBusinessException{
		String nowTime = DateUtil.getCurrentDateTimeString();
		//获取订单信息
		VmOrderInf ordInf = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(VmOrderInfMapper.class)
				.selectByPrimaryKey(orderNo);
		if(ordInf == null){
			throw new BusinessCodeException("JINM0114");//订单信息不存在
		}else{
			if(!"00".equals(ordInf.getState())){
				throw new BusinessCodeException("JINM1105");//当前商品未支付,请支付后才可以提货
			}
		}
		//获取已支付的,待提货的订单商品信息
		VmOrderDetailsExample examp = new VmOrderDetailsExample();
		examp.createCriteria().andChannelEqualTo(ordInf.getChannel()).andOrderIdEqualTo(orderNo);
		List<VmOrderDetails> ordetList = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(VmOrderDetailsMapper.class)
				.selectByExample(examp);
		for (int i = 0; i < ordetList.size(); i++) {
			VmOrderDetails detInf = ordetList.get(i);
			if(detInf != null){
				//创建提货对象
				VmDeliveryInf dlInf = new VmDeliveryInf();
				//获取提货表主键
				String dlId = Service.lookup(IPublicService.class).getSequence("VM_DELIVERY_INF_ID");
				dlInf.setDeliveryId(dlId);					//提货编号
				dlInf.setChannel(ordInf.getChannel());		//渠道
				dlInf.setEquipmentId(ordInf.getEquipmentId());//售货机编号
				dlInf.setPersonId(ordInf.getPersonId());		//会员编号
				dlInf.setOrdDetId(detInf.getDetailsId());	//订单详情编号
				dlInf.setProType(detInf.getProType());		//商品交易类别:00正常商品01抽奖商品
				dlInf.setProName(detInf.getProName());		//商品名称
				dlInf.setProPrice(detInf.getProPrice());	//单价
				if(!CommonUtil.isEmpty(drawNumber)){
					dlInf.setProNums(drawNumber);			//数量
				}else{
					dlInf.setProNums(detInf.getProNums());	//为空取订单中的数量
				}
				dlInf.setAmount(detInf.getAmount());		//金额
				dlInf.setStatus("0");						//0未提货1部分提货2已提货3卡货4清零
				dlInf.setDeliveryNums("0");					//默认未提货/提货数量为0
				dlInf.setCargoWay(detInf.getCargoWay());	//商品所在货道
				dlInf.setRemarks("会员下单,售货机编号:"+ordInf.getEquipmentId());//备注
				dlInf.setCreateUser(ordInf.getPersonId());	//创建人
				dlInf.setCreateTime(nowTime);				//创建时间
				dlInf.setModifyUser(ordInf.getPersonId());	//修改人
				dlInf.setModifyTime(nowTime);				//修改时间
				dlInf.setProEquRelId(detInf.getProEquRelId());                    //货道编号
				//执行新增提货信息
				Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmDeliveryInfMapper.class)
						.insert(dlInf);
				//订单明细表set提货单编号
				detInf.setDeliveryId(dlId);
				Service.lookup(IMINDataBaseService.class)
						.getMybatisMapper(VmOrderDetailsMapper.class)
						.updateByPrimaryKeySelective(detInf);
			}
		}
	}


}