提交

jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiservice/impl/IndexApiServiceImpl.java

@@ -0,0 +1,315 @@
+package org.jeecg.modules.apiservice.impl;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
+import org.apache.commons.lang.StringUtils;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.util.RedisUtil;
+import org.jeecg.config.shiro.ShiroRealm;
+import org.jeecg.modules.apiBean.ActorSetPageBean;
+import org.jeecg.modules.apiBean.TrendsBean;
+import org.jeecg.modules.apiUtils.printUtil;
+import org.jeecg.modules.apiservice.IndexApiService;
+import org.jeecg.modules.atActorCollection.entity.AtActorCollection;
+import org.jeecg.modules.atActorCollection.service.IAtActorCollectionService;
+import org.jeecg.modules.atComplaintReason.entity.AtComplaintReason;
+import org.jeecg.modules.atComplaintReason.service.IAtComplaintReasonService;
+import org.jeecg.modules.atMasterPiece.entity.AtMasterPiece;
+import org.jeecg.modules.atMasterPiece.service.IAtMasterPieceService;
+import org.jeecg.modules.atPerformer.entity.AtPerformer;
+import org.jeecg.modules.atPerformer.service.IAtPerformerService;
+import org.jeecg.modules.atPhoneOrder.entity.AtPhoneOrder;
+import org.jeecg.modules.atPhoneOrder.service.IAtPhoneOrderService;
+import org.jeecg.modules.atPromotion.service.IAtPromotionService;
+import org.jeecg.modules.atThumbsLog.entity.AtThumbsLog;
+import org.jeecg.modules.atThumbsLog.service.IAtThumbsLogService;
+import org.jeecg.modules.atTopPrice.service.IAtTopPriceService;
+import org.jeecg.modules.atTrends.entity.AtTrends;
+import org.jeecg.modules.atTrends.service.IAtTrendsService;
+import org.jeecg.modules.bean.WaterPageBean;
+import org.jeecg.modules.hanHaiBanner.entity.HanHaiBanner;
+import org.jeecg.modules.hanHaiBanner.service.IHanHaiBannerService;
+import org.jeecg.modules.hanHaiMember.entity.HanHaiMember;
+import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService;
+import org.jeecg.modules.pay.MpWxPayService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class IndexApiServiceImpl implements IndexApiService {
+
+    //缓存记录
+    @Resource
+    private RedisUtil redisUtil;
+    //权限验证
+    @Resource
+    private ShiroRealm shiroRealm;
+    //获取个人信息接口
+    @Resource
+    private IHanHaiMemberService hanHaiMemberService;
+    //获取banner信息
+    @Resource
+    private IHanHaiBannerService hanHaiBannerService;
+    //获取认证演员信息
+    @Resource
+    private IAtPerformerService performerService;
+    //获取认证演员集
+    @Resource
+    private IAtPromotionService promotionService;
+    //获取动态信息表
+    @Resource
+    private IAtTrendsService atTrendsService;
+    //获取代表作品
+    @Resource
+    private IAtMasterPieceService atMasterPieceService;
+    //获取投诉原因信息
+    @Resource
+    private IAtComplaintReasonService atComplaintReasonService;
+    //获取演员集
+    @Resource
+    private IAtActorCollectionService atActorCollectionService;
+    //支付接口
+    @Autowired
+    private MpWxPayService mpWxPayService;
+    //获取置顶
+    @Resource
+    private IAtTopPriceService atTopPriceService;
+    //点赞
+    @Resource
+    private IAtThumbsLogService atThumbsLogService;
+    //付费记录
+    @Resource
+    private IAtPhoneOrderService atPhoneOrderService;
+
+
+
+
+
+    // 获取banner列表
+    @Override
+    public Result<?> getBanner(){
+        List<HanHaiBanner> list = hanHaiBannerService.list();
+        return Result.OK("轮播图列表",list);
+    }
+    //获取认证演员
+    @Override
+    public Result<?> getActorList(){
+        List<AtPerformer> list = performerService
+                .lambdaQuery()
+                .orderByDesc(AtPerformer::getCreateTime)
+                .list();
+        //创建一个新的集合
+        List<AtPerformer> newList = new ArrayList<>();
+        for (AtPerformer performer:list) {
+            performer.setUserId(hanHaiMemberService
+                    .lambdaQuery()
+                    .eq(HanHaiMember::getId,performer.getUserId()).one().getNickName());
+            newList.add(performer);
+        }
+        return Result.OK("认证演员列表",newList);
+    }
+
+    // 获取动态列表带分页
+    @Override
+    public Result<?> getTrendsPage(TrendsBean bean){
+        Page<AtTrends> page = new Page<AtTrends>(bean.getPageNo(), bean.getPageSize());
+        Page<AtTrends> pageList = atTrendsService
+                .lambdaQuery()
+                .orderByDesc(AtTrends::getCreateTime)
+                .orderByDesc(AtTrends::getIsTop)
+                .page(page);
+        if(StringUtils.isNotBlank(bean.getTitle())){
+            pageList = atTrendsService
+                    .lambdaQuery()
+                    .like(AtTrends::getTitle,bean.getTitle())
+                    .orderByDesc(AtTrends::getCreateTime)
+                    .orderByDesc(AtTrends::getIsTop)
+                    .page(page);
+        }
+
+
+
+        List<AtTrends> records = pageList.getRecords();
+        //创建一个新的集合
+        List<AtTrends> recordsNew = new ArrayList<>();
+        for (AtTrends atTrends:records) {
+            atTrends.setUserId(hanHaiMemberService
+                    .lambdaQuery()
+                    .eq(HanHaiMember::getId,atTrends.getUserId()).one().getNickName());
+            recordsNew.add(atTrends);
+        }
+        pageList.setRecords(recordsNew);
+        return Result.OK("动态列表", pageList);
+    }
+
+    //获取动态详情
+    @Override
+    public Result<?> getTrendsDetail(String id,String token){
+        AtTrends byId = atTrendsService.getById(id);
+        //根据用户标识查询发布人信息
+        HanHaiMember byId1 = hanHaiMemberService.getById(byId.getUserId());
+        byId.setUserId(byId1.getNickName());
+
+        Map<String,Object> map = new HashMap<>();
+        //作品0/演员1/动态2
+        if (StringUtils.isNotBlank(token)){
+            HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+            AtThumbsLog one = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                    .eq(AtThumbsLog::getType, "2")
+                    .eq(AtThumbsLog::getIsState, "0")
+                    .one();
+            map.put("isThumbs_up", one);
+            AtThumbsLog one2 = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                    .eq(AtThumbsLog::getType, "2")
+                    .eq(AtThumbsLog::getIsState, "1")
+                    .one();
+            map.put("isThumbs_down", one2);
+
+        }
+        map.put("dayMoney",1000);
+        map.put("details", byId);
+        return Result.OK("动态详情", map);
+    }
+
+    //获取代表作品带分页
+    @Override
+    public Result<?> getWorkPage(WaterPageBean bean){
+        Page<AtMasterPiece> page = new Page<AtMasterPiece>(bean.getPageNo(), bean.getPageSize());
+        Page<AtMasterPiece> pageList = atMasterPieceService
+                .lambdaQuery()
+                .orderByDesc(AtMasterPiece::getNum)
+                .page(page);
+
+
+        List<AtMasterPiece> records = pageList.getRecords();
+        List<AtMasterPiece> recordsNew = new ArrayList<>();
+        for (AtMasterPiece atMasterPiece:records) {
+            AtThumbsLog one = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, atMasterPiece.getUserId())
+                    .eq(AtThumbsLog::getType, "2")
+                    .eq(AtThumbsLog::getIsState, "0")
+                    .one();
+            if (one != null){
+                atMasterPiece.setThumbsUp(1);
+            }else{
+                atMasterPiece.setThumbsUp(0);
+            }
+            atMasterPiece.setUserId(hanHaiMemberService.
+                            lambdaQuery().
+                            eq(HanHaiMember::getId, atMasterPiece.getUserId()).one().getNickName()
+            );
+            recordsNew.add(atMasterPiece);
+
+        }
+        pageList.setRecords(recordsNew);
+
+
+
+        return Result.OK("作品列表", pageList);
+    }
+
+    //获取代表作品详情
+    @Override
+    public Result<?> getWorkDetail(String id,String token){
+        AtMasterPiece byId = atMasterPieceService.getById(id);
+        Map<String,Object> map = new HashMap<>();
+        //作品0/演员1/动态2
+        if (StringUtils.isNotBlank(token)){
+            HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+            AtThumbsLog one = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                    .eq(AtThumbsLog::getType, "0")
+                    .eq(AtThumbsLog::getIsState, "0")
+                    .one();
+            map.put("isThumbs_up", one);
+            AtThumbsLog one2 = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                    .eq(AtThumbsLog::getType, "0")
+                    .eq(AtThumbsLog::getIsState, "1")
+                    .one();
+            map.put("isThumbs_down", one2);
+
+
+        }
+        map.put("dayMoney",1000);
+        map.put("details", byId);
+        return Result.OK("作品详情", map);
+    }
+
+    //获取投诉原因
+    @Override
+    public Result<?> getComplaintReason(){
+        List<AtComplaintReason> list = atComplaintReasonService.list();
+        return Result.OK("投诉原因", list);
+    }
+
+    //获取演员集带分页
+    @Override
+    public Result<?> getActorSetPage(ActorSetPageBean bean){
+        Page<AtActorCollection> page = new Page<AtActorCollection>(bean.getPageNo(), bean.getPageSize());
+        Page<AtActorCollection> pageList = atActorCollectionService
+                .page(page);
+        return Result.OK("演员集列表", pageList);
+    }
+
+
+    //获取演员集详情接口
+    @Override
+    public Result<?> getActorDetail(String id,String token){
+        AtActorCollection byId = atActorCollectionService.getById(id);
+        //根据用户标识查询发布人信息
+        HanHaiMember byId1 = hanHaiMemberService.getById(byId.getUserId());
+        byId.setUserId(byId1.getNickName());
+
+        Map<String,Object> map = new HashMap<>();
+        //作品0/演员1/动态2
+        if (StringUtils.isNotBlank(token)){
+            HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+            AtThumbsLog one = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                    .eq(AtThumbsLog::getType, "0")
+                    .eq(AtThumbsLog::getIsState, "0")
+                    .one();
+            map.put("isThumbs_up", one);
+            AtThumbsLog one2 = atThumbsLogService.lambdaQuery()
+                    .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                    .eq(AtThumbsLog::getType, "0")
+                    .eq(AtThumbsLog::getIsState, "1")
+                    .one();
+            map.put("isThumbs_down", one2);
+        }
+        //查询是订单支付记录
+        AtPhoneOrder one = atPhoneOrderService.lambdaQuery()
+                .eq(AtPhoneOrder::getUserId, byId.getUserId())
+                .eq(AtPhoneOrder::getOrderId, id)
+                .eq(AtPhoneOrder::getIsPay, "Y")
+                .one();
+
+        if(one==null){
+            map.put("isPayPhone",0);
+        }else{
+            map.put("isPayPhone",1);
+        }
+
+        map.put("dayMoney",1000);
+        map.put("details", byId);
+        return Result.OK("演员集详情", map);
+    }
+
+
+
+    //获取置顶信息类标
+    @Override
+    public Result<?> getTopPayList(){
+        return Result.OK("置顶信息类标", atTopPriceService.list());
+    }
+
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiservice/impl/InfoApiServiceImpl.java

@@ -0,0 +1,741 @@
+package org.jeecg.modules.apiservice.impl;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
+import org.apache.commons.lang.StringUtils;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.util.RedisUtil;
+import org.jeecg.config.shiro.ShiroRealm;
+import org.jeecg.modules.apiBean.*;
+import org.jeecg.modules.apiservice.InfoApiService;
+import org.jeecg.modules.atActorCollection.entity.AtActorCollection;
+import org.jeecg.modules.atActorCollection.service.IAtActorCollectionService;
+import org.jeecg.modules.atComplaintLog.entity.AtComplaintLog;
+import org.jeecg.modules.atComplaintLog.service.IAtComplaintLogService;
+import org.jeecg.modules.atMasterPiece.entity.AtMasterPiece;
+import org.jeecg.modules.atMasterPiece.service.IAtMasterPieceService;
+import org.jeecg.modules.atOrder.entity.AtOrder;
+import org.jeecg.modules.atOrder.service.IAtOrderService;
+import org.jeecg.modules.atPhoneOrder.entity.AtPhoneOrder;
+import org.jeecg.modules.atPhoneOrder.service.IAtPhoneOrderService;
+import org.jeecg.modules.atPromotion.entity.AtPromotion;
+import org.jeecg.modules.atPromotion.service.IAtPromotionService;
+import org.jeecg.modules.atThumbsLog.entity.AtThumbsLog;
+import org.jeecg.modules.atThumbsLog.service.IAtThumbsLogService;
+import org.jeecg.modules.atTopPrice.entity.AtTopPrice;
+import org.jeecg.modules.atTopPrice.service.IAtTopPriceService;
+import org.jeecg.modules.atTrends.entity.AtTrends;
+import org.jeecg.modules.atTrends.service.IAtTrendsService;
+import org.jeecg.modules.hanHaiBank.entity.HanHaiBank;
+import org.jeecg.modules.hanHaiBank.service.IHanHaiBankService;
+import org.jeecg.modules.hanHaiMember.entity.HanHaiMember;
+import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService;
+import org.jeecg.modules.hanHaiRealEnterprise.entity.HanHaiRealEnterprise;
+import org.jeecg.modules.hanHaiRealEnterprise.service.IHanHaiRealEnterpriseService;
+import org.jeecg.modules.hanHaiRealName.entity.HanHaiRealName;
+import org.jeecg.modules.hanHaiRealName.service.IHanHaiRealNameService;
+import org.jeecg.modules.hanHaiWater.entity.HanHaiWater;
+import org.jeecg.modules.hanHaiWater.service.IHanHaiWaterService;
+import org.jeecg.modules.pay.MpWxPayService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.*;
+
+@Service
+public class InfoApiServiceImpl implements InfoApiService {
+
+    //缓存记录
+    @Resource
+    private RedisUtil redisUtil;
+    //权限验证
+    @Resource
+    private ShiroRealm shiroRealm;
+    //获取个人信息接口
+    @Resource
+    private IHanHaiMemberService hanHaiMemberService;
+    //获取个人认证信息
+    @Resource
+    private IHanHaiRealNameService hanHaiRealNameService;
+    //获取企业认证信息
+    @Resource
+    private IHanHaiRealEnterpriseService hanHaiRealEnterpriseService;
+    //获取流水信息
+    @Resource
+    private IHanHaiWaterService hanHaiWaterService;
+    //获取推广记录信息
+    @Resource
+    private IAtPromotionService atPromotionService;
+    //获取银行卡信息
+    @Resource
+    private IHanHaiBankService hanHaiBankService;
+    //获取动态帖子
+    @Resource
+    private IAtTrendsService atTrendsService;
+    //发布演员集
+    @Resource
+    private IAtActorCollectionService atActorCollectionService;
+
+    //支付接口
+    @Autowired
+    private MpWxPayService mpWxPayService;
+
+    //发布作品
+    @Autowired
+    private IAtMasterPieceService iAtMasterpieceService;
+    //点赞
+    @Resource
+    private IAtThumbsLogService atThumbsLogService;
+    //举报
+    @Resource
+    private IAtComplaintLogService atComplaintLogService;
+    //置顶费用
+    @Resource
+    private IAtTopPriceService atTopPriceService;
+    //推广记录
+    @Resource
+    private IAtOrderService atOrderService;
+    //付费记录
+    @Resource
+    private IAtPhoneOrderService atPhoneOrderService;
+
+
+
+
+
+    //获取个人信息接口
+    @Override
+    public Result<?> getInfo(String token){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        return Result.OK("查询成功", hanHaiMember);
+    }
+
+
+
+    //获取用户平台数据
+    @Override
+    public Result<?> getInfoMoney(String token){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        Map map = new HashMap();
+        map.put("todayMoney",100);
+        map.put("userMoney",100);
+        map.put("userSumMoney",100);
+        map.put("money",88);
+        return Result.OK("查询成功", map);
+    }
+
+    //修改个人信息接口
+    @Override
+    public Result<?> updateInfo(String token, HanHaiMember bean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        bean.setId(hanHaiMember.getId());
+        hanHaiMemberService.updateById(bean);
+        return Result.OK("修改成功");
+    }
+
+
+    //添加银行卡
+    @Override
+    public Result<?> addBankCard(String token, HanHaiBank bean){
+
+        String bankId = bean.getBankId();
+        String name = bean.getName();
+        String card = bean.getCard();
+
+        if(null == bankId){
+            return Result.OK("银行卡号未上传！");
+        }else if(null == name){
+            return Result.OK("姓名未上传！");
+        }else if(null == card){
+            return Result.OK("身份证号未上传！");
+        }
+
+        boolean result = hanHaiBankService.save(bean);
+
+        if(result){
+            return Result.OK("银行卡添加成功！");
+        }else {
+            return Result.OK("银行卡添加失败！");
+        }
+
+    }
+
+
+
+    //获取银行卡列表带分页
+    @Override
+    public Result<?> getBankCardPage(String token, HanHaiBankBean bean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        Page<HanHaiBank> page = new Page<>(bean.getPageNo(),bean.getPageSize());
+        Page<HanHaiBank> pageList = hanHaiBankService
+                .lambdaQuery()
+                .orderByDesc(HanHaiBank::getCreateTime)
+                .eq(HanHaiBank::getUserId,hanHaiMember.getId())
+                .page(page);
+
+        return Result.OK("银行卡列表", pageList);
+    }
+
+
+    //获取收益记录带分页
+    @Override
+    public Result<?> getIncomePage(String token, HanHaiWaterBean bean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        Page<HanHaiWater> page = new Page<HanHaiWater>(bean.getPageNo(), bean.getPageSize());
+        Page<HanHaiWater> pageList = hanHaiWaterService
+                .lambdaQuery()
+                .eq(HanHaiWater::getUserId,hanHaiMember.getId())
+                .orderByDesc(HanHaiWater::getCreateTime)
+                .page(page);
+        return Result.OK("收益记录",pageList);
+    }
+
+    //获取提现记录带分页
+    @Override
+    public Result<?> getWithdrawPage(String token, HanHaiWaterBean bean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        Page<HanHaiWater> page = new Page<HanHaiWater>(bean.getPageNo(), bean.getPageSize());
+        Page<HanHaiWater> pageList = hanHaiWaterService
+                .lambdaQuery()
+                .eq(HanHaiWater::getUserId,hanHaiMember.getId())
+                .orderByDesc(HanHaiWater::getCreateTime)
+                .page(page);
+        return Result.OK("提现记录",pageList);
+    }
+
+
+    //个人认证提交
+    @Override
+    public Result<?> submitCertification(String token, HanHaiRealNameBean hanHaiRealNameBean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+
+        String imageStraight = hanHaiRealNameBean.getImageStraight();
+        String imageReverseSide = hanHaiRealNameBean.getImageReverseSide();
+        String name = hanHaiRealNameBean.getName();
+        String card = hanHaiRealNameBean.getCard();
+
+        HanHaiRealName haiRealName = new HanHaiRealName();
+        if(null != imageStraight){
+            haiRealName.setImageStraight(imageStraight);
+        }else{
+            return Result.OK("身份证正面照未上传！");
+        }
+        if(null != imageReverseSide){
+            haiRealName.setImageReverseSide(imageReverseSide);
+        }else{
+            return Result.OK("身份证反面照未上传！");
+        }
+        if(null != name){
+            haiRealName.setName(name);
+        }else{
+            return Result.OK("姓名未上传！");
+        }
+        if(null != card){
+            haiRealName.setName(card);
+        }else{
+            return Result.OK("身份证号码未上传！");
+        }
+
+        haiRealName.setUserId(hanHaiMember.getId());
+
+        boolean result = hanHaiRealNameService.save(haiRealName);
+
+
+        //创建支付订单
+
+        //获取当前置顶价格
+        BigDecimal money = new BigDecimal("0.01");
+        //吊起微信支付
+        String s = money.multiply(new BigDecimal(100)).toString();
+        int i1 = Double.valueOf(s).intValue();
+
+
+        //创建支付订单
+        Object appOrder = mpWxPayService.createOrder2(
+                "实名认证" ,
+                "127.0.0.1",
+                System.currentTimeMillis()+"",
+                i1,
+                System.currentTimeMillis()+"",
+                hanHaiMember.getAppletOpenid(),
+                "{}");
+
+
+        if(result){
+            return Result.OK("个人认证提交成功！",appOrder);
+        }else {
+            return Result.OK("个人认证提交失败！");
+        }
+
+    }
+
+    //企业认证提交
+    @Override
+    public Result<?> submitCompanyCertification(String token, HanHaiRealEnterpriseBean hanHaiRealEnterpriseBean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+
+        String imageStraight = hanHaiRealEnterpriseBean.getImageStraight();
+        String imageReverseSide = hanHaiRealEnterpriseBean.getImageReverseSide();
+        String name = hanHaiRealEnterpriseBean.getName();
+        String card = hanHaiRealEnterpriseBean.getCard();
+        String tradeImage = hanHaiRealEnterpriseBean.getTradeImage();
+        String otherImage = hanHaiRealEnterpriseBean.getOtherImage();
+
+        HanHaiRealEnterprise haiRealEnterprise = new HanHaiRealEnterprise();
+        if(null != imageStraight){
+            haiRealEnterprise.setImageStraight(imageStraight);
+        }else {
+            return Result.OK("身份证正面照未上传！");
+        }
+        if(null != imageReverseSide){
+            haiRealEnterprise.setImageReverseSide(imageReverseSide);
+        }else {
+            return Result.OK("身份证反面照未上传！");
+        }
+        if(null != name){
+            haiRealEnterprise.setName(name);
+        }else{
+            return Result.OK("法人真实姓名未上传！");
+        }
+        if(null != card){
+            haiRealEnterprise.setName(card);
+        }else{
+            return Result.OK("法人身份证号码未上传！");
+        }
+        if(null != card){
+            haiRealEnterprise.setTradeImage(tradeImage);
+        }else{
+            return Result.OK("营业执照未上传！");
+        }
+        if(null != card){
+            haiRealEnterprise.setOtherImage(otherImage);
+        }else{
+            return Result.OK("其他资质未上传！");
+        }
+
+        haiRealEnterprise.setUserId(hanHaiMember.getId());
+
+        Boolean result = hanHaiRealEnterpriseService.save(haiRealEnterprise);
+
+
+        //获取当前置顶价格
+        BigDecimal money = new BigDecimal("0.01");
+        //吊起微信支付
+        String s = money.multiply(new BigDecimal(100)).toString();
+        int i1 = Double.valueOf(s).intValue();
+
+
+        //创建支付订单
+        Object appOrder = mpWxPayService.createOrder2(
+                "实名认证" ,
+                "127.0.0.1",
+                System.currentTimeMillis()+"",
+                i1,
+                System.currentTimeMillis()+"",
+                hanHaiMember.getAppletOpenid(),
+                "{}");
+
+
+        if(result){
+            return Result.OK("个人认证提交成功！",appOrder);
+        }else {
+            return Result.OK("企业认证提交失败！");
+        }
+    }
+
+    //获取个人认证信息
+    @Override
+    public Result<?> getCertification(String token){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        HanHaiRealName one = hanHaiRealNameService
+                .lambdaQuery()
+                .eq(HanHaiRealName::getUserId, hanHaiMember.getId())
+                .one();
+        return Result.OK("个人认证信息", one);
+    }
+
+    //获取企业认证信息
+    @Override
+    public Result<?> getCompanyCertification(String token){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        List<HanHaiRealEnterprise> list = hanHaiRealEnterpriseService
+                .lambdaQuery()
+                .eq(HanHaiRealEnterprise::getUserId, hanHaiMember.getId())
+                .list();
+        return Result.OK("企业认证信息", list);
+    }
+
+    //获取我的发布列表
+    @Override
+    public Result<?> getMyReleasePage(String token,MyReleasePageBean bean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+
+
+        if(bean.getState() == 0){
+            Page<AtTrends> page = new Page<AtTrends>(bean.getPageNo(), bean.getPageSize());
+            Page<AtTrends> pageList  = atTrendsService.lambdaQuery()
+                    .eq(AtTrends::getUserId, hanHaiMember.getId())
+                    .eq(AtTrends::getIsCard,"N")
+                    .orderByDesc(AtTrends::getCreateTime)
+                    .page(page);
+            return Result.OK("我的发布帖子", pageList);
+        }else{
+            Page<AtActorCollection> page = new Page<AtActorCollection>(bean.getPageNo(), bean.getPageSize());
+            Page<AtActorCollection> page1 = atActorCollectionService.lambdaQuery()
+                    .eq(AtActorCollection::getUserId, hanHaiMember.getId())
+                    .orderByDesc(AtActorCollection::getCreateTime)
+                    .page(page);
+            return Result.OK("我的发布名片", page1);
+
+
+        }
+
+    }
+
+    //获取我的发布详情
+    @Override
+    public Result<?> getMyReleaseDetail(String token,String id){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        AtTrends one = atTrendsService.lambdaQuery()
+                .eq(AtTrends::getId, id)
+                .one();
+        one.setUserId(hanHaiMemberService.lambdaQuery().eq(HanHaiMember::getId, one.getUserId()).one().getNickName());
+
+        return Result.OK("发布详情", one);
+    }
+
+    //获取推广记录列表
+    @Override
+    public Result<?> getPromotionPage(String token, PromotionPageBean bean){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        Page<AtOrder> page = new Page<AtOrder>(bean.getPageNo(), bean.getPageSize());
+        Page<AtOrder> page1 = atOrderService.lambdaQuery()
+                .orderByDesc(AtOrder::getCreateTime)
+                .eq(AtOrder::getUserId,hanHaiMember.getId())
+                .page(page);
+        return Result.OK("推广记录",page1);
+    }
+
+    //获取推广记录详情
+    @Override
+    public Result<?> getPromotionDetail(String token,String id){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+
+        if(StringUtils.isBlank(id)){
+            return Result.error("参数错误！标识不能为空");
+        }
+        AtOrder one = atOrderService.lambdaQuery()
+                .eq(AtOrder::getId, id)
+                .one();
+
+
+
+        return Result.OK("推广记录详情", one);
+    }
+
+
+    //用户提现
+    @Override
+    public Result<?> withdraw(String token, BigDecimal price){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        //金额不能为空
+        if(price == null){
+            return Result.error("参数错误！提现金额不能为空");
+        }
+        if(hanHaiMember.getPrice().compareTo(price) < 0){
+            return Result.error("参数错误！提现金额不能大于用户余额");
+        }
+        hanHaiMember.setPrice(hanHaiMember.getPrice().subtract(price));
+        hanHaiMemberService.updateById(hanHaiMember);
+        HanHaiWater hanHaiWater = new HanHaiWater();
+        hanHaiWater.setUserId(hanHaiMember.getId());
+        hanHaiWater.setPrice(price);
+        hanHaiWater.setType(1);
+        hanHaiWater.setState(0);
+        hanHaiWater.setCreateTime(new Date());
+        hanHaiWaterService.save(hanHaiWater);
+
+        return Result.OK("提现提交成功，等待审核");
+    }
+
+
+    //发布动态
+    @Override
+    public Result<?> releaseTrends(String token, AtTrends atTrends){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        atTrends.setUserId(hanHaiMember.getId());
+        atTrendsService.save(atTrends);
+        //置顶支付置顶费用
+        if(atTrends.getIsTop().equals("Y")){
+            //根据置顶标识查询置顶费用
+            AtTopPrice one = atTopPriceService.lambdaQuery()
+                    .eq(AtTopPrice::getId, atTrends.getTopId())
+                    .one();
+            //获取当前置顶价格
+            BigDecimal money = one.getMoney();
+            //吊起微信支付
+            String s = money.multiply(new BigDecimal(100)).toString();
+            int i1 = Double.valueOf(s).intValue();
+
+            //创建推广记录订单
+            AtOrder atOrder = new AtOrder();
+            String id = ""+System.currentTimeMillis();
+            atOrder.setId(id);
+            atOrder.setName(atTrends.getTitle()+"置顶");
+            atOrder.setImage(atTrends.getImage());
+            atOrder.setPrice(money);
+            atOrder.setCreateTime(new Date());
+            atOrder.setUserId(hanHaiMember.getId());
+            atOrder.setOrderId(atTrends.getId());
+            atOrderService.save(atOrder);
+
+            Object appOrder = mpWxPayService.createOrder(
+                    "购买"+atTrends.getTitle()+"置顶" ,
+                    "127.0.0.1",
+                    id,
+                    i1,
+                    id,
+                    hanHaiMember.getAppletOpenid(),
+                    "{}");
+
+            return Result.OK("微信支付回调成功", appOrder);
+        }
+        return Result.OK("动态发布成功");
+    }
+
+
+    //发布演员集
+    @Override
+    public Result<?> releaseActorSet(String token, AtActorCollection atActorCollection){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        atActorCollection.setUserId(hanHaiMember.getId());
+        atActorCollectionService.save(atActorCollection);
+        return Result.OK("动态发布成功");
+    }
+
+
+    //发布作品
+    @Override
+    public Result<?> releaseWorks(String token, AtMasterPiece atWorks){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        atWorks.setUserId(hanHaiMember.getId());
+        atWorks.setUserImage(hanHaiMember.getHeadImage());
+        iAtMasterpieceService.save(atWorks);
+        return Result.OK("作品发布成功");
+    }
+
+
+    //点赞小程序-点赞type-作品0/演员1/动态2
+    @Override
+    public Result<?> like(String token, String id, Integer type){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        AtThumbsLog one = atThumbsLogService
+                .lambdaQuery()
+                .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                .eq(AtThumbsLog::getType, type)
+                .eq(AtThumbsLog::getIsState, "0")
+                .one();
+        if (one != null){
+            atThumbsLogService.removeById(one.getId());
+
+            //减少点赞数
+            if (type == 1){
+                AtTrends atTrends = atTrendsService.lambdaQuery()
+                        .eq(AtTrends::getId, id)
+                        .one();
+                atTrends.setDropNum(atTrends.getDropNum() - 1);
+                atTrendsService.updateById(atTrends);
+            }else if (type == 2) {
+                AtTrends atTrends = atTrendsService.lambdaQuery()
+                        .eq(AtTrends::getId, id)
+                        .one();
+                atTrends.setDropNum(atTrends.getDropNum() - 1);
+                atTrendsService.updateById(atTrends);
+            }else{
+                AtMasterPiece atMasterPiece = iAtMasterpieceService.lambdaQuery()
+                        .eq(AtMasterPiece::getId, id)
+                        .one();
+                atMasterPiece.setNum(atMasterPiece.getNum() - 1);
+                atMasterPiece.setThumbsUp(atMasterPiece.getThumbsUp() - 1);
+                iAtMasterpieceService.updateById(atMasterPiece);
+            }
+            return Result.ok("取消点赞");
+        }
+        AtThumbsLog newOne = new AtThumbsLog();
+        newOne.setUserId(hanHaiMember.getId());
+        newOne.setType(type);
+        newOne.setOrderId(id);
+        newOne.setIsState("0");
+        newOne.setCreateTime(new Date());
+        atThumbsLogService.save(newOne);
+        //增加点赞数
+        if (type == 1){
+            AtTrends atTrends = atTrendsService.lambdaQuery()
+                    .eq(AtTrends::getId, id)
+                    .one();
+            //数据不能为空
+            if (atTrends == null){
+                return Result.error("数据为空：Id不存在");
+            }
+            atTrends.setDropNum(atTrends.getDropNum() + 1);
+            atTrendsService.updateById(atTrends);
+        }else if (type == 2) {
+            AtTrends atTrends = atTrendsService.lambdaQuery()
+                    .eq(AtTrends::getId, id)
+                    .one();
+            if (atTrends == null){
+                return Result.error("数据为空：Id不存在");
+            }
+            atTrends.setDropNum(atTrends.getDropNum() + 1);
+            atTrendsService.updateById(atTrends);
+        }else{
+            AtMasterPiece atMasterPiece = iAtMasterpieceService.lambdaQuery()
+                    .eq(AtMasterPiece::getId, id)
+                    .one();
+            atMasterPiece.setNum(atMasterPiece.getNum() + 1);
+            atMasterPiece.setThumbsUp(atMasterPiece.getThumbsUp() + 1);
+            iAtMasterpieceService.updateById(atMasterPiece);
+        }
+        return Result.OK("点赞成功");
+    }
+
+
+    //踩
+    @Override
+    public Result<?> dislike(String token, String id, Integer type){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        AtThumbsLog one = atThumbsLogService
+                .lambdaQuery()
+                .eq(AtThumbsLog::getUserId, hanHaiMember.getId())
+                .eq(AtThumbsLog::getType, type)
+                .eq(AtThumbsLog::getIsState, "1")
+                .one();
+        if (one != null){
+            return Result.error("您已经踩过了");
+        }
+        AtThumbsLog newOne = new AtThumbsLog();
+        newOne.setUserId(hanHaiMember.getId());
+        newOne.setType(type);
+        newOne.setOrderId(id);
+        newOne.setIsState("1");
+        newOne.setCreateTime(new Date());
+        atThumbsLogService.save(newOne);
+        return Result.OK("踩成功");
+    }
+
+
+    //举报
+    @Override
+    public Result<?> report( String token, String id, Integer type){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+        AtComplaintLog newOne = new AtComplaintLog();
+        newOne.setUserId(hanHaiMember.getId());
+        newOne.setType(type);
+        newOne.setOrderId(id);
+        newOne.setCreateTime(new Date());
+        atComplaintLogService.save(newOne);
+        return Result.OK("踩成功");
+    }
+
+    @Override
+    public Result<?> getContact( String token, String id){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+
+
+
+
+        //根据置顶标识查询置顶费用
+        AtActorCollection one = atActorCollectionService.lambdaQuery()
+                .eq(AtActorCollection::getId, id)
+                .one();
+        if (one == null){
+            return Result.error("数据不存在");
+        }
+
+        //根据用户标识以及演员标识查询当前是否以存在支付记录
+        AtPhoneOrder one1 = atPhoneOrderService.lambdaQuery()
+                .eq(AtPhoneOrder::getUserId, hanHaiMember.getId())
+                .eq(AtPhoneOrder::getOrderId, id)
+                .eq(AtPhoneOrder::getIsPay, "Y")
+                .one();
+
+        //如果存在并且支付状态为Y则返回已支付
+        if (one1 != null){
+            return Result.OK("已支付,请不要重复支付");
+        }
+
+
+
+        //获取当前置顶价格
+        BigDecimal money = one.getMoney();
+        //吊起微信支付
+        String s = money.multiply(new BigDecimal(100)).toString();
+        int i1 = Double.valueOf(s).intValue();
+
+
+
+        AtPhoneOrder phoneOrder = new AtPhoneOrder();
+        String idStr = ""+System.currentTimeMillis();
+        phoneOrder.setId(idStr);
+        phoneOrder.setUserId(hanHaiMember.getId());
+        phoneOrder.setOrderId(id);
+        phoneOrder.setCreateTime(new Date());
+        phoneOrder.setPrice(money);
+
+        atPhoneOrderService.save(phoneOrder);
+
+        Object appOrder = mpWxPayService.createOrder2(
+                "购买"+one.getTitle()+"联系方式" ,
+                "127.0.0.1",
+                idStr,
+                i1,
+                idStr,
+                hanHaiMember.getAppletOpenid(),
+                "{}");
+        return Result.OK("吊起微信支付",appOrder);
+    }
+
+
+    //确认推广接口
+    @Override
+    public Result<?> confirmPromotion(String token, String id,String dayId){
+        HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token);
+
+        //查询推广记录
+        AtOrder one1 = atOrderService.lambdaQuery()
+                .eq(AtOrder::getOrderId, id)
+                .one();
+
+        AtTopPrice one = atTopPriceService.lambdaQuery()
+                .eq(AtTopPrice::getId, dayId)
+                .one();
+        if (one == null){
+            return Result.error("数据不存在");
+        }
+
+        //获取当前置顶价格
+        BigDecimal money = one.getMoney();
+        //吊起微信支付
+        String s = money.multiply(new BigDecimal(100)).toString();
+        int i1 = Double.valueOf(s).intValue();
+
+
+        //创建支付订单
+        Object appOrder = mpWxPayService.createOrder2(
+                "再次推广" ,
+                "127.0.0.1",
+                System.currentTimeMillis()+"",
+                i1,
+                System.currentTimeMillis()+"",
+                hanHaiMember.getAppletOpenid(),
+                "{}");
+
+
+
+
+
+        return Result.OK("吊起微信支付",appOrder);
+    }
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiservice/impl/LoginApiServiceImpl.java

@@ -0,0 +1,57 @@
+package org.jeecg.modules.apiservice.impl;
+
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.apiservice.LoginApiService;
+import org.jeecg.modules.bean.LoginReq;
+import org.jeecg.modules.hanHaiConf.entity.HanHaiConf;
+import org.jeecg.modules.hanHaiConf.service.IHanHaiConfService;
+import org.jeecg.modules.hanHaiMember.entity.HanHaiMember;
+import org.jeecg.modules.service.AppletLoginService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Service
+public class LoginApiServiceImpl implements LoginApiService {
+
+    @Resource
+    private AppletLoginService appletLoginService;
+    //协议接口
+    @Resource
+    private IHanHaiConfService hanHaiConfService;
+
+    //小程序-登录接口
+    @Override
+    public Result<?> login(LoginReq loginReq)
+    {
+        return appletLoginService.appletLogin(loginReq);
+    }
+
+
+    //小程序-获取用户协议
+    @Override
+    public Result<?> getUserAgreement()
+    {
+
+        HanHaiConf user_xy = hanHaiConfService.lambdaQuery().eq(HanHaiConf::getKeyValue, "user_xy").one();
+        return Result.OK(user_xy.getContent());
+    }
+
+    //获取隐私政策
+    @Override
+    public Result<?> getPrivacyPolicy()
+    {
+
+        HanHaiConf user_ys = hanHaiConfService.lambdaQuery().eq(HanHaiConf::getKeyValue, "user_ys").one();
+        return Result.OK(user_ys.getContent());
+    }
+
+
+    //获取发布帖子发布需知
+    @Override
+    public Result<?> getPublishPostNotice(){
+        HanHaiConf user_tz = hanHaiConfService.lambdaQuery().eq(HanHaiConf::getKeyValue, "user_tz").one();
+        return Result.OK(user_tz.getContent());
+    }
+
+}

jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiservice/impl/OrderApiServiceImpl.java

@@ -0,0 +1,119 @@
+package org.jeecg.modules.apiservice.impl;
+
+import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.apiUtils.printUtil;
+import org.jeecg.modules.apiservice.OrderApiService;
+import org.jeecg.modules.atOrder.entity.AtOrder;
+import org.jeecg.modules.atOrder.service.IAtOrderService;
+import org.jeecg.modules.atPhoneOrder.entity.AtPhoneOrder;
+import org.jeecg.modules.atPhoneOrder.service.IAtPhoneOrderService;
+import org.jeecg.modules.atTrends.entity.AtTrends;
+import org.jeecg.modules.atTrends.service.IAtTrendsService;
+import org.jeecg.modules.hanHaiMember.entity.HanHaiMember;
+import org.jeecg.modules.pay.MpWxPayService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+
+
+@Service
+public class OrderApiServiceImpl implements OrderApiService {
+
+
+    //支付接口
+    @Autowired
+    private MpWxPayService mpWxPayService;
+    //推广记录
+    @Resource
+    private IAtOrderService atOrderService;
+    @Resource
+    private IAtPhoneOrderService atPhoneOrderService;
+    //获取动态帖子
+    @Resource
+    private IAtTrendsService atTrendsService;
+
+
+
+    //创建订单
+    @Override
+    public Result<?> createOrder()
+    {
+        return null;
+    }
+
+    //立即支付
+    @Override
+    public Result<?> payOrder()
+    {
+
+        String s = new BigDecimal(0.01).multiply(new BigDecimal(100)).toString();
+        int i1 = Double.valueOf(s).intValue();
+        Object appOrder = mpWxPayService.createOrder(
+                "购买测试" ,
+                "127.0.0.1",
+                System.currentTimeMillis()+"",
+                i1,
+                System.currentTimeMillis()+"",
+                "ozfsp7eFo_CvJdX5jl5fi4pR5AhI",
+                "{}");
+        //返回支付结果
+        return Result.OK("微信支付回调成功",appOrder);
+    }
+
+
+    //支付回调
+    @Override
+    public Object createNotify(String requestBody){
+        WxPayOrderNotifyResult notify = mpWxPayService.notify(requestBody);
+        String outTradeNo = notify.getOutTradeNo();
+        AtOrder byId = atOrderService.getById(outTradeNo);
+        System.out.println("进入了支付回调");
+        System.out.println(byId);
+        //如果不为空则修改支付状态
+        if(byId!=null)
+        {
+            if ("N".equals(byId.getIsPay())){
+                byId.setIsPay("Y");
+                atOrderService.updateById(byId);
+
+                //修改我的推广的的推广状态
+                AtTrends byId1 = atTrendsService.getById(byId.getOrderId());
+                byId1.setIsPay("Y");
+                atTrendsService.updateById(byId1);
+
+            }
+        }
+
+        return null;
+    }
+
+
+
+    //支付回调
+    @Override
+    public Object createNotify2(String requestBody){
+        WxPayOrderNotifyResult notify = mpWxPayService.notify(requestBody);
+        String outTradeNo = notify.getOutTradeNo();
+        AtPhoneOrder byId = atPhoneOrderService.getById(outTradeNo);
+        System.out.println("进入了支付回调");
+        System.out.println(byId);
+        //如果不为空则修改支付状态
+        if(byId!=null)
+        {
+            if ("N".equals(byId.getIsPay())){
+                byId.setIsPay("Y");
+                atPhoneOrderService.updateById(byId);
+            }
+        }
+
+        return null;
+    }
+
+
+
+
+
+}