订单错误信息捕捉修改

admin

2019-02-15 c12b6ec43f6c79426d6f2337f903d3c0a225e9a5

 fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java

@@ -10,9 +10,6 @@


import javax.annotation.Resource;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.hibernate.HibernateException;

import org.hibernate.Query;

import org.hibernate.SQLQuery;

@@ -32,10 +29,14 @@
import com.yeshi.fanli.service.inter.config.InviteGetMoneyService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.msg.MsgInviteDetailService;

import com.yeshi.fanli.service.inter.msg.UserInviteMsgNotificationService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Service

public class ThreeSaleSerivceImpl implements ThreeSaleSerivce {

@@ -60,6 +61,11 @@
   

   @Resource

   private UserInviteMsgNotificationService userInviteMsgNotificationService;

	
   @Resource

   private  MsgInviteDetailService msgInviteDetailService;

	
	


   public UserInfo getBoss(final long uid) {

      return (UserInfo) dao.excute(new HibernateCallback<UserInfo>() {

@@ -113,8 +119,15 @@
         threeSale.setWorker(inviteeUser);

         threeSaleMapper.insertSelective(threeSale);

         

         // 删除已失效关系

         threeSaleMapper.deleteExpireRecord(inviter.getId(), inviteeUser.getId());

         List<ThreeSale> listExpire = threeSaleMapper.getExpireRecord(inviter.getId(), inviteeUser.getId());

         if (listExpire != null && listExpire.size() > 0) {

            // 删除失效

            for (ThreeSale saleExpire: listExpire) {

               msgInviteDetailService.deleteByThreeSale(saleExpire);

            }

            // 删除已失效关系

            threeSaleMapper.deleteExpireRecord(inviter.getId(), inviteeUser.getId());

         }

         

         //创建通知

         userInviteMsgNotificationService.inviteScan(inviter.getId(), threeSale);

@@ -145,6 +158,20 @@
                  threeSale.setUpdateTime(java.lang.System.currentTimeMillis());

                  threeSale.setWorker(invitee);

                  threeSaleMapper.insertSelective(threeSale);

						
                  // 删除已失效关系

                  threeSaleMapper.deleteExpireRecord(inviter.getId(), invitee.getId());

						
                  List<ThreeSale> listExpire = threeSaleMapper.getExpireRecord(inviter.getId(), invitee.getId());

                  if (listExpire != null && listExpire.size() > 0) {

                     // 删除历史通知

                     for (ThreeSale saleExpire: listExpire) {

                        msgInviteDetailService.deleteByThreeSale(saleExpire);

                     }

                     // 删除已失效关系

                     threeSaleMapper.deleteExpireRecord(inviter.getId(), invitee.getId());

                  }

						
                  userInviteMsgNotificationService.inviteScan(inviter.getId(), threeSale);

                  // threeSaleSerivce.bind(invitee, inviter);



@@ -628,9 +655,21 @@
         threeSale.setUpdateTime(java.lang.System.currentTimeMillis());

         threeSaleMapper.insertSelective(threeSale);

         

			
      }

		
      List<ThreeSale> listExpire = threeSaleMapper.getExpireRecord(inviter.getId(), invitee.getId());

      if (listExpire != null && listExpire.size() > 0) {

         // 删除历史通知

         for (ThreeSale saleExpire: listExpire) {

            msgInviteDetailService.deleteByThreeSale(saleExpire);

         }

         // 删除已失效关系

         threeSaleMapper.deleteExpireRecord(inviter.getId(), invitee.getId());

      }

		
      // 邀请消息

      userInviteMsgNotificationService.inviteSuccess(inviter.getId(), threeSale);



   }