添加个腿推送日志

business/push-service/src/main/java/com/yihu/jw/push/dao/WlyyHttpLogDao.java

@@ -1,11 +1,11 @@
package com.yihu.jw.push.dao;
import com.yihu.jw.entity.hospital.httplog.WlyyHttpLogDO;
import com.yihu.jw.entity.care.common.GetuiRecordDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.repository.PagingAndSortingRepository;
public interface WlyyHttpLogDao extends PagingAndSortingRepository<WlyyHttpLogDO, String>, JpaSpecificationExecutor<WlyyHttpLogDO> {
public interface GetuiRecordDao extends PagingAndSortingRepository<GetuiRecordDO, String>, JpaSpecificationExecutor<GetuiRecordDO> {

business/push-service/src/main/java/com/yihu/jw/push/service/GetuiService.java

@@ -18,10 +18,11 @@ import com.getui.push.v2.sdk.dto.req.message.android.Ups;
import com.getui.push.v2.sdk.dto.req.message.ios.Alert;
import com.getui.push.v2.sdk.dto.req.message.ios.Aps;
import com.getui.push.v2.sdk.dto.req.message.ios.IosDTO;
import com.yihu.jw.entity.care.common.GetuiRecordDO;
import com.yihu.jw.entity.hospital.consult.WlyyHospitalSysDictDO;
import com.yihu.jw.entity.hospital.httplog.WlyyHttpLogDO;
import com.yihu.jw.push.dao.PushHospitalSysDictDao;
import com.yihu.jw.push.dao.WlyyHttpLogDao;
import com.yihu.jw.push.dao.GetuiRecordDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -47,7 +48,7 @@ public class GetuiService {
    @Autowired
    private PushHospitalSysDictDao sysDictDao;
    @Autowired
    private WlyyHttpLogDao httpLogDao;
    private GetuiRecordDao getuiRecordDao;
    private static final Logger logger = LoggerFactory.getLogger(GetuiService.class);
@@ -213,20 +214,20 @@ public class GetuiService {
        // 进行cid单推
        ApiResult<Map<String, Map<String, String>>> apiResult = pushApi.pushToSingleByCid(pushDTO);
        WlyyHttpLogDO httpLogDO = new WlyyHttpLogDO();//报错发送日志
        httpLogDO.setCode(cid);
        httpLogDO.setRequest(json.toJSONString());
        httpLogDO.setResponse(JSONObject.toJSONString(apiResult));
        GetuiRecordDO getuiRecordDO = new GetuiRecordDO();//报错发送日志
        getuiRecordDO.setCid(cid);
        getuiRecordDO.setRequest(json.toJSONString());
        getuiRecordDO.setResponse(JSONObject.toJSONString(apiResult));
        if (apiResult.isSuccess()) {
            // success
            logger.info("发送成功："+apiResult.getData());
            httpLogDO.setStatus("0");
            getuiRecordDO.setStatus(1);
        } else {
            // failed
            logger.info("code:" + apiResult.getCode() + ", msg: " + apiResult.getMsg());
            httpLogDO.setStatus("1");
            getuiRecordDO.setStatus(0);
        }
        httpLogDao.save(httpLogDO);
        getuiRecordDao.save(getuiRecordDO);
    }
    /**

common/common-entity/src/main/java/com/yihu/jw/entity/care/common/GetuiRecordDO.java

@@ -0,0 +1,57 @@
package com.yihu.jw.entity.care.common;
import com.yihu.jw.entity.UuidIdentityEntityWithCreateTime;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
/**
 * 个推推送记录
 * Created by yeshijie on 2022/6/6.
 */
@Entity
@Table(name="base_getui_record")
public class GetuiRecordDO extends UuidIdentityEntityWithCreateTime {
    private Integer status;//状态1成功 0失败
    private String cid;
    private String request;
    private String response;
    @Column(name = "status")
    public Integer getStatus() {
        return status;
    }
    public void setStatus(Integer status) {
        this.status = status;
    }
    @Column(name = "cid")
    public String getCid() {
        return cid;
    }
    public void setCid(String cid) {
        this.cid = cid;
    }
    @Column(name = "request")
    public String getRequest() {
        return request;
    }
    public void setRequest(String request) {
        this.request = request;
    }
    @Column(name = "response")
    public String getResponse() {
        return response;
    }
    public void setResponse(String response) {
        this.response = response;
    }
}