|
@@ -19,16 +19,13 @@ import me.zhengjie.modules.dm.order.domain.DmOrderRecord;
|
|
import me.zhengjie.modules.dm.order.service.DmOrderItemService;
|
|
import me.zhengjie.modules.dm.order.service.DmOrderItemService;
|
|
import me.zhengjie.modules.dm.order.service.DmOrderPaymentService;
|
|
import me.zhengjie.modules.dm.order.service.DmOrderPaymentService;
|
|
import me.zhengjie.modules.dm.order.service.DmOrderRecordService;
|
|
import me.zhengjie.modules.dm.order.service.DmOrderRecordService;
|
|
-import me.zhengjie.modules.dm.order.service.dto.DmExpenseCalendar;
|
|
|
|
-import me.zhengjie.modules.system.domain.Dept;
|
|
|
|
-import me.zhengjie.modules.system.domain.User;
|
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.amqp.core.Message;
|
|
import org.springframework.amqp.core.Message;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import java.io.UnsupportedEncodingException;
|
|
import java.io.UnsupportedEncodingException;
|
|
-import java.util.List;
|
|
|
|
|
|
+import java.sql.Timestamp;
|
|
import java.util.UUID;
|
|
import java.util.UUID;
|
|
|
|
|
|
@Component
|
|
@Component
|
|
@@ -73,6 +70,7 @@ public class ListenerTemplate {
|
|
dmDayPc.setPstate(attendance.getInteger("pstate"));
|
|
dmDayPc.setPstate(attendance.getInteger("pstate"));
|
|
dmDayPc.setWindowName(attendance.getString("window_name"));
|
|
dmDayPc.setWindowName(attendance.getString("window_name"));
|
|
dmDayPc.setCateName(attendance.getString("cate_name"));
|
|
dmDayPc.setCateName(attendance.getString("cate_name"));
|
|
|
|
+ dmDayPc.setDate(new Timestamp(System.currentTimeMillis()));
|
|
|
|
|
|
dmDayPcService.create(dmDayPc);
|
|
dmDayPcService.create(dmDayPc);
|
|
System.out.println("新增dmDayPc===" + dmDayPc);
|
|
System.out.println("新增dmDayPc===" + dmDayPc);
|
|
@@ -91,6 +89,7 @@ public class ListenerTemplate {
|
|
|
|
|
|
@RabbitListener(queues = OrderProduce.NAME_ORDER, containerFactory = OrderProduce.LISTENER_ORDER)
|
|
@RabbitListener(queues = OrderProduce.NAME_ORDER, containerFactory = OrderProduce.LISTENER_ORDER)
|
|
public void dealDeclareOrderMessage(Message message) throws UnsupportedEncodingException {
|
|
public void dealDeclareOrderMessage(Message message) throws UnsupportedEncodingException {
|
|
|
|
+ System.out.println("messageOrder"+message);
|
|
String str = new String(message.getBody(),"utf-8");
|
|
String str = new String(message.getBody(),"utf-8");
|
|
System.out.println("receiveOrder:"+str);
|
|
System.out.println("receiveOrder:"+str);
|
|
try {
|
|
try {
|