//将平安到校信息发送并存储
@RequestMapping(value = "/send/padx")
public void sendPadx(HttpServletRequest request) throws Exception {
InputStream in = request.getInputStream();
String js = StreamUtils.copyToString(in, Charset.forName("UTF-8"));
JSONArray jsarry =JSONArray.fromObject(js);
List<PADX> list = new ArrayList<PADX>();
for(int i =0;i<jsarry.size();i++){
net.sf.json.JSONObject jo = jsarry.getJSONObject(i);
String schName = jo.getString("schName");
String recv = jo.getString("recv");
String stuName = jo.getString("stuName");
String time = jo.getString("time");
String stuIO = jo.getString("stuIO");
int count = PADXService.getCount(schName, recv, stuName, time, stuIO);
if(count > 2){
continue;
}else{
String sendMessage ="家长您好,您的孩子"+stuName+"于"+time+stuIO+"学校。";
Weixin weixin = weixinService.findWeixin(WeixinUtils.getAppId());
String token = weixin.getToken();
sendMessage(token,schName,recv,sendMessage,schName);
PADX padxMessage = new PADX(schName, recv, stuName, time, stuIO);
list.add(padxMessage);
}
}
PADXService.insert(list);
}
package com.doofen.lark.mapper;
import java.util.List;
import com.doofen.lark.entity.Message;
import com.doofen.lark.entity.PADX;
import com.doofen.lark.entity.ReadMessage;
public interface PADXMapper {
public void insert(List<PADX> padxMessages);
public int findTotal(ReadMessage readMessage);
public int getCount(String schName, String recv, String stuName, String time, String stuIO);
public List<PADX> findMessage(ReadMessage readMessage);
}
<!-- getCount -->
<select id="getCount" resultType="java.lang.Integer">
select count(*) from
padx_message
where schName=#{schName} and recv=#{recv} and stuName=#{stuName} and time=#{time} and stuIO=#{stuIO}
</select>
package com.doofen.lark.service;
import java.util.List;
import com.doofen.lark.entity.Message;
import com.doofen.lark.entity.PADX;
import com.doofen.lark.entity.ReadMessage;
public interface PADXService {
public void insert(List<PADX> padxMessages);
public int findTotal(ReadMessage readMessage);
public int getCount(String schName, String recv, String stuName, String time, String stuIO);
public List<PADX> findMessage(ReadMessage readMessage);
}
package com.doofen.lark.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.doofen.lark.entity.Message;
import com.doofen.lark.entity.PADX;
import com.doofen.lark.entity.ReadMessage;
import com.doofen.lark.mapper.PADXMapper;
import com.doofen.lark.service.PADXService;
@Service("padxService")
public class PADXServiceImpl implements PADXService {
@Autowired
private PADXMapper mapper;
@Override
public int findTotal(ReadMessage readMessage) {
return mapper.findTotal(readMessage);
}
@Override
public List<PADX> findMessage(ReadMessage readMessage) {
return mapper.findMessage(readMessage);
}
@Override
public void insert(List<PADX> padxMessages) {
mapper.insert(padxMessages);
}
@Override
public int getCount(String schName, String recv, String stuName,
String time, String stuIO) {
// TODO Auto-generated method stub
return mapper.getCount(schName, recv, stuName, time, stuIO);
}
}