支付凭证回传，商品详情主图

kmall-admin/src/main/java/com/kmall/admin/cuspay/biz/ali/AliCusDeclareBiz.java

@@ -214,6 +214,7 @@ public class AliCusDeclareBiz extends AbstractCusDeclareBiz implements CuspayBiz
         }
 
         MerchNoti merchNoti = new MerchNoti();
+        merchNoti.setOrderSn(params.get("orderSn").toString());
         try {
             if (stringObjectMap != null) {
                 isSuccess = stringObjectMap.get("is_success").toString();

kmall-admin/src/main/java/com/kmall/admin/cuspay/biz/merch/MerchantNoticeBiz.java

@@ -1,28 +1,25 @@
 package com.kmall.admin.cuspay.biz.merch;
 
-import com.kmall.admin.cuspay.biz.CuspayBiz;
+import com.google.common.collect.ImmutableMap;
 import com.kmall.admin.cuspay.common.contant.MerchNoticeDict;
+import com.kmall.admin.cuspay.util.Contants;
 import com.kmall.admin.dao.cuspay.merch.MerchNotiMapper;
 import com.kmall.admin.cuspay.entity.merch.MerchNoti;
-import com.kmall.admin.cuspay.support.msg.resp.ResponseMessage;
-import com.kmall.admin.cuspay.support.msg.resp.ResponseStatus;
-import com.kmall.admin.cuspay.util.OkHttpUtils;
 import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
-import com.google.gson.Gson;
-import okhttp3.Request;
-import okhttp3.RequestBody;
+import com.kmall.admin.haikong.constant.Constants;
+import com.kmall.admin.service.OrderProcessRecordService;
+import com.kmall.admin.service.OrderService;
+import com.kmall.admin.service.PickUpCodeService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.PropertySource;
 import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
 
 import java.io.IOException;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * 商户通知请求回执
@@ -36,7 +33,7 @@ import java.util.Map;
  */
 @Component
 @PropertySource(value = {"classpath:conf/cuspay/cuspay-merch-notice.properties"})
-public class MerchantNoticeBiz implements CuspayBiz{
+public class MerchantNoticeBiz {
     private static final Logger logger = LoggerFactory.getLogger(MerchantNoticeBiz.class);
 
     @Autowired
@@ -47,8 +44,16 @@ public class MerchantNoticeBiz implements CuspayBiz{
     @Autowired
     private MerchNotiMapper merchNotiMapper;
 
-    @Override
-    public void biz(Map<String, Object> params) {
+    @Autowired
+    private PickUpCodeService pickUpCodeService;
+
+    @Autowired
+    private OrderProcessRecordService orderProcessRecordService;
+
+    @Autowired
+    private OrderService orderService;
+
+    public void biz() {
         limit = Integer.parseInt(environment.getProperty("db.merch.notice.limit"));
 
         limit = (limit != null && limit > 0) ? limit : 20;
@@ -64,7 +69,7 @@ public class MerchantNoticeBiz implements CuspayBiz{
 
         notis.forEach(noti->{
 
-            if (noti.getNotifyUrl() == null) {
+            if (StringUtils.isEmpty(noti.getNotifyUrl())) {
                 logger.error("商户通知回调接口为空");
                 noti.setNotiStatue(MerchNoticeDict.NoticeStatus.i_3.getItem()); //发送失败
                 noti.setIsStoped(MerchNoticeDict.IsStopStatus.i_1.getItem());
@@ -72,7 +77,7 @@ public class MerchantNoticeBiz implements CuspayBiz{
                 return;
             }
 
-            if (noti.getNotiCount() == null || noti.getNotiCount() <= 0) {
+            if (Objects.isNull(noti.getNotiCount()) || noti.getNotiCount() <= 0) {
                 logger.error("通知商户次数为空");
                 noti.setNotiStatue(MerchNoticeDict.NoticeStatus.i_3.getItem()); //发送失败
                 noti.setIsStoped(MerchNoticeDict.IsStopStatus.i_1.getItem());
@@ -80,28 +85,32 @@ public class MerchantNoticeBiz implements CuspayBiz{
                 return;
             }
 
-            //组装需要请求的参数
-            String jsonStr = createJsonByNoti(noti);
-            logger.info("商户通知回调参数Parameters:"+ jsonStr);
-
-            int counter = 0;
-
-            while (counter < noti.getNotiCount()) {
-                ++counter;
-
-                Request request = OkHttpUtils.buildRequest(noti.getNotifyUrl(),
-                        RequestBody.create(OkHttpUtils.JSON, jsonStr));
-                String result = null;
-                try{
-                    result = OkHttpUtils.post(request);
-                    noti.setNotiStatue(MerchNoticeDict.NoticeStatus.i_2.getItem()); //通知发送成功
-                    noti.setIsStoped(MerchNoticeDict.IsStopStatus.i_1.getItem());//停止通知
-                    break;
-                }catch (IOException e) {
-                    logger.error("商户回调通知异常", e);
-                    noti.setNotiStatue(MerchNoticeDict.NoticeStatus.i_3.getItem()); //发送失败
-                    noti.setIsStoped(MerchNoticeDict.IsStopStatus.i_1.getItem());
+            if(Constants.DocStatus.item_12.getItem().equals(noti.getCusDeclStatus())){
+                // 身份信息不一致
+                if("2".equals(noti.getBuyerPayerCheck())){
+                    try {
+
+                        // 新增修改kmall中取货码表的状态
+                        Map<String,String> pickUpCodeMap = new HashMap<>();
+                        pickUpCodeMap.put("orderSn", noti.getOrderSn());
+                        pickUpCodeMap.put("pickUpCodeSn","4");
+                        pickUpCodeService.updatePickUpCode(pickUpCodeMap);
+
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+
                 }
+
+                Map<String, Object> recordMap = ImmutableMap.of("orderSn", noti.getOrderSn(), "paymentSuccTime", new Date(),"isPaymentSend", Contants.WX_SUCC);
+                orderProcessRecordService.updateMallOrderProcessRecord(recordMap);
+                Map<String, Object> alipayMap = ImmutableMap.of("orderSn", noti.getOrderSn(), "buyerPayCheck", noti.getBuyerPayerCheck());
+                orderService.updateBuyerPayCheck(alipayMap);
+
+            }else if(Constants.DocStatus.item_13.getItem().equals(noti.getCusDeclStatus())){
+                Map<String, Object> recordMap = ImmutableMap.of("orderSn", noti.getOrderSn(), "paymentSuccTime", new Date(),"isPaymentSend", Contants.WX_FAIL);
+                orderProcessRecordService.updateMallOrderProcessRecord(recordMap);
+
             }
             noticeList.add(noti);
         });
@@ -117,31 +126,6 @@ public class MerchantNoticeBiz implements CuspayBiz{
         }
     }
 
-    private String createJsonByNoti(MerchNoti noti) {
-        Map<String, String> request = Maps.newHashMap();
-        request.put("merchErpOrderSn",noti.getMerchErpOrderSn());
-        request.put("merchSn", noti.getMerchSn());
-        request.put("allPaySn",noti.getAllPaySn());
-        request.put("allPayNo",noti.getAllPayNo());
-        request.put("allMerchId",noti.getAllMerchId());
-        request.put("allSubOrderNo",noti.getAllSubOrderNo());
-        request.put("buyerPayerCheck",noti.getBuyerPayerCheck());
-        request.put("payChnlFlag",noti.getPayChnlFlag());
-        request.put("code",noti.getCode());
-        request.put("msg",noti.getMsg());
-        request.put("cusDeclStatus", noti.getCusDeclStatus());
-        request.put("thirdPartyMerchCode",noti.getThirdPartyMerchCode());
-        request.put("thirdPartyMerchName",noti.getThirdPartyMerchName());
-        request.put("platNo", noti.getPlatSn());
-        request.put("platName", noti.getPlatName());
-        request.put("merchOrderSn",noti.getAllSubOrderId());
-
-        ResponseMessage responseMessage = new ResponseMessage.Builder()
-                .setCode(ResponseStatus.SUCCESS.getItem())
-                .setData(request).build();
-        return new Gson().toJson(responseMessage);
-    }
-
     public void bizsTest() {
         logger.info("测试定时执行11");
         logger.info("测试定时执行11");

kmall-admin/src/main/java/com/kmall/admin/cuspay/biz/wx/WxCusDeclareBiz.java

@@ -239,6 +239,7 @@ public class WxCusDeclareBiz extends AbstractCusDeclareBiz implements CuspayBiz
         }
 
         MerchNoti merchNoti = new MerchNoti();
+        merchNoti.setOrderSn(params.get("orderSn").toString());
         try {
             wxCbPayDoc.setResultCode(wxResponseMsgDto.getResultCode());
             wxCbPayDoc.setReturnCode(wxResponseMsgDto.getReturnCode());

kmall-admin/src/main/java/com/kmall/admin/cuspay/entity/merch/MerchNoti.java

@@ -63,7 +63,9 @@ public class MerchNoti implements Serializable {
 
     private String allSubOrderId;
 
-    private static final long serialVersionUID = 1L;
+    private String orderSn;
+
+    private static final long serialVersionUID = 164513876943515L;
 
     public MerchNoti() {
         super();
@@ -300,4 +302,12 @@ public class MerchNoti implements Serializable {
     public void setTstm(Date tstm) {
         this.tstm = tstm;
     }
+
+    public String getOrderSn() {
+        return orderSn;
+    }
+
+    public void setOrderSn(String orderSn) {
+        this.orderSn = orderSn;
+    }
 }

kmall-admin/src/main/java/com/kmall/admin/cuspay/task/AliPayCuspayTask.java

@@ -19,5 +19,8 @@ public class AliPayCuspayTask {
 
     @Scheduled(fixedDelay = 5000L)
     public void task() {
+
+        merchantNoticeBiz.biz();
+
     }
 }

kmall-admin/src/main/java/com/kmall/admin/dao/OrderDao.java

@@ -185,4 +185,11 @@ public interface OrderDao extends BaseDao<OrderEntity> {
     void updateOrderStatusByOrderSnList(List<String> orderSnList);
 
     Integer queryObjectByMerchOrderSnHkMall(@Param("merchOrderSn")String merchOrderSn);
+
+    /**
+     * 支付单凭证回传更新 buyer_pay_check
+     * @param wxMap 更新数据
+     * @return      结果
+     */
+    int updateBuyerPayCheck(Map<String, Object> wxMap);
 }

kmall-admin/src/main/java/com/kmall/admin/dao/OrderProcessRecordDao.java

@@ -6,6 +6,7 @@ import com.kmall.manager.dao.BaseDao;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 订单流转过程记录表Dao
@@ -26,4 +27,5 @@ public interface OrderProcessRecordDao extends BaseDao<OrderProcessRecordEntity>
 
     void updateHkNoticeMsgMallOrder(List<OrderProcessRecordHkNewEntity> orderProcessRecordList);
 
+    void updateMallOrderProcessRecord(Map<String, Object> recordMap);
 }

kmall-admin/src/main/java/com/kmall/admin/dao/PickUpCodeDao.java

@@ -6,6 +6,7 @@ import com.kmall.manager.dao.BaseDao;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 小票码信息表Dao
@@ -35,4 +36,6 @@ public interface PickUpCodeDao extends BaseDao<PickUpCodeEntity> {
     void updateHkNoticeMsgPickUpCode(List<OrderProcessRecordHkNewEntity> orderProcessRecordList);
 
     void updatePickUpCodeStatusByOrderSn(@Param("orderSn") String orderSn, @Param("pickUpCodeStatus") String pickUpCodeStatus);
+
+    void updatePickUpCode(Map<String, String> pickUpCodeMap);
 }

kmall-admin/src/main/java/com/kmall/admin/haikong/constant/Constants.java

@@ -19,6 +19,25 @@ public class Constants {
 
     /* --------------------------------------------------redis常量----------------------------------------------- */
 
+
+    /* --------------------------------------------------支付宝常量----------------------------------------------- */
+
+    //响应的是否成功
+    public static final String SUCCESS = "T";
+    public static final String SUCCESS_CODE = "SUCCESS";
+    //失败
+    public static final String FAIL = "F";
+    public static final String FAIL_CODE = "FAIL";
+
+    //支付公司标识:支付宝
+    public static final String ALIPAY = "00";
+    //微信
+    public static final String WECHAT = "10";
+    //工行
+    public static final String ICBC = "20";
+
+    /* --------------------------------------------------支付宝常量----------------------------------------------- */
+
     /**
      * 活动主题枚举
      */
@@ -212,4 +231,38 @@ public class Constants {
 
     }
 
+    /**
+     * 海关申报状态，10:等待海关处理，11:海关申报中，12:海关申报成功，13:海关申报中失败
+     */
+    public enum DocStatus {
+        item_10("10", "等待海关处理"),
+        item_11("11", "海关申报中"),
+        item_12("12", "海关申报成功"),
+        item_13("13", "海关申报中失败");
+
+        private String item;
+        private String itemName;
+
+        DocStatus(String item, String itemName) {
+            this.item = item;
+            this.itemName = itemName;
+        }
+
+        public String getItem() {
+            return item;
+        }
+
+        public void setItem(String item) {
+            this.item = item;
+        }
+
+        public String getItemName() {
+            return itemName;
+        }
+
+        public void setItemName(String itemName) {
+            this.itemName = itemName;
+        }
+    }
+
 }

kmall-admin/src/main/java/com/kmall/admin/service/OrderProcessRecordService.java

@@ -84,4 +84,6 @@ public interface OrderProcessRecordService {
      * @return
      */
     Message saveHkNoticeMsg(List<OrderProcessRecordHkNewEntity> orderProcessRecordList,OutRequestMessage outRequestMessage) throws Exception;
+
+    void updateMallOrderProcessRecord(Map<String, Object> recordMap);
 }

kmall-admin/src/main/java/com/kmall/admin/service/OrderService.java

@@ -236,4 +236,12 @@ public interface OrderService {
     CalculateOrderDiscountPriceResponseVO calculateOrderDiscountPrice(CalculateOrderDiscountPriceVO calculateOrderDiscountPriceVo);
 
     R resendOrderHkMall(String orderSn);
+
+
+    /**
+     * 支付单凭证回传更新 buyer_pay_check
+     * @param wxMap 更新数据
+     * @return      结果
+     */
+    int updateBuyerPayCheck(Map<String, Object> wxMap);
 }

kmall-admin/src/main/java/com/kmall/admin/service/PickUpCodeService.java

@@ -78,4 +78,6 @@ public interface PickUpCodeService {
     public String queryPickUpCodeStatus(String orderSn);
 
     void updatePickUpCodeStatusByOrderSn(String orderSn, String pickUpCodeStatus);
+
+    void updatePickUpCode(Map<String,String> pickUpCodeMap);
 }

kmall-admin/src/main/java/com/kmall/admin/service/impl/OrderProcessRecordServiceImpl.java

@@ -201,4 +201,9 @@ public class OrderProcessRecordServiceImpl implements OrderProcessRecordService
         interfaceSendLogEntity.setResponseDate(new Date());
         interfaceSendLogDao.save(interfaceSendLogEntity);
     }
+
+    @Override
+    public void updateMallOrderProcessRecord(Map<String, Object> recordMap) {
+        orderProcessRecordDao.updateMallOrderProcessRecord(recordMap);
+    }
 }

kmall-admin/src/main/java/com/kmall/admin/service/impl/OrderServiceImpl.java

@@ -2316,6 +2316,7 @@ public class OrderServiceImpl implements OrderService {
                     goodsEntity.setSellVolume(goodsDto.getSellVolume());
                     goodsEntity.setActivity(goodsDto.getActivity());
                     goodsEntity.setStoreId(storeId);
+                    goodsEntity.setListPicUrl(goodsDto.getListPicUrl());
                     goodsEntities.add(goodsEntity);
                 } else {
                     // sku不存在
@@ -2843,6 +2844,7 @@ public class OrderServiceImpl implements OrderService {
             // 组装支付单信息
             Map<String, Object> orderSendCusParams = new HashMap<>();
             orderSendCusParams.put("merchSn", order.getMerchSn());
+            orderSendCusParams.put("orderSn", order.getOrder_sn());
             orderSendCusParams.put("merchName", order.getMerchName());
             orderSendCusParams.put("thirdPartyMerchCode", store.getThirdPartyMerchCode());
             orderSendCusParams.put("thirdPartyMerchName", store.getThirdPartyMerchName());
@@ -2971,6 +2973,7 @@ public class OrderServiceImpl implements OrderService {
             // 组装支付单信息
             Map<String, Object> orderSendCusParams = new HashMap<>();
             orderSendCusParams.put("merchSn", order.getMerchSn());
+            orderSendCusParams.put("orderSn", order.getOrder_sn());
             orderSendCusParams.put("merchName", order.getMerchName());
             orderSendCusParams.put("thirdPartyMerchCode", store.getThirdPartyMerchCode());
             orderSendCusParams.put("thirdPartyMerchName", store.getThirdPartyMerchName());
@@ -4873,7 +4876,6 @@ public class OrderServiceImpl implements OrderService {
             orderGoodsVo.setSettlePrice(settlePrice);//商品结算平摊价格
         }
 
-
         // 计算税费
         GoodsEntity goodsEntity = goodsService.queryObject(goodsDto.getId().intValue());
         BigDecimal goodsTax = CalculateTax.calculateFinalTax(goodsEntity, goodsDto.getStoreRetailPrice(), goodsService).setScale(3, RoundingMode.HALF_UP);
@@ -4883,4 +4885,15 @@ public class OrderServiceImpl implements OrderService {
         return orderGoodsVo;
     }
 
+
+    /**
+     * 支付单凭证回传更新 buyer_pay_check
+     *
+     * @param wxMap 更新数据
+     * @return 结果
+     */
+    @Override
+    public int updateBuyerPayCheck(Map<String, Object> wxMap) {
+        return orderDao.updateBuyerPayCheck(wxMap);
+    }
 }

kmall-admin/src/main/java/com/kmall/admin/service/impl/PickUpCodeServiceImpl.java

@@ -105,4 +105,9 @@ public class PickUpCodeServiceImpl implements PickUpCodeService {
     public void updatePickUpCodeStatusByOrderSn(String orderSn, String pickUpCodeStatus) {
         pickUpCodeDao.updatePickUpCodeStatusByOrderSn(orderSn, pickUpCodeStatus);
     }
+
+    @Override
+    public void updatePickUpCode(Map<String, String> pickUpCodeMap) {
+        pickUpCodeDao.updatePickUpCode(pickUpCodeMap);
+    }
 }

kmall-admin/src/main/resources/mybatis/mapper/OrderDao.xml

@@ -2421,9 +2421,35 @@
             #{item}
         </foreach>
     </update>
+    <update id="updateBuyerPayCheck"></update>
 
     <select id="queryObjectByMerchOrderSnHkMall" parameterType="java.lang.String" resultType="java.lang.Integer">
         select count(*) from mall_order a where merch_order_sn = #{merchOrderSn}
     </select>
 
+    <update id="updateBuyerPayCheck" parameterType="hashMap">
+        update mall_order
+        <set >
+            <if test="buyerPayCheck != null">
+                buyer_pay_check = #{buyerPayCheck},
+            </if>
+            <if test="orderStatus != null">
+                order_status = #{orderStatus},
+            </if>
+            <if test="shippingNo != null">
+                shipping_no = #{shippingNo},
+            </if>
+            <if test="shippingCode != null">
+                shipping_code = #{shippingCode},
+            </if>
+            <if test="shippingName != null">
+                shipping_name = #{shippingName},
+            </if>
+            <if test="shippingStatus != null">
+                shipping_status = #{shippingStatus},
+            </if>
+        </set>
+        where order_sn = #{orderSn,jdbcType=VARCHAR}
+    </update>
+
 </mapper>

kmall-admin/src/main/resources/mybatis/mapper/OrderProcessRecordDao.xml

@@ -480,4 +480,55 @@ select
 		</foreach>
 	</update>
 
+	<update id="updateMallOrderProcessRecord" parameterType="hashMap">
+		update mall_order_process_record
+		<set >
+			<if test="paymentStartTime != null">
+				payment_start_time = #{paymentStartTime},
+			</if>
+			<if test="paymentSuccTime != null">
+				payment_succ_time = #{paymentSuccTime}, </if>
+			<if test="isPaymentSend != null" >
+				is_payment_send = #{isPaymentSend,jdbcType=VARCHAR},
+			</if>
+			<if test="eleOrderStartTime != null" >
+				ele_order_start_time = #{eleOrderStartTime,jdbcType=VARCHAR},
+			</if>
+			<if test="eleOrderSuccTime != null" >
+				ele_order_succ_time = #{eleOrderSuccTime,jdbcType=VARCHAR},
+			</if>
+			<if test="isEleOrderSend != null" >
+				is_ele_order_send = #{isEleOrderSend,jdbcType=VARCHAR},
+			</if>
+			<if test="waybillStartTime != null" >
+				waybill_start_time = #{waybillStartTime,jdbcType=VARCHAR},
+			</if>
+			<if test="waybillSuccTime != null" >
+				waybill_succ_time = #{waybillSuccTime,jdbcType=VARCHAR},
+			</if>
+			<if test="customsStartTime != null" >
+				customs_start_time = #{customsStartTime,jdbcType=VARCHAR},
+			</if>
+			<if test="customsSuccTime != null" >
+				customs_succ_time = #{customsSuccTime,jdbcType=VARCHAR},
+			</if>
+			<if test="isCustomsSend != null" >
+				is_customs_send = #{isCustomsSend,jdbcType=TIMESTAMP},
+			</if>
+			<if test="shipmentStartTime != null" >
+				shipment_start_time = #{shipmentStartTime,jdbcType=VARCHAR},
+			</if>
+			<if test="shipmentSuccTime != null" >
+				shipment_succ_time = #{shipmentSuccTime,jdbcType=VARCHAR},
+			</if>
+			<if test="logisticsNo != null">
+				logistics_no = #{logisticsNo},
+			</if>
+			<if test="invtNo != null">
+				invt_no = #{invtNo},
+			</if>
+		</set>
+		where order_sn = #{orderSn,jdbcType=VARCHAR}
+	</update>
+
 </mapper>

kmall-admin/src/main/resources/mybatis/mapper/PickUpCodeDao.xml

@@ -197,5 +197,14 @@
 		where order_sn = #{orderSn}
 	</update>
 
+	<update id="updatePickUpCode" parameterType="hashMap">
+		update mall_pick_up_code
+		<set>
+			<if test="pickUpCodeSn != null">
+				pick_up_code_status = #{pickUpCodeSn}
+			</if>
+		</set>
+		where order_sn = #{orderSn}
+	</update>
 
 </mapper>

kmall-admin/src/main/resources/mybatis/mapper/cuspay/MerchNotiMapper.xml

@@ -31,12 +31,13 @@
     <result column="moder_sn" property="moderSn" jdbcType="VARCHAR" />
     <result column="mod_time" property="modTime" jdbcType="VARCHAR" />
     <result column="tstm" property="tstm" jdbcType="TIMESTAMP" />
+    <result column="order_sn" property="orderSn" jdbcType="VARCHAR" />
   </resultMap>
   <sql id="Base_Column_List" >
     noti_sn, all_pay_sn, merch_sn, merch_name, merch_erp_order_sn, plat_sn, plat_name,
     third_party_merch_code, third_party_merch_name, all_merch_id, all_order_no, all_pay_no,
     all_sub_order_no, all_sub_order_id, pay_chnl_flag, buyer_payer_check, noti_count, is_stoped, cus_decl_status,
-    noti_statue, code, msg, notify_url, remark, creater_sn, create_time, moder_sn, mod_time,
+    noti_statue, code, msg, notify_url, remark, creater_sn, create_time, moder_sn, mod_time, order_sn,
     tstm
   </sql>
   <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.String" >
@@ -150,6 +151,9 @@
       <if test="tstm != null" >
         tstm,
       </if>
+      <if test="orderSn != null" >
+        order_sn,
+      </if>
     </trim>
     <trim prefix="values (" suffix=")" suffixOverrides="," >
       <if test="notiSn != null" >
@@ -239,6 +243,9 @@
       <if test="tstm != null" >
         #{tstm,jdbcType=TIMESTAMP},
       </if>
+      <if test="orderSn != null" >
+        #{orderSn,jdbcType=VARCHAR},
+      </if>
     </trim>
   </insert>
   <update id="updateByPrimaryKeySelective" parameterType="com.kmall.admin.cuspay.entity.merch.MerchNoti" >
@@ -328,6 +335,9 @@
       <if test="tstm != null" >
         tstm = #{tstm,jdbcType=TIMESTAMP},
       </if>
+      <if test="orderSn != null" >
+        order_sn = #{orderSn,jdbcType=VARCHAR},
+      </if>
     </set>
     where noti_sn = #{notiSn,jdbcType=VARCHAR}
   </update>
@@ -368,7 +378,8 @@
         creater_sn,
         create_time,
         moder_sn,
-        mod_time
+        mod_time,
+        order_sn
     </trim>
     VALUES
     <foreach collection="list" item="item" index="index" separator=",">
@@ -401,6 +412,7 @@
           #{item.createTime,jdbcType=VARCHAR},
           #{item.moderSn,jdbcType=VARCHAR},
           #{item.modTime,jdbcType=VARCHAR},
+          #{item.orderSn,jdbcType=VARCHAR},
       </trim>
     </foreach>
   </insert>
@@ -492,6 +504,9 @@
         <if test="item.tstm != null" >
           tstm = #{item.tstm,jdbcType=TIMESTAMP},
         </if>
+        <if test="item.orderSn != null" >
+          order_sn = #{item.orderSn,jdbcType=VARCHAR},
+        </if>
       </set>
       where noti_sn = #{item.notiSn,jdbcType=VARCHAR}
     </foreach>