根据身份证和openid查询中奖结果

common/common-entity/src/main/java/com/yihu/es/entity/QuestionnaireWinningESDO.java

@@ -31,6 +31,8 @@ public class QuestionnaireWinningESDO {
	private String prizeCode;
	//0为未删除，1为删除
	private Integer del;
	//0为未中奖，1为已中奖
	private Integer winning;
	@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyyMMdd'T'HHmmss.SSS'Z'")
	@CreatedDate
	private Date create_time;
@@ -126,4 +128,12 @@ public class QuestionnaireWinningESDO {
	public void setUpdate_time(Date update_time) {
		this.update_time = update_time;
	}
	
	public Integer getWinning() {
		return winning;
	}
	
	public void setWinning(Integer winning) {
		this.winning = winning;
	}
}

patient-co/patient-co-wlyy/doc/技术文档/es/回访问卷新增索引.txt

@@ -35,6 +35,10 @@ POST http://172.19.103.68:9200/wlyy_questionnaire_winning/wlyy_questionnaire_win
                "type": "string",
                "index": "not_analyzed"
            },
            "winning": {
                "type": "string",
                "index": "not_analyzed"
            },
            "create_time": {
                "type": "string",
                "index": "not_analyzed"

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/repository/questionnaire/QuestionnaireWinningDao.java

@@ -0,0 +1,16 @@
package com.yihu.wlyy.repository.questionnaire;
import com.yihu.wlyy.entity.questionnaire.QuestionnaireWinning;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.repository.PagingAndSortingRepository;
/**
 * 调查问卷中奖纪录
 * @author huangwenjie
 * @date 2018/1/28 20:09
 */
public interface QuestionnaireWinningDao extends
		PagingAndSortingRepository<QuestionnaireWinning, Long>,
		JpaSpecificationExecutor<QuestionnaireWinning> {
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/service/app/prescription/PrescriptionInfoService.java

@@ -116,7 +116,7 @@ public class PrescriptionInfoService extends BaseService {
    @Autowired
    private MessageService messageService;
    private static final Logger logger = LoggerFactory.getLogger(HttpUtil.class);
    private static final Logger logger = LoggerFactory.getLogger(PrescriptionInfoService.class);
    /**
     * 获取处方下的详细药品列表

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/service/questionnaire/QuestionnaireService.java

@@ -0,0 +1,48 @@
package com.yihu.wlyy.service.questionnaire;
import com.yihu.es.entity.HealthEduArticleES;
import com.yihu.es.entity.QuestionnaireWinningESDO;
import com.yihu.wlyy.config.es.ElasticFactory;
import com.yihu.wlyy.repository.questionnaire.QuestionnaireWinningDao;
import com.yihu.wlyy.service.BaseService;
import com.yihu.wlyy.util.ElasticsearchUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
/**
 * 回访问卷调查业务逻辑类
 * @author huangwenjie
 * @date 2018/1/28 20:20
 */
@Service
public class QuestionnaireService extends BaseService {
	
	private static final Logger logger = LoggerFactory.getLogger(QuestionnaireService.class);
	@Autowired
	private ElasticFactory elasticFactory;
	@Autowired
	private ElasticsearchUtil elasticsearchUtil;
	@Value("${es.type.QuestionnaireWinning}")
	private String esType;
	@Value("${es.index.QuestionnaireWinning}")
	private String esIndex;
	
	@Autowired
	private QuestionnaireWinningDao questionnaireWinningDao;
	
	/**
	 * 根据身份证和openid从ES查询中奖结果
	 * @param idcard
	 * @param openid
	 * @return
	 * @throws Exception
	 */
	public QuestionnaireWinningESDO getQuestionnaireWinningESDOByIdcardAndOpenid(String idcard,String openid) throws Exception{
		String sql = "SELECT * FROM " + esType + "  where userIdcard= '" + idcard + "' or userOpenid = '"+openid+"' ";
		QuestionnaireWinningESDO result = (QuestionnaireWinningESDO)elasticsearchUtil.excuteOneObject(sql, HealthEduArticleES.class, esIndex, esType);
		return result;
	}
}