1.领优惠券逻辑

2.来源(未完成)

src/main/java/com/bsd/say/controller/WechatController.java

@@ -135,25 +135,8 @@ public class WechatController {
 
     @RequestMapping("test")
     public void test(){
-        JedisPool pool = new JedisPool();
-        RedisProperies redisProperies = new RedisProperies();
-        if (pool == null) {
-            synchronized (WxOpenServiceDemo.class) {
-                if (pool == null) {
-                    pool = new JedisPool(redisProperies, redisProperies.getHost(),
-                            redisProperies.getPort(), redisProperies.getConnectionTimeout(),
-                            redisProperies.getSoTimeout(), redisProperies.getPassword(),
-                            redisProperies.getDatabase(), redisProperies.getClientName(),
-                            redisProperies.isSsl(), redisProperies.getSslSocketFactory(),
-                            redisProperies.getSslParameters(), redisProperies.getHostnameVerifier());
-                }
-            }
-        }
-        Jedis jedis = null;
-        RedisProperies properies = new RedisProperies();
-
-        jedis = pool.getResource();
-        System.out.println(jedis.get("wechat_component_verify_ticket:wx474350bcaea2d745"));
+//        Object o = redisTemplate.opsForValue().getOperations();
+        weixinService.refreshComponentAccessToken();
     }
 
 }

src/main/java/com/bsd/say/entities/Record.java

@@ -10,8 +10,6 @@ import lombok.Data;
 @Data
 public class Record extends BaseEntity{
 
-    private Long id;
-
     private String source;
 
     private String openId;

src/main/java/com/bsd/say/entities/Source.java

@@ -0,0 +1,18 @@
+package com.bsd.say.entities;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+@TableName("source")
+@Data
+public class Source extends BaseEntity{
+
+    private String sourceName;
+
+    private String url;
+
+    private String qrCode;
+
+    private String postCode;
+
+}

src/main/java/com/bsd/say/mapper/SourceMapper.java

@@ -0,0 +1,11 @@
+package com.bsd.say.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.bsd.say.entities.Source;
+import com.bsd.say.entities.Users;
+import org.springframework.stereotype.Repository;
+
+@Repository("sourceMapper")
+public interface SourceMapper extends BaseMapper<Source> {
+
+}

src/main/java/com/bsd/say/service/SourceService.java

@@ -0,0 +1,6 @@
+package com.bsd.say.service;
+
+import com.bsd.say.entities.Source;
+
+public interface SourceService extends BaseService<Source> {
+}

src/main/java/com/bsd/say/service/impl/CouponServiceImpl.java

@@ -23,6 +23,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import javax.annotation.Resource;
 import java.io.IOException;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
@@ -116,13 +117,37 @@ public class CouponServiceImpl extends BaseServiceImpl<CouponMapper, Coupon> imp
                         }
                     }else {
                         //来源微信
-                        String unionId = weixinService.getUnionId(code);
+                        String unionId = "456";
                         logger.info("union_id:"+unionId);
                         users = usersMapper.selectOne(Wrappers.<Users>lambdaQuery().eq(Users::getUnionId,unionId)
                                 .and(queryWrapper1 -> queryWrapper1.eq(Users::getState,1)));
-                        //防非法请求,再校验一遍
-                        List<Coupon> coupons = couponMapper.selectList(Wrappers.<Coupon>lambdaQuery().eq(Coupon::getUserId,users.getId())
+                        List<Coupon> coupons ;
+                        if (users == null){
+                            Users usersByPhone = usersMapper.selectOne(Wrappers.<Users>lambdaQuery().eq(Users::getPhone,phone)
+                                    .and(queryWrapper1 -> queryWrapper1.eq(Users::getState,1)));
+                            //防止先第三方领券，再微信端领券
+                            if (usersByPhone == null){
+                                Users users1 = new Users();
+                                users1.setPhone(phone);
+                                users1.setUnionId(unionId);
+                                users1.setUserType(1);
+                                users1.setCreateDateTime(new Date());
+                                users1.setUpdateDateTime(new Date());
+                                usersMapper.insert(users1);
+                                coupons = couponMapper.selectList(Wrappers.<Coupon>lambdaQuery().eq(Coupon::getUserId,users1.getId())
+                                        .and(queryWrapper1 -> queryWrapper1.eq(Coupon::getState,1)));
+                            }else{
+                                usersByPhone.setUnionId(unionId);
+                                usersByPhone.setUpdateDateTime(new Date());
+                                usersMapper.updateById(usersByPhone);
+                                coupons = couponMapper.selectList(Wrappers.<Coupon>lambdaQuery().eq(Coupon::getUserId,usersByPhone.getId())
                                         .and(queryWrapper1 -> queryWrapper1.eq(Coupon::getState,1)));
+                            }
+                        }else {
+                            coupons = couponMapper.selectList(Wrappers.<Coupon>lambdaQuery().eq(Coupon::getUserId,users.getId())
+                                    .and(queryWrapper1 -> queryWrapper1.eq(Coupon::getState,1)));
+                        }
+                        //防非法请求,再校验一遍
                         if (coupons.size() > 0){
                             ajaxResult.setRetmsg("非法请求，已经领过");
                             ajaxResult.setRetcode(AjaxResult.FAILED);
@@ -131,8 +156,6 @@ public class CouponServiceImpl extends BaseServiceImpl<CouponMapper, Coupon> imp
                         }
                     }
                 }
-
-
                 if (noteCode.equals(redisTemplate.opsForValue().get(phone))){
                     String token = MD5Utils.md5(tokenkey+df.format(new Date()));
                     //验证成功，领券

src/main/java/com/bsd/say/service/impl/LoveLetterServiceImpl.java

@@ -6,8 +6,10 @@ import com.bsd.say.beans.AjaxRequest;
 import com.bsd.say.beans.AjaxResult;
 import com.bsd.say.entities.LoveLetter;
 import com.bsd.say.entities.Record;
+import com.bsd.say.entities.Users;
 import com.bsd.say.mapper.LoveLetterMapper;
 import com.bsd.say.mapper.RecordMapper;
+import com.bsd.say.mapper.UsersMapper;
 import com.bsd.say.service.LoveLetterService;
 import com.bsd.say.util.HttpRequestUtils;
 import com.bsd.say.util.LogUtils;
@@ -33,6 +35,8 @@ public class LoveLetterServiceImpl extends BaseServiceImpl<LoveLetterMapper, Lov
     private RecordMapper recordMapper;
     @Autowired
     private WeixinService weixinService;
+    @Autowired
+    private UsersMapper usersMapper;
     @Override
     public LoveLetterMapper getBaseMapper() {
         return this.loveLetterMapper;
@@ -95,11 +99,6 @@ public class LoveLetterServiceImpl extends BaseServiceImpl<LoveLetterMapper, Lov
                 recordMapper.updateById(record);
             }else {
                 //非微信端来源，待确认
-
-
-
-
-
             }
         }
         ajaxResult.setRetcode(AjaxResult.SUCCESS);
@@ -173,8 +172,6 @@ public class LoveLetterServiceImpl extends BaseServiceImpl<LoveLetterMapper, Lov
             }else {
                 //非微信端待确认。。。
 
-
-
             }
         }
         return ajaxResult;

src/main/java/com/bsd/say/service/impl/SourceServiceImpl.java

@@ -0,0 +1,12 @@
+package com.bsd.say.service.impl;
+
+import com.bsd.say.entities.Source;
+import com.bsd.say.mapper.SourceMapper;
+import com.bsd.say.service.SourceService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service("sourceService")
+@Transactional
+public class SourceServiceImpl extends BaseServiceImpl<SourceMapper,Source> implements SourceService {
+}