记得上下班打卡 | git大法好,push需谨慎

Commit 9c78ae88 authored by GaoHu's avatar GaoHu

Merge branch 'master' into gaohu-smile-0915-three

parents 238d43ed 2cf46df7
...@@ -31,11 +31,11 @@ public class SmileRedisUtils { ...@@ -31,11 +31,11 @@ public class SmileRedisUtils {
public AbstractRedisUtil getRedis() { public AbstractRedisUtil getRedis() {
return redisDataSourceUtil.getRedisSweetUtil(); return redisDataSourceUtil.getRedisKylinUtil();
} }
public Object get(String key){ public Object get(String key){
return redisDataSourceUtil.getRedisSweetUtil().get(key); return redisDataSourceUtil.getRedisKylinUtil().get(key);
} }
/** /**
......
...@@ -54,7 +54,7 @@ ...@@ -54,7 +54,7 @@
<include refid="Rst_CommonCouponBasicDto_Column_List"/> <include refid="Rst_CommonCouponBasicDto_Column_List"/>
FROM candy_common_coupon ccc FROM candy_common_coupon ccc
LEFT JOIN candy_coupon cc ON ccc.coupon_id = cc.coupon_id LEFT JOIN candy_coupon cc ON ccc.coupon_id = cc.coupon_id
WHERE ccc.state <![CDATA[<>]]> 2 WHERE ccc.state in (1,3)
AND ccc.created_at <![CDATA[>=]]> #{ucreatedAt,jdbcType=TIMESTAMP} AND ccc.created_at <![CDATA[>=]]> #{ucreatedAt,jdbcType=TIMESTAMP}
</select> </select>
</mapper> </mapper>
...@@ -56,7 +56,7 @@ ...@@ -56,7 +56,7 @@
<include refid="Rst_UserCouponBasicDto_Column_List"/> <include refid="Rst_UserCouponBasicDto_Column_List"/>
FROM candy_user_coupon cuc FROM candy_user_coupon cuc
LEFT JOIN candy_coupon cc ON cuc.coupon_id = cc.coupon_id LEFT JOIN candy_coupon cc ON cuc.coupon_id = cc.coupon_id
WHERE cuc.state <![CDATA[<>]]> 2 WHERE cuc.state in (1,3,5)
AND cuc.uid = #{uid,jdbcType=VARCHAR} AND cuc.uid = #{uid,jdbcType=VARCHAR}
</select> </select>
</mapper> </mapper>
...@@ -45,7 +45,7 @@ public class PlatformCandyCommonCouponService extends ServiceImpl<CandyCommonCou ...@@ -45,7 +45,7 @@ public class PlatformCandyCommonCouponService extends ServiceImpl<CandyCommonCou
int totalCount = this.count(commonCouponQueryWrapper); int totalCount = this.count(commonCouponQueryWrapper);
int remainCount = totalCount, pSize = 1000; int remainCount = totalCount, pSize = 1000;
if (totalCount > 0) { if (totalCount > 0) {
log.info("券移除处理:公有券[总数:{},AT:{} - {} = {}] >>> BEGIN BEGIN BEGIN", totalCount, currentDateTime, displayDays, currentDateTime.minusDays(displayDays)); log.info("券移除处理:公有券[总数:{},AT:{} - {} = {}] >>> BEGIN BEGIN BEGIN", totalCount, currentDateTime, displayDays, currentDateTime.minusSeconds(displayDays));
} }
ArrayList<CandyCommonCoupon> updateCommonCouponList = ObjectUtil.getCandyCommonCouponArrayList(); ArrayList<CandyCommonCoupon> updateCommonCouponList = ObjectUtil.getCandyCommonCouponArrayList();
......
...@@ -141,7 +141,7 @@ public class PlatformCandyUserCouponService extends ServiceImpl<CandyUserCouponM ...@@ -141,7 +141,7 @@ public class PlatformCandyUserCouponService extends ServiceImpl<CandyUserCouponM
int totalCount = this.count(userCouponQueryWrapper); int totalCount = this.count(userCouponQueryWrapper);
int remainCount = totalCount, pSize = 1000; int remainCount = totalCount, pSize = 1000;
if (totalCount > 0) { if (totalCount > 0) {
log.info("券移除处理:私有券[总数:{},AT:{} - {} = {}] >>> BEGIN BEGIN BEGIN", totalCount, currentDateTime, displayDays, currentDateTime.minusDays(displayDays)); log.info("券移除处理:私有券[总数:{},AT:{} - {} = {}] >>> BEGIN BEGIN BEGIN", totalCount, currentDateTime, displayDays, currentDateTime.minusSeconds(displayDays));
} }
ArrayList<CandyUserCoupon> updateUserCouponList = ObjectUtil.getCandyUserCouponArrayList(); ArrayList<CandyUserCoupon> updateUserCouponList = ObjectUtil.getCandyUserCouponArrayList();
......
...@@ -79,7 +79,7 @@ public class SellDataInfoImpl { ...@@ -79,7 +79,7 @@ public class SellDataInfoImpl {
String performanceId=a.get("yanchuId")==null?"":a.get("yanchuId").toString(); String performanceId=a.get("yanchuId")==null?"":a.get("yanchuId").toString();
String yanChuName=a.get("title")==null?"":a.get("title").toString(); String yanChuName=a.get("title")==null?"":a.get("title").toString();
//判断是否 已经跑过一遍了 //判断是否 已经跑过一遍了
if(redisDataSourceUtil.getRedisSweetUtil().hasKey(SmileRedisConst.SELL_SHOW_PAYMENT_ENDJOB.concat(performanceId).concat(smileUser.getUid()))){ if(redisDataSourceUtil.getRedisKylinUtil().hasKey(SmileRedisConst.SELL_SHOW_PAYMENT_ENDJOB.concat(performanceId).concat(smileUser.getUid()))){
continue; continue;
} }
//获取 该人 该演出 的所有订单 //获取 该人 该演出 的所有订单
...@@ -121,7 +121,7 @@ public class SellDataInfoImpl { ...@@ -121,7 +121,7 @@ public class SellDataInfoImpl {
smileSellDataVO.setSellDataOneVO(listSellDataOneVo); smileSellDataVO.setSellDataOneVO(listSellDataOneVo);
smileSellDataVO.setUpdateTime(LocalDateTime.now()); smileSellDataVO.setUpdateTime(LocalDateTime.now());
//redis 里面放入 //redis 里面放入
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_DATA.concat(smileUser.getUid()).concat(performanceId), smileSellDataVO); redisDataSourceUtil.getRedisKylinUtil().set(SmileRedisConst.SELL_DATA.concat(smileUser.getUid()).concat(performanceId), smileSellDataVO);
Query query = Query.query(Criteria.where("sellDataId").is(smileSellDataVO.getSellDataId())); Query query = Query.query(Criteria.where("sellDataId").is(smileSellDataVO.getSellDataId()));
Document document = (Document)mongoConverter.convertToMongoType(smileSellDataVO); Document document = (Document)mongoConverter.convertToMongoType(smileSellDataVO);
Update update = Update.fromDocument(document); Update update = Update.fromDocument(document);
...@@ -133,8 +133,8 @@ public class SellDataInfoImpl { ...@@ -133,8 +133,8 @@ public class SellDataInfoImpl {
//mongodb 里面放入 //mongodb 里面放入
mongoTemplate.insert(smileSellDataVO, SmileSellDataVO.class.getSimpleName());*/ mongoTemplate.insert(smileSellDataVO, SmileSellDataVO.class.getSimpleName());*/
} }
if(redisDataSourceUtil.getRedisSweetUtil().hasKey(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performanceId).concat(smileUser.getUid()))){ if(redisDataSourceUtil.getRedisKylinUtil().hasKey(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performanceId).concat(smileUser.getUid()))){
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_SHOW_PAYMENT_ENDJOB.concat(performanceId).concat(smileUser.getUid()),"1"); redisDataSourceUtil.getRedisKylinUtil().set(SmileRedisConst.SELL_SHOW_PAYMENT_ENDJOB.concat(performanceId).concat(smileUser.getUid()),"1");
} }
} }
...@@ -178,7 +178,7 @@ public class SellDataInfoImpl { ...@@ -178,7 +178,7 @@ public class SellDataInfoImpl {
for(Map a: userPerformanceList){ for(Map a: userPerformanceList){
//取出id 查看是否结算 //取出id 查看是否结算
String performanceId= a.get("performanceId")==null?"":a.get("performanceId").toString(); String performanceId= a.get("performanceId")==null?"":a.get("performanceId").toString();
if(redisDataSourceUtil.getRedisSweetUtil().hasKey(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performanceId).concat(smileUser.getUid()))){ if(redisDataSourceUtil.getRedisKylinUtil().hasKey(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performanceId).concat(smileUser.getUid()))){
//已结算(已完成) //已结算(已完成)
a.put("status","3"); a.put("status","3");
}else{ }else{
...@@ -202,7 +202,7 @@ public class SellDataInfoImpl { ...@@ -202,7 +202,7 @@ public class SellDataInfoImpl {
//待入账 //待入账
commissionVO.setDaiRuZhang(daiRuZhang); commissionVO.setDaiRuZhang(daiRuZhang);
commissionVO.setKeJieSuan(keJieSuan); commissionVO.setKeJieSuan(keJieSuan);
commissionVO.setZongYingShou((BigDecimal) redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SELL_USER_REVENUE.concat(smileUser.getUid()))); commissionVO.setZongYingShou((BigDecimal) redisDataSourceUtil.getRedisKylinUtil().get(SmileRedisConst.SELL_USER_REVENUE.concat(smileUser.getUid())));
redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_DATA_COMMISSION.concat(smileUser.getUid()),commissionVO); redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_DATA_COMMISSION.concat(smileUser.getUid()),commissionVO);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment