fix

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

@@ -65,6 +65,7 @@ public class CertificationController {
             ApiResult<UserInfo> apiResult = ApiResult.createSuccess(userInfo);
             LOG.info("调用获取用户信息(/certification/getUserInfo)接口成功");
             LOG.debug("调用获取用户信息(/certification/getUserInfo), apiResult:{}", apiResult);
+
             return apiResult;
         } catch (Exception e) {
             LOG.error("调用获取用户信息(/certification/getUserInfo)接口异常", e);
@@ -373,6 +374,14 @@ public class CertificationController {
             LOG.info("apiResult="+apiResult);
             LOG.info("调用保存实名认证信息(/certification/saveUserInfo)接口成功");
             LOG.debug("调用保存实名认证信息(/certification/saveUserInfo), apiResult:{}", apiResult);
+
+
+            //icegan--新增，认证成功则增加销售用户1000积分
+            if(status.equals("2")){
+                LOG.info("实名认证成功，为销售员，增加1000积分");
+                saleService.addIntegral(openId,1000);
+            }
+
             return apiResult;
         } catch (Exception e) {
             LOG.error("调用保存实名认证信息(/certification/saveUserInfo)接口异常", e);

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

@@ -2,6 +2,7 @@ package com.demo.wjj.controller;
 
 import com.demo.wjj.converter.UserRegisterConverter;
 import com.demo.wjj.qo.UserRegisterQo;
+import com.demo.wjj.service.SaleService;
 import com.demo.wjj.service.UserService;
 import com.demo.wjj.utils.ApiResult;
 import com.demo.wjj.utils.EmojiFilterUtil;
@@ -45,6 +46,8 @@ public class UserController {
     private UserRegisterQoValidator userRegisterQoValidator;
     @Autowired
     private UserRegisterConverter userRegisterConverter;
+    @Autowired
+    private SaleService saleService;//icegan--新增
 
     /**
      * 精品机账号
@@ -103,6 +106,12 @@ public class UserController {
                 apiResult = executeResult.getData() ? ApiResult.createSuccess(null) : ApiResult.createFailure();
             }
             LOG.info("调用用户注册(/user/register)接口成功, apiResult => {}", apiResult);
+
+            //icegan--新增，认证成功则增加销售用户1000积分
+            if(apiResult.getCode().equals(Result.SUCCESS.getCode())){
+                LOG.info("实名认证成功，为销售员，增加1000积分");
+                saleService.addIntegral(userRegisterQo.getOpenId(),1000);
+            }
             return apiResult;
         } catch (Exception e) {
             LOG.error("调用用户注册(/user/register)接口异常, userRegisterQo:{}", userRegisterQo, e);

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

@@ -65,4 +65,21 @@ public interface SaleMapper {
      * @return
      */
     int updateOpenId(@Param("agentId") String agentId,@Param("mobile") String mobile,@Param("openId") String openId);
+
+    /**
+     * icegan--新增，更新销售员会员等级
+     * @param agentId
+     * @param openId
+     * @param memberLevel
+     * @return
+     */
+    int updateMemberLevel(@Param("agentId") String agentId, @Param("openId") String openId, @Param("memberLevel") Integer memberLevel);
+
+    /**
+     * icegan--新增，更新销售员积分
+     * @param openId
+     * @param integral
+     * @return
+     */
+    int updateIntegral(@Param("openId") String openId, @Param("memberLevel") Integer integral);
 }

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

@@ -65,4 +65,21 @@ public interface SaleService {
      * @return
      */
     boolean updateOpenId(String agentId,String mobile,String openId);
+
+    /**
+     * icegan--新增，更新销售员会员等级
+     * @param agentId
+     * @param mobile
+     * @param memberLevel
+     * @return
+     */
+    boolean updateMemberLevel(String agentId, String mobile, Integer memberLevel);
+
+    /**
+     * icegan--新增，更新销售员积分
+     * @param openId
+     * @param integral
+     * @return
+     */
+    boolean addIntegral(String openId, Integer integral);
 }

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

@@ -133,4 +133,18 @@ public class SaleServiceImpl implements SaleService {
     public boolean updateOpenId(String agentId, String mobile, String openId) {
         return saleMapper.updateOpenId(agentId,mobile,openId)>0;
     }
+
+    @Override
+    public boolean updateMemberLevel(String agentId, String mobile, Integer memberLevel) {
+        LOG.info("进入更新销售员会员等级, agentId:{}, mobile:{},memberLevel:{}", agentId, mobile,memberLevel);
+        return saleMapper.updateMemberLevel(agentId, mobile, memberLevel)>0;
+    }
+
+    @Override
+    public boolean addIntegral(String openId, Integer integral) {
+        LOG.info("进入更新销售员会员积分, openId:{}, integral:{}", openId,integral);
+        return saleMapper.updateIntegral(openId,integral)>0;
+    }
+
+
 }

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

@@ -37,11 +37,16 @@
         <result column="sale_phone" property="salePhone"/>
         <result column="sale_wxnc" property="saleWxnc"/>
         <result column="wx_openid" property="wxOpenId"/>
+        <result column="member_level" property="memberLevel"/>
+        <result column="integral" property="integral"/>
+        <result column="plat_tp_set" property="integral"/>
+        <result column="deposit" property="deposit"/>
+
     </resultMap>
 
     <!--查询销售员-->
     <select id="selectSale" resultMap="sale">
-        SELECT s.id, s.agent_id, s.agent_name, s.sale_id, s.sale_name, s.sale_phone, s.sale_wxnc
+        SELECT s.id, s.agent_id, s.agent_name, s.sale_id, s.sale_name, s.sale_phone, s.sale_wxnc,s.member_level,s.integral,s.plat_tp_set,s.deposit
         FROM tb_sales s
         WHERE s.regeister_status = '1' AND s.agent_opt = '1' AND s.agent_id = #{agentId} AND s.wx_openId = #{openId}
     </select>
@@ -55,4 +60,14 @@
         update tb_sales set wx_openId = #{openId}
         where agent_id = #{agnetId} and sale_phone = #{mobile}
     </update>
+
+    <update id="updateMemberLevel">
+        update tb_sales set member_level = #{memberLevel}
+        where agent_id = #{agnetId} and sale_phone = #{mobile}
+    </update>
+
+    <update id="updateIntegral">
+        update tb_sales set integral = integral+#{integral}
+        where wx_openid = #{openId}
+    </update>
 </mapper>