Merge branch 'dev' of zd_123/patient-co-management into dev

patient-co-service/wlyy_service/src/main/java/com/yihu/wlyy/service/controller/JMController.java

@@ -346,6 +346,7 @@ public class JMController {
	{
		try {
			String data = jmService.findWzymBymykh(etmykh);
			System.out.println(data);
			JSONObject jsonObject = new JSONObject(data);
			if (jsonObject.getInt("msgCode")==800){
				return Result.success("获取接种记录成功！",data);
@@ -358,4 +359,5 @@ public class JMController {
			return Result.error(ex.getMessage());
		}
	}
}

patient-co-service/wlyy_service/src/main/java/com/yihu/wlyy/service/service/JMService.java

@@ -412,10 +412,12 @@ public class JMService {
            //保存http日志
            logService.saveHttpLog(isSuccess,apistr,content,method,apistr, net.sf.json.JSONObject.fromObject(params).toString(),re,error);
            //保存token到reids
            //保存token到reids.
            if (isSuccess && apistr.equals(GET_TOKEN)){
                //System.out.println();
                redisTemplate.opsForValue().set(redis_key, com.alibaba.fastjson.JSON.parseObject(re).getString("body"),4,TimeUnit.HOURS);
                long tokenCreateTime = com.alibaba.fastjson.JSON.parseObject(re).getLongValue("createtime");
                redisTemplate.opsForValue().set(redis_key, com.alibaba.fastjson.JSON.parseObject(re).getString("body"));
                redisTemplate.expireAt(redis_key,DateUtil.getNextMin(new Date(tokenCreateTime),4*60));
            }
        }
        catch (Exception ex)

patient-co/patient-co-wlyy-job/src/main/java/com/yihu/wlyy/job/AlertChildImmuneVaccinJob.java

@@ -18,8 +18,8 @@ public class AlertChildImmuneVaccinJob implements Job {
    public void execute(JobExecutionContext context) throws JobExecutionException {
        logger.info("START========每天九点提醒居民待接种JOB========");
        try {
            int result = childVaccinImmuneService.alertBefore();
            logger.info("END========每天九点提醒居民待接种JOB========"+result);
            //int result = childVaccinImmuneService.alertBefore();
            //logger.info("END========每天九点提醒居民待接种JOB========"+result);
        }catch (Exception e){
            e.printStackTrace();
            logger.info("END===ERROE===每天九点提醒居民待接种JOB,message:"+e.getMessage());

patient-co/patient-co-wlyy-job/src/main/java/com/yihu/wlyy/service/imm/ChildVaccinImmuneService.java

@@ -274,13 +274,18 @@ public class ChildVaccinImmuneService extends BaseService {
					" LEFT JOIN wlyy_patient p ON cfi.family_code = p.`code`" +
					" WHERE" +
					" cfi.child_code = '"+childCode+"'" +
					" AND cfi.del = 0 and (p.openid is not null or p.openid !='') AND p.`code`='0fab4dd67e074e16ac86db6b6c15233e'";
					" AND cfi.del = 0 and (p.openid is not null or p.openid !='') "
                     +" AND p.`code`='0fab4dd67e074e16ac86db6b6c15233e'"
                    ;
			List<Map<String,Object>> list = jdbcTemplate.queryForList(sql);
			if (list.size()==0){
				return -10000;
			}
			List<String> openIdList = new ArrayList<>();
			for (Map<String,Object> map : list){
                String familyCode = String.valueOf(map.get("code"));
                String openid = String.valueOf(map.get("openid"));
                String familyName = String.valueOf(map.get("name"));
				//如果父母亲都在就都发
				if (!openIdList.contains(String.valueOf(map.get("openid")))){
					if (StringUtils.isNotBlank(String.valueOf(map.get("openid")))){
@@ -293,7 +298,7 @@ public class ChildVaccinImmuneService extends BaseService {
                            json.put("keyword2", temp.getKeyword2().replace("key1",DateUtil.dateToStr(new Date(), "yyyy-MM-dd")));
                            json.put("remark", temp.getRemark());
                            json.put("first", temp.getFirst().replace("key1",String.valueOf(map.get("name"))).replace("key2", childName).replace("key3",jzrq));
                            json.put("url",temp.getUrl().replace("key1",childCode));
                            json.put("url",temp.getUrl().replace("key1",childCode).replace("key2",familyCode).replace("key3",familyName).replace("key4",openid));
                            logger.info("weiTempJOSN:"+json.toString());
							pushMsgTask.putWxMsg(weiXinAccessTokenUtils.getAccessToken(), 11,String.valueOf(map.get("openid")) , String.valueOf(map.get("name")), json);
						}catch (Exception e){

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/service/imm/ChildFamilyImmuneService.java

@@ -241,19 +241,22 @@ public class ChildFamilyImmuneService extends BaseService {
			}
			List<String> openIdList = new ArrayList<>();
			for (Map<String,Object> map : list){
				String familyCode = String.valueOf(map.get("code"));
				String openid = String.valueOf(map.get("openid"));
				String familyName = String.valueOf(map.get("name"));
				//如果父母亲都在就都发
				if (!openIdList.contains(String.valueOf(map.get("openid")))){
					if ( StringUtils.isNotBlank(String.valueOf(map.get("openid")))){
				if (!openIdList.contains(openid)){
					if ( StringUtils.isNotBlank(openid)){
						boolean flag =true;
						try {
							WechatTemplateConfig temp = templateConfigDao.findByScene("template_doctor_survey", "ymjztx");
							JSONObject json = new JSONObject();
							json.put("toUser",String.valueOf(map.get("code")));
							json.put("toUser",familyCode);
							json.put("keyword1", temp.getKeyword1().replace("key1",vaccinName).replace("key2",jzzc));
							json.put("keyword2", temp.getKeyword2().replace("key1",DateUtil.dateToStr(new Date(), "yyyy-MM-dd")));
							json.put("remark", temp.getRemark());
							json.put("first", temp.getFirst().replace("key1",String.valueOf(map.get("name"))).replace("key2", childName).replace("key3",jzrq));
							json.put("url",temp.getUrl().replace("key1",childCode));
							json.put("first", temp.getFirst().replace("key1",familyName).replace("key2", childName).replace("key3",jzrq));
							json.put("url",temp.getUrl().replace("key1",childCode).replace("key2",familyCode).replace("key3",familyName).replace("key4",openid));
							logger.info("weiTempJOSN:"+json.toString());
							pushMsgTask.putWxMsg(weiXinAccessTokenUtils.getAccessToken(), 11,String.valueOf(map.get("openid")) , String.valueOf(map.get("name")), json);
						}catch (Exception e){

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/service/third/guahao/ImmuneService.java

@@ -771,6 +771,7 @@ public class ImmuneService {
		List<NameValuePair> params = new ArrayList<>();
		params.add(new BasicNameValuePair("etmykh", barcode));
		String response = httpClientUtil.post(url, params, "UTF-8");
		System.out.println("获取接种记录结果："+response);
		return response;
	}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/web/data/DataHandlingController.java

@@ -12,6 +12,7 @@ import io.swagger.annotations.ApiParam;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -44,6 +45,10 @@ public class DataHandlingController extends BaseController {
    @Autowired
    private EduArticleService eduArticleService;
    @Autowired
    private StringRedisTemplate redisTemplate;
    private String redis_key ="imm:imm_token_key";
    /**
     * 生成签约表中的行政团队的code
     */
@@ -417,4 +422,17 @@ public class DataHandlingController extends BaseController {
            return write(-1,"清洗数据失败！");
        }
    }
    @RequestMapping(value = "/imm/clearRedis",method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation("计免：清理redis")
    public String clearRedis(@RequestParam(value = "etmykh")String etmykh) {
        try {
            redisTemplate.delete(redis_key);
            return write(200,"操作成功！");
        } catch (Exception ex) {
            ex.printStackTrace();
            return error(-1,"操作失败！" );
        }
    }
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/web/doctor/imm/DoctorImmController.java

@@ -209,7 +209,7 @@ public class DoctorImmController extends BaseController {
			}
		}catch (Exception e){
			error(e);
			return error(-1, e.getMessage());
			return error(-1, "查询失败！");
		}
	}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/web/patient/family/FamilyMemberController.java

@@ -582,7 +582,7 @@ public class FamilyMemberController extends WeixinBaseController {
            }
        }catch (Exception e){
            error(e);
            return error(-1, e.getMessage());
            return error(-1, "查询失败！");
        }
    }
}