保存短信记录

src/main/java/com/pangding/web/authority/service/impl/CompanyAgreementServiceImpl.java

@@ -99,7 +99,7 @@ public class CompanyAgreementServiceImpl implements CompanyAgreementService {
         companyExtendVo.setDivideStatus(0);
         companyExtendVo.setScanCodePayStatus(1);
         companyExtendVo.setInvitationStatus(0);
-        companyExtendVo.setActivationStatus(0);
+        companyExtendVo.setActivationStatus(1);
         companyExtendDao.update(companyExtendVo);
 
         CompanyVo companyVo = new CompanyVo();

src/main/java/com/pangding/web/company/swagger.java

@@ -26,7 +26,8 @@ public class swagger {
                         "com.pangding.web.authority.controller",
                         "com.pangding.web.system.web",
                         "com.pangding.web.report.web",
-                        "com.pangding.web.company.web"
+                        "com.pangding.web.company.web",
+                        "com.pangding.web.sms.web"
                 ))
                 .paths(PathSelectors.any())
                 .build();

src/main/java/com/pangding/web/sms/dao/SmsRecordDao.java

+package com.pangding.web.sms.dao;
+
+import com.yanzuoguang.dao.BaseDao;
+
+public interface SmsRecordDao extends BaseDao {
+}

src/main/java/com/pangding/web/sms/dao/impl/SmsRecordDaoImpl.java

+package com.pangding.web.sms.dao.impl;
+
+import com.pangding.web.sms.dao.SmsRecordDao;
+import com.pangding.web.vo2.user.sms.pd.SmsRecordVo;
+import com.yanzuoguang.dao.impl.BaseDaoImpl;
+import org.springframework.stereotype.Component;
+
+@Component
+public class SmsRecordDaoImpl extends BaseDaoImpl implements SmsRecordDao {
+
+    @Override
+    protected void init() {
+        register(SmsRecordVo.class);
+
+    }
+
+}

src/main/java/com/pangding/web/sms/mq/SmsRecordConSumer.java

+package com.pangding.web.sms.mq;
+
+import com.pangding.web.constant.MqConstant;
+import com.pangding.web.sms.service.SmsRecordService;
+import com.pangding.web.vo2.user.sms.req.SmsRecordReqVo;
+import com.rabbitmq.client.Channel;
+import com.yanzuoguang.mq.service.MqService;
+import com.yanzuoguang.util.helper.JsonHelper;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+public class SmsRecordConSumer {
+
+    private final MqService mqService;
+
+    private final SmsRecordService smsRecordService;
+
+    public SmsRecordConSumer(MqService mqService, SmsRecordService smsRecordService) {
+        this.mqService = mqService;
+        this.smsRecordService = smsRecordService;
+    }
+
+    /**
+     * 资金报表V2生成
+     *
+     * @param content 消息内容
+     * @param message 消息体
+     * @param channel 线程
+     */
+    @RabbitListener(queues = {MqConstant.SAVE_SMS_RECORD})
+    public void reportProductV2Save(String content, Message message, Channel channel) {
+        mqService.basicHandle(message, channel, MqConstant.SAVE_SMS_RECORD, content, 0, (contentTemp) -> {
+            SmsRecordReqVo req = JsonHelper.deserialize(contentTemp, SmsRecordReqVo.class);
+            smsRecordService.save(req);
+        });
+    }
+
+
+
+}

src/main/java/com/pangding/web/sms/service/SmsRecordService.java

+package com.pangding.web.sms.service;
+
+import com.pangding.web.vo2.user.sms.req.SmsRecordReqVo;
+import com.pangding.web.vo2.user.sms.res.SmsRecordResVo;
+
+public interface SmsRecordService {
+
+    SmsRecordResVo load(SmsRecordReqVo req);
+
+    void save(SmsRecordReqVo req);
+
+}

src/main/java/com/pangding/web/sms/service/impl/SmsRecordServiceImpl.java

+package com.pangding.web.sms.service.impl;
+
+import com.pangding.web.sms.dao.SmsRecordDao;
+import com.pangding.web.sms.service.SmsRecordService;
+import com.pangding.web.vo2.user.sms.req.SmsRecordReqVo;
+import com.pangding.web.vo2.user.sms.res.SmsRecordResVo;
+import org.springframework.stereotype.Service;
+
+@Service
+public class SmsRecordServiceImpl implements SmsRecordService {
+
+    private SmsRecordDao smsRecordDao;
+
+    public SmsRecordServiceImpl(SmsRecordDao smsRecordDao) {
+        this.smsRecordDao = smsRecordDao;
+    }
+
+    public SmsRecordResVo load(SmsRecordReqVo req){
+        SmsRecordResVo smsRecordResVo = smsRecordDao.load(req, SmsRecordResVo.class);
+        return smsRecordResVo;
+    }
+
+    public void save(SmsRecordReqVo req){
+        smsRecordDao.save(req);
+    }
+
+}

src/main/java/com/pangding/web/sms/web/SmsRecordController.java

+package com.pangding.web.sms.web;
+
+import com.pangding.web.sms.service.SmsRecordService;
+import com.pangding.web.vo2.user.sms.req.SmsRecordReqVo;
+import com.pangding.web.vo2.user.sms.res.SmsRecordResVo;
+import com.yanzuoguang.util.vo.ResponseResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping(value = "/smsRecord", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+@Api(value = "短信记录查管理", description = "短信记录管理")
+public class SmsRecordController {
+
+    private SmsRecordService smsRecordService;
+
+    public SmsRecordController(SmsRecordService smsRecordService) {
+        this.smsRecordService = smsRecordService;
+    }
+
+    @RequestMapping(value = "/load")
+    @ApiOperation(value = "查询短信跳转链接", notes = "返回成功")
+    public ResponseResult<SmsRecordResVo> load(@RequestBody SmsRecordReqVo req) {
+        return ResponseResult.result(smsRecordService.load(req));
+    }
+
+}