Merge branch 'master' of http://git.iamberry.com/liuzhiwei/iamberry-common-tooth

tooth-common-core/src/main/java/com/iamberry/wechat/core/entity/integral/StayIntegral.java

@@ -9,7 +9,7 @@ public class StayIntegral implements Serializable{
     private Integer stayId;             //记录ID
     private String userOpenId;          //用户openid
     private Integer configId;           //来源
-    private Integer orderId;//订单id
+    private String orderId;//订单id
     private Integer stayNumber;         //积分数量
     private Date stayRecordedTime;      //积分入账时间
     private Integer stayStatus;         //状态
@@ -41,11 +41,11 @@ public class StayIntegral implements Serializable{
         this.configId = configId;
     }
 
-    public Integer getOrderId() {
+    public String getOrderId() {
         return orderId;
     }
 
-    public void setOrderId(Integer orderId) {
+    public void setOrderId(String orderId) {
         this.orderId = orderId;
     }
 

tooth-wechat-interface/src/main/java/com/iamberry/wechat/face/apparatus/ApparatusService.java

@@ -44,10 +44,10 @@ public interface ApparatusService {
     /**
      * 添加待入账积分统一调用该接口
      * @param openId
-     * @param IntegralType 1.新注册会员送一百积分  2.新增牙刷赠送400积分 3.购买牙刷，赠送订单金额乘以2的积分
-     * @param orderAmount  订单金额  IntegralType为3时有值
+     * @param IntegralType 1.新注册会员送一百积分  2.新增牙刷赠送400积分 3.购买牙刷，赠送积分
+     * @param orderAllIntegral  订单金额  IntegralType为3时有值
      * @param orderId  订单id  IntegralType为3时有值
      * @return
      */
-    boolean addStayIntegral(String openId,Integer IntegralType,Double orderAmount,Integer orderId);
+    boolean addStayIntegral(String openId,Integer IntegralType,Integer orderAllIntegral,String orderId);
 }

tooth-wechat-interface/src/main/java/com/iamberry/wechat/face/cart/CartService.java

@@ -1,6 +1,7 @@
 package com.iamberry.wechat.face.cart;
 
 import java.util.List;
+import java.util.Map;
 
 import com.iamberry.wechat.core.entity.PaperBean;
 import com.iamberry.wechat.core.entity.admin.ShopSystemRule;
@@ -137,4 +138,14 @@ public interface CartService {
 	 * @return
 	 */
 	public Integer selectOrderCount(ShopSalesOrderDto shopSalesOrderDto);
+
+	/**
+	 * 修改订单状态
+	 * @param orderId   订单号
+	 * @param status    订单原状态
+	 * @param remark    备注
+	 * @param operation 操作  1：取消订单，2：申请退款，3：取消退款，4：申请退货，5：取消申请退货，6：取消退货，7：申请换货，8：取消换货
+	 * @return
+	 */
+	Map<String,Object> updateOrderStatus(String orderId, Integer status, String remark, int operation);
 }

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/apparatus/ApparatusServiceImpl.java

@@ -35,6 +35,7 @@ public class ApparatusServiceImpl implements ApparatusService {
     @Autowired
     private MemberMapper memberMapper;
 
+
     @Override
     public List<Apparatus> listApparatusPage(Apparatus apparatus) {
         return apparatusMapper.listApparatusPage(apparatus);
@@ -60,11 +61,11 @@ public class ApparatusServiceImpl implements ApparatusService {
             //这里判断是否是会员 1.会员 2.普通用户
             if(memberInfo.getUserIdentity() == 2){
                 //赠送新注册积分
-                addStayIntegral(member.getUserOpenid(),1,0.0,0);
+                addStayIntegral(member.getUserOpenid(),1,0,"");
 
             }
             //赠送400新增牙刷积分
-            addStayIntegral(member.getUserOpenid(),2,0.0,0);
+            addStayIntegral(member.getUserOpenid(),2,0,"");
            //修改用户信息
             member.setUserIdentity(1);
             if(memberMapper.updateMemberByUserId(member) < 1){
@@ -111,13 +112,13 @@ public class ApparatusServiceImpl implements ApparatusService {
      * 添加待入账积分统一调用该接口
      * @param openId
      * @param IntegralType 1.新注册会员送一百积分  2.新增牙刷赠送400积分 3.购买牙刷，赠送订单金额乘以2的积分
-     * @param orderAmount  订单金额  IntegralType为3时有值
+     * @param orderAllIntegral  订单金额  IntegralType为3时有值
      * @param orderId  订单id  IntegralType为3时有值
      * @return
      */
     @Override
     @Transactional
-    public boolean addStayIntegral(String openId,Integer IntegralType,Double orderAmount,Integer orderId){
+    public boolean addStayIntegral(String openId,Integer IntegralType,Integer orderAllIntegral,String orderId){
         if(openId == null||openId.equals("") || IntegralType < 1){
             return false;
         }
@@ -148,15 +149,17 @@ public class ApparatusServiceImpl implements ApparatusService {
                 stayIntegral.setStayRecordedTime(calendar.getTime());
                 break;
             case 3:
-                if(orderAmount == 0){
+                if(orderAllIntegral == 0){
                     break;
                 }
                 integralConfig = getIntegralId(250);
-                stayNumber = (int)(orderAmount * 2);
+                stayNumber = orderAllIntegral;
                 stayIntegral.setOrderId(orderId);
                 //规则表查询新注册会员和新增牙刷积分到账时间（多少天到账）
                 buyConfig = getIntegralId(252);
-                calendar.set(Calendar.DAY_OF_MONTH,calendar.get(Calendar.DAY_OF_MONTH)+buyConfig.getIntegralConfigNumber());
+                ShopSystemRule shopSystemRule=systemMapper.selectOneShopRuleById(252);
+                Integer day = shopSystemRule.getRuleNum().intValue();
+                calendar.set(Calendar.DAY_OF_MONTH,calendar.get(Calendar.DAY_OF_MONTH)+day);
                 stayIntegral.setStayRecordedTime(calendar.getTime());
                 break;
             default:
@@ -165,7 +168,6 @@ public class ApparatusServiceImpl implements ApparatusService {
         if(integralConfig == null){
             return false;
         }
-
         stayIntegral.setUserOpenId(openId);
         stayIntegral.setConfigId(integralConfig.getIntegralConfigId());
         stayIntegral.setStayNumber(stayNumber);

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/cart/CartServiceImpl.java

@@ -1,7 +1,10 @@
 package com.iamberry.wechat.service.cart;
 
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
+import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -256,6 +259,154 @@ public class CartServiceImpl implements CartService {
 		// TODO Auto-generated method stub
 		return cartDao.selectOrderCount(shopSalesOrderDto);
 	}
-	
-	
+
+	@Override
+	public Map<String, Object> updateOrderStatus(String orderId, Integer status, String remark, int operation) {
+		Map<String, Object> map = new HashMap<String, Object>();
+		String txtOpera = getOrderOperation(operation);//获取操作信息
+		boolean flag = false;
+		StringBuilder msg = new StringBuilder();
+		Order order = new Order();
+		order.setSalesOrderid(orderId);
+		order.setOldStatus(status);
+		if (StringUtils.isNotEmpty(remark)) {
+			order.setSalesReturnDes(remark);
+		}
+		switch (status) {	//通过原始订单状态分配可执行的操作
+			case 1: //待支付
+				if (operation == 1) {	//取消订单
+					order.setSalesStatus(0);	//订单取消
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			case 2:	//已支付待发货
+				if (operation == 2) {	//申请退款
+					order.setSalesStatus(3);	//退款申请中
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			case 3:	//退款申请中
+				if (operation == 3) {	//取消退款
+					order.setSalesStatus(2);	//已支付，待发货
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			case 5:	//已发货
+				if (operation == 4) {	//申请退货
+					order.setSalesStatus(6);	//申请退货中
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else if (operation == 7) {	//申请换货
+					order.setSalesStatus(11);	//申请换货中
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			case 6:	//申请退货中
+				if (operation == 5) {	//取消申请退货
+					order.setSalesStatus(5);	//已发货
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			case 7:	//退货中
+				if (operation == 6) {	//取消退货
+					order.setSalesStatus(5);	//已发货
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			case 11:	//申请换货中
+				if (operation == 8) {	//取消换货
+					order.setSalesStatus(5);	//已发货
+					//修改订单状态
+					int num = cartDao.updateOrderByOrder(order);
+					if (num > 0) {
+						flag = true;
+					}
+				} else {
+					msg.append("该订单不支持");
+					msg.append(txtOpera);
+					msg.append("操作,请重新确认!");
+				}
+				break;
+			default:
+				msg.append("该订单不支持");
+				msg.append(txtOpera);
+				msg.append("操作,请重新确认!");
+				break;
+		}
+		map.put("flag",flag);
+		map.put("msg",msg);
+		return map;
+	}
+
+	/**
+	 * 获取用户对订单的操作
+	 * @param operation
+	 * @return
+	 */
+	public String getOrderOperation(int operation) {
+		String txtOpera = "";
+		switch (operation) {
+			case 1:txtOpera = "取消订单";break;
+			case 2:txtOpera = "申请退款";break;
+			case 3:txtOpera = "取消退款";break;
+			case 4:txtOpera = "申请退货";break;
+			case 5:txtOpera = "取消申请退货";break;
+			case 6:txtOpera = "取消退货";break;
+			case 7:txtOpera = "申请换货";break;
+			case 8:txtOpera = "取消换货";break;
+			default:txtOpera = "取消订单";break;
+		}
+		return txtOpera;
+	}
 }

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/cart/dao/CartDao.java

@@ -137,4 +137,11 @@ public interface CartDao {
 	 * @return
 	 */
 	public Integer selectOrderCount(ShopSalesOrderDto shopSalesOrderDto);
+
+	/**
+	 * 修改订单状态和备注信息
+	 * @param order
+	 * @return
+	 */
+	Integer updateOrderByOrder(Order order);
 }

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/cart/dao/impl/CartDaoImpl.java

@@ -198,4 +198,9 @@ public class CartDaoImpl implements CartDao{
 		// TODO Auto-generated method stub
 		return cartMapper.selectOrderCount(shopSalesOrderDto);
 	}
+
+	@Override
+	public Integer updateOrderByOrder(Order order) {
+		return cartMapper.updateOrderByOrder(order);
+	}
 }

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/mapper/CartMapper.java

@@ -85,4 +85,11 @@ public interface CartMapper {
 	 * @return
 	 */
 	public Integer selectOrderCount(ShopSalesOrderDto shopSalesOrderDto);
+
+	/**
+	 * 修改订单状态和备注信息
+	 * @param order
+	 * @return
+	 */
+	Integer updateOrderByOrder(Order order);
 }

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/mapper/cartMapper.xml

@@ -300,6 +300,32 @@ PUBLIC
 			SALES_STATUS = #{oldStatus} 
 		</if>
 	</update>
+
+	<!-- 根据orderId修改订单状态 -->
+	<update id="updateOrderByOrder" parameterType="Order">
+		UPDATE
+			TB_IAMBERRY_SHOP_SALES_ORDER
+		<set>
+			SALES_STATUS = #{salesStatus},
+			<if test="salesReturnDate != null and salesReturnDate != ''">
+				SALES_RETURN_DATE = #{salesReturnDate},
+			</if>
+			<if test="couponId!=null and couponId!=''" >
+				SALES_COUPON_RECEIVE_ID=#{couponId},
+			</if>
+			<if test="salesReturnDes!=null and salesReturnDes!=''" >
+				SALES_RETURN_DES = #{salesReturnDes},
+			</if>
+			<if test="salesChangeOrderid != null and salesChangeOrderid != ''">
+				SALES_CHANGE_ORDERID = #{salesChangeOrderid},
+			</if>
+		</set>
+		WHERE
+			SALES_ORDERID = #{salesOrderid}
+		<if test="oldStatus!=null" >
+			AND SALES_STATUS = #{oldStatus}
+		</if>
+	</update>
 	
 	<!-- 根据openid和状态查询订单数量 -->
 	<select id="selectOrderCount" parameterType="ShopSalesOrderDto" resultType="Integer">

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/mapper/memberMapper.xml

@@ -365,8 +365,8 @@
 	</select>
 
 	<insert id="insertStayIntegral" parameterType="StayIntegral">
-        INSERT INTO (user_openid,config_id,order_id,stay_number,stay_recorded_time,stay_status,stay_remark,stay_create_time)
+        INSERT INTO tb_iamberry_stay_integral (user_openid,config_id,sales_orderid,stay_number,stay_recorded_time,stay_status,stay_remark)
         VALUES
-         (userOpenid,configId,orderId,stayNumber,stayRecordedTime,stayStatus,stayRemark,NOW())
+         (#{userOpenId},#{configId},#{orderId},#{stayNumber},#{stayRecordedTime},#{stayStatus},#{stayRemark})
 	</insert>
 </mapper> 

tooth-wechat-service/src/main/java/com/iamberry/wechat/service/mapper/useIntegralMapper.xml

@@ -80,12 +80,12 @@
           integral_number,
           integral_before_number,
           integral_end_number,
-          integral_remark,
+          integral_remarks,
           integral_create_time
         )
         VALUES
         (
-          #{userOpenid},#{integralType},#{configId},#{integralNumber},
+          #{userOpenId},#{integralType},#{configId},#{integralNumber},
           #{integralBeforeNumber},#{integralEndNumber},#{integralRemark},NOW()
         )
     </insert>

tooth-wechat-web/src/main/java/com/iamberry/wechat/handles/cart/CartHandlers.java

@@ -12,6 +12,7 @@ import javax.servlet.http.HttpServletRequest;
 
 import com.iamberry.wechat.core.entity.product.Product;
 import com.iamberry.wechat.core.entity.product.QrcodeGift;
+import com.iamberry.wechat.face.apparatus.ApparatusService;
 import com.iamberry.wechat.face.order.CodeService;
 import com.iamberry.wechat.service.ImberryConfig;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -53,8 +54,7 @@ import com.iamberry.wechat.tools.StaticInfo;
 import static com.iamberry.wechat.service.ImberryConfig.INFORM_SHIPPING;
 
 @Controller
-//@RequestMapping("/wechat/cart")
-@RequestMapping("/cart")
+@RequestMapping("/wechat/cart")
 public class CartHandlers {
 
 	@Autowired
@@ -84,6 +84,9 @@ public class CartHandlers {
 	@Autowired
 	private CodeService codeService;
 
+	@Autowired
+	private ApparatusService apparatusService;
+
 	/**
 	 * 进入购物车页面
 	 * @param request
@@ -340,8 +343,7 @@ public class CartHandlers {
 									  @RequestParam(value = "pageNO", defaultValue = "1") Integer pageNO,
 									  @RequestParam(value = "salesStatus",defaultValue = "")String salesStatus,
 									  @RequestParam(value = "text",defaultValue = "")String text) throws Exception {
-//		String openId  = WechatUtils.getUserBySession(request).getUserOpenid();
-		String openId  = "oZ9pv02WMRQgyDVRY1a_daYecwHI";
+		String openId  = WechatUtils.getUserBySession(request).getUserOpenid();
 		String beginDate = request.getParameter("beginDate");
 		PaperBean bean = new PaperBean();
 		ResultMsg remsg=new ResultMsg();
@@ -561,6 +563,70 @@ public class CartHandlers {
 	}
 
 	/**
+	 * 	修改订单状态
+	 * @param request
+	 * @param orderId
+	 * @return ResultMsg
+	 * @throws Exception
+	 */
+	@ResponseBody
+	@RequestMapping("/updateOrderStatus")
+	public ResultMsg updateOrderStatus(HttpServletRequest request,
+								 @RequestParam(value = "orderId",defaultValue = "")String orderId,
+								 @RequestParam(value = "remark",defaultValue = "")String remark,
+								 @RequestParam(value = "status",defaultValue = "-1") Integer status)  throws Exception {
+		String openId = WechatUtils.getUserBySession(request).getUserOpenid();
+		ResultMsg remsg = new ResultMsg();
+		Map<String, Object> map = new HashMap<String, Object>();
+		if(status == -1){
+			remsg.setMessage(NameUtils.getConfig("ERRORINFO"));
+			remsg.setResultCode(ResultInfo.ERRORCODE);
+			remsg.setStatus(false);
+			return remsg;
+		}
+
+		if (null != orderId && !"".equals(orderId)) {
+			ShopSalesOrderDto orderDto = this.cartService.getOpenIdAndStatus(orderId);
+			if (orderDto != null) {
+				if (!openId.equals(orderDto.getSalesOpenid())) {
+					remsg.setMessage(NameUtils.getConfig("ERRORINFO"));
+					remsg.setResultCode(ResultInfo.ERRORCODE);
+					remsg.setStatus(false);
+					return remsg;
+				}
+			} else {
+				remsg.setMessage(NameUtils.getConfig("ERRORINFO"));
+				remsg.setResultCode(ResultInfo.ERRORCODE);
+				remsg.setStatus(false);
+				return remsg;
+			}
+			map = cartService.updateOrderStatus(orderId, Integer.valueOf(orderDto.getSalesStatus()), remark, status);
+
+			if (map.get("flag") == true && Integer.valueOf(orderDto.getSalesStatus()) == 1) { //待支付，取消订单
+				if (null != orderDto.getSalesCouponReceiveId() && !"".equals(orderDto.getSalesCouponReceiveId())) {
+					CouponItem couponItem = new CouponItem();
+					couponItem.setCouponItemId(orderDto.getSalesCouponReceiveId());
+					couponItem.setCouponItemUseropenid(openId);
+					couponItem.setCouponUseStatus(1);
+					couponItem.setOldCouponUseStatus(7);
+					couponItemService.updateCouponItemById(couponItem);
+				}
+			}
+		}
+
+		if(map.get("flag") == true){
+			remsg.setMessage(NameUtils.getConfig("SUCCESSINFO"));
+			remsg.setResultCode(ResultInfo.SUCCESSCODE);
+			remsg.setStatus(true);
+		}else{
+			remsg.setMessage(String.valueOf(map.get("msg")));
+			remsg.setResultCode(ResultInfo.ERRORCODE);
+			remsg.setStatus(false);
+		}
+		return remsg;
+	}
+
+	/**
 	 * 	取消订单
 	 * @param request
 	 * @param orderId

tooth-wechat-web/src/main/java/com/iamberry/wechat/handles/order/OrderHandler.java

@@ -113,10 +113,6 @@ public class OrderHandler {
 		OrderPayDto dto = new OrderPayDto();
 		// 用户信息
 		Member member = WechatUtils.getUserBySession(request);
-//		Member member = new Member();
-//		member.setUserId(14708);
-//		member.setUserOpenid("oZ9pv02WMRQgyDVRY1a_daYecwHI");
-
 		member = memberService.getMemberByUserId(member.getUserId());
 		String cartIds = request.getParameter("cartIds");
 		if (cartIds == null) {
@@ -245,10 +241,7 @@ public class OrderHandler {
 		SendPayDto dto = new SendPayDto();
 		dto.setSuccess(false);
 
-		//Member member = WechatUtils.getUserBySession(request); // 当前用户
-		Member member = new Member();
-		member.setUserId(14708);
-		member.setUserOpenid("oZ9pv02WMRQgyDVRY1a_daYecwHI");
+		Member member = WechatUtils.getUserBySession(request); // 当前用户
 
 		/** 数据格式校验 */
 		if (member == null || member.getUserOpenid() == null) {// 校验当前用户信息是否丢失

tooth-wechat-web/src/main/java/com/iamberry/wechat/handles/pay/ResponseWechatPayHandler.java

@@ -25,6 +25,7 @@ import com.iamberry.wechat.core.entity.rent.RentApply;
 import com.iamberry.wechat.core.entity.wx.WxPayResult;
 import com.iamberry.wechat.face.admin.SystemService;
 import com.iamberry.wechat.face.agentInfo.AgentPurchaseOrderService;
+import com.iamberry.wechat.face.apparatus.ApparatusService;
 import com.iamberry.wechat.face.cart.CartService;
 import com.iamberry.wechat.face.coupon.CouponItemService;
 import com.iamberry.wechat.face.giftCard.AgentMachineService;
@@ -62,6 +63,7 @@ import java.net.URLDecoder;
 import java.text.MessageFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.logging.Logger;
 
 /**
  * @author 何秀刚
@@ -123,6 +125,8 @@ public class ResponseWechatPayHandler {
 	private AgentPurchaseOrderService agentPurchaseOrderService;
 	@Autowired
 	private AdminOrderService adminOrderService;
+	@Autowired
+	private ApparatusService apparatusService;
 
 	/**
 	 * 销售订单支付回调方法 -- tooth订单返回
@@ -212,38 +216,18 @@ public class ResponseWechatPayHandler {
 							Integer integral = orderItem.getItemProductDiscount() * (orderItem.getItemNum()*3);
 							allIntegral += integral;
 						}
-
 					}
 					if(couponAmount > 0){  //有优惠券减去优惠券的金额
 						allIntegral += -couponAmount*3;
 					}
-					//allIntegral
+					boolean flag = apparatusService.addStayIntegral(or.getSalesOpenid(),3,allIntegral,or.getSalesOrderid());
+					ratFWLogger.info("积分是否入账："+ flag);
 					/*----------计算积分-----------*/
 
-
-					//更新账户余额
-					/*int balancePayAmount=order.getBalancePayAmount();
-					if(balancePayAmount>0){
-						Member member=new Member();
-						member.setUserOpenid(order.getSalesOpenid());
-						member.setUserIncome(-balancePayAmount);
-						memberService.updateUserIncomeByOpenId(member);
-						
-						//现金使用记录
-						CashLog log=new CashLog();
-						log.setCashLogsIntroduction("订单支出");
-						log.setCashLogsNum(balancePayAmount);
-						log.setCashLogsOpenid(member.getUserOpenid());
-						log.setCashLogsType(2);
-						log.setCashLogsResType(3);
-						log.setCashLogsOrderid(order.getSalesOrderid());
-						log.setCashLogsCreateDate(nowDate);
-						count=cashLogService.addCashLog(log);
-					}*/
 					if (count < 1) {
 						resXml = "<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[报文有误]]></return_msg></xml>";
 					}
-//System.out.println("===========pay 168 快速插入=============="+count);
+
 					// 给订单的回调修改状态
 					try {
 						MQMessage message = new MQMessage();