代码更新

wjj-api/src/main/java/com/demo/wjj/controller/DisplaceController.java

@@ -28,11 +28,9 @@ import org.springframework.web.bind.WebDataBinder;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 import javax.validation.Valid;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * 置换
@@ -205,7 +203,10 @@ public class DisplaceController {
     @GetMapping("/queryUndoList")
     public ApiResult queryUndoList(@RequestParam(required = false) String agentId, @RequestParam(required = false) String openId, HttpServletRequest request) {
         LOG.info("调用获取未审核置换列表(/displace/queryUndoList)接口, agentId:{}, openId:{}", agentId, openId);
-
+        String is_good="1";
+        if(agentId.equals(excellentAccount)){
+            is_good="2";
+        }
         if (StringUtils.isBlank(agentId)) {
             LOG.info("agentId为空");
             return ApiResult.createFailure();
@@ -217,7 +218,7 @@ public class DisplaceController {
         }
 
         try {
-            PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryUndoDisplaceList(agentId, openId, PageBean.create(request));
+            PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryUndoDisplaceList(agentId, openId, PageBean.create(request),is_good);
             ApiResult<PageInfo<DisplaceListBo>> apiResult = ApiResult.createSuccess(pageInfo);
             LOG.info("调用获取未审核置换列表(/displace/queryUndoList)接口成功");
             LOG.debug("未审核置换列表, apiResult:{}", apiResult);
@@ -249,9 +250,13 @@ public class DisplaceController {
             LOG.info("微信openId为空");
             return ApiResult.createFailure();
         }
+        String is_good="1";
+        if(agentId.equals(excellentAccount)){
+            is_good="2";
+        }
 
         try {
-            PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryDoneDisplaceList(agentId, openId, PageBean.create(request));
+            PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryDoneDisplaceList(agentId, openId, PageBean.create(request),is_good);
             ApiResult<PageInfo<DisplaceListBo>> apiResult = ApiResult.createSuccess(pageInfo);
             LOG.info("调用获取已审核置换列表(/displace/queryDoneList)接口成功");
             LOG.debug("未审核置换列表, apiResult:{}", apiResult);
@@ -474,4 +479,170 @@ public class DisplaceController {
             return ApiResult.createFailure();
         }
     }
+
+
+
+//    @RequestMapping("/appAddInfo2")
+//    public void appAddInfo2(String displaceId){
+//
+//        try {
+//            //获取置换信息
+//            DisplaceAudit displaceAuditBean=displaceAuditService.selectDisplaceAuditByDisplaceId(displaceId);
+//
+//            LOG.info("更新为已审核待上架");
+//
+//            // 记录id
+//            String id = displaceAuditBean.getId();
+//            // 车商ID
+//            String ids = displaceAuditBean.getIds();
+//            if(StringUtils.isEmpty(ids)) {
+//                LOG.info("addInfo error!=没有推送车商信息");
+//                return;
+//            }
+//
+//            // 销售员ID
+//            String saleId = displaceAuditBean.getSaleId();
+//            //取出带过来的置换ID
+//            DisplaceAuditBean displace = displaceAuditService.queryAuditPageByDisplaceId(displaceId);
+//            //设备名称
+//            String sbmc = displace.getAttrContent().get("sbpp") + " " + displace.getAttrContent().get("sbxh") + " " + displace.getAttrContent().get("sblx");
+//            // 发布时间
+//            String pubTimeStr = "";
+//            Date pubTime = displaceAuditBean.getPubTime();
+//            try {
+//                pubTimeStr = DateUtil.format(pubTime, "yyyy年MM月dd日 HH:mm");
+//            } catch (Exception e) {
+//                pubTimeStr = "";
+//            }
+//
+//            //存储被推送人 ids
+//            displaceAuditBean.setIds(ids);
+//            PushRecordBean pushRecord = null;
+//            List<PushRecordBean> list = new ArrayList<PushRecordBean>();
+//            String agentId=displaceAuditBean.getAgentId();
+//            AgentBean agentBean = agentBeanService.getAgentBeanByAgentId(agentId);
+//            if(agentBean == null) {
+//                resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "未查询到代理商信息！");
+//                return;
+//            }
+//            String agentName = agentBean.getAgentName();
+//            String appId =agentBean.getPubAppId();
+//            String appSecret = agentBean.getPubAppSecret();
+//            Date startTime = displaceAuditBean.getStartTime();
+//            Date endTime = displaceAuditBean.getEndTime();
+//
+//            // 反馈内容
+//            //  String diggerUrl = TemplateConstants.ZHSH_DIGGER_URL + "?agentId=" + agentId + "&id=" + id;
+//            String diggerUrl = "https://www.weigongcheng.net/wjj-api/index.html#/join" + "?agentId=" + agentId + "&displaceId=" + displaceId + "&status=" + displaceAuditBean.getAuditStatus() + "&id=" + id;
+//            String sms = TemplateConstants.ZHSH_DIGGER_UP_SMS;
+//            sms = sms.replaceAll("agentName", agentName);
+//            sms = sms.replaceAll("displaceId", displaceId);
+//            sms = sms.replaceAll("sbmc", sbmc);
+//
+//            String wxsms = TemplateConstants.ZHSH_DIGGER_TEMPLATE_CONTENT;
+//            wxsms = wxsms.replaceAll("first", "有一台设备正在寻找买家");
+//            wxsms = wxsms.replaceAll("keyword1", sbmc + "");
+//            if ("3".equals(displaceAuditBean.getUpType())) {
+//                wxsms = wxsms.replaceAll("keyword2", "最低价：" + displaceAuditBean.getMinPrice() + "万元-最高价：" + displaceAuditBean.getMaxPrice() + "万元");
+//            } else {
+//                wxsms = wxsms.replaceAll("keyword2", displaceAuditBean.getMinMoney() + "万元");
+//            }
+//            wxsms = wxsms.replaceAll("keyword3", displaceAuditBean.getMoneyRange() + "万元");
+//            wxsms = wxsms.replaceAll("keyword4", DateUtil.format(startTime, "yyyy年MM月dd日 HH:mm"));
+//            wxsms = wxsms.replaceAll("keyword5", displaceAuditBean.getBail() + "万元");
+//            wxsms = wxsms.replaceAll("remark", "点击【详情】前往查看！");
+//
+//            // 发送车商信息
+//            String[] diggers = ids.substring(0, ids.lastIndexOf(",")).split(",");
+//            for (int i = 0; i < diggers.length; i++) {
+//                //获取车商bean，并获取车商微信openid和其他信息
+//                DiggerBean digger = diggerBeanService.queryDiggerByID(diggers[i]);
+//                if (digger == null) {
+//                    continue;
+//                }
+//                String openId = digger.getWxOpenID();
+//                String wxnc = digger.getDaWxnc();
+//                String wxh = digger.getDaWxh();
+//                String name = digger.getDaName();
+//                String phone = digger.getDaPhone();
+//
+//                // 组装车商微信内容
+//                Map<String, TemplateData> param1 = new HashMap<String, TemplateData>();
+//                param1.put("first", new TemplateData("有一台设备正在寻找买家", "#696969"));
+//                param1.put("keyword1", new TemplateData(sbmc + "", "#696969"));
+//                if ("3".equals(displaceAuditBean.getUpType())) {
+//                    param1.put("keyword2", new TemplateData("最低价：" + displaceAuditBean.getMinPrice() + "万元-最高价：" + displaceAuditBean.getMaxPrice() + "万元", "#696969"));
+//                } else {
+//                    param1.put("keyword2", new TemplateData(displaceAuditBean.getMinMoney() + "万元", "#696969"));
+//                }
+//                param1.put("keyword3", new TemplateData(displaceAuditBean.getMoneyRange() + "万元", "#696969"));
+//                param1.put("keyword4", new TemplateData(DateUtil.format(startTime, "yyyy年MM月dd日 HH:mm"), "#696969"));
+//                param1.put("keyword5", new TemplateData(displaceAuditBean.getBail() + "万元", "#696969"));
+//                param1.put("remark", new TemplateData("点击【详情】前往查看！", "#696969"));
+//
+//                wxsms = wxsms.replaceAll("keyword1", wxnc);
+//			   /* pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, "2",ConfigConstants.XXLB_SBSJ,
+//						appId, appSecret, sms, wxsms, param1, diggerUrl, "拍品上架通知");
+//				list.add(pushRecord);*/
+//                pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, "1", ConfigConstants.XXLB_SBSJ,
+//                        appId, appSecret, sms, wxsms, param1, diggerUrl, "拍品上架通知");
+//                list.add(pushRecord);
+//            }
+//
+//            // 发送销售员信息
+//            if (StringUtils.isNotBlank(saleId)) {
+//                SalesBean salesBean = saleBeanService.getSaleBeanBySaleId(saleId);
+//                if (salesBean != null) {
+//                    String openId = salesBean.getWxOpenid();
+//                    String wxnc = salesBean.getSaleWxnc();
+//                    String wxh = salesBean.getSaleWxh();
+//                    String name = salesBean.getSaleName();
+//                    String phone = salesBean.getSalePhone();
+//                    String xqurl = "https://www.xxinjiyuan.com/wjj-api/index.html#/join?agentId=GZZSNJ&displaceId=GZZSNJ-ZH0044&status=finished&id=5c8adc199c7f44a8ac398d9edbcd4914";
+//                    // String saleUrl = TemplateConstants.ZHSH_SALE_URL + "?agentId=" + agentId + "&id=" + id;
+//                    String saleUrl = "https://www.weigongcheng.net/wjj-api/index.html#/join" + "?agentId=" + agentId + "&displaceId=" + displaceId + "&status=" + displaceAuditBean + "&id=" + id;
+//                    // 组装销售员微信内容
+//                    Map<String, TemplateData> param2 = new HashMap<String, TemplateData>();
+//                    param2.put("first", new TemplateData("您上传的设备已上架成功，等待买家出价", "#696969"));
+//                    param2.put("keyword1", new TemplateData(wxnc, "#696969"));
+//                    param2.put("keyword2", new TemplateData(sbmc, "#696969"));
+//                    param2.put("keyword3", new TemplateData(pubTimeStr, "#696969"));
+//                    param2.put("keyword4", new TemplateData("上架成功", "#696969"));
+//
+//                    String upsms = TemplateConstants.ZHSH_SALE_UP_SMS;
+//                    upsms = upsms.replace("sbmc", sbmc);
+//
+//                    String wxsms1 = TemplateConstants.ZHSH_SALE_TEMPLATE_CONTENT;
+//                    wxsms1 = wxsms1.replaceAll("first", "您上传的设备已上架成功，等待买家出价");
+//                    wxsms1 = wxsms1.replaceAll("keyword1", wxnc);
+//                    wxsms1 = wxsms1.replaceAll("keyword2", sbmc);
+//                    wxsms1 = wxsms1.replaceAll("keyword3", pubTimeStr);
+//                    wxsms1 = wxsms1.replaceAll("keyword4", "上架成功");
+//                    wxsms1 = wxsms1.replaceAll("remark", "赶快点击“详情”分享给大家吧！");
+//
+//					/*pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, "2",ConfigConstants.XXLB_SBSJ,
+//							appId, appSecret, upsms, wxsms1, param2, saleUrl, "审核结果通知");
+//					list.add(pushRecord);*/
+//                    pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, "1", ConfigConstants.XXLB_SBSJ,
+//                            appId, appSecret, upsms, wxsms1, param2, saleUrl, "审核结果通知");
+//                    list.add(pushRecord);
+//                }
+//            }
+//
+//            // 保存推送消息
+//            pushRecordBeanService.saveRecords(list);
+//        } catch (Exception e) {
+//            resultBean= new PageResultBean(PageResultBean.FAIL_CODE,"系统繁忙，请稍后再来！");
+//            log.error("addInfo error!",e);
+//        }finally{
+//
+//        }
+//
+//    }
+
+
+
+
+
+
 }

wjj-core/src/main/java/com/demo/wjj/mapper/DisplaceAuditMapper.java

@@ -35,16 +35,16 @@ public interface DisplaceAuditMapper {
      * @param auditStatus 审核状态
      * @return 置换集合
      */
-    List<DisplaceListBo> selectDisplaceList(@Param("agentId") String agentId, @Param("openId") String openId, @Param("auditStatus") String auditStatus);
+    List<DisplaceListBo> selectDisplaceList(@Param("agentId") String agentId, @Param("openId") String openId, @Param("auditStatus") String auditStatus,@Param("is_good") String is_good);
     List<DisplaceListBo> selectDisplaceConfirmList(@Param("agentId") String agentId, @Param("openId") String openId, @Param("auditStatus") String auditStatus);
     List<DisplaceListBo> selectDisplaceOnList(@Param("agentId") String agentId, @Param("now") Date now, @Param("auditStatus") String auditStatus);
     List<DisplaceListBo> selectDisplaceSaleList(@Param("agentId") String agentId, @Param("now") Date now, @Param("auditStatus") String auditStatus);
     List<DisplaceListBo> selectDisplaceHaltList(@Param("agentId") String agentId, @Param("now") Date now, @Param("auditStatus") String auditStatus);
     List<DisplaceListBo> selectDisplaceMyList(@Param("agentId") String agentId, @Param("openId") String openId, @Param("now") Date now, @Param("auditStatus") String auditStatus);
-    List<DisplaceListBo> selectMyList(@Param("agentId") String agentId, @Param("diggerAgentId") String diggerAgentId);
+    List<DisplaceListBo> selectMyList(@Param("agentId") String agentId, @Param("now") Date now, @Param("diggerAgentId") String diggerAgentId);
     List<DisplaceListBo> getDisplaceGoodSaleList(@Param("agentId") String agentId, @Param("openId") String openId, @Param("now") Date now, @Param("auditStatus") String auditStatus);
     List<DisplaceListBo> getDisplaceStorageList(@Param("agentId") String agentId, @Param("openId") String openId, @Param("storageStatus") String storageStatus);
-    int updateByDisplaceId(@Param("displaceId") String displaceId, @Param("ifDeposit") String ifDeposit);
+    int updateByDisplaceId(@Param("displaceId") String displaceId, @Param("ifDeposit") String ifDeposit,@Param("storage") String storage);
 
     /**
      * 查询置换详情
@@ -60,6 +60,8 @@ public interface DisplaceAuditMapper {
      */
     DisplaceAudit selectDisplaceAudit(String displaceId);
 
+    DisplaceAudit selectDisplaceAuditByDisplaceId(String displaceId);
+
     /**
      * 查询被驳回的置换设备数量
      * @param agentId 商家id

wjj-core/src/main/java/com/demo/wjj/po/DisplaceAudit.java

@@ -151,6 +151,16 @@ public class DisplaceAudit extends BasePo {
 
     private String upType;
 
+    private String ids;
+
+    public String getIds() {
+        return ids;
+    }
+
+    public void setIds(String ids) {
+        this.ids = ids;
+    }
+
     public String getUpType() {
         return upType;
     }

wjj-core/src/main/java/com/demo/wjj/service/DisplaceAuditService.java

@@ -30,7 +30,7 @@ public interface DisplaceAuditService {
      * @param pageBean pageBean
      * @return 待审核的置换
      */
-    PageInfo<DisplaceListBo> queryUndoDisplaceList(String agentId, String openId, PageBean pageBean);
+    PageInfo<DisplaceListBo> queryUndoDisplaceList(String agentId, String openId, PageBean pageBean,String is_good);
 
     /**
      * 根据类型查询置换
@@ -46,7 +46,7 @@ public interface DisplaceAuditService {
 
     PageInfo<DisplaceListBo> getDisplaceConfirmList(String agentId, String openId, PageBean pageBean);
 
-    int updateByDisplaceId(String displaceId, String ifDeposit);
+    int updateByDisplaceId(String displaceId, String ifDeposit,String storage);
 
 
 
@@ -57,7 +57,7 @@ public interface DisplaceAuditService {
      * @param pageBean pageBean
      * @return 已审核的置换
      */
-    PageInfo<DisplaceListBo> queryDoneDisplaceList(String agentId, String openId, PageBean pageBean);
+    PageInfo<DisplaceListBo> queryDoneDisplaceList(String agentId, String openId, PageBean pageBean,String is_good);
 
     /**
      * 获取置换详情
@@ -73,6 +73,9 @@ public interface DisplaceAuditService {
      */
     DisplaceAudit getDisplaceAudit(String displaceId);
 
+    DisplaceAudit selectDisplaceAuditByDisplaceId(String displaceId);
+
+
     /**
      * 获取被驳回的置换设备数量
      * @param agentId 商家id

wjj-core/src/main/java/com/demo/wjj/service/impl/DisplaceAuditServiceImpl.java

@@ -62,7 +62,7 @@ public class DisplaceAuditServiceImpl implements DisplaceAuditService {
 
     @ReadOnlyTransactional
     @Override
-    public PageInfo<DisplaceListBo> queryUndoDisplaceList(String agentId, String openId, PageBean pageBean) {
+    public PageInfo<DisplaceListBo> queryUndoDisplaceList(String agentId, String openId, PageBean pageBean,String is_good) {
         LOG.info("进入查询待审核的置换列表, agentId:{}, openId:{}, pageBean:{}", agentId, openId, pageBean);
         if (StringUtils.isBlank(agentId)) {
             LOG.info("agentId为空");
@@ -75,7 +75,7 @@ public class DisplaceAuditServiceImpl implements DisplaceAuditService {
         }
 
         PageHelper.startPage(pageBean.getPageNum(), pageBean.getPageSize(), true);
-        List<DisplaceListBo> displaceListBos = displaceAuditMapper.selectDisplaceList(agentId, openId, DisplaceAudit.AUDIT_STATUS_UNDO);
+        List<DisplaceListBo> displaceListBos = displaceAuditMapper.selectDisplaceList(agentId, openId, DisplaceAudit.AUDIT_STATUS_UNDO,is_good);
         displaceAssemblyService.assembleListAttrContent(displaceListBos);
         LOG.info("退出查询待审核的列表");
         return new PageInfo<>(displaceListBos);
@@ -104,7 +104,7 @@ public class DisplaceAuditServiceImpl implements DisplaceAuditService {
             }
 
             PageHelper.startPage(pageBean.getPageNum(), pageBean.getPageSize(), true);
-            displaceListBos = displaceAuditMapper.selectMyList(agentId, diggerAgent.getDaId());
+            displaceListBos = displaceAuditMapper.selectMyList(agentId, new Date(), diggerAgent.getDaId());
         }
         displaceAssemblyService.assembleListAttrContent(displaceListBos);
         LOG.info("退出查询置换列表");
@@ -160,13 +160,13 @@ public class DisplaceAuditServiceImpl implements DisplaceAuditService {
     }
 
     @Override
-    public int updateByDisplaceId(String displaceId, String ifDeposit) {
-        return displaceAuditMapper.updateByDisplaceId(displaceId,ifDeposit);
+    public int updateByDisplaceId(String displaceId, String ifDeposit,String storage) {
+        return displaceAuditMapper.updateByDisplaceId(displaceId,ifDeposit,storage);
     }
 
     @ReadOnlyTransactional
     @Override
-    public PageInfo<DisplaceListBo> queryDoneDisplaceList(String agentId, String openId, PageBean pageBean) {
+    public PageInfo<DisplaceListBo> queryDoneDisplaceList(String agentId, String openId, PageBean pageBean,String is_good) {
         LOG.info("进入查询已审核的置换列表, agentId:{}, openId:{}, pageBean:{}", agentId, openId, pageBean);
         if (StringUtils.isBlank(agentId)) {
             LOG.info("agentId为空");
@@ -179,7 +179,7 @@ public class DisplaceAuditServiceImpl implements DisplaceAuditService {
         }
 
         PageHelper.startPage(pageBean.getPageNum(), pageBean.getPageSize(), true);
-        List<DisplaceListBo> displaceListBos = displaceAuditMapper.selectDisplaceList(agentId, openId, DisplaceAudit.AUDIT_STATUS_DONE);
+        List<DisplaceListBo> displaceListBos = displaceAuditMapper.selectDisplaceList(agentId, openId, DisplaceAudit.AUDIT_STATUS_DONE, is_good);
         displaceAssemblyService.assembleListAttrContent(displaceListBos);
         LOG.info("退出查询已审核的置换列表");
         return new PageInfo<>(displaceListBos);
@@ -227,6 +227,19 @@ public class DisplaceAuditServiceImpl implements DisplaceAuditService {
     }
 
     @Override
+    public DisplaceAudit selectDisplaceAuditByDisplaceId(String displaceId) {
+        LOG.info("调用获取置换审核, displaceId:{}", displaceId);
+        if (StringUtils.isBlank(displaceId)) {
+            LOG.info("displaceId为空");
+            return null;
+        }
+
+        DisplaceAudit displaceAudit = displaceAuditMapper.selectDisplaceAudit(displaceId);
+        LOG.info("退出获取置换审核, displaceAudit:{}", displaceAudit);
+        return displaceAudit;
+    }
+
+    @Override
     public int getRejectedDisplaceCount(String agentId, String openId) {
         LOG.info("进入查询被驳回的置换设备数量, agentId:{}, openId:{}", agentId, openId);
 

wjj-core/src/main/java/com/demo/wjj/service/impl/OfferServiceImpl.java

@@ -364,6 +364,10 @@ public class OfferServiceImpl implements OfferService {
             displaceAuditService.updateEndTime(displaceAudit.getId(), newEndTime.getTime());
         }
         //精品机一口价成交处理
+        LOG.info("displaceAudit.getIs_good()="+displaceAudit.getIs_good());
+        LOG.info("displaceAudit.getUpType()="+displaceAudit.getUpType());
+        LOG.info("displaceAudit.getPersist_price()="+displaceAudit.getPersist_price());
+        LOG.info("diggerOfferSaveBo.getPrice()="+diggerOfferSaveBo.getPrice());
         if("2".equals(displaceAudit.getIs_good())&&"3".equals(displaceAudit.getUpType())&&displaceAudit.getPersist_price()<=diggerOfferSaveBo.getPrice()){
             //更新置换 结束时间
             Calendar newEndTime = Calendar.getInstance();

wjj-core/src/main/java/com/demo/wjj/service/impl/PayServiceImpl.java

@@ -88,7 +88,6 @@ public class PayServiceImpl implements PayService {
                     .setExecuteResult(false)
                     .setResult(Result.Failure);
         }
-
         String openId = createOrderBo.getOpenId();
         if (StringUtils.isBlank(openId)) {
             LOG.warn("微信openId为空");
@@ -268,8 +267,6 @@ public class PayServiceImpl implements PayService {
         // 默认不是通票, 通票是不需要支付保证金
         newDeposit.setIsCommon("0");
         depositService.save(newDeposit);
-        LOG.info("更新是否支付保证金");
-        displaceAuditService.updateByDisplaceId(productId,"2");
         CreateOrderResult createOrderResult = new CreateOrderResult();
         createOrderResult.setAppId(appId);
         createOrderResult.setTimeStamp(String.valueOf(System.currentTimeMillis() / 1000));
@@ -472,7 +469,8 @@ public class PayServiceImpl implements PayService {
             } else {
                 weiXinPayService.updateOrderStatus(weiXinPay.getId(), WeiXinPay.ORDER_STATUS_SUCCESS);
                 depositService.updatePayStatus(weiXinPay.getOrderNo(), transactionId, "1");
-
+                LOG.info("更新是否支付保证金="+weiXinPay.getProductId());
+                displaceAuditService.updateByDisplaceId(weiXinPay.getProductId(),"2","1");
                 PayParameterJson payParameterJson = JSON.parseObject(weiXinPay.getParameterJson(), PayParameterJson.class);
 
                 saveDisplaceOffUser(weiXinPay, payParameterJson);

wjj-core/src/main/java/com/demo/wjj/service/impl/PayforServiceImpl.java

@@ -2,10 +2,8 @@ package com.demo.wjj.service.impl;
 
 import com.alibaba.fastjson.JSON;
 import com.demo.wjj.bo.*;
-import com.demo.wjj.po.Agent;
-import com.demo.wjj.po.Deposit;
-import com.demo.wjj.po.DiggerAgent;
-import com.demo.wjj.po.WeiXinPay;
+import com.demo.wjj.mapper.ExplainMapper;
+import com.demo.wjj.po.*;
 import com.demo.wjj.service.*;
 import com.demo.wjj.utils.*;
 import com.sun.xml.internal.messaging.saaj.util.ByteInputStream;
@@ -54,6 +52,8 @@ public class PayforServiceImpl implements PayforService{
      */
     @Value("${weixin.pay.apiAddress}")
     private String payApiAddress;
+    @Value("${jpjgh}")
+    private String jpjgh;
     @Autowired
     private DiggerAgentService diggerAgentService;
     @Autowired
@@ -68,6 +68,9 @@ public class PayforServiceImpl implements PayforService{
     @Autowired
     DisplaceAuditService displaceAuditService;
 
+    @Autowired
+    ExplainMapper explainMapper;
+
 
 
     @Override
@@ -135,7 +138,13 @@ public class PayforServiceImpl implements PayforService{
                     .setExecuteResult(false)
                     .setResult(Result.NO_AUTHORITY);
         }
-        Integer deposit = creditsExchangeService.selectByUserId(agentId).getCashDiposit()*100;
+        Integer deposit = 0;
+        if(jpjgh.equals(agentId)){
+            List<Explain> explain=explainMapper.selectExplain();
+            deposit=Integer.parseInt(explain.get(0).getDeposit())*100;
+        }else{
+            deposit=creditsExchangeService.selectByUserId(agentId).getCashDiposit()*100;
+        }
         CreateOrderParameter orderParameter = new CreateOrderParameter();
         orderParameter.setAppId(appId);
         orderParameter.setMchId(mchId);
@@ -222,8 +231,6 @@ public class PayforServiceImpl implements PayforService{
         // 默认不是通票, 通票是不需要支付保证金
         newDeposit.setIsCommon("0");
         depositService.save(newDeposit);
-        LOG.info("更新是否支付保证金");
-        displaceAuditService.updateByDisplaceId(productId,"2");
         CreateOrderResult createOrderResult = new CreateOrderResult();
         createOrderResult.setAppId(appId);
         createOrderResult.setTimeStamp(String.valueOf(System.currentTimeMillis() / 1000));
@@ -412,6 +419,8 @@ public class PayforServiceImpl implements PayforService{
                 weiXinPayService.updateOrderStatus(weiXinPay.getId(), WeiXinPay.ORDER_STATUS_MONEY_ERROR);
                 return null;
             } else {
+                LOG.info("更新是否支付保证金="+weiXinPay.getProductId());
+                displaceAuditService.updateByDisplaceId(weiXinPay.getProductId(),"2","1");
                 weiXinPayService.updateOrderStatus(weiXinPay.getId(), WeiXinPay.ORDER_STATUS_SUCCESS);
                 depositService.updatePayStatus(weiXinPay.getOrderNo(), transactionId, "1");
             }

wjj-core/src/main/resources/mybatis/DisplaceAuditMapper.xml

@@ -34,7 +34,7 @@
 
     <update id="updateByDisplaceId">
         UPDATE tb_displace_audit
-        SET if_deposit = #{ifDeposit}
+        SET if_deposit = #{ifDeposit},storage=#{storage}
         WHERE displace_id = #{displaceId}
     </update>
 
@@ -53,9 +53,17 @@
         </if>
         <if test="auditStatus == 1">
             a.audit_status IN ('1', '3')
+            <if test="is_good == 2">
+                AND   a.if_deposit='2'
+            </if>
+            <if test="is_good == 1">
+                AND   a.if_deposit='1'
+            </if>
         </if>
+        AND a.is_good=#{is_good}
         AND a.agent_id = #{agentId} AND s.agent_id = #{agentId} AND s.wx_openid = #{openId}
         AND a.state = '1'
+
         ORDER BY a.displace_id DESC
     </select>
 
@@ -93,11 +101,20 @@
         <result column="time_delay" property="timeDelay"/>
         <result column="min_money" property="minMoney"/>
         <result column="up_type" property="upType"/>
+        <result column="sale_id" property="saleId"/>
+        <result column="ids" property="ids"/>
+        <result column="is_good" property="is_good"/>
     </resultMap>
 
+    <select id="selectDisplaceAuditByDisplaceId" resultMap="displaceAudit">
+        SELECT a.id, a.displace_id, a.agent_id, a.audit_status, a.start_time, a.end_time, a.bail, a.time_delay, a.min_money,a.persist_price,a.up_type,a.is_good,a.ids
+        FROM tb_displace_audit a
+        WHERE a.state = '1' AND a.displace_id = #{displaceId}
+    </select>
+
     <!--查询置换审核-->
     <select id="selectDisplaceAudit" resultMap="displaceAudit">
-        SELECT a.id, a.displace_id, a.agent_id, a.audit_status, a.start_time, a.end_time, a.bail, a.time_delay, a.min_money,a.persist_price,a.up_type
+        SELECT a.id, a.displace_id, a.agent_id, a.audit_status, a.start_time, a.end_time, a.bail, a.time_delay, a.min_money,a.persist_price,a.up_type,a.is_good
         FROM tb_displace_audit a
         WHERE a.state = '1' AND a.displace_id = #{displaceId}
     </select>
@@ -144,18 +161,16 @@
 
     <!--停售设备-->
     <select id="selectDisplaceHaltList" resultType="com.demo.wjj.bo.DisplaceListBo">
-        SELECT a.id,a.is_kxc isKxc, a.up_type upType, a.displace_id displaceId, IFNULL(a.look_times, 0) lookTimes, IFNULL(b.offer_times, 0) offerTimes, a.first_pic_url picUrl, a.start_time , a.end_time startTime, IFNULL(b.max_offer, a.min_money) currentPrice,a.storage,a.is_good,a.min_price,a.max_price,a.persist_price
-        FROM tb_displace_audit a left JOIN tb_offer b ON b.displace_id=a.displace_id
+        SELECT a.id,a.is_kxc isKxc, a.up_type upType, a.displace_id displaceId, IFNULL(a.look_times, 0) lookTimes, IFNULL(b.offer_times, 0) offerTimes,a.first_pic_url picUrl, a.start_time , a.end_time startTime, IFNULL(b.max_offer, a.min_money) currentPrice,a.storage,a.is_good,a.min_price,a.max_price,a.persist_price
+        FROM tb_displace_audit a left JOIN agent.tb_offer b ON b.displace_id=a.displace_id
         WHERE
         a.audit_status IN ('1', '3')
         AND  #{now} > a.end_time
         AND a.agent_id = #{agentId}
         AND a.state = '1'
-        AND b.offer_times = 0
-        AND b.displace_id=a.displace_id
         AND a.is_good='2'
         AND a.storage='1'
-        And a.if_deposit='2'
+        AND a.if_deposit='2'
         ORDER BY a.start_time DESC
     </select>
 
@@ -185,7 +200,7 @@
         FROM tb_offer_detail d JOIN tb_offer o ON d.offer_id = o.id
         WHERE d.da_id = #{diggerAgentId}
         ) t JOIN tb_displace_audit a ON t.displace_id = a.displace_id LEFT JOIN tb_offer o ON a.displace_id = o.displace_id
-        WHERE a.audit_status IN ('1', '3') AND a.state = '1' AND a.agent_id = #{agentId} and is_good='2'
+        WHERE a.audit_status IN ('1', '3') AND a.state = '1' AND a.agent_id = #{agentId} and is_good='2'  AND  #{now} > a.end_time
         ORDER BY a.start_time DESC
     </select>
 

wjj-core/src/test/java/com/demo/wjj/service/DisplaceAuditServiceTest.java

@@ -17,25 +17,25 @@ public class DisplaceAuditServiceTest extends BaseTest {
     @Autowired
     private DisplaceAuditService displaceAuditService;
 
-    @Ignore
-    @Test
-    public void queryUndoDisplaceList() {
-        PageBean pageBean = new PageBean();
-        pageBean.setPageSize(15);
-        pageBean.setPageNum(1);
-        PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryUndoDisplaceList("aaabbb", "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o", pageBean);
-        System.out.println(JSON.toJSON(pageInfo));
-    }
-
-    @Ignore
-    @Test
-    public void queryDoneDisplaceList() {
-        PageBean pageBean = new PageBean();
-        pageBean.setPageSize(15);
-        pageBean.setPageNum(1);
-        PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryDoneDisplaceList("aaabbb", "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o", pageBean);
-        System.out.println(JSON.toJSON(pageInfo));
-    }
+//    @Ignore
+//    @Test
+//    public void queryUndoDisplaceList() {
+//        PageBean pageBean = new PageBean();
+//        pageBean.setPageSize(15);
+//        pageBean.setPageNum(1);
+//        PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryUndoDisplaceList("aaabbb", "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o", pageBean);
+//        System.out.println(JSON.toJSON(pageInfo));
+//    }
+//
+//    @Ignore
+//    @Test
+//    public void queryDoneDisplaceList() {
+//        PageBean pageBean = new PageBean();
+//        pageBean.setPageSize(15);
+//        pageBean.setPageNum(1);
+//        PageInfo<DisplaceListBo> pageInfo = displaceAuditService.queryDoneDisplaceList("aaabbb", "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o", pageBean);
+//        System.out.println(JSON.toJSON(pageInfo));
+//    }
 
     @Test
     public void getDisplaceDetail() {